mes-client/UAS_BG/FunctionCode/Packing/Packing_PackageCollection.cs

using LabelManager2;
using System;
using System.Data;
using System.Windows.Forms;
using UAS_MES_NEW.DataOperate;
using UAS_MES_NEW.Entity;
using UAS_MES_NEW.PublicMethod;
using System.Drawing;
using System.Threading;
using UAS_MES_NEW.PublicForm;
using System.Collections.Generic;
using System.Diagnostics;
using System.Runtime.InteropServices;
using DevExpress.Printing.Core.PdfExport.Metafile;
using System.Net.Sockets;
using System.Text;
using System.IO;
using UAS_MES_NEW.Make;
using FastReport;
//using Seagull.BarTender.Print;

namespace UAS_MES_NEW.Packing
{
    public partial class Packing_PackageCollection : Form
    {
        DataHelper dh;
        DataTable dt;
        LogStringBuilder sql = new LogStringBuilder();
        AutoSizeFormClass asc = new AutoSizeFormClass();
        ApplicationClass lbl;
        BarTender.Application engine;
        Thread thread;

        DataTable Dbfind;
        string ErrorMessage = "";
        string oMakeCode = "";
        string oMsID = "";
        string oMsStatus = "";
        string oOutBoxCode = "";
        decimal StandardQTY = 0;
        string LastSncode;
        Document doc;
        string PR_CHECKCARTONW = "0";

        ModeBusTCPServer md;

        private TcpClient tcpClient1;
        private NetworkStream stream1;
        private Thread receiveThread1;

        private TcpClient tcpClient2;
        private NetworkStream stream2;
        private Thread receiveThread2;



        private TcpClient tcpClient3;
        private NetworkStream stream3;
        private Thread receiveThread3;

        public Packing_PackageCollection()
        {

            InitializeComponent();
        }

        //创建打印进程
        private void NewPrint()
        {
            try
            {
                //engine = new BarTender.Application();
                //lbl = new ApplicationClass();
                //BaseUtil.WriteLbl();
            }
            catch (Exception ex)
            {
                OperateResult.AppendText("未正确安装打印软件\n" + ex.Message, Color.Red);
            }
        }


        string chooseprintername;
        string label_type = "";
        string label_name = "";

        private void PackCollection_Load(object sender, EventArgs e)
        {

            // 杀死之前全部未关闭的进程
            Process[] processes = System.Diagnostics.Process.GetProcessesByName("lppa");
            Process[] processes1 = System.Diagnostics.Process.GetProcessesByName("bartend");
            for (int i = 0; i < processes1.Length; i++)
            {
                processes1[i].Kill();
            }
            for (int i = 0; i < processes.Length; i++)
            {
                processes[i].Kill();
            }

            pb_name.FormName = Name;
            pb_name.TableName = "ProductBrand";
            pb_name.SetValueField = new string[] { "pb_name" };
            pb_name.SelectField = "pb_name # 品牌";
            pb_name.DBTitle = "品牌";
            pb_name.Condition = "pr_keydepartment = '-1'";
            pb_name.DbChange += Cd_stepcode_DbChange;

            //设置DbFind的必须的数据
            asc.controllInitializeSize(this);
            thread = new Thread(NewPrint);
            thread.Start();
            md = new ModeBusTCPServer();
            dh = SystemInf.dh;
            button2_Click(sender,e);
            button3_Click(sender,e);
            button4_Click(sender,e);
        }

        private void Cd_stepcode_DbChange(object sender, EventArgs e)
        {
            Dbfind = pb_name.ReturnData;
            BaseUtil.SetFormValue(this.Controls, Dbfind);
        }

        private void PackCollection_SizeChanged(object sender, EventArgs e)
        {
            asc.controlAutoSize(this);
        }

        private void PackCollection_Activated(object sender, EventArgs e)
        {
            pi_inoutno.Focus();
        }

        //刷新表单的数据的数据
        private void LoadData()
        {
            
            LoadCollectedNum();
        }

        private void LoadGridData()
        {
            //加载Grid数据
            dt = (DataTable)dh.ExecuteSql(" select pd_piid,pd_prodcode,pr_detail,pr_spec||pr_orispeccode pr_spec,sum(pd_inqty)qty,NVL(PDAQTY,0)PDAQTY from prodiodetail left join SCM_BARCODEIO_IN_VIEW2 on pd_piid = bi_piid and pd_prodcode = bi_prodcode " +
                "left join product on pd_prodcode = pr_code where pd_inoutno ='"+pi_inoutno.Text+ "' group by pd_piid,pd_prodcode,pr_detail,pr_spec||pr_orispeccode,PDAQTY" +
                " ", "select");
            BaseUtil.FillDgvWithDataTable(PackageDetail, dt);
 
        }

        private void Print_Click(object sender, EventArgs e)
        {
         
        }

        //加载工单信息和装箱明细信息
        private void pa_code_KeyDown(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter)
            {
                if (!dh.CheckExist("prodinout left join DOCUMENTSETUP on pi_class = ds_name ", "pi_inoutno = '" + pi_inoutno.Text + "' and DS_INOROUT = 'IN' "))
                {
                    OperateResult.AppendText(">>入库单" + pi_inoutno.Text + "不存在\n", Color.Red, pi_inoutno);
                    return;
                }
                dt = (DataTable)dh.ExecuteSql(" select * from prodinout where pi_inoutno = '" + pi_inoutno.Text + "' ", "select");
                BaseUtil.SetFormValue(this.Controls, dt);
                LoadGridData();
            }
        }

        //输入序列号的回车事件
        private void barcode_KeyDown(object sender, KeyEventArgs e)
        {
           
        }

        private void Clean_Click(object sender, EventArgs e)
        {
            OperateResult.Clear();
        }
        DataTable _dt;
        private void pr_code_TextChanged(object sender, EventArgs e)
        {

        }

        private void PackCollection_FormClosing(object sender, FormClosingEventArgs e)
        {
            BaseUtil.ClosePrint(lbl);
            if (engine != null)
                engine.Quit(BarTender.BtSaveOptions.btDoNotSaveChanges);
            if (stream1 != null)
            {
                stream1.Close();
            }

            if (tcpClient1 != null)
            {
                tcpClient1.Close();
            }

            if (stream2 != null)
            {
                stream2.Close();
            }

            if (tcpClient2 != null)
            {
                tcpClient2.Close();
            }
            dh.Dispose();
        }

        private void Packing_Click(object sender, EventArgs e)
        {
           
        }

      

        bool AutoCut;

      

        private void PrintLabel_SelectedValueChanged(object sender, EventArgs e)
        {

        }

        private void DeleteAll_Click(object sender, EventArgs e)
        {
           
        }

     

        private void LoadCollectedNum()
        {

        }

        private void pa_remark_KeyDown(object sender, KeyEventArgs e)
        {
        
        }

        private void PreFix_KeyDown(object sender, KeyEventArgs e)
        {
           
        }

        private void BuildServer_Click(object sender, EventArgs e)
        {
        }

        private void CloseServer_Click(object sender, EventArgs e)
        {
            if (md.IsOpen)
            {
                md.Close();
                OperateResult.AppendText(">>服务关闭成功\n");
            }
            else
                OperateResult.AppendText(">>服务尚未开启\n");
        }

        private void Remark_PreFix_KeyDown(object sender, KeyEventArgs e)
        {
        }

        private void PackageDetail_CellContentClick(object sender, DataGridViewCellEventArgs e)
        {
        }

        private void button2_Click(object sender, EventArgs e)
        {
            if (tcpClient1==null)
            {
                tcpClient1 = new TcpClient("127.0.0.1", 8001);
                stream1 = tcpClient1.GetStream();

                // 启动接收数据的线程  
                receiveThread1 = new Thread(new ThreadStart(ReceiveData1));
                receiveThread1.Start();
            }
        }

        private void button3_Click(object sender, EventArgs e)
        {
            if (tcpClient2 == null)
            {
                tcpClient2 = new TcpClient("127.0.0.1", 8002);
                stream2 = tcpClient2.GetStream();

                // 启动接收数据的线程  
                receiveThread2 = new Thread(new ThreadStart(ReceiveData2));
                receiveThread2.Start();
            }
        }


        private void ReceiveData1()
        {
            byte[] buffer = new byte[1024];
            int bytesRead;
            Report Report = new Report();
            Report.Load(System.AppDomain.CurrentDomain.BaseDirectory + @"\成品3030.frx");

            while (tcpClient1.Connected)
                {
                try
                {
                    bytesRead = stream1.Read(buffer, 0, buffer.Length);
                    if (bytesRead == 0)
                    {
                        // 如果没有读取到数据，可能是连接已经关闭  
                        OperateResult.AppendText("8001端口未连接\n", Color.Red);
                        break;
                    }
                    string receivedData = Encoding.Default.GetString(buffer, 0, bytesRead);
                    OperateResult.AppendText("ReceiveData1" + receivedData + "\n", Color.Black);
                    if (pi_inoutno.Text != "" && pb_name.Text != "")
                    {
                        string barcode = receivedData.Replace("A,ReadId1,", "").Replace("~","");
                        string message = "";
                        string prodcode = "";
                        string qty = "";
                        string lotno = "";
                        string[] param = new string[] { barcode, pb_name.Text, message, prodcode , qty, lotno };
                        dh.CallProcedure("SP_BARCODEIO_PARSE",ref param);
                        message = param[2];
                        if (message != "null")
                        {
                            OperateResult.AppendText(message+"\n", Color.Red);
                            SendData1("A,ReadId1,1");
                        }
                        else
                        {
                            prodcode = param[3];
                            qty = param[4];
                            lotno = param[5];
                            dt = (DataTable)dh.ExecuteSql("select * from ( select pd_piid,pd_prodcode,pr_detail,pr_spec,sum(pd_inqty)qty,NVL(PDAQTY,0)PDAQTY from prodiodetail left join SCM_BARCODEIO_IN_VIEW2 on pd_piid = bi_piid and pd_prodcode = bi_prodcode " +
                                "       left join product on pd_prodcode = pr_code where pd_inoutno ='"+pi_inoutno.Text+"' group by pd_piid,pd_prodcode,pr_detail,pr_spec,PDAQTY " +
                                "      ) where pd_prodcode = '"+prodcode+"' and qty-pdaqty >="+qty+" ", "select");
                            if (dt.Rows.Count > 0)
                            {
                                string code = "";
                                string[] param1 = new string[] { "","", code };
                                dh.CallProcedure("SP_GETBARCODE", ref param1);
                                code = param1[2].Replace("BARCODE:","");
                                dh.ExecuteSql(" insert into barcodeio(bi_id,bi_barcode,bi_piid,bi_piclass,bi_inoutno,bi_prodcode,bi_whcode,bi_inqty,bi_madedate,bi_indate,bi_content)" +
                                    " values (barcodeio_seq.nextval,'"+code+"','"+pi_id.Text+"','"+pi_class.Text+"','"+pi_inoutno.Text+"','"+prodcode+"','"+pi_whcode.Text+"',"+qty+",sysdate,sysdate,'"+barcode+"') ", "insert");
                                LoadGridData();
                                OperateResult.AppendText("条码:"+barcode+"采集成功\n", Color.Green);

                                DataTable dtbarcode = (DataTable)dh.ExecuteSql(" select '"+code+ "' BAN_BARCODE,'"+ dt.Rows[0]["pd_prodcode"].ToString() + "' BAN_PRODCODE" +
                                    " ,'"+ dt.Rows[0]["pr_spec"].ToString() + "' PR_DETAIL,'"+qty+ "' BAN_QTY  from dual ", "select");

                                Report.PrintSettings.ShowDialog = false;
                                Report.PrintSettings.Printer = PrintList.Text;
                                Report.RegisterData(dtbarcode, "VENDORBARCODE_VIEW");
                                Report.GetDataSource("VENDORBARCODE_VIEW").Enabled = true;
                                Report.Print();


                                SendData1("A,ReadId1,0");
                            }
                            else
                            {
                                OperateResult.AppendText("料号:" +prodcode+"数量:"+qty+ "不满足入库需求，无法入库\n", Color.Red);
                                SendData1("A,ReadId1,1");
                            }

                        }

                    }
                    else
                    {
                        OperateResult.AppendText("入库单与品牌不可为空\n", Color.Red);
                        SendData1("A,ReadId1,1");
                    }
                    //Console.WriteLine("Received: {0}", receivedData);
                }
                catch (Exception ex)
                {
                    Console.WriteLine("8001端口异常" + ex.Message + "\n", Color.Red);
                }
            }


            // 清理资源  
            if (stream1 != null)
            {
                stream1.Close();
            }

            if (tcpClient1 != null)
            {
                tcpClient1.Close();
            }
        }

        private void ReceiveData2()
        {
            byte[] buffer = new byte[1024];
            int bytesRead;


                while (tcpClient2.Connected)
                {
                try
                {
                    bytesRead = stream2.Read(buffer, 0, buffer.Length);
                    if (bytesRead == 0)
                    {
                        // 如果没有读取到数据，可能是连接已经关闭  
                        OperateResult.AppendText("8002端口未连接\n", Color.Red);
                        break;
                    }

                    string receivedData = Encoding.Default.GetString(buffer, 0, bytesRead);
                    OperateResult.AppendText("ReceiveData2" + receivedData + "\n", Color.Black);
                    //Console.WriteLine("Received: {0}", receivedData);
                    string barcode = receivedData.Replace("A,ReadId3,", "").Split('~')[0];
                    string code = receivedData.Replace("A,ReadId3,", "").Split('~')[1];
                    if (dh.CheckExist("barcodeio", "bi_barcode = '" + code + "' and bi_content = '" + barcode + "'"))
                    {
                        OperateResult.AppendText("原厂条码:" + barcode + "与内部条码:" + code + "匹配成功\n", Color.Green);
                        SendData2("A,ReadId3,0");
                    }
                    else
                    {
                        OperateResult.AppendText("原厂条码:"+barcode+"与内部条码:"+code+"匹配失败\n", Color.Red);
                        SendData2("A,ReadId3,1");
                    }
                }
                catch (Exception ex)
                {
                   OperateResult.AppendText("8002端口异常" + ex.Message + "\n", Color.Red);
                }
            }


            // 清理资源  
            if (stream2 != null)
            {
                stream2.Close();
            }

            if (tcpClient2 != null)
            {
                tcpClient2.Close();
            }
        }




        private void SendData1(String data)
        {
            OperateResult.AppendText("SendData1"+data +"\n", Color.Black);
            if (stream1 != null && stream1.CanWrite)
            {
                byte[] buffer = Encoding.Default.GetBytes(data);
                stream1.Write(buffer, 0, buffer.Length);
            }
        }

        private void SendData2(String data)
        {
            OperateResult.AppendText("SendData2"+data + "\n", Color.Black);
            if (stream2 != null && stream2.CanWrite)
            {
                byte[] buffer = Encoding.Default.GetBytes(data);
                stream2.Write(buffer, 0, buffer.Length);
            }
        }

    

        private void DataIn_KeyDown(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter)
            {
                
            }
        }

        private void button1_Click(object sender, EventArgs e)
        {
            Make_BarcodeDetail badcode = new Make_BarcodeDetail(pi_inoutno.Text);
            BaseUtil.SetFormCenter(badcode);
            badcode.ShowDialog();
        }

        private void pb_name_UserControlTextChanged(object sender, EventArgs e)
        {
            if (pb_name.Text != null)
            { 
            SendData1("A,LoadTemplate,{" + pb_name.Text + "}");
           }
        }

        private void button4_Click(object sender, EventArgs e)
        { 
            if (tcpClient3 == null)
            {
                tcpClient3 = new TcpClient("127.0.0.1", 8003);
                stream3 = tcpClient3.GetStream();

                // 启动接收数据的线程  
                receiveThread3 = new Thread(new ThreadStart(ReceiveData3));
                receiveThread3.Start();
            }
        }

        private void ReceiveData3()
        {
           // throw new NotImplementedException();
        }
    }
}