|
@@ -358,8 +358,8 @@ public class CmCouponController extends BaseController {
|
|
|
List<Integer> clubIds = messageCenterDao.ClubIds();
|
|
|
|
|
|
// new Thread(() -> consumer(cmCoupon, clubIds)).start();
|
|
|
+ if("".equals(cmCoupon.getId())){
|
|
|
consumer(cmCoupon, clubIds);
|
|
|
-
|
|
|
RedisLearn.producer(clubIds);
|
|
|
MessageCenter messageCenter = new MessageCenter();
|
|
|
if (cmCoupon.getUserId() != null) {
|
|
@@ -387,7 +387,7 @@ public class CmCouponController extends BaseController {
|
|
|
logger.info(">>>>>>>发送成功");
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+ }
|
|
|
cmCouponService.save(cmCoupon);
|
|
|
addMessage(redirectAttributes, "保存优惠券成功");
|
|
|
return "redirect:" + Global.getAdminPath() + "/coupon/cmCoupon/list?couponType=" + cmCoupon.getCouponType();
|