大淘客搜索接口升级

admin

2020-11-28 dc5be7d38446f70e6ff86df311119c32b41fe7f8

 fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyServiceImpl.java

@@ -20,6 +20,7 @@
import com.yeshi.fanli.entity.money.UserMoneyDetail;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.money.UserMoneyService;

import com.yeshi.fanli.service.manger.msg.RocketMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.mq.cmq.UserMoneyChangeCMQManager;

import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;

@@ -37,8 +38,8 @@
   @Resource

   private UserMoneyDetailMapper userMoneyDetailMapper;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Override

   public BigDecimal getMoneyToday(Long uid) {

@@ -97,7 +98,7 @@
      if (!Constant.IS_TEST) {

         UserMoneyChangeMQMsg msg = new UserMoneyChangeMQMsg(uid, money, new Date());

         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userMoneyAdd, msg);

         producer.send(message);

         rocketMQManager.sendNormalMsg(message, null);

      }

   }