标签：result return request 千万级 商城 put null b2b2c user
@源码地址来源： https://minglisoft.cn/honghu2/business.html会员控制类：
/**
* Copyright © 2012-2017 <a href="http://minglisoft.cn">HongHu</a> All rights reserved.
*/
package com.honghu.cloud.controller;
import java.io.IOException;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang.StringUtils;
import org.apache.http.HttpException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
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.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import com.google.common.collect.Maps;
import com.honghu.cloud.bean.Album;
import com.honghu.cloud.bean.CustomerService;
import com.honghu.cloud.bean.MemberFans;
import com.honghu.cloud.bean.Menu;
import com.honghu.cloud.bean.PredepositLog;
import com.honghu.cloud.bean.PullUserOrder;
import com.honghu.cloud.bean.Role;
import com.honghu.cloud.bean.User;
import com.honghu.cloud.bean.UserCard;
import com.honghu.cloud.bean.VerifyidCard;
import com.honghu.cloud.code.MemberResponseCode;
import com.honghu.cloud.code.ResponseCode;
import com.honghu.cloud.code.ResponseVO;
import com.honghu.cloud.constant.Globals;
import com.honghu.cloud.dto.AccessoryDto;
import com.honghu.cloud.dto.AreaDto;
import com.honghu.cloud.dto.IntegralLogDto;
import com.honghu.cloud.dto.ModularClassDto;
import com.honghu.cloud.dto.StoreDto;
import com.honghu.cloud.dto.SysConfigDto;
import com.honghu.cloud.dto.TemplateDto;
import com.honghu.cloud.dto.UserDto;
import com.honghu.cloud.dto.VerifyCodeDto;
import com.honghu.cloud.feign.AccessoryFeignClient;
import com.honghu.cloud.feign.AreaFeignClient;
import com.honghu.cloud.feign.CouponInfoFeignClient;
import com.honghu.cloud.feign.IntegralLogFeignClient;
import com.honghu.cloud.feign.IntegralToolsFeignClient;
import com.honghu.cloud.feign.ModularClassFeignClient;
import com.honghu.cloud.feign.MsgToolsFeignClient;
import com.honghu.cloud.feign.OrderFormFeignClient;
import com.honghu.cloud.feign.QrCodeFeignClient;
import com.honghu.cloud.feign.StoreFeignClient;
import com.honghu.cloud.feign.SysConfigFeignClient;
import com.honghu.cloud.feign.TemplateFeignClient;
import com.honghu.cloud.feign.TencentIMFeignClient;
import com.honghu.cloud.feign.VerifyCodeFeignClient;
import com.honghu.cloud.redis.RedisUtil;
import com.honghu.cloud.service.IAlbumService;
import com.honghu.cloud.service.ICustomerService;
import com.honghu.cloud.service.IFavoriteService;
import com.honghu.cloud.service.IFootPointService;
import com.honghu.cloud.service.IMemberFansService;
import com.honghu.cloud.service.IPredepositLogService;
import com.honghu.cloud.service.IPullUserOrderService;
import com.honghu.cloud.service.IRoleService;
import com.honghu.cloud.service.IUserCardService;
import com.honghu.cloud.service.IUserService;
import com.honghu.cloud.service.IVerifyidCardService;
import com.honghu.cloud.tools.SecurityUserHolder;
import com.honghu.cloud.utils.CommUtil;
import com.honghu.cloud.utils.JWT;
import com.honghu.cloud.utils.beans.BeanUtils;
import com.honghu.cloud.utils.tools.Md5Encrypt;
import net.sf.json.JSONObject;
/**
* 用户Controller
* @author Administrator
* @param <V>
*
*/
@SuppressWarnings({"rawtypes","unchecked"})
@RestController
@RequestMapping(value = "/user")
/*/*@CrossOrigin(origins = "*", maxAge = 3600, methods = { RequestMethod.GET, RequestMethod.POST, RequestMethod.DELETE,
RequestMethod.PUT })*/
public class UserController {
private static final Logger logger = LoggerFactory.getLogger(UserController.class);
@Autowired
private IUserService userService;
@Autowired
private IFootPointService footPointService;
@Autowired
private CouponInfoFeignClient couponInfoFeignClient;
@Autowired
private OrderFormFeignClient orderFormFeignClient;
@Autowired
private SysConfigFeignClient sysConfigFeignClient;
@Autowired
private AccessoryFeignClient accessoryFeignClient;
@Autowired
private VerifyCodeFeignClient verifyCodeFeignClient;
@Autowired
private MsgToolsFeignClient msgToolsFeignClient;
@Autowired
private IPullUserOrderService pullUserOrderService;
@Autowired
private QrCodeFeignClient qrCodeFeignClient;
@Autowired
private IRoleService roleService;
@Autowired
private AreaFeignClient areaFeignClient;
@Autowired
private IntegralLogFeignClient integralLogFeignClient;
@Autowired
private TemplateFeignClient templateFeignClient;
@Autowired
private ModularClassFeignClient modularClassFeignClient;
@Autowired
private ICustomerService customerService;
@Autowired
private IAlbumService albumService;
@Autowired
private IFavoriteService favoriteService;
@Autowired
private RedisUtil redisUtil;
@Autowired
private IVerifyidCardService verifyidCardService;
@Autowired
private StoreFeignClient storeFeignClient;
@Autowired
private TencentIMFeignClient tencentIMFeignClient;
@Autowired
private IUserCardService userCardService;
@Autowired
private IPredepositLogService predepositLogService;
@Autowired
private IMemberFansService memberFansService;
@Autowired
private IntegralToolsFeignClient integralToolsFeignClient;
@RequestMapping(value = "/apiForFeign/selectByIds", method = RequestMethod.POST)
public List<User> selectByIds(@RequestBody Map<String, Object> params) {
return userService.selectByIds(params);
}
@RequestMapping(value = "/apiForFeign/getMsgSubUsers", method = RequestMethod.GET)
public List<User> getMsgSubUsers(@RequestParam("parent_id") Long parent_id){
return userService.getMsgSubUsers(parent_id);
}
@RequestMapping(value = "/apiForFeign/auditNoteUser", method = RequestMethod.GET)
public List<User> auditNoteUser(){
return userService.auditNoteUser();
}
@RequestMapping(value = "/apiForFeign/selectCount", method = RequestMethod.GET)
public int selectCount(@RequestParam("params")Map<String, Object> params){
return userService.selectCount(params);
}
@RequestMapping(value = "/apiForFeign/whetherFans", method = RequestMethod.GET)
public boolean whetherFans(@RequestParam("mid") Long mid, @RequestParam("fansid") Long fansid) {
MemberFans memberFans = memberFansService.whetherFans(mid, fansid);
if (memberFans != null)
return true;
return false;
}
/**
* 根据用户id查询用户
* @param congelationDto
* @return
*/
@RequestMapping(value = "/apiForFeign/selectByPrimaryKey", method = RequestMethod.GET)
public User selectByPrimaryKey(@RequestParam("id") Long id) {
User user = userService.selectByPrimaryKey(id);
if(user != null && user.getPhoto_id() != null){
user.setPhoto(accessoryFeignClient.selectByPrimaryKey(user.getPhoto_id()));
}
return user;
}
@RequestMapping(value = "/apiForFeign/selectUserCardByUserId", method = RequestMethod.GET)
public UserCard selectUserCardByUserId(@RequestParam("id") Long id) {
return userCardService.selectByUserId(id);
}
@RequestMapping(value = "/apiForFeign/queryPageList", method = RequestMethod.GET)
public List<User> queryPageList(@RequestParam("params")Map<String, Object> params) {
return userService.queryPageList(params, null, null);
}
@RequestMapping(value = "/apiForFeign/verityUserNamePassword", method = RequestMethod.POST)
public List<User> verityUserNamePassword(@RequestBody Map<String, Object> params) {
return userService.verityUserNamePassword(params);
}
@RequestMapping(value = "/apiForFeign/selectPullByOrderId", method = RequestMethod.GET)
public PullUserOrder selectPullByOrderId(@RequestParam("id") Long id) {
PullUserOrder obj = pullUserOrderService.selectPullByOrderId(id);
return obj;
}
@RequestMapping(value = "/apiForFeign/savePullUserOrder", method = RequestMethod.POST)
public void savePullUserOrder(@RequestBody PullUserOrder obj) {
pullUserOrderService.saveEntity(obj);
}
/**
* 根据订单id查询拉新用户表 ,进行删除
* @param id
*/
@RequestMapping(value = "/apiForFeign/delPullByOrderId", method = RequestMethod.GET)
public void delPullByOrderId(@RequestParam("id") Long id) {
pullUserOrderService.deleteByOrderId(id);
}
@RequestMapping(value = "/apiForFeign/queryByProperty", method = RequestMethod.POST)
public User queryByProperty(@RequestParam("params")Map<String, Object> params) {
return userService.queryByProperty(params);
}
@RequestMapping(value = "/apiForFeign/updateById", method = RequestMethod.POST)
public void updateById(@RequestBody User obj) {
userService.updateById(obj);
}
@RequestMapping(value = "/apiForFeign/update", method = RequestMethod.POST)
public void update(@RequestBody User obj) {
userService.update(obj);
}
@RequestMapping(value = "/apiForFeign/saveEntity", method = RequestMethod.POST)
public User saveEntity(@RequestBody User obj) {
return userService.saveEntity(obj);
}
@RequestMapping(value = "/apiForFeign/saveUserCard", method = RequestMethod.POST)
public void saveUserCard(@RequestBody UserCard obj) {
userCardService.saveEntity(obj);
}
/**
* 根据unionid查询用户
* @param unionid
* @return
*/
@RequestMapping(value = "/apiForFeign/selectByUnionid", method = RequestMethod.POST)
public User selectByUnionid(@RequestParam("unionid") String unionid){
return userService.selectByUnionid(unionid);
}
@RequestMapping(value = "/apiForFeign/selectByWxOpenId", method = RequestMethod.POST)
public User selectByWxOpenId(@RequestParam("openid") String openid){
return userService.selectByWxOpenId(openid);
}
@RequestMapping(value = "/apiForFeign/getUserByStoreId", method = RequestMethod.GET)
public User getUserByStoreId(@RequestParam("id") Long id) {
return userService.getUserByStoreId(id);
}
@RequestMapping(value = "/apiForFeign/deleteUserMenu", method = RequestMethod.GET)
public void deleteUserMenu(@RequestParam("id") Long id) {
userService.deleteUserMenu(id);
}
@RequestMapping(value = "/apiForFeign/updateLiveById", method = RequestMethod.GET)
public void updateLiveById(@RequestParam("id") Long id) {
userService.updateLiveById(id);
}
@RequestMapping(value = "/apiForFeign/saveUserMenu", method = RequestMethod.POST)
public void saveUserMenu(@RequestParam("id") Long id,@RequestBody List<Menu> ms) {
userService.saveUserMenu(id,ms);
}
/**
* 客服列表
* @param request
* @param response
* @return
* @throws Exception
*/
@RequestMapping(value="/buyer/customerServiceList", method = RequestMethod.POST)
public Map<String, Object> customerServiceList(HttpServletRequest request,HttpServletResponse response) {
Map<String,Object> params = Maps.newHashMap();
List<CustomerService> list = customerService.queryPages(params);
HashMap<String, Object> result = new HashMap<>();
result.put("list", list);
System.out.println(result);
return ResponseCode.buildSuccessMap(result);
}
/**
* 用户中心完善资料
* @param request
* @param response
* @return
*/
@RequestMapping(value="/buyer/account")
public Map<String, Object> account(HttpServletRequest request,
HttpServletResponse response) {
Map<String, Object> result = new HashMap<String, Object>();
long user_id = SecurityUserHolder.getCurrentUser(request).getId().longValue();
User user = selectByPrimaryKey(user_id);
if(user == null){
return ResponseCode.buildEnumMap(ResponseCode.USER_NOT_EXISTS_ERROR, null);
}
result.put("obj", user);
result.put("imageFilesize", Integer.valueOf(sysConfigFeignClient.getSysConfig().getImageFilesize()));
return ResponseCode.buildSuccessMap(result);
}
/**
* 用户中心完善资料
* @param request
* @param response
* @return
*/
@RequestMapping(value="/buyer/liveCode")
public Map<String, Object> liveCode(HttpServletRequest request,
HttpServletResponse response) {
HashMap<String, Object> result = new HashMap<>();
User user = userService.selectByPrimaryKey(SecurityUserHolder.getCurrentUserId(request));
result.put("liveCode", user.getLive_code());
return ResponseCode.buildSuccessMap(result);
}
/**
* 用户中资料保存
* @param request
* @param response
* @param USER_AGE
* @param card
* @param userName
* @param sex
* @return
* @throws Exception
*/
@RequestMapping(value="/buyer/account_save", method = RequestMethod.POST)
public Map<String, Object> account_saveEntity(HttpServletRequest request,
HttpServletResponse response,@RequestBody JSONObject json) throws Exception {
String userName = json.optString("userName");
String nickName = json.optString("nickName");
String sex = json.optString("sex");
String photo_id = json.optString("photo_id");
String USER_AGE = json.optString("USER_AGE");
User user = this.userService.selectByPrimaryKey(SecurityUserHolder
.getCurrentUser(request).getId());
if ((userName != null) && (!userName.equals(""))) {
user.setTrueName(userName);
}
if ((USER_AGE != null) && (!USER_AGE.equals(""))) {
user.setBirthday(CommUtil.formatDate(USER_AGE));
}
if ((nickName != null) && (!nickName.equals(""))) {
user.setNickName(nickName);
}
if ((sex != null) && (!sex.equals(""))) {
user.setSex(CommUtil.null2Int(sex));
}
if(StringUtils.isNotBlank(photo_id)){
user.setPhoto_id(CommUtil.null2Long(photo_id));
}
this.userService.updateById(user);
try{
//腾讯IM账号资料更改
UserDto userDto = new UserDto();
BeanUtils.copyProperties(user, userDto);
tencentIMFeignClient.portraitSet(userDto);
}catch (Exception e) {
logger.error("UserController >> account_saveEntity >> IM portraitSet "+ e.getMessage());
}
return ResponseCode.buildSuccessMap(null);
}
/**
* 手机客户端商城首页
* @param request
* @param response
* @param store_id
* @return
*/
@RequestMapping(value="/center", method = RequestMethod.POST)
public Map<String, Object> center(HttpServletRequest request, HttpServletResponse response) {
Map<String, Object> result = new HashMap<String, Object>();
UserDto u = SecurityUserHolder.getCurrentUser(request);
if ((u != null) && (!u.equals(""))) {
User user = this.userService.selectByPrimaryKey(SecurityUserHolder
.getCurrentUser(request).getId());
if (user!=null&&user.getPhoto_id()!=null) {
AccessoryDto photo = accessoryFeignClient.selectByPrimaryKey(user.getPhoto_id());
user.setPhoto(photo);
}
int selectCount = footPointService.selectSumCount(user.getId());
/*Map<String,Object> foot_params = Maps.newHashMap();
foot_params.put("fp_user_id", user.getId());
foot_params.put("deleteStatus", 0);
//List<FootPoint> fps = footPointService.queryPageList(foot_params);
//result.put("objs", fps);*/
result.put("footsize", selectCount);
Map<String, Object> params = Maps.newHashMap();
params.put("user_id", user.getId());
params.put("status", Integer.valueOf(0));
result.put("couponInfos",Integer.valueOf(couponInfoFeignClient.selectCount(params)));
/* params.clear();
params.put("status", Integer.valueOf(10));
params.put("user_id", user.getId().toString());
result.put("orders_10",Integer.valueOf(orderFormFeignClient.selectCount(params)));*/
// result.put("integralViewTools", this.integralViewTools);
params.clear();
params.put("type", Integer.valueOf(0));
params.put("user_id", user.getId());
int favorite_goods = favoriteService.selectCount(params);
result.put("favorite_goods", favorite_goods);
params.clear();
params.put("type", Integer.valueOf(1));
params.put("user_id", user.getId());
result.put("favorite_store",favoriteService.selectCount(params));
params.clear();
params.put("order_status", Integer.valueOf(10));
params.put("user_id", user.getId().toString());
//params.put("order_main", Integer.valueOf(1));
//List<OrderFormDto> order_nopays = orderFormFeignClient.queryPageList(params);
Integer order_nopays = orderFormFeignClient.selectCount(params);
String order_nopay = "";
if (order_nopays > 99) {
order_nopay = "99+";
} else {
order_nopay = order_nopays + "";
}
result.put("order_nopay", order_nopay);
params.clear();
params.put("order_status1", Integer.valueOf(14));
params.put("order_status2", Integer.valueOf(20));
params.put("user_id", user.getId().toString());
//params.put("order_main", Integer.valueOf(1));
//List<OrderFormDto> order_noships = orderFormFeignClient.queryPageList(params);
Integer order_noships = orderFormFeignClient.selectCount(params);
String order_noship = "";
if (order_noships > 99) {
order_noship = "99+";
} else {
order_noship = order_noships + "";
}
result.put("order_noship", order_noship);
params.clear();
params.put("order_status1", Integer.valueOf(30));
params.put("order_status2", Integer.valueOf(35));
params.put("user_id", user.getId().toString());
//params.put("order_main", Integer.valueOf(1));
//List<OrderFormDto> order_notakes = orderFormFeignClient.queryPageList(params);
Integer order_notakes = orderFormFeignClient.selectCount(params);
String order_notake = "";
if (order_notakes > 99) {
order_notake = "99+";
} else {
order_notake = order_notakes + "";
}
result.put("order_notake", order_notake);
params.clear();
params.put("order_status", Integer.valueOf(40));
params.put("user_id", user.getId().toString());
Integer order_noevaluate = orderFormFeignClient.selectCount(params);
String noevaluate = "0";
if (order_noevaluate > 99) {
noevaluate = "99+";
} else {
noevaluate = order_noevaluate + "";
}
result.put("noevaluate", noevaluate);
params.clear();
/* params.put("status", Integer.valueOf(0));
params.put("user_id", user.getId());
params.put("parent", -1);
List<MessageDto> msgs = messageFeignClient.queryPageList(params);
result.put("msg_size", msgs.get(0));*/
result.put("user", user);
// result.put("integralViewTools", this.integralViewTools);
result.put("level", integralToolsFeignClient.query_user_level(String.valueOf(user.getId())));
Integer store_status=0;
if (user.getStore_id()!=null) {
StoreDto store = storeFeignClient.selectByPrimaryKey(user.getStore_id());
if (store!=null) {
store_status = store.getStore_status();
ModularClassDto ModularClassDto = modularClassFeignClient.selectByStoreId(store.getId());
if (ModularClassDto!=null) {
result.put("timely", ModularClassDto.isTimely());
}else{
result.put("timely",false);
}
}
}
result.put("store_status", store_status);
//是否是代理商（业务员：推荐开店能获取店铺收益的那种）
Integer platAgent = userService.agentCount(user.getId());
result.put("platAgent", platAgent);
}
return ResponseCode.buildSuccessMap(result);
}
/**
* 个人二维码
* @param request
* @param response
* @return
* @throws Exception
*/
@RequestMapping(value="/buyer/myQrcode", method = RequestMethod.GET)
public Map<String, Object> myQrcode(HttpServletRequest request,HttpServletResponse response) throws Exception {
UserDto userDto = SecurityUserHolder.getCurrentUser(request);
User user = userService.selectByPrimaryKey(userDto.getId());
if(StringUtils.isEmpty(user.getDirect_selling_qr_path())) {
if(null != user.getPhoto_id()){
user.setPhoto(accessoryFeignClient.selectByPrimaryKey(user.getPhoto_id()));
}
BeanUtils.copyProperties(user, userDto);
// 生成用户分销二维码
String myQrcode = qrCodeFeignClient.myQrcode(userDto);
user.setDirect_selling_qr_path(myQrcode);
userService.updateById(user);
}
return ResponseCode.buildSuccessMap(user.getDirect_selling_qr_path());
}
/**
* 用户中心支付密码修改
* @param request
* @param response
* @return
@RequestMapping(value="/buyer/account_pay_password", method = RequestMethod.GET)
public Map<String, Object> account_pay_password(HttpServletRequest request,
HttpServletResponse response) {
Map<String, Object> result = new HashMap<String, Object>();
User user = this.userService.selectByPrimaryKey(SecurityUserHolder.getCurrentUser().getId());
result.put("user", user);
if ((user.getMobile() != null) && (!user.getMobile().equals(""))) {
String show_tel = user.getMobile();
result.put("show_tel", show_tel);
result.put("first", Integer.valueOf(-1));
} else {
result.put("first", "1");
}
return ResponseCode.buildSuccessMap(result);
}*/
/**
* 修改支付密码提交
* @param request
* @param response
* @param pay_password
* @param pay_password_confirm
* @param phone_number
* @param code
* @param t
* @return
*/
@RequestMapping(value="/buyer/account_pay_password_save", method = RequestMethod.POST)
public Map<String, Object> account_pay_password_saveEntity(HttpServletRequest request,
HttpServletResponse response, String pay_password, String pay_password_confirm, String phone_number, String code) {
Map<String, Object> result = new HashMap<String, Object>();
if(null == code || StringUtils.isEmpty(code)){
result.put("op_title", "验证码不能为空，支付密码修改失败");
result.put("url", CommUtil.getURL(request) + "/buyer/account_pay_password");
return ResponseCode.buildCodeMap("20004", "不要做违规操作，超过一定次数将冻结预存款", result);
}
VerifyCodeDto vc = verifyCodeFeignClient.getObjByProperty("mobile", "=", phone_number);
if (vc == null) {
result.put("op_title", "不要做违规操作，超过一定次数将冻结预存款");
result.put("url", CommUtil.getURL(request) + "/buyer/account_pay_password");
return ResponseCode.buildCodeMap("20003", "不要做违规操作，超过一定次数将冻结预存款", result);
}
if (!code.equalsIgnoreCase(vc.getCode())) {
result.put("op_title", "验证码错误，支付密码修改失败");
result.put("url", CommUtil.getURL(request) + "/buyer/account_pay_password");
return ResponseCode.buildCodeMap("20002", "验证码错误，支付密码修改失败", result);
}
if (StringUtils.isEmpty(pay_password) || StringUtils.isEmpty(pay_password_confirm)
|| !StringUtils.equals(pay_password, pay_password_confirm)){
result.put("op_title", "两次密码输入不相同");
result.put("url", CommUtil.getURL(request) + "/buyer/account_pay_password");
return ResponseCode.buildCodeMap("20001", "两次密码输入不相同", result);
}
User user = this.userService.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());
user.setMobile(phone_number);
user.setPay_password(Md5Encrypt.md5(pay_password));
this.userService.updateById(user);
result.put("op_title", "支付密码修改成功");
result.put("url", CommUtil.getURL(request) + "/index");
return ResponseCode.buildSuccessMap(result);
}
/**手机短信密码修改 TODO:(小程序没有
* @param request
* @param response
* @param password 密码
* @param mobile 手机号
* @param mobile_code 验证码
* @return
*//*
@RequestMapping({ "/mobile_account_password_save" })
@ResponseBody
public String mobile_account_password_save(HttpServletRequest request,
HttpServletResponse response,String password,String mobile ,String mobile_code,String password_or) {
if(mobile == null || "".equals(mobile)){
return "403";
}
if(mobile_code == null || "".equals(mobile_code)){
return "404";
}
Jedis jedis = RedisCache.getJedis();
if(jedis.exists(SerializeUtil.serialize(mobile))){
byte[] bs = jedis.get(SerializeUtil.serialize(mobile));
Object deserialize = SerializeUtil.deserialize(bs);
if(deserialize != null){
if(!CommUtil.null2String(mobile_code).equals(deserialize.toString())){
return "402";
}
}
}else{
return "401";
}
if(jedis != null){
jedis.close();
}
if(password != null && password_or != null){
if(password.equals(password_or)){
if(!CommUtil.null2String(mobile).equals("")){
List<User> users=this.userService.selectByMobileOrUserName(mobile);
if(users != null && users.size() > 0){
User user = users.get(0);
user.setPassword(Md5Encrypt.md5(password));
this.userService.updateById(user);
}else{
return "400";
}
}
}else{
return "406";
}
}else{
return "405";
}
return "200";
}
*/
/* *//**
* 修改支付密码-手机短信发送
* @param request
* @param response
* @param mobile
*//*
@RequestMapping(value="/buyer/account_mobile_sms", method = RequestMethod.POST)
public Map<String, Object> account_mobile_sms(HttpServletRequest request,
HttpServletResponse response, String mobile) {
SysConfigDto sysConfigDto = sysConfigFeignClient.getSysConfig();
if (!sysConfigDto.getSmsEnbale()) {
return ResponseCode.buildCodeMap("20002", "短信服务未开启", null);
}
String code = CommUtil.randomInt(4);
String content = "尊敬的" + SecurityUserHolder.getCurrentUser(request).getUserName()
+ "您好，您在试图修改" + sysConfigDto.getWebsiteName() + "的支付密码，"
+ "手机验证码为：" + code + "。[" + sysConfigDto.getTitle() + "]";
boolean ret_op = msgToolsFeignClient.sendSMS(mobile, content);
if (!ret_op) {
return ResponseCode.buildCodeMap("20001", "发送短信失败", null);
}
VerifyCodeDto mvc = verifyCodeFeignClient.getObjByProperty("mobile","=", mobile);
if (mvc == null) {
mvc = new VerifyCodeDto();
}
mvc.setAddTime(new Date());
mvc.setCode(code);
mvc.setMobile(mobile);
verifyCodeFeignClient.updateById(mvc);
return ResponseCode.buildSuccessMap(null);
}
*//**
* 修改绑定手机
* @param request
* @param response
* @return
@RequestMapping(value="/buyer/account_mobile_bind", method = RequestMethod.POST)
public Map<String, Object> account_mobile_password(HttpServletRequest request,
HttpServletResponse response) {
Map<String, Object> result = new HashMap<String, Object>();
User user = this.userService.selectByPrimaryKey(SecurityUserHolder
.getCurrentUser().getId());
if ((user.getMobile() != null) && (!user.getMobile().equals(""))) {
String show_tel = user.getMobile().substring(0, 3) + "*****"
+ user.getMobile().substring(8, 11);
result.put("show_tel", show_tel);
result.put("first", "-1");
} else {
result.put("first", "1");
}
return ResponseCode.buildSuccessMap(result);
}*//*
*//**
* 手机号码绑定提交
* @param request
* @param response
* @param code
* @param new_mobile
* @param t
* @return
* @throws Exception
*//*
@RequestMapping(value="/buyer/account_mobile_bind_save", method = RequestMethod.POST)
public Map<String, Object> account_mobile_bind_saveEntity(HttpServletRequest request,
HttpServletResponse response, String code, String new_mobile,
String t) throws Exception {
Map<String, Object> result = new HashMap<String, Object>();
if (StringUtils.isEmpty(code)) {
result.put("op_title", "验证码不能为空，支付密码修改失败");
result.put("url", CommUtil.getURL(request) + "/buyer/account_mobile_bind");
return ResponseCode.buildCodeMap("20004", "验证码不能为空，支付密码修改失败", result);
}
VerifyCodeDto mvc = verifyCodeFeignClient.getObjByProperty("mobile","=", new_mobile);
if (mvc == null) {
result.put("op_title", "请填写正确的验证码和手机号码，手机绑定失败");
result.put("url", CommUtil.getURL(request) + "/buyer/account_mobile_bind");
return ResponseCode.buildCodeMap("20003", "请填写正确的验证码和手机号码，手机绑定失败", result);
}
if (!StringUtils.equals(mvc.getCode(), code)) {
result.put("op_title", "验证码错误，手机绑定失败");
result.put("url", CommUtil.getURL(request) + "/buyer/account_mobile_bind");
return ResponseCode.buildCodeMap("20002", "验证码错误，手机绑定失败", result);
}
User user = this.userService.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());
if (new_mobile.equals(user.getMobile())) {
result.put("op_title", "新旧输入电话号码不能相同，手机绑定失败");
result.put("url", CommUtil.getURL(request) + "/buyer/account_mobile_bind");
return ResponseCode.buildCodeMap("20001", "新旧输入电话号码不能相同，手机绑定失败", result);
}
user.setMobile(new_mobile);
this.userService.updateById(user);
verifyCodeFeignClient.deleteById(mvc.getId());
result.put("op_title", "手机绑定成功");
String content = "尊敬的" + SecurityUserHolder.getCurrentUser(request).getUserName()
+ "您好，您于" + CommUtil.formatLongDate(new Date())+ "绑定手机号成功。["
+ sysConfigFeignClient.getSysConfig().getTitle() + "]";
msgToolsFeignClient.sendSMS(user.getMobile(), content);
result.put("op_title", "手机绑定成功");
result.put("url", CommUtil.getURL(request) + "/buyer/account_safe");
return ResponseCode.buildSuccessMap(result);
}
*//**
* 手机绑定短信发送
* @param request
* @param response
* @param new_mobile
* @param t
*//*
@RequestMapping(value="/buyer/account_mobile_bind_sms", method = RequestMethod.POST)
public Map<String, Object> account_mobile_bind_sms(HttpServletRequest request,
HttpServletResponse response, String new_mobile) {
SysConfigDto configDto = sysConfigFeignClient.getSysConfig();
if (!configDto.getSmsEnbale()) {
return ResponseCode.buildCodeMap("20002", "短信服务未开启", null);
}
String code = CommUtil.randomInt(4);
String content = "";
content = "尊敬的" + SecurityUserHolder.getCurrentUser(request).getUserName()
+ "您好，您在试图修改" + configDto.getWebsiteName() + "的绑定手机号码，"
+ "手机验证码为：" + code + "。[" + configDto.getTitle() + "]";
boolean ret_op = msgToolsFeignClient.sendSMS(new_mobile, content);
if (!ret_op) {
return ResponseCode.buildCodeMap("20001", "发送短信失败", null);
}
VerifyCodeDto mvc = verifyCodeFeignClient.getObjByProperty("mobile","=", new_mobile);
if (mvc == null) {
mvc = new VerifyCodeDto();
}
mvc.setAddTime(new Date());
mvc.setCode(code);
mvc.setMobile(new_mobile);
verifyCodeFeignClient.updateById(mvc);
return ResponseCode.buildSuccessMap(null);
}*/
/**
* 已有账号绑定保存
* @param request
* @param response
* @param userName
* @param password
* @param mobile_verify_code
* @param mobile
*/
@RequestMapping(value="/buyer/datum2", method = RequestMethod.POST)
public Map<String, Object> datum2(HttpServletRequest request,
HttpServletResponse response, String userName, String password,
String mobile_verify_code, String mobile){
Map<String, Object> result = new HashMap<String, Object>();
VerifyCodeDto mvc = verifyCodeFeignClient.getObjByProperty("mobile","=", mobile);
if (mvc == null) {
result.put("op_title", "请填写正确的验证码和手机号码，手机绑定失败");
result.put("url", CommUtil.getURL(request) + "/buyer/account_mobile_bind");
return ResponseCode.buildCodeMap("20003", "请填写正确的验证码和手机号码，手机绑定失败", result);
}
String passwd = Md5Encrypt.md5(password).toLowerCase();
Map<String, Object> map = Maps.newHashMap();
map.put("userName", userName);
map.put("passwd", passwd);
List<User> users = this.userService.queryPageList(map);
if ((mvc != null) && (mvc.getCode().equalsIgnoreCase(mobile_verify_code))
&& (users.size() > 0)) {
User bind_user = (User) users.get(0);
if (CommUtil.null2String(bind_user.getOpenId()).equals("")) {
User current_user = this.userService.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());
if (current_user != null) {
bind_user.setOpenId(current_user.getOpenId());
bind_user.setUserMark(null);
this.userService.updateById(bind_user);
Map<String,Object> json = Maps.newHashMap();
json.put("login", Boolean.valueOf(true));
json.put("userName", userName);
json.put("passwd", passwd);
json.put("userId", current_user.getId());
return ResponseCode.buildSuccessMap(json);
}
}
return ResponseCode.buildCodeMap("20001", "参数错误", null);
} else {
return ResponseCode.buildCodeMap("20002", "验证码错误", null);
}
}
/**
* 已有账号绑定保存错误提示
* @param request
* @param response
* @return
@RequestMapping(value="/buyer/datum_error", method = RequestMethod.GET)
public Map<String, Object> datum_error(HttpServletRequest request,
HttpServletResponse response) {
Map<String, Object> result = new HashMap<String, Object>();
result.put("op_title", "用户名或验证码输入错误！");
result.put("url", CommUtil.getURL(request) + "/buyer/center");
return ResponseCode.buildSuccessMap(result);
}*/
@RequestMapping(value = "/test", method = RequestMethod.POST)
public ResponseVO login1( HttpServletRequest request){
return MemberResponseCode.buildEnumResponseVO(MemberResponseCode.RESPONSE_CODE_USER_PASSWORD_NOT_EMPTY, null);
}
/**
* 用户登录(WAP)
* @param request
* @return
*/
@RequestMapping(value = "/login", method = RequestMethod.POST)
public ResponseVO login(@RequestBody JSONObject json, HttpServletRequest request){
//获取数据
String username = json.optString("username");
String password = json.optString("password");
//验证用户是否为空;
if(StringUtils.isEmpty(username)){
return MemberResponseCode.buildEnumResponseVO(MemberResponseCode.RESPONSE_CODE_USER_NAME_NOT_EMPTY, null);
}
//验证密码是否为空;
if(StringUtils.isEmpty(password)){
return MemberResponseCode.buildEnumResponseVO(MemberResponseCode.RESPONSE_CODE_USER_PASSWORD_NOT_EMPTY, null);
}
HashMap<String, Object> params = new HashMap<String, Object>();
params.put("userName", username);
List<User> User_list = userService.queryPageList(params);
if(User_list == null||User_list.size()<1){
return MemberResponseCode.buildEnumResponseVO(MemberResponseCode.RESPONSE_CODE_USER_DOES_NOT_EXIST, null);
}
User info = User_list.get(0);
//判断用户是否禁用
if( -1== info.getStatus()){
return MemberResponseCode.buildEnumResponseVO(MemberResponseCode.RESPONSE_CODE_USER_NAME_IS_DISABLE, null);
}
//用户密码是否匹配
if(!StringUtils.equals(Md5Encrypt.md5(password), info.getPassword())){
return MemberResponseCode.buildEnumResponseVO(MemberResponseCode.RESPONSE_CODE_USER_PASSWORD_NOT_VALIDATE, null);
}
String token = JWT.sign(info.getId() + ";" + System.currentTimeMillis()+";"+"app", 0);
// 将token存到redis中，有效期24小时
redisUtil.set(Globals.ANDROID_LOGIN_MARK + info.getId(), token, Globals.USER_INFO_EXPIRE_TIME);
// 覆盖redis用户信息
UserDto userDto = new UserDto();
BeanUtils.copyProperties(info, userDto);
redisUtil.set(Globals.USER_INFO_MARK + info.getId(), userDto, Globals.USER_INFO_EXPIRE_TIME);
//加密用户名、密码
/* String token = JWT.sign(info.getId(), 0);
//将用户名密码生成的token信息放入redis缓存
redisUtil.set(Globals.WAP_LOGIN_MARK + info.getId(), token);*/
Map<String, Object> result = new HashMap<String, Object>();
//根据uid查询member信息
User user = userService.selectByPrimaryKey(info.getId());
/*if (user.getPhoto_id()!=null) {
AccessoryDto accessoryDto = accessoryFeignClient.selectByPrimaryKey(user.getPhoto_id());
if (accessoryDto!=null) user.setPhoto(accessoryDto);
}*/
result.put("userInfo", user);
result.put("token", token);
return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, result);
}
private static final String REGEX1 = "(.*管理员.*)";
private static final String REGEX2 = "(.*admin.*)";
/**
* 注册完成
* @param request
* @param response
* @param userName
* @param password
* @param email
* @param code
* @param user_type
* @return
* @throws HttpException
* @throws IOException
* @throws InterruptedException
*/
@RequestMapping(value="/register_finish", method = RequestMethod.POST)
public Map<String, Object> register_finish(@RequestBody JSONObject json,HttpServletRequest request, HttpServletResponse response
) throws HttpException, IOException, InterruptedException {
// 获取数据
String userName = json.optString("username");
String password = json.optString("password");
String user_type = json.optString("user_type");
String directSellingParent_id = json.optString("directSellingParent_id");
String email = json.optString("email");
// 验证用户是否为空;
if (StringUtils.isEmpty(userName)) {
return ResponseCode.buildFailMap("10004", "参数错误");
}
// 验证密码是否为空;
if (StringUtils.isEmpty(password)) {
return ResponseCode.buildFailMap("10004", "参数错误");
}
SysConfigDto sysConfig = sysConfigFeignClient.getSysConfig();
//查询是否有用户名
HashMap<String, Object> map = new HashMap<String, Object>();
map.put("userName", userName);
List<User> User_list = userService.queryPageList(map);
if (User_list.size() > 0) {
return ResponseCode.buildFailMap("10003", "该用户名已注册");
}
try {
boolean reg = true;
if ((userName.matches(REGEX1)) || (userName.toLowerCase().matches(REGEX2))) {
reg = false;
}
if (reg) {
User user = new User();
user.setUserName(userName);
user.setUserRole("BUYER");
user.setAddTime(new Date());
user.setEmail(email);
user.setAvailableBalance(BigDecimal.valueOf(0L));
user.setFreezeBlance(BigDecimal.valueOf(0L));
if (directSellingParent_id != null) {
User directSellingParent = this.userService
.selectByPrimaryKey(CommUtil.null2Long(directSellingParent_id));
user.setDirectSellingParent(directSellingParent);
}
if ((user_type != null) && (!user_type.equals(""))) {
user.setUser_type(CommUtil.null2Int(user_type));
user.setContact_user(request.getParameter("contact_user"));
user.setDepartment(request.getParameter("department"));
user.setTelephone(request.getParameter("telephone"));
user.setMobile(request.getParameter("mobile"));
user.setCompany_name(request.getParameter("company_name"));
AreaDto area = this.areaFeignClient.selectByPrimaryKey(CommUtil
.null2Long(request.getParameter("area_id")));
user.setCompany_address(area.getParent().getParent()
.getAreaName()
+ area.getParent().getAreaName()
+ area.getAreaName()
+ " "
+ request.getParameter("company_address"));
if (request.getParameter("company_purpose") != null) {
if (!request.getParameter("company_purpose").equals("")) {
user.setCompany_purpose(request.getParameter(
"company_purpose").substring(
0,
request.getParameter("company_purpose")
.length() - 1));
}
}
user.setCompany_url(request.getParameter("company_url"));
user.setCompany_person_num(request
.getParameter("company_person_num"));
user.setCompany_trade(request.getParameter("company_trade"));
user.setCompany_nature(request
.getParameter("company_nature"));
}
user.setPassword(Md5Encrypt.md5(password).toLowerCase());
Map<String, Object> params = Maps.newHashMap();
params.put("type", "BUYER");
List<Role> roles = this.roleService.queryPageList(params);
this.userService.saveUserRole(user.getId(), roles);
if (sysConfig.getIntegral()) {
user.setIntegral(sysConfig
.getMemberRegister());
try {
this.userService.saveEntity(user);
} catch (Exception e) {
e.printStackTrace();
}
IntegralLogDto log = new IntegralLogDto();
log.setAddTime(new Date());
log.setContent("用户注册增加"
+ sysConfig
.getMemberRegister() + "分");
log.setIntegral(sysConfig
.getMemberRegister());
log.setIntegral_user_id(user.getId());
log.setType("reg");
integralLogFeignClient.saveEntity(log);
} else {
this.userService.saveEntity(user);
}
Album album = new Album();
album.setAddTime(new Date());
album.setAlbum_default(true);
album.setAlbum_name("默认相册");
album.setAlbum_sequence(55536);
album.setUser_id(user.getId());
this.albumService.saveEntity(album);
return ResponseCode.buildSuccessMap(null);
}
return ResponseCode.buildFailMap("10001", "请求失败");
} catch (Exception e) {
}
return ResponseCode.buildSuccessMap(null);
}
/**发送短信 (用户登录界面)
* @param mobile
* @return
*/
@RequestMapping(value ="/mobile_send", method = RequestMethod.POST)
public Map<String, Object> mobile_send(@RequestBody JSONObject json) {
// 获取数据
String mobile = json.optString("mobile");
String type = json.optString("type");
if (mobile == null || "".equals(mobile)) {
return ResponseCode.buildReturnMap(ResponseCode.RESPONSE_CODE_USER_MOBILE_OR_TELEPHONE_NOT_EMPTY,
"联系方式不能为空");
}
/* // 系统配置是否开启短信功能 (后面有做验证)
SysConfigDto sysConfig = sysConfigFeignClient.getSysConfig();
if (sysConfig.getSmsEnbale() == false) {
return ResponseCode.buildReturnMap(ResponseCode.RESPONSE_CODE_SMS_CLOSE,"系统尚未开启短信服务");
}*/
// 短信模板(固定模板,一个是注册,一个登陆) 登录验证码
String mark = "sms_tobuyer_user_login_notify"; // 后台短信模板登录标识
if (CommUtil.null2String(type).equals("find")) {
mark = "sms_tobuyer_find_password_notify"; // 重置密码
} else if (CommUtil.null2String(type).equals("bind")) {
mark = "sms_tobuyer_user_login_notify"; // 通用验证码
} else {
List<User> users = this.userService.selectByMobileOrUserName(mobile);// (手机号唯一),通过手机号(账号),查询用户
if (users != null && users.size() > 0) {
mark = "sms_tobuyer_user_login_notify"; // 登录验证码
} else {
mark = "sms_tobuyer_tips_notify";
}
}
// 根据短信模板标识(固定)查询模板信息
HashMap<String, Object> hashMap = new HashMap<String, Object>();
hashMap.put("mark", mark); // 模板标识
hashMap.put("open", 1); // 开启
List<TemplateDto> templatedto_list = templateFeignClient.queryPageList(hashMap);
if (templatedto_list.size()==0) {
return ResponseCode.buildReturnMap(ResponseCode.RESPONSE_CODE_SMS_CLOSE,"系统尚未开启短信服务");
}
ThreadLocalRandom current = ThreadLocalRandom.current();
int muber = current.nextInt(100000, 1000000);
if (!redisUtil.existsHashKey("mobile", mobile)) { //查询是否存在
redisUtil.setHashvValueTimeout("mobile", mobile, muber, 5, TimeUnit.MINUTES); //不存在,则创建,超时时间为5分钟
//TODO(待修改,动态) 目前是阿里的内容
String content = "{\"code\":\"" + muber + "\"}";
msgToolsFeignClient.sendSMS(mobile,templatedto_list.get(0).getSms_mark(),content); //发送短信请求
} else {
Object hashValue = redisUtil.getHashValue("mobile", mobile);
String content = "{\"code\":\"" + hashValue.toString() + "\"}";
msgToolsFeignClient.sendSMS(mobile, templatedto_list.get(0).getSms_mark(), content);
}
//RedisCache.removeObject(mobile);
return ResponseCode.buildSuccessMap("短信已发送");
}
/**短信验证
* @param mobile
* @param code
* @return
*/
/*@RequestMapping({"/code_validate"})
public String code_validate(@RequestBody JSONObject json){
String mobile = json.optString("mobile");
String code = json.optString("code");
if(mobile == null || "".equals(mobile)){
return "404";
}
if(code == null || "".equals(code)){
return "404";
}
Jedis jedis = RedisCache.getJedis();
if(jedis.exists(SerializeUtil.serialize(mobile))){
byte[] bs = jedis.get(SerializeUtil.serialize(mobile));
Object deserialize = SerializeUtil.deserialize(bs);
if(deserialize != null){
if(CommUtil.null2String(code).equals(deserialize.toString())){
return "200";
}else{
return "400";
}
}
}
if(jedis != null){
jedis.close();
}
return "401";
}*/
/**短信验证
* @param mobile
* @param code
* @return
*//*
@RequestMapping({"/code_validate"})
public Boolean code_validate(String mobile,String code){
if(mobile == null || "".equals(mobile)){
return false;
}
if(code == null || "".equals(code)){
return false;
}
Jedis jedis = RedisCache.getJedis();
if(jedis.exists(SerializeUtil.serialize(mobile))){
byte[] bs = jedis.get(SerializeUtil.serialize(mobile));
Object deserialize = SerializeUtil.deserialize(bs);
if(deserialize != null){
if(CommUtil.null2String(code).equals(deserialize.toString())){
RedisCache.removeObject(mobile);
return true;
}
}
}
if(jedis != null){
jedis.close();
}
return false;
}*/
/**
* 用户申请主播,
* 已是主播则进行更换上级
* @param request
* @param response
* @return
*/
@RequestMapping({ "/buyer/add_livecode" })
public Map<String, Object> add_livecode(HttpServletRequest request, HttpServletResponse response,
@RequestBody JSONObject json) {
HashMap<String, Object> result = new HashMap<>();
User user = userService.selectByPrimaryKey(SecurityUserHolder.getCurrentUserId(request));
// 如果是审核通过的主播,则进行更换
result.put("Is_live", user.getIs_live());// 是否是主播
result.put("Live_code_up", user.getLive_code_up());
result.put("goods_id", 502); // 增值服务商品id
return ResponseCode.buildSuccessMap(result);
}
//进身份证验证页面
@RequestMapping({ "/inLiveCode" })
public Map<String, Object> inLiveCode(HttpServletRequest request, HttpServletResponse response) {
UserDto userDto = SecurityUserHolder.getCurrentUser(request);
if(userDto == null){
return ResponseCode.buildEnumMap(ResponseCode.TOKEN_EXPIRE, null);
}
User currentUser = userService.selectByPrimaryKey(userDto.getId());
HashMap<String, Object> result = new HashMap<>();
result.put("is_live", currentUser.getIs_live());
if(currentUser.getIs_live() == 1){
VerifyidCard vc = verifyidCardService.selectByUserId(currentUser.getId());
if(vc != null){
result.put("vc", vc);
}
}
return ResponseCode.buildSuccessMap(result);
}
/**
* 校验邀请码(添加了身份证验证功能)
* @param request
* @param response
* @return
*/
@RequestMapping({ "/checkLiveCode" })
public Map<String, Object> checkLiveCode(HttpServletRequest request, HttpServletResponse response,
@RequestBody JSONObject json) {
String liveCode = json.optString("liveCode");
String name = json.optString("name");
String code = json.optString("code");
String phone = json.optString("phone");
Long img_id1 = json.optLong("img_id1");
Long img_id2 = json.optLong("img_id2");
Long img_id3 = json.optLong("img_id3");
if(StringUtils.isBlank(name) || StringUtils.isBlank(code) || StringUtils.isBlank(phone)
|| img_id1 == null || img_id2 == null || img_id3 == null){
return ResponseCode.buildEnumMap(ResponseCode.REQ_CANNOT_EMPTY, null);
}
if(StringUtils.isBlank(liveCode)){
liveCode = "100000";
}
UserDto userDto = SecurityUserHolder.getCurrentUser(request);
if(userDto == null){
return ResponseCode.buildEnumMap(ResponseCode.TOKEN_EXPIRE, null);
}
HashMap<String, Object> result = new HashMap<>();
User currentUser = userService.selectByPrimaryKey(userDto.getId());
User user = userService.selectByLiveCode(CommUtil.null2Long(liveCode));//100086
boolean isflag=false;
if (user!=null) { //不能是自己的邀请码并且这个邀请码存在
currentUser.setLive_code_up(CommUtil.null2Long(liveCode));
userService.updateById(currentUser);
isflag=true;
}
result.put("check", isflag);
result.put("goods_id", 502); // 增值服务商品id
VerifyidCard vc = verifyidCardService.selectByUserId(currentUser.getId());
boolean bol = false;
if(vc == null){
//保存用户身份证信息
vc = new VerifyidCard();
vc.setAddTime(new Date());
vc.setDeleteStatus(0);
bol = true;
}
vc.setName(name);
vc.setCode(code);
vc.setPhone(phone);
vc.setImg_id1(img_id1);
vc.setImg_id2(img_id2);
vc.setImg_id3(img_id3);
vc.setUid(currentUser.getId());
if(bol){
verifyidCardService.saveEntity(vc);
}else{
verifyidCardService.updateById(vc);
}
return ResponseCode.buildSuccessMap(result);
}
/**
* 判断店铺是否开通主播（用户名+密码）
* @param paraMap
* @return 不为空表示已经开通
*/
@RequestMapping(value = "/apiForFeign/checkingAccount", method = RequestMethod.POST)
public Long checkingAccount(@RequestBody Map<String, String> paraMap){
String userName = paraMap.get("userName");
String password = paraMap.get("password");
User user = userService.selectByUserName(userName);
if(user == null){
return null;
}
if(!StringUtils.equals(password, user.getPassword())){
return null;
}
if(user.getIs_live() != 2){
return null;
}
return user.getId();
}
/**
* 判断店铺是否开通主播（用户名）
* @param paraMap
* @return 不为空表示已经开通
*/
@RequestMapping(value = "/apiForFeign/checkingUserName", method = RequestMethod.POST)
public Long checkingUserName(@RequestBody Map<String, String> paraMap){
String userName = paraMap.get("userName");
User user = userService.selectByUserName(userName);
if(user == null){
return null;
}
if(user.getIs_live() != 2){
return null;
}
return user.getId();
}
/**
* 根据用户名查询用户
* @param username
* @return
*/
@RequestMapping(value = "/apiForFeign/selectByUserName", method = RequestMethod.POST)
public User selectByUserName(@RequestParam("userName")String userName){
return userService.selectByUserName(userName);
}
//将邀请注册奖金提现到余额
@RequestMapping(value ="/invProChangeBalance", method = RequestMethod.POST)
public Map<String, Object> invProChangeBalance(HttpServletRequest request, HttpServletResponse response, @RequestBody JSONObject json) {
String money = json.optString("money");
if(StringUtils.isBlank(money)){
return ResponseCode.buildEnumMap(ResponseCode.REQ_CANNOT_EMPTY, null);
}
UserDto user = SecurityUserHolder.getCurrentUser(request);
if(user == null || user.getId() == null){
return ResponseCode.buildEnumMap(ResponseCode.TOKEN_EXPIRE, null);
}
User inviter = userService.selectByPrimaryKey(user.getId());
//判断是否超过额度
if(new BigDecimal(money).compareTo(inviter.getInvitation_profit()) == 1){
return ResponseCode.buildCodeMap("21001", "超过可转额度", null);
}
//判断金额是不是20的倍数
Integer changeMoney = Integer.parseInt(money);
if(changeMoney >= 0 && changeMoney%20 == 0){
inviter.setInvitation_profit(inviter.getInvitation_profit().subtract(new BigDecimal(money)));
BigDecimal before = inviter.getAvailableBalance();
inviter.setAvailableBalance(inviter.getAvailableBalance().add(new BigDecimal(money)));
userService.updateById(inviter);
try{
//添加记录
PredepositLog log = new PredepositLog();
log.setPd_log_user_id(inviter.getId());
log.setPd_log_amount(new BigDecimal(money));
log.setAmount_before(before);
log.setAmount_after(inviter.getAvailableBalance());
log.setAddTime(new Date());
log.setDeleteStatus(0);
log.setPd_log_info("邀请注册收益转余额");
log.setPd_op_type("分销结算收益");
log.setPd_type("可用预存款");
predepositLogService.saveEntity(log);
}catch (Exception e) {
logger.error("UserController >> invProChangeBalance >> Exception:"+ e.getMessage());
}
}
return ResponseCode.buildSuccessMap(true);
}
/**
* 下单显示 (随机100个用户 )
* @param request
* @param response
* @return
*/
@RequestMapping({ "/userIndex" })
public Map<String, Object> userIndex(HttpServletRequest request, HttpServletResponse response) {
//UserDto userDto = SecurityUserHolder.getCurrentUser(request);
Map<String, Object> params = Maps.newHashMap();
/*if (userDto!=null) {
params.put("id_no", userDto.getId());
}*/
params.put("deleteStatus", 0);
params.put("weixin_unionID_is_no", "weixin_unionID_is_no");
// 总用户数量
int selectCount = userService.selectCount(params);
int c = 0;
int nextInt =0;
if (selectCount<100) {
c=1;
}else{
c = (int) selectCount / 100;
Random random = new Random();
nextInt = random.nextInt(c);
}
HashMap<String, Object> result = new HashMap<>();
// 用户列表
//List<User> list = new ArrayList<User>();
List<User> list = (List<User>) redisUtil.get("userIndexList");
/*result.put("userIndexList", list);
return ResponseCode.buildSuccessMap(result);*/
if (null == list || list.size() < 1) {
params.clear();
params.put("start", nextInt);
params.put("weixin_unionID_is_no", "weixin_unionID_is_no");
list = userService.listIndex(params);
//设置成一天过期
long oneday=24*60*60;
redisUtil.set("userIndexList", list,oneday);
result.put("userIndexList", list);
} else {
result.put("userIndexList", list);
}
return ResponseCode.buildSuccessMap(result);
}
/**
* 查看用户是否有公众号openid (没有则去鱼易库里查,在没有就提示给前端)
* @param request
* @param response
* @return
*//*
@RequestMapping({ "/buyer/selectWxOpenId" })
public Map<String, Object> selectWxOpenId(HttpServletRequest request, HttpServletResponse response,
@RequestBody JSONObject json) {
HashMap<String, Object> result = new HashMap<>();
User user = userService.selectByPrimaryKey(SecurityUserHolder.getCurrentUserId(request));
if(user==null){
// 用户不存在
return ResponseCode.buildFailMap("用户不存在", null);
}
boolean isfalg=false;
String openid=user.getWx_open_id();
//为空则去鱼易数据库查
if(StringUtils.isEmpty(openid)){
JSONObject paramJson = new JSONObject();
paramJson.put("username", user.getMobile());
String data = "";
try {
// 加密data
data = AESUtil.getInstance().Encrypt(paramJson.toString(), AESUtil.akk_secret);
} catch (Exception e) {
log.error("加密请求参数出错，错误信息"+Exceptions.getStackTraceAsString(e));
}
Map<String,String> params = new HashMap<String, String>();
params.put("data", data);
String url = "https://www.fishmq.cn/apply/synchroOpenid";
String result1 = HttpClientUtils.doPostReturn(url, params, "application/json; charset=UTF-8"); //UTF-8
//{"msg":"您的账号未绑定渔易水产科技公众号","code":500}
Map map = (Map)JSON.parse(result1);
Integer code = (Integer)map.get("code");
if(code == 200){
openid=(String) map.get("msg");
isfalg=true;
//将openid 保存进用户表
user.setWx_open_id(openid);
userService.updateById(user);
}
}
//如果openid还为空则返回false,需要用户关注公众号
result.put("isfalg", isfalg);
return ResponseCode.buildSuccessMap(result);
}*/
@RequestMapping(value = "/logoff", method = RequestMethod.POST)
public Map<String,Object> logoff(HttpServletRequest request,@RequestBody JSONObject json){
UserDto currentUser = SecurityUserHolder.getCurrentUser(request);
User user = this.userService.selectByPrimaryKey(currentUser.getId());
// 注销用户
user.setUserName("logoff_" + user.getUserName());
user.setMobile("logoff_" + user.getMobile());
user.setStatus(-2);
user.setWeixin_unionID("logoff_"+user.getWeixin_unionID());
user.setOpenId("logoff_"+user.getOpenId());
user.setWx_open_id("logoff_"+user.getWx_open_id());
user.setDeleteStatus(1);
// 修改登录信息
user.setLastLoginDate(new Date());
user.setLastLoginIp(CommUtil.getIpAddr(request));
userService.updateById(user);
// 将token删除
redisUtil.remove(Globals.ANDROID_LOGIN_MARK + user.getId());
// 返回结果集
return ResponseCode.buildSuccessMap(new HashMap<>());
}
}@源码地址来源： https://minglisoft.cn/honghu2/business.html标签：result,return,request,千万级,商城,put,null,b2b2c,user 来源： https://blog.csdn.net/m0_61571842/article/details/122614416
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。