diff --git a/uapbd/src/test/ErpSaleOrderToBIPBackgroupWorkPlugin.java b/uapbd/src/private/nc/bs/uapbd/bip/workplugin/NCCToBIPBackgroupWorkPlugin.java similarity index 51% rename from uapbd/src/test/ErpSaleOrderToBIPBackgroupWorkPlugin.java rename to uapbd/src/private/nc/bs/uapbd/bip/workplugin/NCCToBIPBackgroupWorkPlugin.java index d77c94c..db22403 100644 --- a/uapbd/src/test/ErpSaleOrderToBIPBackgroupWorkPlugin.java +++ b/uapbd/src/private/nc/bs/uapbd/bip/workplugin/NCCToBIPBackgroupWorkPlugin.java @@ -57,13 +57,11 @@ import nc.vo.pub.BusinessException; -public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { +public class NCCToBIPBackgroupWorkPlugin implements IBackgroundWorkPlugin { private HYSuperDMO superDMO = null; private String baseUrl="https://www.tkkfbip.com"; - - public HYSuperDMO getSuperDMO() { if(superDMO == null) { @@ -74,7 +72,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug } /** - * 检查bip参数是否完整 + * 妫鏌ip鍙傛暟鏄惁瀹屾暣 * @return */ private Map checkBipParam(){ @@ -105,9 +103,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug public PreAlertObject executeTask(BgWorkingContext arg0) throws BusinessException { // TODO Auto-generated method stub - Date date = new Date(); - SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - String dateTime = dateFormat.format(date); + Map bipParamMap= checkBipParam(); if(bipParamMap.isEmpty()) { @@ -125,103 +121,306 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug } - String invoiceReceiveUrl = bipParamMap.get("contractSaleOrder");//开票申请单回传 - if(StringUtils.isEmpty(invoiceReceiveUrl)) { - return null; - } + String dests = bipParamMap.get("dests");//涓婃鎵ц瀹屾垚鏃堕棿 + // 鑾峰彇涓婃鎵ц瀹屾垚鍚庣殑瀹㈡埛璐︽埛淇℃伅 + String sel_sql="select distinct pk_cust from bd_custbank where accclass=1 "; - - Gson gson = new Gson(); - - - //获取未推送合同销售订单更新的销售发票信息; - String sql=" select so_saleinvoice_b.cfirstbid from so_saleinvoice,so_saleinvoice_b where so_saleinvoice.csaleinvoiceid=so_saleinvoice_b.csaleinvoiceid and so_saleinvoice.fstatusflag=2 and nvl(so_saleinvoice_b.vbdef10,'N') in ('~','N') and and nvl(so_saleinvoice.vdef13,'~') not in ('~') "; - - List> l_pk = (List>)new BaseDAO().executeQuery(sql.toString(),new MapListProcessor()); - if(l_pk.isEmpty()) { - return null; - } - - for (Map map : l_pk) { - - - StringBuffer sb = new StringBuffer(); - sb.append(" select so_saleinvoice_b.csaleinvoicebid,so_saleorder.vdef9,so_saleorder_b.vbdef11,so_saleorder_exe.ntotalarmny as totalaccrued ,so_saleorder_exe.ntotalinvoicenum as billqty "); - sb.append(" from so_saleorder_exe,so_saleinvoice_b,so_saleinvoice,so_saleorder_b,so_saleorder "); - sb.append(" where so_saleorder_exe.csaleorderbid=so_saleinvoice_b.csrcbid "); - sb.append(" and so_saleinvoice.csaleinvoiceid=so_saleinvoice_b.csaleinvoiceid and so_saleinvoice.fstatusflag=2 "); - sb.append(" and so_saleorder_exe.csaleorderbid=so_saleorder_b.csaleorderbid "); - sb.append(" and so_saleorder.csaleorderid=so_saleorder_b.csaleorderid "); - sb.append(" and so_saleorder_exe.dr=0 and so_saleorder.dr=0 and so_saleorder_b.dr=0 "); - sb.append(" and nvl(so_saleorder.vdef9,'~') not in ('~') "); - sb.append(" and so_saleorder_exe.csaleorderbid='").append(map.get("cfirstbid")).append("'"); - List> ll_saleorder = (List>)new BaseDAO().executeQuery(sb.toString(),new MapListProcessor()); - - if(ll_saleorder.isEmpty()) { - continue; - } - - - try { - String accessToken=getAccessToken(baseUrl,bipParamMap); - Map tokenParam = new HashMap<>(); - tokenParam.put("access_token", accessToken); - Map headers = new HashMap(); - headers.put("Content-Type", "application/json"); - String custUpdateUrl=baseUrl+invoiceReceiveUrl; - if(accessToken!="") { - JSONObject js_apct_detail =new JSONObject(); - JSONObject js_apct =new JSONObject(); - String hid=ll_saleorder.get(0).get("vdef9");//BIP合同销售订单更新 主表id - List> l_map_f = new ArrayList>(); - for (Map custpkmap : ll_saleorder) { - - Map b_map = new HashMap(); - - b_map.put("id", custpkmap.get("vbdef11"));//BIP合同销售订单更新 子表id - b_map.put("billQty", custpkmap.get("billqty"));//累计开票主数量 - b_map.put("totalAccrued", custpkmap.get("totalaccrued"));//累计确认应收金额 - - l_map_f.add(b_map); - - js_apct.put("contractOrdersList", l_map_f); - js_apct.put("id", hid); - - js_apct_detail.put("HTXSDD", js_apct); - - String resultString=doSendHttp(custUpdateUrl,"POST",tokenParam,"",headers, js_apct_detail.toJSONString()); - Map updateMap = gson.fromJson(resultString, Map.class); - String updateSql=""; - if (StringUtils.equals("200", updateMap.get("code").toString())) {//保存更新成功后需要更新日志表 - updateSql="update so_saleinvoice_b set vbdef10='Y' where csaleinvoiceid='"+map.get("csaleinvoicebid")+"'"; - }else { - updateSql="update so_saleinvoice_b set vbdef10='N' where csaleinvoiceid='"+map.get("csaleinvoicebid")+"'"; - } - getSuperDMO().executeUpdateSQL(updateSql); - - } + if(usercustcode!="") { + sel_sql=sel_sql+" and pk_cust in ( select pk_customer from bd_customer where code='"+usercustcode+"')"; + }else { + if(dests!="") { + sel_sql=sel_sql+" and ts>'"+dests+"'"; +// sel_sql=sel_sql+" and ts>'2020-12-31 11:25:14' and ts <'2021-01-31 11:25:14' "; +// sel_sql=sel_sql+" and ts>'2021-02-28 09:25:07' and ts <'2021-03-20 09:25:07' "; } - - } catch (InvalidKeyException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } catch (NoSuchAlgorithmException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } catch (IOException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - }//获取BIP的token - catch (SQLException e) { - // TODO Auto-generated catch block - e.printStackTrace(); } + + List> ll_cust = (List>)new BaseDAO().executeQuery(sel_sql,new MapListProcessor()); + //涓嶅瓨鍦ㄧ洿鎺ラ鍑轰换鍔 + if(ll_cust.isEmpty()) { + return null; + } + + for (Map custpkmap : ll_cust) { + + String pk_cust=custpkmap.get("pk_cust"); + + System.out.println(pk_cust); + + + String sql="select bd_custbank.pk_custbank,bd_bankaccbas.accnum,bd_bankaccbas.enablestate,bd_bankaccbas.accname,bd_bankaccbas.accountproperty,bd_bankaccbas.combinenum,bd_custbank.pk_cust,bd_customer.code custcode,bd_customer.name custname,\r\n" + + "bd_bankaccbas.pk_bankdoc,bd_bankdoc.code bankdoccode,bd_bankdoc.name bankdocname,bd_bankaccbas.pk_banktype,bd_banktype.code banktypecode,bd_banktype.name banktypename\r\n" + + ",bd_custbank.isdefault,bd_bankaccsub.pk_currtype,bd_currtype.code currcode,bd_currtype.name currname\r\n" + + " from bd_custbank,bd_bankaccbas,bd_bankaccsub,bd_customer,bd_bankdoc,bd_banktype,bd_currtype \r\n" + + " where bd_custbank.pk_bankaccbas=bd_bankaccbas.pk_bankaccbas\r\n" + + " and bd_custbank.pk_bankaccsub=bd_bankaccsub.pk_bankaccsub\r\n" + + " and bd_customer.pk_customer=bd_custbank.pk_cust\r\n" + + " and bd_bankdoc.pk_bankdoc=bd_bankaccbas.pk_bankdoc\r\n" + + " 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鐨則oken + if(accessToken!="") { + String custcode=ll_log.get(0).get("custcode");//瀹㈡埛缂栫爜 + + Gson gson = new Gson(); + + //閫氳繃BIP鐨凙PI鑾峰彇瀹㈡埛淇℃伅 + String custurl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/merchant/detail?access_token="+accessToken; + HashMap custMap = new HashMap(); + custMap.put("code", custcode); + + String custdetailString=doGet(custurl,custMap); + +// Map custDetailresult = gson.fromJson(custdetailString, Map.class); + JSONObject custDetailresult= JSON.parseObject(custdetailString); + if (StringUtils.equals("200", custDetailresult.get("code").toString())) {//瀹㈡埛瀛樺湪 + + Map dataInfo = (Map) custDetailresult.get("data"); + +// dataInfo.remove("merchantApplyRanges"); + + String id=dataInfo.get("id").toString(); + List> l_map_f = new ArrayList>(); + List> l_map = new ArrayList>(); + boolean bool =false; + if(!MMValueCheck.isEmpty(dataInfo.get("merchantAgentFinancialInfos"))){ + bool=true; + l_map=(List>) dataInfo.get("merchantAgentFinancialInfos"); + } + + + Map checkMap = new HashMap(); + checkMap.put("ss", "ss"); + + + + for (Map map : ll_log) {//Erp涓煡璇㈠嚭鏉ョ殑瀹㈡埛瀛愯处鎴 + + + + String accnum=map.get("accnum");//閾惰璐︽埛 + + if(checkMap.containsKey(accnum)) {//鍓旈櫎erp涓摱琛岃处鍙烽噸鍚堟暟鎹 + continue; + }else { + checkMap.put(accnum, accnum); + } + + boolean check =false; + if (bool){//瀹㈡埛涓凡缁忓瓨鍦ㄩ摱琛岃处鎴 + + 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("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); + 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())) {//甯佺瀛樺湪 + Map currencydataInfo = (Map)currencyDetailresult.get("data"); + map_bankinfo.put("currency", currencydataInfo.get("id"));//闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d + } + + String bankUrl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/bankdot/list"; + HashMap paramabank = new HashMap(); + paramabank.put("pageIndex", "0"); + paramabank.put("pageSize", "10"); + 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鑾峰彇瀵瑰簲鐨刬d 缃戠偣api + map_bankinfo.put("bank", bankMap.get("bank"));//闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d + } + + break; + } + } + + if(!check) { + //娌℃湁鍖归厤涓婅蛋鏂板 + Map map_add = new HashMap(); + map_add.put("_status", "Insert"); + map_add.put("merchantId_code_agent_financial_falg", custcode); + map_add.put("bankAccount", accnum); + HashMap accname_map = new HashMap(); + 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鑾峰彇瀵瑰簲鐨刬d +// map_add.put("bank", value)//闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d +// getBIPBankID + String bankUrl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/bankdot/list"; + HashMap paramabank = new HashMap(); + paramabank.put("pageIndex", "0"); + paramabank.put("pageSize", "10"); + paramabank.put("name", map.get("bankdocname")); +// map.get("bankdocname"); + Map bankMap=getBIPBankID(paramabank,bankUrl,accessToken,map.get("bankdocname")); + if(bankMap!=null) { + map_add.put("openBank", bankMap.get("id")); //闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d 缃戠偣api + map_add.put("bank", bankMap.get("bank"));//闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d + } + map_add.put("accountType", map.get("accountproperty")==null?0:map.get("accountproperty")); + map_add.put("merchantId_createOrg", "666666"); + + 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鑾峰彇瀵瑰簲鐨刬d + 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())) {//甯佺瀛樺湪 + Map currencydataInfo = (Map)currencyDetailresult.get("data"); + map_add.put("currency", currencydataInfo.get("id"));//闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d + } + map_add.put("stopstatus", map.get("enablestate")=="2"?true:false); + l_map_f.add(map_add); + } + + }else { + + Map map_add = new HashMap(); + map_add.put("_status", "Insert"); + map_add.put("merchantId_code_agent_financial_falg", custcode); + map_add.put("bankAccount", accnum); + HashMap accname_map = new HashMap(); + accname_map.put("zh_CN", map.get("accname")); + map_add.put("bankAccountName", accname_map); + map_add.put("jointLineNo", map.get("combinenum")); + +// getBIPBankID + String bankUrl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/bankdot/list"; + HashMap paramabank = new HashMap(); + paramabank.put("pageIndex", "0"); + paramabank.put("pageSize", "10"); + paramabank.put("name", map.get("bankdocname")); + + Map bankMap=getBIPBankID(paramabank,bankUrl,accessToken,map.get("bankdocname")); + if(bankMap!=null) { + map_add.put("openBank", bankMap.get("id")); //闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d 缃戠偣api + map_add.put("bank", bankMap.get("bank"));//闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d + } + +// +// map_add.put("accountType", 0); + map_add.put("accountType", map.get("accountproperty")==null?0:map.get("accountproperty")); + map_add.put("merchantId_createOrg", "666666"); +// + map.get("isdefault"); + map_add.put("isDefault", map.get("isdefault")==null||map.get("isdefault").equals("N")?false:true); + map_add.put("merchantId", 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); +// Map currencyDetailresult = gson.fromJson(currencyString, Map.class); + JSONObject currencyDetailresult= JSON.parseObject(currencyString); + if (StringUtils.equals("200", currencyDetailresult.get("code").toString())) {//甯佺瀛樺湪 + Map currencydataInfo = (Map)currencyDetailresult.get("data"); + map_add.put("currency", currencydataInfo.get("id"));//闇瑕佷粠bip鑾峰彇瀵瑰簲鐨刬d + } +// + map_add.put("stopstatus", map.get("enablestate")=="2"?true:false); + l_map_f.add(map_add); + } + + + + } + + if(!l_map.isEmpty()) { + if(!l_map_f.isEmpty()) { + l_map.addAll(l_map_f); + } + + }else { + if(!l_map_f.isEmpty()) { + l_map.addAll(l_map_f); + } + } + + if(!l_map.isEmpty()) { + dataInfo.put("merchantAgentFinancialInfos", l_map); + custDetailresult.put("data", dataInfo); + } + + + //鏇存柊瀹㈡埛淇℃伅锛堥摱琛岃处鎴蜂俊鎭級 + String custUpdateUrl=baseUrl+"/iuap-api-gateway/yonbip/digitalModel/merchant/save"; + + Map tokenParam = new HashMap<>(); + tokenParam.put("access_token", accessToken); +// String jsonData= JSON.toJSONString(custDetailresult); + JSONObject js_apct_detail = JSONObject.parseObject(custdetailString); + Map headers = new HashMap(); + 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瀹㈡埛淇濆瓨鏇存柊鎺ュ彛 + + Map updateMap = gson.fromJson(resultString, Map.class); + if (StringUtils.equals("200", updateMap.get("code").toString())) {//淇濆瓨鏇存柊鎴愬姛鍚庨渶瑕佹洿鏂版棩蹇楄〃 + + + }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涓鎴蜂笉瀛樺湪锛屾洿鏂板搴斿瓙璐︽埛鐨則s鏃堕棿锛屼互渚夸笅娆″啀娆¤兘澶熻幏鍙栧埌 + +// 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")+"'"); + } + + + } + } catch (InvalidKeyException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } catch (NoSuchAlgorithmException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); +// } catch (SQLException e) { +// // TODO Auto-generated catch block +// e.printStackTrace(); + } + } } - + Date date = new Date(); + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String dateTime = dateFormat.format(date); + String sql_update=" update bd_defdoc set name='"+dateTime+"' where code='dests' and pk_defdoclist in (select pk_defdoclist from bd_defdoclist where code='BIP-sq' and dr=0) and dr=0 "; //dateTime + try { + getSuperDMO().executeUpdateSQL(sql_update); + } catch (SQLException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } return null; } @@ -229,22 +428,25 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug /** - * 查询bip 中开户行及银行类型id + * 鏌ヨbip 涓紑鎴疯鍙婇摱琛岀被鍨媔d * @param map * @param bipUrl * @return */ - private static Map getBIPBankID(HashMap map,String bipUrl,String accessToken,String bankdocname) { + private Map getBIPBankID(HashMap map,String bipUrl,String accessToken,String bankdocname) { Gson gson = new Gson(); + + Map headers = new HashMap(); + headers.put("Content-Type", "application/json"); Map tokenParam = new HashMap<>(); tokenParam.put("access_token", accessToken); String jsonData= JSON.toJSONString(map); - String resultString=doSendHttp(bipUrl,"POST",tokenParam,"",new HashMap<>(), jsonData); + 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"); @@ -253,10 +455,10 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug map.remove("linenumber"); map.put("name", bankdocname); jsonData= JSON.toJSONString(map); - resultString=doSendHttp(bipUrl,"POST",tokenParam,"",new HashMap<>(), jsonData); + 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"); @@ -269,7 +471,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug } - public static String doSendHttp(String baseUrl, String method, Map paramMap, String mediaType, Map headers, String json){ + public String doSendHttp(String baseUrl, String method, Map paramMap, String mediaType, Map headers, String json){ HttpURLConnection urlConnection = null; InputStream in = null; OutputStream out = null; @@ -288,11 +490,11 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug } } // 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(); @@ -300,7 +502,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug 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()); @@ -341,7 +543,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug }catch(Exception e) { JSONObject js=new JSONObject(); js.put("",-1); - js.put("message","调用外系统接口失败:"+e.getMessage()); + js.put("message","璋冪敤澶栫郴缁熸帴鍙eけ璐ワ細"+e.getMessage()); result=js.toString(); e.printStackTrace(); }finally { @@ -374,7 +576,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug // 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(); @@ -383,11 +585,11 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug // 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 { // @@ -396,7 +598,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug // } // // -// //开户行 +// //寮鎴疯 // String bankdoccode=map.get("bankdoccode"); // HashMap paramap = new HashMap(); // paramap.put("pageIndex", 0); @@ -430,7 +632,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug params.put("appKey", appKey); String timestamp = String.valueOf(System.currentTimeMillis()); params.put("timestamp", timestamp); - // 计算签名 + // 璁$畻绛惧悕 Map treeMap; if (params instanceof TreeMap) { treeMap = params; @@ -470,9 +672,9 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug 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) @@ -491,9 +693,9 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug 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) @@ -507,7 +709,7 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug } - private static String doGet(String path, Map params) throws IOException { + private String doGet(String path, Map params) throws IOException { HttpURLConnection conn = null; InputStream is = null; BufferedReader br = null; @@ -528,21 +730,21 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug 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杩炴帴瀵硅薄鎵撳紑涓涓繛鎺ワ紝寮鸿浆鎴怘TTPURLConnection绫 conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod("GET"); - //设置连接超时时间和读取超时时间 + //璁剧疆杩炴帴瓒呮椂鏃堕棿鍜岃鍙栬秴鏃舵椂闂 conn.setConnectTimeout(120000); conn.setReadTimeout(120000); conn.setRequestProperty("Accept", "application/json"); - //发送请求 + //鍙戦佽姹 conn.connect(); - //通过conn取得输入流,并使用Reader读取 + //閫氳繃conn鍙栧緱杈撳叆娴侊紝骞朵娇鐢≧eader璇诲彇 if (200 == conn.getResponseCode()) { is = conn.getInputStream(); br = new BufferedReader(new InputStreamReader(is, "UTF-8")); @@ -586,9 +788,9 @@ public class ErpSaleOrderToBIPBackgroupWorkPlugin implements IBackgroundWorkPlug // 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)