diff --git a/pom.xml b/pom.xml
index 177c358c..63b06864 100644
--- a/pom.xml
+++ b/pom.xml
@@ -317,6 +317,11 @@
spring-boot-starter-webflux
+
+
+ org.springframework.boot
+ spring-boot-starter-data-redis
+
net.sf.ehcache
diff --git a/src/main/java/com/zcloud/controller/czksmap/CzksMapController.java b/src/main/java/com/zcloud/controller/czksmap/CzksMapController.java
deleted file mode 100644
index 34e323f9..00000000
--- a/src/main/java/com/zcloud/controller/czksmap/CzksMapController.java
+++ /dev/null
@@ -1,556 +0,0 @@
-package com.zcloud.controller.czksmap;
-
-import com.alibaba.fastjson.JSONObject;
-import com.zcloud.controller.base.BaseController;
-import com.zcloud.entity.Page;
-import com.zcloud.entity.PageData;
-import com.zcloud.service.czksbimap.CzksBiMapService;
-import com.zcloud.service.bus.CorpInfoService;
-import com.zcloud.service.fireresources.CzksFireResourcesService;
-import com.zcloud.service.gatemachine.GateMachineService;
-//import com.zcloud.service.keyProjects.MeteorologicalService;
-//import com.zcloud.service.keyProjects.MeteorologicalinfoService;
-import com.zcloud.service.keyProjects.PlatformvideomanagementService;
-import com.zcloud.service.keyProjects.VideoManagerService;
-import com.zcloud.service.system.DepartmentService;
-import com.zcloud.service.system.UsersService;
-import com.zcloud.util.HttpRequestUtil;
-import com.zcloud.util.Jurisdiction;
-import com.zcloud.util.ReturnMap;
-import com.zcloud.util.Tools;
-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;
-import org.springframework.web.client.RestTemplate;
-
-import javax.annotation.Resource;
-import java.util.HashMap;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 说明:实时地图
- * 官网:www.zcloudchina.com
- */
-@Controller
-@RequestMapping("/czks/map")
-public class CzksMapController extends BaseController {
-
- @Resource
- private CzksBiMapService biMapService;
-
- @Autowired
- private VideoManagerService videomanagerService;
- @Autowired
- private CorpInfoService corpInfoService;
-
- @Autowired
- private PlatformvideomanagementService platformvideomanagementService;
- @Autowired
- private UsersService usersService;
-
-// @Autowired
-// private MeteorologicalinfoService meteorologicalinfoService;
-
- @Autowired
- private RestTemplate restTemplate;
-
- @Autowired
- private CzksFireResourcesService fireResourcesService;
-
- @Autowired
- private DepartmentService departmentService;
-
- @Autowired
- private GateMachineService gateMachineService;
-
-
- @RequestMapping("/getPointInfoADeviceByPid")
- @ResponseBody
- public Object getPointInfoADeviceByPid() {
- PageData pd = this.getPageData();
- PageData map = fireResourcesService.getPointInfoADeviceByPid(pd);
- map.put("result", "success");
- return map;
- }
-
- @RequestMapping("/getPointQualifiedPhotos")
- @ResponseBody
- public Object getPointQualifiedPhotos() {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- map.put("result", "success");
- map.put("varList", fireResourcesService.getPointQualifiedPhotos(pd));
- return map;
- }
-
-
- /**
- * @Description: 消防管控
- * @Author: dearLin
- * @Date: 2023/9/20/020 15:30
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getFireControl")
- @ResponseBody
- public Object getFireControl() throws Exception {
- Map map = new HashMap();
- PageData pageData = this.getPageData();
- LinkedList value = biMapService.getFireControl(pageData);
- for (PageData data : value) {
- data.put("MAP_POINT_NAME", data.getString("NAME"));
- }
- map.put("result", "success");
- map.put("varList", value);
- return map;
- }
-
- /**
- * @Description: 消防资源
- * @Author: dearLin
- * @Date: 2023/9/26/026 17:36
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getFireResourceById")
- @ResponseBody
- public Object getFireResourceById() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pddata = this.getPageData();
- //获取当前人的公司id
- PageData pd = fireResourcesService.getDataById(pddata);
- map.put("pd", pd);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * @Description: 消防救援队
- * @Author: dearLin
- * @Date: 2023/9/20/020 15:30
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getFireRescueTeam")
- @ResponseBody
- public Object getFireRescueTeam() throws Exception {
- Map map = new HashMap();
- PageData pageData = this.getPageData();
- LinkedList data = biMapService.getFireRescueTeam(pageData);
- map.put("result", "success");
- map.put("varList", data);
- return map;
- }
-
-
- /**
- * 气象信息对接接口
- *
- * @return
- * @throws Exception
- */
-// @RequestMapping(value = "/tongMeteorologicalinfoList")
-// @ResponseBody
-// public ReturnMap tongMeteorologicalinfoList(@RequestBody List list) throws Exception {
-// ReturnMap r = new ReturnMap();
-// r = meteorologicalinfoService.tongbuMeteorologicalinfo(list);
-// return r;
-// }
-
-
- /**
- * @Description: 闸机设备在线情况 只有人车闸机
- * @Author: dearLin
- * @Date: 2023/9/23/023 9:04
- * @Param:
- * @Return:
- */
- @RequestMapping("/getOnlineGateEquipment")
- @ResponseBody
- public ReturnMap getOnlineGateEquipment() {
- ReturnMap returnMap = new ReturnMap();
- PageData pageData = this.getPageData();
- PageData value = gateMachineService.getOnlineGateMachine(pageData);
- returnMap.put("pd", value);
- return returnMap;
- }
-
- /**
- * @Description: 闸机位置
- * @Author: dearLin
- * @Date: 2023/9/23/023 9:04
- * @Param:
- * @Return:
- */
-// @RequestMapping("/getGatePosition")
-// @ResponseBody
-// public ReturnMap getGatePosition() {
-// ReturnMap returnMap = new ReturnMap();
-// PageData pageData = this.getPageData();
-// //
-// List value = gateMachineService.getGatePosition(pageData);
-// // 添加标点上的统一的title
-// for (PageData data : value) {
-// if (Tools.notEmpty(data.getString("GATE_AREA_NAME"))) {
-// data.put("MAP_POINT_NAME", data.getString("GATE_AREA_NAME"));
-// } else {
-// data.put("MAP_POINT_NAME", data.getString("NAME"));
-// }
-// }
-// returnMap.put("varList", value);
-// return returnMap;
-// }
-
-
- /**
- * @Description: 口门进出记录列表
- * @Author: dearLin
- * @Date: 2023/9/23/023 9:04
- * @Param:
- * @Return:
- */
- @RequestMapping("/getDoorWayRecords")
- @ResponseBody
- public ReturnMap getDoorWayRecords(Page page) {
- ReturnMap returnMap = new ReturnMap();
- PageData pageData = this.getPageData();
- page.setPd(pageData);
- if ("0".equals(pageData.getString("INDEX"))) {
- // 人
- List value = biMapService.getDoorWayPeopleRecords(page);
- returnMap.put("varList", value);
- return returnMap;
- } else {
- // 车
- List value = biMapService.getDoorWayCarRecords(page);
- returnMap.put("varList", value);
- return returnMap;
- }
- }
-
-
- /**
- * @Description: 闸机进出车、人的数量
- * @Author: dearLin
- * @Date: 2023/9/23/023 9:04
- * @Param:
- * @Return:
- */
- @RequestMapping("/getGatesInAndOutNumById")
- @ResponseBody
- public ReturnMap getGatesInAndOutNumById() {
- ReturnMap returnMap = new ReturnMap();
- PageData pageData = this.getPageData();
- Map data = biMapService.getGatesInAndOutNumById(pageData);
- returnMap.put("pd", data);
- return returnMap;
- }
-
- /**
- * 人员进出记录列表
- *
- * @return
- */
- @RequestMapping("/getGatesInAndOutListById")
- @ResponseBody
- public ReturnMap getGatesInAndOutListById(Page page) {
- ReturnMap returnMap = new ReturnMap();
- PageData pd = this.getPageData();
- page.setPd(pd);
- List recordAllList = gateMachineService.getPersonRecordListAllByEId(page);
- returnMap.put("recordAllList", recordAllList);
- return returnMap;
- }
-
-
- @RequestMapping(value = "/fireResource/list")
- @ResponseBody
- public Object page(Page page) {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- //获取当前人的公司id
- page.setPd(pd);
-
- List varList = fireResourcesService.datalistPage(page);
- map.put("varList", varList);
- map.put("page", page);
- map.put("result", errInfo);
- return map;
- }
-
- @RequestMapping(value = "/fireDevice/listByMap")
- @ResponseBody
- public Object devicelistByMap(Page page) {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- String corpinfoId = Jurisdiction.getCORPINFO_ID();
- pd.put("CORPINFO_ID", corpinfoId);
-
- //获取当前人的公司id
- page.setPd(pd);
- List varList = fireResourcesService.devicelistPage(page);
- map.put("varList", varList);
- map.put("page", page);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * 获取人员、车辆进出记录
- *
- * @param
- * @return
- */
- @RequestMapping(value = "/getPerpleCarGateMachineCount")
- @ResponseBody
- public Object getPerpleCarGateMachineCount() {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- map.put("result", errInfo);
- return map;
- }
-
- @RequestMapping(value = "/getMachineTodayInOutCount")
- @ResponseBody
- public Object getMachineTodayInOutCount() {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- List value = gateMachineService.getTodayInOutCount(pd);
- map.put("varList", value);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * 沧州矿石人员定位,告警数据 Alarm data
- */
- @RequestMapping(value = "/getAlarmData")
- @ResponseBody
- public Object getAlarmData() {
- return HttpRequestUtil.getPeopleApi("/statistics/alarmStatistics/todayAlarm", "");
- }
-
- /**
- * @Description: 定位基础信息
- * @Author: dearLin
- * @Date: 2024/1/6/006 11:15
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "/getCzksBasicLocationInfoData")
- @ResponseBody
- public Object getCzksBasicLocationInfoData() {
- return HttpRequestUtil.getPeopleApi("/statistics/personStatistics/todayPerson", "");
- }
-
- @RequestMapping("/getGatePosition")
- @ResponseBody
- public ReturnMap getCzksGatePosition() {
- ReturnMap returnMap = new ReturnMap();
- PageData pageData = this.getPageData();
- //
- pageData.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
- List value = gateMachineService.getGatePosition(pageData);
- // 添加标点上的统一的title
- for (PageData data : value) {
- if (Tools.notEmpty(data.getString("GATE_AREA_NAME"))) {
- data.put("MAP_POINT_NAME", data.getString("GATE_AREA_NAME"));
- } else {
- data.put("MAP_POINT_NAME", data.getString("NAME"));
- }
- }
- returnMap.put("varList", value);
- return returnMap;
- }
-
- /**
- * @Description: 人员定位信息
- * @Author: dearLin
- * @Date: 2024/1/6/006 17:33
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "person/allPerson/listPage")
- @ResponseBody
- public Object getCzksOnlinePersion() throws Exception {
- PageData pageData = this.getPageData();
- JSONObject request = new JSONObject();
- request.put("pageNum", 1);
- request.put("pageSize", 10);
- request.put("online", "true");
- // 人员定位在线
- ReturnMap online = HttpRequestUtil.getPeopleApi("/person/allPerson/listPage", request.toString());
- pageData.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
- // 系统人员数
- int userCount = usersService.getUserCount(pageData);
- // 系统部门数
- int departCount = departmentService.getDepartmentCount(pageData);
- online.put("userCount",userCount);
- online.put("departCount",departCount);
- return online;
- }
- /**
- * @Description: 电子围栏报警 Electronic fence
- * @Author: dearLin
- * @Date: 2024/1/6/006 11:15
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "/getFenceAlarmList")
- @ResponseBody
- public Object getFenceAlarmList() {
- PageData pageData = this.getPageData();
- JSONObject request = new JSONObject();
- request.put("pageNum", pageData.getString("currentPage"));
- request.put("pageSize", pageData.getString("showCount"));
- request.put("beginTime", pageData.getString("beginTime"));
- request.put("endTime", pageData.getString("endTime"));
- request.put("alarmType", pageData.getString("alarmType"));
- request.put("alarmStatus", pageData.getString("alarmStatus"));
- request.put("realName", pageData.getString("realName"));
- // 标签卡
- return HttpRequestUtil.getPeopleApi("/system/alarm/person/listPage", request.toString());
- }
- /**
- * @Description: 电子围栏报警 Electronic fence
- * @Author: dearLin
- * @Date: 2024/1/6/006 11:15
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "/getElectronicFenceList")
- @ResponseBody
- public Object getElectronicFenceList() {
- PageData pageData = this.getPageData();
- JSONObject request = new JSONObject();
- request.put("pageNum", pageData.getString("currentPage"));
- request.put("pageSize", pageData.getString("showCount"));
- request.put("railName", pageData.getString("railName"));
- // 标签卡
- return HttpRequestUtil.getPeopleApi("/system/rail/listPage", request.toString());
- }
-
- /**
- * @Description: 获取摄像头定位
- * @Author: dearLin
- * @Date: 2024/1/6/006 11:15
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "/getCameraPositioning")
- @ResponseBody
- public Object getCameraPositioning() {
- ReturnMap returnMap = new ReturnMap();
- PageData pageData = new PageData();
- pageData.put("CORPINFO_ID",Jurisdiction.getCORPINFO_ID());
- List dataList = platformvideomanagementService.listAllForMap(pageData);
- returnMap.put("varList",dataList);
- return returnMap;
- }
- /**
- * @Description: 设备在线情况
- * @Author: dearLin
- * @Date: 2024/1/6/006 11:15
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "/getListMapSluiceCount")
- @ResponseBody
- public Object getListMapSluiceCount() {
- ReturnMap returnMap = new ReturnMap();
- PageData pageData = new PageData();
- pageData.put("CORPINFO_ID",Jurisdiction.getCORPINFO_ID());
- List dataList = platformvideomanagementService.getListMapSluiceCount(pageData);
- returnMap.put("varList",dataList);
- return returnMap;
- }
- @RequestMapping(value = "/person/staff/listPage")
- @ResponseBody
- public Object getCzksPersonStaffListPage() {
- PageData pageData = this.getPageData();
- JSONObject request = new JSONObject();
- request.put("pageNum", pageData.getString("pageNum"));
- request.put("pageSize", pageData.getString("pageSize"));
- // 普通员工
- if ("1".equals(pageData.getString("type"))) {
- return HttpRequestUtil.getPeopleApi("/person/staff/listPage", request.toString());
- } else {
- // 相关方 员工
- return HttpRequestUtil.getPeopleApi("/person/allPerson/listPage", request.toString());
- }
- }
- /**
- * 沧州矿石人员定位结束 定位基础信息
- */
- /**
- * 获取人员、车辆进出记录
- *
- * @param
- * @return
- */
- @RequestMapping(value = "/getCurrentLocationOnline")
- @ResponseBody
- public Object getCurrentLocationOnline() {
- Map map = new HashMap();
- String errInfo = "success";
- map.put("result", errInfo);
- return map;
- }
-
- // 获取人员定位信息 根据定位卡(身份证)编码
- @RequestMapping(value = "/getPersonByCardNo")
- @ResponseBody
- public Object getPersonByCardNo() throws Exception {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- PageData value = usersService.getPersonByCardNo(pd);
- map.put("result", "success");
- map.put("pd", value);
- return map;
- }
-
- /**
- * 获取摄像头播放路径(曹妃甸使用)
- *
- * @throws Exception
- */
- @RequestMapping(value = "/getHlsPath")
- @ResponseBody
- public Object getHlsPath() throws Exception {
- Map map = new HashMap();
-
- return map;
- }
-
- /**
- * 查询人员在线及统计数据(曹妃甸使用)
- *
- * @throws Exception
- */
- @RequestMapping(value = "/getCurrentPersonnelData")
- @ResponseBody
- public Object getCurrentPersonnelData() throws Exception {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- return map;
- }
-
- @RequestMapping("/getUserMapInfo")
- @ResponseBody
- public ReturnMap getUserMapInfo() throws Exception {
- PageData pd = this.getPageData();
- pd = usersService.findByCardNo(pd); //列出HotWorkApplicationDelayed列表
- ReturnMap r = ReturnMap.ok();
- r.put("pd", pd);
- return r;
- }
-
-}
diff --git a/src/main/java/com/zcloud/controller/czksmap/CzksMapEightController.java b/src/main/java/com/zcloud/controller/czksmap/CzksMapEightController.java
deleted file mode 100644
index a6957fe7..00000000
--- a/src/main/java/com/zcloud/controller/czksmap/CzksMapEightController.java
+++ /dev/null
@@ -1,187 +0,0 @@
-package com.zcloud.controller.czksmap;
-
-import com.zcloud.controller.base.BaseController;
-import com.zcloud.entity.Page;
-import com.zcloud.entity.PageData;
-import com.zcloud.service.czksbimap.CzksMapEightService;
-import com.zcloud.util.Jurisdiction;
-import org.apache.commons.lang.StringUtils;
-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.RequestParam;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.client.RestTemplate;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 说明:实时地图八项工作内容
- * 官网:www.zcloudchina.com
- */
-@Controller
-@RequestMapping("/czks/Eight")
-public class CzksMapEightController extends BaseController {
-
- @Autowired
- private CzksMapEightService mapEightService;
-
- /**
- * @return
- * @throws Exception
- */
- @RequestMapping(value = "/getEcharts")
- @ResponseBody
- public Object getEcharts() throws Exception {
- PageData pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
-
- return mapEightService.getEchartsOrder(pd);
- }
-
- /**
- * 可视化首页统计数据
- *
- * @param
- * @throws Exception
- */
- @RequestMapping(value = "/findFormCount")
- @ResponseBody
- public Object findFormCount() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
-
- PageData data = mapEightService.statisticsHighRiskWorkByStateOrder(pd);
- map.put("pd", data);
- //pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * 作业实时情况展示(最新18条)
- *
- * @param
- * @throws Exception
- */
- @RequestMapping(value = "/listHighRiskWork")
- @ResponseBody
- public Object listHighRiskWork(Page page) throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
- page.setPd(pd);
- List varList = mapEightService.listHighRiskWorkOrder(page);
- map.put("varList", varList);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * 获取所有高危作业的位置坐标(有坐标数据)
- *
- * @param
- * @throws Exception
- */
- @RequestMapping(value = "/listAllHighRiskWorkLocation")
- @ResponseBody
- public Object listAllHighRiskWorkLocation() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
- List varList;
- if (StringUtils.equals("035958e685cf4850bc40151c5e0617a6", pd.getString("CORPINFO_ID"))) { //一公司
- varList = mapEightService.listAllHighRiskWorkLocation(pd);
- } else {
- varList = mapEightService.listAllHighRiskWorkLocationOrder(pd);
- }
- map.put("varList", varList);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * 根据id以及类型获取数据 一公司
- *
- * @param id 数据id
- * @param type 数据类型 动火 等等
- * @return
- */
- @RequestMapping(value = "/getById")
- @ResponseBody
- public Object getById(@RequestParam(value = "id") String id, @RequestParam("TYPE") String type) throws Exception {
- PageData pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
-
- return mapEightService.getById(pd);
-
- }
-
- /**
- * 根据id以及类型获取数据 其他公司
- *
- * @param id 数据id
- * @param type 数据类型 动火 等等
- * @return
- */
- @RequestMapping(value = "/getByIdOrder")
- @ResponseBody
- public Object getByIdOrder(@RequestParam(value = "id") String id, @RequestParam("TYPE") String type) throws Exception {
- PageData pd = new PageData();
- pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
-
- return mapEightService.getByIdOrder(pd);
-
- }
-
- /**
- * 列表
- *
- * @param page
- * @throws Exception
- */
- @RequestMapping(value = "/list")
- @ResponseBody
- public Object list(Page page) throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
-
- List varList = mapEightService.listAll(pd); //列出HotWorkApplicationDelayed列表
- map.put("varList", varList);
- map.put("page", page);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * 获取动火防护措施
- *
- * @param
- * @throws Exception
- */
- @RequestMapping(value = "/listAllMeasures")
- @ResponseBody
- public Object listAllMeasures() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
-
- List varList = mapEightService.listAllMeasures(pd); //根据ID读取
- map.put("varList", varList);
- map.put("result", errInfo);
- return map;
- }
-
-}
diff --git a/src/main/java/com/zcloud/controller/czksmap/CzksMapPlatFormElectronicController.java b/src/main/java/com/zcloud/controller/czksmap/CzksMapPlatFormElectronicController.java
deleted file mode 100644
index 8088ff7c..00000000
--- a/src/main/java/com/zcloud/controller/czksmap/CzksMapPlatFormElectronicController.java
+++ /dev/null
@@ -1,85 +0,0 @@
-package com.zcloud.controller.czksmap;
-
-import com.zcloud.controller.base.BaseController;
-//import com.zcloud.service.keyProjects.PlatformelectronicService;
-//import com.zcloud.util.hk.HKPostUtil;
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestMapping;
-
-@Controller
-@RequestMapping("/czks/map/mapPlatformelectronic")
-public class CzksMapPlatFormElectronicController extends BaseController {
-// @Autowired
-// private PlatformelectronicService platformelectronicService;
-
- /**总摄像头数
- * @throws Exception
- */
-// @RequestMapping(value="/listAll")
-// @ResponseBody
-// public Object listAll() throws Exception{
-// Map map = new HashMap();
-// String errInfo = "success";
-// PageData pd = new PageData();
-// pd = this.getPageData();
-// Integer allForMap = platformelectronicService.countAllForMap(pd); //列出Platformelectronic列表
-// map.put("allForMap", allForMap);
-// map.put("result", errInfo);
-// return map;
-// }
-
-
- /**根据区域统计摄像头总数
- * @throws Exception
- */
-// @RequestMapping(value="/listAllByArea")
-// @ResponseBody
-// public Object listAllByArea() throws Exception{
-// Map map = new HashMap();
-// String errInfo = "success";
-// PageData pd = new PageData();
-// pd = this.getPageData();
-// List countAllByArea = platformelectronicService.countAllByArea(pd); //列出Platformelectronic列表
-// map.put("varList", countAllByArea);
-// map.put("result", errInfo);
-// return map;
-// }
-
-
- /**地图插点
- * @throws Exception
- */
-// @RequestMapping(value="/listAllLocation")
-// @ResponseBody
-// public Object listAllLocation() throws Exception{
-// Map map = new HashMap();
-// String errInfo = "success";
-// PageData pd = new PageData();
-// pd = this.getPageData();
-// pd.put("forMap","1");
-// List varList = platformelectronicService.listAll(pd); //列出Platformelectronic列表
-// for (PageData data : varList) {
-// data.put("MAP_POINT_NAME", data.getString("NAME"));
-// }
-// map.put("varList", varList);
-// map.put("result", errInfo);
-// return map;
-// }
-
- /**列表
- * @throws Exception
- */
-// @RequestMapping(value="/getHlsPathById")
-// @ResponseBody
-// public Object getHlsPath() throws Exception{
-// Map map = new HashMap();
-// PageData pd =this.getPageData();
-// pd = platformelectronicService.findById(pd);
-// map = HKPostUtil.camerasPreviewURLs(pd.getString("INDEXCODE"),"hls");
-// map.put("pd",pd);
-// map.put("result", "success");
-// return map;
-// }
-
-
-}
diff --git a/src/main/java/com/zcloud/controller/gatemachine/GateMachineController.java b/src/main/java/com/zcloud/controller/gatemachine/GateMachineController.java
index ba62b7bc..2d3b48f9 100644
--- a/src/main/java/com/zcloud/controller/gatemachine/GateMachineController.java
+++ b/src/main/java/com/zcloud/controller/gatemachine/GateMachineController.java
@@ -4,7 +4,6 @@ import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.service.gatemachine.GateMachineService;
-import com.zcloud.util.Jurisdiction;
import com.zcloud.util.ReturnMap;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -53,7 +52,6 @@ public class GateMachineController extends BaseController {
@RequestMapping(value = "/add")
public ReturnMap add() {
PageData pageData = this.getPageData();
- pageData.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
gateMachineService.save(pageData);
return ReturnMap.ok();
}
diff --git a/src/main/java/com/zcloud/controller/gatemachine/GateVideoController.java b/src/main/java/com/zcloud/controller/gatemachine/GateVideoController.java
index e906cf47..bd5b35f9 100644
--- a/src/main/java/com/zcloud/controller/gatemachine/GateVideoController.java
+++ b/src/main/java/com/zcloud/controller/gatemachine/GateVideoController.java
@@ -45,7 +45,6 @@ public class GateVideoController extends BaseController {
pd.put("GATEVIDEO_ID", this.get32UUID()); //主键
pd.put("OPDATE", DateUtil.date2Str(new Date())); //操作日期
pd.put("OPUSER", Jurisdiction.getUsername()); //操作人
- pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); //操作人
pd.put("ISDELETE", "0"); //是否删除
gateVideoService.save(pd);
map.put("result", errInfo);
diff --git a/src/main/java/com/zcloud/controller/map/MapController.java b/src/main/java/com/zcloud/controller/map/MapController.java
index 9d482538..a0116d3e 100644
--- a/src/main/java/com/zcloud/controller/map/MapController.java
+++ b/src/main/java/com/zcloud/controller/map/MapController.java
@@ -3,29 +3,27 @@ package com.zcloud.controller.map;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
+import com.zcloud.mapper.datasource.gatemachine.GateAreaMapper;
import com.zcloud.service.bus.CorpInfoService;
-import com.zcloud.service.fireresources.CzksFireResourcesService;
+import com.zcloud.service.gatemachine.GateCarMachineInfoService;
+import com.zcloud.service.gatemachine.GateMachineInfoService;
import com.zcloud.service.gatemachine.GateMachineService;
import com.zcloud.service.keyProjects.VideoManagerService;
-import com.zcloud.service.map.*;
-import com.zcloud.service.map.util.ReturnMap;
-import com.zcloud.service.map.util.WeatherUtil;
+import com.zcloud.service.map.MapService;
import com.zcloud.service.system.DepartmentService;
import com.zcloud.service.system.UsersService;
-import com.zcloud.util.Jurisdiction;
+import com.zcloud.util.ReturnMap;
import com.zcloud.util.Tools;
-import org.apache.commons.lang.StringUtils;
+import com.zcloud.util.hk.HKUtil;
+import com.zcloud.util.ys.YSUtil;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
-import org.springframework.util.LinkedMultiValueMap;
-import org.springframework.util.MultiValueMap;
-import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.client.RestTemplate;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
import java.util.*;
/**
@@ -45,27 +43,12 @@ public class MapController extends BaseController {
@Autowired
private UsersService usersService;
- @Autowired
- private MeteorologicalinfoService meteorologicalinfoService;
- @Autowired
- private MeteorologicalService meteorologicalService;
+// @Autowired
+// private MeteorologicalinfoService meteorologicalinfoService;
+
@Autowired
private RestTemplate restTemplate;
- @Value("${preventionxgf.api.url}")
- private String url;
-
- @Value("${preventionxgf.api.url}")
- private String xgfUrl;
-
-
- @Value("${cfd.prevention.api.url}")
- private String cfdUrl;
-
- @Autowired
- private BiMapService biMapService;
- @Autowired
- private CzksFireResourcesService fireResourcesService;
@Autowired
private DepartmentService departmentService;
@@ -74,515 +57,24 @@ public class MapController extends BaseController {
private GateMachineService gateMachineService;
@Autowired
- private WeatherUtil weatherUtil;
+ private MapService mapService;
- @ResponseBody
- @RequestMapping("/getCorpInfo")
- public Object getCorpInfo() throws Exception {
- Map map = new HashMap();
- PageData condition = new PageData();
- condition.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
+ @Autowired
+ private YSUtil ysUtil;
- PageData entity = corpInfoService.findById(condition);
- PageData info = new PageData();
- info.put("CORP_INFO_ID",entity.get("CORPINFO_ID"));
- info.put("longitude",entity.get("LONGITUDE"));
- info.put("latitude",entity.get("LATITUDE"));
- map.put("info", info);
- map.put("result", "success");
- return map;
- }
+ @Autowired
+ private GateAreaMapper gateAreaMapper;
- /**
- * @Description: 单位基础信息
- * @Author: dearLin
- * @Date: 2023/9/21/021 16:14
- * @Param: AREA
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "/basicInformation")
- @ResponseBody
- public Object basicInformation() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- // 分公司数量
- PageData numberCountData = corpInfoService.listAllByArea(pd);
- // 相关方单位数
- // 0 ->分公司企业数
- // 1 ->相关方单位数
- // 2 ->员工数
- Map result = restTemplate.getForObject(url + "/api/corpinfo/unitCorpInfo", Map.class);
- List unitCorp = (List) result.get("unitCorp");
- int size = unitCorp != null ? unitCorp.size() : 0;
- // 员工数
- PageData userCountData = usersService.countAllByArea(pd);
- PageData resData = new PageData();
- resData.put("UNITCOUNT", size);
- resData.putAll(numberCountData);
- resData.putAll(userCountData);
- map.put("data", resData);
- map.put("result", errInfo);
- return map;
- }
+ @Autowired
+ private GateMachineInfoService gateMachineInfoService;
- /**
- * @Description: 风险区域统计
- * @Author: dearLin
- * @Date: 2023/9/21/021 16:14
- * @Param: AREA
- * @Return: 重大风险区域数
- * @Return: 较大风险区域数
- * @Return: 一般风险区域数
- * @Return: 低风险区域数
- */
- @RequestMapping(value = "/getRiskAreaCount")
- @ResponseBody
- public Object getRiskAreaCount() {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- List riskIndex = biMapService.getRiskIndex(pd);
- PageData pageData = new PageData();
- riskIndex.forEach(item -> {
- pageData.put(item.getString("TYPE"), item.getString("COUNT"));
- });
- map.put("pd", pageData);
- map.put("result", errInfo);
- return map;
- }
+ @Autowired
+ private GateCarMachineInfoService gateCarMachineInfoService;
- /**
- * listRetrieval
- *
- * @Description: 单位人员信息统计
- * @Author: dearLin
- * @Date: 2023/9/21/021 17:48
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping(value = "/getUnitPersonnel")
- @ResponseBody
- public Object getUnitPersonnel(Page page) throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- page.setPd(pd);
- if (pd.getString("INDEX").equals("0")) {
- List varList = corpInfoService.listRetrieval(page);
- map.put("varList", varList);
- map.put("page", page);
- } else {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("showCount", page.getShowCount());
- paramMap.add("currentPage", pd.get("currentPage"));
-// Map result = HttpClientService.doPost(xgfUrl + "/api/corpinfo/list", pd);
- Map result = restTemplate.postForObject(xgfUrl + "/api/corpinfo/list", paramMap, Map.class);
- map.put("varList", result.get("varList"));
- map.put("page", result.get("page"));
- }
- map.put("result", errInfo);
- return map;
- }
- @RequestMapping(value = "/corpsForMap")
- @ResponseBody
- public Object corpsForMap() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- List varList = corpInfoService.listAllForMap(pd); //根据ID读取
- for (PageData pageData : varList) {
- if (StringUtils.isBlank(pageData.getString("CORP_NAME"))) {
- pageData.put("MAP_POINT_NAME", "");
- } else {
- pageData.put("MAP_POINT_NAME", pageData.getString("CORP_NAME"));
- }
- }
- map.put("varList", varList);
- map.put("result", errInfo);
- return map;
- }
- /**
- * 列表
- *
- * @param
- * @throws Exception
- */
- @RequestMapping(value = "/listbymeteorological")
- @ResponseBody
- public Object listbymeteorological() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- //根据条件增加参数或减少参数 都没有 直接返回空
- if (StringUtils.isBlank(pd.getString("CORPINFO_ID"))) {
- List ArrayDATA_IDS = biMapService.getCorpinfoIds(pd);
- if (ArrayDATA_IDS.size() == 0) {
- map.put("result", errInfo);
- return map;
- }
- pd.put("ids", ArrayDATA_IDS);
- pd.remove("CORPINFO_ID");
- }
- pd = meteorologicalinfoService.listbymeteorological(pd); //列出meteorological列表
- map.put("pd", pd);
- map.put("result", errInfo);
- return map;
- }
- /**
- * 列表
- *
- * @param page
- * @throws Exception
- */
- @RequestMapping(value = "/listbyType")
- @ResponseBody
- public Object listbyType(Page page) throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- //根据条件增加参数或减少参数 都没有 直接返回空
- if (StringUtils.isBlank(pd.getString("CORPINFO_ID"))) {
- List ArrayDATA_IDS = biMapService.getCorpinfoIds(pd);
- if (ArrayDATA_IDS.size() == 0) {
- map.put("result", errInfo);
- return map;
- }
- pd.put("ids", ArrayDATA_IDS);
- pd.remove("CORPINFO_ID");
- }
- page.setPd(pd);
- if (pd.getString("INDEX").equals("0") || "".equals(pd.getString("INDEX"))) {
- List varList = meteorologicalService.listbyType(page);
- for (PageData data : varList) {
- data.put("MAP_POINT_NAME", data.getString("NAME"));
- }
- map.put("varList", varList);
- map.put("page", page);
- }
-// List varList = meteorologicalService.listbyType(page); //列出electronic列表
-// map.put("varList", varList);
-// map.put("page", page);
- map.put("result", errInfo);
- return map;
- }
- /**
- * 设备数量
- *
- * @param
- * @throws Exception
- */
- @RequestMapping(value = "/listbyequipmentcount")
- @ResponseBody
- public Object listbyequipmentcount() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- //根据条件增加参数或减少参数 都没有 直接返回空
- if (StringUtils.isBlank(pd.getString("CORPINFO_ID"))) {
- List ArrayDATA_IDS = biMapService.getCorpinfoIds(pd);
- if (ArrayDATA_IDS.size() == 0) {
- map.put("result", errInfo);
- return map;
- }
- pd.put("ids", ArrayDATA_IDS);
- pd.remove("CORPINFO_ID");
- }
- pd = meteorologicalService.listbyequipmentcount(pd); //列出electronic列表
- map.put("pd", pd);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * 根据id以及类型获取气象监测信息数据
- *
- * @param id 数据id
- * @param type 数据类型 气象站 等等
- * @return
- */
- @RequestMapping(value = "/getById")
- @ResponseBody
- public Object getById(@RequestParam(value = "id") String id, @RequestParam("TYPE") String type) throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- String typeStr = pd.getString("TYPE");
- String idStr = pd.getString("id");
- List pageDataList = new ArrayList<>();
- if (StringUtils.equals(typeStr, "293187ddfd984c9ab3fd716aef58da0e")) {
- pd.put("METEOROLOGICAL_ID", idStr);
- pd = biMapService.listbymeteorological(pd);
- } else if (StringUtils.equals(typeStr, "561347f0cff641dba8b2b22c0f443348")) {
- pd.put("METEOROLOGICAL_ID", idStr);
- pd = biMapService.listbymeteorological(pd);
- } else if (StringUtils.equals(typeStr, "2da29f00852a4653ba3e760b9de57412")) {
- pd.put("METEOROLOGICAL_ID", idStr);
- pd = biMapService.listbymeteorological(pd);
- } else if (StringUtils.equals(typeStr, "732fe73933b845c6b1e2aee06a38ed31")) {
- pd.put("METEOROLOGICAL_ID", idStr);
- pd = biMapService.listbymeteorological(pd);
- }
- map.put("pd", pd);
- map.put("result", errInfo);
- return map;
- }
-
- @RequestMapping(value = "/getWeatherInfo")
- @ResponseBody
- public Object getWeatherInfo() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- map.put("data", WeatherUtil.getWeatherInfo());
- map.put("result", errInfo);
- return map;
- }
-
- @RequestMapping(value = "/getPointsInfo")
- @ResponseBody
- public Object getPointsInfo() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
-
- List pointsList = videomanagerService.getPointsInfo(pd); //根据ID读取
- map.put("pointsList", pointsList);
- map.put("result", errInfo);
- return map;
- }
- /*************************************************/
-
- /**
- * @Description: 风险辨识管控
- * 风险单元数
- * 辨识部位数
- * 风险因素数
- * @Author: dearLin
- * @Date: 2023/9/19/019 16:14
- * @Param: CORPINFO_ID
- * @Return: java.lang.Object
- */
- @RequestMapping("/getRiskIdentificationCount")
- @ResponseBody
- public Object getRiskIdentificationCount() {
- Map map = new HashMap();
- PageData pageData = this.getPageData();
- // bus_riskunit
- // bus_identificationparts
-
- if ("00004".equals(pageData.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/ObtainDisplayData/getRiskList", paramMap, Map.class);
- return result;
- }
- PageData data = biMapService.getRiskIdentificationCount(pageData);
- map.put("result", "success");
- map.put("riskIdentificationCount", data);
- return map;
- }
- // 人员定位信息
-
- /**
- * @Description: 人员定位信息
- * @Author: dearLin
- * @Date: 2023/9/20/020 11:06
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getPersonPositioningCount")
- @ResponseBody
- public Object getPersonPositioningCount() {
- Map map = new HashMap();
- PageData pageData = this.getPageData();
- if ("00004".equals(pageData.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- Map result = new HashMap();
- try {
- result = restTemplate.postForObject(cfdUrl + "/sync/ObtainDisplayData/getUsersCount", paramMap, Map.class);
- } catch (Exception e) {
- result.put("regulatoryUsersInfo", 0);
- result.put("preventionUsersInfo", 0);
- }
- try {
-
- Map perResult = restTemplate.postForObject(cfdUrl + "/sync/UserPosition/getCurrentLocationOnlineCount", paramMap, Map.class);
- result.put("perCount", perResult.get("perCount"));
- } catch (Exception e) {
- result.put("perCount", 0);
- }
-
- return result;
- }
- // bus_riskunit
- // bus_identificationparts
- PageData data = biMapService.getPersonPositioningCount(pageData);
- map.put("result", "success");
- map.put("personPositioningCount", data);
- return map;
- }
-
- /**
- * @Description: 口门管理 Gate management
- * @Author: dearLin
- * @Date: 2023/9/20/020 11:07
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getDoorManagement")
- @ResponseBody
- public Object getDoorManagement() {
- Map map = new HashMap();
- PageData pageData = this.getPageData();
- if ("00004".equals(pageData.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("id", pageData.get("id"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getPerpleCarGateMachineCount", paramMap, Map.class);
- return result;
- }
- List data = new ArrayList<>();
- PageData riskIndex = new PageData();
- riskIndex.put("title", "风险指数");
- riskIndex.put("list", biMapService.getRiskIndex(pageData));
- data.add(riskIndex);
- // 今日情况
- /*
- * todo
- * 是否也按照公司来进行统计
- * bus_carduser 人员进出
- * bus_foreigncar 车辆进出
- *
- * */
- PageData today = new PageData();
- today.put("title", "今日情况");
- today.put("list", biMapService.inAndoutPeoCarToday(pageData));
- data.add(today);
- map.put("result", "success");
- map.put("varList", data);
- return map;
- }
-
- @RequestMapping("/getPointInfoADeviceByPid")
- @ResponseBody
- public Object getPointInfoADeviceByPid() {
- PageData pd = this.getPageData();
- if ("00004".equals(pd.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("FIRE_POINT_ID", pd.getString("FIRE_POINT_ID"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getPointInfoADeviceByPid", paramMap, Map.class);
- return result;
- }
- PageData map = fireResourcesService.getPointInfoADeviceByPid(pd);
- map.put("result", "success");
- return map;
- }
-
- @RequestMapping("/getPointQualifiedPhotos")
- @ResponseBody
- public Object getPointQualifiedPhotos() {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- if ("00004".equals(pd.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("FIRE_POINT_ID", pd.getString("FIRE_POINT_ID"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getPointQualifiedPhotos", paramMap, Map.class);
- return result;
- }
- map.put("result", "success");
- map.put("varList", fireResourcesService.getPointQualifiedPhotos(pd));
- return map;
- }
-
- //股份公司部门数量 所有的
- @RequestMapping(value = "/getRegulatoryDepartmentCount")
- @ResponseBody
- public Object getRegulatoryDepartmentCount() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- List pageData = (List) departmentService.listAll(pd);
- int size = pageData.size();
- map.put("regulatoryDepartmentCount", size);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * @Description: 消防管控
- * @Author: dearLin
- * @Date: 2023/9/20/020 15:30
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getFireControl")
- @ResponseBody
- public Object getFireControl() throws Exception {
- Map map = new HashMap();
- PageData pageData = this.getPageData();
- if ("00004".equals(pageData.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("TYPE", pageData.getString("TYPE"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getFireControl", paramMap, Map.class);
- return result;
- }
- LinkedList value = biMapService.getFireControl(pageData);
- for (PageData data : value) {
- data.put("MAP_POINT_NAME", data.getString("NAME"));
- }
- map.put("result", "success");
- map.put("varList", value);
- return map;
- }
-
- /**
- * @Description: 消防资源
- * @Author: dearLin
- * @Date: 2023/9/26/026 17:36
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getFireResourceById")
- @ResponseBody
- public Object getFireResourceById() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pddata = this.getPageData();
- //获取当前人的公司id
- PageData pd = fireResourcesService.getDataById(pddata);
- map.put("pd", pd);
- map.put("result", errInfo);
- return map;
- }
-
- /**
- * @Description: 消防救援队
- * @Author: dearLin
- * @Date: 2023/9/20/020 15:30
- * @Param: [] []
- * @Return: java.lang.Object
- */
- @RequestMapping("/getFireRescueTeam")
- @ResponseBody
- public Object getFireRescueTeam() throws Exception {
- Map map = new HashMap();
- PageData pageData = this.getPageData();
- LinkedList data = biMapService.getFireRescueTeam(pageData);
- map.put("result", "success");
- map.put("varList", data);
- return map;
- }
/**
* 气象信息对接接口
@@ -590,13 +82,14 @@ public class MapController extends BaseController {
* @return
* @throws Exception
*/
- @RequestMapping(value = "/tongMeteorologicalinfoList")
- @ResponseBody
- public ReturnMap tongMeteorologicalinfoList(@RequestBody List list) throws Exception {
- ReturnMap r = new ReturnMap();
- r = meteorologicalinfoService.tongbuMeteorologicalinfo(list);
- return r;
- }
+// @RequestMapping(value = "/tongMeteorologicalinfoList")
+// @ResponseBody
+// public ReturnMap tongMeteorologicalinfoList(@RequestBody List list) throws Exception {
+// ReturnMap r = new ReturnMap();
+// r = meteorologicalinfoService.tongbuMeteorologicalinfo(list);
+// return r;
+// }
+
/**
* @Description: 闸机设备在线情况 只有人车闸机
@@ -610,12 +103,6 @@ public class MapController extends BaseController {
public ReturnMap getOnlineGateEquipment() {
ReturnMap returnMap = new ReturnMap();
PageData pageData = this.getPageData();
- if ("00004".equals(pageData.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/listMapSluiceCount", paramMap, Map.class);
- return ReturnMap.ok(result);
- }
PageData value = gateMachineService.getOnlineGateMachine(pageData);
returnMap.put("pd", value);
return returnMap;
@@ -633,21 +120,6 @@ public class MapController extends BaseController {
public ReturnMap getGatePosition() {
ReturnMap returnMap = new ReturnMap();
PageData pageData = this.getPageData();
- if ("00004".equals(pageData.getString("GANGKOU"))) {
-
- MultiValueMap paramMap = new LinkedMultiValueMap();
- if ("CAMERA".equals(pageData.getString("TYPE"))) {
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/ObtainDisplayData/listAllCameraForMapToBayonet", paramMap, Map.class);
- return ReturnMap.ok(result);
- } else {
- paramMap.add("TYPE", pageData.getString("TYPE"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getGatePosition", paramMap, Map.class);
- return ReturnMap.ok(result);
- }
-
- }
//
List value = gateMachineService.getGatePosition(pageData);
// 添加标点上的统一的title
@@ -663,51 +135,107 @@ public class MapController extends BaseController {
}
/**
- * @Description: 口门进出记录列表
+ * @Description: 闸机位置
* @Author: dearLin
* @Date: 2023/9/23/023 9:04
* @Param:
* @Return:
*/
- @RequestMapping("/getDoorWayRecords")
+ @RequestMapping("/listGateMachine")
@ResponseBody
- public ReturnMap getDoorWayRecords(Page page) {
+ public ReturnMap listGateMachine() {
ReturnMap returnMap = new ReturnMap();
PageData pageData = this.getPageData();
- page.setPd(pageData);
- if ("0".equals(pageData.getString("INDEX"))) {
- // 人
- List value = biMapService.getDoorWayPeopleRecords(page);
- returnMap.put("varList", value);
- return returnMap;
- } else {
- // 车
- List value = biMapService.getDoorWayCarRecords(page);
- returnMap.put("varList", value);
- return returnMap;
+ List dataList = new ArrayList<>();
+ SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ String fendDate = format.format(new Date());
+ Calendar calendar = Calendar.getInstance();
+ calendar.set(Calendar.HOUR_OF_DAY, 0); // 将时设置为0
+ calendar.set(Calendar.MINUTE, 0); // 将分设置为0
+ calendar.set(Calendar.SECOND, 0); // 将秒设置为0
+ calendar.set(Calendar.MILLISECOND, 0); // 将毫秒设置为0
+ Date currDay = calendar.getTime();
+ String fstartDate = format.format(currDay);
+ if (pageData.get("TYPE").equals("0")) {
+ pageData.put("eventTime",fstartDate);
+ dataList = gateMachineInfoService.findByIds(pageData);
+ }else {
+ pageData.put("CROSSTIME",fstartDate);
+ dataList = gateCarMachineInfoService.findByIds(pageData);
}
+ returnMap.put("varList", dataList);
+ return returnMap;
}
/**
- * @Description: 口门进出记录列表
+ * @Description: 闸机位置
* @Author: dearLin
* @Date: 2023/9/23/023 9:04
* @Param:
* @Return:
*/
- @RequestMapping("/getCfdDoorWayRecords")
+ @RequestMapping("/getPersonAndCarGateInAndOutCount")
@ResponseBody
- public ReturnMap getCfdDoorWayRecords() {
+ public ReturnMap getPersonAndCarGateInAndOutCount() {
ReturnMap returnMap = new ReturnMap();
+ PageData data = new PageData();
PageData pageData = this.getPageData();
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("TYPE", pageData.get("TYPE"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/listPerpleCarGateMachine", paramMap, Map.class);
- return ReturnMap.ok(result);
+ SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ String fendDate = format.format(new Date());
+ Calendar calendar = Calendar.getInstance();
+ calendar.set(Calendar.HOUR_OF_DAY, 0); // 将时设置为0
+ calendar.set(Calendar.MINUTE, 0); // 将分设置为0
+ calendar.set(Calendar.SECOND, 0); // 将秒设置为0
+ calendar.set(Calendar.MILLISECOND, 0); // 将毫秒设置为0
+ Date currDay = calendar.getTime();
+ String fstartDate = format.format(currDay);
+ pageData.put("eventTime",fstartDate);
+ //人闸机
+ PageData personCount = gateMachineInfoService.peopleCount(pageData);
+ if (personCount!=null){
+ data.put("personInCount", personCount.get("inCount"));
+ data.put("personOutCount", personCount.get("outCount"));
+ data.put("personUnkownCount", personCount.get("noCount"));
+ }
+ //车闸机
+ pageData.put("GATE_AREA_TYPE", 1);
+ PageData carCount = gateCarMachineInfoService.carCount(pageData);
+ if (carCount!=null){
+ data.put("carInCount", carCount.get("inCount"));
+ data.put("carOutCount", carCount.get("outCount"));
+ }
+ returnMap.put("data", data);
+ return returnMap;
}
+ /**
+ * @Description: 闸机位置
+ * @Author: dearLin
+ * @Date: 2023/9/23/023 9:04
+ * @Param:
+ * @Return:
+ */
+ @RequestMapping("/getGatePositionCount")
+ @ResponseBody
+ public ReturnMap getGatePositionCount() {
+ ReturnMap returnMap = new ReturnMap();
+ PageData data = new PageData();
+ PageData pageData = this.getPageData();
+ //人闸机
+ pageData.put("GATE_AREA_TYPE", 0);
+ List personMachine = gateAreaMapper.getGatePosition(pageData);
+ data.put("personMachineCount", personMachine.size());
+ //车闸机
+ pageData.put("GATE_AREA_TYPE", 1);
+ List carMachine = gateAreaMapper.getGatePosition(pageData);
+ data.put("carMachineCount", carMachine.size());
+ returnMap.put("data", data);
+ return returnMap;
+ }
+
+
+
/**
* @Description: 闸机进出车、人的数量
* @Author: dearLin
@@ -719,21 +247,58 @@ public class MapController extends BaseController {
@ResponseBody
public ReturnMap getGatesInAndOutNumById() {
ReturnMap returnMap = new ReturnMap();
- PageData pageData = this.getPageData();
- if ("00004".equals(pageData.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("id", pageData.get("id"));
- paramMap.add("TYPE", pageData.get("TYPE"));
- paramMap.add("status", pageData.get("status"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getGatesInAndOutNumById", paramMap, Map.class);
- return ReturnMap.ok(result);
+ PageData pd = this.getPageData();
+ DateFormat dft = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
+ String fendDate = dft.format(new Date());
+ String fstartDate = "";
+ if (pd.getString("status").equals("0")) {
+ Calendar calendar = Calendar.getInstance();
+ calendar.set(Calendar.HOUR_OF_DAY, 0); // 将时设置为0
+ calendar.set(Calendar.MINUTE, 0); // 将分设置为0
+ calendar.set(Calendar.SECOND, 0); // 将秒设置为0
+ calendar.set(Calendar.MILLISECOND, 0); // 将毫秒设置为0
+ Date currDay = calendar.getTime();
+ fstartDate = dft.format(currDay);
+ } else {
+ Calendar now = Calendar.getInstance();
+ now.add(Calendar.MINUTE, -1);
+ Date before = now.getTime();
+ fstartDate = dft.format(before);
}
- PageData data = biMapService.getGatesInAndOutNumById(pageData);
- returnMap.put("pd", data);
+ String[] gateIdsByGateAreaId = mapService.getGateIdsByGateAreaId(pd);
+ Map doorComeAndOutInfo = new HashMap<>();
+ if (pd.getString("TYPE").equals("PERSON_MACHINE")){
+ doorComeAndOutInfo = HKUtil.getDoorComeAndOutInfo(gateIdsByGateAreaId, pd.getString("pageNo"), pd.getString("pageSize"),fstartDate,fendDate);
+ }else {
+ List infoByArea = gateCarMachineInfoService.findInfoByArea(pd);
+ Map data = new HashMap<>();
+ data.put("list", infoByArea);
+ doorComeAndOutInfo.put("data", data);
+ doorComeAndOutInfo.put("code", 0);
+ doorComeAndOutInfo.put("msg", "success");
+ }
+ returnMap.put("doorInfo", doorComeAndOutInfo);
return returnMap;
}
+// /**
+// * @Description: 闸机进出车、人的数量
+// * @Author: dearLin
+// * @Date: 2023/9/23/023 9:04
+// * @Param:
+// * @Return:
+// */
+// @RequestMapping("/test")
+// @ResponseBody
+// public ReturnMap test() {
+// ReturnMap returnMap = new ReturnMap();
+// PageData pd = this.getPageData();
+// String[] gateIdsByGateAreaId = mapService.getGateIdsByGateAreaId(pd);
+// Map doorComeAndOutInfo = HKUtil.getDoorComeAndOutInfo();
+// returnMap.put("doorInfo", doorComeAndOutInfo);
+// return returnMap;
+// }
+
/**
* 人员进出记录列表
*
@@ -751,47 +316,6 @@ public class MapController extends BaseController {
}
- @RequestMapping(value = "/fireResource/list")
- @ResponseBody
- public Object page(Page page) {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- //获取当前人的公司id
- page.setPd(pd);
-
- List varList = fireResourcesService.datalistPage(page);
- map.put("varList", varList);
- map.put("page", page);
- map.put("result", errInfo);
- return map;
- }
-
- @RequestMapping(value = "/fireDevice/listByMap")
- @ResponseBody
- public Object devicelistByMap(Page page) {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = this.getPageData();
- //获取当前人的公司id
- page.setPd(pd);
- if ("00004".equals(pd.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("FIRE_DEVICE_TYPE_ID", pd.getString("FIRE_DEVICE_TYPE_ID"));
- paramMap.add("FIRE_POINT_NAME", pd.getString("FIRE_POINT_NAME"));
- paramMap.add("showCount", page.getShowCount());
- paramMap.add("currentPage", pd.get("currentPage"));
- // /sync/map/fireDevice/listByMap?showCount=¤tPage=
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/fireDevice/listByMap", paramMap, Map.class);
- return result;
- }
- List varList = fireResourcesService.devicelistPage(page);
- map.put("varList", varList);
- map.put("page", page);
- map.put("result", errInfo);
- return map;
- }
/**
* 获取人员、车辆进出记录
@@ -805,13 +329,6 @@ public class MapController extends BaseController {
Map map = new HashMap();
String errInfo = "success";
PageData pd = this.getPageData();
- if ("00004".equals(pd.getString("GANGKOU"))) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("id", pd.get("id"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getPerpleCarGateMachineCount", paramMap, Map.class);
- return result;
- }
map.put("result", errInfo);
return map;
}
@@ -839,23 +356,6 @@ public class MapController extends BaseController {
public Object getCurrentLocationOnline() {
Map map = new HashMap();
String errInfo = "success";
- PageData pd = this.getPageData();
- if ("00004".equals(pd.getString("GANGKOU")) && pd.getString("TYPE").equals("peoplePosition")) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/UserPosition/getCurrentLocationOnline", paramMap, Map.class);
- return result;
- } else if ("00004".equals(pd.getString("GANGKOU")) && pd.getString("TYPE").equals("carPosition")) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/UserPosition/getCarCurrentLocationOnline", paramMap, Map.class);
- return result;
- } else if ("00004".equals(pd.getString("GANGKOU")) && pd.getString("TYPE").equals("CAMERA")) {
- MultiValueMap paramMap = new LinkedMultiValueMap();
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/ObtainDisplayData/listAllCameraForMap", paramMap, Map.class);
- return result;
- }
map.put("result", errInfo);
return map;
}
@@ -881,12 +381,8 @@ public class MapController extends BaseController {
@ResponseBody
public Object getHlsPath() throws Exception {
Map map = new HashMap();
- PageData pd = this.getPageData();
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("INDEXCODE", pd.get("INDEXCODE"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getHlsPath", paramMap, Map.class);
- return result;
+
+ return map;
}
/**
@@ -899,87 +395,13 @@ public class MapController extends BaseController {
public Object getCurrentPersonnelData() throws Exception {
Map map = new HashMap();
PageData pd = this.getPageData();
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("route", pd.get("route"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/UserPosition/getCurrentPersonnelData", paramMap, Map.class);
- return result;
- }
-
- /**
- * 查询告警数据甸使用)
- *
- * @throws Exception
- */
- @RequestMapping(value = "/getCfdAlarmNum")
- @ResponseBody
- public Object getCfdAlarmNum() throws Exception {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- MultiValueMap paramMap = new LinkedMultiValueMap();
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/getAlarmNum", paramMap, Map.class);
- return result;
- }
-
- /**
- * 车辆在线及统计数据(曹妃甸使用)
- *
- * @throws Exception
- */
- @RequestMapping(value = "/getCurrentCarData")
- @ResponseBody
- public Object getCurrentCarData() throws Exception {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("route", pd.get("route"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/UserPosition/getCurrentCarData", paramMap, Map.class);
- return result;
- }
-
- /**
- * 车辆在线及统计数据(曹妃甸使用)
- *
- * @throws Exception
- */
- @RequestMapping(value = "/carPositioningStatistics")
- @ResponseBody
- public Object carPositioningStatistics() throws Exception {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("route", pd.get("route"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/UserPosition/carPositioningStatistics", paramMap, Map.class);
- return result;
- }
-
- /**
- * 获取人员定位统计列表(曹妃甸使用)
- *
- * @throws Exception
- */
- @RequestMapping(value = "/personPositioningStatistics")
- @ResponseBody
- public Object personPositioningStatistics() throws Exception {
- Map map = new HashMap();
- PageData pd = this.getPageData();
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("route", pd.get("route"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/UserPosition/personPositioningStatistics", paramMap, Map.class);
- return result;
+ return map;
}
@RequestMapping("/getUserMapInfo")
@ResponseBody
public ReturnMap getUserMapInfo() throws Exception {
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
+ PageData pd = this.getPageData();
pd = usersService.findByCardNo(pd); //列出HotWorkApplicationDelayed列表
ReturnMap r = ReturnMap.ok();
r.put("pd", pd);
diff --git a/src/main/java/com/zcloud/controller/map/MapEightCfdController.java b/src/main/java/com/zcloud/controller/map/MapEightCfdController.java
deleted file mode 100644
index 65ad33fc..00000000
--- a/src/main/java/com/zcloud/controller/map/MapEightCfdController.java
+++ /dev/null
@@ -1,76 +0,0 @@
-package com.zcloud.controller.map;
-
-import com.zcloud.controller.base.BaseController;
-import com.zcloud.entity.Page;
-import com.zcloud.entity.PageData;
-import com.zcloud.service.map.MapEightCfdService;
-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.RequestParam;
-import org.springframework.web.bind.annotation.ResponseBody;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 说明:实时地图八项工作内容
- * 官网:www.zcloudchina.com
- */
-@Controller
-@RequestMapping("/map/Eight/cfd")
-public class MapEightCfdController extends BaseController {
- @Autowired
- private MapEightCfdService mapEightCfdService;
-
- /**
- * 根据id以及类型获取数据
- * @param id 数据id
- * @param type 数据类型 动火 等等
- * @return
- */
- @RequestMapping(value = "/getByIdOrder")
- @ResponseBody
- public Object getByIdOrder(@RequestParam(value = "id")String id,@RequestParam("TYPE") String type) throws Exception {
- PageData pd = new PageData();
- pd = this.getPageData();
- return mapEightCfdService.getByIdOrder(pd);
- }
-
- /**列表
- * @param page
- * @throws Exception
- */
- @RequestMapping(value="/list")
- @ResponseBody
- public Object list(Page page) throws Exception{
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- List varList = mapEightCfdService.listAll(pd); //列出HotWorkApplicationDelayed列表
- map.put("varList", varList);
- map.put("page", page);
- map.put("result", errInfo);
- return map;
- }
-
- /**获取动火防护措施
- * @param
- * @throws Exception
- */
- @RequestMapping(value="/listAllMeasures")
- @ResponseBody
- public Object listAllMeasures() throws Exception{
- Map map = new HashMap();
- String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- List varList = mapEightCfdService.listAllMeasures(pd); //根据ID读取
- map.put("varList", varList);
- map.put("result", errInfo);
- return map;
- }
-
-}
diff --git a/src/main/java/com/zcloud/controller/map/MapEightController.java b/src/main/java/com/zcloud/controller/map/MapEightController.java
index 9e6e291c..a11ba766 100644
--- a/src/main/java/com/zcloud/controller/map/MapEightController.java
+++ b/src/main/java/com/zcloud/controller/map/MapEightController.java
@@ -4,19 +4,16 @@ import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.service.map.MapEightService;
-import com.zcloud.service.map.util.ReturnMap;
+import com.zcloud.service.system.UsersService;
+import com.zcloud.util.Jurisdiction;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
-import org.springframework.util.LinkedMultiValueMap;
-import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.client.RestTemplate;
-import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -31,8 +28,8 @@ public class MapEightController extends BaseController {
@Autowired
private MapEightService mapEightService;
- @Value("${cfd.prevention.api.url}")
- private String cfdUrl;
+ @Autowired
+ private UsersService usersService;
@Autowired
private RestTemplate restTemplate;
@@ -43,19 +40,10 @@ public class MapEightController extends BaseController {
@RequestMapping(value = "/getEcharts")
@ResponseBody
public Object getEcharts() throws Exception {
- PageData pd = new PageData();
- pd = this.getPageData();
- if (StringUtils.equals("035958e685cf4850bc40151c5e0617a6", pd.getString("CORPINFO_ID"))) { //一公司
- return mapEightService.getEcharts(pd);
- }else if (StringUtils.equals("8854edee3aa94be496cee676b6d4845a", pd.getString("CORPINFO_ID"))) { //曹妃甸东
- MultiValueMap paramMap = new LinkedMultiValueMap();
- //paramMap.add("CORPINFO_ID", pd.getString("CORPINFO_ID"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/Eight/getEcharts", paramMap, Map.class);
- return result;
- } else {
- return mapEightService.getEchartsOrder(pd);
- }
+ PageData pd = this.getPageData();
+ pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
+
+ return mapEightService.getEchartsOrder(pd);
}
/**
@@ -69,23 +57,11 @@ public class MapEightController extends BaseController {
public Object findFormCount() throws Exception {
Map map = new HashMap();
String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- if (StringUtils.equals("035958e685cf4850bc40151c5e0617a6", pd.getString("CORPINFO_ID"))) { // 一公司
- /*风险管控 数据统计*/
- //获取高危作业统计数据(申请数[COUNTAPPLY],审批中[COUNTAPPROVE],归档[COUNTARCHIVE])
- PageData data = mapEightService.statisticsHighRiskWorkByState(pd);
- map.put("pd", data);
- }else if (StringUtils.equals("8854edee3aa94be496cee676b6d4845a", pd.getString("CORPINFO_ID"))) { //曹妃甸东
- MultiValueMap paramMap = new LinkedMultiValueMap();
- //paramMap.add("CORPINFO_ID", pd.getString("CORPINFO_ID"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/Eight/findFormCount", paramMap, Map.class);
- return result;
- } else {
- PageData data = mapEightService.statisticsHighRiskWorkByStateOrder(pd);
- map.put("pd", data);
- }
+ PageData pd = this.getPageData();
+ pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
+
+ PageData data = mapEightService.statisticsHighRiskWorkByStateOrder(pd);
+ map.put("pd", data);
//pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
map.put("result", errInfo);
return map;
@@ -102,32 +78,10 @@ public class MapEightController extends BaseController {
public Object listHighRiskWork(Page page) throws Exception {
Map map = new HashMap();
String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- List varList = new ArrayList<>();
- //根据条件增加参数或减少参数 都没有 直接返回空
- if (StringUtils.isBlank(pd.getString("CORPINFO_ID"))) {
- List ArrayDATA_IDS = mapEightService.getCorpinfoIds(pd);
- if (ArrayDATA_IDS.size() == 0) {
- map.put("result", errInfo);
- return map;
- }
- pd.put("ids", ArrayDATA_IDS);
- pd.remove("CORPINFO_ID");
- }
+ PageData pd = this.getPageData();
+ pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
page.setPd(pd);
- if (StringUtils.equals("035958e685cf4850bc40151c5e0617a6", pd.getString("CORPINFO_ID"))) { //一公司
- //pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
- varList = mapEightService.listHighRiskWork(page);
- } else if (StringUtils.equals("8854edee3aa94be496cee676b6d4845a", pd.getString("CORPINFO_ID"))) { //曹妃甸
- MultiValueMap paramMap = new LinkedMultiValueMap();
- //paramMap.add("CORPINFO_ID", pd.getString("CORPINFO_ID"));
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/map/Eight/listHighRiskWork", paramMap, Map.class);
- return result;
- } else {
- varList = mapEightService.listHighRiskWorkOrder(page);
- }
+ List varList = mapEightService.listHighRiskWorkOrder(page);
map.put("varList", varList);
map.put("result", errInfo);
return map;
@@ -141,53 +95,13 @@ public class MapEightController extends BaseController {
*/
@RequestMapping(value = "/listAllHighRiskWorkLocation")
@ResponseBody
- public Object listAllHighRiskWorkLocation(@RequestParam(value = "CORPINFO_ID") String CORPINFO_ID, @RequestParam("TYPE") String type, @RequestParam("GANGKOU") String GANGKOU, @RequestParam("AREA") String AREA) throws Exception {
+ public Object listAllHighRiskWorkLocation() throws Exception {
Map map = new HashMap();
String errInfo = "success";
- PageData pd = new PageData();
- pd = this.getPageData();
- //pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 企业
- List varList = new ArrayList<>();
- //根据条件增加参数或减少参数 都没有 直接返回空
- if (StringUtils.isBlank(pd.getString("CORPINFO_ID"))) {
- List ArrayDATA_IDS = mapEightService.getCorpinfoIds(pd);
- if (ArrayDATA_IDS.size() == 0) {
- map.put("result", errInfo);
- return map;
- }
- pd.put("ids", ArrayDATA_IDS);
- pd.remove("CORPINFO_ID");
- }
- if (StringUtils.equals("8854edee3aa94be496cee676b6d4845a", pd.getString("CORPINFO_ID"))) { //曹妃甸
- MultiValueMap paramMap = new LinkedMultiValueMap();
- paramMap.add("TYPE", pd.getString("TYPE"));
- if (StringUtils.equals("CAMERA", pd.getString("TYPE"))) {
- Map result =
- restTemplate.postForObject(cfdUrl + "/sync/ObtainDisplayData/listAllCameraForMap", paramMap, Map.class);
- List