#3529304 薪酬相关流程及应用的建模加密设置

.gitignore

@@ -1,15 +1,17 @@
-/weaver-develop.iml
+/weaver-hrm-organization.iml
 /out/
-.idea/
+/.idea/
 
 HELP.md
 target/
 
+### IntelliJ IDEA ###
 .idea
 
-/test
+/src/test
 /src/rebel.xml
 /src/META-INF
-/WEB-INF/config
 
-/log
+/log
+
+/weaver-develop.iml

.idea/artifacts/weaver_develop_jar.xml

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

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

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

.idea/libraries/lib.xml

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

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

src/com/api/liante/controller/WorkflowFieldController.java

@@ -0,0 +1,12 @@
+package com.api.liante.controller;
+
+import javax.ws.rs.Path;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2025/02/07
+ * @version: 1.0
+ */
+@Path("/jcl/liante/workflowfield")
+public class WorkflowFieldController extends com.engine.liante.controller.WorkflowFieldController{
+}

src/com/engine/liante/controller/WorkflowFieldController.java

@@ -0,0 +1,38 @@
+package com.engine.liante.controller;
+
+import com.engine.common.util.ParamUtil;
+import com.engine.common.util.ServiceUtil;
+import com.engine.liante.service.WorkflowFieldService;
+import com.engine.liante.service.impl.WorkflowFieldServiceImpl;
+import com.engine.liante.util.ResponseResult;
+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.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2025/02/07
+ * @version: 1.0
+ */
+public class WorkflowFieldController {
+    private WorkflowFieldService getWorkflowFieldService(User user) {
+        return ServiceUtil.getService(WorkflowFieldServiceImpl.class, user);
+    }
+
+    @GET
+    @Path("/getSalaryStandards")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String getSalaryStandards(@Context HttpServletRequest request, @Context HttpServletResponse response) {
+        User user = HrmUserVarify.getUser(request, response);
+        Map<String, Object> params = ParamUtil.request2Map(request);
+        return new ResponseResult<Map<String, Object>, Map<String, Object>>(user).run(getWorkflowFieldService(user)::getSalaryStandards, params);
+    }
+}

src/com/engine/liante/exception/CustomizeRunTimeException.java

@@ -0,0 +1,22 @@
+package com.engine.liante.exception;
+
+/**
+ * @Author weaver_cl
+ * @Description:
+ * @Date 2023/2/21
+ * @Version V1.0
+ **/
+public class CustomizeRunTimeException extends RuntimeException{
+
+    public CustomizeRunTimeException(String message) {
+        super(message);
+    }
+
+    public CustomizeRunTimeException(Throwable cause) {
+        super(cause);
+    }
+
+    public CustomizeRunTimeException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

src/com/engine/liante/service/WorkflowFieldService.java

@@ -0,0 +1,18 @@
+package com.engine.liante.service;
+
+import java.util.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2025/02/07
+ * @version: 1.0
+ */
+public interface WorkflowFieldService {
+    /**
+     * 获取薪资标准
+     *
+     * @param params
+     * @return
+     */
+    Map<String, Object> getSalaryStandards(Map<String, Object> params);
+}

src/com/engine/liante/service/impl/WorkflowFieldServiceImpl.java

@@ -0,0 +1,42 @@
+package com.engine.liante.service.impl;
+
+import com.engine.core.impl.Service;
+import com.engine.liante.service.WorkflowFieldService;
+import org.apache.commons.lang3.StringUtils;
+import weaver.conn.RecordSet;
+import weaver.general.Util;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author:dxfeng
+ * @createTime: 2025/02/07
+ * @version: 1.0
+ */
+public class WorkflowFieldServiceImpl extends Service implements WorkflowFieldService {
+    @Override
+    public Map<String, Object> getSalaryStandards(Map<String, Object> params) {
+
+        Map<String, Object> dataMap = new HashMap<>();
+        String id = Util.null2String(params.get("id"));
+        String tableName = Util.null2String(params.get("tableName"));
+        String relateField = Util.null2String(params.get("relateField"));
+        if(StringUtils.isBlank(relateField)){
+            relateField="id";
+        }
+        String fields = Util.null2String(params.get("fields"));
+        if (StringUtils.isBlank(id) || StringUtils.isBlank(tableName) || StringUtils.isBlank(fields)) {
+            return dataMap;
+        }
+        RecordSet rs = new RecordSet();
+        rs.executeQuery("select " + fields + " from " + tableName + " where " + relateField + " = ?", id);
+        if (rs.next()) {
+            String[] split = fields.split(",");
+            for (String field : split) {
+                dataMap.put(field, rs.getString(tableName,field,true,true));
+            }
+        }
+            return dataMap;
+    }
+}

src/com/engine/liante/util/ExceptionUtil.java

@@ -0,0 +1,20 @@
+package com.engine.liante.util;
+
+/**
+ * @Author weaver_cl
+ * @Description:
+ * @Date 2023/2/21
+ * @Version V1.0
+ **/
+public class ExceptionUtil {
+    public static String getRealMessage(Throwable e) {
+        while (e != null) {
+            Throwable cause = e.getCause();
+            if (cause == null) {
+                return e.getMessage();
+            }
+            e = cause;
+        }
+        return "";
+    }
+}

src/com/engine/liante/util/ResponseResult.java

@@ -0,0 +1,192 @@
+package com.engine.liante.util;
+
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.engine.core.exception.ECException;
+import com.engine.liante.exception.CustomizeRunTimeException;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.extern.slf4j.Slf4j;
+import weaver.general.BaseBean;
+import weaver.hrm.User;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Supplier;
+
+/**
+ * 请求执行器
+ * <p>Copyright: Copyright (c) 2022</p>
+ * <p>Company: 泛微软件</p>
+ *
+ * @author qiantao
+ * @version 1.0
+ **/
+@Slf4j
+public class ResponseResult<T, R> {
+
+    private static final long serialVersionUID = 1L;
+
+    private final User user;
+
+    private final BaseBean baseBean = new BaseBean();
+
+    private final Boolean isLog = "true".equals(baseBean.getPropValue("hrmSalary", "log"));
+
+    public ResponseResult(User user) {
+        this.user = user;
+    }
+
+    /**
+     * 统一返回方法(自定义返回格式)
+     */
+    public String customRun(Function<T, R> f, T t) {
+        try {
+            if (isLog) {
+                log.info("run api , param {}", t);
+            }
+            return getJsonString(f.apply(t));
+        } catch (CustomizeRunTimeException e) {
+            log.error("api run fail", e);
+            return Error(e.getMessage());
+        } catch (ECException e) {
+            log.error("api run fail", e);
+            Throwable cause = e.getCause();
+            return Error(cause.getMessage());
+        } catch (Exception e) {
+            log.error("api run fail", e);
+            return Error("系统异常!");
+        }
+    }
+
+    /**
+     * 统一返回方法
+     */
+    public String run(Function<T, R> f, T t) {
+        try {
+            if (isLog) {
+                log.info("run api , param {}", t);
+            }
+            return Ok(f.apply(t));
+        } catch (CustomizeRunTimeException e) {
+            log.error("api run fail", e);
+            return Error(e.getMessage());
+        } catch (ECException e) {
+            log.error("api run fail", e);
+            Throwable cause = e.getCause();
+            return Error(cause.getMessage());
+        } catch (Exception e) {
+            log.error("api run fail", e);
+            return Error("系统异常!");
+        }
+    }
+
+    /**
+     * 统一返回方法（有参无返回）
+     */
+    public String run(Consumer<T> f, T t) {
+        try {
+            if (isLog) {
+                log.info("run api , param {}", t);
+            }
+            f.accept(t);
+            return Ok();
+        } catch (CustomizeRunTimeException e) {
+            log.error("api run fail", e);
+            return Error(e.getMessage());
+        } catch (ECException e) {
+            log.error("api run fail", e);
+            return Error(ExceptionUtil.getRealMessage(e));
+        } catch (Exception e) {
+            log.error("api run fail", e);
+            return Error("系统异常!", e);
+        }
+    }
+
+
+    /**
+     * 统一返回方法（无参有返回）
+     */
+    public String run(Supplier<R> f) {
+        try {
+            if (isLog) {
+                log.info("run api");
+            }
+            return Ok(f.get());
+        } catch (CustomizeRunTimeException e) {
+            log.error("api run fail", e);
+            return Error(e.getMessage());
+        } catch (ECException e) {
+            log.error("api run fail", e);
+            Throwable cause = e.getCause();
+            return Error(cause.getMessage());
+        } catch (Exception e) {
+            log.error("api run fail", e);
+            return Error("系统异常!", e);
+        }
+    }
+
+
+    private static String getJsonString(Object apidatas) {
+        ObjectMapper mapper = new ObjectMapper();
+        try {
+            return mapper.writeValueAsString(apidatas);
+        } catch (JsonProcessingException e) {
+            e.printStackTrace();
+        }
+        return "";
+    }
+
+
+    /**
+     * 成功返回
+     */
+    private String Ok() {
+        Map<String, Object> apidatas = new HashMap<>();
+        apidatas.put("api_status", true);
+        return JSONObject.toJSONString(apidatas, SerializerFeature.DisableCircularReferenceDetect);
+    }
+
+
+    /**
+     * 成功返回
+     */
+    private String Ok(R r) {
+        Map<String, Object> apidatas = new HashMap<>();
+        apidatas.put("api_status", true);
+        apidatas.put("data", r);
+        String success = JSON.toJSONString(apidatas);
+        if (isLog) {
+            log.info("run salary api success return {}", success);
+        }
+        return success;
+    }
+
+
+    /**
+     * 失败返回
+     */
+    private static String Error(String message) {
+        Map<String, Object> apidatas = new HashMap<>();
+        apidatas.put("api_status", false);
+        apidatas.put("errormsg", message);
+        return JSONObject.toJSONString(apidatas, SerializerFeature.DisableCircularReferenceDetect);
+    }
+
+
+    /**
+     * 系统异常失败返回
+     */
+    private static String Error(String message, Exception e) {
+        Map<String, Object> apidatas = new HashMap<>();
+        apidatas.put("api_status", false);
+        apidatas.put("errormsg", message);
+        apidatas.put("error", e.getMessage());
+        return JSONObject.toJSONString(apidatas, SerializerFeature.DisableCircularReferenceDetect);
+    }
+
+}

src/test/MainTest.java

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