package com.ruoyi.station.service.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.ruoyi.common.constant.UrlConstant;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.IdUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.station.domain.MjFingerprint;
|
import com.ruoyi.station.domain.MjFingerprintReadHead;
|
import com.ruoyi.station.domain.MjOrderDetail;
|
import com.ruoyi.station.domain.MjWorkUser;
|
import com.ruoyi.station.mapper.MjFingerprintMapper;
|
import com.ruoyi.station.mapper.MjWorkUserMapper;
|
import com.ruoyi.station.service.IMjFingerprintReadHeadService;
|
import com.ruoyi.station.service.IMjOrderDetailService;
|
import com.ruoyi.station.service.IMjWorkUserPushService;
|
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.Service;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 推送用户数据服务
|
*/
|
@Service
|
public class MjWorkUserPushServiceImpl implements IMjWorkUserPushService {
|
|
@Autowired
|
private MjFingerprintMapper mjFingerprintMapper;
|
|
@Autowired
|
private IMjOrderDetailService mjOrderDetailService;
|
|
@Autowired
|
private IMjFingerprintReadHeadService mjFingerprintReadHeadService;
|
|
@Autowired
|
private MjWorkUserMapper mjWorkUserMapper;
|
|
/**
|
* 推送用户基本信息
|
* @param mjWorkUser
|
* @return
|
*/
|
@Override
|
public Integer addUser(MjWorkUser mjWorkUser, Integer fingerprint) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
// List<String> areaIdList = new ArrayList<>();
|
//
|
// MjOrderDetail mjOrderDetail = new MjOrderDetail();
|
// mjOrderDetail.setUserId(mjWorkUser.getId());
|
// List<MjOrderDetail> mjOrderDetailList = mjOrderDetailService.selectMjOrderDetailList(mjOrderDetail);
|
// if(mjOrderDetailList != null && mjOrderDetailList.size() > 0) {
|
// String areaId = mjOrderDetailList.get(0).getAreaId();
|
// if(StringUtils.isNotEmpty(areaId)) {
|
// String[] areaIds = areaId.split(",");
|
// for(String id : areaIds) {
|
// MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
|
// fingerprintReadHead.setAreaId(id);
|
// List<MjFingerprintReadHead> fingerprintReadHeads = mjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
|
// for(MjFingerprintReadHead head : fingerprintReadHeads) {
|
MultiValueMap<String, String> 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("id",mjWorkUser.getId().toString());
|
map.add("userId",mjWorkUser.getUserId());
|
map.add("name",mjWorkUser.getUserName());
|
map.add("pass",mjWorkUser.getPass());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity(UrlConstant.ZK_URL+"api/SDZ/ZktAddUserInfo", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
System.out.println(jsonObject.get("code"));
|
if((int)jsonObject.get("code") == 0) {
|
getFingerInterface(mjWorkUser, fingerprint);
|
}
|
return (int)jsonObject.get("code");
|
// }
|
// }
|
// }
|
// }
|
// return 1;
|
}
|
|
/**
|
* 获取用户指纹信息
|
* @param id
|
* @return
|
*/
|
@Override
|
public Integer getFingerPrint(Long id, Integer fingerIndex) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip",UrlConstant.FIGERPRINT_URL);
|
map.add("port",UrlConstant.FIGERPRINT_PORT);
|
map.add("id",id.toString());
|
map.add("fingerIndex", fingerIndex.toString());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktGetUserTmp", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
JSONObject result = JSONObject.parseObject(jsonObject.get("result").toString());
|
// System.out.println(result.get("TmpData").toString());
|
// System.out.println(jsonObject.get("code"));
|
if((int)jsonObject.get("code") == 1) {
|
return (int)jsonObject.get("code");
|
}
|
if((int)jsonObject.get("code") == 0) {
|
Integer count = mjFingerprintMapper.selectCountByTmpData(id, result.get("TmpData").toString());
|
if(count > 0) {
|
return 2; //重复指纹
|
}
|
}
|
|
MjFingerprint mjFingerprint = new MjFingerprint();
|
mjFingerprint.setId(IdUtils.getUUIDInOrderId()+"");
|
mjFingerprint.setUserId(id);
|
if(result.get("TmpData") != null) {
|
mjFingerprint.setTmpdata(result.get("TmpData").toString());
|
}
|
mjFingerprint.setFingerindex(fingerIndex);
|
mjFingerprintMapper.insertMjFingerprint(mjFingerprint); //插入最新指纹
|
|
return (int)jsonObject.get("code");
|
}
|
|
/**
|
* 获取用户信息
|
* @param id
|
* @return
|
*/
|
@Override
|
public Integer getUsers(String id) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
String[] ids = id.split(",");
|
try {
|
for(String uid : ids) {
|
MjFingerprintReadHead readHead = mjFingerprintReadHeadService.selectMjFingerprintReadHeadById(uid);
|
if(readHead != null) {
|
if(StringUtils.isEmpty(readHead.getIpOrOther()) || StringUtils.isEmpty(readHead.getPort())){
|
continue;
|
}
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", readHead.getIpOrOther());
|
map.add("port", readHead.getPort());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktGetAllUserInfo", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
JSONObject result = JSONObject.parseObject(jsonObject.get("result").toString());
|
System.out.println(jsonObject.get("code"));
|
if((int)jsonObject.get("code") == 1) {
|
return (int)jsonObject.get("code");
|
}
|
JSONArray userList = JSONObject.parseArray(result.get("userList").toString());
|
for(int i=0; i < userList.size(); i++) {
|
JSONObject user = JSONObject.parseObject(userList.get(i).toString());
|
// System.out.println(user.get("name"));
|
// System.out.println(user.get("id"));
|
// System.out.println(user.get("tmpDatas"));
|
if(user != null) {
|
MjWorkUser mjWorkUser = new MjWorkUser();
|
if(StringUtils.isNotEmpty(user.get("id").toString())) {
|
int count = mjWorkUserMapper.selectWorkUserCountById(Long.parseLong(user.get("id").toString()));
|
if(count > 0) {
|
continue;
|
}
|
mjWorkUser.setId(Long.parseLong(user.get("id").toString()));
|
}
|
if(StringUtils.isNotEmpty(user.get("name").toString())) {
|
mjWorkUser.setUserName(user.get("name").toString());
|
}
|
if(StringUtils.isNotEmpty(user.get("pass").toString())) {
|
mjWorkUser.setPass(user.get("pass").toString());
|
}
|
mjWorkUser.setCreateTime(new Date());
|
mjWorkUser.setExpandStatus(1);
|
mjWorkUserMapper.insertMjWorkUser(mjWorkUser); //插入用户
|
}
|
|
JSONArray tmpDatas = JSONObject.parseArray(user.get("tmpDatas").toString());
|
for(int j=0; j < tmpDatas.size(); j++) {
|
JSONObject tmpData = JSONObject.parseObject(tmpDatas.get(j).toString());
|
// System.out.println(tmpData.get("tmpData"));
|
// System.out.println(tmpData.get("fingerIndex"));
|
// System.out.println(tmpData.get("iFlag"));
|
if(tmpData != null) {
|
MjFingerprint mjFingerprint = new MjFingerprint();
|
mjFingerprint.setId(IdUtils.getUUIDInOrderId()+"");
|
mjFingerprint.setUserId(Long.parseLong(user.get("id").toString()));
|
if(tmpData.get("tmpData") != null) {
|
mjFingerprint.setTmpdata(tmpData.get("tmpData").toString());
|
}
|
if(StringUtils.isNotEmpty(tmpData.get("fingerIndex").toString())) {
|
mjFingerprint.setFingerindex(Integer.parseInt(tmpData.get("fingerIndex").toString()));
|
}
|
mjFingerprintMapper.insertMjFingerprint(mjFingerprint); //插入用户指纹
|
}
|
}
|
}
|
}
|
}
|
}catch (Exception e){
|
|
}
|
|
return 0;
|
}
|
|
/**
|
* 从读头清除用户信息
|
* @param fingerprintReadHead
|
* @return
|
*/
|
@Override
|
public Integer removeUserInfoFromFingerHead(MjFingerprintReadHead fingerprintReadHead) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", fingerprintReadHead.getIpOrOther());
|
map.add("port", fingerprintReadHead.getPort());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktResetData", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
|
return (int)jsonObject.get("code");
|
}
|
|
/**
|
* 唤起指纹录入界面
|
*
|
* @return
|
*/
|
public void getFingerInterface(MjWorkUser mjWorkUser, Integer fingerprint) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", UrlConstant.FIGERPRINT_URL);
|
map.add("port", UrlConstant.FIGERPRINT_PORT);
|
map.add("id", mjWorkUser.getId().toString());
|
map.add("fingerIndex", fingerprint.toString());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktStartEnroll", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
|
}
|
|
/**
|
* 删除用户指纹
|
*
|
* @return
|
*/
|
public void removeFingerTmp(String userId, String ip, String port) {
|
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("id", userId);
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktDelUserTmp", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
|
}
|
|
@Override
|
public Integer removeUserTmp(MjFingerprintReadHead fingerprintReadHead) {
|
|
return getUsersFromHead(fingerprintReadHead.getIpOrOther(), fingerprintReadHead.getPort());
|
}
|
|
private Integer getUsersFromHead(String ip, String port) {
|
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);
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktResetDataNew", request , String.class ); //清除指纹
|
ResponseEntity<String> response1 = null;
|
ResponseEntity<String> response2 = null;
|
ResponseEntity<String> response3 = null;
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
JSONObject jsonObject1 = null;
|
JSONObject jsonObject2 = null;
|
JSONObject jsonObject3 = null;
|
|
if(jsonObject != null && (int)jsonObject.get("code") == 0) {
|
response1 = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktRestartDevice", request , String.class ); //重启读头
|
jsonObject1 = JSONObject.parseObject(response1.getBody());
|
}else {
|
System.out.println(response.getBody());
|
return 5;
|
}
|
if(response1 != null && (int)jsonObject1.get("code") == 0) {
|
SimpleDateFormat dfs = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String startTime = DateUtils.getTime();
|
try {
|
Date begin = dfs.parse(startTime);
|
while(true) {
|
response2 = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktIsAlive", request , String.class ); //获取连接状态
|
jsonObject2 = JSONObject.parseObject(response2.getBody());
|
if(response2 != null) {
|
if((int)jsonObject2.get("code") == 0) {
|
response3 = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktRegEvent", request , String.class ); //注册
|
jsonObject3 = JSONObject.parseObject(response3.getBody());
|
break;
|
}else {
|
String endTime = DateUtils.getTime();
|
Date end = dfs.parse(endTime);
|
long between=(end.getTime()-begin.getTime())/1000;//除以1000是为了转换成秒
|
if(between > 180) {
|
return 2; //2超过一分钟未成功重启读头
|
}
|
}
|
}
|
}
|
} catch (ParseException e) {
|
e.printStackTrace();
|
return 1; //1操作失败
|
}
|
}else {
|
return 3;
|
}
|
if(response3 == null) {
|
return 4; //1操作失败
|
}
|
return (int)jsonObject3.get("code");
|
}
|
|
@Override
|
public Integer cleanFingerInfo(MjFingerprintReadHead fingerprintReadHead) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", fingerprintReadHead.getIpOrOther());
|
map.add("port", fingerprintReadHead.getPort());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktResetDataNew", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
return (int)jsonObject.get("code");
|
}
|
|
@Override
|
public Integer restartHead(MjFingerprintReadHead fingerprintReadHead) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", fingerprintReadHead.getIpOrOther());
|
map.add("port", fingerprintReadHead.getPort());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktRestartDevice", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
return (int)jsonObject.get("code");
|
}
|
|
@Override
|
public Integer getConnectStatus(MjFingerprintReadHead fingerprintReadHead) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", fingerprintReadHead.getIpOrOther());
|
map.add("port", fingerprintReadHead.getPort());
|
|
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktIsAlive", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
return (int)jsonObject.get("code");
|
}
|
|
@Override
|
public Integer register(MjFingerprintReadHead fingerprintReadHead) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
|
map.add("ip", fingerprintReadHead.getIpOrOther());
|
map.add("port", fingerprintReadHead.getPort());
|
|
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");
|
}
|
|
@Override
|
public List<MjWorkUser> getNewUser() {
|
List<MjWorkUser> list = mjWorkUserMapper.selectNewUser();
|
return list;
|
}
|
}
|
