| | |
|---|
| | | 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);
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.integralTaskFinish, msg);
|
|---|
| | | producer.send(message);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | msgOther.setSource("首笔分享订单，系统奖励金币 ");
|
|---|
| | | msgOther.setExplain("首笔分享订单得到的奖金不足0.01元时奖励 ");
|
|---|
| | | } else {
|
|---|
| | | msgOther.setSource(level + "级队员首次下单，系统奖励金币 ");
|
|---|
| | | msgOther.setExplain("仅新邀请队员首下单你得到的奖金不足0.01元时奖励 ");
|
|---|
| | | if (level.equalsIgnoreCase("一") || level.equalsIgnoreCase("1"))
|
|---|
| | | msgOther.setSource("直接粉丝首次下单，系统奖励金币 ");
|
|---|
| | | else
|
|---|
| | | msgOther.setSource("间接粉丝首次下单，系统奖励金币 ");
|
|---|
| | | msgOther.setExplain("仅新邀请粉丝首下单你得到的奖金不足0.01元时奖励 ");
|
|---|
| | | }
|
|---|
| | | userOtherMsgNotificationService.firstOrderRewardMsg(uid, null, msgOther);
|
|---|
| | | }
|
|---|
