DriverYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java
@@ -1,5 +1,7 @@ package com.stylefeng.guns.modular.system.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.plugins.Page; import com.baomidou.mybatisplus.service.impl.ServiceImpl; @@ -146,6 +148,9 @@ @Autowired private GeodesyUtil geodesyUtil; @Autowired private ALiSendSms aLiSendSms; @Value("${spring.profiles.active}") private String activeProfile; @@ -199,30 +204,15 @@ } String authCode = sb.toString(); //TODO 短信发送 // //发送验证码短信 // redisTemplate.opsForValue().set(phone, authCode, 5, TimeUnit.MINUTES);//设置五分钟过期 // String templateCode = ""; // switch (type) { // case 1: // templateCode = "SMS_154775435";//身份验证 // break; // case 2: // templateCode = "SMS_154775434";//登录确认 // break; // case 3: // templateCode = "SMS_154775432";//用户注册 // break; // case 4: // templateCode = "SMS_154775431";//修改密码 // break; // } // String sData = aLiSendSms.sendSms(phone, "SMS_229715276", "{\"code\":\"" + authCode + "\"}"); // JSONObject jsonObject = JSON.parseObject(sData); // String message = jsonObject.getString("Message"); // if(!"OK".equals(message)){ // return ResultUtil.error(""); // } // System.out.println(sms); //发送验证码短信 redisTemplate.opsForValue().set(phone, authCode, 5, TimeUnit.MINUTES);//设置五分钟过期 String templateCode = "SMS_501961081"; String sData = aLiSendSms.sendSms(phone, "SMS_501961081", "{\"code\":\"" + authCode + "\"}"); JSONObject jsonObject = JSON.parseObject(sData); String message = jsonObject.getString("Message"); if(!"OK".equals(message)){ return ResultUtil.error(""); } redisTemplate.opsForValue().set(phone, authCode, 5, TimeUnit.MINUTES);//设置五分钟过期 return ResultUtil.success(); } DriverYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/ALiSendSms.java
@@ -21,8 +21,8 @@ // 设置鉴权参数，初始化客户端 private DefaultProfile profile = DefaultProfile.getProfile( "cn-hangzhou",// 地域ID "111",// 您的AccessKey ID "111");// 您的AccessKey Secret "LTAI5t7cSHQ685o2rQ6CaR8u",// 您的AccessKey ID "am8BmIAgUivyvemaWrwmxJVbUiPi6v");// 您的AccessKey Secret private IAcsClient client = new DefaultAcsClient(profile); private static void log_print(String functionName, Object result) { @@ -70,7 +70,7 @@ // 接收短信的手机号码 request.putQueryParameter("PhoneNumbers", phone); // 短信签名名称。请在控制台签名管理页面签名名称一列查看（必须是已添加、并通过审核的短信签名）。 request.putQueryParameter("SignName", "111"); request.putQueryParameter("SignName", "约客多"); // 短信模板ID request.putQueryParameter("TemplateCode", templateCode); // 短信模板变量对应的实际值，JSON格式。 DriverYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/UserUtil.java
@@ -19,7 +19,7 @@ // 生产环境建议使用更安全的密钥管理方案，如密钥管理系统(KMS)、容器密钥注入等 // 请参见：https://cloud.tencent.com/document/product/1278/85305 // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取 Credential cred = new Credential("AKIDRlDTWVIrDOMAl8LMCoF6nGXdXEh19EHC", "tsjPtFQPwX6kGdpgSSI0UmyFQRZeboqe"); Credential cred = new Credential("AKIDZBew0rJbghYnt20oRr44qQpDViu6HMGx", "pRvd9ez71iBSXO1PYrwnPyMVRAew53mH"); // 使用临时密钥示例 // Credential cred = new Credential("SecretId", "SecretKey", "Token"); // 实例化一个http选项，可选的，没有特殊需求可以跳过 @@ -68,7 +68,7 @@ // 实例化一个请求对象,每个接口都会对应一个request对象 IdCardVerificationRequest req = new IdCardVerificationRequest(); req.setIdCard("511028200002150816"); req.setName("刘1"); req.setName("刘杰"); // 返回的resp是一个IdCardVerificationResponse的实例，与请求对象对应 IdCardVerificationResponse resp = client.IdCardVerification(req); if(resp.getResult().equals("0")){ MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyServer0.java
@@ -64,7 +64,7 @@ // ChildChannelHandler 对出入的数据进行的业务操作,其继承ChannelInitializer b.childHandler(new ChildChannelHandler()); System.out.println("服务端开启等待客户端连接 ... ..."); Channel ch = b.bind(8888).sync().channel(); Channel ch = b.bind(8887).sync().channel(); ch.closeFuture().sync(); } catch (Exception e) { e.printStackTrace(); MessagePushTravel/src/main/java/com/sinata/push/util/echo/NettyServer.java
@@ -80,7 +80,7 @@ // 服务器绑定端口监听 ChannelFuture f = bootstrap.bind(nettyPort).sync(); if(f.isSuccess()) { System.out.println("******************************Netty启动成功******************************"); System.out.println("******************************Netty启动成功司机******************************"); } // 监听服务器关闭监听 f.channel().closeFuture().sync();
