新增店长

haoban-manage3-service/pom.xml

@@ -72,6 +72,12 @@
         </dependency>
         <dependency>
             <groupId>com.gic</groupId>
+            <artifactId>haoban-task-api</artifactId>
+            <version>${haoban-task-api}</version>
+        </dependency>
+        
+        <dependency>
+            <groupId>com.gic</groupId>
             <artifactId>haoban-contacts-api</artifactId>
             <version>${haoban-contacts-api}</version>
         </dependency>

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

@@ -4,7 +4,10 @@ import com.alibaba.fastjson.JSONObject;
 import com.gic.binlog.base.entity.GicField;
 import com.gic.binlog.base.entity.GicRecord;
 import com.gic.binlog.base.entity.enums.GicRecordType;
+import com.gic.clerk.api.dto.ClerkDTO;
+import com.gic.clerk.api.service.ClerkService;
 import com.gic.commons.util.EntityUtil;
+import com.gic.commons.util.GICMQClientUtil;
 import com.gic.dubbo.entity.ProviderLocalTag;
 import com.gic.haoban.base.api.common.ServiceResponse;
 import com.gic.haoban.contacts.manage.api.enums.StatusEnum;
@@ -16,6 +19,11 @@ import com.gic.haoban.manage.service.pojo.BinlogBasePojo;
 import com.gic.haoban.manage.service.pojo.ClerkSyncPojo;
 import com.gic.haoban.manage.service.service.StaffClerkBindLogService;
 import com.gic.haoban.manage.service.service.StaffClerkRelationService;
+import com.gic.haoban.task.api.dto.MqMessageQo;
+import com.gic.mq.sdk.exception.RouterException;
+import com.gic.qcloud.cmq.CMQClientException;
+import com.gic.qcloud.cmq.CMQServerException;
+
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.time.DateUtils;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -47,8 +55,10 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
 
     @Autowired
     private StaffClerkRelationApiService staffClerkRelationApiService;
-
-
+    
+    @Autowired
+    private ClerkService clerkService;
+    
 
     @Override
     public void onMessage(ConsumerRecord<String, GicRecord> record) {
@@ -65,6 +75,28 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
 
         if (record.value().getTableName().equals(CLERK)) {
             dealClerk((ClerkSyncPojo)pojo);
+            //TODO 发消息处理新增店长，任务重新分配问题
+            ClerkSyncPojo syncPojo = (ClerkSyncPojo)pojo;
+            GicRecordType gicRecordType = GicRecordType.valueOf(syncPojo.getRecordType());
+            if(gicRecordType.equals(GicRecordType.INSERT)){
+            	//新增店长
+            	String clerkId = syncPojo.getClerkId();
+            	ClerkDTO clerkDTO = clerkService.getClerkByClerkId(clerkId);
+            	Integer clerkType = clerkDTO.getClerkType();
+            	if(clerkType != null && clerkType.intValue() == 1){
+                    //TODO 发消息处理新增店长，任务重新分配问题
+                    try {
+                    	MqMessageQo mqMessageQo = new MqMessageQo();
+                    	mqMessageQo.setType(MqMessageQo.DISTRIBUTE_TASK);
+                    	mqMessageQo.setData(clerkId);
+                    	String s = JSONObject.toJSONString(mqMessageQo);
+						GICMQClientUtil.getClientInstance().sendCommonMessage(RouterConstant.ROUTERTYPE, s,
+								"com.gic.haoban.task.api.service.MqAsynApiService", "run");
+					} catch (Exception e) {
+						e.printStackTrace();
+					}
+            	}
+            }
         }
     }