RocketMQ的消息整改

admin

2019-11-20 8b2191df2f7d94aa299bd43dcbe97c94e5a61bbd

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java

@@ -16,7 +16,12 @@
import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.DateUtil;



import com.aliyun.openservices.ons.api.Message;

import com.aliyun.openservices.ons.api.Producer;

import com.google.gson.Gson;

import com.yeshi.fanli.dao.mybatis.integral.IntegralTaskRecordMapper;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.body.IntegralTaskMQMsg;

import com.yeshi.fanli.dto.msg.MsgOtherRewardIntegralDTO;

import com.yeshi.fanli.entity.bus.user.UserInfoExtra;

import com.yeshi.fanli.entity.integral.IntegralDetail;

@@ -37,6 +42,8 @@
import com.yeshi.fanli.service.inter.user.integral.IntegralTaskService;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

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

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



@Service

public class IntegralTaskRecordServiceImpl implements IntegralTaskRecordService {

@@ -63,6 +70,9 @@
   @Resource

   private ConfigService configService;



   @Resource(name = "producer")

   private Producer producer;



   @Override

   public Integer getTotalGoldCoin(long uid, Long cid, Integer dateType) {

      return integralTaskRecordMapper.getTotalGoldCoin(uid, cid, dateType);

@@ -80,7 +90,7 @@
      taskRecord.setCid(cid);

      taskRecord.setTaskId(taskId);

      taskRecord.setGoldCoin(goldCoin);

      taskRecord.setState(0);

      taskRecord.setState(IntegralTaskRecord.STATE_WAITING_RECIEVE);

      taskRecord.setCreateTime(new Date());

      taskRecord.setUpdateTime(new Date());

      integralTaskRecordMapper.insertSelective(taskRecord);

@@ -207,7 +217,7 @@
      // 更新金币

      userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);



      return (userInfoExtra.getGoldCoin()==null?0:userInfoExtra.getGoldCoin()) + totalGoldCoin;

      return (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()) + totalGoldCoin;

   }



   @Override

@@ -240,7 +250,7 @@
      // 更新金币

      userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);



      return totalGoldCoin+(userInfoExtra.getGoldCoin()==null?0:userInfoExtra.getGoldCoin());

      return totalGoldCoin + (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin());

   }



   @Transactional

@@ -341,6 +351,7 @@
      return integralTaskRecordMapper.countGetCountByTaskIdAndDay(taskId, uid, minTime, maxTime);

   }



   @Transactional

   @Override

   public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException {

      if (record == null)

@@ -356,6 +367,14 @@
      if (record.getUpdateTime() == null)

         record.setUpdateTime(new Date());

      integralTaskRecordMapper.insertSelective(record);

      long count = integralTaskRecordMapper.getTotalGoldCoinByUid(record.getUid());

      if (count >= 200) {// 大于200发送消息

         IntegralTaskMQMsg msg = new IntegralTaskMQMsg(record.getUid(), count, new Date());

         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.integralTaskFinish,

               msg);

         producer.send(message);

      }



      return record;

   }



@@ -376,14 +395,11 @@
      return integralTaskRecordMapper.listByUidAndTaskId(uid, taskId, (page - 1) * count, count);

   }



	
   @Override

   public long getTotalGoldCoinByUid(Long uid) {

      return integralTaskRecordMapper.getTotalGoldCoinByUid(uid);

   }

	
	
	


   @Async()

   @Override

   public void firstRebateOrderRewardBoss(Long uid, Long originUid, String beizu) {

@@ -494,15 +510,16 @@
      }

      userOtherMsgNotificationService.firstOrderRewardMsg(uid, null, msgOther);

   }

	
	


   /**

    * 推广红包折算金币

    * 
    * @param uid

    * @param addGoldCoin

    * @param tlj

    */

   @Override

   @Transactional(rollbackFor = Exception.class)

   public void taoLiJinExchange(Long uid, Integer addGoldCoin, BigDecimal tlj) {

      String uniqueKey = "taoLiJinExchange-" + uid.toString();

      IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);

@@ -541,7 +558,7 @@
      MsgOtherRewardIntegralDTO msgOther = new MsgOtherRewardIntegralDTO();

      msgOther.setTitle("推广红包");

      msgOther.setTotal("推广红包¥" + tlj.setScale(2));

      msgOther.setNum(goldCoin + "枚");

      msgOther.setNum(addGoldCoin + "枚");

      msgOther.setSource("已进入到可用金币中");

      msgOther.setExplain("原推广红包功能下线，剩余推广红包按照10:1折算为金币 ");

      userOtherMsgNotificationService.taoLiJinExchangeMsg(uid, "本折算有且仅有一次", msgOther);