From aeaee7c6999b5580af442c309787f91ad34d9823 Mon Sep 17 00:00:00 2001
From: yuyang <YU930814yang>
Date: Thu, 12 May 2022 16:12:31 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=A4=A7=E5=B1=8F=E6=8C=89?=
 =?UTF-8?q?=E5=8C=BA=E5=9F=9F=E7=BB=9F=E8=AE=A1=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../XhpcDataBigScreenController.java          |  4 ++
 .../mapper/XhpcChargingStationMapper.java     |  2 +
 .../service/XhpcDataBigScreenService.java     |  2 +
 .../impl/XhpcDataBigScreenServiceImpl.java    | 24 ++++++++
 .../mapper/XhpcChargingStationMapper.xml      | 57 +++++++++++++++++++
 .../resources/mapper/XhpcStatisticsMapper.xml |  2 +-
 6 files changed, 90 insertions(+), 1 deletion(-)

diff --git a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/controller/XhpcDataBigScreenController.java b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/controller/XhpcDataBigScreenController.java
index a9632f54..38d04482 100644
--- a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/controller/XhpcDataBigScreenController.java
+++ b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/controller/XhpcDataBigScreenController.java
@@ -129,7 +129,11 @@ public class XhpcDataBigScreenController extends BaseController {
         return xhpcDataBigScreenService.returnCoreLocation(coreParam);
     }
 
+    @GetMapping("/core-chargingStation")
+    public R<List<Map<String, Object>>> returnCoreChargingStation(CoreParam coreParam) {
 
+        return xhpcDataBigScreenService.returnCoreChargingStation(coreParam);
+    }
     /**
      *  工单
      */
diff --git a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcChargingStationMapper.java b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcChargingStationMapper.java
index 06af97bd..0156e5d5 100644
--- a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcChargingStationMapper.java
+++ b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcChargingStationMapper.java
@@ -27,6 +27,8 @@ public interface XhpcChargingStationMapper {
      */
     List<Map<String, Object>> selectByTenantIdAndChargingStationId(@Param("tenantIdsStr") String tenantIdsStr, @Param("chargingStationId") Long chargingStationId);
 
+    List<Map<String, Object>> returnCoreChargingStation(@Param("tenantIdsStr") String tenantIdsStr, @Param("chargingStationId") Long chargingStationId, @Param("areaCode") Integer areaCode,@Param("number") Integer number);
+
     /**
      * @author WH
      * @date 2022/3/3 15:20
diff --git a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/XhpcDataBigScreenService.java b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/XhpcDataBigScreenService.java
index 18b7d61b..a27d8cae 100644
--- a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/XhpcDataBigScreenService.java
+++ b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/XhpcDataBigScreenService.java
@@ -25,6 +25,8 @@ public interface XhpcDataBigScreenService {
      */
     R<List<Map<String, Object>>> returnCoreLocation(CoreParam coreParam);
 
+    R returnCoreChargingStation(CoreParam coreParam);
+
     /**
      * query total count of user
      *
diff --git a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/impl/XhpcDataBigScreenServiceImpl.java b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/impl/XhpcDataBigScreenServiceImpl.java
index 7f3084b5..45ddd633 100644
--- a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/impl/XhpcDataBigScreenServiceImpl.java
+++ b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/service/impl/XhpcDataBigScreenServiceImpl.java
@@ -90,6 +90,30 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService {
         }
     }
 
+    @Override
+    public R returnCoreChargingStation(CoreParam coreParam) {
+        String tenantIdsStr = coreParam.getTenantIds();
+        if (coreParam.getParamType() == null) {
+            return R.fail("ParamType不能为null");
+        }
+        Integer areaCode = coreParam.getAreaCode();
+        int number =0;
+        if(areaCode !=null){
+            number = xhpcChargingStationMapper.getXhpcAreaLevel(areaCode);
+        }
+        String chargingStationIdStr = coreParam.getChargingStationIds();
+        if(chargingStationIdStr==null || "".equals(chargingStationIdStr)){
+            List<Map<String, Object>> list = xhpcChargingStationMapper.returnCoreChargingStation(tenantIdsStr, null, areaCode, number+1);
+            Object[] objects = list.toArray();
+            return R.ok(objects);
+        }
+        long chargingStationId = Long.parseLong(chargingStationIdStr);
+        //judge care param function
+        List<Map<String, Object>> list = xhpcChargingStationMapper.returnCoreChargingStation(tenantIdsStr, chargingStationId, areaCode, number+1);
+        Object[] objects = list.toArray();
+        return R.ok(objects);
+    }
+
     @Override
     public R<Object> queryUserTotalCount(CoreParam coreParam) {
 
diff --git a/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml b/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml
index c08c6f88..e5bbe391 100644
--- a/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml
+++ b/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml
@@ -71,6 +71,63 @@
             AND xhpc_charging_station.charging_station_id = #{chargingStationId}
         </if>
     </select>
+
+    <select id="returnCoreChargingStation" resultType="map">
+        SELECT
+            name,
+            (SELECT count(charging_station_id) FROM  xhpc_charging_station
+        WHERE del_flag = 0
+        <if test="tenantIdsStr!=null and tenantIdsStr!='' ">
+            and find_in_set(tenant_id, #{tenantIdsStr})
+        </if>
+        <if test="areaCode != null and areaCode != '' ">
+            <if test="number ==0">
+                AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =xa.code))
+            </if>
+            <if test="number ==1">
+                AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =xa.code))
+            </if>
+            <if test="number ==2">
+                AND area_code in (select code from xhpc_area where pcode =xa.code)
+            </if>
+            <if test="number ==3">
+                AND area_code =xa.code
+            </if>
+        </if>) value
+        FROM
+        xhpc_area as xa
+        WHERE 1=1
+        <if test="areaCode != null and areaCode != '' ">
+            and xa.level =#{number}
+            <if test="number==0">
+                and (SELECT count(charging_station_id) FROM  xhpc_charging_station
+                WHERE del_flag = 0
+                AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =xa.code)))>0
+            </if>
+            <if test="number ==1">
+                and (SELECT count(charging_station_id) FROM  xhpc_charging_station
+                WHERE del_flag = 0
+                AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =xa.code)))>0
+            </if>
+            <if test="number ==2">
+                and (SELECT count(charging_station_id) FROM  xhpc_charging_station
+                WHERE del_flag = 0
+                AND area_code in (select code from xhpc_area where pcode =xa.code))>0
+            </if>
+            <if test="number ==3">
+                and (SELECT count(charging_station_id) FROM  xhpc_charging_station
+                WHERE del_flag = 0
+                AND area_code =xa.code )>0
+            </if>
+        </if>
+        <if test="areaCode==null or areaCode == '' ">
+           and xa.level =1
+            and (SELECT count(charging_station_id) FROM  xhpc_charging_station
+            WHERE del_flag = 0
+            AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =xa.code)))>0
+        </if>
+    </select>
+
     <select id="selectByTenantIdAndAreaCode" resultType="map">
         SELECT
         xhpc_charging_station.tenant_id tenantId,
diff --git a/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcStatisticsMapper.xml b/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcStatisticsMapper.xml
index 07c06372..33556e60 100644
--- a/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcStatisticsMapper.xml
+++ b/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcStatisticsMapper.xml
@@ -1061,7 +1061,7 @@
         left join xhpc_internet_user as iu on iu.internet_user_id = ss.charging_mode
         where ss.del_flag=0 and ss.type=2
         <if test="startTime !=null and startTime !=''">
-            and ss.create_time &gt;= #{startTime}
+            and ss.create_time &gt;= #{endTime}
         </if>
         <if test="endTime !=null and endTime !=''">
             and ss.create_time &lt;= #{endTime}