登录测试

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

 package com.gic.haoban.manage.service.task;
 
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.gic.binlog.base.entity.GicRecord;
-import com.gic.clerk.api.dto.ClerkListDTO;
 import com.gic.clerk.api.service.ClerkService;
-import com.gic.haoban.common.utils.StringUtil;
-import com.gic.haoban.communicate.api.dto.SyncJsonColumnDTO;
-import com.gic.haoban.communicate.api.dto.SyncJsonDTO;
-import com.gic.haoban.contacts.api.dto.EmployeeClerkAddDTO;
-import com.gic.haoban.contacts.api.service.EmployeeClerkService;
-import com.gic.haoban.contacts.manage.api.dto.DepartmentStoreGroupDTO;
-import com.gic.haoban.contacts.manage.api.service.DepartmentStoreGroupService;
 import com.gic.haoban.contacts.manage.api.service.StoreService;
 import com.gic.haoban.manage.api.service.StaffApiService;
 import org.apache.commons.lang3.StringUtils;
@@ -22,9 +12,6 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.listener.MessageListener;
 
-import java.util.ArrayList;
-import java.util.List;
-
 /**
  * Created 2019/4/10.
  *
@@ -38,10 +25,6 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
 
     private final  String CLERK = "tab_gic_clerk";
     
-    private final String DEPARTMENT = "tab_gic_store_group";
-    
-    private final String STORE_IMAGE = "tab_gic_store_photo";
-    
     @Autowired
     private StoreService storeService;
 
@@ -58,25 +41,6 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
         if(StringUtils.isBlank(message)){
             return;
         }
-//        SyncJsonDTO syncJsonDTO = JSON.toJavaObject((JSONObject)JSON.parse(message),SyncJsonDTO.class);
-//        String fieldListString = syncJsonDTO.getFieldList();
-//        String tableName = syncJsonDTO.getTableName();
-        if(tableName.equals(STORE)){
-        	logger.info("【同步门店】");
-        	String haobanClerkListString = setClerkList(fieldListString);
-        	logger.info("【同步门店】haobanClerkListString={}",haobanClerkListString);
-            storeService.syncGicStore(fieldListString,haobanClerkListString);
-            
-        }else if (tableName.equals(CLERK)){
-        	logger.info("【同步店员】");
-        	try {
-        		employeeClerkService.syncGicClerk(fieldListString);
-			} catch (Exception e) {
-				logger.info("【同步店员】同步失败={}",e.toString());
-			}
-        	
-        	staffApiService.syncGicClerk(fieldListString);
-        }
     }
 
 

haoban-manage3-service/src/main/resources/applicationContext-conf.xml

@@ -5,6 +5,7 @@
 
     <import resource="classpath:gic-haoban-init.xml" />
     <import resource="classpath*:redis-init.xml"/>
+    <import resource="classpath*:kafka-setting.xml"/>
     <import resource="classpath:dubbo-haoban-manage-service.xml" />
     <import resource="classpath:dubbo-setting-test.xml"/>
     <import resource="classpath:jdbc-haoban-manage-service.xml" />