Bplus/ConvertLog/thread/ProcessImport.cs

using ConvertLog.common;
using System;
using System.Data;


namespace ConvertLog.thread
{

    public class ProcessImport : MainThread
    {
        static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(ProcessImport));
        
        public override void Process()
        {
            if (!ConfigData.loadOK) { return; }
            Sleep(10);
            try
            {

                if (ConfigData._ImportQueue.IsEmpty()) return;
                oneImportObj _objImport =(oneImportObj) ConfigData._ImportQueue.Dequeue();
                if(_objImport!=null)
                {
                    int _index=this.GetIndex();
                    ConfigData.threadIsFree[_index] = "0";
                    upload_off(_objImport.importObjList);
                    ConfigData.threadIsFree[_index] = "1";
                    logger.Info("import bunk success");
                }    
                



            }
            catch (Exception ex)
            {
                logger.Info("ProcessImport file total exeption: " + ex.ToString());



            }




        }



        public static void upload_off(List<importObj> _data)
        {
            List<List<string>> DataColumms = new List<List<string>>();
            var v_upload_id = new List<string>();
            var v_upload_detail_id = new List<string>();
            var v_type = new List<string>();
            var v_ticket = new List<string>();
           

            foreach (importObj _obj in _data)
            {
                v_upload_id.Add(_obj.uploadId);
                v_upload_detail_id.Add(_obj.uploadDetailId);
                v_type.Add(_obj.type);
                //v_ticket.Add(_obj.ticket);

                
                v_ticket.Add(_obj.ticket);



            }
            DataColumms.Add(v_upload_id);
            DataColumms.Add(v_upload_detail_id);
            DataColumms.Add(v_type);
            DataColumms.Add(v_ticket);
           

            DataAccess.upload_data("BALANCE_PKG.IMPORT_INSERT", DataColumms);




        }





        


















    }
}