feature: 销售线索 字段

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

@@ -3,21 +3,27 @@ package com.gic.haoban.manage.service.service.out.impl.content;
 import com.alibaba.fastjson.JSON;
 import com.gic.api.base.commons.Page;
 import com.gic.api.base.commons.ServiceResponse;
+import com.gic.commons.util.GICMQClientUtil;
 import com.gic.haoban.manage.api.dto.qdto.content.InteractRecordQDTO;
 import com.gic.haoban.manage.api.enums.content.InteractRecordExtendInfoDTO;
 import com.gic.haoban.manage.api.enums.content.InteractRecordInfoDTO;
 import com.gic.haoban.manage.api.service.content.InteractRecordApiService;
 import com.gic.haoban.manage.service.pojo.bo.content.InteractRecordBO;
 import com.gic.haoban.manage.service.pojo.bo.content.MemberAttrChangeBO;
+import com.gic.haoban.manage.service.pojo.bo.content.binlog.MemberOrderBo;
 import com.gic.haoban.manage.service.pojo.qo.content.InteractRecordQO;
 import com.gic.haoban.manage.service.service.content.InteractRecordService;
 import com.gic.haoban.manage.service.service.content.PotentialCustomerService;
 import com.gic.haoban.manage.service.service.content.adaptor.MaterialEnterpriseAdaptor;
+import com.gic.haoban.manage.service.task.KafkaMessageServiceImpl;
 import com.gic.member.api.dto.event.lifecycle.CreateMemberEventParam;
 import com.gic.member.api.dto.info.MemberSummaryInfoDTO;
 import com.gic.member.api.dto.info.qo.QueryMemberInfoDTO;
 import com.gic.member.api.service.MemberOutApiService;
+import com.gic.order.api.constant.OrderChannelEnum;
 import com.gic.order.api.dto.OrderSaveNotifyDTO;
+import com.gic.order.api.dto.resp.OrderInfoResp;
+import com.gic.order.api.service.member.MemberOrderReadApiService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -47,6 +53,8 @@ public class InteractRecordApiServiceImpl implements InteractRecordApiService {
     private MaterialEnterpriseAdaptor materialEnterpriseAdaptor;
     @Autowired
     MemberOutApiService memberOutApiService;
+    @Autowired
+    private MemberOrderReadApiService memberOrderReadApiService;
 
     /**
      * 查询互动记录
@@ -135,10 +143,10 @@ public class InteractRecordApiServiceImpl implements InteractRecordApiService {
      */
     @Override
     public ServiceResponse<Void> dealMemberOnlineOrder(String params) {
-        return dealMemberOrder(params);
+        return dealMemberOrder(params, true);
     }
 
-    private ServiceResponse<Void> dealMemberOrder(String params) {
+    private ServiceResponse<Void> dealMemberOrder(String params, boolean isOnlineOrder) {
         if (StringUtils.isBlank(params)) {
             return ServiceResponse.success();
         }
@@ -149,6 +157,45 @@ public class InteractRecordApiServiceImpl implements InteractRecordApiService {
             return ServiceResponse.success();
         }
         potentialCustomerService.updateMemberDealFlag(orderSaveNotifyDTO.getEnterpriseId(), orderSaveNotifyDTO.getMemberId());
+
+        String enterpriseId = orderSaveNotifyDTO.getEnterpriseId();
+        String memberId = orderSaveNotifyDTO.getMemberId();
+        String orderId = orderSaveNotifyDTO.getOrderId();
+
+        ServiceResponse<OrderInfoResp> serviceResponse =
+                memberOrderReadApiService.getOrder(enterpriseId, memberId, orderId, isOnlineOrder);
+        if (!serviceResponse.isSuccess() || serviceResponse.getResult() == null) {
+            log.info("获取订单信息异常 {}", JSON.toJSONString(serviceResponse));
+            return ServiceResponse.success();
+        }
+        OrderInfoResp orderInfoResp = serviceResponse.getResult();
+        if (orderInfoResp.getOrderType() == null || OrderChannelEnum.WEIMOB.getSort() != orderInfoResp.getOrderType()) {
+            log.info("订单 {} 非微盟渠道", orderId);
+            return ServiceResponse.success();
+        }
+
+        MemberOrderBo memberOrderBo = new MemberOrderBo();
+        memberOrderBo.setEnterpriseId(orderSaveNotifyDTO.getEnterpriseId());
+        memberOrderBo.setMemberId(orderSaveNotifyDTO.getMemberId());
+        memberOrderBo.setOrderId(orderSaveNotifyDTO.getOrderId());
+        memberOrderBo.setOrderNumber(orderInfoResp.getRorderNumber());
+        memberOrderBo.setOrderTime(orderInfoResp.getOrderTime());
+        if (isOnlineOrder) {
+            memberOrderBo.setTableName(KafkaMessageServiceImpl.tab_gic_eorder);
+        }else {
+            memberOrderBo.setTableName(KafkaMessageServiceImpl.tab_gic_order);
+        }
+
+        try {
+            log.info("发送微盟订单处理消息 {}", params);
+            /**
+             * @see com.gic.haoban.manage.api.service.content.MallOrderStatusChangeApiService#dealWeimoOrder(String)
+             */
+            GICMQClientUtil.getClientInstance().sendMessage("dealWeimoOrderForInteractRecord", JSON.toJSONString(memberOrderBo), 120);
+        }catch (Exception ex) {
+            log.info("处理会员订单异常 ", ex);
+        }
+
         return ServiceResponse.success();
     }
 
@@ -160,7 +207,7 @@ public class InteractRecordApiServiceImpl implements InteractRecordApiService {
      */
     @Override
     public ServiceResponse<Void> dealMemberOffLineOrder(String params) {
-        return dealMemberOrder(params);
+        return dealMemberOrder(params, false);
     }
 
     /**