EVCB_OCPP.OCPPServer.16J/OCPPServer/Service/WebSocketCommandService.cs

using Evcb.Domain.Model;
using Evcb.Repository;
using Evcb.Service;
using Evcb.Service.Helpers;
using Evcb.Service.Service.Common;
using Newtonsoft.Json;
using NLog;
using OCPP_Packet.Packet.DataTransfer;
using OCPP_Packet.Packet.Status;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace OCPPServer.Service
{
    public class WebSocketCommandService : Service<Machine>
    {
        private ILogger logger = NLog.LogManager.GetCurrentClassLogger();

        private readonly IRepository<ChargingRecordStatus> _chargingRecordStatusRepo;
        private readonly IRepository<MachineGun> _machineGunRepo;
        private readonly IRepository<ChargingRecord> _chargingRecordRepo;
        private readonly IRepository<ChargingRecordReport> _chargingRecordReportRepo;
        private readonly IRepository<MachineError> _meRepo;
        private readonly IRepository<MemberCharging> _memberChargingRepo;
        public WebSocketCommandService(IUnitOfWork uow) : base(uow)
        {
            _uow = uow;
            _chargingRecordRepo = _uow.Repository<ChargingRecord>();
            _machineGunRepo = _uow.Repository<MachineGun>();
            _chargingRecordStatusRepo = _uow.Repository<ChargingRecordStatus>();
            _chargingRecordReportRepo = _uow.Repository<ChargingRecordReport>();
            _meRepo = _uow.Repository<MachineError>();
            _memberChargingRepo = _uow.Repository<MemberCharging>();
        }

        public ProcessStatusPacketResult Process1104(ChargingRecordStatus value)
        {
            ProcessStatusPacketResult result = new ProcessStatusPacketResult() { StartChargingType = -1 };
            var gun = _machineGunRepo.Query(c => c.GunSerNo == value.GunSerNo && c.Machine.Id == value.MachineId).Include(c => c.Machine).Include(c => c.Machine.Customer).Select().FirstOrDefault();
            value.CreatedOn = DateTime.Now;
            logger.Trace(value.MachineCustomId + "進入104處理");

            if (gun != null)
            {
                //舊的充電序號
                Guid oldGuid = Guid.Empty;

                //狀態改變，更換序號
                if ((gun.Status == 2 || gun.Status == 3) && (value.Status == 2 || value.Status == 3))
                {
                    //2跟3算同一個狀態 For AC，不更換序號
                }
                else if (gun.Status != value.Status)
                {
                    oldGuid = gun.ChargingSerNo;
                    gun.ChargingSerNo = Guid.NewGuid();
                }

                //從正準備開始充電轉換到充電進行中，新增一筆充電紀錄
                //if (((gun.Status == 1 || gun.Status == 0) && value.Status == 2) || ((gun.Status == 1 || gun.Status == 0) && value.Status == 3))
                if (value.Status == 2)
                {

                    //DateTime sDate = value.StartChargingDateTime.Value.AddMilliseconds(-1);
                    //DateTime eDate = value.StartChargingDateTime.Value.AddMilliseconds(3);
                    ChargingRecord nObj = _chargingRecordRepo.Query(
                    //    c => c.StartChargingDateTime >= sDate
                    //&& c.StartChargingDateTime <= eDate
                    c => c.StartChargingDateTime == value.StartChargingDateTime.Value
                    && c.GunSerNo == value.GunSerNo
                    && c.MachineId == gun.MachineId).Select().FirstOrDefault();

                    //沒有該筆充電序才去產生帳單紀錄
                    if (nObj == null && value.StartChargingDateTime.HasValue)
                    {
                        gun.ChargingSerNo = Guid.NewGuid();

                        nObj = new ChargingRecord()
                        {
                            StartChargingDateTime = value.StartChargingDateTime.Value,
                            StartWith = value.StartWith,
                            GunSerNo = gun.GunSerNo,
                            MachineId = gun.Machine.Id,
                            MachineCustomId = gun.Machine.CustomId,
                            ChargingSerNo = gun.ChargingSerNo,
                            ChargingStrategy = value.ChargingStrategy,
                            ChargingStrategyParam = (int)value.ChargingStrategyParam,
                            CreatedOn = DateTime.Now
                        };

                        _chargingRecordRepo.Add(nObj);

                        logger.Trace(gun.Machine.CustomId + "開始充電轉換到充電進行中");
                        logger.Trace("nObj:" + JsonConvert.SerializeObject(nObj));
                        logger.Trace("value:" + JsonConvert.SerializeObject(value));

                        //如果每筆記錄都要回報
                        if (gun.Machine.Customer.AutoCreateReportRecord)
                        {
                            //如果是卡片充電的話
                            if (value.StartWith == 1)
                            {
                                logger.Trace("卡片充電:");
                                ChargingRecordReport rr = new ChargingRecordReport()
                                {
                                    StartChargingDateTime = value.StartChargingDateTime.Value,
                                    MachineId = nObj.MachineId,
                                    MachineCustomId = nObj.MachineCustomId,
                                    CardNum = value.ReservationCardNum,
                                    StartWith = value.StartWith,
                                    ChargingSerNo = nObj.ChargingSerNo,
                                    CustomerId = gun.Machine.CustomerId,
                                    GunSerNo = value.GunSerNo,
                                    //ChargeStrategy = 2,
                                    ChargeStrategy = value.ChargingStrategy,
                                    ChargeStrategyParam = value.CardBalanceBeforeCharging,
                                    CreatedOn = DateTime.Now,
                                };
                                logger.Trace("rr:" + JsonConvert.SerializeObject(rr));
                                _chargingRecordReportRepo.Add(rr);
                                result.StartChargingType = 0;
                                result.ChargingSerNo = rr.ChargingSerNo;
                                result.Result = 12;
                            }
                        }
                    }
                }

                //發出一個新的告警，就紀錄到table中
                if (value.Status == 6)
                {
                    var hasSameError = _uow.Repository<MachineError>().Query(c => c.MachineId == value.MachineId && c.GunSerNo == gun.GunSerNo).Select().OrderByDescending(c => c.CreatedOn).FirstOrDefault();

                    MachineError me = new MachineError { CreatedOn = DateTime.Now, MachineId = gun.MachineId, PreStatus = gun.Status, Status = value.Status, ErrorCode = value.Warning, GunSerNo = gun.GunSerNo };

                    if (gun.Status != 6)
                    {
                        // Gun previous status is other status
                        if (hasSameError != null)
                        {
                            if (((value.Warning == hasSameError.ErrorCode) && ((value.CreatedOn - hasSameError.CreatedOn).Value.TotalMinutes > 3)) || (value.Warning != hasSameError.ErrorCode))
                            {
                                _meRepo.Add(me);
                                NoticeError(me);
                            }
                        }
                        else
                        {
                            _meRepo.Add(me);
                            NoticeError(me);
                        }
                    }
                    else
                    {
                        // Gun previous status is alarm status
                        if (value.Warning != hasSameError.ErrorCode)
                        {
                            _meRepo.Add(me);
                            NoticeError(me);
                        }
                        //logger.Trace("value.CreatedOn - hasSameError.CreatedOn=" + (value.CreatedOn - hasSameError.CreatedOn).Value.TotalMinutes.ToString());
                    }
                }
                ////從充電中，切換狀態到充電結束
                //if (gun.Status == 2 && value.Status == 3)
                //{
                //    var chargingRecordObj = _chargingRecordRepo.Query(c => c.ChargingSerNo == oldGuid).Select().FirstOrDefault();
                //    chargingRecordObj.EndChargingDateTime = DateTime.Now;
                //    _chargingRecordRepo.Update(chargingRecordObj);
                //}

                gun.Status = value.Status;
                value.ChargingSerNo = gun.ChargingSerNo;
                //value.CreatedOn = DateTime.Now;
                _chargingRecordStatusRepo.Add(value);
                _uow.SaveChanges();

                return result;
            }
            else
            {
                throw new ApplicationException("wrong guns!");
            }
        }

        private IResult NoticeError(MachineError error)
        {
            IResult result = new Result();
            try
            {
                string description = "None";
                var machineRepo = _uow.Repository<Machine>();
                var machine = machineRepo.Query(c => c.Id == error.MachineId).Include(c => c.Customer).Select().FirstOrDefault();
                var accountRepo = _uow.Repository<Account>();
                var account = accountRepo.Query(c => c.CustomerId == machine.CustomerId).Select().FirstOrDefault();
                var errorRepo = _uow.Repository<ErrorCode>();
                var errorMsg = errorRepo.Query(c => c.Code == error.ErrorCode).Select().FirstOrDefault();
                if (errorMsg != null)
                {
                    if (errorMsg.AC == machine.AC)
                    {
                        description = errorMsg.Description;
                    }
                }
                if (!string.IsNullOrEmpty(account.Email))
                {
                    string[] emailgroup = account.Email.Split(',');
                    string subject = string.Format("客户: {0} 飞宏电桩号: {1} 客户电桩号: {2} 错误代码:{3}", machine.Customer.CustomerDesc, machine.CustomId, machine.PartnerPoleId, error.ErrorCode);
                    string detail = string.Format("[时间点: {0}] 飞宏电桩号: {1} 客户电桩号: {2},枪号 : {3},错误代码: {4} 说明: {5}", error.CreatedOn, machine.CustomId, machine.PartnerPoleId, Convert.ToChar(65 + error.GunSerNo), error.ErrorCode, description);
                    string body = string.Format("详细讯息: {2} ", machine.PartnerPoleId, error.ErrorCode, detail);
                    foreach (var email in emailgroup)
                    {
                        DispatchMessageHelper.SendMail(email, subject, body);
                    }
                }

                result.Success = true;
                return result;
            }
            catch (Exception ex)
            {
                logger.Error(ex);
                result.Exception = ex;
                result.Success = false;
                return result;
            }
        }

        /// <summary>
        /// 處理經緯度
        /// </summary>
        /// <param name="machineId">電樁Id</param>
        /// <param name="Location">Location command</param>
        /// <returns></returns>
        public IResult ProcessLocation(string customId, Location value)
        {
            IResult result = new Result();
            double radius = 0.005d;
            try
            {
                var machineRepo = _uow.Repository<Machine>();
                var _chargerStationRepo = _uow.Repository<ChargerStation>();
                var machine = machineRepo.Query(c => c.CustomId == customId).Select().FirstOrDefault();
                var stations = _chargerStationRepo.Query(c => c.CustomerId == machine.CustomerId).Select().ToList();
                //Mapping 充電樁的位置 以資料庫列表中充電樁站點為圓心，判斷上報的充電樁位置是否在附近
                //以0.005d為半徑 超出者預設 0
                //double KeyX = 0d, KeyY = 0d;
                bool isNearAnyStation = false;
                foreach (var station in stations)
                {
                    double YDist = Convert.ToDouble(station.Latitude - Convert.ToDecimal(value.latitude));
                    double XDist = Convert.ToDouble(station.Longitude - Convert.ToDecimal(value.longitude));
                    if (Math.Pow(XDist, 2d) + Math.Pow(YDist, 2d) <= Math.Pow(radius, 2d))
                    {
                        isNearAnyStation = true;
                        if (machine.Location != station.Id)
                        {
                            machine.Location = station.Id;
                        }
                    }
                }

                if (!isNearAnyStation & machine.Location != 0)
                {
                    machine.Location = 0;
                }
                _uow.SaveChanges();
                result.Success = true;
                return result;
            }
            catch (Exception ex)
            {
                logger.Error(ex);
                result.Exception = ex;
                result.Success = false;
                return result;
            }
        }

        /// <summary>
        /// 處理BMS訊息
        /// </summary>
        /// <param name="machineId">電樁Id</param>
        /// <param name="ChargingGunBMS">ChargingGunBMS command</param>
        /// <returns></returns>
        public IResult ProcessChargingGunBMS(string machineId, ChargingGunBMS cmd)
        {
            IResult result = new Result();
            var _machineGunRepo = _uow.Repository<MachineGun>();
            var _chargingRecordBMSRepo = _uow.Repository<ChargingRecordBMS>();
            try
            {
                var chargingSerNo = _machineGunRepo.Query(x => x.MachineId == machineId && x.GunSerNo == cmd.connectorId && x.Status != 0).Select(x => x.ChargingSerNo).FirstOrDefault();
                if (chargingSerNo == null) chargingSerNo = Guid.Empty;

                _chargingRecordBMSRepo.Add(new ChargingRecordBMS()
                {
                    MachineId = machineId,
                    MachineCustomId = _repository.Query(x => x.Id == machineId).Select(x => x.PartnerPoleId).FirstOrDefault(),
                    GunSerNo = Convert.ToByte(cmd.connectorId-1),
                    ChargingSerNo = chargingSerNo == null ? Guid.Empty : chargingSerNo,
                    Status = Convert.ToByte(cmd.status),
                    CarConnection = Convert.ToByte(cmd.carConnectionStatus),
                    BRMBMS_ProtocolVersion = cmd.brm_bmsVersion,
                    BR_BatteryType = Convert.ToByte(cmd.br_BatteryType),
                    BRM_CarBattery_SystemRatedCurrent = Convert.ToDecimal(cmd.brm_BatterySystemRatedcapacity),
                    BRM_CarBattery_SystemRatedVoltage = Convert.ToDecimal(cmd.brm_BatterySystemRatedVoltage),
                    BRM_BatteryManufacturer = cmd.brm_BatteryManufacturer,
                    BRM_BatteryGroupSN = cmd.brm_BatteryNumber,
                    BRM_BatteryGroupProductionDate = cmd.brm_ProductionDate,
                    BRM_BatteryGroupChargingTimes = cmd.brm_BatteryChargeTimes,
                    BRM_BatteryGroupPropertyRight = Convert.ToByte(cmd.brm_BatteryPropertySign),
                    BRM_Reserve = Convert.ToByte(cmd.brm_Reserved),
                    BRM_VIN = cmd.brm_Vin,
                    BRMBMS_SoftwareVersion = cmd.brm_bmsSoftwareVersion,
                    BCP_SingleBatteryAllowChargeMaxVoltage = Convert.ToDecimal(cmd.bcp_SingleBatteryHightestChargeVoltage),
                    BCP_AllowChargeMaxCurrent = Convert.ToDecimal(cmd.bcp_HightestChargeCurrent),
                    BCP_BatteryFlagTotalEnergy = Convert.ToDecimal(cmd.bcp_BatteryLabelingTotalEnergy),
                    BCP_AllowChargeMaxTotalVoltage = Convert.ToDecimal(cmd.bcp_HightestChargeVoltage),
                    BCP_AllowHighestTemperature = cmd.bcp_HightestTemperature,
                    BCP_CarBatterySOC = Convert.ToDecimal(cmd.bcp_VehiclePowerBatteryChargeState),
                    BCP_CarBatteryCurrentBatteryVoltage = Convert.ToDecimal(cmd.bcp_VehicleBatteryCurrentVoltage),
                    BROBMS_IsReadyCharge = Convert.ToByte((cmd.bro_bms_ChargeReadyStatus == ChargeReadyStatus.NotReady) ? 0x00 : ((cmd.bro_bms_ChargeReadyStatus == ChargeReadyStatus.Ready) ? 0xAA : 0xFF)),
                    BCL_Voltage = Convert.ToDecimal(cmd.bcl_DemandVoltage),
                    BCL_Current = Convert.ToDecimal(cmd.bcl_DemandCurrent),
                    BCL_ChargeMode = Convert.ToByte(cmd.bcl_ChargeMode),
                    BCS_ChargeVotageMeasurement = Convert.ToDecimal(cmd.bcs_ChargeVoltageMeasurement),
                    BCS_ChargeCurrentMeasurement = Convert.ToDecimal(cmd.bcs_ChargeCurrentMeasurement),
                    BCS_SingleBatteryMaxVoltage = Convert.ToDecimal(cmd.bcs_HightestSingleBatteryVoltage),
                    BCS_SingleBatteryGroupNumber = cmd.bcs_HightestSingleBatteryNumber,
                    BCS_CurrentSOC = Convert.ToByte(cmd.bcs_CurrentSOC),
                    RemainingChargeMins = cmd.remainingChargeTime,
                    BSM_SingleBatteryMaxVoltageNumber = cmd.bsm_HightestSingleBatteryVoltageNumber,
                    BSM_BatteryHighestTemperature = cmd.bsm_HightestBatteryTemperature,
                    BSM_HighestTemperatureCheckPointNumber = cmd.bsm_HightestTemperatureDetectionPointNumber,
                    BSM_BatteryLowestTemperature = cmd.bsm_LowestBatteryTemperature,
                    BSM_LowestTemperatureCheckPointNumber = cmd.bsm_LowestTemperatureDetectionPointNumber,
                    BSM_SingleBatteryVoltageStatus = Convert.ToByte((cmd.bsm_SingleBatteryVoltageStatus == BMSStatusAType.Normal) ? 0x00 : ((cmd.bsm_SingleBatteryVoltageStatus == BMSStatusAType.TooHigh) ? 0x01 : 0x10)),
                    BSM_CarBatterySOCStatus = Convert.ToByte((cmd.bsm_VehicleBatterySOCStatus == BMSStatusAType.Normal) ? 0x00: ((cmd.bsm_VehicleBatterySOCStatus == BMSStatusAType.TooHigh) ? 0x01 : 0x10)),
                    BSM_BatteryChargineCurrentStatus = Convert.ToByte((cmd.bsm_BatteryChargeCurrentStatus == BMSStatusBType.Normal) ? 0x00 : ((cmd.bsm_BatteryChargeCurrentStatus == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BSM_BatteryTemperatureTooHigh = Convert.ToByte((cmd.bsm_BatteryTemperatureStatus == BMSStatusBType.Normal) ? 0x00 : ((cmd.bsm_BatteryTemperatureStatus == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BSM_BatteryInsulationStatus = Convert.ToByte((cmd.bsm_BatteryInsulationStatus == BMSStatusBType.Normal) ? 0x00 : ((cmd.bsm_BatteryInsulationStatus == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BSM_BatteryOutputConnectionStatus = Convert.ToByte((cmd.bsm_BatteryOutputConnectorConnectionStatus == BMSStatusBType.Normal) ? 0x00 : ((cmd.bsm_BatteryOutputConnectorConnectionStatus == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BSM_AllowCharge = Convert.ToByte((cmd.bsm_IsAllowedCharge == false) ? 0x00 : 0x01),
                    BSTBMS_SOCGoal = Convert.ToByte((cmd.bst_bms_IsAchievedSOCTargetStatus == BMSStatusCType.Below) ? 0x00 : ((cmd.bst_bms_IsAchievedSOCTargetStatus == BMSStatusCType.Standard) ? 0x01 : 0x10)),
                    BSTBMS_TotalVotageSetting = Convert.ToByte((cmd.bst_bms_IsAchievedSettingTotalVoltageStatus == BMSStatusCType.Below) ? 0x00 : ((cmd.bst_bms_IsAchievedSettingTotalVoltageStatus == BMSStatusCType.Standard) ? 0x01 : 0x10)),
                    BST_SingleVotageSetting = Convert.ToByte((cmd.bst_IsAchievedSettingSingleVoltageStatus == BMSStatusCType.Below) ? 0x00 : ((cmd.bst_IsAchievedSettingSingleVoltageStatus == BMSStatusCType.Standard) ? 0x01 : 0x10)),
                    BST_ChargerActiveStop = Convert.ToByte((cmd.bst_chargerAutoTerminationStatus == ChargerAutoTerminationStatus.Normal) ? 0x00 : ((cmd.bst_chargerAutoTerminationStatus == ChargerAutoTerminationStatus.ChargerIsTerminated) ? 0x01 : 0x10)),
                    BST_InsulationError = Convert.ToByte((cmd.bst_InsulationFaultStatus == BMSStatusDType.Normal) ? 0x00 : ((cmd.bst_InsulationFaultStatus == BMSStatusDType.Fault) ? 0x01 : 0x10)),
                    BST_OutputConnectionOverTemperatureError = Convert.ToByte((cmd.bst_OutputConnectorTemperatureStatus == BMSStatusDType.Normal) ? 0x00 : ((cmd.bst_OutputConnectorTemperatureStatus == BMSStatusDType.Fault) ? 0x01 : 0x10)),
                    BSTBMSComponent_OutputConnectionOverTemperatureError = Convert.ToByte((cmd.bst_bms_OutputConnectorTemperatureStatus == BMSStatusDType.Normal) ? 0x00 : ((cmd.bst_bms_OutputConnectorTemperatureStatus == BMSStatusDType.Fault) ? 0x01 : 0x10)),
                    BST_ChargeConnectionError = Convert.ToByte((cmd.bst_chargerConnectorStatus == BMSStatusBType.Normal) ? 0x00 : ((cmd.bst_chargerConnectorStatus == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BST_BatteryGroupOverTemperatureError = Convert.ToByte((cmd.bst_BatteryTemperatureStatus == BMSStatusBType.Normal) ? 0x00 : ((cmd.bst_BatteryTemperatureStatus == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BST_HighVoltageRelayError = Convert.ToByte((cmd.bst_HighVoltageRelayStatus == BMSStatusBType.Normal) ? 0x00 : ((cmd.bst_HighVoltageRelayStatus == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BST_Checkponit2VoltageCheckError = Convert.ToByte((cmd.bst_DetectionPoint2Voltage == BMSStatusBType.Normal) ? 0x00 : ((cmd.bst_DetectionPoint2Voltage == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BST_OtherError = Convert.ToByte((cmd.bst_Other == BMSStatusBType.Normal) ? 0x00 : ((cmd.bst_Other == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BST_OverCurrent = Convert.ToByte((cmd.bst_Current == BMSStatusBType.Normal) ? 0x00 : ((cmd.bst_Current == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BST_VoltageError = Convert.ToByte((cmd.bst_Voltage == BMSStatusBType.Normal) ? 0x00 : ((cmd.bst_Voltage == BMSStatusBType.TooHigh) ? 0x01 : 0x10)),
                    BSD_StopSOC = Convert.ToByte(cmd.bsd_EndSOC),
                    BSD_SingleBatteryLowestVoltage = Convert.ToDecimal(cmd.bsd_SingleBatteryLowestVoltage),
                    BSD_SingleBatteryHighestVoltage = Convert.ToDecimal(cmd.bsd_SingleBatteryHightestVoltage),
                    BSD_BatteryLowestTemperature = cmd.bsd_BatteryLowestTemperature,
                    BSD_BatteryHighestTemperature = cmd.bsd_BatteryHightestTemperature,
                    BEM_ReceivedSPN2560_0x00 = Convert.ToByte((cmd.bem_ReceivedSPN2560_00_Status == BMSStatusEType.Normal) ? 0x00 : ((cmd.bem_ReceivedSPN2560_00_Status == BMSStatusEType.TimeOut) ? 0x01 : 0x10)),
                    BEM_ReceivedSPN2560_0xAA = Convert.ToByte((cmd.bem_ReceivedSPN2560_aa_Status == BMSStatusEType.Normal) ? 0x00 : ((cmd.bem_ReceivedSPN2560_aa_Status == BMSStatusEType.TimeOut) ? 0x01 : 0x10)),
                    BEM_ReceivedSyncAndMaxOutputPower_Timeout = Convert.ToByte((cmd.bem_ReceivedTimeSyncAndMaxOutputStatus == BMSStatusEType.Normal) ? 0x00 : ((cmd.bem_ReceivedTimeSyncAndMaxOutputStatus == BMSStatusEType.TimeOut) ? 0x01 : 0x10)),
                    BEM_ReceivedReadyCharge_Timeout = Convert.ToByte((cmd.bem_ReceivedReadyMessageStatus == BMSStatusEType.Normal) ? 0x00 : ((cmd.bem_ReceivedReadyMessageStatus == BMSStatusEType.TimeOut) ? 0x01 : 0x10)),
                    BEM_ReceivedChargerStatus_Timeout = Convert.ToByte((cmd.bem_ReceivedStatusMessageStatus == BMSStatusEType.Normal) ? 0x00 : ((cmd.bem_ReceivedStatusMessageStatus == BMSStatusEType.TimeOut) ? 0x01 : 0x10)),
                    BEM_ReceivedChargerStopCharge_Timeout = Convert.ToByte((cmd.bem_ReceivedStopMessageStatus == BMSStatusEType.Normal) ? 0x00 : ((cmd.bem_ReceivedStopMessageStatus == BMSStatusEType.TimeOut) ? 0x01 : 0x10)),
                    BEM_ReceivedChargerChargeStatistics_Timeout = Convert.ToByte((cmd.bem_ReceivedStatisticsMessageStatus == BMSStatusEType.Normal) ? 0x00 : ((cmd.bem_ReceivedStatisticsMessageStatus == BMSStatusEType.TimeOut) ? 0x01 : 0x10)),
                    BEM_Other = Convert.ToByte(cmd.bem_Other),
                    CreateOn = DateTime.Now
                });
                _uow.SaveChanges();
                result.Success = true;
            }
            catch (Exception ex)
            {
                result.Exception = ex;
                result.Message = ex.Message;
            }

            return result;
        }

        /// <summary>
        /// 處理ChargeComplete
        /// </summary>
        /// <param name="value">ChargeComplete command</param>
        /// <param name="MachineCustomId">電樁樁號</param>
        /// <returns></returns>
        public IResult ProcessChargeComplete(ChargeComplete value, string MachineCustomId)
        {
            IResult result = new Result();
            var _chargingRecordRepo = _uow.Repository<ChargingRecord>();
            var crrRepo = _uow.Repository<ChargingRecordReport>();
            var machineRepo = _uow.Repository<Machine>();
            try
            {
                var machine = machineRepo.Query(c => c.CustomId == MachineCustomId).Select().FirstOrDefault();
                var chargingTransaction = _uow.Repository<ChargingTransaction>().Query(c => c.TransactionId == value.transactionId).Select().FirstOrDefault();
                if(chargingTransaction == null)
                {
                    result.Success = false;
                    result.Message = "No Transaction Id";
                    return result;
                }
                var record = _chargingRecordRepo.Query(c => c.Id == chargingTransaction.ChargingRecordId).Select().FirstOrDefault();

                //沒有資料就補上去
                bool isNew = false;
                if (record == null)
                {
                    record = new ChargingRecord();
                    record.MachineId = machine.Id;
                    record.MachineCustomId = machine.CustomId;
                    record.GunSerNo = (byte)(value.connectorId-1);
                    record.ChargingSerNo = Guid.NewGuid();
                    record.StartChargingDateTime = value.startChargingDateTime;//value.startChargingDateTime.ToLocalTime();
                    record.EndChargingDateTime = value.chargeCompleteDateTime;//value.chargeCompleteDateTime.ToLocalTime();
                    record.CreatedOn = DateTime.Now;
                    isNew = true;
                }

                #region Mapper
                record.CumulativeKwh = (decimal)value.cumulativeKwh;
                record.KwhBeforeCharging = (decimal)value.beforeChargingKwh;
                record.KwhAfterCharging = (decimal)value.chargeCompleteKwh;
                record.ElectricBill = Decimal.Multiply((decimal)value.cumulativeKwh, machine.PricePerKWH);//(decimal)value.electricBill;
                record.FeeAmount = Decimal.Multiply((decimal)value.cumulativeKwh, machine.FeePerKWH);//(decimal)value.feeAmount;
                record.SumOfMoney = record.ElectricBill + record.FeeAmount;
                record.StopChargingReason = (int)value.reason;
                record.StartWith = (byte)value.startWith;
                record.StartSoc = (byte)value.startChargingSOC;
                record.StartChargingType = (byte)value.startChargingType;
                record.PayOffline = (byte)(value.isPayOffline ? 1 : 0);
                record.EndSoc = (byte)value.chargeCompleteSOC;
                record.ChargingStrategyParam = (int)value.chargingStrategyParameter;
                record.ChargingStrategy = (byte)value.chargingStrategy;
                record.CarNum = value.licensePlateNumber;
                record.CardVIN = value.vinCode;
                record.CardBalanceBeforeCharging = (decimal)value.cardBalanceBeforeCharging;
                record.CardBalanceAfterCharging = (decimal)value.cardBalanceAfterCharging;
                record.Time1 = (decimal)value.sectionKwh[0];
                record.Time2 = (decimal)value.sectionKwh[1];
                record.Time3 = (decimal)value.sectionKwh[2]; 
                record.Time4 = (decimal)value.sectionKwh[3];
                record.Time5 = (decimal)value.sectionKwh[4];
                record.Time6 = (decimal)value.sectionKwh[5];
                record.Time7 = (decimal)value.sectionKwh[6];
                record.Time8 = (decimal)value.sectionKwh[7];
                record.Time9 = (decimal)value.sectionKwh[8];
                record.Time10 = (decimal)value.sectionKwh[9];
                record.Time11 = (decimal)value.sectionKwh[10];
                record.Time12 = (decimal)value.sectionKwh[11];
                record.Time13 = (decimal)value.sectionKwh[12];
                record.Time14 = (decimal)value.sectionKwh[13];
                record.Time15 = (decimal)value.sectionKwh[14];
                record.Time16 = (decimal)value.sectionKwh[15];
                record.Time17 = (decimal)value.sectionKwh[16];
                record.Time18 = (decimal)value.sectionKwh[17];
                record.Time19 = (decimal)value.sectionKwh[18];
                record.Time20 = (decimal)value.sectionKwh[19];
                record.Time21 = (decimal)value.sectionKwh[20];
                record.Time22 = (decimal)value.sectionKwh[21];
                record.Time23 = (decimal)value.sectionKwh[22];
                record.Time24 = (decimal)value.sectionKwh[23];
                record.Time25 = (decimal)value.sectionKwh[24];
                record.Time26 = (decimal)value.sectionKwh[25];
                record.Time27 = (decimal)value.sectionKwh[26];
                record.Time28 = (decimal)value.sectionKwh[27];
                record.Time29 = (decimal)value.sectionKwh[28];
                record.Time30 = (decimal)value.sectionKwh[29];
                record.Time31 = (decimal)value.sectionKwh[30];
                record.Time32 = (decimal)value.sectionKwh[31];
                record.Time33 = (decimal)value.sectionKwh[32];
                record.Time34 = (decimal)value.sectionKwh[33];
                record.Time35 = (decimal)value.sectionKwh[34];
                record.Time36 = (decimal)value.sectionKwh[35];
                record.Time37 = (decimal)value.sectionKwh[36];
                record.Time38 = (decimal)value.sectionKwh[37];
                record.Time39 = (decimal)value.sectionKwh[38];
                record.Time40 = (decimal)value.sectionKwh[39];
                record.Time41 = (decimal)value.sectionKwh[40];
                record.Time42 = (decimal)value.sectionKwh[41];
                record.Time43 = (decimal)value.sectionKwh[42];
                record.Time44 = (decimal)value.sectionKwh[43];
                record.Time45 = (decimal)value.sectionKwh[44];
                record.Time46 = (decimal)value.sectionKwh[45];
                record.Time47 = (decimal)value.sectionKwh[46];
                record.Time48 = (decimal)value.sectionKwh[47];

                record.ClientStartChargingDateTime = value.startChargingDateTime;//value.startChargingDateTime.ToLocalTime();
                record.ClientEndChargingDateTime = value.chargeCompleteDateTime;//value.chargeCompleteDateTime.ToLocalTime();

                if (value.startWith == StartWith.Member)
                {
                    
                    var membertb = _memberChargingRepo.Query(c => c.SelfDefinedId == value.idTag).Select().FirstOrDefault();
                    if (membertb != null)
                    {
                        //會員
                        record.MemberId = membertb.MemberChargingId.ToString();               
                    }
                }
                else if ((value.startWith == StartWith.CardNumber) || (value.startWith == StartWith.Unknown))
                {
                    record.CardNum = value.idTag;
                }
                #endregion Mapper
                if (isNew)
                    _chargingRecordRepo.Add(record);
                else
                    _chargingRecordRepo.Update(record);

                //處理傳送給客戶api的紀錄
                var report = crrRepo.Query(c => c.ChargingSerNo == record.ChargingSerNo).Select().FirstOrDefault();

                if (report == null)
                {
                    report = new ChargingRecordReport();
                    report.CreatedOn = DateTime.Now;
                    report.StartChargingDateTime = record.StartChargingDateTime;
                    report.ChargingSerNo = record.ChargingSerNo;
                    report.CustomerId = machine.CustomerId;
                    report.GunSerNo = record.GunSerNo;
                    report.MachineCustomId = machine.CustomId;
                    report.MachineId = machine.Id;
                    report.MemberId = record.MemberId;
                    report.CardNum = record.CardNum;
                    report.StartWith = record.StartWith;
                    report.Time1 = record.Time1;
                    report.Time2 = record.Time2;
                    report.Time3 = record.Time3;
                    report.Time4 = record.Time4;
                    report.Time5 = record.Time5;
                    report.Time6 = record.Time6;
                    report.Time7 = record.Time7;
                    report.Time8 = record.Time8;
                    report.Time9 = record.Time9;
                    report.Time10 = record.Time10;
                    report.Time11 = record.Time11;
                    report.Time12 = record.Time12;
                    report.Time13 = record.Time13;
                    report.Time14 = record.Time14;
                    report.Time15 = record.Time15;
                    report.Time16 = record.Time16;
                    report.Time17 = record.Time17;
                    report.Time18 = record.Time18;
                    report.Time19 = record.Time19;
                    report.Time20 = record.Time20;
                    report.Time21 = record.Time21;
                    report.Time22 = record.Time22;
                    report.Time23 = record.Time23;
                    report.Time24 = record.Time24;
                    report.Time25 = record.Time25;
                    report.Time26 = record.Time26;
                    report.Time27 = record.Time27;
                    report.Time28 = record.Time28;
                    report.Time29 = record.Time29;
                    report.Time30 = record.Time30;
                    report.Time31 = record.Time31;
                    report.Time32 = record.Time32;
                    report.Time33 = record.Time33;
                    report.Time34 = record.Time34;
                    report.Time35 = record.Time35;
                    report.Time36 = record.Time36;
                    report.Time37 = record.Time37;
                    report.Time38 = record.Time38;
                    report.Time39 = record.Time39;
                    report.Time40 = record.Time40;
                    report.Time41 = record.Time41;
                    report.Time42 = record.Time42;
                    report.Time43 = record.Time43;
                    report.Time44 = record.Time44;
                    report.Time45 = record.Time45;
                    report.Time46 = record.Time46;
                    report.Time47 = record.Time47;
                    report.Time48 = record.Time48;
                    report.ChargeStrategy = record.ChargingStrategy;
                    report.ChargeStrategyParam = record.ChargingStrategyParam;
                    report.SumOfMoney = record.SumOfMoney;
                    report.FeeAmount = record.FeeAmount;
                    report.ElectricBill = record.ElectricBill;
                    report.StartChargingDateTime = record.ClientStartChargingDateTime;
                    report.EndChargingDateTime = record.ClientEndChargingDateTime;
                    report.CumulativeKwh = record.CumulativeKwh;
                    var ts = report.EndChargingDateTime - report.StartChargingDateTime;
                    report.TotalUsedTime = Convert.ToInt32(ts.Value.TotalSeconds);
                    report.CarNum = record.CarNum;
                    report.StartSoc = record.StartSoc;
                    report.EndSoc = record.EndSoc;
                    report.KwhBeforeCharging = record.KwhBeforeCharging;
                    report.KwhAfterCharging = record.KwhAfterCharging;
                    report.CardBalanceBeforeCharging = record.CardBalanceBeforeCharging;
                    report.CardBalanceAfterCharging = record.CardBalanceAfterCharging;
                    report.PayOffline = record.PayOffline;
                    report.CardVIN = record.CardVIN;
                    report.StartChargingType = record.StartChargingType;
                    report.StopChargingReason = record.StopChargingReason;
                    report.UpdatedOn = DateTime.Now;
                    crrRepo.Add(report);
                }
                else
                {
                    report.MemberId = record.MemberId;
                    report.CardNum = record.CardNum;
                    report.StartWith = record.StartWith;
                    report.Time1 = record.Time1;
                    report.Time2 = record.Time2;
                    report.Time3 = record.Time3;
                    report.Time4 = record.Time4;
                    report.Time5 = record.Time5;
                    report.Time6 = record.Time6;
                    report.Time7 = record.Time7;
                    report.Time8 = record.Time8;
                    report.Time9 = record.Time9;
                    report.Time10 = record.Time10;
                    report.Time11 = record.Time11;
                    report.Time12 = record.Time12;
                    report.Time13 = record.Time13;
                    report.Time14 = record.Time14;
                    report.Time15 = record.Time15;
                    report.Time16 = record.Time16;
                    report.Time17 = record.Time17;
                    report.Time18 = record.Time18;
                    report.Time19 = record.Time19;
                    report.Time20 = record.Time20;
                    report.Time21 = record.Time21;
                    report.Time22 = record.Time22;
                    report.Time23 = record.Time23;
                    report.Time24 = record.Time24;
                    report.Time25 = record.Time25;
                    report.Time26 = record.Time26;
                    report.Time27 = record.Time27;
                    report.Time28 = record.Time28;
                    report.Time29 = record.Time29;
                    report.Time30 = record.Time30;
                    report.Time31 = record.Time31;
                    report.Time32 = record.Time32;
                    report.Time33 = record.Time33;
                    report.Time34 = record.Time34;
                    report.Time35 = record.Time35;
                    report.Time36 = record.Time36;
                    report.Time37 = record.Time37;
                    report.Time38 = record.Time38;
                    report.Time39 = record.Time39;
                    report.Time40 = record.Time40;
                    report.Time41 = record.Time41;
                    report.Time42 = record.Time42;
                    report.Time43 = record.Time43;
                    report.Time44 = record.Time44;
                    report.Time45 = record.Time45;
                    report.Time46 = record.Time46;
                    report.Time47 = record.Time47;
                    report.Time48 = record.Time48;
                    report.CumulativeKwh = record.CumulativeKwh;
                    report.EndChargingDateTime = record.ClientEndChargingDateTime;
                    report.StartChargingDateTime = record.ClientStartChargingDateTime;
                    report.FeeAmount = record.FeeAmount;
                    report.ElectricBill = record.ElectricBill;
                    report.SumOfMoney = record.SumOfMoney;
                    var ts = report.EndChargingDateTime - report.StartChargingDateTime;
                    report.TotalUsedTime = Convert.ToInt32(ts.Value.TotalSeconds);
                    report.CarNum = record.CarNum;
                    report.StartSoc = record.StartSoc;
                    report.EndSoc = record.EndSoc;
                    report.KwhBeforeCharging = record.KwhBeforeCharging;
                    report.KwhAfterCharging = record.KwhAfterCharging;
                    report.CardBalanceBeforeCharging = record.CardBalanceBeforeCharging;
                    report.CardBalanceAfterCharging = record.CardBalanceAfterCharging;
                    report.PayOffline = record.PayOffline;
                    report.CardVIN = record.CardVIN;
                    report.StartChargingType = record.StartChargingType;
                    report.StopChargingReason = record.StopChargingReason;
                    report.UpdatedOn = DateTime.Now;
                }

                WarnChargeIsAbnormal(record);
                _uow.SaveChanges();
                result.Success = true;
                return result;
            }
            catch (Exception ex)
            {
                logger.Error(ex);
                result.Exception = ex;
                result.Success = false;
                return result;
            }

        }

        /// <summary>
        /// 通知Email
        /// </summary>
        /// <param name="machineId">電樁Id</param>
        /// <param name="subject">主旨</param>
        /// <param name="body">內文</param>
        /// <returns></returns>
        private IResult NoticeEmail(string machineId, string subject, string body)
        {
            IResult result = new Result();
            try
            {
                var machineRepo = _uow.Repository<Machine>();
                var machine = machineRepo.Query(c => c.Id == machineId).Include(c => c.Customer).Select().FirstOrDefault();
                var accountRepo = _uow.Repository<Account>();
                var account = accountRepo.Query(c => c.CustomerId == machine.CustomerId).Select().FirstOrDefault();

                if (!string.IsNullOrEmpty(account.Email))
                {
                    string[] emailgroup = account.Email.Split(',');
                    string _subject = string.Format("[{0}] 客户: {1} 飞宏电桩号: {2} 客户电桩号: {3} ", subject, machine.Customer.CustomerDesc, machine.CustomId, machine.PartnerPoleId);
                    foreach (var email in emailgroup)
                    {
                        DispatchMessageHelper.SendMail(email, _subject, body);
                    }
                }
                result.Success = true;
                return result;
            }
            catch (Exception ex)
            {
                logger.Error(ex);
                result.Exception = ex;
                result.Success = false;
                return result;
            }
        }

        /// <summary>
        /// 警告充電量異常
        /// </summary>
        /// <returns></returns>
        private IResult WarnChargeIsAbnormal(ChargingRecord record)
        {
            IResult result = new Result();
            try
            {
                //設定條件-充電時間超過 1800秒 -總充電量小於 0.5kw  - StartWith != 2
                if (record.CumulativeKwh < Convert.ToDecimal(0.5) && record.ClientEndChargingDateTime.HasValue
                    && record.ClientStartChargingDateTime.HasValue && record.StartWith != 2)
                {
                    var totalSeconds = record.ClientEndChargingDateTime.Value.Subtract(record.ClientStartChargingDateTime.Value).TotalSeconds;
                    if (totalSeconds > 1800d)
                    {
                        string body = string.Format("详细讯息: 充电序:{0} 充电开始时间:{1} 充电结束时间: {2} 充电秒数:{3} 充电度数:{4}",
                            record.ChargingSerNo, record.ClientStartChargingDateTime.HasValue ? record.ClientStartChargingDateTime.Value.ToString("yyyy-MM-dd HH:mm:ss") : "None",
                            record.ClientEndChargingDateTime.HasValue ? record.ClientEndChargingDateTime.Value.ToString("yyyy-MM-dd HH:mm:ss") : "None", totalSeconds, record.CumulativeKwh);
                        NoticeEmail(record.MachineId, "充电量异常通知", body);
                    }
                }
                result.Success = true;
                return result;
            }
            catch (Exception ex)
            {
                logger.Error(ex);
                result.Success = false;
                result.Exception = ex;
                result.Message = ex.Message;
                return result;
            }
        }
    }
}