diff --git a/main/java/shjh/jhzj7/fi/fi/plugin/task/PersonCustomerBankTask.java b/main/java/shjh/jhzj7/fi/fi/plugin/task/PersonCustomerBankTask.java index d12293b..fed1373 100644 --- a/main/java/shjh/jhzj7/fi/fi/plugin/task/PersonCustomerBankTask.java +++ b/main/java/shjh/jhzj7/fi/fi/plugin/task/PersonCustomerBankTask.java @@ -23,6 +23,7 @@ public class PersonCustomerBankTask extends AbstractTask implements Plugin { private static final String entityName = "bos_user";//系统库 表名 t_sec_user private static final String cusEntityName = "bd_customer";//系统库 表名 T_BD_Customer private static final String bebankName = "bd_bebank";//系统库 行名行号 表名 t_bd_bebank + private static final String jsbankNumber = "105100000017";//中国建设银行总行 @Override public void execute(RequestContext requestContext, Map map) throws KDException { @@ -30,12 +31,14 @@ public class PersonCustomerBankTask extends AbstractTask implements Plugin { QFilter qFilter = new QFilter("shjh_acctnum", QCP.not_equals, "");//收款账号 不为空 DynamicObject[] collection = BusinessDataServiceHelper.load(entityName, "id,number,name,shjh_acctnum,shjh_skyh,shjh_xxyh", qFilter.toArray()); DynamicObject rmbinfo = EsbUtils.getRmb(); + DynamicObject jsbankinfo = BusinessDataServiceHelper.loadSingleFromCache(bebankName,"id,number,name", + new QFilter[]{new QFilter("number","=", jsbankNumber)}); for (DynamicObject userinfo : collection) { - handlePersonForCustomer(userinfo,rmbinfo); + handlePersonForCustomer(userinfo,rmbinfo,jsbankinfo); } } - private void handlePersonForCustomer(DynamicObject ups,DynamicObject rmbinfo){ + private void handlePersonForCustomer(DynamicObject ups,DynamicObject rmbinfo, DynamicObject jsbankinfo){ String cusnumber = ups.getString("number");//客户编号-即是 人员的编号 DynamicObject currentCus = BusinessDataServiceHelper.loadSingle(cusEntityName,new QFilter[]{new QFilter("number","=",cusnumber)}); if(currentCus != null){ @@ -48,22 +51,21 @@ public class PersonCustomerBankTask extends AbstractTask implements Plugin { //只处理新增 return; } - String xxyh = ups.getString("shjh_xxyh");//详细分机银行 + String xxyh = ups.getString("shjh_xxyh");//详细分机银行 //根据详细分机银行 查找对应的行名行号 - DynamicObject bebankinfo = BusinessDataServiceHelper.loadSingleFromCache(bebankName,"id,number,name", - new QFilter[]{new QFilter("name","=",xxyh)}); - if(bebankinfo == null){ - return; + DynamicObject bebankinfo; + //建设银行的员工:开户银行统一放在:105100000017 中国建设银行总行 + if(xxyh != null && "建设银行".equals(xxyh.trim())){ + bebankinfo = jsbankinfo; + }else if(xxyh != null){ + bebankinfo = BusinessDataServiceHelper.loadSingleFromCache(bebankName,"id,number,name", + new QFilter[]{new QFilter("name","=",xxyh)}); + }else{ + bebankinfo = null; } String cusname = ups.getString("name");//姓名 -// String skyh = ups.getString("shjh_skyh");//收款银行 - DynamicObject bankinfo; - if(doc_bank.isEmpty()){ - bankinfo = doc_bank.addNew(); - bankinfo.set("isdefault_bank",true); - }else{ - bankinfo = doc_bank.get(0); - } + DynamicObject bankinfo = doc_bank.addNew(); + bankinfo.set("isdefault_bank",true); bankinfo.set("bankaccount",acctnum);//银行账号 bankinfo.set("accountname",cusname);//账户名称 bankinfo.set("bank",bebankinfo);//开户银行-行名行号 根据入参查找