From 29bb04f5981562726febc3538dbb5bc394017273 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 09 五月 2020 21:41:47 +0800
Subject: [PATCH] 2.1.1相关功能提交
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java | 33 +++++++++++++++++++++------------
1 files changed, 21 insertions(+), 12 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java
index 41975b6..399a1ba 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java
@@ -81,7 +81,7 @@
UserActiveMQMsg msg = new Gson().fromJson(new String(message.getBody()), UserActiveMQMsg.class);
Long uid = msg.getUid();
// 鑰佺敤鎴峰悓姝ョ粦瀹氫俊鎭�
-
+
userInfoModifyRecordService.syncBeforeInfo(uid);
// 浣庣増鏈叏閮ㄥ崌绾ф櫘閫氫細鍛�
@@ -115,16 +115,25 @@
if (vipInfo == null) {// 娌℃湁鐢熸垚楂樼骇鍙婁互涓婁細鍛�
UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);
if (extra != null && !StringUtil.isNullOrEmpty(extra.getInviteCode())) {
- // 鑰佺敤鎴风敓鎴愭櫘閫氫細鍛�
- UserVIPPreInfo vip = new UserVIPPreInfo();
- vip.setCreateTime(new Date());
- vip.setProcess(UserVIPPreInfo.PROCESS_1);
- vip.setUid(uid);
- vip.setSourceType(UserVIPPreInfo.SOURCE_TYPE_ORDER);
- try {
- userVIPPreInfoService.addUserVIPPreInfo(vip);
- } catch (UserVIPPreInfoException e) {
- e.printStackTrace();
+
+ List<Long> uids = new ArrayList<>();
+ uids.add(uid);
+ List<UserInfoRegister> list = userInfoRegisterService.listByMultipleUids(uids);
+ if (list != null && list.size() > 0)// 鏈夋敞鍐屼俊鎭�
+ {
+ if (list.get(0).getCreateTime().getTime() < Constant.NEW_ORDER_FANLI_RULE_TIME) {// 澧炲姞娉ㄥ唽鏃堕棿闄愬埗
+ // 鑰佺敤鎴风敓鎴愭櫘閫氫細鍛�
+ UserVIPPreInfo vip = new UserVIPPreInfo();
+ vip.setCreateTime(new Date());
+ vip.setProcess(UserVIPPreInfo.PROCESS_1);
+ vip.setUid(uid);
+ vip.setSourceType(UserVIPPreInfo.SOURCE_TYPE_ORDER);
+ try {
+ userVIPPreInfoService.addUserVIPPreInfo(vip);
+ } catch (UserVIPPreInfoException e) {
+ e.printStackTrace();
+ }
+ }
}
}
}
@@ -161,7 +170,7 @@
}
}
}
- } else {//涔嬪墠鑰佺増鏈鐞嗕负鏅�氫細鍛樼殑鐢ㄦ埛鍗囩骇鏂扮増鏈�
+ } else {// 涔嬪墠鑰佺増鏈鐞嗕负鏅�氫細鍛樼殑鐢ㄦ埛鍗囩骇鏂扮増鏈�
if (vipInfo.getProcess() == UserVIPPreInfo.PROCESS_1
&& vipInfo.getCreateTime().getTime() < TimeUtil
.convertToTimeTemp("2020-04-30 14:10:00", "yyyy-MM-dd HH:mm:ss")) {
--
Gitblit v1.8.0