换绑主导购清除建联状态

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

+package com.gic.haoban.manage.api.service.common;
+
+import com.gic.api.base.commons.ServiceResponse;
+
+/**
+ * @author: YuZhi
+ * @date: 2022/3/16 13:32
+ */
+public interface RouterApiService {
+
+    /**
+     * 会员导购通用事件订阅
+     * @param params
+     * @return
+     */
+    ServiceResponse<Void> memberClerkEvent(String params);
+
+}

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

+package com.gic.haoban.manage.service.service.out.impl.common;
+
+import com.alibaba.fastjson.JSONObject;
+import com.gic.api.base.commons.ServiceResponse;
+import com.gic.haoban.manage.api.service.common.RouterApiService;
+import com.gic.haoban.manage.service.service.contact.ContactLogService;
+import com.gic.member.api.dto.event.clerk.ClerkAddEventParam;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+
+@Service("routerApiService")
+public class RouterApiServiceImpl implements RouterApiService {
+
+    private static final Logger logger = LogManager.getLogger(RouterApiService.class);
+
+
+    @Autowired
+    private ContactLogService contactLogService;
+
+    @Override
+    public ServiceResponse<Void> memberClerkEvent(String params) {
+        if (StringUtils.isBlank(params)) {
+            return ServiceResponse.success();
+        }
+        ClerkAddEventParam clerkAddEventParam = JSONObject.parseObject(params, ClerkAddEventParam.class);
+        String memberId = clerkAddEventParam.getMemberId();
+        Integer changeType = clerkAddEventParam.getChangeType();
+        if (Objects.equals(changeType, 1)) {
+            // 换绑主导购清除建联状态
+            contactLogService.clearContactLog(memberId, 2);
+        }
+        return ServiceResponse.success();
+    }
+}

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

@@ -23,6 +23,8 @@ public class ContactOrderApiServiceImpl implements ContactOrderApiService {
     @Autowired
     private ContactOrderService contactOrderService;
     @Autowired
+    private ContactLogService contactLogService;
+    @Autowired
     private MemberOrderReadApiService memberOrderReadApiService;
 
     @Override
@@ -38,6 +40,7 @@ public class ContactOrderApiServiceImpl implements ContactOrderApiService {
         }
         OrderInfoResp result = serviceResponse.getResult();
         contactOrderService.saveContactOrder(result);
+        contactLogService.clearContactLog(memberId, 1);
         return ServiceResponse.success();
     }
 

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

@@ -28,6 +28,7 @@
     <dubbo:service interface="com.gic.haoban.manage.api.service.chat.GroupChatPlanApiService" ref="groupChatPlanApiService" timeout="10000"/>
     <dubbo:service interface="com.gic.haoban.manage.api.service.chat.GroupChatHmApiService" ref="groupChatHmApiService" timeout="10000"/>
     <dubbo:service interface="com.gic.haoban.manage.api.service.chat.GroupChatApiService" ref="groupChatApiService" timeout="10000"/>
+    <dubbo:service interface="com.gic.haoban.manage.api.service.common.RouterApiService" ref="routerApiService" timeout="10000"/>
     <!--  社群邀请有礼  -->
     <dubbo:service interface="com.gic.haoban.manage.api.service.chat.GroupChatActivityApiService" ref="groupChatActivityApiService" timeout="10000"/>
     <dubbo:service interface="com.gic.haoban.manage.api.service.chat.GroupChatActivityLogApiService" ref="groupChatActivityLogApiService" timeout="10000"/>