From 297405471e4de9ced067bfc290432410496c8b27 Mon Sep 17 00:00:00 2001 From: "YAS\\29473" <2947326429@qq.com> Date: Mon, 22 Sep 2025 15:11:21 +0800 Subject: [PATCH] update --- .../com/jsowell/pile/rpc/WccServiceImpl.java | 185 ++++++++++++++++++ pom.xml | 2 +- 2 files changed, 186 insertions(+), 1 deletion(-) diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/rpc/WccServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/rpc/WccServiceImpl.java index 245ca769f..5f238cfb2 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/rpc/WccServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/rpc/WccServiceImpl.java @@ -1,5 +1,7 @@ package com.jsowell.pile.rpc; +import com.jsowell.common.core.domain.ykc.BMSChargeInfoData; +import com.jsowell.common.core.domain.ykc.BMSDemandAndChargerOutputData; import com.jsowell.common.core.domain.ykc.RealTimeMonitorData; import com.jsowell.common.dto.JCTRealTimeMonitorData; import com.jsowell.common.dto.thirdparty.*; @@ -13,18 +15,22 @@ import com.jsowell.pile.dto.QueryOrderDTO; import com.jsowell.pile.dto.QueryStartChargeDTO; import com.jsowell.pile.dto.QueryStationInfoDTO; import com.jsowell.pile.dto.nanrui.NRQueryOrderDTO; +import com.jsowell.pile.dto.ningxiajiaotou.NXJTQueryOrdersInfoDTO; +import com.jsowell.pile.dto.ningxiajiaotou.NXJTQueryStationInfoDTO; import com.jsowell.pile.mapper.OrderDetailMapper; import com.jsowell.pile.mapper.PileBasicInfoMapper; import com.jsowell.pile.mapper.ThirdPartyStationRelationMapper; import com.jsowell.pile.service.*; import com.jsowell.pile.thirdparty.EquipmentInfo; import com.jsowell.pile.thirdparty.PileDetailInfoVO; +import com.jsowell.pile.thirdparty.ZDLEquipmentInfo; import com.jsowell.pile.vo.SupStationStatsVO; import com.jsowell.pile.vo.ThirdPartySecretInfoVO; import com.jsowell.pile.vo.base.*; import com.jsowell.pile.vo.lianlian.AccumulativeInfoVO; import com.jsowell.pile.vo.lianlian.OrderTempVO; import com.jsowell.pile.vo.nanrui.JiangSuOrderInfoVO; +import com.jsowell.pile.vo.ningxiajiaotou.NXJTStationInfoVO; import com.jsowell.pile.vo.uniapp.customer.BillingPriceVO; import com.jsowell.pile.vo.uniapp.customer.CurrentTimePriceDetails; import com.jsowell.pile.vo.uniapp.customer.OrderVO; @@ -186,6 +192,53 @@ public class WccServiceImpl implements WccService { return jctPileInfoVOS; } + @Override + public List getPileListForZDL(String stationId) { + List pileListForZDL = pileBasicInfoService.getPileListForZDL(stationId); + if (pileListForZDL == null || pileListForZDL.isEmpty()) { + return Collections.emptyList(); + } + List jctZDLEquipmentInfos = new ArrayList<>(); + for (ZDLEquipmentInfo zdLEquipmentInfo : pileListForZDL) { + JCTZDLEquipmentInfo jctZDLEquipmentInfo = new JCTZDLEquipmentInfo(); + BeanUtils.copyProperties(zdLEquipmentInfo, jctZDLEquipmentInfo); + jctZDLEquipmentInfos.add(jctZDLEquipmentInfo); + } + return jctZDLEquipmentInfos; + + } + + @Override + public List getBMSDemandAndChargerOutputInfoList(String transactionCode) { + List bmsDemandAndChargerOutputInfoList = pileBasicInfoService.getBMSDemandAndChargerOutputInfoList(transactionCode); + if (bmsDemandAndChargerOutputInfoList == null || bmsDemandAndChargerOutputInfoList.isEmpty()) { + return Collections.emptyList(); + + } + List jctBMSDemandAndChargerOutputDataList = new ArrayList<>(); + for (BMSDemandAndChargerOutputData bmsDemandAndChargerOutputData : bmsDemandAndChargerOutputInfoList) { + JCTBMSDemandAndChargerOutputData jctBMSDemandAndChargerOutputData = new JCTBMSDemandAndChargerOutputData(); + BeanUtils.copyProperties(bmsDemandAndChargerOutputData, jctBMSDemandAndChargerOutputData); + jctBMSDemandAndChargerOutputDataList.add(jctBMSDemandAndChargerOutputData); + } + return jctBMSDemandAndChargerOutputDataList; + } + + @Override + public List getBMSChargeInfoList(String transactionCode) { + List bmsChargeInfoList = pileBasicInfoService.getBMSChargeInfoList(transactionCode); + if (bmsChargeInfoList == null || bmsChargeInfoList.isEmpty()) { + return Collections.emptyList(); + } + List jctBMSChargeInfoDataList = new ArrayList<>(); + for (BMSChargeInfoData bmsChargeInfoData : bmsChargeInfoList) { + JCTBMSChargeInfoData jctBMSChargeInfoData = new JCTBMSChargeInfoData(); + BeanUtils.copyProperties(bmsChargeInfoData, jctBMSChargeInfoData); + jctBMSChargeInfoDataList.add(jctBMSChargeInfoData); + } + return jctBMSChargeInfoDataList; + } + // ==================== 使用 ThirdpartySecretInfoService 的方法 ==================== /** * 查询第三方平台配置信息列表 @@ -435,6 +488,52 @@ public class WccServiceImpl implements WccService { return jctSupStationStatsVOs; } + @Override + public List getOrderInfoByNXJT(JCTNXJTQueryOrdersInfoDTO dto) { + if (dto == null) { + return Collections.emptyList(); + } + NXJTQueryOrdersInfoDTO nxjtQueryOrdersInfoDTO = new NXJTQueryOrdersInfoDTO(); + BeanUtils.copyProperties(dto, nxjtQueryOrdersInfoDTO); + List orderVOS = orderBasicInfoService.getOrderInfoByNXJT(nxjtQueryOrdersInfoDTO); + if (orderVOS == null || orderVOS.isEmpty()) { + return Collections.emptyList(); + } + List jctOrderVOS = new ArrayList<>(); + for (OrderVO orderVO : orderVOS) { + JCTOrderVO jctOrderVO = new JCTOrderVO(); + BeanUtils.copyProperties(orderVO, jctOrderVO); + jctOrderVOS.add(jctOrderVO); + } + return jctOrderVOS; + } + + @Override + public JCTOrderVO getChargeOrderInfoByOrderCode(String orderCode) { + OrderVO orderVO = orderBasicInfoService.getChargeOrderInfoByOrderCode(orderCode); + if (orderVO == null) { + return null; + } + JCTOrderVO jctOrderVO = new JCTOrderVO(); + BeanUtils.copyProperties(orderVO, jctOrderVO); + return jctOrderVO; + } + + @Override + public List selectChargingOrder(String pileSn) { + List orderListVOS = orderBasicInfoService.selectChargingOrder(pileSn); + if (orderListVOS == null || orderListVOS.isEmpty()) { + return Collections.emptyList(); + } + List jctOrderListVOS = new ArrayList<>(); + for (OrderListVO orderListVO : orderListVOS) { + JCTOrderListVO jctOrderListVO = new JCTOrderListVO(); + BeanUtils.copyProperties(orderListVO, jctOrderListVO); + jctOrderListVOS.add(jctOrderListVO); + } + return jctOrderListVOS; + } + // ==================== 使用 PileStationInfoService 的方法 ==================== /** * 根据充电桩枪口号查询充电站信息 @@ -495,6 +594,57 @@ public class WccServiceImpl implements WccService { return jctPileStationVO; } + @Override + public JCTPileStationVO getStationInfoByPileSn(String pileSn) { + PileStationVO stationInfoByPileSn = pileStationInfoService.getStationInfoByPileSn(pileSn); + if (stationInfoByPileSn == null) { + return null; + } + JCTPileStationVO jctPileStationVO = new JCTPileStationVO(); + BeanUtils.copyProperties(stationInfoByPileSn, jctPileStationVO); + return jctPileStationVO; + } + + @Override + public List getStationInfosByThirdParty(JCTQueryStationInfoDTO dto) { + if (dto == null) { + return Collections.emptyList(); + } + QueryStationInfoDTO queryStationInfoDTO = new QueryStationInfoDTO(); + BeanUtils.copyProperties(dto, queryStationInfoDTO); + List stationInfosByThirdParty = pileStationInfoService.getStationInfosByThirdParty(queryStationInfoDTO); + if (stationInfosByThirdParty == null || stationInfosByThirdParty.isEmpty()) { + return Collections.emptyList(); + } + List jctThirdPartyStationInfoVOS = new ArrayList<>(); + for (ThirdPartyStationInfoVO thirdPartyStationInfoVO : stationInfosByThirdParty) { + JCTThirdPartyStationInfoVO jctThirdPartyStationInfoVO = new JCTThirdPartyStationInfoVO(); + BeanUtils.copyProperties(thirdPartyStationInfoVO, jctThirdPartyStationInfoVO); + jctThirdPartyStationInfoVOS.add(jctThirdPartyStationInfoVO); + } + return jctThirdPartyStationInfoVOS; + } + + @Override + public List NXJTQueryStationsInfo(JCTNXJTQueryStationInfoDTO dto) { + if (dto == null) { + return Collections.emptyList(); + } + NXJTQueryStationInfoDTO nxjtQueryStationInfoDTO = new NXJTQueryStationInfoDTO(); + BeanUtils.copyProperties(dto, nxjtQueryStationInfoDTO); + List nxjtStationsInfo = pileStationInfoService.NXJTQueryStationsInfo(nxjtQueryStationInfoDTO); + if (nxjtStationsInfo == null || nxjtStationsInfo.isEmpty()) { + return Collections.emptyList(); + } + List jctNXJTStationInfoVOS = new ArrayList<>(); + for (NXJTStationInfoVO nxjtStationInfoVO : nxjtStationsInfo) { + JCTNXJTStationInfoVO jctNXJTStationInfoVO = new JCTNXJTStationInfoVO(); + BeanUtils.copyProperties(nxjtStationInfoVO, jctNXJTStationInfoVO); + jctNXJTStationInfoVOS.add(jctNXJTStationInfoVO); + } + return jctNXJTStationInfoVOS; + } + // ==================== 使用 PileMerchantInfoService 的方法 ==================== @Override public JCTMerchantInfoVO getMerchantInfoVO(String merchantId) { @@ -602,6 +752,26 @@ public class WccServiceImpl implements WccService { return pileConnectorInfoService.getPileConnectorQrCodeUrl(pileConnectorCode); } + @Override + public List getUniAppConnectorList(Long stationId) { + List connectorListForLianLian = pileConnectorInfoService.getUniAppConnectorList(stationId); + if (connectorListForLianLian == null || connectorListForLianLian.isEmpty()) { + return Collections.emptyList(); + } + List jctConnectorInfoVOS = new ArrayList<>(); + for (ConnectorInfoVO connectorInfoVO : connectorListForLianLian) { + JCTConnectorInfoVO jctConnectorInfoVO = new JCTConnectorInfoVO(); + BeanUtils.copyProperties(connectorInfoVO , jctConnectorInfoVO); + jctConnectorInfoVOS.add(jctConnectorInfoVO); + } + return jctConnectorInfoVOS; + } + + @Override + public Map getPileTypeNum(Long stationId) { + return pileConnectorInfoService.getPileTypeNum(stationId); + } + // ==================== 使用 YKCPushCommandService 的方法 ==================== @Override public void pushStartChargingCommand(JCTStartChargingCommand command) { @@ -717,6 +887,21 @@ public class WccServiceImpl implements WccService { return jctThirdPartyStationRelationVO; } + @Override + public List selectThirdPartyStationRelationList(String thirdPlatformType) { + List thirdPartyStationRelationList = thirdPartyStationRelationService.selectThirdPartyStationRelationList(thirdPlatformType); + if (thirdPartyStationRelationList == null) { + return Collections.emptyList(); + } + List jctThirdPartyStationRelations = new ArrayList<>(); + for (ThirdPartyStationRelation thirdPartyStationRelation : thirdPartyStationRelationList) { + JCTThirdPartyStationRelation jctThirdPartyStationRelation = new JCTThirdPartyStationRelation(); + BeanUtils.copyProperties(thirdPartyStationRelation, jctThirdPartyStationRelation); + jctThirdPartyStationRelations.add(jctThirdPartyStationRelation); + } + return jctThirdPartyStationRelations; + } + // ==================== 使用 IAreaCodeInfoService 的方法 ==================== @Override public List selectAreaCodeInfoList(JCTAreaCodeInfo areaCodeInfo) { diff --git a/pom.xml b/pom.xml index 1dc398f9c..9f9ae0feb 100644 --- a/pom.xml +++ b/pom.xml @@ -46,7 +46,7 @@ 3.3.0 2.0.3 - 0.1.0 + 0.1.2