通信LIMS后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
zss
2024-12-04 a43efe9a1de7be71451e84927d88054ff704ca82 
 inspect-server/src/main/java/com/yuanchu/mom/service/impl/ReportServiceImpl.java


@@ -2,6 +2,7 @@




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


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.yuanchu.mom.common.GetLook;


@@ -9,19 +10,14 @@


import com.yuanchu.mom.mapper.*;


import com.yuanchu.mom.pojo.*;


import com.yuanchu.mom.service.ReportService;


import com.yuanchu.mom.utils.QueryWrappers;


import lombok.AllArgsConstructor;


import org.springframework.stereotype.Service;




import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.LocalTime;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.*;


import java.util.stream.Collectors;




@Service


@@ -29,11 +25,14 @@


public class ReportServiceImpl implements ReportService {




    private InsOrderMapper insOrderMapper;


    private InsSampleMapper insSampleMapper;


    private InsProductUserMapper insProductUserMapper;


    private InsProductMapper insProductMapper;


    private GetLook getLook;


    private ScheduleMapper scheduleMapper;


    private UserMapper userMapper;


    private RoleMapper roleMapper;


    private InsSampleUserMapper insSampleUserMapper;




    //每日业务统计


    @Override


@@ -45,9 +44,8 @@


        map.put("RECEIVE", receive);


        //昨日任务接收


        Long received = insOrderMapper.selectCount(Wrappers.<InsOrder>lambdaQuery().eq(InsOrder::getState, 1).apply("DATE(create_time) = CURDATE() - INTERVAL 1 DAY"));


        received = received == 0 ? 1 : received;


        //比例=(今天-昨天)/昨天


        BigDecimal ratio = new BigDecimal(receive - received).divide(new BigDecimal(received), 2, BigDecimal.ROUND_HALF_UP);


        BigDecimal ratio = new BigDecimal(receive - received).divide(new BigDecimal(received == 0 ? 1 : received), 2, BigDecimal.ROUND_HALF_UP);


        map.put("RECEIVE_RATIO", ratio);




        /*任务已完成*/


@@ -56,9 +54,8 @@


        map.put("FINISHE", finishe);


        //昨日任务完成


        Long finished = insOrderMapper.selectCount(Wrappers.<InsOrder>lambdaQuery().eq(InsOrder::getState, 4).apply("DATE(create_time) = CURDATE() - INTERVAL 1 DAY"));


        finished = finished == 0 ? 1 : finished;


        //任务完成比例=(今天-昨天)/昨天


        BigDecimal finishedRatio = new BigDecimal(finishe - finished).divide(new BigDecimal(finished), 2, BigDecimal.ROUND_HALF_UP);


        BigDecimal finishedRatio = new BigDecimal(finishe - finished).divide(new BigDecimal(finished == 0 ? 1 : finished), 2, BigDecimal.ROUND_HALF_UP);


        map.put("FINISHE_RATIO", finishedRatio);




        /*任务剩余*/


@@ -67,9 +64,8 @@


        map.put("SURPLUS", surplus);


        //昨日任务剩余


        long surplused = received - finished;


        surplused = surplused == 0 ? 1 : surplused;


        //剩余比例=(今天-昨天)/昨天


        BigDecimal surplusRatio = new BigDecimal(surplus - surplused).divide(new BigDecimal(surplused), 2, BigDecimal.ROUND_HALF_UP);


        BigDecimal surplusRatio = new BigDecimal(surplus - surplused).divide(new BigDecimal(surplused == 0 ? 1 : surplused), 2, BigDecimal.ROUND_HALF_UP);


        map.put("SURPLUS_RATIO", surplusRatio);




        /*检测费用*/


@@ -93,9 +89,8 @@


        for (CostStatisticsDto record : dtoIPage.getRecords()) {


            priced.add(record.getPrice());


        }


        priced = priced.compareTo(BigDecimal.ZERO) == 0 ? BigDecimal.ONE : priced;


        //比例=(今日-昨日)/昨日


        BigDecimal priceRatio = (price.subtract(priced)).divide(priced, 2, BigDecimal.ROUND_HALF_UP);


        BigDecimal priceRatio = (price.subtract(priced)).divide(priced.compareTo(BigDecimal.ZERO) == 0 ? BigDecimal.ONE : priced, 2, BigDecimal.ROUND_HALF_UP);


        map.put("PRICE_RATIO", priceRatio);




        /*检测工时*/


@@ -110,21 +105,21 @@


        for (CostStatisticsDto record : dtoIPage.getRecords()) {


            costed += record.getCost();


        }


        costed = costed == 0 ? 1 : costed;


        //比例=(今日-昨日)/昨日


        BigDecimal costRatio = new BigDecimal(cost - costed).divide(new BigDecimal(costed), 2, BigDecimal.ROUND_HALF_UP);


        BigDecimal costRatio = new BigDecimal(cost - costed).divide(new BigDecimal(costed == 0 ? 1 : costed), 2, BigDecimal.ROUND_HALF_UP);


        map.put("COST_RATIO", costRatio);






        /*检测人员*/


        //今日检测人员


        Long person = insProductUserMapper.selectCount(Wrappers.<InsProductUser>lambdaQuery().apply("DATE(create_time) = CURDATE()"));


        List<InsProductUser> insProductUsers = insProductUserMapper.selectList(Wrappers.<InsProductUser>lambdaQuery().apply("DATE(create_time) = CURDATE()"));


        long person = insProductUsers.stream().map(InsProductUser::getCreateUser).distinct().count();


        map.put("PERSON", person);


        //昨日检测人员


        Long persons = insProductUserMapper.selectCount(Wrappers.<InsProductUser>lambdaQuery().apply("DATE(create_time) = CURDATE() - INTERVAL 1 DAY"));


        persons = persons == 0 ? 1 : persons;


        List<InsProductUser> insProductUserss = insProductUserMapper.selectList(Wrappers.<InsProductUser>lambdaQuery().apply("DATE(create_time) = CURDATE() - INTERVAL 1 DAY"));


        long persons = insProductUserss.stream().map(InsProductUser::getCreateUser).distinct().count();


        //比例=(今天-昨天)/昨天


        BigDecimal personRatio = new BigDecimal(person - persons).divide(new BigDecimal(persons), 2, BigDecimal.ROUND_HALF_UP);


        BigDecimal personRatio = new BigDecimal(person - persons).divide(new BigDecimal(persons == 0 ? 1 : persons), 2, BigDecimal.ROUND_HALF_UP);


        map.put("PERSON_RATIO", personRatio);




        /*近十日任务接收量与完成量*/


@@ -151,38 +146,116 @@


        /*项目接收*/


        //今日项目接收量


        Long receive = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).apply("DATE(create_time) = CURDATE()"));


        map.put("RECEVICE", receive);


        //昨日项目接收量


        Long received = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).apply("DATE(create_time) = CURDATE() - INTERVAL 1 DAY"));


        //比例=(今天-昨天)/昨天


        BigDecimal ratio = new BigDecimal(receive - received).divide(new BigDecimal(received == 0 ? 1 : received), 2, BigDecimal.ROUND_HALF_UP);


        map.put("RECEIVE_RATIO", ratio);




        /*项目完成*/


        //今日项目完成量


        Long finishe = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).isNotNull(InsProduct::getInsResult).apply("DATE(create_time) = CURDATE()"));


        map.put("FINISHE", finishe);


        //昨日项目完成量


        Long finished = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).isNotNull(InsProduct::getInsResult).apply("DATE(create_time) = CURDATE() - INTERVAL 1 DAY"));


        //任务完成比例=(今天-昨天)/昨天


        BigDecimal finishedRatio = new BigDecimal(finishe - finished).divide(new BigDecimal(finished == 0 ? 1 : finished), 2, BigDecimal.ROUND_HALF_UP);


        map.put("FINISHE_RATIO", finishedRatio);




        /*项目剩余*/


        //今日项目剩余量


        long surplus = receive - finishe;


        map.put("SURPLUS", surplus);


        //昨日项目剩余


        long surplused = received - finished;


        //剩余比例=(今天-昨天)/昨天


        BigDecimal surplusRatio = new BigDecimal(surplus - surplused).divide(new BigDecimal(surplused == 0 ? 1 : surplused), 2, BigDecimal.ROUND_HALF_UP);


        map.put("SURPLUS_RATIO", surplusRatio);




        /*今日项目合格率*/


        //今日完成量中的合格量/今日完成量


        Long accept = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).eq(InsProduct::getInsResult,1).apply("DATE(create_time) = CURDATE()"));


        map.put("ACCEPT", accept);


        BigDecimal acceptRate = new BigDecimal(accept).divide(new BigDecimal(finishe == 0 ? 1 : finishe), 2, BigDecimal.ROUND_HALF_UP);


        map.put("ACCEPT_RATE_TODAY", acceptRate);




        /*今日项目完成率*/


        //今日完成量/今日接收量


        BigDecimal finishRate = new BigDecimal(finishe).divide(new BigDecimal(receive == 0 ? 1 : receive), 2, BigDecimal.ROUND_HALF_UP);


        map.put("FINISH_RATE_TODAY", finishRate);




        /*今日项目延期率*/


        //今日项目剩余/今日项目接收量


        BigDecimal delayRate = new BigDecimal(surplus).divide(new BigDecimal(received == 0 ? 1 : received), 2, BigDecimal.ROUND_HALF_UP);


        map.put("DELAY_RATE_TODAY", delayRate);




        /*近十日的项目接收量与完成量*/


        //获取近十日的横坐标


        LocalDate currentDate = LocalDate.now();


        List<LocalDate> lastTenDays = new ArrayList<>();


        List<Long> receTenDays = new ArrayList<>();


        List<Long> finTenDays = new ArrayList<>();


        for (int i = 9; i > -1; i--) {


            lastTenDays.add(currentDate.minusDays(i));


            receTenDays.add(insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).apply("DATE(create_time) = CURDATE() - INTERVAL " + i + " DAY")));


            finTenDays.add(insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).isNotNull(InsProduct::getInsResult).apply("DATE(create_time) = CURDATE() - INTERVAL " + i + " DAY")));


        }


        map.put("DAYS", lastTenDays);


        map.put("RECETENDAYS", receTenDays);


        map.put("FINISHTENDAYS", finTenDays);




        return map;


    }




    //首页-->日历任务图


    @Override


    public Map<String, Object> calendarWorkByWeek() {


        Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId");


        String name = roleMapper.selectById(userMapper.selectById(userId).getRoleId()).getName();


        Map<String, Object> map = new HashMap<>();


        List<Integer> insState=new ArrayList<>();


        List<Integer> insState = new ArrayList<>();


        insState.add(0);


        insState.add(1);


        /*获取后一周日期*/


        LocalDate currentDate = LocalDate.now();


        List<LocalDate> weekDays = new ArrayList<>();


        for (int i = 0; i <7; i++) {


            weekDays.add(currentDate.plusDays(i));


        for (int i = 6, j = 0; i >= 0; i--, j++) {


            weekDays.add(currentDate.minusDays(i));


            //查询当天需要检测的委托订单


            List<InsOrder> insOrders = insOrderMapper.selectList(Wrappers.<InsOrder>lambdaQuery().eq(InsOrder::getState, 1).in(InsOrder::getInsState, insState).apply("DATE(create_time) = CURDATE() - INTERVAL " + i + " DAY"));


            List<Map<String,Object>> works = insOrders.stream().map(insOrder -> {


            List<InsOrder> insOrders = insOrderMapper.selectList(Wrappers.<InsOrder>lambdaQuery()


                    .eq(InsOrder::getState, 1)


                    .in(InsOrder::getInsState, insState)


                    .apply("DATE(create_time) = CURDATE() - INTERVAL " + j + " DAY"));


            //如果当前登录人是测试工程师或者是检测组长,需要过滤出检验人是他们的订单或者是还没检验的订单


            if (name.equals("测试工程师") || name.equals("检测组长")){


                insOrders = insOrders.stream().filter(insOrder -> {


                    List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, insOrder.getId()));


                    List<Integer> sampleId = insSamples.stream().map(InsSample::getId).collect(Collectors.toList());


                    List<InsSampleUser> insSampleUsers = insSampleUserMapper.selectList(Wrappers.<InsSampleUser>lambdaQuery()


                            .eq(InsSampleUser::getState, 0)  //检验人


                            .in(InsSampleUser::getInsSampleId, sampleId));


                    return insSampleUsers.size() == 0 || insSampleUsers.stream().map(InsSampleUser::getUserId).collect(Collectors.toList()).contains(userId);


                }).collect(Collectors.toList());


            }


            //如果当前登录人是送样员,需过滤出单子的送样员是当前人的订单


            else if (name.equals("送样员")){


                insOrders = insOrders.stream().filter(insOrder ->


                        ObjectUtils.isNotEmpty(insOrder.getIssueUser()) && insOrder.getIssueUser().equals(userId)


                ).collect(Collectors.toList());


            }


            List<Map<String, Object>> works = insOrders.stream().map(insOrder -> {


                List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, insOrder.getId()));


                HashMap<String, Object> hashMap = new HashMap<>();


                hashMap.put("text","委托订单" + insOrder.getEntrustCode() + "检测");


                hashMap.put("type",insOrder.getType());


                hashMap.put("text", insOrder.getEntrustCode());


                hashMap.put("sample", insSamples.stream().map(InsSample::getSample).collect(Collectors.joining(",")));


                hashMap.put("type", insOrder.getType());


                hashMap.put("state", insOrder.getState());


                User user = userMapper.selectById(insOrder.getCreateUser());


                hashMap.put("name", user.getName());


                return  hashMap;


                return hashMap;


            }).collect(Collectors.toList());


            map.put("work"+i, works);


            map.put("work" + i, works);


        }


        map.put("weekDays", weekDays);


        return map;


@@ -208,6 +281,6 @@


        LocalDate localDate = LocalDate.parse(date, DateTimeFormatter.ofPattern("yyyy-MM-dd"));


        LocalDateTime startTime = localDate.atStartOfDay();


        LocalDateTime endTime = localDate.plusDays(1).atStartOfDay().minusSeconds(1);


        return scheduleMapper.selectList(Wrappers.<Schedule>lambdaQuery().eq(Schedule::getUserId,userId).between(Schedule::getScheduleTime,startTime,endTime));


        return scheduleMapper.selectList(Wrappers.<Schedule>lambdaQuery().eq(Schedule::getUserId, userId).between(Schedule::getScheduleTime, startTime, endTime));


    }


}