金融服务获取数据再通过轮询传输到ERP

src/test/java/com/uas/erp/test/ConnectToErpTest.java

@@ -0,0 +1,34 @@
+package com.uas.erp.test;
+
+import com.uas.erp.schedular.UasSchedulingApplication;
+import com.uas.erp.schedular.agent.v1.AbstractAgent;
+import com.uas.erp.schedular.entity.Master;
+import com.uas.erp.schedular.util.ContextHolder;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.ui.ModelMap;
+
+
+/**
+ * 连接ERP测试
+ *
+ * Created by hejq on 2017-12-05.
+ */
+//@RunWith(SpringJUnit4ClassRunner.class)
+//@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = UasSchedulingApplication.class)
+public class ConnectToErpTest extends AbstractAgent {
+
+//	@Test
+	public void testConnect() {
+
+		Master master = new Master();
+		master.setMa_user("UAS");
+		master.setMa_name("UAS");
+		ContextHolder.setMaster(master);
+		String code = "hello world";
+		String url = "/openapi/application/transportData1.action";
+		postForEntity(url, new ModelMap("code", code));
+	}
+}

src/test/java/com/uas/erp/test/ConnectToFinanceTest.java

@@ -0,0 +1,63 @@
+package com.uas.erp.test;
+
+import com.alibaba.fastjson.JSONObject;
+import com.uas.api.crypto.util.FlexJsonUtils;
+import com.uas.erp.schedular.UasSchedulingApplication;
+import com.uas.erp.schedular.entity.Master;
+import com.uas.erp.schedular.finance.task.AbstractTask;
+import com.uas.erp.schedular.financeservice.domain.CustInfo;
+import com.uas.erp.schedular.financeservice.domain.CustomerInfo;
+import com.uas.erp.schedular.util.ContextHolder;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.ui.ModelMap;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+
+
+/**
+ * 从金融平台获取数据再连接ERP的测试
+ *
+ * Created by hejq on 2017-12-22.
+ */
+//@RunWith(SpringJUnit4ClassRunner.class)
+//@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = UasSchedulingApplication.class)
+public class ConnectToFinanceTest extends AbstractTask {
+
+//    @Test
+    public void testConnect() {
+        Master master = new Master();
+        master.setMa_user("UAS");
+        master.setMa_uu(10041166L);
+        master.setMa_accesssecret("2c1ea0898633796fe050007f01002ea6");
+        master.setMa_env("test");
+        master.setMa_name("UAS");
+        ContextHolder.setMaster(master);
+        String jsonStr = getForObject("/erp/customerInfo", String.class);
+        JSONObject jsonObject = JSONObject.parseObject(jsonStr);
+        String size = jsonObject.getString("size");
+        String custInfos = jsonObject.getString("custInfos");
+        List<CustInfo> infos = FlexJsonUtils.fromJsonArray(custInfos, CustInfo.class);
+        if (!CollectionUtils.isEmpty(infos)) {
+            for (CustInfo info : infos) {
+                CustomerInfo customer = new CustomerInfo(info);
+                String url = "/openapi/applicant/financingApply.action";
+                postForEntity(url, new ModelMap("customer", FlexJsonUtils.toJsonDeep(customer))
+                        .addAttribute("accountList", FlexJsonUtils.toJsonDeep(info.getAccountInfoList()))
+                        .addAttribute("associateCompany", FlexJsonUtils.toJsonDeep(info.getAssociateCompanies()))
+                        .addAttribute("businessCondition", FlexJsonUtils.toJsonDeep(info.getBusinessCondition()))
+                        .addAttribute("customerExcutive", FlexJsonUtils.toJsonDeep(info.getCustomerExcutives()))
+                        .addAttribute("financeCondition", FlexJsonUtils.toJsonDeep(info.getFinanceConditions()))
+                        .addAttribute("mfCust", FlexJsonUtils.toJsonDeep(info.getMfCustInfos()))
+                        .addAttribute("financingApply", FlexJsonUtils.toJsonDeep(info.getFinancingApplies()))
+                        .addAttribute("prouductMixe", FlexJsonUtils.toJsonDeep(info.getProductMixes()))
+                        .addAttribute("updowncast", FlexJsonUtils.toJsonDeep(info.getUpdowncasts()))
+                        .addAttribute("shareholders", FlexJsonUtils.toJsonDeep(info.getShareholders()))
+                        .addAttribute("changeInstruction", FlexJsonUtils.toJsonDeep(info.getChangesInstructions())));
+            }
+        }
+    }
+}