【华信科】【富勒WMS对接】【测试环境初始化】

src/test/java/com/uas/eis/UasEisApplicationTests.java

@@ -99,21 +99,45 @@ public class UasEisApplicationTests {
 	@Test
 	public void init_vend() {
 		//DATACENTER_P
-		String ids = baseDao.queryForObject(" select wm_concat(ve_id) from ( select ve_id from  DATACENTER_P.vendor where ve_auditstatus='已审核' and nvl(ve_sendwmsflag,0) = 0 order by ve_id ) where rownum <1000 "
+		String ids = baseDao.queryForObject(" select wm_concat(ve_id) from ( select ve_id from  DATACENTER.vendor where ve_auditstatus='已审核' and nvl(ve_sendwmsflag,0) = 0 order by ve_id ) where rownum <1000 "
 		,String.class);
 		if(ids!=null){
-			erpService.sendVend("DATACENTER_P",ids,"admin","Vendor");
+			erpService.sendVend("DATACENTER",ids,"admin","Vendor");
 		}else {
 			logger.info("初始化完毕");
 		}
 	}
 	@Test
 	public void init_cust() {
-		//DATACENTER_P
-		String ids = baseDao.queryForObject(" select wm_concat(cu_id) from ( select cu_id FROM(SELECT cu_id from  DATACENTER_P.customer where cu_auditstatus='已审核' and nvl(cu_sendwmsflag,0) = 0 order by cu_id) where rownum <1000 )"
+		String master ="DATACENTER";
+		String ids = baseDao.queryForObject(" select wm_concat(cu_id) from ( select cu_id FROM(SELECT cu_id from  "+master+".customer " +
+						"where cu_auditstatus='已审核' and nvl(cu_sendwmsflag,0) = 0 " +
+						"and (cu_code,cu_name) not in (select ve_code,ve_name from vendor where ve_auditstatus='已审核' and nvl(ve_sendwmsflag,0) = -1) " +
+						"order by cu_id) where rownum <1000 )"
 				,String.class);
 		if(ids!=null){
-			erpService.sendCust("DATACENTER_P",ids,"admin","Customer!Base");
+			Map<String, Object> result = erpService.sendCust(master,ids,"admin","Customer!Base");
+			String message = "";
+			if (result.get("success") == null || !"true".equals(result.get("success").toString())) {
+				baseDao.execute("update "+master+".customer set cu_sendwmsflag=-1,cu_sendwmsstatus='同步成功',cu_sendwmserr=null where cu_id in ("+ids+")");
+				if(result.get("errList")!=null){
+					try {
+						List<Map<String,Object>> errList = (List<Map<String,Object>>) result.get("errList");
+						for(Map<String,Object> map:errList){
+							if(StringUtil.hasText(map.get("code"))){
+								message = map.get("eMsg") == null? "同步失败" : map.get("eMsg").toString();
+								message = message.replaceAll("'","''");
+								baseDao.execute("update "+master+".customer set cu_sendwmsstatus='同步失败',cu_sendwmserr='"+message+"' where cu_id in ("+ids+")");
+							}
+						}
+					} catch (Exception e) {
+						e.printStackTrace();
+					}
+				}
+			}else {
+				baseDao.execute("update "+master+".customer set cu_sendwmsflag=-1,cu_sendwmsstatus='同步成功',cu_sendwmserr=null where cu_id in ("+ids+")");
+				System.out.println("同步成功");
+			}
 		}else {
 			logger.info("初始化完毕");
 		}
@@ -126,10 +150,33 @@ public class UasEisApplicationTests {
 //						"where rownum <1000 )"
 //				,String.class);
 //		String ids="100072205";
-		String ids = baseDao.queryForObject(" select wm_concat(pr_id) from ( select pr_id FROM(SELECT pr_id FROM PRODUCT WHERE pr_code in ('PSMN1R0-30YLC115','AW37103D180DNR','GT7867','C0201C0G0R8A500NTA.','QMI8658B','V473K0402X7R250NBT','V101J0105C0G160NZT','V150J0105C0G160NZT','V102M0105X5R160NZT','V104M0105X5R100NZT','V3R6B0105SQC250NZT','V1R3B0105SQC250NZT','V120J0105SQC250NZT','V100J0105GQC250NZT','V102J0201C0G500NAT','GF3986ZSCB','V107M1206X5R6R3N1P','GMK107BBJ475KA-T','V475K0603X5R250NKT','V1R5A0201SQC500NAT','V2R8A0105SQC250NZT','V1R8A0201SQC500NAT','V1R9A0201SQC500NAT','V3R3A0105SQC250NZT','V1R5C0105C0G250NZT','V105K0201X5R6R3NXT','T474K0805X7R500N5R','T474K0805X7R500NHR','NS8241FD','T180G0402C0G500NBT','LIGHTINTENSITYMCU_BOARD_V2.0','LIGHTLNTENSITYPD_BOARD_V2.0','V181K0201C0G500NAT','GUM5228EN3','V2R4A0105SQC250NZT','V150J0105GQC250NZT','V5R4B0105GQC250NZT','CL05B221KB5VPNC','YMN0ATF1B5HFCE') order by pr_id) " +
+		String master ="DATACENTER";
+		String ids = baseDao.queryForObject(" select wm_concat(pr_id) from ( select pr_id FROM(SELECT pr_id FROM "+master+".PRODUCT a " +
+				"	WHERE nvl(a.pr_sendwmsflag,0)=0 and pr_ycxh is not null order by pr_id) " +
 						"where rownum <1000 )",String.class);
 		if(ids!=null){
-			erpService.sendProd("DATACENTER_P", ids, "admin","Product");
+			Map<String, Object> result = erpService.sendProd(master, ids, "admin","Product");
+			String message = "";
+			if (result.get("success") == null || !"true".equals(result.get("success").toString())) {
+				baseDao.execute("update "+master+".product set pr_sendwmsflag=-1,pr_sendwmsstatus='同步成功',pr_sendwmserr=null where pr_id  in ("+ids+")");
+				if(result.get("errList")!=null){
+					try {
+						List<Map<String,Object>> errList = (List<Map<String,Object>>) result.get("errList");
+						for(Map<String,Object> map:errList){
+							if(StringUtil.hasText(map.get("code"))){
+								message = map.get("eMsg") == null? "同步失败" : map.get("eMsg").toString();
+								message = message.replaceAll("'","''");
+								baseDao.execute("update "+master+".product set pr_sendwmsstatus='同步失败',pr_sendwmserr='"+message+"' where pr_id in ("+ids+")");
+							}
+						}
+					} catch (Exception e) {
+						e.printStackTrace();
+					}
+				}
+			}else {
+				baseDao.execute("update "+master+".product set pr_sendwmsflag=-1,pr_sendwmsstatus='同步成功',pr_sendwmserr=null where pr_id  in ("+ids+")");
+				System.out.println("同步成功");
+			}
 		}else {
 			logger.info("初始化完毕");
 		}