update 贵州省平台Service

2026-04-21 03:25:12 +08:00 · 2024-12-20 09:11:48 +08:00
parent d96060da9a
commit 5869e8d5f3
10 changed files with 170 additions and 38 deletions
--- a/jsowell-pile/src/main/java/com/jsowell/pile/dto/OrderPileOccupyDTO.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/dto/OrderPileOccupyDTO.java
@@ -11,7 +11,7 @@ import java.util.Date;
 import java.util.List;

 /**
- * TODO
+ * 占桩订单DTO
 *
 * @author Lemon
 * @Date 2024/7/15 13:37:04
@@ -47,6 +47,11 @@ public class OrderPileOccupyDTO extends BaseEntity {
     */
    private String stationId;

+    /**
+     * 站点名称
+     */
+    private String stationName;
+
    /**
     * 车牌号码
     */
--- a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileBasicInfoMapper.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/PileBasicInfoMapper.java
@@ -4,6 +4,7 @@ import com.jsowell.pile.domain.PileBasicInfo;
 import com.jsowell.pile.dto.IndexQueryDTO;
 import com.jsowell.pile.dto.QueryPileDTO;
 import com.jsowell.pile.dto.ReplaceMerchantStationDTO;
+import com.jsowell.pile.thirdparty.PileDetailInfoVO;
 import com.jsowell.pile.vo.base.PileInfoVO;
 import com.jsowell.pile.vo.uniapp.customer.PersonalPileInfoVO;
 import com.jsowell.pile.vo.uniapp.customer.PileConnectorDetailVO;
@@ -169,4 +170,11 @@ public interface PileBasicInfoMapper {
 	 * @return
 	 */
    PileBasicInfo getMaxNumPileInfo();
+
+	/**
+	 * 获取桩信息详情列表
+	 * @param stationId
+	 * @return
+	 */
+    List<PileDetailInfoVO> getPileDetailInfoList(String stationId);
 }
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/PileBasicInfoService.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/PileBasicInfoService.java
@@ -6,10 +6,7 @@ import com.jsowell.common.core.domain.ykc.RealTimeMonitorData;
 import com.jsowell.pile.domain.PileBasicInfo;
 import com.jsowell.pile.domain.ebike.deviceupload.EBikeMessageCmd20;
 import com.jsowell.pile.dto.*;
-import com.jsowell.pile.thirdparty.ConnectorInfo;
-import com.jsowell.pile.thirdparty.EquipmentInfo;
-import com.jsowell.pile.thirdparty.ZDLConnectorInfo;
-import com.jsowell.pile.thirdparty.ZDLEquipmentInfo;
+import com.jsowell.pile.thirdparty.*;
 import com.jsowell.pile.vo.base.PileInfoVO;
 import com.jsowell.pile.vo.uniapp.customer.GroundLockInfoVO;
 import com.jsowell.pile.vo.uniapp.customer.PersonalPileInfoVO;
@@ -252,4 +249,6 @@ public interface PileBasicInfoService {
 	 * @param message
 	 */
    void registrationEBikePile(EBikeMessageCmd20 message);
+
+	List<PileDetailInfoVO> getPileDetailInfoList(String stationId);
 }
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileBasicInfoServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileBasicInfoServiceImpl.java
@@ -24,13 +24,11 @@ import com.jsowell.pile.mapper.PileBasicInfoMapper;
 import com.jsowell.pile.service.*;
 import com.jsowell.pile.service.programlogic.AbstractProgramLogic;
 import com.jsowell.pile.service.programlogic.ProgramLogicFactory;
-import com.jsowell.pile.thirdparty.ConnectorInfo;
-import com.jsowell.pile.thirdparty.EquipmentInfo;
-import com.jsowell.pile.thirdparty.ZDLConnectorInfo;
-import com.jsowell.pile.thirdparty.ZDLEquipmentInfo;
+import com.jsowell.pile.thirdparty.*;
 import com.jsowell.pile.transaction.dto.PileTransactionDTO;
 import com.jsowell.pile.transaction.service.TransactionService;
 import com.jsowell.pile.util.UserUtils;
+import com.jsowell.pile.vo.base.ConnectorInfoVO;
 import com.jsowell.pile.vo.base.MerchantInfoVO;
 import com.jsowell.pile.vo.base.PileInfoVO;
 import com.jsowell.pile.vo.uniapp.customer.GroundLockInfoVO;
@@ -1226,48 +1224,49 @@ public class PileBasicInfoServiceImpl implements PileBasicInfoService {
 	public List<EquipmentInfo> getPileListForLianLian(String stationId) {
 		List<EquipmentInfo> resultList = new ArrayList<>();
 		// 通过站点id查询桩基本信息
-		List<PileBasicInfo> list = this.getPileListByStationId(stationId);
+		// List<PileBasicInfo> list = this.getPileListByStationId(stationId);
+		List<PileDetailInfoVO> list = getPileDetailInfoList(stationId);
 		// 封装成联联平台对象
-		for (PileBasicInfo pileBasicInfo : list) {
+		for (PileDetailInfoVO pileDetailInfoVO : list) {
 			EquipmentInfo equipmentInfo = new EquipmentInfo();
-			String pileSn = pileBasicInfo.getSn();
+			String pileSn = pileDetailInfoVO.getPileSn();

 			equipmentInfo.setEquipmentID(pileSn);
 			equipmentInfo.setEquipmentClassification(1);
 			equipmentInfo.setManufacturerID(Constants.OPERATORID_LIANLIAN);
 			equipmentInfo.setManufacturerName(Constants.MANUFACTURER_NAME);
-			equipmentInfo.setConstructionTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, pileBasicInfo.getCreateTime()));
-			equipmentInfo.setProductionDate(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, pileBasicInfo.getCreateTime()));
+			equipmentInfo.setConstructionTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, pileDetailInfoVO.getCreateTime()));
+			equipmentInfo.setProductionDate(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, pileDetailInfoVO.getCreateTime()));

-			PileModelInfoVO modelInfo = pileModelInfoService.getPileModelInfoByPileSn(pileSn);
-			if (StringUtils.isBlank(modelInfo.getSpeedType())) {
+			// PileModelInfoVO modelInfo = pileModelInfoService.getPileModelInfoByPileSn(pileSn);
+			if (StringUtils.isBlank(pileDetailInfoVO.getSpeedType())) {
 				continue;
 			}
-			equipmentInfo.setEquipmentType(Integer.valueOf(modelInfo.getSpeedType()));
-			equipmentInfo.setEquipmentModel(modelInfo.getModelName());
+			equipmentInfo.setEquipmentType(Integer.valueOf(pileDetailInfoVO.getSpeedType()));
+			equipmentInfo.setEquipmentModel(pileDetailInfoVO.getModelName());

 			// Map<String, String> pileStatus = pileConnectorInfoService.getPileStatus(Lists.newArrayList(pileBasicInfo.getSn()));
-			Map<String, String> pileStatusMap = pileConnectorInfoService.getPileStatus(Lists.newArrayList(pileSn));
-			String pileStatus = pileStatusMap.get(pileSn);
-			if (StringUtils.equals(PileStatusEnum.ON_LINE.getValue(), pileStatus)) {
-				// 1-在线
-				pileStatus = LianLianPileStatusEnum.NORMAL.getCode();
-			} else if (StringUtils.equals(PileStatusEnum.OFF_LINE.getValue(), pileStatus)) {
-				// 2-离线
-				pileStatus = LianLianPileStatusEnum.CLOSE_OFFLINE.getCode();
-			} else if (StringUtils.equals(PileStatusEnum.FAULT.getValue(), pileStatus)) {
-				// 3-故障
-				pileStatus = LianLianPileStatusEnum.UNDER_MAINTENANCE.getCode();
-			}
-			equipmentInfo.setEquipmentStatus(Integer.valueOf(pileStatus));
-			equipmentInfo.setEquipmentPower(new BigDecimal(modelInfo.getRatedPower()).setScale(1, BigDecimal.ROUND_HALF_UP));
+			// Map<String, String> pileStatusMap = pileConnectorInfoService.getPileStatus(Lists.newArrayList(pileSn));
+			// String pileStatus = pileStatusMap.get(pileSn);
+			// if (StringUtils.equals(PileStatusEnum.ON_LINE.getValue(), pileStatus)) {
+			// 	// 1-在线
+			// 	pileStatus = LianLianPileStatusEnum.NORMAL.getCode();
+			// } else if (StringUtils.equals(PileStatusEnum.OFF_LINE.getValue(), pileStatus)) {
+			// 	// 2-离线
+			// 	pileStatus = LianLianPileStatusEnum.CLOSE_OFFLINE.getCode();
+			// } else if (StringUtils.equals(PileStatusEnum.FAULT.getValue(), pileStatus)) {
+			// 	// 3-故障
+			// 	pileStatus = LianLianPileStatusEnum.UNDER_MAINTENANCE.getCode();
+			// }
+			equipmentInfo.setEquipmentStatus(Integer.valueOf(pileDetailInfoVO.getPileStatus()));
+			equipmentInfo.setEquipmentPower(new BigDecimal(pileDetailInfoVO.getRatedPower()).setScale(1, BigDecimal.ROUND_HALF_UP));
 			equipmentInfo.setNewNationalStandard(1);
 			equipmentInfo.setVinFlag(1);
 			equipmentInfo.setEquipmentName(pileSn);
-			equipmentInfo.setPower(new BigDecimal(modelInfo.getRatedPower()).setScale(1, BigDecimal.ROUND_HALF_UP));
+			equipmentInfo.setPower(new BigDecimal(pileDetailInfoVO.getRatedPower()).setScale(1, BigDecimal.ROUND_HALF_UP));

 			// 枪口列表
-			List<ConnectorInfo> connectorList = getConnectorListForLianLian(pileSn);
+			List<ConnectorInfo> connectorList = getConnectorListForLianLian(pileDetailInfoVO);
 			equipmentInfo.setConnectorInfos(connectorList);

 			resultList.add(equipmentInfo);
@@ -1276,6 +1275,25 @@ public class PileBasicInfoServiceImpl implements PileBasicInfoService {
 		return resultList;
 	}

+	@Override
+	public List<PileDetailInfoVO> getPileDetailInfoList(String stationId) {
+		List<PileDetailInfoVO> pileDetailInfoList = pileBasicInfoMapper.getPileDetailInfoList(stationId);
+		if (CollectionUtils.isEmpty(pileDetailInfoList)) {
+			return new ArrayList<>();
+		}
+		List<String> pileSnList = pileDetailInfoList.stream()
+				.map(PileDetailInfoVO::getPileSn)
+				.collect(Collectors.toList());
+		Map<String, String> pileStatusV2 = pileConnectorInfoService.getPileStatus(pileSnList);
+		pileDetailInfoList.forEach(pileDetailInfoVO -> {
+			String pileSn = pileDetailInfoVO.getPileSn();
+			if (pileStatusV2.containsKey(pileSn)) {
+				pileDetailInfoVO.setPileStatus(pileStatusV2.get(pileSn));
+			}
+		});
+		return pileDetailInfoList;
+	}
+
 	/**
 	 * 获取枪口列表
 	 *
@@ -1357,6 +1375,43 @@ public class PileBasicInfoServiceImpl implements PileBasicInfoService {
 		return resultList;
 	}

+
+	public List<ConnectorInfo> getConnectorListForLianLian(PileDetailInfoVO pileDetailInfoVO) {
+		List<ConnectorInfo> resultList = new ArrayList<>();
+
+		List<PileConnectorInfo> list = pileConnectorInfoService.selectPileConnectorInfoList(pileDetailInfoVO.getPileSn());
+		for (PileConnectorInfo pileConnectorInfo : list) {
+			ConnectorInfo connectorInfo = new ConnectorInfo();
+			connectorInfo.setConnectorID(pileConnectorInfo.getPileConnectorCode());
+			int connectorType = StringUtils.equals("1", pileDetailInfoVO.getSpeedType()) ? 4 : 3;
+			connectorInfo.setConnectorType(connectorType);
+			// 车位号
+			if (StringUtils.isNotBlank(pileConnectorInfo.getParkNo())) {
+				connectorInfo.setParkNo(pileConnectorInfo.getParkNo());
+			}
+			connectorInfo.setVoltageUpperLimits(Integer.valueOf(pileDetailInfoVO.getRatedVoltage()));
+			connectorInfo.setEquipmentClassification(1);
+			connectorInfo.setVoltageLowerLimits(Integer.valueOf(pileDetailInfoVO.getRatedVoltage()));
+			connectorInfo.setCurrent(Integer.valueOf(pileDetailInfoVO.getRatedCurrent()));
+			connectorInfo.setConnectorName(pileConnectorInfo.getPileConnectorCode());
+			connectorInfo.setOperateStatus(50); // 50-正常使用
+			connectorInfo.setOpreateStatus(50); // 50-正常使用
+			connectorInfo.setNationalStandard(2); // 2-2015
+			connectorInfo.setAuxPower(3); // 3-兼容12V和24V
+
+			if (!StringUtils.equals(pileDetailInfoVO.getConnectorNum(), "1")) {
+				// 如果不是单枪，则枪口功率需要除以枪口数量
+				String ratedPowerStr = pileDetailInfoVO.getRatedPower();
+				BigDecimal ratedPower = new BigDecimal(ratedPowerStr);
+				connectorInfo.setPower(ratedPower.divide(new BigDecimal(pileDetailInfoVO.getConnectorNum()), 1, BigDecimal.ROUND_HALF_UP));
+			}else {
+				connectorInfo.setPower(new BigDecimal(pileDetailInfoVO.getRatedPower()).setScale(1, BigDecimal.ROUND_HALF_UP));
+			}
+			resultList.add(connectorInfo);
+		}
+		return resultList;
+	}
+
 	@Override
 	public List<ZDLEquipmentInfo> getPileListForZDL(String stationId) {
 		List<ZDLEquipmentInfo> resultList = new ArrayList<>();
--- a/jsowell-pile/src/main/java/com/jsowell/pile/thirdparty/PileDetailInfoVO.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/thirdparty/PileDetailInfoVO.java
@@ -0,0 +1,33 @@
+package com.jsowell.pile.thirdparty;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * 第三方平台桩信息VO
+ *
+ * @author Lemon
+ * @Date 2024/12/19 14:41:52
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class PileDetailInfoVO {
+
+    private String pileSn;
+
+    private Date createTime;
+
+    private String speedType;
+    private String modelName;
+    private String ratedPower;
+    private String ratedVoltage;
+    private String ratedCurrent;
+    private String connectorNum;
+    private String pileStatus;
+}