Merge remote-tracking branch 'origin/developer' into developer

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/KafkaMessageServiceImpl.java

@@ -74,7 +74,7 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             return;
         }
         BinlogBasePojo pojo = binlogChange(record.value());
-        logger.info("binlog数据：{}", JSONObject.toJSONString(pojo));
+        logger.info("binlog数据接收：{}", JSONObject.toJSONString(pojo));
         if (pojo == null) {
             logger.error("binlog数据为空");
             return;
@@ -87,6 +87,9 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             //门店
             dealStore((StoreSyncPojo) pojo);
         }
+        else if (record.value().getTableName().equals(CLERK)) {
+           logger.info("导购binlog无需监听");
+        }
     }
 
     private void dealClerk(ClerkSyncPojo syncPojo) {
@@ -204,6 +207,7 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             logger.error("门店处理为空");
             return;
         }
+        logger.info("门店binlog监听:{}", JSONObject.toJSONString(syncPojo));
         if (syncPojo.getRecordType() == GicRecordType.UPDATE.value()
                 && (!syncPojo.getStoreName().equals(syncPojo.getOldStoreName()))) {
             logger.info("门店名称变更:{}", JSONObject.toJSONString(syncPojo));
@@ -244,6 +248,7 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
      * @param syncPojo
      */
     private void dealStoreGroup(GroupSyncPojo syncPojo) {
+        logger.info("门店分组变更binlog监听:{}", JSONObject.toJSONString(syncPojo));
         //删除 同步绑定门店
         if (syncPojo!= null && syncPojo.getOldStatus() == 1 && syncPojo.getStatus() == 0) {
             logger.info("门店分组变更，同步绑定门店：{}", JSONObject.toJSONString(syncPojo));