package com.yami.trading.api.controller; import com.yami.trading.api.model.RegisterModel; import com.yami.trading.api.model.UserLoginModel; import com.yami.trading.bean.model.User; import com.yami.trading.common.domain.Result; import com.yami.trading.common.exception.YamiShopBindException; import com.yami.trading.common.util.IPHelper; import com.yami.trading.security.common.bo.UserInfoInTokenBO; import com.yami.trading.security.common.enums.SysTypeEnum; import com.yami.trading.security.common.manager.PasswordCheckManager; import com.yami.trading.security.common.manager.PasswordManager; import com.yami.trading.security.common.manager.TokenStore; import com.yami.trading.security.common.vo.TokenInfoVO; import com.yami.trading.service.syspara.SysparaService; import com.yami.trading.service.user.UserDataService; import com.yami.trading.service.user.UserService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.security.crypto.password.PasswordEncoder; import org.springframework.web.bind.annotation.CrossOrigin; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.validation.Valid; import java.util.Date; /** * @date 2022/3/28 15:20 */ @RestController @RequestMapping("api/") @Api(tags = "非登录接口") public class ApiIndexController { @Autowired private TokenStore tokenStore; @Autowired private PasswordCheckManager passwordCheckManager; @Autowired private PasswordManager passwordManager; @Autowired UserService userService; @Autowired private PasswordEncoder passwordEncoder; @Autowired private RedisTemplate redisTemplate; @Autowired SysparaService sysparaService; @Autowired UserDataService userDataService; @PostMapping("/login") @ApiOperation(value = "账号密码(用于前端登录)", notes = "通过账号/手机号/用户名密码登录，还要携带用户的类型，也就是用户所在的系统") public Result login( @Valid UserLoginModel model) { String mobileOrUserName = model.getUserName(); User user=null; if (model.getType()==1){ user= userService.findByUserMobile(mobileOrUserName); } if (model.getType()==2){ user= userService.findByEmail(mobileOrUserName); } if (model.getType()==3){ user= userService.findByUserName(mobileOrUserName); } if (user==null){ throw new YamiShopBindException("账号或密码不正确"); } // 半小时内密码输入错误十次，已限制登录30分钟 passwordCheckManager.checkPassword(SysTypeEnum.ORDINARY, model.getUserName(), model.getPassWord(), user.getLoginPassword()); UserInfoInTokenBO userInfoInToken = new UserInfoInTokenBO(); userInfoInToken.setUserId(user.getUserId()); userInfoInToken.setSysType(SysTypeEnum.ORDINARY.value()); userInfoInToken.setEnabled(user.getStatus() == 1); user.setUserLastip(IPHelper.getIpAddr()); user.setUserLasttime(new Date()); userService.online(user.getUserId()); userService.updateById(user); tokenStore.deleteAllToken(String.valueOf(SysTypeEnum.ORDINARY.value()), String.valueOf(user.getUserId())); // 存储token返回vo TokenInfoVO tokenInfoVO = tokenStore.storeAndGetVo(userInfoInToken); tokenInfoVO.setToken(tokenInfoVO.getAccessToken()); return Result.succeed(tokenInfoVO); } @PostMapping("/registerNoVerifcode") @ApiOperation(value = "手机/邮箱/用户名注册（无验证码）") public Result register(@Valid RegisterModel model) { String username = model.getUserName(); String password = model.getPassword(); String usercode = model.getUserCode(); // 注册类型：1/手机；2/邮箱；3/用户名； int type = model.getType(); User user = userService.register(model.getUserName(), passwordEncoder.encode(password) , model.getUserCode(), model.getType(),false); UserInfoInTokenBO userInfoInToken = new UserInfoInTokenBO(); userInfoInToken.setUserId(user.getUserId()); userService.online(user.getUserId()); userInfoInToken.setSysType(SysTypeEnum.ORDINARY.value()); userInfoInToken.setEnabled(user.getStatus() == 1); userDataService.saveRegister(user.getUserId()); tokenStore.deleteAllToken(String.valueOf(SysTypeEnum.ORDINARY.value()), String.valueOf(user.getUserId())); // 存储token返回vo TokenInfoVO tokenInfoVO = tokenStore.storeAndGetVo(userInfoInToken); tokenInfoVO.setToken(tokenInfoVO.getAccessToken()); return Result.succeed(tokenInfoVO); } // // @PostMapping("/sendSms") // @ApiOperation(value = "发送短信") // public ResponseEntity sendSms(@RequestBody @Valid SendSmsModel model){ // String ip= IPHelper.getIpAddr(); // String mobile=model.getCode()+model.getMobile(); // String code= redisTemplate.opsForValue().get( RedisKeyConstants.USER_MOBILE_PREFIX+mobile); // if (!StrUtil.isEmpty(code)){ // throw new YamiShopBindException("发送短信频繁,请稍后在试!"); // } // String sendCodeType = sysparaService.find("send_code_type").getSvalue(); // String user = sysparaService.find("smsbao_u").getSvalue(); // String pwd = sysparaService.find("smsbao_p").getSvalue(); // boolean inter=true; // if ("86".equals(model.getCode())) { // inter=false; // } // String sendCodeText =sysparaService.find("send_code_text").getSvalue(); // if (StringUtils.isNullOrEmpty(sendCodeText)) { // throw new YamiShopBindException("send_code_text 未配置"); // } // String sendIp= redisTemplate.opsForValue().get(ip); // if (!StrUtil.isEmpty(sendIp)){ // throw new YamiShopBindException("IP发送短信频繁,请稍后在试!"); // } // Random random = new Random(); // // code = String.valueOf(random.nextInt(999999) % 900000 + 100000); // sendCodeText=MessageFormat.format(sendCodeText, new Object[] { code }); // smsManager.send(sendCodeType,user,pwd,inter,model.getMobile(),sendCodeText); // redisTemplate.opsForValue().set( RedisKeyConstants.USER_MOBILE_PREFIX+mobile,code,60, TimeUnit.SECONDS); // redisTemplate.opsForValue().set(ip,mobile,10, TimeUnit.SECONDS); // return ResponseEntity.ok(null); // } // // @PostMapping("/sendEmail") // @ApiOperation(value = "发送邮箱") // public ResponseEntity sendEmail(@RequestBody @Valid SendEmailModel model){ //// String code= redisTemplate.opsForValue().get( RedisKeyConstants.USER_EMAILL_PREFIX+model.getEmail()); //// if (!StrUtil.isEmpty(code)){ //// throw new YamiShopBindException("发送yo频繁,请稍后在试!"); //// } // // String sendCodeText =sysparaService.find("send_code_text").getSvalue(); // if (StringUtils.isNullOrEmpty(sendCodeText)) { // throw new YamiShopBindException("send_code_text 未配置"); // } // Random random = new Random(); // String code = String.valueOf(random.nextInt(999999) % 900000 + 100000); // sendCodeText=MessageFormat.format(sendCodeText, new Object[] { code }); // String content = MessageFormat.format("code is ：{0}", new Object[] { code }); // EmailMessage emailMessage=new EmailMessage(); // emailMessage.setTomail(model.getEmail()); // emailMessage.setSubject(sendCodeText); // emailMessage.setContent(content); // emailManager.send(emailMessage); // redisTemplate.opsForValue().set( RedisKeyConstants.USER_EMAILL_PREFIX+model.getEmail(),code,60, TimeUnit.SECONDS); // return ResponseEntity.ok(null); // } }