方法修改

src/main/java/com/gic/message/constant/Constants.java

 package com.gic.message.constant;
 
+/**
+ * 
+ * @ClassName: Constants
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 public class Constants {
     public static final String INSERT = "INSERT";
     public static final String UPDATE = "UPDATE";

src/main/java/com/gic/message/dao/mapper/TestMapper.java

 package com.gic.message.dao.mapper;
-
+/**
+ * 
+ * @ClassName: TestMapper
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 public class TestMapper {
 }

src/main/java/com/gic/message/entity/TabCity.java

@@ -5,6 +5,13 @@ import java.util.Date;
 /**
  * tab_city
  */
+/**
+ * 
+ * @ClassName: TabCity
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 public class TabCity {
     /**
      * 城市id

src/main/java/com/gic/message/service/MessageHandler.java

@@ -2,7 +2,22 @@ package com.gic.message.service;
 
 import com.gic.binlog.base.entity.GicRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
-
+/**
+ * 
+ * @ClassName: MessageHandler
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 public interface MessageHandler {
+    /**
+     * handler 
+     * @Title: handler
+     * @Description: 
+     * @author zhiwj 
+     * @param consumerRecord
+     * @return void
+     * @throws 
+     */
     void handler(ConsumerRecord<String, GicRecord> consumerRecord);
 }

src/main/java/com/gic/message/service/impl/KafkaMessageServiceImpl.java

 package com.gic.message.service.impl;
 
-import com.alibaba.fastjson.JSON;
 import com.gic.binlog.base.entity.GicRecord;
 import com.gic.message.service.MessageHandler;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -8,7 +7,13 @@ import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.listener.MessageListener;
-
+/**
+ * 
+ * @ClassName: KafkaMessageServiceImpl
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 public class KafkaMessageServiceImpl implements MessageListener<String, GicRecord> {
     private static final Logger log = LogManager.getLogger(KafkaMessageServiceImpl.class);
     @Autowired

src/main/java/com/gic/message/service/impl/MessageHandlerInit.java

@@ -8,6 +8,13 @@ import javax.annotation.PostConstruct;
 import java.util.HashMap;
 import java.util.Map;
 
+/**
+ * 
+ * @ClassName: MessageHandlerInit
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 @Component
 public class MessageHandlerInit {
     @Autowired

src/main/java/com/gic/message/service/impl/StoreCustomMessageHandler.java

@@ -25,9 +25,19 @@ import org.springframework.stereotype.Component;
 
 import java.util.List;
 import java.util.Map;
-
+/**
+ * 
+ * @ClassName: StoreCustomMessageHandler
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 @Component
 public class StoreCustomMessageHandler implements MessageHandler {
+
+    private static final String OLD_VALUE = "old_value";
+    private static final String NEW_VALUE = "new_value";
+
     @Autowired
     private StoreApiService storeApiService;
     @Autowired
@@ -55,7 +65,7 @@ public class StoreCustomMessageHandler implements MessageHandler {
             enterpriseId = Integer.valueOf(fieldMap.get("new_enterprise_id").getValue());
             storeFieldId = Integer.valueOf(fieldMap.get("new_store_field_id").getValue());
             storeInfoId = Integer.valueOf(fieldMap.get("new_store_info_id").getValue());
-            if(!fieldMap.get("old_value").getValue().equals(fieldMap.get("new_value").getValue())){
+            if(!fieldMap.get(OLD_VALUE).getValue().equals(fieldMap.get(NEW_VALUE).getValue())){
                 this.dealCustomChange(enterpriseId, storeFieldId, storeInfoId, fieldMap);
             }
         }
@@ -91,7 +101,7 @@ public class StoreCustomMessageHandler implements MessageHandler {
                 }
                 StoreWidgetDTO storeWidgetDTO = storeWidget.getResult();
                 if(storeWidgetDTO != null){
-                    if(AuthModeEnum.YES.getCode() == storeWidgetDTO.getAuthMode()){
+                    if(AuthModeEnum.YES.getCode().equals(storeWidgetDTO.getAuthMode())){
                         StoreSearchDTO storeSearchDTO = new StoreSearchDTO();
                         storeSearchDTO.setStoreInfoIds(String.valueOf(storeInfoId));
                         storeSearchDTO.setSearchJson(storeWidgetDTO.getSearchParam());

src/main/java/com/gic/message/service/impl/StoreIndexRefreshHandler.java

@@ -6,7 +6,13 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.concurrent.TimeUnit;
-
+/**
+ * 
+ * @ClassName: StoreIndexRefreshHandler
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 @Component
 public class StoreIndexRefreshHandler {
     @Autowired
@@ -17,7 +23,7 @@ public class StoreIndexRefreshHandler {
         Object cache = RedisUtil.getCache(key);
         if(cache == null){
             this.storeApiService.addStoreToIndex(enterpriseId, storeId);
-            RedisUtil.setCache(key, storeId, 1l, TimeUnit.SECONDS);
+            RedisUtil.setCache(key, storeId, 1L, TimeUnit.SECONDS);
         }
     }
 }

src/main/java/com/gic/message/service/impl/StoreInfoMessageHandler.java

@@ -25,7 +25,13 @@ import org.springframework.stereotype.Component;
 
 import java.util.List;
 import java.util.Map;
-
+/**
+ * 
+ * @ClassName: StoreInfoMessageHandler
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 @Component
 public class StoreInfoMessageHandler implements MessageHandler {
     @Autowired
@@ -91,7 +97,7 @@ public class StoreInfoMessageHandler implements MessageHandler {
                 }
                 StoreWidgetDTO storeWidgetDTO = storeWidget.getResult();
                 if(storeWidgetDTO != null){
-                    if(AuthModeEnum.YES.getCode() == storeWidgetDTO.getAuthMode()){
+                    if(AuthModeEnum.YES.getCode().equals(storeWidgetDTO.getAuthMode())){
                         StoreSearchDTO storeSearchDTO = new StoreSearchDTO();
                         storeSearchDTO.setStoreInfoIds(String.valueOf(storeInfoId));
                         storeSearchDTO.setSearchJson(storeWidgetDTO.getSearchParam());
@@ -109,7 +115,7 @@ public class StoreInfoMessageHandler implements MessageHandler {
                         }else {
                             this.storeAuthorizationApiService.cancelStore(storeInfoId, dto.getUnionEnterpriseId());
                         }
-                        if(Integer.valueOf(fieldMap.get("old_region_id").getValue()) != Integer.valueOf(fieldMap.get("new_region_id").getValue())){
+                        if(!Integer.valueOf(fieldMap.get("old_region_id").getValue()).equals(Integer.valueOf(fieldMap.get("new_region_id").getValue()))){
                             StoreSearchDTO storeSearchDTO1 = new StoreSearchDTO();
                             storeSearchDTO1.setRegionId(Integer.valueOf(fieldMap.get("old_region_id").getValue()));
                             storeSearchDTO1.setSearchJson(storeWidgetDTO.getSearchParam());

src/main/java/com/gic/message/service/impl/StoreMessageHandler.java

@@ -24,9 +24,21 @@ import org.springframework.stereotype.Component;
 
 import java.util.List;
 import java.util.Map;
-
+/**
+ * 
+ * @ClassName: StoreMessageHandler
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 @Component
 public class StoreMessageHandler implements MessageHandler {
+
+    public static final String OLD_STATUS = "old_status";
+    public static final String NEW_STATUS = "new_status";
+    public static final String NEW_OWN_TYPE = "new_own_type";
+    public static final Integer NEW_STATUS_VALUE = 2;
+
     @Autowired
     private StoreApiService storeApiService;
     @Autowired
@@ -57,14 +69,14 @@ public class StoreMessageHandler implements MessageHandler {
             enterpriseId = Integer.valueOf(fieldMap.get("new_enterprise_id").getValue());
             storeId = Integer.valueOf(fieldMap.get("new_store_id").getValue());
             storeInfoId = Integer.valueOf(fieldMap.get("new_store_info_id").getValue());
-            if (Integer.valueOf(fieldMap.get("old_status").getValue()) == 1 && Integer.valueOf(fieldMap.get("new_status").getValue()) == 0) {  //删除
+            if (Integer.valueOf(fieldMap.get(OLD_STATUS).getValue()) == 1 && Integer.valueOf(fieldMap.get(NEW_STATUS).getValue()) == 0) {  //删除
                 this.storeApiService.deleteStoreFromEs(enterpriseId, storeId);
-            } else if (Integer.valueOf(fieldMap.get("old_status").getValue()) == 1 && Integer.valueOf(fieldMap.get("new_status").getValue()) == 2){  //下线
+            } else if (Integer.valueOf(fieldMap.get(OLD_STATUS).getValue()) == 1 && Integer.valueOf(fieldMap.get(NEW_STATUS).getValue()) == NEW_STATUS_VALUE){  //下线
                 //todo 通知会员组（积分成本转移）
             }else {
                 this.storeIndexRefreshHandler.refreshStoreIndex(enterpriseId, storeId);
             }
-            if (StoreOwnTypeEnum.OWNER.getCode() == Integer.valueOf(fieldMap.get("new_own_type").getValue())) {
+            if (StoreOwnTypeEnum.OWNER.getCode() == Integer.valueOf(fieldMap.get(NEW_OWN_TYPE).getValue())) {
                 this.dealStoreChange(enterpriseId, storeId, storeInfoId, GicRecordType.UPDATE.value());
             }
         }
@@ -90,7 +102,7 @@ public class StoreMessageHandler implements MessageHandler {
                 }
                 StoreWidgetDTO storeWidgetDTO = storeWidget.getResult();
                 if(storeWidgetDTO != null){
-                    if(AuthModeEnum.YES.getCode() == storeWidgetDTO.getAuthMode()){
+                    if(AuthModeEnum.YES.getCode().equals(storeWidgetDTO.getAuthMode())){
                         StoreSearchDTO storeSearchDTO = new StoreSearchDTO();
                         storeSearchDTO.setStoreIds(String.valueOf(storeId));
                         storeSearchDTO.setSearchJson(storeWidgetDTO.getSearchParam());

src/main/java/com/gic/message/utils/ListToMapUtil.java

@@ -8,7 +8,13 @@ import org.apache.kafka.clients.consumer.ConsumerRecord;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-
+/**
+ * 
+ * @ClassName: ListToMapUtil
+ * @Description:  
+ * @author zhiwj
+ * @date 2020-09-10 15:10
+ */
 public class ListToMapUtil {
     public static Map<String, GicField> listToMap(ConsumerRecord<String, GicRecord> consumerRecord){
         GicRecord value = consumerRecord.value();