package com.hxzkappboot.controller;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.hxzkappboot.pojo.*;
|
import com.hxzkappboot.service.TbMarsHomesetService;
|
import com.hxzkappboot.service.TbPersonService;
|
import com.hxzkappboot.udp.Udp_Out;
|
import com.hxzkappboot.util.R;
|
import com.hxzkappboot.util.StatusCode;
|
import com.hxzkappboot.util.WechatLoginRequestDTO;
|
import com.tencentcloudapi.common.Credential;
|
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.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.validation.Valid;
|
import java.io.IOException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* <p>
|
* 前端控制器
|
* </p>
|
*
|
* @author wangfei
|
* @since 2024-03-08
|
*/
|
@RestController
|
//@Component
|
//@RequestMapping("/")
|
public class TbPersonController {
|
|
@Autowired
|
TbPersonService personService;
|
|
@Autowired
|
TbMarsHomesetService tbMarsHomesetService;
|
|
|
@GetMapping("/api/wx/findPerson")
|
public R findIdPerson(String name,String company) {
|
R response;
|
String output = name.toUpperCase();//将小写字母转成大写字母
|
if (personService.findIdPerson(output,company) != null) {
|
response = new R(StatusCode.Success);
|
// String token = wechatService.getToken(loginRequest);
|
// tbUser1.setToken(token);
|
response.setData(personService.findIdPerson(output,company));
|
// return personService.findIdPerson(name);
|
} else {
|
response = new R(StatusCode.Fail);
|
response.setCode(-1);
|
response.setMsg("未搜索到数据!");
|
}
|
return response;
|
}
|
|
@GetMapping("/api/wx/acquisition")
|
public R acquisition(String baoliu3,String company) {
|
R response;
|
String output = baoliu3.toUpperCase();//将小写字母转成大写字母
|
|
TbPerson tbPerson = personService.acquisition(output,company);
|
|
if (tbPerson != null) {
|
if (Objects.equals(tbPerson.getBaoliu13(), "高精度") && Objects.equals(tbPerson.getPOnline(), "1")) {
|
response = new R(StatusCode.Success);
|
response.setData(tbPerson);
|
} else {
|
response = new R(StatusCode.Fail);
|
response.setCode(-1);
|
response.setMsg("设备非高精或离线!");
|
}
|
} else {
|
response = new R(StatusCode.Fail);
|
response.setCode(-1);
|
response.setMsg("未搜索到数据!");
|
}
|
return response;
|
}
|
|
// submit
|
|
@PostMapping("/api/wx/MarsHome")
|
public R MarsHome(HttpServletRequest request) {
|
R response;
|
response = new R(StatusCode.Success);
|
List<TbMarsHomeset> gpsList = tbMarsHomesetService.MarsHome();
|
response.setData(gpsList);
|
return response;
|
}
|
|
|
@GetMapping("/api/wx/getGPSCesium")
|
public R getGPSCesium( String company) {
|
R response;
|
response = new R(StatusCode.Success);
|
List<PersonCesium> gpsList = personService.getGPSCesium(company);
|
response.setData(gpsList);
|
return response;
|
}
|
|
|
@PostMapping("/api/wx/updateTagApi")
|
public R upTag(@Valid @RequestBody PersonRequestDTO personRequestDTO) throws IOException {
|
if (Objects.equals(personRequestDTO.getType(), "随机卡")) {
|
TbPerson tbPerson = personService.upTag();
|
// TbPerson person = new TbPerson();
|
if (tbPerson==null){
|
// tagId = "b001";
|
personRequestDTO.setTagId("F001");
|
// personRequestDTO.setPTagid("b001");
|
}else{
|
|
String pTagid = tbPerson.getPTagid();
|
String[] parts = pTagid.split("F");
|
String numberStr = parts[1];
|
int number = Integer.parseInt(numberStr);
|
int incrementedNumber = number + 1;
|
String newNumberStr = String.format("%03d", incrementedNumber);
|
String newTagid = "F" + newNumberStr;
|
personRequestDTO.setTagId(newTagid);
|
}
|
}
|
R response;
|
String xieyi = "BSTOCS1,ADDTAG," + personRequestDTO.getTagId() + "," + personRequestDTO.getName() + ",150,10000,1,系统默认,END";
|
String xieyi1 = "BSTOCS1,PERSONALTER," + personRequestDTO.getTagId() + ","+ personRequestDTO.getName() + ",男,系统默认,END";
|
// Udp_Out.udp_to_cs(xieyi1);
|
if (personRequestDTO.getTagId() == null || personRequestDTO.getType() == null) {
|
response = new R(StatusCode.Fail);
|
return response;
|
}
|
Udp_Out.udp_to_cs(xieyi);
|
Udp_Out.udp_to_cs(xieyi1);
|
try {
|
Thread.sleep(1000);
|
|
}catch (InterruptedException e){
|
Thread.currentThread().interrupt();
|
// logUtil.error("线程中断"+e.getMessage());
|
}
|
|
TbPerson tbPerson = personService.upperson(personRequestDTO.getTagId(),personRequestDTO.getBaoliu38(),personRequestDTO.getPhone());
|
|
// String content = "通过接口修改了标签信息,该标签为:"+tag.getTagId();
|
// String contentew = "Удалить метку через интерфейс:"+tag.getTagId();
|
// SystemLogController.InsertSystemLog("通过接口", gettime(),content,contentew);
|
|
|
response = new R(StatusCode.Success);
|
response.setData(tbPerson);
|
return response;
|
// return resultutil.returnSuccess("success",tag.getTagId());
|
}
|
|
|
@GetMapping("/api/wx/getGPS")
|
public R getGPS(String company) {
|
R response;
|
response = new R(StatusCode.Success);
|
List<TbPersonAndDepartment> gpsList = personService.getGps(company);
|
response.setData(gpsList);
|
return response;
|
}
|
|
@GetMapping("/api/wx/findTag")
|
public R findAll(Page page, String objectid,String company) {
|
R response;
|
IPage<TbPerson> ipage = personService.findAll(page,objectid,company);
|
response = new R(StatusCode.Success);
|
response.setData(ipage);
|
response.setOnline(personService.findonline(company));
|
response.setOffline(personService.findoffline(company));
|
return response;
|
}
|
|
@GetMapping("/api/wx/findtagIdPerson")
|
public R findtagIdPerson(String id){
|
R response;
|
response = new R(StatusCode.Success);
|
response.setData(personService.findtagidPerson(id));
|
return response;
|
}
|
|
|
}
|