ECS / ECS_EquipmentMangaSystem_BingChengTaiGuang · Files

using AutoMapper;
using HHECS.Application.Enums;
using HHECS.BllModel;
using HHECS.Infrastructure.Excel;
using HHECS.Model.Entities;
using HHECS.Model.ExcelModels;
using HHECS.WinCommon.ViewModel;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using MessageBox = HandyControl.Controls.MessageBox;

namespace HHECS.WinClient.View.EquipmentInfo
{
    public class EquipmentVM : VMBase
    {
        #region 属性

        #region Equipment

        public string Code { get; set; }

        public string Name { get; set; }

        public int TypeId { get; set; }

        public string IP { get; set; }

        public string DestinationArea { get; set; }

        public List<Equipment> Equipments { get; set; }

        public PageInfo PageInfo { get; set; } = new PageInfo();

        public Dictionary<string, object> EquipmentTypes { get; set; }

        public bool IsTabMainSelected { get; set; } = true;

        #endregion

        #region EquipmentProp

        public string PropCode { get; set; }

        public string Adress { get; set; }

        public Equipment CurrentEquipment { get; set; }

        public List<EquipmentProp> EquipmentProps { get; set; }

        public bool IsTabDetailSelected { get; set; } = false;

        #endregion

        #endregion

        public EquipmentVM()
        {
            var result = App.EquipmentService.GetEquipmentTypes(t => true);
            if (result.Success)
            {
                var types = result.Data;
                types.Insert(0, new EquipmentType() { Id = 0, Name = "全部" });
                EquipmentTypes = types.ToDictionary(t => t.Name, x => (object)x.Id);
            }
        }

        #region 方法

        #region Equipment

        public void Query()
        {
            Expression<Func<Equipment, bool>> filter = t => true;
            if (!String.IsNullOrWhiteSpace(Code))
            {
                filter = filter.And(t => t.Code.Contains(Code));
            }
            if (!String.IsNullOrWhiteSpace(Name))
            {
                filter = filter.And(t => t.Name.Contains(Name));
            }
            if (TypeId != 0)
            {
                filter = filter.And(t => t.EquipmentTypeId == TypeId);
            }
            if (!String.IsNullOrWhiteSpace(IP))
            {
                filter = filter.And(t => t.IP.Contains(IP));
            }
       

            var result = App.EquipmentService.GetEquipments(filter, PageInfo.PageIndex, PageInfo.PageSize, out long totalCount);
            if (result.Success)
            {
                PageInfo.TotalCount = totalCount;
                Equipments = result.Data;
            }
            else
            {
                MessageBox.Show($"查询失败:{result.Msg}");
            }
        }

        public void New()
        {
            WinEquipmentAddOrEdit win = new WinEquipmentAddOrEdit(0);
            win.ShowDialog();
            Query();
        }

        public void ItemCopy(Equipment equipment)
        {
            if (equipment == null)
            {
                MessageBox.Show("请选中一条数据");
                return;
            }
            var result = App.EquipmentService.CopyEquipment(equipment.Id, App.User.UserCode);
            if (result.Success)
            {
                App.LogService.LogOperation(Title.EquipmentCopy, ModuleConst.Equipment, $"设备复制成功.数据：{JsonConvert.SerializeObject(new { Code = equipment.Code + 2, Name = equipment.Name })}", result.Code.ToString(), App.User.UserCode);
                MessageBox.Show("复制成功");
            }
            else
            {
                App.LogService.LogOperation(Title.EquipmentCopy, ModuleConst.Equipment, $"设备复制失败.数据：{JsonConvert.SerializeObject(new { Code = equipment.Code + 2, Name = equipment.Name })}.详情：{result.Msg}", result.Code.ToString(), App.User.UserCode);
                MessageBox.Show($"复制失败：{result.Msg}");
            }
            Query();
        }

        public void Edit(Equipment equipment)
        {
            if (equipment == null)
            {
                MessageBox.Show("请选中一条数据");
                return;
            }
            WinEquipmentAddOrEdit win = new WinEquipmentAddOrEdit(equipment.Id);
            win.ShowDialog();
            Query();
        }

        public void Delete(List<Equipment> equipments)
        {
            if (equipments == null || equipments.Count == 0)
            {
                MessageBox.Show("未选中数据");
                return;
            }
            if (MessageBox.Show("是否确认删除?", "警告", MessageBoxButton.YesNo) != MessageBoxResult.Yes)
            {
                return;
            }
            var bllResult = App.EquipmentService.DeleteEquipments(equipments);
            if (bllResult.Success)
            {
                App.LogService.LogOperation(Title.EquipmentDelete, ModuleConst.Equipment, $"设备删除成功.数据：{JsonConvert.SerializeObject(equipments.Select(t => new { Id = t.Id, Code = t.Code, Name = t.Name }))}", bllResult.Code.ToString(), App.User.UserCode);
                MessageBox.Show("删除成功");
            }
            else
            {
                App.LogService.LogOperation(Title.EquipmentDelete, ModuleConst.Equipment, $"设备删除失败.数据：{JsonConvert.SerializeObject(equipments.Select(t => new { Id = t.Id, Code = t.Code, Name = t.Name }))}.详情：{bllResult.Msg}", bllResult.Code.ToString(), App.User.UserCode);
                MessageBox.Error($"删除失败:{bllResult.Msg}");
            }
            Query();
        }

        public async void Export()
        {
            try
            {
                if (MessageBox.Show("是否确认导出？", "注意", MessageBoxButton.YesNo) != MessageBoxResult.Yes)
                {
                    return;
                }
                Expression<Func<Equipment, bool>> filter = t => true;
                var result = App.EquipmentService.GetEquipments(filter);
                if (result.Success)
                {
                    var equipments = result.Data;
                    var config = new MapperConfiguration(cfg => cfg.CreateMap<Equipment, EquipmentExcelModel>());
                    var mapper = config.CreateMapper();
                    List<EquipmentExcelModel> models = new List<EquipmentExcelModel>();
                    equipments.ForEach(t =>
                    {
                        var temp = mapper.Map<EquipmentExcelModel>(t);
                        models.Add(temp);
                    });
                    string TimeTxt = DateTime.Now.ToString("yyyy年MM月dd日HH点mm分ss秒");
                    await NPIOHelper.ExportDTtoExcelAsync<EquipmentExcelModel>(models, "设备", string.Format($"{App.ExportPath}设备{TimeTxt}.xlsx"), App.ExportPath);
                    MessageBox.Show($"设备导出成功");
                }
                else
                {
                    MessageBox.Show($"导出失败：{result.Msg}");
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show($"导出异常：{ex.Message}");
            }
        }

        #endregion

        #region EquipmentProp

        public void QueryDetail(Equipment equipment)
        {
            if (equipment == null)
            {
                MessageBox.Show("未选中主数据！");
                IsTabMainSelected = true;
                return;
            }
            //重新查询一遍主数据，防止同步删除
            var result = App.EquipmentService.GetEquipments(t => t.Id == equipment.Id);
            if (result.Success && result.Data.Count > 0)
            {
                CurrentEquipment = result.Data[0];

                Expression<Func<EquipmentProp, bool>> filter = t => t.EquipmentId == equipment.Id;
                if (!String.IsNullOrWhiteSpace(PropCode))
                {
                    filter = filter.And(t => t.EquipmentTypePropTemplateCode.Contains(PropCode));
                }
                if (!String.IsNullOrWhiteSpace(Adress))
                {
                    filter = filter.And(t => t.Address.Contains(Adress));
                }

                var detailResult = App.EquipmentService.GetEquipmentProps(filter);
                if (detailResult.Success)
                {
                    EquipmentProps = detailResult.Data;
                }
                else
                {
                    EquipmentProps = null;
                    MessageBox.Show($"查询当前设备的属性模板失败:{detailResult.Msg}");
                }
                IsTabDetailSelected = true;
            }
            else
            {
                MessageBox.Show($"未能查询到主数据，请刷新");
                IsTabMainSelected = true;
            }
        }

        public void SaveDetail()
        {
            if (EquipmentProps == null || EquipmentProps.Count == 0)
            {
                MessageBox.Show("无可更新项");
                return;
            }
            var result = App.EquipmentService.SaveEquipmentProps(EquipmentProps, App.User.UserCode);
            if (result.Success)
            {
                App.LogService.LogOperation(Title.EquipmentPropSave, ModuleConst.Equipment, $"Id为{CurrentEquipment.Id}的设备属性保存成功.数据：{JsonConvert.SerializeObject(EquipmentProps.Select(t => new { PropCode = t.EquipmentTypePropTemplateCode, Value = t.Value }))}", result.Code.ToString(), App.User.UserCode);
                MessageBox.Show("保存成功");
            }
            else
            {
                App.LogService.LogOperation(Title.EquipmentPropSave, ModuleConst.Equipment, $"Id为{CurrentEquipment.Id}的设备属性保存失败.数据：{JsonConvert.SerializeObject(EquipmentProps.Select(t => new { PropCode = t.EquipmentTypePropTemplateCode, Value = t.Value }))}.详情：{result.Msg}", result.Code.ToString(), App.User.UserCode);
                MessageBox.Show($"保存失败:{result.Msg}");
            }
            QueryDetail(CurrentEquipment);
        }

        public void SyncDetail()
        {
            if (CurrentEquipment == null)
            {
                MessageBox.Show("未选中主数据！");
                IsTabMainSelected = true;
                return;
            }
            var result = App.EquipmentService.SyncEquipmentProp(CurrentEquipment.Id, App.User.UserCode);
            if (result.Success)
            {
                App.LogService.LogOperation(Title.EquipmentPropSync, ModuleConst.Equipment, $"Id为{CurrentEquipment.Id}的设备属性同步成功.", result.Code.ToString(), App.User.UserCode);
                MessageBox.Show("同步成功");
            }
            else
            {
                App.LogService.LogOperation(Title.EquipmentPropSync, ModuleConst.Equipment, $"Id为{CurrentEquipment.Id}的设备属性同步失败.详情：{result.Msg}", result.Code.ToString(), App.User.UserCode);
                MessageBox.Error($"同步失败:{result.Msg}");
            }
            QueryDetail(CurrentEquipment);
        }

        public void DeleteDetail(List<EquipmentProp> equipmentProps)
        {
            if (equipmentProps == null || equipmentProps.Count == 0)
            {
                MessageBox.Show("未选中数据");
                return;
            }
            if (MessageBox.Show("是否确认删除?", "警告", MessageBoxButton.YesNo) != MessageBoxResult.Yes)
            {
                return;
            }
            var bllResult = App.EquipmentService.DeleteEquipmentProps(equipmentProps);
            if (bllResult.Success)
            {
                App.LogService.LogOperation(Title.EquipmentPropDelete, ModuleConst.Equipment, $"设备属性删除成功.设备Id:{CurrentEquipment.Id}，数据：{JsonConvert.SerializeObject(equipmentProps.Select(t => new { Id = t.Id, PropCode = t.EquipmentTypePropTemplateCode, Value = t.Value }))}.", bllResult.Code.ToString(), App.User.UserCode);
                MessageBox.Show("删除成功");
            }
            else
            {
                App.LogService.LogOperation(Title.EquipmentPropDelete, ModuleConst.Equipment, $"设备属性删除失败.设备Id:{CurrentEquipment.Id}，数据：{JsonConvert.SerializeObject(equipmentProps.Select(t => new { Id = t.Id, PropCode = t.EquipmentTypePropTemplateCode, Value = t.Value }))}.详情：{bllResult.Msg}", bllResult.Code.ToString(), App.User.UserCode);
                MessageBox.Error($"删除失败:{bllResult.Msg}");
            }
            QueryDetail(CurrentEquipment);
        }

        public async void ExportDetail()
        {
            MessageBoxResult msbResult = MessageBox.Show("是否导出所有设备的属性明细\n\n提示：\n  “是”：导出所有设备的属性明细\n  “否”：导出当前设备的属性明细\n  “取消”：取消导出操作", "注意", MessageBoxButton.YesNoCancel);
            bool isAllExport = false;
            switch (msbResult)
            {
                case MessageBoxResult.Yes: isAllExport = true; break;
                case MessageBoxResult.No: isAllExport = false; break;
                default: return;
            }
            try
            {
                BllResult<List<Equipment>> result = null;
                if (isAllExport)
                {
                    result = App.EquipmentService.GetEquipments(a => true);
                }
                else
                {
                    result = App.EquipmentService.GetEquipments(a => a.Id == CurrentEquipment.Id);
                }
                if (result.Success && result.Data.Count > 0)
                {
                    var equipments = result.Data;
                    var propsResult = App.EquipmentService.GetEquipmentProps(a => true);
                    if (propsResult.Success)
                    {
                        var props = propsResult.Data;
                        List<EquipmentPropExcelModel> models = new List<EquipmentPropExcelModel>();
                        int flag = 1;
                        int count = 0;
                        foreach (var equipment in equipments)
                        {
                            flag = 1;
                            foreach (var prop in props)
                            {
                                if (equipment.Id == prop.EquipmentId)
                                {
                                    EquipmentPropExcelModel propmodel = new EquipmentPropExcelModel();
                                    propmodel.EquipmentId = equipment.Id;
                                    propmodel.EquipmentCode = equipment.Code;
                                    propmodel.EquipmentName = equipment.Name;
                                    propmodel.Id = prop.Id;
                                    propmodel.PropCode = prop.EquipmentTypePropTemplateCode;
                                    propmodel.PropName = prop.EquipmentTypePropTemplate.Name;
                                    propmodel.PropType = prop.EquipmentTypePropTemplate.PropType;
                                    propmodel.Address = prop.Address;
                                    propmodel.Value = prop.Value;
                                    propmodel.MonitorFailure = prop.EquipmentTypePropTemplate.MonitorFailure;
                                    propmodel.Remark = prop.Remark;
                                    propmodel.Created = prop.Created;
                                    propmodel.CreatedBy = prop.CreatedBy;
                                    propmodel.Updated = prop.Updated;
                                    propmodel.UpdatedBy = prop.UpdatedBy;

                                    models.Add(propmodel);
                                    flag = 0;
                                }
                            }
                            if (flag == 1)
                            {
                                count++;
                            }
                        }
                        //获取实时时间并格式化
                        string TimeTxt = DateTime.Now.ToString("yyyy年MM月dd日HH点mm分ss秒");
                        //将数据导出到excel
                        await NPIOHelper.ExportDTtoExcelAsync<EquipmentPropExcelModel>(models, "设备属性明细", string.Format($"{App.ExportPath}设备属性明细{TimeTxt}.xlsx"), App.ExportPath);
                        string str = "";
                        if (count > 0)
                        {
                            str += $"\n其中{count}个设备没有属性明细，已跳过";
                        }
                        MessageBox.Show($"设备属性明细导出成功" + str);
                    }
                    else
                    {
                        MessageBox.Show($"获取数据出错：{propsResult.Msg}");
                    }
                }
                else
                {
                    MessageBox.Show($"导出失败：未获取到设备主数据.");
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show($"导出异常：{ex.Message}");
            }
        }

        #endregion

        #endregion
    }
}