From 52d4fbddfd46b0dd684d99e5c0849b022606c8e2 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期二, 26 五月 2020 10:37:32 +0800
Subject: [PATCH] 邀请成功消息延迟
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/ThreeSaleSerivceImpl.java | 11 ++++-------
1 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/ThreeSaleSerivceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/ThreeSaleSerivceImpl.java
index ff21505..c4095e6 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/ThreeSaleSerivceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/ThreeSaleSerivceImpl.java
@@ -433,10 +433,14 @@
*/
@Transactional
private void inviteSuccess(Long workerId, Long bossId) {
+ // 鍚屾绮変笣娑堟伅
+ teamFansInfoService.addFansInfo(workerId, bossId, new Date());
+
if (!Constant.IS_TEST) {
UserInviteMQMsg msg = new UserInviteMQMsg(bossId, workerId, null, new Date(),
UserInviteMQMsg.STATE_SUCCESS);
Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.inviteSuccess, msg);
+ message.setStartDeliverTime(java.lang.System.currentTimeMillis() + 5000);
producer.send(message);
}
@@ -445,13 +449,6 @@
public void run() {
try { // 閭�璇烽噾甯�
integralGetService.addInviteLevelOne(bossId, workerId);
- } catch (Exception e) {
- LogHelper.error(e);
- }
-
- // 鍚屾绮変笣娑堟伅
- try {
- teamFansInfoService.addFansInfo(workerId, bossId, new Date());
} catch (Exception e) {
LogHelper.error(e);
}
--
Gitblit v1.8.0