From 6bfd93a6c8a312ed7f313d95d999ca8135930a57 Mon Sep 17 00:00:00 2001
From: zhangyuan <zhangyuan@sarnasea.com>
Date: Mon, 23 May 2022 15:35:34 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0redis=E6=8E=A7=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet/plugin/commons/redis/RedisKeys.java | 29 +++++++++++++++++++
 .../plugin/power/dto/hik/HikErrorInfoDTO.java |  5 ++++
 .../hik/entity/HikErrorInfoEntity.java        |  4 +++
 .../impl/HikCommunityInfoServiceImpl.java     |  2 +-
 .../RentContractInfoController.java           |  8 +++++
 .../rent/service/RentContractInfoService.java | 10 +++++++
 .../impl/RentContractInfoServiceImpl.java     | 14 +++++++++
 .../power/modules/utils/HkDeviceUtil.java     | 13 +++++++++
 8 files changed, 84 insertions(+), 1 deletion(-)
 create mode 100644 epmet-plugins-common/src/main/java/com/epmet/plugin/commons/redis/RedisKeys.java

diff --git a/epmet-plugins-common/src/main/java/com/epmet/plugin/commons/redis/RedisKeys.java b/epmet-plugins-common/src/main/java/com/epmet/plugin/commons/redis/RedisKeys.java
new file mode 100644
index 0000000..b5f3a6e
--- /dev/null
+++ b/epmet-plugins-common/src/main/java/com/epmet/plugin/commons/redis/RedisKeys.java
@@ -0,0 +1,29 @@
+/**
+ * Copyright (c) 2018 人人开源 All rights reserved.
+ * <p>
+ * https://www.renren.io
+ * <p>
+ * 版权所有，侵权必究！
+ */
+
+package com.epmet.plugin.commons.redis;
+
+/**
+ * @author Mark sunlightcs@gmail.com
+ * @since 1.0.0
+ */
+public class RedisKeys {
+
+    /**
+     * redis前缀
+     */
+    private static String rootPrefix = "epmet:";
+
+    /**
+     * 海康accessToken
+     */
+    public static String getHikTokenKey() {
+        return "hik:token";
+    }
+
+}
diff --git a/epmet-plugins-module/pli-power-base/pli-power-base-client/src/main/java/com/epmet/plugin/power/dto/hik/HikErrorInfoDTO.java b/epmet-plugins-module/pli-power-base/pli-power-base-client/src/main/java/com/epmet/plugin/power/dto/hik/HikErrorInfoDTO.java
index 958606d..a06778c 100644
--- a/epmet-plugins-module/pli-power-base/pli-power-base-client/src/main/java/com/epmet/plugin/power/dto/hik/HikErrorInfoDTO.java
+++ b/epmet-plugins-module/pli-power-base/pli-power-base-client/src/main/java/com/epmet/plugin/power/dto/hik/HikErrorInfoDTO.java
@@ -71,4 +71,9 @@ public class HikErrorInfoDTO implements Serializable {
      */
 	private String errorInfo;
 
+    /**
+     * 引用ID
+     */
+    private String referenceId;
+
 }
\ No newline at end of file
diff --git a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/entity/HikErrorInfoEntity.java b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/entity/HikErrorInfoEntity.java
index d4598a7..134ea93 100644
--- a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/entity/HikErrorInfoEntity.java
+++ b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/entity/HikErrorInfoEntity.java
@@ -41,4 +41,8 @@ public class HikErrorInfoEntity extends BaseEpmetEntity {
      */
 	private String errorInfo;
 
+	/**
+	 * 引用ID
+	 */
+	private String referenceId;
 }
diff --git a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/service/impl/HikCommunityInfoServiceImpl.java b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/service/impl/HikCommunityInfoServiceImpl.java
index d10718e..56e441d 100644
--- a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/service/impl/HikCommunityInfoServiceImpl.java
+++ b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/hik/service/impl/HikCommunityInfoServiceImpl.java
@@ -72,7 +72,7 @@ public class HikCommunityInfoServiceImpl extends BaseServiceImpl<HikCommunityInf
 
         QueryWrapper<HikCommunityInfoEntity> wrapper = new QueryWrapper<>();
         wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
-        wrapper.eq(StringUtils.isNotBlank(communityName), "COMMUNITY_NAME", communityName);
+        wrapper.like(StringUtils.isNotBlank(communityName), "COMMUNITY_NAME", communityName);
 
         return wrapper;
     }
diff --git a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/controller/RentContractInfoController.java b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/controller/RentContractInfoController.java
index d0f8f06..5516860 100644
--- a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/controller/RentContractInfoController.java
+++ b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/controller/RentContractInfoController.java
@@ -72,6 +72,14 @@ public class RentContractInfoController {
         return new Result();
     }
 
+    @NoRepeatSubmit
+    @PostMapping("resend/{id}")
+    public Result resend(@PathVariable("id") String id) {
+        //效验数据
+        rentContractInfoService.resend(id);
+        return new Result();
+    }
+
     @NoRepeatSubmit
     @PostMapping("update")
     public Result update(@RequestBody RentContractInfoDTO dto) {
diff --git a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/RentContractInfoService.java b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/RentContractInfoService.java
index 14068e4..742834f 100644
--- a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/RentContractInfoService.java
+++ b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/RentContractInfoService.java
@@ -77,6 +77,16 @@ public interface RentContractInfoService extends BaseService<RentContractInfoEnt
      */
     void send(RentContractInfoDTO dto);
 
+    /**
+     * 重新下发
+     *
+     * @param id
+     * @return void
+     * @author generator
+     * @date 2022-04-22
+     */
+    void resend(String id);
+
     /**
      * 默认更新
      *
diff --git a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/impl/RentContractInfoServiceImpl.java b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/impl/RentContractInfoServiceImpl.java
index 8aa5ac8..c3634d2 100644
--- a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/impl/RentContractInfoServiceImpl.java
+++ b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/rent/service/impl/RentContractInfoServiceImpl.java
@@ -259,6 +259,10 @@ public class RentContractInfoServiceImpl extends BaseServiceImpl<RentContractInf
     public void send(RentContractInfoDTO dto) {
         dto.getTenantList().forEach(item -> {
             try {
+                Map<String, Object> delParams = new HashMap<>();
+                delParams.put("idCard", item.getIdCard());
+                hikErrorInfoService.deletePhysical(delParams);
+
                 HikPersonFormDTO person = new HikPersonFormDTO();
                 person.setFaceUrl(item.getImgList().get(0).getFileUrl());
                 person.setMobile(item.getMobile());
@@ -295,11 +299,21 @@ public class RentContractInfoServiceImpl extends BaseServiceImpl<RentContractInf
                 HikErrorInfoDTO error = new HikErrorInfoDTO();
                 error.setIdCard(item.getIdCard());
                 error.setErrorInfo(e.getMessage());
+                error.setCustomerId(loginUserUtil.getLoginUserCustomerId());
+                error.setReferenceId(dto.getId());
                 hikErrorInfoService.save(error);
             }
         });
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void resend(String id) {
+        HikErrorInfoDTO errorDto = hikErrorInfoService.get(id);
+        RentContractInfoDTO dto = get(errorDto.getReferenceId());
+        send(dto);
+    }
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void update(RentContractInfoDTO dto) {
diff --git a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/utils/HkDeviceUtil.java b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/utils/HkDeviceUtil.java
index 0c47d6b..f52f535 100644
--- a/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/utils/HkDeviceUtil.java
+++ b/epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/utils/HkDeviceUtil.java
@@ -5,9 +5,11 @@ import com.alibaba.fastjson.JSONObject;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.exception.EpmetException;
+import com.epmet.commons.tools.redis.RedisUtils;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.HttpClientManager;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.plugin.commons.redis.RedisKeys;
 import com.epmet.plugin.power.config.HikCloudProperties;
 import com.epmet.plugin.power.dto.hik.form.HikAuthorityFormDTO;
 import com.epmet.plugin.power.dto.hik.form.HikPersonFormDTO;
@@ -32,6 +34,9 @@ public class HkDeviceUtil {
     @Autowired
     private HikCloudProperties hikCloudProperties;
 
+    @Autowired
+    private RedisUtils redisUtils;
+
     private final String GET_ACCESS_TOKEN = "/oauth/token";
     private final String GET_DEVICES = "/api/v1/estate/devices";
     private final String SEND_PERSON = "/api/v1/estate/system/person";
@@ -48,6 +53,12 @@ public class HkDeviceUtil {
      * @date 2022/5/20 16:40
      */
     public String getAccessToken() {
+        String key = RedisKeys.getHikTokenKey();
+        Object obj = redisUtils.get(key);
+        if (null != obj) {
+            return (String) obj;
+        }
+
         String url = hikCloudProperties.getUrl().concat(GET_ACCESS_TOKEN);
         Map<String, Object> paramsMap = new HashMap<>(8);
         paramsMap.put("client_id", hikCloudProperties.getClient());
@@ -65,6 +76,8 @@ public class HkDeviceUtil {
             throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "AccessToken获取失败");
         }
         String accessToken = "Bearer ".concat(toResult.get("access_token").toString());
+
+        redisUtils.set(key, accessToken, RedisUtils.HOUR_ONE_EXPIRE);
         return accessToken;
     }