消息提醒修改

yifu-common/yifu-common-core/src/main/java/com/yifu/cloud/plus/v1/yifu/common/core/constant/CacheConstants.java

@@ -163,4 +163,6 @@ public interface CacheConstants {
 	String EMP_ADD_LOCK ="emp_add_lock";
 
 	String FUND_IMPORT_HANDLE_LOCK = "fund_import_handle_handle_lock";
+
+	public static final String WX_ACCOSS_TOKEN = "WX_ACCOSS_TOKEN";
 }

yifu-common/yifu-common-core/src/main/java/com/yifu/cloud/plus/v1/yifu/common/core/constant/SecurityConstants.java

@@ -124,4 +124,21 @@ public interface SecurityConstants {
 	 */
 	String CLIENT_ID = "clientId";
 
+
+	/**
+	 * @Author: huyc
+	 * @Date: 2023/7/28
+	 * @Description:  企业微信获取access_token
+	 * @return:
+	 **/
+	String WX_GET_ACCOSS_TOKEN="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=%s&corpsecret=%s";
+
+	/**
+	 * @Author: huyc
+	 * @Date: 2023/7/28
+	 * @Description: 企业微信发送消息
+	 * @return:
+	 **/
+	String WX_SEND_MESSAGE = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=%s";
+
 }

yifu-msg/yifu-msg-api/src/main/java/com/yifu/cloud/plus/v1/msg/entity/TMessageInfo.java

@@ -80,6 +80,13 @@ public class TMessageInfo {
 	@ExcelProperty("处理人-当前提醒人")
 	@Schema(description = "处理人-当前提醒人")
 	private String alertUser;
+	/**
+	 * 是否通知企业微信用户 0 是 1 否
+	 */
+	@ExcelAttribute(name = "是否通知企业微信用户", maxLength = 1)
+	@ExcelProperty("是否通知企业微信用户")
+	@Schema(description = "是否通知企业微信用户 0 是 1 否")
+	private String wxFlag;
 	/**
 	 * listUrl
 	 */

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/config/WxConfig.java

+package com.yifu.cloud.plus.v1.msg.config;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.CacheConstants;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.SecurityConstants;
+import com.yifu.cloud.plus.v1.yifu.common.core.exception.CheckedException;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.Common;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.authentication.AuthenticationServiceException;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @Author: huyc
+ * @Date: 2023/7/28
+ * @Description:
+ * @return: 企业微信配置
+ **/
+@Configuration
+@Data
+@Slf4j
+public class WxConfig {
+
+    @Value("${wx.corpid}")
+    private String corpid;
+    @Value("${wx.corpsecret}")
+    private String corpsecret;
+    @Value("${wx.agentid}")
+    private String agentid;
+
+	@Autowired
+	private RedisTemplate redisTemplate;
+
+	//未授权
+	private String accossTokenInvliad = "40014";
+
+    /**
+     * @param
+     * @Author: huyc
+     * @Date: 2023/7/28
+     * @Description: 获取微信accos_token
+     * @return: java.lang.String
+     **/
+    public String getAccessToken(RestTemplate restTemplate) {
+        if (Common.isNotNull(agentid)) {
+            return this.getToken(restTemplate, CacheConstants.WX_ACCOSS_TOKEN.concat(agentid), corpsecret);
+        }
+        return this.getToken(restTemplate, CacheConstants.WX_ACCOSS_TOKEN, corpsecret);
+    }
+
+    public String getAccessToken(RestTemplate restTemplate,String corpsecret)throws AuthenticationServiceException {
+        if(Common.isEmpty(corpsecret)){
+            throw new AuthenticationServiceException("未找到对应的corpsecret请联系管理员配置");
+        }
+        return this.getToken(restTemplate, CacheConstants.WX_ACCOSS_TOKEN.concat(agentid), corpsecret);
+    }
+
+    /**
+     * @param restTemplate
+     * @param tokenKey
+     * @param corpsecretKey
+     * @Description: 获取token
+     * @Author: huyc
+     * @Date: 2023/7/28 14:46
+     * @return: java.lang.String
+     **/
+    public String getToken(RestTemplate restTemplate,String tokenKey, String corpsecretKey) {
+		Object wxToken = redisTemplate.opsForValue().get(tokenKey);
+		if (null != wxToken) {
+			return String.valueOf(wxToken);
+		}
+        String requestTokenUrl = String.format(SecurityConstants.WX_GET_ACCOSS_TOKEN, corpid, corpsecretKey);
+        String result = restTemplate.getForObject(requestTokenUrl, String.class);
+        if (Common.isEmpty(result)) {
+            throw new CheckedException("微信授权失败");
+        }
+        String token = JSON.parseObject(result).getString("access_token");
+        if (Common.isEmpty(token)) {
+            log.info(result);
+            throw new CheckedException("获取微信token失败");
+        }
+        redisTemplate.opsForValue().set(tokenKey, token);
+        redisTemplate.expire(tokenKey, 3600, TimeUnit.SECONDS);
+        return token;
+    }
+
+    /**
+     * @param
+	 * @Author: huyc
+	 * @Date: 2023/7/28 14:43
+     * @Description: 移除微信accossToken
+     * @return: java.lang.String
+     **/
+    public void removeAccessToken() {
+        redisTemplate.delete(CacheConstants.WX_ACCOSS_TOKEN);
+    }
+
+    /**
+     * @param restTemplate
+     * @param requestMap   请求内容
+	 * @Author: huyc
+	 * @Date: 2023/7/28 14:48
+     * @Description: 发送卡片消息
+     * @return: java.lang.String
+     **/
+    public boolean sendTextCard(RestTemplate restTemplate, Map<String, Object> requestMap) {
+        // 必须加上header说明
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
+        Gson gson = new Gson();
+        log.info(gson.toJson(requestMap));
+        HttpEntity<String> requestEntity = new HttpEntity<>(gson.toJson(requestMap), headers);
+        String accessToken = getAccessToken(restTemplate);
+        ResponseEntity<String> responseEntity = restTemplate.postForEntity(String.format(SecurityConstants.WX_SEND_MESSAGE, accessToken), requestEntity, String.class);
+        log.info(JSON.toJSONString(responseEntity));
+        JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(responseEntity));
+        JSONObject jsonBody = jsonObject.getJSONObject("body");
+        if (jsonBody != null) {
+            String errcode = jsonBody.getString("errcode");
+            if (accossTokenInvliad.equals(errcode)) {
+                //删除accossToken缓存
+                removeAccessToken();
+                return false;
+            }
+            if (!CommonConstants.ZERO_STRING.equals(errcode)) { //非正常，则打印错误日志
+                log.info(jsonObject.toJSONString());
+            }
+        } else {
+            log.info(jsonObject.toJSONString());
+        }
+        return true;
+    }
+
+    /**
+     * @param restTemplate
+     * @param requestMap   请求内容
+	 * @Author: huyc
+	 * @Date: 2023/7/28 14:50
+     * @Description: 发送卡片消息
+     * @return: java.lang.String
+     **/
+    public boolean sendAppTextCard(RestTemplate restTemplate, Map<String, Object> requestMap) {
+        // 必须加上header说明
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
+        Gson gson = new Gson();
+        log.info("发企业微信===请求：{}", gson.toJson(requestMap));
+        HttpEntity<String> requestEntity = new HttpEntity<>(gson.toJson(requestMap), headers);
+        String accessToken = getAppAccessToken(restTemplate);
+        ResponseEntity<String> responseEntity = restTemplate.postForEntity(String.format(SecurityConstants.WX_SEND_MESSAGE, accessToken), requestEntity, String.class);
+        log.info("发企业微信===返回：{}",JSON.toJSONString(responseEntity));
+        JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(responseEntity));
+        JSONObject jsonBody = jsonObject.getJSONObject("body");
+        if (jsonBody != null) {
+            String errcode = jsonBody.getString("errcode");
+            if (accossTokenInvliad.equals(errcode)) {
+                //删除accossToken缓存
+                removeAccessToken();
+                return false;
+            }
+            if (!CommonConstants.ZERO_STRING.equals(errcode)) { //非正常，则打印错误日志
+                log.info(jsonObject.toJSONString());
+            }
+        } else {
+            log.info(jsonObject.toJSONString());
+        }
+        return true;
+    }
+	/**
+	 * 功能描述: 获取微信accos_token
+	 * @Author: huyc
+	 * @Date: 2023/7/28 14:50
+	 * @return: java.lang.String
+	 */
+	public String getAppAccessToken(RestTemplate restTemplate) {
+		return this.getToken(restTemplate, CacheConstants.WX_ACCOSS_TOKEN, corpsecret);
+	}
+}

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/controller/TMessageInfoController.java

@@ -79,7 +79,7 @@ public class TMessageInfoController {
     @PostMapping
     @PreAuthorize("@pms.hasPermission('demo_tmessageinfo_add')" )
     public R<Boolean> save(@RequestBody TMessageInfo tMessageInfo) {
-        return R.ok(tMessageInfoService.save(tMessageInfo));
+        return R.ok(tMessageInfoService.saveMessage(tMessageInfo));
     }
 
     /**

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/service/TMessageInfoService.java

@@ -21,7 +21,6 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yifu.cloud.plus.v1.msg.entity.TMessageInfo;
-import org.springframework.web.bind.annotation.RequestBody;
 
 /**
  * 消息提醒
@@ -37,7 +36,9 @@ public interface TMessageInfoService extends IService<TMessageInfo> {
      */
     IPage<TMessageInfo> getTMessageInfoPage(Page<TMessageInfo> page, TMessageInfo tMessageInfo);
 
-	void updateMessageInfo(@RequestBody TMessageInfo tMessageInfo);
+	boolean saveMessage(TMessageInfo tMessageInfo);
 
-	long selectMessageCount(@RequestBody TMessageInfo tMessageInfo);
+	void updateMessageInfo(TMessageInfo tMessageInfo);
+
+	long selectMessageCount(TMessageInfo tMessageInfo);
 }

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/service/impl/TMessageInfoServiceImpl.java

@@ -47,6 +47,12 @@ public class TMessageInfoServiceImpl extends ServiceImpl<TMessageInfoMapper, TMe
         return baseMapper.getTMessageInfoPage(page,tMessageInfo);
     }
 
+	@Override
+	public boolean saveMessage(TMessageInfo tMessageInfo) {
+
+		return false;
+	}
+
 	@Override
 	public void updateMessageInfo(TMessageInfo tMessageInfo) {
 		if (Common.isNotNull(tMessageInfo) && Common.isNotNull(tMessageInfo.getAlertUser())) {

yifu-msg/yifu-msg-biz/src/main/resources/mapper/TMessageInfoMapper.xml

@@ -29,6 +29,7 @@
     <result property="alertType" column="ALERT_TYPE"/>
     <result property="handlerStatus" column="HANDLER_STATUS"/>
     <result property="alertUser" column="ALERT_USER"/>
+    <result property="wxFlag" column="WX_FLAG"/>
     <result property="listUrl" column="LIST_URL"/>
     <result property="infoUrl" column="INFO_URL"/>
     <result property="modelType" column="MODEL_TYPE"/>