diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java index 8bd6eb10c..516bb55a1 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java @@ -320,12 +320,18 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { case COUPON_VERIFY: case B_MICROPAY: case C_ORDER: - if (!param.getClass().equals(WxOrder.class)) + if (param.getClass().equals(WxOrder.class)){ + WxOrder order = (WxOrder) param; + cUserId = order.getCUserId(); + tenantEntity = order; + break; + }else if(param.getClass().equals(WxThirdPartyOrders.class)){ + WxThirdPartyOrders thirdOrder = (WxThirdPartyOrders) param; + cUserId = thirdOrder.getCUserId(); + tenantEntity = thirdOrder; + }else{ return false; - WxOrder order = (WxOrder) param; - cUserId = order.getCUserId(); - tenantEntity = order; - break; + } default: return false; } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxThirdPartyOrdersServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxThirdPartyOrdersServiceImpl.java index 854cebeb1..7082e88c1 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxThirdPartyOrdersServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxThirdPartyOrdersServiceImpl.java @@ -173,13 +173,15 @@ public class WxThirdPartyOrdersServiceImpl implements WxThirdPartyOrdersService record.setIncreasedPoints(creditNum); record.setPointsUpdateTime(creditHistory.getCreateDate()); this.updatePoints(record); - } - try { - wxCouponSendService.sendCouponToUser(EnumCouponSendSendType.B_MICROPAY, record,EnumPayWay.PAY_WAY_NOT_UNPAY_B_MA); - } catch (Exception e) { - logger.error("B端刷卡支付发券: " + e.getMessage()); + try { + wxCouponSendService.sendCouponToUser(EnumCouponSendSendType.B_MICROPAY, record,EnumPayWay.PAY_WAY_NOT_UNPAY_B_MA); + } catch (Exception e) { + logger.error("B端刷卡支付发券: " + e.getMessage()); + } } + + redisLock.unlock(lockKey, timeStr); }else { logger.debug("CacheAspect 读库等待中, key:{}: " + lockKey);