Commit 90287ef8 authored by caotao's avatar caotao

更新场站相关代码

parent 1fec7d86
package com.yeejoin.amos.boot.module.jxiop.api.mapper; package com.yeejoin.amos.boot.module.jxiop.api.mapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.dto.ExStationBasicDto; import com.yeejoin.amos.boot.module.jxiop.api.dto.*;
import com.yeejoin.amos.boot.module.jxiop.api.dto.StationBasicDto;
import com.yeejoin.amos.boot.module.jxiop.api.dto.StationInfoDto;
import com.yeejoin.amos.boot.module.jxiop.api.dto.StationRecordInfo;
import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic; import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
...@@ -46,5 +43,10 @@ public interface StationBasicMapper extends BaseMapper<StationBasic> { ...@@ -46,5 +43,10 @@ public interface StationBasicMapper extends BaseMapper<StationBasic> {
int deleteStationCoordinateByStationid (@Param("sequence_nbr") Long sequence_nbr ); int deleteStationCoordinateByStationid (@Param("sequence_nbr") Long sequence_nbr );
int getStationPersonByStationID (@Param("sequence_nbr") String sequence_nbr ); int getStationPersonByStationID (@Param("sequence_nbr") String sequence_nbr );
/**
* 获取场站相关信息
* @return List<StationTaksDto>
*/
List<StationTaksDto> getStationBasicDtoList();
} }
...@@ -11,10 +11,7 @@ import java.util.List; ...@@ -11,10 +11,7 @@ import java.util.List;
* @createDate: 2023/7/3 * @createDate: 2023/7/3
*/ */
public interface IMonitorFanIndicator { public interface IMonitorFanIndicator {
//批量修改指标值 //批量修改指标值
void UpdateMonitorFanIndicator(List<IndexDto> list); void UpdateMonitorFanIndicator(List<IndexDto> list);
} }
...@@ -142,5 +142,11 @@ ...@@ -142,5 +142,11 @@
WHERE WHERE
station_basic.sequence_nbr = #{sequence_nbr} station_basic.sequence_nbr = #{sequence_nbr}
</select> </select>
<select id="getStationBasicDtoList" resultType="com.yeejoin.amos.boot.module.jxiop.api.dto.StationBasicDto">
SELECT
station_number stationNumber,
gateway_id gateway
FROM
station_basic
</select>
</mapper> </mapper>
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.yeejoin.amos.boot.biz.common.utils.NameUtils;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.module.jxiop.api.service.IMonitorFanAlarmInfoService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import javax.servlet.http.HttpServletRequest;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.entity.MonitorFanAlarmInfo;
import java.lang.reflect.Field;
import java.util.Arrays;
/**
*
*
* @author duanwei
* @date 2023-06-30
*/
@RestController
@Api(tags = "Api")
@RequestMapping(value = "/monitor-fan-alarm-info", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class MonitorFanAlarmInfoController {
@Autowired
IMonitorFanAlarmInfoService iMonitorFanAlarmInfoService;
/**
* 新增
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST)
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public boolean saveMonitorFanAlarmInfo(HttpServletRequest request, @RequestBody MonitorFanAlarmInfo monitorFanAlarmInfo){
return iMonitorFanAlarmInfoService.save(monitorFanAlarmInfo);
}
/**
* 根据id删除
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
@ApiOperation(httpMethod = "DELETE", value = "根据id删除", notes = "根据id删除")
public boolean deleteById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanAlarmInfoService.removeById(id);
}
/**
* 修改
* @return
*/
@RequestMapping(value = "/updateById", method = RequestMethod.PUT)
@ApiOperation(httpMethod = "PUT", value = "修改", notes = "修改")
public boolean updateByIdMonitorFanAlarmInfo(HttpServletRequest request, @RequestBody MonitorFanAlarmInfo monitorFanAlarmInfo){
return iMonitorFanAlarmInfoService.updateById(monitorFanAlarmInfo);
}
/**
* 根据id查询
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "根据id查询", notes = "根据id查询")
public MonitorFanAlarmInfo selectById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanAlarmInfoService.getById(id);
}
/**
* 列表分页查询
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
public IPage<MonitorFanAlarmInfo> listPage(String pageNum,String pageSize,
MonitorFanAlarmInfo monitorFanAlarmInfo){
Page<MonitorFanAlarmInfo> pageBean;
QueryWrapper<MonitorFanAlarmInfo> monitorFanAlarmInfoQueryWrapper = new QueryWrapper<>();
Class<? extends MonitorFanAlarmInfo> aClass = monitorFanAlarmInfo.getClass();
Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
try {
field.setAccessible(true);
Object o = field.get(monitorFanAlarmInfo);
if (o != null) {
Class<?> type = field.getType();
String name = NameUtils.camel2Underline(field.getName());
if (type.equals(Integer.class)) {
Integer fileValue = (Integer) field.get(monitorFanAlarmInfo);
monitorFanAlarmInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(Long.class)) {
Long fileValue = (Long) field.get(monitorFanAlarmInfo);
monitorFanAlarmInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(String.class)) {
String fileValue = (String) field.get(monitorFanAlarmInfo);
monitorFanAlarmInfoQueryWrapper.eq(name, fileValue);
} else {
String fileValue = (String) field.get(monitorFanAlarmInfo);
monitorFanAlarmInfoQueryWrapper.eq(name, fileValue);
}
}
}catch (Exception e) {
}
});
IPage<MonitorFanAlarmInfo> page;
if (StringUtils.isBlank(pageNum) ||StringUtils.isBlank(pageSize)) {
pageBean = new Page<>(0, Long.MAX_VALUE);
}else{
pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
}
page = iMonitorFanAlarmInfoService.page(pageBean, monitorFanAlarmInfoQueryWrapper);
return page;
}
}
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.yeejoin.amos.boot.biz.common.utils.NameUtils;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.module.jxiop.api.service.IMonitorFanInfoService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import javax.servlet.http.HttpServletRequest;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.entity.MonitorFanInfo;
import java.lang.reflect.Field;
import java.util.Arrays;
/**
*
*
* @author duanwei
* @date 2023-06-30
*/
@RestController
@Api(tags = "Api")
@RequestMapping(value = "/monitor-fan-info", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class MonitorFanInfoController {
@Autowired
IMonitorFanInfoService iMonitorFanInfoService;
/**
* 新增
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST)
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public boolean saveMonitorFanInfo(HttpServletRequest request, @RequestBody MonitorFanInfo monitorFanInfo){
return iMonitorFanInfoService.save(monitorFanInfo);
}
/**
* 根据id删除
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
@ApiOperation(httpMethod = "DELETE", value = "根据id删除", notes = "根据id删除")
public boolean deleteById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanInfoService.removeById(id);
}
/**
* 修改
* @return
*/
@RequestMapping(value = "/updateById", method = RequestMethod.PUT)
@ApiOperation(httpMethod = "PUT", value = "修改", notes = "修改")
public boolean updateByIdMonitorFanInfo(HttpServletRequest request, @RequestBody MonitorFanInfo monitorFanInfo){
return iMonitorFanInfoService.updateById(monitorFanInfo);
}
/**
* 根据id查询
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "根据id查询", notes = "根据id查询")
public MonitorFanInfo selectById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanInfoService.getById(id);
}
/**
* 列表分页查询
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
public IPage<MonitorFanInfo> listPage(String pageNum,String pageSize,
MonitorFanInfo monitorFanInfo){
Page<MonitorFanInfo> pageBean;
QueryWrapper<MonitorFanInfo> monitorFanInfoQueryWrapper = new QueryWrapper<>();
Class<? extends MonitorFanInfo> aClass = monitorFanInfo.getClass();
Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
try {
field.setAccessible(true);
Object o = field.get(monitorFanInfo);
if (o != null) {
Class<?> type = field.getType();
String name = NameUtils.camel2Underline(field.getName());
if (type.equals(Integer.class)) {
Integer fileValue = (Integer) field.get(monitorFanInfo);
monitorFanInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(Long.class)) {
Long fileValue = (Long) field.get(monitorFanInfo);
monitorFanInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(String.class)) {
String fileValue = (String) field.get(monitorFanInfo);
monitorFanInfoQueryWrapper.eq(name, fileValue);
} else {
String fileValue = (String) field.get(monitorFanInfo);
monitorFanInfoQueryWrapper.eq(name, fileValue);
}
}
}catch (Exception e) {
}
});
IPage<MonitorFanInfo> page;
if (StringUtils.isBlank(pageNum) ||StringUtils.isBlank(pageSize)) {
pageBean = new Page<>(0, Long.MAX_VALUE);
}else{
pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
}
page = iMonitorFanInfoService.page(pageBean, monitorFanInfoQueryWrapper);
return page;
}
}
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.yeejoin.amos.boot.biz.common.utils.NameUtils;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.module.jxiop.api.service.IMonitorFanRealtimeMonitoringService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import javax.servlet.http.HttpServletRequest;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.entity.MonitorFanRealtimeMonitoring;
import java.lang.reflect.Field;
import java.util.Arrays;
/**
*
*
* @author duanwei
* @date 2023-06-30
*/
@RestController
@Api(tags = "Api")
@RequestMapping(value = "/monitor-fan-realtime-monitoring", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class MonitorFanRealtimeMonitoringController {
@Autowired
IMonitorFanRealtimeMonitoringService iMonitorFanRealtimeMonitoringService;
/**
* 新增
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST)
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public boolean saveMonitorFanRealtimeMonitoring(HttpServletRequest request, @RequestBody MonitorFanRealtimeMonitoring monitorFanRealtimeMonitoring){
return iMonitorFanRealtimeMonitoringService.save(monitorFanRealtimeMonitoring);
}
/**
* 根据id删除
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
@ApiOperation(httpMethod = "DELETE", value = "根据id删除", notes = "根据id删除")
public boolean deleteById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanRealtimeMonitoringService.removeById(id);
}
/**
* 修改
* @return
*/
@RequestMapping(value = "/updateById", method = RequestMethod.PUT)
@ApiOperation(httpMethod = "PUT", value = "修改", notes = "修改")
public boolean updateByIdMonitorFanRealtimeMonitoring(HttpServletRequest request, @RequestBody MonitorFanRealtimeMonitoring monitorFanRealtimeMonitoring){
return iMonitorFanRealtimeMonitoringService.updateById(monitorFanRealtimeMonitoring);
}
/**
* 根据id查询
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "根据id查询", notes = "根据id查询")
public MonitorFanRealtimeMonitoring selectById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanRealtimeMonitoringService.getById(id);
}
/**
* 列表分页查询
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
public IPage<MonitorFanRealtimeMonitoring> listPage(String pageNum,String pageSize,
MonitorFanRealtimeMonitoring monitorFanRealtimeMonitoring){
Page<MonitorFanRealtimeMonitoring> pageBean;
QueryWrapper<MonitorFanRealtimeMonitoring> monitorFanRealtimeMonitoringQueryWrapper = new QueryWrapper<>();
Class<? extends MonitorFanRealtimeMonitoring> aClass = monitorFanRealtimeMonitoring.getClass();
Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
try {
field.setAccessible(true);
Object o = field.get(monitorFanRealtimeMonitoring);
if (o != null) {
Class<?> type = field.getType();
String name = NameUtils.camel2Underline(field.getName());
if (type.equals(Integer.class)) {
Integer fileValue = (Integer) field.get(monitorFanRealtimeMonitoring);
monitorFanRealtimeMonitoringQueryWrapper.eq(name, fileValue);
} else if (type.equals(Long.class)) {
Long fileValue = (Long) field.get(monitorFanRealtimeMonitoring);
monitorFanRealtimeMonitoringQueryWrapper.eq(name, fileValue);
} else if (type.equals(String.class)) {
String fileValue = (String) field.get(monitorFanRealtimeMonitoring);
monitorFanRealtimeMonitoringQueryWrapper.eq(name, fileValue);
} else {
String fileValue = (String) field.get(monitorFanRealtimeMonitoring);
monitorFanRealtimeMonitoringQueryWrapper.eq(name, fileValue);
}
}
}catch (Exception e) {
}
});
IPage<MonitorFanRealtimeMonitoring> page;
if (StringUtils.isBlank(pageNum) ||StringUtils.isBlank(pageSize)) {
pageBean = new Page<>(0, Long.MAX_VALUE);
}else{
pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
}
page = iMonitorFanRealtimeMonitoringService.page(pageBean, monitorFanRealtimeMonitoringQueryWrapper);
return page;
}
}
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.yeejoin.amos.boot.biz.common.utils.NameUtils;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.module.jxiop.api.service.IMonitorFanRealtimeRunningService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import javax.servlet.http.HttpServletRequest;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.entity.MonitorFanRealtimeRunning;
import java.lang.reflect.Field;
import java.util.Arrays;
/**
*
*
* @author duanwei
* @date 2023-06-30
*/
@RestController
@Api(tags = "Api")
@RequestMapping(value = "/monitor-fan-realtime-running", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class MonitorFanRealtimeRunningController {
@Autowired
IMonitorFanRealtimeRunningService iMonitorFanRealtimeRunningService;
/**
* 新增
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST)
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public boolean saveMonitorFanRealtimeRunning(HttpServletRequest request, @RequestBody MonitorFanRealtimeRunning monitorFanRealtimeRunning){
return iMonitorFanRealtimeRunningService.save(monitorFanRealtimeRunning);
}
/**
* 根据id删除
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
@ApiOperation(httpMethod = "DELETE", value = "根据id删除", notes = "根据id删除")
public boolean deleteById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanRealtimeRunningService.removeById(id);
}
/**
* 修改
* @return
*/
@RequestMapping(value = "/updateById", method = RequestMethod.PUT)
@ApiOperation(httpMethod = "PUT", value = "修改", notes = "修改")
public boolean updateByIdMonitorFanRealtimeRunning(HttpServletRequest request, @RequestBody MonitorFanRealtimeRunning monitorFanRealtimeRunning){
return iMonitorFanRealtimeRunningService.updateById(monitorFanRealtimeRunning);
}
/**
* 根据id查询
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "根据id查询", notes = "根据id查询")
public MonitorFanRealtimeRunning selectById(HttpServletRequest request, @PathVariable Long id){
return iMonitorFanRealtimeRunningService.getById(id);
}
/**
* 列表分页查询
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
public IPage<MonitorFanRealtimeRunning> listPage(String pageNum,String pageSize,
MonitorFanRealtimeRunning monitorFanRealtimeRunning){
Page<MonitorFanRealtimeRunning> pageBean;
QueryWrapper<MonitorFanRealtimeRunning> monitorFanRealtimeRunningQueryWrapper = new QueryWrapper<>();
Class<? extends MonitorFanRealtimeRunning> aClass = monitorFanRealtimeRunning.getClass();
Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
try {
field.setAccessible(true);
Object o = field.get(monitorFanRealtimeRunning);
if (o != null) {
Class<?> type = field.getType();
String name = NameUtils.camel2Underline(field.getName());
if (type.equals(Integer.class)) {
Integer fileValue = (Integer) field.get(monitorFanRealtimeRunning);
monitorFanRealtimeRunningQueryWrapper.eq(name, fileValue);
} else if (type.equals(Long.class)) {
Long fileValue = (Long) field.get(monitorFanRealtimeRunning);
monitorFanRealtimeRunningQueryWrapper.eq(name, fileValue);
} else if (type.equals(String.class)) {
String fileValue = (String) field.get(monitorFanRealtimeRunning);
monitorFanRealtimeRunningQueryWrapper.eq(name, fileValue);
} else {
String fileValue = (String) field.get(monitorFanRealtimeRunning);
monitorFanRealtimeRunningQueryWrapper.eq(name, fileValue);
}
}
}catch (Exception e) {
}
});
IPage<MonitorFanRealtimeRunning> page;
if (StringUtils.isBlank(pageNum) ||StringUtils.isBlank(pageSize)) {
pageBean = new Page<>(0, Long.MAX_VALUE);
}else{
pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
}
page = iMonitorFanRealtimeRunningService.page(pageBean, monitorFanRealtimeRunningQueryWrapper);
return page;
}
}
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.yeejoin.amos.boot.biz.common.utils.NameUtils;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.module.jxiop.api.service.IMonitorPowerInfoService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import javax.servlet.http.HttpServletRequest;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.entity.MonitorPowerInfo;
import java.lang.reflect.Field;
import java.util.Arrays;
/**
*
*
* @author duanwei
* @date 2023-06-30
*/
@RestController
@Api(tags = "Api")
@RequestMapping(value = "/monitor-power-info", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class MonitorPowerInfoController {
@Autowired
IMonitorPowerInfoService iMonitorPowerInfoService;
/**
* 新增
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST)
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public boolean saveMonitorPowerInfo(HttpServletRequest request, @RequestBody MonitorPowerInfo monitorPowerInfo){
return iMonitorPowerInfoService.save(monitorPowerInfo);
}
/**
* 根据id删除
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
@ApiOperation(httpMethod = "DELETE", value = "根据id删除", notes = "根据id删除")
public boolean deleteById(HttpServletRequest request, @PathVariable Long id){
return iMonitorPowerInfoService.removeById(id);
}
/**
* 修改
* @return
*/
@RequestMapping(value = "/updateById", method = RequestMethod.PUT)
@ApiOperation(httpMethod = "PUT", value = "修改", notes = "修改")
public boolean updateByIdMonitorPowerInfo(HttpServletRequest request, @RequestBody MonitorPowerInfo monitorPowerInfo){
return iMonitorPowerInfoService.updateById(monitorPowerInfo);
}
/**
* 根据id查询
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "根据id查询", notes = "根据id查询")
public MonitorPowerInfo selectById(HttpServletRequest request, @PathVariable Long id){
return iMonitorPowerInfoService.getById(id);
}
/**
* 列表分页查询
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
public IPage<MonitorPowerInfo> listPage(String pageNum,String pageSize,
MonitorPowerInfo monitorPowerInfo){
Page<MonitorPowerInfo> pageBean;
QueryWrapper<MonitorPowerInfo> monitorPowerInfoQueryWrapper = new QueryWrapper<>();
Class<? extends MonitorPowerInfo> aClass = monitorPowerInfo.getClass();
Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
try {
field.setAccessible(true);
Object o = field.get(monitorPowerInfo);
if (o != null) {
Class<?> type = field.getType();
String name = NameUtils.camel2Underline(field.getName());
if (type.equals(Integer.class)) {
Integer fileValue = (Integer) field.get(monitorPowerInfo);
monitorPowerInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(Long.class)) {
Long fileValue = (Long) field.get(monitorPowerInfo);
monitorPowerInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(String.class)) {
String fileValue = (String) field.get(monitorPowerInfo);
monitorPowerInfoQueryWrapper.eq(name, fileValue);
} else {
String fileValue = (String) field.get(monitorPowerInfo);
monitorPowerInfoQueryWrapper.eq(name, fileValue);
}
}
}catch (Exception e) {
}
});
IPage<MonitorPowerInfo> page;
if (StringUtils.isBlank(pageNum) ||StringUtils.isBlank(pageSize)) {
pageBean = new Page<>(0, Long.MAX_VALUE);
}else{
pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
}
page = iMonitorPowerInfoService.page(pageBean, monitorPowerInfoQueryWrapper);
return page;
}
}
package com.yeejoin.amos.boot.module.jxiop.biz.controller;
import com.yeejoin.amos.boot.biz.common.utils.NameUtils;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.module.jxiop.api.service.IMonitorStationInfoService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import javax.servlet.http.HttpServletRequest;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.entity.MonitorStationInfo;
import java.lang.reflect.Field;
import java.util.Arrays;
/**
*
*
* @author duanwei
* @date 2023-06-30
*/
@RestController
@Api(tags = "Api")
@RequestMapping(value = "/monitor-station-info", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class MonitorStationInfoController {
@Autowired
IMonitorStationInfoService iMonitorStationInfoService;
/**
* 新增
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST)
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public boolean saveMonitorStationInfo(HttpServletRequest request, @RequestBody MonitorStationInfo monitorStationInfo){
return iMonitorStationInfoService.save(monitorStationInfo);
}
/**
* 根据id删除
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
@ApiOperation(httpMethod = "DELETE", value = "根据id删除", notes = "根据id删除")
public boolean deleteById(HttpServletRequest request, @PathVariable Long id){
return iMonitorStationInfoService.removeById(id);
}
/**
* 修改
* @return
*/
@RequestMapping(value = "/updateById", method = RequestMethod.PUT)
@ApiOperation(httpMethod = "PUT", value = "修改", notes = "修改")
public boolean updateByIdMonitorStationInfo(HttpServletRequest request, @RequestBody MonitorStationInfo monitorStationInfo){
return iMonitorStationInfoService.updateById(monitorStationInfo);
}
/**
* 根据id查询
* @param id
* @return
*/
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "根据id查询", notes = "根据id查询")
public MonitorStationInfo selectById(HttpServletRequest request, @PathVariable Long id){
return iMonitorStationInfoService.getById(id);
}
/**
* 列表分页查询
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
public IPage<MonitorStationInfo> listPage(String pageNum,String pageSize,
MonitorStationInfo monitorStationInfo){
Page<MonitorStationInfo> pageBean;
QueryWrapper<MonitorStationInfo> monitorStationInfoQueryWrapper = new QueryWrapper<>();
Class<? extends MonitorStationInfo> aClass = monitorStationInfo.getClass();
Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
try {
field.setAccessible(true);
Object o = field.get(monitorStationInfo);
if (o != null) {
Class<?> type = field.getType();
String name = NameUtils.camel2Underline(field.getName());
if (type.equals(Integer.class)) {
Integer fileValue = (Integer) field.get(monitorStationInfo);
monitorStationInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(Long.class)) {
Long fileValue = (Long) field.get(monitorStationInfo);
monitorStationInfoQueryWrapper.eq(name, fileValue);
} else if (type.equals(String.class)) {
String fileValue = (String) field.get(monitorStationInfo);
monitorStationInfoQueryWrapper.eq(name, fileValue);
} else {
String fileValue = (String) field.get(monitorStationInfo);
monitorStationInfoQueryWrapper.eq(name, fileValue);
}
}
}catch (Exception e) {
}
});
IPage<MonitorStationInfo> page;
if (StringUtils.isBlank(pageNum) ||StringUtils.isBlank(pageSize)) {
pageBean = new Page<>(0, Long.MAX_VALUE);
}else{
pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
}
page = iMonitorStationInfoService.page(pageBean, monitorStationInfoQueryWrapper);
return page;
}
}
...@@ -172,7 +172,7 @@ public class StationBasicController extends BaseController { ...@@ -172,7 +172,7 @@ public class StationBasicController extends BaseController {
* *
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "场站地图数据", notes = "场站地图数据") @ApiOperation(httpMethod = "GET", value = "场站地图数据", notes = "场站地图数据")
@GetMapping(value = "/listforMap") @GetMapping(value = "/listforMap")
public ResponseModel<List<StationInfoDto>> getStationList(@RequestParam(value = "areaCode", required = false) String areaCode,@RequestParam(value = "type", required = false) String type) { public ResponseModel<List<StationInfoDto>> getStationList(@RequestParam(value = "areaCode", required = false) String areaCode,@RequestParam(value = "type", required = false) String type) {
......
...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.jxiop.api.dto.StationBasicDto; import com.yeejoin.amos.boot.module.jxiop.api.dto.StationBasicDto;
import com.yeejoin.amos.boot.module.jxiop.api.dto.StationInfoDto; import com.yeejoin.amos.boot.module.jxiop.api.dto.StationInfoDto;
import com.yeejoin.amos.boot.module.jxiop.api.dto.StationRecordInfo; import com.yeejoin.amos.boot.module.jxiop.api.dto.StationRecordInfo;
import com.yeejoin.amos.boot.module.jxiop.api.dto.StationTaksDto;
import com.yeejoin.amos.boot.module.jxiop.api.entity.*; import com.yeejoin.amos.boot.module.jxiop.api.entity.*;
import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper; import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
import com.yeejoin.amos.boot.module.jxiop.api.service.IStationBasicService; import com.yeejoin.amos.boot.module.jxiop.api.service.IStationBasicService;
...@@ -164,4 +165,8 @@ public class StationBasicServiceImpl extends BaseService<StationBasicDto, Statio ...@@ -164,4 +165,8 @@ public class StationBasicServiceImpl extends BaseService<StationBasicDto, Statio
} }
public List<StationTaksDto> getStationTaksDtoList(){
return stationBasicMapper.getStationBasicDtoList();
}
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment