Commit 8b146574 authored by shiyu's avatar shiyu

登陆完成后返回用户信息

parent 1419c7e5
...@@ -13,7 +13,7 @@ public interface CollectionBookDao { ...@@ -13,7 +13,7 @@ public interface CollectionBookDao {
* @param collectionBook * @param collectionBook
* @return * @return
*/ */
int insert(CollectionBook collectionBook); long insert(CollectionBook collectionBook);
/** /**
* 更新记录 * 更新记录
......
...@@ -31,8 +31,8 @@ public class UserDaoImpl implements UserDao { ...@@ -31,8 +31,8 @@ public class UserDaoImpl implements UserDao {
UserExample example = new UserExample(); UserExample example = new UserExample();
UserExample.Criteria criteria = example.createCriteria(); UserExample.Criteria criteria = example.createCriteria();
criteria.andIdEqualTo(user.getId()); criteria.andIdEqualTo(user.getId());
List<User> userList = userMapper.selectByExample(example); long count = userMapper.countByExample(example);
if (CollectionUtils.isEmpty(userList)) { if (count == 0) {
return userMapper.insertBySelfId(user); return userMapper.insertBySelfId(user);
} }
return 0; return 0;
...@@ -41,9 +41,6 @@ public class UserDaoImpl implements UserDao { ...@@ -41,9 +41,6 @@ public class UserDaoImpl implements UserDao {
@Override @Override
public User queryByOid(String openId) { public User queryByOid(String openId) {
CloudServerResponse<com.wwdz.user.api.model.user.User> cloudServerResponse = userReadService.getUserByOpenIdOrUnionId(null, openId); CloudServerResponse<com.wwdz.user.api.model.user.User> cloudServerResponse = userReadService.getUserByOpenIdOrUnionId(null, openId);
......
...@@ -20,8 +20,9 @@ public class CollectionBookDaoImpl implements CollectionBookDao { ...@@ -20,8 +20,9 @@ public class CollectionBookDaoImpl implements CollectionBookDao {
@Override @Override
public int insert(CollectionBook collectionBook) { public long insert(CollectionBook collectionBook) {
return collectionBookMapper.insert(collectionBook); collectionBookMapper.insert(collectionBook);
return collectionBook.getId();
} }
......
...@@ -3,10 +3,7 @@ package com.wwdz.ch.wx.impl; ...@@ -3,10 +3,7 @@ package com.wwdz.ch.wx.impl;
import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult; import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
import com.alibaba.dubbo.config.annotation.Reference; import com.alibaba.dubbo.config.annotation.Reference;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.wwdz.ch.core.consts.ConsignSaleEnum; import com.wwdz.ch.core.consts.*;
import com.wwdz.ch.core.consts.IMEnum;
import com.wwdz.ch.core.consts.ResultCode;
import com.wwdz.ch.core.consts.ReturnOrderEnum;
import com.wwdz.ch.core.entity.im.SendChatMsgRequestDto; import com.wwdz.ch.core.entity.im.SendChatMsgRequestDto;
import com.wwdz.ch.core.im.api.ChatUserApi; import com.wwdz.ch.core.im.api.ChatUserApi;
import com.wwdz.ch.core.im.api.ConversationApi; import com.wwdz.ch.core.im.api.ConversationApi;
...@@ -15,14 +12,12 @@ import com.wwdz.ch.core.notify.NotifyService; ...@@ -15,14 +12,12 @@ import com.wwdz.ch.core.notify.NotifyService;
import com.wwdz.ch.core.notify.SmsResult; import com.wwdz.ch.core.notify.SmsResult;
import com.wwdz.ch.core.type.Result; import com.wwdz.ch.core.type.Result;
import com.wwdz.ch.core.type.UserTypeEnum; import com.wwdz.ch.core.type.UserTypeEnum;
import com.wwdz.ch.core.util.CacheUtil;
import com.wwdz.ch.core.util.CharUtil; import com.wwdz.ch.core.util.CharUtil;
import com.wwdz.ch.core.util.RegexUtil; import com.wwdz.ch.core.util.RegexUtil;
import com.wwdz.ch.core.util.UUID; import com.wwdz.ch.core.util.UUID;
import com.wwdz.ch.core.util.bcrypt.BCryptPasswordEncoder; import com.wwdz.ch.core.util.bcrypt.BCryptPasswordEncoder;
import com.wwdz.ch.db.dao.AiAssistantDao; import com.wwdz.ch.db.dao.*;
import com.wwdz.ch.db.dao.ConsignSaleDao;
import com.wwdz.ch.db.dao.ReturnOrderDao;
import com.wwdz.ch.db.dao.UserDao;
import com.wwdz.ch.db.dao.distribution.ShopWhiteListDao; import com.wwdz.ch.db.dao.distribution.ShopWhiteListDao;
import com.wwdz.ch.db.domain.AiAssistant; import com.wwdz.ch.db.domain.AiAssistant;
import com.wwdz.ch.db.domain.Switch; import com.wwdz.ch.db.domain.Switch;
...@@ -149,6 +144,12 @@ public class UserServiceImpl implements UserService { ...@@ -149,6 +144,12 @@ public class UserServiceImpl implements UserService {
@Autowired @Autowired
ShopWhiteListDao shopWhiteListDao; ShopWhiteListDao shopWhiteListDao;
@Autowired
CacheUtil cacheUtil;
@Autowired
FollowFansRecordDao followFansRecordDao;
@Override @Override
public Result finishLogin(UserRequestDto dto) { public Result finishLogin(UserRequestDto dto) {
...@@ -224,6 +225,15 @@ public class UserServiceImpl implements UserService { ...@@ -224,6 +225,15 @@ public class UserServiceImpl implements UserService {
// 缓存用户信息 // 缓存用户信息
String userKey = MessageFormat.format(CacheCodeConstants.USER_INFO_KEY, user.getId()); String userKey = MessageFormat.format(CacheCodeConstants.USER_INFO_KEY, user.getId());
redisUtil.set(userKey, user, 2 * 60 * 60); redisUtil.set(userKey, user, 2 * 60 * 60);
//返回用户信息
user = cacheUtil.getAppletUserById(dto.getUserId());
result.put("avatar", com.xxdxxs.utils.StringUtils.isEmpty(user.getAvatar()) ? CommConsts.DEFAULT_AVATAR_URL : user.getAvatar());
result.put("name", com.xxdxxs.utils.StringUtils.isEmpty(user.getNickname()) ? "微信用户" : user.getNickname());
result.put("background", com.xxdxxs.utils.StringUtils.isEmpty(user.getBackground()) ? CommConsts.DEFAULT_BACKGROUND_URL : user.getBackground());
result.put("profile", user.getProfile());
long fansNum = followFansRecordDao.countFans(dto.getUserId());
result.put("fansNum", fansNum);
logger.info("【请求结束】登录信息初始化成功, 响应结果:{}", JSONObject.toJSONString(result)); logger.info("【请求结束】登录信息初始化成功, 响应结果:{}", JSONObject.toJSONString(result));
return Result.success(result); return Result.success(result);
} }
...@@ -376,7 +386,6 @@ public class UserServiceImpl implements UserService { ...@@ -376,7 +386,6 @@ public class UserServiceImpl implements UserService {
} }
}*/ }*/
@Transactional(rollbackFor = Exception.class)
@Override @Override
public Result updateProfile(UserRequestDto dto) { public Result updateProfile(UserRequestDto dto) {
try { try {
...@@ -394,12 +403,10 @@ public class UserServiceImpl implements UserService { ...@@ -394,12 +403,10 @@ public class UserServiceImpl implements UserService {
return Result.success(); return Result.success();
} catch (Exception e) { } catch (Exception e) {
logger.error("用户修改个性签名失败", e); logger.error("用户修改个性签名失败", e);
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return Result.failed("修改个性签名失败"); return Result.failed("修改个性签名失败");
} }
} }
@Transactional(rollbackFor = Exception.class)
@Override @Override
public Result updateBackground(UserRequestDto dto) { public Result updateBackground(UserRequestDto dto) {
try { try {
...@@ -417,7 +424,6 @@ public class UserServiceImpl implements UserService { ...@@ -417,7 +424,6 @@ public class UserServiceImpl implements UserService {
return Result.success(); return Result.success();
} catch (Exception e) { } catch (Exception e) {
logger.error("用户修改背景失败", e); logger.error("用户修改背景失败", e);
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return Result.failed("修改背景失败"); return Result.failed("修改背景失败");
} }
} }
......
...@@ -3,6 +3,7 @@ package com.wwdz.ch.wx.impl.distribution; ...@@ -3,6 +3,7 @@ package com.wwdz.ch.wx.impl.distribution;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.wwdz.ch.core.type.Result; import com.wwdz.ch.core.type.Result;
import com.wwdz.ch.db.dao.CollectionBookSortDao; import com.wwdz.ch.db.dao.CollectionBookSortDao;
import com.wwdz.ch.db.dao.CollectorWhiteListDao;
import com.wwdz.ch.db.dao.distribution.CollectionBookDao; import com.wwdz.ch.db.dao.distribution.CollectionBookDao;
import com.wwdz.ch.db.dao.distribution.CollectionItemsRelationDao; import com.wwdz.ch.db.dao.distribution.CollectionItemsRelationDao;
import com.wwdz.ch.db.dao.distribution.CollectionShareRecordDao; import com.wwdz.ch.db.dao.distribution.CollectionShareRecordDao;
...@@ -11,6 +12,7 @@ import com.wwdz.ch.db.domain.distribution.CollectionBook; ...@@ -11,6 +12,7 @@ import com.wwdz.ch.db.domain.distribution.CollectionBook;
import com.wwdz.ch.db.domain.distribution.CollectionShareRecord; import com.wwdz.ch.db.domain.distribution.CollectionShareRecord;
import com.wwdz.ch.db.dto.request.distribution.CollectionBookRequestDto; import com.wwdz.ch.db.dto.request.distribution.CollectionBookRequestDto;
import com.wwdz.ch.db.dto.request.distribution.CollectionItemsRelationRequestDto; import com.wwdz.ch.db.dto.request.distribution.CollectionItemsRelationRequestDto;
import com.wwdz.ch.wx.constant.CollectionBookConstants;
import com.wwdz.ch.wx.service.distribution.CollectionBookService; import com.wwdz.ch.wx.service.distribution.CollectionBookService;
import com.xxdxxs.utils.EntityMapper; import com.xxdxxs.utils.EntityMapper;
import com.xxdxxs.utils.StringUtils; import com.xxdxxs.utils.StringUtils;
...@@ -38,6 +40,9 @@ public class CollectionBookServiceImpl implements CollectionBookService { ...@@ -38,6 +40,9 @@ public class CollectionBookServiceImpl implements CollectionBookService {
@Autowired @Autowired
CollectionBookSortDao collectionBookSortDao; CollectionBookSortDao collectionBookSortDao;
@Autowired
CollectorWhiteListDao collectorWhiteListDao;
@Override @Override
public Result create(CollectionBookRequestDto dto) { public Result create(CollectionBookRequestDto dto) {
try { try {
...@@ -55,7 +60,15 @@ public class CollectionBookServiceImpl implements CollectionBookService { ...@@ -55,7 +60,15 @@ public class CollectionBookServiceImpl implements CollectionBookService {
collectionBook.setCreateTime(new Date()); collectionBook.setCreateTime(new Date());
collectionBook.setUpdateTime(new Date()); collectionBook.setUpdateTime(new Date());
collectionBook.setIsDeleted(false); collectionBook.setIsDeleted(false);
collectionBookDao.insert(collectionBook); long bookId = collectionBookDao.insert(collectionBook);
//更新标签排序
CollectionBookSort collectionBookSort = collectionBookSortDao.find(dto.getUserId());
if (collectionBookSort != null) {
String sortInfo = collectionBookSort.getSortInfo();
sortInfo = sortInfo + "," + bookId;
collectionBookSortDao.update(dto.getUserId(), sortInfo);
}
return Result.success(); return Result.success();
} catch (Exception e) { } catch (Exception e) {
logger.error("新建收藏册 error: {}", e); logger.error("新建收藏册 error: {}", e);
...@@ -95,19 +108,39 @@ public class CollectionBookServiceImpl implements CollectionBookService { ...@@ -95,19 +108,39 @@ public class CollectionBookServiceImpl implements CollectionBookService {
userId = itemUserId; userId = itemUserId;
} }
} }
List<CollectionBook> collectionBookList = collectionBookDao.findByUserId(userId); //查询标签排序记录
collectionBookList.forEach(collectionBook -> { CollectionBookSort collectionBookSort = collectionBookSortDao.find(userId);
Map<String, Object> map = new HashMap<>(); //没有排序记录,则使用默认排序
map.put("id", collectionBook.getId()); if (collectionBookSort == null) {
map.put("title", collectionBook.getTitle()); //查询藏家白名单, 在白名单中说是藏家,需要加上默认标签
list.add(map); if (dto.getIsHasExtraLabel()) {
}); if (collectorWhiteListDao.isExisted(userId)) {
if (dto.getIsHasExtraLabel()) { for (CollectionBookConstants.DefaultBookEnum defaultBookEnum: CollectionBookConstants.DefaultBookEnum.values()) {
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
map.put("id", 0); map.put("id", defaultBookEnum.getId());
map.put("title", "我收藏的"); map.put("title", defaultBookEnum.getName());
list.add(0, map); list.add(map);
}
}
Map<String, Object> map = new HashMap<>();
map.put("id", 0);
map.put("title", "我收藏的");
list.add(0, map);
}
List<CollectionBook> collectionBookList = collectionBookDao.findByUserId(userId);
collectionBookList.forEach(collectionBook -> {
Map<String, Object> map = new HashMap<>();
map.put("id", collectionBook.getId());
map.put("title", collectionBook.getTitle());
list.add(map);
});
} else {
//用户自定义排序
String sortInfo = collectionBookSort.getSortInfo();
} }
return Result.success(list); return Result.success(list);
} catch (Exception e) { } catch (Exception e) {
logger.error("查询收藏册 error: {}", e); logger.error("查询收藏册 error: {}", e);
...@@ -124,6 +157,16 @@ public class CollectionBookServiceImpl implements CollectionBookService { ...@@ -124,6 +157,16 @@ public class CollectionBookServiceImpl implements CollectionBookService {
CollectionItemsRelationRequestDto collectionItemsRelationRequestDto = new CollectionItemsRelationRequestDto(); CollectionItemsRelationRequestDto collectionItemsRelationRequestDto = new CollectionItemsRelationRequestDto();
collectionItemsRelationRequestDto.setCollectionBookId(dto.getId()); collectionItemsRelationRequestDto.setCollectionBookId(dto.getId());
collectionItemsRelationDao.delete(collectionItemsRelationRequestDto); collectionItemsRelationDao.delete(collectionItemsRelationRequestDto);
//更新标签排序
CollectionBookSort collectionBookSort = collectionBookSortDao.find(dto.getUserId());
if (collectionBookSort != null) {
String sortInfo = collectionBookSort.getSortInfo();
List<String> list = Arrays.asList(sortInfo.split(","));
list.remove("" + dto.getId());
sortInfo = String.join("," , list);
collectionBookSortDao.update(dto.getUserId(), sortInfo);
}
return Result.success(); return Result.success();
} catch (Exception e) { } catch (Exception e) {
logger.error("删除收藏册 error: {}", e); logger.error("删除收藏册 error: {}", e);
......
...@@ -134,8 +134,8 @@ public class WxUserController { ...@@ -134,8 +134,8 @@ public class WxUserController {
if (StringUtils.isBlank(dto.getProfile())) { if (StringUtils.isBlank(dto.getProfile())) {
dto.setProfile(""); dto.setProfile("");
} else { } else {
if (dto.getProfile().length() > 30) { if (dto.getProfile().length() > 100) {
return Result.failed("个人简介的字数应在30字以内"); return Result.failed("个人简介应在100字以内");
} }
} }
return userService.updateProfile(dto); return userService.updateProfile(dto);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment