|
@@ -1,14 +1,14 @@
|
|
package com.cpp.web.service.datafactory.impl;
|
|
package com.cpp.web.service.datafactory.impl;
|
|
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
import cn.hutool.json.JSONUtil;
|
|
-import com.cpp.web.domain.alarm.AbnormalAlarm;
|
|
|
|
import com.cpp.web.domain.datafactory.BaseParsing;
|
|
import com.cpp.web.domain.datafactory.BaseParsing;
|
|
import com.cpp.web.domain.datafactory.dto.ParsingResultDto;
|
|
import com.cpp.web.domain.datafactory.dto.ParsingResultDto;
|
|
import com.cpp.web.domain.datafactory.enums.FileTypeEnum;
|
|
import com.cpp.web.domain.datafactory.enums.FileTypeEnum;
|
|
import com.cpp.web.domain.enums.AlarmEnum;
|
|
import com.cpp.web.domain.enums.AlarmEnum;
|
|
import com.cpp.web.domain.enums.DataSourcesEnum;
|
|
import com.cpp.web.domain.enums.DataSourcesEnum;
|
|
-import com.cpp.web.service.alarm.AbnormalAlarmService;
|
|
|
|
|
|
+import com.cpp.web.domain.overhaulplan.OverhaulPlan;
|
|
import com.cpp.web.service.datafactory.ParsingInterface;
|
|
import com.cpp.web.service.datafactory.ParsingInterface;
|
|
|
|
+import com.cpp.web.service.overhaulplan.OverhaulPlanService;
|
|
import com.cpp.web.utils.LogUtil;
|
|
import com.cpp.web.utils.LogUtil;
|
|
import com.cpp.web.utils.ParsingFileUtil;
|
|
import com.cpp.web.utils.ParsingFileUtil;
|
|
import lombok.AllArgsConstructor;
|
|
import lombok.AllArgsConstructor;
|
|
@@ -35,7 +35,7 @@ import java.util.List;
|
|
@Transactional
|
|
@Transactional
|
|
public class ParsingStatusServiceImpl implements ParsingInterface {
|
|
public class ParsingStatusServiceImpl implements ParsingInterface {
|
|
|
|
|
|
- private final AbnormalAlarmService abnormalAlarmService;
|
|
|
|
|
|
+ private final OverhaulPlanService overhaulPlanService;
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public boolean save(BaseParsing parsingInfo) {
|
|
public boolean save(BaseParsing parsingInfo) {
|
|
@@ -108,8 +108,20 @@ public class ParsingStatusServiceImpl implements ParsingInterface {
|
|
LogUtil.info(DataSourcesEnum.E1, AlarmEnum.E3, LogUtil.format("站端磁盘空间达到 {}%,请关注!", this.hardDiskCapacity), stationCode);
|
|
LogUtil.info(DataSourcesEnum.E1, AlarmEnum.E3, LogUtil.format("站端磁盘空间达到 {}%,请关注!", this.hardDiskCapacity), stationCode);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- if (this.restrictedPlans != null&&restrictedPlans.size()>0) {
|
|
|
|
|
|
+ if (this.restrictedPlans != null && restrictedPlans.size() > 0) {
|
|
|
|
+ List<OverhaulPlan> overhaulPlans = new ArrayList<>();
|
|
|
|
+ for (RestrictedPlan restrictedPlan : restrictedPlans) {
|
|
|
|
+ OverhaulPlan overhaulPlan = new OverhaulPlan();
|
|
|
|
+ overhaulPlan.setDescription(restrictedPlan.getDescribe());
|
|
|
|
+ overhaulPlan.setEndTime(restrictedPlan.getEndTime());
|
|
|
|
+ overhaulPlan.setStartTime(restrictedPlan.startTime);
|
|
|
|
+ overhaulPlan.setOverhaulCapacity(restrictedPlan.getCapacity());
|
|
|
|
+ overhaulPlan.setStationCode(stationCode);
|
|
|
|
+ overhaulPlan.setName(restrictedPlan.getPlanName());
|
|
|
|
+ overhaulPlans.add(overhaulPlan);
|
|
|
|
+ }
|
|
|
|
|
|
|
|
+ overhaulPlanService.saveBatch(overhaulPlans);
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|