From fc4ff1d833d32e159f8f0224fc1f71eec07c51eb Mon Sep 17 00:00:00 2001 From: blankk <2649084208@qq.com> Date: Tue, 20 Sep 2022 13:37:57 +0800 Subject: [PATCH] =?UTF-8?q?=E9=A2=84=E8=AD=A6=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../warning/controller/WaAlarmController.java | 98 ++++++++++++++++ .../controller/WaEmployeeController.java | 96 ++++++++++++++++ .../controller/WaMessageController.java | 96 ++++++++++++++++ .../controller/WaThresholdController.java | 106 ++++++++++++++++++ .../ruoyi/code/warning/domain/WaAlarm.java | 41 +++++++ .../ruoyi/code/warning/domain/WaEmpMsg.java | 36 ++++++ .../ruoyi/code/warning/domain/WaEmployee.java | 39 +++++++ .../ruoyi/code/warning/domain/WaMessage.java | 50 +++++++++ .../code/warning/domain/WaThreshold.java | 40 +++++++ .../code/warning/mapper/WaAlarmMapper.java | 17 +++ .../code/warning/mapper/WaEmpMsgMapper.java | 23 ++++ .../code/warning/mapper/WaEmployeeMapper.java | 18 +++ .../code/warning/mapper/WaMessageMapper.java | 17 +++ .../warning/mapper/WaThresholdMapper.java | 18 +++ .../code/warning/service/IWaAlarmService.java | 22 ++++ .../warning/service/IWaEmpMsgService.java | 21 ++++ .../warning/service/IWaEmployeeService.java | 24 ++++ .../warning/service/IWaMessageService.java | 35 ++++++ .../warning/service/IWaThresholdService.java | 22 ++++ .../service/impl/WaAlarmServiceImpl.java | 39 +++++++ .../service/impl/WaEmpMsgServiceImpl.java | 33 ++++++ .../service/impl/WaEmployeeServiceImpl.java | 59 ++++++++++ .../service/impl/WaMessageServiceImpl.java | 90 +++++++++++++++ .../service/impl/WaThresholdServiceImpl.java | 36 ++++++ .../mapper/warning/WaEmpMsgMapper.xml | 15 +++ .../mapper/warning/WaMessageMapper.xml | 5 + 26 files changed, 1096 insertions(+) create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaAlarmController.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaEmployeeController.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaMessageController.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaThresholdController.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmpMsg.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmployee.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaMessage.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaThreshold.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmpMsgMapper.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmployeeMapper.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaMessageMapper.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaThresholdMapper.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmpMsgService.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmployeeService.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaMessageService.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaThresholdService.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmpMsgServiceImpl.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmployeeServiceImpl.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaMessageServiceImpl.java create mode 100644 ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaThresholdServiceImpl.java create mode 100644 ruoyi-code/src/main/resources/mapper/warning/WaEmpMsgMapper.xml create mode 100644 ruoyi-code/src/main/resources/mapper/warning/WaMessageMapper.xml diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaAlarmController.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaAlarmController.java new file mode 100644 index 0000000..1fd2ced --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaAlarmController.java @@ -0,0 +1,98 @@ +package com.ruoyi.code.warning.controller; + +import com.ruoyi.code.warning.domain.WaAlarm; +import com.ruoyi.code.warning.service.IWaAlarmService; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.common.utils.poi.ExcelUtil; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletResponse; +import java.util.Arrays; +import java.util.List; +import java.util.Map; +/** + * 预警管理Controller + * + * @author ruoyi + * @date 2022-09-19 + */ +@RestController +@RequestMapping("/warning/alarm") +public class WaAlarmController extends BaseController +{ + @Resource + private IWaAlarmService waAlarmService; + + /** + * 查询列表 + */ + @PreAuthorize("@ss.hasPermi('warning:alarm:list')") + @RequestMapping("/list") + public R list(@RequestParam Map params){ + return waAlarmService.queryPage(params); + } + + /** + * 获取详细信息 + */ + @RequestMapping("/info/{id}") + @PreAuthorize("@ss.hasPermi('warning:alarm:query')") + public R info(@PathVariable("id") Long id){ + WaAlarm waAlarm = waAlarmService.getById(id); + + return R.ok().put("data", waAlarm); + } + + + /** + * 导出列表 + */ + @PreAuthorize("@ss.hasPermi('warning:alarm:export')") + @Log(title = "列表", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, WaAlarm waAlarm) + { + List list = waAlarmService.list(); + ExcelUtil util = new ExcelUtil(WaAlarm.class); + util.exportExcel(response, list, "列表数据"); + } + + /** + * 新增 + */ + @RequestMapping("/add") + @Log(title = "WaAlarm", businessType = BusinessType.INSERT) + @PreAuthorize("@ss.hasPermi('warning:alarm:add')") + public R add(@RequestBody WaAlarm waAlarm){ + waAlarmService.save(waAlarm); + return R.ok(); + } + + /** + * 修改 + */ + @RequestMapping("/edit") + @PreAuthorize("@ss.hasPermi('warning:alarm:edit')") + @Log(title = "WaAlarm", businessType = BusinessType.UPDATE) + public R edit(@RequestBody WaAlarm waAlarm){ + waAlarmService.updateById(waAlarm); + return R.ok(); + } + + /** + * 删除 + */ + @RequestMapping("/delete/{ids}") + @PreAuthorize("@ss.hasPermi('warning:alarm:remove')") + @Log(title = "WaAlarm", businessType = BusinessType.DELETE) + public R delete(@PathVariable Long[] ids){ + waAlarmService.removeByIds(Arrays.asList(ids)); + return R.ok(); + } + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaEmployeeController.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaEmployeeController.java new file mode 100644 index 0000000..e02b81f --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaEmployeeController.java @@ -0,0 +1,96 @@ +package com.ruoyi.code.warning.controller; + +import com.ruoyi.code.warning.domain.WaEmployee; +import com.ruoyi.code.warning.service.IWaEmployeeService; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.common.utils.poi.ExcelUtil; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletResponse; +import java.util.Arrays; +import java.util.List; +import java.util.Map; +/** + * 人员管理Controller + * + * @author ruoyi + * @date 2022-09-19 + */ +@RestController +@RequestMapping("/warning/employee") +public class WaEmployeeController extends BaseController +{ + @Resource + private IWaEmployeeService waEmployeeService; + + /** + * 查询列表 + */ + @PreAuthorize("@ss.hasPermi('warning:employee:list')") + @RequestMapping("/list") + public R list(@RequestParam Map params){ + return waEmployeeService.queryPage(params); + } + + /** + * 获取详细信息 + */ + @RequestMapping("/info/{id}") + @PreAuthorize("@ss.hasPermi('warning:employee:query')") + public R info(@PathVariable("id") Long id){ + WaEmployee waEmployee = waEmployeeService.getById(id); + return R.ok().put("data", waEmployee); + } + + + /** + * 导出列表 + */ + @PreAuthorize("@ss.hasPermi('warning:employee:export')") + @Log(title = "列表", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, WaEmployee waEmployee) + { + List list = waEmployeeService.list(); + ExcelUtil util = new ExcelUtil(WaEmployee.class); + util.exportExcel(response, list, "列表数据"); + } + + /** + * 新增 + */ + @RequestMapping("/add") + @Log(title = "WaEmployee", businessType = BusinessType.INSERT) + @PreAuthorize("@ss.hasPermi('warning:employee:add')") + public R add(@RequestBody WaEmployee waEmployee){ + waEmployeeService.save(waEmployee); + return R.ok(); + } + + /** + * 修改 + */ + @RequestMapping("/edit") + @PreAuthorize("@ss.hasPermi('warning:employee:edit')") + @Log(title = "WaEmployee", businessType = BusinessType.UPDATE) + public R edit(@RequestBody WaEmployee waEmployee){ + waEmployeeService.updateById(waEmployee); + return R.ok(); + } + + /** + * 删除 + */ + @RequestMapping("/delete/{ids}") + @PreAuthorize("@ss.hasPermi('warning:employee:remove')") + @Log(title = "WaEmployee", businessType = BusinessType.DELETE) + public R delete(@PathVariable Long[] ids){ + return waEmployeeService.delByIds(Arrays.asList(ids)); + } + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaMessageController.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaMessageController.java new file mode 100644 index 0000000..9107e24 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaMessageController.java @@ -0,0 +1,96 @@ +package com.ruoyi.code.warning.controller; + +import com.ruoyi.code.warning.domain.WaMessage; +import com.ruoyi.code.warning.service.IWaMessageService; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.common.utils.poi.ExcelUtil; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletResponse; +import java.util.Arrays; +import java.util.List; +import java.util.Map; +/** + * 短信管理Controller + * + * @author ruoyi + * @date 2022-09-19 + */ +@RestController +@RequestMapping("/warning/message") +public class WaMessageController extends BaseController +{ + @Resource + private IWaMessageService waMessageService; + + /** + * 查询列表 + */ + @PreAuthorize("@ss.hasPermi('warning:message:list')") + @RequestMapping("/list") + public R list(@RequestParam Map params){ + return waMessageService.queryPage(params); + } + + /** + * 获取详细信息 + */ + @RequestMapping("/info/{id}") + @PreAuthorize("@ss.hasPermi('warning:message:query')") + public R info(@PathVariable("id") Long id){ + WaMessage waMessage = waMessageService.selectById(id); + return R.ok().put("data", waMessage); + } + + + /** + * 导出列表 + */ + @PreAuthorize("@ss.hasPermi('warning:message:export')") + @Log(title = "列表", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, WaMessage waMessage) + { + List list = waMessageService.list(); + ExcelUtil util = new ExcelUtil(WaMessage.class); + util.exportExcel(response, list, "列表数据"); + } + + /** + * 新增 + */ + @RequestMapping("/add") + @Log(title = "WaMessage", businessType = BusinessType.INSERT) + @PreAuthorize("@ss.hasPermi('warning:message:add')") + public R add(@RequestBody WaMessage waMessage){ + return waMessageService.saveMessage(waMessage); + } + + /** + * 修改 + */ + @RequestMapping("/edit") + @PreAuthorize("@ss.hasPermi('warning:message:edit')") + @Log(title = "WaMessage", businessType = BusinessType.UPDATE) + public R edit(@RequestBody WaMessage waMessage){ + waMessageService.updateByMessage(waMessage); + return R.ok(); + } + + /** + * 删除 + */ + @RequestMapping("/delete/{ids}") + @PreAuthorize("@ss.hasPermi('warning:message:remove')") + @Log(title = "WaMessage", businessType = BusinessType.DELETE) + public R delete(@PathVariable Long[] ids){ + waMessageService.delByIds(Arrays.asList(ids)); + return R.ok(); + } + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaThresholdController.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaThresholdController.java new file mode 100644 index 0000000..2d82ab6 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/controller/WaThresholdController.java @@ -0,0 +1,106 @@ +package com.ruoyi.code.warning.controller; + +import java.util.List; +import java.util.Arrays; +import java.util.Map; +import javax.servlet.http.HttpServletResponse; +import javax.annotation.Resource; +import com.ruoyi.common.core.page.R; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.code.warning.domain.WaThreshold; +import com.ruoyi.code.warning.service.IWaThresholdService; +import com.ruoyi.common.utils.poi.ExcelUtil; +/** + * 阈值管理Controller + * + * @author ruoyi + * @date 2022-09-19 + */ +@RestController +@RequestMapping("/warning/threshold") +public class WaThresholdController extends BaseController +{ + @Resource + private IWaThresholdService waThresholdService; + + /** + * 查询列表 + */ + @PreAuthorize("@ss.hasPermi('warning:threshold:list')") + @RequestMapping("/list") + public R list(@RequestParam Map params){ + return waThresholdService.queryPage(params); + } + + /** + * 获取详细信息 + */ + @RequestMapping("/info/{id}") + @PreAuthorize("@ss.hasPermi('warning:threshold:query')") + public R info(@PathVariable("id") Long id){ + WaThreshold waThreshold = waThresholdService.getById(id); + + return R.ok().put("data", waThreshold); + } + + + /** + * 导出列表 + */ + @PreAuthorize("@ss.hasPermi('warning:threshold:export')") + @Log(title = "列表", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, WaThreshold waThreshold) + { + List list = waThresholdService.list(); + ExcelUtil util = new ExcelUtil(WaThreshold.class); + util.exportExcel(response, list, "列表数据"); + } + + /** + * 新增 + */ + @RequestMapping("/add") + @Log(title = "WaThreshold", businessType = BusinessType.INSERT) + @PreAuthorize("@ss.hasPermi('warning:threshold:add')") + public R add(@RequestBody WaThreshold waThreshold){ + waThresholdService.save(waThreshold); + return R.ok(); + } + + /** + * 修改 + */ + @RequestMapping("/edit") + @PreAuthorize("@ss.hasPermi('warning:threshold:edit')") + @Log(title = "WaThreshold", businessType = BusinessType.UPDATE) + public R edit(@RequestBody WaThreshold waThreshold){ + waThresholdService.updateById(waThreshold); + return R.ok(); + } + + /** + * 删除 + */ + @RequestMapping("/delete/{ids}") + @PreAuthorize("@ss.hasPermi('warning:threshold:remove')") + @Log(title = "WaThreshold", businessType = BusinessType.DELETE) + public R delete(@PathVariable Long[] ids){ + waThresholdService.removeByIds(Arrays.asList(ids)); + return R.ok(); + } + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java new file mode 100644 index 0000000..13b8da7 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaAlarm.java @@ -0,0 +1,41 @@ +package com.ruoyi.code.warning.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + + +/** + * 预警管理对象 wa_alarm + * + * @author ruoyi + * @date 2022-09-19 + */ +@Data +@TableName("wa_alarm") +public class WaAlarm implements Serializable +{ + private static final long serialVersionUID = 1L; + + /** 预警id */ + @TableId(type = IdType.INPUT) + private Long id; + + /** 测站id */ + private Long stnmId; + + /** 预警内容 */ + private String alarmContent; + + /** 预警时间 */ + private Date alarmTime; + + /** 0 未删除 1 删除 */ +// @TableLogic + private Long deleted; + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmpMsg.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmpMsg.java new file mode 100644 index 0000000..85b33b0 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmpMsg.java @@ -0,0 +1,36 @@ +package com.ruoyi.code.warning.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.TableId; +import com.ruoyi.common.annotation.Excel; +import java.io.Serializable; +import lombok.Data; + + +/** + * 短信人员对象 wa_emp_msg + * + * @author ruoyi + * @date 2022-09-20 + */ +@Data +@TableName("wa_emp_msg") +public class WaEmpMsg implements Serializable +{ + private static final long serialVersionUID = 1L; + + /** id */ + @TableId(type = IdType.INPUT) + private Long id; + + /** 人员id */ + private Long empId; + + /** 消息id */ + private Long msgId; + + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmployee.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmployee.java new file mode 100644 index 0000000..293bf23 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaEmployee.java @@ -0,0 +1,39 @@ +package com.ruoyi.code.warning.domain; + +import com.baomidou.mybatisplus.annotation.*; +import lombok.Data; + +import java.io.Serializable; + + +/** + * 人员管理对象 wa_employee + * + * @author ruoyi + * @date 2022-09-19 + */ +@Data +@TableName("wa_employee") +public class WaEmployee implements Serializable +{ + private static final long serialVersionUID = 1L; + + /** id */ + @TableId(type = IdType.INPUT) + private Long id; + + /** 姓名 */ + private String name; + + /** 手机号 */ + private Long phone; + + /** 备注 */ + private String remarks; + + /** 0 未删除 1 删除 */ +// @TableLogic + private Long deleted; + + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaMessage.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaMessage.java new file mode 100644 index 0000000..7087cbe --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaMessage.java @@ -0,0 +1,50 @@ +package com.ruoyi.code.warning.domain; + +import com.baomidou.mybatisplus.annotation.*; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + + +/** + * 短信管理对象 wa_message + * + * @author ruoyi + * @date 2022-09-19 + */ +@Data +@TableName("wa_message") +public class WaMessage implements Serializable +{ + private static final long serialVersionUID = 1L; + + /** 短信id */ + @TableId(value = "id",type = IdType.AUTO) + private Long id; + + /** 短信名称 */ + private String msgName; + + /** 短信内容 */ + private String msgContent; + + /** 发送时间 */ + private Date sendTime; + + /** 消息状态 */ + private String sendStaus; + + /** 测站id */ + private Long stnmId; + + /** 人员id */ + @TableField(exist = false) + private Long empId; + + /** 0 未删除 1 删除 */ +// @TableLogic + private Long deleted; + + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaThreshold.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaThreshold.java new file mode 100644 index 0000000..4d3a4d0 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/domain/WaThreshold.java @@ -0,0 +1,40 @@ +package com.ruoyi.code.warning.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; + + +/** + * 阈值管理对象 wa_threshold + * + * @author ruoyi + * @date 2022-09-19 + */ +@Data +@TableName("wa_threshold") +public class WaThreshold implements Serializable +{ + private static final long serialVersionUID = 1L; + + /** 阈值id */ + @TableId(type = IdType.INPUT) + private Long id; + + /** 阈值一级 */ + private String thresholdLevelL; + + /** 阈值二级 */ + private String thresholdLevelLl; + + /** 阈值三级 */ + private String thresholdLevelLll; + + /** 测站id */ + private Long stnmId; + + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java new file mode 100644 index 0000000..65e8d6a --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaAlarmMapper.java @@ -0,0 +1,17 @@ +package com.ruoyi.code.warning.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Mapper; +import com.ruoyi.code.warning.domain.WaAlarm; + +/** + * Mapper接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Mapper +public interface WaAlarmMapper extends BaseMapper +{ + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmpMsgMapper.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmpMsgMapper.java new file mode 100644 index 0000000..be205d2 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmpMsgMapper.java @@ -0,0 +1,23 @@ +package com.ruoyi.code.warning.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ruoyi.code.warning.domain.WaEmpMsg; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +/** + * Mapper接口 + * + * @author ruoyi + * @date 2022-09-20 + */ +@Mapper +public interface WaEmpMsgMapper extends BaseMapper +{ + + boolean saveMessageAndStation(@Param("empId")Long empId, @Param("msgId")Long msgId); + + Long selectEmpIdByMsgId(Long msgId); + + WaEmpMsg selectByMsgId(Long id); +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmployeeMapper.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmployeeMapper.java new file mode 100644 index 0000000..0706e6b --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaEmployeeMapper.java @@ -0,0 +1,18 @@ +package com.ruoyi.code.warning.mapper; + +import java.util.List; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Mapper; +import com.ruoyi.code.warning.domain.WaEmployee; + +/** + * Mapper接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Mapper +public interface WaEmployeeMapper extends BaseMapper +{ + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaMessageMapper.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaMessageMapper.java new file mode 100644 index 0000000..908d533 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaMessageMapper.java @@ -0,0 +1,17 @@ +package com.ruoyi.code.warning.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ruoyi.code.warning.domain.WaMessage; +import org.apache.ibatis.annotations.Mapper; + +/** + * Mapper接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Mapper +public interface WaMessageMapper extends BaseMapper +{ + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaThresholdMapper.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaThresholdMapper.java new file mode 100644 index 0000000..a1ee6b1 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/mapper/WaThresholdMapper.java @@ -0,0 +1,18 @@ +package com.ruoyi.code.warning.mapper; + +import java.util.List; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Mapper; +import com.ruoyi.code.warning.domain.WaThreshold; + +/** + * Mapper接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Mapper +public interface WaThresholdMapper extends BaseMapper +{ + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java new file mode 100644 index 0000000..78e747f --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaAlarmService.java @@ -0,0 +1,22 @@ +package com.ruoyi.code.warning.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.code.warning.domain.WaAlarm; +import com.ruoyi.common.core.page.R; + +import java.util.Map; + +/** + * Service接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +public interface IWaAlarmService extends IService +{ + /** + * 查询 + */ + R queryPage(Map params); + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmpMsgService.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmpMsgService.java new file mode 100644 index 0000000..2798ffc --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmpMsgService.java @@ -0,0 +1,21 @@ +package com.ruoyi.code.warning.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.common.core.page.R; +import java.util.Map; +import com.ruoyi.code.warning.domain.WaEmpMsg; + +/** + * Service接口 + * + * @author ruoyi + * @date 2022-09-20 + */ +public interface IWaEmpMsgService extends IService +{ + /** + * 查询 + */ + R queryPage(Map params); + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmployeeService.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmployeeService.java new file mode 100644 index 0000000..69db1d1 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaEmployeeService.java @@ -0,0 +1,24 @@ +package com.ruoyi.code.warning.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.code.warning.domain.WaEmployee; +import com.ruoyi.common.core.page.R; + +import java.util.List; +import java.util.Map; + +/** + * Service接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +public interface IWaEmployeeService extends IService +{ + /** + * 查询 + */ + R queryPage(Map params); + + R delByIds(List asList); +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaMessageService.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaMessageService.java new file mode 100644 index 0000000..c7a6fc4 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaMessageService.java @@ -0,0 +1,35 @@ +package com.ruoyi.code.warning.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.code.warning.domain.WaMessage; +import com.ruoyi.common.core.page.R; + +import java.util.List; +import java.util.Map; + +/** + * Service接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +public interface IWaMessageService extends IService +{ + /** + * 查询 + */ + R queryPage(Map params); + + /** + * 保存短信 + * @param waMessage + * @return + */ + R saveMessage(WaMessage waMessage); + + WaMessage selectById(Long id); + + void updateByMessage(WaMessage waMessage); + + void delByIds(List asList); +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaThresholdService.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaThresholdService.java new file mode 100644 index 0000000..5137655 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/IWaThresholdService.java @@ -0,0 +1,22 @@ +package com.ruoyi.code.warning.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ruoyi.code.warning.domain.WaThreshold; +import com.ruoyi.common.core.page.R; + +import java.util.Map; + +/** + * Service接口 + * + * @author ruoyi + * @date 2022-09-19 + */ +public interface IWaThresholdService extends IService +{ + /** + * 查询 + */ + R queryPage(Map params); + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java new file mode 100644 index 0000000..fa2f686 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaAlarmServiceImpl.java @@ -0,0 +1,39 @@ +package com.ruoyi.code.warning.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.code.warning.domain.WaAlarm; +import com.ruoyi.code.warning.mapper.WaAlarmMapper; +import com.ruoyi.code.warning.service.IWaAlarmService; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.utils.Query; +import com.ruoyi.common.utils.StringUtils; +import org.springframework.stereotype.Service; + +import java.util.Map; + +/** + * Service业务层处理 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Service("waAlarmService") +public class WaAlarmServiceImpl extends ServiceImpl implements IWaAlarmService +{ + @Override + public R queryPage(Map params) { + Object stnmId = params.get("stnmId"); + Object alarmTime = params.get("alarmTime"); + IPage page = this.page( + new Query().getPage(params), + new QueryWrapper() + .eq(StringUtils.isNotNull(stnmId),"stnm_id",stnmId) + .eq(StringUtils.isNotNull(alarmTime),"alarm_time",alarmTime) + ); + + return R.ok().put("count", page.getTotal()).put("data", page.getRecords()); + } + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmpMsgServiceImpl.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmpMsgServiceImpl.java new file mode 100644 index 0000000..a4a2813 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmpMsgServiceImpl.java @@ -0,0 +1,33 @@ +package com.ruoyi.code.warning.service.impl; + +import java.util.Map; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.utils.Query; +import org.springframework.stereotype.Service; +import com.ruoyi.code.warning.mapper.WaEmpMsgMapper; +import com.ruoyi.code.warning.domain.WaEmpMsg; +import com.ruoyi.code.warning.service.IWaEmpMsgService; + +/** + * Service业务层处理 + * + * @author ruoyi + * @date 2022-09-20 + */ +@Service("waEmpMsgService") +public class WaEmpMsgServiceImpl extends ServiceImpl implements IWaEmpMsgService +{ + @Override + public R queryPage(Map params) { + IPage page = this.page( + new Query().getPage(params), + new QueryWrapper() + ); + + return R.ok().put("count", page.getTotal()).put("data", page.getRecords()); + } + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmployeeServiceImpl.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmployeeServiceImpl.java new file mode 100644 index 0000000..738546a --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaEmployeeServiceImpl.java @@ -0,0 +1,59 @@ +package com.ruoyi.code.warning.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.code.warning.domain.WaEmpMsg; +import com.ruoyi.code.warning.domain.WaEmployee; +import com.ruoyi.code.warning.mapper.WaEmpMsgMapper; +import com.ruoyi.code.warning.mapper.WaEmployeeMapper; +import com.ruoyi.code.warning.service.IWaEmployeeService; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.utils.Query; +import org.apache.commons.lang3.ObjectUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; +import java.util.Map; + +/** + * Service业务层处理 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Service("waEmployeeService") +public class WaEmployeeServiceImpl extends ServiceImpl implements IWaEmployeeService +{ + @Autowired + private WaEmpMsgMapper waEmpMsgMapper; + + @Override + public R queryPage(Map params) { + Object name = params.get("name"); + Object phone = params.get("phone"); + IPage page = this.page( + new Query().getPage(params), + new QueryWrapper() + .like(ObjectUtils.isNotEmpty(name),"name",name) + .eq(ObjectUtils.isNotEmpty(phone),"phone",phone) + ); + + return R.ok().put("count", page.getTotal()).put("data", page.getRecords()); + } + + @Override + public R delByIds(List asList) { + if (asList.size() > 0){ + List list = waEmpMsgMapper.selectList(new LambdaQueryWrapper() + .in(WaEmpMsg::getEmpId, asList)); + if (list.size() == 0) { + baseMapper.deleteBatchIds(asList); + return R.ok(); + } + } + return R.error("该用户有短信消息，不能删除！"); + } +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaMessageServiceImpl.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaMessageServiceImpl.java new file mode 100644 index 0000000..329cfee --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaMessageServiceImpl.java @@ -0,0 +1,90 @@ +package com.ruoyi.code.warning.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.code.warning.domain.WaEmpMsg; +import com.ruoyi.code.warning.domain.WaMessage; +import com.ruoyi.code.warning.mapper.WaEmpMsgMapper; +import com.ruoyi.code.warning.mapper.WaMessageMapper; +import com.ruoyi.code.warning.service.IWaMessageService; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.utils.Query; +import org.apache.commons.lang3.ObjectUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.List; +import java.util.Map; + +/** + * Service业务层处理 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Service("waMessageService") +public class WaMessageServiceImpl extends ServiceImpl implements IWaMessageService +{ + @Autowired + private WaEmpMsgMapper waEmpMsgMapper; + + @Override + public R queryPage(Map params) { + Object stnmId = params.get("stnmId"); + Object sendTime = params.get("sendTime"); + Object sendStatus = params.get("sendStatus"); + IPage page = this.page( + new Query().getPage(params), + new QueryWrapper() + .eq(ObjectUtils.isNotEmpty(stnmId),"stnm_id",stnmId) + .eq(ObjectUtils.isNotEmpty(sendTime),"send_time",sendTime) + .eq(ObjectUtils.isNotEmpty(sendStatus),"send_status",sendStatus) + ); + + return R.ok().put("count", page.getTotal()).put("data", page.getRecords()); + } + + @Override + @Transactional + public R saveMessage(WaMessage waMessage) { + int result = baseMapper.insert(waMessage); + System.out.println(waMessage.getId()); + if (result > 0){ + boolean flag = waEmpMsgMapper.saveMessageAndStation(waMessage.getEmpId(),waMessage.getId()); + if(flag){ + return R.ok(); + } + } + return R.error(); + } + + + @Override + public WaMessage selectById(Long id) { + WaMessage waMessage = baseMapper.selectById(id); + Long msgId = waMessage.getId(); + Long empId = waEmpMsgMapper.selectEmpIdByMsgId(msgId); + waMessage.setEmpId(empId); + return waMessage; + } + + @Override + public void updateByMessage(WaMessage waMessage) { + baseMapper.updateById(waMessage); + Long empId = waMessage.getEmpId(); + WaEmpMsg waEmpMsg = waEmpMsgMapper.selectByMsgId(waMessage.getId()); + waEmpMsg.setEmpId(empId); + waEmpMsgMapper.updateById(waEmpMsg); + } + + @Override + public void delByIds(List asList) { + baseMapper.deleteBatchIds(asList); + waEmpMsgMapper.delete(new LambdaQueryWrapper() + .in(WaEmpMsg::getMsgId,asList)); + } + +} diff --git a/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaThresholdServiceImpl.java b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaThresholdServiceImpl.java new file mode 100644 index 0000000..7fb2193 --- /dev/null +++ b/ruoyi-code/src/main/java/com/ruoyi/code/warning/service/impl/WaThresholdServiceImpl.java @@ -0,0 +1,36 @@ +package com.ruoyi.code.warning.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.code.warning.domain.WaThreshold; +import com.ruoyi.code.warning.mapper.WaThresholdMapper; +import com.ruoyi.code.warning.service.IWaThresholdService; +import com.ruoyi.common.core.page.R; +import com.ruoyi.common.utils.Query; +import org.apache.commons.lang3.ObjectUtils; +import org.springframework.stereotype.Service; + +import java.util.Map; + +/** + * Service业务层处理 + * + * @author ruoyi + * @date 2022-09-19 + */ +@Service("waThresholdService") +public class WaThresholdServiceImpl extends ServiceImpl implements IWaThresholdService +{ + @Override + public R queryPage(Map params) { + IPage page = this.page( + new Query().getPage(params), + new QueryWrapper() + .eq(ObjectUtils.isNotEmpty(params.get("stnmId")),"stnm_id",params.get("stnmId")) + ); + + return R.ok().put("count", page.getTotal()).put("data", page.getRecords()); + } + +} diff --git a/ruoyi-code/src/main/resources/mapper/warning/WaEmpMsgMapper.xml b/ruoyi-code/src/main/resources/mapper/warning/WaEmpMsgMapper.xml new file mode 100644 index 0000000..74f5805 --- /dev/null +++ b/ruoyi-code/src/main/resources/mapper/warning/WaEmpMsgMapper.xml @@ -0,0 +1,15 @@ + + + + + insert into wa_emp_msg(emp_id,msg_id) value(#{empId},#{msgId}) + + + + diff --git a/ruoyi-code/src/main/resources/mapper/warning/WaMessageMapper.xml b/ruoyi-code/src/main/resources/mapper/warning/WaMessageMapper.xml new file mode 100644 index 0000000..350d756 --- /dev/null +++ b/ruoyi-code/src/main/resources/mapper/warning/WaMessageMapper.xml @@ -0,0 +1,5 @@ + + + + +