添加钉钉接口相关

attendance-performance-manager/src/main/java/com/mortals/xhx/common/key/RedisKey.java

@@ -9,18 +9,11 @@ public class RedisKey {
      * 登录  key
      */
     public static final String KEY_MENU_CACHE = "iot:base:MenuCacheKey:";
-    /**
-     * 设备心跳上报
-     */
-    public static final String KEY_DEVICE_ONLINE_CACHE = "device:online:";
-
-
 
-    public static final String KEY_SITE_CACHE = "siteDict";
 
-    public static final String KEY_PLATFORM_CACHE = "platformDict";
-
-    public static final String KEY_PRODUCT_CACHE = "productDict";
+    /**
+     * 钉钉 访问token
+     */
+    public static final String KEY_DINGTALK_ACCESSTOKEN_CACHE = "dingtalk:token:";
 
-    public static final String KEY_TOKEN_API_CACHE = "token:api:";
 }

attendance-performance-manager/src/main/java/com/mortals/xhx/module/check/service/impl/CheckReviewRecordServiceImpl.java

@@ -83,9 +83,9 @@ public class CheckReviewRecordServiceImpl extends AbstractCRUDServiceImpl<CheckR
                     msg.setMsgtype("link");
                     Link link = new Link();
                     link.setPicUrl("测试图片链接");
-                    link.setMessageUrl("测试消息链接");
-                    link.setText("测试文本");
-                    link.setTitle("测试标题");
+                    link.setMessageUrl("http://www.baidu.com");
+                    link.setText("你有一条绩效考核核查通知，请及时查看！");
+                    link.setTitle("绩效考核核查通知");
                     msg.setLink(link);
 
                     workMsgReq.setUseridList(personRest.getMsg());

attendance-performance-manager/src/main/java/com/mortals/xhx/module/dingding/AbstractDingTalkService.java

@@ -7,9 +7,12 @@ import com.dingtalk.api.response.OapiGettokenResponse;
 import com.hikvision.artemis.sdk.config.ArtemisConfig;
 import com.mortals.framework.common.Rest;
 import com.mortals.framework.exception.AppException;
+import com.mortals.framework.service.ICacheService;
+import com.mortals.xhx.common.key.RedisKey;
 import com.mortals.xhx.common.pdu.ApiRespPdu;
 import com.mortals.xhx.module.dingding.personal.service.IDingPersonService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.util.ObjectUtils;
 
@@ -32,7 +35,7 @@ public abstract class AbstractDingTalkService implements IDingPersonService {
     protected Long agentId;
 
     /**
-     * AgentId
+     * domain
      */
     @Value("${dingtalk.domain:https://oapi.dingtalk.com}")
     protected String domain;
@@ -49,43 +52,38 @@ public abstract class AbstractDingTalkService implements IDingPersonService {
     @Value("${dingtalk.AppSecret:''}")
     protected String appSecret;
 
-    /**
-     * getToken
-     */
-    @Value("${dingtalk.gettoken:https://oapi.dingtalk.com/gettoken}")
-    protected String getTokneUrl;
-
-    protected String dingToken;
+    @Autowired
+    private ICacheService cacheService;
 
     protected DingTalkClient getDingTalkClient(String path) {
         DingTalkClient client = new DefaultDingTalkClient(domain + path);
         return client;
     }
 
-    protected void checkToken() {
-        if (ObjectUtils.isEmpty(dingToken)) {
-            dingToken = getToken().getData();
-        }
-    }
 
     @Override
-    public Rest<String> getToken() {
+    public String getToken() {
         try {
+            String dingToken = cacheService.get(RedisKey.KEY_DINGTALK_ACCESSTOKEN_CACHE);
+            if (ObjectUtils.isEmpty(dingToken)) {
                 DingTalkClient client = getDingTalkClient("/gettoken");
                 OapiGettokenRequest req = new OapiGettokenRequest();
                 req.setAppkey(appKey);
                 req.setAppsecret(appSecret);
                 OapiGettokenResponse rsp = client.execute(req);
-            log.info("OapiGettokenResponse:{}",rsp.getBody());
+                log.info("OapiGettokenResponse:{}", rsp.getBody());
                 if (rsp.getErrcode() == 0) {
-                return Rest.ok(rsp.getAccessToken());
+                    cacheService.setex(RedisKey.KEY_DINGTALK_ACCESSTOKEN_CACHE, rsp.getAccessToken(), 4800);
+                    return rsp.getAccessToken();
                 } else {
-                throw new AppException(rsp.getMessage());
+                    throw new AppException(String.format("code:{},errorMsg:{}", rsp.getErrcode(), rsp.getErrmsg()));
+                }
+            } else {
+                return dingToken;
             }
-
         } catch (Exception e) {
             log.error("获取TOKEN异常", e);
-            return Rest.fail(e.getMessage());
+            throw new AppException(e.getMessage());
         }
     }
 

attendance-performance-manager/src/main/java/com/mortals/xhx/module/dingding/IDingTalkService.java

@@ -3,5 +3,5 @@ package com.mortals.xhx.module.dingding;
 import com.mortals.framework.common.Rest;
 
 public interface IDingTalkService {
-    Rest<String> getToken();
+    String getToken();
 }

attendance-performance-manager/src/main/java/com/mortals/xhx/module/dingding/personal/service/impl/DingPersonServiceImpl.java

@@ -24,11 +24,10 @@ public class DingPersonServiceImpl extends AbstractDingTalkService implements ID
     public Rest<String> getPersonByMobile(String mobile) {
         try {
             DingTalkClient client = getDingTalkClient("/topapi/v2/user/getbymobile");
-            checkToken();
             OapiV2UserGetbymobileRequest req = new OapiV2UserGetbymobileRequest();
             req.setMobile(mobile);
             log.info("getPersonByMobile:{}",mobile);
-            OapiV2UserGetbymobileResponse rsp = client.execute(req, dingToken);
+            OapiV2UserGetbymobileResponse rsp = client.execute(req, getToken());
             log.info("OapiV2UserGetbymobileResponse:{}",rsp.getBody());
             if (rsp.getErrcode() == 0) {
                 return Rest.ok(rsp.getResult().getUserid());
@@ -45,13 +44,13 @@ public class DingPersonServiceImpl extends AbstractDingTalkService implements ID
     public Rest<String> sendWorkMsg(WorkMsgReq workMsgReq) {
         try {
             DingTalkClient client = getDingTalkClient("/topapi/message/corpconversation/asyncsend_v2");
-            checkToken();
+
             OapiMessageCorpconversationAsyncsendV2Request req = new OapiMessageCorpconversationAsyncsendV2Request();
             req.setAgentId(agentId);
             req.setUseridList(workMsgReq.getUseridList());
             req.setMsg(JSON.toJSONString(workMsgReq.getMsg()));
             log.info("sendWorkMsg:{}", JSON.toJSONString(workMsgReq));
-            OapiMessageCorpconversationAsyncsendV2Response rsp = client.execute(req, dingToken);
+            OapiMessageCorpconversationAsyncsendV2Response rsp = client.execute(req, getToken());
             log.info("OapiMessageResponse:{}",rsp.getBody());
             if (rsp.getErrcode() == 0) {
                 return Rest.ok(rsp.getMsg(), rsp.getRequestId());

attendance-performance-manager/src/main/java/com/mortals/xhx/module/perform/model/PerformAttendAppealEntity.java

@@ -11,11 +11,11 @@ import com.mortals.xhx.module.perform.model.vo.PerformAttendAppealVo;
 import com.mortals.xhx.module.perform.model.PerformAttendAppealFilesEntity;
 import lombok.Data;
 /**
-* 绩效记录申诉信息实体对象
-*
-* @author zxfei
-* @date 2023-07-12
-*/
+ * 绩效记录申诉信息实体对象
+ *
+ * @author zxfei
+ * @date 2023-07-15
+ */
 @Data
 public class PerformAttendAppealEntity extends PerformAttendAppealVo {
     private static final long serialVersionUID = 1L;
@@ -235,6 +235,15 @@ public class PerformAttendAppealEntity extends PerformAttendAppealVo {
      * 绩效类型【attend:考勤绩效,review:评价差评绩效,complain:评价投诉绩效,gowork:办件绩效,effect:效能绩效,other:其它绩效】
      */
     private String performType;
+    /**
+     * 扣分人员
+     */
+    @Excel(name = "扣分人员")
+    private String deductPerson;
+    /**
+     * 扣分时间
+     */
+    private Date deductTime;
     /**
      * 绩效记录申诉附件信息信息
      */
@@ -363,5 +372,9 @@ public class PerformAttendAppealEntity extends PerformAttendAppealVo {
         this.irregularOtherType = -1;
 
         this.performType = "";
+
+        this.deductPerson = "";
+
+        this.deductTime = null;
     }
 }
\ No newline at end of file

attendance-performance-manager/src/main/java/com/mortals/xhx/module/perform/model/PerformAttendAppealQuery.java

@@ -6,11 +6,11 @@ import java.util.Date;
 import java.util.List;
 import com.mortals.xhx.module.perform.model.PerformAttendAppealEntity;
 /**
-* 绩效记录申诉信息查询对象
-*
-* @author zxfei
-* @date 2023-07-12
-*/
+ * 绩效记录申诉信息查询对象
+ *
+ * @author zxfei
+ * @date 2023-07-15
+ */
 public class PerformAttendAppealQuery extends PerformAttendAppealEntity {
     /** 开始 序号，主键，自增长 */
     private Long idStart;
@@ -469,6 +469,17 @@ public class PerformAttendAppealQuery extends PerformAttendAppealEntity {
 
     /** 绩效类型【attend:考勤绩效,review:评价差评绩效,complain:评价投诉绩效,gowork:办件绩效,effect:效能绩效,other:其它绩效】排除列表 */
     private List <String> performTypeNotList;
+    /** 扣分人员 */
+    private List<String> deductPersonList;
+
+    /** 扣分人员排除列表 */
+    private List <String> deductPersonNotList;
+    /** 开始 扣分时间 */
+    private String deductTimeStart;
+
+    /** 结束 扣分时间 */
+    private String deductTimeEnd;
+
     /** OR条件集合，列表项之间是OR，项内容之间是AND，如：(list[0].1 and list[0].2) or (list[1].3 and list[1].4) */
     private List<PerformAttendAppealQuery> orConditionList;
 
@@ -3070,6 +3081,70 @@ public class PerformAttendAppealQuery extends PerformAttendAppealEntity {
         this.performTypeNotList = performTypeNotList;
     }
 
+    /**
+     * 获取 扣分人员
+     * @return deductPersonList
+     */
+    public List<String> getDeductPersonList(){
+        return this.deductPersonList;
+    }
+
+    /**
+     * 设置 扣分人员
+     * @param deductPersonList
+     */
+    public void setDeductPersonList(List<String> deductPersonList){
+        this.deductPersonList = deductPersonList;
+    }
+
+    /**
+     * 获取 扣分人员
+     * @return deductPersonNotList
+     */
+    public List<String> getDeductPersonNotList(){
+        return this.deductPersonNotList;
+    }
+
+    /**
+     * 设置 扣分人员
+     * @param deductPersonNotList
+     */
+    public void setDeductPersonNotList(List<String> deductPersonNotList){
+        this.deductPersonNotList = deductPersonNotList;
+    }
+
+    /**
+     * 获取 开始 扣分时间
+     * @return deductTimeStart
+     */
+    public String getDeductTimeStart(){
+        return this.deductTimeStart;
+    }
+
+    /**
+     * 设置 开始 扣分时间
+     * @param deductTimeStart
+     */
+    public void setDeductTimeStart(String deductTimeStart){
+        this.deductTimeStart = deductTimeStart;
+    }
+
+    /**
+     * 获取 结束 扣分时间
+     * @return deductTimeEnd
+     */
+    public String getDeductTimeEnd(){
+        return this.deductTimeEnd;
+    }
+
+    /**
+     * 设置 结束 扣分时间
+     * @param deductTimeEnd
+     */
+    public void setDeductTimeEnd(String deductTimeEnd){
+        this.deductTimeEnd = deductTimeEnd;
+    }
+
     /**
      * 设置  序号，主键，自增长
      * @param id
@@ -4494,6 +4569,26 @@ public class PerformAttendAppealQuery extends PerformAttendAppealEntity {
         return this;
     }
 
+
+    /**
+     * 设置 扣分人员
+     * @param deductPerson
+     */
+    public PerformAttendAppealQuery deductPerson(String deductPerson){
+        setDeductPerson(deductPerson);
+        return this;
+    }
+
+    /**
+     * 设置 扣分人员
+     * @param deductPersonList
+     */
+    public PerformAttendAppealQuery deductPersonList(List<String> deductPersonList){
+        this.deductPersonList = deductPersonList;
+        return this;
+    }
+
+
     /**
      * 获取 OR条件集合，列表项之间是OR，项内容之间是AND，如：(list[0].1 and list[0].2) or (list[1].3 and list[1].4)
      * @return orConditionList

db/add.sql

@@ -641,3 +641,12 @@ CREATE TABLE mortals_xhx_staff_perform_summary(
 PRIMARY KEY  (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='员工绩效统计';
 
+
+-- ----------------------------
+2023-7-15
+-- ----------------------------
+
+
+ALTER TABLE mortals_xhx_perform_attend_appeal ADD COLUMN `deductPerson` varchar(128)      COMMENT '扣分人员' AFTER subMethod;
+ALTER TABLE mortals_xhx_perform_attend_appeal ADD COLUMN  `deductTime` datetime      COMMENT '扣分时间' AFTER deductPerson;
+