充电桩协议数据: all left

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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;
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        BalanceUpdateReplyData balanceUpdateReplyData = objectMapper.convertValue(req, BalanceUpdateReplyData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        BmsChargingData bmsChargingData = objectMapper.convertValue(req, BmsChargingData.class);
+        String orderNo = bmsChargingData.getOrderNo();
+        Map<String, Object> cacheOrder = REDIS.getCacheMap(orderNo);
+        List<BmsChargingData> bmsChargingDataList = (List<BmsChargingData>) cacheOrder.getOrDefault("bmsChargings", new ArrayList<>());
+        bmsChargingDataList.add(bmsChargingData);
+        cacheOrder.put("bmsChargings", bmsChargingDataList);
+        REDIS.setCacheMap(orderNo, cacheOrder);
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        BmsErrorData bmsErrorData = objectMapper.convertValue(req, BmsErrorData.class);
+        String orderNo = bmsErrorData.getOrderNo();
+        Map<String, Object> cacheOrder = REDIS.getCacheMap(orderNo);
+        List<BmsErrorData> bmsErrorDataList = (List<BmsErrorData>) cacheOrder.getOrDefault("bmsErrors", new ArrayList<>());
+        bmsErrorDataList.add(bmsErrorData);
+        cacheOrder.put("bmsErrors", bmsErrorDataList);
+        REDIS.setCacheMap(orderNo, cacheOrder);
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        BmsInterruptData bmsInterruptData = objectMapper.convertValue(req, BmsInterruptData.class);
+        String orderNo = bmsInterruptData.getOrderNo();
+        Map<String, Object> cacheOrder = REDIS.getCacheMap(orderNo);
+        cacheOrder.put("bmsInterrupt", bmsInterruptData);
+        REDIS.setCacheMap(orderNo, cacheOrder);
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        BmsReqChargerOutputData bmsReqChargerOutputData = objectMapper.convertValue(req, BmsReqChargerOutputData.class);
+        String orderNo = bmsReqChargerOutputData.getOrderNo();
+        Map<String, Object> cacheOrder = REDIS.getCacheMap(orderNo);
+        List<BmsReqChargerOutputData> bmsReqChargerOutputDataList = (List<BmsReqChargerOutputData>) cacheOrder.getOrDefault("bmsErrors", new ArrayList<>());
+        bmsReqChargerOutputDataList.add(bmsReqChargerOutputData);
+        cacheOrder.put("bmsReqChargerOutputs", bmsReqChargerOutputDataList);
+        REDIS.setCacheMap(orderNo, cacheOrder);
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        ChargerInterruptData chargerInterruptData = objectMapper.convertValue(req, ChargerInterruptData.class);
+        String orderNo = chargerInterruptData.getOrderNo();
+        Map<String, Object> cacheOrder = REDIS.getCacheMap(orderNo);
+        cacheOrder.put("chargerInterrupt", chargerInterruptData);
+        REDIS.setCacheMap(orderNo, cacheOrder);
+        return new ServiceResult(false);
+    }
+
+}

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);
+    }
+
+}

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);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        OfflineCardSyncReplyData offlineCardSyncReplyData = objectMapper.convertValue(req, OfflineCardSyncReplyData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        OrderData orderData = objectMapper.convertValue(req, OrderData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        PileConfigReplyData pileConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        PileRateModelConfigReplyData pileRateModelConfigReplyData = objectMapper.convertValue(req, PileRateModelConfigReplyData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        PileStartChargingData pileStartChargingData = objectMapper.convertValue(req, PileStartChargingData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        PileConfigReplyData pileConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        PileStartChargingData pileStartChargingData = objectMapper.convertValue(req, PileStartChargingData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

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<String, Object> req = sp.getParameters();
+        ObjectMapper objectMapper = new ObjectMapper();
+        RemoteStopReplyData remoteStopReplyData = objectMapper.convertValue(req, RemoteStopReplyData.class);
+        //todo
+        return new ServiceResult(false);
+    }
+
+}

xhpc-modules/xhpc-power-pile/src/main/resources/svcmainlogic.xml

@@ -16,5 +16,21 @@
         <entry key="15" value-ref="ChargingHandshakeDataLogic"/>
         <entry key="17" value-ref="ChargingConfigDataLogic"/>
         <entry key="19" value-ref="ChargingCompletedDataLogic"/>
+        <entry key="1B" value-ref="BmsErrorDataLogic"/>
+        <entry key="1D" value-ref="BmsInterruptDataLogic"/>
+        <entry key="21" value-ref="ChargerInterruptDataLogic"/>
+        <entry key="23" value-ref="BmsReqChargerOutputDataLogic"/>
+        <entry key="25" value-ref="BmsChargingDataLogic"/>
+        <entry key="31" value-ref="PileStartChargingDataLogic"/>
+        <entry key="33" value-ref="RemoteStartReplyDataLogic"/>
+        <entry key="35" value-ref="RemoteStopReplyDataLogic"/>
+        <entry key="3B" value-ref="OrderDataLogic"/>
+        <entry key="41" value-ref="BalanceUpdateReplyDataLogic"/>
+        <entry key="43" value-ref="OfflineCardSyncReplyDataLogic"/>
+        <entry key="45" value-ref="OfflineCardEraseReplyDataLogic"/>
+        <entry key="47" value-ref="OfflineCardInquiryReplyDataLogic"/>
+        <entry key="51" value-ref="PileConfigReplyDataLogic"/>
+        <entry key="55" value-ref="PileTimeConfigReplyDataLogic"/>
+        <entry key="57" value-ref="PileRateModelConfigReplyDataLogic"/>
     </util:map>
 </beans>