From 6b8131766ade76b1ca2b2968bfff7afe756a926d Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Thu, 5 Nov 2020 17:42:04 +0800
Subject: [PATCH 1/9] =?UTF-8?q?=E7=94=A8=E6=88=B7=E5=8B=8B=E7=AB=A0?=
 =?UTF-8?q?=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet/commons/tools/redis/RedisUtils.java | 41 ++++++++-
 .../epmet/dto/form/UserBadgeUnitFormDTO.java  | 48 ++++++++++
 .../com/epmet/constant/UserRedisKeys.java     | 10 ++
 .../src/main/java/com/epmet/dao/BadgeDao.java | 10 ++
 .../java/com/epmet/redis/UserBadgeRedis.java  | 92 ++++++++++++++++---
 .../src/main/resources/mapper/BadgeDao.xml    | 39 ++++++++
 6 files changed, 227 insertions(+), 13 deletions(-)
 create mode 100644 epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserBadgeUnitFormDTO.java

diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
index 27a081dacc..db65ca6e0d 100644
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
@@ -9,16 +9,23 @@
 package com.epmet.commons.tools.redis;
 
 import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.exception.RenException;
+import com.epmet.commons.tools.utils.ConvertUtils;
+import org.apache.poi.ss.formula.functions.T;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 import org.springframework.data.redis.core.*;
 import org.springframework.data.redis.support.atomic.RedisAtomicLong;
 import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
 
 import java.util.Collection;
+import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 
 /**
  * Redis工具类
@@ -171,10 +178,40 @@ public class RedisUtils {
         }
     }
 
-    public Object lindex(String key,Long index){
-        return redisTemplate.opsForList().index(key,index);
+    public Object lindex(String key,Long index){ return redisTemplate.opsForList().index(key,index);
     }
 
+    public <T> List<T> lrange(String key,long start,long end,Class<T> clazz){
+        List<Object> content =  redisTemplate.opsForList().range(key,start,end);
+        if(CollectionUtils.isEmpty(content)) return null;
+         return content.stream().map( o -> {
+                try {
+                    T target = clazz.newInstance();
+                    BeanUtils.copyProperties(o, target);
+                    return target;
+                }catch (Exception e){throw new RenException("convert error");}finally{throw new RenException("convert error");}
+            }).collect(Collectors.toList());
+    }
+
+    /**
+     * @Description Redis lrem :
+     *                      根据参数 count 的值，移除列表中与参数 value 相等的元素
+     * COUNT 的值可以是以下几种 ：
+     *                      count > 0 : 从表头开始向表尾搜索，移除与 value 相等的元素，数量为 count
+     *                      count < 0 : 从表尾开始向表头搜索，移除与 value 相等的元素，数量为 count 的绝对值
+     *                      count = 0 : 移除表中所有与 value 相等的值
+     * 返回值 :
+     *          被移除元素的数量
+     *          列表不存在时返回 0
+     * @param key
+     * @param count
+     * @param o 这里的Object需要重写equals(FIXME 注意序列化)
+     * @return long
+     * @author wangc
+     * @date 2020.11.05 10:22
+    */
+    public long lrem(String key,long count,Object o){ return redisTemplate.opsForList().remove(key,count,o);}
+
     public Object rightPop(String key) {
         return redisTemplate.opsForList().rightPop(key);
     }
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserBadgeUnitFormDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserBadgeUnitFormDTO.java
new file mode 100644
index 0000000000..406f527bb9
--- /dev/null
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserBadgeUnitFormDTO.java
@@ -0,0 +1,48 @@
+package com.epmet.dto.form;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Objects;
+
+/**
+ * @Description 用户-徽章缓存单元
+ * @ClassName UserBadgeUnitFormDTO
+ * @Auth wangc
+ * @Date 2020-11-05 10:00
+ */
+@Data
+public class UserBadgeUnitFormDTO implements Serializable {
+    private static final long serialVersionUID = -4497394865738168850L;
+
+    /**
+     * 徽章Id
+     */
+    private String badgeId;
+
+    /**
+     * 徽章图标  url
+     */
+    private String badgeIcon;
+
+    /**
+     * 徽章名称
+     */
+    private String badgeName;
+
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        UserBadgeUnitFormDTO that = (UserBadgeUnitFormDTO) o;
+        return badgeId.equals(that.badgeId) &&
+                badgeIcon.equals(that.badgeIcon) &&
+                badgeName.equals(that.badgeName);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(badgeId, badgeIcon, badgeName);
+    }
+}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java
index f4fffb6975..599beea58f 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java
@@ -23,4 +23,14 @@ public class UserRedisKeys {
     public static String getResiUserKey(String userId){
         return rootPrefix.concat("resi:user:").concat(userId);
     }
+    
+    /**
+     * @Description 用户勋章缓存 epmet:badge:user:[customerId]:[userId]
+     * @param userId
+     * @return epmet:badge:user:[customerId]:[userId]
+     * @author wangc
+     * @date 2020.11.05 13:34
+    */
+    public static String getResiUserBadgeKey(String customerId,String userId){
+        return rootPrefix.concat("badge:user:").concat(customerId).concat(userId);}
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
index 965f753b6e..3b3fa6c596 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
@@ -20,6 +20,7 @@ package com.epmet.dao;
 import com.epmet.commons.mybatis.dao.BaseDao;
 import com.epmet.dto.result.BadgeDetailResultDTO;
 import com.epmet.dto.result.BadgeListResultDTO;
+import com.epmet.dto.result.UserBadgeListResultDTO;
 import com.epmet.entity.BadgeEntity;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -105,4 +106,13 @@ public interface BadgeDao extends BaseDao<BadgeEntity> {
 	 * @return void
 	 */
 	void deleteBadge(@Param("customerId") String customerId, @Param("badgeId") String badgeId);
+
+	/**
+	 * @Description 查询客户的徽章
+	 * @param customerId
+	 * @return java.util.List<com.epmet.dto.result.UserBadgeListResultDTO>
+	 * @author wangc
+	 * @date 2020.11.05 15:50
+	*/
+	List<UserBadgeListResultDTO> selectCustomerBadgePool(@Param("customerId") String customerId);
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
index c9eaee4367..0fc766cdf6 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
@@ -1,13 +1,26 @@
 package com.epmet.redis;
 
+
+import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
+import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.redis.RedisUtils;
+import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.constant.BadgeConstant;
+import com.epmet.constant.UserRedisKeys;
+import com.epmet.dao.BadgeDao;
+import com.epmet.dto.form.UserBadgeUnitFormDTO;
+import com.epmet.dto.result.BadgeListResultDTO;
 import com.epmet.dto.result.UserBadgeListResultDTO;
+import com.epmet.service.UserBadgeService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
+import java.util.Optional;
 
 import static com.epmet.commons.tools.redis.RedisUtils.MINUTE_THIRTY_EXPIRE;
 
@@ -16,45 +29,50 @@ import static com.epmet.commons.tools.redis.RedisUtils.MINUTE_THIRTY_EXPIRE;
  * @DateTime 2020/11/3 2:21 下午
  */
 @Component
+@Slf4j
 public class UserBadgeRedis {
 
     @Autowired
     private RedisUtils redisUtils;
+    @Autowired
+    private BadgeDao badgeDao;
+    @Autowired
+    private UserBadgeService badgeService;
 
     /**
-     * @Description  获取客户徽章信息
+     * @Description 获取客户徽章信息
      * @Param customerId
      * @author zxc
      * @date 2020/11/3 2:50 下午
      */
-    public Object getCustomerBadge(String customerId){
+    public Object getCustomerBadge(String customerId) {
         Object userBadge = redisUtils.hGet(BadgeConstant.BADGE_KEY + customerId, BadgeConstant.BADGE);
         return userBadge;
     }
 
     /**
-     * @Description  存放客户徽章信息
+     * @Description 存放客户徽章信息
      * @Param userBadge
      * @Param customerId
      * @author zxc
      * @date 2020/11/3 2:51 下午
      */
-    public void setCustomerBadge(List<UserBadgeListResultDTO> userBadge, String customerId){
-        redisUtils.hSet(BadgeConstant.BADGE_KEY+customerId,BadgeConstant.BADGE, JSON.toJSON(userBadge).toString(),-1);
+    public void setCustomerBadge(List<UserBadgeListResultDTO> userBadge, String customerId) {
+        redisUtils.hSet(BadgeConstant.BADGE_KEY + customerId, BadgeConstant.BADGE, JSON.toJSON(userBadge).toString(), -1);
     }
 
     /**
-     * @Description  删除客户徽章信息
+     * @Description 删除客户徽章信息
      * @Param customerId
      * @author zxc
      * @date 2020/11/5 3:06 下午
      */
-    public void delCustomerBadge(String customerId){
-        redisUtils.hDel(BadgeConstant.BADGE_KEY+customerId,BadgeConstant.BADGE);
+    public void delCustomerBadge(String customerId) {
+        redisUtils.hDel(BadgeConstant.BADGE_KEY + customerId, BadgeConstant.BADGE);
     }
 
     /**
-     * @Description  存放徽章审核 手机验证码
+     * @Description 存放徽章审核 手机验证码
      * @Param mobile
      * @author zxc
      * @date 2020/11/5 10:30 上午
@@ -65,7 +83,7 @@ public class UserBadgeRedis {
     }
 
     /**
-     * @Description  获取徽章审核 手机验证码
+     * @Description 获取徽章审核 手机验证码
      * @Param mobile
      * @author zxc
      * @date 2020/11/5 10:30 上午
@@ -76,4 +94,56 @@ public class UserBadgeRedis {
         return smsCode;
     }
 
-}
+    /**
+     * @param userId
+     * @return java.util.List<com.epmet.dto.form.UserBadgeUnitFormDTO>
+     * @Description 获取用户的全部勋章信息(点亮的 、 排序从前到后)
+     * @author wangc
+     * @date 2020.11.05 13:26
+     */
+    public List<UserBadgeUnitFormDTO> obtainUserBadge2List(String userId) {
+        //TODO  补偿
+        return redisUtils.lrange(UserRedisKeys.getResiUserKey(userId), NumConstant.ZERO, NumConstant.ONE_NEG, UserBadgeUnitFormDTO.class);
+    }
+
+    /**
+     * 用户点亮或取消徽章
+     * @param
+     * @return int
+     * @Description 入栈时使用lpush 出栈时使用lrem
+     * @author wangc
+     * @date 2020.11.05 13:37
+     */
+    public long pushOrRemoveUserBadge4List(String userId, String badgeId, String customerId) {
+        List<UserBadgeUnitFormDTO> orient = obtainUserBadge2List(userId);
+        UserBadgeUnitFormDTO unit = null;
+
+        if (!CollectionUtils.isEmpty(orient)) {
+            Optional<UserBadgeUnitFormDTO> opt = orient.stream().filter(badge -> StringUtils.equals(badgeId, badge.getBadgeId())).findFirst();
+            if (opt.isPresent()) {
+                unit = opt.get();
+                return redisUtils.lrem(UserRedisKeys.getResiUserBadgeKey(customerId, userId), NumConstant.ONE, unit);
+            }
+        }
+
+            //徽章池
+            List<UserBadgeListResultDTO> badgePool =
+                    Optional.ofNullable(JSON.parseArray(getCustomerBadge(customerId).toString(), UserBadgeListResultDTO.class))
+                            .orElse(badgeDao.selectCustomerBadgePool(customerId));
+            if (CollectionUtils.isEmpty(badgePool)) {
+                log.error("com.epmet.redis.UserBadgeRedis.pushOrRemoveUserBadge4List，缓存中客户{}下的徽章池为空", customerId);
+                return NumConstant.ZERO;
+            }
+
+            if (null == unit) {
+                Optional<UserBadgeListResultDTO> poolOpt =
+                        badgePool.stream().filter(badge -> StringUtils.equals(badge.getBadgeId(), badgeId)).findFirst();
+                if (poolOpt.isPresent()) unit = ConvertUtils.sourceToTarget(poolOpt.get(), UserBadgeUnitFormDTO.class);
+                else return NumConstant.ZERO;
+            }
+            redisUtils.leftPush(UserRedisKeys.getResiUserBadgeKey(customerId, userId), unit);
+            return NumConstant.ONE;
+        }
+
+    }
+
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
index 322604bc70..d66bb7194a 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
@@ -112,5 +112,44 @@
         select * from badge where DEL_FLAG = '0' AND CUSTOMER_ID = #{customerId} AND ID = #{badgeId}
     </select>
 
+    <!-- 查询客户的徽章 -->
+    <select id="selectCustomerBadgePool" resultType="com.epmet.dto.result.UserBadgeListResultDTO">
+        SELECT
+            temp.badgeId,
+            temp.BADGE_ICON,
+            temp.BADGE_NAME,
+            temp.CUSTOMER_ID,
+            temp.UPDATED_TIME
+        FROM(
+                SELECT
+                    ID AS badgeId,
+                    CUSTOMER_ID,
+                    BADGE_NAME ,
+                    BADGE_ICON ,
+                    UPDATED_TIME
+                FROM
+                    BADGE
+                WHERE
+                    DEL_FLAG = '0'
+                    AND BADGE_STATUS = 'online'
+                    AND CUSTOMER_ID = #{customerId}
+
+                UNION
+
+                SELECT
+                    outter.ID AS badgeId,
+                    outter.CUSTOMER_ID,
+                    outter.BADGE_NAME,
+                    outter.BADGE_ICON,
+                    outter.UPDATED_TIME
+                FROM
+                    BADGE outter
+                WHERE
+                    DEL_FLAG = '0'
+                    AND BADGE_STATUS = 'online'
+                    AND CUSTOMER_ID = 'default'
+                    AND NOT EXISTS ( SELECT id FROM badge WHERE del_flag = '0' AND customer_id = #{customerId} AND ID = outter.ID AND badge_status = 'online' )
+        ) AS temp ORDER BY temp.UPDATED_TIME DESC
+    </select>
 
 </mapper>
\ No newline at end of file

From cca7e6eb309fdb7f9f7ad3ca2be377cabc6d56f8 Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Fri, 6 Nov 2020 09:11:51 +0800
Subject: [PATCH 2/9] =?UTF-8?q?=E7=94=A8=E6=88=B7=E5=8B=8B=E7=AB=A0?=
 =?UTF-8?q?=E7=BC=93=E5=AD=98=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/epmet/controller/BadgeController.java   |  5 +++++
 .../main/java/com/epmet/redis/UserBadgeRedis.java    |  5 ++++-
 .../main/java/com/epmet/service/BadgeService.java    |  2 ++
 .../com/epmet/service/impl/BadgeServiceImpl.java     | 12 ++++++++++++
 4 files changed, 23 insertions(+), 1 deletion(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
index 92a2621013..463fa4874a 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
@@ -100,5 +100,10 @@ public class BadgeController {
 		return new Result();
 	}
 
+	@PostMapping("test-cache")
+	public Result testCache(){
+		badgeService.testCache();
+		return new Result();
+	}
 
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
index 0fc766cdf6..da4eecfd5b 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
@@ -127,8 +127,11 @@ public class UserBadgeRedis {
         }
 
             //徽章池
+            Object badgeObj = getCustomerBadge(customerId);
+
             List<UserBadgeListResultDTO> badgePool =
-                    Optional.ofNullable(JSON.parseArray(getCustomerBadge(customerId).toString(), UserBadgeListResultDTO.class))
+                    null == badgeObj ? null :
+                    Optional.ofNullable(JSON.parseArray(badgeObj.toString(), UserBadgeListResultDTO.class))
                             .orElse(badgeDao.selectCustomerBadgePool(customerId));
             if (CollectionUtils.isEmpty(badgePool)) {
                 log.error("com.epmet.redis.UserBadgeRedis.pushOrRemoveUserBadge4List，缓存中客户{}下的徽章池为空", customerId);
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
index 7b73e28561..f041e19286 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
@@ -147,4 +147,6 @@ public interface BadgeService extends BaseService<BadgeEntity> {
      * @return void
      */
     void deleteBadge(TokenDto tokenDto, BadgeFormDTO formDTO);
+
+    void testCache();
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
index 021b0c734a..21462c8b7d 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
@@ -33,12 +33,15 @@ import com.epmet.dto.BadgeDTO;
 import com.epmet.dto.form.AddBadgeFormDTO;
 import com.epmet.dto.form.BadgeFormDTO;
 import com.epmet.dto.form.EditBadgeFormDTO;
+import com.epmet.dto.form.UserBadgeUnitFormDTO;
 import com.epmet.dto.result.BadgeDetailResultDTO;
 import com.epmet.dto.result.BadgeListResultDTO;
 import com.epmet.entity.BadgeCertificationConfigEntity;
 import com.epmet.entity.BadgeEntity;
+import com.epmet.redis.UserBadgeRedis;
 import com.epmet.service.BadgeCertificationConfigService;
 import com.epmet.service.BadgeService;
+import com.epmet.service.UserBadgeService;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -61,6 +64,8 @@ public class BadgeServiceImpl extends BaseServiceImpl<BadgeDao, BadgeEntity> imp
 
     @Autowired
     private BadgeCertificationConfigService badgeCertificationConfigService;
+    @Autowired
+    private UserBadgeRedis badgeRedis;
 
 
     @Override
@@ -245,4 +250,11 @@ public class BadgeServiceImpl extends BaseServiceImpl<BadgeDao, BadgeEntity> imp
         badgeCertificationConfigService.deleteConfig(tokenDto.getCustomerId(), formDTO.getBadgeId());
     }
 
+    @Override
+    public void testCache() {
+        badgeRedis.pushOrRemoveUserBadge4List("test-wc","1","45687aa479955f9d06204d415238f7cc");
+        List<UserBadgeUnitFormDTO> cache = badgeRedis.obtainUserBadge2List("test-wc");
+        System.out.println(cache);
+    }
+
 }
\ No newline at end of file

From b4b2f872e839fb9cca9645c4e705e0c00c205920 Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrt@163.com>
Date: Fri, 6 Nov 2020 09:36:20 +0800
Subject: [PATCH 3/9] =?UTF-8?q?=E8=AE=A2=E9=98=85=E7=9B=B8=E5=90=8C?=
 =?UTF-8?q?=E6=A8=A1=E6=9D=BF=E6=97=B6=E6=B7=BB=E5=8A=A0=E5=85=B3=E9=94=AE?=
 =?UTF-8?q?=E5=AD=97=E9=99=90=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../tools/exception/EpmetErrorCode.java       |   1 +
 .../com/epmet/constant/BadgeConstant.java     |   6 +
 .../dto/UserBadgeCertificateRecordDTO.java    |   2 +-
 .../com/epmet/dto/form/BadgeAuditFormDTO.java |  20 +++
 .../java/com/epmet/dto/form/BadgeFormDTO.java |   8 ++
 .../dto/result/BadgeAuditRecordResultDTO.java |  43 +++++++
 .../dto/result/BadgeAuditingResultDTO.java    |  43 +++++++
 .../com/epmet/controller/BadgeController.java |  44 +++++++
 .../src/main/java/com/epmet/dao/BadgeDao.java |  27 ++++
 .../dao/UserBadgeCertificateRecordDao.java    |  33 +++++
 .../UserBadgeCertificateRecordEntity.java     | 116 ++++++++++++++++++
 .../java/com/epmet/service/BadgeService.java  |  33 +++++
 .../UserBadgeCertificateRecordService.java    |  95 ++++++++++++++
 .../epmet/service/impl/BadgeServiceImpl.java  |  88 ++++++++++++-
 ...UserBadgeCertificateRecordServiceImpl.java | 100 +++++++++++++++
 .../src/main/resources/mapper/BadgeDao.xml    |  72 ++++++++++-
 .../mapper/UserBadgeCertificateRecordDao.xml  |  32 +++++
 17 files changed, 754 insertions(+), 9 deletions(-)
 create mode 100644 epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeAuditFormDTO.java
 create mode 100644 epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java
 create mode 100644 epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditingResultDTO.java
 create mode 100644 epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserBadgeCertificateRecordDao.java
 create mode 100644 epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java
 create mode 100644 epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBadgeCertificateRecordService.java
 create mode 100644 epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeCertificateRecordServiceImpl.java
 create mode 100644 epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeCertificateRecordDao.xml

diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java
index 2242a9ef9c..e864c6b743 100644
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java
@@ -97,6 +97,7 @@ public enum EpmetErrorCode {
 
 	//徽章管理
 	DUPLICATE_BADGE_NAME(8515, "徽章名已存在"),
+	DUPLICATE_PARTY_BADGE_NAME(8516, "不可删除党员徽章"),
 
     // 该错误不会提示给前端，只是后端传输错误信息用。
     ACCESS_SQL_FILTER_MISSION_ARGS(8701, "缺少生成权限过滤SQL所需参数"),
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/constant/BadgeConstant.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/constant/BadgeConstant.java
index 315bf66a30..f8b6dcc2e5 100644
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/constant/BadgeConstant.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/constant/BadgeConstant.java
@@ -24,4 +24,10 @@ public interface BadgeConstant {
 
     String SMS_CODE_KEY = "epmet:smsCode:badge:";
 
+    String PARTY ="party";
+
+    String ONLINE ="online";
+
+    String OFFLINE ="offline";
+
 }
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java
index ffa2be3013..820f0fa45c 100644
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/UserBadgeCertificateRecordDTO.java
@@ -13,7 +13,7 @@ import java.util.Date;
 public class UserBadgeCertificateRecordDTO implements Serializable {
 
     private static final long serialVersionUID = 3207509834642386145L;
-
+    private String id;
     private String customerId;
     private String gridId;
     private String userId;
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeAuditFormDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeAuditFormDTO.java
new file mode 100644
index 0000000000..f7d3deac7d
--- /dev/null
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeAuditFormDTO.java
@@ -0,0 +1,20 @@
+package com.epmet.dto.form;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/11/5 11:06
+ */
+@NoArgsConstructor
+@Data
+public class BadgeAuditFormDTO implements Serializable {
+	private static final long serialVersionUID = 2209535364555130964L;
+	private String recordId;
+	private String auditStatus;
+	private String auditRemark;
+}
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeFormDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeFormDTO.java
index 4b35497e8b..e9702144f0 100644
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeFormDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/BadgeFormDTO.java
@@ -13,4 +13,12 @@ import java.io.Serializable;
 public class BadgeFormDTO implements Serializable {
 	private static final long serialVersionUID = 9156247659994638103L;
 	private String badgeId;
+	/**
+	 * 页码
+	 */
+	private Integer pageNo;
+	/**
+	 * 每页显示数量
+	 */
+	private Integer pageSize;
 }
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java
new file mode 100644
index 0000000000..363441ad46
--- /dev/null
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditRecordResultDTO.java
@@ -0,0 +1,43 @@
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/11/5 10:57
+ */
+@Data
+public class BadgeAuditRecordResultDTO implements Serializable {
+	private static final long serialVersionUID = 6004101838042628105L;
+	/**
+	 * 徽章Id
+	 */
+	private String badgeId;
+	/**
+	 * 徽章名称
+	 */
+	private String badgeName;
+	/**
+	 * 徽章图标url
+	 */
+	private String badgeIcon;
+	/**
+	 * 用户Id
+	 */
+	private String userId;
+	/**
+	 * 用户名
+	 */
+	private String userName;
+	/**
+	 * 创建时间
+	 */
+	private Long createTime;
+	/**
+	 * 用户名
+	 */
+	private String auditStatus;
+}
diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditingResultDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditingResultDTO.java
new file mode 100644
index 0000000000..bbf6381d82
--- /dev/null
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/BadgeAuditingResultDTO.java
@@ -0,0 +1,43 @@
+package com.epmet.dto.result;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/11/5 9:34
+ */
+@NoArgsConstructor
+@Data
+public class BadgeAuditingResultDTO implements Serializable {
+
+	private static final long serialVersionUID = -361914591952483084L;
+	/**
+	 * 徽章Id
+	 */
+	private String badgeId;
+	/**
+	 * 徽章名称
+	 */
+	private String badgeName;
+	/**
+	 * 徽章图标url
+	 */
+	private String badgeIcon;
+	/**
+	 * 用户Id
+	 */
+	private String userId;
+	/**
+	 * 用户名
+	 */
+	private String userName;
+	/**
+	 * 创建时间
+	 */
+	private Long createTime;
+
+}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
index 463fa4874a..12042c4fbd 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/BadgeController.java
@@ -5,8 +5,11 @@ import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.validator.ValidatorUtils;
 import com.epmet.dto.form.AddBadgeFormDTO;
+import com.epmet.dto.form.BadgeAuditFormDTO;
 import com.epmet.dto.form.BadgeFormDTO;
 import com.epmet.dto.form.EditBadgeFormDTO;
+import com.epmet.dto.result.BadgeAuditRecordResultDTO;
+import com.epmet.dto.result.BadgeAuditingResultDTO;
 import com.epmet.dto.result.BadgeDetailResultDTO;
 import com.epmet.dto.result.BadgeListResultDTO;
 import com.epmet.service.BadgeService;
@@ -105,5 +108,46 @@ public class BadgeController {
 		badgeService.testCache();
 		return new Result();
 	}
+	/**
+	 * 待审核列表
+	 * @author zhaoqifeng
+	 * @date 2020/11/5 9:51
+	 * @param tokenDto
+	 * @param formDTO
+	 * @return com.epmet.commons.tools.utils.Result<java.util.List<com.epmet.dto.result.BadgeAuditingResultDTO>>
+	 */
+	@PostMapping("auditinglist")
+	public Result<List<BadgeAuditingResultDTO>> auditingList(@LoginUser TokenDto tokenDto, @RequestBody BadgeFormDTO formDTO) {
+		List<BadgeAuditingResultDTO> result = badgeService.auditingList(tokenDto, formDTO);
+		return new Result<List<BadgeAuditingResultDTO>>().ok(result);
+	}
+
+	/**
+	 * 审核历史列表
+	 * @author zhaoqifeng
+	 * @date 2020/11/5 10:59
+	 * @param tokenDto
+	 * @param formDTO
+	 * @return com.epmet.commons.tools.utils.Result<java.util.List<com.epmet.dto.result.BadgeAuditRecordResultDTO>>
+	 */
+	@PostMapping("auditrecord")
+	public Result<List<BadgeAuditRecordResultDTO>> auditRecord(@LoginUser TokenDto tokenDto, @RequestBody BadgeFormDTO formDTO) {
+		List<BadgeAuditRecordResultDTO> result = badgeService.auditRecord(tokenDto, formDTO);
+		return new Result<List<BadgeAuditRecordResultDTO>>().ok(result);
+	}
+
+	/**
+	 * 审核
+	 * @author zhaoqifeng
+	 * @date 2020/11/5 11:09
+	 * @param tokenDto
+	 * @param formDTO
+	 * @return com.epmet.commons.tools.utils.Result
+	 */
+	@PostMapping("audit")
+	public Result audit(@LoginUser TokenDto tokenDto, @RequestBody BadgeAuditFormDTO formDTO) {
+		badgeService.audit(tokenDto, formDTO);
+		return new Result();
+	}
 
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
index 3b3fa6c596..a0c2fb42b6 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/BadgeDao.java
@@ -18,6 +18,8 @@
 package com.epmet.dao;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.result.BadgeAuditRecordResultDTO;
+import com.epmet.dto.result.BadgeAuditingResultDTO;
 import com.epmet.dto.result.BadgeDetailResultDTO;
 import com.epmet.dto.result.BadgeListResultDTO;
 import com.epmet.dto.result.UserBadgeListResultDTO;
@@ -107,6 +109,31 @@ public interface BadgeDao extends BaseDao<BadgeEntity> {
 	 */
 	void deleteBadge(@Param("customerId") String customerId, @Param("badgeId") String badgeId);
 
+
+	/**
+	 * 待审核列表
+	 * @author zhaoqifeng
+	 * @date 2020/11/5 10:01
+	 * @param customerId
+	 * @param pageNo
+	 * @param pageSize
+	 * @return java.util.List<com.epmet.dto.result.BadgeAuditingResultDTO>
+	 */
+	List<BadgeAuditingResultDTO> selectAuditingList(@Param("customerId") String customerId, @Param("pageNo") Integer pageNo,
+													@Param("pageSize") Integer pageSize);
+
+	/**
+	 * 审核历史列表
+	 * @author zhaoqifeng
+	 * @date 2020/11/5 11:01
+	 * @param customerId
+	 * @param pageNo
+	 * @param pageSize
+	 * @return java.util.List<com.epmet.dto.result.BadgeAuditRecordResultDTO>
+	 */
+	List<BadgeAuditRecordResultDTO> selectAuditRecord(@Param("customerId") String customerId, @Param("pageNo") Integer pageNo,
+													   @Param("pageSize") Integer pageSize);
+
 	/**
 	 * @Description 查询客户的徽章
 	 * @param customerId
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserBadgeCertificateRecordDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserBadgeCertificateRecordDao.java
new file mode 100644
index 0000000000..f7f4dba91c
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserBadgeCertificateRecordDao.java
@@ -0,0 +1,33 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ * <p>
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * <p>
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ * <p>
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package com.epmet.dao;
+
+import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.entity.UserBadgeCertificateRecordEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户认证徽章记录表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-11-05
+ */
+@Mapper
+public interface UserBadgeCertificateRecordDao extends BaseDao<UserBadgeCertificateRecordEntity> {
+	
+}
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java
new file mode 100644
index 0000000000..867ae11bdb
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/entity/UserBadgeCertificateRecordEntity.java
@@ -0,0 +1,116 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ * <p>
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * <p>
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ * <p>
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package com.epmet.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import com.epmet.commons.mybatis.entity.BaseEpmetEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * 用户认证徽章记录表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-11-05
+ */
+@Data
+@EqualsAndHashCode(callSuper=false)
+@TableName("user_badge_certificate_record")
+public class UserBadgeCertificateRecordEntity extends BaseEpmetEntity {
+
+	private static final long serialVersionUID = 1L;
+
+    /**
+     * 客户Id 
+     */
+	private String customerId;
+
+    /**
+     * 用户注册网格ID
+     */
+	private String gridId;
+
+    /**
+     * 用户ID
+     */
+	private String userId;
+
+    /**
+     * 徽章ID
+     */
+	private String badgeId;
+
+    /**
+     * 姓
+     */
+	private String surname;
+
+    /**
+     * 名
+     */
+	private String name;
+
+    /**
+     * 手机号
+     */
+	private String mobile;
+
+    /**
+     * 身份证号 网格内去重
+     */
+	private String idNum;
+
+    /**
+     * 认证证件图片
+     */
+	private String certificationImg;
+
+    /**
+     * 认证说明(备注)
+     */
+	private String remaek;
+
+    /**
+     * 审核状态 approved:审核通过，rejected:审核驳回;auditing:审核中
+     */
+	private String auditStatus;
+
+    /**
+     * 审核意见
+     */
+	private String auditRemark;
+
+    /**
+     * 审核人 审核人Id
+     */
+	private String staffId;
+
+    /**
+     * 审核时间
+     */
+	private Date auditTime;
+
+    /**
+     * 是否是最新纪录：yes：最新纪录，no：非最新纪录
+     */
+	private String isLast;
+
+}
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
index f041e19286..9b13682b6f 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/BadgeService.java
@@ -22,8 +22,11 @@ import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.dto.BadgeDTO;
 import com.epmet.dto.form.AddBadgeFormDTO;
+import com.epmet.dto.form.BadgeAuditFormDTO;
 import com.epmet.dto.form.BadgeFormDTO;
 import com.epmet.dto.form.EditBadgeFormDTO;
+import com.epmet.dto.result.BadgeAuditRecordResultDTO;
+import com.epmet.dto.result.BadgeAuditingResultDTO;
 import com.epmet.dto.result.BadgeDetailResultDTO;
 import com.epmet.dto.result.BadgeListResultDTO;
 import com.epmet.entity.BadgeEntity;
@@ -148,5 +151,35 @@ public interface BadgeService extends BaseService<BadgeEntity> {
      */
     void deleteBadge(TokenDto tokenDto, BadgeFormDTO formDTO);
 
+    /**
+     * 待审核列表
+     * @author zhaoqifeng
+     * @date 2020/11/5 9:50
+     * @param tokenDto
+     * @param formDTO
+     * @return java.util.List<com.epmet.dto.result.BadgeAuditingResultDTO>
+     */
+    List<BadgeAuditingResultDTO> auditingList(TokenDto tokenDto, BadgeFormDTO formDTO);
+
+    /**
+     * 审核历史列表
+     * @author zhaoqifeng
+     * @date 2020/11/5 10:59
+     * @param tokenDto
+     * @param formDTO
+     * @return java.util.List<com.epmet.dto.result.BadgeAuditRecordResultDTO>
+     */
+    List<BadgeAuditRecordResultDTO> auditRecord(TokenDto tokenDto, BadgeFormDTO formDTO);
+
+    /**
+     * 审核
+     * @author zhaoqifeng
+     * @date 2020/11/5 11:08
+     * @param tokenDto
+     * @param formDTO
+     * @return void
+     */
+    void audit(TokenDto tokenDto, BadgeAuditFormDTO formDTO);
+
     void testCache();
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBadgeCertificateRecordService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBadgeCertificateRecordService.java
new file mode 100644
index 0000000000..154c8685db
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBadgeCertificateRecordService.java
@@ -0,0 +1,95 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ * <p>
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * <p>
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ * <p>
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package com.epmet.service;
+
+import com.epmet.commons.mybatis.service.BaseService;
+import com.epmet.commons.tools.page.PageData;
+import com.epmet.dto.UserBadgeCertificateRecordDTO;
+import com.epmet.entity.UserBadgeCertificateRecordEntity;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户认证徽章记录表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-11-05
+ */
+public interface UserBadgeCertificateRecordService extends BaseService<UserBadgeCertificateRecordEntity> {
+
+    /**
+     * 默认分页
+     *
+     * @param params
+     * @return PageData<UserBadgeCertificateRecordDTO>
+     * @author generator
+     * @date 2020-11-05
+     */
+    PageData<UserBadgeCertificateRecordDTO> page(Map<String, Object> params);
+
+    /**
+     * 默认查询
+     *
+     * @param params
+     * @return java.util.List<UserBadgeCertificateRecordDTO>
+     * @author generator
+     * @date 2020-11-05
+     */
+    List<UserBadgeCertificateRecordDTO> list(Map<String, Object> params);
+
+    /**
+     * 单条查询
+     *
+     * @param id
+     * @return UserBadgeCertificateRecordDTO
+     * @author generator
+     * @date 2020-11-05
+     */
+    UserBadgeCertificateRecordDTO get(String id);
+
+    /**
+     * 默认保存
+     *
+     * @param dto
+     * @return void
+     * @author generator
+     * @date 2020-11-05
+     */
+    void save(UserBadgeCertificateRecordDTO dto);
+
+    /**
+     * 默认更新
+     *
+     * @param dto
+     * @return void
+     * @author generator
+     * @date 2020-11-05
+     */
+    void update(UserBadgeCertificateRecordDTO dto);
+
+    /**
+     * 批量删除
+     *
+     * @param ids
+     * @return void
+     * @author generator
+     * @date 2020-11-05
+     */
+    void delete(String[] ids);
+}
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
index 21462c8b7d..4f461457f8 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
@@ -30,9 +30,13 @@ import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.constant.BadgeConstant;
 import com.epmet.dao.BadgeDao;
 import com.epmet.dto.BadgeDTO;
+import com.epmet.dto.UserBadgeCertificateRecordDTO;
 import com.epmet.dto.form.AddBadgeFormDTO;
+import com.epmet.dto.form.BadgeAuditFormDTO;
 import com.epmet.dto.form.BadgeFormDTO;
 import com.epmet.dto.form.EditBadgeFormDTO;
+import com.epmet.dto.result.BadgeAuditRecordResultDTO;
+import com.epmet.dto.result.BadgeAuditingResultDTO;
 import com.epmet.dto.form.UserBadgeUnitFormDTO;
 import com.epmet.dto.result.BadgeDetailResultDTO;
 import com.epmet.dto.result.BadgeListResultDTO;
@@ -41,6 +45,7 @@ import com.epmet.entity.BadgeEntity;
 import com.epmet.redis.UserBadgeRedis;
 import com.epmet.service.BadgeCertificationConfigService;
 import com.epmet.service.BadgeService;
+import com.epmet.service.UserBadgeCertificateRecordService;
 import com.epmet.service.UserBadgeService;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -48,10 +53,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * 徽章
@@ -65,6 +67,8 @@ public class BadgeServiceImpl extends BaseServiceImpl<BadgeDao, BadgeEntity> imp
     @Autowired
     private BadgeCertificationConfigService badgeCertificationConfigService;
     @Autowired
+    private UserBadgeCertificateRecordService userBadgeCertificateRecordService;
+    @Autowired
     private UserBadgeRedis badgeRedis;
 
 
@@ -164,6 +168,9 @@ public class BadgeServiceImpl extends BaseServiceImpl<BadgeDao, BadgeEntity> imp
             badgeList.add(badge);
         });
         badgeCertificationConfigService.insertBatch(badgeList);
+        if (BadgeConstant.ONLINE.equals(formDTO.getBadgeStatus())) {
+            //TODO 更新Redis
+        }
     }
 
     /**
@@ -225,6 +232,9 @@ public class BadgeServiceImpl extends BaseServiceImpl<BadgeDao, BadgeEntity> imp
             badgeList.add(badge);
         });
         badgeCertificationConfigService.saveConfig(tokenDto.getCustomerId(), formDTO.getBadgeId(), badgeList);
+        if (BadgeConstant.OFFLINE.equals(formDTO.getBadgeStatus())) {
+            //TODO 更新Redis
+        }
     }
 
     /**
@@ -241,13 +251,83 @@ public class BadgeServiceImpl extends BaseServiceImpl<BadgeDao, BadgeEntity> imp
         BadgeEntity badgeEntity = baseDao.selectBadgeInfo(tokenDto.getCustomerId(), formDTO.getBadgeId());
         if (null == badgeEntity) {
             badgeEntity = baseDao.selectBadgeInfo("default", formDTO.getBadgeId());
+            if (BadgeConstant.PARTY.equals(badgeEntity.getFixationBadgeType())) {
+                throw new RenException(EpmetErrorCode.DUPLICATE_PARTY_BADGE_NAME.getCode());
+            }
             badgeEntity.setCustomerId(tokenDto.getCustomerId());
             badgeEntity.setDelFlag(NumConstant.ONE_STR);
             baseDao.insert(badgeEntity);
         } else {
+            if (BadgeConstant.PARTY.equals(badgeEntity.getFixationBadgeType())) {
+                throw new RenException(EpmetErrorCode.DUPLICATE_PARTY_BADGE_NAME.getCode());
+            }
             baseDao.deleteBadge(tokenDto.getCustomerId(), formDTO.getBadgeId());
         }
         badgeCertificationConfigService.deleteConfig(tokenDto.getCustomerId(), formDTO.getBadgeId());
+        //TODO 更新Redis
+    }
+
+    /**
+     * 待审核列表
+     *
+     * @param tokenDto
+     * @param formDTO
+     * @return java.util.List<com.epmet.dto.result.BadgeAuditingResultDTO>
+     * @author zhaoqifeng
+     * @date 2020/11/5 9:50
+     */
+    @Override
+    public List<BadgeAuditingResultDTO> auditingList(TokenDto tokenDto, BadgeFormDTO formDTO) {
+        int pageIndex = (formDTO.getPageNo() - NumConstant.ONE) * formDTO.getPageSize();
+        List<BadgeAuditingResultDTO> list = baseDao.selectAuditingList(tokenDto.getCustomerId(), pageIndex, formDTO.getPageSize());
+        list.forEach(item -> {
+            item.setCreateTime(item.getCreateTime()/NumConstant.SIXTY);
+        });
+        return list;
+    }
+
+    /**
+     * 审核历史列表
+     *
+     * @param tokenDto
+     * @param formDTO
+     * @return java.util.List<com.epmet.dto.result.BadgeAuditRecordResultDTO>
+     * @author zhaoqifeng
+     * @date 2020/11/5 10:59
+     */
+    @Override
+    public List<BadgeAuditRecordResultDTO> auditRecord(TokenDto tokenDto, BadgeFormDTO formDTO) {
+        int pageIndex = (formDTO.getPageNo() - NumConstant.ONE) * formDTO.getPageSize();
+        List<BadgeAuditRecordResultDTO> list = baseDao.selectAuditRecord(tokenDto.getCustomerId(), pageIndex, formDTO.getPageSize());
+        list.forEach(item -> {
+            item.setCreateTime(item.getCreateTime()/NumConstant.SIXTY);
+        });
+        return list;
+    }
+
+    /**
+     * 审核
+     *
+     * @param tokenDto
+     * @param formDTO
+     * @return void
+     * @author zhaoqifeng
+     * @date 2020/11/5 11:08
+     */
+    @Override
+    public void audit(TokenDto tokenDto, BadgeAuditFormDTO formDTO) {
+        UserBadgeCertificateRecordDTO dto  = new UserBadgeCertificateRecordDTO();
+        dto.setId(formDTO.getRecordId());
+        dto.setAuditStatus(formDTO.getAuditStatus());
+        dto.setAuditRemark(formDTO.getAuditRemark());
+        dto.setStaffId(tokenDto.getUserId());
+        dto.setAuditTime(new Date());
+
+        userBadgeCertificateRecordService.update(dto);
+
+        if(BadgeConstant.APPROVED.equals(formDTO.getAuditStatus())) {
+            //TODO 更新Redis
+        }
     }
 
     @Override
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeCertificateRecordServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeCertificateRecordServiceImpl.java
new file mode 100644
index 0000000000..6f798abc79
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeCertificateRecordServiceImpl.java
@@ -0,0 +1,100 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ * <p>
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * <p>
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ * <p>
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package com.epmet.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.dao.UserBadgeCertificateRecordDao;
+import com.epmet.dto.UserBadgeCertificateRecordDTO;
+import com.epmet.entity.UserBadgeCertificateRecordEntity;
+import com.epmet.service.UserBadgeCertificateRecordService;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户认证徽章记录表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2020-11-05
+ */
+@Service
+public class UserBadgeCertificateRecordServiceImpl extends BaseServiceImpl<UserBadgeCertificateRecordDao, UserBadgeCertificateRecordEntity> implements UserBadgeCertificateRecordService {
+
+
+    @Override
+    public PageData<UserBadgeCertificateRecordDTO> page(Map<String, Object> params) {
+        IPage<UserBadgeCertificateRecordEntity> page = baseDao.selectPage(
+                getPage(params, FieldConstant.CREATED_TIME, false),
+                getWrapper(params)
+        );
+        return getPageData(page, UserBadgeCertificateRecordDTO.class);
+    }
+
+    @Override
+    public List<UserBadgeCertificateRecordDTO> list(Map<String, Object> params) {
+        List<UserBadgeCertificateRecordEntity> entityList = baseDao.selectList(getWrapper(params));
+
+        return ConvertUtils.sourceToTarget(entityList, UserBadgeCertificateRecordDTO.class);
+    }
+
+    private QueryWrapper<UserBadgeCertificateRecordEntity> getWrapper(Map<String, Object> params){
+        String id = (String)params.get(FieldConstant.ID_HUMP);
+
+        QueryWrapper<UserBadgeCertificateRecordEntity> wrapper = new QueryWrapper<>();
+        wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
+
+        return wrapper;
+    }
+
+    @Override
+    public UserBadgeCertificateRecordDTO get(String id) {
+        UserBadgeCertificateRecordEntity entity = baseDao.selectById(id);
+        return ConvertUtils.sourceToTarget(entity, UserBadgeCertificateRecordDTO.class);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void save(UserBadgeCertificateRecordDTO dto) {
+        UserBadgeCertificateRecordEntity entity = ConvertUtils.sourceToTarget(dto, UserBadgeCertificateRecordEntity.class);
+        insert(entity);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void update(UserBadgeCertificateRecordDTO dto) {
+        UserBadgeCertificateRecordEntity entity = ConvertUtils.sourceToTarget(dto, UserBadgeCertificateRecordEntity.class);
+        updateById(entity);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void delete(String[] ids) {
+        // 逻辑删除（@TableLogic 注解）
+        baseDao.deleteBatchIds(Arrays.asList(ids));
+    }
+
+}
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
index d66bb7194a..978a9cf13b 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/BadgeDao.xml
@@ -44,7 +44,7 @@
                 SELECT * FROM badge a
                 WHERE CUSTOMER_ID = 'default' AND a.DEL_FLAG = '0'
                   AND NOT EXISTS
-                    ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.BADGE_NAME = b.BADGE_NAME AND b.DEL_FLAG = '0')) t
+                    ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.ID = b.ID)) t
         ORDER BY
             CREATED_TIME DESC
     </select>
@@ -65,7 +65,7 @@
                 SELECT * FROM badge a
                 WHERE CUSTOMER_ID = 'default' AND a.DEL_FLAG = '0'
                   AND NOT EXISTS
-                    ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.BADGE_NAME = b.BADGE_NAME AND b.DEL_FLAG = '0' )) t) a
+                    ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.BADGE_NAME = b.BADGE_NAME)) t) a
         WHERE BADGE_NAME = #{badgeName}
     </select>
     <select id="selectDetail" resultType="com.epmet.dto.result.BadgeDetailResultDTO">
@@ -85,7 +85,7 @@
                      SELECT * FROM badge a
                      WHERE CUSTOMER_ID = 'default' AND a.DEL_FLAG = '0'
                        AND NOT EXISTS
-                         ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.BADGE_NAME = b.BADGE_NAME AND b.DEL_FLAG = '0' )) t) a
+                         ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.BADGE_NAME = b.BADGE_NAME  )) t) a
         WHERE badgeId = #{badgeId}
     </select>
     <select id="getDuplicateNameForEdit" resultType="com.epmet.dto.result.BadgeListResultDTO">
@@ -105,12 +105,76 @@
                      SELECT * FROM badge a
                      WHERE CUSTOMER_ID = 'default' AND a.DEL_FLAG = '0'
                        AND NOT EXISTS
-                         ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.BADGE_NAME = b.BADGE_NAME AND b.DEL_FLAG = '0' )) t) a
+                         ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.BADGE_NAME = b.BADGE_NAME )) t) a
         WHERE BADGE_NAME = #{badgeName} AND badgeId != #{badgeId}
     </select>
     <select id="selectBadgeInfo" resultType="com.epmet.entity.BadgeEntity">
         select * from badge where DEL_FLAG = '0' AND CUSTOMER_ID = #{customerId} AND ID = #{badgeId}
     </select>
+    <select id="selectAuditingList" resultType="com.epmet.dto.result.BadgeAuditingResultDTO">
+        SELECT
+            ubcr.ID,
+            badge.BADGE_NAME,
+            badge.BADGE_ICON,
+            ubcr.USER_ID,
+            ubi.REAL_NAME AS "userName",
+            unix_timestamp(ubcr.CREATED_TIME) AS "createTime"
+        FROM
+            user_badge_certificate_record  ubcr
+            LEFT JOIN user_base_info ubi ON ubcr.USER_ID = ubi.USER_ID
+            LEFT JOIN (SELECT
+                    ID,
+                    BADGE_NAME,
+                    BADGE_ICON,
+                    BADGE_STATUS
+                FROM
+                    (
+                        SELECT * FROM badge
+                        WHERE CUSTOMER_ID = #{customerId} AND DEL_FLAG = '0'
+                        UNION ALL
+                        SELECT * FROM badge a
+                        WHERE CUSTOMER_ID = 'default' AND a.DEL_FLAG = '0'
+                          AND NOT EXISTS
+                            ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.ID = b.ID AND b.DEL_FLAG = '0')) t) badge ON ubcr.BADGE_ID = badge.ID
+        WHERE
+            AUDIT_STATUS = 'auditing'
+            AND ubcr.DEL_FLAG = '0'
+            AND ubcr.CUSTOMER_ID = #{customerId}
+        ORDER BY ubcr.CREATED_TIME DESC
+        LIMIT #{pageNo}, #{pageSize}
+    </select>
+    <select id="selectAuditRecord" resultType="com.epmet.dto.result.BadgeAuditRecordResultDTO">
+        SELECT
+            ubcr.ID,
+            badge.BADGE_NAME,
+            badge.BADGE_ICON,
+            ubcr.USER_ID,
+            ubi.REAL_NAME AS "userName",
+            unix_timestamp(ubcr.CREATED_TIME) AS "createTime"
+        FROM
+            user_badge_certificate_record  ubcr
+                LEFT JOIN user_base_info ubi ON ubcr.USER_ID = ubi.USER_ID
+                LEFT JOIN (SELECT
+                               ID,
+                               BADGE_NAME,
+                               BADGE_ICON,
+                               BADGE_STATUS
+                           FROM
+                               (
+                                   SELECT * FROM badge
+                                   WHERE CUSTOMER_ID = #{customerId} AND DEL_FLAG = '0'
+                                   UNION ALL
+                                   SELECT * FROM badge a
+                                   WHERE CUSTOMER_ID = 'default' AND a.DEL_FLAG = '0'
+                                     AND NOT EXISTS
+                                       ( SELECT ID FROM badge b WHERE CUSTOMER_ID = #{customerId} AND a.ID = b.ID AND b.DEL_FLAG = '0')) t) badge ON ubcr.BADGE_ID = badge.ID
+        WHERE
+            AUDIT_STATUS != 'auditing'
+          AND ubcr.DEL_FLAG = '0'
+          AND ubcr.CUSTOMER_ID = #{customerId}
+        ORDER BY ubcr.CREATED_TIME DESC
+        LIMIT #{pageNo}, #{pageSize}
+    </select>
 
     <!-- 查询客户的徽章 -->
     <select id="selectCustomerBadgePool" resultType="com.epmet.dto.result.UserBadgeListResultDTO">
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeCertificateRecordDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeCertificateRecordDao.xml
new file mode 100644
index 0000000000..a2f59e8b8e
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/UserBadgeCertificateRecordDao.xml
@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.epmet.dao.UserBadgeCertificateRecordDao">
+
+    <resultMap type="com.epmet.entity.UserBadgeCertificateRecordEntity" id="userBadgeCertificateRecordMap">
+        <result property="id" column="ID"/>
+        <result property="customerId" column="CUSTOMER_ID"/>
+        <result property="gridId" column="GRID_ID"/>
+        <result property="userId" column="USER_ID"/>
+        <result property="badgeId" column="BADGE_ID"/>
+        <result property="surname" column="SURNAME"/>
+        <result property="name" column="NAME"/>
+        <result property="mobile" column="MOBILE"/>
+        <result property="idNum" column="ID_NUM"/>
+        <result property="certificationImg" column="CERTIFICATION_IMG"/>
+        <result property="remaek" column="REMAEK"/>
+        <result property="auditStatus" column="AUDIT_STATUS"/>
+        <result property="auditRemark" column="AUDIT_REMARK"/>
+        <result property="staffId" column="STAFF_ID"/>
+        <result property="auditTime" column="AUDIT_TIME"/>
+        <result property="isLast" column="IS_LAST"/>
+        <result property="delFlag" column="DEL_FLAG"/>
+        <result property="revision" column="REVISION"/>
+        <result property="createdBy" column="CREATED_BY"/>
+        <result property="createdTime" column="CREATED_TIME"/>
+        <result property="updatedBy" column="UPDATED_BY"/>
+        <result property="updatedTime" column="UPDATED_TIME"/>
+    </resultMap>
+
+
+</mapper>
\ No newline at end of file

From d288d08ed657591fd501efeb83a2540e04eea810 Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Fri, 6 Nov 2020 09:48:36 +0800
Subject: [PATCH 4/9] =?UTF-8?q?=E7=94=A8=E6=88=B7=E5=8B=8B=E7=AB=A0?=
 =?UTF-8?q?=E7=BC=93=E5=AD=98=E4=BF=AE=E6=94=B9.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/epmet/commons/tools/redis/RedisUtils.java | 2 +-
 .../src/main/java/com/epmet/constant/UserRedisKeys.java     | 2 +-
 .../src/main/java/com/epmet/redis/UserBadgeRedis.java       | 6 +++---
 .../main/java/com/epmet/service/impl/BadgeServiceImpl.java  | 2 +-
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
index db65ca6e0d..19d8e73374 100644
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisUtils.java
@@ -189,7 +189,7 @@ public class RedisUtils {
                     T target = clazz.newInstance();
                     BeanUtils.copyProperties(o, target);
                     return target;
-                }catch (Exception e){throw new RenException("convert error");}finally{throw new RenException("convert error");}
+                }catch (Exception e){throw new RenException("convert error");}
             }).collect(Collectors.toList());
     }
 
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java
index 599beea58f..46f5ad1fa2 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/UserRedisKeys.java
@@ -32,5 +32,5 @@ public class UserRedisKeys {
      * @date 2020.11.05 13:34
     */
     public static String getResiUserBadgeKey(String customerId,String userId){
-        return rootPrefix.concat("badge:user:").concat(customerId).concat(userId);}
+        return rootPrefix.concat("badge:user:").concat(customerId).concat(":").concat(userId);}
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
index da4eecfd5b..dcac2a8d9b 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
@@ -101,9 +101,9 @@ public class UserBadgeRedis {
      * @author wangc
      * @date 2020.11.05 13:26
      */
-    public List<UserBadgeUnitFormDTO> obtainUserBadge2List(String userId) {
+    public List<UserBadgeUnitFormDTO> obtainUserBadge2List(String userId,String customerId) {
         //TODO  补偿
-        return redisUtils.lrange(UserRedisKeys.getResiUserKey(userId), NumConstant.ZERO, NumConstant.ONE_NEG, UserBadgeUnitFormDTO.class);
+        return redisUtils.lrange(UserRedisKeys.getResiUserBadgeKey(customerId,userId), NumConstant.ZERO, NumConstant.ONE_NEG, UserBadgeUnitFormDTO.class);
     }
 
     /**
@@ -115,7 +115,7 @@ public class UserBadgeRedis {
      * @date 2020.11.05 13:37
      */
     public long pushOrRemoveUserBadge4List(String userId, String badgeId, String customerId) {
-        List<UserBadgeUnitFormDTO> orient = obtainUserBadge2List(userId);
+        List<UserBadgeUnitFormDTO> orient = obtainUserBadge2List(userId,customerId);
         UserBadgeUnitFormDTO unit = null;
 
         if (!CollectionUtils.isEmpty(orient)) {
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
index 4f461457f8..36ea72d2ff 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java
@@ -333,7 +333,7 @@ public class BadgeServiceImpl extends BaseServiceImpl<BadgeDao, BadgeEntity> imp
     @Override
     public void testCache() {
         badgeRedis.pushOrRemoveUserBadge4List("test-wc","1","45687aa479955f9d06204d415238f7cc");
-        List<UserBadgeUnitFormDTO> cache = badgeRedis.obtainUserBadge2List("test-wc");
+        List<UserBadgeUnitFormDTO> cache = badgeRedis.obtainUserBadge2List("test-wc","45687aa479955f9d06204d415238f7cc");
         System.out.println(cache);
     }
 

From 1e664b6ec54aaacb5f1bba626ef4a85d8375c84e Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Fri, 6 Nov 2020 10:01:31 +0800
Subject: [PATCH 5/9] =?UTF-8?q?=E5=BE=BD=E7=AB=A0=E7=82=B9=E4=BA=AE?=
 =?UTF-8?q?=E5=8F=96=E6=B6=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/epmet/service/impl/UserBadgeServiceImpl.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
index 986d9eed7f..c8cf999968 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
@@ -218,8 +218,9 @@ public class UserBadgeServiceImpl implements UserBadgeService {
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void openedOrClosed(OpenedOrClosedFormDTO openedOrClosedFormDTO) {
-        userBadgeDao.updateIsOpen(openedOrClosedFormDTO);
+    public void openedOrClosed(OpenedOrClosedFormDTO form) {
+        userBadgeDao.updateIsOpen(form);
+        userBadgeRedis.pushOrRemoveUserBadge4List(form.getUserId(),form.getBadgeId(),form.getCustomerId());
     }
 
     /**

From 5f0eab13c93da93d8954994bc60fff5c954be8b5 Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Fri, 6 Nov 2020 10:01:43 +0800
Subject: [PATCH 6/9] =?UTF-8?q?=E7=BC=93=E5=AD=98=E4=B8=AD=E6=B2=A1?=
 =?UTF-8?q?=E6=9C=89=E5=AE=A2=E6=88=B7=E5=8B=8B=E7=AB=A0=E5=88=99=E5=8E=BB?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/epmet/redis/UserBadgeRedis.java     | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
index dcac2a8d9b..0b57fcbb9f 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/redis/UserBadgeRedis.java
@@ -1,7 +1,7 @@
 package com.epmet.redis;
 
 
-import cn.hutool.json.JSONUtil;
+
 import com.alibaba.fastjson.JSON;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.redis.RedisUtils;
@@ -10,7 +10,6 @@ import com.epmet.constant.BadgeConstant;
 import com.epmet.constant.UserRedisKeys;
 import com.epmet.dao.BadgeDao;
 import com.epmet.dto.form.UserBadgeUnitFormDTO;
-import com.epmet.dto.result.BadgeListResultDTO;
 import com.epmet.dto.result.UserBadgeListResultDTO;
 import com.epmet.service.UserBadgeService;
 import lombok.extern.slf4j.Slf4j;
@@ -130,9 +129,8 @@ public class UserBadgeRedis {
             Object badgeObj = getCustomerBadge(customerId);
 
             List<UserBadgeListResultDTO> badgePool =
-                    null == badgeObj ? null :
-                    Optional.ofNullable(JSON.parseArray(badgeObj.toString(), UserBadgeListResultDTO.class))
-                            .orElse(badgeDao.selectCustomerBadgePool(customerId));
+                    null == badgeObj ? badgeDao.selectCustomerBadgePool(customerId) : JSON.parseArray(badgeObj.toString(), UserBadgeListResultDTO.class);
+
             if (CollectionUtils.isEmpty(badgePool)) {
                 log.error("com.epmet.redis.UserBadgeRedis.pushOrRemoveUserBadge4List，缓存中客户{}下的徽章池为空", customerId);
                 return NumConstant.ZERO;

From ab8638384c013769177ca1ed5cc1e76908b61d60 Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Fri, 6 Nov 2020 14:33:12 +0800
Subject: [PATCH 7/9] =?UTF-8?q?=E5=BE=BD=E7=AB=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/service/impl/UserBadgeServiceImpl.java   | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
index c8cf999968..32b0cef882 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
@@ -240,12 +240,14 @@ public class UserBadgeServiceImpl implements UserBadgeService {
             List<UserBadgeListResultDTO> badgeByCustomer = groupByCustomer.get(customerId);
             if (!CollectionUtils.isEmpty(badgeByCustomer)) {
                 resultUserBadge.forEach(r -> {
-                    badgeByCustomer.forEach(b -> {
-                        if (r.getBadgeId().equals(b.getBadgeId())) {
-                            BeanUtils.copyProperties(b, r);
+                    for (int i = NumConstant.ZERO; i < badgeByCustomer.size(); i++) {
+                        if (r.getBadgeId().equals(badgeByCustomer.get(i).getBadgeId())) {
+                            BeanUtils.copyProperties(badgeByCustomer.get(i), r);
+                            badgeByCustomer.remove(badgeByCustomer.get(i));
                         }
-                    });
+                    }
                 });
+                resultUserBadge.addAll(badgeByCustomer);
             }
             userBadgeRedis.setCustomerBadge(resultUserBadge, customerId);
         }

From 9025367bdb97d34715305f65b403db17eaac5689 Mon Sep 17 00:00:00 2001
From: liushaowen <565850092@qq.com>
Date: Fri, 6 Nov 2020 15:24:17 +0800
Subject: [PATCH 8/9] =?UTF-8?q?=E8=BF=90=E8=90=A5=E7=AB=AF=E7=94=A8-Elemen?=
 =?UTF-8?q?tTree=E7=BB=93=E6=9E=84=E7=9A=84Agency=E5=88=97=E8=A1=A8?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/CustomerAgencyController.java  | 22 +++++++++++++-
 .../java/com/epmet/dao/CustomerAgencyDao.java | 12 +++++++-
 .../epmet/service/CustomerAgencyService.java  | 11 ++++++-
 .../impl/CustomerAgencyServiceImpl.java       | 29 ++++++++++++++++++-
 .../resources/mapper/CustomerAgencyDao.xml    | 10 ++++++-
 5 files changed, 79 insertions(+), 5 deletions(-)

diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
index c8b2350e16..6701fc7bee 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
@@ -17,7 +17,9 @@
 
 package com.epmet.controller;
 
+import com.baomidou.mybatisplus.extension.api.R;
 import com.epmet.commons.tools.annotation.LoginUser;
+import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ExcelUtils;
@@ -32,10 +34,13 @@ import com.epmet.dto.form.*;
 import com.epmet.dto.result.*;
 import com.epmet.excel.CustomerAgencyExcel;
 import com.epmet.service.CustomerAgencyService;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletResponse;
+import javax.validation.constraints.NotBlank;
 import java.util.List;
 import java.util.Map;
 
@@ -242,4 +247,19 @@ public class CustomerAgencyController {
     public Result<StaffInAgencyListResultDTO> staffInAgencyList(@LoginUser TokenDto tokenDTO) {
         return new Result<StaffInAgencyListResultDTO>().ok(customerAgencyService.staffInAgencyList(tokenDTO.getUserId()));
     }
-}
\ No newline at end of file
+
+    /**
+     * @Description 对外接口，根据customerId返回Element UI中Tree结构的agency列表
+     * @param customerId
+     * @return com.epmet.commons.tools.utils.Result
+     * @Author liushaowen
+     * @Date 2020/11/6 13:51
+     */
+    @PostMapping("getAgencyElementTree")
+    public Result<AgencyElementTreeResultDTO> getAgencyElementTree(String customerId){
+        if (StringUtils.isBlank(customerId)){
+            throw new RenException("customerId不能为空");
+        }
+        return new Result<AgencyElementTreeResultDTO>().ok(customerAgencyService.getAgencyElementTree(customerId));
+    }
+}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java
index eeeecf60db..19b2e338b4 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/dao/CustomerAgencyDao.java
@@ -175,4 +175,14 @@ public interface CustomerAgencyDao extends BaseDao<CustomerAgencyEntity> {
      * @Description 查询工作人员所属组织信息
      **/
     AgencyResultDTO selectAgencyByStaffId(@Param("staffId") String staffId);
-}
\ No newline at end of file
+
+    /**
+     * @Description 返回elementTree结构的agency树
+     * @param customerId
+     * @param pid
+     * @return java.util.List<com.epmet.dto.result.AgencyElementTreeResultDTO.Agency>
+     * @Author liushaowen
+     * @Date 2020/11/6 14:57
+     */
+    List<AgencyElementTreeResultDTO.Agency> getAgencyElementTree(@Param("customerId") String customerId,@Param("pid") String pid);
+}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java
index b7a556c5b0..aecfd85109 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerAgencyService.java
@@ -213,4 +213,13 @@ public interface CustomerAgencyService extends BaseService<CustomerAgencyEntity>
      * @Description 工作端-查询当前人员所属组织及所有下级组织
      **/
     StaffInAgencyListResultDTO staffInAgencyList(String staffId);
-}
\ No newline at end of file
+
+    /**
+     * @Description 运营端-返回element ui - tree 结构agency列表
+     * @param customerId
+     * @return com.epmet.dto.result.AgencyElementTreeResultDTO
+     * @Author liushaowen
+     * @Date 2020/11/6 14:02
+     */
+    AgencyElementTreeResultDTO getAgencyElementTree(String customerId);
+}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java
index db160cba61..9838fdd95f 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerAgencyServiceImpl.java
@@ -994,4 +994,31 @@ public class CustomerAgencyServiceImpl extends BaseServiceImpl<CustomerAgencyDao
         return resultDTO;
     }
 
-}
\ No newline at end of file
+    /**
+     * @param customerId
+     * @return com.epmet.dto.result.AgencyElementTreeResultDTO
+     * @Description 运营端-返回element ui - tree 结构agency列表
+     * @Author liushaowen
+     * @Date 2020/11/6 14:02
+     */
+    @Override
+    public AgencyElementTreeResultDTO getAgencyElementTree(String customerId) {
+        List<AgencyElementTreeResultDTO.Agency> agencyList = baseDao.getAgencyElementTree(customerId, "0");
+        Set<String> defaultKeys = new HashSet<>();
+        traversalAgencyList(agencyList,0,defaultKeys);
+        AgencyElementTreeResultDTO dto = new AgencyElementTreeResultDTO();
+        dto.setList(agencyList);
+        dto.setDefaultKeys(defaultKeys);
+        return dto;
+    }
+    private void traversalAgencyList(List<AgencyElementTreeResultDTO.Agency> agencyList,int times,Set<String> set){
+        if (agencyList.size() > 0 && times < 2){
+            for (AgencyElementTreeResultDTO.Agency list : agencyList) {
+                set.add(list.getId());
+                times++;
+                traversalAgencyList(list.getChildren(),times,set);
+            }
+        }
+    }
+
+}
diff --git a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml
index 4e295b44cf..7326a91f31 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml
+++ b/epmet-module/gov-org/gov-org-server/src/main/resources/mapper/CustomerAgencyDao.xml
@@ -290,4 +290,12 @@
         AND csa.user_id = #{staffId}
     </select>
 
-</mapper>
\ No newline at end of file
+    <resultMap id="elementTreeAgency" type="com.epmet.dto.result.AgencyElementTreeResultDTO$Agency">
+        <id column="ID" property="id"></id>
+        <result column="ORGANIZATION_NAME" property="label"></result>
+        <collection property="children" select="getAgencyElementTree" column="{pid=id,customerId=customer_id}"></collection>
+    </resultMap>
+    <select id="getAgencyElementTree" resultMap="elementTreeAgency">
+        select id,organization_name,customer_id from customer_agency where pid = #{pid} and customer_id = #{customerId}
+    </select>
+</mapper>

From a3ec6bacde0e8381db0423a656a5689eafb8857f Mon Sep 17 00:00:00 2001
From: liushaowen <565850092@qq.com>
Date: Fri, 6 Nov 2020 15:29:08 +0800
Subject: [PATCH 9/9] =?UTF-8?q?url=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/epmet/controller/CustomerAgencyController.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
index 6701fc7bee..3d14c14ea7 100644
--- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
+++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerAgencyController.java
@@ -255,7 +255,7 @@ public class CustomerAgencyController {
      * @Author liushaowen
      * @Date 2020/11/6 13:51
      */
-    @PostMapping("getAgencyElementTree")
+    @PostMapping("getagencyelementtree")
     public Result<AgencyElementTreeResultDTO> getAgencyElementTree(String customerId){
         if (StringUtils.isBlank(customerId)){
             throw new RenException("customerId不能为空");