autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-04-20 02:55:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

对接内蒙古平台

Browse Source
This commit is contained in:
Guoqs
2024-11-08 16:47:34 +08:00
parent d636c46d57
commit 54b40e6e56
1 changed files with 56 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/NeiMengGuPlatformServiceImpl.java vendored
View File

@@ -35,6 +35,7 @@ import com.jsowell.pile.vo.base.ThirdPartyStationInfoVO;
import com.jsowell.pile.vo.base.ThirdPartyStationRelationVO;
import com.jsowell.pile.vo.uniapp.customer.BillingPriceVO;
import com.jsowell.pile.vo.web.PileConnectorInfoVO;
import com.jsowell.pile.vo.web.PileMerchantInfoVO;
import com.jsowell.pile.vo.web.PileStationVO;
import com.jsowell.thirdparty.lianlian.domain.ConnectorChargeStatusInfo;
import com.jsowell.thirdparty.lianlian.domain.ConnectorStatusInfo;
@@ -339,12 +340,11 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
* @param dto 查询站点信息dto
* @throws UnsupportedOperationException 未实现异常
*/
@Override
public Map<String, String> queryStationStatus(QueryStationInfoDTO dto) {
public Map<String, String> queryStationStatusOld(QueryStationInfoDTO dto) {
List<String> stationIds = dto.getStationIds();
List<StationStatusInfo> StationStatusInfos = new ArrayList<>();
List<Object> connectorStatusInfos = new ArrayList<>();
// ThirdPartyPlatformConfig configInfo = thirdPartyPlatformConfigService.getInfoByOperatorId(dto.getOperatorId());
ThirdPartySecretInfoVO thirdPartySecretInfoVO = thirdpartySecretInfoService.queryByThirdPlatformType(thirdPlatformType);
if (thirdPartySecretInfoVO == null) {
return null;
@@ -412,6 +412,59 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
return resultMap;
}
@Override
public Map<String, String> queryStationStatus(QueryStationInfoDTO dto) {
List<String> stationIds = dto.getStationIds();
List<SupStationStatusInfo> stationStatusInfos = Lists.newArrayList();
ThirdPartySecretInfoVO thirdPartySecretInfoVO = thirdpartySecretInfoService.queryByThirdPlatformType(thirdPlatformType);
if (thirdPartySecretInfoVO == null) {
return null;
}
for (String stationId : stationIds) {
// 查询站点的运营商信息
PileMerchantInfoVO pileMerchantInfoVO = pileMerchantInfoService.queryMerchantInfoByStationId(stationId);
if (pileMerchantInfoVO == null) {
continue;
}
String operatorID = Constants.OPERATORID_JIANG_SU;
String organizationCode = pileMerchantInfoVO.getOrganizationCode();
String equipmentOwnerId = StringUtils.substring(organizationCode, organizationCode.length() - 10, organizationCode.length() - 1);
SupStationStatusInfo stationStatusInfo = new SupStationStatusInfo();
stationStatusInfo.setStationID(stationId);
stationStatusInfo.setEquipmentOwnerID(equipmentOwnerId);
stationStatusInfo.setOperatorID(operatorID);
// 根据站点id查询充电桩列表
List<ConnectorInfoVO> connectorInfoVOList = pileConnectorInfoService.getConnectorListForLianLian(Long.parseLong(stationId));
List<SupConnectorStatusInfo> connectorStatusInfos = Lists.newArrayList();
// 遍历充电桩列表
for (ConnectorInfoVO connectorInfoVO : connectorInfoVOList) {
SupConnectorStatusInfo connectorStatusInfo = new SupConnectorStatusInfo();
connectorStatusInfo.setOperatorID(operatorID);
connectorStatusInfo.setEquipmentOwnerID(equipmentOwnerId);
connectorStatusInfo.setStationID(stationId);
connectorStatusInfo.setEquipmentID(connectorInfoVO.getPileSn());
connectorStatusInfo.setConnectorID(connectorInfoVO.getPileConnectorCode());
connectorStatusInfo.setEquipmentClassification(Constants.ONE);
String connectorStatus = connectorInfoVO.getConnectorStatus();
connectorStatusInfo.setStatus(Integer.parseInt(connectorStatus));
connectorStatusInfo.setStatusDesc(PileConnectorDataBaseStatusEnum.getStatusDescription(connectorStatus));
// connectorStatusInfo.setParkStatus();
// connectorStatusInfo.setLockStatus();
connectorStatusInfo.setBatteryStatus(Constants.ZERO);
connectorStatusInfo.setBatteryPackID("");
connectorStatusInfo.setLastChangeTime(DateUtils.getDateTime());
connectorStatusInfos.add(connectorStatusInfo);
}
stationStatusInfo.setConnectorStatusInfos(connectorStatusInfos);
stationStatusInfos.add(stationStatusInfo);
}
// 结果集
Map<String, Object> map = Maps.newHashMap();
map.put("StationStatusInfos", stationStatusInfos);
Map<String, String> resultMap = ThirdPartyPlatformUtils.generateResultMap(map, thirdPartySecretInfoVO);
return resultMap;
}
/**
* 设备状态变化推送 notification_stationStatus
* 推送充电设备接口状态信息 supervise_notification_station_status