From 4f5a5b0a00c01491f009074351089f086f950d3e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 01 六月 2021 19:09:48 +0800
Subject: [PATCH] 系统配置改为数据库
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInviteRecordServiceImpl.java | 124 ++++++++++++++++++++++-------------------
1 files changed, 66 insertions(+), 58 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInviteRecordServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInviteRecordServiceImpl.java
index f3e102f..717bb52 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInviteRecordServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInviteRecordServiceImpl.java
@@ -4,6 +4,8 @@
import javax.annotation.Resource;
+import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;
+import com.yeshi.fanli.service.inter.config.SystemConfigService;
import com.yeshi.fanli.util.wx.MyWXLoginUtil;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@@ -19,64 +21,70 @@
@Service
public class UserInviteRecordServiceImpl implements UserInviteRecordService {
- @Resource
- private UserInviteRecordMapper userInviteRecordMapper;
-
- @Resource
- private UserInfoService userInfoService;
-
- @Async("pushExecutor")
- @Override
- public void saveInviteRecord(String code, String uid) {
-
- // 鐢ㄦ埛code 鏈幏鍙栧埌
- if (code == null || uid == null || uid.trim().length() == 0) {
- return;
- }
-
- // 娌″緱杩欎釜浜�
- Long invitId = Long.parseLong(uid);
-
- UserInfo inviter = userInfoService.getUserById(invitId);
- if (inviter == null) {
- return;
- }
+ @Resource
+ private UserInviteRecordMapper userInviteRecordMapper;
- // 鑾峰彇寰俊淇℃伅
- WeiXinUser weiXinUser = MyWXLoginUtil.getWeiXinWYUser(code);
- if (weiXinUser == null) {
- return;
- }
-
- String wxUnionId = weiXinUser.getUnionid();
- if (wxUnionId == null || wxUnionId.trim().length() == 0) {
- return;
- }
-
- // 鏄惁鏄個璇疯�呰嚜宸辫瘑鍒�
- if (wxUnionId.equals(inviter.getWxUnionId())) {
- return;
- }
-
- UserInviteRecord record = userInviteRecordMapper.getByInviterIdAndUnionid(invitId, wxUnionId);
- if (record != null) {
- UserInviteRecord userInviteRecord = new UserInviteRecord();
- userInviteRecord.setId(record.getId());
- userInviteRecord.setUpdateTime(new Date());
- userInviteRecordMapper.updateByPrimaryKey(record);
- } else {
- UserInviteRecord userInviteRecord = new UserInviteRecord();
- userInviteRecord.setInviterId(invitId);
- userInviteRecord.setWxUnionid(wxUnionId);
- userInviteRecord.setCreateTime(new Date());
- userInviteRecord.setUpdateTime(new Date());
- userInviteRecordMapper.insertSelective(userInviteRecord);
- }
- }
+ @Resource
+ private UserInfoService userInfoService;
- @Override
- public Long getNewestInviterId(String wxUnionId) {
- return userInviteRecordMapper.getNewestInviterId(wxUnionId);
- }
-
+ @Resource
+ private SystemConfigService systemConfigService;
+
+ @Async("pushExecutor")
+ @Override
+ public void saveInviteRecord(String code, String uid) {
+
+ // 鐢ㄦ埛code 鏈幏鍙栧埌
+ if (code == null || uid == null || uid.trim().length() == 0) {
+ return;
+ }
+
+ // 娌″緱杩欎釜浜�
+ Long invitId = Long.parseLong(uid);
+
+ UserInfo inviter = userInfoService.getUserById(invitId);
+ if (inviter == null) {
+ return;
+ }
+
+ // 鑾峰彇寰俊淇℃伅
+ String wxGZAppId = systemConfigService.getValueCache(SystemConfigKeyEnum.wxGZAppId, inviter.getSystem());
+ String wxGZSecretId = systemConfigService.getValueCache(SystemConfigKeyEnum.wxGZAppSecret, inviter.getSystem());
+
+ WeiXinUser weiXinUser = MyWXLoginUtil.getWeiXinWYUser(code, wxGZAppId, wxGZSecretId);
+ if (weiXinUser == null) {
+ return;
+ }
+
+ String wxUnionId = weiXinUser.getUnionid();
+ if (wxUnionId == null || wxUnionId.trim().length() == 0) {
+ return;
+ }
+
+ // 鏄惁鏄個璇疯�呰嚜宸辫瘑鍒�
+ if (wxUnionId.equals(inviter.getWxUnionId())) {
+ return;
+ }
+
+ UserInviteRecord record = userInviteRecordMapper.getByInviterIdAndUnionid(invitId, wxUnionId);
+ if (record != null) {
+ UserInviteRecord userInviteRecord = new UserInviteRecord();
+ userInviteRecord.setId(record.getId());
+ userInviteRecord.setUpdateTime(new Date());
+ userInviteRecordMapper.updateByPrimaryKey(record);
+ } else {
+ UserInviteRecord userInviteRecord = new UserInviteRecord();
+ userInviteRecord.setInviterId(invitId);
+ userInviteRecord.setWxUnionid(wxUnionId);
+ userInviteRecord.setCreateTime(new Date());
+ userInviteRecord.setUpdateTime(new Date());
+ userInviteRecordMapper.insertSelective(userInviteRecord);
+ }
+ }
+
+ @Override
+ public Long getNewestInviterId(String wxUnionId) {
+ return userInviteRecordMapper.getNewestInviterId(wxUnionId);
+ }
+
}
--
Gitblit v1.8.0