MES_Client/TGMES/Core.StlMes.Client.LgResMgt/Mcms/frmLocalTruckScaleActuals.cs

using Infragistics.Win.UltraWinListView;
using Infragistics.Win.UltraWinTabControl;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Timers;
using System.Windows.Forms;
using System.Xml.Linq;
using Core.Mes.Client.Comm.Control;
using Core.Mes.Client.Comm.Server;
using Core.Mes.Client.Comm.Tool;
using Core.StlMes.Client.LgResMgt.Mcms.entity;
using CoreFS.CA06;
using Infragistics.Win;
using Infragistics.Win.Misc;
using Infragistics.Win.UltraWinEditors;
using Infragistics.Win.UltraWinGrid;
using Infragistics.Win.UltraWinListView;
using Infragistics.Win.UltraWinTabControl;
using Newtonsoft.Json;
using Newtonsoft.Json.Serialization;
using NPOI.HSSF.UserModel;
using NPOI.SS.UserModel;
using NPOI.SS.Util;
using BorderStyle = NPOI.SS.UserModel.BorderStyle;
using HorizontalAlignment = NPOI.SS.UserModel.HorizontalAlignment;
using Timer = System.Timers.Timer;
using System.Net.Sockets;
using System.Threading;
using System.Text;
using System.Collections;
using Core.Mes.Client.Comm.Format;

namespace Core.StlMes.Client.LgResMgt.Mcms
{
    public partial class frmLocalTruckScaleActuals : FrmBase
    {
        public frmLocalTruckScaleActuals(OpeBase _ob)
        {
            InitializeComponent();
            new CodeFile.FormMove(this, panel1);
            ob = _ob;
        }
        bool start = true;
        private static object sync = new object();
        private static frmLocalTruckScaleActuals instance;
        public static frmLocalTruckScaleActuals GetSingleton(OpeBase _ob)
        {
            lock (sync)
            {
                ;
                if (instance == null || instance.IsDisposed)
                    instance = new frmLocalTruckScaleActuals(_ob);

            }
            return instance;
        }
        private CommunicationEntity communicationnow;
        private frmMessage _frmMessage;
        private CmmPoundBaseEntity cmmPoundBase;
        private CmmActualWeightEntity cmmactual = new CmmActualWeightEntity();
        private CmmActualWeightEntity cmmactualbefore = new CmmActualWeightEntity();
        private List<CmmPoundBaseEntity> poundInfos;
        private List<CmmBaseSpotInfoEntity> CmmBaseSpotInfo;
        private void comboBox1_SelectedValueChanged(object sender, EventArgs e)
        {
            if (cboPoundList.Text.Trim() == "")
                return;

            if ((cboPoundList.Text.Trim() != null) && (communicationnow != null))
            {
                communicationnow.Communication.Show = false;
                communicationnow.Communication.Stop();
                communicationnow.Communication.ReceiveData -= defultClenttEntity_ReceiveData;

            }
            communicationnow = null;
            communicationnow = new CommunicationEntity();
            var combase = CmmBaseSpotInfo.First(p => p.BaseSpotNo == cboPoundList.Text);
            communicationnow.Communication = new SocketClient
            {
                Ip = combase.WeightIp,
                Port = combase.WeightPort,
                Show = true
            };
            communicationnow.PoundNo = cboPoundList.Text;
            communicationnow.Communication.Show = true;
            WeightLoad(communicationnow.Communication, communicationnow.PoundNo);
        }
        /// <summary>
        /// 启动采集
        /// </summary>
        /// <param name="communication"></param>
        private void WeightLoad(iCommunication communication, string PNO)
        {

            communication.ReceiveData += defultClenttEntity_ReceiveData;

            CmmBaseProtocolEntity cmmBaseProtocol = null;
            cmmPoundBase = poundInfos.First(p => p.PoundNo == PNO);
            if (cmmPoundBase != null)
            {
                List<CmmBaseProtocolCEntity> protocols = EntityHelper.GetData<CmmBaseProtocolCEntity>(
                    "com.steering.Mcms.ProcotolServer.getProcotolId",
                    new object[] { cmmPoundBase.PoundProtocolId },
                    ob);
                if ((protocols != null) && protocols.Any())
                    cmmBaseProtocol = new CmmBaseProtocolEntity
                    {
                        ProtocolId = cmmPoundBase.PoundProtocolId,
                        ListC = protocols
                    };
                //  cboPoundList.Text = cmmPoundBase.PoundNo;
            }
            communication.ChangeProtocol(new TruckScaleProtocol(cmmBaseProtocol));
            utbConnect_Click(null, null);
        }
        private void defultClenttEntity_ReceiveData(object sender, object data, string message, DataType datatype,
      byte[] bdata)
        {
            SocketClient client = sender as SocketClient;

            if (client.Show == true)
            {
                ShowMessage(data, message, datatype, sender);
            }
        }
        private void ShowMessage(object data, string message, DataType dataType, object sender)
        {
            SocketClient client = sender as SocketClient;
            if (dataType == DataType.ReceiveData)
            {
                double wt;
                if (double.TryParse(data.ToString2(), out wt))
                    txtWeight.SafeRefreshControl(() => { txtWeight.Text = (wt / 100d).ToString("0.00") + "t"; });
            }
            else if (dataType == DataType.Open)
            {
                utbConnect.SafeRefreshControl(() => utbConnect.Appearance.ForeColor = Color.Red);
                txtMessage.SafeRefreshControl(
                    () =>
                        txtMessage.Text =
                            client.Status
                                ? "已打开"
                                : "已关闭");
                //   cboNo.SafeRefreshControl(() => cboNo.Enabled = false);
            }
            else if (dataType == DataType.Close)
            {
                utbConnect.SafeRefreshControl(() => utbConnect.Appearance.ForeColor = Color.Lime);
                txtMessage.SafeRefreshControl(
                    () =>
                        txtMessage.Text =
                         client.Status
                                ? "已打开"
                                : "已关闭");
            }
            else if (dataType == DataType.Error)
            {
                MessageBox.Show(message);
            }
            else if (dataType == DataType.ClientReconnect)
            {
                txtMessage.SafeRefreshControl(() => txtMessage.Text = "网络异常,正在重连服务！");
            }
            //   txtMessage.SafeRefreshControl(() => txtMessage.Text = client.ToString());


            if ((_frmMessage != null) && !_frmMessage.IsDisposed)
                _frmMessage.SafeShowMsg(message, dataType);
            else
                _frmMessage = null;
        }

        private void frmLocalTruckScaleActual_Load(object sender, EventArgs e)
        {
            txtMessage.Text = "";
            labRealWgt.Text = "";
            txtTaer_wt.Text = "";
            txtNet_wet.Text = "";
            txtCross_wt.Text = "";
            poundInfos = EntityHelper.GetData<CmmPoundBaseEntity>(
             "com.steering.Mcms.PoundBaseServer.getPoudInfo",
             new object[] { ValidDataPurviewIds },
             ob);
            CmmBaseSpotInfo = EntityHelper.GetData<CmmBaseSpotInfoEntity>(
                 "com.steering.Mcms.CmmBaseSpotInfoServer.doQuery",
                 new object[] { },
                 ob);
            this.WindowState = FormWindowState.Normal;
        }

        private void utbConnect_Click(object sender, EventArgs e)
        {
            if (communicationnow.Communication == null) return;

            if ((communicationnow.Communication != null) && communicationnow.Communication.Status)
            {
                communicationnow.Communication.Stop();
            }
            else
            {
                communicationnow.Communication.Start();

            }
        }
        private bool boolbefor = false;
        private void timer1_Tick(object sender, EventArgs e)
        {
            try
            {
                double wt;

                if (double.TryParse(txtWeight.Text.Replace("t", ""), out wt))
                {
                    if ((wt == 0 || wt < 0)&&txtMessage.Text != " ")
                    {
                        start = false;
                        txtMessage.SafeRefreshControl(() => txtMessage.Text = " ");
                    }
                    else
                    {
                        start = true;
                    }

                    if (communicationnow == null)
                        return;
                    if (wt < 0.5 && boolbefor == false)
                    {
                        textCar_no.SafeRefreshControl(() => textCar_no.Text = "");
                        labRealWgt.SafeRefreshControl(() => labRealWgt.Text = "");
                        txtTaer_wt.SafeRefreshControl(() => txtTaer_wt.Text = "");
                        txtCross_wt.SafeRefreshControl(() => txtCross_wt.Text = "");
                        txtNet_wet.SafeRefreshControl(() => txtNet_wet.Text = "");
                        boolbefor = true;
                        var CmmA = EntityHelper.GetData<CmmActualWeightEntity>(
    "com.steering.Mcms.CmmActualWeightServer.doQuery", new object[] { }, ob);
                        cmmactualbefore = CmmA.First(p => p.BaseSpotNo == communicationnow.PoundNo);

                    }
                    if ((cmmactualbefore != null) && (cmmactualbefore.BaseSpotNo != cboPoundList.Text.Trim()))
                    {
                        boolbefor = false;
                    }
                    if (wt >= 0.5)
                    {
                        txtMessage.SafeRefreshControl(() => txtMessage.Text = "开始计量");
                        var CmmA = EntityHelper.GetData<CmmActualWeightEntity>(
             "com.steering.Mcms.CmmActualWeightServer.doQuery", new object[] { }, ob);
                        cmmactual = CmmA.First(p => p.BaseSpotNo == cboPoundList.Text);
                    }
                    if ((cmmactualbefore == null && cmmactual != null) || ((cmmactualbefore.RecordNo != cmmactual.RecordNo) && (!(string.IsNullOrEmpty(cmmactual.RecordNo)))))
                    {
                        boolbefor = false;
                        var dic = new Dictionary<string, object>();

                        dic.Add("recordNo", cmmactual.RecordNo);
                        //         dic.Add("validflag", new List<string> { "2" });
                        CmmWeightRecordEntity cmmrecord = EntityHelper.GetData<CmmWeightRecordEntity>(
                                 "com.steering.Mcms.RecordServer.doQueryRecord",
                                 new object[] { dic },
                                 ob).First();
                        textCar_no.SafeRefreshControl(() => textCar_no.Text = cmmrecord.CarNo);
                        labRealWgt.SafeRefreshControl(() => labRealWgt.Text = cmmrecord.RecordWeight.ToString() + "t");
                        if (cmmrecord.Validflag == "2")
                        {
                            var dic1 = new Dictionary<string, object>();
                            string strtime = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
                            string strtime1 = DateTime.Now.AddDays(1).ToString("yyyy-MM-dd 07:00:00");
                            dic1.Add("time", strtime);
                            dic1.Add("time1", strtime1);
                            dic1.Add("carNo", cmmrecord.CarNo);
                            // dic.Add("shippersName", cmmrecord.ShippersName);
                            //   dic.Add("receiveName", cmmrecord.ReceiveName); 
                            dic1.Add("validflag", new List<string> { "1" });
                            List<CmmWeightResultEntity> list = EntityHelper.GetData<CmmWeightResultEntity>(
                                "com.steering.Mcms.ResultServer.doQuery",
                                new object[] { dic1 },
                                ob);
                            var p = list.First();
                            if (p != null)
                            {
                                txtTaer_wt.SafeRefreshControl(() => txtTaer_wt.Text = p.TareWt + "t");
                                txtCross_wt.SafeRefreshControl(() => txtCross_wt.Text = p.GrossWt + "t");
                                txtNet_wet.SafeRefreshControl(() => txtNet_wet.Text = p.NetWt + "t");
                            }
                        }
                    }
                }
            }
            catch
            { }
        }



        private void btnClose_Click(object sender, EventArgs e)
        {
            this.Close();
        }

        private void pictureBox1_Click(object sender, EventArgs e)
        {
            this.WindowState = FormWindowState.Maximized;
        }

        private void timer2_Tick(object sender, EventArgs e)
        {
            labDate.Text = DateTime.Now.ToString();
        }
    }
}