Merge remote-tracking branch 'origin/developer' into developer

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

@@ -149,6 +149,9 @@ public class StaffClerkRelationDTO implements Serializable {
     }
 
     public Integer getOpenConcatFlag() {
+        if(null == openConcatFlag) {
+            return 0 ;
+        }
         return openConcatFlag;
     }
 

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

+package com.gic.haoban.manage.api.dto.qdto;
+
+import java.io.Serializable;
+
+
+/**
+ * 导购删除、门店转移、新增修改店长
+ *
+ * @author mozhu
+ * @date 2022-07-15 10:33:15
+ */
+public class ClerkSyncQDTO implements Serializable {
+
+    private static final long serialVersionUID = 3952563675969267345L;
+
+    private String clerkId;
+
+    private String storeId;
+
+    private String clerkCode;
+
+    private String enterpriseId;
+
+    private Integer status;
+
+    private Integer oldStatus;
+    /**
+     * 1:删除；2：门店转移；3：导购其他数据变动
+     */
+    private Integer type;
+
+    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;
+    }
+
+    public Integer getOldStatus() {
+        return oldStatus;
+    }
+
+    public void setOldStatus(Integer oldStatus) {
+        this.oldStatus = oldStatus;
+    }
+
+    public Integer getType() {
+        return type;
+    }
+
+    public void setType(Integer type) {
+        this.type = type;
+    }
+}

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

@@ -187,13 +187,13 @@ public interface StaffClerkRelationApiService {
 
 
     /**
-     * 导购门店转移
-     * clerkStoreMoveMq
+     * 导购门店转移或者删除
+     * clerkStoreMoveDelMq
      *
      * @param param 参数
      * @author mozhu
      * @date 2022-07-12 18:57:15
      */
-    void clerkStoreMove(String param);
+    void clerkStoreMoveDel(String param);
 
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/hm/WxUserAddLogMapper.java

@@ -26,6 +26,8 @@ public interface WxUserAddLogMapper {
      */
     public int insert(TabWxUserAddLog entity);
 
+    public int updateMemberInfo(TabWxUserAddLog entity);
+
     /**
      * 
     * @Title: listAllForDel
@@ -47,9 +49,9 @@ public interface WxUserAddLogMapper {
     * @return
     * @throws
      */
-    public TabWxUserAddLog selectNewLog(@Param("externalUserid")String externalUserid, @Param("wxUserId")String wxUserId);
-    
-    
+    public TabWxUserAddLog selectNewLog(@Param("externalUserid") String externalUserid,
+            @Param("wxUserId") String wxUserId);
+
     /**
      * 
     * @Title: listAllForDel

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

@@ -27,7 +27,19 @@ public interface WxUserAddLogService {
      */
     public void save(WxUserAddLogQDTO qdto);
     
-    public void updateMemberInfo(String wxEnterpriseId , String wxUserId , String externalUserid , String memberId) ;
+    /**
+     * 
+    * @Title: updateMemberInfo
+    * @Description: 更新会员信息
+    * @author xugh
+    * @param wxEnterpriseId
+    * @param enterpriseId
+    * @param staffId
+    * @param externalUserid
+    * @param memberId
+    * @throws
+     */
+    public void updateMemberInfo(String wxEnterpriseId , String enterpriseId , String staffId , String externalUserid , String memberId) ;
     
     /**
      * 

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

 package com.gic.haoban.manage.service.service.hm.impl;
 
+import java.util.Date;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -109,18 +111,31 @@ public class WxUserAddLogServiceImpl implements WxUserAddLogService {
         this.wxUserAddLogMapper.insert(entity);
 
     }
-    
+
     @Override
-    public void updateMemberInfo(String wxEnterpriseId,  String wxUserId , String externalUserid, String memberId) {
-        
+    public void updateMemberInfo(String wxEnterpriseId, String enterpriseId, String staffId, String externalUserid,
+            String memberId) {
+        if (StringUtils.isNotBlank(memberId)) {
+            TabWxUserAddLog entity = new TabWxUserAddLog();
+            entity = this.addMemberInfo(enterpriseId, memberId, entity);
+            entity.setEnterpriseId(enterpriseId);
+            entity.setWxEnterpriseId(wxEnterpriseId);
+            entity.setExternalUserid(externalUserid);
+            entity.setStaffId(staffId);
+            if (null != entity) {
+                entity.setCreateTime(new Date());
+                this.wxUserAddLogMapper.updateMemberInfo(entity);
+            }
+        }
     }
-    
+
     // 冗余会员信息
     private TabWxUserAddLog addMemberInfo(String enterpriseId, String memberId, TabWxUserAddLog entity) {
         String returnFields = "memberId,photoUrl,name,nickName,cardNo,gradeId,gradeName,phoneNumber";
         JSONObject memberObj = this.memberQueryService.queryDataSingle(enterpriseId, memberId, returnFields);
         if (null == memberObj) {
-            return entity;
+            log.info("会员不存在,memberId={}", memberId);
+            return null;
         }
         MemberDataDTO memberDataDTO = memberObj.toJavaObject(MemberDataDTO.class);
         entity.setMemberId(memberId);

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

@@ -381,7 +381,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
         }
 
         log.info("插入加好友日志");
-        wxUserAddLogService.updateMemberInfo(wxEnterpriseId,externalUserId,memberId);
+        wxUserAddLogService.updateMemberInfo(wxEnterpriseId,enterpriseId,staffId,externalUserId,memberId);
     }
 
     /**

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

@@ -56,10 +56,10 @@ public class HmGroupApiServiceImpl implements HmGroupApiService {
     public ServiceResponse<Long> saveOrUpdateHmGroupSetting(HmGroupDTO hmGroupDTO) {
         log.info("[saveOrUpdateHmGroupSetting] params:{}", JSON.toJSONString(hmGroupDTO));
         if (StringUtils.isBlank(hmGroupDTO.getGroupName())) {
-            return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", HaoBanErrCodeCommon.ERR_5.getMsg());
+            return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", "分组名称不存在");
         }
         if (StringUtils.equals(DEFAULT_GROUP_NAME, hmGroupDTO.getGroupName())) {
-            return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_9.getCode() + "", HaoBanErrCodeCommon.ERR_9.getMsg());
+            return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_9.getCode() + "", "分组名称不可使用默认分组名称");
         }
         HmGroupInfoQO groupInfoQo = new HmGroupInfoQO();
         groupInfoQo.setGroupName(hmGroupDTO.getGroupName());
@@ -71,19 +71,19 @@ public class HmGroupApiServiceImpl implements HmGroupApiService {
             // insert
             // check groupName unique
             if (CollectionUtils.isNotEmpty(hmGroupSettingPage.getResult())) {
-                return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", HaoBanErrCodeCommon.ERR_5.getMsg());
+                return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", "该分组名称已存在，请重新输入");
             }
         } else {
             // update
             if (CollectionUtils.isNotEmpty(hmGroupSettingPage.getResult())
                     && hmGroupSettingPage.getTotalCount() > 1) {
                 // 名称重复
-                return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", HaoBanErrCodeCommon.ERR_5.getMsg());
+                return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", "该分组名称已存在，请重新输入");
             }
             if (CollectionUtils.isNotEmpty(hmGroupSettingPage.getResult())
                     && !hmGroupSettingPage.getResult().get(0).getGroupId().equals(hmGroupDTO.getGroupId())) {
                 // 名称重复
-                return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", HaoBanErrCodeCommon.ERR_5.getMsg());
+                return ServiceResponse.failure(HaoBanErrCodeCommon.ERR_5.getCode() + "", "该分组名称已存在，请重新输入");
             }
             HmGroupSettingBO groupSettingBo = groupService.queryGroupSettingDetail(hmGroupDTO.getGroupId());
             if (groupSettingBo == null) {

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

@@ -279,6 +279,7 @@ public class HmLinkApiServiceImpl implements HmLinkApiService {
             if (openFlag == 1) {
                 // 门店规则1推荐门店 2附件门店
                 int storeType = storeRuleObj.getIntValue("store_type");
+                // 过滤有活码的门店
                 List<HmLinkStoreDTO> storeList = this.hmLinkStoreService.listByLinkId(wxEnterpriseId, enterpriseId,
                         linkId);
                 log.info("门店规则={},推荐门店列表={}", storeType, JSON.toJSONString(storeList));

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

@@ -75,11 +75,14 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
         }
         BinlogBasePojo pojo = binlogChange(record.value());
         logger.info("binlog数据：{}", JSONObject.toJSONString(pojo));
-
+        if (pojo == null) {
+            logger.error("binlog数据为空");
+            return;
+        }
         if (record.value().getTableName().equals(CLERK)) {
-            dealClerk((ClerkSyncPojo) pojo);
-            //发消息处理新增店长，任务重新分配问题
             ClerkSyncPojo syncPojo = (ClerkSyncPojo) pojo;
+            dealClerk(syncPojo);
+            //发消息处理新增店长，任务重新分配问题
             GicRecordType gicRecordType = GicRecordType.valueOf(syncPojo.getRecordType());
             if (gicRecordType.equals(GicRecordType.INSERT)
                     || gicRecordType.equals(GicRecordType.UPDATE)) {
@@ -96,6 +99,7 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
                     try {
                         logger.info("待分配任务重分配======>{}", clerkId);
                         MqMessageQo mqMessageQo = new MqMessageQo();
+                        //任务分配给店长
                         mqMessageQo.setType(MqMessageQo.DISTRIBUTE_TASK);
                         mqMessageQo.setData(clerkId);
                         String s = JSONObject.toJSONString(mqMessageQo);
@@ -106,11 +110,13 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
                     }
                 }
             }
+        }
+        else if (record.value().getTableName().equals(GROUP)) {
             //分组
-        } else if (record.value().getTableName().equals(GROUP)) {
             dealStoreGroup((GroupSyncPojo) pojo);
+        }
+        else if (record.value().getTableName().equals(STORE)) {
             //门店
-        } else if (record.value().getTableName().equals(STORE)) {
             dealStore((StoreSyncPojo) pojo);
         }
     }

haoban-manage3-service/src/main/resources/dubbo-haoban-manage-service.xml

@@ -176,6 +176,7 @@
                      interface="com.gic.enterprise.api.service.StoreWidgetService" timeout="10000"
                      retries="0" check="false"/>
    <dubbo:reference interface="com.gic.enterprise.api.service.EnterpriseUseForbidService" id="enterpriseUseForbidService"/>                  
+   <dubbo:reference id="memberTagOpenApiService" interface="com.gic.member.tag.api.service.MemberTagOpenApiService" timeout="10000" retries="0" check="false"/>
                      
 
 

haoban-manage3-service/src/main/resources/mapper/hm/WxUserAddLogMapper.xml

@@ -106,7 +106,8 @@
 	  member_label_name,
 	  create_time,
 	  update_time,
-	  all_del_flag
+	  add_time ,
+	  all_del_flag 
   )VALUES(
 	  #{logId,jdbcType=BIGINT},
 	  #{wxEnterpriseId,jdbcType=VARCHAR},
@@ -139,11 +140,31 @@
 	  #{memberLabelName,jdbcType=VARCHAR},
 	  now(),
 	  now(),
+	  now(),
 	  #{allDelFlag,jdbcType=INTEGER}
   )
   ]]>
 	</insert>
 
+
+	<update id="updateMemberInfo" parameterType="com.gic.haoban.manage.service.entity.hm.TabWxUserAddLog">
+		  UPDATE tab_haoban_wx_user_add_log SET
+			  member_id=#{memberId,jdbcType=VARCHAR},
+			  member_name=#{memberName,jdbcType=VARCHAR},
+			  member_nick=#{memberNick,jdbcType=VARCHAR},
+			  member_image=#{memberImage,jdbcType=VARCHAR},
+			  member_phone=#{memberPhone,jdbcType=VARCHAR},
+			  member_grade_id=#{memberGradeId,jdbcType=VARCHAR},
+			  member_grade_name=#{memberGradeName,jdbcType=VARCHAR},
+			  member_card_no=#{memberCardNo,jdbcType=VARCHAR},
+			  <if test="null != createTime">
+			  	 create_time = #{createTime} ,
+			  </if>
+			  update_time=now()  WHERE 
+		    external_userid=#{externalUserid} and staff_id=#{staffId} and membre_id is null 
+	</update>
+
+
 	<select id="listAllForDel"
 		parameterType="com.gic.haoban.manage.service.entity.hm.TabWxUserAddLog"
 		resultMap="result-map-tabHaobanWxUserAddLog">
@@ -162,10 +183,13 @@
 		status_flag != 0 order by create_time desc limit 1
 	</select>
 
-	<select id="listForPage" parameterType="com.gic.haoban.manage.api.dto.qdto.hm.WxUserAddLogSearchQDTO" resultMap="result-map-tabHaobanWxUserAddLog">
+	<select id="listForPage"
+		parameterType="com.gic.haoban.manage.api.dto.qdto.hm.WxUserAddLogSearchQDTO"
+		resultMap="result-map-tabHaobanWxUserAddLog">
 		select
 		<include refid="Base_Column_List" />
 		from tab_haoban_wx_user_add_log where 1
-		and status_flag != 0 order by create_time desc 
+		and status_flag != 0 order by
+		create_time desc
 	</select>
 </mapper> 
\ No newline at end of file

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

@@ -23,6 +23,7 @@ import com.gic.haoban.manage.api.enums.hm.HmWelcomeType;
 import com.gic.haoban.manage.api.service.hm.HmWelcomeRelationApiService;
 import com.gic.haoban.manage.api.service.out.WelcomeApiService;
 import com.gic.haoban.manage.web.errCode.HaoBanErrCode;
+import com.gic.haoban.manage.web.log.LogRecordAfterServiceImpl;
 import com.gic.haoban.manage.web.log.LogRecordUserServiceImpl;
 import com.gic.haoban.manage.web.qo.welcome.ListWelcomeQO;
 import com.gic.haoban.manage.web.qo.welcome.SaveFriendSettingQO;
@@ -31,6 +32,7 @@ import com.gic.log.record.anno.GicLogRecord;
 import com.gic.log.record.util.GicLogRecordCategoryEnum;
 import com.gic.log.record.util.GicLogRecordEvaluationContext;
 import com.gic.log.record.util.GicLogRecordOptTypeEnum;
+import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -83,7 +85,7 @@ public class WelcomeController extends WebBaseController {
      * @date : 2022/2/11
      */
     @GicLogRecord(value = "${#logContent}", category = GicLogRecordCategoryEnum.HUOMA, optType = GicLogRecordOptTypeEnum.WELCOME_ADD
-            ,optPage = "引流链接-落地页模板", userFunc = LogRecordUserServiceImpl.class )
+            ,optPage = "欢迎语设置-新建欢迎语", userFunc = LogRecordUserServiceImpl.class, afterFunc = LogRecordAfterServiceImpl.class)
     @RequestMapping(value = "/save", method = RequestMethod.POST)
     public RestResponse<Boolean> saveWelcome(@RequestBody @Valid SaveWelcomeQO qo) {
         WebLoginDTO login = AuthWebRequestUtil.getLoginUser();
@@ -107,19 +109,27 @@ public class WelcomeController extends WebBaseController {
             qdto.setType(HmWelcomeType.NORMAL.getCode());
         }
         String logContent = "";
+        if (HmWelcomeType.NORMAL.getCode().equals(qdto.getType())){
+            GicLogRecordEvaluationContext.putAttribute(LogRecordAfterServiceImpl.WELCOME_TYPE, HmWelcomeType.NORMAL.getCode());
+            logContent = "新增普通欢迎语";
+        }else {
+            GicLogRecordEvaluationContext.putAttribute(LogRecordAfterServiceImpl.WELCOME_TYPE, HmWelcomeType.SPECIAL.getCode());
+            logContent = "新增特殊欢迎语";
+        }
         if (qdto.getWelcomeId() == null) {
-            logContent = "新增特殊欢迎语【" + qdto.getTitle() + "】";
+            logContent = logContent + "【" + qdto.getTitle() + "】";
+            GicLogRecordEvaluationContext.putAttribute(LogRecordAfterServiceImpl.WELCOME_OPT, "add");
         } else {
+            GicLogRecordEvaluationContext.putAttribute(LogRecordAfterServiceImpl.WELCOME_OPT, "edit");
             ServiceResponse<WelcomeDetailDTO> welcomeResult = welcomeApiService.getWelcome(qdto.getWelcomeId(), qdto.getWxEnterpriseId());
             if (welcomeResult.getResult() != null) {
-                //
                 WelcomeDetailDTO welcomeDetail = welcomeResult.getResult();
                 logContent = this.buildEditWelcomeOpLog(welcomeDetail, qdto);
             }
         }
         GicLogRecordEvaluationContext.putAttribute("logContent", logContent);
         ServiceResponse<Boolean> response = welcomeApiService.saveWelcome(qdto);
-        if (response.isSuccess()){
+        if (!response.isSuccess()){
             GicLogRecordEvaluationContext.noWriteLog();
         }
         return RestResponse.successResult(response.getResult());
@@ -141,8 +151,10 @@ public class WelcomeController extends WebBaseController {
             oldMedia.add(WelcomeMediaTypeEnum.getDescByCode(welcomeMediaDTO.getMediaType()) + "-" + welcomeMediaDTO.getMediaTitle());
         }
         List<String> newMedia = new ArrayList<>();
-        for (SaveWelcomeMediaQDTO saveWelcomeMediaQDTO : qdto.getWelcomeMediaList()) {
-            newMedia.add(WelcomeMediaTypeEnum.getDescByCode(saveWelcomeMediaQDTO.getMediaType()) + "-" + saveWelcomeMediaQDTO.getMediaTitle());
+        if (CollectionUtils.isNotEmpty(qdto.getWelcomeMediaList())) {
+            for (SaveWelcomeMediaQDTO saveWelcomeMediaQDTO : qdto.getWelcomeMediaList()) {
+                newMedia.add(WelcomeMediaTypeEnum.getDescByCode(saveWelcomeMediaQDTO.getMediaType()) + "-" + saveWelcomeMediaQDTO.getMediaTitle());
+            }
         }
         stringBuilder.append(StringUtils.join(oldMedia, "、"))
                 .append("」变更为「")
@@ -160,7 +172,7 @@ public class WelcomeController extends WebBaseController {
      * @date : 2022/2/11
      */
     @GicLogRecord(value = "${#logContent}", category = GicLogRecordCategoryEnum.HUOMA, optType = GicLogRecordOptTypeEnum.WELCOM_DEL
-            ,optPage = "引流链接-落地页模板", userFunc = LogRecordUserServiceImpl.class )
+            ,optPage = "欢迎语设置-特殊欢迎语", userFunc = LogRecordUserServiceImpl.class )
     @RequestMapping(value = "/remove")
     public RestResponse<?> removeWelcome(@RequestParam("welcomeId") String welcomeId) {
         if (StringUtils.isEmpty(welcomeId)) {

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/log/LogRecordAfterServiceImpl.java

+package com.gic.haoban.manage.web.log;
+
+import com.gic.log.record.bean.GicLogRecordBean;
+import com.gic.log.record.service.LogRecordAfterService;
+import com.gic.log.record.util.GicLogRecordEvaluationContext;
+import com.gic.log.record.util.GicLogRecordOptTypeEnum;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author MUSI
+ * @Date 2022/7/15 11:50 AM
+ * @Description
+ * @Version
+ **/
+@Component
+public class LogRecordAfterServiceImpl extends LogRecordAfterService {
+
+    public static final String WELCOME_TYPE = "welcome_type";
+    public static final String WELCOME_OPT = "welcome_opt";
+
+    @Override
+    public void deal(GicLogRecordBean gicLogRecordBean) {
+        String value = GicLogRecordEvaluationContext.getAttribute(WELCOME_OPT, String.class);
+        if ("add".equals(value)){
+            // 新建普通欢迎语
+            this.changeLogRecordOptType(gicLogRecordBean, GicLogRecordOptTypeEnum.WELCOME_ADD);
+        }
+        if (StringUtils.equals("edit", value)){
+            // 编辑普通欢迎语
+            this.changeLogRecordOptType(gicLogRecordBean, GicLogRecordOptTypeEnum.WELCOM_UPDATE);
+        }
+    }
+
+    private void changeLogRecordOptType(GicLogRecordBean gicLogRecordBean, GicLogRecordOptTypeEnum optTypeEnum){
+        if (gicLogRecordBean == null || optTypeEnum == null){
+            return;
+        }
+        gicLogRecordBean.setOptType(optTypeEnum.getType());
+        gicLogRecordBean.setOptTypeName(optTypeEnum.getName());
+        gicLogRecordBean.setSystemType(optTypeEnum.getSystemType());
+    }
+}