AX.FileDataUpload.Manual/FileDataUpload/viewModel/MainWindowViewModel.cs

using FileDataUpload.Common;
using FileDataUpload.Entity;
using FileDataUpload.FileOperate;
using FileDataUpload.Mqtt;
using GalaSoft.MvvmLight;
using GalaSoft.MvvmLight.Command;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace FileDataUpload.viewModel
{
    public class MainWindowViewModel: ViewModelBase
    {

        private readonly FileHelper fileHelper = FileHelper.Instance;

        private readonly JsonChange jsonChange = JsonChange.Instance;

        private readonly MqttClient client = MqttClient.Instance;

        private readonly LogHelper logHelper = LogHelper.Instance;

        private AppConfig appConfig = AppConfig.Instance;

        private ObservableCollection<dynamic> listItems = new ObservableCollection<dynamic>();

        [Obsolete]
        public MainWindowViewModel()
        {
            try
            {
                client.PrintMessageReceivedEvent += PrintMessageToListBox;
                ConnectCommand = new RelayCommand(Connect);
                DisConnectCommand = new RelayCommand(DisConnect);
                SubscriptionCommand = new RelayCommand(Subscription);
                UnsubscribeCommand = new RelayCommand(Unsubscribe);

                UploadFileDataCommand = new RelayCommand(UploadFileData);

                ChooseFileCommand = new RelayCommand(ChooseFile);

                PushMessageCommand = new RelayCommand(PushMessage);

                borkerIp = "scada.midea.com";
                borkerPort = "1883";

                PrintMessageToListBox("文件数据上传程序初始化成功");
            }catch(Exception ex)
            {

                PrintMessageToListBox($"文件数据上传程序初始化失败:{ex.Message}");
            }
        }

        #region Command
        /// <summary>
        /// 连接
        /// </summary>
        public RelayCommand ConnectCommand { get; set; }

        /// <summary>
        /// 断开
        /// </summary>
        public RelayCommand DisConnectCommand { get; set; }

        /// <summary>
        /// 订阅
        /// </summary>
        public RelayCommand SubscriptionCommand { get; set; }

        /// <summary>
        /// 取消订阅
        /// </summary>
        public RelayCommand UnsubscribeCommand { get; set; }

        /// <summary>
        /// 选择文件
        /// </summary>
        public RelayCommand ChooseFileCommand { get; set; }

        /// <summary>
        /// 上传文件数据
        /// </summary>
        public RelayCommand UploadFileDataCommand { get; set; }

        /// <summary>
        /// 推送消息
        /// </summary>
        public RelayCommand PushMessageCommand { get; set; }

        #endregion

        private IEnumerable listBoxData;
        /// <summary>
        /// LisBox数据模板
        /// </summary>
        public IEnumerable ListBoxData
        {
            get { return listBoxData; }
            set { listBoxData = value; RaisePropertyChanged(() => ListBoxData); }
        }

        public String borkerIp = String.Empty;

        public String borkerPort = String.Empty;

        public String clientId = String.Empty;

        public String userName = String.Empty;

        public String password = String.Empty;

        public String topical = String.Empty;

        public String messageStr = String.Empty;

        public String BorkerIp
        {
            get { return borkerIp; }
            set { borkerIp = value; RaisePropertyChanged(()=> BorkerIp); }
        }

        public String BorkerPort
        {
            get { return borkerPort; }
            set { borkerPort = value; RaisePropertyChanged(()=> BorkerPort); }
        }

        public String ClientId
        {
            get { return clientId; }
            set { clientId = value; RaisePropertyChanged(()=> ClientId); }
        }

        public String UserName
        {
            get { return userName; }
            set { userName = value; RaisePropertyChanged(()=> UserName); }
        }

        public String Password
        {
            get { return password; }
            set { password = value; RaisePropertyChanged(()=> Password); }
        }

        public String Topical
        {
            get { return topical; }
            set { topical = value; RaisePropertyChanged(()=> Topical); }
        }

        public String MessageStr
        {
            get { return messageStr; }
            set { messageStr = value; RaisePropertyChanged(() => MessageStr); }
        }

        /// <summary>
        /// 建立连接
        /// </summary>
        public void Connect()
        {
            if(string.IsNullOrEmpty(BorkerIp) || string.IsNullOrEmpty(BorkerPort))
            {
                PrintMessageToListBox("连接失败：Borker IP、Port不允许为空");
                return;
            }

            if (string.IsNullOrEmpty(ClientId) || string.IsNullOrEmpty(UserName) || string.IsNullOrEmpty(Password))
            {
                PrintMessageToListBox("连接失败：ClientId、UserName、Password不允许为空");
                return;
            }

            client.Connect(BorkerIp, Convert.ToInt32(BorkerPort), ClientId,UserName,Password);

        }

        /// <summary>
        /// 断开连接
        /// </summary>
        public void DisConnect()
        {
            client.DisConnect();
        }

        /// <summary>
        /// 订阅主题
        /// </summary>
        public void Subscription()
        {
            if (string.IsNullOrEmpty(topical))
            {
                PrintMessageToListBox("订阅主题不允许为空");
                return;
            }
            client.SubscriptionAsync(topical);
        }

        /// <summary>
        /// 取消订阅
        /// </summary>
        public void Unsubscribe()
        {
            if (string.IsNullOrEmpty(topical))
            {
                PrintMessageToListBox("取消订阅主题不允许为空");
                return;
            }
            client.Unsubscribe(topical);
        }


        /// <summary>
        /// 选择文件
        /// </summary>
        [System.Obsolete]
        public void ChooseFile()
        {
            string fileName = "";
            OpenFileDialog openFileDialog = new OpenFileDialog();
            openFileDialog.Multiselect = true;      //该值确定是否可以选择多个文件
            openFileDialog.Title = "请选择文件";     //弹窗的标题
            openFileDialog.InitialDirectory = "D:\\";       //默认打开的文件夹的位置
            openFileDialog.Filter = "MicroSoft Excel文件(*.xlsx)|*.xlsx|所有文件(*.*)|*.*";       //筛选文件
            openFileDialog.ShowHelp = true;     //是否显示“帮助”按钮

            if (openFileDialog.ShowDialog() == System.Windows.Forms.DialogResult.OK)
            {
                fileName = openFileDialog.FileName;
                var info = fileHelper.ReadExcelFile_New(fileName);
                //var info = fileHelper.ReadExcelFile(fileName);
                if (info != null)
                {
                    MessageStr = jsonChange.ModeToJson(info);
                    PrintMessageToListBox($"文件读取成功：{MessageStr}");
                }
                else
                {
                    PrintMessageToListBox($"文件读取失败，请仔细检查文件格式");
                }
                
            }
        }

        [Obsolete]
        public void UploadFileData()
        {
            string fileName = "";
            OpenFileDialog openFileDialog = new OpenFileDialog();
            openFileDialog.Multiselect = true;      //该值确定是否可以选择多个文件
            openFileDialog.Title = "请选择文件";     //弹窗的标题
            openFileDialog.InitialDirectory = "D:\\";       //默认打开的文件夹的位置
            openFileDialog.Filter = "MicroSoft Excel文件(*.xlsx)|*.xlsx|所有文件(*.*)|*.*";       //筛选文件
            openFileDialog.ShowHelp = true;     //是否显示“帮助”按钮

            if (openFileDialog.ShowDialog() == System.Windows.Forms.DialogResult.OK)
            {
                fileName = openFileDialog.FileName;
                UploadFileData(fileName);
            }
        }

        [Obsolete]
        private async void UploadFileData(string path)
        {
            try
            {
                int pushFlag = 0;

                Dictionary<string, List<DeviceParam>> info = fileHelper.ReadExcelFile_New(path);

                if (info != null)
                {
                    borkerIp = "scada.midea.com";
                    borkerPort = "1883";
                    foreach (var item in info)
                    {
                        switch (item.Key)
                        {
                            case "铆压环":
                                clientId = "EV62Q0000501YASM346";
                                userName = "EV62Q0000501YASM346|1";
                                password = "30dc225be0cb418b974b68eb10339b31";
                                pushFlag = appConfig.pushFlag_RivetingRing + 1;
                                break;

                            case "限位器":
                                clientId = "EV33210110YTJDMC001";
                                userName = "EV33210110YTJDMC001|1";
                                password = "cebf88bcc61147c1a42a4749fadf2ed1";
                                pushFlag = appConfig.pushFlag_Stopper + 1;
                                break;

                            case "排气阀片":
                                clientId = "EV33200210YTJDMC008";
                                userName = "EV33200210YTJDMC008|1";
                                password = "396bf2a332f64810a12a0385cae8c5a9";
                                pushFlag = appConfig.pushFlag_displacingValve + 1;
                                break;
                        }
                        this.Connect();
                        await Task.Delay(1000 * 5);
                        var @params = item.Value.OrderBy(x => Convert.ToInt32(x.data.propertyCode.Substring(3, x.data.propertyCode.Length - 3))).ToList();
                        foreach (var param in @params)
                        {
                            param.data.deviceCode = ClientId;
                            PrintMessageToListBox($"{item.Key}---上传{param.data.propertyCode}数据：{jsonChange.ModeToJson(param)}");

                            topical = $"/sys/932e4a47e5414e058fdbd067a4942247/device/{clientId}/thing/property/{param.data.propertyCode}/post";

                            if (param.data.propertyCode == "tag10")
                            {
                                param.data.propertyValue = pushFlag;
                            }

                            messageStr = jsonChange.ModeToJson(param);



                            this.PushMessage();

                            await Task.Delay(1000 * 1);
                        }
                        UpdatePushFlag(item.Key);
                        this.DisConnect();
                    }
                }
                else
                {
                    PrintMessageToListBox("文件读取失败，请仔细检查文件格式");
                }
            }catch(Exception ex)
            {
                PrintMessageToListBox($"文件解析上传异常:{ex.Message}");
            }
        }

        public void PushMessage()
        {
            try
            {
                if (string.IsNullOrEmpty(Topical) || string.IsNullOrEmpty(MessageStr))
                {
                    PrintMessageToListBox("推送消息主题、内容不允许为空");
                    return;
                }
                client.Publish(Topical, MessageStr);
            }catch(Exception ex)
            {
                PrintMessageToListBox($"消息推送异常：{ex.Message}");
            }
        }


        /// <summary>
        /// listBox绑定日志
        /// </summary>
        /// <param name="message"></param>
        private void PrintMessageToListBox(string message)
        {
            logHelper.Info(message);

            listItems.Add($"{DateTime.Now.ToString("HH:mm:ss")}==>{message}");
            
            ListBoxData = listItems.OrderByDescending(x=>x);
        }

        /// <summary>
        /// 更新推送标志位
        /// </summary>
        /// <param name="sheetName"></param>
        private void UpdatePushFlag(string sheetName)
        {
            switch (sheetName)
            {
                case "铆压环":
                    appConfig.pushFlag_RivetingRing = appConfig.pushFlag_RivetingRing + 1;
                    break;

                case "限位器":
                    appConfig.pushFlag_Stopper = appConfig.pushFlag_Stopper + 1;
                    break;

                case "排气阀片":
                    appConfig.pushFlag_displacingValve = appConfig.pushFlag_displacingValve + 1;
                    break;
            }
        }
    }
}