roles = new ArrayList<>();
- roles.add("ROLE_CONSUMER");
- consumer.setRoles(roles);
- switch (consumerToken.getLogtype()) {
- case LogTypeConsts.SMS:
- ApiVO apiVO = checkSmsCode2Redis(BizConsts.CONSUMER_LOGIN_SMS, consumerToken.getUsername(),
- consumerToken.getSmscode());
- if (apiVO.isFail()) {
- return apiVO;
- }
- consumer.setNickname(consumerToken.getUsername());
- consumer.setHead("/head/def.png");
- consumer.setRegType(DictRegTypeConsts.DICT_MOBILE);
- break;
- case LogTypeConsts.QQ:
- consumer.setQqId(consumerToken.getOpenid());
- consumer.setNickname(consumerToken.getNickname());
- setHeader(consumerToken, consumer, false);
- setSex(consumerToken, consumer);
- consumer.setRegType(DictRegTypeConsts.DICT_QQ);
- break;
- case LogTypeConsts.WECHAT:
- consumer.setWechatId(consumerToken.getOpenid());
- consumer.setNickname(consumerToken.getNickname());
- setHeader(consumerToken, consumer, false);
- setSex(consumerToken, consumer);
- consumer.setRegType(DictRegTypeConsts.DICT_WECHAT);
- break;
- case LogTypeConsts.WEIBO:
- consumer.setWeiboId(consumerToken.getOpenid());
- consumer.setNickname(consumerToken.getNickname());
- setHeader(consumerToken, consumer, false);
- setSex(consumerToken, consumer);
- consumer.setRegType(DictRegTypeConsts.DICT_WEIBO);
- break;
- default:
- return new ApiVO(ApiVO.STATUS.F, "暂不支持的登录方式");
- }
- Integer result = consumerMapper.insert(consumer);
- if (result < 1) {
- return new ApiVO(ApiVO.STATUS.F, RespsConsts.CODE_FAIL, "登录失败");
- }
- return new ApiVO(ApiVO.STATUS.S).setObject1(consumer);
- }
-
-
public Consumer getConsumerByQQOpenid(String openid) {
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("qq_id", openid);
diff --git a/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/web/SecurityCtrl.java b/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/web/SecurityCtrl.java
index 8f5ea6f..549faf9 100644
--- a/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/web/SecurityCtrl.java
+++ b/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/web/SecurityCtrl.java
@@ -1,7 +1,23 @@
package com.yexuejc.springboot.base.web;
+import com.yexuejc.base.http.Resps;
+import com.yexuejc.base.pojo.ApiVO;
+import com.yexuejc.base.util.RegexUtil;
+import com.yexuejc.base.util.StrUtil;
+import com.yexuejc.springboot.base.autoconfigure.MutiRedisAutoConfiguration;
+import com.yexuejc.springboot.base.constant.BizConsts;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
/**
*
* Security 登录注册相关controller
@@ -19,5 +35,49 @@ import org.springframework.web.bind.annotation.RestController;
@RestController
public class SecurityCtrl {
+ @Autowired
+ @Qualifier(MutiRedisAutoConfiguration.BEAN_REDIS_TEMPLATE1)
+ RedisTemplate redisTemplate;
+
+ /**
+ * 登录发送短信
+ *
+ * @param mobile
+ * @return
+ */
+ @RequestMapping(value = "/login/{mobile}", method = RequestMethod.POST)
+ public Resps login(@PathVariable String mobile) {
+ if (!RegexUtil.regex(mobile, RegexUtil.REGEX_MOBILE)) {
+ return Resps.fail("手机号不正确");
+ }
+ ApiVO apiVO = sendSmsCode(BizConsts.CONSUMER_LOGIN_SMS, mobile);
+ if (apiVO.isFail()) {
+ return Resps.fail(apiVO.getMsg());
+ }
+ return Resps.success(apiVO.getMsg());
+ }
+
+ private ApiVO sendSmsCode(String smsType, String mobile) {
+ String smsId = StrUtil.genUUID(30);
+ String code = StrUtil.genNum().substring(2, 8);
+ //自己接入短信发送
+ boolean result = true;
+ if (result) {
+ //成功
+ //存reids
+ Map map = new HashMap<>();
+ map.put("smsId", smsId);
+ map.put("code", code);
+ map.put("trade_id", "短信返回id");
+ map.put("validatedNums", 0);
+ redisTemplate.afterPropertiesSet();
+ redisTemplate.opsForHash().putAll(smsType + "." + mobile, map);
+ // 过期时间：5分钟
+ redisTemplate.expire(smsType + "." + mobile, 5 * 60, TimeUnit.SECONDS);
+ return new ApiVO(ApiVO.STATUS.S, "短信发送成功");
+ } else {
+ return new ApiVO(ApiVO.STATUS.F, "短信发送失败");
+ }
+ }
}