From 0e9b6603d4ae9d11c1fbc90257ce816c5807b8ff Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 28 十月 2022 16:55:02 +0800
Subject: [PATCH] 批量添加结算消息
---
app/src/main/java/com/yeshi/makemoney/app/service/impl/user/UserInfoServiceImpl.java | 52 +++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 41 insertions(+), 11 deletions(-)
diff --git a/app/src/main/java/com/yeshi/makemoney/app/service/impl/user/UserInfoServiceImpl.java b/app/src/main/java/com/yeshi/makemoney/app/service/impl/user/UserInfoServiceImpl.java
index 86d5f39..cfa0dc8 100644
--- a/app/src/main/java/com/yeshi/makemoney/app/service/impl/user/UserInfoServiceImpl.java
+++ b/app/src/main/java/com/yeshi/makemoney/app/service/impl/user/UserInfoServiceImpl.java
@@ -5,15 +5,20 @@
import com.yeshi.makemoney.app.entity.SystemEnum;
import com.yeshi.makemoney.app.service.inter.user.QQUserInfoService;
+import com.yeshi.makemoney.app.service.inter.user.UserExtraInfoService;
import com.yeshi.makemoney.app.service.inter.user.WXUserInfoService;
+import com.yeshi.makemoney.app.utils.user.InviteCodeUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
-import java.util.ArrayList;
-import java.util.Date;
+import java.util.*;
import org.yeshi.utils.bean.BeanUtil;
-import java.util.List;
+import java.util.stream.Collectors;
import com.yeshi.makemoney.app.dao.user.UserInfoDao;
import com.yeshi.makemoney.app.entity.user.UserInfo;
@@ -27,6 +32,8 @@
@Service
public class UserInfoServiceImpl implements UserInfoService {
+ Logger logger = LoggerFactory.getLogger(UserInfoService.class);
+
@Resource
private UserInfoDao userInfoMapper;
@Resource
@@ -34,25 +41,29 @@
@Resource
private QQUserInfoService qqUserInfoService;
+ @Resource
+ private UserExtraInfoService userExtraInfoService;
+
@Override
public List<UserInfo> list(UserInfoQuery userInfoQuery, int page, int pageSize) {
DaoQuery daoQuery = new DaoQuery();
- try {
- BeanUtil.copyProperties(userInfoQuery, daoQuery);
- } catch (IllegalAccessException e) {
- e.printStackTrace();
- }
+ daoQuery.uid=userInfoQuery.getUid();
+
+ daoQuery.sortList = Arrays.asList(new String[]{"create_time desc"});
+
daoQuery.start = (page - 1) * pageSize;
daoQuery.count = pageSize;
return userInfoMapper.list(daoQuery);
}
@Override
- public List<UserInfo> list(List<Long> uidList) {
- if(uidList==null||uidList.size()==0) {
+ public List<UserInfo> list(Collection<Long> uidList) {
+ if (uidList == null || uidList.size() == 0) {
return new ArrayList<>();
}
- return userInfoMapper.listByUids(uidList);
+ List<Long> list = new ArrayList<>();
+ list.addAll(uidList);
+ return userInfoMapper.listByUids(list);
}
@Override
@@ -81,6 +92,9 @@
}
//淇濆瓨
userInfoMapper.insertSelective(userInfo);
+
+ //娣诲姞閭�璇风爜
+ userExtraInfoService.setInviteCode(userInfo.getId(), InviteCodeUtil.createInviteCode(userInfo.getId()));
}
@Override
@@ -222,5 +236,21 @@
return userInfos != null && userInfos.size() > 0 ? userInfos.get(0) : null;
}
+ @Override
+ public void forbiddenUser(List<Long> uidList, String adminId) {
+ if (uidList == null || uidList.size() == 0) {
+ return;
+ }
+
+ for (Long uid : uidList) {
+ UserInfo user = new UserInfo();
+ user.setId(uid);
+ user.setStatus(UserInfo.STATUS_FORBIDDEN);
+ update(user);
+ logger.warn("灏佺鐢ㄦ埛锛� uid-{} adminId-{}", uid, adminId);
+ }
+
+ }
+
}
\ No newline at end of file
--
Gitblit v1.8.0