diff --git a/src/main/java/com/zcloud/controller/alarm/AlarmDictController.java b/src/main/java/com/zcloud/controller/alarm/AlarmDictController.java new file mode 100644 index 00000000..a0181aee --- /dev/null +++ b/src/main/java/com/zcloud/controller/alarm/AlarmDictController.java @@ -0,0 +1,150 @@ +package com.zcloud.controller.alarm; + +import com.zcloud.controller.base.BaseController; +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; +import com.zcloud.service.alarm.AlarmDictService; +import com.zcloud.util.DateUtil; +import com.zcloud.util.Jurisdiction; +import com.zcloud.util.Tools; +import org.apache.shiro.authz.annotation.RequiresPermissions; +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 java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * 说明:门口门禁区域 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +@Controller +@RequestMapping("/alarmDict") +public class AlarmDictController extends BaseController { + + @Autowired + private AlarmDictService alarmDictService; + + /**新增 + * @param + * @throws Exception + */ + @RequestMapping(value="/add") + @RequiresPermissions("alarmDict:add") + @ResponseBody + public Object add() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + pd.put("CREATOR", Jurisdiction.getUSER_ID()); // 添加人 + pd.put("CREATTIME", DateUtil.date2Str(new Date())); // 添加时间 + pd.put("ISDELETE", "0"); //是否删除 + pd.put("OPERATOR", Jurisdiction.getUsername()); //修改人 + pd.put("OPERATTIME", DateUtil.date2Str(new Date()));//修改时间 + return alarmDictService.save(pd); + } + + /**删除 + * @param + * @throws Exception + */ + @RequestMapping(value="/delete") + @RequiresPermissions("alarmDict:del") + @ResponseBody + public Object delete() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + return alarmDictService.delete(pd); + } + + /**修改 + * @param + * @throws Exception + */ + @RequestMapping(value="/edit") + @RequiresPermissions("alarmDict:edit") + @ResponseBody + public Object edit() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + pd.put("OPERATOR", Jurisdiction.getUsername()); //修改人 + pd.put("OPERATTIME", DateUtil.date2Str(new Date()));//修改时间 + return alarmDictService.edit(pd); + } + + /**列表 + * @param page + * @throws Exception + */ + @RequestMapping(value="/list") + @RequiresPermissions("alarmDict:list") + @ResponseBody + public Object list(Page page) throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + PageData pd = new PageData(); + pd = this.getPageData(); + String KEYWORDS = pd.getString("KEYWORDS"); //关键词检索条件 + if(Tools.notEmpty(KEYWORDS))pd.put("KEYWORDS", KEYWORDS.trim()); + page.setPd(pd); + List varList = alarmDictService.list(page); //列出Coursectk列表 + map.put("varList", varList); + map.put("page", page); + map.put("result", errInfo); + return map; + } + + /**列表 + * @param page + * @throws Exception + */ + @RequestMapping(value="/listByType") + @RequiresPermissions("alarmDict:list") + @ResponseBody + public Object listByType(Page page) throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + PageData pd = new PageData(); + pd = this.getPageData(); + List varList = alarmDictService.listByType(pd); //列出Coursectk列表 + map.put("varList", varList); + map.put("result", errInfo); + return map; + } + + /**去修改页面获取数据 + * @param + * @throws Exception + */ + @RequestMapping(value="/goEdit") + @RequiresPermissions("alarmDict:edit") + @ResponseBody + public Object goEdit() throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + PageData pd = new PageData(); + pd = this.getPageData(); + pd = alarmDictService.findById(pd); //根据ID读取 + map.put("pd", pd); + map.put("result", errInfo); + return map; + } + + /**定位 + * @param + * @throws Exception + */ + @RequestMapping(value="/savePosition") + @ResponseBody + public Object savePosition() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + return alarmDictService.savePosition(pd); //根据ID读取 + } + +} diff --git a/src/main/java/com/zcloud/controller/alarm/AlarmInfoController.java b/src/main/java/com/zcloud/controller/alarm/AlarmInfoController.java new file mode 100644 index 00000000..beaa3cad --- /dev/null +++ b/src/main/java/com/zcloud/controller/alarm/AlarmInfoController.java @@ -0,0 +1,130 @@ +package com.zcloud.controller.alarm; + +import com.zcloud.controller.base.BaseController; +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; +import com.zcloud.service.alarm.AlarmInfoService; +import com.zcloud.util.DateUtil; +import com.zcloud.util.Jurisdiction; +import org.apache.shiro.authz.annotation.RequiresPermissions; +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 java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * 说明:门口门禁区域 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +@Controller +@RequestMapping("/alarmInfo") +public class AlarmInfoController extends BaseController { + + @Autowired + private AlarmInfoService alarmInfoService; + + /**新增 + * @param + * @throws Exception + */ + @RequestMapping(value="/add") + @RequiresPermissions("alarmInfo:add") + @ResponseBody + public Object add() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); // 添加时间 + pd.put("CREATOR", Jurisdiction.getUSER_ID()); // 添加人 + pd.put("CREATTIME", DateUtil.date2Str(new Date())); // 添加时间 + pd.put("ISDELETE", "0"); //是否删除 + pd.put("OPERATOR", Jurisdiction.getUsername()); //修改人 + pd.put("OPERATTIME", DateUtil.date2Str(new Date()));//修改时间 + return alarmInfoService.save(pd); + } + + /**删除 + * @param + * @throws Exception + */ + @RequestMapping(value="/delete") + @RequiresPermissions("mkmjDoor:del") + @ResponseBody + public Object delete() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + return alarmInfoService.delete(pd); + } + + /**修改 + * @param + * @throws Exception + */ + @RequestMapping(value="/edit") + @RequiresPermissions("mkmjDoor:edit") + @ResponseBody + public Object edit() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + pd.put("OPERATOR", Jurisdiction.getUsername()); //修改人 + pd.put("OPERATTIME", DateUtil.date2Str(new Date()));//修改时间 + return alarmInfoService.edit(pd); + } + + /**列表 + * @param page + * @throws Exception + */ + @RequestMapping(value="/list") + @RequiresPermissions("mkmjDoor:list") + @ResponseBody + public Object list(Page page) throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + PageData pd = new PageData(); + pd = this.getPageData(); + page.setPd(pd); + List varList = alarmInfoService.list(page); //列出Coursectk列表 + map.put("varList", varList); + map.put("page", page); + map.put("result", errInfo); + return map; + } + + /**去修改页面获取数据 + * @param + * @throws Exception + */ + @RequestMapping(value="/goEdit") + @RequiresPermissions("mkmjDoor:edit") + @ResponseBody + public Object goEdit() throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + PageData pd = new PageData(); + pd = this.getPageData(); + pd = alarmInfoService.findById(pd); //根据ID读取 + map.put("pd", pd); + map.put("result", errInfo); + return map; + } + + /**定位 + * @param + * @throws Exception + */ + @RequestMapping(value="/savePosition") + @ResponseBody + public Object savePosition() throws Exception{ + PageData pd = new PageData(); + pd = this.getPageData(); + return alarmInfoService.savePosition(pd); //根据ID读取 + } + +} diff --git a/src/main/java/com/zcloud/controller/firemanager/FireDeviceController.java b/src/main/java/com/zcloud/controller/firemanager/FireDeviceController.java index 8fa77095..cc36aaf0 100644 --- a/src/main/java/com/zcloud/controller/firemanager/FireDeviceController.java +++ b/src/main/java/com/zcloud/controller/firemanager/FireDeviceController.java @@ -5,6 +5,7 @@ import java.util.*; import com.alibaba.fastjson.JSON; import com.zcloud.aspect.DockAnnotation; +import com.zcloud.entity.system.Department; import com.zcloud.entity.system.Dictionaries; import com.zcloud.service.bus.ImgFilesService; import com.zcloud.service.system.DepartmentService; @@ -25,6 +26,7 @@ import com.zcloud.entity.PageData; import com.zcloud.service.firemanager.FireDeviceService; import com.zcloud.util.*; import com.zcloud.util.logAop.LogOperation; +import org.springframework.web.servlet.ModelAndView; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; @@ -79,6 +81,53 @@ public class FireDeviceController extends BaseController { return map; } + @RequestMapping(value = "/listAllForExcel") +// @ResponseBody + public ModelAndView listAllForExcel() throws Exception{ + ModelAndView mv = new ModelAndView(); + PageData pd = new PageData(); + pd = this.getPageData(); + pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID()); + Map dataMap = new HashMap(); + List titles = new ArrayList(); + titles.add("序号"); //1 + titles.add("器材类型"); //2 + titles.add("器材编号"); //3 + titles.add("消防区域名称"); //4 + titles.add("消防点位名称"); //5 + titles.add("消防区域编码"); //6 + titles.add("消防点位编码"); //7 + titles.add("有效期开始时间"); //8 + titles.add("有效期结束时间"); //9 + titles.add("存放地点"); //10 + titles.add("负责部门"); //11 + titles.add("点位负责人"); //12 + dataMap.put("titles", titles); + List varOList = fireDeviceService.listAllForExcel(pd); + List varList = new ArrayList(); + for(int i=0;i map = new HashMap(); + String errInfo = "success"; + PageData pd = new PageData(); + pd = this.getPageData(); + List varList = mkmjDockDeviceService.listAll(pd); //列出Coursectk列表 + map.put("varList", varList); + map.put("result", errInfo); + return map; + } + /**去修改页面获取数据 * @param * @throws Exception diff --git a/src/main/java/com/zcloud/controller/mkmj/MkmjPathController.java b/src/main/java/com/zcloud/controller/mkmj/MkmjPathController.java index 053b98ad..64c467f1 100644 --- a/src/main/java/com/zcloud/controller/mkmj/MkmjPathController.java +++ b/src/main/java/com/zcloud/controller/mkmj/MkmjPathController.java @@ -13,10 +13,7 @@ import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; -import java.util.Date; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; /** * 说明:门口门禁区域 @@ -113,7 +110,12 @@ public class MkmjPathController extends BaseController { PageData pd = new PageData(); pd = this.getPageData(); page.setPd(pd); - List varList = mkmjPathService.getCarAndPeopleInfolistPage(page); //列出Coursectk列表 + List varList = new ArrayList<>(); + if (!Tools.isEmpty(pd.get("DOOR_TYPE")) && pd.get("DOOR_TYPE").equals("0")) { + varList = mkmjPathService.getPeopleInfolistPage(page); //列出人闸机信息列表 + }else { + varList = mkmjPathService.getCarInfolistPage(page); //列出车闸机信息列表 + } map.put("varList", varList); map.put("page", page); map.put("result", errInfo); diff --git a/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmDictMapper.java b/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmDictMapper.java new file mode 100644 index 00000000..1d2e4311 --- /dev/null +++ b/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmDictMapper.java @@ -0,0 +1,73 @@ +package com.zcloud.mapper.datasource.alarm; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +public interface AlarmDictMapper { + + /**新增 + * @param pd + * @throws Exception + */ + void save(PageData pd); + + /**删除 + * @param pd + * @throws Exception + */ + void delete(PageData pd); + + /**修改 + * @param pd + * @throws Exception + */ + void edit(PageData pd); + + /**列表 + * @param page + * @throws Exception + */ + List datalistPage(Page page); + + List listByType(PageData pd); + + /**列表(全部) + * @param pd + * @throws Exception + */ + List listAll(PageData pd); + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + PageData findById(PageData pd); + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + void deleteAll(String[] ArrayDATA_IDS); + + /**. + * 校验名称是否重复 修改时传入数据id + * @param pageData + * @return + */ + PageData findByOnly(PageData pageData); + + /** + * 定位 + * @param pd + */ + void savePosition(PageData pd); +} + diff --git a/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmInfoMapper.java b/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmInfoMapper.java new file mode 100644 index 00000000..635f1a11 --- /dev/null +++ b/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmInfoMapper.java @@ -0,0 +1,68 @@ +package com.zcloud.mapper.datasource.alarm; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +public interface AlarmInfoMapper { + + /**新增 + * @param pd + * @throws Exception + */ + void save(PageData pd); + + /**删除 + * @param pd + * @throws Exception + */ + void delete(PageData pd); + + /**修改 + * @param pd + * @throws Exception + */ + void edit(PageData pd); + + /**列表 + * @param page + * @throws Exception + */ + List datalistPage(Page page); + + /**列表(全部) + * @param pd + * @throws Exception + */ + List listAll(PageData pd); + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + PageData findById(PageData pd); + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + void deleteAll(String[] ArrayDATA_IDS); + + /** + * 定位 + * @param pd + */ + void savePosition(PageData pd); + + void saveAll(PageData pd); + + List findThreshold(PageData pd); +} + diff --git a/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmMapper.java b/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmMapper.java new file mode 100644 index 00000000..00a5f89d --- /dev/null +++ b/src/main/java/com/zcloud/mapper/datasource/alarm/AlarmMapper.java @@ -0,0 +1,71 @@ +package com.zcloud.mapper.datasource.alarm; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +public interface AlarmMapper { + + /**新增 + * @param pd + * @throws Exception + */ + void save(PageData pd); + + /**删除 + * @param pd + * @throws Exception + */ + void delete(PageData pd); + + /**修改 + * @param pd + * @throws Exception + */ + void edit(PageData pd); + + /**列表 + * @param page + * @throws Exception + */ + List datalistPage(Page page); + + /**列表(全部) + * @param pd + * @throws Exception + */ + List listAll(PageData pd); + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + PageData findById(PageData pd); + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + void deleteAll(String[] ArrayDATA_IDS); + + /**. + * 校验名称是否重复 修改时传入数据id + * @param pageData + * @return + */ + PageData findByOnly(PageData pageData); + + /** + * 定位 + * @param pd + */ + void savePosition(PageData pd); +} + diff --git a/src/main/java/com/zcloud/mapper/datasource/firemanager/FireDeviceMapper.java b/src/main/java/com/zcloud/mapper/datasource/firemanager/FireDeviceMapper.java index 2ff6a166..5d143111 100644 --- a/src/main/java/com/zcloud/mapper/datasource/firemanager/FireDeviceMapper.java +++ b/src/main/java/com/zcloud/mapper/datasource/firemanager/FireDeviceMapper.java @@ -21,6 +21,8 @@ public interface FireDeviceMapper { */ public List datalistPage(Page page); + public List listAllForExcel(PageData pd); + /** * @Description: 列表查询给点位扫码h5页面 * @Author: dearLin diff --git a/src/main/java/com/zcloud/mapper/datasource/mkmj/MkmjPathMapper.java b/src/main/java/com/zcloud/mapper/datasource/mkmj/MkmjPathMapper.java index 6e33c3e6..e307868c 100644 --- a/src/main/java/com/zcloud/mapper/datasource/mkmj/MkmjPathMapper.java +++ b/src/main/java/com/zcloud/mapper/datasource/mkmj/MkmjPathMapper.java @@ -43,7 +43,9 @@ public interface MkmjPathMapper { */ List listAll(PageData pd); - List getCarAndPeopleInfolistPage(Page page); + List getPeopleInfolistPage(Page page); + + List getCarInfolistPage(Page page); /**通过id获取数据 * @param pd diff --git a/src/main/java/com/zcloud/service/alarm/AlarmDictService.java b/src/main/java/com/zcloud/service/alarm/AlarmDictService.java new file mode 100644 index 00000000..c0ae352f --- /dev/null +++ b/src/main/java/com/zcloud/service/alarm/AlarmDictService.java @@ -0,0 +1,67 @@ +package com.zcloud.service.alarm; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +public interface AlarmDictService { + + /**新增 + * @param pd + * @throws Exception + */ + public Object save(PageData pd)throws Exception; + + /**删除 + * @param pd + * @throws Exception + */ + public Object delete(PageData pd)throws Exception; + + /**修改 + * @param pd + * @throws Exception + */ + public Object edit(PageData pd)throws Exception; + + /**列表 + * @param page + * @throws Exception + */ + public List list(Page page)throws Exception; + + public List listByType(PageData pd)throws Exception; + + /**列表(全部) + * @param pd + * @throws Exception + */ + public List listAll(PageData pd)throws Exception; + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + public PageData findById(PageData pd)throws Exception; + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + public Object deleteAll(String[] ArrayDATA_IDS)throws Exception; + + /** + * 定位 + * @param pd + * @return + */ + Object savePosition(PageData pd); +} + diff --git a/src/main/java/com/zcloud/service/alarm/AlarmInfoService.java b/src/main/java/com/zcloud/service/alarm/AlarmInfoService.java new file mode 100644 index 00000000..ee6b4863 --- /dev/null +++ b/src/main/java/com/zcloud/service/alarm/AlarmInfoService.java @@ -0,0 +1,69 @@ +package com.zcloud.service.alarm; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +public interface AlarmInfoService { + + /**新增 + * @param pd + * @throws Exception + */ + public Object save(PageData pd)throws Exception; + + /**删除 + * @param pd + * @throws Exception + */ + public Object delete(PageData pd)throws Exception; + + /**修改 + * @param pd + * @throws Exception + */ + public Object edit(PageData pd)throws Exception; + + /**列表 + * @param page + * @throws Exception + */ + public List list(Page page)throws Exception; + + /**列表(全部) + * @param pd + * @throws Exception + */ + public List listAll(PageData pd)throws Exception; + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + public PageData findById(PageData pd)throws Exception; + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + public Object deleteAll(String[] ArrayDATA_IDS)throws Exception; + + /** + * 定位 + * @param pd + * @return + */ + Object savePosition(PageData pd); + + void saveAll(PageData pd); + + List findThreshold(PageData pd); +} + diff --git a/src/main/java/com/zcloud/service/alarm/AlarmService.java b/src/main/java/com/zcloud/service/alarm/AlarmService.java new file mode 100644 index 00000000..93eb9867 --- /dev/null +++ b/src/main/java/com/zcloud/service/alarm/AlarmService.java @@ -0,0 +1,65 @@ +package com.zcloud.service.alarm; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +public interface AlarmService { + + /**新增 + * @param pd + * @throws Exception + */ + public Object save(PageData pd)throws Exception; + + /**删除 + * @param pd + * @throws Exception + */ + public Object delete(PageData pd)throws Exception; + + /**修改 + * @param pd + * @throws Exception + */ + public Object edit(PageData pd)throws Exception; + + /**列表 + * @param page + * @throws Exception + */ + public List list(Page page)throws Exception; + + /**列表(全部) + * @param pd + * @throws Exception + */ + public List listAll(PageData pd)throws Exception; + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + public PageData findById(PageData pd)throws Exception; + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + public Object deleteAll(String[] ArrayDATA_IDS)throws Exception; + + /** + * 定位 + * @param pd + * @return + */ + Object savePosition(PageData pd); +} + diff --git a/src/main/java/com/zcloud/service/alarm/impl/AlarmDictServiceImpl.java b/src/main/java/com/zcloud/service/alarm/impl/AlarmDictServiceImpl.java new file mode 100644 index 00000000..f1c34b9c --- /dev/null +++ b/src/main/java/com/zcloud/service/alarm/impl/AlarmDictServiceImpl.java @@ -0,0 +1,125 @@ +package com.zcloud.service.alarm.impl; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; +import com.zcloud.mapper.datasource.alarm.AlarmDictMapper; +import com.zcloud.service.alarm.AlarmDictService; +import com.zcloud.util.UuidUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +@Service +@Transactional //开启事物 +public class AlarmDictServiceImpl implements AlarmDictService { + + @Autowired + private AlarmDictMapper alarmDictMapper; + + /**新增 + * @param pd + * @throws Exception + */ + public Object save(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + pd.put("ALARM_DICT_ID", UuidUtil.get32UUID()); + alarmDictMapper.save(pd); + map.put("result", errInfo); + map.put("msg", "保存成功"); + return map; + } + + /**删除 + * @param pd + * @throws Exception + */ + public Object delete(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmDictMapper.delete(pd); + map.put("result", errInfo); + map.put("msg", "删除成功"); + return map; + } + + /**修改 + * @param pd + * @throws Exception + */ + public Object edit(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmDictMapper.edit(pd); + map.put("result", errInfo); + map.put("msg", "编辑成功"); + return map; + } + + /**列表 + * @param page + * @throws Exception + */ + public List list(Page page)throws Exception{ + return alarmDictMapper.datalistPage(page); + } + + /**列表 + * @param page + * @throws Exception + */ + public List listByType(PageData pd)throws Exception{ + return alarmDictMapper.listByType(pd); + } + + /**列表(全部) + * @param pd + * @throws Exception + */ + public List listAll(PageData pd)throws Exception{ + return alarmDictMapper.listAll(pd); + } + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + public PageData findById(PageData pd)throws Exception{ + return alarmDictMapper.findById(pd); + } + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + public Object deleteAll(String[] ArrayDATA_IDS)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmDictMapper.deleteAll(ArrayDATA_IDS); + map.put("result", errInfo); + map.put("msg", "删除成功"); + return map; + } + + @Override + public Object savePosition(PageData pd) { + Map map = new HashMap(); + String errInfo = "success"; + alarmDictMapper.savePosition(pd); + map.put("result", errInfo); + map.put("msg", "定位成功"); + return map; + } + +} + diff --git a/src/main/java/com/zcloud/service/alarm/impl/AlarmInfoServiceImpl.java b/src/main/java/com/zcloud/service/alarm/impl/AlarmInfoServiceImpl.java new file mode 100644 index 00000000..d22a86b0 --- /dev/null +++ b/src/main/java/com/zcloud/service/alarm/impl/AlarmInfoServiceImpl.java @@ -0,0 +1,128 @@ +package com.zcloud.service.alarm.impl; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; +import com.zcloud.mapper.datasource.alarm.AlarmInfoMapper; +import com.zcloud.service.alarm.AlarmInfoService; +import com.zcloud.util.UuidUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +@Service +@Transactional //开启事物 +public class AlarmInfoServiceImpl implements AlarmInfoService { + + @Autowired + private AlarmInfoMapper alarmInfoMapper; + + /**新增 + * @param pd + * @throws Exception + */ + public Object save(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + pd.put("ALARM_INFO_ID", UuidUtil.get32UUID()); + alarmInfoMapper.save(pd); + map.put("result", errInfo); + map.put("msg", "保存成功"); + return map; + } + + /**删除 + * @param pd + * @throws Exception + */ + public Object delete(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.delete(pd); + map.put("result", errInfo); + map.put("msg", "删除成功"); + return map; + } + + /**修改 + * @param pd + * @throws Exception + */ + public Object edit(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.edit(pd); + map.put("result", errInfo); + map.put("msg", "编辑成功"); + return map; + } + + /**列表 + * @param page + * @throws Exception + */ + public List list(Page page)throws Exception{ + return alarmInfoMapper.datalistPage(page); + } + + /**列表(全部) + * @param pd + * @throws Exception + */ + public List listAll(PageData pd)throws Exception{ + return alarmInfoMapper.listAll(pd); + } + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + public PageData findById(PageData pd)throws Exception{ + return alarmInfoMapper.findById(pd); + } + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + public Object deleteAll(String[] ArrayDATA_IDS)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.deleteAll(ArrayDATA_IDS); + map.put("result", errInfo); + map.put("msg", "删除成功"); + return map; + } + + @Override + public Object savePosition(PageData pd) { + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.savePosition(pd); + map.put("result", errInfo); + map.put("msg", "定位成功"); + return map; + } + + @Override + public List findThreshold(PageData pd) { + List threshold = alarmInfoMapper.findThreshold(pd); + return threshold; + } + + @Override + public void saveAll(PageData pd) { + alarmInfoMapper.saveAll(pd); + } + +} + diff --git a/src/main/java/com/zcloud/service/alarm/impl/AlarmServiceImpl.java b/src/main/java/com/zcloud/service/alarm/impl/AlarmServiceImpl.java new file mode 100644 index 00000000..3320f010 --- /dev/null +++ b/src/main/java/com/zcloud/service/alarm/impl/AlarmServiceImpl.java @@ -0,0 +1,117 @@ +package com.zcloud.service.alarm.impl; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; +import com.zcloud.mapper.datasource.alarm.AlarmMapper; +import com.zcloud.service.alarm.AlarmService; +import com.zcloud.util.UuidUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * 说明:门口门禁区域闸机 + * 作者:zhaoyu + * 时间:2024-01-16 + * 官网:www.zcloudchina.com + */ +@Service +@Transactional //开启事物 +public class AlarmServiceImpl implements AlarmService { + + @Autowired + private AlarmMapper alarmInfoMapper; + + /**新增 + * @param pd + * @throws Exception + */ + public Object save(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + pd.put("ALARM_ID", UuidUtil.get32UUID()); + alarmInfoMapper.save(pd); + map.put("result", errInfo); + map.put("msg", "保存成功"); + return map; + } + + /**删除 + * @param pd + * @throws Exception + */ + public Object delete(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.delete(pd); + map.put("result", errInfo); + map.put("msg", "删除成功"); + return map; + } + + /**修改 + * @param pd + * @throws Exception + */ + public Object edit(PageData pd)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.edit(pd); + map.put("result", errInfo); + map.put("msg", "编辑成功"); + return map; + } + + /**列表 + * @param page + * @throws Exception + */ + public List list(Page page)throws Exception{ + return alarmInfoMapper.datalistPage(page); + } + + /**列表(全部) + * @param pd + * @throws Exception + */ + public List listAll(PageData pd)throws Exception{ + return alarmInfoMapper.listAll(pd); + } + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + public PageData findById(PageData pd)throws Exception{ + return alarmInfoMapper.findById(pd); + } + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + public Object deleteAll(String[] ArrayDATA_IDS)throws Exception{ + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.deleteAll(ArrayDATA_IDS); + map.put("result", errInfo); + map.put("msg", "删除成功"); + return map; + } + + @Override + public Object savePosition(PageData pd) { + Map map = new HashMap(); + String errInfo = "success"; + alarmInfoMapper.savePosition(pd); + map.put("result", errInfo); + map.put("msg", "定位成功"); + return map; + } + +} + diff --git a/src/main/java/com/zcloud/service/firemanager/FireDeviceService.java b/src/main/java/com/zcloud/service/firemanager/FireDeviceService.java index ae0e4b44..e27b86fe 100644 --- a/src/main/java/com/zcloud/service/firemanager/FireDeviceService.java +++ b/src/main/java/com/zcloud/service/firemanager/FireDeviceService.java @@ -13,6 +13,8 @@ import com.zcloud.entity.PageData; public interface FireDeviceService { List list(Page page); + List listAllForExcel(PageData pd); + PageData findById(PageData pd); void updFireDeviceById(PageData pd); diff --git a/src/main/java/com/zcloud/service/firemanager/impl/FireDeviceServiceImpl.java b/src/main/java/com/zcloud/service/firemanager/impl/FireDeviceServiceImpl.java index 4717e555..d33037a9 100644 --- a/src/main/java/com/zcloud/service/firemanager/impl/FireDeviceServiceImpl.java +++ b/src/main/java/com/zcloud/service/firemanager/impl/FireDeviceServiceImpl.java @@ -51,6 +51,11 @@ public class FireDeviceServiceImpl implements FireDeviceService { return fireDeviceMapper.datalistPage(page); } + @Override + public List listAllForExcel(PageData pd) { + return fireDeviceMapper.listAllForExcel(pd); + } + @Override public PageData findById(PageData pd) { return fireDeviceMapper.findById(pd); diff --git a/src/main/java/com/zcloud/service/mkmj/MkmjPathService.java b/src/main/java/com/zcloud/service/mkmj/MkmjPathService.java index 33cb632f..7c722dab 100644 --- a/src/main/java/com/zcloud/service/mkmj/MkmjPathService.java +++ b/src/main/java/com/zcloud/service/mkmj/MkmjPathService.java @@ -43,7 +43,9 @@ public interface MkmjPathService { */ public List listAll(PageData pd)throws Exception; - public List getCarAndPeopleInfolistPage(Page page)throws Exception; + public List getPeopleInfolistPage(Page page)throws Exception; + + public List getCarInfolistPage(Page page)throws Exception; /**通过id获取数据 * @param pd diff --git a/src/main/java/com/zcloud/service/mkmj/impl/MkmjPathServiceImpl.java b/src/main/java/com/zcloud/service/mkmj/impl/MkmjPathServiceImpl.java index 0e608f66..b594bf8b 100644 --- a/src/main/java/com/zcloud/service/mkmj/impl/MkmjPathServiceImpl.java +++ b/src/main/java/com/zcloud/service/mkmj/impl/MkmjPathServiceImpl.java @@ -103,8 +103,16 @@ public class MkmjPathServiceImpl implements MkmjPathService { * @param pd * @throws Exception */ - public List getCarAndPeopleInfolistPage(Page page)throws Exception{ - return mkmjPathMapper.getCarAndPeopleInfolistPage(page); + public List getPeopleInfolistPage(Page page)throws Exception{ + return mkmjPathMapper.getPeopleInfolistPage(page); + } + + /**列表(全部) + * @param pd + * @throws Exception + */ + public List getCarInfolistPage(Page page)throws Exception{ + return mkmjPathMapper.getCarInfolistPage(page); } /**通过id获取数据 diff --git a/src/main/java/com/zcloud/util/AnemometerScheduled.java b/src/main/java/com/zcloud/util/AnemometerScheduled.java deleted file mode 100644 index f4c405ee..00000000 --- a/src/main/java/com/zcloud/util/AnemometerScheduled.java +++ /dev/null @@ -1,138 +0,0 @@ -package com.zcloud.util; - -import com.zcloud.entity.PageData; -import com.zcloud.service.announcement.AnemometerService; -import com.zcloud.service.bus.SysDateService; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Component; - -/** - * 风速仪定时器 - */ -@Component -public class AnemometerScheduled { - @Autowired - private AnemometerService anemometerService; - - - //@Scheduled(cron ="0 5 0 * * ?")//每天12点05 - @Scheduled(cron ="0 30 0 * * ?")//每天12点30 - - //@Scheduled(cron ="*/20 * * * * ?")//测试 - public void scheduled(){ - try { - System.out.println("============同步风速仪=========="); - PageData pd = new PageData(); - pd.put("SYSDATE_ID", this.get32UUID()); //主键 - pd.put("DATE", DateUtil.getDay()); - pd.put("DAY_START", DateUtil.getDay()+" 00:00:00"); - pd.put("DAY_END", DateUtil.getDay()+" 23:59:59"); - pd.put("WEEK_START", DateUtil.getWeekStart()); - pd.put("WEEK_END", DateUtil.getWeekEnd()); - String year = DateUtil.getYear().toString(); - String month = DateUtil.getMonth().toString(); - Integer day = Integer.parseInt(DateUtil.getOnlyDay().toString()); - String xunStartTime = year + "-" + month + "-"; - String xunEndTime = year + "-" + month + "-"; - if(day <= 10) { - xunStartTime = xunStartTime+"01 00:00:00"; - xunEndTime = xunEndTime+"10 23:59:59"; - } else if(day > 10 && day <= 20) { - xunStartTime = xunStartTime+"11 00:00:00"; - xunEndTime = xunEndTime+"20 23:59:59"; - } else { - xunStartTime = xunStartTime+"21 00:00:00"; - xunEndTime = DateUtil.getMonthEndDay()+" 23:59:59"; - } - pd.put("XUN_START", xunStartTime); - pd.put("XUN_END", xunEndTime); - pd.put("MONTH_START", DateUtil.getMonthFirstDay()+" 00:00:00"); - pd.put("MONTH_END", DateUtil.getMonthEndDay()+" 23:59:59"); - pd.put("QUARTER_START", DateUtil.quarterStart()+" 00:00:00"); - pd.put("QUARTER_END", DateUtil.quarterEnd()+" 23:59:59"); - String HalfYearStartTime = DateUtil.getYear().toString(); - String HalfYearEndTime = DateUtil.getYear().toString(); - Integer bmonth = Integer.parseInt(DateUtil.getMonth().toString()); - - if(bmonth <= 6) { - HalfYearStartTime = HalfYearStartTime+"-01-01 00:00:00"; - HalfYearEndTime = HalfYearEndTime+"-06-30 23:59:59"; - } else if(bmonth > 6) { - HalfYearStartTime = HalfYearStartTime+"-07-01 00:00:00"; - HalfYearEndTime = HalfYearEndTime+"-12-31 23:59:59"; - } - pd.put("HALFYEAR_START", HalfYearStartTime); - pd.put("HALFYEAR_END", HalfYearEndTime); - pd.put("YEAR_START", DateUtil.getCurrYearFirst()+" 00:00:00"); - pd.put("YEAR_END", DateUtil.getCurrYearLast()+" 23:59:59"); -// sysdateService.save(pd); - } catch (Exception e) { - e.printStackTrace(); - } - } - - /** - * 数据初始化:bus_sysdate表时使用 - */ - /* public void scheduled(){ - try { - System.out.println("============定时增加日期=========="); - for(int i=0;i < 730;i++) { - PageData pd = new PageData(); - pd.put("SYSDATE_ID", this.get32UUID()); //主键 - pd.put("DATE", DateSysUtil.getDay(i)); - pd.put("DAY_START", DateSysUtil.getDay(i)+" 00:00:00"); - pd.put("DAY_END", DateSysUtil.getDay(i)+" 23:59:59"); - pd.put("WEEK_START", DateSysUtil.getWeekStart(i)); - pd.put("WEEK_END", DateSysUtil.getWeekEnd(i)); - String year = DateSysUtil.getYear(i).toString(); - String month = DateSysUtil.getMonth(i).toString(); - Integer day = Integer.parseInt(DateSysUtil.getOnlyDay(i).toString()); - String xunStartTime = year + "-" + month + "-"; - String xunEndTime = year + "-" + month + "-"; - if(day <= 10) { - xunStartTime = xunStartTime+"01 00:00:00"; - xunEndTime = xunEndTime+"10 23:59:59"; - } else if(day > 10 && day <= 20) { - xunStartTime = xunStartTime+"11 00:00:00"; - xunEndTime = xunEndTime+"20 23:59:59"; - } else { - xunStartTime = xunStartTime+"21 00:00:00"; - xunEndTime = DateSysUtil.getMonthEndDay(i)+" 23:59:59"; - } - pd.put("XUN_START", xunStartTime); - pd.put("XUN_END", xunEndTime); - pd.put("MONTH_START", DateSysUtil.getMonthFirstDay(i)+" 00:00:00"); - pd.put("MONTH_END", DateSysUtil.getMonthEndDay(i)+" 23:59:59"); - pd.put("QUARTER_START", DateSysUtil.quarterStart(i)+" 00:00:00"); - pd.put("QUARTER_END", DateSysUtil.quarterEnd(i)+" 23:59:59"); - String HalfYearStartTime = DateSysUtil.getYear(i).toString(); - String HalfYearEndTime = DateSysUtil.getYear(i).toString(); - Integer bmonth = Integer.parseInt(DateSysUtil.getMonth(i).toString()); - - if(bmonth <= 6) { - HalfYearStartTime = HalfYearStartTime+"-01-01 00:00:00"; - HalfYearEndTime = HalfYearEndTime+"-06-30 23:59:59"; - } else if(bmonth > 6) { - HalfYearStartTime = HalfYearStartTime+"-07-01 00:00:00"; - HalfYearEndTime = HalfYearEndTime+"-12-31 23:59:59"; - } - pd.put("HALFYEAR_START", HalfYearStartTime); - pd.put("HALFYEAR_END", HalfYearEndTime); - pd.put("YEAR_START", DateSysUtil.getCurrYearFirst(i)+" 00:00:00"); - pd.put("YEAR_END", DateSysUtil.getCurrYearLast(i)+" 23:59:59"); - sysdateService.save(pd); - } - - } catch (Exception e) { - e.printStackTrace(); - } - }*/ - /**得到32位的uuid - * @return - */ - public String get32UUID(){ - return UuidUtil.get32UUID(); - } -} diff --git a/src/main/java/com/zcloud/util/SaveAnemometerInfoScheduled.java b/src/main/java/com/zcloud/util/SaveAnemometerInfoScheduled.java index 00372972..1d793ae2 100644 --- a/src/main/java/com/zcloud/util/SaveAnemometerInfoScheduled.java +++ b/src/main/java/com/zcloud/util/SaveAnemometerInfoScheduled.java @@ -1,6 +1,7 @@ package com.zcloud.util; import com.zcloud.entity.PageData; +import com.zcloud.service.alarm.AlarmInfoService; import com.zcloud.service.announcement.AnemometerLocalService; import com.zcloud.service.announcement.AnemometerMachineService; import com.zcloud.service.announcement.AnemometerService; @@ -10,10 +11,7 @@ import org.springframework.stereotype.Component; import java.text.ParseException; import java.text.SimpleDateFormat; -import java.util.Date; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; @Component public class SaveAnemometerInfoScheduled { @@ -23,8 +21,10 @@ public class SaveAnemometerInfoScheduled { private AnemometerLocalService anemometerLocalService; @Autowired private AnemometerMachineService anemometerMachineService; + @Autowired + private AlarmInfoService alarmInfoService; -// @Scheduled(cron ="*/5 * * * * ? ") + @Scheduled(cron ="*/15 * * * * ? ") public void scheduled() throws Exception{ saveAnemometerInfo(); } @@ -61,6 +61,44 @@ public class SaveAnemometerInfoScheduled { } } }); + List alarmList = new ArrayList<>(); + //查询风速仪报警阈值 + PageData tPd = new PageData(); + tPd.put("DICT_NAME","风速仪"); + List levelList = alarmInfoService.findThreshold(tPd); + for (PageData codeData : anemometerList) { + //若风速大于阈值则存储报警信息 + for (PageData data : levelList) { + if (Double.parseDouble(codeData.getString("FVALUE")) > Double.parseDouble(data.getString("LEVELVALUE"))) { + PageData alarmPd = new PageData(); + alarmPd.put("ALARM_INFO_ID",UuidUtil.get32UUID()); + alarmPd.put("ALARM_VALUE",codeData.getString("FVALUE")); + alarmPd.put("ALARM_TIME",DateUtil.date2Str(new Date())); + alarmPd.put("LEVEL",data.getString("LEVELNAME")); + alarmPd.put("CREATOR","c5187fb9565649a89267f9adf6b0fab6"); + alarmPd.put("CREATTIME",DateUtil.date2Str(new Date())); + alarmPd.put("OPERATOR","c5187fb9565649a89267f9adf6b0fab6"); + alarmPd.put("OPERATTIME",DateUtil.date2Str(new Date())); + alarmPd.put("ISDELETE","0"); + alarmPd.put("LOG",data.getString("LOG")); + if (anemometerMachineMap.containsKey(codeData.getString("FNAME"))) { + for (PageData machinePd : anemometerMachineList) { + if (machinePd.getString("FNAME").equals(codeData.getString("FNAME"))) { + alarmPd.put("ANEMOMETER_ID",machinePd.getString("FID")); + } + } + } + alarmList.add(alarmPd); + break; + } + } + } + if (alarmList.size() > 0) { + PageData alarmSavePd = new PageData(); + alarmSavePd.put("list",alarmList); + alarmInfoService.saveAll(alarmSavePd); + } + System.out.println(anemometerList); //保存获取的风速数据到本地 anemometerLocalService.BatchinsertInfo(anemometerList); } diff --git a/src/main/resources/mybatis/datasource/alarm/AlarmDictMapper.xml b/src/main/resources/mybatis/datasource/alarm/AlarmDictMapper.xml new file mode 100644 index 00000000..7bf7dde0 --- /dev/null +++ b/src/main/resources/mybatis/datasource/alarm/AlarmDictMapper.xml @@ -0,0 +1,183 @@ + + + + + + + BUS_ALARM_DICT + + + + + f.ALARM_DICT_ID, + f.PARENT_ID, + f.DICT_NAME, + f.DICT_TYPE, + f.CONTENT, + f.DICT_VALUE, + f.CREATOR, + f.CREATTIME, + f.OPERATOR, + f.OPERATTIME, + f.ISDELETE + + + + + ALARM_DICT_ID, + PARENT_ID, + DICT_NAME, + DICT_TYPE, + CONTENT, + DICT_VALUE, + CREATOR, + CREATTIME, + OPERATOR, + OPERATTIME, + ISDELETE + + + + + #{ALARM_DICT_ID}, + #{PARENT_ID}, + #{DICT_NAME}, + #{DICT_TYPE}, + #{CONTENT}, + #{DICT_VALUE}, + #{CREATOR}, + #{CREATTIME}, + #{OPERATOR}, + #{OPERATTIME}, + #{ISDELETE} + + + + + insert into + + ( + + ) values ( + + ) + + + + + update + + set + ISDELETE = '1' + where + ALARM_DICT_ID = #{ALARM_DICT_ID} + + + + + update + + set + ALARM_DICT_ID = ALARM_DICT_ID + + ,DICT_NAME = #{DICT_NAME} + + + ,PARENT_ID = #{PARENT_ID} + + + ,DICT_TYPE = #{DICT_TYPE} + + + ,CONTENT = #{CONTENT} + + + ,DICT_VALUE = #{DICT_VALUE} + + + ,CREATOR = #{CREATOR} + + + ,CREATTIME = #{CREATTIME} + + + ,OPERATOR = #{OPERATOR} + + + ,OPERATTIME = #{OPERATTIME} + + + ,ISDELETE = #{ISDELETE} + + where + ALARM_DICT_ID=#{ALARM_DICT_ID} + + + + + + + + + + + + + + + + + update + + set + ISDELETE = '1' + where + ALARM_DICT_ID in + + #{item} + + + diff --git a/src/main/resources/mybatis/datasource/alarm/AlarmInfoMapper.xml b/src/main/resources/mybatis/datasource/alarm/AlarmInfoMapper.xml new file mode 100644 index 00000000..c4273ec7 --- /dev/null +++ b/src/main/resources/mybatis/datasource/alarm/AlarmInfoMapper.xml @@ -0,0 +1,205 @@ + + + + + + + BUS_ALARM_INFO + + + + + f.ALARM_INFO_ID, + f.ALARM_VALUE, + f.ALARM_TIME, + f.LEVEL, + f.CREATOR, + f.CREATTIME, + f.OPERATOR, + f.OPERATTIME, + f.ISDELETE, + f.LOG, + f.ANEMOMETER_ID + + + + + ALARM_INFO_ID, + ALARM_VALUE, + ALARM_TIME, + LEVEL, + CREATOR, + CREATTIME, + OPERATOR, + OPERATTIME, + ISDELETE, + LOG, + ANEMOMETER_ID + + + + + #{ALARM_INFO_ID}, + #{ALARM_VALUE}, + #{ALARM_TIME}, + #{LEVEL}, + #{CREATOR}, + #{CREATTIME}, + #{OPERATOR}, + #{OPERATTIME}, + #{ISDELETE}, + #{LOG}, + #{ANEMOMETER_ID} + + + + + insert into + + ( + + ) values ( + + ) + + + + + update + + set + ISDELETE = '1' + where + ALARM_INFO_ID = #{ALARM_INFO_ID} + + + + + update + + set + ALARM_INFO_ID = ALARM_INFO_ID + + ,ALARM_VALUE = #{ALARM_VALUE} + + + ,ALARM_TIME = #{ALARM_TIME} + + + ,LEVEL = #{LEVEL} + + + ,CREATOR = #{CREATOR} + + + ,CREATTIME = #{CREATTIME} + + + ,OPERATOR = #{OPERATOR} + + + ,ISDELETE = #{ISDELETE} + + where + ALARM_INFO_ID=#{ALARM_INFO_ID} + + + + + + + + + + + + + + update + + set + ISDELETE = '1' + where + ALARM_INFO_ID in + + #{item} + + + + + + insert into + + ( + ALARM_INFO_ID, + ALARM_VALUE, + ALARM_TIME, + LEVEL, + CREATOR, + CREATTIME, + OPERATOR, + OPERATTIME, + ISDELETE, + LOG, + ANEMOMETER_ID + ) + values + + ( + #{item.ALARM_INFO_ID}, + #{item.ALARM_VALUE}, + #{item.ALARM_TIME}, + #{item.LEVEL}, + #{item.CREATOR}, + #{item.CREATTIME}, + #{item.OPERATOR}, + #{item.OPERATTIME}, + #{item.ISDELETE}, + #{item.LOG}, + #{item.ANEMOMETER_ID} + ) + + + + + + diff --git a/src/main/resources/mybatis/datasource/alarm/AlarmMapper.xml b/src/main/resources/mybatis/datasource/alarm/AlarmMapper.xml new file mode 100644 index 00000000..eec72626 --- /dev/null +++ b/src/main/resources/mybatis/datasource/alarm/AlarmMapper.xml @@ -0,0 +1,149 @@ + + + + + + + BUS_ALARM + + + + + f.ALARM_ID, + f.ALARM_NAME, + f.ALARM_TYPE, + f.ALARM_LEVELS, + f.CREATOR, + f.CREATTIME, + f.OPERATOR, + f.OPERATTIME, + f.ISDELETE + + + + + ALARM_ID, + ALARM_NAME, + ALARM_TYPE, + ALARM_LEVELS, + CREATOR, + CREATTIME, + OPERATOR, + OPERATTIME, + ISDELETE + + + + + #{ALARM_ID}, + #{ALARM_NAME}, + #{ALARM_TYPE}, + #{ALARM_LEVELS}, + #{CREATOR}, + #{CREATTIME}, + #{OPERATOR}, + #{OPERATTIME}, + #{ISDELETE} + + + + + insert into + + ( + + ) values ( + + ) + + + + + update + + set + ISDELETE = '1' + where + ALARM_ID = #{ALARM_ID} + + + + + update + + set + ALARM_ID = ALARM_ID + + ,ALARM_NAME = #{ALARM_NAME} + + + ,ALARM_TYPE = #{ALARM_TYPE} + + + ,ALARM_LEVELS = #{ALARM_LEVELS} + + + ,CREATOR = #{CREATOR} + + + ,CREATTIME = #{CREATTIME} + + + ,OPERATOR = #{OPERATOR} + + + ,ISDELETE = #{ISDELETE} + + where + ALARM_ID=#{ALARM_ID} + + + + + + + + + + + + + + update + + set + ISDELETE = '1' + where + ALARM_ID in + + #{item} + + + diff --git a/src/main/resources/mybatis/datasource/firemanager/FireDeviceMapper.xml b/src/main/resources/mybatis/datasource/firemanager/FireDeviceMapper.xml index 4d6bfc1d..9de846c0 100644 --- a/src/main/resources/mybatis/datasource/firemanager/FireDeviceMapper.xml +++ b/src/main/resources/mybatis/datasource/firemanager/FireDeviceMapper.xml @@ -131,6 +131,57 @@ DESC + + diff --git a/src/main/resources/mybatis/datasource/mkmj/MkmjPathMapper.xml b/src/main/resources/mybatis/datasource/mkmj/MkmjPathMapper.xml index a4167599..7d5c5227 100644 --- a/src/main/resources/mybatis/datasource/mkmj/MkmjPathMapper.xml +++ b/src/main/resources/mybatis/datasource/mkmj/MkmjPathMapper.xml @@ -144,48 +144,64 @@ - - SELECT - * + p.personName NAME, + ( CASE WHEN p.devName LIKE CONCAT( CONCAT( '%', '入' ), '%' ) THEN '进' WHEN p.devName LIKE CONCAT( CONCAT( '%', '出' ), '%' ) THEN '出' END ) STATUS, + p.eventTime TIME, + p.readerDevName BAYNAME, + p.devName DOORNAME FROM - ( - SELECT - c.carsign NAME, - c.entrystatus STATUS, - c.chtime TIME, - c.bayonetname BAYNAME, - c.accessname DOORNAME - FROM - mkmj_door f - LEFT JOIN dj_car_log c ON f.SOURCE_ID = c.accId - WHERE - f.DOOR_ID = #{pd.DOOR_ID} - - and - ( - c.carsign LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%') - ) - - UNION ALL - SELECT - p.username NAME, - p.entrystatus STATUS, - p.chtime TIME, - p.bayonetname BAYNAME, - p.accessname DOORNAME - FROM - mkmj_door f - LEFT JOIN dj_person_log p ON f.SOURCE_ID = p.accId - WHERE - f.DOOR_ID = #{pd.DOOR_ID} - - and - ( - p.username LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%') - ) - - ) info where NAME IS NOT NULL + mkmj_door f + LEFT JOIN ( + SELECT + GROUP_CONCAT( d.DEVICE_NAME SEPARATOR ',' ) devNames, + f.DOOR_ID + FROM + mkmj_device f + LEFT JOIN mkmj_dock_device d ON f.DOCK_DEVICE_ID = d.DOCK_DEVICE_ID + WHERE + f.ISDELETE = '0' + GROUP BY + f.DOOR_ID) d ON d.DOOR_ID = f.DOOR_ID + LEFT JOIN mk_gate_person_machine_info p ON FIND_IN_SET(p.devName,d.devNames) + WHERE p.ISDELETE = '0' AND f.DOOR_ID = #{pd.DOOR_ID} + GROUP BY p.MACHINE_INFO_ID + ORDER BY p.eventTime + + + +