短信验证登录

beidou-admin/src/main/java/cn/com/taiji/beidou/web/controller/system/SysLoginController.java

@@ -9,6 +9,8 @@ import cn.com.taiji.beidou.common.utils.SecurityUtils;
 import cn.com.taiji.beidou.framework.web.service.SysLoginService;
 import cn.com.taiji.beidou.framework.web.service.SysPermissionService;
 import cn.com.taiji.beidou.system.service.ISysMenuService;
+import cn.com.taiji.beidou.system.service.ISysUserService;
+import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -35,6 +37,9 @@ public class SysLoginController
     @Autowired
     private SysPermissionService permissionService;
 
+    @Autowired
+    private ISysUserService userService;
+
     /**
      * 登录方法
      * 
@@ -52,6 +57,14 @@ public class SysLoginController
         return ajax;
     }
 
+    @ApiOperation("手机号+短信验证码登录")
+    @PostMapping("/loginByCode")
+    public AjaxResult loginByCode(String mobile,String code){
+
+        return AjaxResult.success(loginService.loginByCode(mobile,code));
+    }
+
+
     /**
      * 获取用户信息
      * 
@@ -84,4 +97,11 @@ public class SysLoginController
         List<SysMenu> menus = menuService.selectMenuTreeByUserId(userId);
         return AjaxResult.success(menuService.buildMenus(menus));
     }
+
+    @ApiOperation("获取短信验证码")
+    @GetMapping("/getCode")
+    public AjaxResult getCode(String telephone)
+    {
+        return AjaxResult.success(loginService.getCode(telephone));
+    }
 }

beidou-admin/src/main/java/cn/com/taiji/beidou/web/controller/system/SysUserController.java

@@ -16,6 +16,7 @@ import cn.com.taiji.beidou.system.service.ISysDeptService;
 import cn.com.taiji.beidou.system.service.ISysPostService;
 import cn.com.taiji.beidou.system.service.ISysRoleService;
 import cn.com.taiji.beidou.system.service.ISysUserService;
+import io.swagger.annotations.ApiOperation;
 import org.apache.commons.lang3.ArrayUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -241,6 +242,7 @@ public class SysUserController extends BaseController
     /**
      * 获取部门树列表
      */
+    @ApiOperation("获取部门树列表")
     @PreAuthorize("@ss.hasPermi('system:user:list')")
     @GetMapping("/deptTree")
     public AjaxResult deptTree(SysDept dept)

beidou-admin/src/main/resources/application-druid.yml

@@ -6,9 +6,12 @@ spring:
         druid:
             # 主库数据源
             master:
-                url: jdbc:mysql://localhost:3306/ax_beidou?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+#                url: jdbc:mysql://localhost:3306/ax_beidou?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+#                username: root
+#                password: root
+                url: jdbc:mysql://120.25.74.229:8006/ax_beidou?useUnicode=true&characterEncoding=utf-8&useSSL=false
                 username: root
-                password: root
+                password: ROOT@taiji2022!
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭

beidou-admin/src/main/resources/application.yml

@@ -76,7 +76,7 @@ spring:
     # 数据库索引
     database: 0
     # 密码
-    password: 
+    password: 12345
     # 连接超时时间
     timeout: 10s
     lettuce:

beidou-framework/src/main/java/cn/com/taiji/beidou/framework/config/SecurityConfig.java

@@ -111,7 +111,7 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter
                 // 过滤请求
                 .authorizeRequests()
                 // 对于登录login 注册register 验证码captchaImage 允许匿名访问
-                .antMatchers("/login", "/register", "/captchaImage").permitAll()
+                .antMatchers("/login","/loginByCode","/getCode", "/register", "/captchaImage").permitAll()
                 // 静态资源，可匿名访问
                 .antMatchers(HttpMethod.GET, "/", "/*.html", "/**/*.html", "/**/*.css", "/**/*.js", "/profile/**").permitAll()
                 .antMatchers("/swagger-ui.html","/doc.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**").permitAll()

beidou-framework/src/main/java/cn/com/taiji/beidou/framework/web/service/SysLoginService.java

@@ -17,6 +17,7 @@ import cn.com.taiji.beidou.common.utils.ip.IpUtils;
 import cn.com.taiji.beidou.framework.manager.AsyncManager;
 import cn.com.taiji.beidou.framework.manager.factory.AsyncFactory;
 import cn.com.taiji.beidou.framework.security.context.AuthenticationContextHolder;
+import cn.com.taiji.beidou.framework.web.util.SmsUtil;
 import cn.com.taiji.beidou.system.service.ISysConfigService;
 import cn.com.taiji.beidou.system.service.ISysUserService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -27,6 +28,8 @@ import org.springframework.security.core.Authentication;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 /**
  * 登录校验方法
@@ -49,6 +52,9 @@ public class SysLoginService
     private ISysUserService userService;
 
     @Autowired
+    private UserDetailsServiceImpl userDetailsService ;
+
+    @Autowired
     private ISysConfigService configService;
 
     /**
@@ -101,6 +107,28 @@ public class SysLoginService
         return tokenService.createToken(loginUser);
     }
 
+
+    /**
+     * 手机号+短信验证码登录
+     * @param mobile
+     * @param code
+     * @return
+     */
+    public String loginByCode(String mobile,  String code)
+    {
+        //验证短信验证码
+        String cacheCode = redisCache.getCacheObject(mobile).toString();
+        if(!code.equals(cacheCode)){
+            return "验证码错误！";
+        }
+        SysUser sysUser = userService.selectUserByPhone(mobile);
+        AsyncManager.me().execute(AsyncFactory.recordLogininfor(sysUser.getUserName(), Constants.LOGIN_SUCCESS, MessageUtils.message("user.login.success")));
+        LoginUser loginUser = (LoginUser) userDetailsService.createLoginUser(sysUser);
+        recordLoginInfo(loginUser.getUserId());
+        // 生成token
+        return tokenService.createToken(loginUser);
+    }
+
     /**
      * 校验验证码
      * 
@@ -139,4 +167,32 @@ public class SysLoginService
         sysUser.setLoginDate(DateUtils.getNowDate());
         userService.updateUserProfile(sysUser);
     }
+
+    /**
+     * 获取短信验证码
+     * @param telephone
+     * @return
+     */
+    public String getCode(String telephone){
+        try {
+            SysUser user = new SysUser();
+            user.setPhonenumber(telephone);
+            List<SysUser> sysUsers = userService.selectUserList(user);
+
+            if(sysUsers.size()<=0){
+                return "手机号码不存在！请联系管理员";
+            }
+            String randomCode = SmsUtil.getRandomCode(4);
+
+            String result = SmsUtil.sendSms(telephone, randomCode);
+            if(result.contains("success")){
+                //todo 此处将验证码存储到数据库
+                redisCache.setCacheObject(telephone,randomCode,10, TimeUnit.MINUTES);
+            }
+            return result;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return "短信发送失败，请稍后重试！";
+        }
+    }
 }

beidou-framework/src/main/java/cn/com/taiji/beidou/framework/web/util/Md5Utils.java

@@ -0,0 +1,37 @@
+package cn.com.taiji.beidou.framework.web.util;
+
+import java.security.MessageDigest;
+
+/**
+ * MD5密码加密工具
+ * @author lizhi
+ */
+public class Md5Utils {
+	private static final char[] HEX_DIGITS = "0123456789abcdef".toCharArray();
+	private static final char[] CHAR_ARRAY = "_-0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ".toCharArray();
+
+	public static String md5(String srcStr) {
+		return hash("MD5", srcStr);
+	}
+
+	public static String hash(String algorithm, String srcStr) {
+		try {
+			MessageDigest md = MessageDigest.getInstance(algorithm);
+			byte[] bytes = md.digest(srcStr.getBytes("utf-8"));
+			return toHex(bytes);
+		} catch (Exception var4) {
+			throw new RuntimeException(var4);
+		}
+	}
+
+	public static String toHex(byte[] bytes) {
+		StringBuilder ret = new StringBuilder(bytes.length * 2);
+
+		for(int i = 0; i < bytes.length; ++i) {
+			ret.append(HEX_DIGITS[bytes[i] >> 4 & 15]);
+			ret.append(HEX_DIGITS[bytes[i] & 15]);
+		}
+
+		return ret.toString();
+	}
+}

beidou-framework/src/main/java/cn/com/taiji/beidou/framework/web/util/SmsUtil.java

@@ -0,0 +1,168 @@
+package cn.com.taiji.beidou.framework.web.util;
+
+import com.alibaba.fastjson2.JSONObject;
+import org.apache.commons.codec.binary.Base64;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.http.client.SimpleClientHttpRequestFactory;
+import org.springframework.web.client.RestTemplate;
+
+import java.nio.charset.StandardCharsets;
+import java.util.HashMap;
+import java.util.Random;
+import java.util.UUID;
+
+/**
+ * @Author CHEN
+ * @Date 2022/11/8 9:34
+ */
+public class SmsUtil{
+
+    private static String[] NUMBERS = {"0", "1", "2", "3", "4", "5", "6", "7", "8", "9"};
+    private static Random RANDOM = new Random();
+
+    @Value("${sms.url-prefix}")
+    private String url;
+    @Value("${sms.port}")
+    private String port;
+    /**
+     * 经办机构编码
+     */
+    private static final String JBJGBM = "460000008";
+
+    /**
+     * 接口账号用户名
+     */
+    private static final String AP_ID = "sgpttyrzzx";
+
+    /**
+     * 签名编码
+     */
+    private static final String SIGN = "zSp2Jjtnao1AikYI";
+
+    /**
+     * 密钥
+     */
+    private static final String SECRET_KEY = "tdOcOn";
+
+    /**
+     * 获取随机的数字
+     * @param length
+     * @return
+     */
+    public static String getRandomCode(Integer length) {
+        StringBuilder builder = new StringBuilder(length);
+        for (int i = 0; i < length; i++) {
+            builder.append(NUMBERS[RANDOM.nextInt(NUMBERS.length)]);
+        }
+
+        return builder.toString();
+    }
+
+
+    /**
+     * 拼接短信平台参数
+     * @param mobiles
+     * @param validCode
+     * @return
+     * @throws Exception
+     */
+    private static String GetSmsParam(String mobiles, String validCode) throws Exception {
+        HashMap<String, String> submit = new HashMap<>();
+        // 经办机构编码
+        submit.put("jbjgbm",JBJGBM);
+        System.out.println("jbjgbm："+ JBJGBM);
+
+        // 接口账号用户名
+        submit.put("apId",AP_ID);
+        System.out.println("apId："+ AP_ID);
+
+        // 短信流水号
+        String uuid = UUID.randomUUID().toString();
+        uuid = uuid.replace("-","");
+        submit.put("dxId",uuid);
+        System.out.println("dxId：" + submit.get("dxId"));
+
+        // 短信类型
+        submit.put("dxType","900");
+        System.out.println("dxType："+ "900");
+
+        // 收信手机号
+        submit.put("mobiles",mobiles);
+        System.out.println("mobiles："+ submit.get("mobiles"));
+
+        // 短信内容
+        submit.put("content","【海南社会管理信息化平台】 您的登录验证码为：" + validCode + "。有效时长为10分钟，请勿将验证码告知他人。");
+        System.out.println("content："+ submit.get("content"));
+
+        // 签名
+        submit.put("sign",SIGN);
+        System.out.println("sign："+ SIGN);
+
+        // 短信优先级
+        submit.put("priority","5");
+        System.out.println("priority："+ "5");
+
+        StringBuffer sb = new StringBuffer();
+        //sb.append("【jbjgbm】");
+        sb.append(submit.get("jbjgbm"));
+        //sb.append("【apId】");
+        sb.append(submit.get("apId"));
+        //sb.append("【secretKey】");
+        sb.append(SECRET_KEY);
+        //sb.append("【dxId】");
+        sb.append(submit.get("dxId"));
+        //sb.append("【dxType】");
+        sb.append(submit.get("dxType"));
+        //sb.append("【mobiles】");
+        sb.append(submit.get("mobiles"));
+        //sb.append("【content】");
+        sb.append(submit.get("content"));
+        //sb.append("【sign】");
+        sb.append(submit.get("sign"));
+        //sb.append("【priority】");
+        sb.append(submit.get("priority"));
+        System.out.println("StringBuffer：" + sb.toString());
+
+
+        // MD5 加密参数
+        String recordMac = Md5Utils.md5(sb.toString());
+        System.out.println("Mac：" + recordMac);
+        submit.put("mac",recordMac);
+        String params = JSONObject.toJSONString(submit);
+        System.out.println("JSON Params：" + params);
+
+        // BASE64加密参数
+        String encode = Base64.encodeBase64String(params.getBytes(StandardCharsets.UTF_8));
+        System.out.println("params：" + encode);
+        return encode;
+    }
+
+    /**
+     * 发送短信
+     * @param mobiles
+     * @param validCode
+     * @return
+     * @throws Exception
+     */
+    public static String sendSms(String mobiles, String validCode) throws Exception {
+        SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
+        requestFactory.setConnectTimeout(5000);
+        RestTemplate restTemplate = new RestTemplate();
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+
+        String data = GetSmsParam(mobiles,validCode);
+
+        // post发送请求
+        // 互联网地址测试：10.113.50.2:18010
+        // 政务外网正式：172.19.150.2:18003
+        ResponseEntity<String> exchange = restTemplate.exchange("http://59.212.117.83:18003/sms/api/smsData.do?addMessage&data=" + data, HttpMethod.POST, null, String.class);
+        //获取idaas返回的json
+        String resData = exchange.getBody();
+        return resData;
+    }
+}

beidou-ship/pom.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>ax-beidou</artifactId>
+        <groupId>cn.com.taiji</groupId>
+        <version>1.0.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>beidou-ship</artifactId>
+
+    <dependencies>
+
+        <!-- 通用工具-->
+        <dependency>
+            <groupId>cn.com.taiji</groupId>
+            <artifactId>beidou-common</artifactId>
+        </dependency>
+
+    </dependencies>
+
+</project>

beidou-system/src/main/java/cn/com/taiji/beidou/system/mapper/SysUserMapper.java

@@ -45,6 +45,12 @@ public interface SysUserMapper
     public SysUser selectUserByUserName(String userName);
 
     /**
+     * 通过电话号码查询用户
+     * @param phoneNumber
+     * @return
+     */
+    SysUser selectUserByPhone(String phoneNumber);
+    /**
      * 通过用户ID查询用户
      * 
      * @param userId 用户ID

beidou-system/src/main/java/cn/com/taiji/beidou/system/service/ISysUserService.java

@@ -44,6 +44,14 @@ public interface ISysUserService
     public SysUser selectUserByUserName(String userName);
 
     /**
+     * 通过电话号码查询用户
+     *
+     * @param phoneNumber 电话
+     * @return 用户对象信息
+     */
+    public SysUser selectUserByPhone(String phoneNumber);
+
+    /**
      * 通过用户ID查询用户
      * 
      * @param userId 用户ID

beidou-system/src/main/java/cn/com/taiji/beidou/system/service/impl/SysUserServiceImpl.java

@@ -110,6 +110,18 @@ public class SysUserServiceImpl implements ISysUserService
     }
 
     /**
+     * 通过电话号码查询用户
+     *
+     * @param phoneNumber 电话号码
+     * @return 用户对象信息
+     */
+    @Override
+    public SysUser selectUserByPhone(String phoneNumber)
+    {
+        return userMapper.selectUserByPhone(phoneNumber);
+    }
+
+    /**
      * 通过用户ID查询用户
      * 
      * @param userId 用户ID

beidou-system/src/main/resources/mapper/system/SysUserMapper.xml

@@ -124,6 +124,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 	    <include refid="selectUserVo"/>
 		where u.user_name = #{userName} and u.del_flag = '0'
 	</select>
+
+	<select id="selectUserByPhone" parameterType="String" resultMap="SysUserResult">
+		select u.user_id, u.dept_id, u.nick_name, u.user_name, u.email, u.avatar, u.phonenumber, u.sex, u.status, u.del_flag, u.login_ip, u.login_date, u.create_by, u.create_time, u.remark, d.dept_name, d.leader from sys_user u
+		left join sys_dept d on u.dept_id = d.dept_id
+		where u.phonenumber = #{phoneNumber} and u.del_flag = '0'
+	</select>
 	
 	<select id="selectUserById" parameterType="Long" resultMap="SysUserResult">
 		<include refid="selectUserVo"/>

pom.xml

@@ -194,6 +194,8 @@
         <module>beidou-quartz</module>
         <module>beidou-generator</module>
         <module>beidou-common</module>
+        <module>beidou-ship</module>
+        <module>beidou-ship</module>
     </modules>
     <packaging>pom</packaging>