手动控制页面开发

master
林颖晨 2 years ago
parent b722eac09a
commit 87eaca1744
  1. 2
      psdc-admin/src/main/resources/application-dev.yml
  2. 2
      psdc-admin/src/main/resources/application-prop.yml
  3. 2
      psdc-business/src/main/java/com/psdc/service/IPsdcDeviceService.java
  4. 8
      psdc-business/src/main/java/com/psdc/service/impl/PsdcDeviceServiceImpl.java
  5. 1
      psdc-business/src/main/resources/mapper/business/PsdcControlLogMapper.xml
  6. 4
      psdc-common/src/main/java/com/psdc/core/controller/BaseController.java
  7. 4
      psdc-common/src/main/java/com/psdc/utils/PageUtils.java
  8. 21
      psdc-web/src/main/java/com/psdc/controller/control/ManualControl.java

@ -103,7 +103,7 @@ token:
# 令牌密钥 # 令牌密钥
secret: abcdefghijklmnopqrstuvwxyz secret: abcdefghijklmnopqrstuvwxyz
# 令牌有效期(默认30分钟) # 令牌有效期(默认30分钟)
expireTime: 30 expireTime: 600
# MyBatis配置 # MyBatis配置
mybatis: mybatis:

@ -103,7 +103,7 @@ token:
# 令牌密钥 # 令牌密钥
secret: abcdefghijklmnopqrstuvwxyz secret: abcdefghijklmnopqrstuvwxyz
# 令牌有效期(默认30分钟) # 令牌有效期(默认30分钟)
expireTime: 30 expireTime: 600
# MyBatis配置 # MyBatis配置
mybatis: mybatis:

@ -64,6 +64,6 @@ public interface IPsdcDeviceService {
* @param runStatus * @param runStatus
* @return * @return
*/ */
int controlDeviceStartAndStop(Integer deviceId,Integer runStatus); int controlDeviceStartAndStop(Integer deviceId,Integer runStatus,String controlBy);
} }

@ -104,7 +104,7 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService{
* @return * @return
*/ */
@Override @Override
public int controlDeviceStartAndStop(Integer deviceId, Integer runStatus) { public int controlDeviceStartAndStop(Integer deviceId, Integer runStatus,String controlBy) {
String s = ""; String s = "";
if(runStatus == 1){ if(runStatus == 1){
@ -116,15 +116,15 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService{
PsdcDevice psdcDevice = psdcDeviceMapper.queryById(deviceId); PsdcDevice psdcDevice = psdcDeviceMapper.queryById(deviceId);
if(psdcDevice == null){ if(psdcDevice == null){
psdcControlLogMapper.insert(new PsdcControlLog(deviceId,null,null,"设备启停",s,2,"未找到该设备",SecurityUtils.getUsername())); psdcControlLogMapper.insert(new PsdcControlLog(deviceId,null,null,"设备启停",s,2,"未找到该设备",controlBy));
throw new ControlException("控制失败,未找到该设备"); throw new ControlException("控制失败,未找到该设备");
} }
//TODO 发送MQTT指令 //TODO 发送MQTT指令
// psdcControlLogMapper.insert(new PsdcControlLog(deviceId,psdcDevice.getDeviceName(),psdcDevice.getDeviceSn(),"设备启停",s,2,"等待终端响应超时",SecurityUtils.getUsername())); // psdcControlLogMapper.insert(new PsdcControlLog(deviceId,psdcDevice.getDeviceName(),psdcDevice.getDeviceSn(),"设备启停",s,2,"等待终端响应超时",controlBy));
//发送成功 //发送成功
psdcControlLogMapper.insert(new PsdcControlLog(deviceId,psdcDevice.getDeviceName(),psdcDevice.getDeviceSn(),"设备启停",s,2,"控制成功",SecurityUtils.getUsername())); psdcControlLogMapper.insert(new PsdcControlLog(deviceId,psdcDevice.getDeviceName(),psdcDevice.getDeviceSn(),"设备启停",s,2,"控制成功",controlBy));
return psdcDeviceMapper.updateDevRunStatusByDevId(deviceId,runStatus); return psdcDeviceMapper.updateDevRunStatusByDevId(deviceId,runStatus);
} }

@ -77,6 +77,7 @@
and update_time = #{updateTime} and update_time = #{updateTime}
</if> </if>
</where> </where>
order by create_time desc
</select> </select>
<!--统计总行数--> <!--统计总行数-->

@ -4,12 +4,16 @@ import java.beans.PropertyEditorSupport;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.github.pagehelper.page.PageMethod;
import com.psdc.constant.HttpStatus; import com.psdc.constant.HttpStatus;
import com.psdc.utils.DateUtils; import com.psdc.utils.DateUtils;
import com.psdc.utils.PageUtils; import com.psdc.utils.PageUtils;
import com.psdc.utils.SecurityUtils; import com.psdc.utils.SecurityUtils;
import com.psdc.utils.StringUtils; import com.psdc.utils.StringUtils;
import com.psdc.utils.sql.SqlUtil; import com.psdc.utils.sql.SqlUtil;
import org.apache.poi.ss.formula.functions.T;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.web.bind.WebDataBinder; import org.springframework.web.bind.WebDataBinder;

@ -1,9 +1,13 @@
package com.psdc.utils; package com.psdc.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.page.PageMethod;
import com.psdc.core.page.PageDomain; import com.psdc.core.page.PageDomain;
import com.psdc.core.page.TableSupport; import com.psdc.core.page.TableSupport;
import com.psdc.utils.sql.SqlUtil; import com.psdc.utils.sql.SqlUtil;
import org.apache.poi.ss.formula.functions.T;
/** /**
* 分页工具类 * 分页工具类

@ -1,22 +1,22 @@
package com.psdc.controller.control; package com.psdc.controller.control;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.github.pagehelper.page.PageMethod;
import com.psdc.core.controller.BaseController; import com.psdc.core.controller.BaseController;
import com.psdc.core.domain.AjaxResult; import com.psdc.core.domain.AjaxResult;
import com.psdc.core.domain.entity.SysUser;
import com.psdc.core.page.TableDataInfo; import com.psdc.core.page.TableDataInfo;
import com.psdc.domain.SysConfig;
import com.psdc.entity.PsdcControlLog; import com.psdc.entity.PsdcControlLog;
import com.psdc.entity.vo.DeviceStatusVo; import com.psdc.entity.vo.DeviceStatusVo;
import com.psdc.service.IPsdcControlLogService; import com.psdc.service.IPsdcControlLogService;
import com.psdc.service.IPsdcDeviceService; import com.psdc.service.IPsdcDeviceService;
import org.aspectj.weaver.loadtime.Aj; import com.psdc.utils.SecurityUtils;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.List; import java.util.List;
import java.util.Map;
@RestController @RestController
@ -49,7 +49,7 @@ public class ManualControl extends BaseController {
@PreAuthorize("@ss.hasPermi('control:manual:startstop')") @PreAuthorize("@ss.hasPermi('control:manual:startstop')")
@PostMapping("/startAndStop") @PostMapping("/startAndStop")
public AjaxResult deviceStartAndStop(@RequestBody JSONObject jsonObject){ public AjaxResult deviceStartAndStop(@RequestBody JSONObject jsonObject){
int i = psdcDeviceService.controlDeviceStartAndStop(jsonObject.getInteger("deviceId"), jsonObject.getInteger("runStatus")); int i = psdcDeviceService.controlDeviceStartAndStop(jsonObject.getInteger("deviceId"), jsonObject.getInteger("runStatus"), SecurityUtils.getUsername());
if ( i == 1){ if ( i == 1){
return AjaxResult.success("控制成功"); return AjaxResult.success("控制成功");
} else { } else {
@ -60,11 +60,14 @@ public class ManualControl extends BaseController {
/** /**
* 获取调控日志列表 * 获取调控日志列表
*/ */
@PreAuthorize("@ss.hasPermi('control:timer:controlLogList')") @PreAuthorize("@ss.hasPermi('control:manual:controlLogList')")
@GetMapping("/controlLogList") @PostMapping("/controlLogList")
public TableDataInfo controlLogList(PsdcControlLog psdcControlLog) { public TableDataInfo controlLogList(@RequestBody JSONObject jsonObject) {
startPage(); PageMethod.startPage(jsonObject.getInteger("pageNum"),jsonObject.getInteger("pageSize"));
PsdcControlLog psdcControlLog = JSON.parseObject(String.valueOf(jsonObject), PsdcControlLog.class);
List<PsdcControlLog> list = psdcControlLogService.query(psdcControlLog); List<PsdcControlLog> list = psdcControlLogService.query(psdcControlLog);
return getDataTable(list); return getDataTable(list);
} }
} }

Loading…
Cancel
Save