将CMQ替换为rabbitmq

admin

2024-10-16 62a447d89331aee1feae7724c7616aa1bb2cfe79

 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/LostOrderControllerV2.java

@@ -21,101 +21,103 @@
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.io.PrintWriter;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

/**
 * 动态
 * 
 * @author Administrator
 *
 * @author Administrator
 */
@Controller
@RequestMapping("api/v2/lostOrder")
public class LostOrderControllerV2 {

   @Resource
   private LostOrderService lostOrderService;
    @Resource
    private LostOrderService lostOrderService;

   @Resource
   private ConfigService configService;
    @Resource
    private ConfigService configService;


   @RequestMapping("findLostOrder")
   public void findLostOrder(AcceptData acceptData, LostOrder lostOrder, HttpServletRequest request, PrintWriter out) {
      Integer type = lostOrder.getType();
      if (type == null) {
         type = Constant.SOURCE_TYPE_TAOBAO;
      }
    @RequestMapping("findLostOrder")
    public void findLostOrder(AcceptData acceptData, LostOrder lostOrder, HttpServletRequest request, PrintWriter out) {
        Integer type = lostOrder.getType();
        if (type == null) {
            type = Constant.SOURCE_TYPE_TAOBAO;
        }

      boolean orderNum = true;
      String orderId = lostOrder.getOrderId();
      if (type == Constant.SOURCE_TYPE_TAOBAO) {
         if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 12 || orderId.length() > 20)) {
            orderNum = false;
         } else {
            orderNum = Utils.isOrderNum(orderId);
         }
      } else if (type == Constant.SOURCE_TYPE_JD) {
         if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 6 || orderId.length() > 20)) {
            orderNum = false;
         }
      } else if (type == Constant.SOURCE_TYPE_PDD) {
         if (!orderId.contains("-")) {
            orderNum = false;
         } else {
            String[] split = orderId.split("-");
            if (split == null || split.length != 2) {
               orderNum = false;
            } else {
               if (!NumberUtil.isNumeric(split[0]) || !NumberUtil.isNumeric(split[1])) {
                  orderNum = false;
               }
            }
         }
      } else if (type == Constant.SOURCE_TYPE_VIP) {
         if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 10 || orderId.length() > 18)) {
            orderNum = false;
         }
      } else if (type == Constant.SOURCE_TYPE_SUNING) {
         if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 10 || orderId.length() > 15)) {
            orderNum = false;
         }
      }
        boolean orderNum = true;
        String orderId = lostOrder.getOrderId();
        if (type == Constant.SOURCE_TYPE_TAOBAO) {
            if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 12 || orderId.length() > 20)) {
                orderNum = false;
            } else {
                orderNum = Utils.isOrderNum(orderId);
            }
        } else if (type == Constant.SOURCE_TYPE_JD) {
            if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 6 || orderId.length() > 20)) {
                orderNum = false;
            }
        } else if (type == Constant.SOURCE_TYPE_PDD) {
            if (!orderId.contains("-")) {
                orderNum = false;
            } else {
                String[] split = orderId.split("-");
                if (split == null || split.length != 2) {
                    orderNum = false;
                } else {
                    if (!NumberUtil.isNumeric(split[0]) || !NumberUtil.isNumeric(split[1])) {
                        orderNum = false;
                    }
                }
            }
        } else if (type == Constant.SOURCE_TYPE_VIP) {
            if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 10 || orderId.length() > 18)) {
                orderNum = false;
            }
        } else if (type == Constant.SOURCE_TYPE_SUNING) {
            if (!NumberUtil.isNumeric(orderId) || (orderId.length() < 10 || orderId.length() > 15)) {
                orderNum = false;
            }
        }

      if (lostOrder.getUserInfo() == null || lostOrder.getUserInfo().getId() == null
            || lostOrder.getUserInfo().getId() <= 0) {
         out.print(JsonUtil.loadFalseResult(1,
               String.format("请登录%s账号", Constant.getAppName(acceptData.getPlatform(), acceptData.getVersion()))));
         return;
      }
      lostOrder.setIpInfo(IPUtil.getRemotIP(request) + ":" + request.getRemotePort());
      int state;
      String stateInfo = "提交成功，请等待审核结果";
      if (!orderNum) {
         state = -4;
         stateInfo = "请提交准确的订单号";
      } else {
         lostOrder.setResultCode(LostOrder.RESULT_CODE_VERFING);
         state = lostOrderService.addLostOrder(lostOrder);
         if (state == -3) {
            stateInfo = "该订单已被统计，无需申诉";
         } else if (state == -2) {
            stateInfo = "请勿重复提交,该订单正在审核中";
         } else if (state == -1) {
            stateInfo = "该订单申诉已通过，请在订单列表中查看";
         } else if (state == -5) {
            stateInfo = "分享奖金订单无需申诉";
         } else if (state == -6) {
            stateInfo = "该订单申诉已失败，请在订单列表中查看";
         } else if (state == -7) {
            stateInfo = "今日申诉次数已达上限";
         } else if (state == -1001) {
            stateInfo = "订单违规";
         }
      }
      JSONObject data = new JSONObject();
      data.put("state", state);
      data.put("info", stateInfo);
      out.print(JsonUtil.loadTrueResult(data));
   }
        if (lostOrder.getUserInfo() == null || lostOrder.getUserInfo().getId() == null
                || lostOrder.getUserInfo().getId() <= 0) {
            out.print(JsonUtil.loadFalseResult(1,
                    String.format("请登录%s账号", Constant.getAppName(acceptData.getPlatform(), acceptData.getVersion()))));
            return;
        }
        lostOrder.setIpInfo(IPUtil.getRemotIP(request) + ":" + request.getRemotePort());
        int state;
        String stateInfo = "提交成功，请等待审核结果";
        if (!orderNum) {
            state = -4;
            stateInfo = "请提交准确的订单号";
        } else {
            lostOrder.setResultCode(LostOrder.RESULT_CODE_VERFING);
            state = lostOrderService.addLostOrder(lostOrder);
            if (state == -3) {
                stateInfo = "该订单已被统计，无需申诉";
            } else if (state == -2) {
                stateInfo = "请勿重复提交,该订单正在审核中";
            } else if (state == -1) {
                stateInfo = "该订单申诉已通过，请在订单列表中查看";
            } else if (state == -5) {
                stateInfo = "分享奖金订单无需申诉";
            } else if (state == -6) {
                stateInfo = "该订单申诉已失败，请在订单列表中查看";
            } else if (state == -7) {
                stateInfo = "今日申诉次数已达上限";
            } else if (state == -1001) {
                stateInfo = "订单违规";
            }
        }
        JSONObject data = new JSONObject();
        data.put("state", state);
        data.put("info", stateInfo);
        out.print(JsonUtil.loadTrueResult(data));
    }

}