产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
huminmin
13 小时以前 186e25fed2ba68e445a4cd8dffb0bde6b02af93a 
 src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java


@@ -3,7 +3,13 @@


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.ruoyi.approve.mapper.ApproveProcessMapper;


import com.ruoyi.approve.pojo.ApproveProcess;


import com.ruoyi.collaborativeApproval.mapper.NoticeMapper;


import com.ruoyi.collaborativeApproval.pojo.Notice;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.device.mapper.DeviceMaintenanceMapper;


import com.ruoyi.device.mapper.DeviceRepairMapper;


import com.ruoyi.device.pojo.DeviceMaintenance;


import com.ruoyi.device.pojo.DeviceRepair;


import com.ruoyi.dto.MapDto;


import com.ruoyi.framework.security.LoginUser;


import com.ruoyi.home.dto.*;


@@ -40,6 +46,7 @@


import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.time.*;


import java.time.format.DateTimeFormatter;


import java.time.temporal.TemporalAdjusters;


import java.util.*;


import java.util.concurrent.atomic.AtomicInteger;


@@ -88,6 +95,9 @@




    @Autowired


    private SysDeptMapper sysDeptMapper;




    @Autowired


    private NoticeMapper noticeMapper;




    @Override


    public HomeBusinessDto business() {


@@ -266,50 +276,83 @@




    @Override


    public QualityStatisticsDto qualityStatistics() {


        // 获取一周数据


        // 获取当前时间


        // 获取近四个月数据（往前推三个月，共4个完整月份）


        LocalDate today = LocalDate.now();


        // 获取本周周一


        LocalDate startOfWeek = today.with(DayOfWeek.MONDAY);


        // 获取本周周日


        LocalDate endOfWeek = today.with(DayOfWeek.SUNDAY);


        LambdaQueryWrapper<QualityInspect> qualityInspectLambdaQueryWrapper = new LambdaQueryWrapper<>();


        qualityInspectLambdaQueryWrapper.ge(QualityInspect::getCheckTime, startOfWeek)


                .gt(QualityInspect::getCheckTime, endOfWeek);


        List<QualityInspect> qualityInspects = qualityStatisticsMapper.selectList(qualityInspectLambdaQueryWrapper);


        // 定义日期格式化器（用于显示“年月”格式）


        DateTimeFormatter monthFormatter = DateTimeFormatter.ofPattern("yyyy-MM");




        QualityStatisticsDto qualityStatisticsDto = new QualityStatisticsDto();


        qualityStatisticsDto.setSupplierNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(0)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add));


        qualityStatisticsDto.setProcessNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(1)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add));


        qualityStatisticsDto.setFactoryNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(2)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add));


        List<QualityStatisticsItem> qualityStatisticsItems = new ArrayList<>();


        for (int j = 1; j < 8; j++) {


            LocalDate endTime = startOfWeek.plusDays(j);


            LocalDate startTime = endTime.minusDays(1);


            QualityStatisticsItem qualityStatisticsItem = new QualityStatisticsItem();


            qualityStatisticsItem.setDate(startTime.toString());


            qualityStatisticsItem.setSupplierNum(qualityInspects.stream()


                    .filter(item -> item.getInspectType().equals(0) && "不合格".equals(item.getCheckResult())


                            && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                            && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))




        BigDecimal supplierNum = new BigDecimal(0);


        BigDecimal factoryNum = new BigDecimal(0);


        BigDecimal processNum = new BigDecimal(0);


        // 循环4次，分别统计近4个月的数据（当前月、前1个月、前2个月、前3个月）


        for (int i = 3; i >= 0; i--) {


            // 计算当前循环对应的月份（i=0：当前月，i=1：前1个月，以此类推）


            LocalDate currentMonth = today.minusMonths(i);


            // 当月的开始日期（每月1号）


            LocalDate monthStart = currentMonth.withDayOfMonth(1);


            // 当月的结束日期（每月最后一天）


            LocalDate monthEnd = currentMonth.withDayOfMonth(currentMonth.lengthOfMonth());




            // 构建当月的查询条件（如果想一次性查全4个月数据再内存筛选，可优化为先查全再循环筛选）


            LambdaQueryWrapper<QualityInspect> queryWrapper = new LambdaQueryWrapper<>();


            queryWrapper.ge(QualityInspect::getCheckTime, monthStart)


                    .le(QualityInspect::getCheckTime, monthEnd); // 筛选当月数据


            List<QualityInspect> monthInspects = qualityStatisticsMapper.selectList(queryWrapper);


            BigDecimal reduce = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(0))


                    .map(QualityInspect::getQuantity)


                    .reduce(BigDecimal.ZERO, BigDecimal::add)


            );


            qualityStatisticsItem.setFactoryNum(qualityInspects.stream()


                    .filter(item -> item.getInspectType().equals(1) && "不合格".equals(item.getCheckResult())


                            && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                            && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                    .reduce(BigDecimal.ZERO, BigDecimal::add);


            supplierNum = supplierNum.add(reduce);


            BigDecimal reduce1 = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(1))


                    .map(QualityInspect::getQuantity)


                    .reduce(BigDecimal.ZERO, BigDecimal::add)


            );


            qualityStatisticsItem.setProcessNum(qualityInspects.stream()


                    .filter(item -> item.getInspectType().equals(2) && "不合格".equals(item.getCheckResult())


                            && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                            && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                    .reduce(BigDecimal.ZERO, BigDecimal::add);


            processNum= processNum.add(reduce1);


            BigDecimal reduce2 = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(2))


                    .map(QualityInspect::getQuantity)


                    .reduce(BigDecimal.ZERO, BigDecimal::add));


            qualityStatisticsItems.add(qualityStatisticsItem);


                    .reduce(BigDecimal.ZERO, BigDecimal::add);


            factoryNum = factoryNum.add(reduce2);




            // 构建当月统计项


            QualityStatisticsItem item = new QualityStatisticsItem();


            item.setDate(monthStart.format(monthFormatter)); // 日期显示为“年月”（如 2025-10）




            // 1. 供应商检验（类型0）- 合格数量


            BigDecimal supplierQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(0)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


                    .reduce(BigDecimal.ZERO, BigDecimal::add);


            item.setSupplierNum(supplierQualified);




            // 2. 工序检验（类型1）- 合格数量


            BigDecimal processQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(1)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


                    .reduce(BigDecimal.ZERO, BigDecimal::add);


            item.setProcessNum(processQualified);




            // 3. 工厂检验（类型2）- 合格数量


            BigDecimal factoryQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(2)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


                    .reduce(BigDecimal.ZERO, BigDecimal::add);


            item.setFactoryNum(factoryQualified);




            qualityStatisticsItems.add(item);


        }


        // 统计近4个月总数据（所有月份汇总）


        qualityStatisticsDto.setProcessNum(processNum);


        qualityStatisticsDto.setSupplierNum(supplierNum);


        qualityStatisticsDto.setFactoryNum(factoryNum);


        qualityStatisticsDto.setItem(qualityStatisticsItems);




        return qualityStatisticsDto;


    }




@@ -409,4 +452,32 @@




        return statisticsReceivablePayableDto;


    }




    @Autowired


    private DeviceRepairMapper deviceRepairMapper;




    @Override


    public Map<String, Object> approveAndDeviceTodos() {


        // 审批协同待办


        Long aLong = approveProcessMapper.selectCount(new LambdaQueryWrapper<ApproveProcess>()


                .eq(ApproveProcess::getApproveUserCurrentId, SecurityUtils.getUserId())


                .eq(ApproveProcess::getApproveDelete, 0)


                .in(ApproveProcess::getApproveStatus, 0, 1, 3));


        // 设备报修待办


        Long aLong1 = deviceRepairMapper.selectCount(new LambdaQueryWrapper<DeviceRepair>()


                .eq(DeviceRepair::getStatus, 0)


                .eq(DeviceRepair::getRepairName, SecurityUtils.getLoginUser().getNickName()));


        return new HashMap<String, Object>() {{


            put("approveTodo", aLong);


            put("deviceRepairTodo", aLong1);


        }};


    }




    @Override


    public Long noticesCount() {


        // 查询未过期的通知数量：状态为发布且过期时间大于等于当前日期


        return noticeMapper.selectCount(new LambdaQueryWrapper<Notice>()


                .eq(Notice::getStatus, 1) // 1表示发布状态


                .ge(Notice::getExpirationDate, new Date())); // 过期时间大于等于当前日期


    }


}