diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpD.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpD.java new file mode 100644 index 000000000..1dc651a25 --- /dev/null +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpD.java @@ -0,0 +1,206 @@ +package com.njcn.prepare.harmonic.pojo.po; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.njcn.db.bo.BaseEntity; +import java.io.Serializable; +import java.time.LocalDate; +import lombok.Getter; +import lombok.Setter; + +/** + *

+ * 母线越限详情 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +@Getter +@Setter +@TableName("r_dim_bus_up_d") +public class RDimBusUpD extends BaseEntity { + + private static final long serialVersionUID = 1L; + + private LocalDate statisticDate; + + private String phasicType; + + private String busId; + + private String midBusId; + + private String effectId; + + private String effectIds; + + private String vlotageLevel; + + private Integer v; + + private Integer allTime; + + private Integer flickerAllTime; + + private Integer freqDevOvertime; + + private Integer voltageDevOvertime; + + private Integer ubalanceOvertime; + + private Integer flickerOvertime; + + private Integer uaberranceOvertime; + + private Integer iNegOvertime; + + @TableField(value = "uharm_2_overtime") + private Integer uharm2Overtime; + + @TableField(value = "uharm_3_overtime") + private Integer uharm3Overtime; + + @TableField(value = "uharm_4_overtime") + private Integer uharm4Overtime; + + @TableField(value = "uharm_5_overtime") + private Integer uharm5Overtime; + + @TableField(value = "uharm_6_overtime") + private Integer uharm6Overtime; + + @TableField(value = "uharm_7_overtime") + private Integer uharm7Overtime; + + @TableField(value = "uharm_8_overtime") + private Integer uharm8Overtime; + + @TableField(value = "uharm_9_overtime") + private Integer uharm9Overtime; + + @TableField(value = "uharm_10_overtime") + private Integer uharm10Overtime; + + @TableField(value = "uharm_11_overtime") + private Integer uharm11Overtime; + + @TableField(value = "uharm_12_overtime") + private Integer uharm12Overtime; + + @TableField(value = "uharm_13_overtime") + private Integer uharm13Overtime; + + @TableField(value = "uharm_14_overtime") + private Integer uharm14Overtime; + + @TableField(value = "uharm_15_overtime") + private Integer uharm15Overtime; + + @TableField(value = "uharm_16_overtime") + private Integer uharm16Overtime; + + @TableField(value = "uharm_17_overtime") + private Integer uharm17Overtime; + + @TableField(value = "uharm_18_overtime") + private Integer uharm18Overtime; + + @TableField(value = "uharm_19_overtime") + private Integer uharm19Overtime; + + @TableField(value = "uharm_20_overtime") + private Integer uharm20Overtime; + + @TableField(value = "uharm_21_overtime") + private Integer uharm21Overtime; + + @TableField(value = "uharm_22_overtime") + private Integer uharm22Overtime; + + @TableField(value = "uharm_23_overtime") + private Integer uharm23Overtime; + + @TableField(value = "uharm_24_overtime") + private Integer uharm24Overtime; + + @TableField(value = "uharm_25_overtime") + private Integer uharm25Overtime; + + @TableField(value = "uharm_26_overtime") + private Integer uharm26Overtime; + + @TableField(value = "uharm_27_overtime") + private Integer uharm27Overtime; + + @TableField(value = "uharm_28_overtime") + private Integer uharm28Overtime; + + @TableField(value = "uharm_29_overtime") + private Integer uharm29Overtime; + + @TableField(value = "uharm_30_overtime") + private Integer uharm30Overtime; + + @TableField(value = "uharm_31_overtime") + private Integer uharm31Overtime; + + @TableField(value = "uharm_32_overtime") + private Integer uharm32Overtime; + + @TableField(value = "uharm_33_overtime") + private Integer uharm33Overtime; + + @TableField(value = "uharm_34_overtime") + private Integer uharm34Overtime; + + @TableField(value = "uharm_35_overtime") + private Integer uharm35Overtime; + + @TableField(value = "uharm_36_overtime") + private Integer uharm36Overtime; + + @TableField(value = "uharm_37_overtime") + private Integer uharm37Overtime; + + @TableField(value = "uharm_38_overtime") + private Integer uharm38Overtime; + + @TableField(value = "uharm_39_overtime") + private Integer uharm39Overtime; + + @TableField(value = "uharm_40_overtime") + private Integer uharm40Overtime; + + @TableField(value = "uharm_41_overtime") + private Integer uharm41Overtime; + + @TableField(value = "uharm_42_overtime") + private Integer uharm42Overtime; + + @TableField(value = "uharm_43_overtime") + private Integer uharm43Overtime; + + @TableField(value = "uharm_44_overtime") + private Integer uharm44Overtime; + + @TableField(value = "uharm_45_overtime") + private Integer uharm45Overtime; + + @TableField(value = "uharm_46_overtime") + private Integer uharm46Overtime; + + @TableField(value = "uharm_47_overtime") + private Integer uharm47Overtime; + + @TableField(value = "uharm_48_overtime") + private Integer uharm48Overtime; + + @TableField(value = "uharm_49_overtime") + private Integer uharm49Overtime; + + @TableField(value = "uharm_50_overtime") + private Integer uharm50Overtime; + + +} diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpM.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpM.java new file mode 100644 index 000000000..03669a997 --- /dev/null +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpM.java @@ -0,0 +1,154 @@ +package com.njcn.prepare.harmonic.pojo.po; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.njcn.db.bo.BaseEntity; +import java.io.Serializable; +import java.time.LocalDate; +import lombok.Getter; +import lombok.Setter; + +/** + *

+ * 母线越限详情 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +@Getter +@Setter +@TableName("r_dim_bus_up_m") +public class RDimBusUpM extends BaseEntity { + + private static final long serialVersionUID = 1L; + + private LocalDate statisticDate; + + private String phasicType; + + private String busId; + + private String effectId; + + private String effectIds; + + private String vlotageLevel; + + private Integer v; + + private Integer allTime; + + private Integer flickerAllTime; + + private Integer freqDevOvertime; + + private Integer voltageDevOvertime; + + private Integer ubalanceOvertime; + + private Integer flickerOvertime; + + private Integer uaberranceOvertime; + + private Integer iNegOvertime; + + private Integer uharm2Overtime; + + private Integer uharm3Overtime; + + private Integer uharm4Overtime; + + private Integer uharm5Overtime; + + private Integer uharm6Overtime; + + private Integer uharm7Overtime; + + private Integer uharm8Overtime; + + private Integer uharm9Overtime; + + private Integer uharm10Overtime; + + private Integer uharm11Overtime; + + private Integer uharm12Overtime; + + private Integer uharm13Overtime; + + private Integer uharm14Overtime; + + private Integer uharm15Overtime; + + private Integer uharm16Overtime; + + private Integer uharm17Overtime; + + private Integer uharm18Overtime; + + private Integer uharm19Overtime; + + private Integer uharm20Overtime; + + private Integer uharm21Overtime; + + private Integer uharm22Overtime; + + private Integer uharm23Overtime; + + private Integer uharm24Overtime; + + private Integer uharm25Overtime; + + private Integer uharm26Overtime; + + private Integer uharm27Overtime; + + private Integer uharm28Overtime; + + private Integer uharm29Overtime; + + private Integer uharm30Overtime; + + private Integer uharm31Overtime; + + private Integer uharm32Overtime; + + private Integer uharm33Overtime; + + private Integer uharm34Overtime; + + private Integer uharm35Overtime; + + private Integer uharm36Overtime; + + private Integer uharm37Overtime; + + private Integer uharm38Overtime; + + private Integer uharm39Overtime; + + private Integer uharm40Overtime; + + private Integer uharm41Overtime; + + private Integer uharm42Overtime; + + private Integer uharm43Overtime; + + private Integer uharm44Overtime; + + private Integer uharm45Overtime; + + private Integer uharm46Overtime; + + private Integer uharm47Overtime; + + private Integer uharm48Overtime; + + private Integer uharm49Overtime; + + private Integer uharm50Overtime; + + +} diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpY.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpY.java new file mode 100644 index 000000000..374f3b3de --- /dev/null +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/pojo/po/RDimBusUpY.java @@ -0,0 +1,154 @@ +package com.njcn.prepare.harmonic.pojo.po; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.njcn.db.bo.BaseEntity; +import java.io.Serializable; +import java.time.LocalDate; +import lombok.Getter; +import lombok.Setter; + +/** + *

+ * 母线越限详情 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +@Getter +@Setter +@TableName("r_dim_bus_up_y") +public class RDimBusUpY extends BaseEntity { + + private static final long serialVersionUID = 1L; + + private LocalDate statisticDate; + + private String phasicType; + + private String busId; + + private String effectId; + + private String effectIds; + + private String vlotageLevel; + + private Integer v; + + private Integer allTime; + + private Integer flickerAllTime; + + private Integer freqDevOvertime; + + private Integer voltageDevOvertime; + + private Integer ubalanceOvertime; + + private Integer flickerOvertime; + + private Integer uaberranceOvertime; + + private Integer iNegOvertime; + + private Integer uharm2Overtime; + + private Integer uharm3Overtime; + + private Integer uharm4Overtime; + + private Integer uharm5Overtime; + + private Integer uharm6Overtime; + + private Integer uharm7Overtime; + + private Integer uharm8Overtime; + + private Integer uharm9Overtime; + + private Integer uharm10Overtime; + + private Integer uharm11Overtime; + + private Integer uharm12Overtime; + + private Integer uharm13Overtime; + + private Integer uharm14Overtime; + + private Integer uharm15Overtime; + + private Integer uharm16Overtime; + + private Integer uharm17Overtime; + + private Integer uharm18Overtime; + + private Integer uharm19Overtime; + + private Integer uharm20Overtime; + + private Integer uharm21Overtime; + + private Integer uharm22Overtime; + + private Integer uharm23Overtime; + + private Integer uharm24Overtime; + + private Integer uharm25Overtime; + + private Integer uharm26Overtime; + + private Integer uharm27Overtime; + + private Integer uharm28Overtime; + + private Integer uharm29Overtime; + + private Integer uharm30Overtime; + + private Integer uharm31Overtime; + + private Integer uharm32Overtime; + + private Integer uharm33Overtime; + + private Integer uharm34Overtime; + + private Integer uharm35Overtime; + + private Integer uharm36Overtime; + + private Integer uharm37Overtime; + + private Integer uharm38Overtime; + + private Integer uharm39Overtime; + + private Integer uharm40Overtime; + + private Integer uharm41Overtime; + + private Integer uharm42Overtime; + + private Integer uharm43Overtime; + + private Integer uharm44Overtime; + + private Integer uharm45Overtime; + + private Integer uharm46Overtime; + + private Integer uharm47Overtime; + + private Integer uharm48Overtime; + + private Integer uharm49Overtime; + + private Integer uharm50Overtime; + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpDMapper.java new file mode 100644 index 000000000..f43c94684 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpDMapper.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.mapper.mysql.upload; + + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpD; + +/** + *

+ * 母线越限详情 Mapper 接口 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +public interface RDimBusUpDMapper extends BaseMapper { + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpMMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpMMapper.java new file mode 100644 index 000000000..4f005cd6c --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpMMapper.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.mapper.mysql.upload; + + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpM; + +/** + *

+ * 母线越限详情 Mapper 接口 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +public interface RDimBusUpMMapper extends BaseMapper { + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpYMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpYMapper.java new file mode 100644 index 000000000..1bb272c2b --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/upload/RDimBusUpYMapper.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.mapper.mysql.upload; + + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpY; + +/** + *

+ * 母线越限详情 Mapper 接口 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +public interface RDimBusUpYMapper extends BaseMapper { + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpDService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpDService.java new file mode 100644 index 000000000..b189afafd --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpDService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.upload; + + +import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpD; + +/** + *

+ * 母线越限详情 服务类 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +public interface IRDimBusUpDService extends IService { + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpMService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpMService.java new file mode 100644 index 000000000..3a09f1fd3 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpMService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.upload; + + +import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpM; + +/** + *

+ * 母线越限详情 服务类 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +public interface IRDimBusUpMService extends IService { + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpYService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpYService.java new file mode 100644 index 000000000..107052733 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/IRDimBusUpYService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.upload; + + +import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpY; + +/** + *

+ * 母线越限详情 服务类 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +public interface IRDimBusUpYService extends IService { + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/PmsRunStatisticMServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/PmsRunStatisticMServiceImpl.java index 4c3f1c636..654e6fcb5 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/PmsRunStatisticMServiceImpl.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/PmsRunStatisticMServiceImpl.java @@ -61,6 +61,8 @@ public class PmsRunStatisticMServiceImpl extends MppServiceImpl busRunSet = new HashSet<>(); Set stationSet = new HashSet<>(); + Set devRunSet = new HashSet<>(); + Set typicalSet = new HashSet<>(); val.forEach(item->{ if(StrUtil.isNotBlank(item.getRunMonitorIds())){ @@ -83,12 +85,16 @@ public class PmsRunStatisticMServiceImpl extends MppServiceImpl implements IPmsRunStatisticYService { - private final PmsRunStatisticMMapper pmsRunStatisticMMapper; + private final PmsRunStatisticDMapper pmsRunStatisticDMapper; @@ -46,10 +48,10 @@ public class PmsRunStatisticYServiceImpl extends MppServiceImpl lambdaQueryWrapper = new LambdaQueryWrapper<>(); - lambdaQueryWrapper.between(PmsRunStatisticM::getStatisticDate,begin,end); - List pmsRunStatisticDList = pmsRunStatisticMMapper.selectList(lambdaQueryWrapper); - Map> map = pmsRunStatisticDList.stream().collect(Collectors.groupingBy(PmsRunStatisticM::getDeptId)); + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.between(PmsRunStatisticD::getStatisticDate,begin,end); + List pmsRunStatisticDList = pmsRunStatisticDMapper.selectList(lambdaQueryWrapper); + Map> map = pmsRunStatisticDList.stream().collect(Collectors.groupingBy(PmsRunStatisticD::getDeptId)); map.forEach((key,val)->{ PmsRunStatisticY pmsRunStatisticY = new PmsRunStatisticY(); @@ -63,6 +65,8 @@ public class PmsRunStatisticYServiceImpl extends MppServiceImpl busRunSet = new HashSet<>(); Set stationSet = new HashSet<>(); + Set devRunSet = new HashSet<>(); + Set typicalSet = new HashSet<>(); val.forEach(item->{ if(StrUtil.isNotBlank(item.getRunMonitorIds())){ @@ -85,18 +89,21 @@ public class PmsRunStatisticYServiceImpl extends MppServiceImpl + * 母线越限详情 服务实现类 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +@Service +public class RDimBusUpDServiceImpl extends ServiceImpl implements IRDimBusUpDService { + + // void handBusDay(); + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/RDimBusUpMServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/RDimBusUpMServiceImpl.java new file mode 100644 index 000000000..b661b7c62 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/RDimBusUpMServiceImpl.java @@ -0,0 +1,21 @@ +package com.njcn.prepare.harmonic.service.mysql.upload.impl; + + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.mapper.mysql.upload.RDimBusUpMMapper; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpM; +import com.njcn.prepare.harmonic.service.mysql.upload.IRDimBusUpMService; +import org.springframework.stereotype.Service; + +/** + *

+ * 母线越限详情 服务实现类 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +@Service +public class RDimBusUpMServiceImpl extends ServiceImpl implements IRDimBusUpMService { + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/RDimBusUpYServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/RDimBusUpYServiceImpl.java new file mode 100644 index 000000000..61c5cd4ff --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/upload/impl/RDimBusUpYServiceImpl.java @@ -0,0 +1,21 @@ +package com.njcn.prepare.harmonic.service.mysql.upload.impl; + + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.mapper.mysql.upload.RDimBusUpYMapper; +import com.njcn.prepare.harmonic.pojo.po.RDimBusUpY; +import com.njcn.prepare.harmonic.service.mysql.upload.IRDimBusUpYService; +import org.springframework.stereotype.Service; + +/** + *

+ * 母线越限详情 服务实现类 + *

+ * + * @author cdf + * @since 2024-05-09 + */ +@Service +public class RDimBusUpYServiceImpl extends ServiceImpl implements IRDimBusUpYService { + +}