diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/CallEasBlacklistServices.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/CallEasBlacklistServices.java index e00016e..4fc74b0 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/CallEasBlacklistServices.java +++ b/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); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/ChangeWhiteListState.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/ChangeWhiteListState.java index d71a13e..d810a0e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/easoa/ChangeWhiteListState.java +++ b/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> 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("新增黑名单时更改白名单状态完成"); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java index e722c45..889c40e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/prop/ConfigProp.java +++ b/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}") diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomJavaCode.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomJavaCode.java index 3768bbf..6643a77 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomJavaCode.java +++ b/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> 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 hashMap = new HashMap(); - 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);