From 66a917b300f8e5d8510eff2b2fa8d0487990a080 Mon Sep 17 00:00:00 2001
From: yuxueliang0813 <407010292@qq.com>
Date: Mon, 16 Jun 2025 12:22:41 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=BA=E5=91=98=E8=B4=A6=E5=8F=B7=E5=8F=8D?=
 =?UTF-8?q?=E5=86=99=E8=87=B3=E5=AE=A2=E6=88=B7=E4=BC=98=E5=8C=96=E5=BB=BA?=
 =?UTF-8?q?=E8=AE=BE=E9=93=B6=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../plugin/task/PersonCustomerBankTask.java   | 32 ++++++++++---------
 1 file changed, 17 insertions(+), 15 deletions(-)

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<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, "");//收款账号 不为空
         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);//开户银行-行名行号 根据入参查找