接口初始化

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

@@ -11,4 +11,25 @@ public interface StaffClerkRelationService {
 
 	List<StaffClerkRelationDTO> listBindCodeByStaffId(List<String> enterpriseIdList, String staffId);
 
+	/**
+	 * 删除绑定
+	 * @param clerkId
+	 * @return
+	 */
+	public boolean delBind(String clerkId);
+
+	/**
+	 * 绑定
+	 * @param dto
+	 * @return
+	 */
+	public boolean bind(StaffClerkRelationDTO dto);
+
+	/**
+	 * 根据clerkId 更新数据
+	 * @param dto
+	 * @return
+	 */
+	public boolean updateByClerkId(StaffClerkRelationDTO dto);
+
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/impl/StaffClerkRelationServiceImpl.java

@@ -25,4 +25,18 @@ public class StaffClerkRelationServiceImpl implements StaffClerkRelationService
 		return EntityUtil.changeEntityListByJSON(StaffClerkRelationDTO.class, mapper.listBindCodeByStaffId(enterpriseIdList,staffId));
 	}
 
+	@Override
+	public boolean delBind(String clerkId) {
+		return false;
+	}
+
+	@Override
+	public boolean bind(StaffClerkRelationDTO dto) {
+		return false;
+	}
+
+	@Override
+	public boolean updateByClerkId(StaffClerkRelationDTO dto) {
+		return false;
+	}
 }

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

@@ -37,12 +37,12 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
     @Override
     public void onMessage(ConsumerRecord<String, GicRecord> record) {
         logger.info("message：{}", JSONObject.toJSONString(record.value()));
-        String message = JSONObject.toJSONString(record.value());
-        if(StringUtils.isBlank(message)){
+        if(record.value()==null){
+            logger.info("数据为空");
             return;
         }
         BinlogBasePojo pojo = binlogChange(record.value());
-        logger.info("pojo：{}", JSONObject.toJSONString(pojo));
+        logger.info("binlog数据：{}", JSONObject.toJSONString(pojo));
 
 
     }