diff --git a/mallinkService/src/main/java/com/iformall/common/ErrorCode.java b/mallinkService/src/main/java/com/iformall/common/ErrorCode.java index 635ab2750..459ea05d8 100644 --- a/mallinkService/src/main/java/com/iformall/common/ErrorCode.java +++ b/mallinkService/src/main/java/com/iformall/common/ErrorCode.java @@ -152,6 +152,9 @@ public enum ErrorCode{ ORDER_PRESS_IS_OVERTIME(3010, "砍价已过期"), ORDER_PRESS_IS_COMPLETE(3011, "砍价已完成"), ORDER_UNPAID(3012, "您有未支付的订单"), + ORDER_USER_NOT_MATCH(2013, "订单用户不匹配"), + ORDER_COUPON_CHANNEL_NOT_MATCH(2014, "订单渠道不匹配"), + ORDER_COUPON_NOT_MATCH(2015, "订单券不匹配"), /** * 卡券 diff --git a/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideOrderSuccessMsgServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideOrderSuccessMsgServiceImpl.java index 652616f42..daad81d89 100644 --- a/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideOrderSuccessMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideOrderSuccessMsgServiceImpl.java @@ -1,11 +1,13 @@ package com.iformall.service.msg.impl; +import com.iformall.common.ErrorCode; import com.iformall.domain.po.WxCUser; import com.iformall.domain.po.WxCoupon; import com.iformall.domain.po.WxCouponChannel; import com.iformall.domain.po.WxOrder; import com.iformall.domain.po.msg.BaseMsg; import com.iformall.domain.po.msg.FmInsideOrderSuccessMsg; +import com.iformall.exception.MallinkException; import com.iformall.service.WxCUserService; import com.iformall.service.WxCouponChannelService; import com.iformall.service.WxCouponService; @@ -45,25 +47,31 @@ public class FmInsideOrderSuccessMsgServiceImpl implements MsgSendService { WxOrder record = orderService.getById(msg.getOrderId()); if(record == null) { logger.error("订单未找到" + msg.getOrderId()); + throw new MallinkException(ErrorCode.ORDER_IS_NOT_FIND.getCode(), "订单未找到" + msg.getOrderId()); } if(record.getcUserId() != msg.getCUserId()) { logger.error("订单用户不一致" + msg.getOrderId()); + throw new MallinkException(ErrorCode.ORDER_USER_NOT_MATCH.getCode(), "订单用户不一致" + msg.getOrderId()); } WxCouponChannel couponChannel = couponChannelService.getById(record.getCouponChannelId()); if(couponChannel == null) { logger.error("投放渠道未找到" + record.getCouponChannelId()); + throw new MallinkException(ErrorCode.ORDER_COUPON_CHANNEL_NOT_MATCH.getCode(), "投放渠道未找到" + record.getCouponChannelId()); } if(couponChannel.getCouponId() != msg.getCouponId()) { logger.error("券ID不一致" + msg.getCouponId()); + throw new MallinkException(ErrorCode.ORDER_COUPON_NOT_MATCH.getCode(), "订单用户不一致" + msg.getOrderId()); } WxCUser user = userService.getById(msg.getCUserId()); if(user == null) { logger.error("用户未找到" + msg.getCUserId()); + throw new MallinkException(ErrorCode.USER_IS_EMPTY.getCode(), "用户未找到" + msg.getCUserId()); } WxCoupon coupon = couponService.getById(msg.getCouponId()); if(coupon == null) { logger.error("券未找到" + msg.getCouponId()); + throw new MallinkException(ErrorCode.COUPON_ORDER_IS_NULL.getCode(), "券未找到" + msg.getCouponId()); } // 下订单后处理