package com.tievd.jyz.controller;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.tievd.cube.commons.annotations.DictApi;
|
import com.tievd.cube.commons.base.Result;
|
import com.tievd.jyz.constants.SystemConstant;
|
import com.tievd.jyz.mqtt.MqttMsgReceiver;
|
import com.tievd.jyz.mqtt.dto.SystemStatusDTO;
|
import com.tievd.jyz.util.MultiMinioUtil;
|
import com.tievd.jyz.util.StringCampareUtil;
|
import lombok.SneakyThrows;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.*;
|
|
@Slf4j
|
@DictApi
|
@RestController
|
@RequestMapping("/third")
|
public class ThirdController {
|
|
@Autowired
|
MqttMsgReceiver mqttMsgReceiver;
|
|
@Value("${third.aibox.url:http://25.30.13.30}")
|
String thirdBoxUrl;
|
|
@Value("${third.aibox.url:/api/v1/notify/config}")
|
String aiboxConfig;
|
|
@Autowired
|
MultiMinioUtil s3Util;
|
|
@Autowired
|
ApplicationContext context;
|
|
/**
|
* 第三方卸油 算法code map
|
*/
|
static Map<Integer, String> algCodeMap = new HashMap<>();
|
|
static {
|
algCodeMap.put(23, "X10001");
|
algCodeMap.put(24, "X10002");
|
algCodeMap.put(25, "X10004");
|
algCodeMap.put(26, "X10003");
|
algCodeMap.put(27, "X10006");
|
algCodeMap.put(28, "X10005");
|
algCodeMap.put(29, "X10007");
|
algCodeMap.put(30, "X10008");
|
}
|
|
//http://25.30.14.164:8080/cube/third/deviceHeart
|
@PostMapping("/deviceHeart")
|
public void deviceHeart(@RequestBody JSONObject param, HttpServletRequest request) {
|
log.info("=====>接收到卸油aibox心跳", param.toJSONString());
|
param.put("type", MqttMsgReceiver.REGISTER);
|
param.put("time", System.currentTimeMillis());
|
JSONObject data = new JSONObject();
|
data.put("deviceType", "AIbox");
|
data.put("version", param.get("soft_version"));
|
data.put("name", "AIbox卸油设备");
|
data.put("ip", request.getRemoteHost());
|
data.put("port", 80);
|
param.put("data", data);
|
|
mqttMsgReceiver.dealCommandMsg(param.toJSONString());
|
}
|
|
@SneakyThrows
|
@PostMapping("/oilOutEvent")
|
public void oilOutEvent(@RequestBody JSONObject thirdData) {
|
log.info("=====>接收到卸油aibox事件上报");
|
JSONArray events = thirdData.getJSONArray("oil_results");
|
if (CollectionUtils.isEmpty(events)) {
|
log.info("=====>接收到卸油aibox事件异常--未包含完整信息");
|
return;
|
}
|
JSONObject msgJson = new JSONObject();
|
msgJson.put("time", System.currentTimeMillis());
|
|
List eventList = new ArrayList();
|
List cameraList = new ArrayList();
|
for (int i = 0; i < events.size(); i++) {
|
JSONObject event = events.getJSONObject(i);
|
msgJson.putIfAbsent("sn", event.getString("serial_number"));
|
try {
|
//数据
|
JSONObject convertEvent = converEvent(event);
|
log.info("=====>转换卸油事件信息: {}", convertEvent.toJSONString());
|
eventList.add(convertEvent);
|
JSONObject camera = convertCamera(event);
|
cameraList.add(camera);
|
} catch (Exception e) {
|
log.error("第三方数据转换异常", e);
|
}
|
}
|
|
//上报摄像头数据--------
|
msgJson.put("type", MqttMsgReceiver.BASE_UPDATE);
|
msgJson.put("data", generateCameraMsg(cameraList));
|
mqttMsgReceiver.dealCommandMsg(msgJson.toJSONString());
|
Thread.sleep(5000);
|
//上报摄像头状态--------
|
msgJson.put("type", MqttMsgReceiver.HEARTBEAT);
|
msgJson.put("data", new JSONObject(){{
|
put("camera", cameraList);
|
put("system", new SystemStatusDTO());
|
}});
|
mqttMsgReceiver.dealCommandMsg(msgJson.toJSONString());
|
Thread.sleep(1000);
|
//上报事件数据----------
|
msgJson.put("type", MqttMsgReceiver.EVENT_INFO);
|
msgJson.put("data", eventList);
|
mqttMsgReceiver.dealEventMsg(msgJson.toJSONString());
|
|
}
|
|
/**
|
* 摄像头数据
|
* @param cameraList
|
* @return
|
*/
|
JSONObject generateCameraMsg(List cameraList) {
|
JSONObject cameraMsg = new JSONObject();
|
cameraMsg.put("mode", "inc");
|
cameraMsg.put("exist", new JSONObject(){{
|
put("cameras", cameraList);
|
}});
|
return cameraMsg;
|
}
|
|
public JSONObject convertCamera(JSONObject event) {
|
JSONObject camera = new JSONObject();
|
//主要数据
|
camera.put("code", event.getString("IPC_serial_num"));
|
camera.put("name", event.getString("channel_name"));
|
camera.put("ip", event.getString("IPC_addr"));
|
camera.put("rtsp", event.getString("IPC_addr"));
|
camera.put("installAddress", SystemConstant.INSTALL_ADDRESS_OIL_OUT);
|
camera.put("status", SystemConstant.DEVICE_ONLINE);
|
camera.put("updateTime", new Date().getTime());
|
return camera;
|
}
|
|
/**
|
* 事件信息
|
* @param event
|
* @return
|
*/
|
JSONObject converEvent(JSONObject event){
|
JSONObject convertEvent = new JSONObject();
|
//主要数据
|
convertEvent.put("eventCode", event.getString("process_id") + event.getString("step_id"));
|
|
//上传信息中无车牌号，暂时使用第三方的processId作为record id传入记录中
|
convertEvent.put("id", event.getString("process_id").substring(2));
|
convertEvent.put("eventType", event.getString("step_status"));
|
convertEvent.put("algCode", algCodeMap.get(event.getIntValue("step_type")));
|
convertEvent.put("cameraCode", event.getString("IPC_serial_num"));
|
convertEvent.put("code", event.getString("IPC_serial_num"));
|
convertEvent.put("cameraName", event.getString("channel_name"));
|
convertEvent.put("cameraIp", event.getString("IPC_addr"));
|
//采集时间，UTC 格式，单位s
|
long time = event.getLong("timestamp") + 8 * 60 * 60;
|
convertEvent.put("alarmTime", time);
|
|
//转s3地址
|
String imgType = event.getJSONObject("big_image").getString("ImageType");
|
String imgBase = event.getJSONObject("big_image").getString("Image");
|
byte[] imgByte = Base64.getDecoder().decode(imgBase);
|
String parentPath = "oilout/";
|
String key = s3Util.upload(imgByte, parentPath + convertEvent.getString("eventCode") + "." + imgType);
|
String url = s3Util.getBucketName() + SystemConstant.s3_split_char + key;
|
convertEvent.put("sourceType", imgType);
|
convertEvent.put("imgPath", url);
|
JSONObject extend = new JSONObject();
|
extend.putAll(convertEvent);
|
convertEvent.put("extend", extend);
|
return convertEvent;
|
|
}
|
|
|
@SneakyThrows
|
@PostMapping("/reportVideo")
|
public void reportVideo(HttpServletRequest request) {
|
log.info("=====>接收到卸油aibox视频上报");
|
// String key = s3Util.upload(file.getBytes(), file.getName());
|
// String url = s3Util.getBucketName() + SystemConstant.s3_split_char + key;
|
|
JSONObject data = new JSONObject();
|
data.put("type", MqttMsgReceiver.CUT_VIDEO);
|
//todo 缺少事件基础数据
|
|
|
|
mqttMsgReceiver.dealCommandMsg("");
|
}
|
|
|
@GetMapping("/aiboxConfig")
|
Result<JSONObject> getAiboxConfig() {
|
JSONObject config = new RestTemplate().getForObject(thirdBoxUrl + aiboxConfig, JSONObject.class);
|
return Result.ok(config);
|
}
|
|
|
@PutMapping("/aiboxConfig")
|
Result<JSONObject> putAiboxConfig(JSONObject putConfig) {
|
RestTemplate restTemplate = new RestTemplate();
|
restTemplate.put(thirdBoxUrl + aiboxConfig, putConfig);
|
JSONObject config = restTemplate.getForObject(thirdBoxUrl + aiboxConfig, JSONObject.class);
|
return Result.ok(config);
|
}
|
|
@GetMapping("/grade/{grade}")
|
Result<String> gradeSet(@PathVariable int grade) {
|
StringCampareUtil.grade = grade;
|
return Result.ok("成功");
|
}
|
|
//调试接口
|
@GetMapping("/similar")
|
Result<?> similarGet() {
|
return Result.ok(StringCampareUtil.similarMap);
|
}
|
|
@GetMapping("/similar/put/{sameStr}")
|
Result<?> similarPut(@PathVariable String sameStr) {
|
char key = sameStr.charAt(0);
|
StringCampareUtil.similarMap.put(key, sameStr);
|
return Result.ok("成功");
|
}
|
|
@PutMapping("/similar")
|
Result<?> similarPut(@RequestBody Map<Character, String> sameMap) {
|
StringCampareUtil.similarMap.putAll(sameMap);
|
return Result.ok(StringCampareUtil.similarMap);
|
}
|
|
}
|
