明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
liujie
7 小时以前 0f4459e4201fdc19185b7dd03215871f036acd70 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderAccountingStrategyServiceImpl.java


@@ -13,8 +13,10 @@


import javax.annotation.Resource;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.text.DateFormat;


import java.text.SimpleDateFormat;


import java.time.Duration;


import java.time.format.DateTimeFormatter;


import java.util.*;


import java.util.stream.Collectors;


import java.util.stream.LongStream;


@@ -43,19 +45,23 @@


   @Override


   public List<List<Map<String, Object>>> getTotalElectricQuantity(Integer days, Set<Integer> siteIds) {


      SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");


      DateTimeFormatter sdf1 = DateTimeFormatter.ofPattern("yyyy-MM-dd");


      Calendar calendar = Calendar.getInstance();


      calendar.set(Calendar.DAY_OF_YEAR, calendar.get(Calendar.DAY_OF_YEAR) - days);


      String startTime = sdf.format(calendar.getTime()) + " 00:00:00";


      List<TChargingOrder> list = chargingOrderService.list(new LambdaQueryWrapper<TChargingOrder>().in(TChargingOrder::getSiteId, siteIds).eq(TChargingOrder::getStatus, 5)


            .eq(TChargingOrder::getDelFlag, 0).last(" and end_time between '" + startTime + "' and DATE_FORMAT('%Y-%m-%d %H:%i:%s', now())"));


            .eq(TChargingOrder::getDelFlag, 0).last(" and start_time between '" + startTime + "' and DATE_FORMAT(now(), '%Y-%m-%d %H:%i:%s')"));


      List<Long> orderId = list.stream().map(TChargingOrder::getId).collect(Collectors.toList());


      List<TChargingOrderAccountingStrategy> list1 = this.list(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().in(TChargingOrderAccountingStrategy::getChargingOrderId, orderId));


		


      List<TChargingOrderAccountingStrategy> list1 = new ArrayList<>();


      if(orderId.size() > 0){


         list1 = this.list(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().in(TChargingOrderAccountingStrategy::getChargingOrderId, orderId));


      }




      List<List<Map<String, Object>>> list2 = new ArrayList<>();


      Calendar nowDateTime = Calendar.getInstance();


      for (int i = days; i >= 0; i--) {


         Calendar nowDateTime = Calendar.getInstance();


         nowDateTime.set(Calendar.DAY_OF_YEAR, nowDateTime.get(Calendar.DAY_OF_YEAR) - i);


         List<TChargingOrder> collect = list.stream().filter(s -> sdf.format(s.getEndTime()).equals(sdf.format(nowDateTime.getTime()))).collect(Collectors.toList());


         List<TChargingOrder> collect = list.stream().filter(s -> s.getStartTime().format(sdf1).equals(sdf.format(nowDateTime.getTime()))).collect(Collectors.toList());


         List<Long> orderIds = collect.stream().map(TChargingOrder::getId).collect(Collectors.toList());


         


         


@@ -71,21 +77,21 @@


         map2.put("name", "峰");


         BigDecimal value2 = list1.stream().filter(s -> orderIds.contains(s.getChargingOrderId()) && s.getType() == 2)


               .map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add);


         map1.put("value", value2.setScale(2, RoundingMode.HALF_EVEN));


         map2.put("value", value2.setScale(2, RoundingMode.HALF_EVEN));


         datas.add(map2);


         


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


         map3.put("name", "平");


         BigDecimal value3 = list1.stream().filter(s -> orderIds.contains(s.getChargingOrderId()) && s.getType() == 3)


               .map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add);


         map1.put("value", value3.setScale(2, RoundingMode.HALF_EVEN));


         map3.put("value", value3.setScale(2, RoundingMode.HALF_EVEN));


         datas.add(map3);


         


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


         map4.put("name", "谷");


         BigDecimal value4 = list1.stream().filter(s -> orderIds.contains(s.getChargingOrderId()) && s.getType() == 4)


               .map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add);


         map1.put("value", value4.setScale(2, RoundingMode.HALF_EVEN));


         map4.put("value", value4.setScale(2, RoundingMode.HALF_EVEN));


         datas.add(map4);


         list2.add(datas);


      }


@@ -105,15 +111,15 @@


      calendar.set(Calendar.DAY_OF_YEAR, calendar.get(Calendar.DAY_OF_YEAR) - days);


      String startTime = sdf.format(calendar.getTime()) + " 00:00:00";


      List<TChargingOrder> list = chargingOrderService.list(new LambdaQueryWrapper<TChargingOrder>().in(TChargingOrder::getSiteId, siteIds).eq(TChargingOrder::getStatus, 5)


            .eq(TChargingOrder::getDelFlag, 0).last(" and end_time between '" + startTime + "' and DATE_FORMAT('%Y-%m-%d %H:%i:%s', now())"));


            .eq(TChargingOrder::getDelFlag, 0).last(" and start_time between '" + startTime + "' and DATE_FORMAT(now(), '%Y-%m-%d %H:%i:%s')"));


      


      List<Double> list2 = new ArrayList<>();


      Calendar nowDateTime = Calendar.getInstance();


      //遍历获取每天的数值


      for (int i = days; i >= 0; i--) {


         Calendar nowDateTime = Calendar.getInstance();


         nowDateTime.set(Calendar.DAY_OF_YEAR, nowDateTime.get(Calendar.DAY_OF_YEAR) - i);


         //充电量


         BigDecimal reduce = list.stream().filter(s -> sdf.format(s.getEndTime()).equals(sdf.format(nowDateTime.getTime())))


         BigDecimal reduce = list.stream().filter(s -> s.getStartTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")).equals(sdf.format(nowDateTime.getTime())))


               .map(TChargingOrder::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add);


         list2.add(reduce.doubleValue());


      }