From 947e406dbf47e3004f90ffbc8d4bebfbe5ce151c Mon Sep 17 00:00:00 2001 From: ZZ Date: Fri, 23 Jul 2021 14:29:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=85=E7=94=B5=E6=A1=A9=E5=8D=8F=E8=AE=AE?= =?UTF-8?q?=E6=95=B0=E6=8D=AE:=20all=20left?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pilemsg/BalanceUpdateReplyData.java | 39 ++ .../xhpc/common/pilemsg/BmsChargingData.java | 171 +++++++++ .../com/xhpc/common/pilemsg/BmsErrorData.java | 281 ++++++++++++++ .../xhpc/common/pilemsg/BmsInterruptData.java | 72 ++++ .../pilemsg/BmsReqChargerOutputData.java | 160 ++++++++ .../common/pilemsg/ChargerInterruptData.java | 72 ++++ .../pilemsg/OfflineCardSyncReplyData.java | 39 ++ .../com/xhpc/common/pilemsg/OrderData.java | 347 ++++++++++++++++++ .../common/pilemsg/PileConfigReplyData.java | 28 ++ .../pilemsg/PileRateModelConfigReplyData.java | 28 ++ .../common/pilemsg/PileStartChargingData.java | 83 +++++ .../pilemsg/PileTimeConfigReplyData.java | 28 ++ .../common/pilemsg/RemoteStartReplyData.java | 61 +++ .../common/pilemsg/RemoteStopReplyData.java | 50 +++ .../service/BalanceUpdateReplyDataLogic.java | 31 ++ .../xhpc/pp/service/BmsChargingDataLogic.java | 40 ++ .../xhpc/pp/service/BmsErrorDataLogic.java | 40 ++ .../pp/service/BmsInterruptDataLogic.java | 36 ++ .../service/BmsReqChargerOutputDataLogic.java | 40 ++ .../pp/service/ChargerInterruptDataLogic.java | 36 ++ .../OfflineCardEraseReplyDataLogic.java | 24 ++ .../OfflineCardInquiryReplyDataLogic.java | 24 ++ .../OfflineCardSyncReplyDataLogic.java | 31 ++ .../com/xhpc/pp/service/OrderDataLogic.java | 31 ++ .../pp/service/PileConfigReplyDataLogic.java | 31 ++ .../PileRateModelConfigReplyDataLogic.java | 31 ++ .../service/PileStartChargingDataLogic.java | 31 ++ .../service/PileTimeConfigReplyDataLogic.java | 31 ++ .../pp/service/RemoteStartReplyDataLogic.java | 31 ++ .../pp/service/RemoteStopReplyDataLogic.java | 31 ++ .../src/main/resources/svcmainlogic.xml | 16 + 31 files changed, 1994 insertions(+) create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BalanceUpdateReplyData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsChargingData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsErrorData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsInterruptData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsReqChargerOutputData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/ChargerInterruptData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OfflineCardSyncReplyData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OrderData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileConfigReplyData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileRateModelConfigReplyData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileStartChargingData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileTimeConfigReplyData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStartReplyData.java create mode 100644 xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStopReplyData.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BalanceUpdateReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsChargingDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsErrorDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsInterruptDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsReqChargerOutputDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/ChargerInterruptDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardEraseReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardInquiryReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardSyncReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OrderDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileConfigReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileRateModelConfigReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileStartChargingDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileTimeConfigReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStartReplyDataLogic.java create mode 100644 xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStopReplyDataLogic.java diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BalanceUpdateReplyData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BalanceUpdateReplyData.java new file mode 100644 index 00000000..82c0707e --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BalanceUpdateReplyData.java @@ -0,0 +1,39 @@ +package com.xhpc.common.pilemsg; + +public class BalanceUpdateReplyData extends BaseData { + + private String pileNo; //桩号 + private String cardNo; //物理卡号 + private String modifyResult; //修改结果 + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getCardNo() { + + return cardNo; + } + + public void setCardNo(String cardNo) { + + this.cardNo = cardNo; + } + + public String getModifyResult() { + + return modifyResult; + } + + public void setModifyResult(String modifyResult) { + + this.modifyResult = modifyResult; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsChargingData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsChargingData.java new file mode 100644 index 00000000..c569d31e --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsChargingData.java @@ -0,0 +1,171 @@ +package com.xhpc.common.pilemsg; + +public class BmsChargingData extends BaseData { + + private String orderNo; //交易流水号 + private String pileNo; //桩号 + private String gunId; //枪号 + private String maxMonoBatVoltId; //BMS 最高单体动力蓄电池电压所在编号 + private String maxBatTemperature; //BMS 最高动力蓄电池温度 + private String maxTempCheckPntId; //BMS 最高温度检测点编号 + private String miniBatTemperature; //最低动力蓄电池温度 + private String miniBatTempCheckPntId; //最低动力蓄电池温度检测点编号 + private String monoBatVoltExtreme; //BMS 单体动力蓄电池电压过高/过低 + private String vehicleBatSocExtreme; //BMS 整车动力蓄电池荷电状态SOC 过高/过低 + private String batChargeCurrentExtreme; //BMS 动力蓄电池充电过电流 + private String batTemperatureExtreme; //BMS 动力蓄电池温度过高 + private String batInsulation; //BMS 动力蓄电池绝缘状态 + private String batPackOutConnStatus; //BMS 动力蓄电池组输出连接器连接状态 + private String chargingForbidden; //充电禁止 + + public String getOrderNo() { + + return orderNo; + } + + public void setOrderNo(String orderNo) { + + this.orderNo = orderNo; + } + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getMaxMonoBatVoltId() { + + return maxMonoBatVoltId; + } + + public void setMaxMonoBatVoltId(String maxMonoBatVoltId) { + + this.maxMonoBatVoltId = maxMonoBatVoltId; + } + + public String getMaxBatTemperature() { + + return maxBatTemperature; + } + + public void setMaxBatTemperature(String maxBatTemperature) { + + this.maxBatTemperature = maxBatTemperature; + } + + public String getMaxTempCheckPntId() { + + return maxTempCheckPntId; + } + + public void setMaxTempCheckPntId(String maxTempCheckPntId) { + + this.maxTempCheckPntId = maxTempCheckPntId; + } + + public String getMiniBatTemperature() { + + return miniBatTemperature; + } + + public void setMiniBatTemperature(String miniBatTemperature) { + + this.miniBatTemperature = miniBatTemperature; + } + + public String getMiniBatTempCheckPntId() { + + return miniBatTempCheckPntId; + } + + public void setMiniBatTempCheckPntId(String miniBatTempCheckPntId) { + + this.miniBatTempCheckPntId = miniBatTempCheckPntId; + } + + public String getMonoBatVoltExtreme() { + + return monoBatVoltExtreme; + } + + public void setMonoBatVoltExtreme(String monoBatVoltExtreme) { + + this.monoBatVoltExtreme = monoBatVoltExtreme; + } + + public String getVehicleBatSocExtreme() { + + return vehicleBatSocExtreme; + } + + public void setVehicleBatSocExtreme(String vehicleBatSocExtreme) { + + this.vehicleBatSocExtreme = vehicleBatSocExtreme; + } + + public String getBatChargeCurrentExtreme() { + + return batChargeCurrentExtreme; + } + + public void setBatChargeCurrentExtreme(String batChargeCurrentExtreme) { + + this.batChargeCurrentExtreme = batChargeCurrentExtreme; + } + + public String getBatTemperatureExtreme() { + + return batTemperatureExtreme; + } + + public void setBatTemperatureExtreme(String batTemperatureExtreme) { + + this.batTemperatureExtreme = batTemperatureExtreme; + } + + public String getBatInsulation() { + + return batInsulation; + } + + public void setBatInsulation(String batInsulation) { + + this.batInsulation = batInsulation; + } + + public String getBatPackOutConnStatus() { + + return batPackOutConnStatus; + } + + public void setBatPackOutConnStatus(String batPackOutConnStatus) { + + this.batPackOutConnStatus = batPackOutConnStatus; + } + + public String getChargingForbidden() { + + return chargingForbidden; + } + + public void setChargingForbidden(String chargingForbidden) { + + this.chargingForbidden = chargingForbidden; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsErrorData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsErrorData.java new file mode 100644 index 00000000..c771410f --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsErrorData.java @@ -0,0 +1,281 @@ +package com.xhpc.common.pilemsg; + +public class BmsErrorData extends BaseData { + + private String orderNo; //交易流水号 + private String pileNo; //桩号 + private String gunId; //枪号 + private String SPN25600x00; //接收 SPN2560=0x00 的充电机辨识报文超时 <00>：=正常；<01>：=超时；<10>：=不可信状态 + private String SPN25600xAA; //接收 SPN2560=0xAA 的充电机辨识报文超时 + private String reserved; //预留位 + private String timeSyncAndMaxOutputMsgOt; //接收充电机的时间同步和充电机最大输出能力报文超时 + private String chargeCompleteMsgOt; //接收充电机完成充电准备报文超时 + private String reserved1; //预留位 + private String chargeStatusMsgOt; //接收充电机充电状态报文超时 + private String chargeStopMsgOt; //接收充电机中止充电报文超时 + private String reserved2; //预留位 + private String chargerSummaryMsgOt; //接收充电机充电统计报文超时 + private String bmsOther; //其他 + private String bmsAndVehicleIdentMsgOt; //接收 BMS 和车辆的辨识报文超时 + private String reserved3; //预留位 + private String batteryChargeParamMsgOt; //接收电池充电参数报文超时 + private String bmsChargingPreparedMsgOt; //接收 BMS 完成充电准备报文超时 + private String reserved4; //预留位 + private String batteryChargeStatusSummaryMsgOt; //接收电池充电总状态报文超时 + private String batteryChargingRequestMsgOt; //接收电池充电要求报文超时 + private String bmsStopMsgOt; //接收 BMS 中止充电报文超时 + private String reserved5; //预留位 + private String bmsChargingSummaryMsgOt; //接收 BMS 充电统计报文超时 + private String chargerOther; //充电机其他 + + public String getOrderNo() { + + return orderNo; + } + + public void setOrderNo(String orderNo) { + + this.orderNo = orderNo; + } + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getSPN25600x00() { + + return SPN25600x00; + } + + public void setSPN25600x00(String SPN25600x00) { + + this.SPN25600x00 = SPN25600x00; + } + + public String getSPN25600xAA() { + + return SPN25600xAA; + } + + public void setSPN25600xAA(String SPN25600xAA) { + + this.SPN25600xAA = SPN25600xAA; + } + + public String getReserved() { + + return reserved; + } + + public void setReserved(String reserved) { + + this.reserved = reserved; + } + + public String getTimeSyncAndMaxOutputMsgOt() { + + return timeSyncAndMaxOutputMsgOt; + } + + public void setTimeSyncAndMaxOutputMsgOt(String timeSyncAndMaxOutputMsgOt) { + + this.timeSyncAndMaxOutputMsgOt = timeSyncAndMaxOutputMsgOt; + } + + public String getChargeCompleteMsgOt() { + + return chargeCompleteMsgOt; + } + + public void setChargeCompleteMsgOt(String chargeCompleteMsgOt) { + + this.chargeCompleteMsgOt = chargeCompleteMsgOt; + } + + public String getReserved1() { + + return reserved1; + } + + public void setReserved1(String reserved1) { + + this.reserved1 = reserved1; + } + + public String getChargeStatusMsgOt() { + + return chargeStatusMsgOt; + } + + public void setChargeStatusMsgOt(String chargeStatusMsgOt) { + + this.chargeStatusMsgOt = chargeStatusMsgOt; + } + + public String getChargeStopMsgOt() { + + return chargeStopMsgOt; + } + + public void setChargeStopMsgOt(String chargeStopMsgOt) { + + this.chargeStopMsgOt = chargeStopMsgOt; + } + + public String getReserved2() { + + return reserved2; + } + + public void setReserved2(String reserved2) { + + this.reserved2 = reserved2; + } + + public String getChargerSummaryMsgOt() { + + return chargerSummaryMsgOt; + } + + public void setChargerSummaryMsgOt(String chargerSummaryMsgOt) { + + this.chargerSummaryMsgOt = chargerSummaryMsgOt; + } + + public String getBmsOther() { + + return bmsOther; + } + + public void setBmsOther(String bmsOther) { + + this.bmsOther = bmsOther; + } + + public String getBmsAndVehicleIdentMsgOt() { + + return bmsAndVehicleIdentMsgOt; + } + + public void setBmsAndVehicleIdentMsgOt(String bmsAndVehicleIdentMsgOt) { + + this.bmsAndVehicleIdentMsgOt = bmsAndVehicleIdentMsgOt; + } + + public String getReserved3() { + + return reserved3; + } + + public void setReserved3(String reserved3) { + + this.reserved3 = reserved3; + } + + public String getBatteryChargeParamMsgOt() { + + return batteryChargeParamMsgOt; + } + + public void setBatteryChargeParamMsgOt(String batteryChargeParamMsgOt) { + + this.batteryChargeParamMsgOt = batteryChargeParamMsgOt; + } + + public String getBmsChargingPreparedMsgOt() { + + return bmsChargingPreparedMsgOt; + } + + public void setBmsChargingPreparedMsgOt(String bmsChargingPreparedMsgOt) { + + this.bmsChargingPreparedMsgOt = bmsChargingPreparedMsgOt; + } + + public String getReserved4() { + + return reserved4; + } + + public void setReserved4(String reserved4) { + + this.reserved4 = reserved4; + } + + public String getBatteryChargeStatusSummaryMsgOt() { + + return batteryChargeStatusSummaryMsgOt; + } + + public void setBatteryChargeStatusSummaryMsgOt(String batteryChargeStatusSummaryMsgOt) { + + this.batteryChargeStatusSummaryMsgOt = batteryChargeStatusSummaryMsgOt; + } + + public String getBatteryChargingRequestMsgOt() { + + return batteryChargingRequestMsgOt; + } + + public void setBatteryChargingRequestMsgOt(String batteryChargingRequestMsgOt) { + + this.batteryChargingRequestMsgOt = batteryChargingRequestMsgOt; + } + + public String getBmsStopMsgOt() { + + return bmsStopMsgOt; + } + + public void setBmsStopMsgOt(String bmsStopMsgOt) { + + this.bmsStopMsgOt = bmsStopMsgOt; + } + + public String getReserved5() { + + return reserved5; + } + + public void setReserved5(String reserved5) { + + this.reserved5 = reserved5; + } + + public String getBmsChargingSummaryMsgOt() { + + return bmsChargingSummaryMsgOt; + } + + public void setBmsChargingSummaryMsgOt(String bmsChargingSummaryMsgOt) { + + this.bmsChargingSummaryMsgOt = bmsChargingSummaryMsgOt; + } + + public String getChargerOther() { + + return chargerOther; + } + + public void setChargerOther(String chargerOther) { + + this.chargerOther = chargerOther; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsInterruptData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsInterruptData.java new file mode 100644 index 00000000..d91badcd --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsInterruptData.java @@ -0,0 +1,72 @@ +package com.xhpc.common.pilemsg; + +public class BmsInterruptData extends BaseData { + + private String orderNo; //交易流水号 + private String pileNo; //桩号 + private String gunId; //枪号 + private String bmsStopReason; //BMS 中止充电原因 + private String bmsStopFaultReason; //BMS 中止充电故障原因 + private String bmsStopErrorReason; //BMS 中止充电错误原因 + + public String getOrderNo() { + + return orderNo; + } + + public void setOrderNo(String orderNo) { + + this.orderNo = orderNo; + } + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getBmsStopReason() { + + return bmsStopReason; + } + + public void setBmsStopReason(String bmsStopReason) { + + this.bmsStopReason = bmsStopReason; + } + + public String getBmsStopFaultReason() { + + return bmsStopFaultReason; + } + + public void setBmsStopFaultReason(String bmsStopFaultReason) { + + this.bmsStopFaultReason = bmsStopFaultReason; + } + + public String getBmsStopErrorReason() { + + return bmsStopErrorReason; + } + + public void setBmsStopErrorReason(String bmsStopErrorReason) { + + this.bmsStopErrorReason = bmsStopErrorReason; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsReqChargerOutputData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsReqChargerOutputData.java new file mode 100644 index 00000000..b88aac4a --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/BmsReqChargerOutputData.java @@ -0,0 +1,160 @@ +package com.xhpc.common.pilemsg; + +public class BmsReqChargerOutputData extends BaseData { + + private String orderNo; //交易流水号 + private String pileNo; //桩号 + private String gunId; //枪号 + private String bmsVoltageRequest; //BMS 电压需求 + private String bmsCurrentRequest; //BMS 电流需求 + private String bmsChargingMod; //BMS 充电模式 + private String bmsChargingVolt; //BMS 充电电压测量值 + private String bmsChargingCurrent; //BMS 充电电流测量值 + private String monoBatteryVoltGroupId; //BMS 最高单体动力蓄电池电压及组号 + private String soc; //BMS 当前荷电状态 SOC（ %） + private String bmsEstRemainingTime; //BMS 估算剩余充电时间 + private String pileVoltageOutput; //电桩电压输出值 + private String pileCurrentOutput; //电桩电流输出值 + private String chargingTimeSummary; //累计充电时间 + + public String getOrderNo() { + + return orderNo; + } + + public void setOrderNo(String orderNo) { + + this.orderNo = orderNo; + } + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getBmsVoltageRequest() { + + return bmsVoltageRequest; + } + + public void setBmsVoltageRequest(String bmsVoltageRequest) { + + this.bmsVoltageRequest = bmsVoltageRequest; + } + + public String getBmsCurrentRequest() { + + return bmsCurrentRequest; + } + + public void setBmsCurrentRequest(String bmsCurrentRequest) { + + this.bmsCurrentRequest = bmsCurrentRequest; + } + + public String getBmsChargingMod() { + + return bmsChargingMod; + } + + public void setBmsChargingMod(String bmsChargingMod) { + + this.bmsChargingMod = bmsChargingMod; + } + + public String getBmsChargingVolt() { + + return bmsChargingVolt; + } + + public void setBmsChargingVolt(String bmsChargingVolt) { + + this.bmsChargingVolt = bmsChargingVolt; + } + + public String getBmsChargingCurrent() { + + return bmsChargingCurrent; + } + + public void setBmsChargingCurrent(String bmsChargingCurrent) { + + this.bmsChargingCurrent = bmsChargingCurrent; + } + + public String getMonoBatteryVoltGroupId() { + + return monoBatteryVoltGroupId; + } + + public void setMonoBatteryVoltGroupId(String monoBatteryVoltGroupId) { + + this.monoBatteryVoltGroupId = monoBatteryVoltGroupId; + } + + public String getSoc() { + + return soc; + } + + public void setSoc(String soc) { + + this.soc = soc; + } + + public String getBmsEstRemainingTime() { + + return bmsEstRemainingTime; + } + + public void setBmsEstRemainingTime(String bmsEstRemainingTime) { + + this.bmsEstRemainingTime = bmsEstRemainingTime; + } + + public String getPileVoltageOutput() { + + return pileVoltageOutput; + } + + public void setPileVoltageOutput(String pileVoltageOutput) { + + this.pileVoltageOutput = pileVoltageOutput; + } + + public String getPileCurrentOutput() { + + return pileCurrentOutput; + } + + public void setPileCurrentOutput(String pileCurrentOutput) { + + this.pileCurrentOutput = pileCurrentOutput; + } + + public String getChargingTimeSummary() { + + return chargingTimeSummary; + } + + public void setChargingTimeSummary(String chargingTimeSummary) { + + this.chargingTimeSummary = chargingTimeSummary; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/ChargerInterruptData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/ChargerInterruptData.java new file mode 100644 index 00000000..2bbd6e96 --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/ChargerInterruptData.java @@ -0,0 +1,72 @@ +package com.xhpc.common.pilemsg; + +public class ChargerInterruptData extends BaseData { + + private String orderNo; //交易流水号 + private String pileNo; //桩号 + private String gunId; //枪号 + private String chargerStopReason; //充电机 中止充电原因 + private String chargerStopFaultReason; //充电机 中止充电故障原因 + private String chargerStopErrorReason; //充电机 中止充电错误原因 + + public String getOrderNo() { + + return orderNo; + } + + public void setOrderNo(String orderNo) { + + this.orderNo = orderNo; + } + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getChargerStopReason() { + + return chargerStopReason; + } + + public void setChargerStopReason(String chargerStopReason) { + + this.chargerStopReason = chargerStopReason; + } + + public String getChargerStopFaultReason() { + + return chargerStopFaultReason; + } + + public void setChargerStopFaultReason(String chargerStopFaultReason) { + + this.chargerStopFaultReason = chargerStopFaultReason; + } + + public String getChargerStopErrorReason() { + + return chargerStopErrorReason; + } + + public void setChargerStopErrorReason(String chargerStopErrorReason) { + + this.chargerStopErrorReason = chargerStopErrorReason; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OfflineCardSyncReplyData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OfflineCardSyncReplyData.java new file mode 100644 index 00000000..34c90b3a --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OfflineCardSyncReplyData.java @@ -0,0 +1,39 @@ +package com.xhpc.common.pilemsg; + +public class OfflineCardSyncReplyData extends BaseData { + + private String pileNo; //桩号 + private String writeResult; //保存结果 + private String failResult; //失败原因 + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getWriteResult() { + + return writeResult; + } + + public void setWriteResult(String writeResult) { + + this.writeResult = writeResult; + } + + public String getFailResult() { + + return failResult; + } + + public void setFailResult(String failResult) { + + this.failResult = failResult; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OrderData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OrderData.java new file mode 100644 index 00000000..cdaa03bd --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/OrderData.java @@ -0,0 +1,347 @@ +package com.xhpc.common.pilemsg; + +public class OrderData extends BaseData { + + private String orderNo; //交易流水号 + private String pileNo; //桩号 + private String gunId; //枪号 + private String startTime; //开始时间CP56Time2a格式 + private String endTime; //结束时间CP56Time2a格式 + private String t1Price; //尖单价 + private String t1PowerQuantity; //尖电量 + private String t1LossQuantity; //计损尖电量 + private String t1Cost; //尖金额 + private String t2Price; //峰单价 + private String t2PowerQuantity; //峰电量 + private String t2LossQuantity; //计损峰电量 + private String t2Cost; //峰金额 + private String t3Price; //平单价 + private String t3PowerQuantity; //平电量 + private String t3LossQuantity; //计损平电量 + private String t3Cost; //平金额 + private String t4Price; //谷单价 + private String t4PowerQuantity; //谷电量 + private String t4LossQuantity; //计损谷电量 + private String t4Cost; //谷金额 + private String electricMeterStart; //电表总起值 + private String electricMeterEnd; //电表总止值 + private String totalPowerQuantity; //总电量 + private String totalLossPowerQuantity; //计损总电量 + private String cost; //消费金额 + private String vinNormal; //VIN 码，此处 VIN 码和充电时 VIN码不同，正序直接上传，无需补0和反序 + private String transactionFlag; //交易标识 + private String transactionDatetime; //交易日期、时间CP56Time2a格式 + private String stopReason; //停止原因 + private String cardNo; //物理卡号 + + public String getOrderNo() { + + return orderNo; + } + + public void setOrderNo(String orderNo) { + + this.orderNo = orderNo; + } + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getStartTime() { + + return startTime; + } + + public void setStartTime(String startTime) { + + this.startTime = startTime; + } + + public String getEndTime() { + + return endTime; + } + + public void setEndTime(String endTime) { + + this.endTime = endTime; + } + + public String getT1Price() { + + return t1Price; + } + + public void setT1Price(String t1Price) { + + this.t1Price = t1Price; + } + + public String getT1PowerQuantity() { + + return t1PowerQuantity; + } + + public void setT1PowerQuantity(String t1PowerQuantity) { + + this.t1PowerQuantity = t1PowerQuantity; + } + + public String getT1LossQuantity() { + + return t1LossQuantity; + } + + public void setT1LossQuantity(String t1LossQuantity) { + + this.t1LossQuantity = t1LossQuantity; + } + + public String getT1Cost() { + + return t1Cost; + } + + public void setT1Cost(String t1Cost) { + + this.t1Cost = t1Cost; + } + + public String getT2Price() { + + return t2Price; + } + + public void setT2Price(String t2Price) { + + this.t2Price = t2Price; + } + + public String getT2PowerQuantity() { + + return t2PowerQuantity; + } + + public void setT2PowerQuantity(String t2PowerQuantity) { + + this.t2PowerQuantity = t2PowerQuantity; + } + + public String getT2LossQuantity() { + + return t2LossQuantity; + } + + public void setT2LossQuantity(String t2LossQuantity) { + + this.t2LossQuantity = t2LossQuantity; + } + + public String getT2Cost() { + + return t2Cost; + } + + public void setT2Cost(String t2Cost) { + + this.t2Cost = t2Cost; + } + + public String getT3Price() { + + return t3Price; + } + + public void setT3Price(String t3Price) { + + this.t3Price = t3Price; + } + + public String getT3PowerQuantity() { + + return t3PowerQuantity; + } + + public void setT3PowerQuantity(String t3PowerQuantity) { + + this.t3PowerQuantity = t3PowerQuantity; + } + + public String getT3LossQuantity() { + + return t3LossQuantity; + } + + public void setT3LossQuantity(String t3LossQuantity) { + + this.t3LossQuantity = t3LossQuantity; + } + + public String getT3Cost() { + + return t3Cost; + } + + public void setT3Cost(String t3Cost) { + + this.t3Cost = t3Cost; + } + + public String getT4Price() { + + return t4Price; + } + + public void setT4Price(String t4Price) { + + this.t4Price = t4Price; + } + + public String getT4PowerQuantity() { + + return t4PowerQuantity; + } + + public void setT4PowerQuantity(String t4PowerQuantity) { + + this.t4PowerQuantity = t4PowerQuantity; + } + + public String getT4LossQuantity() { + + return t4LossQuantity; + } + + public void setT4LossQuantity(String t4LossQuantity) { + + this.t4LossQuantity = t4LossQuantity; + } + + public String getT4Cost() { + + return t4Cost; + } + + public void setT4Cost(String t4Cost) { + + this.t4Cost = t4Cost; + } + + public String getElectricMeterStart() { + + return electricMeterStart; + } + + public void setElectricMeterStart(String electricMeterStart) { + + this.electricMeterStart = electricMeterStart; + } + + public String getElectricMeterEnd() { + + return electricMeterEnd; + } + + public void setElectricMeterEnd(String electricMeterEnd) { + + this.electricMeterEnd = electricMeterEnd; + } + + public String getTotalPowerQuantity() { + + return totalPowerQuantity; + } + + public void setTotalPowerQuantity(String totalPowerQuantity) { + + this.totalPowerQuantity = totalPowerQuantity; + } + + public String getTotalLossPowerQuantity() { + + return totalLossPowerQuantity; + } + + public void setTotalLossPowerQuantity(String totalLossPowerQuantity) { + + this.totalLossPowerQuantity = totalLossPowerQuantity; + } + + public String getCost() { + + return cost; + } + + public void setCost(String cost) { + + this.cost = cost; + } + + public String getVinNormal() { + + return vinNormal; + } + + public void setVinNormal(String vinNormal) { + + this.vinNormal = vinNormal; + } + + public String getTransactionFlag() { + + return transactionFlag; + } + + public void setTransactionFlag(String transactionFlag) { + + this.transactionFlag = transactionFlag; + } + + public String getTransactionDatetime() { + + return transactionDatetime; + } + + public void setTransactionDatetime(String transactionDatetime) { + + this.transactionDatetime = transactionDatetime; + } + + public String getStopReason() { + + return stopReason; + } + + public void setStopReason(String stopReason) { + + this.stopReason = stopReason; + } + + public String getCardNo() { + + return cardNo; + } + + public void setCardNo(String cardNo) { + + this.cardNo = cardNo; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileConfigReplyData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileConfigReplyData.java new file mode 100644 index 00000000..766409fc --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileConfigReplyData.java @@ -0,0 +1,28 @@ +package com.xhpc.common.pilemsg; + +public class PileConfigReplyData extends BaseData { + + private String pileNo; //桩号 + private String configResult; //设置结果 + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getConfigResult() { + + return configResult; + } + + public void setConfigResult(String configResult) { + + this.configResult = configResult; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileRateModelConfigReplyData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileRateModelConfigReplyData.java new file mode 100644 index 00000000..2544bdc1 --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileRateModelConfigReplyData.java @@ -0,0 +1,28 @@ +package com.xhpc.common.pilemsg; + +public class PileRateModelConfigReplyData extends BaseData { + + private String pileNo; //桩号 + private String configResult; //设置结果 + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getConfigResult() { + + return configResult; + } + + public void setConfigResult(String configResult) { + + this.configResult = configResult; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileStartChargingData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileStartChargingData.java new file mode 100644 index 00000000..94c7aeb7 --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileStartChargingData.java @@ -0,0 +1,83 @@ +package com.xhpc.common.pilemsg; + +public class PileStartChargingData extends BaseData { + + private String pileNo; //桩号 + private String gunId; //枪号 + private String startType; //启动方式 + private String passwordRequired; //是否需要密码 + private String accountOrCardNo; //账号或者物理卡号 + private String password; //密码 + private String vin; //VIN + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getStartType() { + + return startType; + } + + public void setStartType(String startType) { + + this.startType = startType; + } + + public String getPasswordRequired() { + + return passwordRequired; + } + + public void setPasswordRequired(String passwordRequired) { + + this.passwordRequired = passwordRequired; + } + + public String getAccountOrCardNo() { + + return accountOrCardNo; + } + + public void setAccountOrCardNo(String accountOrCardNo) { + + this.accountOrCardNo = accountOrCardNo; + } + + public String getPassword() { + + return password; + } + + public void setPassword(String password) { + + this.password = password; + } + + public String getVin() { + + return vin; + } + + public void setVin(String vin) { + + this.vin = vin; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileTimeConfigReplyData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileTimeConfigReplyData.java new file mode 100644 index 00000000..3a978ba6 --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/PileTimeConfigReplyData.java @@ -0,0 +1,28 @@ +package com.xhpc.common.pilemsg; + +public class PileTimeConfigReplyData extends BaseData { + + private String pileNo; //桩号 + private String setTime; //当前时间CP56Time2a格式 + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getSetTime() { + + return setTime; + } + + public void setSetTime(String setTime) { + + this.setTime = setTime; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStartReplyData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStartReplyData.java new file mode 100644 index 00000000..881e1925 --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStartReplyData.java @@ -0,0 +1,61 @@ +package com.xhpc.common.pilemsg; + +public class RemoteStartReplyData extends BaseData { + + private String orderNo; //交易流水号 + private String pileNo; //桩号 + private String gunId; //枪号 + private String startResult; //启动结果 + private String failReason; //失败原因 + + public String getOrderNo() { + + return orderNo; + } + + public void setOrderNo(String orderNo) { + + this.orderNo = orderNo; + } + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getStartResult() { + + return startResult; + } + + public void setStartResult(String startResult) { + + this.startResult = startResult; + } + + public String getFailReason() { + + return failReason; + } + + public void setFailReason(String failReason) { + + this.failReason = failReason; + } + +} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStopReplyData.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStopReplyData.java new file mode 100644 index 00000000..a97355cb --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/pilemsg/RemoteStopReplyData.java @@ -0,0 +1,50 @@ +package com.xhpc.common.pilemsg; + +public class RemoteStopReplyData extends BaseData { + + private String pileNo; //桩号 + private String gunId; //枪号 + private String stopResult; //停止结果 + private String failReason; //失败原因 + + public String getPileNo() { + + return pileNo; + } + + public void setPileNo(String pileNo) { + + this.pileNo = pileNo; + } + + public String getGunId() { + + return gunId; + } + + public void setGunId(String gunId) { + + this.gunId = gunId; + } + + public String getStopResult() { + + return stopResult; + } + + public void setStopResult(String stopResult) { + + this.stopResult = stopResult; + } + + public String getFailReason() { + + return failReason; + } + + public void setFailReason(String failReason) { + + this.failReason = failReason; + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BalanceUpdateReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BalanceUpdateReplyDataLogic.java new file mode 100644 index 00000000..1456a966 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BalanceUpdateReplyDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.BalanceUpdateReplyData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("BalanceUpdateReplyDataLogic") +public class BalanceUpdateReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(BalanceUpdateReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + BalanceUpdateReplyData balanceUpdateReplyData = objectMapper.convertValue(req, BalanceUpdateReplyData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsChargingDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsChargingDataLogic.java new file mode 100644 index 00000000..bab70c48 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsChargingDataLogic.java @@ -0,0 +1,40 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.BmsChargingData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +import static com.xhpc.pp.server.ChargingPileServer.REDIS; + +@Lazy +@Component("BmsChargingDataLogic") +public class BmsChargingDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(BmsChargingDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + BmsChargingData bmsChargingData = objectMapper.convertValue(req, BmsChargingData.class); + String orderNo = bmsChargingData.getOrderNo(); + Map cacheOrder = REDIS.getCacheMap(orderNo); + List bmsChargingDataList = (List) cacheOrder.getOrDefault("bmsChargings", new ArrayList<>()); + bmsChargingDataList.add(bmsChargingData); + cacheOrder.put("bmsChargings", bmsChargingDataList); + REDIS.setCacheMap(orderNo, cacheOrder); + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsErrorDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsErrorDataLogic.java new file mode 100644 index 00000000..4287090b --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsErrorDataLogic.java @@ -0,0 +1,40 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.BmsErrorData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +import static com.xhpc.pp.server.ChargingPileServer.REDIS; + +@Lazy +@Component("BmsErrorDataLogic") +public class BmsErrorDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(BmsErrorDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + BmsErrorData bmsErrorData = objectMapper.convertValue(req, BmsErrorData.class); + String orderNo = bmsErrorData.getOrderNo(); + Map cacheOrder = REDIS.getCacheMap(orderNo); + List bmsErrorDataList = (List) cacheOrder.getOrDefault("bmsErrors", new ArrayList<>()); + bmsErrorDataList.add(bmsErrorData); + cacheOrder.put("bmsErrors", bmsErrorDataList); + REDIS.setCacheMap(orderNo, cacheOrder); + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsInterruptDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsInterruptDataLogic.java new file mode 100644 index 00000000..b0c5ccbc --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsInterruptDataLogic.java @@ -0,0 +1,36 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.BmsInterruptData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +import static com.xhpc.pp.server.ChargingPileServer.REDIS; + +@Lazy +@Component("BmsInterruptDataLogic") +public class BmsInterruptDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(BmsInterruptDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + BmsInterruptData bmsInterruptData = objectMapper.convertValue(req, BmsInterruptData.class); + String orderNo = bmsInterruptData.getOrderNo(); + Map cacheOrder = REDIS.getCacheMap(orderNo); + cacheOrder.put("bmsInterrupt", bmsInterruptData); + REDIS.setCacheMap(orderNo, cacheOrder); + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsReqChargerOutputDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsReqChargerOutputDataLogic.java new file mode 100644 index 00000000..616f1eee --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/BmsReqChargerOutputDataLogic.java @@ -0,0 +1,40 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.BmsReqChargerOutputData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +import static com.xhpc.pp.server.ChargingPileServer.REDIS; + +@Lazy +@Component("BmsReqChargerOutputDataLogic") +public class BmsReqChargerOutputDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(BmsReqChargerOutputDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + BmsReqChargerOutputData bmsReqChargerOutputData = objectMapper.convertValue(req, BmsReqChargerOutputData.class); + String orderNo = bmsReqChargerOutputData.getOrderNo(); + Map cacheOrder = REDIS.getCacheMap(orderNo); + List bmsReqChargerOutputDataList = (List) cacheOrder.getOrDefault("bmsErrors", new ArrayList<>()); + bmsReqChargerOutputDataList.add(bmsReqChargerOutputData); + cacheOrder.put("bmsReqChargerOutputs", bmsReqChargerOutputDataList); + REDIS.setCacheMap(orderNo, cacheOrder); + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/ChargerInterruptDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/ChargerInterruptDataLogic.java new file mode 100644 index 00000000..47268916 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/ChargerInterruptDataLogic.java @@ -0,0 +1,36 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.ChargerInterruptData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +import static com.xhpc.pp.server.ChargingPileServer.REDIS; + +@Lazy +@Component("ChargerInterruptDataLogic") +public class ChargerInterruptDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(ChargerInterruptDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + ChargerInterruptData chargerInterruptData = objectMapper.convertValue(req, ChargerInterruptData.class); + String orderNo = chargerInterruptData.getOrderNo(); + Map cacheOrder = REDIS.getCacheMap(orderNo); + cacheOrder.put("chargerInterrupt", chargerInterruptData); + REDIS.setCacheMap(orderNo, cacheOrder); + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardEraseReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardEraseReplyDataLogic.java new file mode 100644 index 00000000..393c02f5 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardEraseReplyDataLogic.java @@ -0,0 +1,24 @@ +package com.xhpc.pp.service; + +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +@Lazy +@Component("OfflineCardEraseReplyDataLogic") +public class OfflineCardEraseReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(OfflineCardEraseReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardInquiryReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardInquiryReplyDataLogic.java new file mode 100644 index 00000000..877660f4 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardInquiryReplyDataLogic.java @@ -0,0 +1,24 @@ +package com.xhpc.pp.service; + +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +@Lazy +@Component("OfflineCardInquiryReplyDataLogic") +public class OfflineCardInquiryReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(OfflineCardInquiryReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardSyncReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardSyncReplyDataLogic.java new file mode 100644 index 00000000..9aa24f2f --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OfflineCardSyncReplyDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.OfflineCardSyncReplyData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("OfflineCardSyncReplyDataLogic") +public class OfflineCardSyncReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(OfflineCardSyncReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + OfflineCardSyncReplyData offlineCardSyncReplyData = objectMapper.convertValue(req, OfflineCardSyncReplyData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OrderDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OrderDataLogic.java new file mode 100644 index 00000000..8b0a51a5 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/OrderDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.OrderData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("OrderDataLogic") +public class OrderDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(OrderDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + OrderData orderData = objectMapper.convertValue(req, OrderData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileConfigReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileConfigReplyDataLogic.java new file mode 100644 index 00000000..851a221d --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileConfigReplyDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.PileConfigReplyData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("PileConfigReplyDataLogic") +public class PileConfigReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(PileConfigReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + PileConfigReplyData pileConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileRateModelConfigReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileRateModelConfigReplyDataLogic.java new file mode 100644 index 00000000..3523bf60 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileRateModelConfigReplyDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.PileRateModelConfigReplyData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("PileRateModelConfigReplyDataLogic") +public class PileRateModelConfigReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(PileRateModelConfigReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + PileRateModelConfigReplyData pileRateModelConfigReplyData = objectMapper.convertValue(req, PileRateModelConfigReplyData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileStartChargingDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileStartChargingDataLogic.java new file mode 100644 index 00000000..d01ce898 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileStartChargingDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.PileStartChargingData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("PileStartChargingDataLogic") +public class PileStartChargingDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(PileStartChargingDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + PileStartChargingData pileStartChargingData = objectMapper.convertValue(req, PileStartChargingData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileTimeConfigReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileTimeConfigReplyDataLogic.java new file mode 100644 index 00000000..afc128cc --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/PileTimeConfigReplyDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.PileConfigReplyData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("PileTimeConfigReplyDataLogic") +public class PileTimeConfigReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(PileTimeConfigReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + PileConfigReplyData pileConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStartReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStartReplyDataLogic.java new file mode 100644 index 00000000..4a78a6e5 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStartReplyDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.PileStartChargingData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("RemoteStartReplyDataLogic") +public class RemoteStartReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(RemoteStartReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + PileStartChargingData pileStartChargingData = objectMapper.convertValue(req, PileStartChargingData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStopReplyDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStopReplyDataLogic.java new file mode 100644 index 00000000..b8425bf6 --- /dev/null +++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/service/RemoteStopReplyDataLogic.java @@ -0,0 +1,31 @@ +package com.xhpc.pp.service; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.xhpc.common.pilemsg.RemoteStopReplyData; +import com.xhpc.pp.tx.ServiceParameter; +import com.xhpc.pp.tx.ServiceResult; +import com.xhpc.pp.tx.logic.ServiceLogic; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Lazy +@Component("RemoteStopReplyDataLogic") +public class RemoteStopReplyDataLogic implements ServiceLogic { + + private static Logger log = LoggerFactory.getLogger(RemoteStopReplyDataLogic.class); + + @Override + public ServiceResult service(ServiceParameter sp) throws Exception { + + Map req = sp.getParameters(); + ObjectMapper objectMapper = new ObjectMapper(); + RemoteStopReplyData remoteStopReplyData = objectMapper.convertValue(req, RemoteStopReplyData.class); + //todo + return new ServiceResult(false); + } + +} diff --git a/xhpc-modules/xhpc-power-pile/src/main/resources/svcmainlogic.xml b/xhpc-modules/xhpc-power-pile/src/main/resources/svcmainlogic.xml index e16a06f0..41ac0e99 100644 --- a/xhpc-modules/xhpc-power-pile/src/main/resources/svcmainlogic.xml +++ b/xhpc-modules/xhpc-power-pile/src/main/resources/svcmainlogic.xml @@ -16,5 +16,21 @@ + + + + + + + + + + + + + + + +