已完成对alarmController修改

src/main/java/com/welampiot/common/InterfaceResultEnum.java

@@ -243,6 +243,13 @@ public enum InterfaceResultEnum {
 
     // 告警维修 0800-0899
     REPAIR_INFOR_ERROR("0800","暂无维修信息","No maintenance information","Пока нет информации о ремонте"),
+    REPAIR_PARAM_EMPTY_ERROR("0801","编号与名字不能同时为空","Number and name cannot both be empty","Номер и имя не могут быть пустыми одновременно"),
+    CHECK_INFORMATION_ERROR("0802","无此设备,请检查相关输入信息","No such device, please check the relevant input information","Без этого устройства проверьте соответствующую входную информацию"),
+
+    //维修人员 0900-0999
+    PERSON_BIND_ERROR("0900","推送人员已经绑定了","The pusher is already bound","толкатель уже связал"),
+    PERSON_OVER_ERROR("0901","推送人员不能超过10个","No more than 10 people can be pushed","Численность персонала не должна превышать 10 человек"),
+
 
     ;
     private String code;

src/main/java/com/welampiot/controller/AlarmController.java

@@ -4,6 +4,7 @@ import com.welampiot.common.BaseResult;
 import com.welampiot.common.InterfaceResultEnum;
 import com.welampiot.dto.*;
 import com.welampiot.service.*;
+import com.welampiot.service.impl.WifiServiceImpl;
 import com.welampiot.utils.ExcelUtil;
 import com.welampiot.utils.ToolUtils;
 import com.welampiot.vo.*;
@@ -70,6 +71,18 @@ public class AlarmController {
     private VideoMonitorService videoMonitorService;
     @Autowired
     private EmergencyVideoService emergencyVideoService;
+    @Autowired
+    private WifiServiceImpl WifiService;
+    @Autowired
+    private RfidService rfidService;
+    @Autowired
+    private ScreenService screenService;
+    @Autowired
+    private ChargeService chargeService;
+    @Autowired
+    private EnvmonitorService envmonitorService;
+    @Autowired
+    private AirSwitchInfoService airSwitchInfoService;
 
     /**
      * 获取告警列表
@@ -545,17 +558,43 @@ public class AlarmController {
     public BaseResult<?> sendUserList(HttpServletRequest request) {
         Integer version = (Integer) toolUtils.getRequestContent(request,"version",1);
         Integer sectionId = (Integer) toolUtils.getRequestContent(request,"sectionId",1);
-        int page = request.getParameter("page") == null ? 1 : Integer.parseInt(request.getParameter("page"));
-        int count = request.getParameter("count") == null ? 16 : Integer.parseInt(request.getParameter("count"));
-        SendStatusVO sendStatusVO = new SendStatusVO();
-        sendStatusVO.setPage(count * (page - 1));
-        sendStatusVO.setCount(count);
-        sendStatusVO.setSectionList(toolUtils.getSectionList(request));
-        sendStatusVO.setSectionId(sectionId);
-        List<SendStatusDTO> sendPersonList = sendStatusService.getSendPersonList(sendStatusVO);
-        SendStatusVO vo = new SendStatusVO();
-        vo.setList(sendPersonList);
-        return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,vo);
+        if (sectionId == 0)
+            return toolUtils.response(InterfaceResultEnum.LACK_PARAM_ERROR,version);
+
+        RepairPersonnelDTO repairPersonnel = new RepairPersonnelDTO();
+
+        SectionDTO sectionDTO = new SectionDTO();
+        sectionDTO.setId(sectionId);
+        SectionDTO dataByVO = sectionService.getDataByVO(sectionDTO);
+        if (dataByVO == null || dataByVO.getAlarmUser() == null){
+            List<RepairPersonnelDTO>list = new ArrayList<>();
+            repairPersonnel.setList(list);
+            return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,repairPersonnel);
+        }
+        String[] userIdList = dataByVO.getAlarmUser().split(",");
+        List<RepairPersonnelDTO>list = repairPersonnelService.getRepairPersonnelByIds(userIdList);
+        SendStatusDTO dto = new SendStatusDTO();
+        dto.setSectionId(sectionId);
+        List<SendStatusDTO> sectionUsers = sendStatusService.getSectionUsers(dto);
+        for (RepairPersonnelDTO item:list) {
+            Integer isset = 0;
+            for (SendStatusDTO statusDTO:sectionUsers) {
+               if (item.getId().equals(statusDTO.getRepairUserId())){
+                   isset = 1;
+                    item.setIsPhone(statusDTO.getIsPhone());
+                    item.setIsEmail(statusDTO.getIsEmail());
+                    item.setStatus(statusDTO.getStatus());
+                    break;
+               }
+            }
+            if (isset == 0){
+                item.setIsPhone(0);
+                item.setIsEmail(0);
+                item.setStatus(0);
+            }
+        }
+        repairPersonnel.setList(list);
+        return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,repairPersonnel);
     }
 
     /**
@@ -570,6 +609,29 @@ public class AlarmController {
         Integer id = (Integer) toolUtils.getRequestContent(request,"id",1);
         if (id == 0 || sectionId == 0)
             return toolUtils.response(InterfaceResultEnum.LACK_PARAM_ERROR,version);
+
+        SectionDTO sectionDTO = new SectionDTO();
+        sectionDTO.setId(sectionId);
+        SectionDTO dataByVO = sectionService.getDataByVO(sectionDTO);
+        if (dataByVO == null){
+            return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version);
+        }
+        String[] userIdList = dataByVO.getAlarmUser().split(",");
+        if (userIdList == null) return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS, version);
+
+        ArrayList<String> newList = new ArrayList<>();
+        for (String userId:userIdList) {
+            if (!userId.isEmpty() && !id.equals(Integer.parseInt(userId))){
+               newList.add(userId);
+            }
+        }
+        //更新section
+        String userJoin = "";
+        if (newList != null){
+            userJoin = String.join(",", newList);
+        }
+        sectionDTO.setAlarmUser(userJoin);
+        sectionService.updateSectionById(sectionDTO);
         sendStatusService.deleteSendStatusData(sectionId,id);
         return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version);
     }
@@ -586,10 +648,36 @@ public class AlarmController {
         Integer id = (Integer) toolUtils.getRequestContent(request,"id",1);
         if (id == 0 || sectionId == 0)
             return toolUtils.response(InterfaceResultEnum.LACK_PARAM_ERROR,version);
-        SendStatusDTO sendStatusDTO = new SendStatusDTO();
-        sendStatusDTO.setSectionId(sectionId);
-        sendStatusDTO.setRepairUserid(id);
-        sendStatusService.addSendStatusData(sendStatusDTO);
+
+        SectionDTO sectionDTO = new SectionDTO();
+        sectionDTO.setId(sectionId);
+        SectionDTO dataByVO = sectionService.getDataByVO(sectionDTO);
+        ArrayList<String> newList = new ArrayList<>();
+        Integer personCount = 0;
+        if (dataByVO != null && dataByVO.getAlarmUser() != null){
+            String[] userIdList = dataByVO.getAlarmUser().split(",");
+            newList.addAll(Arrays.asList(userIdList));
+            boolean contains = newList.contains(id);
+            if (contains == true) return toolUtils.response(InterfaceResultEnum.PERSON_BIND_ERROR, version);
+            personCount = repairPersonnelService.getCountRepairPersonnel(userIdList);
+        }
+        if (personCount >= 10)  return toolUtils.response(InterfaceResultEnum.PERSON_OVER_ERROR, version);
+        newList.add(id.toString());
+        //更新section
+        String userJoin = "";
+        if (newList != null){
+            userJoin = String.join(",", newList);
+        }
+        sectionDTO.setAlarmUser(userJoin);
+        sectionService.updateSectionById(sectionDTO);
+        SendStatusDTO statusDTO = new SendStatusDTO();
+        statusDTO.setSectionId(sectionId);
+        statusDTO.setRepairUserId(id);
+        statusDTO.setIsPhone(1);
+        statusDTO.setIsEmail(1);
+        statusDTO.setType(version);
+
+        sendStatusService.addSendStatusData(statusDTO);
         return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version);
     }
 
@@ -607,12 +695,20 @@ public class AlarmController {
         Integer isEmail = (Integer) toolUtils.getRequestContent(request,"isEmail",1);
         if (id == 0 || sectionId == 0)
             return toolUtils.response(InterfaceResultEnum.LACK_PARAM_ERROR,version);
-        SendStatusDTO sendStatusDTO = new SendStatusDTO();
-        sendStatusDTO.setSectionId(sectionId);
-        sendStatusDTO.setRepairUserid(id);
-        sendStatusDTO.setIsPhone(isPhone);
-        sendStatusDTO.setIsEmail(isEmail);
-        sendStatusService.updateSendStatusData(sendStatusDTO);
+        SendStatusDTO statusDTO = new SendStatusDTO();
+        statusDTO.setSectionId(sectionId);
+        statusDTO.setRepairUserId(id);
+        statusDTO.setIsPhone(isPhone);
+        statusDTO.setIsEmail(isEmail);
+        statusDTO.setType(version);
+       List<SendStatusDTO>list = sendStatusService.getSectionUsers(statusDTO);
+       if (list == null || list.get(0).getId() == null){
+           //添加
+           sendStatusService.addSendStatusData(statusDTO);
+       }else {
+           //更新
+           sendStatusService.updateSendStatusData(statusDTO);
+       }
         return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version);
     }
 
@@ -631,9 +727,16 @@ public class AlarmController {
             return toolUtils.response(InterfaceResultEnum.LACK_PARAM_ERROR,version);
         SendStatusDTO sendStatusDTO = new SendStatusDTO();
         sendStatusDTO.setSectionId(sectionId);
-        sendStatusDTO.setRepairUserid(id);
+        sendStatusDTO.setRepairUserId(id);
+        List<SendStatusDTO>list = sendStatusService.getSectionUsers(sendStatusDTO);
         sendStatusDTO.setStatus(status);
-        sendStatusService.updateCloseStatus(sendStatusDTO);
+        if (list == null || list.get(0).getId() == null){
+            //添加
+            sendStatusService.addCloseStatus(sendStatusDTO);
+        }else {
+            //更新
+            sendStatusService.updateCloseStatus(sendStatusDTO);
+        }
         return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version);
     }
 
@@ -645,11 +748,24 @@ public class AlarmController {
     @RequestMapping(value = "/emAlarmHistory", method = RequestMethod.POST)
     public BaseResult<?> emAlarmHistory(HttpServletRequest request) {
         Integer version = (Integer) toolUtils.getRequestContent(request,"version",1);
-        List<Integer> sectionList = toolUtils.getSectionList(request);
-        List<EmergencyInfoLogDTO> list = emergencyInfoLogService.getEmergencyInfoLogListBySectionList(sectionList);
-        EmergencyInfoLogVO emergencyInfoLogVO = new EmergencyInfoLogVO();
-        emergencyInfoLogVO.setList(list);
-        return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,emergencyInfoLogVO);
+        UserDTO user = toolUtils.getUser(request);
+        List<String> sectionList = null;
+        EmergencyVO emergencyVO = new EmergencyVO();
+
+        if (user.getRole() != ToolUtils.SYSTEM_ADMIN){
+            List<EmergencyDTO>list = new ArrayList<>();
+            emergencyVO.setList(list);
+            sectionList = toolUtils.getSectionList(request);
+            if (sectionList == null) return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,emergencyVO);
+        }
+        emergencyVO.setSectionList(sectionList);
+       List<EmergencyDTO> joinList = emergencyService.getEmergencyJoinList(emergencyVO);
+        for (EmergencyDTO dto:joinList) {
+            dto.setName(dto.getSection()+" "+dto.getModel());
+        }
+        emergencyVO.setSectionList(null);
+        emergencyVO.setList(joinList);
+        return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,emergencyVO);
     }
 
     /**
@@ -663,27 +779,34 @@ public class AlarmController {
         Integer version = detailsVO.getVersion();
         Integer id = detailsVO.getId();
         if (id == 0) return toolUtils.response(InterfaceResultEnum.LACK_PARAM_ERROR,version);
-        Integer sectionId = emergencyService.getEmergencySectionIdById(id);
-        List<EmergencyVideoDTO> emergencyVideoList = emergencyVideoService.getVideoIdByEmergencyId(id);
-        List<VideoMonitorDTO> videoList = videoMonitorService.getVideoListBySectionId(sectionId);
-        List<Integer> ids = new ArrayList<>();
-        emergencyVideoList.forEach(dto -> ids.add(dto.getVideoId()));
-        for (VideoMonitorDTO dto : videoList) {
-            boolean isFlag = false;
-            for (Integer integer : ids) {
-                if (dto.getId().equals(integer)) {
-                    dto.setSelect(1);
-                    isFlag = true;
-                    break;
+        List<EmergencyVideoDTO> videoIdList = emergencyVideoService.getVideoIdByEmergencyId(id);
+        EmergencyDTO sectionOne = emergencyService.getSectionOne(id);
+
+        VideoMonitorVO videoMonitor = new VideoMonitorVO();
+        ArrayList<VideoMonitorDTO> list = new ArrayList<>();
+        videoMonitor.setList(list);
+
+        if (sectionOne != null && sectionOne.getSectionId() != null){
+            List<VideoMonitorDTO> dataList = videoMonitorService.getDataList(sectionOne);
+            //取出videoIdList的videoId值再去重
+            HashSet<Integer> videoIds = new HashSet<>();
+            if (videoIdList != null){
+                for (EmergencyVideoDTO dto:videoIdList) {
+                    videoIds.add(dto.getVideoId());
                 }
             }
-            if (!isFlag) {
-                dto.setSelect(0);
+
+            for (VideoMonitorDTO dto:dataList) {
+                dto.setStatus(0);
+                if (videoIdList != null){
+                   if (videoIds.contains(dto.getId())){
+                       dto.setStatus(1);
+                   }
+                }
             }
+            videoMonitor.setList(dataList);
         }
-        VideoMonitorVO videoMonitorVO = new VideoMonitorVO();
-        videoMonitorVO.setList(videoList);
-        return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,videoMonitorVO);
+        return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version,videoMonitor);
     }
 
     /**
@@ -708,4 +831,165 @@ public class AlarmController {
         }
         return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version);
     }
+    @RequestMapping(value = "/saveAlarmData", method = RequestMethod.POST)
+    public BaseResult<?> saveAlarmData(HttpServletRequest request) {
+        String number = request.getParameter("number");
+        String name = request.getParameter("name");
+        Integer areaId = request.getParameter("areaId") == null ? 0 : Integer.parseInt(request.getParameter("areaId"));
+        Integer sectionId = request.getParameter("sectionId") == null ? 0 : Integer.parseInt(request.getParameter("sectionId"));
+        String createTime = request.getParameter("createTime");
+        Integer devType = request.getParameter("devType") == null ? 0 : Integer.parseInt(request.getParameter("devType"));
+        Integer dType = request.getParameter("dType") == null ? 0 : Integer.parseInt(request.getParameter("dType"));
+        String alarmType = request.getParameter("alarmType");
+        Integer source = request.getParameter("source") == null ? 1 : Integer.parseInt(request.getParameter("source"));
+        Integer level = request.getParameter("level") == null ? 0 : Integer.parseInt(request.getParameter("level"));
+        Integer alarmStatus = request.getParameter("alarmStatus") == null ? 0 : Integer.parseInt(request.getParameter("alarmStatus"));
+        Integer version = request.getParameter("version") == null ? 0 : Integer.parseInt(request.getParameter("version"));
+
+        if (areaId == 0 || sectionId == 0) return toolUtils.response(InterfaceResultEnum.LACK_PARAM_ERROR,version);
+        if (number == null && name == null) return toolUtils.response(InterfaceResultEnum.REPAIR_PARAM_EMPTY_ERROR,version);
+        SectionDTO sectionDTO = new SectionDTO();
+        sectionDTO.setPid(areaId);
+        sectionDTO.setId(sectionId);
+        GlobalLocationDTO timeZoneData = globalLocationService.getTimeZoneData(sectionDTO);
+
+        HashMap<String,Object> where = new HashMap<>();
+        //HashMap<String,Object> where1 = new HashMap<>();
+        where.put("areaId",areaId);
+        where.put("sectionId",sectionId);
+        if (number != null){
+            String[] numberArr = number.split("_");
+            if (numberArr.length == 1 || (numberArr.length == 2 && numberArr[1].equals("1"))){
+                where.put("number",numberArr[0]);
+                where.put("mode",0);
+            }else {
+                where.put("number",numberArr[0]);
+                where.put("mode",1);
+            }
+        }
+        if (name != null){
+            where.put("name",name);
+        }
+        //设备类型（0 路灯，1 灯杆，2 井盖, 3 水浸，4配电柜）
+        Integer id = 0;
+        if (devType == 0){
+            //灯
+            LampInfoDTO oneLamp = lampService.getOneData(where);
+            if (oneLamp == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+            id = oneLamp.getId();
+        }else if (devType == 1){
+            //灯杆
+            //灯杆上的设备类型（0 路灯，1 摄像头，2 WIFI，3 RFID，4 LED屏，5 一键报警，6 充电桩，7 气象站，8 微基站，9 气象站）
+            if (dType == 0){
+                //灯
+                LampInfoDTO oneLamp = lampService.getOneData(where);
+                if (oneLamp == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneLamp.getId();
+            } else if (dType == 1) {
+                //1 摄像头
+                where.put("number",number);
+                where.put("name",name);
+
+                VideoMonitorDTO oneMonitor = videoMonitorService.getOneMonitor(where);
+                if (oneMonitor == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneMonitor.getId();
+            } else if (dType == 2) {
+                //2 WIFI  num
+                where.put("number",number);
+                where.put("name",name);
+                WifiDTO oneWifi = WifiService.getOneWifi(where);
+                if (oneWifi == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneWifi.getId();
+            } else if (dType == 3) {
+                //3 RFID  num
+                where.put("number",number);
+                where.put("name",name);
+                RfidDTO oneRifd = rfidService.getOneRifd(where);
+                if (oneRifd == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneRifd.getId();
+            } else if (dType == 4) {
+                //4 LED屏
+                where.put("number",number);
+                where.put("model",name);
+                ScreenDTO oneScreen = screenService.getOneScreen(where);
+                if (oneScreen == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneScreen.getId();
+            } else if (dType == 5) {
+                //5 一键报警，
+                where.put("number",number);
+                where.put("model",name);
+                EmergencyDTO oneEmergency = emergencyService.getOneEmergency(where);
+                if (oneEmergency == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneEmergency.getId();
+            } else if (dType == 6) {
+                //6 充电桩，
+                where.put("number",number);
+                where.put("model",name);
+                ChargeDTO oneCharge = chargeService.getOneCharge(where);
+                if (oneCharge == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneCharge.getId();
+            } else if (dType == 7) {
+                //7 气象站，8 微基站，9 音柱
+                where.put("number",number);
+                where.put("model",name);
+                EnvmonitorDTO oneEnvmonitor = envmonitorService.getOneEnvmonitor(where);
+                if (oneEnvmonitor == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+                id = oneEnvmonitor.getId();
+            }
+        } else if (devType == 2) {
+            //2 井盖, 3 水浸，4配电柜
+            where.put("number",number);
+            where.put("name",name);
+            ManholeDTO oneManhole = manholeService.getOneManhole(where);
+            if (oneManhole == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+            id = oneManhole.getId();
+        } else if (devType == 3) {
+            //3 水浸，4配电柜
+            where.put("number",number);
+            where.put("name",name);
+            WaterImmersionDevInfoDTO oneWaterImmersion = waterImmersionDevInfoService.getOneWaterImmersion(where);
+            if (oneWaterImmersion == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+            id = oneWaterImmersion.getId();
+        } else {
+            //4配电柜
+            where.put("address",number);
+            where.put("name",name);
+            AirSwitchInfoDTO oneAirSwitch = airSwitchInfoService.getOneAirSwitch(where);
+            if (oneAirSwitch == null) return toolUtils.response(InterfaceResultEnum.CHECK_INFORMATION_ERROR,version);
+            id = oneAirSwitch.getId();
+        }
+        AllAlarmInfoLogDTO allAlarmInfoLogDTO = new AllAlarmInfoLogDTO();
+        allAlarmInfoLogDTO.setLampId(id);
+        allAlarmInfoLogDTO.setStrAlarmType(alarmType);
+        Integer timezone = timeZoneData.getTimezone();
+        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        String newCreatetime = "";
+        Date parse = null;
+        if (timezone > 0){
+
+            try {
+                parse = dateFormat.parse(createTime);
+            } catch (ParseException e) {
+                throw new RuntimeException(e);
+            }
+            long stamp = parse.getTime() / 1000 - timezone * 3600;
+            newCreatetime = dateFormat.format(new Date(stamp));
+        }else if (timezone < 0){
+            try {
+                parse = dateFormat.parse(createTime);
+            } catch (ParseException e) {
+                throw new RuntimeException(e);
+            }
+            long stamp = parse.getTime() / 1000 + timezone * 3600;
+            newCreatetime = dateFormat.format(new Date(stamp));
+        }
+        allAlarmInfoLogDTO.setUpdateTime(newCreatetime);
+        allAlarmInfoLogDTO.setDevType(devType);
+        allAlarmInfoLogDTO.setDType(dType);
+        allAlarmInfoLogDTO.setSource(source);
+        allAlarmInfoLogDTO.setLevel(level);
+        allAlarmInfoLogDTO.setAlarmStatus(alarmStatus);
+        allAlarmInfoLogService.addAlarmData(allAlarmInfoLogDTO);
+        return toolUtils.response(InterfaceResultEnum.OPERATION_SUCCESS,version);
+    }
 }

src/main/java/com/welampiot/dao/AirSwitchInfoDao.java

@@ -3,6 +3,7 @@ package com.welampiot.dao;
 import com.welampiot.dto.AirSwitchInfoDTO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -37,4 +38,5 @@ public interface AirSwitchInfoDao {
     void updateAirSwitchStatusById(AirSwitchInfoDTO dto);
     List<AirSwitchInfoDTO> getAirSwitchAddressByEleBoxAddr(@Param("address") String address);
     Integer getAirSwitchCountByEleBoxAddr(@Param("address") String address);
+    AirSwitchInfoDTO getOneAirSwitch(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/AllAlarmInfoLogDao.java

@@ -54,4 +54,6 @@ public interface AllAlarmInfoLogDao {
     Integer getOneLampPoleAlarmTotal(@Param("lampPoleId") Integer lampPoleId);
 
     List<AllAlarmInfoLogDTO> getOneLampPoleAlarmList(@Param("lampPoleId") Integer lampPoleId);
+
+    void addAlarmData(AllAlarmInfoLogDTO dto);
 }

src/main/java/com/welampiot/dao/ChargeDao.java

@@ -3,6 +3,7 @@ package com.welampiot.dao;
 import com.welampiot.dto.ChargeDTO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -48,4 +49,6 @@ public interface ChargeDao {
     List<ChargeDTO> getChargeListByDTO(ChargeDTO dto);
 
     Integer getChargeTotalByDTO(ChargeDTO dto);
+
+    ChargeDTO getOneCharge(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/EmergencyDao.java

@@ -4,6 +4,7 @@ import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.vo.EmergencyVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -37,4 +38,8 @@ public interface EmergencyDao {
     void updateEmergencyData(EmergencyDTO dto);
 
     List<EmergencyDTO> getEmergencyDevList(EmergencyVO vo);
+
+    List<EmergencyDTO> getEmergencyJoinList(EmergencyVO vo);
+    EmergencyDTO getSectionOne(Integer id);
+    EmergencyDTO getOneEmergency(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/EmergencyVideoDao.java

@@ -1,5 +1,6 @@
 package com.welampiot.dao;
 
+import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.dto.EmergencyVideoDTO;
 import org.apache.ibatis.annotations.Param;
 

src/main/java/com/welampiot/dao/EnvmonitorDao.java

@@ -6,6 +6,7 @@ import com.welampiot.vo.EnvmonitorVO;
 import com.welampiot.vo.MapDataVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -69,4 +70,6 @@ public interface EnvmonitorDao {
 
     List<EnvmonitorDTO> getIlluminanceListByVO(EnvmonitorVO vo);
     List<EnvmonitorDTO> getNewMapDataByVO(MapDataVO vo);
+    EnvmonitorDTO getOneEnvmonitor(HashMap<String,Object> map);
+
 }

src/main/java/com/welampiot/dao/GlobalLocationDao.java

@@ -1,6 +1,7 @@
 package com.welampiot.dao;
 
 import com.welampiot.dto.GlobalLocationDTO;
+import com.welampiot.dto.SectionDTO;
 import com.welampiot.vo.GlobalLocationVO;
 import org.apache.ibatis.annotations.Param;
 
@@ -50,4 +51,5 @@ public interface GlobalLocationDao {
     List<GlobalLocationDTO> getCityLampPoleCountList(GlobalLocationVO vo);
     GlobalLocationDTO getDataByDto(GlobalLocationDTO dto);
     List<GlobalLocationDTO> getAreaList(GlobalLocationDTO dto);
+    GlobalLocationDTO getTimeZoneData(SectionDTO dto);
 }

src/main/java/com/welampiot/dao/LampDao.java

@@ -9,6 +9,7 @@ import com.welampiot.vo.LampLogVO;
 import com.welampiot.vo.LampVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 public interface LampDao {
@@ -66,4 +67,5 @@ public interface LampDao {
     List<LampInfoDTO> getListByDto(LampInfoDTO dto);
     void addByDto(LampInfoDTO dto);
     void updateById(LampInfoDTO dto);
+    LampInfoDTO getOneData(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/ManholeDao.java

@@ -3,6 +3,7 @@ package com.welampiot.dao;
 import com.welampiot.dto.ManholeDTO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -44,4 +45,5 @@ public interface ManholeDao {
     ManholeDTO getManholeDTOById(@Param("id") Integer id);
 
     ManholeDTO getTiltManholeByLampPoleId(@Param("lampPoleId") Integer lampPoleId);
+    ManholeDTO getOneManhole(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/RepairPersonnelDao.java

@@ -32,4 +32,6 @@ public interface RepairPersonnelDao {
     void deleteRepairPersonnelDataByDTO(@Param("id") Integer id);
 
     List<RepairPersonnelDTO> getRepairPersonnelDropDownListByDTO(@Param("id") Integer id);
+    List<RepairPersonnelDTO> getRepairPersonnelByIds(String[] ids);
+    Integer getCountRepairPersonnel(String[] ids);
 }

src/main/java/com/welampiot/dao/RfidDao.java

@@ -0,0 +1,9 @@
+package com.welampiot.dao;
+
+import com.welampiot.dto.RfidDTO;
+
+import java.util.HashMap;
+
+public interface RfidDao {
+    RfidDTO getOneRifd(HashMap<String,Object> map);
+}

src/main/java/com/welampiot/dao/ScreenDao.java

@@ -3,6 +3,7 @@ package com.welampiot.dao;
 import com.welampiot.dto.ScreenDTO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -40,4 +41,5 @@ public interface ScreenDao {
     Integer checkScreenData(ScreenDTO dto);
     ScreenDTO getScreenById(@Param("id")int id);
     void updateByDto(ScreenDTO dto);
+    ScreenDTO getOneScreen(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/SectionDao.java

@@ -23,4 +23,5 @@ public interface SectionDao {
     List<SectionDTO> getAllSectionList();
     List<SectionDTO> getAllSectionListByPid(@Param("id") Integer id);
     SectionDTO getDataByVO(SectionDTO dto);
+    void updateSectionById(SectionDTO dto);
 }

src/main/java/com/welampiot/dao/SendStatusDao.java

@@ -25,4 +25,8 @@ public interface SendStatusDao {
     void updateSendStatusData(SendStatusDTO dto);
 
     void updateCloseStatus(SendStatusDTO dto);
+
+    List<SendStatusDTO>getSectionUsers(SendStatusDTO dto);
+
+    void addCloseStatus(SendStatusDTO dto);
 }

src/main/java/com/welampiot/dao/VideoMonitorDao.java

@@ -1,9 +1,11 @@
 package com.welampiot.dao;
 
+import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.dto.VideoMonitorDTO;
 import com.welampiot.vo.VideoMonitorVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 public interface VideoMonitorDao {
@@ -47,4 +49,8 @@ public interface VideoMonitorDao {
     VideoMonitorDTO getVideoMonitorByLampPoleId(@Param("lampPoleId") Integer lampPoleId);
 
     void updateIsAutoStatus(VideoMonitorDTO dto);
+
+    List<VideoMonitorDTO> getDataList(EmergencyDTO dto);
+
+    VideoMonitorDTO getOneMonitor(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/WaterImmersionDevInfoDao.java

@@ -4,6 +4,7 @@ import com.welampiot.dto.WaterImmersionDevInfoDTO;
 import com.welampiot.dto.WaterImmersionDevInfoLogDTO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -47,4 +48,5 @@ public interface WaterImmersionDevInfoDao {
     Integer getWaterImmersionNewCount(WaterImmersionDevInfoDTO dto);
     void updateDelayTimeByDto(WaterImmersionDevInfoDTO dto);
     int getTotalBySectionList(WaterImmersionDevInfoDTO dto);
+    WaterImmersionDevInfoDTO getOneWaterImmersion(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dao/WifiDao.java

@@ -3,6 +3,7 @@ package com.welampiot.dao;
 import com.welampiot.dto.WifiDTO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -34,4 +35,5 @@ public interface WifiDao {
     WifiDTO getWifiInfoDetails(WifiDTO dto);
     WifiDTO getTotalWifiCountAndFlow(WifiDTO dto);
     WifiDTO getWifiByLampPoleId(@Param("lampPoleId") Integer lampPoleId);
+    WifiDTO getOneWifi(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/dto/AllAlarmInfoLogDTO.java

@@ -31,4 +31,6 @@ public class AllAlarmInfoLogDTO {
     private String alarmInfo;
     private String beginDate;
     private String endDate;
+    private Integer source;
+    private Integer level;
 }

src/main/java/com/welampiot/dto/EmergencyDTO.java

@@ -3,6 +3,7 @@ package com.welampiot.dto;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.util.List;
 
 /**
  * ClassName: EmergencyDTO
@@ -50,4 +51,9 @@ public class EmergencyDTO implements Serializable {
     private String expirationDate;
 
     private static final long serialVersionUID = 1L;
+
+    private String section;
+
+    private String beginDate;
+    private String name;
 }

src/main/java/com/welampiot/dto/RepairPersonnelDTO.java

@@ -3,6 +3,7 @@ package com.welampiot.dto;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.util.List;
 
 /**
  * ClassName: RepairPersonnelDTO
@@ -60,4 +61,10 @@ public class RepairPersonnelDTO implements Serializable {
     private Integer select;
 
     private static final long serialVersionUID = 1L;
+    private List<RepairPersonnelDTO> list;
+    private String department;
+    private String jobNumber;
+    private Integer isPhone;
+    private Integer isEmail;
+    private Integer status;
 }

src/main/java/com/welampiot/dto/RfidDTO.java

@@ -0,0 +1,16 @@
+package com.welampiot.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class RfidDTO implements Serializable {
+    private Integer id;
+    private String model;
+    private String num;
+    private String remarks;
+    private Integer lampPoleId;
+    private String installDate;
+    private String expirationDate;
+}

src/main/java/com/welampiot/dto/SendStatusDTO.java

@@ -19,7 +19,7 @@ public class SendStatusDTO implements Serializable {
 
     private Integer sectionId;
 
-    private Integer repairUserid; // 推送人员id
+    private Integer repairUserId; // 推送人员id
 
     private Integer isPhone; // 是否开启短信推送
 

src/main/java/com/welampiot/service/AirSwitchInfoService.java

@@ -6,6 +6,7 @@ import com.welampiot.vo.AirSwitchDetailVO;
 import com.welampiot.vo.AirSwitchInfoReturnVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 
@@ -31,4 +32,5 @@ public interface AirSwitchInfoService {
     void updateAirSwitchStatusById(AirSwitchInfoDTO dto);
     List<AirSwitchInfoDTO> getAirSwitchAddressByEleBoxAddr(String address);
     Integer getAirSwitchCountByEleBoxAddr(String address);
+    AirSwitchInfoDTO getOneAirSwitch(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/AllAlarmInfoLogService.java

@@ -53,4 +53,5 @@ public interface AllAlarmInfoLogService {
     List<AllAlarmInfoLogDTO> getOneLampPoleAlarmList(Integer lampPoleId);
 
     List<AllAlarmInfoLogDTO> getLessLampAlarmInfoList(AllAlarmInfoLogVO vo);
+    void addAlarmData(AllAlarmInfoLogDTO dto);
 }

src/main/java/com/welampiot/service/ChargeService.java

@@ -3,6 +3,7 @@ package com.welampiot.service;
 import com.welampiot.dto.ChargeDTO;
 import com.welampiot.vo.ChargeVO;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -36,4 +37,5 @@ public interface ChargeService {
     List<ChargeDTO> getChargeListByDTO(ChargeDTO dto);
 
     Integer getChargeTotalByDTO(ChargeDTO dto);
+    ChargeDTO getOneCharge(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/EmergencyService.java

@@ -3,6 +3,7 @@ package com.welampiot.service;
 import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.vo.EmergencyVO;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -36,4 +37,8 @@ public interface EmergencyService {
     void updateEmergencyData(EmergencyDTO dto);
 
     List<EmergencyDTO> getEmergencyDevList(EmergencyVO vo);
+
+    List<EmergencyDTO> getEmergencyJoinList(EmergencyVO vo);
+    EmergencyDTO getSectionOne(Integer id);
+    EmergencyDTO getOneEmergency(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/EmergencyVideoService.java

@@ -1,5 +1,6 @@
 package com.welampiot.service;
 
+import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.dto.EmergencyVideoDTO;
 
 import java.util.List;

src/main/java/com/welampiot/service/EnvmonitorService.java

@@ -5,6 +5,7 @@ import com.welampiot.vo.EnvmonitorDetailVO;
 import com.welampiot.vo.EnvmonitorVO;
 import com.welampiot.vo.MapDataVO;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -66,4 +67,5 @@ public interface EnvmonitorService {
 
     List<EnvmonitorDTO> getIlluminanceListByVO(EnvmonitorVO vo);
     List<EnvmonitorDTO> getNewMapDataByVO(MapDataVO vo);
+    EnvmonitorDTO getOneEnvmonitor(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/GlobalLocationService.java

@@ -1,6 +1,7 @@
 package com.welampiot.service;
 
 import com.welampiot.dto.GlobalLocationDTO;
+import com.welampiot.dto.SectionDTO;
 import com.welampiot.vo.GlobalLocationVO;
 import org.apache.ibatis.annotations.Param;
 
@@ -35,4 +36,5 @@ public interface GlobalLocationService {
     List<GlobalLocationDTO> getCountryOfSectionList(Integer level, Integer version);
     GlobalLocationDTO getDataByDto(GlobalLocationDTO dto);
     List<GlobalLocationDTO> getAreaList(GlobalLocationDTO dto);
+    GlobalLocationDTO getTimeZoneData(SectionDTO dto);
 }

src/main/java/com/welampiot/service/LampService.java

@@ -7,6 +7,7 @@ import com.welampiot.vo.*;
 import org.apache.ibatis.annotations.Param;
 
 import java.text.ParseException;
+import java.util.HashMap;
 import java.util.List;
 
 public interface LampService {
@@ -66,4 +67,5 @@ public interface LampService {
     List<LampInfoDTO> getListByDto(LampInfoDTO dto);
     void addByDto(LampInfoDTO dto);
     void updateById(LampInfoDTO dto);
+    LampInfoDTO getOneData(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/ManholeService.java

@@ -3,6 +3,7 @@ package com.welampiot.service;
 import com.welampiot.dto.ManholeDTO;
 import com.welampiot.vo.ManholeVO;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -36,4 +37,5 @@ public interface ManholeService {
     ManholeDTO getManholeDTOById(Integer id);
 
     ManholeDTO getTiltManholeByLampPoleId(Integer lampPoleId);
+    ManholeDTO getOneManhole(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/RepairPersonnelService.java

@@ -5,6 +5,8 @@ import com.welampiot.vo.RepairPersonnelDetailsVO;
 import com.welampiot.vo.RepairPersonnelVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 /**
  * ClassName: RepairPersonnelService
  * Package: com.welampiot.service
@@ -32,4 +34,6 @@ public interface RepairPersonnelService {
     void deleteRepairPersonnelDataByDTO(@Param("id") Integer id);
 
     RepairPersonnelVO getRepairPersonnelDropDownListByDTO(Integer id);
+    List<RepairPersonnelDTO> getRepairPersonnelByIds(String[] ids);
+    Integer getCountRepairPersonnel(String[] ids);
 }

src/main/java/com/welampiot/service/RfidService.java

@@ -0,0 +1,9 @@
+package com.welampiot.service;
+
+import com.welampiot.dto.RfidDTO;
+
+import java.util.HashMap;
+
+public interface RfidService {
+    RfidDTO getOneRifd(HashMap<String,Object> map);
+}

src/main/java/com/welampiot/service/ScreenService.java

@@ -3,8 +3,8 @@ package com.welampiot.service;
 import com.welampiot.dto.ScreenDTO;
 import com.welampiot.vo.ScreenDetailsVO;
 import com.welampiot.vo.ScreenVO;
-import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -38,4 +38,5 @@ public interface ScreenService {
     Integer checkScreenData(ScreenDTO dto);
     ScreenDTO getScreenById(int id);
     void updateByDto(ScreenDTO dto);
+    ScreenDTO getOneScreen(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/SectionService.java

@@ -24,4 +24,5 @@ public interface SectionService {
     List<SectionDTO> getAllSectionList();
     List<SectionDTO> getAllSectionListByPid(@Param("id") Integer id);
     SectionDTO getDataByVO(SectionDTO dto);
+    void updateSectionById(SectionDTO dto);
 }

src/main/java/com/welampiot/service/SendStatusService.java

@@ -24,4 +24,7 @@ public interface SendStatusService {
     void updateSendStatusData(SendStatusDTO dto);
 
     void updateCloseStatus(SendStatusDTO dto);
+    List<SendStatusDTO>getSectionUsers(SendStatusDTO dto);
+
+    void addCloseStatus(SendStatusDTO dto);
 }

src/main/java/com/welampiot/service/VideoMonitorService.java

@@ -1,9 +1,11 @@
 package com.welampiot.service;
 
+import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.dto.VideoMonitorDTO;
 import com.welampiot.vo.VideoMonitorVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 public interface VideoMonitorService {
@@ -33,4 +35,6 @@ public interface VideoMonitorService {
     VideoMonitorDTO getTotalCarAndPeople(VideoMonitorVO vo);
     VideoMonitorDTO getVideoMonitorByLampPoleId(Integer lampPoleId);
     void updateIsAutoStatus(VideoMonitorDTO dto);
+    List<VideoMonitorDTO> getDataList(EmergencyDTO dto);
+    VideoMonitorDTO getOneMonitor(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/WaterImmersionDevInfoService.java

@@ -5,6 +5,8 @@ import com.welampiot.dto.WaterImmersionDevInfoLogDTO;
 import com.welampiot.vo.WaterImmersionDevInfoLogVO;
 import com.welampiot.vo.WaterImmersionDevInfoVO;
 
+import java.util.HashMap;
+
 /**
  * ClassName: WaterImmersionDevInfoService
  * Package: com.welampiot.service
@@ -40,4 +42,5 @@ public interface WaterImmersionDevInfoService {
     Integer getWaterImmersionNewCount(WaterImmersionDevInfoDTO dto);
     void updateDelayTimeByDto(WaterImmersionDevInfoDTO dto);
     int getTotalBySectionList(WaterImmersionDevInfoDTO dto);
+    WaterImmersionDevInfoDTO getOneWaterImmersion(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/WifiService.java

@@ -6,6 +6,7 @@ import com.welampiot.vo.WifiOutInfoVO;
 import com.welampiot.vo.WifiVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -36,4 +37,5 @@ public interface WifiService {
     WifiDTO getWifiInfoDetails(WifiDTO dto);
     WifiDTO getTotalWifiCountAndFlow(WifiDTO dto);
     WifiDTO getWifiByLampPoleId(Integer lampPoleId);
+    WifiDTO getOneWifi(HashMap<String,Object> map);
 }

src/main/java/com/welampiot/service/impl/AirSwitchInfoServiceImpl.java

@@ -18,6 +18,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -162,4 +163,8 @@ public class AirSwitchInfoServiceImpl implements AirSwitchInfoService {
     public Integer getAirSwitchCountByEleBoxAddr(String address) {
         return airSwitchInfoDao.getAirSwitchCountByEleBoxAddr(address);
     }
+    @Override
+    public AirSwitchInfoDTO getOneAirSwitch(HashMap<String,Object> map){
+        return airSwitchInfoDao.getOneAirSwitch(map);
+    }
 }

src/main/java/com/welampiot/service/impl/AllAlarmInfoLogServiceImpl.java

@@ -212,4 +212,8 @@ public class AllAlarmInfoLogServiceImpl implements AllAlarmInfoLogService {
     public List<AllAlarmInfoLogDTO> getLessLampAlarmInfoList(AllAlarmInfoLogVO vo) {
         return allAlarmInfoLogDao.getLessLampAlarmInfoList(vo);
     }
+    @Override
+    public void addAlarmData(AllAlarmInfoLogDTO dto){
+        allAlarmInfoLogDao.addAlarmData(dto);
+    }
 }

src/main/java/com/welampiot/service/impl/ChargeServiceImpl.java

@@ -11,6 +11,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -212,4 +213,8 @@ public class ChargeServiceImpl implements ChargeService {
     public Integer getChargeTotalByDTO(ChargeDTO dto) {
         return chargeDao.getChargeTotalByDTO(dto);
     }
+    @Override
+    public ChargeDTO getOneCharge(HashMap<String,Object> map){
+        return chargeDao.getOneCharge(map);
+    }
 }

src/main/java/com/welampiot/service/impl/EmergencyServiceImpl.java

@@ -7,6 +7,7 @@ import com.welampiot.vo.EmergencyVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -77,4 +78,16 @@ public class EmergencyServiceImpl implements EmergencyService {
     public List<EmergencyDTO> getEmergencyDevList(EmergencyVO vo) {
         return emergencyDao.getEmergencyDevList(vo);
     }
+    @Override
+    public List<EmergencyDTO> getEmergencyJoinList(EmergencyVO vo){
+        return emergencyDao.getEmergencyJoinList(vo);
+    }
+    @Override
+    public EmergencyDTO getSectionOne(Integer id){
+        return emergencyDao.getSectionOne(id);
+    }
+    @Override
+    public EmergencyDTO getOneEmergency(HashMap<String,Object> map){
+        return emergencyDao.getOneEmergency(map);
+    }
 }

src/main/java/com/welampiot/service/impl/EmergencyVideoServiceImpl.java

@@ -1,6 +1,7 @@
 package com.welampiot.service.impl;
 
 import com.welampiot.dao.EmergencyVideoDao;
+import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.dto.EmergencyVideoDTO;
 import com.welampiot.service.EmergencyVideoService;
 import org.springframework.beans.factory.annotation.Autowired;

src/main/java/com/welampiot/service/impl/EnvmonitorServiceImpl.java

@@ -13,6 +13,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -306,4 +307,8 @@ public class EnvmonitorServiceImpl implements EnvmonitorService {
     public List<EnvmonitorDTO> getNewMapDataByVO(MapDataVO vo) {
         return envmonitorDao.getNewMapDataByVO(vo);
     }
+    @Override
+    public EnvmonitorDTO getOneEnvmonitor(HashMap<String,Object> map){
+        return envmonitorDao.getOneEnvmonitor(map);
+    }
 }

src/main/java/com/welampiot/service/impl/GlobalLocationServiceImpl.java

@@ -2,6 +2,7 @@ package com.welampiot.service.impl;
 
 import com.welampiot.dao.GlobalLocationDao;
 import com.welampiot.dto.GlobalLocationDTO;
+import com.welampiot.dto.SectionDTO;
 import com.welampiot.service.GlobalLocationService;
 import com.welampiot.vo.GlobalLocationVO;
 import org.apache.ibatis.annotations.Param;
@@ -247,4 +248,8 @@ public class GlobalLocationServiceImpl implements GlobalLocationService {
     public List<GlobalLocationDTO> getAreaList(GlobalLocationDTO dto){
         return globalLocationDao.getAreaList(dto);
     }
+    @Override
+    public GlobalLocationDTO getTimeZoneData(SectionDTO dto){
+        return globalLocationDao.getTimeZoneData(dto);
+    }
 }

src/main/java/com/welampiot/service/impl/LampServiceImpl.java

@@ -782,4 +782,8 @@ public class LampServiceImpl implements LampService {
     public void updateById(LampInfoDTO dto){
          lampDao.updateById( dto);
     }
+    @Override
+    public LampInfoDTO getOneData(HashMap<String,Object> map){
+        return lampDao.getOneData(map);
+    }
 }

src/main/java/com/welampiot/service/impl/ManholeServiceImpl.java

@@ -14,6 +14,7 @@ import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -287,4 +288,9 @@ public class ManholeServiceImpl implements ManholeService {
         dto.setAlarmInfo(alarmInfo);
         return dto;
     }
+
+    @Override
+    public ManholeDTO getOneManhole(HashMap<String,Object> map){
+        return manholeDao.getOneManhole(map);
+    }
 }

src/main/java/com/welampiot/service/impl/RepairPersonnelServiceImpl.java

@@ -80,4 +80,12 @@ public class RepairPersonnelServiceImpl implements RepairPersonnelService {
         vo.setList(dropDownListByDTO);
         return vo;
     }
+    @Override
+    public List<RepairPersonnelDTO> getRepairPersonnelByIds(String[] ids){
+        return repairPersonnelDao.getRepairPersonnelByIds(ids);
+    }
+    @Override
+    public Integer getCountRepairPersonnel(String[] ids){
+        return repairPersonnelDao.getCountRepairPersonnel(ids);
+    }
 }

src/main/java/com/welampiot/service/impl/RfidServiceImpl.java

@@ -0,0 +1,19 @@
+package com.welampiot.service.impl;
+
+import com.welampiot.dao.RfidDao;
+import com.welampiot.dto.RfidDTO;
+import com.welampiot.service.RfidService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+
+@Service
+public class RfidServiceImpl implements RfidService {
+    @Autowired
+    RfidDao rfidDao;
+    @Override
+    public RfidDTO getOneRifd(HashMap<String,Object> map){
+        return rfidDao.getOneRifd(map);
+    }
+}

src/main/java/com/welampiot/service/impl/ScreenServiceImpl.java

@@ -12,6 +12,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -267,4 +268,7 @@ public class ScreenServiceImpl implements ScreenService {
     public Integer getTotalBySectionList(ScreenDTO dto) {
         return screenDao.getTotalBySectionList(dto);
     }
+    public ScreenDTO getOneScreen(HashMap<String,Object> map){
+        return screenDao.getOneScreen(map);
+    }
 }

src/main/java/com/welampiot/service/impl/SectionServiceImpl.java

@@ -82,4 +82,7 @@ public class SectionServiceImpl implements SectionService {
     public SectionDTO getDataByVO(SectionDTO dto){
         return sectionDao.getDataByVO(dto);
     }
+    public void updateSectionById(SectionDTO dto){
+        sectionDao.updateSectionById( dto);
+    }
 }

src/main/java/com/welampiot/service/impl/SendStatusServiceImpl.java

@@ -47,4 +47,12 @@ public class SendStatusServiceImpl implements SendStatusService {
     public void updateCloseStatus(SendStatusDTO dto) {
         sendStatusDao.updateCloseStatus(dto);
     }
+    @Override
+    public List<SendStatusDTO>getSectionUsers(SendStatusDTO dto){
+        return sendStatusDao.getSectionUsers(dto);
+    }
+    @Override
+    public void addCloseStatus(SendStatusDTO dto){
+        sendStatusDao.addCloseStatus(dto);
+    }
 }

src/main/java/com/welampiot/service/impl/VideoMonitorServiceImpl.java

@@ -1,12 +1,14 @@
 package com.welampiot.service.impl;
 
 import com.welampiot.dao.VideoMonitorDao;
+import com.welampiot.dto.EmergencyDTO;
 import com.welampiot.dto.VideoMonitorDTO;
 import com.welampiot.service.VideoMonitorService;
 import com.welampiot.vo.VideoMonitorVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.HashMap;
 import java.util.List;
 
 @Service
@@ -144,4 +146,14 @@ public class VideoMonitorServiceImpl implements VideoMonitorService {
     public VideoMonitorDTO getOneByDevId(String devId) {
         return videoMonitorDao.getOneByDevId(devId);
     }
+
+    @Override
+    public List<VideoMonitorDTO> getDataList(EmergencyDTO dto){
+        return videoMonitorDao.getDataList(dto);
+    }
+    @Override
+    public VideoMonitorDTO getOneMonitor(HashMap<String,Object> map){
+        return videoMonitorDao.getOneMonitor(map);
+    }
+
 }

src/main/java/com/welampiot/service/impl/WaterImmersionDevInfoServiceImpl.java

@@ -13,6 +13,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -315,4 +316,8 @@ public class WaterImmersionDevInfoServiceImpl implements WaterImmersionDevInfoSe
     public int getTotalBySectionList(WaterImmersionDevInfoDTO dto) {
         return waterImmersionDevInfoDao.getTotalBySectionList(dto);
     }
+    @Override
+    public WaterImmersionDevInfoDTO getOneWaterImmersion(HashMap<String,Object> map){
+        return waterImmersionDevInfoDao.getOneWaterImmersion(map);
+    }
 }

src/main/java/com/welampiot/service/impl/WifiServiceImpl.java

@@ -17,6 +17,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -263,4 +264,8 @@ public class WifiServiceImpl implements WifiService {
         }
         return dto;
     }
+    @Override
+    public WifiDTO getOneWifi(HashMap<String,Object> map){
+        return wifiDao.getOneWifi(map);
+    }
 }

src/main/resources/mapper/AirSwitchInfoMapper.xml

@@ -128,4 +128,21 @@
         where e.address = #{address}
     </select>
 
+    <select id="getOneAirSwitch" parameterType="HashMap" resultType="AirSwitchInfoDTO">
+        select E.id  
+        from air_switch_info M 
+            left join electric_box E on M.box_id = E.id 
+        where E.areaid = #{areaId} and E.sectionid = #{sectionid} 
+        <choose>
+            <when test="address != null and name == null">
+                and M.address = #{address}
+            </when>
+            <when test="address == null and name != null">
+                and M.name = #{name}
+            </when>
+            <otherwise>
+                and M.address = #{address} and M.name = #{name}
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/AllAlarmInfoLogMapper.xml

@@ -931,4 +931,9 @@
         order by a.updatetime desc
     </select>
 
+    <insert id="addAlarmData" parameterType="allAlarmInfoLogDTO" keyProperty="id" useGeneratedKeys="true">
+        insert into all_alarm_info_log(lampid,stralarmtype,updatetime,devType,dType,source,level,alarm_status)
+        values
+            (#{lampId},#{strAlarmType},#{updateTime},#{devType},#{dType},#{source},#{level},#{alarmStatus})
+    </insert>
 </mapper>

src/main/resources/mapper/ChargeMapper.xml

@@ -280,4 +280,21 @@
         </if>
     </select>
 
+    <select id="getOneCharge" parameterType="HashMap" resultType="ChargeDTO">
+        select C.id
+        from charge C
+            left join lamp_pole P on P.id = C.lamp_pole_id
+        where P.areaid = #{areaId} and P.sectionid = #{sectionid}
+        <choose>
+            <when test="number != null and model == null">
+                and C.num = #{number}
+            </when>
+            <when test="number == null and model != null">
+                and C.model = #{model}
+            </when>
+            <otherwise>
+                and C.num = #{number} and C.model = #{model}
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/EmergencyMapper.xml

@@ -120,4 +120,44 @@
         </if>
     </select>
 
+    <select id="getEmergencyJoinList" resultType="EmergencyDTO" parameterType="EmergencyVO">
+        select d.name as section,a.model,b.beginDate
+        from emergency a
+        left join emergency_info_log b on a.id = b.deviceid
+        left join lamp_pole c on a.lamp_pole_id = c.id
+        left join section d on c.sectionid = d.id
+        where  b.id is not null
+        <if test="sectionList != null">
+           and c.sectionid in
+            <foreach collection="sectionList" separator="," open="(" close=")" item="item">
+                #{item}
+            </foreach>
+        </if>
+        order by b.beginDate desc limit 20
+    </select>
+
+    <select id="getSectionOne"  resultType="EmergencyDTO">
+        select b.sectionid as sectionId
+        from emergency a
+        left join lamp_pole b on a.lamp_pole_id = b.id
+        where a.id = #{id} limit 1
+    </select>
+
+    <select id="getOneEmergency" resultType="EmergencyDTO" parameterType="HashMap">
+        select E.id
+        from emergency E
+            left join lamp_pole P on P.id = E.lamp_pole_id
+        where P.areaid = #{areaId} and P.sectionid = #{sectionId}
+        <choose>
+            <when test="number != null and model == null">
+                and E.num = #{number}
+            </when>
+            <when test="number == null and model != null">
+                and E.model = #{model}
+            </when>
+            <otherwise>
+                and E.num = #{number} and E.model = #{model}
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/EnvmonitorMapper.xml

@@ -651,4 +651,21 @@
         group by L.id
     </select>
 
+    <select id="getOneEnvmonitor" parameterType="HashMap" resultType="EnvmonitorDTO">
+        select E.id
+        from envmonitor E
+            left join lamp_pole P on P.id = E.lamp_pole_id
+        where P.areaid = #{areaId} and P.sectionid = #{sectionId}
+        <choose>
+            <when test="number != null and model == null">
+                and E.model = #{number}
+            </when>
+            <when test="number == null and model != null">
+                and E.model = #{model}
+            </when>
+            <otherwise>
+                and (E.model = #{number} or E.model = #{model})
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/GlobalLocationMapper.xml

@@ -386,4 +386,11 @@
             </foreach>
         </if>
     </select>
+
+    <select id="getTimeZoneData" parameterType="SectionDTO" resultType="GlobalLocationDTO">
+        select S.timezone
+        from global_location G
+        left join `section` S on S.pid = G.id
+        where G.id = #{pid} and S.id = #{id}
+    </select>
 </mapper>

src/main/resources/mapper/LampMapper.xml

@@ -1327,4 +1327,20 @@
 
         where id = #{id}
     </update>
+
+    <select id="getOneData" parameterType="HashMap" resultType="LampInfoDTO">
+        select id,name,address,mode
+        from lampinfo
+        where areaid = #{areaId} and sectionid = #{sectionId}
+        <if test="name != null">
+            and  name = #{name}
+        </if>
+        <if test="number != null">
+            and number = #{number}
+        </if>
+        <if test="mode != null">
+            and mode = #{mode}
+        </if>
+
+    </select>
 </mapper>

src/main/resources/mapper/ManholeMapper.xml

@@ -202,4 +202,20 @@
         where td.lamp_pole_id = #{lampPoleId}
     </select>
 
+    <select id="getOneManhole" parameterType="HashMap" resultType="ManholeDTO">
+        select id
+        from manhole
+        where areaid = #{areaId} and sectionid = #{sectionId}
+        <choose>
+            <when test="number != null and name == null">
+               and name = #{number}
+            </when>
+            <when test="number == null and name != null">
+                and name = #{name}
+            </when>
+            <otherwise>
+                and (name = #{number} or name = #{name})
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/RepairPersonnelMapper.xml

@@ -84,5 +84,26 @@
         from repair_personnel r
         where r.own_id = #{id}
     </select>
-    
+
+    <select id="getRepairPersonnelByIds" parameterType="String" resultType="com.welampiot.dto.RepairPersonnelDTO">
+        select id,name,company,section as department,phone,number as jobNumber,email
+        from repair_personnel
+        where
+        <if test="ids != null">
+            id in
+            <foreach collection="ids" item="item" open="(" separator="," close=")">
+                #{item}
+            </foreach>
+        </if>
+    </select>
+    <select id="getCountRepairPersonnel" parameterType="String" resultType="Integer">
+        select count(*) from repair_personnel
+        where
+        <if test="ids != null">
+            id in
+            <foreach collection="ids" item="item" open="(" separator="," close=")">
+                #{item}
+            </foreach>
+        </if>
+    </select>
 </mapper>

src/main/resources/mapper/RfidMapper.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.welampiot.dao.RfidDao">
+    <select id="getOneRifd" parameterType="HashMap" resultType="RfidDTO">
+        select R.id
+        from rfid R
+            left join lamp_pole P on P.id = R.lamp_pole_id
+        where P.areaid = #{areaId} and P.sectionid = #{sectionid}
+        <choose>
+            <when test="name != null and number == null">
+                and R.num = #{name}
+            </when>
+            <when test="name == null and number != null">
+                and R.num = #{number}
+            </when>
+            <otherwise>
+                and (R.num = #{name} or R.num = #{number})
+            </otherwise>
+        </choose>
+    </select>
+</mapper>

src/main/resources/mapper/ScreenMapper.xml

@@ -226,4 +226,21 @@
         </if>
     </select>
 
+    <select id="getOneScreen" parameterType="HashMap" resultType="ScreenDTO">
+        select S.id
+        from screen S
+            left join lamp_pole P on P.id = S.lamp_pole_id
+        where P.areaid = #{areaId} and P.sectionid = #{sectionId}
+        <choose>
+            <when test="number != null and model == null">
+                and S.num = #{number}
+            </when>
+            <when test="number == null and model != null">
+                and S.model = #{model}
+            </when>
+            <otherwise>
+                and S.num = #{number} and S.model = #{model}
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/SectionMapper.xml

@@ -128,11 +128,17 @@
         where g.id = #{id}
     </select>
     <select id="getDataByVO" resultType="SectionDTO">
-        select id,name,pid from section
+        select id,name,pid,alarmUser from section
         <trim prefix="where" suffixOverrides="and|or">
             <if test="id != null">
                 id = #{id}
             </if>
         </trim>
     </select>
+    <update id="updateSectionById" parameterType="SectionDTO">
+        update section s
+        set
+            alarmUser = #{alarmUser}
+        where s.id = #{id}
+    </update>
 </mapper>

src/main/resources/mapper/SendStatusMapper.xml

@@ -38,8 +38,8 @@
     </delete>
 
     <insert id="addSendStatusData" keyProperty="id" useGeneratedKeys="true" parameterType="SendStatusDTO">
-        insert into send_status(sectionId,repairUserId)
-        values (#{sectionId},#{repairUserid})
+        insert into send_status(sectionId,repairUserId,isPhone,isEmail,type)
+        values (#{sectionId},#{repairUserId},#{isPhone},#{isEmail},#{type})
     </insert>
 
     <update id="updateSendStatusData" parameterType="SendStatusDTO">
@@ -47,14 +47,33 @@
         set
             s.isPhone = #{isPhone},
             s.isEmail = #{isEmail}
-        where s.repairUserId = #{repairUserid} and s.sectionId = #{sectionId}
+        where s.repairUserId = #{repairUserId} and s.sectionId = #{sectionId}
     </update>
 
     <update id="updateCloseStatus" parameterType="SendStatusDTO">
         update send_status s
         set
             s.status = #{status}
-        where s.repairUserId = #{repairUserid} and s.sectionId = #{sectionId}
+        where s.repairUserId = #{repairUserId} and s.sectionId = #{sectionId}
     </update>
 
+    <update id="addCloseStatus"  keyProperty="id" useGeneratedKeys="true" parameterType="SendStatusDTO">
+        insert into send_status(sectionId,repairUserId,status)
+        values (#{sectionId},#{repairUserId},#{status})
+    </update>
+
+    <select id="getSectionUsers" parameterType="SendStatusDTO" resultType="SendStatusDTO">
+        select id,repairUserId,isPhone,isEmail,status
+        from send_status
+        where
+            <trim suffixOverrides="and|or">
+                <if test="sectionId != null or sectionId != 0">
+                    sectionId = #{sectionId} and
+                </if>
+                <if test="repairUserId != null">
+                    repairUserId = #{repairUserId} and
+                </if>
+            </trim>
+
+    </select>
 </mapper>

src/main/resources/mapper/VideoMonitorMapper.xml

@@ -424,4 +424,26 @@
         where v.id = #{id}
     </update>
 
+    <select id="getDataList" resultType="VideoMonitorDTO" parameterType="EmergencyDTO">
+        select id,name
+        from video_monitor
+        where lamp_pole_id != 0 and lamp_pole_id is not null and sectionid = #{sectionId}
+    </select>
+
+    <select id="getOneMonitor"  resultType="VideoMonitorDTO" parameterType="HashMap">
+        select id
+        from video_monitor
+        where areaid = #{areaId} and sectionid = #{sectionId}
+        <choose>
+            <when test="name != null and number == null">
+                and name = #{name}
+            </when>
+            <when test="name == null and number != null">
+                and name = #{number}
+            </when>
+            <otherwise>
+                and (name = #{name} or name = #{number})
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/WaterImmersionDevInfoMapper.xml

@@ -245,4 +245,22 @@
             </foreach>
         </if>
     </select>
+
+    <select id="getOneWaterImmersion" parameterType="HashMap" resultType="WaterImmersionDevInfoDTO">
+        select W.id
+        from water_immersion_dev_info W
+            left join lamp_pole P on P.id = W.lamp_pole_id
+        where P.areaid = #{areaId} and P.sectionid = #{sectionid}
+        <choose>
+            <when test="number != null and name == null">
+                and W.number = #{number}
+            </when>
+            <when test="number == null and name != null">
+                and W.name = #{name}
+            </when>
+            <otherwise>
+                and W.number = #{number} and W.name = #{name}
+            </otherwise>
+        </choose>
+    </select>
 </mapper>

src/main/resources/mapper/WifiMapper.xml

@@ -293,4 +293,23 @@
         from wifi w
         where w.lamp_pole_id = #{lampPoleId}
     </select>
+
+    <select id="getOneWifi" resultType="WifiDTO" parameterType="HashMap">
+        select W.id
+        from wifi W
+            left join lamp_pole P on P.id = W.lamp_pole_id
+        where P.areaid = #{areaId} and P.sectionid = #{sectionid}
+        <choose>
+            <when test="name != null and number == null">
+                and W.num = #{name}
+            </when>
+            <when test="name == null and number != null">
+                and W.num = #{number}
+            </when>
+            <otherwise>
+                and (W.num = #{name} or W.num = #{number})
+            </otherwise>
+        </choose>
+
+    </select>
 </mapper>

src/test/java/com/welampiot/service/UserServiceTest.java

@@ -1,11 +1,7 @@
 package com.welampiot.service;
 
 import com.welampiot.configuration.LastSqlInterceptor;
-import com.welampiot.dto.AcDevInfoDTO;
-import com.welampiot.dto.GroupDTO;
-import com.welampiot.dto.LampInfoDTO;
-import com.welampiot.dto.OperationLogDTO;
-import com.welampiot.utils.*;
+import com.welampiot.utils.ToolUtils;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -14,7 +10,6 @@ import org.springframework.test.context.junit4.SpringRunner;
 
 import javax.annotation.Resource;
 import javax.sql.DataSource;
-import java.util.*;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest
@@ -35,9 +30,6 @@ public class UserServiceTest {
 
     @Test
     public void testConnection() throws Exception {
-        String str = "供电异常,供电异常1";
-        String s = toolUtils.changeAlarm(str);
-        System.out.println("====dd:"+s);
 
         //schemaParamsterInterceptor.intercept()
 //        long l = System.currentTimeMillis() - (24L * 3600 * 30*1000);