EquipmentVM.cs 7.11 KB
using CommunityToolkit.Mvvm.ComponentModel;
using CommunityToolkit.Mvvm.Input;
using HandyControl.Data;
using HHECS.BllModel;
using HHECS.RobotTool.Model;
using HHECS.RobotTool.View.EquipmentPropView;
using HHECS.RobotTool.View.EquipmentView;
using LinqKit;
using System.Collections;
using System.Collections.ObjectModel;
using System.Configuration;
using System.Linq.Expressions;
using System.Windows;
using MessageBox = HandyControl.Controls.MessageBox;

namespace HHECS.RobotTool.ViewModel.EquipmentVM
{
    public partial class EquipmentVM : ViewModelBase
    {
        [ObservableProperty]
        private string equipmentCode = null!;

        [ObservableProperty]
        private string equipmentName = null!;

        [ObservableProperty]
        private Dictionary<int, string> equipmentTypes = new Dictionary<int, string>();

        [ObservableProperty]
        private string destinationArea = null!;

        [ObservableProperty]
        private int equipmentTypeId = 0;

        [ObservableProperty]
        private ObservableCollection<EquipmentExtend> equipments = new ObservableCollection<EquipmentExtend>();

        public EquipmentVM()
        {
            InitialData();
            LoadData();
        }

        private void InitialData()
        {
            try
            {
                var result = _freeSql.Queryable<EquipmentTypeExtend>().ToList();
                var keyValuePairs = new Dictionary<int, string>
                {
                    { 0,"全部" }
                };

                foreach (var item in result)
                {
                    keyValuePairs.Add(item.Id, item.Name);
                }
                EquipmentTypes = keyValuePairs;
                DestinationArea = ConfigurationManager.AppSettings["Area"]!;
                InitialBtns(typeof(EquipmentView).Name);
            }
            catch (Exception ex)
            {
                MessageBox.Error($"[{nameof(EquipmentVM)}]加载数据失败.{ex.Message}");
            }
        }

        [RelayCommand]
        public void Serach()
        {
            var result = LoadData();
            if (!result.Success)
            {
                MessageBox.Error($"[{nameof(EquipmentVM)}]加载数据失败.{result.Msg}");
            }
        }

        [RelayCommand]
        public void Add()
        {
            var view = new EquipmentAddOrEditView();
            var result = view.ShowDialog();
            if (result == true)
            {
                LoadData();
            }
        }

        [RelayCommand]
        public void Edit(int equipmentId)
        {
            var view = new EquipmentAddOrEditView(equipmentId);
            var result = view.ShowDialog();
            if (result == true)
            {
                LoadData();
            }
        }

        [RelayCommand]
        public void Delete(int equipmentId)
        {
            try
            {
                var result = MessageBox.Ask($"确认删除数据?");
                if (result != MessageBoxResult.OK)
                {
                    return;
                }

                _freeSql.Delete<EquipmentPropExtend>().Where(x => x.EquipmentId == equipmentId).ExecuteAffrows();
                _freeSql.Delete<EquipmentExtend>().Where(x => x.Id == equipmentId).ExecuteAffrows();
                LoadData();
                MessageBox.Success("删除数据成功");
            }
            catch (Exception ex)
            {
                MessageBox.Error($"删除数据失败.{ex.Message}");
            }
        }

        [RelayCommand]
        public void Detail(EquipmentExtend equipment)
        {
            var view = new EquipmentPropMonitor(equipment);
            view.ShowDialog();
        }

        [RelayCommand]
        public void BatchDelete(IList sender)
        {
            try
            {
                var equipments = sender.Cast<EquipmentExtend>().ToList();
                if (equipments.Count == 0)
                {
                    MessageBox.Warning("未选中任何数据!");
                    return;
                }

                var result = MessageBox.Ask($"确认删除选中数据?");
                if (result != MessageBoxResult.OK)
                {
                    return;
                }

                var equipmentIds = equipments.Select(x => x.Id).ToList();
                var equipmentPropIds = _freeSql.Queryable<EquipmentPropExtend>().Where(x => equipmentIds.Contains(x.EquipmentId)).ToList(x => x.Id);
                _freeSql.Delete<EquipmentExtend>().Where(x => equipmentIds.Contains(x.Id)).ExecuteAffrows();
                _freeSql.Delete<EquipmentPropExtend>().Where(x => equipmentPropIds.Contains(x.Id)).ExecuteAffrows();
                LoadData();
                MessageBox.Success($"成功删除{equipments.Count}条数据");
            }
            catch (Exception ex)
            {
                MessageBox.Error($"删除失败.{ex.Message}");
            }
        }

        /// <summary>
        /// 页码改变
        /// </summary>
        [RelayCommand]
        private void PageUpdated(FunctionEventArgs<int> info)
        {
            PageIndex = info.Info;
            LoadData();
        }

        private BllResult LoadData()
        {
            try
            {
                var query = _freeSql.Queryable<EquipmentExtend>().Where(GetFilter()).Include(x => x.EquipmentType);
                var total = query.Count();
                MaxPage = total / PageSize + Convert.ToInt32(total % PageSize != 0);
                var result = query.Page(PageIndex, PageSize).ToList();

                var robotConfigIds = result.Select(x => x.RobotConfigId).Distinct().ToList();
                var robotConfigs = _freeSql.Queryable<RobotConfig>().Where(x => robotConfigIds.Contains(x.Id)).ToList(x => new RobotConfig
                {
                    Id = x.Id,
                    Code = x.Code,
                });

                result.ForEach(x =>
                {
                    x.RobotConfig = robotConfigs.Where(r => r.Id == x.RobotConfigId).FirstOrDefault()!;
                });

                Equipments = new ObservableCollection<EquipmentExtend>(result);
                return BllResultFactory.Success();
            }
            catch (Exception ex)
            {
                return BllResultFactory.Error(ex.Message);
            }
        }

        private Expression<Func<EquipmentExtend, bool>> GetFilter()
        {
            var filter = PredicateBuilder.New<EquipmentExtend>(true);
            if (!string.IsNullOrWhiteSpace(EquipmentCode))
            {
                filter = filter.And(x => x.Code.Contains(EquipmentCode));
            }
            if (!string.IsNullOrWhiteSpace(EquipmentName))
            {
                filter = filter.And(x => x.Name.Contains(EquipmentName));
            }
            if (EquipmentTypeId != 0)
            {
                filter = filter.And(x => x.EquipmentTypeId == EquipmentTypeId);
            }
            if (!string.IsNullOrWhiteSpace(DestinationArea))
            {
                filter = filter.And(x => x.DestinationArea == DestinationArea);
            }

            return filter;
        }
    }
}