人员账号反写至客户优化建设银行
This commit is contained in:
		
							parent
							
								
									3cb4ac795e
								
							
						
					
					
						commit
						66a917b300
					
				|  | @ -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 entityName = "bos_user";//系统库 表名 t_sec_user | ||||||
|     private static final String cusEntityName = "bd_customer";//系统库 表名 T_BD_Customer |     private static final String cusEntityName = "bd_customer";//系统库 表名 T_BD_Customer | ||||||
|     private static final String bebankName = "bd_bebank";//系统库 行名行号 表名 t_bd_bebank |     private static final String bebankName = "bd_bebank";//系统库 行名行号 表名 t_bd_bebank | ||||||
|  |     private static final String jsbankNumber = "105100000017";//中国建设银行总行 | ||||||
| 
 | 
 | ||||||
|     @Override |     @Override | ||||||
|     public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException { |     public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException { | ||||||
|  | @ -30,12 +31,14 @@ public class PersonCustomerBankTask extends AbstractTask implements Plugin { | ||||||
|         QFilter qFilter = new QFilter("shjh_acctnum", QCP.not_equals, "");//收款账号 不为空 |         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[] collection = BusinessDataServiceHelper.load(entityName, "id,number,name,shjh_acctnum,shjh_skyh,shjh_xxyh", qFilter.toArray()); | ||||||
|         DynamicObject rmbinfo = EsbUtils.getRmb(); |         DynamicObject rmbinfo = EsbUtils.getRmb(); | ||||||
|  |         DynamicObject jsbankinfo = BusinessDataServiceHelper.loadSingleFromCache(bebankName,"id,number,name", | ||||||
|  |                 new QFilter[]{new QFilter("number","=", jsbankNumber)}); | ||||||
|         for (DynamicObject userinfo : collection) { |         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");//客户编号-即是 人员的编号 |         String cusnumber = ups.getString("number");//客户编号-即是 人员的编号 | ||||||
|         DynamicObject currentCus = BusinessDataServiceHelper.loadSingle(cusEntityName,new QFilter[]{new QFilter("number","=",cusnumber)}); |         DynamicObject currentCus = BusinessDataServiceHelper.loadSingle(cusEntityName,new QFilter[]{new QFilter("number","=",cusnumber)}); | ||||||
|         if(currentCus != null){ |         if(currentCus != null){ | ||||||
|  | @ -48,22 +51,21 @@ public class PersonCustomerBankTask extends AbstractTask implements Plugin { | ||||||
|                 //只处理新增 |                 //只处理新增 | ||||||
|                 return; |                 return; | ||||||
|             } |             } | ||||||
|             String xxyh =  ups.getString("shjh_xxyh");//详细分机银行 |             String xxyh = ups.getString("shjh_xxyh");//详细分机银行 | ||||||
|             //根据详细分机银行 查找对应的行名行号 |             //根据详细分机银行 查找对应的行名行号 | ||||||
|             DynamicObject bebankinfo = BusinessDataServiceHelper.loadSingleFromCache(bebankName,"id,number,name", |             DynamicObject bebankinfo; | ||||||
|                     new QFilter[]{new QFilter("name","=",xxyh)}); |             //建设银行的员工:开户银行统一放在:105100000017 中国建设银行总行 | ||||||
|             if(bebankinfo == null){ |             if(xxyh != null && "建设银行".equals(xxyh.trim())){ | ||||||
|                 return; |                 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 cusname = ups.getString("name");//姓名 | ||||||
| //            String skyh = ups.getString("shjh_skyh");//收款银行 |             DynamicObject bankinfo = doc_bank.addNew(); | ||||||
|             DynamicObject bankinfo; |             bankinfo.set("isdefault_bank",true); | ||||||
|             if(doc_bank.isEmpty()){ |  | ||||||
|                 bankinfo = doc_bank.addNew(); |  | ||||||
|                 bankinfo.set("isdefault_bank",true); |  | ||||||
|             }else{ |  | ||||||
|                 bankinfo = doc_bank.get(0); |  | ||||||
|             } |  | ||||||
|             bankinfo.set("bankaccount",acctnum);//银行账号 |             bankinfo.set("bankaccount",acctnum);//银行账号 | ||||||
|             bankinfo.set("accountname",cusname);//账户名称 |             bankinfo.set("accountname",cusname);//账户名称 | ||||||
|             bankinfo.set("bank",bebankinfo);//开户银行-行名行号 根据入参查找 |             bankinfo.set("bank",bebankinfo);//开户银行-行名行号 根据入参查找 | ||||||
|  |  | ||||||
		Loading…
	
		Reference in New Issue