From 80ba91f12d32ce902bfb5e0c7129714cbdfc3e79 Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Sun, 25 Jun 2023 13:11:02 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=90=88=E5=B9=B6mq=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/factory/receiver/ErrorQueueHandler.java | 10 +++++----- .../snm/controller/PanFactoryDataController.java | 4 ++-- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/ErrorQueueHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/ErrorQueueHandler.java index 208643ffc..8410156ec 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/ErrorQueueHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/ErrorQueueHandler.java @@ -1,8 +1,8 @@ package com.logpm.factory.receiver; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; -import com.logpm.factory.snm.entity.PanOrderStatusLog; -import com.logpm.factory.snm.service.IPanOrderStatusLogService; +import com.logpm.factory.snm.entity.OrderStatusLog; +import com.logpm.factory.snm.service.IOrderStatusLogService; import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.RabbitConstant; @@ -27,7 +27,7 @@ import java.util.Map; public class ErrorQueueHandler { @Autowired - private IPanOrderStatusLogService panOrderStatusLogService; + private IOrderStatusLogService orderStatusLogService; @RabbitHandler public void orderStatusHandlerManualAck(Map map, Message message, Channel channel) { @@ -35,10 +35,10 @@ public class ErrorQueueHandler { final long deliveryTag = message.getMessageProperties().getDeliveryTag(); try { Long logId = (Long) map.get("logId"); - UpdateWrapper updateWrapper = new UpdateWrapper<>(); + UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.set("status",2) .eq("id",logId); - boolean updateFlag = panOrderStatusLogService.update(updateWrapper); + boolean updateFlag = orderStatusLogService.update(updateWrapper); if(updateFlag){ channel.basicAck(deliveryTag, false); }else{ diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/controller/PanFactoryDataController.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/controller/PanFactoryDataController.java index 01eb8801d..0746f1dc9 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/controller/PanFactoryDataController.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/controller/PanFactoryDataController.java @@ -172,7 +172,7 @@ public class PanFactoryDataController extends BladeController { try{ //先保存原始请求数据 - PanOrderStatusLog panOrderStatusLog = new PanOrderStatusLog(); + OrderStatusLog panOrderStatusLog = new OrderStatusLog(); panOrderStatusLog.setArgs(JSONObject.toJSONString(orderInfoDTO)); panOrderStatusLog.setStatus(1); panOrderStatusLog.setType(1); @@ -207,7 +207,7 @@ public class PanFactoryDataController extends BladeController { try{ //先保存原始请求数据 - PanOrderStatusLog panOrderStatusLog = new PanOrderStatusLog(); + OrderStatusLog panOrderStatusLog = new OrderStatusLog(); panOrderStatusLog.setArgs(JSONObject.toJSONString(orderStatusDTO)); panOrderStatusLog.setStatus(1); panOrderStatusLog.setType(2);