diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java new file mode 100644 index 0000000..f97a3f6 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java @@ -0,0 +1,92 @@ +package com.casic.missiles.modular.system.controller; + + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.common.constant.factory.PageFactory; +import com.casic.missiles.core.common.service.ICommonPermissionService; +import com.casic.missiles.core.datascope.DataScope; +import com.casic.missiles.modular.system.service.DeviceTubeService; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +/** + * @author cz + * @date 2022-7-6 + */ +@RestController +@RequestMapping("/tube") +public class DeviceTubeController { + + private final DeviceTubeService tubeService; + private ICommonPermissionService permissionService; + + public DeviceTubeController(DeviceTubeService tubeService, ICommonPermissionService permissionService) { + this.tubeService = tubeService; + this.permissionService = permissionService; + } + + /** + * 获取点位列表 + */ + @RequestMapping(value = "/well/list") + @ResponseBody + public Object tubeDeviceList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceList(dataScope); + } + + /** + * 获取管盯设备组列表信息 + */ + @RequestMapping(value = "/groups/list") + @ResponseBody + public Object DevicesGroupList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceGroupsList(dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/listpage") + @ResponseBody + public Object DeviceListPage(String wellGroupId, Integer order) { + Page> page = new PageFactory>().defaultPage(); + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceListPage(order,page, wellGroupId, dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/history") + @ResponseBody + public Object DeviceHistory(String devcode, String beginTime, String endTime) { + Page> page = new PageFactory>().defaultPage(); + return tubeService.tubeDataHistory(page,devcode, beginTime, endTime); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/list") + @ResponseBody + public Object DeviceList(String wellGroupId) { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceList(wellGroupId, dataScope); + } + + + /** + * 获取详情信息 + */ + @RequestMapping(value = "/detail/{detailId}") + @ResponseBody + public Object list(@PathVariable(name = "detailId") String tubeId) { + return tubeService.deviceDetail(tubeId); + } +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java new file mode 100644 index 0000000..f97a3f6 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java @@ -0,0 +1,92 @@ +package com.casic.missiles.modular.system.controller; + + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.common.constant.factory.PageFactory; +import com.casic.missiles.core.common.service.ICommonPermissionService; +import com.casic.missiles.core.datascope.DataScope; +import com.casic.missiles.modular.system.service.DeviceTubeService; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +/** + * @author cz + * @date 2022-7-6 + */ +@RestController +@RequestMapping("/tube") +public class DeviceTubeController { + + private final DeviceTubeService tubeService; + private ICommonPermissionService permissionService; + + public DeviceTubeController(DeviceTubeService tubeService, ICommonPermissionService permissionService) { + this.tubeService = tubeService; + this.permissionService = permissionService; + } + + /** + * 获取点位列表 + */ + @RequestMapping(value = "/well/list") + @ResponseBody + public Object tubeDeviceList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceList(dataScope); + } + + /** + * 获取管盯设备组列表信息 + */ + @RequestMapping(value = "/groups/list") + @ResponseBody + public Object DevicesGroupList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceGroupsList(dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/listpage") + @ResponseBody + public Object DeviceListPage(String wellGroupId, Integer order) { + Page> page = new PageFactory>().defaultPage(); + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceListPage(order,page, wellGroupId, dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/history") + @ResponseBody + public Object DeviceHistory(String devcode, String beginTime, String endTime) { + Page> page = new PageFactory>().defaultPage(); + return tubeService.tubeDataHistory(page,devcode, beginTime, endTime); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/list") + @ResponseBody + public Object DeviceList(String wellGroupId) { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceList(wellGroupId, dataScope); + } + + + /** + * 获取详情信息 + */ + @RequestMapping(value = "/detail/{detailId}") + @ResponseBody + public Object list(@PathVariable(name = "detailId") String tubeId) { + return tubeService.deviceDetail(tubeId); + } +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java new file mode 100644 index 0000000..e55ef62 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java @@ -0,0 +1,31 @@ +package com.casic.missiles.modular.system.dao; + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.datascope.DataScope; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +@Mapper +public interface DeviceTubeMapper { + + List> deviceList(@Param("scope") DataScope dataScope); + + List> deviceGroupsList(@Param("scope") DataScope dataScope); + + List> groupDeviceListPage(@Param("page")Page> page, @Param("wellGroupId") String wellGroupId, + @Param("scope") DataScope dataScope); + + Map dataTubeByDevcode(@Param("devcode")String devcode); + + List> tubeDataHistory(@Param("page") Page> page,@Param("devcode") String devcode, + @Param("endTime") String endTime,@Param("beginTime") String beginTime); + + + List> groupDeviceList(@Param("wellGroupId") String wellGroupId, @Param("scope") DataScope dataScope); + + Map deviceDetail(@Param("id") Long id); + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java new file mode 100644 index 0000000..f97a3f6 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java @@ -0,0 +1,92 @@ +package com.casic.missiles.modular.system.controller; + + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.common.constant.factory.PageFactory; +import com.casic.missiles.core.common.service.ICommonPermissionService; +import com.casic.missiles.core.datascope.DataScope; +import com.casic.missiles.modular.system.service.DeviceTubeService; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +/** + * @author cz + * @date 2022-7-6 + */ +@RestController +@RequestMapping("/tube") +public class DeviceTubeController { + + private final DeviceTubeService tubeService; + private ICommonPermissionService permissionService; + + public DeviceTubeController(DeviceTubeService tubeService, ICommonPermissionService permissionService) { + this.tubeService = tubeService; + this.permissionService = permissionService; + } + + /** + * 获取点位列表 + */ + @RequestMapping(value = "/well/list") + @ResponseBody + public Object tubeDeviceList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceList(dataScope); + } + + /** + * 获取管盯设备组列表信息 + */ + @RequestMapping(value = "/groups/list") + @ResponseBody + public Object DevicesGroupList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceGroupsList(dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/listpage") + @ResponseBody + public Object DeviceListPage(String wellGroupId, Integer order) { + Page> page = new PageFactory>().defaultPage(); + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceListPage(order,page, wellGroupId, dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/history") + @ResponseBody + public Object DeviceHistory(String devcode, String beginTime, String endTime) { + Page> page = new PageFactory>().defaultPage(); + return tubeService.tubeDataHistory(page,devcode, beginTime, endTime); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/list") + @ResponseBody + public Object DeviceList(String wellGroupId) { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceList(wellGroupId, dataScope); + } + + + /** + * 获取详情信息 + */ + @RequestMapping(value = "/detail/{detailId}") + @ResponseBody + public Object list(@PathVariable(name = "detailId") String tubeId) { + return tubeService.deviceDetail(tubeId); + } +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java new file mode 100644 index 0000000..e55ef62 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java @@ -0,0 +1,31 @@ +package com.casic.missiles.modular.system.dao; + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.datascope.DataScope; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +@Mapper +public interface DeviceTubeMapper { + + List> deviceList(@Param("scope") DataScope dataScope); + + List> deviceGroupsList(@Param("scope") DataScope dataScope); + + List> groupDeviceListPage(@Param("page")Page> page, @Param("wellGroupId") String wellGroupId, + @Param("scope") DataScope dataScope); + + Map dataTubeByDevcode(@Param("devcode")String devcode); + + List> tubeDataHistory(@Param("page") Page> page,@Param("devcode") String devcode, + @Param("endTime") String endTime,@Param("beginTime") String beginTime); + + + List> groupDeviceList(@Param("wellGroupId") String wellGroupId, @Param("scope") DataScope dataScope); + + Map deviceDetail(@Param("id") Long id); + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml new file mode 100644 index 0000000..42cae85 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml @@ -0,0 +1,127 @@ + + + + + + and datediff(now(),UPTIME) ${paramDay} + + + + AND date_part('day',now(),UPTIME) ${paramDay} + + + + and date_part(now(),UPTIME) ${paramDay} + + + + str_to_date(${paramStr},'%Y-%m-%d %H:%i') + + + + TO_DATE(${paramStr},'yyyy-MM-dd HH24:mi') + + + + TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi') + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java new file mode 100644 index 0000000..f97a3f6 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java @@ -0,0 +1,92 @@ +package com.casic.missiles.modular.system.controller; + + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.common.constant.factory.PageFactory; +import com.casic.missiles.core.common.service.ICommonPermissionService; +import com.casic.missiles.core.datascope.DataScope; +import com.casic.missiles.modular.system.service.DeviceTubeService; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +/** + * @author cz + * @date 2022-7-6 + */ +@RestController +@RequestMapping("/tube") +public class DeviceTubeController { + + private final DeviceTubeService tubeService; + private ICommonPermissionService permissionService; + + public DeviceTubeController(DeviceTubeService tubeService, ICommonPermissionService permissionService) { + this.tubeService = tubeService; + this.permissionService = permissionService; + } + + /** + * 获取点位列表 + */ + @RequestMapping(value = "/well/list") + @ResponseBody + public Object tubeDeviceList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceList(dataScope); + } + + /** + * 获取管盯设备组列表信息 + */ + @RequestMapping(value = "/groups/list") + @ResponseBody + public Object DevicesGroupList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceGroupsList(dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/listpage") + @ResponseBody + public Object DeviceListPage(String wellGroupId, Integer order) { + Page> page = new PageFactory>().defaultPage(); + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceListPage(order,page, wellGroupId, dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/history") + @ResponseBody + public Object DeviceHistory(String devcode, String beginTime, String endTime) { + Page> page = new PageFactory>().defaultPage(); + return tubeService.tubeDataHistory(page,devcode, beginTime, endTime); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/list") + @ResponseBody + public Object DeviceList(String wellGroupId) { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceList(wellGroupId, dataScope); + } + + + /** + * 获取详情信息 + */ + @RequestMapping(value = "/detail/{detailId}") + @ResponseBody + public Object list(@PathVariable(name = "detailId") String tubeId) { + return tubeService.deviceDetail(tubeId); + } +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java new file mode 100644 index 0000000..e55ef62 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java @@ -0,0 +1,31 @@ +package com.casic.missiles.modular.system.dao; + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.datascope.DataScope; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +@Mapper +public interface DeviceTubeMapper { + + List> deviceList(@Param("scope") DataScope dataScope); + + List> deviceGroupsList(@Param("scope") DataScope dataScope); + + List> groupDeviceListPage(@Param("page")Page> page, @Param("wellGroupId") String wellGroupId, + @Param("scope") DataScope dataScope); + + Map dataTubeByDevcode(@Param("devcode")String devcode); + + List> tubeDataHistory(@Param("page") Page> page,@Param("devcode") String devcode, + @Param("endTime") String endTime,@Param("beginTime") String beginTime); + + + List> groupDeviceList(@Param("wellGroupId") String wellGroupId, @Param("scope") DataScope dataScope); + + Map deviceDetail(@Param("id") Long id); + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml new file mode 100644 index 0000000..42cae85 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml @@ -0,0 +1,127 @@ + + + + + + and datediff(now(),UPTIME) ${paramDay} + + + + AND date_part('day',now(),UPTIME) ${paramDay} + + + + and date_part(now(),UPTIME) ${paramDay} + + + + str_to_date(${paramStr},'%Y-%m-%d %H:%i') + + + + TO_DATE(${paramStr},'yyyy-MM-dd HH24:mi') + + + + TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi') + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/DeviceTubeService.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/DeviceTubeService.java new file mode 100644 index 0000000..0bf5970 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/DeviceTubeService.java @@ -0,0 +1,50 @@ +package com.casic.missiles.modular.system.service; + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.datascope.DataScope; + +import java.util.Map; + +public interface DeviceTubeService { + + /** + * 获取点位信息 + * + * @return + */ + Object deviceList(DataScope dataScope); + + /** + * 获取设备列表信息 + * + * @param dataScope + * @return + */ + Object deviceGroupsList(DataScope dataScope); + + + /** + * 获取设备列表信息 + * + * @param wellGroupId + * @return + */ + Object groupDeviceListPage(Integer oreder, Page> page, String wellGroupId, DataScope dataScope); + + Object tubeDataHistory( Page> page,String DEVCOE, String beginTime, String endTime); + + + /** + * 获取同一个组设备列表信息 + * + * @param wellGroupId + * @return + */ + Object groupDeviceList(String wellGroupId, DataScope dataScope); + + /** + * 获取详情信息 + */ + Object deviceDetail(String id); + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java new file mode 100644 index 0000000..f97a3f6 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/controller/DeviceTubeController.java @@ -0,0 +1,92 @@ +package com.casic.missiles.modular.system.controller; + + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.common.constant.factory.PageFactory; +import com.casic.missiles.core.common.service.ICommonPermissionService; +import com.casic.missiles.core.datascope.DataScope; +import com.casic.missiles.modular.system.service.DeviceTubeService; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +/** + * @author cz + * @date 2022-7-6 + */ +@RestController +@RequestMapping("/tube") +public class DeviceTubeController { + + private final DeviceTubeService tubeService; + private ICommonPermissionService permissionService; + + public DeviceTubeController(DeviceTubeService tubeService, ICommonPermissionService permissionService) { + this.tubeService = tubeService; + this.permissionService = permissionService; + } + + /** + * 获取点位列表 + */ + @RequestMapping(value = "/well/list") + @ResponseBody + public Object tubeDeviceList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceList(dataScope); + } + + /** + * 获取管盯设备组列表信息 + */ + @RequestMapping(value = "/groups/list") + @ResponseBody + public Object DevicesGroupList() { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.deviceGroupsList(dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/listpage") + @ResponseBody + public Object DeviceListPage(String wellGroupId, Integer order) { + Page> page = new PageFactory>().defaultPage(); + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceListPage(order,page, wellGroupId, dataScope); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/history") + @ResponseBody + public Object DeviceHistory(String devcode, String beginTime, String endTime) { + Page> page = new PageFactory>().defaultPage(); + return tubeService.tubeDataHistory(page,devcode, beginTime, endTime); + } + + /** + * 获取列表 + */ + @RequestMapping(value = "/groupdevice/list") + @ResponseBody + public Object DeviceList(String wellGroupId) { + DataScope dataScope = permissionService.getCurrUserDataScope(); + return tubeService.groupDeviceList(wellGroupId, dataScope); + } + + + /** + * 获取详情信息 + */ + @RequestMapping(value = "/detail/{detailId}") + @ResponseBody + public Object list(@PathVariable(name = "detailId") String tubeId) { + return tubeService.deviceDetail(tubeId); + } +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java new file mode 100644 index 0000000..e55ef62 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/DeviceTubeMapper.java @@ -0,0 +1,31 @@ +package com.casic.missiles.modular.system.dao; + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.datascope.DataScope; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +@Mapper +public interface DeviceTubeMapper { + + List> deviceList(@Param("scope") DataScope dataScope); + + List> deviceGroupsList(@Param("scope") DataScope dataScope); + + List> groupDeviceListPage(@Param("page")Page> page, @Param("wellGroupId") String wellGroupId, + @Param("scope") DataScope dataScope); + + Map dataTubeByDevcode(@Param("devcode")String devcode); + + List> tubeDataHistory(@Param("page") Page> page,@Param("devcode") String devcode, + @Param("endTime") String endTime,@Param("beginTime") String beginTime); + + + List> groupDeviceList(@Param("wellGroupId") String wellGroupId, @Param("scope") DataScope dataScope); + + Map deviceDetail(@Param("id") Long id); + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml new file mode 100644 index 0000000..42cae85 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/dao/mapping/DeviceTubeMapper.xml @@ -0,0 +1,127 @@ + + + + + + and datediff(now(),UPTIME) ${paramDay} + + + + AND date_part('day',now(),UPTIME) ${paramDay} + + + + and date_part(now(),UPTIME) ${paramDay} + + + + str_to_date(${paramStr},'%Y-%m-%d %H:%i') + + + + TO_DATE(${paramStr},'yyyy-MM-dd HH24:mi') + + + + TO_DATE(${paramStr},'yyyy-mm-dd hh24:mi') + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/DeviceTubeService.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/DeviceTubeService.java new file mode 100644 index 0000000..0bf5970 --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/DeviceTubeService.java @@ -0,0 +1,50 @@ +package com.casic.missiles.modular.system.service; + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.datascope.DataScope; + +import java.util.Map; + +public interface DeviceTubeService { + + /** + * 获取点位信息 + * + * @return + */ + Object deviceList(DataScope dataScope); + + /** + * 获取设备列表信息 + * + * @param dataScope + * @return + */ + Object deviceGroupsList(DataScope dataScope); + + + /** + * 获取设备列表信息 + * + * @param wellGroupId + * @return + */ + Object groupDeviceListPage(Integer oreder, Page> page, String wellGroupId, DataScope dataScope); + + Object tubeDataHistory( Page> page,String DEVCOE, String beginTime, String endTime); + + + /** + * 获取同一个组设备列表信息 + * + * @param wellGroupId + * @return + */ + Object groupDeviceList(String wellGroupId, DataScope dataScope); + + /** + * 获取详情信息 + */ + Object deviceDetail(String id); + +} diff --git a/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/DeviceTubeServiceImpl.java b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/DeviceTubeServiceImpl.java new file mode 100644 index 0000000..0d47b3f --- /dev/null +++ b/casic-device/src/main/java/com/casic/missiles/modular/system/service/impl/DeviceTubeServiceImpl.java @@ -0,0 +1,204 @@ +package com.casic.missiles.modular.system.service.impl; + +import com.baomidou.mybatisplus.plugins.Page; +import com.casic.missiles.core.base.response.ResponseData; +import com.casic.missiles.core.datascope.DataScope; +import com.casic.missiles.modular.system.dao.DeviceTubeMapper; +import com.casic.missiles.modular.system.service.DeviceTubeService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.dao.DataAccessException; +import org.springframework.stereotype.Service; + +import java.math.BigDecimal; +import java.util.*; +import java.util.stream.Collectors; + +@Service +@Slf4j +public class DeviceTubeServiceImpl implements DeviceTubeService { + + private final DeviceTubeMapper deviceTubeMapper; + + public DeviceTubeServiceImpl(DeviceTubeMapper deviceTubeMapper) { + this.deviceTubeMapper = deviceTubeMapper; + } + + /** + * 获取点位信息 + * + * @return + */ + public Object deviceList(DataScope dataScope) { + ResponseData responseData = new ResponseData(); + try { + List> tubeWellList = deviceTubeMapper.deviceList(dataScope); + responseData.setCode(ResponseData.DEFAULT_SUCCESS_CODE); + responseData.setMessage(ResponseData.DEFAULT_SUCCESS_MESSAGE); + responseData.setData(tubeWellList); + } catch (DataAccessException sqlex) { + responseData.setCode(ResponseData.DEFAULT_ERROR_CODE); + responseData.setMessage("请求数据异常"); + responseData.setSuccess(true); + log.error("主题:获取点位信息列表出现异常,异常信息为{}", sqlex); + } + return responseData; + } + + /** + * 获取组列表信息 + * + * @param dataScope + * @return + */ + public Object deviceGroupsList(DataScope dataScope) { + ResponseData responseData = new ResponseData(); + try { + List> tubeDeviceList = deviceTubeMapper.deviceGroupsList(dataScope); + responseData.setCode(ResponseData.DEFAULT_SUCCESS_CODE); + responseData.setMessage(ResponseData.DEFAULT_SUCCESS_MESSAGE); + responseData.setData(tubeDeviceList); + } catch (DataAccessException sqlex) { + responseData.setCode(ResponseData.DEFAULT_ERROR_CODE); + responseData.setMessage("请求数据异常"); + responseData.setSuccess(true); + log.error("主题:数据上报保存出现错误,异常信息为{}", sqlex); + } + return responseData; + } + + /** + * 分页获取点位信息 + * + * @param oreder + * @param page + * @param wellGroupId + * @param dataScope + * @return + */ + public Object groupDeviceListPage(Integer oreder, Page> page, String wellGroupId, DataScope dataScope) { + ResponseData responseData = new ResponseData(); + try { + List> tubeDeviceList = deviceTubeMapper.groupDeviceListPage(page, wellGroupId, dataScope); + List> tubeDataDeviceList = new ArrayList<>(); + tubeDeviceList.forEach(tubeDevice -> { + Map tubeDeviceData = deviceTubeMapper.dataTubeByDevcode(tubeDevice.get("DEVCODE").toString()); + if (tubeDeviceData == null) { + tubeDeviceData = new HashMap<>(); + initTubeDeviceData(tubeDeviceData, tubeDevice.get("DEVCODE")); + } + tubeDeviceData.put("deviceName", tubeDevice.get("DEVICE_NAME")); + tubeDataDeviceList.add(tubeDeviceData); + } + ); + if (oreder != null && oreder == 0) { + resvertSortStrength(tubeDataDeviceList); + } else { + sortStrength(tubeDataDeviceList); + } + responseData.setCode(ResponseData.DEFAULT_SUCCESS_CODE); + responseData.setMessage(ResponseData.DEFAULT_SUCCESS_MESSAGE); + responseData.setData(tubeDataDeviceList); + } catch (DataAccessException sqlex) { + responseData.setCode(ResponseData.DEFAULT_ERROR_CODE); + responseData.setMessage("请求数据异常"); + responseData.setSuccess(true); + log.error("主题:数据上报保存出现错误,异常信息为{}", sqlex); + } + return responseData; + } + + /** + * 获取历史记录信息 + * + * @param page + * @param devcode + * @param beginTime + * @param endTime + * @return + */ + public Object tubeDataHistory(Page> page, String devcode, String beginTime, String endTime) { + ResponseData responseData = new ResponseData(); + try { + List> tubeDeviceList = deviceTubeMapper.tubeDataHistory(page, devcode, beginTime, endTime); + responseData.setCode(ResponseData.DEFAULT_SUCCESS_CODE); + responseData.setMessage(ResponseData.DEFAULT_SUCCESS_MESSAGE); + responseData.setData(tubeDeviceList); + } catch (DataAccessException sqlex) { + responseData.setCode(ResponseData.DEFAULT_ERROR_CODE); + responseData.setMessage("请求数据异常"); + responseData.setSuccess(true); + log.error("主题:数据上报保存出现错误,异常信息为{}", sqlex); + } + return responseData; + } + + /** + * 获取设备列表的信息 + * + * @param wellGroupId + * @return + */ + public Object groupDeviceList(String wellGroupId, DataScope dataScope) { + ResponseData responseData = new ResponseData(); + try { + List> tubeDeviceList = deviceTubeMapper.groupDeviceList(wellGroupId, dataScope); + responseData.setCode(ResponseData.DEFAULT_SUCCESS_CODE); + responseData.setMessage(ResponseData.DEFAULT_SUCCESS_MESSAGE); + responseData.setData(tubeDeviceList); + } catch (DataAccessException sqlex) { + responseData.setCode(ResponseData.DEFAULT_ERROR_CODE); + responseData.setMessage("请求数据异常"); + responseData.setSuccess(true); + log.error("主题:数据上报保存出现错误,异常信息为{}", sqlex); + } + return responseData; + } + + /** + * 获取详情信息 + */ + public Object deviceDetail(String id) { + ResponseData responseData = new ResponseData(); + try { + Map tubeDeviceData = deviceTubeMapper.deviceDetail(Long.valueOf(id)); + responseData.setCode(ResponseData.DEFAULT_SUCCESS_CODE); + responseData.setMessage(ResponseData.DEFAULT_SUCCESS_MESSAGE); + responseData.setData(tubeDeviceData); + } catch (DataAccessException sqlex) { + responseData.setCode(ResponseData.DEFAULT_ERROR_CODE); + responseData.setMessage("请求数据异常"); + responseData.setSuccess(true); + log.error("主题:数据上报保存出现错误,异常信息为{}", sqlex); + } + return responseData; + } + + + private void sortStrength(List> lstMap) { + Collections.sort(lstMap, new Comparator>() { + public int compare(Map o1, Map o2) { + return o1.get("strength").toString().compareTo(o2.get("strength").toString()); + } + }); + } + + private void initTubeDeviceData(Map tubeDeviceData, Object devcode) { + tubeDeviceData.put("deviceCode", devcode); + tubeDeviceData.put("strength", -1); + tubeDeviceData.put("uptime", new Date()); + tubeDeviceData.put("strength", -1); + tubeDeviceData.put("pci", ""); + tubeDeviceData.put("rsrp", ""); + tubeDeviceData.put("snr", ""); + tubeDeviceData.put("cell", ""); + tubeDeviceData.put("id", ""); + } + + private void resvertSortStrength(List> lstMap) { + Collections.sort(lstMap, new Comparator>() { + public int compare(Map o1, Map o2) { + return o2.get("strength").toString().compareTo(o1.get("strength").toString()); + } + }); + } +}