同步来客吧商户激活和商城订单数据

kxs-product/kxs-product-biz/src/main/java/com/kxs/product/biz/mq/RabbitKxsOrderQueueListener.java

@@ -1,14 +1,11 @@
 package com.kxs.product.biz.mq;
 
 import com.alibaba.fastjson.JSON;
-import com.kxs.common.core.constant.SecurityConstants;
 import com.kxs.product.api.amqp.rabbit.RabbitKxsOrderQueueMQ;
 import com.kxs.product.api.amqp.rabbit.RabbitShopTimeoutQueueMQ;
 import com.kxs.product.api.model.KxsShopOrder;
 import com.kxs.product.biz.constant.enums.KxsShopEnum;
 import com.kxs.product.biz.service.KxsShopOrderService;
-import com.kxs.system.api.dto.kxsapp.camp.CampAddBcqtTeamDTO;
-import com.kxs.system.api.feign.RemoteUserService;
 import com.rabbitmq.client.Channel;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -30,7 +27,6 @@ import java.io.IOException;
 @Slf4j
 @RequiredArgsConstructor
 public class RabbitKxsOrderQueueListener {
-	private final RemoteUserService remoteUserService;
 
 	/**
 	 * 监听 老平台订单队列
@@ -45,10 +41,7 @@ public class RabbitKxsOrderQueueListener {
 			RabbitKxsOrderQueueMQ.MsgEntity parse = RabbitKxsOrderQueueMQ.parse(msg);
 			//处理百城千团订单，创建活动
 			if(parse.getProductId() == 100 && parse.getStatus() == 2){
-				CampAddBcqtTeamDTO campAddBcqtTeamDTO = new CampAddBcqtTeamDTO();
-				campAddBcqtTeamDTO.setCaptainId(Long.valueOf(parse.getUserId()));
-				campAddBcqtTeamDTO.setTeamName(parse.getRemark());
-				remoteUserService.addBcqtTeam(campAddBcqtTeamDTO, SecurityConstants.FROM_IN);
+
 			}
 
 			channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);

kxs-stat/kxs-stat-biz/src/main/java/com/kxs/stat/biz/mq/RabbitLkbQueueListener.java

@@ -115,7 +115,7 @@ public class RabbitLkbQueueListener {
             try {
                 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
             } catch (IOException ex) {
-                log.error("来客吧商户激活消费失败" + ex.getMessage(), ex);
+                log.error("来客吧商户激活手动确认失败" + ex.getMessage(), ex);
             }
         }
     }
@@ -221,7 +221,7 @@ public class RabbitLkbQueueListener {
             try {
                 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
             } catch (IOException ex) {
-                log.error("来客吧交易数据消费失败" + ex.getMessage(), ex);
+                log.error("来客吧交易数据手动确认失败" + ex.getMessage(), ex);
             }
         }
     }