aps-modules/aps-core/src/main/java/com/aps/core/controller/basicData/ApsGasPipelineCapacityPlanController.java
@@ -24,7 +24,7 @@ /** * æ°ä½ç®¡è·¯äº§è½è§åController * * * @author hjy * @date 2025-04-24 */ @@ -32,8 +32,7 @@ @Tag(name = "æ°ä½ç®¡è·¯äº§è½è§å", description = "æ°ä½ç®¡è·¯äº§è½è§åæ¥å£") @RestController @RequestMapping("/gasPipelineCapacityPlan") public class ApsGasPipelineCapacityPlanController extends BaseController { public class ApsGasPipelineCapacityPlanController extends BaseController { @Autowired private IApsGasPipelineCapacityPlanService apsGasPipelineCapacityPlanService; @@ -46,43 +45,42 @@ @Operation(summary = "æ¥è¯¢æ°ä½ç®¡è·¯äº§è½è§åå表", description = "å页æ¥è¯¢") @RequiresPermissions("aps:gasPipelineCapacityPlan:list") @GetMapping("/list") public TableDataInfo list(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { public TableDataInfo list(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { // startPage(); List<ApsGasPipelineCapacityPlan> list = apsGasPipelineCapacityPlanService.selectApsGasPipelineCapacityPlanList(apsGasPipelineCapacityPlan); ApsStandardProcess apsStandardProcess = new ApsStandardProcess(); apsStandardProcess.setMajor(apsGasPipelineCapacityPlan.getMajor()); apsStandardProcess.setPlant(apsGasPipelineCapacityPlan.getOrgCode()); List<ApsStandardProcess> processList = apsStandardProcessService.selectApsStandardProcessListAll(apsStandardProcess); if(list.isEmpty()){ for(ApsStandardProcess apsStandardProcessTemp : processList){ if (list.isEmpty()) { for (ApsStandardProcess apsStandardProcessTemp : processList) { ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlanTemp = new ApsGasPipelineCapacityPlan(); apsGasPipelineCapacityPlanTemp.setProcessName(apsStandardProcessTemp.getProcessName()); apsGasPipelineCapacityPlanTemp.setOrgCode(apsStandardProcessTemp.getPlant()); list.add(apsGasPipelineCapacityPlanTemp); } } if(processList.size()>list.size()){ if (processList.size() > list.size()) { List<String> newProcess = new ArrayList<>(); for(ApsStandardProcess apsStandardProcessTemp : processList){ for (ApsStandardProcess apsStandardProcessTemp : processList) { boolean flag = true; for(ApsGasPipelineCapacityPlan temp : list){ if(apsStandardProcessTemp.getProcessName().equals(temp.getProcessName())){ for (ApsGasPipelineCapacityPlan temp : list) { if (apsStandardProcessTemp.getProcessName().equals(temp.getProcessName())) { flag = false; break; } } if(flag){ if (flag) { newProcess.add(apsStandardProcessTemp.getProcessName()); } } for(String processName : newProcess){ for (String processName : newProcess) { ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlanTemp = new ApsGasPipelineCapacityPlan(); apsGasPipelineCapacityPlanTemp.setProcessName(processName); list.add(apsGasPipelineCapacityPlanTemp); } } list.sort((a, b)->a.getProcessName().compareTo(b.getProcessName())); list.sort((a, b) -> a.getProcessName().compareTo(b.getProcessName())); return getDataTable(list); } @@ -93,11 +91,30 @@ @RequiresPermissions("aps:gasPipelineCapacityPlan:export") @Log(title = "æ°ä½ç®¡è·¯äº§è½è§å", businessType = BusinessType.EXPORT) @PostMapping("/export") public void export(HttpServletResponse response, ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { public void export(HttpServletResponse response, ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { List<ApsGasPipelineCapacityPlan> list = apsGasPipelineCapacityPlanService.selectApsGasPipelineCapacityPlanList(apsGasPipelineCapacityPlan); ExcelUtil<ApsGasPipelineCapacityPlan> util = new ExcelUtil<ApsGasPipelineCapacityPlan>(ApsGasPipelineCapacityPlan.class); util.exportExcel(response, list, "æ°ä½ç®¡è·¯äº§è½è§åæ°æ®"); } /** * å¤å¶æ°ä½ç®¡è·¯äº§è½è§å */ @Operation(summary = "å¤å¶æ°ä½ç®¡è·¯äº§è½è§å", description = "å¤å¶") // @RequiresPermissions("aps:gasPipelineCapacityPlan:copy") @Log(title = "å¤å¶æ°ä½ç®¡è·¯äº§è½è§å", businessType = BusinessType.INSERT) @PutMapping("/copy") public AjaxResult copy( // æ ¼å¼ï¼yyyy-MM @RequestParam String date, @RequestParam String factory, // æ ¼å¼ï¼yyyy-MM @RequestParam String toStart, // æ ¼å¼ï¼yyyy-MM @RequestParam String toEnd) { apsGasPipelineCapacityPlanService.copyPlan(date, factory, toStart, toEnd); return success(); } /** @@ -106,8 +123,7 @@ @Operation(summary = "è·åæ°ä½ç®¡è·¯äº§è½è§å详ç»ä¿¡æ¯", description = "æ ¹æ®idè·å") @RequiresPermissions("aps:gasPipelineCapacityPlan:query") @GetMapping(value = "/{id}") public AjaxResult getInfo(@PathVariable("id") Long id) { public AjaxResult getInfo(@PathVariable("id") Long id) { return success(apsGasPipelineCapacityPlanService.selectApsGasPipelineCapacityPlanById(id)); } @@ -118,14 +134,13 @@ @RequiresPermissions("aps:gasPipelineCapacityPlan:add") @Log(title = "æ°ä½ç®¡è·¯äº§è½è§å", businessType = BusinessType.INSERT) @PostMapping public AjaxResult add(@RequestBody List<ApsGasPipelineCapacityPlan> apsGasPipelineCapacityPlan) { public AjaxResult add(@RequestBody List<ApsGasPipelineCapacityPlan> apsGasPipelineCapacityPlan) { apsGasPipelineCapacityPlan.forEach(apsGasPipelineCapacityPlanTemp -> { if(apsGasPipelineCapacityPlanTemp.getId()==null){ if (apsGasPipelineCapacityPlanTemp.getId() == null) { apsGasPipelineCapacityPlanTemp.setCreateBy(SecurityUtils.getUsername()); apsGasPipelineCapacityPlanTemp.setCreateTime(DateUtils.getNowDate()); apsGasPipelineCapacityPlanService.insertApsGasPipelineCapacityPlan(apsGasPipelineCapacityPlanTemp); }else{ } else { apsGasPipelineCapacityPlanTemp.setUpdateBy(SecurityUtils.getUsername()); apsGasPipelineCapacityPlanTemp.setUpdateTime(DateUtils.getNowDate()); apsGasPipelineCapacityPlanService.updateApsGasPipelineCapacityPlan(apsGasPipelineCapacityPlanTemp); @@ -141,8 +156,7 @@ @RequiresPermissions("aps:gasPipelineCapacityPlan:edit") @Log(title = "æ°ä½ç®¡è·¯äº§è½è§å", businessType = BusinessType.UPDATE) @PutMapping public AjaxResult edit(@RequestBody ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { public AjaxResult edit(@RequestBody ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { return toAjax(apsGasPipelineCapacityPlanService.updateApsGasPipelineCapacityPlan(apsGasPipelineCapacityPlan)); } @@ -152,9 +166,8 @@ @Operation(summary = "å 餿°ä½ç®¡è·¯äº§è½è§å", description = "æ¹éå é¤") @RequiresPermissions("aps:gasPipelineCapacityPlan:remove") @Log(title = "æ°ä½ç®¡è·¯äº§è½è§å", businessType = BusinessType.DELETE) @DeleteMapping("/{ids}") public AjaxResult remove(@PathVariable Long[] ids) { @DeleteMapping("/{ids}") public AjaxResult remove(@PathVariable Long[] ids) { return toAjax(apsGasPipelineCapacityPlanService.deleteApsGasPipelineCapacityPlanByIds(ids)); } } aps-modules/aps-core/src/main/java/com/aps/core/controller/mainPlan/ApsGasPipelineMoController.java
@@ -130,11 +130,11 @@ */ @SneakyThrows @Operation(summary = "ä¸è½½æ°ä½å·¥åæ°æ®å¯¼å ¥æ¨¡æ¿", description = "ä¸è½½æ°ä½å·¥åæ°æ®å¯¼å ¥æ¨¡æ¿") @RequiresPermissions("gasPipeline:mo:template") @Log(title = "ä¸è½½æ°ä½å·¥åæ°æ®å¯¼å ¥æ¨¡æ¿", businessType = BusinessType.EXPORT) // @RequiresPermissions("gasPipeline:mo:template") // @Log(title = "ä¸è½½æ°ä½å·¥åæ°æ®å¯¼å ¥æ¨¡æ¿", businessType = BusinessType.EXPORT) @GetMapping("/template") public ResponseEntity<ByteArrayResource> exportTemplate() { byte[] file = IOUtils.resourceToByteArray("/templates/ä¸ä¼ æ°ä½å·¥åæ°æ®æ¨¡æ¿.xlsx"); byte[] file = IOUtils.resourceToByteArray("/templates/æ°ä½å·¥åæ°æ®æ¨¡æ¿v1.0.xlsx"); ByteArrayResource resource = new ByteArrayResource(file); return ResponseEntity.ok() .header(HttpHeaders.CONTENT_DISPOSITION, aps-modules/aps-core/src/main/java/com/aps/core/controller/mainPlan/ApsGasPipelinePredictionController.java
@@ -70,11 +70,11 @@ */ @SneakyThrows @Operation(summary = "ä¸è½½æ°ä½é¢æµæ°æ®å¯¼å ¥æ¨¡æ¿", description = "ä¸è½½æ°ä½é¢æµæ°æ®å¯¼å ¥æ¨¡æ¿") @RequiresPermissions("gasPipeline:prediction:template") @Log(title = "ä¸è½½æ°ä½é¢æµæ°æ®å¯¼å ¥æ¨¡æ¿", businessType = BusinessType.EXPORT) // @RequiresPermissions("gasPipeline:prediction:template") // @Log(title = "ä¸è½½æ°ä½é¢æµæ°æ®å¯¼å ¥æ¨¡æ¿", businessType = BusinessType.EXPORT) @GetMapping("/template") public ResponseEntity<ByteArrayResource> exportTemplate() { byte[] file = IOUtils.resourceToByteArray("/templates/ä¸ä¼ æ°ä½é¢æµæ°æ®æ¨¡æ¿.xlsx"); byte[] file = IOUtils.resourceToByteArray("/templates/æ°ä½é¢æµæ°æ®æ¨¡æ¿v1.0.xlsx"); ByteArrayResource resource = new ByteArrayResource(file); return ResponseEntity.ok() .header(HttpHeaders.CONTENT_DISPOSITION, aps-modules/aps-core/src/main/java/com/aps/core/domain/ApsGasPipelineCapacityPlan.java
@@ -2,6 +2,7 @@ import com.aps.common.core.annotation.Excel; import com.aps.common.core.web.domain.BaseEntity; import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.v3.oas.annotations.media.Schema; import org.apache.commons.lang3.builder.ToStringBuilder; import org.apache.commons.lang3.builder.ToStringStyle; @@ -20,6 +21,7 @@ private static final long serialVersionUID = 1L; /** 主é®id */ @JsonFormat(shape = JsonFormat.Shape.STRING) @Schema(description = "主é®id", type = "Long") private Long id; aps-modules/aps-core/src/main/java/com/aps/core/mapper/ApsGasPipelineCapacityPlanMapper.java
@@ -61,4 +61,6 @@ * @return ç»æ */ public int deleteApsGasPipelineCapacityPlanByIds(Long[] ids); void deleteByDateAndFactory(String year, String month, String factory); } aps-modules/aps-core/src/main/java/com/aps/core/service/IApsGasPipelineCapacityPlanService.java
@@ -59,4 +59,6 @@ * @return ç»æ */ public int deleteApsGasPipelineCapacityPlanById(Long id); void copyPlan(String date, String factory, String toStart, String toEnd); } aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsGasPipelineCapacityPlanServiceImpl.java
@@ -5,56 +5,59 @@ import com.aps.core.domain.ApsGasPipelineCapacityPlan; import com.aps.core.mapper.ApsGasPipelineCapacityPlanMapper; import com.aps.core.service.IApsGasPipelineCapacityPlanService; import lombok.SneakyThrows; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.sql.Timestamp; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.util.Calendar; import java.util.Date; import java.util.List; /** * æ°ä½ç®¡è·¯äº§è½è§åServiceä¸å¡å±å¤ç * * * @author hjy * @date 2025-04-24 */ @Service public class ApsGasPipelineCapacityPlanServiceImpl implements IApsGasPipelineCapacityPlanService { public class ApsGasPipelineCapacityPlanServiceImpl implements IApsGasPipelineCapacityPlanService { @Autowired private ApsGasPipelineCapacityPlanMapper apsGasPipelineCapacityPlanMapper; /** * æ¥è¯¢æ°ä½ç®¡è·¯äº§è½è§å * * * @param id æ°ä½ç®¡è·¯äº§è½è§åä¸»é® * @return æ°ä½ç®¡è·¯äº§è½è§å */ @Override public ApsGasPipelineCapacityPlan selectApsGasPipelineCapacityPlanById(Long id) { public ApsGasPipelineCapacityPlan selectApsGasPipelineCapacityPlanById(Long id) { return apsGasPipelineCapacityPlanMapper.selectApsGasPipelineCapacityPlanById(id); } /** * æ¥è¯¢æ°ä½ç®¡è·¯äº§è½è§åå表 * * * @param apsGasPipelineCapacityPlan æ°ä½ç®¡è·¯äº§è½è§å * @return æ°ä½ç®¡è·¯äº§è½è§å */ @Override public List<ApsGasPipelineCapacityPlan> selectApsGasPipelineCapacityPlanList(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { public List<ApsGasPipelineCapacityPlan> selectApsGasPipelineCapacityPlanList(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { return apsGasPipelineCapacityPlanMapper.selectApsGasPipelineCapacityPlanList(apsGasPipelineCapacityPlan); } /** * æ°å¢æ°ä½ç®¡è·¯äº§è½è§å * * * @param apsGasPipelineCapacityPlan æ°ä½ç®¡è·¯äº§è½è§å * @return ç»æ */ @Override public int insertApsGasPipelineCapacityPlan(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { public int insertApsGasPipelineCapacityPlan(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { apsGasPipelineCapacityPlan.setCreateTime(DateUtils.getNowDate()); apsGasPipelineCapacityPlan.setCreateBy(SecurityUtils.getUsername()); return apsGasPipelineCapacityPlanMapper.insertApsGasPipelineCapacityPlan(apsGasPipelineCapacityPlan); @@ -62,13 +65,12 @@ /** * ä¿®æ¹æ°ä½ç®¡è·¯äº§è½è§å * * * @param apsGasPipelineCapacityPlan æ°ä½ç®¡è·¯äº§è½è§å * @return ç»æ */ @Override public int updateApsGasPipelineCapacityPlan(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { public int updateApsGasPipelineCapacityPlan(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) { apsGasPipelineCapacityPlan.setUpdateTime(DateUtils.getNowDate()); apsGasPipelineCapacityPlan.setUpdateBy(SecurityUtils.getUsername()); return apsGasPipelineCapacityPlanMapper.updateApsGasPipelineCapacityPlan(apsGasPipelineCapacityPlan); @@ -76,25 +78,65 @@ /** * æ¹éå 餿°ä½ç®¡è·¯äº§è½è§å * * * @param ids éè¦å é¤çæ°ä½ç®¡è·¯äº§è½è§åä¸»é® * @return ç»æ */ @Override public int deleteApsGasPipelineCapacityPlanByIds(Long[] ids) { public int deleteApsGasPipelineCapacityPlanByIds(Long[] ids) { return apsGasPipelineCapacityPlanMapper.deleteApsGasPipelineCapacityPlanByIds(ids); } /** * å 餿°ä½ç®¡è·¯äº§è½è§åä¿¡æ¯ * * * @param id æ°ä½ç®¡è·¯äº§è½è§åä¸»é® * @return ç»æ */ @Override public int deleteApsGasPipelineCapacityPlanById(Long id) { public int deleteApsGasPipelineCapacityPlanById(Long id) { return apsGasPipelineCapacityPlanMapper.deleteApsGasPipelineCapacityPlanById(id); } @SneakyThrows @Override @Transactional(rollbackFor = Exception.class) public void copyPlan(String date, String factory, String toStart, String toEnd) { String[] dtSrc = date.split("-"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM"); Calendar dtStart = Calendar.getInstance(); dtStart.setTime(sdf.parse(toStart)); dtStart.set(Calendar.DAY_OF_MONTH, 1); Calendar dtEnd = Calendar.getInstance(); dtEnd.setTime(sdf.parse(toEnd)); dtEnd.set(Calendar.DAY_OF_MONTH, 2); ApsGasPipelineCapacityPlan plan = new ApsGasPipelineCapacityPlan(); plan.setYear(Integer.valueOf(dtSrc[0]).toString()); plan.setMonth(Integer.valueOf(dtSrc[1]).toString()); plan.setOrgCode(factory); List<ApsGasPipelineCapacityPlan> templatePlans = apsGasPipelineCapacityPlanMapper.selectApsGasPipelineCapacityPlanList(plan); while (dtStart.before(dtEnd)) { String year = dtStart.get(Calendar.YEAR) + ""; String month = (dtStart.get(Calendar.MONTH) + 1) + ""; apsGasPipelineCapacityPlanMapper.deleteByDateAndFactory( year, month, factory ); templatePlans.forEach(p -> { p.setYear(year); p.setMonth(month); p.setCreateBy(SecurityUtils.getUsername()); p.setCreateTime(new Date()); p.setUpdateBy(null); p.setUpdateTime(null); apsGasPipelineCapacityPlanMapper.insertApsGasPipelineCapacityPlan(p); }); dtStart.add(Calendar.MONTH, 1); } } } aps-modules/aps-core/src/main/resources/mapper/core/ApsGasPipelineCapacityPlanMapper.xml
@@ -133,4 +133,11 @@ #{id} </foreach> </delete> <delete id="deleteByDateAndFactory" > delete from aps_gas_pipeline_capacity_plan where year = #{year} and month = #{month} and org_code = #{factory} </delete> </mapper> aps-modules/aps-core/src/main/resources/templates/ÉÏ´«ÆøÌ幤µ¥Êý¾ÝÄ£°å.xlsxBinary files differ
aps-modules/aps-core/src/main/resources/templates/ÉÏ´«ÆøÌåÔ¤²âÊý¾ÝÄ£°å.xlsxBinary files differ
aps-modules/aps-core/src/main/resources/templates/ÆøÌ幤µ¥Êý¾ÝÄ£°åv1.0.xlsxBinary files differ
aps-modules/aps-core/src/main/resources/templates/ÆøÌåÔ¤²âÊý¾ÝÄ£°åv1.0.xlsxBinary files differ