package cn.gistack.sm.hk.service;
|
|
import cn.gistack.sm.hk.entity.HkEvent;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
|
@Component
|
public class AsyncHkEventService {
|
|
@Autowired
|
private HkEventService hkEventService;
|
|
/**
|
* 异步加载海康视频事件
|
* @param jsonData
|
*/
|
@Async
|
public void saveHkEventInfo(String jsonData){
|
JSONObject jsonObject = JSONObject.parseObject(jsonData);
|
String params = jsonObject.get("params").toString();
|
JSONObject parseObject = JSONObject.parseObject(params);
|
JSONArray eventsArray = parseObject.getJSONArray("events");
|
Date sendTime = parseObject.getDate("sendTime");
|
for (int i = 0; i < eventsArray.size(); i++) {
|
HkEvent hkEvent = new HkEvent();
|
hkEvent.setEventId(eventsArray.getJSONObject(i).getString("eventId"));
|
hkEvent.setEventType(eventsArray.getJSONObject(i).getLong("eventType"));
|
hkEvent.setSrcIndex(eventsArray.getJSONObject(i).getString("srcIndex"));
|
hkEvent.setSrcName(eventsArray.getJSONObject(i).getString("srcName"));
|
hkEvent.setSrcType(eventsArray.getJSONObject(i).getString("srcType"));
|
hkEvent.setSrcParentIndex(eventsArray.getJSONObject(i).getString("srcParentIndex"));
|
hkEvent.setTimeout(eventsArray.getJSONObject(i).getLong("timeout"));
|
hkEvent.setHappenTime(eventsArray.getJSONObject(i).getDate("happenTime"));
|
hkEvent.setStatus(eventsArray.getJSONObject(i).getInteger("status"));
|
hkEvent.setEventLvl(eventsArray.getJSONObject(i).getInteger("eventLvl"));
|
hkEvent.setCreateTime(new Date());
|
hkEvent.setSendTime(sendTime);
|
// 保存
|
hkEventService.save(hkEvent);
|
}
|
}
|
}
|
