|
|
using DotNetty.Transport.Channels;
|
|
|
using HybirdFrameworkCore.Autofac.Attribute;
|
|
|
using log4net;
|
|
|
using Service.Charger.Client;
|
|
|
using Service.Charger.Common;
|
|
|
using Service.Charger.Msg.Charger.Req;
|
|
|
using Service.Charger.Msg.Host.Resp;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Linq;
|
|
|
using System.Text;
|
|
|
using System.Threading.Tasks;
|
|
|
using Common.Const;
|
|
|
using Entity.DbModel.Station;
|
|
|
using Repository;
|
|
|
using Repository.Station;
|
|
|
|
|
|
namespace Service.Charger.Handler
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 遥信数据上报Handler
|
|
|
/// </summary>
|
|
|
//TODO::Order 应该是多少
|
|
|
[Order(8)]
|
|
|
[Scope("InstancePerDependency")]
|
|
|
public class UploadRemoteSignalDataHandler : SimpleChannelInboundHandler<UploadRemoteSignalData>, IBaseHandler
|
|
|
{
|
|
|
private static readonly ILog Log = LogManager.GetLogger(typeof(UploadRemoteSignalDataHandler));
|
|
|
private BinInfoRepository BinInfoRepository { get; set; }
|
|
|
private EquipAlarmRecordRepository EquipAlarmRecordRepository { get; set; }
|
|
|
private EquipAlarmProcessRecordRepository EquipAlarmProcessRecordRepository { get; set; }
|
|
|
private EquipAlarmDefineRepository EquipAlarmDefineRepository { get; set; }
|
|
|
public UploadRemoteSignalDataHandler(BinInfoRepository _binInfoRepository,
|
|
|
EquipAlarmRecordRepository _EquipAlarmRecordRepository,
|
|
|
EquipAlarmProcessRecordRepository _EquipAlarmProcessRecordRepository,
|
|
|
EquipAlarmDefineRepository _EquipAlarmDefineRepository)
|
|
|
{
|
|
|
BinInfoRepository = _binInfoRepository;
|
|
|
EquipAlarmRecordRepository = _EquipAlarmRecordRepository;
|
|
|
EquipAlarmProcessRecordRepository = _EquipAlarmProcessRecordRepository;
|
|
|
EquipAlarmDefineRepository = _EquipAlarmDefineRepository;
|
|
|
}
|
|
|
|
|
|
protected override void ChannelRead0(IChannelHandlerContext ctx, UploadRemoteSignalData msg)
|
|
|
{
|
|
|
if (ClientMgr.TryGetClient(ctx.Channel, out var sn, out var client))
|
|
|
{
|
|
|
//存储日志
|
|
|
Log.Info($"receive {msg} from {sn}");
|
|
|
|
|
|
client.Workstate = msg.WorkStatus;
|
|
|
client.IsCharged = msg.WorkStatus == 1 ? true : false;
|
|
|
client.TotalError = msg.TotalError;
|
|
|
client.TotalWarning = msg.TotalWarning;
|
|
|
client.UploadRemoteSignalData = msg;
|
|
|
|
|
|
//Desc:充电状态;0-未知；1-正在充电；2-无电池；3-禁用；4-充电完成
|
|
|
if (msg.WorkStatus == 1)
|
|
|
BinInfoRepository.Update(i => i.ChargeStatus == msg.WorkStatus, i => i.ChargerNo == sn);
|
|
|
else if (msg.WorkStatus == 2 || msg.WorkStatus == 0)
|
|
|
{
|
|
|
BinInfoRepository.Update(i => i.ChargeStatus == 4, i => i.ChargerNo == sn);
|
|
|
}
|
|
|
|
|
|
#region 充电机故障显示
|
|
|
//不准确，注释
|
|
|
//if(sn=="C2008")
|
|
|
//if (msg.TotalWarning||msg.TotalError)
|
|
|
{
|
|
|
var lstEquipAlarmDefine = EquipAlarmDefineRepository.QueryListByClause(i => i.EquipCode == "充电机");
|
|
|
|
|
|
List<string> lstAlarm = new List<string>();
|
|
|
|
|
|
if (msg.EmergencyStop)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="1").ToList()[0].ErrorCode);
|
|
|
if (msg.SmokeFault)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="2").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargeACInputCircuitBreakerFault)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="3").ToList()[0].ErrorCode);
|
|
|
if (msg.DcBusPositElecContactorRefuFault)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="4").ToList()[0].ErrorCode);
|
|
|
if (msg.DcBusNegatElecContactorRefuFault)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="5").ToList()[0].ErrorCode);
|
|
|
if (msg.DcBusPositElecFusesFault)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="6").ToList()[0].ErrorCode);
|
|
|
if (msg.DDcBusNegatElecFusesFault)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="7").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargingInterfaceLockError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="8").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargerFanError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="9").ToList()[0].ErrorCode);
|
|
|
if (msg.ArresterError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="10").ToList()[0].ErrorCode);
|
|
|
if (msg.InsulationDetectionAlarm)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="11").ToList()[0].ErrorCode);
|
|
|
if (msg.InsulationDetectionError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="12").ToList()[0].ErrorCode);
|
|
|
if (msg.BatteryPolarityReverseError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="13").ToList()[0].ErrorCode);
|
|
|
if (msg.VeConGuidanceFailure)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="14").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargingOverTempError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="15").ToList()[0].ErrorCode);
|
|
|
if (msg.InterfaceOverFaulty)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="16").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargingGunNotHomingError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="17").ToList()[0].ErrorCode);
|
|
|
if (msg.BmsConnError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="18").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargerInputOverVoltageError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="19").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargerInputUnderVoltageError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="20").ToList()[0].ErrorCode);
|
|
|
if (msg.DcBusOutputOverVoltageError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="21").ToList()[0].ErrorCode);
|
|
|
if (msg.DcBusOutputUnderVoltageError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="22").ToList()[0].ErrorCode);
|
|
|
if (msg.DcBusOutputOverCurrentError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="23").ToList()[0].ErrorCode);
|
|
|
if (msg.VehicleConnStatus)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="24").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargeStationGunHolderStatus)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="25").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargingInterfaceLockStatus)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="26").ToList()[0].ErrorCode);
|
|
|
if (msg.PositiveDcTransmissionContactorStatus)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="27").ToList()[0].ErrorCode);
|
|
|
if (msg.NegativeDcTransmissionContactorStatus)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="28").ToList()[0].ErrorCode);
|
|
|
if (msg.EntranceGuardError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="29").ToList()[0].ErrorCode);
|
|
|
if (msg.PConA3dhesionFailure)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="30").ToList()[0].ErrorCode);
|
|
|
if (msg.NConadhesionFailure)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="31").ToList()[0].ErrorCode);
|
|
|
if (msg.ReliefCircuitError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="32").ToList()[0].ErrorCode);
|
|
|
if (msg.ConActivated)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="33").ToList()[0].ErrorCode);
|
|
|
if (msg.ConAdhesionFailure)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="34").ToList()[0].ErrorCode);
|
|
|
if (msg.AuxiliaryPowerError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="35").ToList()[0].ErrorCode);
|
|
|
if (msg.ModuleOutputReverseError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="36").ToList()[0].ErrorCode);
|
|
|
if (msg.AcContactorStatus)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="37").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargingGunOverTempWarning)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="38").ToList()[0].ErrorCode);
|
|
|
if (msg.ChargerOverTempWarning)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="39").ToList()[0].ErrorCode);
|
|
|
if (msg.MeterConnError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="40").ToList()[0].ErrorCode);
|
|
|
if (msg.MeterDataError)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="41").ToList()[0].ErrorCode);
|
|
|
if (msg.WaterloggingWarning)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="42").ToList()[0].ErrorCode);
|
|
|
if (msg.ReversePowerWarning)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="43").ToList()[0].ErrorCode);
|
|
|
if (msg.BatteryPackAuxiliaryPowerStatus)lstAlarm.Add(sn+lstEquipAlarmDefine.Where(i=>i.ErrorCode=="44").ToList()[0].ErrorCode);
|
|
|
|
|
|
|
|
|
//查询当前充电机的实时报警信息
|
|
|
var lstNowEquipAlarmRecord = EquipAlarmRecordRepository.QueryListByClause(i => i.EquipCode == sn);
|
|
|
var sqllstAlarm=lstNowEquipAlarmRecord.Select(obj => obj.ErrorCode).ToList();//当前报警列表
|
|
|
|
|
|
// 找出实时报警中存在但数据库中不存在的元素
|
|
|
List<string> uniqueToList1 = lstAlarm.Except(sqllstAlarm).ToList();
|
|
|
|
|
|
// 找出数据库中存在但实时报警中不存在的元素
|
|
|
List<string> uniqueToList2 = sqllstAlarm.Except(lstAlarm).ToList();
|
|
|
if (uniqueToList1.Count > 0)
|
|
|
{//这里要添加新的报警数据
|
|
|
foreach (var errorCode in uniqueToList1)
|
|
|
{
|
|
|
EquipAlarmDefine? alarmDefine = EquipAlarmDefineRepository.QueryByClause(i=>i.ErrorCode==errorCode.Replace(sn,""));
|
|
|
if (alarmDefine != null)
|
|
|
{
|
|
|
EquipAlarmRecord record = new EquipAlarmRecord()
|
|
|
{
|
|
|
EquipTypeCode = alarmDefine.EquipTypeCode,
|
|
|
EquipCode = sn,
|
|
|
ErrorCode = errorCode,
|
|
|
ErrorLevel = alarmDefine.ErrorLevel,
|
|
|
ErrorMsg = alarmDefine.ErrorMsg,
|
|
|
ProcessMethod = alarmDefine.ProcessMethod,
|
|
|
StartTime= DateTime.Now
|
|
|
};
|
|
|
EquipAlarmRecordRepository.Insert(record);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
else if (uniqueToList2.Count > 0)
|
|
|
{
|
|
|
//这些是要清除实时报警，并且处理记录的。
|
|
|
// 使用LINQ找出ErrorCode在uniqueToList2中的EquipAlarmRecord对象
|
|
|
List<EquipAlarmRecord> filteredObjectList = lstNowEquipAlarmRecord
|
|
|
.Where(obj => uniqueToList2.Contains(obj.ErrorCode))
|
|
|
.ToList();
|
|
|
foreach (var VARIABLE in filteredObjectList)
|
|
|
{
|
|
|
EquipAlarmProcessRecord EquipAlarmProcessRecord = new EquipAlarmProcessRecord();
|
|
|
EquipAlarmProcessRecord.EquipTypeCode = VARIABLE.EquipTypeCode;
|
|
|
EquipAlarmProcessRecord.EquipCode = VARIABLE.EquipCode;
|
|
|
EquipAlarmProcessRecord.ErrorCode = VARIABLE.ErrorCode;
|
|
|
EquipAlarmProcessRecord.ErrorLevel = VARIABLE.ErrorLevel;
|
|
|
EquipAlarmProcessRecord.ErrorMsg = VARIABLE.ErrorMsg;
|
|
|
EquipAlarmProcessRecord.ProcessMethod = VARIABLE.ProcessMethod;
|
|
|
EquipAlarmProcessRecord.StartTime = VARIABLE.StartTime;
|
|
|
EquipAlarmProcessRecord.ProcessTime=DateTime.Now;
|
|
|
|
|
|
EquipAlarmProcessRecordRepository.Insert(EquipAlarmProcessRecord);
|
|
|
}
|
|
|
EquipAlarmRecordRepository.Delete(filteredObjectList);
|
|
|
}
|
|
|
}
|
|
|
//else
|
|
|
//{
|
|
|
/*var lstNowEquipAlarmRecord = EquipAlarmRecordRepository.QueryListByClause(i => i.EquipCode == sn);
|
|
|
if (lstNowEquipAlarmRecord.Count > 0)
|
|
|
{
|
|
|
foreach (var VARIABLE in lstNowEquipAlarmRecord)
|
|
|
{
|
|
|
EquipAlarmProcessRecord EquipAlarmProcessRecord = new EquipAlarmProcessRecord();
|
|
|
EquipAlarmProcessRecord.EquipTypeCode = VARIABLE.EquipTypeCode;
|
|
|
EquipAlarmProcessRecord.EquipCode = VARIABLE.EquipCode;
|
|
|
EquipAlarmProcessRecord.ErrorCode = VARIABLE.ErrorCode;
|
|
|
EquipAlarmProcessRecord.ErrorLevel = VARIABLE.ErrorLevel;
|
|
|
EquipAlarmProcessRecord.ErrorMsg = VARIABLE.ErrorMsg;
|
|
|
EquipAlarmProcessRecord.ProcessMethod = VARIABLE.ProcessMethod;
|
|
|
EquipAlarmProcessRecord.StartTime = VARIABLE.StartTime;
|
|
|
EquipAlarmProcessRecord.ProcessTime=DateTime.Now;
|
|
|
|
|
|
EquipAlarmProcessRecordRepository.Insert(EquipAlarmProcessRecord);
|
|
|
}
|
|
|
}
|
|
|
EquipAlarmRecordRepository.Delete(i=>i.Id>0);*/
|
|
|
//}
|
|
|
|
|
|
#endregion
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
} |
