2023-05-11 14:03:26 完成用户所属设备列表查询接口,完成根据设备Id查询设备当前状态接口!

master
魔神煜修罗皇 2 years ago
parent 78f3453d99
commit 5f350b53f4
  1. 3
      psdc-business/src/main/java/com/psdc/mapper/PsdcDeviceMapper.java
  2. 4
      psdc-business/src/main/java/com/psdc/service/IPsdcDeviceService.java
  3. 7
      psdc-business/src/main/java/com/psdc/service/impl/PsdcDeviceServiceImpl.java
  4. 14
      psdc-business/src/main/resources/mapper/business/PsdcDeviceMapper.xml
  5. 33
      psdc-web/src/main/java/com/psdc/controller/monitor/SandTableController.java
  6. 21
      psdc-web/src/main/java/com/psdc/controller/monitor/TotalElectricMeterController.java

@ -3,6 +3,7 @@ package com.psdc.mapper;
import java.util.List; import java.util.List;
import com.psdc.entity.PsdcDevice; import com.psdc.entity.PsdcDevice;
import com.psdc.entity.vo.DeviceStatusVo;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;
@ -24,6 +25,8 @@ public interface PsdcDeviceMapper{
*/ */
PsdcDevice queryById(Integer deviceId); PsdcDevice queryById(Integer deviceId);
DeviceStatusVo queryDeviceStatusById(@Param(value = "deviceId") Integer deviceId);
List<Integer> selMyWorkDevices(@Param(value = "devType") Integer devType, List<Integer> selMyWorkDevices(@Param(value = "devType") Integer devType,
@Param(value = "userId") Long userId); @Param(value = "userId") Long userId);

@ -27,6 +27,10 @@ public interface IPsdcDeviceService {
*/ */
List<DeviceStatusVo> queryDeviceStatus(); List<DeviceStatusVo> queryDeviceStatus();
DeviceStatusVo queryDeviceStatusById(Integer deviceId);
/** /**
* 新增数据 * 新增数据
* *

@ -36,6 +36,8 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService{
return psdcDeviceMapper.queryById(deviceId); return psdcDeviceMapper.queryById(deviceId);
} }
/** /**
* 根据用户id查询设备列表 * 根据用户id查询设备列表
* @return * @return
@ -53,6 +55,11 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService{
}).collect(Collectors.toList()); }).collect(Collectors.toList());
} }
@Override
public DeviceStatusVo queryDeviceStatusById(Integer deviceId) {
return psdcDeviceMapper.queryDeviceStatusById(deviceId);
}
/** /**
* 新增数据 * 新增数据
* *

@ -21,6 +21,20 @@
<result property="updateTime" column="update_time" /> <result property="updateTime" column="update_time" />
</resultMap> </resultMap>
<resultMap id="PsdcDeviceMap2" type="com.psdc.entity.vo.DeviceStatusVo">
<result property="deviceId" column="device_id" />
<result property="deviceType" column="device_type" />
<result property="deviceSn" column="device_sn" />
<result property="deviceName" column="device_name" />
<result property="photoUrl" column="photo_url" />
<result property="deviceRunstatus" column="device_runstatus" />
</resultMap>
<select id="queryDeviceStatusById" resultMap="PsdcDeviceMap2">
Select device_id, device_type, device_sn, device_name, device_runstatus, photo_url From psdc_device
Where device_id = #{deviceId}
</select>
<!-- 通过ID查询单条数据 --> <!-- 通过ID查询单条数据 -->
<select id="queryById" resultMap="PsdcDeviceMap"> <select id="queryById" resultMap="PsdcDeviceMap">
select device_id, select device_id,

@ -0,0 +1,33 @@
package com.psdc.controller.monitor;
import com.psdc.core.domain.AjaxResult;
import com.psdc.service.IPsdcDeviceService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
/**
* @Author戴仕崑
* @Projectpsdc
* @FilenameSandTableController
* @Date2023/5/11 13:40
* @Version 1.0
*/
@RestController
@RequestMapping("/api/monitor/sp/index")
public class SandTableController {
@Autowired
IPsdcDeviceService psdcDeviceService;
@PreAuthorize("@ss.hasPermi('emonitor:sp')")
@RequestMapping(value = "/sel1/{deviceId}", method = RequestMethod.GET)
public AjaxResult seldrgl1(@PathVariable(value = "deviceId", required = false) Integer deviceId){
AjaxResult ajax = AjaxResult.success(psdcDeviceService.queryDeviceStatusById(deviceId));
return ajax;
}
}

@ -1,7 +1,9 @@
package com.psdc.controller.monitor; package com.psdc.controller.monitor;
import com.psdc.core.domain.AjaxResult; import com.psdc.core.domain.AjaxResult;
import com.psdc.entity.PsdcDevice;
import com.psdc.entity.res.PsdcDevicePowerRes; import com.psdc.entity.res.PsdcDevicePowerRes;
import com.psdc.service.IPsdcDeviceService;
import com.psdc.service.IPsdcElectricHtdataService; import com.psdc.service.IPsdcElectricHtdataService;
import com.psdc.service.IPsdcThermometerHtdataService; import com.psdc.service.IPsdcThermometerHtdataService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -11,6 +13,8 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -31,6 +35,23 @@ public class TotalElectricMeterController {
@Autowired @Autowired
IPsdcElectricHtdataService psdcElectricHtdataService; IPsdcElectricHtdataService psdcElectricHtdataService;
@Autowired
IPsdcDeviceService psdcDeviceService;
@PreAuthorize("@ss.hasPermi('emonitor:db')")
@RequestMapping(value = "/selMydevices", method = RequestMethod.GET)
public AjaxResult selMydevices() {
List<Map> maps = new ArrayList<>();
List<PsdcDevice> list = psdcDeviceService.queryByUserId();
for (PsdcDevice dd : list){
Map<String, Object> map = new HashMap<>();
map.put("label", dd.getDeviceName());
map.put("value", dd.getDeviceId());
maps.add(map);
}
return AjaxResult.success("用户所属设备列表", maps);
}
@PreAuthorize("@ss.hasPermi('emonitor:db')") @PreAuthorize("@ss.hasPermi('emonitor:db')")
@RequestMapping(value = "/sel1/{deviceId}", method = RequestMethod.GET) @RequestMapping(value = "/sel1/{deviceId}", method = RequestMethod.GET)
public AjaxResult selzdb1(@PathVariable(value = "deviceId", required = false) Integer deviceId) { public AjaxResult selzdb1(@PathVariable(value = "deviceId", required = false) Integer deviceId) {

Loading…
Cancel
Save