package com.ld.igds.protocol.snap;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.camera.data.ApiSnapReq;
|
import com.ld.igds.file.CoreFileService;
|
import com.ld.igds.file.dto.FileData;
|
import com.ld.igds.models.SnapSer;
|
import com.ld.igds.protocol.snap.server.Message;
|
import com.ld.igds.protocol.snap.server.SnapServerEngine;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.view.service.SnapSerService;
|
import com.ld.igds.warn.data.WarnData;
|
import com.ld.igds.constant.WarnLevel;
|
import com.ld.igds.constant.WarnStatus;
|
import com.ld.igds.constant.WarnType;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.time.DateFormatUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
|
|
/**
|
* 抓拍结果返回
|
*/
|
@Slf4j
|
@Component(AnalysisService.BEAN_ID)
|
public class AnalysisService {
|
|
public static final String BEAN_ID = "snap.analysisService";
|
|
@Autowired
|
private SnapSerService snapSerService;
|
@Autowired
|
private CoreFileService fileService;
|
|
/**
|
* 解析插件返回的信息
|
*
|
* @param message
|
*/
|
public void analysis(Message message) {
|
|
log.info("抓拍插件--->平台--{}", message.toString());
|
|
//添加心跳维持信息
|
SnapUtils.addHeartBeat(message.getIp(), message.getPort());
|
|
//新设备上线
|
if (message.getFunctionId().equals(SnapUtils.FUNC_ID_0)) {
|
|
SnapServerEngine.updateKey(message.getIp(), message.getPort(), message.getSn());
|
|
snapSerService.connectAdd(message.getSn(), message.getIp(), message.getPort());
|
|
log.info("++++抓拍插件登录认证完成++++-SN={}", message.getSn());
|
}
|
|
//抓拍结果返回
|
if (message.getFunctionId().equals(SnapUtils.FUNC_ID_1)) {
|
|
JSONObject jsonContent = JSONObject.parseObject(message.getContent());
|
|
String imgData = (String) jsonContent.get("data");
|
|
if ("error".equals(imgData) || StringUtils.isEmpty(imgData)) {
|
SnapUtils.removeRequest(message.getOrderId().toString());
|
log.error("抓拍插件--->平台--终端抓拍插件抓拍失败.");
|
return;
|
}
|
|
this.analysisImg2Disk(message.getOrderId(), imgData);
|
}
|
|
//事件通知
|
if (message.getFunctionId().equals(SnapUtils.FUNC_ID_2)) {
|
|
|
JSONObject jsonContent = JSONObject.parseObject(message.getContent());
|
|
String action = (String) jsonContent.get("action");
|
|
//断电
|
if (SnapUtils.ACTION_CODE_10.equals(action)) {
|
SnapSer snapSer = snapSerService.getCacheBySn(message.getSn());
|
|
WarnData warnData = new WarnData();
|
warnData.setCompanyId(snapSer.getCompanyId());
|
warnData.setDepotId(snapSer.getDeptId());
|
warnData.setId(ContextUtil.getUUID());
|
warnData.setLevel(WarnLevel.LEVEL_01.getCode());
|
warnData.setName("库区断电警告");
|
warnData.setStatus(WarnStatus.STATUS_10.getCode());
|
warnData.setTime(new Date());
|
warnData.setType(WarnType.TYPE_01.getCode());
|
warnData.setInfo("系统收到库区断电警告通知，已经启动断电抓拍逻辑，请联系库区核对断电原因，时间：" + DateFormatUtils.format(warnData.getTime(), "yyyy-MM-dd HH:mm"));
|
|
|
//TODO 逻辑待调整
|
// coreWarnService.addWarn(warnData);
|
}
|
|
//上电
|
if (SnapUtils.ACTION_CODE_11.equals(action)) {
|
SnapSer snapSer = snapSerService.getCacheBySn(message.getSn());
|
|
WarnData warnData = new WarnData();
|
warnData.setCompanyId(snapSer.getCompanyId());
|
warnData.setDepotId(snapSer.getDeptId());
|
warnData.setId(ContextUtil.getUUID());
|
warnData.setType(WarnType.TYPE_03.getCode());
|
warnData.setName("库区上电通知");
|
warnData.setStatus(WarnStatus.STATUS_40.getCode());
|
warnData.setTime(new Date());
|
warnData.setLevel(WarnLevel.LEVEL_01.getCode());
|
warnData.setInfo("系统收到库区上电通知，时间：" + DateFormatUtils.format(warnData.getTime(), "yyyy-MM-dd HH:mm"));
|
|
//TODO 逻辑待调整
|
//coreWarnService.addWarn(warnData);
|
}
|
|
|
//主动心跳
|
if (SnapUtils.ACTION_CODE_20.equals(action)) {
|
log.debug("------------------抓拍插件心跳维持----------------");
|
}
|
}
|
}
|
|
|
private void analysisImg2Disk(Integer orderId, String imgData) {
|
ApiSnapReq apiSnapReq = SnapUtils.getRequest(orderId.toString());
|
if (null == apiSnapReq) {
|
log.error("----平台解析抓拍插件返回信息，没有获取到原来请求，解析失败.");
|
return;
|
}
|
|
log.debug("----抓拍返回----{}", apiSnapReq);
|
|
|
//如果没有外键信息，表示只保持图片即可，如果有则需要添加附件列表。
|
if (null == apiSnapReq.getBizId()) {
|
fileService.baseImg2Disk(apiSnapReq.getFilePath(), apiSnapReq.getFileName(), imgData);
|
} else {
|
if (null == apiSnapReq.getFilePath()) {
|
apiSnapReq.setFilePath(fileService.getCommonFilePath(new Date()));
|
}
|
if (null == apiSnapReq.getFileName()) {
|
apiSnapReq.setFileName(ContextUtil.getCurTimeMillis() + ".jpg");
|
}
|
|
FileData fileData = new FileData();
|
fileData.setFileId(ContextUtil.getUUID());
|
fileData.setCompanyId(ContextUtil.getDefaultCompanyId());
|
fileData.setBizId(apiSnapReq.getBizId());
|
fileData.setFileName(apiSnapReq.getFileName());
|
fileData.setBizTag(apiSnapReq.getCameraName());
|
fileData.setCreateTime(new Date());
|
fileService.addRecord(fileData);
|
|
//持久保存
|
fileService.baseImg2Disk(apiSnapReq.getFilePath(), apiSnapReq.getFileName(), imgData);
|
|
}
|
|
log.info("平台解析--抓拍插件照片成功--{}", apiSnapReq.getFilePath() + apiSnapReq.getFileName());
|
}
|
|
|
}
|
