package com.ruoyi.quartz.task;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.ruoyi.common.constant.UrlConstant;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.station.domain.*;
|
import com.ruoyi.station.model.TmpDataModel;
|
import com.ruoyi.station.model.WorkUserModel;
|
import com.ruoyi.station.service.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.*;
|
|
|
@Component("operationHeadTask")
|
public class OperationHeadTask {
|
|
@Autowired
|
private IMjHeadsUsersService headsUsersService;
|
@Autowired
|
private IMjFingerprintReadHeadService fingerprintReadHeadService;
|
@Autowired
|
private IMjWorkUserPushService mjWorkUserPushService;
|
@Autowired
|
private IMjWorkUserService workUserService;
|
@Autowired
|
private IMjFingerprintService fingerprintService;
|
|
public void tongBu() {
|
int flag = 0;
|
List<MjHeadsUsers> list = headsUsersService.selectMjHeadsUsersListByWorking();
|
List<MjHeadsUsers> list2 = headsUsersService.selectMjHeadsUsersListByUnWorking();
|
for(MjHeadsUsers headsUsers:list){
|
MjHeadsUsers find = new MjHeadsUsers();
|
find.setUserId(headsUsers.getUserId());
|
find.setHeadId(headsUsers.getHeadId());
|
find.setAuthorizeType(0);
|
List<MjHeadsUsers> mjHeadsUsers = headsUsersService.selectMjHeadsUsersList(find);
|
if(mjHeadsUsers.size()==0){
|
addPush(headsUsers);
|
flag++;
|
}
|
}
|
//System.out.println("推送读头:"+flag+"个");
|
|
int flag2=0;
|
for(MjHeadsUsers headsUsers:list2){
|
MjHeadsUsers find = new MjHeadsUsers();
|
find.setUserId(headsUsers.getUserId());
|
find.setHeadId(headsUsers.getHeadId());
|
find.setAuthorizeType(0);
|
List<MjHeadsUsers> mjHeadsUsers = headsUsersService.selectMjHeadsUsersList(find);
|
if(mjHeadsUsers.size()==0){
|
Thread t = new Thread(new Runnable(){
|
public void run(){
|
MjFingerprintReadHead head = fingerprintReadHeadService.selectMjFingerprintReadHeadById(headsUsers.getHeadId());
|
if(StringUtils.isNotEmpty(head.getIpOrOther()) && StringUtils.isNotEmpty(head.getPort())) {
|
try {
|
mjWorkUserPushService.removeFingerTmp(headsUsers.getUserId().toString(), head.getIpOrOther(), head.getPort());
|
} catch (Exception e) {
|
//System.out.println("把指纹从读头取消授权异常!");
|
}
|
}
|
}
|
});
|
t.start();
|
headsUsersService.deleteMjHeadsUsersById(headsUsers.getId());
|
flag2++;
|
//System.out.println("删除读头："+headsUsers.getId());
|
}else{
|
headsUsersService.deleteMjHeadsUsersById(headsUsers.getId());
|
flag2++;
|
}
|
}
|
//System.out.println("删除headUser的读头："+flag2);
|
}
|
|
public void addPush(MjHeadsUsers headsUsers){
|
Thread t = new Thread(new Runnable(){
|
public void run(){
|
MjFingerprintReadHead head = fingerprintReadHeadService.selectMjFingerprintReadHeadById(headsUsers.getHeadId());
|
List<TmpDataModel> tmpDataModels = fingerprintService.selectMjFingerprintListByUserId(headsUsers.getUserId());
|
String users = domainToModel(headsUsers, tmpDataModels);
|
|
int code = addTeamUsers(users,head);
|
if(code==0){
|
//System.out.println("室外读头推送成功"+head.getIpOrOther());
|
}else{
|
//System.out.println("推送失败");
|
}
|
}
|
});
|
t.start();
|
headsUsers.setAuthorizeResult(2);
|
headsUsersService.updateMjHeadsUsers(headsUsers);
|
}
|
|
//增加组用户
|
private Integer addTeamUsers(String value, MjFingerprintReadHead head) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
JSONObject jsonObject = null;
|
|
MultiValueMap<String, Object> map= new LinkedMultiValueMap<>();
|
|
map.add("ip", head.getIpOrOther());
|
map.add("port", head.getPort());
|
map.add("userDatas", value);
|
|
HttpEntity<MultiValueMap<String, Object>> request = new HttpEntity<>(map, headers);
|
try {
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktAddUserTmpByList", request , String.class );
|
jsonObject = JSONObject.parseObject(response.getBody());
|
//System.out.println(response.getBody());
|
}catch (Exception e) {
|
e.printStackTrace();
|
return 1;
|
}
|
if(jsonObject != null) {
|
return (int)jsonObject.get("code");
|
}
|
return 1;
|
}
|
|
//转换为访问所需model
|
private String domainToModel(MjHeadsUsers headsUsers, List<TmpDataModel> mjFingerprintList) {
|
List<WorkUserModel> wums = new ArrayList<WorkUserModel>();
|
|
WorkUserModel workUserModel = new WorkUserModel();
|
workUserModel.setId(headsUsers.getUserId().toString().trim());
|
MjWorkUser workUser = workUserService.selectMjWorkUserById(headsUsers.getUserId());
|
workUserModel.setName(workUser.getUserName().trim());
|
workUserModel.setPass("");
|
workUserModel.setiPrivilege(0);
|
workUserModel.setFlag("a");
|
workUserModel.setTmpDatas(mjFingerprintList);
|
wums.add(workUserModel);
|
|
JSONArray jsonArray=new JSONArray(Collections.singletonList(wums));
|
String userDatas = jsonArray.toString().substring(1, jsonArray.toString().length()-1);
|
return userDatas;
|
}
|
}
|
