考勤模块一直日历排班功能页面班次列表接口

.idea/artifacts/weaver_develop_jar.xml

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

src/com/api/jclattendance/web/WorkRulesController.java

@@ -0,0 +1,13 @@
+package com.api.jclattendance.web;
+
+import javax.ws.rs.Path;
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/12/26 6:52 PM
+ * @Description: 班次列表
+ * @Version 1.0
+ */
+@Path("/bs/jcl/workrules")
+public class WorkRulesController extends com.engine.jclattendance.web.WorkRulesController{
+}

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

@@ -0,0 +1,22 @@
+package com.engine.jclattendance.exception;
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/11/16 2:37 PM
+ * @Description: TODO
+ * @Version 1.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/jclattendance/service/WorkRulesService.java

@@ -0,0 +1,21 @@
+package com.engine.jclattendance.service;
+
+import java.util.Map;
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/12/26 6:53 PM
+ * @Description: TODO
+ * @Version 1.0
+ */
+public interface WorkRulesService {
+
+    /**
+     * @Description: 班次列表
+     * @Author: liang.cheng
+     * @Date: 2023/12/26 7:18 PM
+     * @param: [resourceIds]
+     * @return: java.lang.String
+     */
+    Map<String, Object> getWorkRulesList(String resourceIds);
+}

src/com/engine/jclattendance/service/impl/WorkRulesServiceImpl.java

@@ -0,0 +1,64 @@
+package com.engine.jclattendance.service.impl;
+
+import com.cloudstore.eccom.constant.WeaBoolAttr;
+import com.cloudstore.eccom.pc.table.WeaTable;
+import com.cloudstore.eccom.pc.table.WeaTableColumn;
+import com.cloudstore.eccom.pc.table.WeaTableType;
+import com.cloudstore.eccom.result.WeaResultMsg;
+import com.engine.core.impl.Service;
+import com.engine.jclattendance.service.WorkRulesService;
+import weaver.conn.RecordSet;
+import weaver.conn.constant.DBConstant;
+import weaver.general.PageIdConst;
+import weaver.systeminfo.SystemEnv;
+
+import java.util.HashMap;
+import java.util.Map;
+
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/12/26 6:54 PM
+ * @Description: TODO
+ * @Version 1.0
+ */
+public class WorkRulesServiceImpl extends Service implements WorkRulesService {
+    @Override
+    public Map<String, Object> getWorkRulesList(String resourceIds) {
+        Map<String, Object> resultMap = new HashMap<>(4);
+
+        WeaTable table = new WeaTable();
+        String pageId = "ba1c29c23a8a46d9acff1d2ee4ff5fb3";
+        table.setPageID(pageId);
+        table.setPageUID(String.format("%s_%s",pageId,user.getUID()));
+        String pageSize = PageIdConst.getPageSize(pageId, user.getUID());
+        table.setPagesize(pageSize);
+        RecordSet rs=new RecordSet();
+        String fields = "t.id, t.mc,t.jc,t.ys,CONCAT(kssj, '-', jssj) as bcsj";
+        if(DBConstant.DB_TYPE_SQLSERVER.equalsIgnoreCase(rs.getDBType())){
+            fields = "t.id, t.mc,t.jc,t.ys,kssj + '-' + jssj as bcsj";
+        }
+        table.setBackfields(fields);
+
+        String fromSql = " from uf_jcl_kq_bcxx t";
+        table.setSqlform(fromSql);
+
+        String sqlWhere = " where 1=1 and t.attendance_organization in ("+resourceIds+")";
+        table.setSqlwhere(sqlWhere);
+
+        table.setSqlprimarykey("id");
+        table.getColumns().add(new WeaTableColumn("id").setDisplay(WeaBoolAttr.FALSE));
+        table.getColumns().add(new WeaTableColumn("20%", "班次名称", "mc"));
+        table.getColumns().add(new WeaTableColumn("20%", "简称", "jc"));
+        table.getColumns().add(new WeaTableColumn("20%", "颜色", "ys"));
+        table.getColumns().add(new WeaTableColumn("40%", "班次时间", "bcsj"));
+
+        table.setTableType(WeaTableType.RADIO);
+
+        WeaResultMsg result = new WeaResultMsg(false);
+        result.putAll(table.makeDataResult());
+        result.success();
+        resultMap.putAll(result.getResultMap());
+        return resultMap;
+    }
+}

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

@@ -0,0 +1,20 @@
+package com.engine.jclattendance.util;
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/11/16 2:37 PM
+ * @Description: TODO
+ * @Version 1.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/jclattendance/util/ResponseResult.java

@@ -0,0 +1,184 @@
+package com.engine.jclattendance.util;
+
+
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.engine.core.exception.ECException;
+import com.engine.jclattendance.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;
+
+
+@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 = getJsonString(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/com/engine/jclattendance/web/WorkRulesController.java

@@ -0,0 +1,42 @@
+package com.engine.jclattendance.web;
+
+import com.engine.common.util.ServiceUtil;
+import com.engine.jclattendance.service.WorkRulesService;
+import com.engine.jclattendance.service.impl.WorkRulesServiceImpl;
+import com.engine.jclattendance.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.QueryParam;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.MediaType;
+import java.util.Map;
+
+/**
+ * @Author liang.cheng
+ * @Date 2023/12/26 6:52 PM
+ * @Description: TODO
+ * @Version 1.0
+ */
+public class WorkRulesController {
+
+    private WorkRulesService getReportCollectService(User user) {
+        return ServiceUtil.getService(WorkRulesServiceImpl.class,user);
+    }
+
+
+    @GET
+    @Path("/list")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String getWorkRulesList(@Context HttpServletRequest request, @Context HttpServletResponse response,
+                                    @QueryParam("resourceIds") String resourceIds) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<String, Map<String, Object>>(user).run(getReportCollectService(user) :: getWorkRulesList,resourceIds);
+    }
+
+}

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) {
-
-    }
-}