.gitignore

@@ -1,11 +1,15 @@
 /weaver-develop.iml
 /out/
 .idea/
-/target/
+
+HELP.md
+target/
+
+.idea
+
 /test
 /src/rebel.xml
 /src/META-INF
 /WEB-INF/config
-/log
+
-/src/META-INF/
+/log
-/src/test/

.idea/artifacts/weaver_develop_jar.xml

@@ -0,0 +1,8 @@
+<component name="ArtifactManager">
+  <artifact type="jar" name="weaver-develop:jar">
+    <output-path>$PROJECT_DIR$/out/artifacts/weaver_develop_jar</output-path>
+    <root id="archive" name="weaver-develop.jar">
+      <element id="module-output" name="weaver-develop" />
+    </root>
+  </artifact>
+</component>

.idea/compiler.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="CompilerConfiguration">
+    <annotationProcessing>
+      <profile default="true" name="Default" enabled="true" />
+    </annotationProcessing>
+  </component>
+</project>

.idea/libraries/classbean.xml

@@ -0,0 +1,9 @@
+<component name="libraryTable">
+  <library name="classbean">
+    <CLASSES>
+      <root url="file://$PROJECT_DIR$/../../../../weaver/ecology/classbean" />
+    </CLASSES>
+    <JAVADOC />
+    <SOURCES />
+  </library>
+</component>

.idea/libraries/lib.xml

@@ -0,0 +1,13 @@
+<component name="libraryTable">
+  <library name="lib">
+    <CLASSES>
+      <root url="file://$PROJECT_DIR$/../../../../weaver/ecology/WEB-INF/lib" />
+    </CLASSES>
+    <JAVADOC />
+    <SOURCES>
+      <root url="file://$PROJECT_DIR$/../../../../weaver/ecology/WEB-INF/lib" />
+    </SOURCES>
+    <jarDirectory url="file://$PROJECT_DIR$/../../../../weaver/ecology/WEB-INF/lib" recursive="false" />
+    <jarDirectory url="file://$PROJECT_DIR$/../../../../weaver/ecology/WEB-INF/lib" recursive="false" type="SOURCES" />
+  </library>
+</component>

src/META-INF/MANIFEST.MF

@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Main-Class: test.MainTest
+

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

@@ -0,0 +1,13 @@
+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

@@ -0,0 +1,68 @@
+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 = "field100043"; //移动电话自定义字段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

@@ -0,0 +1,16 @@
+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

@@ -0,0 +1,24 @@
+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

@@ -0,0 +1,57 @@
+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/test/MainTest.java

@@ -0,0 +1,14 @@
+package test;
+
+/**
+ * @Author weaver_cl
+ * @Description:
+ * @Date 2022/10/9
+ * @Version V1.0
+ **/
+public class MainTest {
+
+    public static void main(String[] args) {
+
+    }
+}

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

@@ -0,0 +1,135 @@
+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;
+    }
+}