rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/redpack/RedPackWinInviteServiceImpl.java

@@ -40,6 +40,7 @@
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;

import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService;

import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

@@ -95,6 +96,9 @@
   

   @Resource

   private UserSystemCouponService userSystemCouponService;

	
   @Resource

   private UserInviteMsgNotificationService userInviteMsgNotificationService;

   



   @Override

@@ -529,7 +533,7 @@
            continue;

         // 付款金额限制

         BigDecimal payment = commonOrder.getPayment();

         if (payment == null || payment.compareTo(limitPayMent) <= 0) 
         if (payment == null || payment.compareTo(limitPayMent) < 0) 
            continue;

         

         // 商品佣金比例限制

@@ -561,6 +565,10 @@
      winInvite.setType(RedPackWinInviteTypeEnum.inviteDownOrder);

      winInvite.setIdentifyCode(StringUtil.Md5(RedPackWinInviteTypeEnum.inviteDownOrder.name() + ":" + orderUid));

      redPackWinInviteMapper.insertSelective(winInvite);

		
      // 消息提醒

      UserInfo userInfo = userInfoService.selectByPKey(orderUid);

      userInviteMsgNotificationService.pullNewRedPack(bossId, userInfo.getNickName(), userInfo.getPortrait());

   }

   

   @Override