人员定位模拟数据

ebc-sea-platform/src/main/java/com/ai/ipu/server/controller/ReceiveSubscribeController.java

import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.server.service.interfaces.ReceiveSubscribeService;
import com.ai.ipu.server.util.EbcConstant;
import com.ai.ipu.server.util.JingPingSendDateUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
		dataMap.put("latitude",detailInfo.getJSONObject("latitude").getString("value"));//纬度
		dataMap.put("newDate",detailInfo.getJSONObject("msgDate").getString("value"));//最新定位时间
		
		String topic="";
		switch (detailInfo.getJSONObject("alarmType").getString("value")) {
		case "1": //自动报警
			dataMap.put("alarmType",EbcConstant.location_status_autosos);//报警类型
			dataMap.put("alarmTypeZH",EbcConstant.location_status_autosos_ZH);//报警类型
			topic=JingPingSendDateUtil.topic_alarm;
		//报警类型
		switch (detailInfo.getJSONObject("alarmType").getIntValue("value")) {
		case 1: //自动报警
			dataMap.put("locationStatus",EbcConstant.location_status_autosos);//报警类型
			dataMap.put("alarmType",EbcConstant.alarm_type_autosos);//报警类型
			break;
		case "2": //手动报警
			dataMap.put("alarmType",EbcConstant.location_status_jogsos);//报警类型
			dataMap.put("alarmTypeZH",EbcConstant.location_status_jogsos_ZH);//报警类型
			topic=JingPingSendDateUtil.topic_alarm;
		case 2: //手动报警
			dataMap.put("locationStatus",EbcConstant.location_status_jogsos);//报警类型
			dataMap.put("alarmType",EbcConstant.alarm_type_jogsos);//报警类型
			break;
		case "4": //离线
			dataMap.put("alarmType",EbcConstant.location_status_offline);//报警类型
			dataMap.put("alarmTypeZH",EbcConstant.location_status_offline_ZH);//报警类型
			topic=JingPingSendDateUtil.topic_offline;
		case 4: //离线
			dataMap.put("locationStatus",EbcConstant.location_status_offline);//报警类型
			dataMap.put("alarmType",EbcConstant.alarm_type_offline);//报警类型
			break;
		default:
			break;
			logger.error("告警消息的内容错误，消息为：" +msg);
			return msg;
		}
		
		//推送镜屏
		String jingpingData=JSON.toJSONString(dataMap);
		logger.debug("推送镜屏数据：" +jingpingData);
		JingPingSendDateUtil.sendData(topic,jingpingData);
		
		//保存报警数据
		//分析并推送报警数据
		receiveSubscribeService.receiveIotAlarmData(dataMap);
		
		return msg;

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/impl/DeviceManageDaoImpl.java

	}
	@Override
	public Map<String, Object> queryAssociatUser(JMap params) throws Exception {
		List<Map<String, Object>> userAndDeviceList = dao.selectByCond(userAndDevicetableName, params);
	public Map<String, Object> queryOneBindDeviceInfo(Map<String, Object> dataMap) throws Exception {
		List<Map<String, Object>> userAndDeviceList = dao.selectByCond(userAndDevicetableName, dataMap);
		if (userAndDeviceList.isEmpty()) {
			return null;
		} else {
		map1.put("locationStatus", EbcConstant.location_status_normal);//状态: 0定位
		map1.put("deviceId", "999571");//终端ID
		map1.put("deviceNo", "999571");//终端编号
		map1.put("longitude", "123.7709438548");//经度
		map1.put("latitude", "31.58477450849");//纬度
		map1.put("newDate", "2020-10-26 10:12:24");//最新定位时间
		map1.put("longitude", "123.7709439");//经度
		map1.put("latitude", "31.5847745");//纬度
		map1.put("newDate", "2020-10-27 13:14:15");//最新定位时间
		list.add(map1);
		Map<String, Object> map2=new HashMap<String, Object>();
		map2.put("locationStatus", EbcConstant.location_status_normal);//状态: 0定位
		map2.put("deviceId", "981489");//终端ID
		map2.put("deviceNo", "981489");//终端编号
		map2.put("longitude", "126.422192652");//经度
		map2.put("latitude", "32.045333123");//纬度
		map2.put("longitude", "125.4221927");//经度
		map2.put("latitude", "32.0453331");//纬度
		map2.put("newDate", "2020-10-26 11:22:33");//最新定位时间
		list.add(map2);
		
		map3.put("locationStatus", EbcConstant.location_status_normal);//状态: 0定位
		map3.put("deviceId", "981453");//终端ID
		map3.put("deviceNo", "981453");//终端编号
		map3.put("longitude", "127.422192652");//经度
		map3.put("latitude", "34.045333123");//纬度
		map3.put("longitude", "122.0221926");//经度
		map3.put("latitude", "33.5453331");//纬度
		map3.put("newDate", "2020-10-27 12:31:45");//最新定位时间
		list.add(map3);
		
		map4.put("locationStatus", EbcConstant.location_status_normal);//状态: 0定位
		map4.put("deviceId", "23125");//终端ID
		map4.put("deviceNo", "23125");//终端编号
		map4.put("longitude", "125.822192652");//经度
		map4.put("latitude", "33.345333123");//纬度
		map4.put("newDate", "2020-10-27 09:18:13");//最新定位时间
		map4.put("longitude", "125.3221927");//经度
		map4.put("latitude", "33.3453331");//纬度
		map4.put("newDate", "2020-10-27 13:40:40");//最新定位时间
		list.add(map4);
		
		Map<String, Object> map5=new HashMap<String, Object>();
		map5.put("locationStatus", EbcConstant.location_status_normal);//状态: 0定位
		map5.put("deviceId", "23126");//终端ID
		map5.put("deviceNo", "23126");//终端编号
		map5.put("longitude", "126.922192652");//经度
		map5.put("latitude", "32.945333123");//纬度
		map5.put("longitude", "125.4221927");//经度
		map5.put("latitude", "32.9453331");//纬度
		map5.put("newDate", "2020-10-27 18:20:30");//最新定位时间
		list.add(map5);
		
		map6.put("locationStatus", EbcConstant.location_status_exclusion);//状态:3违规(禁区)
		map6.put("deviceId", "23128");//终端ID
		map6.put("deviceNo", "23128");//终端编号
		map6.put("longitude", "127.422192652");//经度
		map6.put("latitude", "33.045333123");//纬度
		map6.put("newDate", "2020-10-25 14:28:38");//最新定位时间
		map6.put("longitude", "124.5309335");//经度
		map6.put("latitude", "33.7753425");//纬度
		map6.put("newDate", "2020-10-27 14:28:38");//最新定位时间
		list.add(map6);
		
		Map<String, Object> map7=new HashMap<String, Object>();
		map7.put("locationStatus", EbcConstant.location_status_offline);//状态:1离线
		map7.put("deviceId", "23129");//终端ID
		map7.put("deviceNo", "23129");//终端编号
		map7.put("longitude", "121.422192652");//经度
		map7.put("latitude", "31.045333123");//纬度
		map7.put("longitude", "122.4221927");//经度
		map7.put("latitude", "32.6453331");//纬度
		map7.put("newDate", "2020-10-27 14:15:22");//最新定位时间
		list.add(map7);

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/impl/MapTagManageDaoImpl.java

		params.put("mapTagShape", "POLYGON ((" + params.getString("mapTagShape") + "))");
		params.put("residenceTimeLength",
				params.get("residenceTimeLength") == null ? null : params.get("residenceTimeLength"));
				params.get("residenceTimeLength") == null ? 0 : params.getInt("residenceTimeLength"));
		params.put("mapTagContent", params.get("mapTagContent") == null ? null : params.get("mapTagContent"));
		params.put("remarks", params.get("remarks") == null ? null : params.get("remarks"));

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/impl/RescueDaoImpl.java

import com.ai.ipu.data.JMap;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
import com.ai.ipu.server.dao.interfaces.RescueDao;
import com.ai.ipu.server.util.EbcConstant;
@Component
public class RescueDaoImpl extends AbstractBizDao implements RescueDao {
		sql.append(" FROM LR_RESCUE_LOG l ");
		sql.append(" WHERE 1=1 ");
		sql.append(" AND RESCUERS_DATE IS NULL ");//TODO 救援时间为空
		sql.append(" AND ALARM_TYPE <> '").append(EbcConstant.alarm_type_offline).append("' ");//不属于离线告警
		sql.append(" AND DEVICE_ID = #{deviceId} ");
		dataMap.put("deviceId", params.get("deviceId"));
		

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/interfaces/DeviceManageDao.java

	List<Map<String, Object>> queryAssociatBoatInfo(JMap params) throws Exception;
	Map<String, Object> queryAssociatUser(JMap params) throws Exception;
	/**
	 * 查询单个终端绑定信息
	 * @param params
	 * @return
	 * @throws Exception
	 */
	Map<String, Object> queryOneBindDeviceInfo(Map<String, Object> dataMap) throws Exception;
	int bindDevice(Map params, String type) throws Exception;

ebc-sea-platform/src/main/java/com/ai/ipu/server/enums/ProductEnums.java

 */
public enum ProductEnums {
	// 船舶
	ship("003", "船舶", 1),
	ship("001", "船舶", 1),
	// 风机
	fan("001", "风机", 2),
	fan("002", "风机", 2),
	// 升压站
	booster("002", "升压站", 2),
	booster("003", "升压站", 2),
	// 测风塔
	anemometer("004", "测风塔", 2);

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/impl/DeviceManageServiceImpl.java

	@Override
	public Map<String, Object> verifyUserOrBoatAssociatInfo(JMap params) throws Exception {
		// 查询用户与终端关联表，如果有数据返回，无数据返回空
		Map<String, Object> userAndDeviceMap = deviceManageDao.queryAssociatUser(params);
		Map<String, Object> dataMap=new HashMap<String, Object>();
		dataMap.put("PARTY_CODE", params.get("PARTY_CODE"));
		Map<String, Object> userAndDeviceMap = deviceManageDao.queryOneBindDeviceInfo(dataMap);
		return userAndDeviceMap;
	}

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/impl/ReceiveSubscribeServiceImpl.java

import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.data.JMap;
import com.ai.ipu.database.conn.SqlSessionManager;
import com.ai.ipu.server.dao.interfaces.AreaInOutRecordDao;
import com.ai.ipu.server.dao.interfaces.DeviceManageDao;
import com.ai.ipu.server.dao.interfaces.MapTagManageDao;
	@Autowired
	AreaInOutRecordDao areaInOutRecordDao;
	//private ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
	private ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
	@Override
	public void receiveIotLocationData(JMap dataMap) {
		executeReceiveIotLocationData(dataMap);
		
		/*cachedThreadPool.execute(new Runnable() {
		cachedThreadPool.execute(new Runnable() {
			@Override
			public void run() {
				logger.debug("启动定位信息新线程：" + Thread.currentThread().getName());
				executeReceiveIotLocationData(dataMap);
				try {
					logger.debug("启动定位信息新线程：" + Thread.currentThread().getName());
					executeReceiveIotLocationData(dataMap);
					logger.debug("数据库连接全量提交");
					SqlSessionManager.commitAll();
				} catch (Exception ex) {
					logger.error(ex.getMessage());
					logger.debug("数据库连接全量回滚");
					SqlSessionManager.rollbackAll();
				} finally {
					logger.debug("数据库连接全量回收");
					SqlSessionManager.closeAll();
				}
			}
		});*/
		});
	}
	@Override
	public void receiveIotAlarmData(JMap dataMap) {
		executeReceiveIotAlarmData(dataMap);
		
		/*cachedThreadPool.execute(new Runnable() {
		cachedThreadPool.execute(new Runnable() {
			@Override
			public void run() {
				logger.debug("启动报警信息新线程：" + Thread.currentThread().getName());
				executeReceiveIotAlarmData(dataMap);
				try {
					logger.debug("启动报警信息新线程：" + Thread.currentThread().getName());
					executeReceiveIotAlarmData(dataMap);
					logger.debug("数据库连接全量提交");
					SqlSessionManager.commitAll();
				} catch (Exception ex) {
					logger.error(ex.getMessage());
					logger.debug("数据库连接全量回滚");
					SqlSessionManager.rollbackAll();
				} finally {
					logger.debug("数据库连接全量回收");
					SqlSessionManager.closeAll();
				}
			}
		});*/
		});
	}
	/**
	 * 处理定位数据
	 * @param dataMap
	 * @throws Exception 
	 */
	private void executeReceiveIotLocationData(JMap params) {
		try {
			// 1、查询是否为需救援的人员
			Map<String, Object> alarmMap = rescueDao.queryNoCloseRescueLog(params);
			// 当前已为报警信息
			if (alarmMap != null) {
				logger.info("定位信息为已报警人员：" + alarmMap.get("MAP_TAG_NAME"));
				// 执行对应方法
				beforeAlarmLocationData(params, alarmMap);
				// 报警人员不再进行围栏计算
				return;
			}
	private void executeReceiveIotLocationData(JMap params) throws Exception {
		// 1、获取人员信息
		Map<String, Object> dataMap=new HashMap<String, Object>();
		dataMap.put("DEVICE_ID", params.get("deviceId"));
		Map<String, Object> deviceAndUser = deviceManageDao.queryOneBindDeviceInfo(dataMap);
		params.put("userName", deviceAndUser.get("PARTY_NAME"));
		// 2、查询是否为需救援的人员
		Map<String, Object> alarmMap = rescueDao.queryNoCloseRescueLog(params);
		// 当前已为报警信息
		if (alarmMap != null && !alarmMap.isEmpty()) {
			logger.info("定位信息为已报警人员：" + alarmMap.get("MAP_TAG_NAME"));
			// 执行对应方法
			beforeAlarmLocationData(params, alarmMap);
			// 报警人员不再进行围栏计算
			return;
		}
			logger.debug("定位信息不是报警人员");
			// 2、查询人员当前是否在围栏内
			JMap currentAreaInfoJMap = mapTagManageDao.getInAreaInfo(params.getString("longitude"),
					params.getString("latitude"));
			// 3、查询人员之前所在围栏信息
			List<Map<String, Object>> beforeAreaMapList = areaInOutRecordDao.getBeforeAreaInfo(params);
			// 4、判断当前是否在围栏内
			if (currentAreaInfoJMap.getInt("mapTagNum") == 0) {
				logger.debug("定位信息不在围栏内");
				currentNotInArea(params, beforeAreaMapList);
			} else {
				logger.debug("定位信息在围栏内,围栏数量:" + currentAreaInfoJMap.getInt("mapTagNum"));
				currentInArea(params, currentAreaInfoJMap, beforeAreaMapList);
			}
		logger.debug("定位信息不是报警人员");
		// 3、查询人员当前是否在围栏内
		JMap currentAreaInfoJMap = mapTagManageDao.getInAreaInfo(params.getString("longitude"),
				params.getString("latitude"));
		// 4、查询人员之前所在围栏信息
		List<Map<String, Object>> beforeAreaMapList = areaInOutRecordDao.getBeforeAreaInfo(params);
		} catch (Exception ex) {
			logger.error(ex.getMessage());
		// 5、判断当前是否在围栏内
		if (currentAreaInfoJMap.getInt("mapTagNum") == 0) {
			logger.debug("定位信息不在围栏内");
			currentNotInArea(params, beforeAreaMapList);
		} else {
			logger.debug("定位信息在围栏内,围栏数量:" + currentAreaInfoJMap.getInt("mapTagNum"));
			currentInArea(params, currentAreaInfoJMap, beforeAreaMapList);
		}
	}
	 * @throws ParseException 
	 */
	private void beforeAlarmLocationData(JMap params, Map<String, Object> alarmMap) throws Exception {
		String newDate = params.getString("newDate");// 当前定位时间
		String alarmDate = String.valueOf(alarmMap.get("CALLER_DATE"));// 求救时间
		params.put("alarmDate", alarmDate);
		// 计算持续时长
		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		long newDateLong = simpleDateFormat.parse(newDate).getTime();
		long alarmDateLong = simpleDateFormat.parse(alarmDate).getTime();
		long alarmLong = newDateLong - alarmDateLong;
			BigDecimal alarmLongBigDecimal = new BigDecimal(alarmLong);
			// 单位为分，四舍五入不保留小数
			alarmLongBigDecimal = alarmLongBigDecimal.divide(new BigDecimal("60000L"), 0, BigDecimal.ROUND_HALF_UP);
			params.put("alarmLong", alarmLongBigDecimal.intValue());
		params.put("alarmLong", JingPingSendDateUtil.getBetweenMinuteValue(alarmDate, params.getString("newDate")));
		// 推送镜屏
		String jingpingData = JSON.toJSONString(params);
	 */
	private void currentInAreaSendData(JMap params, List<Map<String, Object>> currentAreaInfoList)
			throws ParseException {
		// 获得用于推送镜屏的围栏信息
		int maxMapTagGrade = 0; // 围栏优先级(电子围栏5>定点3>考勤1、作业1)
		long minInAreaLong = System.currentTimeMillis();// 进入围栏最早的时间戳
		int mapTagIndex = 0;// 围栏的索引
		Map<String, Object> sendDataAreaInfo = null;// 用于推送镜屏的围栏信息
		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		for (int i = 0; i < currentAreaInfoList.size(); i++) {
						.getTime();
				if (inAreaLong < minInAreaLong) {
					minInAreaLong = inAreaLong;
					mapTagIndex = i;
					sendDataAreaInfo = currentAreaInfoList.get(i);
				}
			} else if (mapTagGrade > maxMapTagGrade) {
				maxMapTagGrade = mapTagGrade;
				minInAreaLong = simpleDateFormat.parse(String.valueOf(currentAreaInfoList.get(i).get("inAreaDate")))
						.getTime();
				mapTagIndex = i;
				sendDataAreaInfo = currentAreaInfoList.get(i);
			}
		}
		if (maxMapTagGrade == 5) {
			logger.info("镜屏推送进入电子围栏的信息");
			// 进入电子围栏(禁区)，需显示进入时间
			params.put("inDate", currentAreaInfoList.get(mapTagIndex).get("inAreaDate"));
			params.put("inDate", sendDataAreaInfo.get("inAreaDate"));
			params.put("locationStatus", EbcConstant.location_status_exclusion);
		} else if (maxMapTagGrade == 3) {
			// 进入定点(限时)，需计算是否超时
			String newDate = params.getString("newDate");// 当前定位时间
			long newDateLong = simpleDateFormat.parse(newDate).getTime();
			long fixedLong = newDateLong - minInAreaLong;
			if (fixedLong>=60000L) {
				BigDecimal fixedLongBigDecimal = new BigDecimal(fixedLong);
				// 单位为分，四舍五入不保留小数
				long fixedMinute = fixedLongBigDecimal.divide(new BigDecimal("60000L"), 0, BigDecimal.ROUND_HALF_UP)
						.longValue();
			int fixedLong = JingPingSendDateUtil.getBetweenMinuteValue(
					String.valueOf(sendDataAreaInfo.get("inAreaDate")), params.getString("newDate"));
			if (fixedLong > 0) {
				// 围栏要求定点时间
				long residenceTimeLength = Long
						.getLong(String.valueOf(currentAreaInfoList.get(mapTagIndex).get("RESIDENCE_TIME_LENGTH")));
				int residenceTimeLength = Integer
						.getInteger(String.valueOf(sendDataAreaInfo.get("RESIDENCE_TIME_LENGTH")));
				if (residenceTimeLength <= fixedMinute) {
				if (residenceTimeLength <= fixedLong) {
					// 已超时
					logger.info("镜屏推送进入定点的信息");
					logger.info("镜屏推送进入定点(限时)的信息");
					params.put("locationStatus", EbcConstant.location_status_overtime);
				}
				params.put("fixedLong", fixedMinute);
			}
			params.put("fixedLong", fixedLong);
		}
		String jingpingData = JSON.toJSONString(params);
	/**
	 * 处理报警数据
	 * @param dataMap
	 * @throws Exception 
	 */
	private void executeReceiveIotAlarmData(JMap params) {
		try {
			// 1、获取人员信息
			Map<String, Object> deviceAndUser = deviceManageDao.queryAssociatUser(params);
			// 2、获取围栏信息
			JMap currentAreaInfoJMap = mapTagManageDao.getInAreaInfo(params.getString("longitude"),
					params.getString("latitude"));
			// 拼接添加数据
			Map<String, Object> dataMap = new HashMap<String, Object>();
			dataMap.put("CALLER_ID", deviceAndUser.get("PARTY_CODE")); // 报警人员标识
			dataMap.put("DEVICE_ID", params.get("deviceId")); // 终端标识
			dataMap.put("PARTY_TYPE", deviceAndUser.get("PARTY_TYPE")); // 参与人类型
			dataMap.put("PARTY_CODE", deviceAndUser.get("PARTY_CODE")); // 参与人业务编码
			dataMap.put("PARTY_NAME", deviceAndUser.get("PARTY_NAME")); // 参与人名称
			dataMap.put("ALARM_TYPE", params.get("alarmTypeZH")); // 告警类型
			dataMap.put("LONGITUDE", params.get("longitude")); // 报警经度
			dataMap.put("LATITUDE", params.get("latitude")); // 报警纬度
			dataMap.put("CALLER_DATE", params.get("msgDate")); // 报警时间
			// 报警位置
			if (currentAreaInfoJMap.getInt("mapTagNum") > 0) {
				// 当前所在围栏列表
				List<Map<String, Object>> currentAreaInfoList = (List<Map<String, Object>>) currentAreaInfoJMap
						.get("resultList");
				StringBuffer mapTagName = new StringBuffer(
						String.valueOf(currentAreaInfoList.get(0).get("MAP_TAG_NAME")));
				for (int i = 1; i < currentAreaInfoList.size(); i++) {
					mapTagName.append(",").append(String.valueOf(currentAreaInfoList.get(i).get("MAP_TAG_NAME")));
				}
	private void executeReceiveIotAlarmData(JMap params) throws Exception {
		// 1、获取人员信息
		Map<String, Object> dataMap=new HashMap<String, Object>();
		dataMap.put("DEVICE_ID", params.get("deviceId"));
		Map<String, Object> deviceAndUser = deviceManageDao.queryOneBindDeviceInfo(dataMap);
		params.put("userName", deviceAndUser.get("PARTY_NAME"));
		// 2、查询是否为需救援的人员
		Map<String, Object> alarmMap = rescueDao.queryNoCloseRescueLog(params);
		// 3、判断是否存在未救援的报警信息
		if (alarmMap == null || alarmMap.isEmpty()) {
			logger.debug("新增报警信息");
			params.put("isNewAlarm", "1");
			// 保存报警数据
			saveAlarmData(params, deviceAndUser);
		} else {
			params.put("isNewAlarm", "0");
			logger.debug("报警信息未处理");
		}
				dataMap.put("CALLER_LOCATION", mapTagName.toString());
			} else {
				dataMap.put("CALLER_LOCATION", "");
			}
		// 4、推送镜屏
		String jingpingData = JSON.toJSONString(params);
		logger.debug("推送镜屏数据：" + jingpingData);
		JingPingSendDateUtil.sendData(JingPingSendDateUtil.topic_personnel, jingpingData);
	}
			// 3、保存报警数据
			logger.debug("记录告警日志");
			rescueDao.addRescueLog(dataMap);
	/**
	 * 保存报警数据
	 * @param params
	 * @param deviceAndUser
	 * @throws Exception
	 */
	private void saveAlarmData(JMap params, Map<String, Object> deviceAndUser) throws Exception {
		// 1、获取围栏信息
		JMap currentAreaInfoJMap = mapTagManageDao.getInAreaInfo(params.getString("longitude"),
				params.getString("latitude"));
		// 2、拼接添加数据
		Map<String, Object> dataMap = new HashMap<String, Object>();
		dataMap.put("CALLER_ID", deviceAndUser.get("PARTY_CODE")); // 报警人员标识
		dataMap.put("DEVICE_ID", params.get("deviceId")); // 终端标识
		dataMap.put("PARTY_TYPE", deviceAndUser.get("PARTY_TYPE")); // 参与人类型
		dataMap.put("PARTY_CODE", deviceAndUser.get("PARTY_CODE")); // 参与人业务编码
		dataMap.put("PARTY_NAME", deviceAndUser.get("PARTY_NAME")); // 参与人名称
		dataMap.put("ALARM_TYPE", params.get("alarmType")); // 告警类型
		dataMap.put("LONGITUDE", params.get("longitude")); // 报警经度
		dataMap.put("LATITUDE", params.get("latitude")); // 报警纬度
		dataMap.put("CALLER_DATE", params.get("msgDate")); // 报警时间
		// 报警位置
		if (currentAreaInfoJMap.getInt("mapTagNum") > 0) {
			// 当前所在围栏列表
			List<Map<String, Object>> currentAreaInfoList = (List<Map<String, Object>>) currentAreaInfoJMap
					.get("resultList");
			StringBuffer mapTagName = new StringBuffer(String.valueOf(currentAreaInfoList.get(0).get("MAP_TAG_NAME")));
			for (int i = 1; i < currentAreaInfoList.size(); i++) {
				mapTagName.append(",").append(String.valueOf(currentAreaInfoList.get(i).get("MAP_TAG_NAME")));
			}
		} catch (Exception e) {
			logger.error("记录告警日志失败");
			dataMap.put("CALLER_LOCATION", mapTagName.toString());
		} else {
			dataMap.put("CALLER_LOCATION", "");
		}
		// 3、保存报警数据
		logger.debug("记录告警日志");
		rescueDao.addRescueLog(dataMap);
	}
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/util/EbcConstant.java

	//人员状态：救援人员
	public static final String location_status_rescuers="6";
	
	//人员状态：离线
	public static final String location_status_offline_ZH="离线告警";
	//告警类型：离线
	public static final String alarm_type_offline="离线告警";
	
	//人员状态：违规
	public static final String location_status_exclusion_ZH="违规告警";
	//告警类型：SOS(手动)
	public static final String alarm_type_jogsos="手动告警";
	
	//人员状态：SOS(手动)
	public static final String location_status_jogsos_ZH="手动告警";
	
	//人员状态：SOS(自动)
	public static final String location_status_autosos_ZH="落水告警";
	//告警类型：SOS(自动)
	public static final String alarm_type_autosos="落水告警";
	
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/util/JingPingSendDateUtil.java

package com.ai.ipu.server.util;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
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;
 * 2020-10-21
 */
public class JingPingSendDateUtil {
	
	// 人员定位topic(正常)
	public static final String topic_personnel = "personnel";
	// 救援定位topic(SOS)
	public static final String topic_alarm = "alarm";
	// 离线topic(离线)
	public static final String topic_offline = "offline";
	// 人员定位topic
	public static final String topic_personnel = "personnel";
	// 违规topic(违规)
	public static final String topic_violation = "violation";
	// 救援定位topic
	//public static final String topic_alarm = "alarm";
	public static void sendData(String topic, String msg) {
		if (!EventChannelTool.isExistSubscriber(topic)) {
		publisher.publish(topic, publisherEvent);
	}
	/**
	 * 计算两个时间相隔的分钟数(endDate-beginDate)
	 * @param beginDate
	 * @param endDate
	 * @return
	 * @throws ParseException 
	 */
	public static int getBetweenMinuteValue(String beginDate, String endDate) throws ParseException {
		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		long endDateLong = simpleDateFormat.parse(endDate).getTime();
		long beginDateLong = simpleDateFormat.parse(beginDate).getTime();
		long alarmLong = endDateLong - beginDateLong;
		if (alarmLong>0) {
			BigDecimal alarmLongBigDecimal = new BigDecimal(alarmLong);
			// 单位为分，四舍五入不保留小数
			alarmLongBigDecimal = alarmLongBigDecimal.divide(new BigDecimal("60000L"), 0, BigDecimal.ROUND_HALF_UP);
			return alarmLongBigDecimal.intValue();
		}else {
			return 0;
		}
		
	}
}