缓存

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/dto/form/DingMiniInfoFormDTO.java

@@ -0,0 +1,26 @@
+package com.epmet.commons.tools.dto.form;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2022/9/15 10:25
+ * @DESC
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class DingMiniInfoFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 2661531490851265637L;
+
+    public interface DingMiniInfoForm{}
+
+    @NotBlank(message = "suiteKey不能为空",groups = DingMiniInfoForm.class)
+    private String suiteKey;
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/feign/CommonThirdFeignClient.java

@@ -0,0 +1,24 @@
+package com.epmet.commons.tools.feign;
+
+import com.epmet.commons.tools.constant.ServiceConstant;
+import com.epmet.commons.tools.dto.form.DingMiniInfoFormDTO;
+import com.epmet.commons.tools.feign.fallback.CommonThirdFeignClientFallBackFactory;
+import com.epmet.commons.tools.redis.common.bean.DingMiniInfoCache;
+import com.epmet.commons.tools.utils.Result;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+
+/**
+ * @Description
+ * @Author zxc
+ */
+@FeignClient(name = ServiceConstant.EPMET_THIRD_SERVER, fallbackFactory = CommonThirdFeignClientFallBackFactory.class)
+// @FeignClient(name = ServiceConstant.EPMET_THIRD_SERVER, fallbackFactory = CommonAggFeignClientFallBackFactory.class,url = "localhost:8110")
+public interface CommonThirdFeignClient {
+
+    @PostMapping("/third/dingTalk/getDingMiniInfo")
+    Result<DingMiniInfoCache> getDingMiniInfo(@RequestBody DingMiniInfoFormDTO formDTO);
+
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/feign/fallback/CommonThirdFeignClientFallBackFactory.java

@@ -0,0 +1,20 @@
+package com.epmet.commons.tools.feign.fallback;
+
+import com.epmet.commons.tools.exception.ExceptionUtils;
+import com.epmet.commons.tools.feign.CommonThirdFeignClient;
+import feign.hystrix.FallbackFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class CommonThirdFeignClientFallBackFactory implements FallbackFactory<CommonThirdFeignClient> {
+
+    private CommonThirdFeignClientFallback fallback = new CommonThirdFeignClientFallback();
+
+    @Override
+    public CommonThirdFeignClient create(Throwable cause) {
+        log.error(String.format("FeignClient调用发生异常,异常信息:%s", ExceptionUtils.getThrowableErrorStackTrace(cause)));
+        return fallback;
+    }
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/feign/fallback/CommonThirdFeignClientFallback.java

@@ -0,0 +1,24 @@
+package com.epmet.commons.tools.feign.fallback;
+
+import com.epmet.commons.tools.constant.ServiceConstant;
+import com.epmet.commons.tools.dto.form.DingMiniInfoFormDTO;
+import com.epmet.commons.tools.feign.CommonThirdFeignClient;
+import com.epmet.commons.tools.redis.common.bean.DingMiniInfoCache;
+import com.epmet.commons.tools.utils.ModuleUtils;
+import com.epmet.commons.tools.utils.Result;
+import org.springframework.stereotype.Component;
+
+/**
+ *
+ * @Author zxc
+ * @Description
+ * @Date
+ **/
+@Component
+public class CommonThirdFeignClientFallback implements CommonThirdFeignClient {
+
+    @Override
+    public Result<DingMiniInfoCache> getDingMiniInfo(DingMiniInfoFormDTO formDTO) {
+        return ModuleUtils.feignConError(ServiceConstant.EPMET_THIRD_SERVER, "getDingMiniInfo", formDTO);
+    }
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisKeys.java

@@ -881,4 +881,8 @@ public class RedisKeys {
 	public static String getSuiteTicketKey(String suiteKey) {
 		return rootPrefix.concat("ding:suiteTicket:" + suiteKey);
 	}
+
+	public static String getDingMiniInfoKey(String suiteKey) {
+		return rootPrefix.concat("ding:miniInfo:" + suiteKey);
+	}
 }

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/common/CustomerDingDingRedis.java

@@ -0,0 +1,58 @@
+package com.epmet.commons.tools.redis.common;
+
+import com.epmet.commons.tools.dto.form.DingMiniInfoFormDTO;
+import com.epmet.commons.tools.exception.EpmetException;
+import com.epmet.commons.tools.feign.CommonThirdFeignClient;
+import com.epmet.commons.tools.redis.RedisKeys;
+import com.epmet.commons.tools.redis.RedisUtils;
+import com.epmet.commons.tools.redis.common.bean.DingMiniInfoCache;
+import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.commons.tools.utils.Result;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import javax.annotation.PostConstruct;
+import java.util.Map;
+
+/**
+ * @Author zxc
+ * @DateTime 2022/9/15 10:01
+ * @DESC
+ */
+@Slf4j
+@Component
+public class CustomerDingDingRedis {
+
+    @Autowired
+    private CommonThirdFeignClient thirdFeignClient;
+    @Autowired
+    private RedisUtils redisUtils;
+
+    private static CustomerDingDingRedis customerDingDingRedis;
+
+    @PostConstruct
+    public void init() {
+        customerDingDingRedis = this;
+        customerDingDingRedis.thirdFeignClient = this.thirdFeignClient;
+        customerDingDingRedis.redisUtils = this.redisUtils;
+    }
+
+    public static DingMiniInfoCache getDingMiniInfo(String suiteKey){
+        String key = RedisKeys.getDingMiniInfoKey(suiteKey);
+        Map<String, Object> miniInfoMap = customerDingDingRedis.redisUtils.hGetAll(key);
+        if (!CollectionUtils.isEmpty(miniInfoMap)){
+            return ConvertUtils.mapToEntity(miniInfoMap,DingMiniInfoCache.class);
+        }
+        Result<DingMiniInfoCache> dingMiniInfoResult = customerDingDingRedis.thirdFeignClient.getDingMiniInfo(new DingMiniInfoFormDTO(suiteKey));
+        if (!dingMiniInfoResult.success()){
+            throw new EpmetException("查询dingMiniInfo失败...");
+        }
+        if (null == dingMiniInfoResult.getData()){
+            return null;
+        }
+        return dingMiniInfoResult.getData();
+    }
+
+}

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/common/bean/DingMiniInfoCache.java

@@ -0,0 +1,52 @@
+package com.epmet.commons.tools.redis.common.bean;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2022/9/15 10:11
+ * @DESC
+ */
+@Data
+public class DingMiniInfoCache implements Serializable {
+
+    private static final long serialVersionUID = -6956910978074595334L;
+
+    private String id;
+
+    /**
+     *
+     */
+    private String suiteId;
+
+    /**
+     *
+     */
+    private String appId;
+
+    /**
+     *
+     */
+    private String miniAppId;
+
+    /**
+     *
+     */
+    private String suiteName;
+
+    /**
+     *
+     */
+    private String suiteKey;
+
+    /**
+     *
+     */
+    private String suiteSecret;
+
+    private String token;
+
+    private String aesKey;
+}

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/controller/dingtalk/CallbackController.java

@@ -4,6 +4,8 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.aliyun.dingtalk.util.DingCallbackCrypto;
 import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.dto.form.DingMiniInfoFormDTO;
+import com.epmet.commons.tools.redis.common.bean.DingMiniInfoCache;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.validator.ValidatorUtils;
 import com.epmet.dao.OpenSyncBizDataDao;
@@ -138,4 +140,16 @@ public class CallbackController {
         ValidatorUtils.validateEntity(formDTO, ExemptLoginUserDetailFormDTO.ExemptLoginUserDetailForm.class);
         return new Result<Object>().ok(dingTalkService.getExemptLoginUserDetail(formDTO));
     }
+
+    /**
+     * Desc: 获取钉钉小程序信息
+     * @param formDTO
+     * @author zxc
+     * @date 2022/9/15 10:46
+     */
+    @PostMapping("getDingMiniInfo")
+    public Result<DingMiniInfoCache> getDingMiniInfo(@RequestBody DingMiniInfoFormDTO formDTO){
+        ValidatorUtils.validateEntity(formDTO, DingMiniInfoFormDTO.DingMiniInfoForm.class);
+        return new Result<DingMiniInfoCache>().ok(dingTalkService.getDingMiniInfo(formDTO));
+    }
 }

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/DingTalkService.java

@@ -1,5 +1,7 @@
 package com.epmet.service;
 
+import com.epmet.commons.tools.dto.form.DingMiniInfoFormDTO;
+import com.epmet.commons.tools.redis.common.bean.DingMiniInfoCache;
 import com.epmet.dto.form.ExemptLoginUserDetailFormDTO;
 
 /**
@@ -11,4 +13,12 @@ public interface DingTalkService {
 
     Object getExemptLoginUserDetail(ExemptLoginUserDetailFormDTO formDTO);
 
+    /**
+     * Desc: 获取钉钉小程序信息
+     * @param formDTO
+     * @author zxc
+     * @date 2022/9/15 10:46
+     */
+    DingMiniInfoCache getDingMiniInfo(DingMiniInfoFormDTO formDTO);
+
 }

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/impl/DingTalkServiceImpl.java

@@ -1,5 +1,6 @@
 package com.epmet.service.impl;
 
+import cn.hutool.core.bean.BeanUtil;
 import com.alibaba.fastjson.JSON;
 import com.aliyun.dingtalk.module.Result;
 import com.dingtalk.api.DefaultDingTalkClient;
@@ -8,7 +9,12 @@ import com.dingtalk.api.request.OapiV2UserGetRequest;
 import com.dingtalk.api.request.OapiV2UserGetuserinfoRequest;
 import com.dingtalk.api.response.OapiV2UserGetResponse;
 import com.dingtalk.api.response.OapiV2UserGetuserinfoResponse;
+import com.epmet.commons.tools.dto.form.DingMiniInfoFormDTO;
 import com.epmet.commons.tools.exception.EpmetException;
+import com.epmet.commons.tools.redis.RedisKeys;
+import com.epmet.commons.tools.redis.RedisUtils;
+import com.epmet.commons.tools.redis.common.bean.DingMiniInfoCache;
+import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.dao.OpenSyncBizDataDao;
 import com.epmet.dto.DingMiniInfoDTO;
 import com.epmet.dto.form.ExemptLoginUserDetailFormDTO;
@@ -20,6 +26,7 @@ import com.taobao.dingtalk.vo.result.AccessTokenResult;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
 import java.util.Map;
 
@@ -38,6 +45,8 @@ public class DingTalkServiceImpl implements DingTalkService {
     private OpenSyncBizDataDao openSyncBizDataDao;
     @Autowired
     private DingDingCallbackRedis dingCallbackRedis;
+    @Autowired
+    private RedisUtils redisUtils;
 
     @Override
     public Object getExemptLoginUserDetail(ExemptLoginUserDetailFormDTO formDTO) {
@@ -75,4 +84,26 @@ public class DingTalkServiceImpl implements DingTalkService {
         }
         return o;
     }
+
+    /**
+     * Desc: 获取钉钉小程序信息
+     * @param formDTO
+     * @author zxc
+     * @date 2022/9/15 10:46
+     */
+    @Override
+    public DingMiniInfoCache getDingMiniInfo(DingMiniInfoFormDTO formDTO) {
+        String key = RedisKeys.getDingMiniInfoKey(formDTO.getSuiteKey());
+        Map<String, Object> dingMiniInfoMap = redisUtils.hGetAll(key);
+        if (!CollectionUtils.isEmpty(dingMiniInfoMap)) {
+            DingMiniInfoCache dingMiniInfoCache = ConvertUtils.mapToEntity(dingMiniInfoMap,DingMiniInfoCache.class);
+            return dingMiniInfoCache;
+        }
+        DingMiniInfoDTO dingMiniInfo = openSyncBizDataDao.getDingMiniInfo(formDTO.getSuiteKey());
+        if (null != dingMiniInfo){
+            redisUtils.hMSet(key, BeanUtil.beanToMap(dingMiniInfo));
+            return ConvertUtils.sourceToTarget(dingMiniInfo,DingMiniInfoCache.class);
+        }
+        return null;
+    }
 }