Skip to content

A
amos-boot-biz
Commit 315e9dc7 authored by caotao's avatar caotao
Browse files
Options

户用光伏-运维工单代码调整。

parent fdd6fa0b
Show whitespace changes
Inline Side-by-side
Showing with 374 additions and 316 deletions
amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/JpStation.java
View file @ 315e9dc7
...@@ -8,6 +8,7 @@ import lombok.EqualsAndHashCode; ...@@ -8,6 +8,7 @@ import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import java.util.Date; import java.util.Date;
import java.util.List;
/** /**
* 第三方场站 * 第三方场站
...@@ -218,4 +219,7 @@ public class JpStation extends BaseEntity { ...@@ -218,4 +219,7 @@ public class JpStation extends BaseEntity {
@TableField("amos_company_code") @TableField("amos_company_code")
private String amosCompanyCode; private String amosCompanyCode;
@TableField(exist = false)
private List<String> snCodes;
} }
amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/JpStationMapper.java
View file @ 315e9dc7
...@@ -27,6 +27,8 @@ public interface JpStationMapper extends BaseMapper<JpStation> { ...@@ -27,6 +27,8 @@ public interface JpStationMapper extends BaseMapper<JpStation> {
@UserEmpower(field ={"regional_companies_code","amos_company_code"} ,fieldConditions ={"in","in"} ,relationship="and") @UserEmpower(field ={"regional_companies_code","amos_company_code"} ,fieldConditions ={"in","in"} ,relationship="and")
List<JpStation> getJpStation(@Param("dto") JpStationDto reviewDto); List<JpStation> getJpStation(@Param("dto") JpStationDto reviewDto);
List<JpStation> getJpStationList(@Param("dto") JpStationDto reviewDto);
@UserEmpower(field ={"ORG_CODE"} ,fieldConditions ={"in"} ,relationship="") @UserEmpower(field ={"ORG_CODE"} ,fieldConditions ={"in"} ,relationship="")
List<DropDown> getRegion(); List<DropDown> getRegion();
......
amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/mysql/JpStationMapper.xml
View file @ 315e9dc7
...@@ -200,6 +200,47 @@ ...@@ -200,6 +200,47 @@
</where> </where>
</select> </select>
<select id="getJpStationList" resultType="com.yeejoin.amos.boot.module.hygf.api.entity.JpStation">
select
*
from hygf_jp_station
<where>
is_delete=0
<if test="dto.name!=null">
and hygf_jp_station.name like concat(concat("%",#{dto.name}),"%")
</if>
<if test="dto.userName!=null">
and hygf_jp_station.user_name like concat(concat("%",#{dto.userName}),"%")
</if>
<if test="dto.address!=null">
and hygf_jp_station.address like concat(concat("%",#{dto.address}),"%")
</if>
<if test="dto.area!=null">
and hygf_jp_station.area like concat(concat("%",#{dto.area}),"%")
</if>
<if test="dto.thirdStationIds!=null and dto.thirdStationIds.size()> 0 ">
and hygf_jp_station.third_station_id in
<foreach collection="dto.thirdStationIds" item="item" index="index" open="(" separator="," close=")">
#{item}
</foreach>
</if>
<if test="dto.thirdStationId!=null">
and hygf_jp_station.third_station_id =#{dto.thirdStationId}
</if>
<if test="dto.regionalCompaniesCode!=null and dto.regionalCompaniesCode!=''">
and hygf_jp_station.regional_companies_code =#{dto.regionalCompaniesCode}
</if>
<if test="dto.amosCompanyCode!=null and dto.amosCompanyCode!=''">
and hygf_jp_station.amos_company_code =#{dto.amosCompanyCode}
</if>
<if test="dto.state!=null">
and hygf_jp_station.`state` =#{dto.state}
</if>
</where>
</select>
<select id="getRegion" resultType="com.yeejoin.amos.boot.module.hygf.api.dto.DropDown"> <select id="getRegion" resultType="com.yeejoin.amos.boot.module.hygf.api.dto.DropDown">
SELECT privilege_company.ORG_CODE orgCode , SELECT privilege_company.ORG_CODE orgCode ,
privilege_company.COMPANY_NAME name privilege_company.COMPANY_NAME name
......
amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/JpStationController.java
View file @ 315e9dc7
...@@ -36,6 +36,14 @@ import java.util.stream.Collectors; ...@@ -36,6 +36,14 @@ import java.util.stream.Collectors;
@RequestMapping(value = "/jp-station") @RequestMapping(value = "/jp-station")
public class JpStationController extends BaseController { public class JpStationController extends BaseController {
private static Double CARBON = 0.997 * 0.001;
private static Double SULFUR = 0.03 * 0.001;
private static Double DUST = 0.272 * 0.001;
private static Double COAL = 0.4 * 0.001;
private static String ZX = "在线";
private static String LX = "离线";
private static String BJ = "报警";
private static int FDXSS = 1000;
@Autowired @Autowired
JpStationServiceImpl jpStationServiceImpl; JpStationServiceImpl jpStationServiceImpl;
@Autowired @Autowired
...@@ -46,20 +54,11 @@ public class JpStationController extends BaseController { ...@@ -46,20 +54,11 @@ public class JpStationController extends BaseController {
JpCollectorMapper jpCollectorMapper; JpCollectorMapper jpCollectorMapper;
@Autowired @Autowired
JpInverterMapper jpInverterMapper; JpInverterMapper jpInverterMapper;
@Autowired @Autowired
DayGenerateServiceImpl dayGenerateServiceImpl; DayGenerateServiceImpl dayGenerateServiceImpl;
@Autowired @Autowired
RegionalCompaniesMapper regionalCompaniesMapper; RegionalCompaniesMapper regionalCompaniesMapper;
private static Double CARBON=0.997*0.001;
private static Double SULFUR=0.03*0.001;
private static Double DUST=0.272*0.001;
private static Double COAL=0.4*0.001;
private static String ZX="在线";
private static String LX="离线";
private static String BJ="报警";
private static int FDXSS=1000;
/** /**
* 新增第三方场站 * 新增第三方场站
* *
...@@ -82,7 +81,7 @@ public class JpStationController extends BaseController { ...@@ -82,7 +81,7 @@ public class JpStationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/{sequenceNbr}") @PutMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新第三方场站", notes = "根据sequenceNbr更新第三方场站") @ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新第三方场站", notes = "根据sequenceNbr更新第三方场站")
public ResponseModel<JpStationDto> updateBySequenceNbrJpStation(@RequestBody JpStationDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) { public ResponseModel<JpStationDto> updateBySequenceNbrJpStation(@RequestBody JpStationDto model, @PathVariable(value = "sequenceNbr") Long sequenceNbr) {
model.setSequenceNbr(sequenceNbr); model.setSequenceNbr(sequenceNbr);
return ResponseHelper.buildResponse(jpStationServiceImpl.updateWithModel(model)); return ResponseHelper.buildResponse(jpStationServiceImpl.updateWithModel(model));
} }
...@@ -96,7 +95,7 @@ public class JpStationController extends BaseController { ...@@ -96,7 +95,7 @@ public class JpStationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}") @DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除第三方场站", notes = "根据sequenceNbr删除第三方场站") @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除第三方场站", notes = "根据sequenceNbr删除第三方场站")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){ public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr) {
return ResponseHelper.buildResponse(jpStationServiceImpl.removeById(sequenceNbr)); return ResponseHelper.buildResponse(jpStationServiceImpl.removeById(sequenceNbr));
} }
...@@ -108,16 +107,16 @@ public class JpStationController extends BaseController { ...@@ -108,16 +107,16 @@ public class JpStationController extends BaseController {
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getBysequenceNbr") @GetMapping(value = "/getBysequenceNbr")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个第三方场站", notes = "根据sequenceNbr查询单个第三方场站") @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个第三方场站", notes = "根据sequenceNbr查询单个第三方场站")
public ResponseModel<JpStationDto> selectOne( String id) { public ResponseModel<JpStationDto> selectOne(String id) {
Long sequenceNbr=Long.valueOf(id); Long sequenceNbr = Long.valueOf(id);
JpStationDto jpStationDto= jpStationServiceImpl.queryBySeq(sequenceNbr); JpStationDto jpStationDto = jpStationServiceImpl.queryBySeq(sequenceNbr);
LambdaQueryWrapper<JpInverter> qug=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpInverter> qug = new LambdaQueryWrapper<>();
qug.eq(JpInverter::getThirdStationId,jpStationDto.getThirdStationId()); qug.eq(JpInverter::getThirdStationId, jpStationDto.getThirdStationId());
List<JpInverter> jpInverter=jpInverterMapper.selectList(qug); List<JpInverter> jpInverter = jpInverterMapper.selectList(qug);
LambdaQueryWrapper<JpCollector> qug1=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpCollector> qug1 = new LambdaQueryWrapper<>();
qug1.eq(JpCollector::getThirdStationId,jpStationDto.getThirdStationId()); qug1.eq(JpCollector::getThirdStationId, jpStationDto.getThirdStationId());
List<JpCollector> jpCollector=jpCollectorMapper.selectList(qug1); List<JpCollector> jpCollector = jpCollectorMapper.selectList(qug1);
jpStationDto.setJpCollector(jpCollector); jpStationDto.setJpCollector(jpCollector);
jpStationDto.setJpInverter(jpInverter); jpStationDto.setJpInverter(jpInverter);
// //区域公司 // //区域公司
...@@ -132,31 +131,31 @@ public class JpStationController extends BaseController { ...@@ -132,31 +131,31 @@ public class JpStationController extends BaseController {
// jpStationDto.setRegionalCompaniesName(personnelBusiness.getRegionalCompaniesName()); // jpStationDto.setRegionalCompaniesName(personnelBusiness.getRegionalCompaniesName());
return ResponseHelper.buildResponse(jpStationDto); return ResponseHelper.buildResponse(jpStationDto);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getBysequenceNbrnew") @GetMapping(value = "/getBysequenceNbrnew")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个第三方场站", notes = "根据sequenceNbr查询单个第三方场站") @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个第三方场站", notes = "根据sequenceNbr查询单个第三方场站")
public ResponseModel<JpStationDto> selectOneThirdStationId( String id) { public ResponseModel<JpStationDto> selectOneThirdStationId(String id) {
LambdaQueryWrapper<JpStation> qug3=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpStation> qug3 = new LambdaQueryWrapper<>();
qug3.eq(JpStation::getThirdStationId,id); qug3.eq(JpStation::getThirdStationId, id);
JpStation JpStation=jpStationMapper.selectOne(qug3); JpStation JpStation = jpStationMapper.selectOne(qug3);
JpStationDto jpStationDto= jpStationServiceImpl.queryBySeq(JpStation.getSequenceNbr()); JpStationDto jpStationDto = jpStationServiceImpl.queryBySeq(JpStation.getSequenceNbr());
LambdaQueryWrapper<JpInverter> qug=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpInverter> qug = new LambdaQueryWrapper<>();
qug.eq(JpInverter::getThirdStationId,jpStationDto.getThirdStationId()); qug.eq(JpInverter::getThirdStationId, jpStationDto.getThirdStationId());
List<JpInverter> jpInverter=jpInverterMapper.selectList(qug); List<JpInverter> jpInverter = jpInverterMapper.selectList(qug);
LambdaQueryWrapper<JpCollector> qug1=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpCollector> qug1 = new LambdaQueryWrapper<>();
qug1.eq(JpCollector::getThirdStationId,jpStationDto.getThirdStationId()); qug1.eq(JpCollector::getThirdStationId, jpStationDto.getThirdStationId());
List<JpCollector> jpCollector=jpCollectorMapper.selectList(qug1); List<JpCollector> jpCollector = jpCollectorMapper.selectList(qug1);
jpStationDto.setJpCollector(jpCollector); jpStationDto.setJpCollector(jpCollector);
jpStationDto.setJpInverter(jpInverter); jpStationDto.setJpInverter(jpInverter);
//区域公司 //区域公司
LambdaQueryWrapper<RegionalCompanies> qug2=new LambdaQueryWrapper<>(); LambdaQueryWrapper<RegionalCompanies> qug2 = new LambdaQueryWrapper<>();
qug2.eq(RegionalCompanies::getRegionalCompaniesCode,jpStationDto.getRegionalCompaniesCode()); qug2.eq(RegionalCompanies::getRegionalCompaniesCode, jpStationDto.getRegionalCompaniesCode());
qug2.last("LIMIT 1"); qug2.last("LIMIT 1");
RegionalCompanies personnelBusiness= regionalCompaniesMapper.selectOne(qug2); RegionalCompanies personnelBusiness = regionalCompaniesMapper.selectOne(qug2);
String names = jpCollector.stream().map(JpCollector::getSnCode).collect(Collectors.joining(",")); String names = jpCollector.stream().map(JpCollector::getSnCode).collect(Collectors.joining(","));
String name = jpInverter.stream().map(JpInverter::getSnCode).collect(Collectors.joining(",")); String name = jpInverter.stream().map(JpInverter::getSnCode).collect(Collectors.joining(","));
jpStationDto.setNbsn(name); jpStationDto.setNbsn(name);
...@@ -165,6 +164,7 @@ public class JpStationController extends BaseController { ...@@ -165,6 +164,7 @@ public class JpStationController extends BaseController {
jpStationDto.setRegionalCompaniesName(personnelBusiness.getRegionalCompaniesName()); jpStationDto.setRegionalCompaniesName(personnelBusiness.getRegionalCompaniesName());
return ResponseHelper.buildResponse(jpStationDto); return ResponseHelper.buildResponse(jpStationDto);
} }
/** /**
* 列表分页查询 * 列表分页查询
* *
...@@ -175,66 +175,67 @@ public class JpStationController extends BaseController { ...@@ -175,66 +175,67 @@ public class JpStationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/queryPage") @GetMapping(value = "/queryPage")
@ApiOperation(httpMethod = "GET",value = "场站列表", notes = "场站列表") @ApiOperation(httpMethod = "GET", value = "场站列表", notes = "场站列表")
public ResponseModel<Page<JpStationDto>> queryForDealerReviewPage(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<JpStationDto>> queryForDealerReviewPage(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size, JpStationDto reviewDto) { (value = "size") int size, JpStationDto reviewDto) {
List<JpPersonStation> pPersonStation=null; List<JpPersonStation> pPersonStation = null;
if(reviewDto.getName()!=null&&!"".equals(reviewDto.getName())){ if (reviewDto.getName() != null && !"".equals(reviewDto.getName())) {
LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug1 = new LambdaQueryWrapper<>();
qug1.like(JpPersonStation::getStationName,reviewDto.getName()); qug1.like(JpPersonStation::getStationName, reviewDto.getName());
pPersonStation=pPersonStationMapper.selectList(qug1); pPersonStation = pPersonStationMapper.selectList(qug1);
}else{ } else {
//获取当前人管理场站 //获取当前人管理场站
//获取当前人管理场站 //获取当前人管理场站
LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug = new LambdaQueryWrapper<>();
qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId()); qug.eq(JpPersonStation::getPersonId, getUserInfo().getUserId());
pPersonStation=pPersonStationMapper.selectList(qug); pPersonStation = pPersonStationMapper.selectList(qug);
} }
// if(reviewDto.getThirdStationId()==null){ // if(reviewDto.getThirdStationId()==null){
if(pPersonStation!=null&&!pPersonStation.isEmpty()){ if (pPersonStation != null && !pPersonStation.isEmpty()) {
reviewDto.setStatioId(pPersonStation.isEmpty()?null:pPersonStation); reviewDto.setStatioId(pPersonStation.isEmpty() ? null : pPersonStation);
}else{ } else {
return ResponseHelper.buildResponse(null); return ResponseHelper.buildResponse(null);
} }
// } // }
Page<JpStationDto> page=jpStationServiceImpl.queryForJpStationPage(current,size,reviewDto); Page<JpStationDto> page = jpStationServiceImpl.queryForJpStationPage(current, size, reviewDto);
return ResponseHelper.buildResponse(page); return ResponseHelper.buildResponse(page);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/countState") @GetMapping(value = "/countState")
@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<>(); Set<String> se = new HashSet<>();
List<JpPersonStation> pPersonStation=null; List<JpPersonStation> pPersonStation = null;
if(reviewDto.getName()!=null&&!"".equals(reviewDto.getName())){ if (reviewDto.getName() != null && !"".equals(reviewDto.getName())) {
LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug1 = new LambdaQueryWrapper<>();
qug1.like(JpPersonStation::getStationName,reviewDto.getName()); qug1.like(JpPersonStation::getStationName, reviewDto.getName());
pPersonStation=pPersonStationMapper.selectList(qug1); pPersonStation = pPersonStationMapper.selectList(qug1);
}else{ } else {
//获取当前人管理场站 //获取当前人管理场站
LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug = new LambdaQueryWrapper<>();
qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId()); qug.eq(JpPersonStation::getPersonId, getUserInfo().getUserId());
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);
collector.put("bj",0); collector.put("bj", 0);
collector.put("lx",0); collector.put("lx", 0);
if(list!=null&&!list.isEmpty()){ if (list != null && !list.isEmpty()) {
for (Map<String, Object> map : list) { for (Map<String, Object> map : list) {
if("在线".equals(map.get("state").toString())){ if ("在线".equals(map.get("state").toString())) {
collector.put("zx",Integer.valueOf(map.get("num").toString())); collector.put("zx", Integer.valueOf(map.get("num").toString()));
}else if("离线".equals(map.get("state").toString())){ } else if ("离线".equals(map.get("state").toString())) {
collector.put("lx",Integer.valueOf(map.get("num").toString())); collector.put("lx", Integer.valueOf(map.get("num").toString()));
}else if("报警".equals(map.get("state").toString())){ } else if ("报警".equals(map.get("state").toString())) {
collector.put("bj",Integer.valueOf(map.get("num").toString())); collector.put("bj", Integer.valueOf(map.get("num").toString()));
} }
} }
} }
...@@ -243,90 +244,88 @@ public class JpStationController extends BaseController { ...@@ -243,90 +244,88 @@ public class JpStationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getpStation") @GetMapping(value = "/getpStation")
@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; List<JpPersonStation> pPersonStation = null;
if(reviewDto.getName()!=null&&!"".equals(reviewDto.getName())){ if (reviewDto.getName() != null && !"".equals(reviewDto.getName())) {
LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug1 = new LambdaQueryWrapper<>();
qug1.like(JpPersonStation::getStationName,reviewDto.getName()); qug1.like(JpPersonStation::getStationName, reviewDto.getName());
pPersonStation=pPersonStationMapper.selectList(qug1); pPersonStation = pPersonStationMapper.selectList(qug1);
}else{ } else {
//获取当前人管理场站 //获取当前人管理场站
LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug = new LambdaQueryWrapper<>();
qug.eq(JpPersonStation::getPersonId,getUserInfo().getUserId()); qug.eq(JpPersonStation::getPersonId, getUserInfo().getUserId());
pPersonStation=pPersonStationMapper.selectList(qug); 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); } else {
}else{
return ResponseHelper.buildResponse(null); return ResponseHelper.buildResponse(null);
} }
List<Map<String,Object>> listCollector= jpCollectorMapper.queryCollectorCountStatus(reviewDto); List<Map<String, Object>> listCollector = jpCollectorMapper.queryCollectorCountStatus(reviewDto);
List<Map<String,Object>> listInverter= jpInverterMapper.queryInverterCountStatus(reviewDto); List<Map<String, Object>> listInverter = jpInverterMapper.queryInverterCountStatus(reviewDto);
Map<String,Object> collector =new HashMap<>(); Map<String, Object> collector = new HashMap<>();
collector.put("zx",0); collector.put("zx", 0);
collector.put("gj",0); collector.put("gj", 0);
collector.put("lx",0); collector.put("lx", 0);
Map<String,Object> inverter =new HashMap<>(); Map<String, Object> inverter = new HashMap<>();
inverter.put("zx",0); inverter.put("zx", 0);
inverter.put("gj",0); inverter.put("gj", 0);
inverter.put("lx",0); inverter.put("lx", 0);
if(!listCollector.isEmpty()){ if (!listCollector.isEmpty()) {
for (Map<String, Object> map : listCollector) { for (Map<String, Object> map : listCollector) {
if("在线".equals(map.get("state").toString())){ if ("在线".equals(map.get("state").toString())) {
collector.put("zx",Integer.valueOf(map.get("num").toString())); collector.put("zx", Integer.valueOf(map.get("num").toString()));
}else if("离线".equals(map.get("state").toString())){ } else if ("离线".equals(map.get("state").toString())) {
collector.put("lx",Integer.valueOf(map.get("num").toString())); collector.put("lx", Integer.valueOf(map.get("num").toString()));
}else if("报警".equals(map.get("state").toString())){ } else if ("报警".equals(map.get("state").toString())) {
collector.put("gj",Integer.valueOf(map.get("num").toString())); collector.put("gj", Integer.valueOf(map.get("num").toString()));
} }
} }
} }
if(!listInverter.isEmpty()){ if (!listInverter.isEmpty()) {
for (Map<String, Object> map : listInverter) { for (Map<String, Object> map : listInverter) {
if("在线".equals(map.get("state").toString())){ if ("在线".equals(map.get("state").toString())) {
inverter.put("zx",Integer.valueOf(map.get("num").toString())); inverter.put("zx", Integer.valueOf(map.get("num").toString()));
}else if("离线".equals(map.get("state").toString())){ } else if ("离线".equals(map.get("state").toString())) {
inverter.put("lx",Integer.valueOf(map.get("num").toString())); inverter.put("lx", Integer.valueOf(map.get("num").toString()));
}else if("报警".equals(map.get("state").toString())){ } else if ("报警".equals(map.get("state").toString())) {
inverter.put("gj",Integer.valueOf(map.get("num").toString())); inverter.put("gj", Integer.valueOf(map.get("num").toString()));
} }
} }
} }
Map<String,Object> map=new HashMap<>(); Map<String, Object> map = new HashMap<>();
map.put("collector",collector); map.put("collector", collector);
map.put("inverter",inverter); map.put("inverter", inverter);
return ResponseHelper.buildResponse(map); return ResponseHelper.buildResponse(map);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/queryListcz") @GetMapping(value = "/queryListcz")
@ApiOperation(httpMethod = "GET",value = "登陆人管理场站列表", notes = "登陆人管理场站列表") @ApiOperation(httpMethod = "GET", value = "登陆人管理场站列表", notes = "登陆人管理场站列表")
public ResponseModel<List<JpPersonStation>> queryList( ) { public ResponseModel<List<JpPersonStation>> queryList() {
//获取当前人管理场站 //获取当前人管理场站
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); List<JpPersonStation> pPersonStation = pPersonStationMapper.selectList(qug);
return ResponseHelper.buildResponse(pPersonStation); return ResponseHelper.buildResponse(pPersonStation);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/queryUserListyz") @GetMapping(value = "/queryUserListyz")
@ApiOperation(httpMethod = "GET",value = "登陆人管理场站业主列表", notes = "登陆人管理场站业主列表") @ApiOperation(httpMethod = "GET", value = "登陆人管理场站业主列表", notes = "登陆人管理场站业主列表")
public ResponseModel<List<String>> queryUserList( ) { public ResponseModel<List<String>> queryUserList() {
//获取当前人管理场站 //获取当前人管理场站
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); List<JpPersonStation> pPersonStation = pPersonStationMapper.selectList(qug);
List data=new ArrayList(); List data = new ArrayList();
if(pPersonStation!=null&& !pPersonStation.isEmpty()){ if (pPersonStation != null && !pPersonStation.isEmpty()) {
for (JpPersonStation jpPersonStation : pPersonStation) { for (JpPersonStation jpPersonStation : pPersonStation) {
data.add(jpPersonStation.getOwner()); data.add(jpPersonStation.getOwner());
} }
...@@ -336,18 +335,18 @@ public class JpStationController extends BaseController { ...@@ -336,18 +335,18 @@ public class JpStationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "电站监控电量收益", notes = "电站监控电量收益") @ApiOperation(httpMethod = "GET", value = "电站监控电量收益", notes = "电站监控电量收益")
@GetMapping(value = "/getIncomePower") @GetMapping(value = "/getIncomePower")
public ResponseModel<JpStationDto> getIncomePower(JpStationDto reviewDto) { public ResponseModel<JpStationDto> getIncomePower(JpStationDto reviewDto) {
//获取当前人管理场站 //获取当前人管理场站
if(reviewDto.getThirdStationId()==null){ if (reviewDto.getThirdStationId() == null) {
//获取当前人管理场站 //获取当前人管理场站
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); List<JpPersonStation> 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);
}else{ } else {
return ResponseHelper.buildResponse(null); return ResponseHelper.buildResponse(null);
} }
} }
...@@ -355,59 +354,59 @@ public class JpStationController extends BaseController { ...@@ -355,59 +354,59 @@ public class JpStationController extends BaseController {
} }
@TycloudOperation(needAuth = false,ApiLevel = UserType.AGENCY) @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "工率曲线", notes = "电站监控电量收益") @ApiOperation(httpMethod = "GET", value = "工率曲线", notes = "电站监控电量收益")
@GetMapping(value = "/getPowerqx") @GetMapping(value = "/getPowerqx")
public ResponseModel< Map<String, List<Object>>> getPowerqx(JpStationDto reviewDto,String date, String type) { public ResponseModel<Map<String, List<Object>>> getPowerqx(JpStationDto reviewDto, String date, String type) {
//获取当前人管理场站 //获取当前人管理场站
List<String> data=new ArrayList(); List<String> data = new ArrayList();
Set<String> se=new HashSet<>(); Set<String> se = new HashSet<>();
if(reviewDto.getName()!=null){ if (reviewDto.getName() != null) {
LambdaQueryWrapper<JpPersonStation> qug1=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug1 = new LambdaQueryWrapper<>();
qug1.like(JpPersonStation::getStationName,reviewDto.getName()); qug1.like(JpPersonStation::getStationName, reviewDto.getName());
List<JpPersonStation> pPersonStation1=pPersonStationMapper.selectList(qug1); List<JpPersonStation> pPersonStation1 = pPersonStationMapper.selectList(qug1);
if(pPersonStation1!=null&&!pPersonStation1.isEmpty()){ if (pPersonStation1 != null && !pPersonStation1.isEmpty()) {
for (JpPersonStation jpPersonStation : pPersonStation1) { for (JpPersonStation jpPersonStation : pPersonStation1) {
se.add(jpPersonStation.getStationId()); se.add(jpPersonStation.getStationId());
} }
} }
data.addAll(se); data.addAll(se);
}else{ } else {
if(reviewDto.getThirdStationId()==null){ if (reviewDto.getThirdStationId() == null) {
//获取当前人管理场站 //获取当前人管理场站
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); List<JpPersonStation> pPersonStation = pPersonStationMapper.selectList(qug);
if(pPersonStation!=null&&!pPersonStation.isEmpty()){ if (pPersonStation != null && !pPersonStation.isEmpty()) {
for (JpPersonStation jpPersonStation : pPersonStation) { for (JpPersonStation jpPersonStation : pPersonStation) {
data.add(jpPersonStation.getStationId()); data.add(jpPersonStation.getStationId());
} }
}else{ } else {
return ResponseHelper.buildResponse(null); return ResponseHelper.buildResponse(null);
} }
}else{ } else {
data.add(reviewDto.getThirdStationId()); data.add(reviewDto.getThirdStationId());
} }
} }
return ResponseHelper.buildResponse(jpStationServiceImpl.getPowerqx( date, type,data)); return ResponseHelper.buildResponse(jpStationServiceImpl.getPowerqx(date, type, data));
} }
//查询当前登录人权限区域公司 //查询当前登录人权限区域公司
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "查询当前登录人权限区域公司", notes = "查询当前登录人权限区域公司") @ApiOperation(httpMethod = "GET", value = "查询当前登录人权限区域公司", notes = "查询当前登录人权限区域公司")
@GetMapping(value = "/getRegion") @GetMapping(value = "/getRegion")
@UserLimits @UserLimits
public ResponseModel<List<Map<String,String>>> getRegion() { public ResponseModel<List<Map<String, String>>> getRegion() {
List<DropDown> list= jpStationMapper.getRegion(); List<DropDown> list = jpStationMapper.getRegion();
List<Map<String,String>> result = new ArrayList<>(); List<Map<String, String>> result = new ArrayList<>();
list.forEach(dropDown -> { list.forEach(dropDown -> {
Map<String,String> item = new HashMap<>(); Map<String, String> item = new HashMap<>();
item.put("text",dropDown.getName()); item.put("text", dropDown.getName());
item.put("value",dropDown.getOrgCode()); item.put("value", dropDown.getOrgCode());
result.add(item); result.add(item);
}); });
...@@ -417,16 +416,16 @@ public class JpStationController extends BaseController { ...@@ -417,16 +416,16 @@ public class JpStationController extends BaseController {
//查询当前登录人权限经销商 //查询当前登录人权限经销商
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "查询当前登录人权限经销商", notes = "查询当前登录人权限经销商") @ApiOperation(httpMethod = "GET", value = "查询当前登录人权限经销商", notes = "查询当前登录人权限经销商")
@GetMapping(value = "/getDealer") @GetMapping(value = "/getDealer")
@UserLimits @UserLimits
public ResponseModel<List<Map<String,String>>> getDealer(String regionalCompaniesCode ) { public ResponseModel<List<Map<String, String>>> getDealer(String regionalCompaniesCode) {
List<DropDown> list= jpStationMapper.getDealer(regionalCompaniesCode); List<DropDown> list = jpStationMapper.getDealer(regionalCompaniesCode);
List<Map<String,String>> result = new ArrayList<>(); List<Map<String, String>> result = new ArrayList<>();
list.forEach(dropDown -> { list.forEach(dropDown -> {
Map<String,String> item = new HashMap<>(); Map<String, String> item = new HashMap<>();
item.put("text",dropDown.getName()); item.put("text", dropDown.getName());
item.put("value",dropDown.getOrgCode()); item.put("value", dropDown.getOrgCode());
result.add(item); result.add(item);
}); });
return ResponseHelper.buildResponse(result); return ResponseHelper.buildResponse(result);
...@@ -435,22 +434,22 @@ public class JpStationController extends BaseController { ...@@ -435,22 +434,22 @@ public class JpStationController extends BaseController {
//电站发电量统计 //电站发电量统计
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "电站发电量统计", notes = "电站发电量统计") @ApiOperation(httpMethod = "GET", value = "电站发电量统计", notes = "电站发电量统计")
@GetMapping(value = "/getCountJpStationdata") @GetMapping(value = "/getCountJpStationdata")
@UserLimits @UserLimits
public ResponseModel< Page<JpStationDto>> getCountJpStationdata(JpStationDto reviewDto) { public ResponseModel<Page<JpStationDto>> getCountJpStationdata(JpStationDto reviewDto) {
JpStationDto jpStation= jpStationMapper.getCountJpStationdata(reviewDto); JpStationDto jpStation = jpStationMapper.getCountJpStationdata(reviewDto);
List<Map<String,Object>> powerRatio=new ArrayList<>(); List<Map<String, Object>> powerRatio = new ArrayList<>();
Map<String,Object> map=new HashMap<>(); Map<String, Object> map = new HashMap<>();
if(jpStation!=null&&jpStation.getRealTimePower()!=null&&jpStation.getRatedPower()!=null&&jpStation.getRatedPower()>0){ if (jpStation != null && jpStation.getRealTimePower() != null && jpStation.getRatedPower() != null && jpStation.getRatedPower() > 0) {
map.put("value",String.format("%.4f",jpStation.getRealTimePower()/(jpStation.getCapacity()*FDXSS))); map.put("value", String.format("%.4f", jpStation.getRealTimePower() / (jpStation.getCapacity() * FDXSS)));
}else{ } else {
jpStation=new JpStationDto(); jpStation = new JpStationDto();
map.put("value",0); map.put("value", 0);
} }
powerRatio.add(map); powerRatio.add(map);
jpStation.setPowerRatio(powerRatio); jpStation.setPowerRatio(powerRatio);
List<JpStationDto> list=new ArrayList<>(); List<JpStationDto> list = new ArrayList<>();
list.add(jpStation); list.add(jpStation);
Page<JpStationDto> result = new Page<>(); Page<JpStationDto> result = new Page<>();
result.setCurrent(1); result.setCurrent(1);
...@@ -461,34 +460,43 @@ public class JpStationController extends BaseController { ...@@ -461,34 +460,43 @@ public class JpStationController extends BaseController {
//电站分布 //电站分布
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "电站分布", notes = "电站分布") @ApiOperation(httpMethod = "GET", value = "电站分布", notes = "电站分布")
@GetMapping(value = "/getJpStation") @GetMapping(value = "/getJpStation")
@UserLimits @UserLimits
public Object getJpStation(JpStationDto reviewDto) { public Object getJpStation(JpStationDto reviewDto) {
List<JpStation> list= jpStationMapper.getJpStation(reviewDto); List<JpStation> list = jpStationMapper.getJpStation(reviewDto);
return ResponseHelper.buildResponse(list); return ResponseHelper.buildResponse(list);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "GET", value = "电站场站无权限", notes = "电站场站无权限")
@GetMapping(value = "/getJpStationList")
public ResponseModel<List<JpStation>> getJpStationList(JpStationDto reviewDto) {
return ResponseHelper.buildResponse(jpStationServiceImpl.getJpStationList(reviewDto));
}
//节能减排 //节能减排
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "节能减排", notes = "节能减排") @ApiOperation(httpMethod = "GET", value = "节能减排", notes = "节能减排")
@GetMapping(value = "/getEnergyConservation") @GetMapping(value = "/getEnergyConservation")
@UserLimits @UserLimits
public ResponseModel< Page<Map<String,Object>>> getEnergyConservation(JpStationDto reviewDto) { public ResponseModel<Page<Map<String, Object>>> getEnergyConservation(JpStationDto reviewDto) {
Page<Map<String,Object>> result =new Page<>(); Page<Map<String, Object>> result = new Page<>();
List<Map<String,Object>> itemList =new ArrayList<>(); List<Map<String, Object>> itemList = new ArrayList<>();
JpStationDto jpStation= jpStationMapper.getCountJpStationdata(reviewDto); JpStationDto jpStation = jpStationMapper.getCountJpStationdata(reviewDto);
Map<String,Object> map=new HashMap<>(); Map<String, Object> map = new HashMap<>();
DecimalFormat format2 = new DecimalFormat("0.00"); DecimalFormat format2 = new DecimalFormat("0.00");
//炭 //炭
map.put("carbon",format2.format(jpStation.getAccumulatedPower()*FDXSS*CARBON)); map.put("carbon", format2.format(jpStation.getAccumulatedPower() * FDXSS * CARBON));
//硫 //硫
map.put("sulfur",format2.format(jpStation.getAccumulatedPower()*FDXSS*SULFUR)); map.put("sulfur", format2.format(jpStation.getAccumulatedPower() * FDXSS * SULFUR));
//粉尘 //粉尘
map.put("dust",format2.format(jpStation.getAccumulatedPower()*FDXSS*DUST)); map.put("dust", format2.format(jpStation.getAccumulatedPower() * FDXSS * DUST));
//煤 //煤
map.put("coal",format2.format(jpStation.getAccumulatedPower()*FDXSS*COAL)); map.put("coal", format2.format(jpStation.getAccumulatedPower() * FDXSS * COAL));
itemList.add(map); itemList.add(map);
result.setCurrent(1); result.setCurrent(1);
result.setTotal(1); result.setTotal(1);
...@@ -497,138 +505,134 @@ public class JpStationController extends BaseController { ...@@ -497,138 +505,134 @@ public class JpStationController extends BaseController {
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "电站列表统计", notes = "电站列表统计") @ApiOperation(httpMethod = "GET", value = "电站列表统计", notes = "电站列表统计")
@GetMapping(value = "/getjpStationConservation") @GetMapping(value = "/getjpStationConservation")
@UserLimits @UserLimits
public ResponseModel< Page<Map<String,Object>>> getjpStationConservation(JpStationDto reviewDto) { public ResponseModel<Page<Map<String, Object>>> getjpStationConservation(JpStationDto reviewDto) {
JpStationDto jpStation= jpStationMapper.getCountJpStationdata(reviewDto); JpStationDto jpStation = jpStationMapper.getCountJpStationdata(reviewDto);
List<Map<String,Object>> date=new ArrayList<>(); List<Map<String, Object>> date = new ArrayList<>();
Map<String,Object> map=new HashMap<>(); Map<String, Object> map = new HashMap<>();
DecimalFormat format2 = new DecimalFormat("0.000"); DecimalFormat format2 = new DecimalFormat("0.000");
//炭 //炭
map.put("name1","实时功率(kW)"); map.put("name1", "实时功率(kW)");
map.put("name2","组件总容量(MWp)"); map.put("name2", "组件总容量(MWp)");
map.put("value1",format2.format(jpStation.getRealTimePower())); map.put("value1", format2.format(jpStation.getRealTimePower()));
//硫 //硫
map.put("value2",format2.format(jpStation.getCapacity())); map.put("value2", format2.format(jpStation.getCapacity()));
Map<String,Object> map2=new HashMap<>(); Map<String, Object> map2 = new HashMap<>();
map2.put("name1","当日电量(MWh)"); map2.put("name1", "当日电量(MWh)");
map2.put("name2","当日收益(元)"); map2.put("name2", "当日收益(元)");
//炭 //炭
map2.put("value1",format2.format(jpStation.getDayGenerate())); map2.put("value1", format2.format(jpStation.getDayGenerate()));
//硫 //硫
map2.put("value2",format2.format(jpStation.getDayIncome())); map2.put("value2", format2.format(jpStation.getDayIncome()));
Map<String,Object> map3=new HashMap<>(); Map<String, Object> map3 = new HashMap<>();
map3.put("name1","当月电量(MWh)"); map3.put("name1", "当月电量(MWh)");
map3.put("name2","当月收益(万元)"); map3.put("name2", "当月收益(万元)");
//炭 //炭
map3.put("value1",format2.format(jpStation.getMonthGenerate())); map3.put("value1", format2.format(jpStation.getMonthGenerate()));
//硫 //硫
map3.put("value2",format2.format(jpStation.getMonthIncome())); map3.put("value2", format2.format(jpStation.getMonthIncome()));
Map<String,Object> map4=new HashMap<>(); Map<String, Object> map4 = new HashMap<>();
map4.put("name1","累计电量(MWh)"); map4.put("name1", "累计电量(MWh)");
map4.put("name2","累计收益(万元)"); map4.put("name2", "累计收益(万元)");
//炭 //炭
map4.put("value1",format2.format(jpStation.getAccumulatedPower())); map4.put("value1", format2.format(jpStation.getAccumulatedPower()));
//硫 //硫
map4.put("value2",format2.format(jpStation.getCumulativeIncome())); map4.put("value2", format2.format(jpStation.getCumulativeIncome()));
date.add(map); date.add(map);
date.add(map2); date.add(map2);
date.add(map3); date.add(map3);
date.add(map4); date.add(map4);
Page<Map<String,Object>> page = new Page<>(1, 4); Page<Map<String, Object>> page = new Page<>(1, 4);
page.setRecords(date); page.setRecords(date);
return ResponseHelper.buildResponse(page); return ResponseHelper.buildResponse(page);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "电站统计", notes = "电站统计") @ApiOperation(httpMethod = "GET", value = "电站统计", notes = "电站统计")
@GetMapping(value = "/getcountJpStationNum") @GetMapping(value = "/getcountJpStationNum")
public ResponseModel<List<Map<String,Object>>> getcountJpStationNum(JpStationDto reviewDto) { public ResponseModel<List<Map<String, Object>>> getcountJpStationNum(JpStationDto reviewDto) {
List<Map<String,Object>> itemList =new ArrayList<>(); List<Map<String, Object>> itemList = new ArrayList<>();
Map<String,Object> collector =new HashMap<>(); Map<String, Object> collector = new HashMap<>();
collector.put("在线",0); collector.put("在线", 0);
collector.put("离线",0); collector.put("离线", 0);
collector.put("报警",0); collector.put("报警", 0);
List<Map<String,Object>> list= jpStationServiceImpl.getcountState(reviewDto); List<Map<String, Object>> list = jpStationServiceImpl.getcountState(reviewDto);
if(list!=null&&!list.isEmpty()){ if (list != null && !list.isEmpty()) {
for (Map<String, Object> map : list) { for (Map<String, Object> map : list) {
if(ZX.equals(map.get("state").toString())){ if (ZX.equals(map.get("state").toString())) {
collector.put("正常",Integer.valueOf(map.get("num").toString())); collector.put("正常", Integer.valueOf(map.get("num").toString()));
}else if(LX.equals(map.get("state").toString())){ } else if (LX.equals(map.get("state").toString())) {
collector.put("离线",Integer.valueOf(map.get("num").toString())); collector.put("离线", Integer.valueOf(map.get("num").toString()));
}else if(BJ.equals(map.get("state").toString())){ } else if (BJ.equals(map.get("state").toString())) {
collector.put("报警",Integer.valueOf(map.get("num").toString())); collector.put("报警", Integer.valueOf(map.get("num").toString()));
} }
} }
} }
Map<String,Object> result = new HashMap<>(); Map<String, Object> result = new HashMap<>();
result.put("name","正常"); result.put("name", "正常");
result.put("value",collector.get("正常")); result.put("value", collector.get("正常"));
itemList.add(result); itemList.add(result);
Map<String,Object> result1 = new HashMap<>(); Map<String, Object> result1 = new HashMap<>();
result1.put("name","离线"); result1.put("name", "离线");
result1.put("value",collector.get("离线")); result1.put("value", collector.get("离线"));
itemList.add(result1); itemList.add(result1);
Map<String,Object> result2 = new HashMap<>(); Map<String, Object> result2 = new HashMap<>();
result2.put("name","报警"); result2.put("name", "报警");
result2.put("value",collector.get("报警")); result2.put("value", collector.get("报警"));
itemList.add(result2); itemList.add(result2);
return ResponseHelper.buildResponse(itemList); return ResponseHelper.buildResponse(itemList);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "电站统计", notes = "电站统计") @ApiOperation(httpMethod = "GET", value = "电站统计", notes = "电站统计")
@GetMapping(value = "/getcountJpStation") @GetMapping(value = "/getcountJpStation")
public ResponseModel<Page< Map<String,Object>>> getcountJpStation(JpStationDto reviewDto) { public ResponseModel<Page<Map<String, Object>>> getcountJpStation(JpStationDto reviewDto) {
List<Map<String,Object>> itemList =new ArrayList<>(); List<Map<String, Object>> itemList = new ArrayList<>();
Map<String,Object> collector =new HashMap<>(); Map<String, Object> collector = new HashMap<>();
collector.put("zx",0); collector.put("zx", 0);
collector.put("bj",0); collector.put("bj", 0);
collector.put("lx",0); collector.put("lx", 0);
List<Map<String,Object>> list= jpStationServiceImpl.getcountState(reviewDto); List<Map<String, Object>> list = jpStationServiceImpl.getcountState(reviewDto);
if(list!=null&&!list.isEmpty()){ if (list != null && !list.isEmpty()) {
for (Map<String, Object> map : list) { for (Map<String, Object> map : list) {
if(ZX.equals(map.get("state").toString())){ if (ZX.equals(map.get("state").toString())) {
collector.put("zx",Integer.valueOf(map.get("num").toString())); collector.put("zx", Integer.valueOf(map.get("num").toString()));
}else if(LX.equals(map.get("state").toString())){ } else if (LX.equals(map.get("state").toString())) {
collector.put("lx",Integer.valueOf(map.get("num").toString())); collector.put("lx", Integer.valueOf(map.get("num").toString()));
}else if(BJ.equals(map.get("state").toString())){ } else if (BJ.equals(map.get("state").toString())) {
collector.put("bj",Integer.valueOf(map.get("num").toString())); collector.put("bj", Integer.valueOf(map.get("num").toString()));
} }
} }
} }
Map<String,Object> js= jpStationServiceImpl.getcountStatejs(reviewDto); Map<String, Object> js = jpStationServiceImpl.getcountStatejs(reviewDto);
Map<String,Object> tc= jpStationServiceImpl.getcountStatetc(reviewDto); Map<String, Object> tc = jpStationServiceImpl.getcountStatetc(reviewDto);
Map<String,Object> jr= jpStationServiceImpl.getcountStatejr(reviewDto); Map<String, Object> jr = jpStationServiceImpl.getcountStatejr(reviewDto);
Map<String,Object> zs= jpStationServiceImpl.getcount(reviewDto); Map<String, Object> zs = jpStationServiceImpl.getcount(reviewDto);
collector.put("js",js.get("num")); collector.put("js", js.get("num"));
collector.put("tc",tc.get("num")); collector.put("tc", tc.get("num"));
collector.put("jr",jr.get("num")); collector.put("jr", jr.get("num"));
collector.put("zs",zs.get("num")); collector.put("zs", zs.get("num"));
itemList.add(collector); itemList.add(collector);
Page< Map<String,Object>> result =new Page<>(); Page<Map<String, Object>> result = new Page<>();
result.setCurrent(1); result.setCurrent(1);
result.setTotal(1); result.setTotal(1);
result.setRecords(itemList); result.setRecords(itemList);
...@@ -638,23 +642,23 @@ public class JpStationController extends BaseController { ...@@ -638,23 +642,23 @@ public class JpStationController extends BaseController {
//日满发小时排行 //日满发小时排行
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "日满发小时排行", notes = "日满发小时排行") @ApiOperation(httpMethod = "GET", value = "日满发小时排行", notes = "日满发小时排行")
@GetMapping(value = "/getDayGenerateph") @GetMapping(value = "/getDayGenerateph")
public ResponseModel< Page< Map<String,Object>>> getDayGenerateph(JpStationDto reviewDto,String type,String dateTime ) { public ResponseModel<Page<Map<String, Object>>> getDayGenerateph(JpStationDto reviewDto, String type, String dateTime) {
List<JpStation> list= jpStationServiceImpl.getJpStation(reviewDto); List<JpStation> list = jpStationServiceImpl.getJpStation(reviewDto);
List<Map<String,Object>> li=new ArrayList<>(); List<Map<String, Object>> li = new ArrayList<>();
List<DayGenerate> date= dayGenerateServiceImpl.getDayGenerateph(list,type,dateTime); List<DayGenerate> date = dayGenerateServiceImpl.getDayGenerateph(list, type, dateTime);
DecimalFormat format2 = new DecimalFormat("0.00"); DecimalFormat format2 = new DecimalFormat("0.00");
if(date!=null&&!list.isEmpty()){ if (date != null && !list.isEmpty()) {
for (DayGenerate dayGenerate : date) { for (DayGenerate dayGenerate : date) {
Map<String,Object> map =new HashMap<>(); Map<String, Object> map = new HashMap<>();
for (JpStation jpStation : list) { for (JpStation jpStation : list) {
if(dayGenerate.getThirdStationId().equals(jpStation.getThirdStationId())){ if (dayGenerate.getThirdStationId().equals(jpStation.getThirdStationId())) {
map.put("id",jpStation.getSequenceNbr()); map.put("id", jpStation.getSequenceNbr());
map.put("name",jpStation.getName()); map.put("name", jpStation.getName());
map.put("address",jpStation.getAddress()); map.put("address", jpStation.getAddress());
map.put("fullhour",format2.format(dayGenerate.getFullhour())); map.put("fullhour", format2.format(dayGenerate.getFullhour()));
li.add(map); li.add(map);
break; break;
} }
...@@ -662,7 +666,7 @@ public class JpStationController extends BaseController { ...@@ -662,7 +666,7 @@ public class JpStationController extends BaseController {
} }
} }
Page< Map<String,Object>> result =new Page<>(); Page<Map<String, Object>> result = new Page<>();
result.setCurrent(1); result.setCurrent(1);
result.setTotal(10); result.setTotal(10);
result.setRecords(li); result.setRecords(li);
...@@ -670,66 +674,64 @@ public class JpStationController extends BaseController { ...@@ -670,66 +674,64 @@ public class JpStationController extends BaseController {
} }
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@TycloudOperation(needAuth = false,ApiLevel = UserType.AGENCY) @ApiOperation(httpMethod = "GET", value = "发电量曲线", notes = "发电量曲线")
@ApiOperation(httpMethod = "GET",value = "发电量曲线", notes = "发电量曲线")
@GetMapping(value = "/getGenerateqx") @GetMapping(value = "/getGenerateqx")
public ResponseModel< Map<String, List<Object>>> getGenerateqx(JpStationDto reviewDto,String date, String type) { public ResponseModel<Map<String, List<Object>>> getGenerateqx(JpStationDto reviewDto, String date, String type) {
Map<String, List<Object>> map= jpStationServiceImpl.getGenerateqx( date, type,reviewDto); Map<String, List<Object>> map = jpStationServiceImpl.getGenerateqx(date, type, reviewDto);
return ResponseHelper.buildResponse(map); return ResponseHelper.buildResponse(map);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "工率曲线", notes = "电站监控电量收益") @ApiOperation(httpMethod = "GET", value = "工率曲线", notes = "电站监控电量收益")
@GetMapping(value = "/getPowerqxnew") @GetMapping(value = "/getPowerqxnew")
public ResponseModel< Map<String, List<Object>>> getPowerqxnew(JpStationDto reviewDto,String date) { public ResponseModel<Map<String, List<Object>>> getPowerqxnew(JpStationDto reviewDto, String date) {
Map<String, List<Object>> map= jpStationServiceImpl.getPowerqxnew( date,reviewDto); Map<String, List<Object>> map = jpStationServiceImpl.getPowerqxnew(date, reviewDto);
return ResponseHelper.buildResponse(map); return ResponseHelper.buildResponse(map);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/queryPagenew") @GetMapping(value = "/queryPagenew")
@ApiOperation(httpMethod = "GET",value = "场站列表", notes = "场站列表") @ApiOperation(httpMethod = "GET", value = "场站列表", notes = "场站列表")
public ResponseModel<Page<JpStationDto>> queryPagenew(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<JpStationDto>> queryPagenew(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size, JpStationDto reviewDto) { (value = "size") int size, JpStationDto reviewDto) {
Page<JpStationDto> page=jpStationServiceImpl.queryForJpStationPagenew(current,size,reviewDto); Page<JpStationDto> page = jpStationServiceImpl.queryForJpStationPagenew(current, size, reviewDto);
return ResponseHelper.buildResponse(page); return ResponseHelper.buildResponse(page);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping (value = "/queryReport") @PostMapping(value = "/queryReport")
@ApiOperation(httpMethod = "POST",value = "场站报表", notes = "场站报表") @ApiOperation(httpMethod = "POST", value = "场站报表", notes = "场站报表")
public ResponseModel<Page<JpStationDto>> queryReport(@RequestParam(value = "current") int current, @RequestParam public ResponseModel<Page<JpStationDto>> queryReport(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size,@RequestBody JpStationDto reviewDto,@RequestParam(value = "type") String type) { (value = "size") int size, @RequestBody JpStationDto reviewDto, @RequestParam(value = "type") String type) {
Page<JpStationDto> page=jpStationServiceImpl.queryReport(current,size,reviewDto,type); Page<JpStationDto> page = jpStationServiceImpl.queryReport(current, size, reviewDto, type);
return ResponseHelper.buildResponse(page); return ResponseHelper.buildResponse(page);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "登录人场站", notes = "登录人场站") @ApiOperation(httpMethod = "GET", value = "登录人场站", notes = "登录人场站")
@GetMapping(value = "/getuserJpStation") @GetMapping(value = "/getuserJpStation")
public ResponseModel< List<JpStation>> getuserJpStation(JpStationDto reviewDto) { public ResponseModel<List<JpStation>> getuserJpStation(JpStationDto reviewDto) {
List<JpStation> list = jpStationServiceImpl.getJpStation(reviewDto); List<JpStation> list = jpStationServiceImpl.getJpStation(reviewDto);
return ResponseHelper.buildResponse(list); return ResponseHelper.buildResponse(list);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "工率曲线", notes = "电站监控电量收益") @ApiOperation(httpMethod = "GET", value = "工率曲线", notes = "电站监控电量收益")
@GetMapping(value = "/test") @GetMapping(value = "/test")
public Object getPowerqx(JpStationDto reviewDto) { public Object getPowerqx(JpStationDto reviewDto) {
List<JpStation> list= jpStationServiceImpl.getJpStation(new JpStationDto()); List<JpStation> list = jpStationServiceImpl.getJpStation(new JpStationDto());
return list; return list;
} }
...@@ -737,11 +739,11 @@ public class JpStationController extends BaseController { ...@@ -737,11 +739,11 @@ public class JpStationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@RequestMapping(value = "/jpstationReportExport", method = RequestMethod.POST) @RequestMapping(value = "/jpstationReportExport", method = RequestMethod.POST)
@ApiOperation(httpMethod = "POST", value = "电站报表导出", notes = "电站报表导出") @ApiOperation(httpMethod = "POST", value = "电站报表导出", notes = "电站报表导出")
public void jpstationReportExport( HttpServletResponse response,@RequestBody JpStationDto reviewDto,@RequestParam(value = "type")String type) { public void jpstationReportExport(HttpServletResponse response, @RequestBody JpStationDto reviewDto, @RequestParam(value = "type") String type) {
// List<JpStation> jpStation=jpStationServiceImpl.getJpStation(new JpStationDto()); // List<JpStation> jpStation=jpStationServiceImpl.getJpStation(new JpStationDto());
// List<String> stationIds = jpStation.stream().map(jpStation1 -> jpStation1.getThirdStationId()).collect(Collectors.toList()); // List<String> stationIds = jpStation.stream().map(jpStation1 -> jpStation1.getThirdStationId()).collect(Collectors.toList());
List<JpStationDto> jpStationDtos = jpStationServiceImpl.selectReportDate(reviewDto, type,response); List<JpStationDto> jpStationDtos = jpStationServiceImpl.selectReportDate(reviewDto, type, response);
// try { // try {
// setResponseHeadForDowload(response,"电站报表.xls"); // setResponseHeadForDowload(response,"电站报表.xls");
// EasyExcel.write(response.getOutputStream()).head(JpStationDto.class).excelType(ExcelTypeEnum.XLS).sheet("电站报表") // EasyExcel.write(response.getOutputStream()).head(JpStationDto.class).excelType(ExcelTypeEnum.XLS).sheet("电站报表")
...@@ -753,6 +755,4 @@ public class JpStationController extends BaseController { ...@@ -753,6 +755,4 @@ public class JpStationController extends BaseController {
} }
} }
amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/JpStationServiceImpl.java
View file @ 315e9dc7
...@@ -4,15 +4,14 @@ import cn.hutool.core.date.DateUtil; ...@@ -4,15 +4,14 @@ import cn.hutool.core.date.DateUtil;
import com.alibaba.excel.EasyExcel; import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.support.ExcelTypeEnum; import com.alibaba.excel.support.ExcelTypeEnum;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.yeejoin.amos.boot.module.hygf.api.config.UserLimits; import com.yeejoin.amos.boot.module.hygf.api.config.UserLimits;
import com.yeejoin.amos.boot.module.hygf.api.dto.*; import com.yeejoin.amos.boot.module.hygf.api.dto.*;
import com.yeejoin.amos.boot.module.hygf.api.entity.DayGenerate; import com.yeejoin.amos.boot.module.hygf.api.entity.*;
import com.yeejoin.amos.boot.module.hygf.api.entity.JpStation; import com.yeejoin.amos.boot.module.hygf.api.mapper.JpInverterMapper;
import com.yeejoin.amos.boot.module.hygf.api.entity.MonthGenerate;
import com.yeejoin.amos.boot.module.hygf.api.entity.YearGenerate;
import com.yeejoin.amos.boot.module.hygf.api.mapper.JpStationMapper; import com.yeejoin.amos.boot.module.hygf.api.mapper.JpStationMapper;
import com.yeejoin.amos.boot.module.hygf.api.service.IJpStationService; import com.yeejoin.amos.boot.module.hygf.api.service.IJpStationService;
import com.yeejoin.amos.boot.module.hygf.api.tdenginemapper.DayGenerateMapper; import com.yeejoin.amos.boot.module.hygf.api.tdenginemapper.DayGenerateMapper;
...@@ -46,6 +45,8 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS ...@@ -46,6 +45,8 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS
@Autowired @Autowired
JpStationMapper jpStationMapper; JpStationMapper jpStationMapper;
@Autowired @Autowired
JpInverterMapper jpInverterMapper;
@Autowired
MonthPowerMapper monthPowerMapper; MonthPowerMapper monthPowerMapper;
@Autowired @Autowired
MonthPowerServiceImpl monthPowerServiceImpl; MonthPowerServiceImpl monthPowerServiceImpl;
...@@ -175,6 +176,16 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS ...@@ -175,6 +176,16 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS
return jpStationMapper.getcountStatetc(reviewDto); return jpStationMapper.getcountStatetc(reviewDto);
} }
public List<JpStation>getJpStationList (JpStationDto reviewDto){
List<JpInverter> dataJpInverter=jpInverterMapper.selectList(new QueryWrapper<JpInverter>().isNotNull("third_station_id"));
Map<String,List<String>> inverterMap=dataJpInverter.stream().collect(Collectors.groupingBy(JpInverter::getThirdStationId,Collectors.mapping(JpInverter::getSnCode,Collectors.toList())));
List<JpStation> list= jpStationMapper.getJpStationList(reviewDto);
list.forEach(jpStation -> {
jpStation.setSnCodes(inverterMap.get(jpStation.getThirdStationId()));
});
return list;
}
@Override @Override
@UserLimits @UserLimits
public Map<String, Object> getcountStatejs(JpStationDto reviewDto) { public Map<String, Object> getcountStatejs(JpStationDto reviewDto) {
......
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