package com.hxzkmonitor.controller;
|
|
import cloud.tianai.captcha.application.vo.CaptchaResponse;
|
import cloud.tianai.captcha.application.vo.ImageCaptchaVO;
|
import cloud.tianai.captcha.common.response.ApiResponse;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.hxzkmonitor.pojo.*;
|
import com.hxzkmonitor.service.TbDuanxinlogService;
|
import com.hxzkmonitor.service.TbLoginLogService;
|
import com.hxzkmonitor.service.TbMacService;
|
import com.hxzkmonitor.service.TbUserService;
|
import com.hxzkmonitor.util.HttpClientUtil;
|
import com.hxzkmonitor.util.MiMi;
|
import org.springframework.core.ParameterizedTypeReference;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.web.client.RestTemplate;
|
import com.hxzkmonitor.util.R;
|
import com.tencentcloudapi.common.Credential;
|
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
|
import com.tencentcloudapi.common.profile.ClientProfile;
|
import com.tencentcloudapi.common.profile.HttpProfile;
|
import com.tencentcloudapi.sms.v20210111.SmsClient;
|
import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest;
|
import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
|
import org.springframework.security.crypto.password.PasswordEncoder;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.List;
|
|
/**
|
* <p>
|
* 前端控制器
|
* </p>
|
*
|
* @author wangfei
|
* @since 2024-08-05
|
*/
|
@CrossOrigin
|
@RestController
|
@RequestMapping("/")
|
|
public class TbUserController {
|
|
private String SecretId = "AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
|
private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
|
|
@Autowired
|
TbUserService tbUserService;
|
|
@Autowired
|
TbLoginLogService tbLoginLogService;
|
@Autowired
|
TbDuanxinlogService tbDuanxinlogService;
|
|
@Autowired
|
TbMacService tbMacService;
|
|
@Autowired
|
RestTemplate restTemplate;
|
|
// private final RestTemplate restTemplate;
|
//
|
// public YourClassName(RestTemplate restTemplate) {
|
// this.restTemplate = restTemplate;
|
// }
|
|
@ApiOperation(value = "分页查询", notes = "分页查询")
|
@GetMapping("/api/getUserPage")
|
public R getUserPage(Page page) {
|
IPage<TbUser> ipage = tbUserService.getUserPage(page);
|
|
return R.ok(ipage);
|
}
|
|
@PostMapping("/api/addorupUser")
|
public R addorupUser(TbUser tbUser) {
|
if (tbUser.getPassword() != null) {
|
tbUser.setPassword(passwordEncoder().encode(tbUser.getPassword()));
|
}
|
|
|
if (tbUser.getId()==null){
|
TbUser phone = tbUserService.findPhoneUser(tbUser.getAdminphone());
|
if (phone==null){
|
return R.ok(tbUserService.addorupUser(tbUser));
|
}else{
|
return R.failed("当前手机号已存在，请更换手机号");
|
}
|
}else{
|
return R.ok(tbUserService.addorupUser(tbUser));
|
}
|
|
}
|
|
@GetMapping("/api/code")
|
@ResponseBody
|
public CaptchaResponse<ImageCaptchaVO> genCaptcha(HttpServletRequest request, @RequestParam(value = "type", required = false) String type) {
|
// 构建请求参数
|
HttpEntity<String> entity = new HttpEntity<>("Parameters", null);
|
ResponseEntity<CaptchaResponse<ImageCaptchaVO>> response = restTemplate.exchange(
|
"http://localhost:8086/gen",
|
HttpMethod.GET,
|
entity,
|
new ParameterizedTypeReference<CaptchaResponse<ImageCaptchaVO>>() {},
|
"type", type
|
);
|
|
// 返回结果
|
return response.getBody();
|
}
|
|
@PostMapping("/api/checkCode")
|
public ApiResponse<?> checkCaptcha(@RequestBody Data data) {
|
// 远端 check 服务的 URL
|
String url = "http://localhost:8086/check";
|
|
// 发送 POST 请求到远端服务
|
ApiResponse<?> response = restTemplate.postForObject(url, data, ApiResponse.class);
|
|
if (response.isSuccess()) {
|
return ApiResponse.ofSuccess(Collections.singletonMap("id", data.getId()));
|
}
|
return response;
|
}
|
|
@GetMapping("/api/delUser")
|
public R delUser(Integer id) {
|
return R.ok(tbUserService.delUser(id));
|
}
|
|
@GetMapping("/api/searchUser")
|
public R searchUser(Page page, String keyword) {
|
return R.ok(tbUserService.searchUser(page, keyword));
|
}
|
|
@GetMapping("/api/findPhoneUser")
|
public R findPhoneUser(String phone) {
|
return R.ok(tbUserService.findPhoneUser(phone));
|
}
|
|
|
@PostMapping("api/users")
|
public R checkLogin(TbUser user) {
|
TbUser user1 = new TbUser();
|
String token = "hfghjhrtiyerjiofmwefnwefiewhiof212424";
|
|
List<TbMac> list1 = tbMacService.list();
|
System.out.println(list1.get(0));
|
MiMi mi = new MiMi();
|
String mm = MiMi.DecodePasswd(list1.get(0).getPassmac());
|
|
// if ( )
|
// 使用DateTimeFormatter解析字符串日期
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
|
|
// mm.split(";")[1];
|
System.out.println(mm);
|
if (user.getAdminphone() == null || user.getAdminphone().equals("")) {
|
user1 = tbUserService.checkLogin(user);
|
if (user1 != null) {
|
boolean isMatch = passwordEncoder().matches(user.getPassword(), user1.getPassword());
|
if (isMatch) {
|
user1.setToken(token);
|
String result= HttpClientUtil. doGet("http://localhost:8181/check");
|
System.out.println(result);//返回pdf地址
|
// if (result=="false"){
|
user1.setUsermsg(result);
|
// }
|
// try{
|
// LocalDate dateToCompare = LocalDate.parse(mm.split(";")[1], formatter);
|
//
|
// // 获取当前日期
|
// LocalDate today = LocalDate.now();
|
//
|
// // 比较日期
|
// if (dateToCompare.isBefore(today)) {
|
// System.out.println(mm.split(";")[1] + " 在今天之前");
|
// } else if (dateToCompare.isAfter(today)) {
|
//
|
// System.out.println(mm.split(";")[1] + " 在今天之后");
|
// user1.setUsermsg("注册码过期");
|
// return R.ok("注册码过期");
|
// } else {
|
// System.out.println(mm.split(";")[1] + " 就是今天");
|
// }
|
// }catch (ArrayIndexOutOfBoundsException e){
|
// user1.setUsermsg("注册码错误");
|
// return R.ok(user1);
|
// }
|
|
return R.ok(user1);
|
} else {
|
return R.failed("密码错误");
|
}
|
} else {
|
return R.failed("登录失败，请检查账号密码");
|
}
|
//用户名密码登录
|
} else {
|
//手机号验证码登录
|
user1 = tbUserService.loginPhone(user);
|
if (user1 != null) {
|
user1.setToken(token);
|
String result= HttpClientUtil. doGet("http://localhost:8181/check");
|
System.out.println(result);//返回pdf地址
|
// if (result=="false"){
|
user1.setUsermsg(result);
|
|
// }
|
// try{
|
//
|
// LocalDate dateToCompare = LocalDate.parse(mm.split(";")[1], formatter);
|
//
|
// // 获取当前日期
|
// LocalDate today = LocalDate.now();
|
//
|
// // 比较日期
|
// if (dateToCompare.isBefore(today)) {
|
//
|
// System.out.println(mm.split(";")[1] + " 在今天之前");
|
// } else if (dateToCompare.isAfter(today)) {
|
//
|
// System.out.println(mm.split(";")[1] + " 在今天之后");
|
// user1.setUsermsg("注册码过期");
|
// return R.ok("注册码过期");
|
// } else {
|
// System.out.println(mm.split(";")[1] + " 就是今天");
|
// }
|
// }catch (ArrayIndexOutOfBoundsException e){
|
// user1.setUsermsg("注册码错误");
|
// return R.ok(user1);
|
// }
|
return R.ok(user1);
|
} else {
|
return R.failed("登录失败，请检查账号密码");
|
}
|
}
|
|
}
|
|
@GetMapping("api/updatepassword2")
|
public R updatepassword2(String username, String oldpassword, String newpassword) {
|
TbUser user1 = new TbUser();
|
user1.setUsername(username);
|
TbUser user = tbUserService.checkLogin(user1);
|
boolean isMatch = passwordEncoder().matches(oldpassword, user.getPassword());
|
if (isMatch) {
|
user.setPassword(passwordEncoder().encode(newpassword));
|
tbUserService.addorupUser(user);
|
return R.ok(user);
|
} else {
|
return R.failed("原密码错误");
|
}
|
}
|
|
public PasswordEncoder passwordEncoder() {
|
return new BCryptPasswordEncoder();
|
}
|
|
@GetMapping("api/users")
|
public R getLogin(String phone) {
|
System.out.println("收到待校验token：" + phone);
|
// String token = "hfghjhrtiyerjiofmwefnwefiewhiof212424";
|
// R response = new R(StatusCode.Success);
|
|
TbUser tbUser1 = tbUserService.findPhoneUser(phone);
|
List<String> list = new ArrayList<>();
|
list.add(tbUser1.getRole());
|
TbUser tbUser = new TbUser();
|
tbUser.setIds(tbUser1.getId().toString());
|
tbUser.setName(tbUser1.getUsername());
|
// tbUser.setUsername("admin");
|
// tbUser.setPassword("11111");
|
//tbUser.setAvatar("https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1591530122836&di=b7bd6587bd70954db2f6a5c7588ca5ba&imgtype=0&src=http%3A%2F%2Fimg.wxcha.com%2Ffile%2F201901%2F03%2Fc447d5e161.jpg%3Fdown");
|
tbUser.setStatus("1");
|
tbUser.setTelephone(tbUser1.getAdminphone());
|
// tbUser.setLastLoginIp("27.154.74.117");
|
// tbUser.setLastLoginTime("1534837621348");
|
// tbUser.setCreatorId("admin");
|
// tbUser.setCreateTime("1497160610259");
|
// tbUser.setMerchantCode("TLif2btpzg079h15bk");
|
// tbUser.setDeleted("0");
|
tbUser.setRoles(list);
|
// if (username.equals("admin") && password.equals("111111")){
|
// response.setData(token);
|
// }else{
|
// response = new R(StatusCode.Fail.getCode(), "失败");
|
// }
|
// R response = new R(StatusCode.Success);
|
// try {
|
// wechatService.checkToken(token);
|
// } catch (Exception e) {
|
// response = new R(StatusCode.Fail.getCode(), e.getMessage());
|
// }
|
// response.setData(tbUser);
|
return R.ok(tbUser);
|
}
|
|
@GetMapping("/api/getsystem")
|
public R getsystem( String csname,String phone) {
|
return R.ok(tbUserService.getsystem(csname,phone));
|
}
|
|
@GetMapping("api/sms")
|
public R sms(String phone, Integer randomNumber) throws TencentCloudSDKException {
|
try {
|
System.out.println("生成的随机整数是：" + randomNumber);
|
// 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
// 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
Credential cred = new Credential(SecretId, SecretKey);
|
// 实例化一个http选项，可选的，没有特殊需求可以跳过
|
HttpProfile httpProfile = new HttpProfile();
|
httpProfile.setEndpoint("sms.tencentcloudapi.com");
|
// 实例化一个client选项，可选的，没有特殊需求可以跳过
|
ClientProfile clientProfile = new ClientProfile();
|
clientProfile.setHttpProfile(httpProfile);
|
// 实例化要请求产品的client对象,clientProfile是可选的
|
SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
|
// 实例化一个请求对象,每个接口都会对应一个request对象
|
SendSmsRequest req = new SendSmsRequest();
|
String[] phoneNumberSet1 = {phone};
|
req.setPhoneNumberSet(phoneNumberSet1);
|
|
req.setSmsSdkAppId("1400838975");
|
req.setSignName("北京华星北斗智控");
|
req.setTemplateId("1878379");
|
|
String[] templateParamSet1 = {String.valueOf(randomNumber)};
|
req.setTemplateParamSet(templateParamSet1);
|
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
// 输出json格式的字符串回包
|
System.out.println(SendSmsResponse.toJsonString(resp));
|
TbUser tbUser = tbUserService.findPhoneUser(phone);
|
TbDuanxinlog duanxinlog = new TbDuanxinlog();
|
duanxinlog.setName(tbUser.getUsername());
|
duanxinlog.setPhone(phone);
|
|
duanxinlog.setMsg("登录验证码:" + randomNumber + ",该验证码2分钟内有效，如非本人操作请忽略该短信");
|
tbDuanxinlogService.addorupDuanxinlog(duanxinlog);
|
} catch (TencentCloudSDKException e) {
|
System.out.println(e.toString());
|
}
|
return R.ok(randomNumber);
|
}
|
}
|
