/*
|
* Copyright (c) 2018-2999 广州市蓝海创新科技有限公司 All rights reserved.
|
*
|
* https://www.mall4j.com/
|
*
|
* 未经允许，不可做商业用途！
|
*
|
* 版权所有，侵权必究！
|
*/
|
package com.yami.shop.api.controller;
|
|
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.yami.shop.bean.app.dto.OrderCountData;
|
import com.yami.shop.bean.app.dto.UserCenterInfoDto;
|
import com.yami.shop.bean.app.dto.UserDto;
|
import com.yami.shop.bean.app.dto.UserInfoDto;
|
import com.yami.shop.bean.app.param.UserInfoParam;
|
import com.yami.shop.bean.event.UpdateDistributionUserEvent;
|
import com.yami.shop.bean.model.ShopAuditing;
|
import com.yami.shop.bean.model.ShopDetail;
|
import com.yami.shop.bean.model.User;
|
import com.yami.shop.bean.model.UserExtension;
|
import com.yami.shop.bean.param.UserParam;
|
import com.yami.shop.bean.param.im.ImConfigParam;
|
import com.yami.shop.common.config.Constant;
|
import com.yami.shop.common.exception.YamiShopBindException;
|
import com.yami.shop.common.i18n.I18nMessage;
|
import com.yami.shop.common.i18n.LanguageEnum;
|
import com.yami.shop.common.response.ResponseEnum;
|
import com.yami.shop.common.response.ServerResponseEntity;
|
import com.yami.shop.config.WxConfig;
|
import com.yami.shop.distribution.common.dto.AchievementDataDto;
|
import com.yami.shop.distribution.common.dto.DistributionUserWalletDto;
|
import com.yami.shop.distribution.common.model.DistributionUser;
|
import com.yami.shop.distribution.common.service.DistributionUserService;
|
import com.yami.shop.security.api.util.SecurityUtils;
|
import com.yami.shop.security.common.service.ImTokenService;
|
import com.yami.shop.security.common.vo.ImTokenInfo;
|
import com.yami.shop.service.*;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import lombok.AllArgsConstructor;
|
import ma.glasnost.orika.MapperFacade;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.text.DecimalFormat;
|
import java.util.Objects;
|
|
/**
|
* 用户信息
|
*
|
* @author LGH
|
*/
|
@RestController
|
@RequestMapping("/p/user")
|
@Tag(name = "用户接口")
|
@AllArgsConstructor
|
public class UserController {
|
|
private final UserService userService;
|
|
private final ApplicationContext applicationContext;
|
|
private final MapperFacade mapperFacade;
|
|
private final OrderService orderService;
|
|
private final ShopDetailService shopDetailService;
|
|
private final ShopAuditingService shopAuditingService;
|
|
private final WxConfig wxConfig;
|
|
private final UserExtensionService userExtensionService;
|
|
private DistributionUserService distributionUserService;
|
|
private final ImTokenService imTokenService;
|
|
private final SysConfigService sysConfigService;
|
|
@GetMapping("/userInfo")
|
@Operation(summary = "查看用户信息" , description = "根据用户ID（userId）获取用户信息")
|
public ServerResponseEntity<UserDto> userInfo() {
|
String userId = SecurityUtils.getUser().getUserId();
|
User user = userService.getUserByUserId(userId);
|
if (Objects.isNull(user)) {
|
return ServerResponseEntity.success();
|
}
|
//获取用户等级积分详细表
|
UserExtension extension = userExtensionService.getOne(
|
new LambdaQueryWrapper<UserExtension>().eq(UserExtension::getUserId, SecurityUtils.getUser().getUserId()));
|
UserDto userDto = mapperFacade.map(user, UserDto.class);
|
userDto.setLevel(extension.getLevel());
|
userDto.setUsername(user.getUserName());
|
userDto.setGrowth(extension.getGrowth());
|
userDto.setScore(extension.getScore());
|
userDto.setLevelType(extension.getLevelType());
|
userDto.setBalance(extension.getBalance());
|
if (userDto.getUserMobile() != null) {
|
userDto.setMobile(userDto.getUserMobile().replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2"));
|
}
|
return ServerResponseEntity.success(userDto);
|
}
|
|
@GetMapping("/getUserByUserId")
|
@Operation(summary = "查看用户信息" , description = "根据用户ID（userId）获取用户信息")
|
public ServerResponseEntity<User> getUserByUserId() {
|
String userId = SecurityUtils.getUser().getUserId();
|
User user = userService.getUserByUserId(userId);
|
if (null!= user) {
|
return ServerResponseEntity.success(user);
|
}
|
return ServerResponseEntity.showFailMsg("用户信息不存在");
|
}
|
|
@PutMapping("/setUserInfo")
|
@Operation(summary = "设置用户信息" , description = "设置用户信息")
|
public ServerResponseEntity<Void> setUserInfo(@RequestBody UserInfoParam userInfoParam) {
|
String userId = SecurityUtils.getUser().getUserId();
|
User user = new User();
|
user.setUserId(userId);
|
user.setPic(StrUtil.isBlank(userInfoParam.getAvatarUrl()) ? user.getPic() : userInfoParam.getAvatarUrl());
|
user.setSex(userInfoParam.getSex() == null ? user.getSex() : userInfoParam.getSex());
|
user.setUserMobile(userInfoParam.getUserMobile() == null ? user.getUserMobile() : userInfoParam.getUserMobile());
|
user.setBirthDate(userInfoParam.getBirthDate() == null ? user.getBirthDate() : userInfoParam.getBirthDate());
|
user.setUserMail(StrUtil.isNotBlank(userInfoParam.getUserMail()) ? userInfoParam.getUserMail() : user.getUserMail());
|
if (StrUtil.isNotBlank(userInfoParam.getNickName())) {
|
user.setNickName(userInfoParam.getNickName());
|
}
|
// 如果有一项不为空，则发送事件，修改分销员信息（如果是分销员）
|
if (StrUtil.isNotBlank(userInfoParam.getAvatarUrl()) || StrUtil.isNotBlank(userInfoParam.getNickName())) {
|
applicationContext.publishEvent(new UpdateDistributionUserEvent(userInfoParam, user.getUserId()));
|
}
|
userService.updateById(user);
|
|
User userInfo = userService.getById(userId);
|
userInfo.setPayPassword(null);
|
|
try {
|
imSetUserInfo(userInfo);
|
}catch (Exception e) {
|
e.printStackTrace();
|
}
|
return ServerResponseEntity.success();
|
}
|
|
@Async
|
private void imSetUserInfo(User userInfo) {
|
ImConfigParam imConfig = sysConfigService.getSysConfigObject("IM_CONFIG", ImConfigParam.class);
|
imTokenService.updateImUserInfo(userInfo, imConfig);
|
}
|
|
@GetMapping("/centerInfo")
|
@Operation(summary = "个人中心信息" , description = "获取用户个人中心信息")
|
public ServerResponseEntity<UserCenterInfoDto> centerInfo() {
|
String userId = SecurityUtils.getUser().getUserId();
|
UserCenterInfoDto userCenterInfoDto = new UserCenterInfoDto();
|
userCenterInfoDto.setOrderCountData(orderService.getOrderCount(userId));
|
ShopAuditing shopAuditing = shopAuditingService.getShopAuditingByUserId(userId);
|
userCenterInfoDto.setShopAuditStatus(shopAuditing == null ? null : shopAuditing.getStatus());
|
ShopDetail shopDetail = shopDetailService.getShopDetailByUserId(userId);
|
userCenterInfoDto.setIsSetPassword(shopDetail != null && StrUtil.isNotBlank(shopDetail.getPassword()));
|
userCenterInfoDto.setShopId(shopDetail == null ? null : shopDetail.getShopId());
|
userCenterInfoDto.setShopStatus(shopDetail == null ? null : shopDetail.getShopStatus());
|
return ServerResponseEntity.success(userCenterInfoDto);
|
}
|
|
|
@GetMapping("/getUserScore")
|
@Operation(summary = "获取用户积分" , description = "返回用户的积分信息")
|
public ServerResponseEntity<UserParam> getUserScore() {
|
String userId = SecurityUtils.getUser().getUserId();
|
User user = userService.getById(userId);
|
UserParam userParam = mapperFacade.map(user, UserParam.class);
|
System.out.println();
|
return ServerResponseEntity.success(userParam);
|
}
|
|
@GetMapping("/getUserInfo")
|
@Operation(summary = "获取用户信息" , description = "返回用户的信息")
|
public ServerResponseEntity<UserInfoDto> getUserInfo() {
|
String userId = SecurityUtils.getUser().getUserId();
|
UserInfoDto userInfo = userExtensionService.getUserInfo(userId);
|
return ServerResponseEntity.success(userInfo);
|
}
|
|
@Operation(summary = "注销账户" , description = "注销账户")
|
@GetMapping("/destroy")
|
@Parameter(name = "forceDestroy", description = "强制注销" )
|
public ServerResponseEntity<Void> destroy(@RequestParam(value = "forceDestroy", required = false, defaultValue = "false") Boolean forceDestroy) {
|
String userId = SecurityUtils.getUser().getUserId();
|
// 检查此账户是否有未完成的订单
|
OrderCountData orderCount = orderService.getOrderCount(userId);
|
|
if (orderCount.getConsignment() + orderCount.getPayed() + orderCount.getRefund() + orderCount.getGrouping() > 0) {
|
// 存在未完成订单不能注销
|
throw new YamiShopBindException("yami.order.unfinished.cannot.destroy.account");
|
}
|
|
if (!forceDestroy) {
|
//用户余额
|
Double balance = 0.00;
|
//分销可提现余额
|
Double settledAmount = 0.00;
|
// 检查余额
|
UserInfoDto userInfo = userExtensionService.getUserInfo(userId);
|
if (userInfo.getTotalBalance() > 0) {
|
balance = userInfo.getTotalBalance();
|
}
|
// 检查分销账户余额
|
DistributionUser distributionUser = distributionUserService.getByUserIdAndShopId(userId, Constant.PLATFORM_SHOP_ID);
|
if (Objects.nonNull(distributionUser)) {
|
AchievementDataDto achievementDataDto = distributionUserService.getAchievementDataDtoById(distributionUser.getDistributionUserId());
|
DistributionUserWalletDto distributionUserWallet = achievementDataDto.getDistributionUserWallet();
|
settledAmount=distributionUserWallet.getSettledAmount();
|
}
|
String warnMsg = "";
|
DecimalFormat df = new DecimalFormat("#0.00");
|
String formatBanlance = df.format(balance);
|
String formatSettledAmount = df.format(settledAmount);
|
if(balance>0&&settledAmount>0){
|
if (Objects.equals(I18nMessage.getDbLang(), LanguageEnum.LANGUAGE_ZH_CN.getLang())) {
|
warnMsg = "您的账户当前仍有余额" + formatBanlance + "元及分销余额"+formatSettledAmount +"元，注销账户后所有余额将清零，请考虑清楚后再注销";
|
}else {
|
warnMsg = "You still have" + formatBanlance +" dollars and settledAmount "+formatSettledAmount+" dollars in your account, all balance will be cleared after you destroy the account. Please consider carefully before operation";
|
}
|
return ServerResponseEntity.showFailMsg(warnMsg);
|
}else if(balance>0){
|
if (Objects.equals(I18nMessage.getDbLang(), LanguageEnum.LANGUAGE_ZH_CN.getLang())) {
|
warnMsg = "您的账户当前仍有余额" +formatBanlance+ "元，注销账户后所有余额将清零，请考虑清楚后再注销";
|
}else {
|
warnMsg = "You still have" + formatBanlance +" dollars in your account, all balance will be cleared after you destroy the account. Please consider carefully before operation";
|
}
|
return ServerResponseEntity.showFailMsg(warnMsg);
|
}else if(settledAmount>0){
|
if (Objects.equals(I18nMessage.getDbLang(), LanguageEnum.LANGUAGE_ZH_CN.getLang())) {
|
warnMsg = "您的账户当前仍有分销余额" + formatSettledAmount + "元，注销账户后所有余额将清零，请考虑清楚后再注销";
|
}else {
|
warnMsg = "You still have settledAmount " + formatSettledAmount +" dollars in your account, all balance will be cleared after you destroy the account. Please consider carefully before operation";
|
}
|
return ServerResponseEntity.showFailMsg(warnMsg);
|
}
|
}
|
userService.destroyUser(userId);
|
return ServerResponseEntity.success();
|
}
|
|
@PostMapping("/updateUser")
|
@Operation(summary = "修改用户信息")
|
public ServerResponseEntity<String> updateUser(@RequestBody User user) {
|
Boolean flag = userService.updateById(user);
|
if(flag){
|
return ServerResponseEntity.success(ResponseEnum.OK.getMsg());
|
}else{
|
return ServerResponseEntity.showFailMsg(ResponseEnum.ERROR.getMsg());
|
}
|
}
|
@PostMapping("/activeUserAdver")
|
@Operation(summary = "用户激活广告信息")
|
public ServerResponseEntity<String> activeUserAdver() {
|
String userId = SecurityUtils.getUser().getUserId();
|
String msg = userService.activeUserAdver(userId);
|
if(ResponseEnum.OK.getMsg().equals(msg)){
|
return ServerResponseEntity.success(ResponseEnum.OK.getMsg());
|
}else{
|
return ServerResponseEntity.showFailMsg(msg);
|
}
|
}
|
}
|
