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 c016ba9e..06af97bd 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 @@ -43,17 +43,17 @@ public interface XhpcChargingStationMapper { * @date 2022/3/4 11:21 * @since version-1.0 */ - List selectChargingStationIds(@Param("tenantIdList") List tenantIdList); + List selectChargingStationIds(@Param("tenantIdsStr") String tenantIdsStr); /** * 查询枪的使用率 */ - List getTerminal(@Param("chargingStationIds")List chargingStationIds,@Param("tenantIds")List tenantIds); + List getTerminal(@Param("chargingStationIds")List chargingStationIds,@Param("tenantIdsStr")String tenantIdsStr); /** * 查询枪的使用率 */ - List> getWorkOrderTerminal(@Param("chargingStationIds")List chargingStationIds,@Param("tenantIds")List tenantIds); + List> getWorkOrderTerminal(@Param("chargingStationIds")List chargingStationIds,@Param("tenantIdsStr")String tenantIdsStr); } \ No newline at end of file diff --git a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcHistoryOrderMapper.java b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcHistoryOrderMapper.java index 513681d8..047eb0d9 100644 --- a/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcHistoryOrderMapper.java +++ b/xhpc-modules/xhpc-card/src/main/java/com/xhpc/card/mapper/XhpcHistoryOrderMapper.java @@ -28,7 +28,7 @@ public interface XhpcHistoryOrderMapper { * @since version-1.0 */ Long selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime( - @Param("tenantIdList") List tenantIdList, + @Param("tenantIdsStr") String tenantIdsStr, @Param("chargingStationIdList") List chargingStationIdList, @Param("userType") Integer userType, @Param("currentTime") String currentTime); @@ -45,11 +45,11 @@ public interface XhpcHistoryOrderMapper { @Param("chargingStationIdList") List chargingStationIdList); Long selectCountByTenantIdsAndChargingStationIds( - @Param("tenantIdList") List tenantIdList, + @Param("tenantIdsStr") String tenantIdsStr, @Param("chargingStationIdList") List chargingStationIdList); Long selectOrderCountBy( - @Param("tenantIdList") List tenantIdList, + @Param("tenantIdsStr") String tenantIdsStr, @Param("chargingStationIdList") List chargingStationIdList, @Param("userType") Integer userType, @Param("operatorId3rdptyEvcs") String operatorId3rdptyEvcs); @@ -62,7 +62,7 @@ public interface XhpcHistoryOrderMapper { * @since version-1.0 */ List> selectOrderTrendByTenantIdsAndChargingStationIds( - @Param("tenantIdList") List tenantIdList, + @Param("tenantIdsStr") String tenantIdsStr, @Param("chargingStationIdList") List chargingStationIdList); } \ No newline at end of file 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 3e515418..7f3084b5 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 @@ -44,8 +44,6 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; if (coreParam.getParamType() == null) { return R.fail("ParamType不能为null"); @@ -97,9 +95,6 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; - //judge care param function switch (coreParam.getParamType()) { case 0: @@ -107,18 +102,18 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { //get user count of c client Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdList); + List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } else { //get user count of c client Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdList); + List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } //query charging station infos of whole area @@ -136,8 +131,8 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } else { xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); @@ -146,8 +141,8 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } case 2: @@ -162,8 +157,8 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } else { return R.fail("传入的参数有误"); @@ -180,8 +175,6 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; String currentTime = MyDateUtil.getCurrentDateStrInYyyyMmDdHhMmSsFormat(); //judge care param function @@ -191,18 +184,18 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { //get user count of c client Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, currentTime); - List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdList); + List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, currentTime); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, currentTime); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, currentTime); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, currentTime); return R.ok(appUserCount + communityUserCount + customerUserCount); } else { //get user count of c client Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, currentTime); - List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdList); + List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, currentTime); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, currentTime); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, currentTime); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, currentTime); return R.ok(appUserCount + communityUserCount + customerUserCount); } //query charging station infos of whole area @@ -220,8 +213,8 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } else { xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); @@ -230,8 +223,8 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } case 2: @@ -246,8 +239,8 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); - Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long communityUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long customerUserCount = xhpcHistoryOrderMapper.selectUserTotalCountByTenantIdsAndChargingStationIdsAndUserTypeAndCurrentTime(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); return R.ok(appUserCount + communityUserCount + customerUserCount); } else { return R.fail("传入的参数有误"); @@ -264,9 +257,6 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; - //judge care param function switch (coreParam.getParamType()) { case 0: @@ -331,16 +321,12 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; //judge care param function switch (coreParam.getParamType()) { case 0: tenantIdsStr = coreParam.getTenantIds(); if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - tenantIdArray = tenantIdsStr.split(","); - tenantIdList = Arrays.stream(tenantIdArray).collect(Collectors.toList()); - OrderRatio orderRatio = getOrderRatio(tenantIdList, null); + OrderRatio orderRatio = getOrderRatio(tenantIdsStr, null); return R.ok(orderRatio); } else { OrderRatio orderRatio = getOrderRatio(null, null); @@ -360,7 +346,7 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - OrderRatio orderRatio = getOrderRatio(tenantIdList, chargingStationIdList); + OrderRatio orderRatio = getOrderRatio(tenantIdsStr, chargingStationIdList); return R.ok(orderRatio); } else { xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); @@ -368,7 +354,7 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - OrderRatio orderRatio = getOrderRatio(tenantIdList, chargingStationIdList); + OrderRatio orderRatio = getOrderRatio(tenantIdsStr, chargingStationIdList); return R.ok(orderRatio); } case 2: @@ -382,7 +368,7 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - OrderRatio orderRatio = getOrderRatio(tenantIdList, chargingStationIdList); + OrderRatio orderRatio = getOrderRatio(tenantIdsStr, chargingStationIdList); return R.ok(orderRatio); } else { return R.fail("传入的参数有误"); @@ -404,19 +390,13 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { public R queryTerminalGun(CoreParam coreParam) { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; Map map =new HashMap<>(); ArrayList chargingStationIdList = new ArrayList<>(); //judge care param function switch (coreParam.getParamType()) { case 0://全国 tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - tenantIdArray = tenantIdsStr.split(","); - tenantIdList = Arrays.stream(tenantIdArray).collect(Collectors.toList()); - } - return getMapR(chargingStationIdList,tenantIdList, map); + return getMapR(chargingStationIdList,tenantIdsStr, map); //query charging station infos of whole area case 1://省市区 Integer areaCode = coreParam.getAreaCode(); @@ -436,7 +416,7 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } } - return getMapR(chargingStationIdList,tenantIdList, map); + return getMapR(chargingStationIdList,tenantIdsStr, map); case 2://场站 //query location info of special charging station of special tenant tenantIdsStr = coreParam.getTenantIds(); @@ -447,7 +427,7 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - return getMapR(chargingStationIdList,tenantIdList, map); + return getMapR(chargingStationIdList,tenantIdsStr, map); } else { return R.fail("传入的参数有误"); } @@ -458,8 +438,8 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { return R.ok(); } - private R> getMapR(List chargingStationIdList,List tenantIdList, Map map) { - List terminal = xhpcChargingStationMapper.getTerminal(chargingStationIdList, tenantIdList); + private R> getMapR(List chargingStationIdList,String tenantIdsStr, Map map) { + List terminal = xhpcChargingStationMapper.getTerminal(chargingStationIdList, tenantIdsStr); int total =terminal.size();//离线 int offLine =0;//离线 int fault =0;//故障 @@ -506,8 +486,6 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; //judge care param function switch (coreParam.getParamType()) { case 0: @@ -570,17 +548,11 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; //judge care param function switch (coreParam.getParamType()) { case 0: tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - tenantIdArray = tenantIdsStr.split(","); - tenantIdList = Arrays.stream(tenantIdArray).collect(Collectors.toList()); - } - return getOrderTrend(tenantIdList, null); + return getOrderTrend(tenantIdsStr, null); case 1: Integer areaCode = coreParam.getAreaCode(); tenantIdsStr = coreParam.getTenantIds(); @@ -594,14 +566,14 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - return getOrderTrend(tenantIdList, chargingStationIdList); + return getOrderTrend(tenantIdsStr, chargingStationIdList); } else { xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); ArrayList chargingStationIdList = new ArrayList<>(); for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - return getOrderTrend(tenantIdList, chargingStationIdList); + return getOrderTrend(tenantIdsStr, chargingStationIdList); } case 2: //query location info of special charging station of special tenant @@ -614,7 +586,7 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - return getOrderTrend(tenantIdList, chargingStationIdList); + return getOrderTrend(tenantIdsStr, chargingStationIdList); } else { return R.fail("传入的参数有误"); } @@ -627,17 +599,11 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { public R queryWorkOrder(CoreParam coreParam) { String tenantIdsStr = null; List> xhpcChargingStationList = null; - List tenantIdList = null; - String[] tenantIdArray = null; //judge care param function switch (coreParam.getParamType()) { case 0: tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - tenantIdArray = tenantIdsStr.split(","); - tenantIdList = Arrays.stream(tenantIdArray).collect(Collectors.toList()); - } - return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(null,tenantIdList)); + return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(null,tenantIdsStr)); //query charging station infos of whole area case 1: Integer areaCode = coreParam.getAreaCode(); @@ -652,14 +618,14 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdList)); + return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdsStr)); } else { xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); ArrayList chargingStationIdList = new ArrayList<>(); for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdList)); + return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdsStr)); } case 2: //query location info of special charging station of special tenant @@ -672,7 +638,7 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { for (Map chargingStation : xhpcChargingStationList) { chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); } - return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdList)); + return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdsStr)); } else { return R.fail("传入的参数有误"); } @@ -681,9 +647,9 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { } } - private R getOrderTrend(List tenantIdList, ArrayList chargingStationIdList) { + private R getOrderTrend(String tenantIdsStr, ArrayList chargingStationIdList) { - List> orderTrendList = xhpcHistoryOrderMapper.selectOrderTrendByTenantIdsAndChargingStationIds(tenantIdList, chargingStationIdList); + List> orderTrendList = xhpcHistoryOrderMapper.selectOrderTrendByTenantIdsAndChargingStationIds(tenantIdsStr, chargingStationIdList); OrderTrend orderTrend = new OrderTrend(); orderTrend.setData(new ArrayList<>()); orderTrend.setTotalItems(0L); @@ -740,38 +706,37 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { /** * 获取订单来源比例方法 * - * @param tenantIdList 租户id集合 * @param chargingStationIdList 电站id集合 * @author WH * @date 2022/3/15 17:08 * @since version-1.0 */ - private OrderRatio getOrderRatio(List tenantIdList, List chargingStationIdList) { + private OrderRatio getOrderRatio(String tenantIdsStr, List chargingStationIdList) { - Long totalCount = xhpcHistoryOrderMapper.selectCountByTenantIdsAndChargingStationIds(tenantIdList, chargingStationIdList); + Long totalCount = xhpcHistoryOrderMapper.selectCountByTenantIdsAndChargingStationIds(tenantIdsStr, chargingStationIdList); OrderRatio orderRatio = new OrderRatio(); orderRatio.setTotalCount(totalCount); - Long stClientNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdList, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); + Long stClientNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdsStr, chargingStationIdList, UserTypeUtil.COMMUNIT_TYPE, null); double stClientNumberDouble = stClientNumber.doubleValue(); long stClientRatio = (long) (stClientNumberDouble / totalCount * 100); orderRatio.setStClientRatio(stClientRatio); - Long bClientNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdList, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); + Long bClientNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdsStr, chargingStationIdList, UserTypeUtil.CUSTOMERS_TYPE, null); double bClientNumberDouble = bClientNumber.doubleValue(); long bClientRatio = (long) (bClientNumberDouble / totalCount * 100); orderRatio.setBClientRatio(bClientRatio); - Long kuaiDianNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdList, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.KUAI_DIAN_EVCS); + Long kuaiDianNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdsStr, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.KUAI_DIAN_EVCS); double kuaiDianNumberDouble = kuaiDianNumber.doubleValue(); long kuaiDianRatio = (long) (kuaiDianNumberDouble / totalCount * 100); orderRatio.setKuaiDianRatio(kuaiDianRatio); - Long hengDaNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdList, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.HENG_DA_EVCS); + Long hengDaNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdsStr, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.HENG_DA_EVCS); double hengDaNumberDouble = hengDaNumber.doubleValue(); long hengDaRatio = (long) (hengDaNumberDouble / totalCount * 100); orderRatio.setHengDaRatio(hengDaRatio); - Long xinDianTuNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdList, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.XIN_DIAN_TU_EVCS); + Long xinDianTuNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdsStr, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.XIN_DIAN_TU_EVCS); double xinDianTuNumberDouble = xinDianTuNumber.doubleValue(); long xinDianTuRatio = (long) (xinDianTuNumberDouble / totalCount * 100); orderRatio.setXinDianTuRatio(xinDianTuRatio); - Long xiaoJuNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdList, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.XIAO_JU_EVCS); + Long xiaoJuNumber = xhpcHistoryOrderMapper.selectOrderCountBy(tenantIdsStr, chargingStationIdList, UserTypeUtil.INTERNET_TYPE, ConstantClass.XIAO_JU_EVCS); double xiaoJuNumberDouble = xiaoJuNumber.doubleValue(); long xiaoJuRatio = (long) (xiaoJuNumberDouble / totalCount * 100); orderRatio.setXiaoJuRatio(xiaoJuRatio); 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 6936cd77..b6dec5c0 100644 --- a/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml +++ b/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml @@ -110,11 +110,8 @@ FROM xhpc_charging_station - - and tenant_id in - - #{tenantId} - + + and find_in_set(tenant_id, #{tenantIdsStr}) @@ -483,16 +480,13 @@ select serial_number as serialNumber from xhpc_terminal where del_flag = 0 - - and tenant_id in - - #{tenantId} - + + and find_in_set(tenant_id, #{tenantIdsStr}) and charging_station_id in - #{tenantId} + #{chargingStationId} @@ -504,18 +498,8 @@ status from xhpc_work_order where 1=1 - - and tenant_id in - - #{tenantId} - - - - and find_in_set((select serial_number from xhpc_terminal where charging_station_id in - - #{tenantId} - - ),serial_number) + + and find_in_set(tenant_id, #{tenantIdsStr}) order by create_time desc diff --git a/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcHistoryOrderMapper.xml b/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcHistoryOrderMapper.xml index 78dd21a2..a71d6441 100644 --- a/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcHistoryOrderMapper.xml +++ b/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcHistoryOrderMapper.xml @@ -89,14 +89,11 @@ xhpc_history_order WHERE del_flag = 0 - - AND tenant_id IN - - #{tenantId} - + + and find_in_set(tenant_id, #{tenantIdsStr}) - AND tenant_id IN + AND charging_station_id IN #{chargingStationId} @@ -111,7 +108,7 @@ + diff --git a/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/controller/XhpcUserAccountStatementController.java b/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/controller/XhpcUserAccountStatementController.java index 78f83573..bbb032d8 100644 --- a/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/controller/XhpcUserAccountStatementController.java +++ b/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/controller/XhpcUserAccountStatementController.java @@ -31,8 +31,9 @@ public class XhpcUserAccountStatementController extends BaseController { */ @ApiOperation(value = "用户流水分页列表") @GetMapping("/page") - public TableDataInfo page(HttpServletRequest request) { - List> list = iXhpcUserAccountStatementService.page(request); + public TableDataInfo page(Long appUserId) { + startPage(); + List> list = iXhpcUserAccountStatementService.page(appUserId); return getDataTable(list); } diff --git a/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/IXhpcUserAccountStatementService.java b/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/IXhpcUserAccountStatementService.java index d7bf57e2..84fbfd74 100644 --- a/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/IXhpcUserAccountStatementService.java +++ b/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/IXhpcUserAccountStatementService.java @@ -26,7 +26,7 @@ public interface IXhpcUserAccountStatementService { * @param appUserId C端用户id * @return */ - public List> page(HttpServletRequest request); + public List> page(Long appUserId); /** * 用户流水列表 diff --git a/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/impl/XhpcUserAccountStatementServiceImpl.java b/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/impl/XhpcUserAccountStatementServiceImpl.java index b81f41e0..3cd06aca 100644 --- a/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/impl/XhpcUserAccountStatementServiceImpl.java +++ b/xhpc-modules/xhpc-payment/src/main/java/com/xhpc/payment/service/impl/XhpcUserAccountStatementServiceImpl.java @@ -58,21 +58,12 @@ public class XhpcUserAccountStatementServiceImpl extends BaseService implements * @return */ @Override - public List> page(HttpServletRequest request) { + public List> page(Long appUserId) { List> list =new ArrayList<>(); - LoginUser loginUser = tokenService.getLoginUser(request); - Long userid = loginUser.getUserid(); - String tenantId = loginUser.getTenantId(); - Integer userType = loginUser.getUserType(); - R user = userTypeService.getUser(null, userid, userType, null, tenantId); - if(user !=null && user.getData() !=null){ - Map userMessage = (Map)user.getData(); - if (userMessage != null) { - startPage(); - return xhpcUserAccountStatementMapper.page(userid,userType,tenantId); - } + if(appUserId==null){ + return list; } - return list; + return xhpcUserAccountStatementMapper.page(appUserId,0,null); } /** diff --git a/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcAppUserMapper.xml b/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcAppUserMapper.xml index 74e8f0d3..afa6194a 100644 --- a/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcAppUserMapper.xml +++ b/xhpc-modules/xhpc-user/src/main/resources/mapper/XhpcAppUserMapper.xml @@ -196,7 +196,7 @@ CASE WHEN xau.`status` = 0 THEN '正常' else '禁用' end statusName, CASE WHEN a.count > 0 THEN '老用户' else '新用户' end newUser from xhpc_app_user xau - LEFT JOIN (select count(1) count ,user_id from xhpc_charge_order where del_flag = 0 ) a on a.user_id = + LEFT JOIN (select count(1) count ,user_id from xhpc_charge_order where del_flag = 0 and source =0 GROUP BY user_id) a on a.user_id = xau.app_user_id WHERE xau.del_flag = 0