package com.ruoyi.quartz.task;
|
|
import com.ruoyi.station.domain.*;
|
import com.ruoyi.station.service.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
|
/**
|
* 定时扫描工单，如有生效工单则推送对应负责人到控制板
|
*/
|
@Component("pushUserInfoTask")
|
public class PushUserInfoTask {
|
|
@Autowired
|
private IMjHeadsUsersService iMjHeadsUsersService;
|
|
public void pushUser() {
|
MjWorkOrder mjWorkOrder = new MjWorkOrder();
|
mjWorkOrder.setEndTime(new Date());
|
iMjHeadsUsersService.deleteByEndTime(mjWorkOrder);
|
//System.out.println("删除过期扫描完成");
|
}
|
|
/*public void pushUser() {
|
|
checkOrderValid();
|
checkOrderInvalid();
|
}
|
|
//监测生效工单
|
private void checkOrderValid() {
|
MjDataPushLog mjDataPushLog = new MjDataPushLog();
|
|
List<MjWorkOrder> mjWorkOrderList = mjWorkOrderService.selectMjWorkOrderByDate(); //从无效工单中获取有效工单
|
|
List<MjWorkUser> mjWorkUserList = new ArrayList<>();
|
List<String> AreaIdList = new ArrayList<>();
|
if(mjWorkOrderList != null && mjWorkOrderList.size() > 0) {
|
for(MjWorkOrder mjWorkOrder : mjWorkOrderList) {
|
//日志记录
|
mjDataPushLog.setId(IdUtils.getUUIDInOrderId()+"");
|
mjDataPushLog.setType(mjWorkOrder.getType());
|
mjDataPushLog.setTypeName(mjWorkOrder.getTypeName());
|
mjDataPushLog.setWorkType(mjWorkOrder.getWorkType());
|
mjDataPushLog.setOrderId(mjWorkOrder.getId());
|
mjDataPushLog.setOrderName(mjWorkOrder.getOrderName());
|
mjDataPushLog.setTaskName(mjWorkOrder.getTaskName());
|
mjDataPushLog.setOrganizationId(mjWorkOrder.getOrganizationId());
|
mjDataPushLog.setOrderName(mjWorkOrder.getOrganizationName());
|
mjDataPushLog.setOpenMode(mjWorkOrder.getOpenMode());
|
mjDataPushLog.setStartTime(mjWorkOrder.getStartTime());
|
mjDataPushLog.setEndTime(mjWorkOrder.getEndTime());
|
mjDataPushLog.setCreateTime(new Date());
|
mjDataPushLog.setCreateBy(mjWorkOrder.getCreateBy());
|
if(mjWorkOrder != null && mjWorkOrder.getId() != null) {
|
MjOrderDetail mjOrderDetail = new MjOrderDetail();
|
mjOrderDetail.setOrderId(mjWorkOrder.getId());
|
List<MjOrderDetail> mjOrderDetailList = mjOrderDetailService.selectMjOrderDetailList(mjOrderDetail); //获取工单对应详情信息
|
if(mjOrderDetailList != null && mjOrderDetailList.size() > 0) {
|
String togetherUserIds = "";
|
for(MjOrderDetail mjOrderDetail1 : mjOrderDetailList) {
|
if(mjOrderDetail1 != null && mjOrderDetail1.getUserId() != null) {
|
if(mjOrderDetail1.getAreaId() != null && StringUtils.isNotEmpty(mjOrderDetail1.getAreaId())) {
|
AreaIdList.add(mjOrderDetail1.getAreaId());
|
}
|
mjDataPushLog.setAreaId(mjOrderDetail1.getAreaId());
|
mjDataPushLog.setAreaName(mjOrderDetail1.getAreaName());
|
mjDataPushLog.setDoorId(mjOrderDetail1.getDoorId());
|
mjDataPushLog.setOperationType(0); //新增
|
mjDataPushLog.setAuthorizeType("0"); //增加授权
|
|
MjWorkUser mjWorkUser = mjWorkUserService.selectMjWorkUserById(mjOrderDetail1.getUserId()); //获取负责人
|
if(mjWorkUser != null) {
|
// if(mjOrderDetailList.get(0).getId() == mjOrderDetail1.getId() && mjWorkUser != null) { //第一人为主负责人
|
if(mjOrderDetail1.getMainUser() != null ) {
|
if(mjOrderDetail1.getMainUser() == 1){ //第一人为主负责人
|
mjDataPushLog.setUserId(mjWorkUser.getId().toString());
|
mjDataPushLog.setOperator(mjOrderDetail.getUserName());
|
mjWorkUser.setFlag("a");
|
}else {
|
//拼接同行人id
|
if(togetherUserIds == "") {
|
togetherUserIds+=mjWorkUser.getId().toString();
|
}else {
|
togetherUserIds+=","+mjWorkUser.getId().toString();
|
}
|
// mjDataPushLog.setUserId(mjWorkUser.getId().toString());
|
mjWorkUser.setFlag("x");
|
}
|
}
|
mjWorkUserList.add(mjWorkUser);
|
}
|
}
|
}
|
mjDataPushLog.setTogetherUserIds(togetherUserIds);
|
}
|
}
|
}
|
}
|
if(mjWorkUserList.size() > 0) {
|
List<WorkUserModel> workUserModelList = new ArrayList<>();
|
for(MjWorkUser mjWorkUser : mjWorkUserList) {
|
if(mjWorkUser != null && mjWorkUser.getId() != null) {
|
|
List<TmpDataModel> mjFingerprintList = mjFingerprintService.selectMjFingerprintListByUserId(mjWorkUser.getId()); //获取负责人指纹信息
|
WorkUserModel workUserModel = domainToModel(mjWorkUser, mjFingerprintList);
|
workUserModelList.add(workUserModel);
|
}
|
}
|
|
JSONArray jsonArray=new JSONArray(Collections.singletonList(workUserModelList));
|
String userDatas = jsonArray.toString().substring(1, jsonArray.toString().length()-1);
|
addOrDelUserList(mjDataPushLog, userDatas, AreaIdList, true);
|
}
|
}
|
|
//监测失效工单
|
private void checkOrderInvalid() {
|
MjDataPushLog mjDataPushLog = new MjDataPushLog();
|
List<MjWorkOrder> mjWorkOrderList = mjWorkOrderService.selectMjWorkOrderByDateForInvalid(); //从有效工单中获取无效工单
|
|
List<MjWorkUser> mjWorkUserList = new ArrayList<>();
|
List<String> AreaIdList = new ArrayList<>();
|
if(mjWorkOrderList != null && mjWorkOrderList.size() > 0) {
|
for(MjWorkOrder mjWorkOrder : mjWorkOrderList) {
|
|
//日志记录
|
mjDataPushLog.setId(IdUtils.getUUIDInOrderId()+"");
|
mjDataPushLog.setType(mjWorkOrder.getType());
|
mjDataPushLog.setTypeName(mjWorkOrder.getTypeName());
|
mjDataPushLog.setWorkType(mjWorkOrder.getWorkType());
|
mjDataPushLog.setOrderId(mjWorkOrder.getId());
|
mjDataPushLog.setOrderName(mjWorkOrder.getOrderName());
|
mjDataPushLog.setTaskName(mjWorkOrder.getTaskName());
|
mjDataPushLog.setOrganizationId(mjWorkOrder.getOrganizationId());
|
mjDataPushLog.setOrderName(mjWorkOrder.getOrganizationName());
|
mjDataPushLog.setOpenMode(mjWorkOrder.getOpenMode());
|
mjDataPushLog.setStartTime(mjWorkOrder.getStartTime());
|
mjDataPushLog.setEndTime(mjWorkOrder.getEndTime());
|
mjDataPushLog.setCreateTime(new Date());
|
mjDataPushLog.setCreateBy(mjWorkOrder.getCreateBy());
|
|
if(mjWorkOrder != null && mjWorkOrder.getId() != null) {
|
MjOrderDetail mjOrderDetail = new MjOrderDetail();
|
mjOrderDetail.setOrderId(mjWorkOrder.getId());
|
List<MjOrderDetail> mjOrderDetailList = mjOrderDetailService.selectMjOrderDetailList(mjOrderDetail); //获取工单对应详情信息
|
if(mjOrderDetailList != null && mjOrderDetailList.size() > 0) {
|
String userIds = "";
|
for(MjOrderDetail mjOrderDetail1 : mjOrderDetailList) {
|
if(mjOrderDetail1.getAreaId() != null && StringUtils.isNotEmpty(mjOrderDetail1.getAreaId())) {
|
AreaIdList.add(mjOrderDetail1.getAreaId());
|
}
|
mjDataPushLog.setAreaId(mjOrderDetail1.getAreaId());
|
mjDataPushLog.setAreaName(mjOrderDetail1.getAreaName());
|
mjDataPushLog.setDoorId(mjOrderDetail1.getDoorId());
|
mjDataPushLog.setOperationType(2); //删除
|
mjDataPushLog.setAuthorizeType("1"); //取消授权
|
|
if(mjOrderDetail1 != null && mjOrderDetail1.getUserId() != null) {
|
MjWorkUser mjWorkUser = mjWorkUserService.selectMjWorkUserById(mjOrderDetail1.getUserId()); //获取负责人
|
if(mjWorkUser != null) {
|
if(userIds == "") {
|
userIds += mjWorkUser.getId().toString();
|
}else {
|
userIds += "," + mjWorkUser.getId().toString();
|
}
|
}
|
}
|
}
|
mjDataPushLog.setTogetherUserIds(userIds); //包含负责人(删除的记录包含负责人，添加的只有同行人)
|
|
addOrDelUserList(mjDataPushLog, userIds, AreaIdList, false);
|
}
|
}
|
}
|
}
|
}
|
|
//添加、删除工单负责人
|
private void addOrDelUserList(MjDataPushLog mjDataPushLog, String value, List<String> AreaIdList, boolean isAdd) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
if(AreaIdList.size() > 0) {
|
ResponseEntity<String> response = null;
|
for(String areaId : AreaIdList) {
|
String[] areaIds = areaId.split(",");
|
if(areaIds != null && AreaIdList.size() > 0) {
|
for(String aId : areaIds) {
|
MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
|
fingerprintReadHead.setAreaId(aId);
|
List<MjFingerprintReadHead> fingerprintReadHeads = mjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
|
for(MjFingerprintReadHead head : fingerprintReadHeads) {
|
MultiValueMap<String, Object> map= new LinkedMultiValueMap<>();
|
|
// map.add("ip",UrlConstant.FIGERPRINT_URL);
|
// map.add("port",UrlConstant.FIGERPRINT_PORT);
|
map.add("ip", head.getIpOrOther());
|
map.add("port", head.getPort());
|
map.add("userDatas", value);
|
|
HttpEntity<MultiValueMap<String, Object>> request = new HttpEntity<>(map, headers);
|
try {
|
if(head.getNewOldStatus() == 0) { //新设备
|
if(isAdd) {
|
response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktAddUserToOpenDoor", request , String.class );
|
}else {
|
response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktdelUserToOpenDoor", request , String.class );
|
}
|
}else if(head.getNewOldStatus() == 1) { //旧设备
|
if(isAdd) {
|
response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ1/ZktAddUserToOpenDoor", request , String.class );
|
}else {
|
response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ1/ZktdelUserToOpenDoor", request , String.class );
|
}
|
}
|
|
}catch (Exception e) {
|
e.printStackTrace();
|
mjDataPushLog.setAuthorizeResult("2"); //授权失败
|
mjDataPushLogService.insertMjDataPushLog(mjDataPushLog); //日志
|
return;
|
}
|
|
System.out.println(response.getBody());
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
System.out.println(jsonObject.get("code"));
|
if(jsonObject.get("code").toString().equals("0")) {
|
|
// regEvent(head.getIpOrOther(), head.getPort(), "http://localhost:8088/api/visit/addVisitInfo/"); //注册
|
|
mjDataPushLog.setAuthorizeResult("1"); //授权成功
|
MjWorkOrder mjWorkOrder = new MjWorkOrder();
|
mjWorkOrder.setId(mjDataPushLog.getOrderId());
|
if(isAdd) {
|
mjWorkOrder.setValidFlag(1); //工单状态生效
|
}else {
|
mjWorkOrder.setValidFlag(0); //工单状态失效
|
}
|
mjWorkOrderService.updateMjWorkOrder(mjWorkOrder);
|
}else {
|
mjDataPushLog.setAuthorizeResult("2"); //授权失败
|
}
|
}
|
}
|
}
|
}
|
if(response != null) {
|
mjDataPushLogService.insertMjDataPushLog(mjDataPushLog); //日志
|
}
|
}
|
}
|
|
//转换为访问所需model
|
private WorkUserModel domainToModel(MjWorkUser mjWorkUser, List<TmpDataModel> mjFingerprintList) {
|
WorkUserModel workUserModel = new WorkUserModel();
|
workUserModel.setId(mjWorkUser.getId().toString());
|
workUserModel.setName(mjWorkUser.getUserName());
|
workUserModel.setPass(mjWorkUser.getPass());
|
workUserModel.setiPrivilege(Integer.valueOf(mjWorkUser.getiPrivilege()));
|
workUserModel.setFlag(mjWorkUser.getFlag());
|
workUserModel.setTmpDatas(mjFingerprintList);
|
return workUserModel;
|
}
|
|
//读头注册监听
|
private Integer regEvent(String ip, String port, String url) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", ip);
|
map.add("port", port);
|
map.add("url", url);
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktRegEvent", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
|
return (int)jsonObject.get("code");
|
}*/
|
}
|
