blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-09-19 4ee98db54c451f1f44d499f0f418cf5795ffdb32 
 ycl-server/src/main/java/com/ycl/task/ContractTask.java


@@ -3,40 +3,34 @@




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


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


import com.mongodb.client.result.DeleteResult;


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


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


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


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


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


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


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


import com.ycl.platform.domain.result.UY.RecordMetaDSumResult;


import com.ycl.platform.domain.result.UY.VideoOnlineResult;


import com.ycl.platform.domain.vo.CalculateRuleVO;


import com.ycl.platform.domain.vo.ContractVO;


import com.ycl.platform.domain.vo.ReportVO;


import com.ycl.platform.domain.vo.WorkOrderVO;


import com.ycl.platform.mapper.*;


import com.ycl.platform.service.IContractScoreService;


import com.ycl.utils.DateUtils;


import constant.ApiConstants;


import constant.RedisConstant;


import enumeration.ContractRule;


import enumeration.ErrorType;


import enumeration.general.AuditingStatus;


import enumeration.general.ErrorTypeEnum;


import enumeration.general.RuleDeductCategoryEnum;


import enumeration.general.WorkOrderStatusEnum;


import lombok.extern.slf4j.Slf4j;


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


import org.springframework.data.mongodb.core.MongoTemplate;


import org.springframework.data.mongodb.core.query.Criteria;


import org.springframework.data.mongodb.core.query.Query;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Component;


import org.springframework.util.CollectionUtils;




import javax.management.monitor.Monitor;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.util.*;


import java.util.stream.Collectors;


@@ -67,7 +61,7 @@


    private static final Integer Offline = -1;


    private static final String AuditStatus_Pass = "1";


    private static final String Remark = "系统生成";


    private static final Integer randomSize = 50;


    private static final Integer randomSize = 30;




    /**


     * 合同考核 在线率每日任务检测


@@ -94,7 +88,7 @@


                        )


                ));


        Map<String, Integer> onlineStatusMap = new HashMap<>();


        //查mongo获取设备在线情况


        //TODO 在线率修改，查mongo获取设备在线情况


        Date date = DateUtils.getDay(2024, 7, 13);


        //车辆、人脸


        Query query = new Query();


@@ -445,8 +439,8 @@


                                for (CalculateRuleVO calculateRuleVO : ruleList) {


                                    Double max = calculateRuleVO.getMax();


                                    Double min = calculateRuleVO.getMin();


                                    //判断范围在哪个区间


                                    if (checkRange(min, max, BigDecimal.valueOf(result.getMissDuration()))) {


                                    //判断范围在哪个区间 单位是小时转换为分钟


                                    if (checkRange(min, max, BigDecimal.valueOf(result.getMissDuration()*60))) {


                                        if (calculateRuleVO.getNum() == null) {


                                            calculateRuleVO.setNum(1);


                                        } else {


@@ -458,7 +452,7 @@


                        }


                    }


                    for (CalculateRuleVO calculateRuleVO : ruleList) {


                        if (calculateRuleVO.getNum() > 0) {


                        if (calculateRuleVO.getNum()!=null && calculateRuleVO.getNum() > 0) {


                            //需要扣除的分数，此规则只有一条不需要判断范围


                            double deductScore = calculateRuleVO.getCalcFraction() * calculateRuleVO.getNum();


                            ContractScore contractScore = getContractScore(calculateRuleVO, deductScore, calculateRuleVO.getNum() + "", Remark + calculateRuleVO.getNum() + "路设备违反规则");