From bc870473e29f49fd59fed002ce230f57137719e7 Mon Sep 17 00:00:00 2001 From: "zhangxinah@yonyou.com" Date: Thu, 8 May 2025 14:44:23 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=BC=96=E7=A0=81gbk?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../NCCToBIPBackgroupWorkPlugin.java | 130 +++++++++--------- 1 file changed, 65 insertions(+), 65 deletions(-) diff --git a/uapbd/src/private/nc/bs/uapbd/bip/workplugin/NCCToBIPBackgroupWorkPlugin.java b/uapbd/src/private/nc/bs/uapbd/bip/workplugin/NCCToBIPBackgroupWorkPlugin.java index aabec31..e63e16b 100644 --- a/uapbd/src/private/nc/bs/uapbd/bip/workplugin/NCCToBIPBackgroupWorkPlugin.java +++ b/uapbd/src/private/nc/bs/uapbd/bip/workplugin/NCCToBIPBackgroupWorkPlugin.java @@ -72,7 +72,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { } /** - * 检查bip参数是否完整 + * bipǷ * @return */ private Map checkBipParam(){ @@ -121,8 +121,8 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { } - String dests = bipParamMap.get("dests");//上次执行完成时间 - // 获取上次执行完成后的客户账户信息 + String dests = bipParamMap.get("dests");//ϴִʱ + // ȡϴִɺĿͻ˻Ϣ String sel_sql="select distinct pk_cust from bd_custbank where accclass=1 "; if(usercustcode!="") { @@ -140,7 +140,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { List> ll_cust = (List>)new BaseDAO().executeQuery(sel_sql,new MapListProcessor()); - //不存在直接退出任务 + //ֱ˳ if(ll_cust.isEmpty()) { return null; } @@ -163,19 +163,19 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { " and bd_banktype.pk_banktype=bd_bankaccbas.pk_banktype\r\n" + " and bd_currtype.pk_currtype=bd_bankaccsub.pk_currtype\r\n" + " and bd_custbank.accclass=1 and bd_customer.pk_customer='"+pk_cust+"'"; - //获取客户的银行账户子户信息 + //ȡͻ˻ӻϢ List> ll_log = (List>)new BaseDAO().executeQuery(sql,new MapListProcessor()); if(!ll_log.isEmpty()) { try { - String accessToken=getAccessToken(baseUrl,bipParamMap);//获取BIP的token + String accessToken=getAccessToken(baseUrl,bipParamMap);//ȡBIPtoken if(accessToken!="") { - String custcode=ll_log.get(0).get("custcode");//客户编码 + String custcode=ll_log.get(0).get("custcode");//ͻ Gson gson = new Gson(); - //通过BIP的API获取客户信息 + //ͨBIPAPIȡͻϢ String custurl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/merchant/detail?access_token="+accessToken; HashMap custMap = new HashMap(); custMap.put("code", custcode); @@ -184,7 +184,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { // Map custDetailresult = gson.fromJson(custdetailString, Map.class); JSONObject custDetailresult= JSON.parseObject(custdetailString); - if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//客户存在 + if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//ͻ Map dataInfo = (Map) custDetailresult.get("data"); @@ -205,26 +205,26 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { - for (Map map : ll_log) {//Erp中查询出来的客户子账户 + for (Map map : ll_log) {//ErpвѯĿͻ˻ - String accnum=map.get("accnum");//银行账户 + String accnum=map.get("accnum");//˻ - if(checkMap.containsKey(accnum)) {//剔除erp中银行账号重合数据 + if(checkMap.containsKey(accnum)) {//޳erp˺غ continue; }else { checkMap.put(accnum, accnum); } boolean check =false; - if (bool){//客户中已经存在银行账户 + if (bool){//ͻѾ˻ - for (Map map_bankinfo : l_map) {//循环BIP客户信息里的银行账户 - if (StringUtils.equals(accnum, map_bankinfo.get("bankAccount").toString())) {//匹配上，做更新 + for (Map map_bankinfo : l_map) {//ѭBIPͻϢ˻ + if (StringUtils.equals(accnum, map_bankinfo.get("bankAccount").toString())) {//ƥϣ check=true; map_bankinfo.put("_status", "Update"); - map_bankinfo.put("jointLineNo", map.get("combinenum"));//联行号 + map_bankinfo.put("jointLineNo", map.get("combinenum"));//к map_bankinfo.put("accountType", map.get("accountproperty")==null?0:map.get("accountproperty")); map_bankinfo.put("isDefault", map.get("isdefault")==null||map.get("isdefault").equals("N")?false:true); map_bankinfo.put("stopstatus", map.get("enablestate")=="2"?true:false); @@ -233,9 +233,9 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { paramCurrMap.put("code", map.get("currcode")); String currencyString=doGet(currencyUrl, paramCurrMap); JSONObject currencyDetailresult= JSON.parseObject(currencyString); - if (StringUtils.equals("200", currencyDetailresult.get("code").toString())) {//币种存在 + if (StringUtils.equals("200", currencyDetailresult.get("code").toString())) {//ִ Map currencydataInfo = (Map)currencyDetailresult.get("data"); - map_bankinfo.put("currency", currencydataInfo.get("id"));//需要从bip获取对应的id + map_bankinfo.put("currency", currencydataInfo.get("id"));//ҪbipȡӦid } String bankUrl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/bankdot/list"; @@ -245,8 +245,8 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { paramabank.put("name", map.get("bankdocname")); Map bankMap=getBIPBankID(paramabank,bankUrl,accessToken,map.get("bankdocname")); if(bankMap!=null) { - map_bankinfo.put("openBank", bankMap.get("id")); //需要从bip获取对应的id 网点api - map_bankinfo.put("bank", bankMap.get("bank"));//需要从bip获取对应的id + map_bankinfo.put("openBank", bankMap.get("id")); //ҪbipȡӦid api + map_bankinfo.put("bank", bankMap.get("bank"));//ҪbipȡӦid } break; @@ -254,7 +254,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { } if(!check) { - //没有匹配上走新增 + //ûƥ Map map_add = new HashMap(); map_add.put("_status", "Insert"); map_add.put("merchantId_code_agent_financial_falg", custcode); @@ -263,8 +263,8 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { accname_map.put("zh_CN", map.get("accname")); map_add.put("bankAccountName", accname_map); map_add.put("jointLineNo", map.get("combinenum")); -// map_add.put("openBank", value) 需要从bip获取对应的id -// map_add.put("bank", value)//需要从bip获取对应的id +// map_add.put("openBank", value) ҪbipȡӦid +// map_add.put("bank", value)//ҪbipȡӦid // getBIPBankID String bankUrl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/bankdot/list"; HashMap paramabank = new HashMap(); @@ -274,8 +274,8 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { // map.get("bankdocname"); Map bankMap=getBIPBankID(paramabank,bankUrl,accessToken,map.get("bankdocname")); if(bankMap!=null) { - map_add.put("openBank", bankMap.get("id")); //需要从bip获取对应的id 网点api - map_add.put("bank", bankMap.get("bank"));//需要从bip获取对应的id + map_add.put("openBank", bankMap.get("id")); //ҪbipȡӦid api + map_add.put("bank", bankMap.get("bank"));//ҪbipȡӦid } map_add.put("accountType", map.get("accountproperty")==null?0:map.get("accountproperty")); map_add.put("merchantId_createOrg", "666666"); @@ -283,15 +283,15 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { map.get("isdefault"); map_add.put("isDefault", map.get("isdefault")==null||map.get("isdefault").equals("N")?false:true); map_add.put("merchantId", id); -// map_add.put("currency", value);需要从bip获取对应的id +// map_add.put("currency", value);ҪbipȡӦid String currencyUrl = baseUrl+"/iuap-api-gateway/yonbip/digitalModel/currency/findByCode?access_token="+accessToken; HashMap paramCurrMap = new HashMap(); paramCurrMap.put("code", map.get("currcode")); String currencyString=doGet(currencyUrl, paramCurrMap); JSONObject currencyDetailresult= JSON.parseObject(currencyString); - if (StringUtils.equals("200", currencyDetailresult.get("code").toString())) {//币种存在 + if (StringUtils.equals("200", currencyDetailresult.get("code").toString())) {//ִ Map currencydataInfo = (Map)currencyDetailresult.get("data"); - map_add.put("currency", currencydataInfo.get("id"));//需要从bip获取对应的id + map_add.put("currency", currencydataInfo.get("id"));//ҪbipȡӦid } map_add.put("stopstatus", map.get("enablestate")=="2"?true:false); if(bankMap!=null) { @@ -320,8 +320,8 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { Map bankMap=getBIPBankID(paramabank,bankUrl,accessToken,map.get("bankdocname")); if(bankMap!=null) { - map_add.put("openBank", bankMap.get("id")); //需要从bip获取对应的id 网点api - map_add.put("bank", bankMap.get("bank"));//需要从bip获取对应的id + map_add.put("openBank", bankMap.get("id")); //ҪbipȡӦid api + map_add.put("bank", bankMap.get("bank"));//ҪbipȡӦid } // @@ -338,9 +338,9 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { String currencyString=doGet(currencyUrl, paramCurrMap); // Map currencyDetailresult = gson.fromJson(currencyString, Map.class); JSONObject currencyDetailresult= JSON.parseObject(currencyString); - if (StringUtils.equals("200", currencyDetailresult.get("code").toString())) {//币种存在 + if (StringUtils.equals("200", currencyDetailresult.get("code").toString())) {//ִ Map currencydataInfo = (Map)currencyDetailresult.get("data"); - map_add.put("currency", currencydataInfo.get("id"));//需要从bip获取对应的id + map_add.put("currency", currencydataInfo.get("id"));//ҪbipȡӦid } // map_add.put("stopstatus", map.get("enablestate")=="2"?true:false); @@ -370,7 +370,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { } - //更新客户信息（银行账户信息） + //¿ͻϢ˻Ϣ String custUpdateUrl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/merchant/save"; Map tokenParam = new HashMap<>(); @@ -381,20 +381,20 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { headers.put("Content-Type", "application/json"); String resultString=doSendHttp(custUpdateUrl,"POST",tokenParam,"",headers, custDetailresult.toJSONString()); -// String updateRestult= doPost(custUpdateUrl, custDetailresult);//调用BIP客户保存更新接口 -// String updateRestult= doPost(custUpdateUrl, custDetailresult);//调用BIP客户保存更新接口 +// String updateRestult= doPost(custUpdateUrl, custDetailresult);//BIPͻ½ӿ +// String updateRestult= doPost(custUpdateUrl, custDetailresult);//BIPͻ½ӿ Map updateMap = gson.fromJson(resultString, Map.class); - if (StringUtils.equals("200", updateMap.get("code").toString())) {//保存更新成功后需要更新日志表 + if (StringUtils.equals("200", updateMap.get("code").toString())) {//³ɹҪ־ - }else {//更新失败后，更新对应子账户的ts时间，以便下次再次能够获取到 + }else {//ʧܺ󣬸¶Ӧ˻tsʱ䣬Ա´ٴܹȡ // getSuperDMO().executeUpdateSQL("update bd_custbank set pk_custbank='"+ll_log.get(0).get("pk_custbank")+"' where pk_custbank='"+ll_log.get(0).get("pk_custbank")+"'"); } - }else {//BIP中客户不存在，更新对应子账户的ts时间，以便下次再次能够获取到 + }else {//BIPпͻڣ¶Ӧ˻tsʱ䣬Ա´ٴܹȡ // getSuperDMO().executeUpdateSQL("update bd_custbank set pk_custbank='"+ll_log.get(0).get("pk_custbank")+"' where pk_custbank='"+ll_log.get(0).get("pk_custbank")+"'"); } @@ -433,7 +433,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { /** - * 查询bip 中开户行及银行类型id + * ѯbip пмid * @param map * @param bipUrl * @return @@ -451,7 +451,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { String resultString=doSendHttp(bipUrl,"POST",tokenParam,"",headers, jsonData); // Map custDetailresult = gson.fromJson(resultString, Map.class); JSONObject custDetailresult= JSON.parseObject(resultString); - if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//数据存在 + if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//ݴ Map dataInfo = (Map)custDetailresult.get("data"); if(!MMValueCheck.isEmpty(dataInfo.get("recordList"))){ List> l_record=(List>) dataInfo.get("recordList"); @@ -463,7 +463,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { resultString=doSendHttp(bipUrl,"POST",tokenParam,"",headers, jsonData); // custDetailresult = gson.fromJson(resultString, Map.class); custDetailresult= JSON.parseObject(resultString); - if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//数据存在 + if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//ݴ dataInfo = (Map)custDetailresult.get("data"); if(!MMValueCheck.isEmpty(dataInfo.get("recordList"))){ List> l_record=(List>) dataInfo.get("recordList"); @@ -495,11 +495,11 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { } } // log.error("uRL:" + baseUrl); -// // 打印请求URL和方法 +// // ӡURLͷ // log.error("Request URL: " + baseUrl); // log.error("Request Method: " + method); URL urlobj = new URL(baseUrl); - if("https".equalsIgnoreCase(urlobj.getProtocol())) {//判定网址是否信任，不信任则调用忽略信任工具类SslUtil + if("https".equalsIgnoreCase(urlobj.getProtocol())) {//жַǷΣúιSslUtil IgnoreSslUtil.ignoreSsl(); } urlConnection = (HttpURLConnection)urlobj.openConnection(); @@ -507,7 +507,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { urlConnection.setRequestMethod(method); urlConnection.setDoInput(true); urlConnection.setUseCaches(false); - // 如果设置了自定义头，则打印它们 + // Զͷӡ if (headers != null && !headers.isEmpty()) { for (Map.Entry entry : headers.entrySet()) { urlConnection.addRequestProperty(entry.getKey(), entry.getValue()); @@ -548,7 +548,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { }catch(Exception e) { JSONObject js=new JSONObject(); js.put("",-1); - js.put("message","调用外系统接口失败："+e.getMessage()); + js.put("message","ϵͳӿʧܣ"+e.getMessage()); result=js.toString(); e.printStackTrace(); }finally { @@ -581,7 +581,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { // private String createCustBankMap(Map map,String access_token) { // Gson gson = new Gson(); -// //获取BIP中的客户详情 +// //ȡBIPеĿͻ // String custcode=map.get("custcode"); // String custurl=baseUrl+"/yonbip/digitalModel/merchant/detail?access_token="+access_token; // HashMap custMap = new HashMap(); @@ -590,11 +590,11 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { // String custdetailString=doGet(custurl,custMap); // // Map custDetailresult = gson.fromJson(custdetailString, Map.class); -// if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//客户存在 +// if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//ͻ // // Map dataInfo = (Map) custDetailresult.get("data"); // -// if (!MMValueCheck.isEmpty(dataInfo.get("merchantAgentFinancialInfos"))){//客户中已经存在银行账户 +// if (!MMValueCheck.isEmpty(dataInfo.get("merchantAgentFinancialInfos"))){//ͻѾ˻ // // }else { // @@ -603,7 +603,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { // } // // -// //开户行 +// // // String bankdoccode=map.get("bankdoccode"); // HashMap paramap = new HashMap(); // paramap.put("pageIndex", 0); @@ -637,7 +637,7 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { params.put("appKey", appKey); String timestamp = String.valueOf(System.currentTimeMillis()); params.put("timestamp", timestamp); - // 计算签名 + // ǩ Map treeMap; if (params instanceof TreeMap) { treeMap = params; @@ -677,9 +677,9 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { cm.setMaxTotal(500); cm.setDefaultMaxPerRoute(50); - RequestConfig globalConfig = RequestConfig.custom().setConnectionRequestTimeout(5000) // 连接池获取连接超时 - .setConnectTimeout(5000) // 连接建立超时 - .setSocketTimeout(20000) // 等待响应超时 + RequestConfig globalConfig = RequestConfig.custom().setConnectionRequestTimeout(5000) // ӳػȡӳʱ + .setConnectTimeout(5000) // ӽʱ + .setSocketTimeout(20000) // ȴӦʱ .setCookieSpec(CookieSpecs.IGNORE_COOKIES).build(); CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(cm) @@ -698,9 +698,9 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { cm.setMaxTotal(500); cm.setDefaultMaxPerRoute(50); - RequestConfig globalConfig = RequestConfig.custom().setConnectionRequestTimeout(5000) // 连接池获取连接超时 - .setConnectTimeout(5000) // 连接建立超时 - .setSocketTimeout(20000) // 等待响应超时 + RequestConfig globalConfig = RequestConfig.custom().setConnectionRequestTimeout(5000) // ӳػȡӳʱ + .setConnectTimeout(5000) // ӽʱ + .setSocketTimeout(20000) // ȴӦʱ .setCookieSpec(CookieSpecs.IGNORE_COOKIES).build(); CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(cm) @@ -735,21 +735,21 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { path += '?' + paramStr; } } - //创建远程url连接对象 + //ԶurlӶ URL url = new URL(path); - if("https".equalsIgnoreCase(url.getProtocol())){//判定网址是否信任，不信任则调用忽略信任工具类SslUtil + if("https".equalsIgnoreCase(url.getProtocol())){//жַǷΣúιSslUtil IgnoreSslUtil.ignoreSsl(); } - //通过远程url连接对象打开一个连接，强转成HTTPURLConnection类 + //ͨԶurlӶһӣǿתHTTPURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod("GET"); - //设置连接超时时间和读取超时时间 + //ӳʱʱͶȡʱʱ conn.setConnectTimeout(120000); conn.setReadTimeout(120000); conn.setRequestProperty("Accept", "application/json"); - //发送请求 + // conn.connect(); - //通过conn取得输入流，并使用Reader读取 + //ͨconnȡʹReaderȡ if (200 == conn.getResponseCode()) { is = conn.getInputStream(); br = new BufferedReader(new InputStreamReader(is, "UTF-8")); @@ -793,9 +793,9 @@ public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { // cm.setMaxTotal(500); // cm.setDefaultMaxPerRoute(50); // -// RequestConfig globalConfig = RequestConfig.custom().setConnectionRequestTimeout(5000) // 连接池获取连接超时 -// .setConnectTimeout(5000) // 连接建立超时 -// .setSocketTimeout(20000) // 等待响应超时 +// RequestConfig globalConfig = RequestConfig.custom().setConnectionRequestTimeout(5000) // ӳػȡӳʱ +// .setConnectTimeout(5000) // ӽʱ +// .setSocketTimeout(20000) // ȴӦʱ // .setCookieSpec(CookieSpecs.IGNORE_COOKIES).build(); // // CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(cm)