Commit 766dc496 authored by tangwei's avatar tangwei

增小程序监盘条件

parent 32c6a2b8
...@@ -96,4 +96,7 @@ public class JpInverterDto extends BaseDto { ...@@ -96,4 +96,7 @@ public class JpInverterDto extends BaseDto {
private String stationName; private String stationName;
private List<String> stationIds; private List<String> stationIds;
@ApiModelProperty(value = "所属电站名称")
private String name;
} }
...@@ -78,5 +78,5 @@ public class TdHygfJpInverterWarnDto { ...@@ -78,5 +78,5 @@ public class TdHygfJpInverterWarnDto {
private List<String> stationIds; private List<String> stationIds;
private List<String> states; private List<String> states;
private String name;
} }
...@@ -115,10 +115,19 @@ public class JpInverterController extends BaseController { ...@@ -115,10 +115,19 @@ public class JpInverterController extends BaseController {
@ApiOperation(httpMethod = "GET", value = "户用光伏监盘逆变器表分页查询", notes = "户用光伏监盘逆变器表分页查询") @ApiOperation(httpMethod = "GET", value = "户用光伏监盘逆变器表分页查询", notes = "户用光伏监盘逆变器表分页查询")
public ResponseModel<Page<JpInverterDto>> queryForPage(@RequestParam(value = "current") int current, public ResponseModel<Page<JpInverterDto>> queryForPage(@RequestParam(value = "current") int current,
@RequestParam(value = "size") int size, JpInverterDto jpInverterDto) { @RequestParam(value = "size") int size, JpInverterDto jpInverterDto) {
LambdaQueryWrapper<JpPersonStation> qug = new LambdaQueryWrapper<>(); List<JpPersonStation> pPersonStation =null;
qug.eq(JpPersonStation::getPersonId, getUserInfo().getUserId()); if(jpInverterDto.getName()!=null){
List<JpPersonStation> pPersonStation = pPersonStationMapper.selectList(qug); LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>();
qug1.like(JpPersonStation::getStationName,jpInverterDto.getName());
pPersonStation=pPersonStationMapper.selectList(qug1);
}else{
LambdaQueryWrapper<JpPersonStation> qug = new LambdaQueryWrapper<>();
qug.eq(JpPersonStation::getPersonId, getUserInfo().getUserId());
pPersonStation = pPersonStationMapper.selectList(qug);
}
if (!pPersonStation.isEmpty()) { if (!pPersonStation.isEmpty()) {
Page<JpInverterDto> page = new Page<JpInverterDto>(); Page<JpInverterDto> page = new Page<JpInverterDto>();
page.setCurrent(current); page.setCurrent(current);
......
...@@ -148,11 +148,19 @@ public class JpStationController extends BaseController { ...@@ -148,11 +148,19 @@ public class JpStationController extends BaseController {
@ApiOperation(httpMethod = "GET",value = "场站列表", notes = "场站列表") @ApiOperation(httpMethod = "GET",value = "场站列表", notes = "场站列表")
public ResponseModel< Map<String,Object> > countState(JpStationDto reviewDto) { public ResponseModel< Map<String,Object> > countState(JpStationDto reviewDto) {
Set<String> se=new HashSet<>();
List<JpPersonStation> pPersonStation=null;
if(reviewDto.getName()!=null){
LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>();
qug1.like(JpPersonStation::getStationName,reviewDto.getName());
pPersonStation=pPersonStationMapper.selectList(qug1);
}else{
//获取当前人管理场站 //获取当前人管理场站
LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>();
qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId()); qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId());
List<JpPersonStation> pPersonStation=pPersonStationMapper.selectList(qug); pPersonStation=pPersonStationMapper.selectList(qug);
reviewDto.setStatioId(pPersonStation.isEmpty()?null:pPersonStation); }
reviewDto.setStatioId(pPersonStation.isEmpty()?null:pPersonStation);
List<Map<String,Object>> list= jpStationMapper.countState(reviewDto); List<Map<String,Object>> list= jpStationMapper.countState(reviewDto);
Map<String,Object> collector =new HashMap<>(); Map<String,Object> collector =new HashMap<>();
collector.put("zx",0); collector.put("zx",0);
...@@ -177,10 +185,19 @@ public class JpStationController extends BaseController { ...@@ -177,10 +185,19 @@ public class JpStationController extends BaseController {
@ApiOperation(httpMethod = "GET",value = "设备监控", notes = "设备监控") @ApiOperation(httpMethod = "GET",value = "设备监控", notes = "设备监控")
public ResponseModel<Map<String,Object>> getpStation(JpStationDto reviewDto) { public ResponseModel<Map<String,Object>> getpStation(JpStationDto reviewDto) {
//获取当前人管理场站 List<JpPersonStation> pPersonStation=null;
LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>(); if(reviewDto.getName()!=null){
qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId()); LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>();
List<JpPersonStation> pPersonStation=pPersonStationMapper.selectList(qug); qug1.like(JpPersonStation::getStationName,reviewDto.getName());
pPersonStation=pPersonStationMapper.selectList(qug1);
}else{
//获取当前人管理场站
LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>();
qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId());
pPersonStation=pPersonStationMapper.selectList(qug);
}
if(pPersonStation!=null&&!pPersonStation.isEmpty()){ if(pPersonStation!=null&&!pPersonStation.isEmpty()){
reviewDto.setStatioId(pPersonStation.isEmpty()?null:pPersonStation); reviewDto.setStatioId(pPersonStation.isEmpty()?null:pPersonStation);
......
...@@ -133,9 +133,20 @@ public class TdHygfJpInverterWarnController extends BaseController { ...@@ -133,9 +133,20 @@ public class TdHygfJpInverterWarnController extends BaseController {
@ApiOperation(httpMethod = "GET", value = "户用光伏监盘逆变器报警表分页查询", notes = "户用光伏监盘逆变器报警表分页查询") @ApiOperation(httpMethod = "GET", value = "户用光伏监盘逆变器报警表分页查询", notes = "户用光伏监盘逆变器报警表分页查询")
public ResponseModel<Page<TdHygfJpInverterWarnDto>> queryForPage(@RequestParam(value = "current") int current, public ResponseModel<Page<TdHygfJpInverterWarnDto>> queryForPage(@RequestParam(value = "current") int current,
@RequestParam(value = "size") int size, TdHygfJpInverterWarnDto tdHygfJpInverterWarnDto) { @RequestParam(value = "size") int size, TdHygfJpInverterWarnDto tdHygfJpInverterWarnDto) {
LambdaQueryWrapper<JpPersonStation> qug = new LambdaQueryWrapper<>(); List<JpPersonStation> pPersonStation =null;
qug.eq(JpPersonStation::getPersonId, getUserInfo().getUserId()); if(tdHygfJpInverterWarnDto.getName()!=null){
List<JpPersonStation> pPersonStation = pPersonStationMapper.selectList(qug); LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>();
qug1.like(JpPersonStation::getStationName,tdHygfJpInverterWarnDto.getName());
pPersonStation=pPersonStationMapper.selectList(qug1);
}else{
LambdaQueryWrapper<JpPersonStation> qug = new LambdaQueryWrapper<>();
qug.eq(JpPersonStation::getPersonId, getUserInfo().getUserId());
pPersonStation = pPersonStationMapper.selectList(qug);
}
if (!pPersonStation.isEmpty()) { if (!pPersonStation.isEmpty()) {
Page<TdHygfJpInverterWarnDto> page = new Page<TdHygfJpInverterWarnDto>(); Page<TdHygfJpInverterWarnDto> page = new Page<TdHygfJpInverterWarnDto>();
...@@ -171,6 +182,12 @@ public class TdHygfJpInverterWarnController extends BaseController { ...@@ -171,6 +182,12 @@ public class TdHygfJpInverterWarnController extends BaseController {
@GetMapping(value = "/selectcount") @GetMapping(value = "/selectcount")
public ResponseModel< Map<String,Object> > selectcount(JpStationDto reviewDto) { public ResponseModel< Map<String,Object> > selectcount(JpStationDto reviewDto) {
LambdaQueryWrapper<JpStation> qugda=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpStation> qugda=new LambdaQueryWrapper<>();
//获取当前人管理场站 //获取当前人管理场站
if(reviewDto.getThirdStationId()==null){ if(reviewDto.getThirdStationId()==null){
//获取当前人管理场站 //获取当前人管理场站
...@@ -194,7 +211,7 @@ public class TdHygfJpInverterWarnController extends BaseController { ...@@ -194,7 +211,7 @@ public class TdHygfJpInverterWarnController extends BaseController {
}else{ }else{
qugda.eq(JpStation::getThirdStationId,reviewDto.getThirdStationId()); qugda.eq(JpStation::getThirdStationId,reviewDto.getThirdStationId());
} }
qugda.like(reviewDto.getUserName()!=null,JpStation::getUserName,reviewDto.getUserName()); qugda.like(reviewDto.getName()!=null,JpStation::getName,reviewDto.getName());
qugda.like(reviewDto.getArea()!=null,JpStation::getArea,reviewDto.getArea()); qugda.like(reviewDto.getArea()!=null,JpStation::getArea,reviewDto.getArea());
List<JpStation> pPersonStation=jpStationMapper.selectList(qugda); List<JpStation> pPersonStation=jpStationMapper.selectList(qugda);
List<Map<String,Object>> datalist= tdHygfJpInverterWarnMapper.getCountTdHygfJpInverterWarn(pPersonStation!=null&&!pPersonStation.isEmpty()?pPersonStation:null); List<Map<String,Object>> datalist= tdHygfJpInverterWarnMapper.getCountTdHygfJpInverterWarn(pPersonStation!=null&&!pPersonStation.isEmpty()?pPersonStation:null);
......
...@@ -42,6 +42,11 @@ public class JpCollectorServiceImpl extends BaseService<JpCollectorDto, JpCollec ...@@ -42,6 +42,11 @@ public class JpCollectorServiceImpl extends BaseService<JpCollectorDto, JpCollec
if (!jpCollectorDto.getStationIds().isEmpty()) { if (!jpCollectorDto.getStationIds().isEmpty()) {
wrapper.in(JpCollector::getThirdStationId, jpCollectorDto.getStationIds()); wrapper.in(JpCollector::getThirdStationId, jpCollectorDto.getStationIds());
} }
if (!jpCollectorDto.getSnCode().isEmpty()) {
wrapper.like(JpCollector::getSnCode, jpCollectorDto.getSnCode());
}
entiryPage = (Page<JpCollector>) this.page(entiryPage, wrapper); entiryPage = (Page<JpCollector>) this.page(entiryPage, wrapper);
if (!ValidationUtil.isEmpty(entiryPage.getRecords())) { if (!ValidationUtil.isEmpty(entiryPage.getRecords())) {
page.setTotal(entiryPage.getTotal()); page.setTotal(entiryPage.getTotal());
......
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