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<String, String> redisTemplate;
|
|
@Autowired
|
SysparaService sysparaService;
|
|
@Autowired
|
UserDataService userDataService;
|
|
|
@PostMapping("/login")
|
@ApiOperation(value = "账号密码(用于前端登录)", notes = "通过账号/手机号/用户名密码登录，还要携带用户的类型，也就是用户所在的系统")
|
public Result<TokenInfoVO> 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);
|
// }
|
|
}
|
