dxhy-consumer/src/main/java/com/dxhy/entrance/dxhyconsumer/aop/SimsOrderSysLogAspect.java

@@ -9,7 +9,6 @@ import com.dxhy.base.thirdservice.module.thirdservice.itax.model.SysLogEntity;
 import com.dxhy.order.baseservice.annotation.SysLog;
 import com.dxhy.order.baseservice.constant.NsrQueueEnum;
 import com.dxhy.order.baseservice.constant.OrderEnum;
-import com.dxhy.order.consumer.modules.bespoke.config.datasource.config.DynamicContextHolder;
 import com.dxhy.order.invoice.module.rabbitmq.model.RabbitMqCommonMessage;
 import com.dxhy.order.invoice.module.rabbitmq.service.RabbitMqSendMessageService;
 import lombok.extern.slf4j.Slf4j;
@@ -60,7 +59,6 @@ public class SimsOrderSysLogAspect {
     public Object around(ProceedingJoinPoint point) throws Throwable {
 
         long beginTime = System.currentTimeMillis();
-        DynamicContextHolder.push(com.dxhy.management.common.constant.ConfigureConstant.MAIN);
         //执行方法
         Object result = point.proceed();
         //执行时长(毫秒)

order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/controller/OrderHandleController.java

@@ -192,8 +192,6 @@ public class OrderHandleController {
         } catch (Exception e){
             log.error("{}保存订单异常", LOGGER_MSG, e);
             return R.error("保存订单异常请联系运维人员");
-        }finally {
-            DynamicContextHolder.push(com.dxhy.management.common.constant.ConfigureConstant.MAIN);
         }
 
 

order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/OrderHandleServiceImpl.java

@@ -369,7 +369,6 @@ public class OrderHandleServiceImpl implements OrderHandleService {
 
         if (!ConfigureConstant.STRING_0000.equals(fileModel.getCode())){
             updatePushErrorMsgToDb(commonTsMqData.getFpTsMqData().getFpqqlsh(),fileModel.getMsg(), shList);
-            return R.error(fileModel.getMsg());
         }
 
         String orderId = orderInvoiceInfo.getOrderInfoId();
@@ -402,7 +401,6 @@ public class OrderHandleServiceImpl implements OrderHandleService {
         if (CollectionUtils.isEmpty(orderOriginExtendInfos)){
             updatePushErrorMsgToDb(commonTsMqData.getFpTsMqData().getFpqqlsh(),"原始订单信息不存在无法进行推送", shList);
             log.error("原始订单信息不存在无法进行推送");
-            return R.error("原始订单信息不存在");
         }
         OrderService orderService = SpringUtil.getBean(serviceConfig.getService(commonTsMqData.getNsrsbh()), OrderService.class);
         R r;

order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/SkOrderServiceImpl.java

@@ -93,12 +93,11 @@ public class SkOrderServiceImpl implements OrderService {
     public R orderRead(ReqParam reqParam) {
 
 
-        int count = ConfigureConstant.INT_0;
-        try {
         DynamicContextHolder.push(reqParam.getNsrsbh());
         List<SkOrderInfo> skOrderInfoList = skOrderMapper.findOrderHeadList(reqParam);
         log.debug("查询到订单数据:{}", JSON.toJSONString(skOrderInfoList));
 
+        int count = ConfigureConstant.INT_0;
         if (CollectionUtils.isNotEmpty(skOrderInfoList)) {
             for (SkOrderInfo skOrderInfo : skOrderInfoList) {
 
@@ -114,13 +113,6 @@ public class SkOrderServiceImpl implements OrderService {
 
             }
         }
-        }catch (Exception e) {
-            log.error("订单读取异常", e);
-            return R.error("订单读取异常");
-        } finally {
-            DynamicContextHolder.push(ConfigureConstant.MAIN);
-        }
-
         return R.ok("成功读取" + count + "条订单数据");
     }
 

order-management-order/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/InvoiceDataServiceImpl.java

@@ -112,9 +112,9 @@ public class InvoiceDataServiceImpl implements InvoiceDataService {
             commonTsMqData.setNsrsbh(orderInvoiceInfo.getXhfNsrsbh());
             commonTsMqData.setEntId(orderInvoiceInfo.getEntId());
             commonTsMqData.setFpTsMqData(fpTsMqData);
-            rabbitMqSendMessageService.autoSendRabbitMqMessageForBusiness(NsrQueueEnum.PUSH_MESSAGE.getValue(), JsonUtils.getInstance().toJsonString(commonTsMqData));
+//            rabbitMqSendMessageService.autoSendRabbitMqMessageForBusiness(NsrQueueEnum.PUSH_MESSAGE.getValue(), JsonUtils.getInstance().toJsonString(commonTsMqData));
 
-//            orderHandleService.backMsg(JSON.toJSONString(commonTsMqData));
+            orderHandleService.backMsg(JSON.toJSONString(commonTsMqData));
             successCount++;
 
         }