From 2da61bee0bf3de8b82bc0a15b2341f7a418a5b19 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=9D=96?= Date: Mon, 13 May 2024 09:34:20 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=8E=E6=B3=9B=E5=BE=AE=E5=90=8C=E6=AD=A5?= =?UTF-8?q?=E4=BA=BA=E5=91=98=E4=BF=A1=E6=81=AF0.1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../shkd/cosmic/cxkg/task/UserTaskImpl.java | 114 ++++++++++++++++++ 1 file changed, 114 insertions(+) create mode 100644 shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/task/UserTaskImpl.java diff --git a/shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/task/UserTaskImpl.java b/shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/task/UserTaskImpl.java new file mode 100644 index 0000000..8d47b90 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/task/UserTaskImpl.java @@ -0,0 +1,114 @@ +package shkd.cosmic.cxkg.task; + +import cn.hutool.http.HttpRequest; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import kd.bos.context.RequestContext; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.exception.KDException; +import kd.bos.permission.model.UserParam; +import kd.bos.schedule.executor.AbstractTask; +import kd.bos.service.ServiceFactory; + +import kd.bos.servicehelper.QueryServiceHelper; +import kd.bos.servicehelper.user.UserServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import shkd.cosmic.cxkg.task.DTO.Query; +import shkd.cosmic.cxkg.task.DTO.QueryDTO; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * + * + */ +public class UserTaskImpl extends AbstractTask { + + private static final int PAGESIZE = 20; + private int CURPAGE = 1; + private DynamicObjectCollection queryOrges; + + @Override + public void execute(RequestContext requestContext, Map map) throws KDException { + DynamicObjectCollection queryOrges = QueryServiceHelper.query("bos_adminorg", + "id,number,shkd_oaid", null);//查询星瀚系统部门集合 + Map orgIds = new HashMap();//存放系统中已经存在的用户id集合 + for (DynamicObject queryOrg : queryOrges) { + orgIds.put(queryOrg.getString("number"), (queryOrg.getLong("id") + ""));//存放已经存在的部门的id以及oaid + } + + //bos_base_user_syn_weaver2kd + QueryDTO queryDTO = new QueryDTO(); + queryDTO.setCurpage(4); + queryDTO.setPagesize(1); + Query query = new Query(); + query.setQueryDTO(queryDTO); + String requestBody = JSON.toJSONString(query); + String jsonResponse = HttpRequest.post("http://" + "10.157.226.9:8088" + "/api/hrm/resful/getHrmUserInfoWithPage") + .body(requestBody).timeout(20000) //20s 超时 + .execute().body(); + JSONObject resultJson = JSONObject.parseObject(jsonResponse); + JSONArray dataList = resultJson.getJSONObject("data").getJSONArray("dataList"); + + List paramList = new ArrayList<>(); + UserParam user = null; + for (int i = 0; i < dataList.size(); i++) { + JSONObject userData = dataList.getJSONObject(i); + System.out.println(i + "-----------" + userData); + user = new UserParam(); + // user.setCustomUserId(123456780L); + Map dataMap = new HashMap<>(); + dataMap.put("number", userData.getString("workcode")); //工号 + dataMap.put("name", userData.getString("lastname")); // 姓名 + dataMap.put("username", userData.getString("loginid")); //用户名 + dataMap.put("usertype", "1"); + dataMap.put("phone", userData.getString("mobile")); + dataMap.put("email", userData.getString("email")); + // dataMap.put("idcard", userData.getString("certificatenum")); //身份证 + dataMap.put("birthday", userData.getString("birthday")); + dataMap.put("gender", userData.getString("sex")); //int + // dataMap.put("picturefield", ""); //头像 + + // 职位分录 + List> posList = new ArrayList<>(); + Map entryentity = new HashMap<>(); + // 设置部门ID + entryentity.put("dpt", orgIds.get(userData.getString("departmentcode"))); // 部门 + entryentity.put("position", userData.getString("jobactivityname")); // 职位 + //entryentity.put("isincharge", false); //负责人 + //entryentity.put("ispartjob", false); //兼职 + entryentity.put("superior", userData.getString("managerid")); // 直接上级 + entryentity.put("seq", 1); + posList.add(entryentity); + + dataMap.put("entryentity", posList); + user.setDataMap(dataMap); + user.setCustomUserId(userData.getInteger("id")); + // user.setId(293); + paramList.add(user); + } + + // 业务调用可以参照接口名，以下举例说明微服务调用方式 + // IUserService userService = (IUserService) ServiceFactory.getService(IUserService.class); + //kd.bos.servicehelper.user.UserServiceHelper.addOrUpdate(List userList) + // userService.addOrUpdate(paramList); + UserServiceHelper.addOrUpdate(paramList); + // SaveServiceHelper.save(); + + + List paramList2 = new ArrayList<>(); + // 判断执行结果 + for (UserParam result : paramList) { + if (!result.isSuccess()) { + // + System.out.println(result.getId() + "-----------" + result.getMsg()); + paramList2.add(result); + } + } + } +}