From 3b0516a2959e25576e4f3fda697a3b025d06c8c9 Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期二, 24 六月 2025 14:09:07 +0800
Subject: [PATCH] 每日录像可用指标添加日志,修改大屏为查看当前月平均

---
 ycl-server/src/main/java/com/ycl/platform/service/impl/TContractServiceImpl.java |  165 +++++++++++++++++++++++++++++++++---------------------
 1 files changed, 100 insertions(+), 65 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/TContractServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/TContractServiceImpl.java
index 346b141..a3d1960 100644
--- a/ycl-server/src/main/java/com/ycl/platform/service/impl/TContractServiceImpl.java
+++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/TContractServiceImpl.java
@@ -4,6 +4,7 @@
 import com.alibaba.excel.read.listener.PageReadListener;
 import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy;
 import com.alibaba.fastjson2.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -22,6 +23,7 @@
 import com.ycl.system.Result;
 import com.ycl.system.page.PageUtil;
 import com.ycl.utils.DateUtils;
+import com.ycl.utils.SecurityUtils;
 import com.ycl.utils.StringUtils;
 import enumeration.ContractStatus;
 import enumeration.general.RuleDeductCategoryEnum;
@@ -32,14 +34,13 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
+import org.springframework.util.CollectionUtils;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.io.IOException;
 import java.net.URLEncoder;
 import java.nio.charset.StandardCharsets;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -79,69 +80,39 @@
 
     private List<CalculateRule> getExcelData() {
         ArrayList<CalculateRule> list = new ArrayList<>();
-        CalculateRule calculateRule1 = new CalculateRule();
-        calculateRule1.setId(1);
-        calculateRule1.setRuleName("瑙嗛骞冲潎鍦ㄧ嚎鐜�");
-        calculateRule1.setRuleCondition("鈮�98%");
-        calculateRule1.setMax(98D);
-        calculateRule1.setDeductCategory(RuleDeductCategoryEnum.DEDUCT_POINTS);
-        calculateRule1.setCalcFraction(0.00);
-        list.add(calculateRule1);
-        CalculateRule calculateRule2 = new CalculateRule();
-        calculateRule2.setRuleName("瑙嗛骞冲潎鍦ㄧ嚎鐜�");
-        calculateRule2.setRuleCondition("95%鈮よ棰戝钩鍧囧湪绾跨巼锛�98%");
-        calculateRule2.setMax(97D);
-        calculateRule2.setMin(95D);
-        calculateRule2.setDeductCategory(RuleDeductCategoryEnum.DEDUCT_POINTS);
-        calculateRule2.setCalcFraction(5.00);
-        list.add(calculateRule2);
-        CalculateRule calculateRule3 = new CalculateRule();
-        calculateRule3.setRuleName("瑙嗛骞冲潎鍦ㄧ嚎鐜�");
-        calculateRule3.setRuleCondition("90%鈮よ棰戝钩鍧囧湪绾跨巼锛�95%");
-        calculateRule3.setMax(94D);
-        calculateRule3.setMin(90D);
-        calculateRule3.setDeductCategory(RuleDeductCategoryEnum.DEDUCT_POINTS);
-        calculateRule3.setCalcFraction(10.00);
-        list.add(calculateRule3);
-        CalculateRule calculateRule33 = new CalculateRule();
-        calculateRule33.setRuleName("瑙嗛骞冲潎鍦ㄧ嚎鐜�");
-        calculateRule33.setRuleCondition("锛�90%");
-        calculateRule33.setMin(89D);
-        calculateRule33.setDeductCategory(RuleDeductCategoryEnum.DEDUCT_POINTS);
-        calculateRule33.setCalcFraction(10.00);
-        list.add(calculateRule33);
-        CalculateRule calculateRule4 = new CalculateRule();
-        calculateRule4.setId(2);
-        calculateRule4.setRuleName("鍓嶇鎰熺煡婧愭不鐞嗗伐浣�");
-        calculateRule4.setRuleCondition("鏃堕挓鍚屾锛堣秴杩嚶�3绉掍负涓嶅悎鏍硷級");
-        calculateRule4.setDeductCategory(RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY);
-        calculateRule4.setCalcFraction(0.1);
-        list.add(calculateRule4);
-        CalculateRule calculateRule7 = new CalculateRule();
-        calculateRule7.setRuleName("鍓嶇鎰熺煡婧愭不鐞嗗伐浣�");
-        calculateRule7.setRuleCondition("OSD鏍囪瘑");
-        calculateRule7.setDeductCategory(RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY);
-        calculateRule7.setCalcFraction(0.1);
-        list.add(calculateRule7);
-        CalculateRule calculateRule6 = new CalculateRule();
-        calculateRule6.setRuleName("鍓嶇鎰熺煡婧愭不鐞嗗伐浣�");
-        calculateRule6.setRuleCondition("涓�鏈轰竴妗�");
-        calculateRule6.setDeductCategory(RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY);
-        calculateRule6.setCalcFraction(0.1);
-        list.add(calculateRule6);
-        CalculateRule calculateRule5 = new CalculateRule();
-        calculateRule5.setId(3);
-        calculateRule5.setRuleName("鍚庡彴绯荤粺鐨勪繚闅�");
-        calculateRule5.setRuleCondition("鍗曟鏁呴殰鏃堕暱鑻ヨ秴鍑�72灏忔椂涓嶈冻144灏忔椂鐨勶紝姣忚秴鍑�12灏忔椂锛堜笉瓒�12灏忔椂鎸�12灏忔椂璁★級");
-        calculateRule5.setMax(144D);
-        calculateRule5.setMin(72D);
-        calculateRule5.setDeductCategory(RuleDeductCategoryEnum.MULTIPLY_POINTS_AFTER_DIVIDING_QUANTITY);
-        calculateRule5.setCalcFraction(2.00);
-        calculateRule5.setCalcUnit(12);
-        list.add(calculateRule5);
+        setTemplateRule(list,1,"璁惧骞冲潎鍦ㄧ嚎鐜�","鈮�98%",null,98D,RuleDeductCategoryEnum.DEDUCT_POINTS,0.00);
+        setTemplateRule(list,null,"璁惧骞冲潎鍦ㄧ嚎鐜�","95%鈮よ澶囧钩鍧囧湪绾跨巼锛�98%",97D,95D,RuleDeductCategoryEnum.DEDUCT_POINTS,5.00);
+        setTemplateRule(list,null,"璁惧骞冲潎鍦ㄧ嚎鐜�","90%鈮よ澶囧钩鍧囧湪绾跨巼锛�95%",94D,90D,RuleDeductCategoryEnum.DEDUCT_POINTS,10.00);
+        setTemplateRule(list,null,"璁惧骞冲潎鍦ㄧ嚎鐜�","锛�90%",89D,null,RuleDeductCategoryEnum.DEDUCT_POINTS,20.00);
+
+        setTemplateRule(list,2,"鍓嶇鎰熺煡婧愭不鐞嗗伐浣�","鏃堕挓鍚屾",null,25D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,0.1);
+        setTemplateRule(list,null,"鍓嶇鎰熺煡婧愭不鐞嗗伐浣�","OSD鏍囪瘑",null,25D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,0.1);
+        setTemplateRule(list,null,"鍓嶇鎰熺煡婧愭不鐞嗗伐浣�","涓�鏈轰竴妗�",null,25D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,0.1);
+
+        setTemplateRule(list,3,"瀵逛簬鍓嶇鐐逛綅寮傚父鎯呭喌鐨勫鐞�","闀滃ご鏁呴殰鎴栨薄鏌撴垨鏍戞灊閬尅鎴栨灙鏈鸿瑙掑亸绉绘甯歌搴︽垨琛ュ厜鐏簲浜湭浜�,24灏忔椂鍚庢湭淇鐨�",48D,25D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,0.5);
+        setTemplateRule(list,null,"瀵逛簬鍓嶇鐐逛綅寮傚父鎯呭喌鐨勫鐞�","闀滃ご鏁呴殰鎴栨薄鏌撴垨鏍戞灊閬尅鎴栨灙鏈鸿瑙掑亸绉绘甯歌搴︽垨琛ュ厜鐏簲浜湭浜�,48灏忔椂鍚庢湭淇鐨�",null,49D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,1.0);
+
+        setTemplateRule(list,4,"纭繚褰曞儚瀹屾暣涓嶅畾鏈熷鎵�鏈夌偣浣嶅綍鍍忓畬鏁存�ф娊鏌�","姣忚矾瑙嗛绱涓㈠け10鍒嗛挓锛堝惈锛変互鍐�",10D,null,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,0.2);
+        setTemplateRule(list,null,"纭繚褰曞儚瀹屾暣涓嶅畾鏈熷鎵�鏈夌偣浣嶅綍鍍忓畬鏁存�ф娊鏌�","涓㈠け10-60 鍒嗛挓锛堝惈锛�",60D,9D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,0.5);
+        setTemplateRule(list,null,"纭繚褰曞儚瀹屾暣涓嶅畾鏈熷鎵�鏈夌偣浣嶅綍鍍忓畬鏁存�ф娊鏌�","涓㈠け1 灏忔椂-4 灏忔椂锛堝惈锛�",240D,59D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,1.0);
+        setTemplateRule(list,null,"纭繚褰曞儚瀹屾暣涓嶅畾鏈熷鎵�鏈夌偣浣嶅綍鍍忓畬鏁存�ф娊鏌�","涓㈠け4 灏忔椂-12 灏忔椂锛堝惈锛�",720D,539D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,1.5);
+        setTemplateRule(list,null,"纭繚褰曞儚瀹屾暣涓嶅畾鏈熷鎵�鏈夌偣浣嶅綍鍍忓畬鏁存�ф娊鏌�","涓㈠け12 灏忔椂浠ヤ笂",null,719D,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,2.0);
+
+        setTemplateRule(list,5,"纭繚鍥剧墖瀹屾暣涓嶅畾鏈熷鎵�鏈変汉鑴歌溅杈嗕互鍙婃櫤鑳藉墠绔姄鎷嶇殑鍥剧墖瀹屾暣鎬ф娊鏌�","鍙戠幇鍚庡彴瀛樺偍涓嶈兘璋冨彇鍓嶇璁惧鍥剧墖",null,null,RuleDeductCategoryEnum.MULTIPLY_POINTS_BY_QUANTITY,2.0);
+
         return list;
     }
-
+    private static void setTemplateRule(ArrayList<CalculateRule> list,Integer id,String ruleName,String condition,Double max,Double min,RuleDeductCategoryEnum deductCategoryEnum,Double calcFraction) {
+        CalculateRule calculateRule = new CalculateRule();
+        calculateRule.setId(id);
+        calculateRule.setRuleName(ruleName);
+        calculateRule.setRuleCondition(condition);
+        calculateRule.setMax(max);
+        calculateRule.setMin(min);
+        calculateRule.setDeductCategory(deductCategoryEnum);
+        calculateRule.setCalcFraction(calcFraction);
+        list.add(calculateRule);
+    }
     @Override
     @Transactional
     @SneakyThrows
@@ -184,12 +155,66 @@
         calculateMoneyRuleService.saveBatch(JSON.parseArray(tContract.getRuleList(), CalculateMoneyRule.class).stream().peek(
                 calculateMoneyRule -> calculateMoneyRule.setContractId(tContract.getId().intValue())
         ).collect(Collectors.toList()));
+
+
+        return AjaxResult.success("鎿嶄綔鎴愬姛");
+    }
+
+    @Override
+    public AjaxResult importRule(MultipartFile file, TContract tContract) throws IOException {
+
+        // 鑾峰彇鍚堝悓Excel瑙勫垯
+        List<CalculateRule> list = new ArrayList<>();
+        if(file!=null) {
+            EasyExcel.read(file.getInputStream(), CalculateRule.class, new PageReadListener<CalculateRule>(list::addAll)).sheet().doRead();
+
+            // 閬嶅巻鐖跺瓙鍏崇郴
+            List<CalculateRule> calculateRulesToSave = new ArrayList<>();
+            for (CalculateRule calculateRule : list) {
+                // 鍒ゆ柇鏁版嵁瀹屾暣鎬�
+                if (ObjectUtils.isEmpty(calculateRule.getDeductCategory())) {
+                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                    return AjaxResult.warn("璇烽�夋嫨" + calculateRule.getRuleName() + calculateRule.getRuleCondition() + "鎵e垎鏂瑰紡");
+                }
+                if (RuleDeductCategoryEnum.MULTIPLY_POINTS_AFTER_DIVIDING_QUANTITY.equals(calculateRule.getDeductCategory()) && ObjectUtils.isEmpty(calculateRule.getCalcUnit())) {
+                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                    return AjaxResult.warn("璇峰~鍐�" + calculateRule.getRuleName() + calculateRule.getRuleCondition() + "闄や互鏁伴噺");
+                }
+                if (ObjectUtils.isEmpty(calculateRule.getCalcFraction())) {
+                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                    return AjaxResult.warn("璇峰~鍐�" + calculateRule.getRuleName() + calculateRule.getRuleCondition() + "鎵e垎鏁板��");
+                }
+                // 淇濆瓨瑙勫垯
+                if (StringUtils.isNotBlank(calculateRule.getRuleName())) {
+                    calculateRule.setContractId(tContract.getId().intValue());
+                    calculateRule.setCreateTime(DateUtils.getNowDate());
+                    calculateRule.setUpdateTime(DateUtils.getNowDate());
+                    calculateRulesToSave.add(calculateRule);
+                }
+            }
+            if (!CollectionUtils.isEmpty(calculateRulesToSave)) {
+                //鍒犻櫎鍘熻鍒�
+                calculateRuleService.remove(new QueryWrapper<CalculateRule>().eq("contract_id", tContract.getId()));
+                // 鎵归噺淇濆瓨瑙勫垯
+                calculateRuleService.saveBatch(calculateRulesToSave);
+            }
+        }
+        List<CalculateMoneyRule> moneyRule = JSON.parseArray(tContract.getRuleList(), CalculateMoneyRule.class).stream().peek(
+                calculateMoneyRule -> calculateMoneyRule.setContractId(tContract.getId().intValue())
+        ).collect(Collectors.toList());
+        if (!CollectionUtils.isEmpty(moneyRule)) {
+            //鍒犻櫎鍘熻鍒�
+            calculateMoneyRuleService.remove(new QueryWrapper<CalculateMoneyRule>().eq("contract_id",tContract.getId()));
+            //鎵归噺淇濆瓨鑰冩牳缁撴灉搴旂敤瑙勫垯
+            calculateMoneyRuleService.saveBatch(moneyRule);
+        }
         return AjaxResult.success("鎿嶄綔鎴愬姛");
     }
 
     @Override
     public Result selectAll(ContractQuery query) {
         IPage<ContractVO> page = PageUtil.getPage(query, ContractVO.class);
+        query.setUnitId(SecurityUtils.getUnitId());
         baseMapper.getPage(page, query);
         page.getRecords().stream().forEach(contract -> {
             Date now = new Date();
@@ -216,4 +241,14 @@
                 .ge(TContract::getEndTime, DateUtils.getDate())
                 .list();
     }
+
+    @Override
+    public Result timeRange(Integer unitId) {
+        List<TContract> unitContractList = new LambdaQueryChainWrapper<>(baseMapper)
+                .select(TContract::getId, TContract::getName, TContract::getStartTime, TContract::getEndTime)
+                .eq(TContract::getUnitId, unitId)
+                .ge(TContract::getEndTime, new Date())
+                .list();
+        return Result.ok().data(unitContractList);
+    }
 }

--
Gitblit v1.8.0