package com.ishop.merchant.platform;
|
|
import com.iplatform.base.Constants;
|
import com.iplatform.base.service.RoleServiceImpl;
|
import com.iplatform.base.util.TextUtils;
|
import com.iplatform.core.BeanContextAware;
|
import com.iplatform.model.po.S_role;
|
import com.iplatform.model.po.S_user_core;
|
import com.iplatform.model.po.S_user_login;
|
import com.ishop.merchant.BaseController;
|
import com.ishop.merchant.pojo.UserSearchParam;
|
import com.ishop.model.po.EbUser;
|
import com.ishop.model.request.UserAssignTagRequest;
|
import com.ishop.model.request.UserBalanceRequest;
|
import com.ishop.model.vo.RoleMerchantVo;
|
import com.walker.db.page.GenericPager;
|
import com.walker.infrastructure.utils.KeyValue;
|
import com.walker.infrastructure.utils.PhoneNumberUtils;
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.web.ResponseValue;
|
import com.walker.web.UserOnlineProvider;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@RestController
|
@RequestMapping("/platform/user")
|
public class UserRegisterController extends BaseController {
|
|
@RequestMapping(value = "/tag", method = RequestMethod.POST)
|
public ResponseValue setUserTag(@RequestBody UserAssignTagRequest request){
|
if(request == null
|
|| StringUtils.isEmpty(request.getTagIds())
|
|| StringUtils.isEmpty(request.getIds())){
|
return ResponseValue.error("设置标签参数未提交");
|
}
|
List<Long> userIds = TextUtils.stringToLongArrayByRegex(request.getIds(), StringUtils.DEFAULT_SPLIT_SEPARATOR);
|
// 更新用户标签
|
this.getUserRegisterService().execBatchTag(userIds, request.getTagIds());
|
// 更新用户缓存
|
this.batchUpdateEbUserCache(userIds);
|
return ResponseValue.success();
|
}
|
|
/**
|
* 保存移动端，作为商户管理角色设置。
|
* @param request
|
* @return
|
* @date 2023-09-25
|
*/
|
@RequestMapping(value = "/roles/merchant/save", method = RequestMethod.POST)
|
public ResponseValue saveRegUserMerchantAdmin(@RequestBody RoleMerchantVo request){
|
if(request == null
|
|| StringUtils.isEmpty(request.getRoleId())
|
|| request.getMerId() <= 0){
|
return ResponseValue.error("请设置管理角色信息");
|
}
|
if(request.getUserId() <= 0){
|
return ResponseValue.error("用户信息错误，userId为空");
|
}
|
long roleId = Long.parseLong(request.getRoleId());
|
|
this.getUserRegisterService().execRoleMerchantAdmin(request.getType(), roleId, request.getMerId(), request.getUserId());
|
// 1.更新用户缓存，2.删除用户登录缓存
|
S_user_core userCore = this.getUser(request.getUserId());
|
userCore.setType(request.getType());
|
userCore.setMer_id(request.getMerId());
|
this.getUserCacheProvider().updateUser(userCore);
|
|
S_user_login user_login = this.getUserLoginCache().getUserLogin(userCore.getUser_name());
|
if(user_login == null){
|
logger.warn("移动端商户角色设置：登录缓存未查到用户信息，无法删除登录缓存。user = {}", userCore.getUser_name());
|
return ResponseValue.success();
|
}
|
String uuid = user_login.getUuid();
|
UserOnlineProvider userOnlineProvider = BeanContextAware.getBeanByType(UserOnlineProvider.class);
|
userOnlineProvider.removeUserPrincipal(uuid);
|
logger.debug("删除用户登录缓存：uuid={}", uuid);
|
return ResponseValue.success();
|
}
|
|
@RequestMapping(value = "/roles/merchant", method = RequestMethod.GET)
|
public ResponseValue showUserMerchantRole(Long id){
|
if(id == null || id <= 0){
|
return ResponseValue.error("id is required!");
|
}
|
List<S_role> roleList = BeanContextAware.getBeanByType(RoleServiceImpl.class).queryUserRoleList(id);
|
S_user_core user = this.getUser(id);
|
|
RoleMerchantVo vo = new RoleMerchantVo();
|
vo.setType(user.getType());
|
vo.setMerId(user.getMer_id());
|
vo.setUserId(id);
|
if(!StringUtils.isEmptyList(roleList)){
|
// 移动端只会配置一个角色。
|
vo.setRoleId(String.valueOf(roleList.get(0).getRole_id()));
|
} else {
|
vo.setRoleId(StringUtils.EMPTY_STRING);
|
}
|
return ResponseValue.success(vo);
|
}
|
|
/**
|
* 在平台端，管理用户，可以设置移动端用户为商户管理员，看到一些管理功能界面。
|
* <pre>
|
* 1) 设置移动端用户属于某个角色，如：明运管理员等
|
* 2)
|
* </pre>
|
* @return
|
* @date 2023-09-25
|
*/
|
@RequestMapping(value = "/roles", method = RequestMethod.GET)
|
public ResponseValue listRole(){
|
List<S_role> roleList = this.getUserService().select(new S_role());
|
List<KeyValue> data = new ArrayList<>(8);
|
if(!StringUtils.isEmptyList(roleList)){
|
for(S_role role : roleList){
|
data.add(new KeyValue(role.getRole_id().toString(), role.getRole_name()));
|
}
|
}
|
return ResponseValue.success(data);
|
}
|
|
@RequestMapping(value = "/list", method = RequestMethod.GET)
|
public ResponseValue list(UserSearchParam param){
|
// if(param == null){
|
// return ResponseValue.error(Constants.ERROR_ARGUMENT);
|
// }
|
GenericPager<EbUser> pager = this.getUserRegisterService().queryPageUserList(param);
|
if(!StringUtils.isEmptyList(pager.getDatas())){
|
for(EbUser e : pager.getDatas()){
|
if(StringUtils.isNotEmpty(e.getAvatar())){
|
e.setAvatar(this.getCdnUrl() + e.getAvatar());
|
}
|
}
|
}
|
return ResponseValue.success(pager);
|
}
|
|
@RequestMapping(value = "/detail", method = RequestMethod.GET)
|
public ResponseValue detail(Long id){
|
if(id == null || id.longValue() <= 0){
|
return ResponseValue.error(Constants.ERROR_ARGUMENT);
|
}
|
EbUser user = this.getUserRegCache().get(id);
|
if(user == null){
|
return ResponseValue.error("无效用户");
|
}
|
if(user.getSpreadUid() != null && user.getSpreadUid().longValue() > 0){
|
user.setParameterString("spreadName", this.getUserRegisterName(user.getSpreadUid()));
|
}
|
// 手机号脱敏，放在另外属性中
|
if(StringUtils.isNotEmpty(user.getPhone())){
|
user.setParameterString("userPhone", PhoneNumberUtils.maskMobile(user.getPhone()));
|
}
|
return ResponseValue.success(user);
|
}
|
|
/**
|
* 用户后台充值，变动余额。
|
* @param request
|
* @return
|
* @date 2023-09-06
|
*/
|
@RequestMapping(value = "/operate/balance", method = RequestMethod.GET)
|
public ResponseValue userBalance(UserBalanceRequest request){
|
if(request == null || request.getUid() == null){
|
return ResponseValue.error(Constants.ERROR_ARGUMENT);
|
}
|
if(request.getMoney() == null || request.getMoney().doubleValue() == 0){
|
return ResponseValue.error("充值金额为0");
|
}
|
EbUser user = this.getUserRegCache().get(request.getUid());
|
if(user == null){
|
return ResponseValue.error("用户不存在");
|
}
|
if (user.getIsLogoff().intValue() == 1) {
|
return ResponseValue.error("已注销用户不可操作");
|
}
|
|
// 减少时要判断小于0的情况,添加时判断是否超过数据限制
|
if (request.getOperateType().equals(com.ishop.merchant.Constants.OPERATION_TYPE_SUBTRACT)) {
|
if ((user.getNowMoney().doubleValue() - request.getMoney().doubleValue()) < 0) {
|
return ResponseValue.error("余额扣减后不能小于0");
|
}
|
} else if(request.getOperateType().equals(com.ishop.merchant.Constants.OPERATION_TYPE_ADD)){
|
if((user.getNowMoney().doubleValue() + request.getMoney().doubleValue()) > 99999999.99){
|
return ResponseValue.error("余额添加后后不能大于99999999.99");
|
}
|
} else {
|
throw new UnsupportedOperationException("不支持的操作类型：" + request.getOperateType());
|
}
|
|
this.getUserRegisterService().execModifyUserBalance(request.getUid(), request.getMoney().doubleValue(), request.getOperateType(), user.getNowMoney().doubleValue());
|
return ResponseValue.success();
|
}
|
}
|
