新增定位推送，修改枚举类的位置

ebc-sea-platform/.project

@@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
	<name>ebc-sea-platform</name>
	<comment></comment>
	<projects>
	</projects>
	<buildSpec>
		<buildCommand>
			<name>org.eclipse.jdt.core.javabuilder</name>
			<arguments>
			</arguments>
		</buildCommand>
		<buildCommand>
			<name>org.eclipse.m2e.core.maven2Builder</name>
			<arguments>
			</arguments>
		</buildCommand>
	</buildSpec>
	<natures>
		<nature>org.eclipse.jdt.core.javanature</nature>
		<nature>org.eclipse.m2e.core.maven2Nature</nature>
	</natures>
</projectDescription>

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

@@ -59,7 +59,7 @@ public class DeviceManageController {
		// 每页条数
		int pageSize = EbcConstant.comboBox_maxNum;
		List<Map<String, Object>> resultList = deviceManageService.queryListDeviceInfo(params, pageNum, pageSize);
		List<Map<String, String>> resultList = deviceManageService.queryListDeviceInfo(params, pageNum, pageSize);
		result.put("dataList", resultList);
		return result;
	}
@@ -239,6 +239,23 @@ public class DeviceManageController {
		result.put("result", associatMap);
		return result;
	}
	
	/**
	 * 获取当前终端定位信息
	 * 
	 * @param params
	 * @return
	 * @throws Exception
	 */
	@ResponseBody
	@RequestMapping("/queryCurrentDeviceLocationInfo")
	public JMap queryCurrentDeviceLocationInfo(JMap params) throws Exception {
		JMap result = new JsonMap();
		List<Map<String, Object>> resultList = deviceManageService.queryCurrentDeviceLocationInfo(params);
		result.put("dataList", resultList);
		return result;
	}
	/**
	 * 导入终端信息

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

@@ -119,6 +119,19 @@ public class EquipmentManageController {
    }
    /**
     * 获取所有设备信息
     */
    @ResponseBody
    @RequestMapping("/queryAllEquipmentInfo")
    public JMap queryAllEquipmentInfo(JMap params) throws Exception {
    	JMap result = new JsonMap();
    	
		List<Map<String, Object>> resultList = equipmentManageService.queryAllEquipmentInfo(params);
		result.put("dataList", resultList);
		return result;
    }
    
    /**
     * 导入设备信息
     */
    @ResponseBody

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

@@ -11,7 +11,8 @@ import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.server.service.interfaces.AreaInOutRecordService;
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;
@@ -27,7 +28,7 @@ public class ReceiveSubscribeController {
	private static final ILogger logger = IpuLoggerFactory.createLogger(ReceiveSubscribeController.class);
	
	@Autowired
	AreaInOutRecordService areaInOutRecordService;
	ReceiveSubscribeService receiveSubscribeService;
	
	/**
	 * 接收定位消息
@@ -35,33 +36,24 @@ public class ReceiveSubscribeController {
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value = "/receiveLocationData", method = RequestMethod.POST)
	public String receiveLocationData(@RequestBody String msg) {
	@RequestMapping(value = "/receiveIotLocationData", method = RequestMethod.POST)
	public String receiveIotLocationData(@RequestBody String msg) {
		logger.info("已接收定位消息，消息为：" +msg);
		try {
			//解析数据
			JSONObject msgJson=JSON.parseObject(msg);
			JSONObject detailInfo=msgJson.getJSONObject("detailInfo");
			JMap dataMap=new JsonMap();
			dataMap.put("id",msgJson.getString("resourceId"));//设备id
			dataMap.put("latitude",detailInfo.getJSONObject("latitude").getString("value"));//经度
			dataMap.put("longitude",detailInfo.getJSONObject("longitude").getString("value"));//纬度
			dataMap.put("msgDate",detailInfo.getJSONObject("msgDate").getString("value"));//时间
			
			//推送镜屏
			String jingpingData=JSON.toJSONString(dataMap);
			logger.debug("推送镜屏数据：" +jingpingData);
			JingPingSendDateUtil.sendData(JingPingSendDateUtil.topic_personnel,jingpingData);
			
			//TODO 记录围栏
			areaInOutRecordService.addAreaInOutRecord(dataMap);
			
			return msg;
		} catch (Exception ex) {
			logger.error(ex.getMessage());
			return ex.getMessage();
		}
		
		//解析数据
		JSONObject msgJson=JSON.parseObject(msg);
		JSONObject detailInfo=msgJson.getJSONObject("detailInfo");
		JMap dataMap=new JsonMap();
		dataMap.put("deviceId",msgJson.getString("resourceId"));//设备id
		dataMap.put("deviceNo",msgJson.getString("resourceId"));//设备编码
		dataMap.put("longitude",detailInfo.getJSONObject("longitude").getString("value"));//经度
		dataMap.put("latitude",detailInfo.getJSONObject("latitude").getString("value"));//纬度
		dataMap.put("newDate",detailInfo.getJSONObject("msgDate").getString("value"));//最新定位时间
		
		//分析并推送定位数据
		receiveSubscribeService.receiveIotLocationData(dataMap);
		
		return msg;
	}
	/**
@@ -70,30 +62,50 @@ public class ReceiveSubscribeController {
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value = "/receiveAlarmData", method = RequestMethod.POST)
	public String receiveAlarmData(@RequestBody String msg) {
		try {
			System.out.println("已接收告警消息，消息为：\n" + JSON.toJSON(msg));
			return msg;
		} catch (Exception ex) {
			return ex.getMessage();
		}
	}
	/**
	 * 接收在线离线消息
	 * @param msg
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value = "/receiveOnOfflineData", method = RequestMethod.POST)
	public String receiveOnOfflineData(@RequestBody String msg) {
		try {
			System.out.println("已接收在线离线消息，消息为：\n" + JSON.toJSON(msg));
			return msg;
		} catch (Exception ex) {
			return ex.getMessage();
	@RequestMapping(value = "/receiveIotAlarmData", method = RequestMethod.POST)
	public String receiveIotAlarmData(@RequestBody String msg) {
		logger.info("已接收告警消息，消息为：" +msg);
		
		//解析数据
		JSONObject msgJson=JSON.parseObject(msg);
		JSONObject detailInfo=msgJson.getJSONObject("detailInfo");
		JMap dataMap=new JsonMap();
		dataMap.put("deviceId",msgJson.getString("resourceId"));//设备id
		dataMap.put("deviceNo",msgJson.getString("resourceId"));//设备编码
		dataMap.put("longitude",detailInfo.getJSONObject("longitude").getString("value"));//经度
		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;
			break;
		case "2": //手动报警
			dataMap.put("alarmType",EbcConstant.location_status_jogsos);//报警类型
			dataMap.put("alarmTypeZH",EbcConstant.location_status_jogsos_ZH);//报警类型
			topic=JingPingSendDateUtil.topic_alarm;
			break;
		case "4": //离线
			dataMap.put("alarmType",EbcConstant.location_status_offline);//报警类型
			dataMap.put("alarmTypeZH",EbcConstant.location_status_offline_ZH);//报警类型
			topic=JingPingSendDateUtil.topic_offline;
			break;
		default:
			break;
		}
		
		//推送镜屏
		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/controller/RescueController.java

@@ -0,0 +1,122 @@
package com.ai.ipu.server.controller;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.server.service.interfaces.ExportService;
import com.ai.ipu.server.service.interfaces.RescueService;
import com.github.pagehelper.PageInfo;
import java.util.List;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
/**
 * 报警救援
 */
@Controller
@RequestMapping("/rescue")
public class RescueController {
    @Autowired
    RescueService rescueService;
    
    /**
	 * 分页查询报警救援日志
	 * 
	 * @param params
	 * @return
	 * @throws Exception
	 */
	@ResponseBody
	@RequestMapping("/queryPageRescueLog")
	public JMap queryPageRescueLog(JMap params) throws Exception {
		// 当前页数
		int pageNum = params.getInt("pageNum") < 1 ? 1 : params.getInt("pageNum");
		// 每页条数
		int pageSize = params.getInt("pageSize") < 1 ? 10 : params.getInt("pageSize");
		JMap result = rescueService.queryPageRescueLog(params, pageNum, pageSize);
		result.put("pageNum", pageNum);
		result.put("pageSize", pageSize);
		return result;
	}
	/**
	 * 查询单个报警救援日志
	 * 
	 * @param params
	 * @return
	 * @throws Exception
	 */
	@ResponseBody
	@RequestMapping("/queryOneRescueLog")
	public JMap queryOneRescueLog(JMap params) throws Exception {
		JMap result = new JsonMap();
		if (params == null || params.get("rescueLogId") == null) {
			result.put("result", false);
			result.put("errMsg", "操作失败");
			return result;
		}
		Map<String, Object> resultMap = rescueService.queryOneRescueLog(params);
		result.put("resultData", resultMap);
		return result;
	}
	/**
	 * 指派救援
	 * 
	 * @param params
	 * @return
	 * @throws Exception
	 */
	@ResponseBody
	@RequestMapping("/assignRescuer")
	public JMap assignRescuer(JMap params) throws Exception {
		JMap result = new JsonMap();
		if (params == null || params.get("rescueLogId") == null||params.get("rescuerCode") == null) {
			result.put("result", false);
			result.put("errMsg", "指派失败");
			return result;
		}
		boolean resultMap = rescueService.assignRescuer(params);
		result.put("result", resultMap);
		return result;
	}
	
	/**
	 * 关闭救援
	 * 
	 * @param params
	 * @return
	 * @throws Exception
	 */
	@ResponseBody
	@RequestMapping("/closeRescuer")
	public JMap closeRescuer(JMap params) throws Exception {
		JMap result = new JsonMap();
		
		if (params == null || params.get("rescueLogId") == null) {
			result.put("result", false);
			result.put("errMsg", "关闭失败");
			return result;
		}
		
		boolean resultMap = rescueService.closeRescuer(params);
		result.put("result", resultMap);
		return result;
	}
}

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

@@ -2,6 +2,7 @@ package com.ai.ipu.server.dao.impl;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Component;
@@ -39,23 +40,25 @@ public class AreaInOutRecordDaoImpl extends AbstractBizDao implements AreaInOutR
	}
	@Override
	public JMap getBeforeAreaInfo(JMap params) throws Exception {
		// TODO Auto-generated method stub
		return null;
	public List<Map<String, Object>> getBeforeAreaInfo(JMap params) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		
		StringBuilder sql=new StringBuilder();
		sql.append(" SELECT a.RECORD_ID,a.MAP_TAG_ID,a.IN_DATE, ");
		sql.append(" m.MAP_TAG_NAME,m.MAP_TAG_TYPE,m.RESIDENCE_TIME_LENGTH ");
		sql.append(" FROM LR_AREA_IN_OUT_RECORD a ");
		sql.append(" LEFT JOIN LR_MAP_TAG m ON m.MAP_TAG_ID=a.MAP_TAG_ID ");
		sql.append(" WHERE 1=1 ");
		sql.append(" AND a.OUT_DATE IS NULL ");
		
		sql.append(" AND a.DEVICE_ID = #{deviceId} ");
		dataMap.put("deviceId", params.get("deviceId"));
		
		return dao.executeSelect(sql.toString(), dataMap);
	}
	
	@Override
	public boolean addAreaInOutRecord(JMap params) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		dataMap.put("MAP_TAG_ID", params.get("mapTagId"));
		dataMap.put("EMPLOYEE_ID", params.get("employeeId"));
		dataMap.put("DEVICE_ID", params.get("deviceId"));
		dataMap.put("LONGITUDE", params.get("longitude"));
		dataMap.put("LATITUDE", params.get("latitude"));
		dataMap.put("RECORD_LOCATION", params.get("recordLocation"));
		dataMap.put("IN_DATE", params.get("inDate"));
		dataMap.put("OUT_DATE", params.get("outDate"));
		dataMap.put("REMARKS", params.get("remarks"));
	public boolean addAreaInRecord(Map<String, Object> dataMap) throws Exception {
		dataMap.put("DATA_STATUS", "1");
		//TODO 创建人和操作人的编号和部门
		dataMap.put("CREATE_DATE", TimeUtil.getSysTime());
@@ -67,5 +70,36 @@ public class AreaInOutRecordDaoImpl extends AbstractBizDao implements AreaInOutR
		
		return dao.insert("LR_AREA_IN_OUT_RECORD", dataMap) > 0;
	}
	
	@Override
	public boolean updateAreaOutRecord(Map<String, Object> dataMap) throws Exception {
		//TODO 操作人的编号和部门
		dataMap.put("doneDate", TimeUtil.getSysTime());
		dataMap.put("opId", "");
		dataMap.put("orgId", "");
		
		StringBuffer sql=new StringBuffer();
		sql.append(" UPDATE LR_AREA_IN_OUT_RECORD SET ");
		sql.append(" OUT_DATE = #{outDate},  ");
		sql.append(" DONE_DATE = #{doneDate}, ");
		sql.append(" OP_ID = #{opId},  ");
		sql.append(" ORG_ID = #{orgId} ");
		sql.append(" WHERE 1=1 ");
		
		
		if (dataMap.get("recordId") instanceof List) {
			List<String> recordIdList=(List<String>) dataMap.get("recordId");
			sql.append(" AND RECORD_ID in ( ");
			for (int i = 0; i < recordIdList.size(); i++) {
				sql.append("'").append(recordIdList.get(i)).append("'");
				if (i<recordIdList.size()-1) sql.append(",");
			}
			sql.append(" ) ");
		}else {
			sql.append(" AND RECORD_ID = #{recordId} ");
		}
		
		return dao.executeUpdate(sql.toString(), dataMap)>0;
	}
}

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

@@ -6,19 +6,18 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.ai.ipu.sql.mgmt.ISqlMgmtDao;
import com.ai.ipu.sql.mgmt.SqlMgmtDaoFactory;
import org.springframework.stereotype.Component;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
import com.ai.ipu.server.dao.interfaces.DeviceManageDao;
import com.ai.ipu.server.model.IotUrlEnum;
import com.ai.ipu.server.enums.IotUrlEnums;
import com.ai.ipu.server.enums.ProductEnums;
import com.ai.ipu.server.util.EbcConstant;
import com.ai.ipu.server.util.NorthboundInterfaceUtil;
import com.ai.ipu.server.util.ProductEnum;
import com.ai.ipu.sql.mgmt.ISqlMgmtDao;
import com.ai.ipu.sql.mgmt.SqlMgmtDaoFactory;
import com.alibaba.fastjson.JSONObject;
@Component
@@ -41,7 +40,7 @@ public class DeviceManageDaoImpl extends AbstractBizDao implements DeviceManageD
		paramsMap.put("businessParams", params.get("businessParams"));
		// 拼接接口地址
		String url = IotUrlEnum.queryPageDevice.getUrl();
		String url = IotUrlEnums.queryPageDevice.getUrl();
		Map<String, String> map = NorthboundInterfaceUtil.iotPostCallUtil(url, paramsMap);
		return map;
	}
@@ -52,7 +51,7 @@ public class DeviceManageDaoImpl extends AbstractBizDao implements DeviceManageD
		sql.append(" SELECT FACILITY_NAME NAME,DEVICE_ID FROM LR_FACILITY ");
		sql.append(" WHERE 1=1 ");
		sql.append(" AND FACILITY_TYPE ='").append(ProductEnum.ship.getProductId()).append("' ");
		sql.append(" AND FACILITY_TYPE ='").append(ProductEnums.ship.getProductId()).append("' ");
		sql.append(" AND DEVICE_ID IS NOT NULL ");
		sql.append(" UNION ALL ");
@@ -69,7 +68,7 @@ public class DeviceManageDaoImpl extends AbstractBizDao implements DeviceManageD
	@Override
	public JMap queryOneDeviceInfo(JMap params) throws Exception {
		// 拼接接口地址
		String url = IotUrlEnum.queryOneDevice.getUrl() + params.getString("deviceId");
		String url = IotUrlEnums.queryOneDevice.getUrl() + params.getString("deviceId");
		Map<String, String> map = NorthboundInterfaceUtil.iotGetCallUtil(url);
		JMap deviceInfoMap = new JsonMap(JSONObject.toJSONString(map.get("result")));
@@ -91,7 +90,7 @@ public class DeviceManageDaoImpl extends AbstractBizDao implements DeviceManageD
		paramsMap.put("remarks", params.getString("remarks")); // 备注
		// 拼接接口地址
		String url = IotUrlEnum.addDevice.getUrl();
		String url = IotUrlEnums.addDevice.getUrl();
		Map<String, String> map = NorthboundInterfaceUtil.iotPostCallUtil(url, paramsMap);
		return map;
	}
@@ -108,7 +107,7 @@ public class DeviceManageDaoImpl extends AbstractBizDao implements DeviceManageD
		paramsMap.put("remarks", params.getString("remarks")); // 备注
		// 拼接接口地址
		String url = IotUrlEnum.updateDevice.getUrl();
		String url = IotUrlEnums.updateDevice.getUrl();
		Map<String, String> map = NorthboundInterfaceUtil.iotPostCallUtil(url, paramsMap);
		return map;
	}
@@ -116,7 +115,7 @@ public class DeviceManageDaoImpl extends AbstractBizDao implements DeviceManageD
	@Override
	public Map<String, String> deleteDeviceInfo(JMap params) throws Exception {
		// 拼接接口地址
		String url = IotUrlEnum.deleteDevice.getUrl() + params.getString("deviceId");
		String url = IotUrlEnums.deleteDevice.getUrl() + params.getString("deviceId");
		Map<String, String> map = NorthboundInterfaceUtil.iotGetCallUtil(url);
		return map;
	}
@@ -184,4 +183,32 @@ public class DeviceManageDaoImpl extends AbstractBizDao implements DeviceManageD
	}
	@Override
	public List<Map<String, Object>> queryCurrentDeviceLocationInfo(JMap params) throws Exception {
		// TODO 调用北向接口获取当前终端位置
		
		List<Map<String, Object>> list=new ArrayList<Map<String, Object>>();
		
		Map<String, Object> map1=new HashMap<String, Object>();
		map1.put("PARTY_NAME", "张三");//人员姓名
		map1.put("LOCATION_STATUS", EbcConstant.location_status_normal);//状态: 0定位
		map1.put("DEVICE_ID", "23128");//终端ID
		map1.put("DEVICE_NO", "23128");//终端编号
		map1.put("LONGITUDE", "123.7709438548");//经度
		map1.put("LATITUDE", "31.58477450849");//纬度
		map1.put("LOCATION_DATE", "2020-10-26 10:12:24");//最新定位时间
		list.add(map1);
		
		Map<String, Object> map2=new HashMap<String, Object>();
		map2.put("PARTY_NAME", "李四");//人员姓名
		map2.put("LOCATION_STATUS", EbcConstant.location_status_autosos);//状态:4自动报警
		map2.put("DEVICE_ID", "23125");//终端ID
		map2.put("DEVICE_NO", "23125");//终端编号
		map2.put("LONGITUDE", "126.422192652");//经度
		map2.put("LATITUDE", "32.045333123");//纬度
		map2.put("LOCATION_DATE", "2020-10-26 11:22:33");//最新定位时间
		list.add(map2);
		
		return list;
	}
}

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

@@ -77,6 +77,38 @@ public class EquipmentManageDaoImpl extends AbstractBizDao implements EquipmentM
    }
    @Override
	public List<Map<String, Object>> queryAllEquipmentInfo(JMap params) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		
		StringBuilder sql = new StringBuilder();
		sql.append(" SELECT FACILITY_ID,FACILITY_TYPE,FACILITY_CODE,FACILITY_NAME,LONGITUDE,LATITUDE ");
		sql.append(" FROM LR_FACILITY ");
		sql.append(" WHERE 1=1 ");
		//标记类型:可传多个，用逗号隔开
		String facilityType=params.getString("facilityType");
		if (facilityType != null) {
			if (facilityType.indexOf(",")>0) {
				String[] facilityTypeArray=facilityType.split(",");
				sql.append(" AND FACILITY_TYPE IN ( ");
				for (int i = 0; i < facilityTypeArray.length; i++) {
					sql.append(" '").append(facilityTypeArray[i]).append("' ");
					if (i!=facilityTypeArray.length-1) {
						sql.append(" , ");
					}
				}
				sql.append(" ) ");
			}else {
				sql.append(" AND MAP_TAG_TYPE = #{facilityType} ");
				dataMap.put("facilityType", facilityType);
			}
		}
		return dao.executeSelect(sql.toString(), dataMap);
		
	}
    
    @Override
    public Map<String, Object> verifyEquipmentInfoRepetition(JMap params) throws Exception {
        List<Map<String, Object>> verifyList=new ArrayList<>();
        //验证修改重复
@@ -101,4 +133,5 @@ public class EquipmentManageDaoImpl extends AbstractBizDao implements EquipmentM
            return verifyList.get(0);
        }
    }
}

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

@@ -26,11 +26,11 @@ public class MapTagManageDaoImpl extends AbstractBizDao implements MapTagManageD
	@Override
	public JMap queryPageMapTagInfo(JMap params, int pageNum, int pageSize) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		
		Map<String, Object> dataMap = new HashMap<String, Object>();
		StringBuilder sql = new StringBuilder();
		sql.append(" SELECT MAP_TAG_ID,DEPARTMENT_ID,MAP_TAG_NAME,MAP_TAG_TYPE,MAP_TAG_CONTENT, ");
		sql.append(" ASTEXT(MAP_TAG_SHAPE) MAP_TAG_SHAPE,REMARKS,CREATE_DATE ");
		sql.append(" ASTEXT(MAP_TAG_SHAPE) MAP_TAG_SHAPE,RESIDENCE_TIME_LENGTH,REMARKS,CREATE_DATE ");
		sql.append(" FROM LR_MAP_TAG WHERE 1=1 ");
		if (params.get("mapTagType") != null) {
@@ -45,44 +45,44 @@ public class MapTagManageDaoImpl extends AbstractBizDao implements MapTagManageD
		sql.append(" ORDER BY CREATE_DATE DESC ");
		//获取数据列表
		List<Map<String, Object>> data=dao.executeSelect(sql.toString(), dataMap, pageNum, pageSize);
		
		//获取总条数
		sql.insert(0,"select count(1) dataNum from ( ");
		// 获取数据列表
		List<Map<String, Object>> data = dao.executeSelect(sql.toString(), dataMap, pageNum, pageSize);
		// 获取总条数
		sql.insert(0, "select count(1) dataNum from ( ");
		sql.append(" ) a ");
		
		Map map=dao.executeSelectOne(sql.toString(), dataMap);
		
		Map map = dao.executeSelectOne(sql.toString(), dataMap);
		JMap result = new JsonMap();
		result.put("dataList", data);
		result.put("dataNum", map.get("dataNum"));
		return result ;
		return result;
	}
	@Override
	public List<Map<String, Object>> queryListMapTagInfo(JMap params) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		
		Map<String, Object> dataMap = new HashMap<String, Object>();
		StringBuilder sql = new StringBuilder();
		sql.append(" SELECT MAP_TAG_ID,DEPARTMENT_ID,MAP_TAG_NAME,MAP_TAG_TYPE,MAP_TAG_CONTENT, ");
		sql.append(" ASTEXT(MAP_TAG_SHAPE) MAP_TAG_SHAPE,REMARKS,CREATE_DATE ");
		sql.append(" ASTEXT(MAP_TAG_SHAPE) MAP_TAG_SHAPE,RESIDENCE_TIME_LENGTH,REMARKS,CREATE_DATE ");
		sql.append(" FROM LR_MAP_TAG WHERE 1=1 ");
		//标记类型:可传多个，用逗号隔开
		String mapTagType=params.getString("mapTagType");
		// 标记类型:可传多个，用逗号隔开
		String mapTagType = params.getString("mapTagType");
		if (mapTagType != null) {
			if (mapTagType.indexOf(",")>0) {
				String[] mapTagTypeArray=mapTagType.split(",");
			if (mapTagType.indexOf(",") > 0) {
				String[] mapTagTypeArray = mapTagType.split(",");
				sql.append(" AND MAP_TAG_TYPE IN ( ");
				for (int i = 0; i < mapTagTypeArray.length; i++) {
					sql.append(" '").append(mapTagTypeArray[i]).append("' ");
					if (i!=mapTagTypeArray.length-1) {
					if (i != mapTagTypeArray.length - 1) {
						sql.append(" , ");
					}
				}
				sql.append(" ) ");
			}else {
			} else {
				sql.append(" AND MAP_TAG_TYPE = #{mapTagType} ");
				dataMap.put("mapTagType", mapTagType);
			}
@@ -95,21 +95,22 @@ public class MapTagManageDaoImpl extends AbstractBizDao implements MapTagManageD
	public Map<String, Object> queryOneMapTagInfo(JMap params) throws Exception {
		StringBuilder sql = new StringBuilder();
		sql.append(" SELECT MAP_TAG_ID,DEPARTMENT_ID,MAP_TAG_NAME,MAP_TAG_TYPE,MAP_TAG_CONTENT, ");
		sql.append(" ASTEXT(MAP_TAG_SHAPE) MAP_TAG_SHAPE,REMARKS,CREATE_DATE  ");
		sql.append(" ASTEXT(MAP_TAG_SHAPE) MAP_TAG_SHAPE,RESIDENCE_TIME_LENGTH,REMARKS,CREATE_DATE  ");
		sql.append(" FROM LR_MAP_TAG WHERE MAP_TAG_ID=#{mapTagId} ");
		return dao.executeSelectOne(sql.toString(), params);
	}
	@Override
	public boolean addMapTagInfo(JMap params) throws Exception {
		//拼接经纬度函数
		params.put("mapTagShape", "POLYGON (("+params.getString("mapTagShape")+"))");
		
		params.put("mapTagContent", params.get("mapTagContent")==null?"": params.get("mapTagContent"));
		params.put("remarks", params.get("remarks")==null?"": params.get("remarks"));
		
		// 拼接经纬度函数
		params.put("mapTagShape", "POLYGON ((" + params.getString("mapTagShape") + "))");
		params.put("residenceTimeLength", params.get("residenceTimeLength") == null ? null : params.get("residenceTimeLength"));
		params.put("mapTagContent", params.get("mapTagContent") == null ? null : params.get("mapTagContent"));
		params.put("remarks", params.get("remarks") == null ? null : params.get("remarks"));
		params.put("dataStatus", "1");
		//TODO 创建人和操作人的编号和部门
		// TODO 创建人和操作人的编号和部门
		params.put("departmentId", 1);
		params.put("createDate", TimeUtil.getSysTime());
		params.put("createOpId", "");
@@ -125,11 +126,11 @@ public class MapTagManageDaoImpl extends AbstractBizDao implements MapTagManageD
	@Override
	public boolean modifyMapTagInfo(JMap params) throws Exception {
		//拼接经纬度函数
		params.put("mapTagShape", "POLYGON (("+params.getString("mapTagShape")+"))");
		
		// 拼接经纬度函数
		params.put("mapTagShape", "POLYGON ((" + params.getString("mapTagShape") + "))");
		params.put("doneDate", TimeUtil.getSysTime());
		//TODO 操作人的编号和部门
		// TODO 操作人的编号和部门
		params.put("opId", "");
		params.put("orgId", "");
@@ -140,25 +141,28 @@ public class MapTagManageDaoImpl extends AbstractBizDao implements MapTagManageD
	@Override
	public boolean deleteMapTagInfo(JMap params) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		Map<String, Object> dataMap = new HashMap<String, Object>();
		dataMap.put("MAP_TAG_ID", params.get("mapTagId"));
		
		return dao.delete("LR_MAP_TAG", dataMap) > 0;
	}
	@Override
	public JMap getInAreaInfo(String latitude,String longitude) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		dataMap.put("coordinate", "POINT("+longitude+" "+latitude+")");
		
		String sql = "SELECT t.MAP_TAG_ID,t.MAP_TAG_NAME,t.MAP_TAG_TYPE,t.MAP_TAG_CONTENT "
	public JMap getInAreaInfo(String longitude, String latitude) throws Exception {
		Map<String, Object> dataMap = new HashMap<String, Object>();
		dataMap.put("coordinate", "POINT(" + longitude + " " + latitude + ")");
		String sql = "SELECT t.MAP_TAG_ID,t.MAP_TAG_NAME,t.MAP_TAG_TYPE,t.MAP_TAG_CONTENT,t.RESIDENCE_TIME_LENGTH "
				+ " FROM LR_MAP_TAG t WHERE ST_Within(PolygonFromText(#{coordinate}),t.MAP_TAG_SHAPE)=1";
		List<Map<String, Object>> resultList = dao.executeSelect(sql, dataMap);
		
		JMap result=new JsonMap();
		JMap result = new JsonMap();
		if (resultList != null && !resultList.isEmpty()) {
			result.put("mapTagNum", resultList.size());
			result.put("resultList", resultList);
			result.put("mapTagId", resultList.get(0).get("MAP_TAG_ID"));
			result.put("mapTagName", resultList.get(0).get("MAP_TAG_NAME"));
			result.put("mapTagType", resultList.get(0).get("MAP_TAG_TYPE"));
		} else {
			result.put("mapTagNum", 0);
		}

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

@@ -0,0 +1,84 @@
package com.ai.ipu.server.dao.impl;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Component;
import com.ai.ipu.common.date.TimeUtil;
import com.ai.ipu.data.JMap;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
import com.ai.ipu.server.dao.interfaces.RescueDao;
@Component
public class RescueDaoImpl extends AbstractBizDao implements RescueDao {
	public RescueDaoImpl() throws IOException {
		super("ebc");
	}
	@Override
	public JMap queryPageRescueLog(JMap params, int pageNum, int pageSize) throws Exception {
		// TODO Auto-generated method stub
		return null;
	}
	@Override
	public Map<String, Object> queryNoCloseRescueLog(JMap params) throws Exception {
		Map<String, Object> dataMap=new HashMap<String, Object>();
		StringBuilder sql=new StringBuilder();
		sql.append(" SELECT l.LOG_ID,l.CALLER_ID,l.DEVICE_ID,l.PARTY_TYPE,l.PARTY_CODE, ");
		sql.append(" l.PARTY_NAME,l.ALARM_TYPE,l.CALLER_DATE, ");
		sql.append(" l.RESCUERS_DATE,l.REMARKS ");
		sql.append(" FROM LR_RESCUE_LOG l ");
		sql.append(" WHERE 1=1 ");
		sql.append(" AND RESCUERS_DATE IS NULL ");//TODO 救援时间为空
		sql.append(" AND DEVICE_ID = #{deviceId} ");
		dataMap.put("deviceId", params.get("deviceId"));
		
		return dao.executeSelectOne(sql.toString(), dataMap);
	}
	@Override
	public Map<String, Object> queryOneRescueLog(JMap params) throws Exception {
		// TODO Auto-generated method stub
		return null;
	}
	/**
	 * TODO 临时存放
	 * 添加救援日志
	 */
	@Override
	public boolean addRescueLog(Map<String, Object> dataMap) throws Exception {
		dataMap.put("dataStatus", "1");
		//TODO 创建人和操作人的编号和部门
		dataMap.put("departmentId", 1);
		dataMap.put("createDate", TimeUtil.getSysTime());
		dataMap.put("createOpId", "");
		dataMap.put("createOrgId", "");
		dataMap.put("doneDate", TimeUtil.getSysTime());
		dataMap.put("opId", "");
		dataMap.put("orgId", "");
		int num=dao.insert("LR_RESCUE_LOG", dataMap);
		
		return num > 0;
	}
	@Override
	public boolean assignRescuer(JMap params) throws Exception {
		// TODO Auto-generated method stub
		return false;
	}
	@Override
	public boolean closeRescuer(JMap params) throws Exception {
		// TODO Auto-generated method stub
		return false;
	}
}

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

@@ -1,5 +1,6 @@
package com.ai.ipu.server.dao.interfaces;
import java.util.List;
import java.util.Map;
import com.ai.ipu.data.JMap;
@@ -45,13 +46,21 @@ public interface AreaInOutRecordDao {
	 * @return 
	 * @throws Exception
	 */
	JMap getBeforeAreaInfo(JMap params) throws Exception;
	List<Map<String, Object>> getBeforeAreaInfo(JMap params) throws Exception;
	/**
	 * 插入进出围栏日志
	 * @param params
	 * 插入进入围栏的日志
	 * @param dataMap
	 * @return
	 * @throws Exception
	 */
	boolean addAreaInRecord(Map<String, Object> dataMap) throws Exception;
	
	/**
	 * 修改出围栏的日志
	 * @param dataMap
	 * @return
	 * @throws Exception
	 */
	boolean addAreaInOutRecord(JMap params) throws Exception;
	boolean updateAreaOutRecord(Map<String, Object> dataMap) throws Exception;
}

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

@@ -64,4 +64,6 @@ public interface DeviceManageDao {
	int bindDevice(Map params, String type) throws Exception;
	int unbindDevice(Map params, String type) throws Exception;
	
	List<Map<String, Object>> queryCurrentDeviceLocationInfo(JMap params) throws Exception;
}

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

@@ -19,6 +19,8 @@ public interface EquipmentManageDao {
    boolean deleteEquipmentsInfo(List<Map<String, Object>> paramsList) throws Exception;
    boolean importEquipmentInfo(List<Map<String, Object>> paramsList) throws Exception;
    
    List<Map<String, Object>> queryAllEquipmentInfo(JMap params) throws Exception;
    Map<String, Object> verifyEquipmentInfoRepetition(JMap params) throws Exception;
}

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

@@ -61,11 +61,11 @@ public interface MapTagManageDao {
	/**
	 * 获取坐标点所在的围栏
	 * 
	 * @param latitude 经度
	 * @param longitude 纬度
	 * @param longitude 经度
	 * @param latitude 纬度
	 * @return
	 * @throws Exception
	 */
	JMap getInAreaInfo(String latitude,String longitude) throws Exception;
	JMap getInAreaInfo(String longitude, String latitude) throws Exception;
}

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

@@ -0,0 +1,57 @@
package com.ai.ipu.server.dao.interfaces;
import java.util.List;
import java.util.Map;
import com.ai.ipu.data.JMap;
public interface RescueDao {
	/**
	 * 分页查询报警救援日志
	 * @param params
	 * @param pageNum 当前页数
	 * @param pageSize 每页条数
	 * @return
	 * @throws Exception
	 */
	JMap queryPageRescueLog(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 根据终端标识获取未关闭的报警救援日志
	 * @param params
	 * @return
	 * @throws Exception
	 */
	Map<String, Object> queryNoCloseRescueLog(JMap params) throws Exception;
	/**
	 * 根据终端标识获取单个报警救援日志
	 * @param params
	 * @return
	 * @throws Exception
	 */
	Map<String, Object> queryOneRescueLog(JMap params) throws Exception;
	/**
	 * 添加报警救援日志
	 * @param dataMap
	 * @return
	 * @throws Exception
	 */
	boolean addRescueLog(Map<String, Object> dataMap) throws Exception;
	/**
	 * 指派救援
	 * @return
	 * @throws Exception
	 */
	boolean assignRescuer(JMap params) throws Exception;
	/**
	 * 关闭救援
	 * @return
	 * @throws Exception
	 */
	boolean closeRescuer(JMap params) throws Exception;
}

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

@@ -0,0 +1,33 @@
package com.ai.ipu.server.enums;
import com.ai.ipu.server.model.UrlAddress;
/**
 * iot 北向接口业务数据的地址枚举
 * 
 * @author konghl@asiainfo.com
 * 2020-10-20
 */
public enum IotUrlEnums {
	// 分页查询终端
	queryPageDevice("findTerminal"),
	// 添加终端
	addDevice("device"),
	// 修改终端
	updateDevice("updateDevice"),
	// 删除终端
	deleteDevice("deleteDevice?deviceId="),
	// 查询单个设备
	queryOneDevice("deviceSimpleDetail?deviceId=");
	private String url;
	private IotUrlEnums(String url) {
		this.url = url;
	}
	public String getUrl() {
		return UrlAddress.IOT_URL1 + "/" + url;
	}
}

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

@@ -0,0 +1,76 @@
package com.ai.ipu.server.enums;
import java.util.HashMap;
import java.util.Map;
/**
 * 设备类型枚举
 * 
 * @author konghl@asiainfo.com 
 * 2020-10-19
 */
public enum ProductEnums {
	// 船舶
	ship("001", "船舶", 1),
	// 风机
	fan("002", "风机", 2),
	// 升压站
	booster("003", "升压站", 2),
	// 测风塔
	anemometer("004", "测风塔", 2);
	private String productId;
	private String productName;
	private int productType;
	private ProductEnums(String productId, String productName, int productType) {
		this.productId = productId;
		this.productName = productName;
		this.productType = productType;
	}
	public String getProductId() {
		return productId;
	}
	public String getProductName() {
		return productName;
	}
	public int getProductType() {
		return productType;
	}
	/**
	 * 根据类型获取对应的产品类型列表
	 * 
	 * @param type 类型(1:绑定终端，2:不绑定终端)
	 * @return
	 */
	public static Map<String, Object> getProductByType(int type) {
		Map<String, Object> map = new HashMap<String, Object>();
		for (ProductEnums productEnum : ProductEnums.values()) {
			if (productEnum.getProductType() == type) {
				map.put("id", productEnum.getProductId());
				map.put("name", productEnum.getProductName());
			}
		}
		return map;
	}
	/**
	 * 获取所有的产品类型列表
	 * 
	 * @return
	 */
	public static Map<String, Object> getAllProduct() {
		Map<String, Object> map = new HashMap<String, Object>();
		for (ProductEnums productEnum : ProductEnums.values()) {
			map.put("id", productEnum.getProductId());
			map.put("name", productEnum.getProductName());
		}
		return map;
	}
}

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

@@ -0,0 +1,164 @@
package com.ai.ipu.server.enums;
import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.Map;
import org.springframework.util.ReflectionUtils;
public enum UserEnums {
    oneUser(1, "张三", "1111", "搜救", "经理"),
    twoUser(2, "李四", "2222", "搜救", "员工"),
    threeUser(3, "王五", "3333", "搜救", "员工"),
    fiveUser(4, "赵六", "4444", "搜救", "员工"),
    sixUser(5, "田七", "5555", "搜救", "员工");
    public int id; //id
    public String userName;//姓名
    public String employeeNo;//员工编号
    public String department;//部门
    public String duty;//职务
    UserEnums() {
    }
    UserEnums(int id, String userName, String employeeNo, String department, String duty) {
        this.id = id;
        this.userName = userName;
        this.employeeNo = employeeNo;
        this.department = department;
        this.duty = duty;
    }
    public int getId() {
        return id;
    }
    public String getUserName() {
        return userName;
    }
    public String getEmployeeNo() {
        return employeeNo;
    }
    public String getDepartment() {
        return department;
    }
    public String getDuty() {
        return duty;
    }
    /**
     * 根据id返回枚举值
     * @param id
     * @return
     */
    public static UserEnums   getEumByid(int id){
        for(UserEnums userEnum: UserEnums.values()) {
            if(userEnum.getId()==id) {
                return userEnum;
            }
        }
        return null;
    }
    /**
     * 根据序号获取枚举数组中的值，序号必须从0开始
     * @param id
     * @return
     * @throws IllegalAccessException
     * @throws IllegalArgumentException
     * @throws InvocationTargetException
     * @throws InstantiationException
     */
    public static <T> List<T> getEumByKey(int id) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException, InstantiationException {
        List<String> enumList=getEumValueList();
        List<T> enumList1=new ArrayList<T>();
        for(UserEnums testEnums: UserEnums.values()) {
            if(testEnums.getId()==id) {
                Class<?> clazz=testEnums.getClass();
                // 获取所有常量
                Object object = clazz.getEnumConstants()[id];
                Field[]  filedFields=clazz.getFields();
                for (Field field : filedFields) {
                    field.setAccessible(true);
                    Object sssObject=field.get(object);
                    if(enumList.contains(field.getName())) {
                        continue;
                    }else {
                        if(sssObject!=null)
                            enumList1.add((T) sssObject);
                    }
                }
                return enumList1;
            }
        }
        return null;
    }
    /**
     * 获取枚举值常量列表
     * @param
     * @return
     */
    public static List<String>  getEumValueList() {
        List<String> list=new ArrayList<String>();
        for(Object object:UserEnums.values()) {
            list.add(object.toString());
        }
        return list;
    }
    /**
     * 传入方法名称  values是值 ，field是 字段mingcheng
     * @param <T>
     * @param enumType
     * @param value
     * @param field
     * @return
     * @throws Exception
     */
    public static <T extends Enum<T>> T getEnumOnValue(Class<T> enumType, String value, String field) throws Exception {
        for (Object obj : enumType.getEnumConstants()) {
            Method m = obj.getClass().getDeclaredMethod("values", null);
            Object[] results = (Object[]) m.invoke(obj, null);
            for (Object result : results) {
                Field codeField = result.getClass().getDeclaredField(field);
                ReflectionUtils.makeAccessible(codeField);
                String fileValue = String.valueOf(ReflectionUtils.getField(codeField, result));
                if (fileValue.equals(value)) {
                    return (T) result;
                }
            }
        }
        return null;
    }
    /**
     * 获取所有的用户放到list里
     *
     * @return
     * @throws Exception
     */
    public static List<Map<String,Object>> getUserList(){
        ArrayList<Map<String,Object>> list = new ArrayList<Map<String,Object>>();
        for(UserEnums userEnum : UserEnums .values()){
            Map<String,Object> userMap = new HashMap<String,Object>();
            userMap.put("id",userEnum.getId());
            userMap.put("userName",userEnum.getUserName());
            userMap.put("employeeNo",userEnum.getEmployeeNo());
            userMap.put("department",userEnum.getDepartment());
            userMap.put("duty",userEnum.getDuty());
            list.add(userMap);
        }
        return list;
    }
}

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

@@ -13,7 +13,7 @@ import org.springframework.stereotype.Service;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.server.dao.interfaces.DeviceManageDao;
import com.ai.ipu.server.model.UserEnums;
import com.ai.ipu.server.enums.UserEnums;
import com.ai.ipu.server.service.interfaces.DeviceManageService;
import com.ai.ipu.server.util.EbcConstant;
import com.alibaba.fastjson.JSON;
@@ -100,7 +100,7 @@ public class DeviceManageServiceImpl implements DeviceManageService {
	}
	@Override
	public List<Map<String, Object>> queryListDeviceInfo(JMap params, int pageNum, int pageSize) throws Exception {
	public List<Map<String, String>> queryListDeviceInfo(JMap params, int pageNum, int pageSize) throws Exception {
		// 查询条件
		Map<String, String> businessParams = new HashMap<String, String>();
		businessParams.put("specId", EbcConstant.beidouDevice_product_id); // 所属产品
@@ -108,9 +108,21 @@ public class DeviceManageServiceImpl implements DeviceManageService {
		params.put("businessParams", businessParams);
		Map<String, String> deviceInfoMap = deviceManageDao.queryPageDeviceInfo(params, pageNum, pageSize);
		List<Map> deviceInfoList = JSON.parseArray(deviceInfoMap.get("result"), Map.class);
		List<Map> deviceInfoList = JSON.parseArray(JSON.toJSONString(deviceInfoMap.get("result")), Map.class);
		// 整理返回数据信息
		List<Map<String, String>> dataList = new ArrayList<Map<String, String>>();
		if (deviceInfoList != null && deviceInfoList.size() > 0) {
			for (Map map : deviceInfoList) {
				Map<String, String> dataMap = new HashMap<String, String>();
				String deviceId = String.valueOf(map.get("resourceId"));
				dataMap.put("deviceId", deviceId);
				dataMap.put("deviceNo", deviceId);
				dataList.add(dataMap);
			}
		}
		return queryListDeviceInfo(params, pageNum, pageSize);
		return dataList;
	}
	@Override
@@ -137,14 +149,13 @@ public class DeviceManageServiceImpl implements DeviceManageService {
	public List<Map<String, Object>> queryAssociatInfo(JMap params) throws Exception {
		if (EbcConstant.bind_device_type_user.equals(params.get("type"))) {
			// 类型是用户，查询用户列表
			// 调用uspa接口获取人员信息 暂时用枚举
			List<Map<String, Object>> userList = UserEnums.getUserList();
			return userList;
			// TODO 调用uspa接口获取人员信息 暂时用枚举
			return UserEnums.getUserList();
		} else if (EbcConstant.bind_device_type_ship.equals(params.get("type"))) {
			// 类型是船舶，查询船舶列表
			return deviceManageDao.queryAssociatBoatInfo(params);
		}
		return null;
		return new ArrayList<Map<String, Object>>();
	}
	@Override
@@ -166,4 +177,9 @@ public class DeviceManageServiceImpl implements DeviceManageService {
		return num > 0;
	}
	@Override
	public List<Map<String, Object>> queryCurrentDeviceLocationInfo(JMap params) throws Exception {
		return deviceManageDao.queryCurrentDeviceLocationInfo(params);
	}
}

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

@@ -53,6 +53,11 @@ public class EquipmentManageServiceImpl implements EquipmentManageService {
    }
    @Override
	public List<Map<String, Object>> queryAllEquipmentInfo(JMap params) throws Exception {
		return equipmentManageDao.queryAllEquipmentInfo(params);
	}
    
    @Override
    public Map<String, Object> verifyEquipmentInfoRepetition(JMap params) throws Exception{
        return equipmentManageDao.verifyEquipmentInfoRepetition(params);
    }

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

@@ -0,0 +1,264 @@
package com.ai.ipu.server.service.impl;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.data.JMap;
import com.ai.ipu.server.dao.interfaces.AreaInOutRecordDao;
import com.ai.ipu.server.dao.interfaces.DeviceManageDao;
import com.ai.ipu.server.dao.interfaces.MapTagManageDao;
import com.ai.ipu.server.dao.interfaces.RescueDao;
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;
@Service
public class ReceiveSubscribeServiceImpl implements ReceiveSubscribeService {
	private static final ILogger logger = IpuLoggerFactory.createLogger(ReceiveSubscribeServiceImpl.class);
	@Autowired
	MapTagManageDao mapTagManageDao;
	@Autowired
	DeviceManageDao deviceManageDao;
	@Autowired
	RescueDao rescueDao;
	@Autowired
	AreaInOutRecordDao areaInOutRecordDao;
	ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
	@Override
	public void receiveIotLocationData(JMap dataMap) {
		executeReceiveIotLocationData(dataMap);
		/*ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
		cachedThreadPool.execute(new Runnable() {
			 
			@Override
			public void run() {
				
			}
		});*/
	}
	@Override
	public void receiveIotAlarmData(JMap dataMap) {
		executeReceiveIotAlarmData(dataMap);
	}
	/**
	 * 处理定位数据
	 * @param dataMap
	 */
	private void executeReceiveIotLocationData(JMap params) {
		try {
			// 1、查询是否为需救援的人员
			Map<String, Object> alarmMap = rescueDao.queryNoCloseRescueLog(params);
			// 当前已为报警信息
			if (alarmMap != null) {
				// 执行对应方法
				beforeAlarmLocationData(params, alarmMap);
			}
			// 2、查询人员当前是否在围栏内
			JMap currentAreaInfoJMap = mapTagManageDao.getInAreaInfo(params.getString("longitude"),
					params.getString("latitude"));
			// 3、查询人员之前所在围栏信息
			List<Map<String, Object>> beforeAreaMapList = areaInOutRecordDao.getBeforeAreaInfo(params);
			if (currentAreaInfoJMap.getInt("mapTagNum") == 0) {
				// 当前未在围栏内
				currentNotInArea(params, beforeAreaMapList);
			} else {
				// 当前在围栏内
				// TODO 当前只判断一个围栏信息
				List<Map<String, Object>> currentAreaInfoList=(List<Map<String, Object>>)currentAreaInfoJMap.get("resultList");
				Map<String, Object> currentAreaInfoMap = currentAreaInfoList.get(0);
				currentInArea(params, currentAreaInfoMap, beforeAreaMapList);
			}
		} catch (Exception ex) {
			logger.error(ex.getMessage());
		}
	}
	/**
	 * 当前已为报警信息
	 * 
	 * @param params
	 * @param alarmMap
	 * @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.toString());
		// 推送镜屏
		String jingpingData = JSON.toJSONString(params);
		logger.debug("推送镜屏数据：" + jingpingData);
		JingPingSendDateUtil.sendData(JingPingSendDateUtil.topic_personnel, jingpingData);
	}
	/**
	 * 当前未在围栏内
	 * @param params
	 * @param beforeAreaMapList 之前进入围栏的信息
	 * @throws Exception 
	 */
	private void currentNotInArea(JMap params, List<Map<String, Object>> beforeAreaMapList) throws Exception {
		// 1、判断之前是否已在围栏内
		if (beforeAreaMapList != null) {
			List<String> recordIdList=new ArrayList<String>();
			for (Map<String, Object> beforeAreaMap : beforeAreaMapList) {
				recordIdList.add(String.valueOf(beforeAreaMap.get("RECORD_ID")));
			}
			
			Map<String, Object> dataMap = new HashMap<String, Object>();
			dataMap.put("recordId", recordIdList);// 进入围栏记录ID
			dataMap.put("outDate", params.get("newDate")); // 离开围栏时间
			// 记录离开围栏时间
			areaInOutRecordDao.updateAreaOutRecord(dataMap);
		}
		// 2、推送镜屏
		String jingpingData = JSON.toJSONString(params);
		logger.debug("推送镜屏数据：" + jingpingData);
		JingPingSendDateUtil.sendData(JingPingSendDateUtil.topic_personnel, jingpingData);
	}
	/**
	 * 进入围栏
	 * @param params
	 * @param currentAreaInfoMap 当前所在围栏信息
	 * @param beforeAreaMapList 之前进入围栏的信息
	 * @throws Exception 
	 */
	private void currentInArea(JMap params, Map<String, Object> currentAreaInfoMap,
			List<Map<String, Object>> beforeAreaMapList) throws Exception {
		// 围栏类型
		String mapTagType = String.valueOf(currentAreaInfoMap.get("MAP_TAG_TYPE"));
		if (beforeAreaMapList != null&&beforeAreaMapList.size()>0) {
			// 之前在围栏内
			// TODO 当前只判断一个围栏信息
			Map<String, Object> beforeAreaMap = beforeAreaMapList.get(0);
			if (String.valueOf(beforeAreaMap.get("MAP_TAG_ID"))
					.equals(String.valueOf(currentAreaInfoMap.get("mapTagId")))) {
				// 如果是定点围栏，则计算进入时长
				if (EbcConstant.area_type_temporariness.equals(mapTagType)) {
					// 计算已进入时长
					String newDate = params.getString("newDate");// 当前定位时间
					SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
					long newDateLong = simpleDateFormat.parse(newDate).getTime();
					long fixedLong = System.currentTimeMillis() - newDateLong;
					BigDecimal fixedLongBigDecimal = new BigDecimal(fixedLong);
					// 单位为分，四舍五入不保留小数
					long fixedMinute = fixedLongBigDecimal.divide(new BigDecimal("60000L"), 0, BigDecimal.ROUND_HALF_UP)
							.longValue();
					// 围栏要求定点时间
					long residenceTimeLength = Long
							.getLong(String.valueOf(currentAreaInfoMap.get("RESIDENCE_TIME_LENGTH")));
					if (residenceTimeLength < fixedMinute) {
						// 定点超过要求时间
						params.put("locationStatus", EbcConstant.location_status_violation);
					}
					params.put("fixedLong", fixedMinute);
				}
			}
		} else {
			// 之前不在围栏内
			Map<String, Object> dataMap = new HashMap<String, Object>();
			dataMap.put("MAP_TAG_ID", currentAreaInfoMap.get("MAP_TAG_ID"));
			dataMap.put("EMPLOYEE_ID", 0);// TODO 人员ID
			dataMap.put("DEVICE_ID", params.get("deviceId"));
			dataMap.put("LONGITUDE", params.get("longitude"));
			dataMap.put("LATITUDE", params.get("latitude"));
			dataMap.put("RECORD_LOCATION", currentAreaInfoMap.get("MAP_TAG_NAME"));
			dataMap.put("IN_DATE", params.get("newDate"));
			// 记录进入围栏日志
			areaInOutRecordDao.addAreaInRecord(dataMap);
		}
		// 2、推送镜屏
		String jingpingData = JSON.toJSONString(params);
		logger.debug("推送镜屏数据：" + jingpingData);
		JingPingSendDateUtil.sendData(JingPingSendDateUtil.topic_personnel, jingpingData);
	}
	/**
	 * 处理报警数据
	 * @param dataMap
	 */
	private void executeReceiveIotAlarmData(JMap params) {
		try {
			// 1、获取人员信息
			Map<String, Object> deviceAndUser = deviceManageDao.queryAssociatUser(params);
			// 2、获取围栏信息
			JMap currentAreaInfo = 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 (currentAreaInfo.getInt("mapTagNum") > 0) {
				// TODO 只记录第一条围栏地址
				dataMap.put("CALLER_LOCATION", currentAreaInfo.get("mapTagName"));
			} else {
				dataMap.put("CALLER_LOCATION", "");
			}
			// 3、保存报警数据
			rescueDao.addRescueLog(dataMap);
		} catch (Exception e) {
			logger.error("保存报警数据失败");
		}
	}
}

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

@@ -0,0 +1,38 @@
package com.ai.ipu.server.service.impl;
import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ai.ipu.data.JMap;
import com.ai.ipu.server.dao.interfaces.RescueDao;
import com.ai.ipu.server.service.interfaces.RescueService;
@Service
public class RescueServiceImpl implements RescueService {
	@Autowired
	RescueDao rescueDao;
	@Override
	public JMap queryPageRescueLog(JMap params, int pageNum, int pageSize) throws Exception {
		return rescueDao.queryPageRescueLog(params, pageNum, pageSize);
	}
	@Override
	public Map<String, Object> queryOneRescueLog(JMap params) throws Exception {
		return rescueDao.queryOneRescueLog(params);
	}
	@Override
	public boolean assignRescuer(JMap params) throws Exception {
		return rescueDao.assignRescuer(params);
	}
	@Override
	public boolean closeRescuer(JMap params) throws Exception {
		return rescueDao.closeRescuer(params);
	}
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/interfaces/DeviceManageService.java

@@ -25,7 +25,7 @@ public interface DeviceManageService {
	 * @return
	 * @throws Exception
	 */
	List<Map<String, Object>> queryListDeviceInfo(JMap params, int pageNum, int pageSize) throws Exception;
	List<Map<String, String>> queryListDeviceInfo(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 获取单个终端信息
@@ -66,4 +66,6 @@ public interface DeviceManageService {
	List<Map<String, Object>> queryAssociatInfo(JMap params) throws Exception;
	Map<String, Object> verifyUserOrBoatAssociatInfo(JMap params) throws Exception;
	
	List<Map<String, Object>> queryCurrentDeviceLocationInfo(JMap params) throws Exception;
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/interfaces/EquipmentManageService.java

@@ -20,5 +20,7 @@ public interface EquipmentManageService {
    boolean importEquipmentInfo(List<Map<String,Object>> paramsList) throws Exception;
    List<Map<String, Object>> queryAllEquipmentInfo(JMap params) throws Exception;
    
    Map<String, Object> verifyEquipmentInfoRepetition(JMap params) throws Exception;
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/interfaces/ExportService.java

@@ -1,11 +1,10 @@
package com.ai.ipu.server.service.interfaces;
import com.ai.ipu.data.JMap;
import org.springframework.http.ResponseEntity;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.http.ResponseEntity;
public interface ExportService {
    ResponseEntity<byte[]> exportMapTagInfoToExcel(HttpServletRequest request, HttpServletResponse response, Object object);

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/interfaces/GisTokenService.java

@@ -1,7 +1,5 @@
package com.ai.ipu.server.service.interfaces;
import com.ai.ipu.data.JMap;
import java.util.Map;
public interface GisTokenService {

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/interfaces/ReceiveSubscribeService.java

@@ -0,0 +1,10 @@
package com.ai.ipu.server.service.interfaces;
import com.ai.ipu.data.JMap;
public interface ReceiveSubscribeService {
	
	void receiveIotLocationData(JMap dataMap);
	
	void receiveIotAlarmData(JMap dataMap);
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/service/interfaces/RescueService.java

@@ -0,0 +1,41 @@
package com.ai.ipu.server.service.interfaces;
import java.util.Map;
import com.ai.ipu.data.JMap;
public interface RescueService {
	/**
	 * 分页查询报警救援日志
	 * @param params
	 * @param pageNum 当前页数
	 * @param pageSize 每页条数
	 * @return
	 * @throws Exception
	 */
	JMap queryPageRescueLog(JMap params, int pageNum, int pageSize) throws Exception;
	/**
	 * 获取单个报警救援日志
	 * @param params
	 * @return
	 * @throws Exception
	 */
	Map<String, Object> queryOneRescueLog(JMap params) throws Exception;
	/**
	 * 指派救援
	 * @return
	 * @throws Exception
	 */
	boolean assignRescuer(JMap params) throws Exception;
	/**
	 * 关闭救援
	 * @return
	 * @throws Exception
	 */
	boolean closeRescuer(JMap params) throws Exception;
}

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

@@ -42,4 +42,34 @@ public class EbcConstant {
	// 围栏标记类型：定点
	public static final String area_type_temporariness = "4";
	//定位状态：正常
	public static final String location_status_normal="0";
	
	//定位状态：离线
	public static final String location_status_offline="1";
	
	//定位状态：违规
	public static final String location_status_violation="2";
	
	//人员状态：SOS(手动)
	public static final String location_status_jogsos="3";
	
	//人员状态：SOS(自动)
	public static final String location_status_autosos="4";
	
	//人员状态：救援人员
	public static final String location_status_rescuers="5";
	
	//人员状态：离线
	public static final String location_status_offline_ZH="离线告警";
	
	//人员状态：违规
	public static final String location_status_violation_ZH="违规告警";
	
	//人员状态：SOS(手动)
	public static final String location_status_jogsos_ZH="手动告警";
	
	//人员状态：SOS(自动)
	public static final String location_status_autosos_ZH="落水告警";
	
}

ebc-sea-platform/src/main/resources/sql/ipu/MapTagManageDao.xml

@@ -4,7 +4,7 @@
		<![CDATA[
		<insert id="addMapTagInfo" resultType="java.util.Map" useGeneratedKeys="true" keyProperty="MAP_TAG_ID">
			INSERT INTO LR_MAP_TAG(		
			DEPARTMENT_ID,MAP_TAG_NAME,MAP_TAG_TYPE,MAP_TAG_CONTENT,MAP_TAG_SHAPE,REMARKS,
			DEPARTMENT_ID,MAP_TAG_NAME,MAP_TAG_TYPE,MAP_TAG_CONTENT,MAP_TAG_SHAPE,RESIDENCE_TIME_LENGTH,REMARKS,
			DATA_STATUS,CREATE_DATE,CREATE_OP_ID,CREATE_ORG_ID,DONE_DATE,OP_ID,ORG_ID
		   )VALUES (
			#{departmentId},
@@ -12,6 +12,7 @@
			#{mapTagType},
			#{mapTagContent},
			POLYGONFROMTEXT(#{mapTagShape}),
			#{residenceTimeLength},
			#{remarks},
			
			#{dataStatus},
@@ -44,6 +45,9 @@
				<if test="mapTagContent != null">
					MAP_TAG_CONTENT = #{mapTagContent},
				</if>
				<if test="residenceTimeLength != null">
					RESIDENCE_TIME_LENGTH = #{residenceTimeLength},
				</if>
				<if test="remarks != null">
					REMARKS = #{remarks},
				</if>