增加redis控制

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";
+    }
+
+}

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;
+
 }

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;
 }

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;
     }

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

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);
+
     /**
      * 默认更新
      *

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

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;
     }