#3178759 人员入职、人员异动 接口开发

src/com/api/jygf/web/MobilePermissionsAction.java

@@ -1,13 +0,0 @@
-package com.api.jygf.web;
-
-import javax.ws.rs.Path;
-
-/**
- * @Author weaver_cl
- * @Description:
- * @Date 2022/10/9
- * @Version V1.0
- **/
-@Path("/mobile/permission")
-public class MobilePermissionsAction extends com.engine.jygf.web.MobilePermissionsAction {
-}

src/com/engine/jygf/cmd/MobilePermissionsCmd.java

@@ -1,68 +0,0 @@
-package com.engine.jygf.cmd;
-
-import com.engine.common.biz.AbstractCommonCommand;
-import com.engine.common.entity.BizLogContext;
-import com.engine.core.interceptor.CommandContext;
-import org.apache.commons.lang3.StringUtils;
-import weaver.conn.RecordSet;
-import weaver.hrm.User;
-import weaver.wechat.util.Utils;
-
-import java.util.*;
-
-/**
- * @Author weaver_cl
- * @Description:
- * @Date 2022/10/9
- * @Version V1.0
- **/
-public class MobilePermissionsCmd extends AbstractCommonCommand<Map<String, Object>> {
-
-    private static final String FIELDID = "field100026"; //移动电话自定义字段
-
-    private static final String SCOPE = "HrmCustomFieldByInfoType";
-
-    private static final String SCOPEID = "-1";
-
-    public MobilePermissionsCmd(Map<String, Object> params, User user) {
-        this.user = user;
-        this.params = params;
-    }
-
-    @Override
-    public BizLogContext getLogContext() {
-        return null;
-    }
-
-
-    @Override
-    public Map<String, Object> execute(CommandContext commandContext) {
-        Map<String, Object> data = new HashMap<>();
-        String uid =  Utils.null2String(user.getUID());
-        RecordSet rs = new RecordSet();
-        HashSet<String> ids = new HashSet<>();
-        ids.add(uid);
-        rs.executeQuery("select ckr,bckr from uf_yddhqx_dt1");
-        while (rs.next()) {
-            String ckr = Utils.null2String(rs.getString("ckr"));
-            String bckr = Utils.null2String(rs.getString("bckr"));
-            if (Arrays.asList(ckr.split(",")).contains(uid)) {
-                ids.addAll(Arrays.asList(bckr.split(",")));
-            }
-        }
-
-        Map<String,String> mobileInfo = new HashMap<>();
-        String value = StringUtils.join(ids,",");
-        rs.executeQuery("select id,"+FIELDID+" from cus_fielddata where scope = ? and scopeid = ?" +
-                " and id in ("+value+")",SCOPE,SCOPEID);
-        while (rs.next()){
-            mobileInfo.put(Utils.null2String(rs.getString("id")),rs.getString(FIELDID));
-        }
-
-        data.put("ids",ids);
-        data.put("mobileInfo",mobileInfo);
-        return data;
-    }
-
-
-}

src/com/engine/jygf/service/MobilePermissionsService.java

@@ -1,16 +0,0 @@
-package com.engine.jygf.service;
-
-import weaver.hrm.User;
-
-import java.util.Map;
-
-/**
- * @Author weaver_cl
- * @Description:
- * @Date 2022/10/9
- * @Version V1.0
- **/
-public interface MobilePermissionsService {
-
-    Map<String, Object> getPermissionInfo(Map<String, Object> params, User user);
-}

src/com/engine/jygf/service/impl/MobilePermissionsServiceImpl.java

@@ -1,24 +0,0 @@
-package com.engine.jygf.service.impl;
-
-import com.engine.core.impl.Service;
-import com.engine.jygf.cmd.MobilePermissionsCmd;
-import com.engine.jygf.service.MobilePermissionsService;
-import weaver.hrm.User;
-
-import java.util.Map;
-
-/**
- * @Author weaver_cl
- * @Description:
- * @Date 2022/10/9
- * @Version V1.0
- **/
-public class MobilePermissionsServiceImpl extends Service implements MobilePermissionsService {
-
-
-
-    @Override
-    public Map<String, Object> getPermissionInfo(Map<String, Object> params, User user) {
-        return commandExecutor.execute(new MobilePermissionsCmd(params,user));
-    }
-}

src/com/engine/jygf/web/MobilePermissionsAction.java

@@ -1,57 +0,0 @@
-package com.engine.jygf.web;
-
-import com.alibaba.fastjson.JSONObject;
-import com.engine.common.util.ParamUtil;
-import com.engine.common.util.ServiceUtil;
-import com.engine.jygf.service.MobilePermissionsService;
-import com.engine.jygf.service.impl.MobilePermissionsServiceImpl;
-import weaver.hrm.HrmUserVarify;
-import weaver.hrm.User;
-
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.ws.rs.GET;
-import javax.ws.rs.Path;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.Context;
-import javax.ws.rs.core.MediaType;
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * @Author weaver_cl
- * @Description:
- * @Date 2022/10/9
- * @Version V1.0
- **/
-public class MobilePermissionsAction {
-
-    public MobilePermissionsService getMobilePermissionsService(User user) {
-        return ServiceUtil.getService(MobilePermissionsServiceImpl.class,user);
-    }
-
-    /**
-     * 晶优光伏 移动电话通过建模控制权限 通讯录显示
-     * @param request
-     * @param response
-     * @return
-     */
-    @GET
-    @Path("/controller")
-    @Produces(MediaType.APPLICATION_JSON)
-    public String getPermissionInfo(@Context HttpServletRequest request, @Context HttpServletResponse response) {
-        Map<String, Object> apidatas = new HashMap<>();
-        try {
-            User user = HrmUserVarify.getUser(request, response);
-            //实例化Service 并调用业务类处理
-            apidatas = getMobilePermissionsService(user).getPermissionInfo(ParamUtil.request2Map(request), user);
-        } catch (Exception e) {
-            //异常处理
-            apidatas.put("api_status", false);
-        }
-        return JSONObject.toJSONString(apidatas);
-    }
-
-
-
-}

src/weaver/interfaces/gsjrkg/action/SyncCertificateAction.java

@@ -1,135 +0,0 @@
-package weaver.interfaces.gsjrkg.action;
-
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
-import weaver.conn.RecordSet;
-import weaver.general.Util;
-import weaver.interfaces.workflow.action.Action;
-import weaver.soa.workflow.request.MainTableInfo;
-import weaver.soa.workflow.request.Property;
-import weaver.soa.workflow.request.RequestInfo;
-
-import java.util.*;
-
-/**
- * @Description: 同步证书到人员卡片个人信息
- * @author:dxfeng
- * @createTime: 2023/02/20
- * @version: 1.0
- */
-public class SyncCertificateAction implements Action {
-    /**
-     * 建模表表名
-     */
-    private String modeTableName;
-
-    /**
-     * 参数名称：建模表字段名：人员表字段名
-     */
-    private String params;
-
-    private String resourceFieldGroup;
-
-    @Override
-    public String execute(RequestInfo requestInfo) {
-        if (StringUtils.isBlank(params)) {
-            requestInfo.getRequestManager().setMessagecontent("自定义接口参数值配置错误");
-            return Action.FAILURE_AND_CONTINUE;
-        }
-        if (StringUtils.isBlank(resourceFieldGroup)) {
-            // -1:基本信息,1:个人信息,3:工作信息
-            resourceFieldGroup = "1";
-        }
-        Map<String, String> fieldMap = new HashMap<>();
-        String[] fieldsArray = params.split(";");
-        for (String fields : fieldsArray) {
-            String[] field = fields.split(":");
-            if (field.length == 2) {
-                fieldMap.put(field[0], field[1]);
-            }
-        }
-        if (fieldMap.size() != fieldsArray.length) {
-            requestInfo.getRequestManager().setMessagecontent("自定义接口参数值格式错误,请检查");
-            return Action.FAILURE_AND_CONTINUE;
-        }
-        Set<String> modeFields = fieldMap.keySet();
-        Map<String, Set<String>> modeMap = new HashMap<>();
-
-        RecordSet rs = new RecordSet();
-        String resourceId = "";
-        MainTableInfo mainTableInfo = requestInfo.getMainTableInfo();
-        Property[] property = mainTableInfo.getProperty();
-        for (Property item : property) {
-            String name = item.getName();
-            String value = Util.null2String(item.getValue());
-            if (StringUtils.isNotBlank(name) && StringUtils.isNotBlank(value)) {
-                if ("xm".equals(name)) {
-                    resourceId = value;
-                }
-            }
-        }
-        // 查询当前人员的所有数据
-        StringBuilder sqlBuilder = new StringBuilder("select ").append(StringUtils.join(modeFields, ",")).append(" from ").append(modeTableName).append(" where xm = ").append(resourceId).append(" order by id");
-        rs.executeQuery(sqlBuilder.toString());
-        while (rs.next()) {
-            appendIds(modeFields, rs, modeMap);
-        }
-        // 判断有无数据，没有的话插入数据
-        sqlBuilder = new StringBuilder("SELECT id FROM CUS_FIELDDATA where scope ='HrmCustomFieldByInfoType' and scopeid = '").append(resourceFieldGroup).append("' and id =? ");
-        rs.executeQuery(sqlBuilder.toString(), resourceId);
-        if (!rs.next()) {
-            // 插入人员信息数据
-            rs.executeUpdate("insert into cus_fielddata (scope,scopeid,id) values ('HrmCustomFieldByInfoType','" + resourceFieldGroup + "',?)", resourceId);
-        }
-        // 组装更新SQL语句
-        sqlBuilder = new StringBuilder("update cus_fielddata set ");
-        for (Map.Entry<String, String> entry : fieldMap.entrySet()) {
-            Set<String> valueSet = modeMap.get(entry.getKey());
-            String values = CollectionUtils.isEmpty(valueSet) ? "" : StringUtils.join(valueSet, ",");
-            sqlBuilder.append(" ").append(entry.getValue()).append(" = '").append(values).append("',");
-        }
-        sqlBuilder.deleteCharAt(sqlBuilder.length() - 1);
-        sqlBuilder.append(" where scope ='HrmCustomFieldByInfoType' and scopeid = ").append(resourceFieldGroup).append(" and id = ").append(resourceId);
-        rs.executeUpdate(sqlBuilder.toString());
-
-        return Action.SUCCESS;
-    }
-
-
-    private void appendIds(Set<String> modeFields, RecordSet rs, Map<String, Set<String>> modeMap) {
-        for (String modeField : modeFields) {
-            String ids = rs.getString(modeField);
-            if (StringUtils.isBlank(ids)) {
-                return;
-            }
-            if (CollectionUtils.isEmpty(modeMap.get(modeField))) {
-                modeMap.put(modeField, new HashSet<>());
-            }
-            modeMap.get(modeField).addAll(Arrays.asList(ids.split(",")));
-        }
-    }
-
-    public String getParams() {
-        return params;
-    }
-
-    public void setParams(String params) {
-        this.params = params;
-    }
-
-    public String getModeTableName() {
-        return modeTableName;
-    }
-
-    public void setModeTableName(String modeTableName) {
-        this.modeTableName = modeTableName;
-    }
-
-    public String getResourceFieldGroup() {
-        return resourceFieldGroup;
-    }
-
-    public void setResourceFieldGroup(String resourceFieldGroup) {
-        this.resourceFieldGroup = resourceFieldGroup;
-    }
-}

src/weaver/interfaces/thwl/action/PersonSingleAddAction.java

@@ -0,0 +1,99 @@
+package weaver.interfaces.thwl.action;
+
+import org.apache.commons.lang3.StringUtils;
+import weaver.conn.RecordSet;
+import weaver.general.BaseBean;
+import weaver.general.Util;
+import weaver.hrm.company.DepartmentComInfo;
+import weaver.interfaces.thwl.action.sdk.AddRequest;
+import weaver.interfaces.thwl.action.sdk.ArtemisUtil;
+import weaver.interfaces.workflow.action.Action;
+import weaver.soa.workflow.request.MainTableInfo;
+import weaver.soa.workflow.request.Property;
+import weaver.soa.workflow.request.RequestInfo;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/08/14
+ * @version: 1.0
+ */
+public class PersonSingleAddAction implements Action {
+    @Override
+    public String execute(RequestInfo requestInfo) {
+        try {
+            MainTableInfo mainTableInfo = requestInfo.getMainTableInfo();
+            Property[] properties = mainTableInfo.getProperty();
+            Map<String, String> mainDataMap = new HashMap<>(16);
+            for (Property property : properties) {
+                mainDataMap.put(property.getName(), property.getValue());
+            }
+
+            String ryid = Util.null2String(mainDataMap.get("ryid"));
+            if (StringUtils.isBlank(ryid)) {
+                requestInfo.getRequestManager().setMessagecontent("未获取到有效的人员ID，请确认");
+                return Action.FAILURE_AND_CONTINUE;
+            }
+
+            RecordSet rs = new RecordSet();
+            rs.executeQuery("select t.departmentid,t.lastname,t.sex,t.birthday,t.mobile,t.certificatenum,t.workcode from hrmresource t where t.id = ? ", ryid);
+            String departmentId = "";
+            String lastName = "";
+            String sex = "";
+            String birthday = "";
+            String mobile = "";
+            String certificateNum = "";
+            String workCode = "";
+            if (rs.next()) {
+                departmentId = rs.getString("departmentid");
+                lastName = rs.getString("lastname");
+                sex = rs.getString("sex");
+                birthday = rs.getString("birthday");
+                mobile = rs.getString("mobile");
+                certificateNum = rs.getString("certificatenum");
+                workCode = rs.getString("workcode");
+            }
+
+            DepartmentComInfo departmentComInfo = new DepartmentComInfo();
+            String departmentMark = departmentComInfo.getDepartmentmark(departmentId);
+            String departmentCode = departmentComInfo.getDepartmentCode(departmentId);
+            if (StringUtils.isBlank(departmentCode)) {
+                requestInfo.getRequestManager().setMessagecontent("未获取到当前人员的部门编号，请确认");
+                return Action.FAILURE_AND_CONTINUE;
+            }
+
+            // 获取组织唯一标识
+            String orgIndexCode = ArtemisUtil.getOrgIndexCode(departmentMark, departmentCode, 1, 10);
+            if (StringUtils.isBlank(orgIndexCode)) {
+                requestInfo.getRequestManager().setMessagecontent("未获取到当前人员部门的组织唯一标识码，请确认");
+                return Action.FAILURE_AND_CONTINUE;
+            }
+
+            // 添加人员
+            AddRequest addRequest = new AddRequest();
+            addRequest.setPersonName(lastName);
+            String gender = "0";
+            if ("0".equals(sex)) {
+                gender = "1";
+            } else if ("1".equals(sex)) {
+                gender = "2";
+            }
+            addRequest.setGender(gender);
+            addRequest.setOrgIndexCode(orgIndexCode);
+            addRequest.setBirthday(birthday);
+            addRequest.setPhoneNo(mobile);
+            addRequest.setCertificateType("111");
+            addRequest.setCertificateNo(certificateNum);
+            addRequest.setJobNo(workCode);
+
+            ArtemisUtil.personSingleAdd(addRequest);
+            return Action.SUCCESS;
+        } catch (Exception e) {
+            requestInfo.getRequestManager().setMessagecontent(e.getMessage());
+            new BaseBean().writeLog(e);
+            return Action.FAILURE_AND_CONTINUE;
+        }
+    }
+}

src/weaver/interfaces/thwl/action/sdk/AddRequest.java

@@ -0,0 +1,101 @@
+package weaver.interfaces.thwl.action.sdk;
+
+import java.util.ArrayList;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/08/14
+ * @version: 1.0
+ */
+public class AddRequest {
+    private String personName;
+    private String gender;
+    private String orgIndexCode;
+    private String birthday;
+    private String phoneNo;
+    private String email;
+    private String certificateType;
+    private String certificateNo;
+    private String jobNo;
+    private ArrayList<Faces> faces;
+
+    public String getPersonName() {
+        return personName;
+    }
+
+    public void setPersonName(String personName) {
+        this.personName = personName;
+    }
+
+    public String getGender() {
+        return gender;
+    }
+
+    public void setGender(String gender) {
+        this.gender = gender;
+    }
+
+    public String getOrgIndexCode() {
+        return orgIndexCode;
+    }
+
+    public void setOrgIndexCode(String orgIndexCode) {
+        this.orgIndexCode = orgIndexCode;
+    }
+
+    public String getBirthday() {
+        return birthday;
+    }
+
+    public void setBirthday(String birthday) {
+        this.birthday = birthday;
+    }
+
+    public String getPhoneNo() {
+        return phoneNo;
+    }
+
+    public void setPhoneNo(String phoneNo) {
+        this.phoneNo = phoneNo;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getCertificateType() {
+        return certificateType;
+    }
+
+    public void setCertificateType(String certificateType) {
+        this.certificateType = certificateType;
+    }
+
+    public String getCertificateNo() {
+        return certificateNo;
+    }
+
+    public void setCertificateNo(String certificateNo) {
+        this.certificateNo = certificateNo;
+    }
+
+    public String getJobNo() {
+        return jobNo;
+    }
+
+    public void setJobNo(String jobNo) {
+        this.jobNo = jobNo;
+    }
+
+    public ArrayList<Faces> getFaces() {
+        return faces;
+    }
+
+    public void setFaces(ArrayList<Faces> faces) {
+        this.faces = faces;
+    }
+}

src/weaver/interfaces/thwl/action/sdk/ArtemisUtil.java

@@ -0,0 +1,184 @@
+package weaver.interfaces.thwl.action.sdk;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.hikvision.artemis.sdk.ArtemisHttpUtil;
+import com.hikvision.artemis.sdk.config.ArtemisConfig;
+import weaver.general.BaseBean;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/08/14
+ * @version: 1.0
+ */
+public class ArtemisUtil {
+    /**
+     * 代理API网关nginx服务器ip端口
+     */
+    private static final String HOST = new BaseBean().getPropValue("artemisSdk", "host");
+    /**
+     * 秘钥appkey
+     */
+    private static final String APP_KEY = new BaseBean().getPropValue("artemisSdk", "appKey");
+    /**
+     * 秘钥appSecret
+     */
+    private static final String APP_SECRET = new BaseBean().getPropValue("artemisSdk", "appSecret");
+
+    private static BaseBean baseBean = new BaseBean();
+
+    /**
+     * 构建config对象
+     *
+     * @return
+     */
+    private static ArtemisConfig getConfig() {
+        ArtemisConfig config = new ArtemisConfig();
+        config.setHost(HOST);
+        config.setAppKey(APP_KEY);
+        config.setAppSecret(APP_SECRET);
+        return config;
+    }
+
+    /**
+     * 人员新增
+     *
+     * @param addRequest
+     * @throws Exception
+     */
+    public static void personSingleAdd(AddRequest addRequest) throws Exception {
+        Map<String, String> path = new HashMap<String, String>(2) {
+            {
+                put("https://", "/artemis/api/resource/v2/person/single/add");
+            }
+        };
+        String body = JSON.toJSONString(addRequest);
+        String response = ArtemisHttpUtil.doPostStringArtemis(getConfig(), path, body, null, null, "application/json");
+        JSONObject jsonObject = JSON.parseObject(response);
+        baseBean.writeLog("body==" + body);
+        baseBean.writeLog("response==" + response);
+        String code = jsonObject.getString("code");
+        String msg = jsonObject.getString("msg");
+        if ("0".equals(code) && "SUCCESS".equalsIgnoreCase(msg)) {
+            return;
+        }
+        throw new RuntimeException(msg);
+    }
+
+    /**
+     * 人员更新
+     *
+     * @param updateRequest
+     * @throws Exception
+     */
+    public static void personSingleUpdate(UpdateRequest updateRequest) throws Exception {
+        Map<String, String> path = new HashMap<String, String>(2) {
+            {
+                put("https://", "/artemis/api/resource/v1/person/single/update");
+            }
+        };
+        String body = JSON.toJSONString(updateRequest);
+        String response = ArtemisHttpUtil.doPostStringArtemis(getConfig(), path, body, null, null, "application/json");
+        baseBean.writeLog("body==" + body);
+        baseBean.writeLog("response==" + response);
+        JSONObject jsonObject = JSON.parseObject(response);
+        String code = jsonObject.getString("code");
+        String msg = jsonObject.getString("msg");
+        if ("0".equals(code) && "SUCCESS".equalsIgnoreCase(msg)) {
+            return;
+        }
+        throw new RuntimeException(msg);
+    }
+
+
+    /**
+     * 获取部门组织唯一标识
+     *
+     * @param departmentMark
+     * @param departmentCode
+     * @param pageNo
+     * @param pageSize
+     * @return
+     * @throws Exception
+     */
+    public static String getOrgIndexCode(String departmentMark, String departmentCode, int pageNo, int pageSize) throws Exception {
+        Map<String, String> path = new HashMap<String, String>(2) {
+            {
+                put("https://", "/artemis/api/resource/v2/org/advance/orgList");
+            }
+        };
+        OrgListRequest orgListRequest = new OrgListRequest();
+        orgListRequest.setOrgName(departmentMark);
+        orgListRequest.setPageNo(pageNo);
+        orgListRequest.setPageSize(pageSize);
+
+        String body = JSON.toJSONString(orgListRequest);
+        String response = ArtemisHttpUtil.doPostStringArtemis(getConfig(), path, body, null, null, "application/json");
+        baseBean.writeLog("departmentCode==" + departmentCode + ",body==" + body);
+        baseBean.writeLog("response==" + response);
+        JSONObject jsonObject = JSON.parseObject(response);
+        String code = jsonObject.getString("code");
+        String msg = jsonObject.getString("msg");
+        if ("0".equals(code) && "SUCCESS".equalsIgnoreCase(msg)) {
+            JSONObject data = jsonObject.getJSONObject("data");
+            JSONArray list = data.getJSONArray("list");
+            // 遍历List 通过部门编号获取组织代码
+            if (list.size() > 0) {
+                for (int i = 0; i < list.size(); i++) {
+                    JSONObject item = list.getJSONObject(i);
+                    if (departmentCode.equals(item.getString("organizationCode"))) {
+                        return item.getString("orgIndexCode");
+                    }
+                }
+                // 当前页未匹配到，获取下一页的数据匹配
+                return getOrgIndexCode(departmentMark, departmentCode, pageNo + 1, pageSize);
+            }
+            // 未匹配到，返回空
+            return "";
+        } else {
+            throw new RuntimeException(msg);
+        }
+    }
+
+
+    /**
+     * 获取人员ID
+     *
+     * @param personInfoRequest
+     * @return
+     */
+    public static String getPersonId(PersonInfoRequest personInfoRequest) throws Exception {
+        Map<String, String> path = new HashMap<String, String>(2) {
+            {
+                put("https://", "/artemis/api/resource/v1/person/condition/personInfo");
+
+            }
+        };
+        String body = JSON.toJSONString(personInfoRequest);
+        String response = ArtemisHttpUtil.doPostStringArtemis(getConfig(), path, body, null, null, "application/json");
+        baseBean.writeLog("body==" + body);
+        baseBean.writeLog("response==" + response);
+        String personId = "";
+        JSONObject jsonObject = JSON.parseObject(response);
+        String code = jsonObject.getString("code");
+        String msg = jsonObject.getString("msg");
+        if ("0".equals(code) && "SUCCESS".equalsIgnoreCase(msg)) {
+            JSONObject data = jsonObject.getJSONObject("data");
+            JSONArray list = data.getJSONArray("list");
+            int total = data.getIntValue("total");
+            if (total > 0) {
+                JSONObject info = list.getJSONObject(0);
+                personId = info.getString("personId");
+            }
+        } else {
+            throw new RuntimeException(msg);
+        }
+        return personId;
+    }
+
+
+}

src/weaver/interfaces/thwl/action/sdk/Faces.java

@@ -0,0 +1,19 @@
+package weaver.interfaces.thwl.action.sdk;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/08/14
+ * @version: 1.0
+ */
+public class Faces {
+    private String faceData;
+
+    public String getFaceData() {
+        return faceData;
+    }
+
+    public void setFaceData(String faceData) {
+        this.faceData = faceData;
+    }
+}
+

src/weaver/interfaces/thwl/action/sdk/OrgListRequest.java

@@ -0,0 +1,89 @@
+package weaver.interfaces.thwl.action.sdk;
+
+import weaver.workflow.ruleDesign.Expressions;
+
+import java.util.ArrayList;
+
+public class OrgListRequest {
+	private String orgName;
+	private String orgIndexCodes;
+	private Integer pageNo;
+	private Integer pageSize;
+	private String parentOrgIndexCodes;
+	private Boolean isSubOrg;
+	private ArrayList<Expressions> expressions;
+	private String orderBy;
+	private String orderType;
+
+	public String getOrgName() {
+		return orgName;
+	}
+
+	public void setOrgName(String orgName) {
+		this.orgName = orgName;
+	}
+
+	public String getOrgIndexCodes() {
+		return orgIndexCodes;
+	}
+
+	public void setOrgIndexCodes(String orgIndexCodes) {
+		this.orgIndexCodes = orgIndexCodes;
+	}
+
+	public Integer getPageNo() {
+		return pageNo;
+	}
+
+	public void setPageNo(Integer pageNo) {
+		this.pageNo = pageNo;
+	}
+
+	public Integer getPageSize() {
+		return pageSize;
+	}
+
+	public void setPageSize(Integer pageSize) {
+		this.pageSize = pageSize;
+	}
+
+	public String getParentOrgIndexCodes() {
+		return parentOrgIndexCodes;
+	}
+
+	public void setParentOrgIndexCodes(String parentOrgIndexCodes) {
+		this.parentOrgIndexCodes = parentOrgIndexCodes;
+	}
+
+	public Boolean getIsSubOrg() {
+		return isSubOrg;
+	}
+
+	public void setIsSubOrg(Boolean isSubOrg) {
+		this.isSubOrg = isSubOrg;
+	}
+
+	public ArrayList<Expressions> getExpressions() {
+		return expressions;
+	}
+
+	public void setExpressions(ArrayList<Expressions> expressions) {
+		this.expressions = expressions;
+	}
+
+	public String getOrderBy() {
+		return orderBy;
+	}
+
+	public void setOrderBy(String orderBy) {
+		this.orderBy = orderBy;
+	}
+
+	public String getOrderType() {
+		return orderType;
+	}
+
+	public void setOrderType(String orderType) {
+		this.orderType = orderType;
+	}
+}

src/weaver/interfaces/thwl/action/sdk/PersonInfoRequest.java

@@ -0,0 +1,25 @@
+package weaver.interfaces.thwl.action.sdk;
+
+import java.util.ArrayList;
+
+public class PersonInfoRequest {
+	private String paramName;
+	private ArrayList<String> paramValue;
+
+	public String getParamName() {
+		return paramName;
+	}
+
+	public void setParamName(String paramName) {
+		this.paramName = paramName;
+	}
+
+	public ArrayList<String> getParamValue() {
+		return paramValue;
+	}
+
+	public void setParamValue(ArrayList<String> paramValue) {
+		this.paramValue = paramValue;
+	}
+}
+

src/weaver/interfaces/thwl/action/sdk/UpdateRequest.java

@@ -0,0 +1,162 @@
+package weaver.interfaces.thwl.action.sdk;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/08/15
+ * @version: 1.0
+ */
+public class UpdateRequest {
+    private String personId;
+    private String personName;
+    private String orgIndexCode;
+    private Integer gender;
+    private String birthday;
+    private String phoneNo;
+    private String email;
+    private String certificateType;
+    private String certificateNo;
+    private String jobNo;
+    private String firstWorkingTime;
+    private String enterTime;
+    private String formalEmpTime;
+    private String empType;
+    private String empLevel;
+    private String workPlace;
+    private String leaveTime;
+
+    public String getPersonId() {
+        return personId;
+    }
+
+    public void setPersonId(String personId) {
+        this.personId = personId;
+    }
+
+    public String getPersonName() {
+        return personName;
+    }
+
+    public void setPersonName(String personName) {
+        this.personName = personName;
+    }
+
+    public String getOrgIndexCode() {
+        return orgIndexCode;
+    }
+
+    public void setOrgIndexCode(String orgIndexCode) {
+        this.orgIndexCode = orgIndexCode;
+    }
+
+    public Integer getGender() {
+        return gender;
+    }
+
+    public void setGender(Integer gender) {
+        this.gender = gender;
+    }
+
+    public String getBirthday() {
+        return birthday;
+    }
+
+    public void setBirthday(String birthday) {
+        this.birthday = birthday;
+    }
+
+    public String getPhoneNo() {
+        return phoneNo;
+    }
+
+    public void setPhoneNo(String phoneNo) {
+        this.phoneNo = phoneNo;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getCertificateType() {
+        return certificateType;
+    }
+
+    public void setCertificateType(String certificateType) {
+        this.certificateType = certificateType;
+    }
+
+    public String getCertificateNo() {
+        return certificateNo;
+    }
+
+    public void setCertificateNo(String certificateNo) {
+        this.certificateNo = certificateNo;
+    }
+
+    public String getJobNo() {
+        return jobNo;
+    }
+
+    public void setJobNo(String jobNo) {
+        this.jobNo = jobNo;
+    }
+
+    public String getFirstWorkingTime() {
+        return firstWorkingTime;
+    }
+
+    public void setFirstWorkingTime(String firstWorkingTime) {
+        this.firstWorkingTime = firstWorkingTime;
+    }
+
+    public String getEnterTime() {
+        return enterTime;
+    }
+
+    public void setEnterTime(String enterTime) {
+        this.enterTime = enterTime;
+    }
+
+    public String getFormalEmpTime() {
+        return formalEmpTime;
+    }
+
+    public void setFormalEmpTime(String formalEmpTime) {
+        this.formalEmpTime = formalEmpTime;
+    }
+
+    public String getEmpType() {
+        return empType;
+    }
+
+    public void setEmpType(String empType) {
+        this.empType = empType;
+    }
+
+    public String getEmpLevel() {
+        return empLevel;
+    }
+
+    public void setEmpLevel(String empLevel) {
+        this.empLevel = empLevel;
+    }
+
+    public String getWorkPlace() {
+        return workPlace;
+    }
+
+    public void setWorkPlace(String workPlace) {
+        this.workPlace = workPlace;
+    }
+
+    public String getLeaveTime() {
+        return leaveTime;
+    }
+
+    public void setLeaveTime(String leaveTime) {
+        this.leaveTime = leaveTime;
+    }
+}

src/weaver/interfaces/thwl/cronjob/PersonSyncUpdateJob.java

@@ -0,0 +1,75 @@
+package weaver.interfaces.thwl.cronjob;
+
+import org.apache.commons.lang3.StringUtils;
+import weaver.common.DateUtil;
+import weaver.conn.RecordSet;
+import weaver.hrm.company.DepartmentComInfo;
+import weaver.hrm.resource.ResourceComInfo;
+import weaver.interfaces.schedule.BaseCronJob;
+import weaver.interfaces.thwl.action.sdk.ArtemisUtil;
+import weaver.interfaces.thwl.action.sdk.PersonInfoRequest;
+import weaver.interfaces.thwl.action.sdk.UpdateRequest;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2024/08/14
+ * @version: 1.0
+ */
+public class PersonSyncUpdateJob extends BaseCronJob {
+    @Override
+    public void execute() {
+        RecordSet rs = new RecordSet();
+        try {
+            String currentDate = DateUtil.getCurrentDate();
+            rs.executeQuery("select ydryxm,drgzbm from formtable_main_176 where dgrq = ? ", currentDate);
+            List<Map<String, String>> personList = new ArrayList<>();
+            while (rs.next()) {
+                Map<String, String> map = new HashMap<>();
+                map.put(rs.getString("ydryxm"), rs.getString("drgzbm"));
+                personList.add(map);
+            }
+            rs.writeLog("人员异动同步任务开始，共查询到异动人员" + personList.size());
+
+            DepartmentComInfo departmentComInfo = new DepartmentComInfo();
+            ResourceComInfo resourceComInfo = new ResourceComInfo();
+            for (Map<String, String> item : personList) {
+                try {
+                    String ydryxm = item.get("ydryxm");
+                    String drgzbm = item.get("drgzbm");
+                    String departmentCode = departmentComInfo.getDepartmentCode(drgzbm);
+                    String departmentMark = departmentComInfo.getDepartmentmark(drgzbm);
+
+                    // 获取组织唯一标识
+                    String orgIndexCode = ArtemisUtil.getOrgIndexCode(departmentMark,departmentCode,1,10);
+
+                    // 获取人员ID
+                    String workCode = resourceComInfo.getWorkcode(ydryxm);
+                    PersonInfoRequest personInfoRequest = new PersonInfoRequest();
+                    personInfoRequest.setParamName("");
+                    ArrayList<String> list = new ArrayList<>();
+                    list.add(workCode);
+                    personInfoRequest.setParamValue(list);
+                    String personId = ArtemisUtil.getPersonId(personInfoRequest);
+                    rs.writeLog("ydryxm==" + ydryxm + ",drgzbm==" + drgzbm + ",workCode==" + workCode + ",personId==" + personId);
+                    if(StringUtils.isBlank(workCode) || StringUtils.isBlank(personId)){
+                        continue;
+                    }
+
+                    UpdateRequest updateRequest = new UpdateRequest();
+                    updateRequest.setPersonId(personId);
+                    updateRequest.setOrgIndexCode(orgIndexCode);
+                    ArtemisUtil.personSingleUpdate(updateRequest);
+                } catch (Exception e) {
+                    rs.writeLog(e);
+                }
+            }
+        } catch (Exception e) {
+            rs.writeLog("人员异动同步失败", e);
+        }
+    }
+}