修改 如果 新增 controller报错后 发送mq的逻辑

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/inner/GoblinConsumerServiceImpl.java

@@ -8,6 +8,7 @@ import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.dto.PhoneDto;
 import com.liquidnet.service.goblin.service.manage.IGoblinConsumerService;
+import com.liquidnet.service.goblin.util.QueueUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -21,6 +22,8 @@ public class GoblinConsumerServiceImpl implements IGoblinConsumerService {
 
     @Autowired
     private RedisUtil redisUtil;
+    @Autowired
+    private QueueUtils queueUtils;
 
     @Override
     public ResponseDto<Boolean> consumerType12(String finalSkuId, Integer finalType, String xlsPath) {
@@ -45,6 +48,8 @@ public class GoblinConsumerServiceImpl implements IGoblinConsumerService {
                 }
             })).sheet().doRead();
         } catch (Exception e) {
+            queueUtils.sendMsgByRedisXls(xlsPath, finalType.toString(), finalSkuId);
+            log.error("指定购买 xls 异常 ：",e);
             return ResponseDto.failure();
         }
         return ResponseDto.success();
@@ -86,6 +91,8 @@ public class GoblinConsumerServiceImpl implements IGoblinConsumerService {
                 })).sheet().doRead();
             }
         } catch (Exception e) {
+            queueUtils.sendMsgByRedisXls(listId, xlsPath, oXlsPath, finalType.toString(), finalSkuId);
+            log.error("分批购 xls 异常 ：",e);
             return ResponseDto.failure();
         }
         return ResponseDto.success();

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinConsumerServiceImpl.java

@@ -2,6 +2,7 @@ package com.liquidnet.service.kylin.service.impl;
 
 import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.service.base.ErrorMapping;
+import com.liquidnet.service.base.OrderCloseMapping;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
@@ -18,6 +19,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.LinkedList;
 
 
 /**
@@ -34,17 +36,27 @@ public class KylinConsumerServiceImpl implements IKylinConsmerService {
 
     @Autowired
     DataUtils dataUtils;
+    @Autowired
+    private QueueUtils queueUtils;
 
 
     @Override
     public ResponseDto<Boolean> orderTransferOverTime(String orderId) {
-        KylinOrderTicketVo vo = dataUtils.getOrderTicketVo(orderId);
-        String uid = vo.getTransferUid();
-        vo.setTransferUid("");
-        vo.setTransferStatus(0);
-        dataUtils.delTransferOrder(uid);
-        dataUtils.setOrderTicketVo(orderId, vo);
-        dataUtils.resetOrderListVo(vo.getUserId(), 2, orderId, vo);
-        return null;
+        try {
+            KylinOrderTicketVo vo = dataUtils.getOrderTicketVo(orderId);
+            String uid = vo.getTransferUid();
+            vo.setTransferUid("");
+            vo.setTransferStatus(0);
+            dataUtils.delTransferOrder(uid);
+            dataUtils.setOrderTicketVo(orderId, vo);
+            dataUtils.resetOrderListVo(vo.getUserId(), 2, orderId, vo);
+            return ResponseDto.success();
+        }catch (Exception e){
+            LinkedList<String> mqList = new LinkedList<>();
+            mqList.add(orderId);
+            queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_TRANSFER_OVERTIME.getKey(), OrderCloseMapping.get(mqList));
+            log.error("转赠 过期 异常 ：",e);
+            return ResponseDto.failure();
+        }
     }
 }