package com.skyline.electricity.timer;
|
|
import org.springframework.stereotype.*;
|
import org.springframework.context.annotation.*;
|
import org.springframework.beans.factory.annotation.*;
|
import org.springframework.messaging.simp.*;
|
|
import java.text.ParseException;
|
import java.util.concurrent.*;
|
import com.skyline.electricity.service.*;
|
import com.vividsolutions.jts.geom.*;
|
import java.text.*;
|
import java.nio.charset.*;
|
import org.springframework.http.converter.*;
|
import org.springframework.web.client.*;
|
import com.vividsolutions.jts.io.*;
|
import com.alibaba.fastjson.*;
|
import org.springframework.http.*;
|
import java.util.*;
|
import org.springframework.scheduling.annotation.*;
|
import org.springframework.util.*;
|
import com.skyline.electricity.entity.*;
|
import com.skyline.electricity.pojo.*;
|
import com.skyline.electricity.controller.*;
|
import java.io.*;
|
import java.util.stream.Collectors;
|
|
import org.slf4j.*;
|
|
@Component
|
@Configuration
|
@EnableScheduling
|
public class SchedulerTask
|
{
|
private static Logger log;
|
public static List<PersonPosition> personlocationentity;
|
@Autowired
|
private ConfigInfo configInfo;
|
private static int locationEnable;
|
@Autowired
|
SimpMessagingTemplate simpMessagingTemplate;
|
@Autowired
|
private DetectService detectService;
|
@Autowired
|
private OutService outService;
|
private ConcurrentHashMap cmap;
|
@Autowired
|
private RemoteController remoteController;
|
@Autowired
|
private InfoSynchService infoSynchService;
|
|
@Autowired
|
private DeviceController deviceController ;
|
@Autowired
|
private InformationService informationService ;
|
|
|
@Autowired
|
WebSocketController webSocketController ;
|
|
|
GeometryFactory geometryFactory;
|
WKTReader reader;
|
private Point point;
|
private Polygon polygon;
|
private Map<Object, Object> map;
|
private static final SimpleDateFormat dateFormat;
|
public Integer mux;
|
|
public SchedulerTask() {
|
this.cmap = new ConcurrentHashMap();
|
this.geometryFactory = new GeometryFactory();
|
this.reader = new WKTReader(this.geometryFactory);
|
this.map = new HashMap<Object, Object>();
|
this.mux = 1;
|
}
|
// 读取information表数据，此表保留用户最后一次定位信息
|
@Scheduled(fixedRate = 5000L)
|
public void webSocketGetInfo( ) {
|
|
List<String> list = informationService.listInformations().stream().map(r->r.getXy()).collect(Collectors.toList());
|
|
List<RetInfo> rlist = new ArrayList<>();
|
list.stream().forEach(r->rlist.add(JSONObject.parseObject(r,RetInfo.class))) ;
|
if( list != null && list.size() > 0){
|
System.out.println("scheduled....push size:"+list.size());
|
webSocketController.sendAllMessage(JSONObject.toJSONString(rlist));
|
}
|
// System.out.println( "websocket status ..["+JSONObject.toJSONString(rlist)+"]" );
|
//推送报警信息
|
//pushIM(rlist);
|
}
|
|
/**
|
* {
|
* "type":"3",
|
* "source":"2",
|
* "vedioUrl":"",
|
* "cameraCode":"",
|
* "cameraName":"",
|
* "startDate":"1234567890",
|
* "warnName": "张三进入围栏大厂区"
|
* }
|
*/
|
@Async
|
public void pushIM(List<RetInfo> rlist){
|
final RestTemplate template = new RestTemplate();
|
Map<String, String> map = new HashMap<>();
|
|
rlist.stream().forEach((k) -> {
|
// if( k.getStatus().equals("ok")) return ;
|
//System.out.println( "k====="+k.getLongitude()+" "+k.getLatitude()) ;
|
MonitorInfo monitor = informationService.queryMinDistance(k.getLongitude(),k.getLatitude());
|
if( monitor == null ) return ;
|
|
//严谨的处理应该有判断高度，这里暂时不处理
|
|
map.put("type", "3");
|
map.put("source", "2");
|
map.put("vedioUrl", monitor.getHk_rtsp());
|
map.put("cameraCode", monitor.getMonitor_id());
|
map.put("cameraName", monitor.getMonitor_name());
|
Date date = new Date();
|
// try {
|
// date = DateFormat.getDateInstance().parse(k.getStartTime());
|
// } catch (ParseException e) {
|
// e.printStackTrace();
|
// date = new Date();
|
// }
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String formattedDate = sdf.format(date);
|
map.put("startDate",formattedDate);
|
map.put("warnName", k.getUserName()+"进入"+k.getFence_name());
|
String url = configInfo.getWarn_url();
|
//System.out.println( "post url warning "+url) ;
|
//System.out.println( "post url warning "+configInfo.getServer_url()) ;
|
url = "http://10.69.206.205:8080/a/ew/ewWarning/warning";
|
ResponseEntity<String> result = template.postForEntity(url, map,String.class);
|
//System.out.println("【user info】:"+result);
|
|
});
|
|
}
|
|
|
// @Scheduled(fixedRate = 5000L)
|
public void getInfo() {
|
final RestTemplate template = new RestTemplate();
|
final Map<String, String> configInfo = (Map<String, String>)this.remoteController.getConfigInfo();
|
final String appid = configInfo.get("appid");
|
final String tenantId = configInfo.get("tenantId");
|
final String secret = configInfo.get("secret");
|
final String coUrl = configInfo.get("coUrl");
|
final String imUrl = configInfo.get("imUrl");
|
final String dzzzUrl = configInfo.get("dzzzUrl");
|
final String shopId = configInfo.get("shopId");
|
final String modId = configInfo.get("modId");
|
final String modKey = configInfo.get("modKey");
|
final Integer pageNum = Integer.parseInt(configInfo.get("pageNum"));
|
final Integer pageSize = Integer.parseInt(configInfo.get("pageSize"));
|
final Integer value = Integer.parseInt(configInfo.get("value"));
|
final String safeSystem_ip = configInfo.get("safeSystem_ip");
|
final String senderName = "围栏预警";
|
final String url = safeSystem_ip + "/a/in/api/woWt/savePersonAccess";
|
template.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
|
final HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
final HttpHeaders header = new HttpHeaders();
|
header.setContentType(MediaType.APPLICATION_JSON_UTF8);
|
final Map<String, Object> configMap = new HashMap<String, Object>();
|
configMap.put("appid", appid);
|
configMap.put("secret", secret);
|
configMap.put("tenantId", tenantId);
|
// ResponseEntity<String> response = null;
|
// try {
|
// response = (ResponseEntity<String>)template.getForEntity(coUrl + "/oapi/gettoken?appid={appid}&secret={secret}&tenantId={tenantId}", (Class)String.class, (Map)configMap);
|
//
|
// }
|
// catch (RestClientException e7) {
|
// for (int i = 0; i < 10; ++i) {
|
// response = (ResponseEntity<String>)template.getForEntity(coUrl + "/oapi/gettoken?appid={appid}&secret={secret}&tenantId={tenantId}", (Class)String.class, (Map)configMap);
|
// }
|
// }
|
// final String body = (String)response.getBody();
|
// System.out.println("weilan resp:["+body+"]");
|
// final JSONObject jsonObjectResult = JSONObject.parseObject(body);
|
// final String access_token = jsonObjectResult.getString("access_token");
|
final String access_token = "";
|
final MultiValueMap<String, String> params = (MultiValueMap<String, String>)new LinkedMultiValueMap();
|
params.add("token", access_token);
|
params.add("senderName", senderName);
|
params.add("sender", appid);
|
final JSONObject message = new JSONObject();
|
final List<String> recipientsIds = (List<String>)this.infoSynchService.getRecipientsIds();
|
final StringBuffer stringBuffer = new StringBuffer();
|
for (int j = 0; j < recipientsIds.size(); ++j) {
|
if (j != recipientsIds.size() - 1) {
|
stringBuffer.append(recipientsIds.get(j) + ",");
|
}
|
else {
|
stringBuffer.append(recipientsIds.get(j));
|
}
|
}
|
message.put("recipient", (Object)stringBuffer.toString().trim());
|
message.put("msgId", (Object)UUID.randomUUID().toString());
|
message.put("displayType", (Object)"microapp");
|
message.put("handleState", (Object)"false");
|
final JSONObject msg = new JSONObject();
|
msg.put("type", (Object)"text");
|
msg.put("url", (Object)"");
|
msg.put("redirectUrl", (Object)"");
|
msg.put("fun", (Object)"");
|
msg.put("avatar", (Object)"");
|
final Map<Object, Object> map = new HashMap<Object, Object>();
|
final Map<String, Object> locations = (Map<String, Object>)this.remoteController.getMultiPersonlocations(shopId, modId, modKey, pageNum, pageSize, (int)value);
|
//final List<PersonPosition> list = SchedulerTask.personlocationentity = locations.get("list");
|
final List<PersonPosition> list = (List<PersonPosition>)locations.get("list");
|
final List<Map<String, Object>> personlist = new ArrayList<Map<String, Object>>();
|
final Iterator<PersonPosition> it = list.iterator();
|
while (it.hasNext()) {
|
final PersonPosition p = it.next();
|
if (p.getAlitude() == null || p.getLatitude() == null || p.getLongitude() == null) {
|
it.remove();
|
}
|
}
|
final List<FencePosition> fencePositionList = (List<FencePosition>)this.detectService.getFenceInfoByStatus();
|
final Information information = new Information();
|
final String glpoly = this.configInfo.getGl();
|
final String qjpoly = this.configInfo.getQj();
|
Polygon glpolygon = null;
|
Polygon qjpolygon = null;
|
try {
|
glpolygon = (Polygon)this.reader.read("POLYGON((" + glpoly + "))");
|
qjpolygon = (Polygon)this.reader.read("POLYGON((" + qjpoly + "))");
|
}
|
catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
final List<Map<String, Object>> fixedPolygon = new ArrayList<Map<String, Object>>();
|
double startaltitude = 0.0;
|
double endaltitude = 6.3;
|
for (int k = 1; k < 4; ++k) {
|
final Map<String, Object> polyinfo = new HashMap<String, Object>();
|
polyinfo.put("polygon", qjpolygon.toString());
|
polyinfo.put("startaltitude", startaltitude);
|
polyinfo.put("endaltitude", endaltitude);
|
polyinfo.put("name", "qj" + k);
|
startaltitude += 6.3;
|
endaltitude += 6.3;
|
fixedPolygon.add(polyinfo);
|
}
|
startaltitude = 0.0;
|
endaltitude = 6.3;
|
for (int k = 1; k < 3; ++k) {
|
final Map<String, Object> polyinfo = new HashMap<String, Object>();
|
polyinfo.put("polygon", glpolygon.toString());
|
polyinfo.put("startaltitude", startaltitude);
|
polyinfo.put("endaltitude", endaltitude);
|
if (k == 2) {
|
polyinfo.put("name", "gl3");
|
}
|
else {
|
polyinfo.put("name", "gl" + k);
|
}
|
startaltitude += 12.6;
|
endaltitude += 12.6;
|
fixedPolygon.add(polyinfo);
|
}
|
int personcount = 0;
|
SchedulerTask.log.warn("人员位置list" + list.toString());
|
if (list.size() > 0) {
|
for (int l = 0; l < fixedPolygon.size(); ++l) {
|
personcount = 0;
|
personlist.clear();
|
for (int m = 0; m < list.size(); ++m) {
|
final String compoint = list.get(m).getLongitude() + " " + list.get(m).getLatitude();
|
final String userId = list.get(m).getUserId();
|
try {
|
this.point = (Point)this.reader.read("POINT(" + compoint + ")");
|
}
|
catch (Exception e2) {
|
e2.printStackTrace();
|
}
|
if (this.point != null) {
|
map.put("point", this.point.toString());
|
}
|
map.put("polygon", fixedPolygon.get(l).get("polygon"));
|
final String flag = this.detectService.judge((Map)map);
|
final boolean mark = Double.parseDouble(list.get(m).getAlitude()) > Double.parseDouble(fixedPolygon.get(l).get("startaltitude").toString()) && Double.parseDouble(list.get(m).getAlitude()) < Double.parseDouble(fixedPolygon.get(l).get("endaltitude").toString());
|
if (flag.equals("t") && mark) {
|
final Map<String, Object> tempmap = new HashMap<String, Object>();
|
tempmap.put("workid", fixedPolygon.get(l).get("name"));
|
tempmap.put("userid", list.get(m).getUserId().toString());
|
personlist.add(tempmap);
|
++personcount;
|
}
|
if (m == list.size() - 1) {
|
this.detectService.insertfixareaPersonRel((List)personlist, fixedPolygon.get(l).get("name").toString(), personcount);
|
}
|
}
|
}
|
for (int l = 0; l < fencePositionList.size(); ++l) {
|
personcount = 0;
|
personlist.clear();
|
final String workId = fencePositionList.get(l).getWorkId();
|
final List<String> allowList = (List<String>)this.infoSynchService.selectAllowList(workId);
|
try {
|
this.polygon = (Polygon)this.reader.read("POLYGON((" + fencePositionList.get(l).getFenceposition() + "))");
|
}
|
catch (Exception e3) {
|
e3.printStackTrace();
|
}
|
for (int j2 = 0; j2 < list.size(); ++j2) {
|
final String compoint2 = list.get(j2).getLongitude() + " " + list.get(j2).getLatitude();
|
final String userId2 = list.get(j2).getUserId();
|
final boolean isExist = allowList.contains(userId2);
|
final Information info = this.detectService.selectPosition(userId2, fencePositionList.get(l).getWorkId());
|
try {
|
this.point = (Point)this.reader.read("POINT(" + compoint2 + ")");
|
}
|
catch (Exception e4) {
|
e4.printStackTrace();
|
}
|
if (this.point != null) {
|
map.put("point", this.point.toString());
|
}
|
map.put("polygon", this.polygon.toString());
|
final String flag2 = this.detectService.judge((Map)map);
|
final boolean mark2 = Double.parseDouble(list.get(j2).getAlitude()) > fencePositionList.get(l).getStartaltitude() && Double.parseDouble(list.get(j2).getAlitude()) < fencePositionList.get(l).getEndaltitude();
|
if (flag2.equals("t") && mark2) {
|
final Map<String, Object> tempmap2 = new HashMap<String, Object>();
|
tempmap2.put("fname", fencePositionList.get(l).getFname());
|
tempmap2.put("workid", fencePositionList.get(l).getWorkId());
|
tempmap2.put("userid", list.get(j2).getUserId().toString());
|
personlist.add(tempmap2);
|
++personcount;
|
}
|
if (j2 == list.size() - 1) {
|
final FencePosition fencePost = fencePositionList.get(l);
|
fencePost.setPersoncount(Integer.valueOf(personcount));
|
this.detectService.updateFenceInfo(fencePost);
|
for (final Map<String, Object> map2 : personlist) {
|
map2.put("personcount", personcount);
|
}
|
this.detectService.insertFencePersonRel((List)personlist, fencePost.getWorkId());
|
}
|
if (info == null && mark2) {
|
if (flag2.equals("t")) {
|
information.setWtId(fencePositionList.get(l).getWorkId());
|
information.setUserId(list.get(j2).getUserId());
|
information.setUserName(list.get(j2).getUserName());
|
information.setStartTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()).toString());
|
information.setName(fencePositionList.get(l).getFname());
|
information.setFence_type(fencePositionList.get(l).getType());
|
information.setStatus("in");
|
SchedulerTask.log.warn("in调用插入时间 " + information.toString());
|
this.cmap.put(list.get(j2).getUserId(), 1);
|
final String json = JSON.toJSONString((Object)information);
|
this.detectService.insertInfo(information);
|
if (fencePositionList.get(l).getType().equals("temp")) {
|
final HttpEntity<MultiValueMap<String, String>> as_request = (HttpEntity<MultiValueMap<String, String>>)new HttpEntity((Object)json, (MultiValueMap)header);
|
template.postForEntity(url, (Object)as_request, (Class)String.class, new Object[0]);
|
SchedulerTask.log.warn("临时围栏工作票：+" + fencePositionList.get(l).getWorkId());
|
final List<Map> workleader = (List<Map>)this.detectService.selectWorkLeader(fencePositionList.get(l).getWorkId());
|
SchedulerTask.log.warn("工作票负责人" + workleader.toString());
|
if (workleader.get(0).get("id").equals(list.get(j2).getUserId())) {
|
SchedulerTask.log.warn(list.get(j2).getUserName() + "该员工是工作票负责人");
|
final Information lastInformation = this.detectService.queryInformation(information.getWtId(), workleader.get(0).get("id").toString());
|
SchedulerTask.log.warn("上次的出记录" + lastInformation.toString());
|
SchedulerTask.log.warn("本次出入记录" + information.toString());
|
if (lastInformation != null) {
|
final String startWorkTimeAM = new SimpleDateFormat("yyyy-MM-dd").format(new Date()).toString() + " 08:30";
|
final String endWorkTimeAM = new SimpleDateFormat("yyyy-MM-dd").format(new Date()).toString() + " 11:30";
|
final String startWorkTimePM = new SimpleDateFormat("yyyy-MM-dd").format(new Date()).toString() + " 13:30";
|
final String endWorkTimePM = new SimpleDateFormat("yyyy-MM-dd").format(new Date()).toString() + " 17:30";
|
final String currentTime = information.getStartTime();
|
final String lastTime = lastInformation.getStartTime();
|
boolean fig = false;
|
try {
|
final Date now = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(currentTime);
|
final Date date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(lastTime);
|
final long l2 = (now.getTime() - date.getTime()) / 1000L / 60L;
|
if (l2 > 10L) {
|
if (lastTime.compareTo(startWorkTimeAM) > 0 && lastTime.compareTo(endWorkTimeAM) < 0 && currentTime.compareTo(startWorkTimeAM) > 0 && currentTime.compareTo(endWorkTimeAM) < 0) {
|
fig = true;
|
}
|
if (currentTime.compareTo(startWorkTimePM) > 0 && currentTime.compareTo(endWorkTimePM) < 0 && lastTime.compareTo(startWorkTimePM) > 0 && lastTime.compareTo(endWorkTimePM) < 0) {
|
fig = true;
|
}
|
}
|
if (fig) {
|
SchedulerTask.log.warn("推送信息给工作台");
|
msg.put("title", (Object)"离开工作票区域超时告警");
|
final String enter_msg = "工作票负责人:" + workleader.get(0).get("name") + "离开" + fencePositionList.get(l).getFname() + "\u56f4\u680f\uff0c\u65f6\u95f4" + l2 + "\u5206\u949f";
|
msg.put("msg", (Object)enter_msg);
|
message.put("message", (Object)msg.toString());
|
SchedulerTask.log.warn("gengxin");
|
this.detectService.updateFenceAlarmCount(fencePositionList.get(l).getWorkId());
|
SchedulerTask.log.warn("gengxinwanchen");
|
SchedulerTask.log.warn("工作票负责人告警前");
|
this.pushMessage(list.get(j2).getUserId(), dzzzUrl, imUrl, tenantId, params, headers, template, configMap, message);
|
SchedulerTask.log.warn("工作票负责人告警后");
|
}
|
}
|
catch (Exception e5) {
|
e5.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|
}
|
else if (info != null) {
|
SchedulerTask.log.warn("1");
|
if (flag2.equals("t") && mark2) {
|
SchedulerTask.log.warn("2");
|
if (!isExist) {
|
SchedulerTask.log.warn("3");
|
if (list.get(j2).getType().equals("UWB") && !fencePositionList.get(l).getType().equals("temp")) {
|
final Information entryinfo = this.detectService.selectPosition(userId2, fencePositionList.get(l).getWorkId());
|
SchedulerTask.log.warn("固定围栏进入记录" + entryinfo.toString());
|
Date entrydata = null;
|
try {
|
entrydata = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(entryinfo.getStartTime());
|
}
|
catch (Exception e6) {
|
SchedulerTask.log.warn(e6.toString());
|
e6.printStackTrace();
|
}
|
SchedulerTask.log.warn("时间判断" + (System.currentTimeMillis() - entrydata.getTime() > 20000L) + (System.currentTimeMillis() - entrydata.getTime() < 25000L));
|
SchedulerTask.log.warn(this.cmap.toString());
|
if (System.currentTimeMillis() - entrydata.getTime() > 20000L) {
|
synchronized (this.mux) {
|
final int a = l;
|
final int b = j2;
|
if (this.cmap.containsKey(userId2)) {
|
this.cmap.remove(list.get(b).getUserId());
|
SchedulerTask.log.warn("固定围栏进入超过1分钟");
|
msg.put("title", (Object)"异常进入告警");
|
final String quit_msg = "未授权人" + list.get(b).getUserName() + "进入" + fencePositionList.get(a).getFname();
|
msg.put("msg", (Object)quit_msg);
|
message.put("message", (Object)msg.toString());
|
SchedulerTask.log.warn("推送标签前" + msg.toString());
|
final Object uwbBody = this.remoteController.sendMessageToUWB(list.get(b).getShopId(), list.get(b).getUserId(), Integer.valueOf(0), "BELL_VIBRATE");
|
SchedulerTask.log.warn("推送标签后");
|
SchedulerTask.log.warn("uwp固定围栏报警开始");
|
SchedulerTask.log.warn("更新预警次数" + fencePositionList.get(a).getWorkId());
|
this.detectService.updateFenceAlarmCount(fencePositionList.get(a).getWorkId());
|
SchedulerTask.log.warn("更新预警次数完成");
|
this.pushCommonMessage(list.get(b).getUserId(), dzzzUrl, imUrl, tenantId, params, headers, template, configMap, message);
|
SchedulerTask.log.warn("uwp固定围栏报警结束");
|
SchedulerTask.log.warn("cmap清除" + list.get(b).getUserId());
|
}
|
}
|
}
|
}
|
}
|
}
|
else {
|
if (this.cmap.contains(userId2)) {
|
this.cmap.remove(userId2);
|
}
|
SchedulerTask.log.warn(this.cmap.toString());
|
this.detectService.changeStatus(userId2, fencePositionList.get(l).getWorkId());
|
SchedulerTask.log.warn("改变状态" + userId2.toString());
|
information.setUserId(list.get(j2).getUserId());
|
information.setUserName(list.get(j2).getUserName());
|
information.setWtId(fencePositionList.get(l).getWorkId());
|
information.setStartTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()).toString());
|
information.setName(fencePositionList.get(l).getFname());
|
information.setFence_type(fencePositionList.get(l).getType());
|
information.setStatus("out");
|
final String json = JSON.toJSONString((Object)information);
|
SchedulerTask.log.warn("out\u8c03\u7528" + information.toString());
|
this.detectService.insertInfo(information);
|
if (fencePositionList.get(l).getType().equals("temp")) {
|
final HttpEntity<MultiValueMap<String, String>> request = (HttpEntity<MultiValueMap<String, String>>)new HttpEntity((Object)json, (MultiValueMap)header);
|
template.postForEntity(url, (Object)request, (Class)String.class, new Object[0]);
|
}
|
}
|
}
|
}
|
}
|
}
|
else {
|
this.detectService.delAllFencePersonRel();
|
}
|
}
|
|
|
public void pushMessage(final String userid, final String dzzzUrl, final String imUrl, final String tenantId, final MultiValueMap<String, String> params, final HttpHeaders headers, final RestTemplate template, final Map<String, Object> configMap, final JSONObject message) {
|
final StringBuilder recipent = new StringBuilder(message.get((Object)"recipient").toString());
|
final List<Map> zhurenlist = (List<Map>)this.detectService.selectDepartDeputyDirectorByStaffid(userid);
|
if (',' != recipent.charAt(recipent.length() - 1)) {
|
recipent.append(",");
|
}
|
for (final Map zhuren : zhurenlist) {
|
recipent.append(zhuren.get("id")).append(",");
|
}
|
SchedulerTask.log.warn("recip" + recipent.toString());
|
SchedulerTask.log.warn("当值值长");
|
SchedulerTask.log.warn("configMap" + configMap.toString());
|
final String dzzzresponse = (String)template.getForObject(dzzzUrl, (Class)String.class, new Object[0]);
|
final JSONObject json = JSONObject.parseObject(dzzzresponse);
|
SchedulerTask.log.warn(dzzzresponse.toString());
|
SchedulerTask.log.warn(json.getJSONObject("data").getString("id"));
|
//System.out.println(json.getJSONObject("data").getString("id"));
|
if (',' == recipent.charAt(recipent.length() - 1)) {
|
recipent.append(json.getJSONObject("data").getString("id"));
|
}
|
else {
|
recipent.append(',' + json.getJSONObject("data").getString("id"));
|
}
|
message.put("recipient", recipent.toString());
|
params.add("message", message.toString());
|
final HttpEntity<MultiValueMap<String, String>> httpEntity = (HttpEntity<MultiValueMap<String, String>>)new HttpEntity((Object)params, (MultiValueMap)headers);
|
SchedulerTask.log.warn("推送参数" + params.toString());
|
SchedulerTask.log.warn("推送实体httpEnitty", (Object)httpEntity.toString());
|
final ResponseEntity responseEntity = template.postForEntity(imUrl + "/oapi/message/sendworkmsg?tenantId=" + tenantId, (Object)httpEntity, (Class)String.class, new Object[0]);
|
SchedulerTask.log.warn("推送结果" + responseEntity.toString());
|
}
|
|
public void pushCommonMessage(final String userid, final String dzzzUrl, final String imUrl, final String tenantId, final MultiValueMap<String, String> params, final HttpHeaders headers, final RestTemplate template, final Map<String, Object> configMap, final JSONObject message) {
|
final StringBuilder recipent = new StringBuilder(message.get((Object)"recipient").toString());
|
if (',' != recipent.charAt(recipent.length() - 1)) {
|
recipent.append(",");
|
}
|
final List<Map> zhurenlist = (List<Map>)this.detectService.selectDepartDeputyDirectorByStaffid(userid);
|
for (final Map zhuren : zhurenlist) {
|
recipent.append(zhuren.get("id")).append(",");
|
}
|
SchedulerTask.log.warn("recip" + recipent.toString());
|
SchedulerTask.log.warn("当值值长");
|
SchedulerTask.log.warn("configMap" + configMap.toString());
|
final List<Map> outlist = (List<Map>)this.outService.selectExternPeople(userid);
|
for (final Map map : outlist) {
|
recipent.append(map.get("PRO_LEADER").toString() + ",");
|
}
|
final String dzzzresponse = (String)template.getForObject(dzzzUrl, (Class)String.class, new Object[0]);
|
final JSONObject json = JSONObject.parseObject(dzzzresponse);
|
SchedulerTask.log.warn(dzzzresponse.toString());
|
SchedulerTask.log.warn(json.getJSONObject("data").getString("id"));
|
//System.out.println(json.getJSONObject("data").getString("id"));
|
if (',' == recipent.charAt(recipent.length() - 1)) {
|
recipent.append(json.getJSONObject("data").getString("id"));
|
}
|
else {
|
recipent.append(',' + json.getJSONObject("data").getString("id"));
|
}
|
message.put("recipient", recipent.toString());
|
params.add("message", message.toString());
|
final HttpEntity<MultiValueMap<String, String>> httpEntity = (HttpEntity<MultiValueMap<String, String>>)new HttpEntity((Object)params, (MultiValueMap)headers);
|
SchedulerTask.log.warn("推送参数" + params.toString());
|
SchedulerTask.log.warn("推送实体httpEnitty", (Object)httpEntity.toString());
|
final ResponseEntity responseEntity = template.postForEntity(imUrl + "/oapi/message/sendworkmsg?tenantId=" + tenantId, (Object)httpEntity, (Class)String.class, new Object[0]);
|
SchedulerTask.log.warn("推送结果" + responseEntity.toString());
|
}
|
|
// @Scheduled(fixedRate = 5000L)
|
public void changeFenceStatus() {
|
final List<FencePosition> fencePositions = (List<FencePosition>)this.detectService.getTempFenceInfo();
|
for (final FencePosition fencePosition : fencePositions) {
|
if (!StringUtils.isEmpty((Object)fencePosition.getStarttime()) && StringUtils.isEmpty((Object)fencePosition.getDisabledtime())) {
|
if (SchedulerTask.dateFormat.format(new Date()).compareTo(fencePosition.getStarttime()) >= 0) {
|
this.detectService.setFenceEnabledByStartTime(fencePosition.getWorkId());
|
}
|
else {
|
this.detectService.setFenceDisabled(fencePosition.getWorkId());
|
}
|
}
|
else if (!StringUtils.isEmpty((Object)fencePosition.getStarttime()) && !StringUtils.isEmpty((Object)fencePosition.getDisabledtime())) {
|
if (SchedulerTask.dateFormat.format(new Date()).compareTo(fencePosition.getDisabledtime()) <= 0 && SchedulerTask.dateFormat.format(new Date()).compareTo(fencePosition.getStarttime()) >= 0) {
|
this.detectService.setFenceEnabled(fencePosition.getWorkId());
|
}
|
else {
|
if (SchedulerTask.dateFormat.format(new Date()).compareTo(fencePosition.getDisabledtime()) < 0 && SchedulerTask.dateFormat.format(new Date()).compareTo(fencePosition.getStarttime()) > 0) {
|
continue;
|
}
|
this.detectService.setFenceDisabled(fencePosition.getWorkId());
|
}
|
}
|
else {
|
if (!StringUtils.isEmpty((Object)fencePosition.getStarttime())) {
|
continue;
|
}
|
this.detectService.setFenceDisabled(fencePosition.getWorkId());
|
}
|
}
|
}
|
|
// @Scheduled(fixedRate = 60000L)
|
public void setRecipients() {
|
final List<Recipients> recipients_list = (List<Recipients>)this.infoSynchService.selectRecipients();
|
final List<Recipients> recipients = (List<Recipients>)this.infoSynchService.getRecipients();
|
for (final Recipients recipient : recipients_list) {
|
if (!recipients.contains(recipient)) {
|
this.infoSynchService.setRecipients(recipient);
|
}
|
}
|
}
|
|
public void setPermissions() {
|
final List<Permissions> permissions_list = (List<Permissions>)this.infoSynchService.selectPermissions();
|
final List<Permissions> permissions = (List<Permissions>)this.infoSynchService.getPermissions();
|
for (final Permissions permission : permissions_list) {
|
if (!permissions.contains(permission)) {
|
this.infoSynchService.setPermissions(permission);
|
}
|
}
|
}
|
|
// @Scheduled(fixedRate = 300000L)
|
public void setWhiteList() {
|
final List<Fence_User> list = (List<Fence_User>)this.infoSynchService.selectWhiteList();
|
final List<FencePosition> fenceList = (List<FencePosition>)this.detectService.getFixedFenceInfo();
|
for (int i = 0; i < fenceList.size(); ++i) {
|
final String workId = fenceList.get(i).getWorkId();
|
for (final Fence_User user : list) {
|
user.setWorkId(workId);
|
final Fence_User fence_user = this.infoSynchService.selectUniqueInfo(user);
|
if (fence_user == null) {
|
this.infoSynchService.insertWhiteList(user);
|
}
|
}
|
}
|
}
|
|
//@Scheduled(fixedRate = 5000L)
|
public void test() {
|
SchedulerTask.locationEnable = this.configInfo.getLocationEnable();
|
if (SchedulerTask.locationEnable == 1) {
|
final Map<String, Object> map = new HashMap<String, Object>();
|
if (SchedulerTask.personlocationentity != null) {
|
map.put("list", SchedulerTask.personlocationentity);
|
}
|
try {
|
WebSocketServer.BroadCastInfo(JSONObject.toJSONString((Object)map));
|
}
|
catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
public static void main(final String[] args) {
|
}
|
|
static {
|
SchedulerTask.log = LoggerFactory.getLogger((Class)SchedulerTask.class);
|
SchedulerTask.personlocationentity = null;
|
dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
}
|
}
|
