You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
461 lines
16 KiB
461 lines
16 KiB
using Entity.Constant;
|
|
using Entity.DbModel.Station;
|
|
using HybirdFrameworkCore.Autofac;
|
|
using log4net;
|
|
using Newtonsoft.Json;
|
|
using Repository.Station;
|
|
using Service.Cloud.Client;
|
|
using Service.Cloud.Msg.Cloud.Req;
|
|
using Service.Cloud.Msg.Cloud.Resp;
|
|
using Service.Cloud.Msg.Host.Req;
|
|
using Service.Cloud.Msg.Host.Req.OutCharger;
|
|
using Service.Execute.Model;
|
|
using Service.Execute.Model.Tbox;
|
|
using Service.Init;
|
|
using System.Security.Cryptography;
|
|
|
|
namespace Service.Execute.Api;
|
|
|
|
public abstract class CloudApi
|
|
{
|
|
private const int TimeSpan = 10;
|
|
|
|
private static readonly ILog Log = LogManager.GetLogger("CloudApi");
|
|
|
|
/// <summary>
|
|
/// 云平台车辆认证
|
|
/// </summary>
|
|
/// <param name="rfidReadModel"></param>
|
|
/// <returns></returns>
|
|
public static CarAuthRes? VehicleCheck(RfidReadModel rfidReadModel, SwapOrder swapOrder)
|
|
|
|
{
|
|
CarAuth carAuth = new()
|
|
{
|
|
ty = 2,
|
|
rfid = rfidReadModel.VelVin,
|
|
cn = rfidReadModel.VelNo,
|
|
vi = rfidReadModel.VelVin,
|
|
// mac = rfidReadModel.VelMac,
|
|
en = 0,
|
|
dt = swapOrder.VehicleEnterTime,
|
|
mode = 0,
|
|
};
|
|
|
|
Log.Info(
|
|
$" CloudApi VehicleCheck SendVehicleCertification param={JsonConvert.SerializeObject(carAuth)}");
|
|
CarAuthRes? sendVehicleCertification =
|
|
CloudClientMgr.CloudClient?.SendVehicleCertification(carAuth,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
|
|
Log.Info(
|
|
$" CloudApi VehicleCheck SendVehicleCertification resp={JsonConvert.SerializeObject(sendVehicleCertification)}");
|
|
|
|
|
|
return sendVehicleCertification;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 上报换电订单
|
|
/// </summary>
|
|
/// <param name="rfidReadModel"></param>
|
|
/// <param name="swapOrder"></param>
|
|
/// <returns></returns>
|
|
public static int UploadSwapOrder(SwapOrder swapOrder, int seq, SwapOrderBattery swapOrderBattery, int uploadType
|
|
,SwapOrderReportCloud orderReportCloud)
|
|
|
|
{
|
|
StaSwapRecord staSwapRecord = new()
|
|
{
|
|
rfid = swapOrder.VehicleVin,
|
|
sn = StaticStationInfo.StationNo,
|
|
son = swapOrder.CloudSn,
|
|
cn = swapOrder.VehicleNo,
|
|
so = seq,
|
|
ct = swapOrder.VehicleEnterTime,
|
|
st = swapOrder.SwapBeginTime,
|
|
dbid = swapOrderBattery.UpBatteryNo,
|
|
deno = swapOrderBattery.UpBatteryBinNo,
|
|
dsoc = swapOrderBattery.UpBatterySoc.ToInt(),
|
|
//dsoe = swapOrderBattery.UpBatterySoe.ToInt(),
|
|
et = swapOrder.SwapEndTime,
|
|
od = 0,
|
|
ot = swapOrder.VehicleLeaveTime,
|
|
rs = 0,
|
|
sflx = 0,
|
|
sfs = uploadType,
|
|
ubid = swapOrderBattery.DownBatteryNo,
|
|
ueno = swapOrderBattery.DownBatteryBinNo,
|
|
usoc = swapOrderBattery.DownBatterySoc.ToInt(),
|
|
// usoe = swapOrderBattery.DownBatterySoe.ToInt(),
|
|
vin = swapOrder.VehicleVin,
|
|
wt = new TimeSpan((swapOrder.SwapEndTime.ToDateTime().Ticks - swapOrder.SwapBeginTime.ToDateTime().Ticks))
|
|
.TotalSeconds.ToInt(),
|
|
vtm=orderReportCloud.Vtm,
|
|
};
|
|
Log.Info(
|
|
$" CloudApi UploadSwapOrder seq={seq} SendUploadPowerChangeOrder param={JsonConvert.SerializeObject(staSwapRecord)}");
|
|
|
|
StaSwapRecordRes? sendUploadPowerChangeOrder = CloudClientMgr.CloudClient?.SendUploadPowerChangeOrder(
|
|
staSwapRecord,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
Log.Info(
|
|
$" CloudApi UploadSwapOrder seq={seq} SendUploadPowerChangeOrder resp={JsonConvert.SerializeObject(sendUploadPowerChangeOrder)}");
|
|
|
|
if (sendUploadPowerChangeOrder == null)
|
|
{
|
|
return -1;
|
|
}
|
|
|
|
return sendUploadPowerChangeOrder.re;
|
|
}
|
|
|
|
|
|
public static InfoEnum.BusinessSwappingForCloudState BusinessSwappingForCloudState =
|
|
InfoEnum.BusinessSwappingForCloudState.Idle;
|
|
/// <summary>
|
|
/// 上报换电步序到云端
|
|
/// </summary>
|
|
public static void SendStateLog( )
|
|
{
|
|
if (BusinessSwappingForCloudState!= StationSoftMgr.SwappingStateMachine.BusinessSwappingForCloudState)
|
|
{
|
|
StationChnRunStatus stationChnRunStatus = null;
|
|
|
|
|
|
if (StationSoftMgr.SwappingStateMachine.BusinessSwappingForCloudState != InfoEnum.BusinessSwappingForCloudState.Idle||
|
|
StationSoftMgr.SwappingStateMachine.BusinessSwappingForCloudState != InfoEnum.BusinessSwappingForCloudState.UnKnown)
|
|
{
|
|
stationChnRunStatus = new()
|
|
{
|
|
ec = 0,
|
|
ws = StationSoftMgr.SwappingStateMachine.SwapStatus == 0 ? 2 : 3,
|
|
cs = (int)StationSoftMgr.SwappingStateMachine.BusinessSwappingForCloudState,
|
|
iv = StationSoftMgr.SwappingStateMachine.RadarInFlag == true ? 1 : 2,
|
|
ls = StationSoftMgr.SwappingStateMachine.VelUnlockFlag == true ? 2 : 1,
|
|
fl = Convert.ToInt32(StaticStationInfo.Faultlevel),
|
|
ut = DateTime.Now,
|
|
|
|
};
|
|
}
|
|
else//空闲
|
|
{
|
|
|
|
stationChnRunStatus = new()
|
|
{
|
|
ec = 0,
|
|
ws = 1,
|
|
cs = 1,
|
|
iv = 2,
|
|
ls = 0,
|
|
fl = Convert.ToInt32(StaticStationInfo.Faultlevel),
|
|
ut = DateTime.Now,
|
|
|
|
};
|
|
}
|
|
|
|
CloudClientMgr.CloudClient?.SendChannelStatusReporting(stationChnRunStatus,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
|
|
for (int i = 0; i < 3; i++)
|
|
{
|
|
|
|
}
|
|
|
|
}
|
|
BusinessSwappingForCloudState = StationSoftMgr.SwappingStateMachine.BusinessSwappingForCloudState;
|
|
return;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 上报车辆数据
|
|
/// </summary>
|
|
public static void UploadTBoxCarInfo(SwapOrder swapOrder, TboxCarInfoModel model)
|
|
{
|
|
return;
|
|
}
|
|
/// <summary>
|
|
/// 换电车辆数据上报
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendVehicleDataReporting(SwappingStateMachine machine,int vet)
|
|
{
|
|
var carInfoBatteryInfos = machine.BoxCarInfoModel?.CarInfo?.BatteryInfos;
|
|
CardataReport cardataReport = new()
|
|
{
|
|
on = machine.SwapOrder.Sn,
|
|
ct = DateTime.Now,
|
|
cn = machine.SwapOrder.VehicleNo,
|
|
rfid = "",
|
|
Vi = machine.SwapOrder.VehicleVin,
|
|
mc = "",
|
|
bn = carInfoBatteryInfos.Count > 0 ? carInfoBatteryInfos[0].BatteryNo : "",
|
|
ec = 0,
|
|
soc = carInfoBatteryInfos.Count > 0 ? Convert.ToSingle(carInfoBatteryInfos[0].Soc) : 0,
|
|
bskm = Convert.ToSingle(machine.BoxCarInfoModel?.ElecMsg?.SubMile),
|
|
btkm = Convert.ToSingle(machine.BoxCarInfoModel?.ElecMsg?.TotalMile),
|
|
soh = carInfoBatteryInfos.Count > 0 ? Convert.ToSingle(carInfoBatteryInfos[0].Soh) : 0,
|
|
soe = carInfoBatteryInfos.Count > 0 ? Convert.ToSingle(carInfoBatteryInfos[0].Soe) : 0,
|
|
vtm = Convert.ToSingle(machine.BoxCarInfoModel?.ElecMsg?.TotalMile),
|
|
vet = vet,
|
|
vtdc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.AccDischargeCount),
|
|
vtfe = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.AccFallbackCount),
|
|
vtcc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.AccChargeCount),
|
|
vtec = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.AccKgce),
|
|
rtdc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.ThisTimeRealDischarge),
|
|
lsdc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.LastTimeBalanceDischarge),
|
|
rtfc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.ThisTimeRealFeedbackPower),
|
|
lsfc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.LastTimeBalanceFeedbackPower),
|
|
rtcc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.ThisTimeRealChargeCount),
|
|
lscc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.LastTimeBalanceChargeCount),
|
|
rtec = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.ThisTimeRealKgce),
|
|
ltfc = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.LastTimeBalanceKgce),
|
|
wsec = Convert.ToInt32(machine.BoxCarInfoModel?.ElecMsg?.ElectricityToBeSettled),
|
|
};
|
|
//CloudClientMgr.CloudClient?.SendVehicleDataReporting(cardataReport,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
|
|
}
|
|
/// <summary>
|
|
/// 云平台下发换电指令
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public static CarCanStart CarCanStart()
|
|
{
|
|
Log.Info(
|
|
$" CloudApi CarCanStart ");
|
|
var cloudClientCarCanStart = CloudClientMgr.CloudClient.CarCanStart;
|
|
Log.Info(
|
|
$" CloudApi CarCanStart resp= {JsonConvert.SerializeObject(cloudClientCarCanStart)}");
|
|
return cloudClientCarCanStart;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 清除下发的换电指令
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public static bool ClearCarCanStartInfo()
|
|
{
|
|
CloudClientMgr.CloudClient.CarCanStart = null;
|
|
return true;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 9.2.1.3 站控上报充电枪充电结束事件
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendPileEndCharge(PileEndCharge req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendPileEndCharge(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
/// <summary>
|
|
/// 9.2.1.7 站控上报充电枪充电遥测数据
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendPileChargeRealtime(PileChargeRealtime req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendPileChargeRealtime(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
/// <summary>
|
|
/// 9.2.1.5 站控上报充电枪实时数据上报
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendPileRealtime(PileRealtime req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendPileRealtime(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
/// <summary>
|
|
/// 换电站状态上报
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendHostStatusReported(StationRunStatus req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendHostStatusReported(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
/// <summary>
|
|
/// 空调信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendAirConditioningData(AcDataInfo req)
|
|
{
|
|
|
|
CloudClientMgr.CloudClient?.SendAirConditioningData(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 换电站温湿度数据信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendEvmDataInfo(EvmDataInfo req)
|
|
{
|
|
|
|
CloudClientMgr.CloudClient?.SendEvmDataInfo(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 电能表累计值信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendPowerTotal(PowerTotal req)
|
|
{
|
|
|
|
CloudClientMgr.CloudClient?.SendPowerTotal(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 换电站电能表变化值信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendStaChargingTotal(StaChargingTotal req)
|
|
{
|
|
|
|
CloudClientMgr.CloudClient?.SendStaChargingTotal(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 换电站分时用电统计信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendStaHourEnergyVal(StaHourEnergyVal req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendStaHourEnergyVal(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 电能表小时能耗值信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendMeterEnergyKwh(MeterEnergyKwh req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendMeterEnergyKwh(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 电能表每天能耗值信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendMeterDayEnergyVal(MeterDayEnergyVal req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendMeterDayEnergyVal(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 换电站每天用电统计信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendStaDayEnergyVal(StaDayEnergyVal req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendStaDayEnergyVal(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 换电站日运行统计结果信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendStaDayOpeEnergyVal(StaDayOpeEnergyVal req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendStaDayOpeEnergyVal(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 换电站分时用电计费信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendStaHourAmountVal(StaHourAmountVal req)
|
|
{
|
|
CloudClientMgr.CloudClient?.SendStaHourAmountVal(req,
|
|
global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
//TODO 未调试，先注释上传
|
|
|
|
/// <summary>
|
|
/// 换电站进行签到认证
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendSignIn()
|
|
{
|
|
SignIn signIn = new()
|
|
{
|
|
sn = StaticStationInfo.StationNo,
|
|
ky = StaticStationInfo.StationSn,
|
|
st = "02",
|
|
dv = "",
|
|
sv = StaticStationInfo.StationSftVer,
|
|
ss = StaticStationInfo.Sevstatus,
|
|
ca = Convert.ToSingle(StaticStationInfo.DistributionCapacity),
|
|
|
|
VS = "1.0",
|
|
cp = Convert.ToInt32(StaticStationInfo.TotalPower),
|
|
bs= StaticStationInfo.StationVersion,
|
|
lo= StaticStationInfo.Longitude,
|
|
la= StaticStationInfo.Latitude,
|
|
en=1,
|
|
cn=7,
|
|
eid= Convert.ToInt32(StaticStationInfo.Ceid),
|
|
oid = Convert.ToInt32(StaticStationInfo.Oid),
|
|
|
|
|
|
};
|
|
//CloudClientMgr.CloudClient?.SendSignIn(signIn,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
/// <summary>
|
|
/// 换电站上报设备列表
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendDevList(DevList req)
|
|
{
|
|
// CloudClientMgr.CloudClient?.SendReportingDeviceList(req,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 实时故障上报
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendRealTimeFaultInfo(FaultReport req)
|
|
{
|
|
//CloudClientMgr.CloudClient?.SendRealTimeFaultInfo(req,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
/// <summary>
|
|
/// 换电站设备状态开始日志信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendStartLogMessage(EqmStateStartLogInfo req)
|
|
{
|
|
// CloudClientMgr.CloudClient?.SendStartLogMessage(req,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
/// <summary>
|
|
/// 换电站设备状态结束日志信息
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
public static void SendEndLogMessage(EqmStateEndLogInfo req)
|
|
{
|
|
//CloudClientMgr.CloudClient?.SendEndLogMessage(req,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
public static void SendBatteryTotal(BatteryTotal req)
|
|
{
|
|
// CloudClientMgr.CloudClient?.SendBatteryTotal(req,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
|
|
public static void SendChargingTotalDis(ChargingTotalDis req)
|
|
{
|
|
// CloudClientMgr.CloudClient?.SendChargingTotalDis(req,
|
|
// global::System.TimeSpan.FromSeconds(TimeSpan));
|
|
}
|
|
} |