QZHY_CP/MidDataTable/CSendDeviceOrder.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Threading;
using Microsoft.VisualBasic;
using ICommLayer;
using System.Security.Cryptography;
using DBFactory;

namespace MidDataTable
{
    /// <summary>
    /// 20200430�м����ӿ�
    /// �����豸������
    /// �����ߣ�zhangbo
    /// </summary>
    public class CSendDeviceOrder: ISendDeviceOrder
    {
        string _commLayerError;

        public string CommLayerError
        {
            get { return _commLayerError; }
            set { _commLayerError = value; }
        }

        public static DBOperator dbo = CommonClassLib.AppSettings.dbo; //20130510
        public CSendDeviceOrder()
        {
           
        }
        //~CSendDeviceOrder()
        //{
        //   
        //}

        /// <summary>
        /// ����AGV����
        /// </summary>
        /// <param name="MessageIndex">��Ϣ����</param>
        /// <param name="TaskIndex">��������</param>
        /// <param name="Order">AGV������</param>
        /// Ĭ��ȡ�ͻ�
        /// <param name="DeviceIndex">�豸����</param>
        /// <param name="StartX">0</param>
        /// <param name="StartY">0</param>
        /// <param name="StartZ">����ȡ��վ̨����������</param>
        /// <param name="EndX"></param>
        /// <param name="EndY"></param>
        /// <param name="EndZ">�����ͻ�վ̨����������</param>
        /// <returns>����AGV�����Ƿ��ɹ�</returns>
        public bool SendDeviceOrder(int MessageIndex, int TaskIndex, int Order, int DeviceIndex, int StartX, int StartY, int StartZ, int EndX, int EndY, int EndZ)
        {
            StringBuilder sss = new StringBuilder();
           
            DataView valist = dbo.ExceSQL(string.Format("select * from t_monitor_task where F_MonitorIndex={0} and F_Status=0 ", TaskIndex)).Tables[0].DefaultView;
            if (valist.Count == 0)
            {
                _commLayerError = "OPCClient.CSendDeviceOrder.SendDeviceOrder�������󣺲�����"+ TaskIndex +" ��Ӧ�Ŀ���ָ��!";
                return false;
            }
            try
            {
                int fid = Convert.ToInt32(valist[0]["F_ManageTaskIndex"]);
                int mti = Convert.ToInt32(valist[0]["F_ManageTASKKINDINDEX"]);
                
                var dv = dbo.ExceSQL(string.Format("select  * from   agv_task where fid = {0} and agv_task_id = {1}", fid, TaskIndex)).Tables[0].DefaultView;
                if (dv.Count > 0)
                {
                    
                    _commLayerError = "OPCClient.CSendDeviceOrder.SendDeviceOrder�����������м����Ѵ��ڸ�ָ�"+ TaskIndex;
                    return false;
                }

                object ob = new object[11] { fid, TaskIndex, Convert.ToInt32(valist[0]["F_MonitorTaskLevel"]), 0, 0, StartX, EndX, 0,0, "", DateTime.Now.ToString("u")};
                dbo.ExceSQL(string.Format("INSERT INTO agv_task(FID, AGV_TASK_ID,AGV_TASK_LEVEL,PALLET_BARCODE,PALLET_TYPE, START_DEVICE_CODE, FINISH_DEVICE_CODE,AGV_TASK_STATUS, AGV_CODE, ERROR_TEXT, INSERT_TIME,WCS_FLAG) " +
                    "VALUES({0},{1},'{2}','{3}','{4}','{5}','{6}','{7}','{8}','{9}','{10}','0')",
                    fid, TaskIndex, Convert.ToInt32(valist[0]["F_MonitorTaskLevel"]), 0, 0, StartX, EndX, 0, 0, "", DateTime.Now.ToString("u")));//ob


                sss.Remove(0, sss.Length);
                sss.Append("���룺").Append(0).Append("**д��־1").Append("**������" + TaskIndex.ToString())
                    .Append("**��ʼվ̨" + StartX.ToString()).Append("**��ֹվ̨" + EndX.ToString());

                CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "����AGV����","", sss.ToString());
                if (EndX == 22024 || EndX == 22023 || EndX == 22046 || EndX == 22049) 
                {
                    //վ̨�߼��л�
                    dbo.ExceSQL(string.Format("update t_base_device set F_HaveGoods = {0} where F_DeviceIndex = {1}", Convert.ToInt32(mti.ToString() + fid.ToString()), EndX));
                }

                {
                    #region ���ݻ�������AGV���񣬷���ʱ�����ɲ�������

                    int newTaskEnd = EndX; //���������յ�
                    int newTaskStart = GetPilerLocat(newTaskEnd);//������������
                    if (newTaskStart != -1)
                    {
                        Model.MDevice conveyor = Model.CGetInfo.GetDeviceInfo(newTaskEnd);
                        if (conveyor.SplitByte_0 == 0)
                        {
                            var dv2 = dbo.ExceSQL(string.Format("select  * from  agv_task where fid = {0} and agv_task_id = {1}", fid, TaskIndex)).Tables[0].DefaultView;
                            if ( dv2[0]["WCS_FLAG"] == null || dv2[0]["WCS_FLAG"].ToString() == "0" )
                            {
                                if (GetManageTaskCountForStartAndEndDevice(newTaskStart, newTaskEnd) == 0)
                                {
                                    object obb = new object[15] { CGetDeviceState.GetTempManageIdx(), 2, "S-" + valist[0]["F_TxtParam"], 1, 4, 1, 1, 1, "-", newTaskStart, newTaskEnd, "-", 0, DateTime.Now.ToString("u"), 0 };
                                    string strs = string.Format("INSERT INTO T_Manage_Task(FID, F_ManageTaskKindIndex,FPALLETBARCODE,FMANAGETASKTYPE,FCONTROLTASKTYPE, FTASKLEVEL, FSTARTWAREHOUSE,FENDWAREHOUSE, FSTARTCELL, FSTARTDEVICE, FENDDEVICE, FENDCELL, FSTATUS, FBEGTIME, FIntoStepOK)" +
                                        "VALUES({0},{1},'{2}',{3},{4},{5},{6},'{7}','{8}','{9}',{10},'{11}','{12}','{13}','{14}')",
                                        CGetDeviceState.GetTempManageIdx(), 2, "S-" + valist[0]["F_TxtParam"], 1, 4, 1, 1, 1, "-", newTaskStart, newTaskEnd, "-", 0, DateTime.Now.ToString("u"), 0);
                                    dbo.ExceSQL(strs);

                                }

                                dbo.ExceSQL(string.Format("update AGV_TASK set WCS_FLAG = 1 where AGV_TASK_ID = {0}", TaskIndex));
                                CommonClassLib.CCarryConvert.WriteDarkCasket("OPCClient", "AGVȡ��ͬʱ�����ɲ���������", newTaskStart.ToString(), TaskIndex.ToString());

                            }
                        }
                    }
                    #endregion
                }
                return true;
            }
            catch (Exception ex)
            {
                _commLayerError = "OPCClient.CSendDeviceOrder.SendDeviceOrder����������" + ex.Message;
                return false;
            }

        }
        public int GetManageTaskCountForStartAndEndDevice(int start, int end)
        {
            DataView dv = new DataView();
            string sql = string.Empty;
            try
            {

                {
                    sql = string.Format("SELECT * FROM T_Manage_Task WHERE FSTARTDEVICE = '{0}' and FENDDEVICE = '{1}' ",
                                                                    start, end);
                }
                dv = dbo.ExceSQL(sql).Tables[0].DefaultView;

                return dv.Count;
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                dv.Dispose();
            }

        }
        //���������ߣ����ز����̻����������ߵ�λ��
        public int GetPilerLocat(int device)
        {
            DataView valist = dbo.ExceSQL(string.Format("select * from T_Base_PLC_Ask where F_DeviceIndex = {0} and F_Askkind = 9", device)).Tables[0].DefaultView;


            if (valist.Count > 0)
            {
                return Convert.ToInt32(valist[0]["F_TempFirstProject"]);
            }
            else
            {
                return -1;
            }


        }
        public bool SendDeviceOrder(int MessageIndex, int TaskIndex, int Order, int DeviceIndex, int ArrowDeviceIndex)
        {
            return true;
        }
        public bool SendDeviceOrder(int MessageIndex, int TaskIndex, int Order, int DeviceIndex, int StartX, int StartY, int StartZ, int EndX, int EndY, int EndZ, string DoubleFork)
        {
            return true;

        }
        public bool SendDeviceOrder(int DeviceIndex, string TobaccoCode, bool HaveFirstProjectCode, bool IfSmallTobacco, int Count)
        {
            return true;
        }
        public bool WriteDBData(StringBuilder[] ItemNames, StringBuilder[] ItemValues)
        {
            return true;
        }
        public bool WriteDBData(StringBuilder[] ItemNames, StringBuilder[] ItemValues, string PLCconnectionID)
        {
            return true;
        }
    }
}