package com.terra.lfdcexp.entity;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.terra.lfdcexp.service.WeilanMonService;
|
import com.terra.lfdcexp.util.HttpClientUtil;
|
import com.terra.lfdcexp.util.JsonUtils;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Data
|
@Slf4j
|
public class FenceEntityVo {
|
|
@Value("${http.alertinfo}")
|
private String http_alertinfo;
|
@Value("${http.topost}")
|
private String topost_alertinfo;
|
@Autowired
|
WeilanMonService weilanMonService ;
|
private List<FenceEntity> fenceEntityList;
|
|
private void parser(String json) {
|
if (fenceEntityList == null) {
|
fenceEntityList = new ArrayList<FenceEntity>();
|
}
|
|
fenceEntityList = JSON.parseArray(json, FenceEntity.class);
|
System.out.println("parse fenceEntity" + fenceEntityList.size());
|
|
}
|
|
public List<FenceEntity> isAlert(String msg) {
|
parser(msg);
|
if (fenceEntityList == null) return new ArrayList<FenceEntity>();
|
List<FenceEntity> fenceList =
|
fenceEntityList.stream().filter(line -> (line.getEvents().indexOf("21") > -1)) // 过滤掉cjavapy
|
.collect(Collectors.toList());
|
//code = 21 报警
|
/**
|
* 报警围栏数组与报警信息数据，通过usrname比较，相同的发送
|
*/
|
if (fenceList.size() > 0) {
|
|
String alertInfoJson = HttpClientUtil.doGet(http_alertinfo);
|
AlertInfoVo alertInfoVo = new AlertInfoVo();
|
alertInfoVo.parser(alertInfoJson);
|
List<AlertInfo> alertInfoInList = alertInfoVo.getStatusInList();
|
if (alertInfoInList != null && alertInfoInList.size() > 0)
|
for (FenceEntity f : fenceList) {
|
for(AlertInfo a: alertInfoInList){
|
if( a.getUserName().equals(f.getUserName())){
|
//通过围栏获取摄像头id，这里只获取一个摄像头
|
WeilanMonEntity w = weilanMonService.getOne(new QueryWrapper<WeilanMonEntity>().eq("f_id",a.getWtId()));
|
WarnEntity warnEntity = new WarnEntity();
|
if( w != null) {
|
warnEntity.setCameraCode(w.getGId());
|
warnEntity.setType("3");
|
warnEntity.setSource("1");
|
warnEntity.setStartDate(a.getStartTime());
|
warnEntity.setWarnName(f.getUserName() + "进入" + a.getName() + "围栏");
|
String retFromTopost = HttpClientUtil.doPostJson(topost_alertinfo, JsonUtils.toJson(warnEntity));
|
log.info(retFromTopost+"\n"+JsonUtils.toJson(warnEntity)+"\n");
|
}
|
}
|
}
|
}
|
|
}
|
|
|
return null;
|
|
}
|
}
|
