Merge branch 'developer' of http://115.159.76.241/haoban3.0/haoban-manage3.0.git into developer

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/dto/AuditStaffDTO.java

+package com.gic.haoban.manage.api.dto;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+public class AuditStaffDTO implements Serializable{
+	
+	private String staffId;
+	
+	private String wxEnterpriseId;
+
+    private String wxUserId;
+
+    private String clerkId;
+
+    private String clerkName;
+
+    private String clerkCode;
+
+    private String staffName;
+    
+    private String headPic;
+    
+    private Integer bindType;
+    
+    private Integer addOrDel;
+
+    private static final long serialVersionUID = 1L;
+
+	public String getStaffId() {
+		return staffId;
+	}
+
+	public void setStaffId(String staffId) {
+		this.staffId = staffId;
+	}
+
+	public String getWxEnterpriseId() {
+		return wxEnterpriseId;
+	}
+
+	public void setWxEnterpriseId(String wxEnterpriseId) {
+		this.wxEnterpriseId = wxEnterpriseId;
+	}
+
+	public String getWxUserId() {
+		return wxUserId;
+	}
+
+	public void setWxUserId(String wxUserId) {
+		this.wxUserId = wxUserId;
+	}
+
+	public String getClerkId() {
+		return clerkId;
+	}
+
+	public void setClerkId(String clerkId) {
+		this.clerkId = clerkId;
+	}
+
+	public String getClerkName() {
+		return clerkName;
+	}
+
+	public void setClerkName(String clerkName) {
+		this.clerkName = clerkName;
+	}
+
+	public String getClerkCode() {
+		return clerkCode;
+	}
+
+	public void setClerkCode(String clerkCode) {
+		this.clerkCode = clerkCode;
+	}
+
+	public String getStaffName() {
+		return staffName;
+	}
+
+	public void setStaffName(String staffName) {
+		this.staffName = staffName;
+	}
+
+	public String getHeadPic() {
+		return headPic;
+	}
+
+	public void setHeadPic(String headPic) {
+		this.headPic = headPic;
+	}
+
+	public Integer getBindType() {
+		return bindType;
+	}
+
+	public void setBindType(Integer bindType) {
+		this.bindType = bindType;
+	}
+
+	public Integer getAddOrDel() {
+		return addOrDel;
+	}
+
+	public void setAddOrDel(Integer addOrDel) {
+		this.addOrDel = addOrDel;
+	}
+
+    
+}

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

@@ -14,7 +14,7 @@ public interface AuditApiService {
 	
 	Page<AuditDTO> page(Integer auditType, String search,String wxEnterpriseId,String enterpriseId,Integer auditStatus,Integer auditFlag,BasePageInfo pageInfo);
 	
-	void audit(String auditId,String aduitName);
+	String audit(String auditId,String aduitName);
 	
 	void refuse(String auditId,String auditReason,String aduitName);
 	

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

+package com.gic.haoban.manage.service.pojo;
+
+import com.gic.binlog.base.entity.enums.GicRecordType;
+
+import java.io.Serializable;
+
+/**
+ * Created 2020/5/27.
+ *
+ * @author hua
+ */
+public class BinlogBasePojo implements Serializable {
+    protected int recordType;
+    protected String prefix;
+
+    public void setRecordType(int recordType) {
+        this.recordType = recordType;
+    }
+
+    public int getRecordType() {
+        return recordType;
+    }
+    public String getPrefix() {
+        return prefix;
+    }
+
+}

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

+package com.gic.haoban.manage.service.pojo;
+
+import com.alibaba.fastjson.annotation.JSONField;
+
+import java.io.Serializable;
+
+/**
+ * Created 2020/5/27.
+ *
+ * @author hua
+ */
+public class ClerkSyncPojo extends BinlogBasePojo {
+    @JSONField(name = "clerk_id")
+    private String clerkId;
+
+    @JSONField(name = "storeId")
+    private String storeId;
+
+    @JSONField(name = "clerk_code")
+    private String clerkCode;
+
+    @JSONField(name = "enterprise_id")
+    private String enterpriseId;
+
+    private Integer status;
+
+    public ClerkSyncPojo() {
+        prefix="clerk";
+    }
+
+    public String getClerkId() {
+        return clerkId;
+    }
+
+    public void setClerkId(String clerkId) {
+        this.clerkId = clerkId;
+    }
+
+    public String getStoreId() {
+        return storeId;
+    }
+
+    public void setStoreId(String storeId) {
+        this.storeId = storeId;
+    }
+
+    public String getClerkCode() {
+        return clerkCode;
+    }
+
+    public void setClerkCode(String clerkCode) {
+        this.clerkCode = clerkCode;
+    }
+
+    public String getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(String enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+}

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

@@ -116,10 +116,10 @@ public class AuditApiServiceImpl implements AuditApiService{
 	}
 	@Transactional
 	@Override
-	public void audit(String auditId,String auditName) {
+	public String audit(String auditId,String auditName) {
 		TabHaobanAudit tab = auditMapper.selectByPrimaryKey(auditId);
 		if(tab==null){
-			return;
+			return "1";
 		}
 		tab.setAuditId(auditId);
 		tab.setAuditStatus(1);
@@ -140,6 +140,7 @@ public class AuditApiServiceImpl implements AuditApiService{
 		TabHaobanAudit tab2 = auditMapper.selectByPrimaryKey(auditId);
 		String staffId = tab2.getCommitStaffId();
 		this.sendMessageByStaffId(staffId, storeId, title, content);
+		return "";
 	}
 	@Override
 	public void refuse(String auditId, String auditReason,String auditName) {

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.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.commons.util.BeanUtil;
+import com.gic.commons.util.EntityUtil;
+import com.gic.haoban.manage.service.pojo.BinlogBasePojo;
+import com.gic.haoban.manage.service.pojo.ClerkSyncPojo;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.kafka.listener.MessageListener;
 
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
 /**
  * Created 2019/4/10.
  *
@@ -22,6 +33,7 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
     private final  String CLERK = "tab_gic_clerk";
 
 
+
     @Override
     public void onMessage(ConsumerRecord<String, GicRecord> record) {
         logger.info("message：{}", JSONObject.toJSONString(record.value()));
@@ -29,6 +41,33 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
         if(StringUtils.isBlank(message)){
             return;
         }
+        BinlogBasePojo pojo = binlogChange(record.value());
+        logger.info("pojo：{}", JSONObject.toJSONString(pojo));
+
+
+    }
+
+    private BinlogBasePojo binlogChange(GicRecord record) {
+        ClerkSyncPojo pojo=new ClerkSyncPojo();
+        pojo.setRecordType(record.getRecordType().value());
+        if(record.getTableName().equals(CLERK)) {
+            return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class);
+        }else if (record.getTableName().equals(STORE)) {
+            return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class);
+        }else{
+            return null;
+        }
+    }
+
+    private BinlogBasePojo binlogMap(List<GicField> list,GicRecordType recordType,Class<? extends BinlogBasePojo> aclass) {
+        Map<String,String> mid=new HashMap<>();
+        for (GicField gicField : list) {
+            mid.put(gicField.getName(),gicField.getValue());
+        }
+        BinlogBasePojo pojo = EntityUtil.changeEntityByJSON(aclass, mid);
+        pojo.setRecordType(recordType.value());
+        return pojo;
+
     }
 
 

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/AuditController.java

@@ -14,6 +14,7 @@ import com.gic.enterprise.api.dto.StoreDTO;
 import com.gic.enterprise.api.service.StoreService;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.common.utils.GlobalVar;
+import com.gic.haoban.common.utils.UuidUtil;
 import com.gic.haoban.manage.api.dto.*;
 import com.gic.haoban.manage.api.enums.StoreFieldEnum;
 import com.gic.haoban.manage.api.service.ApplicationSettingApiService;
@@ -100,6 +101,7 @@ public class AuditController extends WebBaseController{
 		List<StoreDTO> stores = storeService.getStores(array);
 		Map<String,StoreDTO> map = com.gic.commons.util.CollectionUtil.toMap(stores, "storeId");
 		for(AuditDTO dto:list){
+			if(dto.getAuditType() !=null && dto.getAuditType()== 1){
 				String t = dto.getChangeField();
 				String detail = "";
 				if(StoreFieldEnum.STORE_NAME.getValue().equals(t)){
@@ -123,6 +125,42 @@ public class AuditController extends WebBaseController{
 					detail = "门店图片变更";
 				}
 				dto.setDetail(detail);
+			}else if(dto.getAuditType() !=null && dto.getAuditType()== 2){
+				//门店账户申请
+				String oldValue = dto.getOldValue();
+				String newValue = dto.getNewValue();
+				AuditStaffDTO auditStaffDTO = JSONObject.parseObject(oldValue, AuditStaffDTO.class);
+				Integer t = auditStaffDTO.getAddOrDel();
+				if(t == 0){
+					//新增导购
+					String detail = "新增导购："+auditStaffDTO.getClerkName()+"("+auditStaffDTO.getClerkCode()+")";
+					dto.setDetail(detail);
+				}else{
+					//删除导购
+					String detail = "删除导购："+auditStaffDTO.getClerkName()+"("+auditStaffDTO.getClerkCode()+")";
+					dto.setDetail(detail);
+				}
+			}else if(dto.getAuditType() !=null && dto.getAuditType()== 3){
+				//门店导购变更
+				//门店账户申请
+				String oldValue = dto.getOldValue();
+				AuditStaffDTO oldAuditStaffDTO = JSONObject.parseObject(oldValue, AuditStaffDTO.class);
+				Integer t = oldAuditStaffDTO.getBindType();
+				if(t == 0){
+					//绑定
+					String staffName = oldAuditStaffDTO.getStaffName();
+					String clerkCode = oldAuditStaffDTO.getClerkCode();
+					String detail = staffName+"申请关联导购code:"+clerkCode;
+					dto.setDetail(detail);
+				}else{
+					//解绑
+					String staffName = oldAuditStaffDTO.getStaffName();
+					String clerkCode = oldAuditStaffDTO.getClerkCode();
+					String detail = staffName+"申请解绑导购code："+clerkCode;
+					dto.setDetail(detail);
+				}
+				
+			}
 			String storeName = map.get(dto.getCommitStoreId())==null?"":map.get(dto.getCommitStoreId()).getStoreName();
 			dto.setCommitStoreName(storeName);
 		}
@@ -137,14 +175,32 @@ public class AuditController extends WebBaseController{
 			return resultResponse(HaoBanErrCode.ERR_2);
 		}
 		StaffDTO staffDTO = staffApiService.selectById(staffId);
-//		StaffVO staffVO = new StaffVO();
-//		staffVO.setPhoneNumber(phoneNumber);
-//		staffVO.setNationCode(nationCode);
-//		staffVO.setPostion(postion);
 		return resultResponse(HaoBanErrCode.ERR_1,staffDTO);
 	}
 	
-	
+	//批量同意
+	@HttpLimit
+	@RequestMapping("batch-approve")
+	public HaobanResponse batchApprove(String auditIds,String auditName ) {
+		if(StringUtils.isAnyBlank(auditIds)){
+			return resultResponse(HaoBanErrCode.ERR_2);
+		}
+		String[] s = auditIds.split(",");
+		int successCount = 0;
+		int failCount = 0;
+		String batchId = UuidUtil.randomUUID();
+		for(String auditId : s){
+			String result = auditApiService.audit(auditId,auditName);
+			if(StringUtils.isEmpty(result)){
+				successCount = successCount+1;
+				//TODO 插入批量日志
+			}else{
+				failCount = failCount+1;
+				//TODO 插入批量日志
+			}
+		}
+		return resultResponse(HaoBanErrCode.ERR_1);
+	}
 	
 	//审核拒绝
 	@HttpLimit