Merge remote-tracking branch 'origin/master'

src/main/java/fi/ar/opplugin/FinarbillPushOpPlugin.java

@@ -13,6 +13,7 @@ import kd.bos.servicehelper.botp.ConvertServiceHelper;
 import kd.bos.metadata.botp.ConvertRuleReader;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 
 /**
@@ -33,15 +34,15 @@ public class FinarbillPushOpPlugin extends AbstractOperationServicePlugIn {
             QFilter filter=new QFilter("nckd_checkboxfield1", QCP.equals,true);
             //未结算金额不为0
             filter.and("unsettleamount", QCP.not_equals,0);
-            DynamicObject[] dynamicObjects=BusinessDataServiceHelper.load(ar_finarbill,"id",new QFilter[]{filter});
+            Map<Object, DynamicObject> dynamicObjects = BusinessDataServiceHelper.loadFromCache(ar_finarbill, new QFilter[]{filter});
             //获取转换规则id
             ConvertRuleReader read=new ConvertRuleReader();
             List<String> loadRuleIds = read.loadRuleIds(ar_finarbill, ar_baddebtlossbill, false);
-            for (int i=0;i< dynamicObjects.length;i++)
+            for (Object idkey:dynamicObjects.keySet())
             {
                 //获取应收挂帐单
-                DynamicObject info= BusinessDataServiceHelper
-                        .loadSingle(dynamicObjects[i].getPkValue(),dynamicObjects[i].getDynamicObjectType().getName());
+                //当前单头
+                DynamicObject info = dynamicObjects.get(idkey);
                 //源单id
                 Long pkid=info.getLong("id");
                 // 下推参数，设置所选数据项

src/main/java/fi/em/formPlugin/ReimbursementFormPlugin.java

@@ -109,12 +109,10 @@ public class ReimbursementFormPlugin extends AbstractFormPlugin implements Plugi
         QFilter nckd_orgamountFilter = new QFilter("costdept.number", QCP.equals, costdeptNumber);
         nckd_orgamountFilter.and("billstatus", QCP.equals, "E");
         nckd_orgamountFilter.and("creator.number",QCP.equals,creatorNumber);
-        DynamicObject[] nckd_orgamountaccount = BusinessDataServiceHelper.
-                load(er_prepaybill, "id", new QFilter[]{nckd_orgamountFilter});
-
-        for (int c=0;c<nckd_orgamountaccount.length;c++){
-            //当前循环动因基础资料单头
-            DynamicObject dynamicObject = BusinessDataServiceHelper.loadSingle(nckd_orgamountaccount[c].getPkValue(), nckd_orgamountaccount[c].getDynamicObjectType().getName());
+        Map<Object,DynamicObject> nckd_orgamountaccount=BusinessDataServiceHelper.loadFromCache(er_prepaybill, new QFilter[]{nckd_orgamountFilter});
+        for (Object idkey:nckd_orgamountaccount.keySet()){
+            //当前单头
+            DynamicObject dynamicObject = nckd_orgamountaccount.get(idkey);
             //单据编号
             String billno= dynamicObject.getString("billno");
             //循环分录

src/main/java/kd/bos/login/thirdauth/app/ZSBGAuthtication.java

@@ -1,6 +1,6 @@
 package kd.bos.login.thirdauth.app;
 
-import com.jxbank.sso.des.LockDesUtil;
+//import com.jxbank.sso.des.LockDesUtil;
 import kd.bos.dc.api.model.Account;
 
 import javax.servlet.http.HttpServletRequest;
@@ -24,11 +24,11 @@ public class ZSBGAuthtication extends ThirdAppAuthtication{
         result.setSucceed(false);
         if(user!=null && !"".equals(user)){
             String token = request.getParameter("token");
-            if (LockDesUtil.isTheRightDate(user, token)) {//调用第三方jar包方法验证token和user一致
-                result.setUserType(UserType.WORKER_NUMBER);
-                result.setSucceed(true);
-                result.setUserFlag(user);
-            }
+//            if (LockDesUtil.isTheRightDate(user, token)) {//调用第三方jar包方法验证token和user一致
+//                result.setUserType(UserType.WORKER_NUMBER);
+//                result.setSucceed(true);
+//                result.setUserFlag(user);
+//            }
         }
 
         return result;

src/main/java/sys/sc/formplugin/TestPlugin.java

@@ -665,7 +665,6 @@ public class TestPlugin  extends AbstractListPlugin {
                 throw new RuntimeException(ex);
             }
         }
-
         //读取行名行号，存入对应基础资料中
         if("hmhh".equals(e.getOperateKey())) {
             //行名行号表字段
@@ -800,8 +799,172 @@ public class TestPlugin  extends AbstractListPlugin {
         //获取linux服务器连接
         if ("connect".equals(e.getOperateKey()))
         {
-            InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("produceurl");
-
+            //更新人员
+            // 从 nckd_basicdata 表中获取所有人员数据，假设通过某个条件查找
+            DynamicObject[] personDataArray = BusinessDataServiceHelper.load(
+                    "nckd_basicdata",
+                    "id,nckd_employeeid,nckd_name,nckd_gender,nckd_nl,nckd_zzmm,nckd_zgxl,nckd_orgidname,nckd_orgidcode,nckd_posidname,nckd_posidcode,nckd_yggxlb,nckd_status,nckd_sjh",
+                    null
+            );
+            if (personDataArray == null || personDataArray.length == 0) {
+                this.getView().showMessage("未从 nckd_basicdata 表中获取到任何人员数据！");
+                return;
+            }
+            String msg="";
+            for (DynamicObject personData : personDataArray) {
+                //获取id
+                String id=personData.getString("id");
+                // 获取工号
+                String gonghao = personData.getString("nckd_employeeid");
+                if (gonghao == null || gonghao.isEmpty()) {
+                    continue;
+                }
+                //获取姓名
+                String empname=personData.getString("");
+                // 查询用户是否已存在
+                DynamicObject existingUser = BusinessDataServiceHelper.loadSingle(
+                        "bos_user", new QFilter[]{new QFilter("number", "=", gonghao)}
+                );
+                // 用户已存在，进行数据更新
+                if (existingUser != null) {
+                    //初始化
+                    boolean isUpdated = false;
+                    // 比较并更新性别
+                    Object newGender = personData.get("nckd_gender");
+                    if (!newGender.equals(existingUser.get("gender"))) {
+                        existingUser.set("gender", newGender);
+                        isUpdated = true;
+                    }
+                    // 比较并更新手机号
+                    Object newPhone = personData.get("nckd_sjh");
+                    if (!newPhone.equals(existingUser.get("phone"))) {
+                        existingUser.set("phone", newPhone);
+                        isUpdated = true;
+                    }
+                    //更新部门和岗位
+                    DynamicObjectCollection existingDeptEntries = existingUser.getDynamicObjectCollection("entryentity");
+                    //人员部门分录
+                    DynamicObject existingDeptEntry = existingDeptEntries.isEmpty() ? null : existingDeptEntries.get(0);
+                    // 获取新的部门信息
+                    String deptCode = personData.getString("nckd_orgidcode");
+                    DynamicObject newOrgInfo = BusinessDataServiceHelper.loadSingle(
+                            "bos_adminorg", new QFilter[]{new QFilter("number", "=", deptCode)}
+                    );
+                    boolean deptUpdated = false;
+                    if (newOrgInfo != null) {
+                        if (existingDeptEntry == null) {
+                            // 如果没有现有部门分录，则添加新的部门分录
+                            existingDeptEntry = existingDeptEntries.addNew();
+                            deptUpdated = true;
+                        }
+                        // 比较并更新部门信息
+                        if (!deptCode.equals(existingDeptEntry.get("dpt.number"))) {
+                            existingDeptEntry.set("dpt", newOrgInfo);
+                            deptUpdated = true;
+                        }
+                        // 更新组织结构
+                        DynamicObjectCollection structureInfoCollection = newOrgInfo.getDynamicObjectCollection("structure");
+                        if (structureInfoCollection != null && !structureInfoCollection.isEmpty()) {
+                            DynamicObject structureInfo = structureInfoCollection.get(0);
+                            if(existingDeptEntry.getDynamicObject("orgstructure")!=null){
+                                if (!structureInfo.getPkValue().equals(existingDeptEntry.getDynamicObject("orgstructure").getPkValue())) {
+                                    existingDeptEntry.set("orgstructure", structureInfo.getPkValue());
+                                    deptUpdated = true;
+                                }
+                            }else{
+                                existingDeptEntry.set("orgstructure", structureInfo.getPkValue());
+                                deptUpdated = true;
+                            }
+                        }
+                        // 标记是否需要保存
+                        if (deptUpdated) {
+                            isUpdated = true;
+                        }
+                    } else {
+                        this.getView().showMessage("未找到部门编码为 " + deptCode + " 的部门信息！");
+                    }
+                    // 获取新的岗位信息
+                    String postName = personData.getString("nckd_posidname");
+                    if (!postName.equals(existingDeptEntry.getString("position"))) {
+                        existingDeptEntry.set("position", postName);
+                        isUpdated = true;
+                    }
+                    // 如果有更新则保存
+                    if (isUpdated) {
+                        SaveServiceHelper.save(new DynamicObject[]{existingUser});
+                        msg+="工号为 " + gonghao + " 的用户信息已更新！";
+                    }
+                } else {
+                    // 用户不存在，创建新用户
+                    DynamicObjectType userType = EntityMetadataCache.getDataEntityType("bos_user");
+                    DynamicObject userinfo = new DynamicObject(userType);
+                    ORM impl = ORM.create();
+                    userinfo.set("id", impl.genLongId("bos_user"));
+                    userinfo.set("number", gonghao);
+                    // 设置其他字段
+                    userinfo.set("gender", personData.get("nckd_gender"));
+                    //人员手机号
+                    userinfo.set("phone", personData.get("nckd_sjh"));
+                    // 设置其他固定字段
+                    userinfo.set("startdate", new Date());
+                    Calendar c = Calendar.getInstance();
+                    c.set(Calendar.YEAR, 2999);
+                    userinfo.set("enddate", c.getTime());
+                    userinfo.set("masterid", userinfo.get("id"));
+                    userinfo.set("enable", 1);
+                    userinfo.set("status", "C");
+                    userinfo.set("password", "8HrquJnZfyOkmmHkpGLXfg==");
+                    userinfo.set("isregisted", "1");
+                    userinfo.set("isactived", "1");
+                    userinfo.set("pswstrategy", "338333884850648064");
+                    userinfo.set("psweffectivedate", new Date());
+                    userinfo.set("useenddate", c.getTime());
+                    // 设置姓名和拼音
+                    String name = personData.getString("nckd_name");
+                    userinfo.set("name", name);
+                    String fullPinyin = UserOperationUtils.getFullSpellByName(name);
+                    String simplePinyin = UserOperationUtils.getFirstSpellByName(name);
+                    userinfo.set("fullpinyin", fullPinyin);
+                    userinfo.set("simplepinyin", simplePinyin);
+                    // 设置用户名
+                    String username = UserOperationUtils.getUserNameByFormatedFullPinyin(
+                            (long) userinfo.getPkValue(), fullPinyin, null
+                    );
+                    userinfo.set("username", username);
+                    // 创建部门分录
+                    DynamicObjectCollection bmflList = userinfo.getDynamicObjectCollection("entryentity");
+                    DynamicObject bumeninfo = bmflList.addNew();
+                    // 获取部门编码并在 bos_adminorg 表中查找部门信息
+                    String deptCode = personData.getString("nckd_orgidcode");
+                    DynamicObject orginfo = BusinessDataServiceHelper.loadSingle(
+                            "bos_adminorg", new QFilter[]{new QFilter("number", "=", deptCode)}
+                    );
+                    if (orginfo != null) {
+                        bumeninfo.set("dpt", orginfo);
+                        // 获取组织的分录集合 structure 的第一条数据
+                        DynamicObjectCollection structureInfoCollection = orginfo.getDynamicObjectCollection("structure");
+                        if (structureInfoCollection != null && !structureInfoCollection.isEmpty()) {
+                            DynamicObject structureInfo = structureInfoCollection.get(0); // 获取第一条结构信息
+                            bumeninfo.set("orgstructure", structureInfo.getPkValue());
+                        } else {
+                            this.getView().showMessage("部门编码为 " + deptCode + " 的部门缺少组织结构信息，跳过该记录。");
+                        }
+                    }
+                    String postName = personData.getString("nckd_posidname");;
+                    bumeninfo.set("position", postName);
+                    //所在岗位名称
+                    String positionnumber = personData.getString("nckd_posidname");;
+                    bumeninfo.set("post", positionnumber);
+                    // 保存新用户信息
+                    SaveServiceHelper.save(new DynamicObject[]{userinfo});
+                    msg+="工号为 " + gonghao + " 的用户已创建！";
+                }
+            }
+            if("".equals(msg)){
+                this.getView().showMessage("没有需要更新或新增的人员");
+            }else{
+                this.getView().showMessage(msg);
+            }
         }
 
     }

src/main/java/sys/sc/opplugin/utils/InterFaceImgUtils.java

@@ -50,6 +50,8 @@ public class InterFaceImgUtils {
     public String getServerEndsign() {
         return jkpzxx.getString("nckd_endsign");
     }
+    //获取文件名
+    public String getFileName() {return jkpzxx.getString("nckd_filename");}
 
 
 }

src/main/java/sys/sc/task/CreatDatDailyTask.java

@@ -33,9 +33,6 @@ import java.util.Map;
  */
 public class CreatDatDailyTask extends AbstractTask {
     private static final Log log = LogFactory.getLog(CreatDatDailyTask.class);
-
-    //接口配置信息基础资料标识
-    private static String nckd_jkpzxx="nckd_jkpzxx";
     //数据表字段基础资料标识
     private static String nckd_tablebasic="nckd_tablebasic";
     @Override
@@ -45,85 +42,87 @@ public class CreatDatDailyTask extends AbstractTask {
 
     @Override
     public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
+        //获取调度参数
+        String frequency= (String) map.get("frequency");
         //取已审核的数据
         QFilter filter=new QFilter("status", QCP.equals,"C");
         //数据表基础资料
-        DynamicObject[] tableDy=BusinessDataServiceHelper.load(nckd_tablebasic,"id",new QFilter[]{filter});
+        DynamicObject[] tableDy=BusinessDataServiceHelper
+                .load(nckd_tablebasic,"id,nckd_tableentry,nckd_isable,nckd_entrycode,nckd_dooperation,number,nckd_biazppnum,creatdat",new QFilter[]{filter});
         log.info("----------------------读取数据表基础资料-------------------");
-        for (DynamicObject item:tableDy)
-        {
-            log.info("-------------------------获取服务器连接-----------------");
-            List<String> fileList=new ArrayList<>();
-            //获取表字段当前分录
-            DynamicObjectCollection dynamicObjectCollection=item.getDynamicObjectCollection("nckd_tableentry");
-            for (DynamicObject itemmen:dynamicObjectCollection) {
-                //将打勾的字段到处
-                if (itemmen.getBoolean("nckd_isable")) {
-                    //需要导入的标识写入list中
-                    fileList.add(itemmen.getString("nckd_entrycode"));
+        for (DynamicObject item:tableDy) {
+            //参数执行频率等于表的执行频率则生成文件
+            if (frequency.equals(item.getString("nckd_dooperation"))) {
+                log.info("-------------------------获取服务器连接-----------------");
+                List<String> fileList=new ArrayList<>();
+                //获取表字段当前分录
+                DynamicObjectCollection dynamicObjectCollection=item.getDynamicObjectCollection("nckd_tableentry");
+                for (DynamicObject itemmen:dynamicObjectCollection) {
+                    //将打勾的字段导出
+                    if (itemmen.getBoolean("nckd_isable")) {
+                        //需要导入的标识写入list中
+                        fileList.add(itemmen.getString("nckd_entrycode"));
+                    }
                 }
-            }
-            //获取当前选择的表名
-            String tablenumber=item.getString("number");
-            //业务编码
-            String bizappnum=item.getString("nckd_biazppnum");
-            //接口配置信息获取
-            //读取接口配置信息获取
-            InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("creatdat");
-            //服务器路径
-            String nckd_url=interFaceImgUtils.getServerUrl();
-            if (nckd_url.equals("/var/appstatic/")) {
-                nckd_url="/home/kingdee/cosmic/nginx-appstatic/store/appstatic/";
-            }
-            //分割符号
-            String spiltsign=interFaceImgUtils.getServerSplit();
-            //结束符号
-            String endsign=interFaceImgUtils.getServerEndsign();
-            //上传文件到服务器中
-            //服务器端口
-            String host=interFaceImgUtils.getServerName();
-            //服务器用户名
-            String username=interFaceImgUtils.getServerUser();
-            //服务器密码
-            String password=interFaceImgUtils.getServerPassword();
-            //服务器路径
-            //服务器端口号
-            int port= interFaceImgUtils.getProt();
-            try {
+                //获取当前选择的表名
+                String tablenumber=item.getString("number");
+                //业务编码
+                String bizappnum=item.getString("nckd_biazppnum");
+                //接口配置信息获取
+                //读取接口配置信息获取
+                InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("creatdat");
+                //服务器路径
+                String nckd_url=interFaceImgUtils.getServerUrl();
+                //分割符号
+                String spiltsign=interFaceImgUtils.getServerSplit();
+                //结束符号
+                String endsign=interFaceImgUtils.getServerEndsign();
                 //上传文件到服务器中
-                SftpClient sftpClient=new SftpClient(host,username,password,port);
-                //获取服务器连接
-                sftpClient.connect();
-                //创建文件夹，为当天日期
-                Date currentDate=new Date();
-                //设置日期格式
-                SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd");
-                String dateStr=sf.format(currentDate);
-                String filePathWithDate=nckd_url+dateStr;
-                //创建文件夹，名为当前日期
-                sftpClient.creatDir(filePathWithDate);
-                //临时文件
-                File localFile = File.createTempFile(tablenumber, ".dat");
-                File dest=new File(localFile.getParent()+File.separator+tablenumber.toUpperCase()+".dat");
-                //重命名文件
-                localFile.renameTo(dest);
-                //文件写入
-                DatFileCreatUtils datFileCreatUtils=new DatFileCreatUtils(tablenumber,bizappnum,fileList,dest.getAbsolutePath(),spiltsign,endsign);
-                //生成dat文件到本地
-                datFileCreatUtils.creatDatFile();
-                //从本地传文件到服务器
-                sftpClient.fileCreat(dest.getAbsolutePath(),filePathWithDate);
-                //上传后删除临时文件
-                localFile.delete();
-                dest.delete();
-                //关闭连接
-                sftpClient.disconnect();
-            } catch (IOException e) {
-                throw new RuntimeException(e);
-            } catch (SftpException e) {
-                throw new RuntimeException(e);
-            } catch (Exception e) {
-                throw new RuntimeException(e);
+                //服务器端口
+                String host=interFaceImgUtils.getServerName();
+                //服务器用户名
+                String username=interFaceImgUtils.getServerUser();
+                //服务器密码
+                String password=interFaceImgUtils.getServerPassword();
+                //服务器路径
+                //服务器端口号
+                int port= interFaceImgUtils.getProt();
+                try {
+                    //上传文件到服务器中
+                    SftpClient sftpClient=new SftpClient(host,username,password,port);
+                    //获取服务器连接
+                    sftpClient.connect();
+                    //创建文件夹，为当天日期
+                    Date currentDate=new Date();
+                    //设置日期格式
+                    SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd");
+                    String dateStr=sf.format(currentDate);
+                    String filePathWithDate=nckd_url+dateStr;
+                    //创建文件夹，名为当前日期
+                    sftpClient.creatDir(filePathWithDate);
+                    //临时文件
+                    File localFile = File.createTempFile(tablenumber, ".dat");
+                    File dest=new File(localFile.getParent()+File.separator+tablenumber.toUpperCase()+".dat");
+                    //重命名文件
+                    localFile.renameTo(dest);
+                    //文件写入
+                    DatFileCreatUtils datFileCreatUtils=new DatFileCreatUtils(tablenumber,bizappnum,fileList,dest.getAbsolutePath(),spiltsign,endsign);
+                    //生成dat文件到本地
+                    datFileCreatUtils.creatDatFile();
+                    //从本地传文件到服务器
+                    sftpClient.fileCreat(dest.getAbsolutePath(),filePathWithDate);
+                    //上传后删除临时文件
+                    localFile.delete();
+                    dest.delete();
+                    //关闭连接
+                    sftpClient.disconnect();
+                } catch (IOException e) {
+                    throw new RuntimeException(e);
+                } catch (SftpException e) {
+                    throw new RuntimeException(e);
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
             }
         }
     }

src/main/java/sys/sc/task/UpdateBankDailyTask.java

@@ -13,6 +13,7 @@ import kd.bos.schedule.api.MessageHandler;
 import kd.bos.schedule.executor.AbstractTask;
 import kd.bos.servicehelper.BusinessDataServiceHelper;
 import kd.bos.servicehelper.operation.SaveServiceHelper;
+import sys.sc.opplugin.utils.InterFaceImgUtils;
 import sys.sc.opplugin.utils.SftpClient;
 
 import java.io.BufferedReader;
@@ -28,11 +29,7 @@ import java.util.*;
  */
 public class UpdateBankDailyTask extends AbstractTask {
     private static final Log log = LogFactory.getLog(UpdateBankDailyTask.class);
-    public static String host="192.168.10.69";//服务器ip地址
-    public static String username="root";//用户名
-    public static int port = 22;//端口号
-    public static String password="Kd@86262007";//用户密码
-
+    public InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("produceurl");
 
     @Override
     public MessageHandler getMessageHandle() {
@@ -51,13 +48,24 @@ public class UpdateBankDailyTask extends AbstractTask {
         String bd_bebank="bd_bebank";
         try {
             log.info("----------------------获取服务器连接------------------------");
+            //服务器ip
+            String host=interFaceImgUtils.getServerName();
+            //用户名
+            String username=interFaceImgUtils.getServerUser();
+            //用户密码
+            String password=interFaceImgUtils.getServerPassword();
+            //分割符
+            String splitsign=interFaceImgUtils.getServerSplit();
+            //结尾符
+            String endsign=interFaceImgUtils.getServerEndsign();
+            int port= interFaceImgUtils.getProt();
             //获取服务器连接
             SftpClient sftpClient=new SftpClient(host,username,password,port);
             sftpClient.connect();
             List<DynamicObject> createdataList = new ArrayList<>();
             List<DynamicObject> updatedataList = new ArrayList<>();
             //文件路径
-            String fileurl = getFileUrl("hmhhurl");
+            String fileurl = getFileUrl();
             //基础资料
             DynamicObjectType dynamicObjectType = EntityMetadataCache.getDataEntityType(bd_bebank);
             //国家基础资料(中国)
@@ -78,9 +86,9 @@ public class UpdateBankDailyTask extends AbstractTask {
                 String line;
                 while ((line = reader.readLine()) != null) {
                     //去掉换行符|$|
-                    line = line.replace("|$|", "");
+                    line = line.replace(endsign, "");
                     //
空格符号，根据这个符号分割
-                    String[] fields = line.split("\u0001");
+                    String[] fields = line.split(splitsign);
                     //如果获取的数据行不等于预设字段的行，则跳过这行数据
 //                        if (fields.length != selector.size()) {
 //                            continue;
@@ -176,15 +184,12 @@ public class UpdateBankDailyTask extends AbstractTask {
     }
 
     //根据接口配置信息获取组织人员，拼接服务器文件路径url,参数为urlcode接口配置信息编码
-    public String getFileUrl(String urlcode)
+    public String getFileUrl()
     {
-        //组织人员接口配置信息获取
-        DynamicObject nckd_jkpzxx= BusinessDataServiceHelper
-                .loadSingle("nckd_jkpzxx", new QFilter[]{new QFilter("number", "=", urlcode)});
         //取文件名
-        String nckd_filename=nckd_jkpzxx.getString("nckd_filename");
+        String nckd_filename=interFaceImgUtils.getFileName();
         //获取文件路径
-        String nckd_url=nckd_jkpzxx.getString("nckd_url");
+        String nckd_url=interFaceImgUtils.getServerUrl();
         //当前日期
         Date currentDate=new Date();
         Calendar calendar = Calendar.getInstance();
@@ -196,10 +201,6 @@ public class UpdateBankDailyTask extends AbstractTask {
         SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd");
         String datestr=sf.format(newDate);
         //文件路径拼接
-        //真实路径
-        if (nckd_url.equals("/var/appstatic/")) {
-            nckd_url="/home/kingdee/cosmic/nginx-appstatic/store/appstatic/";
-        }
         String realPath = nckd_url+datestr+"/"+nckd_filename;
         return realPath;
     }

src/main/java/sys/sc/task/UpdateDataDailyTask.java

@@ -18,6 +18,7 @@ import kd.bos.sec.user.utils.UserOperationUtils;
 import kd.bos.servicehelper.BusinessDataServiceHelper;
 import kd.bos.servicehelper.operation.SaveServiceHelper;
 import sys.sc.formplugin.ABillServiceHelper;
+import sys.sc.opplugin.utils.InterFaceImgUtils;
 import sys.sc.opplugin.utils.SftpClient;
 
 import java.io.*;
@@ -32,10 +33,18 @@ import java.util.*;
 public class UpdateDataDailyTask extends AbstractTask {
 
     private static final Log log = LogFactory.getLog(UpdateDataDailyTask.class);
-    public static String host="192.168.10.69";//服务器ip地址
-    public static String username="root";//用户名
-    public static int port = 22;//端口号
-    public static String password="Kd@86262007";//用户密码
+    public InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("produceurl");    //服务器ip
+    public String host=interFaceImgUtils.getServerName();
+    //用户名
+    public String username=interFaceImgUtils.getServerUser();
+    //用户密码
+    public String password=interFaceImgUtils.getServerPassword();
+    //分割符
+    public String splitsign=interFaceImgUtils.getServerSplit();
+    //结尾符
+    public String endsign=interFaceImgUtils.getServerEndsign();
+    public int port= interFaceImgUtils.getProt();
+
 
 
     @Override
@@ -50,6 +59,7 @@ public class UpdateDataDailyTask extends AbstractTask {
         //文件路径
         String path=getFileUrl("organduserurl");
         try {
+
             //获取连接对象
             SftpClient sftpClient=new SftpClient(host,username,password,port);
             sftpClient.connect();
@@ -93,9 +103,9 @@ public class UpdateDataDailyTask extends AbstractTask {
                 String line;
                 while ((line = reader.readLine()) != null) {
                     //去掉换行符|$|
-                    line = line.replace("|$|", "");
+                    line = line.replace(endsign, "");
                     //
空格符号，根据这个符号分割
-                    String[] fields = line.split("\u0001");
+                    String[] fields = line.split(splitsign);
                     //如果获取的数据行不等于预设字段的行，则跳过这行数据
                     if (fields.length != selector.size()) {
                         continue;
@@ -184,7 +194,7 @@ public class UpdateDataDailyTask extends AbstractTask {
             log.info("指定的上级组织 'jxyh' 未找到！");
             return;
         }
-        IFormView orgview = ABillServiceHelper.createAddView("bos_adminorg");
+
         for (DynamicObject record : nckdData) {
             // 判断并创建或更新所在单位
             //所在单位编码
@@ -196,6 +206,7 @@ public class UpdateDataDailyTask extends AbstractTask {
             );
             //没有单位则创建
             if (org == null) {
+                IFormView orgview = ABillServiceHelper.createAddView("bos_adminorg");
                 //组织编码
                 orgview.getModel().setValue("number", szdwbm);
                 //组织名称
@@ -232,7 +243,7 @@ public class UpdateDataDailyTask extends AbstractTask {
             //一级机构
             DynamicObject yjjg = BusinessDataServiceHelper.loadSingle("bos_adminorg", new QFilter[]{new QFilter("number", "=", yjjgbm)});
             if (yjjg == null) {
-                IFormView yjjgView=orgview;
+                IFormView yjjgView=ABillServiceHelper.createAddView("bos_adminorg");
                 yjjgView.getModel().setValue("number", yjjgbm);
                 yjjgView.getModel().setValue("name", yjjgmc);
                 yjjgView.getModel().setValue("parent", org); // 父级组织为 org
@@ -258,7 +269,7 @@ public class UpdateDataDailyTask extends AbstractTask {
             //所在部门
             DynamicObject szbm = BusinessDataServiceHelper.loadSingle("bos_adminorg", new QFilter[]{new QFilter("number", "=", szbmbm)});
             if (szbm == null) {
-                IFormView szbmView=orgview;
+                IFormView szbmView=ABillServiceHelper.createAddView("bos_adminorg");
                 szbmView.getModel().setValue("number", szbmbm);
                 szbmView.getModel().setValue("name", szbmmc);
                 szbmView.getModel().setValue("parent", yjjg); // 设置父级为 yjjg
@@ -354,15 +365,20 @@ public class UpdateDataDailyTask extends AbstractTask {
                     // 更新组织结构
                     DynamicObjectCollection structureInfoCollection = newOrgInfo.getDynamicObjectCollection("structure");
                     if (structureInfoCollection != null && !structureInfoCollection.isEmpty()) {
-                        DynamicObject structureInfo = structureInfoCollection.get(0);
-                        if(existingDeptEntry.getDynamicObject("orgstructure")!=null){
-                            if (!structureInfo.getPkValue().equals(existingDeptEntry.getDynamicObject("orgstructure").getPkValue())) {
-                                existingDeptEntry.set("orgstructure", structureInfo.getPkValue());
-                                deptUpdated = true;
+                        for (DynamicObject item:structureInfoCollection) {
+                            //不为兼职则更新
+                            if (!item.getBoolean("ispartjob")) {
+                                DynamicObject structureInfo=item;//获取结构信息
+                                if(existingDeptEntry.getDynamicObject("orgstructure")!=null){
+                                    if (!structureInfo.getPkValue().equals(existingDeptEntry.getDynamicObject("orgstructure").getPkValue())) {
+                                        existingDeptEntry.set("orgstructure", structureInfo.getPkValue());
+                                        deptUpdated = true;
+                                    }
+                                }else{
+                                    existingDeptEntry.set("orgstructure", structureInfo.getPkValue());
+                                    deptUpdated = true;
+                                }
                             }
-                        }else{
-                            existingDeptEntry.set("orgstructure", structureInfo.getPkValue());
-                            deptUpdated = true;
                         }
                     }
                     // 标记是否需要保存
@@ -433,8 +449,13 @@ public class UpdateDataDailyTask extends AbstractTask {
                     // 获取组织的分录集合 structure 的第一条数据
                     DynamicObjectCollection structureInfoCollection = orginfo.getDynamicObjectCollection("structure");
                     if (structureInfoCollection != null && !structureInfoCollection.isEmpty()) {
-                        DynamicObject structureInfo = structureInfoCollection.get(0); // 获取第一条结构信息
-                        bumeninfo.set("orgstructure", structureInfo.getPkValue());
+                        for (DynamicObject item:structureInfoCollection) {
+                            //不为兼职则更新
+                            if (!item.getBoolean("ispartjob")) {
+                                DynamicObject structureInfo=item;//获取结构信息
+                                bumeninfo.set("orgstructure",structureInfo.getPkValue());
+                            }
+                        }
                     } else {
                         log.info("部门编码为 " + deptCode + " 的部门缺少组织结构信息，跳过该记录。");
                     }
@@ -477,9 +498,6 @@ public class UpdateDataDailyTask extends AbstractTask {
         String datestr=sf.format(newDate);
         //文件路径拼接
         //真实路径
-        if (nckd_url.equals("/var/appstatic/")) {
-            nckd_url="/home/kingdee/cosmic/nginx-appstatic/store/appstatic/";
-        }
         String realPath = nckd_url+datestr+"/"+nckd_filename;
         return realPath;
     }

src/main/java/sys/sc/task/UpdateImpairmentDailyTask.java

@@ -15,6 +15,7 @@ import kd.bos.schedule.executor.AbstractTask;
 import kd.bos.servicehelper.BusinessDataServiceHelper;
 import kd.bos.servicehelper.operation.DeleteServiceHelper;
 import kd.bos.servicehelper.operation.SaveServiceHelper;
+import sys.sc.opplugin.utils.InterFaceImgUtils;
 import sys.sc.opplugin.utils.SftpClient;
 
 import java.io.*;
@@ -28,10 +29,19 @@ import java.util.*;
  */
 public class UpdateImpairmentDailyTask extends AbstractTask {
     private static final Log log = LogFactory.getLog(UpdateImpairmentDailyTask.class);
-    public static String host="192.168.10.69";//服务器ip地址
-    public static String username="root";//用户名
-    public static int port = 22;//端口号
-    public static String password="Kd@86262007";//用户密码
+    public InterFaceImgUtils interFaceImgUtils=new InterFaceImgUtils("produceurl");
+    //服务器ip
+    public String host=interFaceImgUtils.getServerName();
+    //用户名
+    public String username=interFaceImgUtils.getServerUser();
+    //用户密码
+    public String password=interFaceImgUtils.getServerPassword();
+    //分割符
+    public String splitsign=interFaceImgUtils.getServerSplit();
+    //结尾符
+    public String endsign=interFaceImgUtils.getServerEndsign();
+    public int port= interFaceImgUtils.getProt();
+
 
 
     @Override
@@ -67,9 +77,9 @@ public class UpdateImpairmentDailyTask extends AbstractTask {
                 String line;
                 while ((line = reader.readLine()) != null) {
                     //去掉换行符|$|
-                    line = line.replace("|$|", "");
+                    line = line.replace(endsign, "");
                     //
空格符号，根据这个符号分割
-                    String[] fields = line.split("\u0001");
+                    String[] fields = line.split(splitsign);
                     //如果获取的数据行不等于预设字段的行，则跳过这行数据
                     if (fields.length != selector.size()) {
                         continue;
@@ -138,10 +148,6 @@ public class UpdateImpairmentDailyTask extends AbstractTask {
         //转换日期格式
         SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd");
         String datestr=sf.format(newDate);
-        //真实路径
-        if (nckd_url.equals("/var/appstatic/")) {
-            nckd_url="/home/kingdee/cosmic/nginx-appstatic/store/appstatic/";
-        }
         //文件完整路径
         String realPath = nckd_url+datestr+ File.separator+nckd_filename;
         return realPath;