帷幄君成-富创-后端代码
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
huangjiayang
2025-04-27 da7ca397f86db83e6113f792ad819adb9f73d9e7 
 aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPartRouteStatServiceImpl.java


@@ -3,20 +3,38 @@


import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.ZoneId;


import java.time.format.DateTimeFormatter;


import java.time.temporal.ChronoUnit;


import java.util.*;


import java.util.stream.Collectors;




import com.aps.common.core.utils.poi.ExcelUtil;


import com.aps.common.core.utils.uuid.IdUtils;


import com.aps.common.core.web.domain.AjaxResult;


import com.aps.core.domain.ApsPartPlan;


import com.aps.core.domain.ApsResourceDateStat;


import com.aps.core.domain.ApsResourceGroup;


import com.aps.core.mapper.ApsAbnormalProcessAnalysisMapper;


import com.aps.core.mapper.ApsResourceGroupMapper;


import com.aps.core.service.IApsAbnormalProcessAnalysisService;


import jakarta.annotation.Resource;


import jakarta.servlet.http.HttpServletResponse;


import lombok.extern.slf4j.Slf4j;


import org.apache.poi.ss.usermodel.*;


import org.apache.poi.ss.util.CellRangeAddress;


import org.apache.poi.util.IOUtils;


import org.apache.poi.util.Removal;


import org.apache.poi.xssf.streaming.SXSSFCell;


import org.apache.poi.xssf.streaming.SXSSFRow;


import org.apache.poi.xssf.streaming.SXSSFSheet;


import org.apache.poi.xssf.streaming.SXSSFWorkbook;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import com.aps.core.mapper.ApsPartRouteStatMapper;


import com.aps.core.domain.ApsPartRouteStat;


import com.aps.core.service.IApsPartRouteStatService;


import org.springframework.transaction.annotation.Transactional;




import static java.util.stream.Collectors.groupingBy;




@@ -26,13 +44,20 @@


 * @author zhl


 * @date 2025-04-11


 */


@Slf4j


@Service


public class ApsPartRouteStatServiceImpl implements IApsPartRouteStatService 


{




    @Autowired


    private ApsPartRouteStatMapper apsPartRouteStatMapper;


    @Autowired


    private ApsResourceGroupMapper resourceGroupMapper;


    @Autowired


    private ApsResourceGroupMapper apsResourceGroupMapper;




    @Resource


    private IApsAbnormalProcessAnalysisService analysisService;




    /**


     * 查询零件统计表


@@ -112,6 +137,7 @@


    /**


     * 查询零件工序并更新计划开工日期


     * */


    @Transactional


    @Override


    public void updatePartRoutPlanDate() {


        List<ApsPartRouteStat> tempList = apsPartRouteStatMapper.selectPartRoutStat();


@@ -131,24 +157,31 @@


                /*判断当前工序 当前工序只有一条*/


                if (stat.getCurrentProcessNumber().equals(stat.getRoadProcessNumber())) {


                    /* 对 stat.getProcessPlanStartDay() 和当前日期 进行对比，只对比到日，不用管十分秒*/


                    if (stat.getProcessPlanStartDay().toLocalDate().isBefore(LocalDateTime.now().toLocalDate())) {


                        stat.setProcessPlanStartDay(LocalDateTime.now());


                    LocalDate startLocalDate = LocalDate.ofInstant(stat.getProcessPlanStartDay().toInstant(), ZoneId.systemDefault());


                    LocalDate nowLocalDate = LocalDate.now();


                    if (startLocalDate.isBefore(nowLocalDate)) {


                        stat.setProcessPlanStartDay(new Date());


                    }


                }


                /*未开工工序的计划开工日=上一道工序的计划开工日+上一道工序的工序总工时。*/


                if (stat.getCurrentProcessNumber().compareTo(stat.getRoadProcessNumber()) < 0) {


                    if (last != null) {


                        stat.setProcessPlanStartDay(last.getProcessPlanStartDay().plusHours(last.getProcessTotalTime()));


                        LocalDateTime lastStartDate = LocalDateTime.ofInstant(last.getProcessPlanStartDay().toInstant(), ZoneId.systemDefault());


                        lastStartDate.plusHours(last.getProcessTotalTime().longValue());


                        stat.setProcessPlanStartDay(Date.from(lastStartDate.atZone(ZoneId.systemDefault()).toInstant()));


                    }


                }


                /*保存上一步计算的 开工日*/


                last = stat;


                stat.setId(IdUtils.fastUUID().toString());


                stat.setBatchNumber(batchNum);


                stat.setDelFlag("0");


                apsPartRouteStatMapper.insertApsPartRouteStat(stat);


            }


        }


        apsPartRouteStatMapper.deleteLastBatch(batchNum);


        /*计算并保存 工序异常信息*/


        analysisService.batchSaveAbnormalInfo();


    }


    /** 查询资源日历表


     */


@@ -157,6 +190,7 @@


        /*查出所有统计的数据*/


        AjaxResult result = new AjaxResult(200, "生成成功");


        List<ApsResourceDateStat> list = apsPartRouteStatMapper.selectResourceDateStat();


        List<ApsResourceGroup> resourceGroupList = apsResourceGroupMapper.selectApsResourceGroupList(new ApsResourceGroup());


        if (!list.isEmpty()) {


            /*求出计划的最大时间，没有 设置为当前时间+15天*/


            ApsResourceDateStat apsResourceDateStat = list.stream().max(Comparator.comparing(ApsResourceDateStat::getPlanDay)).orElse(null);


@@ -173,10 +207,11 @@


                startDay = startDay.plus(1, ChronoUnit.DAYS);


            }


            /*组织出列头数据*/


            List<String> resourceNames =list.stream().map(ApsResourceDateStat::getResourceName).distinct().toList();




            /*准备资源组信息*/


            List<Map<String, List<ApsResourceDateStat>>> targetList = new ArrayList<>();


            resourceNames.forEach(resourceName -> {


            resourceGroupList.forEach(resourceGroup -> {


                String resourceName=resourceGroup.getResourceGroupName();


                        /*根据日期表头的顺序，组织出每个日期下的统计项目*/


                Map<String, List<ApsResourceDateStat>> maps = new HashMap<>(Map.of());


                List<ApsResourceDateStat> currentDaysResouces=new ArrayList<>();


@@ -193,7 +228,7 @@


                    else {


                        ApsResourceDateStat empty = new ApsResourceDateStat();


                        empty.setPlanDay(LocalDate.parse(planDay, formatter));


                        empty.setDesignTimes(0);


                        empty.setDesignTimes(resourceGroup.getDevicesQuantity().intValue()*resourceGroup.getTheoryHours().intValue());


                        empty.setRequireTimes(0);


                        empty.setResourceName(resourceName);


                        empty.setResourceGroupName(resourceName);


@@ -210,4 +245,97 @@


        return result;


    }




    @Override


    public void exportExcel(HttpServletResponse response) {


        SXSSFWorkbook wb = new SXSSFWorkbook(500);


        wb.createSheet();


        wb.setSheetName(0, "零件统计表");


        response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");


        response.setCharacterEncoding("utf-8");




        Map<String, CellStyle> styles = createStyles(wb);


        CellStyle title = styles.get("title");


        try


        {




            AjaxResult stat = selectResourceDateStat();


            List<String> days = (List<String>) stat.get("planTitle");


            List<Map<String, List<ApsResourceDateStat>>> table= (List<Map<String, List<ApsResourceDateStat>>>) stat.get("planTable");


            SXSSFSheet sheet = wb.getSheetAt(0);


            /*填写日期列 和 工时列*/


            SXSSFRow rowDay = sheet.createRow(0);


            SXSSFRow rowTitle = sheet.createRow(1);




            SXSSFCell daytitle = rowDay.createCell(0);


            daytitle.setCellValue("日期");


            daytitle.setCellStyle(title);


            SXSSFCell titleCell = rowTitle.createCell(0);


            titleCell.setCellValue("资源组");


            titleCell.setCellStyle(title);




            for (int i = 0; i < days.size(); i++) {


                SXSSFCell dateCell = rowDay.createCell(i * 3 + 1);


                SXSSFCell designHoursCell = rowTitle.createCell(i * 3 + 1);


                SXSSFCell requireHoursCell = rowTitle.createCell(i * 3 + 2);


                SXSSFCell loadCell = rowTitle.createCell(i * 3 + 3);


                dateCell.setCellValue(days.get(i));


                designHoursCell.setCellValue("设计工时");


                requireHoursCell.setCellValue("需求工时");


                loadCell.setCellValue("产能负荷");


                /*set cell style*/


                dateCell.setCellStyle(title);


                designHoursCell.setCellStyle(title);


                requireHoursCell.setCellStyle(title);


                loadCell.setCellStyle(title);




                /*合并日期单元格*/


                sheet.addMergedRegion( new CellRangeAddress(0, 0, i*3+1, i*3+3));


            }


            for (int i = 0; i < table.size(); i++) {


                Map<String, List<ApsResourceDateStat>> resourceList = table.get(i);


                /*创建数据行*/


                SXSSFRow dataRow  = sheet.createRow(i+2);


                for( Map.Entry<String, List<ApsResourceDateStat>> entry : resourceList.entrySet()){


                    String resourceName = entry.getKey();


                    List<ApsResourceDateStat> resourceDateStats = entry.getValue();


                    dataRow.createCell(0).setCellValue(resourceName);


                    for (int j = 0; j < resourceDateStats.size(); j++) {


                        ApsResourceDateStat apsResourceDateStat = resourceDateStats.get(j);


                        dataRow.createCell(j*3+1).setCellValue(apsResourceDateStat.getDesignTimes());


                        dataRow.createCell(j*3+2).setCellValue(apsResourceDateStat.getRequireTimes());


                        dataRow.createCell(j*3+3).setCellValue(apsResourceDateStat.getCapacityLoad().doubleValue()+"%");


                    }


                }




            }


            wb.write(response.getOutputStream());


        }


        catch (Exception e)


        {


            log.error("导出Excel异常{}", e.getMessage());


        }


        finally


        {


            IOUtils.closeQuietly(wb);


        }




    }


    private Map<String,CellStyle> createStyles(SXSSFWorkbook wb)


    {


        Map<String,CellStyle> styles=new HashMap<>();


        CellStyle style = wb.createCellStyle();


        style.setAlignment(HorizontalAlignment.CENTER);


        style.setVerticalAlignment(VerticalAlignment.CENTER);


        Font titleFont = wb.createFont();


        titleFont.setFontName("Arial");


        titleFont.setFontHeightInPoints((short) 12);


        titleFont.setBold(true);


        style.setFont(titleFont);


        DataFormat dataFormat = wb.createDataFormat();


        style.setDataFormat(dataFormat.getFormat("@"));


        styles.put("title", style);


        return styles;


    }






}