Commit a0ecae62 authored by tangwei's avatar tangwei

修改户用光伏监控

parent 5ae1804b
...@@ -33,7 +33,7 @@ public class JpInverterDto extends BaseDto { ...@@ -33,7 +33,7 @@ public class JpInverterDto extends BaseDto {
private Double ratedPower; private Double ratedPower;
@ApiModelProperty(value = "采集器id") @ApiModelProperty(value = "采集器id")
private Long collectorId; private String collectorId;
@ApiModelProperty(value = "采集器sn编码") @ApiModelProperty(value = "采集器sn编码")
private String collectorSnCode; private String collectorSnCode;
......
...@@ -22,7 +22,7 @@ public class JpInverterElectricityDto extends BaseDto { ...@@ -22,7 +22,7 @@ public class JpInverterElectricityDto extends BaseDto {
@ApiModelProperty(value = "逆变器id") @ApiModelProperty(value = "逆变器id")
private Long inverterId; private String inverterId;
@ApiModelProperty(value = "sn编码") @ApiModelProperty(value = "sn编码")
private String snCode; private String snCode;
......
...@@ -44,7 +44,7 @@ public class JpInverter extends BaseEntity { ...@@ -44,7 +44,7 @@ public class JpInverter extends BaseEntity {
* 采集器id * 采集器id
*/ */
@TableField("collector_id") @TableField("collector_id")
private Long collectorId; private String collectorId;
/** /**
* 采集器sn编码 * 采集器sn编码
......
...@@ -26,7 +26,7 @@ public class JpInverterElectricity extends BaseEntity { ...@@ -26,7 +26,7 @@ public class JpInverterElectricity extends BaseEntity {
* 逆变器id * 逆变器id
*/ */
@TableField("inverter_id") @TableField("inverter_id")
private Long inverterId; private String inverterId;
/** /**
* sn编码 * sn编码
......
...@@ -14,5 +14,5 @@ import java.util.Set; ...@@ -14,5 +14,5 @@ import java.util.Set;
*/ */
public interface IJpStationService { public interface IJpStationService {
Map<String, List<Object>> getPowerqx(String date, String type, List<Long> statioId); Map<String, List<Object>> getPowerqx(String date, String type, List<String> statioId);
} }
...@@ -26,12 +26,12 @@ public interface MonthPowerMapper extends BaseMapper<MonthPower> { ...@@ -26,12 +26,12 @@ public interface MonthPowerMapper extends BaseMapper<MonthPower> {
List<PowerCurveDto> getDayPower(@Param("startTime") Long startTime, @Param("endTime") Long endTime,@Param("dto")List<Long> statioId); List<PowerCurveDto> getDayPower(@Param("startTime") Long startTime, @Param("endTime") Long endTime,@Param("dto")List<Long> statioId);
List<PowerCurveDto> getMonthPower(@Param("date") String month,@Param("dto")List<Long> statioId); List<PowerCurveDto> getMonthPower(@Param("date") String month,@Param("dto")List<String> statioId);
List<PowerCurveDto> getYearPower(@Param("date") String month,@Param("dto")List<Long> statioId); List<PowerCurveDto> getYearPower(@Param("date") String month,@Param("dto")List<String> statioId);
List<PowerCurveDto> getAllPower(@Param("date") String month,@Param("dto")List<Long> statioId); List<PowerCurveDto> getAllPower(@Param("date") String month,@Param("dto")List<String> statioId);
List<PowerCurveDto> getDayPowercount(@Param("date") String month,@Param("dto")List<Long> statioId); List<PowerCurveDto> getDayPowercount(@Param("date") String month,@Param("dto")List<String> statioId);
} }
...@@ -33,13 +33,13 @@ ...@@ -33,13 +33,13 @@
`day_power_use` dayPowerUse, `day_power_use` dayPowerUse,
`month_power_use` monthPowerUse, `month_power_use` monthPowerUse,
`year_power_use` yearPowerUse, `year_power_use` yearPowerUse,
FORMAT(`real_time_power`,3) realTimePower, ROUND(`real_time_power`,3) realTimePower,
FORMAT(`accumulated_power`/1000,3) accumulatedPower, ROUND(`accumulated_power`/1000,3) accumulatedPower,
`state` , `state` ,
`type`, `type`,
`organizational_code` organizationalCode, `organizational_code` organizationalCode,
`is_delete` isDelete, `is_delete` isDelete,
FORMAT(`day_generate`,3) dayGenerate, ROUND(`day_generate`,3) dayGenerate,
`month_generate` monthGenerate, `month_generate` monthGenerate,
`year_generate` yearGenerate, `year_generate` yearGenerate,
`day_income` dayIncome, `day_income` dayIncome,
...@@ -83,20 +83,20 @@ ...@@ -83,20 +83,20 @@
select select
FORMAT(sum(real_time_power),3) realTimePower, ROUND(sum(real_time_power),3) realTimePower,
FORMAT(sum(capacity)/1000,3) capacity, ROUND(sum(capacity)/1000,3) capacity,
FORMAT(sum(day_generate)/1000,3) dayGenerate, ROUND(sum(day_generate)/1000,3) dayGenerate,
FORMAT(sum(month_generate)/1000,3) monthGenerate, ROUND(sum(month_generate)/1000,3) monthGenerate,
FORMAT(sum(year_generate)/1000,3) yearGenerate, ROUND(sum(year_generate)/1000,3) yearGenerate,
FORMAT(sum(accumulated_power)/1000,3) accumulatedPower, ROUND(sum(accumulated_power)/1000,3) accumulatedPower,
FORMAT( sum(day_income),3) dayIncome, ROUND( sum(day_income),3) dayIncome,
FORMAT(sum(month_income)/10000,3) monthIncome, ROUND(sum(month_income)/10000,3) monthIncome,
FORMAT(sum(year_income)/10000,3) yearIncome, ROUND(sum(year_income)/10000,3) yearIncome,
FORMAT(sum(cumulative_income)/10000,3) cumulativeIncome, ROUND(sum(cumulative_income)/10000,3) cumulativeIncome,
FORMAT(sum(day_power_use)/1000,3) dayPowerUse, ROUND(sum(day_power_use)/1000,3) dayPowerUse,
FORMAT(sum(month_power_use)/1000,3) monthPowerUse, ROUND(sum(month_power_use)/1000,3) monthPowerUse,
FORMAT(sum(year_power_use)/1000,3) yearPowerUse, ROUND(sum(year_power_use)/1000,3) yearPowerUse,
FORMAT(sum(rated_power),3) ratedPower, ROUND(sum(rated_power),3) ratedPower,
count(*) countBuiltNum count(*) countBuiltNum
from hygf_jp_station from hygf_jp_station
<where> <where>
......
...@@ -282,7 +282,7 @@ public class JpStationController extends BaseController { ...@@ -282,7 +282,7 @@ public class JpStationController extends BaseController {
@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<Long> data=new ArrayList(); List<String> data=new ArrayList();
if(reviewDto.getThirdStationId()==null){ if(reviewDto.getThirdStationId()==null){
//获取当前人管理场站 //获取当前人管理场站
LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>(); LambdaQueryWrapper<JpPersonStation> qug=new LambdaQueryWrapper<>();
...@@ -291,13 +291,13 @@ public class JpStationController extends BaseController { ...@@ -291,13 +291,13 @@ public class JpStationController extends BaseController {
if(pPersonStation!=null&&!pPersonStation.isEmpty()){ if(pPersonStation!=null&&!pPersonStation.isEmpty()){
for (JpPersonStation jpPersonStation : pPersonStation) { for (JpPersonStation jpPersonStation : pPersonStation) {
data.add(Long.valueOf(jpPersonStation.getStationId())); data.add(jpPersonStation.getStationId());
} }
}else{ }else{
return ResponseHelper.buildResponse(null); return ResponseHelper.buildResponse(null);
} }
}else{ }else{
data.add(Long.valueOf(reviewDto.getThirdStationId())); data.add(reviewDto.getThirdStationId());
} }
return ResponseHelper.buildResponse(jpStationServiceImpl.getPowerqx( date, type,data)); return ResponseHelper.buildResponse(jpStationServiceImpl.getPowerqx( date, type,data));
} }
......
...@@ -59,7 +59,7 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS ...@@ -59,7 +59,7 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS
@Override @Override
public Map<String, List<Object>> getPowerqx(String date, String type,List<Long> statioId) { public Map<String, List<Object>> getPowerqx(String date, String type,List<String> statioId) {
List<PowerCurveDto> data=null; List<PowerCurveDto> data=null;
List<Object> listx =new ArrayList<>(); List<Object> listx =new ArrayList<>();
List<Object> listy =new ArrayList<>(); List<Object> listy =new ArrayList<>();
...@@ -88,7 +88,7 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS ...@@ -88,7 +88,7 @@ public class JpStationServiceImpl extends BaseService<JpStationDto,JpStation,JpS
for (int i = 0; i < listx.size(); i++) { for (int i = 0; i < listx.size(); i++) {
if(datum.getDate().equals(listx.get(i).toString())){ if(datum.getDate().equals(listx.get(i).toString())){
listy.remove(i); listy.remove(i);
String format = new DecimalFormat("#.000").format(datum.getNum()); String format = datum.getNum()!=null?new DecimalFormat("#.000").format(datum.getNum()):"0";
listy.add(i,format); listy.add(i,format);
break; break;
} }
......
...@@ -62,14 +62,16 @@ public class MonthPowerServiceImpl extends BaseService<MonthPowerDto,MonthPower, ...@@ -62,14 +62,16 @@ public class MonthPowerServiceImpl extends BaseService<MonthPowerDto,MonthPower,
wrapperday.eq(MonthPower::getDay, formattedDateday); wrapperday.eq(MonthPower::getDay, formattedDateday);
List<MonthPower> listdday= this.list(wrapperday); List<MonthPower> listdday= this.list(wrapperday);
if(listdday!=null&&!listdday.isEmpty()){ if(listdday!=null&&!listdday.isEmpty()){
for (MonthPower monthPower : listdday) { for (MonthPower monthPower : list) {
for (MonthPower power : list) { for (MonthPower power : listdday) {
if(monthPower.getThirdStationId().equals(power.getThirdStationId())){ if(monthPower.getThirdStationId().equals(power.getThirdStationId())){
monthPower.setPower(power.getPower()); power.setCreatedTime(monthPower.getCreatedTime());
}else{
} }
} }
} }
this.saveBatch(listdday); this.saveBatch(list);
}else{ }else{
this.saveBatch(list); this.saveBatch(list);
} }
...@@ -83,14 +85,15 @@ public class MonthPowerServiceImpl extends BaseService<MonthPowerDto,MonthPower, ...@@ -83,14 +85,15 @@ public class MonthPowerServiceImpl extends BaseService<MonthPowerDto,MonthPower,
wrapper.eq(YearPower::getMonth, formattedDate); wrapper.eq(YearPower::getMonth, formattedDate);
List<YearPower> listdY= yearPowerServiceImpl.list(wrapper); List<YearPower> listdY= yearPowerServiceImpl.list(wrapper);
if(listdY!=null&&!listdY.isEmpty()){ if(listdY!=null&&!listdY.isEmpty()){
for (YearPower yearPower : listdY) { for (YearPower yearPower : listd) {
for (YearPower power : listd) { for (YearPower power : listdY) {
if(yearPower.getThirdStationId().equals(power.getThirdStationId())){ if(yearPower.getThirdStationId()!=null&&yearPower.getThirdStationId().equals(power.getThirdStationId())){
yearPower.setPower(power.getPower()); //yearPower.setPower(power.getPower());
yearPower.setCreatedTime(power.getCreatedTime());
} }
} }
} }
yearPowerServiceImpl.saveBatch(listdY); yearPowerServiceImpl.saveBatch(listd);
}else{ }else{
yearPowerServiceImpl.saveBatch(listd); yearPowerServiceImpl.saveBatch(listd);
} }
...@@ -103,14 +106,15 @@ public class MonthPowerServiceImpl extends BaseService<MonthPowerDto,MonthPower, ...@@ -103,14 +106,15 @@ public class MonthPowerServiceImpl extends BaseService<MonthPowerDto,MonthPower,
wrapper1.eq(AllPower::getYear, formattedDate1); wrapper1.eq(AllPower::getYear, formattedDate1);
List<AllPower> listdall= allPowerServiceImpl.list(wrapper1); List<AllPower> listdall= allPowerServiceImpl.list(wrapper1);
if(listdall!=null&&!listdall.isEmpty()){ if(listdall!=null&&!listdall.isEmpty()){
for (AllPower yearPower : listdall) { for (AllPower yearPower : listdy) {
for (AllPower power : listdy) { for (AllPower power : listdall) {
if(yearPower.getThirdStationId().equals(power.getThirdStationId())){ if(yearPower.getThirdStationId()!=null&&yearPower.getThirdStationId().equals(power.getThirdStationId())){
yearPower.setPower(power.getPower()); // yearPower.setPower(power.getPower());
yearPower.setCreatedTime(power.getCreatedTime());
} }
} }
} }
allPowerServiceImpl.saveBatch(listdall); allPowerServiceImpl.saveBatch(listdy);
}else{ }else{
allPowerServiceImpl.saveBatch(listdy); allPowerServiceImpl.saveBatch(listdy);
} }
......
...@@ -6,7 +6,7 @@ ...@@ -6,7 +6,7 @@
<select id="timingTemporarysSorageData" resultType="map"> <select id="timingTemporarysSorageData" resultType="map">
SELECT FORMAT( sum(value),2)as value , SELECT ROUND( sum(value),2)as value ,
created_time as createdTime , created_time as createdTime ,
equipmentIndexName equipmentIndexName
FROM FROM
......
...@@ -91,7 +91,7 @@ ...@@ -91,7 +91,7 @@
</select> </select>
<select id="projectScheduleSuperviseNum" resultType="String"> <select id="projectScheduleSuperviseNum" resultType="String">
select format((l.num/(tz_ugp_project.length/10))*100,0) as scheludel from select ROUND((l.num/(tz_ugp_project.length/10))*100,0) as scheludel from
(select q.project_id, (q.num - w.num) as num (select q.project_id, (q.num - w.num) as num
from from
(select tz_ugp_weld.project_id, count(*) as num from tz_ugp_weld where (select tz_ugp_weld.project_id, count(*) as num from tz_ugp_weld where
...@@ -137,7 +137,7 @@ ...@@ -137,7 +137,7 @@
</select> </select>
<select id="projectScheduleInspectionNum" resultType="String"> <select id="projectScheduleInspectionNum" resultType="String">
select format((l.num/(tz_ugp_project.length/10))*100,0) as scheludel from select ROUND((l.num/(tz_ugp_project.length/10))*100,0) as scheludel from
(select q.project_id, (q.num - w.num) as num (select q.project_id, (q.num - w.num) as num
from from
(select tz_ugp_weld.project_id, count(*) as num from tz_ugp_weld where (select tz_ugp_weld.project_id, count(*) as num from tz_ugp_weld where
......
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