From de256ebf775773e37bf0c9cbccfac67ac4540de7 Mon Sep 17 00:00:00 2001 From: yuyang Date: Wed, 18 May 2022 10:50:21 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=95=B0=E6=8D=AE=E5=A4=A7?= =?UTF-8?q?=E5=B1=8F=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/XhpcDataBigScreenServiceImpl.java | 395 +++++++++--------- .../mapper/XhpcChargingStationMapper.xml | 28 +- .../mapper/XhpcHistoryOrderMapper.xml | 6 +- 3 files changed, 222 insertions(+), 207 deletions(-) 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 295a97f4..6be291ae 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 @@ -118,161 +118,175 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { String tenantIdsStr = null; List> xhpcChargingStationList = null; + + Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); + List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); + //(0 C端用户 1 流量方用户 2社区用户 3B端用户) + 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); + //judge care param function - switch (coreParam.getParamType()) { - case 0: - tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - //get user count of c client - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); - List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); - //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - 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(tenantIdsStr); - //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - 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 - case 1: - Integer areaCode = coreParam.getAreaCode(); - tenantIdsStr = coreParam.getTenantIds(); - int number =0; - if(areaCode !=null){ - number = xhpcChargingStationMapper.getXhpcAreaLevel(areaCode); - } - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); - ArrayList chargingStationIdList = new ArrayList<>(); - for (Map chargingStation : xhpcChargingStationList) { - chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); - } - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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); - ArrayList chargingStationIdList = new ArrayList<>(); - for (Map chargingStation : xhpcChargingStationList) { - chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); - } - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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: - //query location info of special charging station of special tenant - tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - String chargingStationIdStr = coreParam.getChargingStationIds(); - long chargingStationId = Long.parseLong(chargingStationIdStr); - xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndChargingStationId(tenantIdsStr, chargingStationId); - ArrayList chargingStationIdList = new ArrayList<>(); - for (Map chargingStation : xhpcChargingStationList) { - chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); - } - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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("传入的参数有误"); - } - default: - R.fail("param type is invalid"); - break; - } - return null; +// switch (coreParam.getParamType()) { +// case 0: +// tenantIdsStr = coreParam.getTenantIds(); +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// //get user count of c client +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, null); +// List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); +// //(0 C端用户 1 流量方用户 2社区用户 3B端用户) +// 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(tenantIdsStr); +// //(0 C端用户 1 流量方用户 2社区用户 3B端用户) +// 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 +// case 1: +// Integer areaCode = coreParam.getAreaCode(); +// tenantIdsStr = coreParam.getTenantIds(); +// int number =0; +// if(areaCode !=null){ +// number = xhpcChargingStationMapper.getXhpcAreaLevel(areaCode); +// } +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); +// ArrayList chargingStationIdList = new ArrayList<>(); +// for (Map chargingStation : xhpcChargingStationList) { +// chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); +// } +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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); +// ArrayList chargingStationIdList = new ArrayList<>(); +// for (Map chargingStation : xhpcChargingStationList) { +// chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); +// } +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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: +// //query location info of special charging station of special tenant +// tenantIdsStr = coreParam.getTenantIds(); +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// String chargingStationIdStr = coreParam.getChargingStationIds(); +// long chargingStationId = Long.parseLong(chargingStationIdStr); +// xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndChargingStationId(tenantIdsStr, chargingStationId); +// ArrayList chargingStationIdList = new ArrayList<>(); +// for (Map chargingStation : xhpcChargingStationList) { +// chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); +// } +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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("传入的参数有误"); +// } +// default: +// R.fail("param type is invalid"); +// break; +// } +// return null; } @Override public R queryUserActivation(CoreParam coreParam) { String tenantIdsStr = null; - List> xhpcChargingStationList = null; String currentTime = MyDateUtil.getCurrentDateStrInYyyyMmDdHhMmSsFormat(); + //tenantIdsStr = coreParam.getTenantIds(); + Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, currentTime); + List chargingStationIdList = new ArrayList<>(); + //(0 C端用户 1 流量方用户 2社区用户 3B端用户) + 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); //judge care param function - switch (coreParam.getParamType()) { - case 0: - tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - //get user count of c client - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, currentTime); - List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); - //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - 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(tenantIdsStr); - //(0 C端用户 1 流量方用户 2社区用户 3B端用户) - 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 - case 1: - Integer areaCode = coreParam.getAreaCode(); - tenantIdsStr = coreParam.getTenantIds(); - int number =0; - if(areaCode !=null){ - number = xhpcChargingStationMapper.getXhpcAreaLevel(areaCode); - } - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); - ArrayList chargingStationIdList = new ArrayList<>(); - for (Map chargingStation : xhpcChargingStationList) { - chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); - } - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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); - ArrayList chargingStationIdList = new ArrayList<>(); - for (Map chargingStation : xhpcChargingStationList) { - chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); - } - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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: - //query location info of special charging station of special tenant - tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - String chargingStationIdStr = coreParam.getChargingStationIds(); - long chargingStationId = Long.parseLong(chargingStationIdStr); - xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndChargingStationId(tenantIdsStr, chargingStationId); - ArrayList chargingStationIdList = new ArrayList<>(); - for (Map chargingStation : xhpcChargingStationList) { - chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); - } - Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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("传入的参数有误"); - } - default: - R.fail("param type is invalid"); - break; - } - return null; +// switch (coreParam.getParamType()) { +// case 0: +// tenantIdsStr = coreParam.getTenantIds(); +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// //get user count of c client +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, currentTime); +// List chargingStationIdList = xhpcChargingStationMapper.selectChargingStationIds(tenantIdsStr); +// //(0 C端用户 1 流量方用户 2社区用户 3B端用户) +// 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(tenantIdsStr); +// //(0 C端用户 1 流量方用户 2社区用户 3B端用户) +// 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 +// case 1: +// Integer areaCode = coreParam.getAreaCode(); +// tenantIdsStr = coreParam.getTenantIds(); +// int number =0; +// if(areaCode !=null){ +// number = xhpcChargingStationMapper.getXhpcAreaLevel(areaCode); +// } +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndAreaCode(tenantIdsStr, areaCode,number); +// ArrayList chargingStationIdList = new ArrayList<>(); +// for (Map chargingStation : xhpcChargingStationList) { +// chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); +// } +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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); +// ArrayList chargingStationIdList = new ArrayList<>(); +// for (Map chargingStation : xhpcChargingStationList) { +// chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); +// } +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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: +// //query location info of special charging station of special tenant +// tenantIdsStr = coreParam.getTenantIds(); +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// String chargingStationIdStr = coreParam.getChargingStationIds(); +// long chargingStationId = Long.parseLong(chargingStationIdStr); +// xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndChargingStationId(tenantIdsStr, chargingStationId); +// ArrayList chargingStationIdList = new ArrayList<>(); +// for (Map chargingStation : xhpcChargingStationList) { +// chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); +// } +// Long appUserCount = xhpcAppUserMapper.selectTotalCountByTenantIdAndCurrentTime(tenantIdsStr, 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("传入的参数有误"); +// } +// default: +// R.fail("param type is invalid"); +// break; +// } +// return null; } @Override @@ -622,52 +636,53 @@ public class XhpcDataBigScreenServiceImpl implements XhpcDataBigScreenService { public R queryWorkOrder(CoreParam coreParam) { String tenantIdsStr = null; List> xhpcChargingStationList = null; + return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(null,null)); //judge care param function - switch (coreParam.getParamType()) { - case 0: - tenantIdsStr = coreParam.getTenantIds(); - return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(null,tenantIdsStr)); - //query charging station infos of whole area - case 1: - Integer areaCode = coreParam.getAreaCode(); - tenantIdsStr = coreParam.getTenantIds(); - int number =0; - if(areaCode !=null){ - number = xhpcChargingStationMapper.getXhpcAreaLevel(areaCode); - } - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - 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,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,tenantIdsStr)); - } - case 2: - //query location info of special charging station of special tenant - tenantIdsStr = coreParam.getTenantIds(); - if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { - String chargingStationIdStr = coreParam.getChargingStationIds(); - long chargingStationId = Long.parseLong(chargingStationIdStr); - xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndChargingStationId(tenantIdsStr, chargingStationId); - ArrayList chargingStationIdList = new ArrayList<>(); - for (Map chargingStation : xhpcChargingStationList) { - chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); - } - return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdsStr)); - } else { - return R.fail("传入的参数有误"); - } - default: - return R.fail("param type is invalid"); - } +// switch (coreParam.getParamType()) { +// case 0: +// tenantIdsStr = coreParam.getTenantIds(); +// return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(null,tenantIdsStr)); +// //query charging station infos of whole area +// case 1: +// Integer areaCode = coreParam.getAreaCode(); +// tenantIdsStr = coreParam.getTenantIds(); +// int number =0; +// if(areaCode !=null){ +// number = xhpcChargingStationMapper.getXhpcAreaLevel(areaCode); +// } +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// 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,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,tenantIdsStr)); +// } +// case 2: +// //query location info of special charging station of special tenant +// tenantIdsStr = coreParam.getTenantIds(); +// if (!"".equals(tenantIdsStr) && tenantIdsStr != null) { +// String chargingStationIdStr = coreParam.getChargingStationIds(); +// long chargingStationId = Long.parseLong(chargingStationIdStr); +// xhpcChargingStationList = xhpcChargingStationMapper.selectByTenantIdAndChargingStationId(tenantIdsStr, chargingStationId); +// ArrayList chargingStationIdList = new ArrayList<>(); +// for (Map chargingStation : xhpcChargingStationList) { +// chargingStationIdList.add((Long) chargingStation.get(ConstantClass.CHARGING_STATION_ID)); +// } +// return R.ok(xhpcChargingStationMapper.getWorkOrderTerminal(chargingStationIdList,tenantIdsStr)); +// } else { +// return R.fail("传入的参数有误"); +// } +// default: +// return R.fail("param type is invalid"); +// } } private R getOrderTrend(String tenantIdsStr, ArrayList chargingStationIdList) { 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 7d697c7a..7f39f944 100644 --- a/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml +++ b/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcChargingStationMapper.xml @@ -82,10 +82,10 @@ - AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =xa.code)) + AND area_code in (select code from xhpc_area_pc where pcode in(select code from xhpc_area_pc where pcode =xa.code)) - AND area_code in (select code from xhpc_area where pcode =xa.code) + AND area_code in (select code from xhpc_area_pc where pcode =xa.code) AND area_code =xa.code @@ -93,45 +93,45 @@ - AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =xa.code)) + AND area_code in (select code from xhpc_area_pc where pcode in(select code from xhpc_area_pc where pcode =xa.code)) - AND area_code in (select code from xhpc_area where pcode =xa.code) + AND area_code in (select code from xhpc_area_pc where pcode =xa.code) AND area_code =xa.code ) value FROM - xhpc_area as xa + xhpc_area_pc as xa WHERE 1=1 and xa.level =#{number} 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 + AND area_code in (select code from xhpc_area_pc where pcode in(select code from xhpc_area_pc where pcode =xa.code)))>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 =xa.code))>0 - AND (xa.code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =#{areaCode})) - or xa.code in (select code from xhpc_area where pcode =#{areaCode}) + AND area_code in (select code from xhpc_area_pc where pcode =xa.code))>0 + AND (xa.code in (select code from xhpc_area_pc where pcode in(select code from xhpc_area_pc where pcode =#{areaCode})) + or xa.code in (select code from xhpc_area_pc where pcode =#{areaCode}) ) and (SELECT count(charging_station_id) FROM xhpc_charging_station WHERE del_flag = 0 AND area_code =xa.code )>0 - and xa.code in (select code from xhpc_area where pcode =#{areaCode}) + and xa.code in (select code from xhpc_area_pc where pcode =#{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 + AND area_code in (select code from xhpc_area_pc where pcode in(select code from xhpc_area_pc where pcode =xa.code)))>0 @@ -152,10 +152,10 @@ - AND area_code in (select code from xhpc_area where pcode in(select code from xhpc_area where pcode =#{areaCode})) + AND area_code in (select code from xhpc_area_pc where pcode in(select code from xhpc_area_pc where pcode =#{areaCode})) - AND area_code in (select code from xhpc_area where pcode =#{areaCode}) + AND area_code in (select code from xhpc_area_pc where pcode =#{areaCode}) AND area_code =#{areaCode} @@ -164,7 +164,7 @@ 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 853d09fa..0a5a77f6 100644 --- a/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcHistoryOrderMapper.xml +++ b/xhpc-modules/xhpc-card/src/main/resources/mapper/XhpcHistoryOrderMapper.xml @@ -129,7 +129,7 @@ FROM xhpc_history_order WHERE - del_flag = 0 and charging_mode is not null + del_flag = 0 and find_in_set(tenant_id, #{tenantIdsStr}) @@ -174,7 +174,7 @@ FROM mysql.help_topic t WHERE - t.help_topic_id 31 + t.help_topic_id 15 ) a LEFT JOIN ( SELECT @@ -193,7 +193,7 @@ #{chargingStationId} - AND end_time =]]> DATE_ADD( now(), INTERVAL - 31 DAY ) + AND end_time =]]> DATE_ADD( now(), INTERVAL - 15 DAY ) GROUP BY DATE_FORMAT( end_time, "%Y-%m-%d" )) b ON a.`current_time` = b.end_time ORDER BY