111

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

@@ -78,14 +78,15 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             //TODO 发消息处理新增店长，任务重新分配问题
             ClerkSyncPojo syncPojo = (ClerkSyncPojo)pojo;
             GicRecordType gicRecordType = GicRecordType.valueOf(syncPojo.getRecordType());
-            if(gicRecordType.equals(GicRecordType.INSERT)){
-            	//新增店长
+            if(gicRecordType.equals(GicRecordType.INSERT) || gicRecordType.equals(GicRecordType.UPDATE)){
+            	//新增,更新某个人为店长
             	String clerkId = syncPojo.getClerkId();
             	ClerkDTO clerkDTO = clerkService.getClerkByClerkId(clerkId);
             	Integer clerkType = clerkDTO.getClerkType();
             	if(clerkType != null && clerkType.intValue() == 1){
                     //TODO 发消息处理新增店长，任务重新分配问题
                     try {
+                    	logger.info("待分配任务重分配======>{}",clerkId);
                     	MqMessageQo mqMessageQo = new MqMessageQo();
                     	mqMessageQo.setType(MqMessageQo.DISTRIBUTE_TASK);
                     	mqMessageQo.setData(clerkId);