package com.hxzk.controller;
|
|
import com.github.pagehelper.PageInfo;
|
import com.hxzk.pojo.*;
|
import com.hxzk.service.*;
|
|
import com.hxzk.util.*;
|
import com.hxzk.util.token.TokenUtil;
|
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 org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.servlet.ModelAndView;
|
|
import javax.servlet.ServletException;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.io.UnsupportedEncodingException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
|
@RestController
|
@RequestMapping("/")
|
public class UserController {
|
public static String username = "";
|
@Autowired
|
TokenUtil tokenUtil;
|
@Autowired
|
CabinetService cabinetService;
|
@Autowired
|
UserService userService;
|
@Autowired
|
ComapanyService comapanyService;
|
@Autowired
|
ScreenService screenService;
|
@Autowired
|
WarningService warningService;
|
@Autowired
|
TbSmsReminderService smsReminderService;
|
@Autowired
|
SmsLogService smsLogService;
|
@Autowired
|
TbDaoHangService daoHangService;
|
@Autowired
|
DaoHangUserService daoHangUserService;
|
@Autowired
|
SystemLogService systemLogService;
|
@Autowired
|
WarnTongJiService warnTongJiService;
|
@Autowired
|
SessionManager sessionManager;
|
@Autowired
|
PersonService personService;
|
@Autowired
|
FaKaService faKaService;
|
private String SecretId ="AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
|
private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
|
|
private Integer todes = 0;
|
private Integer bbbj = 0;
|
|
// 创建一个固定大小的线程池
|
ExecutorService threadPool = Executors.newFixedThreadPool(1);
|
|
|
@Autowired
|
private HttpServletRequest request; // 自动注入 HttpServletRequest
|
|
public TbUser getUser() {
|
// 从 request 中获取用户信息
|
String userId = (String) request.getAttribute("userId");
|
String userRole = (String) request.getAttribute("userRole");
|
TbUser user = new TbUser();
|
user.setUsername(userId);
|
user.setJuese(userRole);
|
// 使用 userId 和 userRole 进行业务逻辑处理
|
System.out.println("当前用户ID: " + userId);
|
System.out.println("当前用户角色: " + userRole);
|
return user;
|
}
|
|
@PostMapping("login")
|
public String login(TbUser user, HttpServletRequest request) throws UnsupportedEncodingException {
|
request.setCharacterEncoding("UTF-8");
|
TbUser user1 = new TbUser();
|
if (user.getPhone() == null || user.getPhone().equals("")) {
|
user1 = userService.login(user);
|
if (user1 != null) {
|
username = user1.getUsername();
|
}else {
|
return "0";
|
}
|
//用户名密码登录
|
} else {
|
//手机号验证码登录
|
user1 = userService.loginPhone(user);
|
if (user1 != null) {
|
username = user1.getUsername();
|
}else {
|
return "0";
|
}
|
}
|
//用户名密码登录
|
// 将要执行的任务封装为一个Runnable对象
|
if (todes == 0){
|
Runnable task = new Runnable() {
|
@Override
|
public void run() {
|
MyThreadTask myThreadTask = new MyThreadTask(warningService, smsReminderService, smsLogService,warnTongJiService);
|
myThreadTask.run();
|
todes = 1;
|
}
|
};
|
|
// 提交任务给线程池执行
|
threadPool.submit(task);
|
}
|
sessionManager.setCurrentUser(request,user1);
|
// if (bbbj == 0){
|
// NettyServer nettyServer = new NettyServer(personService,cabinetService,faKaService);
|
// nettyServer.server(8889);
|
// bbbj++;
|
// }
|
String token = tokenUtil.getToken(user.getUsername(),user.getJuese());
|
return token;
|
}
|
@GetMapping("findUserRole")
|
public TbUser UserRole(TbUser user){
|
return userService.UserRole(user);
|
}
|
//获取验证码
|
@GetMapping("sms")
|
public int sms(String phone,int 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));
|
} catch (TencentCloudSDKException e) {
|
System.out.println(e.toString());
|
}
|
return randomNumber;
|
}
|
|
@GetMapping("findUser")
|
result<List<TbUser>> findUser(Integer page, Integer limit,HttpServletRequest request) throws UnsupportedEncodingException {
|
PageInfo<TbUser> cz= userService.findAll(page, limit);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
@PostMapping("addUser")
|
public int addUser(TbUser user,HttpServletResponse response,String caozuoName,HttpServletRequest request) throws IOException {
|
TbUser user1 = sessionManager.getCurrentUser(request);
|
user.setTime(gettime());
|
if (user.getUadd() == null || user.getUadd() == ""){
|
user.setUadd("No");
|
}else{
|
user.setUadd("Yes");
|
}
|
if (user.getUdelete() == null || user.getUdelete() == ""){
|
user.setUdelete("No");
|
}else {
|
user.setUdelete("Yes");
|
}
|
if (user.getUupdate() == null || user.getUupdate() == ""){
|
user.setUupdate("No");
|
}else{
|
user.setUupdate("Yes");
|
}
|
if(user.getUjoin() == null || user.getUjoin() == ""){
|
user.setUjoin("No");
|
}else{
|
user.setUjoin("Yes");
|
}
|
userService.addUser(user);
|
String content = "添加了一个用户,该用户为："+user.getUsername();
|
String contentew = "Добавлен пользователь, который является："+user.getUsername();
|
String ipAddress = request.getRemoteAddr();
|
SystemLogController.InsertSystemLog(user1.getUsername(),gettime(),content,"新增",ipAddress);
|
//给该用户设置默认查看所有导航
|
List<TbDaohang> daohangs = daoHangService.findAll();
|
for (int i = 0 ; i < daohangs.size();i++){
|
TbDaohangUser daohangUser = new TbDaohangUser();
|
daohangUser.setSrc(daohangs.get(i).getSrc());
|
daohangUser.setIshow("1");
|
daohangUser.setParent(String.valueOf(daohangs.get(i).getParent()));
|
daohangUser.setParents(daohangs.get(i).getParents());
|
daohangUser.setName(daohangs.get(i).getName());
|
daohangUser.setLevel(daohangs.get(i).getLevel());
|
daohangUser.setIcon(daohangs.get(i).getIcon());
|
daohangUser.setUsername(user.getUsername());
|
daoHangUserService.UserAdd(daohangUser);
|
}
|
return 1;
|
}
|
@PostMapping("updateUser")
|
public void updateUser(TbUser user,HttpServletResponse response,HttpServletRequest request) throws IOException {
|
TbUser user1 = sessionManager.getCurrentUser(request);
|
if (user.getUadd() == null || user.getUadd() == ""){
|
user.setUadd("No");
|
}else{
|
user.setUadd("Yes");
|
}
|
if (user.getUdelete() == null || user.getUdelete() == ""){
|
user.setUdelete("No");
|
}else {
|
user.setUdelete("Yes");
|
}
|
if (user.getUupdate() == null || user.getUupdate() == ""){
|
user.setUupdate("No");
|
}else{
|
user.setUupdate("Yes");
|
}
|
if(user.getUjoin() == null || user.getUjoin() == ""){
|
user.setUjoin("No");
|
}else{
|
user.setUjoin("Yes");
|
}
|
user.setTime(gettime());
|
userService.updateUser(user);
|
String content= "修改了一个用户,该用户为："+user.getUsername();
|
String contentew= "Изменен пользователь, который является："+user.getUsername();
|
String ipAddress = request.getRemoteAddr();
|
SystemLogController.InsertSystemLog(user1.getUsername(),gettime(),content,"修改",ipAddress);
|
response.sendRedirect("/hxzkuwb/HouTai/User/User.jsp");
|
}
|
@GetMapping("deleteUser")
|
public void deleteUser(TbUser user,HttpServletResponse response,HttpServletRequest request) throws IOException {
|
TbUser user1 = sessionManager.getCurrentUser(request);
|
userService.deleteUser(user);
|
screenService.deScreen(user.getUsername());
|
String content= "删除了一个用户,该用户为："+user.getUsername();
|
String contentew= "Удален пользователь, который является："+user.getUsername();
|
String ipAddress = request.getRemoteAddr();
|
SystemLogController.InsertSystemLog(user1.getUsername(),gettime(),content,"删除",ipAddress);
|
response.sendRedirect("/hxzkuwb/HouTai/User/User.jsp");
|
}
|
|
//用户表格搜索
|
@PostMapping("findUserSearch")
|
result<List<TbUser>> findUserSearch(Integer page, Integer limit,TbUser user){
|
PageInfo<TbUser> cz= userService.findSearch(page, limit,user);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
|
//获取所有公司表格
|
@GetMapping("findCompany")
|
result<List<TbCompany>> findCompany(Integer page, Integer limit){
|
PageInfo<TbCompany> cz= comapanyService.findAll(page, limit);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
//获取所有公司下拉框
|
@GetMapping("listCompany")
|
public List<TbCompany> listcompany(){
|
return comapanyService.listcompany();
|
}
|
|
//添加公司
|
@PostMapping("addCompany")
|
public void addCompany(TbCompany company, HttpServletResponse response,HttpServletRequest request) throws IOException {
|
TbUser user = sessionManager.getCurrentUser(request);
|
Calendar calendar = Calendar.getInstance();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String dateStr = sdf.format(calendar.getTime());
|
company.setAddtime(dateStr);
|
comapanyService.addCompany(company);
|
TbScreenSettings screenSettings = new TbScreenSettings();
|
screenSettings.setCompanyname(company.getCompanyname());
|
screenService.AddScreen(screenSettings);
|
String content = "增加了一个公司,该公司名称为："+company.getCompanyname();
|
String contentew = "Добавлена компания, которая называется："+company.getCompanyname();
|
String ipAddress = request.getRemoteAddr();
|
SystemLogController.InsertSystemLog(user.getUsername(),gettime(),content,"增加",ipAddress);
|
response.sendRedirect("/hxzkuwb/HouTai/User/Company.jsp");
|
}
|
|
@PostMapping("updateCompany")
|
public void updateCompany(TbCompany company,HttpServletResponse response,HttpServletRequest request) throws IOException {
|
TbUser user = sessionManager.getCurrentUser(request);
|
comapanyService.updateCompany(company);
|
String content = "修改了一个公司,该公司名称为："+company.getCompanyname();
|
String contentew = "Изменилось название компании,："+company.getCompanyname();
|
String ipAddress = request.getRemoteAddr();
|
SystemLogController.InsertSystemLog(user.getUsername(),gettime(),content,"修改",ipAddress);
|
response.sendRedirect("/hxzkuwb/HouTai/User/Company.jsp");
|
}
|
|
@PostMapping("deleteCompany")
|
public int deleteCompany(TbCompany company,HttpServletRequest request){
|
TbUser user = sessionManager.getCurrentUser(request);
|
screenService.deScreen(company.getCompanyname());
|
String content = "删除了一个公司,该公司名称为："+company.getCompanyname();
|
String contentew = "Удалено название компании："+company.getCompanyname();
|
String ipAddress = request.getRemoteAddr();
|
SystemLogController.InsertSystemLog(user.getUsername(),gettime(),content,"删除",ipAddress);
|
return comapanyService.deleteCompany(company);
|
}
|
|
@PostMapping("findcompanySearch")
|
result<List<TbCompany>> findanchorSearch(Integer page, Integer limit, TbCompany company){
|
PageInfo<TbCompany> cz= comapanyService.findSearch(page, limit,company);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
//根据用户名称查询公司设置的系统名称
|
@GetMapping("findCompanySystemName")
|
public TbCompany findComapanySystemName(String username){
|
TbUser user = userService.findCompanyName(username);
|
return comapanyService.findCompany(user.getCompany());
|
}
|
//ID查找
|
@GetMapping("findIdUser")
|
public TbUser findIdUser(Integer id){
|
return userService.findIdUser(id);
|
}
|
//手机号查找
|
@GetMapping("findPhoneUser")
|
public TbUser findPhoneUser(String phone){
|
return userService.findPhoneUser(phone);
|
}
|
@GetMapping("findNameUser")
|
public int findNameUser(String name){
|
return userService.findNameUser(name);
|
}
|
|
@PostMapping("findUserAndPhone")
|
public TbUser findUserAndPhone(TbUser user){
|
return userService.findUserAndPhone(user);
|
}
|
@GetMapping("upUserYanZheng")
|
public int upUserYanZheng(TbUser user){
|
return userService.upUserYanZheng(user);
|
}
|
|
@GetMapping("upUserJiaYanZheng")
|
public int upUserJiaYanZheng(TbUser user){
|
return userService.upUserJiaYanZheng(user);
|
}
|
@PostMapping("upPassword")
|
public int UpPassword(TbUser user){
|
return userService.UpPassword(user);
|
}
|
|
// @PostMapping("getToken")
|
// public String getToken(@RequestBody String token){
|
// return tokenUtil.getToken(token);
|
// }
|
// @PostMapping("JieXiToken")
|
// public String JieXiToken(String token){
|
// return tokenUtil.parseToken(token);
|
// }
|
|
@RequestMapping("/Mars3dMap")
|
public ModelAndView mars3dMap() {
|
ModelAndView modelAndView = new ModelAndView("view/Home/Mars3dMap");
|
return modelAndView;
|
}
|
|
@RequestMapping("/Mars3")
|
public ModelAndView Mars3() {
|
ModelAndView modelAndView = new ModelAndView("view/Home/Mars3dMap");
|
return modelAndView;
|
}
|
|
@PostMapping("CheckToken")
|
public Integer CheckToken(String sessionId){
|
Map<String, String> map;
|
try {
|
map = tokenUtil.parseToken(sessionId);
|
}catch (Exception e){
|
return 1;
|
}
|
return 0;
|
|
}
|
|
@GetMapping("UpdateCode")
|
public Integer UpdateCode(){
|
TbUser user = getUser();
|
TbUser user1 = userService.findUserAndPhone(user);
|
String phone = user1.getPhone();
|
Integer codes = 0;
|
try {
|
Random random = new Random();
|
|
// 生成一个 4 位数的随机整数 (1000 到 9999 之间)
|
int randomCode = random.nextInt(9000) + 1000;
|
|
// 输出随机验证码
|
System.out.println("生成的随机整数是：" + randomCode);
|
// 实例化一个认证对象，入参需要传入腾讯云账户 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(randomCode)};
|
req.setTemplateParamSet(templateParamSet1);
|
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
// 输出json格式的字符串回包
|
System.out.println(SendSmsResponse.toJsonString(resp));
|
codes = randomCode * 12;
|
} catch (TencentCloudSDKException e) {
|
System.out.println(e.toString());
|
}
|
|
return codes;
|
}
|
|
//修改为新密码
|
@GetMapping("UpPass")
|
public Integer UpPass(String newpassword){
|
TbUser user = getUser();
|
TbUser user1 = userService.findUserAndPhone(user);
|
user1.setPassword(newpassword);
|
return userService.UpPass(user1);
|
}
|
|
@GetMapping("FindTokenUser")
|
public TbUser FindTokenUser(){
|
TbUser user = getUser();
|
TbUser user1 = userService.findUserAndPhone(user);
|
return user1;
|
}
|
@GetMapping("FindAdminUser")
|
public Integer FindAdminUser(){
|
return userService.FindAdminUser();
|
}
|
|
public String gettime(){
|
Date now = new Date();
|
// 创建日期格式化对象，设置格式为 "yyyy-MM-dd HH:mm"
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
// 格式化日期对象，输出字符串结果
|
String formattedDate = sdf.format(now);
|
return formattedDate;
|
}
|
|
}
|
