blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-07-29 ad31fa93abe524baec2216f9b2f203acb8cc2d6a 
 ycl-server/src/main/java/com/ycl/platform/service/impl/CheckIndexCarServiceImpl.java


@@ -1,24 +1,29 @@


package com.ycl.platform.service.impl;




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


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ycl.platform.domain.entity.CalculateReport;


import com.ycl.platform.domain.entity.CheckIndexCar;


import com.ycl.platform.domain.entity.TMonitor;


import com.ycl.platform.domain.result.HK.SnapshotDataMonitorResult;


import com.ycl.platform.mapper.CalculateReportMapper;


import com.ycl.platform.mapper.CheckIndexCarMapper;


import com.ycl.platform.service.ICheckIndexCarService;


import com.ycl.platform.service.ITMonitorService;


import com.ycl.system.entity.SysDept;


import com.ycl.system.mapper.SysDeptMapper;


import constant.ApiConstants;


import constant.CheckConstants;


import lombok.extern.slf4j.Slf4j;


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


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;


import utils.DateUtils;




import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.function.Function;


import java.util.stream.Collectors;




@@ -29,7 +34,8 @@


 * @date 2024-04-29


 */


@Service


public class CheckIndexCarServiceImpl implements ICheckIndexCarService {


@Slf4j


public class CheckIndexCarServiceImpl extends ServiceImpl<CheckIndexCarMapper, CheckIndexCar> implements ICheckIndexCarService {


    @Autowired


    private CheckIndexCarMapper checkIndexCarMapper;


    @Autowired


@@ -103,12 +109,14 @@


    public int deleteCheckIndexCarById(Long id) {


        return checkIndexCarMapper.deleteCheckIndexCarById(id);


    }




    /**


     * 计算车辆点位在线率、视图库对接稳定性


     *


     *  获取分省厅、区域的map<k,v> k为deptId或者Province_deptId


     *  循环map计算点位在线率


     *  更新或新增


     * @param list


     */


    //TODO:视图库对接稳定性


    @Override


    public void siteOnline(List<SnapshotDataMonitorResult> list) {


        //设备id


@@ -130,7 +138,7 @@


            deptIds.forEach(deptId -> areaStatsMap.put(deptId + "", new AreaStats()));




            //转换为map


            //TODO：分省厅市局


            //TODO：分省厅市局  需要补充集合数据


            List<String> provinceIds = new ArrayList<>();


            Map<String, TMonitor> monitorMap = monitors.stream().collect(Collectors.toMap(TMonitor::getSerialNumber, Function.identity()));


            for (SnapshotDataMonitorResult result : list) {


@@ -158,23 +166,55 @@


                            provinceStats.offlineSites++;


                        } else {


                            //区域总抓拍量


                            provinceStats.totalSites += result.getDataCount();


                            provinceStats.totalDataSum += result.getDataCount();


                        }


                        //区域点位总数


                        provinceStats.totalDataSum++;


                        provinceStats.totalSites++;


                        areaStatsMap.put("Province_" + monitor.getDeptId(), areaStats);


                    }


                }


                areaStatsMap.put(monitor.getDeptId() + "", areaStats);


            }




            List<CheckIndexCar> checkIndexCarList = checkIndexCarMapper.selectToday(DateUtils.getDate());


            List<CheckIndexCar> checkIndexCars = new ArrayList<>();


            areaStatsMap.forEach((k, v) -> {


                if (k.startsWith("Province_")) {




                if (v.totalSites == 0) {


                    log.info("部门id为{}总点位数为0", k);


                } else {


                    CheckIndexCar checkIndexCar = new CheckIndexCar();


                    //找是否已经存在数据


                    Optional<CheckIndexCar> first;


                    if (k.startsWith("Province_")) {


                        //省厅


                        String[] idArray = k.split("_");


                        first = checkIndexCarList.stream().filter(item -> idArray[1].equals(item.getDeptId() + "") && CheckConstants.Examine_Tag_City.equals(item.getExamineTag()))


                                .findFirst();


                        checkIndexCar.setExamineTag(CheckConstants.Examine_Tag_City);


                        checkIndexCar.setDeptId(Long.parseLong(idArray[1]));


                    } else {


                        //区县


                        first = checkIndexCarList.stream().filter(item -> k.equals(item.getDeptId() + "") && CheckConstants.Examine_Tag_County.equals(item.getExamineTag()))


                                .findFirst();


                        checkIndexCar.setExamineTag(CheckConstants.Examine_Tag_County);


                        checkIndexCar.setDeptId(Long.parseLong(k));


                    }


                    checkIndexCar.setCreateTime(new Date());


                    if (first.isPresent()) {


                        checkIndexCar = first.get();


                    }


                    // 将整数转换为BigDecimal


                    BigDecimal totalSitesBd = new BigDecimal(v.totalSites);


                    BigDecimal offlineSitesBd = new BigDecimal(v.offlineSites);


                    // 执行计算，保留四位小数并四舍五入


                    BigDecimal onlineSitesBd = totalSitesBd.subtract(offlineSitesBd);


                    BigDecimal siteOnline = onlineSitesBd.divide(totalSitesBd, 4, RoundingMode.HALF_UP);


                    checkIndexCar.setSiteOnline(siteOnline);


                    checkIndexCars.add(checkIndexCar);


                }


            });


            CheckIndexCar checkIndexCar = new CheckIndexCar();




            saveOrUpdateBatch(checkIndexCars);


        }


    }




}