数智双碳-文印排放核心指标、排放分析、排放排名

src/main/java/com/sky/ioc/controller/carbon/PrintController.java

@@ -2,6 +2,7 @@ package com.sky.ioc.controller.carbon;
 
 import com.sky.ioc.entity.params.IocParam;
 import com.sky.ioc.service.carbon.CarbonService;
+import com.sky.ioc.service.carbon.PrintCarbonService;
 import com.sky.ioc.tool.ReturnMsg;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -31,19 +32,22 @@ public class PrintController {
     @Autowired
     private CarbonService carbonService;
 
+    @Autowired
+    PrintCarbonService printCarbonService;
+
 
 
     @ApiOperation("核心指标")
     @PostMapping("/getPrintCoreIndicators")
     public ReturnMsg getPrintCoreIndicators(@RequestBody IocParam iocParam){
-        return carbonService.getPrintCoreIndicators(iocParam);
+        return printCarbonService.getPrintCoreIndicators(iocParam);
     }
 
 
     @ApiOperation("文印排放分析")
     @PostMapping("/getPrintInfo")
     public ReturnMsg getPrintInfo(@RequestBody IocParam iocParam){
-        return carbonService.getPrintInfo(iocParam);
+        return printCarbonService.getPrintInfo(iocParam);
     }
 
 
@@ -52,7 +56,7 @@ public class PrintController {
     @ApiOperation("文印排放排名")
     @PostMapping("/getPrintInfoOrder")
     public ReturnMsg getPrintInfoOrder(@RequestBody IocParam iocParam){
-        return carbonService.getPrintInfoOrder(iocParam);
+        return printCarbonService.getPrintInfoOrder(iocParam);
     }
 
 }

src/main/java/com/sky/ioc/mapper/carbon/CarCarbonMapper.java

@@ -25,7 +25,7 @@ public interface CarCarbonMapper extends BaseMapper<CarCarbon> {
     Double getDischargeByTime(@Param("iocParam")IocParam iocParam);
 
     @Select("<script> " +
-            "select coalesce(sum(discharge),0) from car_carbon where  1=1 " +
+            "select coalesce(sum(mileage),0) from car_carbon where  1=1 " +
             "<if test='iocParam!=null and iocParam.timeRange!=null '>" +
             "and time between #{iocParam.timeRange.startDate} and #{iocParam.timeRange.endDate} " +
             "</if>" +

src/main/java/com/sky/ioc/mapper/carbon/PrintCarbonMapper.java

@@ -0,0 +1,73 @@
+package com.sky.ioc.mapper.carbon;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sky.ioc.entity.domain.carbon.PrintCarbon;
+import com.sky.ioc.entity.params.IocParam;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface PrintCarbonMapper extends BaseMapper<PrintCarbon> {
+
+    @Select("<script> " +
+            "select coalesce(sum(discharge),0) from print_carbon where  1=1 " +
+            "<if test='iocParam!=null and iocParam.timeRange!=null '>" +
+            "and time between #{iocParam.timeRange.startDate} and #{iocParam.timeRange.endDate} " +
+            "</if>" +
+            "<if test='iocParam!=null and iocParam.deptId!=null '>" +
+            "and dept_id = #{iocParam.deptId} " +
+            "</if>" +
+            "</script>")
+    Double getDischargeByTime(@Param("iocParam") IocParam iocParam);
+
+    @Select("<script> " +
+            "select coalesce(sum(paper),0) from print_carbon where  1=1 " +
+            "<if test='iocParam!=null and iocParam.timeRange!=null '>" +
+            "and time between #{iocParam.timeRange.startDate} and #{iocParam.timeRange.endDate} " +
+            "</if>" +
+            "<if test='iocParam!=null and iocParam.deptId!=null '>" +
+            "and dept_id = #{iocParam.deptId} " +
+            "</if>" +
+            "</script>")
+    long getPaperByTime(@Param("iocParam")IocParam iocParam);
+
+    @Select("<script> " +
+            "select coalesce(sum(inkbox),0) from print_carbon where  1=1 " +
+            "<if test='iocParam!=null and iocParam.timeRange!=null '>" +
+            "and time between #{iocParam.timeRange.startDate} and #{iocParam.timeRange.endDate} " +
+            "</if>" +
+            "<if test='iocParam!=null and iocParam.deptId!=null '>" +
+            "and dept_id = #{iocParam.deptId} " +
+            "</if>" +
+            "</script>")
+    double getInkboxByTime(@Param("iocParam")IocParam iocParam);
+
+    @Select("<script> " +
+            "select coalesce(sum(discharge),0) as total,dept_id,department.name  from print_carbon " +
+            "LEFT JOIN department on print_carbon.dept_id= department.id " +
+            "where  1=1 " +
+            "<if test='iocParam!=null and iocParam.timeRange!=null '>" +
+            "and time between #{iocParam.timeRange.startDate} and #{iocParam.timeRange.endDate} " +
+            "</if>" +
+            "<if test='iocParam!=null and iocParam.deptId!=null '>" +
+            "and dept_id = #{iocParam.deptId} " +
+            "</if>" +
+            " GROUP BY dept_id,department.name ORDER BY total desc </script>")
+    List<Map<String,Object>> getDischargeOrderByTime(@Param("iocParam")IocParam iocParam);
+
+
+    @Select("<script> " +
+            "select coalesce(count(DISTINCT user_id),0) from print_carbon where  1=1 " +
+            "<if test='iocParam!=null and iocParam.timeRange!=null '>" +
+            "and time between #{iocParam.timeRange.startDate} and #{iocParam.timeRange.endDate} " +
+            "</if>" +
+            "<if test='iocParam!=null and iocParam.deptId!=null '>" +
+            "and dept_id = #{iocParam.deptId} " +
+            "</if>" +
+            "</script>")
+    Integer getUserByTime(@Param("iocParam")IocParam iocParam);
+}

src/main/java/com/sky/ioc/service/carbon/CarbonService.java

@@ -35,16 +35,6 @@ public interface CarbonService {
     ReturnMsg  getCarbonNews(IocParam iocParam);
 
     ReturnMsg  getCarbonProportion(IocParam iocParam);
-
-
-
-
-    ReturnMsg  getPrintCoreIndicators(IocParam iocParam);
-
-    ReturnMsg  getPrintInfoOrder(IocParam iocParam);
-
-    ReturnMsg  getPrintInfo(IocParam iocParam);
-
     ReturnMsg  getPhotovoltaicInfoOrder(IocParam iocParam);
 
     ReturnMsg  getPhotovoltaicInfo(IocParam iocParam);

src/main/java/com/sky/ioc/service/carbon/PrintCarbonService.java

@@ -0,0 +1,12 @@
+package com.sky.ioc.service.carbon;
+
+import com.sky.ioc.entity.params.IocParam;
+import com.sky.ioc.tool.ReturnMsg;
+
+public interface PrintCarbonService {
+    ReturnMsg getPrintCoreIndicators(IocParam iocParam);
+
+    ReturnMsg  getPrintInfo(IocParam iocParam);
+
+    ReturnMsg  getPrintInfoOrder(IocParam iocParam);
+}

src/main/java/com/sky/ioc/service/carbon/impl/CarbonServiceImpl.java

@@ -418,58 +418,11 @@ public class CarbonServiceImpl implements CarbonService {
         return ReturnMsg.ok(list);
     }
 
-    @Override
-    public ReturnMsg getPrintCoreIndicators(IocParam iocParam) {
-        Indeicator indeicator = new Indeicator();
-        List<JSONObject> objects = indeicator.getList();
-        ThreadLocalRandom random = ThreadLocalRandom.current();
-        int totalPrint = random.nextInt(100, 1000);
-        int avgPrint = random.nextInt(50,500);
-        int avgPaper = random.nextInt(1,200);
-        int avgCartridge = random.nextInt(10,100);
-        while (avgCartridge>avgPaper){
-            avgCartridge = random.nextInt(10,100);
-        }
-        while (avgPrint>totalPrint){
-            avgPrint = random.nextInt(50,500);
-        }
-        float compare = (float) Math.random();
-        DecimalFormat decimalFormat = new DecimalFormat("#.0");
-        compare = Float.parseFloat(decimalFormat.format(compare));
-        objects.get(0).put("value",totalPrint);
-        objects.get(0).put("compare",compare);
 
-        objects.get(1).put("value",avgPrint);
-        objects.get(1).put("compare",compare);
 
-        objects.get(2).put("value",avgPaper);
-        objects.get(2).put("compare",compare);
 
-        objects.get(3).put("value",avgCartridge);
-        objects.get(3).put("compare",compare);
-        indeicator.setWorthAttention("⽂印管理持续为您服务");
-        indeicator.setList(objects);
-        return ReturnMsg.ok(indeicator);
-    }
 
-    @Override
-    public ReturnMsg getPrintInfoOrder(IocParam iocParam) {
-        String[] param = {"Print"};
-        String[] labKey = {"中旬","规划院","成分","上分","广分","郑分"};
-        List<Label> labels1 = GeneralMethod.getInstance().dataGeneration(param, labKey);
-        return ReturnMsg.ok(labels1);
-    }
 
-    @Override
-    public ReturnMsg getPrintInfo(IocParam iocParam) {
-        String[] param = {"zhongxun","guihuayuanBJ","zhengfen","guangfen","shangfen","chengfen"};
-        String startStr = iocParam.getTimeRange().getStartDate();
-        String endStr = iocParam.getTimeRange().getEndDate();
-        List<String> lists = DateUtil.getBetweenDays(startStr, endStr);
-        String[] labKey = lists.toArray(new String[0]);
-        List<Label> labels1 = GeneralMethod.getInstance().dataGeneration(param, labKey);
-        return ReturnMsg.ok(labels1);
-    }
 
     @Override
     public ReturnMsg getPhotovoltaicInfoOrder(IocParam iocParam) {

src/main/java/com/sky/ioc/service/carbon/impl/PrintCarbonServiceImpl.java

@@ -0,0 +1,117 @@
+package com.sky.ioc.service.carbon.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sky.ioc.entity.Indeicator;
+import com.sky.ioc.entity.Label;
+import com.sky.ioc.entity.domain.space.Company;
+import com.sky.ioc.entity.domain.space.Department;
+import com.sky.ioc.entity.params.IocParam;
+import com.sky.ioc.entity.params.IocTimeRange;
+import com.sky.ioc.mapper.carbon.PrintCarbonMapper;
+import com.sky.ioc.mapper.space.CompanyMapper;
+import com.sky.ioc.mapper.space.DepartmentMapper;
+import com.sky.ioc.service.carbon.PrintCarbonService;
+import com.sky.ioc.tool.DateUtil;
+import com.sky.ioc.tool.GeneralMethod;
+import com.sky.ioc.tool.MathUtils;
+import com.sky.ioc.tool.ReturnMsg;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.DecimalFormat;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ThreadLocalRandom;
+import java.util.stream.Collectors;
+
+@Service
+public class PrintCarbonServiceImpl implements PrintCarbonService {
+
+    @Autowired
+    PrintCarbonMapper printCarbonMapper;
+
+    @Autowired
+    CompanyMapper companyMapper;
+
+    @Autowired
+    DepartmentMapper departmentMapper;
+
+    @Override
+    public ReturnMsg getPrintCoreIndicators(IocParam iocParam) {
+        Indeicator indeicator = new Indeicator();
+        List<JSONObject> objects = indeicator.getList();
+        Double totalPrint = printCarbonMapper.getDischargeByTime(iocParam);
+        Long totalPaper = printCarbonMapper.getPaperByTime(iocParam);
+        Double totalInkbox = printCarbonMapper.getInkboxByTime(iocParam);
+        Integer totalPerson = printCarbonMapper.getUserByTime(iocParam);
+        float compare = (float) Math.random();
+        DecimalFormat decimalFormat = new DecimalFormat("#.0");
+        compare = Float.parseFloat(decimalFormat.format(compare));
+        objects.get(0).put("value",MathUtils.division(totalPrint,1,2));
+        objects.get(0).put("compare",compare);
+
+        objects.get(1).put("value", MathUtils.division(totalPrint,totalPerson,2));
+        objects.get(1).put("compare",compare);
+
+        objects.get(2).put("value",MathUtils.division(totalPaper,totalPerson,2));
+        objects.get(2).put("compare",compare);
+
+        objects.get(3).put("value",MathUtils.division(totalInkbox,totalPerson,2));
+        objects.get(3).put("compare",compare);
+        indeicator.setWorthAttention("⽂印管理持续为您服务");
+        indeicator.setList(objects);
+        return ReturnMsg.ok(indeicator);
+    }
+
+    @Override
+    public ReturnMsg getPrintInfo(IocParam iocParam) {
+        Company company =  companyMapper.selectById(1);
+        Department department = departmentMapper.selectById(company.getOfficeId());
+        List<Department> departments =departmentMapper.selectList(new LambdaQueryWrapper<Department>().eq(Department::getParentId,department.getOriId()));
+        String[] param = departments.stream().map(Department::getName).collect(Collectors.toList()).toArray(new String[0]);
+        String startStr = iocParam.getTimeRange().getStartDate();
+        String endStr = iocParam.getTimeRange().getEndDate();
+        List<String> lists = DateUtil.getBetweenDays(startStr, endStr);
+        String[] labKey = lists.toArray(new String[0]);
+        List<Label> labels1 = new ArrayList<>();
+        for (int i = 0; i < labKey.length; i++) {
+            Label label = new Label();
+            IocParam iocParam1 = new IocParam();
+            IocTimeRange iocTimeRange = new IocTimeRange();
+            iocTimeRange.setStartDate(labKey[i]+" 00:00:00");
+            iocTimeRange.setEndDate(labKey[i]+" 23:59:59");
+            iocParam1.setTimeRange(iocTimeRange);
+            JSONObject jsonObject = new JSONObject();
+            for (int j = 0; j < departments.size(); j++) {
+                iocParam1.setDeptId(departments.get(j).getId());
+                double total = printCarbonMapper.getDischargeByTime(iocParam1);
+                jsonObject.put(param[j],total);
+            }
+            label.setJsonObject(jsonObject);
+            label.setLabel(labKey[i]);
+            labels1.add(label);
+        }
+        // List<Label> labels1 = GeneralMethod.getInstance().dataGeneration(param, labKey);
+        return ReturnMsg.ok(labels1);
+    }
+
+    @Override
+    public ReturnMsg getPrintInfoOrder(IocParam iocParam) {
+        String[] param = {"Print"};
+        //String[] labKey = {"中旬","规划院","成分","上分","广分","郑分"};
+        List<Map<String,Object>> lists = printCarbonMapper.getDischargeOrderByTime(iocParam);
+        List<Label> labels1 = new ArrayList<>();
+        for(Map<String,Object> map:lists){
+            Label label = new Label();
+            JSONObject jsonObject = new JSONObject();
+            label.setJsonObject(jsonObject);
+            label.setLabel(String.valueOf(map.get("name")));
+            labels1.add(label);
+            jsonObject.put(param[0],MathUtils.division(Double.parseDouble(String.valueOf(map.get("total"))),1,2));
+        }
+       // List<Label> labels1 = GeneralMethod.getInstance().dataGeneration(param, labKey);
+        return ReturnMsg.ok(labels1);
+    }
+}