黑名单

secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/CallEasBlacklistServices.java

@@ -71,14 +71,22 @@ public class CallEasBlacklistServices  {
                 info.setSYSID("SYS005");
                 input.setSyncBlackListInfo(info);
                 String uri = configProp.getNewblacklist();
+                logger.error("------- uri= " + uri);
                 SI_BlacklistSync_OUTServiceStub stub = new SI_BlacklistSync_OUTServiceStub(uri);
                 stub._getServiceClient().getOptions().setProperty("__CHUNKED__", Boolean.FALSE);
                 stub._getServiceClient().getOptions().setTimeOutInMilliSeconds(300000);
                 stub._getServiceClient().getOptions().setProperty(HTTPConstants.SO_TIMEOUT,300000);
                 stub._getServiceClient().getOptions().setProperty(HTTPConstants.CONNECTION_TIMEOUT,300000);
                 HttpTransportPropertiesImpl.Authenticator auth = new HttpTransportPropertiesImpl.Authenticator();
-                auth.setUsername("pouser");
+
-                auth.setPassword("htjt_2018");
+//                auth.setUsername("pouser");
+//                auth.setPassword("htjt_2018");
+                String user = configProp.getHtsysjcmt_po_user();
+                String password = configProp.getHtsysjcmt_po_password();
+                logger.error("------- user : " + user);
+                logger.error("------- password : " + password);
+                auth.setUsername(user);
+                auth.setPassword(password);
 
 
                 stub._getServiceClient().getOptions().setProperty(org.apache.axis2.kernel.http.HTTPConstants.AUTHENTICATE,auth);

secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/ChangeWhiteListState.java

@@ -24,7 +24,7 @@ public class ChangeWhiteListState  {
 	public static final org.slf4j.Logger logger = LoggerFactory.getLogger(ChangeWhiteListState.class);
 
 	public void changeState(List<Map<String, String>> list) {
-		logger.error(String.valueOf("新增黑名单时更改白名单状态开始"));
+		logger.error(String.valueOf("新增黑名单时更改白名单状态开始 list = " + list.toString()));
 		RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
 		try {
 			for (int i = 0; i < list.size(); i++) {
@@ -35,9 +35,11 @@ public class ChangeWhiteListState  {
 				String sql = "";
 				if (!"".equals(mc) && mc != null) {
 					sql = "select * from e10_core_business.dbo.formtable_main_1556 where (mc='" + mc + "' or shxydm='" + dm + "') and bmdzt='0'";
+					logger.error(String.valueOf("sql1 = " + sql ));
 					String poolname = CONN_TYPE.workflow.getType();
 					// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
-					rs.executeSql(sql, poolname);
+					boolean b1 = rs.executeSql(sql, poolname);
+					logger.error(String.valueOf("b1 = " + b1 ));
 				}
 				if (rs != null) {
 					while (rs.next()) {
@@ -81,13 +83,15 @@ public class ChangeWhiteListState  {
 						infos.addWhiteListInfos(info);
 					}
 					String sql_update = "update e10_core_business.dbo.formtable_main_1556 set bmdzt='1' where mc='" + mc + "'";
-					rs.executeSql(sql_update);
+					logger.error(String.valueOf("sql_update = " + sql_update ));
+					boolean b2 = rs.executeSql(sql_update);
+					logger.error(String.valueOf("b2 = " + b2 ));
 					infos.setITFID("");
 					infos.setSENDID("");
 					infos.setSYSID("");
 					input.setSyncWhiteListInfo(infos);
 					String[] returnArr = syncState(input);
-					logger.error("新增黑名单时更改白名单状态--(" + mc, dm + "):state--" + returnArr[0] + ",message--" + returnArr[2]);
+					logger.error("新增黑名单时更改白名单状态--(" + mc + dm + "):state--" + returnArr[0] + ",message--" + returnArr[2]);
 				}
 			}
 			logger.error("新增黑名单时更改白名单状态完成");

secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java

@@ -223,8 +223,10 @@ public class ConfigProp {
     private String efsaccount;
     @Value("${efspassword}")
     private String efspassword;
-
+    @Value("&{weaver-secondev-htsysjcmt-po_user}")
-
+    private String htsysjcmt_po_user;
+    @Value("&{weaver-secondev-htsysjcmt-po_password}")
+    private String htsysjcmt_po_password;
 
     //htsrmoasync
     @Value("${htshop}")

secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomJavaCode.java

@@ -67,9 +67,9 @@ public class CustomJavaCode extends BaseBean implements Action, EsbServerlessRpc
             recordSet.executeSql(str1);
             ArrayList<Map<String, String>> arrayList = new ArrayList();
             while (recordSet.next()) {
-                int k = recordSet.getInt("id");
+                String k = recordSet.getString("id");
                 String str4 = recordSet.getString("bh");
-                int m = recordSet.getInt("lx");
+                String m = recordSet.getString("lx");
                 String str5 = recordSet.getString("mc");
                 String str6 = recordSet.getString("dm");
                 String str7 = recordSet.getInt("zt") + "";
@@ -80,10 +80,10 @@ public class CustomJavaCode extends BaseBean implements Action, EsbServerlessRpc
                 String str10 = recordSet.getString("modedatacreatedate");
                 String str11 = recordSet.getString("modedatacreatetime");
                 Map<String, String> hashMap = new HashMap<String, String>();
-                hashMap.put("id", k + "");
+                hashMap.put("id", k  );
                 hashMap.put("bh", str4);
                 hashMap.put("dm", str6);
-                hashMap.put("lx", m + "");
+                hashMap.put("lx", m  );
                 hashMap.put("mc", str5);
                 hashMap.put("zt", str7);
                 hashMap.put("yxjzq", str8);
@@ -97,7 +97,7 @@ public class CustomJavaCode extends BaseBean implements Action, EsbServerlessRpc
             String[] arrayOfString = callEasBlacklistServices.syncBlacklist(arrayList);
             String str2 = arrayOfString[0];
             String str3 = arrayOfString[1];
-            logger.error("do blacklist webservice: " + str2 + "][message : " + str3 + "]");
+            logger.error("callEasBlacklistServices  do blacklist webservice: " + str2 + "][message : " + str3 + "]");
 
 
             changeWhiteListState.changeState(arrayList);