@源码地址来源: 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