// 美团酒店更新推送处理调整

consumer-manager/consumer-basic/consumer-basic-biz/src/main/java/com/qls/consumer/biz/config/ReceiveHandlerBasic.java

@@ -11,7 +11,6 @@ import com.qls.core.dto.*;
 import com.qls.core.entity.HtHotel;
 import com.qls.core.entity.OpTaskStatus;
 import com.qls.mt.api.MtRemoteService;
-import com.qls.mt.module.callback.ProductChangeMessage;
 import com.qls.rabbitmq.SendMsg;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -53,7 +52,7 @@ public class ReceiveHandlerBasic {
         for (Message msg : list) {
             byte[] bytes = msg.getBody();
             ProductChangeMQ productChangeMQ = JSONObject.parseObject(bytes, ProductChangeMQ.class);
-            if (productChangeMQ.getPartnerId().equals(22116)) {
+            if (productChangeMQ.getPartnerId().equals(29082)) {
                 productChangeMQS1.add(productChangeMQ);
             } else {
                 productChangeMQS2.add(productChangeMQ);
@@ -64,14 +63,14 @@ public class ReceiveHandlerBasic {
             ProductChangeMQBatch productChangeMQBatch = new ProductChangeMQBatch();
             if (!productChangeMQS1.isEmpty()) {
                 productChangeMQBatch.setProductChangeMQS(productChangeMQS1);
-                productChangeMQBatch.setPartnerId(22116);
-                mtRemoteService.productBatch(productChangeMQBatch);
-            }
-            if (!productChangeMQS2.isEmpty()) {
-                productChangeMQBatch.setProductChangeMQS(productChangeMQS2);
-                productChangeMQBatch.setPartnerId(5173);
+                productChangeMQBatch.setPartnerId(29082);
                 mtRemoteService.productBatch(productChangeMQBatch);
             }
+//            if (!productChangeMQS2.isEmpty()) {
+//                productChangeMQBatch.setProductChangeMQS(productChangeMQS2);
+//                productChangeMQBatch.setPartnerId(5173);
+//                mtRemoteService.productBatch(productChangeMQBatch);
+//            }
         } catch (Exception e) {
             log.error("产品变化远程服务接口调用失败");
         }
@@ -141,7 +140,7 @@ public class ReceiveHandlerBasic {
             opTaskStatus.setStartTime(new Date());
             Integer taskCode = Integer.parseInt("" + System.currentTimeMillis() / 1000);
             opTaskStatus.setTaskCode(taskCode);
-            opTaskStatus.setDtId(61);
+            opTaskStatus.setDtId(1);
             opTaskStatusService.save(opTaskStatus);
             for (int i = 0; i < hotelArray.size(); i++) {
                 JSONObject hotel = hotelArray.getJSONObject(i);