镜屏任务

security-protection-service/src/main/java/com/ai/bss/security/protection/service/task/AlarmMirrorTask.java

package com.ai.bss.security.protection.service.task;
import com.ai.abc.api.model.CommonRequest;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.security.protection.service.interfaces.CharSpecService;
import com.ai.bss.security.protection.utils.EbcConstant;
import com.ai.bss.work.task.model.common.WorkTask;
import com.ai.bss.worker.service.api.EntityAlarmHandle;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.collections4.map.HashedMap;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Map;
@Component
public class AlarmMirrorTask implements EntityAlarmHandle {
	private Logger logger = LoggerFactory.getLogger(AlarmMirrorTask.class);
	@Autowired
	private CharSpecService charSpecService;
	/**
	 * 镜屏推送实时报警信息
	 *
	 * @param workTask
	 * @return
	 */
	@Override
	public CommonResponse<Map<String, Object>> alarmHandle(CommonRequest<WorkTask> workTask) {
		logger.debug("====================实时报警接收镜屏数据: " + JSON.toJSONString(workTask));
		try {
			String charValueSet = workTask.getData().getCharValueSet();
			JSONObject alarmJsonObj = JSONObject.parseObject(charValueSet);
			Map<String, String> resultMap = new HashedMap<String, String>();
			resultMap.put("workTaskId", workTask.getData().getWorkTaskId());
			resultMap.put("employeeName", workTask.getData().getTargetEmployeeRoleName());
			resultMap.put("longitude", alarmJsonObj.getString("longitude"));
			resultMap.put("latitude", alarmJsonObj.getString("latitude"));
			resultMap.put("businessType", alarmJsonObj.getString("businessType"));
			String msg = JSON.toJSONString(CommonResponse.ok(resultMap));
			logger.info("实时报警推送镜屏数据: " + msg);
			MirrorManagement.sendData(MirrorManagement.TOPIC_ALARM, msg);
		} catch (Exception e) {
			logger.error("实时报警推送镜屏失败: " + e.getMessage());
		}
		return null;
	}
}

security-protection-service/src/main/java/com/ai/bss/security/protection/service/task/MirrorManagement.java

package com.ai.bss.security.protection.service.task;
import com.ai.ipu.server.connect.ps.EventChannelTool;
import com.ai.ipu.server.connect.ps.EventChannelTool.PublisherEvent;
import com.ai.ipu.server.connect.ps.ISubscriber;
import com.ai.ipu.server.connect.ps.impl.Publisher;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
 * 镜屏推送消息
 * @author konghl@asiainfo.com
 * 2020-10-21
 */
public class MirrorManagement {
	private static Logger logger = LoggerFactory.getLogger(MirrorManagement.class);
	// 定位topic
	public static final String TOPIC_LOCATION = "personnel";
	// 报警topic
	public static final String TOPIC_ALARM = "alarm";
	public static void sendData(String topic, String msg) {
		logger.debug("推送镜屏数据: topic=" + topic + " , data=" + msg);
		if (!EventChannelTool.isExistSubscriber(topic)) {
			// 如果没有订阅 先不管
			logger.debug("未推送镜屏数据，原因是没有订阅：topic="+topic);
			return;
		}
		// 你发送的内容
		final Publisher publisher = new Publisher(topic);
		PublisherEvent<?> publisherEvent = new PublisherEvent<String>(msg) {
			@Override
			public void callback(String topic, ISubscriber... subscribers) {
				// 可记录消息发布后的统计日志
			}
		};
		publisher.publish(topic, publisherEvent);
		logger.debug("推送镜屏数据成功");
	}
}