erp/ecomServer/MainForm.cs

using BizCom;
using Castle.ActiveRecord;
using Castle.ActiveRecord.Framework.Config;
using Newtonsoft.Json;
using NHibernate.Hql.Ast.ANTLR.Tree;
using NHibernate.Mapping;
using SiteCore;
using SiteCore.Handler;
using SiteCore.taobao;
using SiteCore.taoObj;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Management;
using System.Net;
using System.Runtime.InteropServices;
using System.Security.Cryptography;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using Utils;
using static Castle.ActiveRecord.Framework.DictionaryAdapter;
using static SiteCore.taoObj.dataShopResponseVo;

namespace ErpServer
{
    public partial class MainForm : Form
    {
        private static readonly string iniFile = Application.StartupPath + "\\config.ini";
        private static readonly string logPath = Application.StartupPath + "\\log";

        #region hideform
        [DllImport("user32.dll")]
        public static extern Int32 GetWindowLong(IntPtr hwnd, Int32 index);
        [DllImport("user32.dll")]
        public static extern Int32 SetWindowLong(IntPtr hwnd, Int32 index, Int32 newValue);
        public const int GWL_EXSTYLE = (-20);
        private static void AddWindowExStyle(IntPtr hwnd, Int32 val)
        {
            int oldValue = GetWindowLong(hwnd, GWL_EXSTYLE);
            if (oldValue == 0)
            {
                throw new System.ComponentModel.Win32Exception();
            }
            if (0 == SetWindowLong(hwnd, GWL_EXSTYLE, oldValue | val))
            {
                throw new System.ComponentModel.Win32Exception();
            }
        }
        public static int WS_EX_TOOLWINDOW = 0x00000080;
        //我把这个过程封装下：
        public static void SetFormToolWindowStyle(Form form)
        {
            AddWindowExStyle(form.Handle, WS_EX_TOOLWINDOW);
        }
        #endregion

        public MainForm()
        {
            InitializeComponent();
        }

        private void initActiveRecord()
        {
            //IConfigurationSource source = ConfigurationManager.GetSection("activerecord") as IConfigurationSource;
            InPlaceConfigurationSource source = new InPlaceConfigurationSource();
            System.Collections.Generic.IDictionary<string, string> properties = new System.Collections.Generic.Dictionary<string, string>();
            properties.Add("connection.driver_class", "NHibernate.Driver.SqlClientDriver");
            properties.Add("proxyfactory.factory_class", "NHibernate.ByteCode.Castle.ProxyFactoryFactory,NHibernate.ByteCode.Castle");
            properties.Add("dialect", "NHibernate.Dialect.MsSql2005Dialect");
            properties.Add("connection.provider", "NHibernate.Connection.DriverConnectionProvider");
            string conn = ConfigurationManager.ConnectionStrings["ConnStr"].ConnectionString;
            properties.Add("connection.connection_string", conn);
            source.Add(typeof(ActiveRecordBase), properties);
            Type[] acTypes = new[]
                            {
                                 typeof(XUser),
                                 typeof(XModular),
                                 typeof(CeErpModular),
                                 typeof(CeErpUser),
                                 typeof(CeErpPost),
                                 //typeof(CeErpPersonPost),
                                 typeof(CeErpUserInfo),
                                 typeof(CeErpOrganization),
                                 typeof(CeErpShop),
                                 typeof(CeErpSupplier),
                                 typeof(CeErpProduct),
                                 typeof(CeErpProductHour),
                                 typeof(CeErpSupplierProduct),
                                 typeof(CeErpTrade),
                                 typeof(CeErpTradeOrder),
                                 typeof(CeErpTradeCell),
                                 typeof(CeErpTradeLog),
                                 typeof(CeErpTradeResponsible),
                                 typeof(CeErpTradeRefund),
                                 typeof(CeErpTradeSample),
                                 typeof(CeErpBill),
                                 typeof(CeErpReturnCash),
                                 typeof(CeErpExpressInfo),
                                 typeof(CeErpUserPost),
                                 typeof(CeErpZhangDan),
                                 typeof(CeErpInvoicingInfo),
                                 typeof(CeErpCustomer),
                                 typeof(CeErpTmcLog),
                                 typeof(XPermission),
                                 typeof(XLog),
                                 typeof(CeErpMessageTip),
                                 typeof(CeErpSpecialRefund),
                                 typeof(CEErpPrintModel),
                                 typeof(CeErpProductPrice),
                                 typeof(CeErpDesignerBill),
                                 typeof(CeErpOrderFormData ),
                                 typeof(CeErpDesignerFinishRateNew),
                                 typeof(CeErpDesignerBillLog),
                                 typeof(CeErpTradeAfterSaleExtend),
                                 typeof(CeErpDataSendOrderInfo),
                                 typeof(CeErpDesignInfo),
                                 typeof(shopInfo),
                                 typeof(CeErpTradeCellExtend),
                                 typeof(CeErpTradeSpu),
                                 typeof(CeErpSukuraData),
                                 typeof(CeErpTradeAfterSaleLog)

                             };
            ActiveRecordStarter.Initialize(source, acTypes);
            //ActiveRecordStarter.Initialize(Assembly.GetExecutingAssembly(), source);
        }


        int tb_err = 0;
        int bu_err = 0;
        int pre_err = 0;
        int sd_err = 0;
        int refund_tb_err = 0;
        int refund_bu_err = 0;
        HttpHelper http = null;
        TimerCallback syncTaoBaoBack = null;
        TimerCallback syncPreBack = null;
        TimerCallback syncSdBack = null;
        TimerCallback syncRefundTB = null;
        System.Threading.Timer disTimer = null;
        System.Threading.Timer preTimer = null;
        System.Threading.Timer sdTimer = null;
        System.Threading.Timer refundDisTimer = null;
        string paidanSync = "";
        string dinggaolvSync = "";
        string unusualSync = "";
        string refundSync = "";

        private void MainForm_Load(object sender, EventArgs e)
        {
            SetFormToolWindowStyle(this);
            CheckForIllegalCrossThreadCalls = false;

            this.SetVisibleCore(false);

            if (!Directory.Exists(logPath)) Directory.CreateDirectory(logPath);

            http = new HttpHelper();
            //siteUrl = INI.GetIniValue("Config", "siteUrl", iniFile);
            //apiUrl = INI.GetIniValue("Config", "apiUrl", iniFile);
            //siteProcUser = INI.GetIniValue("Config", "siteProcUser", iniFile);

            helper.clearLog();
            //设置数据库连接
            SqlHelper.connString = webConfig.ConnStr;

            if (SqlHelper.connString == null || SqlHelper.connString == "")
            {
                helper.writeLog("没有数据库连接无法执行");
                return;
            }

            initActiveRecord();

            /****淘宝同步***/
            string taobaoSync = INI.GetIniValue("Config", "tbSync", iniFile);
            if (taobaoSync == "1")
            {
                helper.writeLog("淘宝同步");
                syncTaoBaoBack = new TimerCallback(syncTaoBaoCall);
                disTimer = new System.Threading.Timer(syncTaoBaoBack, null, 3000, 3000);
                syncPreBack = new TimerCallback(syncPreCall);
                preTimer = new System.Threading.Timer(syncPreBack, null, 3000, 3000);
                syncSdBack = new TimerCallback(syncSdCall);
                sdTimer = new System.Threading.Timer(syncSdBack, null, 3000, 3000);

            }

            //****售后退款推送同步****/
            string refundTBSync = INI.GetIniValue("Config", "refundTbSync", iniFile);
            if (refundTBSync == "1")
            {
                helper.writeLog("淘宝退款同步");
                syncRefundTB = new TimerCallback(syncRefundTaoBaoCall);
                refundDisTimer = new System.Threading.Timer(syncRefundTB, null, 80000, 80000);
            }

            paidanSync = INI.GetIniValue("Config", "paidanSync", iniFile);
            dinggaolvSync = INI.GetIniValue("Config", "dinggaolvSync", iniFile);
            unusualSync = INI.GetIniValue("Config", "unusualSync", iniFile);
            refundSync = INI.GetIniValue("Config", "refundSync", iniFile);

            string APP_NAME = INI.GetIniValue("Global", "AppName", iniFile);
            notifyIcon.Text = APP_NAME + "";
            this.Text = APP_NAME + "";


            System.Timers.Timer pTimer = new System.Timers.Timer(60000);
            pTimer.Elapsed += PTimer_Elapsed;
            pTimer.AutoReset = true;//获取该定时器自动执行
            pTimer.Enabled = true;//这个一定要写，要不然定时器不会执行的

            helper.writeLog(APP_NAME + "服务端启动");
            AppendLog(APP_NAME + "服务端启动");

        }

        private void PTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            int intHour = e.SignalTime.Hour;
            int intMinute = e.SignalTime.Minute;
            string im = intMinute.ToString();
            string hm = e.SignalTime.ToString("HH:mm");
            WriteLog(string.Format("自动派单：" + paidanSync));
            if (paidanSync == "1")//自动派单
            {
                WriteLog(string.Format("自动派单：" + hm));
                disTimerCall(null);
                syncDataSendOrder();
                sendOrderInfo();
                connetUrl();
            }
            if (intHour == 2 && intMinute == 0)
            {
                dayClearTimerCall(null);
                helper.clearLog();
            }
            if (dinggaolvSync == "1")
            {
                if (intHour == 2 && intMinute % 10 == 0 && intMinute < 41)
                {
                    commonHelper.saveErpDesignerGather();
                }
            }
            if (unusualSync == "1")
            {
                if (intMinute == 1)
                {
                    unUsualOrderTimerCall(null);
                }
            }
            if (refundSync == "1")
            {
                if (intMinute == 2)
                {
                    reFundsDataTimerCall(null);
                }
            }
            if (intMinute > 0 && intMinute % 10 != 0)
            {
                syncBuChaJiaCall();
            }
        }
        bool buchaPop = false;
        /// <summary>
        /// 补差价
        /// </summary>
        private void syncBuChaJiaCall()
        {
            if (buchaPop) return;
            WriteLog(string.Format("开始补差"));
            buchaPop = true;
            new Thread(new ThreadStart(delegate ()
            {
                try
                {
                    string sql = "select top 100 * from s_buchajia order by addtime asc";
                    DataTable dt = SqlHelper.ExecuteDataset(sql).Tables[0];
                    if (dt == null || dt.Rows.Count < 1)
                    {
                        buchaPop = false;
                        return;
                    }
                    List<string> idLst = new List<string>();
                    foreach (DataRow dr in dt.Rows)
                    {
                        idLst.Add(dr["ID"].ToString());
                        while (true)
                        {
                            try
                            {
                                switch (dr["dotype"].ToString().ToLower().Trim())
                                {
                                    case "updatestate_close":
                                        {
                                            sql = "update CE_ErpTradeCell WITH(ROWLOCK) set OrderState=" + dr["orderstate"] + ",IsUrgency=0,isReturn=0,isRefund=2 where tid='" + dr["ctid"] + "' and isAfterSaleOrder=0";
                                            SqlHelper.ExecuteNonQuery(sql);
                                            break;
                                        }
                                    case "updatestate_complete":
                                        {
                                            //sql.AppendFormat("update ce_ErpTradeCell set OrderState={1},IsUrgency=0 where IsPreDelivery=0 and tid='{0}' and SplitTag='' and isAfterSaleOrder=0;", tObj.refOid, (int)OrderState.交易完成);
                                            //拆分单更新，只有下单完成的才更新成已发货已完成
                                            //sql.AppendFormat("update ce_ErpTradeCell set OrderState={1},IsUrgency=0 where IsPreDelivery=0 and tid='{0}' and SplitTag!='' and OrderState>5 and isAfterSaleOrder=0;", tObj.refOid, (int)OrderState.交易完成);
                                            sql = "update CE_ErpTradeCell WITH(ROWLOCK) set OrderState=" + dr["orderstate"] + ",IsUrgency=0,isReturn=0 where tid='" + dr["ctid"] + "' and IsPreDelivery=0  and SplitTag='' and isAfterSaleOrder=0 ;";
                                            sql += "update CE_ErpTradeCell WITH(ROWLOCK) set OrderState=" + dr["orderstate"] + ",IsUrgency=0,isReturn=0 where tid='" + dr["ctid"] + "' and IsPreDelivery=0  and SplitTag!='' and OrderState>6 and isAfterSaleOrder=0 ;";
                                            SqlHelper.ExecuteNonQuery(sql);
                                            break;
                                        }
                                    case "updatestate_shipped":
                                        {
                                            sql = "update CE_ErpTradeCell WITH(ROWLOCK) set OrderState=" + dr["orderstate"] + ",IsUrgency=0,isReturn=0  where tid='" + dr["ctid"] + "' and IsPreDelivery=0  and SplitTag='' and isAfterSaleOrder=0 ;";
                                            sql += "update CE_ErpTradeCell WITH(ROWLOCK) set OrderState=" + dr["orderstate"] + ",IsUrgency=0,isReturn=0  where tid='" + dr["ctid"] + "' and IsPreDelivery=0  and SplitTag!='' and OrderState>6 and isAfterSaleOrder=0 ;";
                                            SqlHelper.ExecuteNonQuery(sql);
                                            break;
                                        }
                                    case "refund":
                                        {
                                            if (Convert.ToInt32(dr["refundState"]) == 1)
                                            {
                                                sql = "update CE_ErpTradeCell WITH(ROWLOCK) set IsRefund=" + dr["refundState"] + ",IsReadTag=2  where isAfterSaleOrder=0 and tid='" + dr["ctid"] + "'";
                                            }
                                            else
                                                sql = "update CE_ErpTradeCell WITH(ROWLOCK) set IsRefund=" + dr["refundState"] + " where isAfterSaleOrder=0 and tid='" + dr["ctid"] + "'";
                                            SqlHelper.ExecuteNonQuery(sql);
                                            break;
                                        }
                                    case "billres":
                                        {
                                            commonHelper.checkBillResult(Convert.ToInt32(dr["ctid"]));
                                            break;
                                        }
                                    case "bucha_delivery":
                                        {
                                            commonHelper.setBuChaDelivery(dr["ctid"].ToString(), dr["poscode"].ToString(), dr["comcode"].ToString(), dr["outSid"].ToString());
                                            break;
                                        }
                                    default:
                                        {
                                            DataTable dataTable = SqlHelper.ExecuteDataset(string.Format("SELECT orderFrom FROM [dbo].[Ce_ErpTradeCellExtend] WHERE ctid = '{0}'", dr["ctid"].ToString())).Tables[0];
                                            int num = 0;
                                            if (dataTable!= null && !Convert.IsDBNull(dataTable.Rows[0]["orderFrom"]))
                                            {
                                                num = Convert.ToInt16(dataTable.Rows[0]["orderFrom"]);
                                            }
                                            SqlParameter[] sqlParameter ={
                                            new SqlParameter("@mainctids", SqlDbType.VarChar,200),
                                            new SqlParameter("@res", SqlDbType.VarChar, 4000) };
                                            sqlParameter[0].Value = dr["ctid"].ToString();
                                            sqlParameter[1].Direction = ParameterDirection.Output;
                                            if (num == 30)
                                            {
                                                SqlHelper.ExecuteNonQueryStoreWithTimeOut("sp_set_bucha_ctid", sqlParameter, 10);
                                            }
                                            else
                                            {
                                                SqlHelper.ExecuteNonQueryStoreWithTimeOut("sp_set_bucha", sqlParameter, 10);
                                            }

                                            break;
                                        }
                                }
                                bu_err = 0;
                                break;
                            }
                            catch (Exception ex)
                            {
                                idLst.Remove(dr["ID"].ToString());
                                if (ex.Message.IndexOf("死锁") != -1)
                                {
                                    bu_err++;
                                    helper.writeLog("buchajia,死锁了,继续执行");
                                    Thread.Sleep(1000);
                                }
                                else
                                {
                                    XLog.SaveLog(0, "syncBuChaJiaCall------" + ex.Message);
                                    break;
                                }
                            }
                        }
                    }
                    if (idLst.Count > 0)
                    {
                        sql = "delete from s_buchajia where id in (" + string.Join(",", idLst.ToArray()) + ") ;";
                        SqlHelper.ExecuteNonQuery(sql);
                        helper.writeLog("补差价调整完成" + idLst.Count);
                    }
                }
                catch (Exception ex)
                {
                    XLog.SaveLog(0, "syncBuChaJiaCall" + ex.Message);
                }
                buchaPop = false;
            })).Start();
        }


        /// <summary>
        /// 分解数据表
        /// </summary>
        /// <param name="originalTab">需要分解的表</param>
        /// <param name="rowsNum">每个表包含的数据量</param>
        /// <returns></returns>
        public DataSet SplitDataTable(DataTable originalTab, int rowsNum)
        {
            //获取所需创建的表数量
            if (rowsNum == 0)
            {
                rowsNum = 1;
            }
            int tableNum = originalTab.Rows.Count / rowsNum;

            //获取数据余数
            int remainder = originalTab.Rows.Count % rowsNum;

            DataSet ds = new DataSet();

            //如果只需要创建1个表，直接将原始表存入DataSet
            if (tableNum == 0)
            {
                if (originalTab.Rows.Count == 0)
                {
                    ds.Tables.Add(new DataTable());
                }
                else
                {
                    ds.Tables.Add(originalTab);
                }
            }
            else
            {
                DataTable[] tableSlice = new DataTable[tableNum];

                //Save orginal columns into new table.
                for (int c = 0; c < tableNum; c++)
                {
                    tableSlice[c] = new DataTable();
                    foreach (DataColumn dc in originalTab.Columns)
                    {
                        tableSlice[c].Columns.Add(dc.ColumnName, dc.DataType);
                    }
                }
                //Import Rows
                for (int i = 0; i < tableNum; i++)
                {
                    // if the current table is not the last one
                    if (i != tableNum - 1)
                    {
                        for (int j = i * rowsNum; j < ((i + 1) * rowsNum); j++)
                        {
                            tableSlice[i].ImportRow(originalTab.Rows[j]);
                        }
                    }
                    else
                    {
                        for (int k = i * rowsNum; k < ((i + 1) * rowsNum + remainder); k++)
                        {
                            tableSlice[i].ImportRow(originalTab.Rows[k]);
                        }
                    }
                }

                //add all tables into a dataset
                foreach (DataTable dt in tableSlice)
                {
                    ds.Tables.Add(dt);
                }
            }
            return ds;
        }

        bool isGet = false;
        int tbt_count = 0;
        int tbt_max = 0;
        private void syncTaoBaoCall(object obj)
        {
            if (isGet) return;
            isGet = true;
            try
            {
                string sql = "select top 200 * from S_TaoBaoTmc2 order by id asc";
                DataTable dt = SqlHelper.ExecuteDataset(sql).Tables[0];
                if (dt != null && dt.Rows.Count > 0)
                {
                    taobaoThread(dt);
                }
                //DataSet ds = SplitDataTable(dt,100);
                //tbt_count = 0;
                //tbt_max = ds.Tables.Count;
                //for (int i = 0; i < tbt_max; i++)
                //{
                //    ThreadPool.QueueUserWorkItem(stat => {
                //        taobaoThread(stat);
                //    }, ds.Tables[i]);
                //}
                //while (tbt_count < tbt_max)
                //{
                //    Thread.Sleep(1000);
                //}
                //helper.writeLog("整批同步完成!!");

            }
            catch (Exception ex)
            {
                XLog.SaveLog(0, "syncTaoBaoCall" + ex.Message);
            }
            finally
            {
                isGet = false;
            }
        }

        private void taobaoThread(object _dt)
        {
            try
            {
                DataTable dt = (DataTable)_dt;
                List<string> idLst = new List<string>();
                helper.writeLog(dt.Rows[0]["id"].ToString());
                foreach (DataRow dr in dt.Rows)
                {
                    idLst.Add(dr["id"].ToString());
                    while (true)
                    {
                        if (tb_err >= 15)
                        {
                            Environment.Exit(0);
                            return;
                        }
                        try
                        {
                            tmcHelper.Api_TmcTradeMsg(dr["message"].ToString());
                            tb_err = 0;
                            break;
                        }
                        catch (Exception ex)
                        {
                            if (ex.Message.IndexOf("死锁") != -1)
                            {
                                tb_err++;
                                helper.writeLog("同步死锁了,继续执行");
                                Thread.Sleep(1000);
                            }
                            else
                            {
                                XLog.SaveLog(0, dr["message"].ToString() + "------" + ex.Message);
                                break;
                            }
                        }
                    }
                }
                if (idLst.Count > 0)
                {
                    string sql = "delete from S_TaoBaoTmc2 where id in (" + string.Join(",", idLst.ToArray()) + ") ;";
                    SqlHelper.ExecuteNonQuery(sql);
                    helper.writeLog("同步完成" + idLst.Count);
                }
            }
            catch (Exception ex) { }
            finally
            {
                tbt_count++;
            }
        }

        bool preIsGet = false;
        private void syncPreCall(object obj)
        {
            if (preIsGet) return;
            preIsGet = true;
            string sql = "select top 200 * from CE_ErpPreRequestData order by id asc";
            DataTable dt = SqlHelper.ExecuteDataset(sql).Tables[0];

            try
            {
                if (dt != null && dt.Rows.Count > 0)
                {
                    List<string> idLst = new List<string>();
                    helper.writeLog(dt.Rows[0]["id"].ToString());
                    foreach (DataRow dr in dt.Rows)
                    {
                        idLst.Add(dr["id"].ToString());
                        while (true)
                        {
                            if (pre_err >= 15)
                            {
                                Environment.Exit(0);
                                return;
                            }
                            try
                            {
                                preSalesHelper.dealMessageInfo(dr["data"].ToString());
                                pre_err = 0;
                                break;
                            }
                            catch (Exception ex)
                            {
                                if (ex.Message.IndexOf("死锁") != -1)
                                {
                                    pre_err++;
                                    helper.writeLog("同步死锁了,继续执行");
                                    Thread.Sleep(1000);
                                }
                                else
                                {
                                    XLog.SaveLog(0, dr["message"].ToString() + "------" + ex.Message);
                                    break;
                                }
                            }
                        }
                    }
                    if (idLst.Count > 0)
                    {
                        SqlHelper.ExecuteNonQuery("delete from CE_ErpPreRequestData where id in (" + string.Join(",", idLst) + ") ;");
                        helper.writeLog("同步完成" + idLst.Count);
                    }
                }
            }
            catch (Exception e)
            {

            }
            finally
            {
                preIsGet = false;
            }
        }
        bool sdIsGet = false;
        private void syncSdCall(object obj)
        {
            if (sdIsGet) return;
            sdIsGet = true;
            string sql = "select top 200 * from CE_ErpShengdaRequestData order by id asc";
            DataTable dt = SqlHelper.ExecuteDataset(sql).Tables[0];

            try
            {
                if (dt != null && dt.Rows.Count > 0)
                {
                    List<string> idLst = new List<string>();
                    helper.writeLog(dt.Rows[0]["id"].ToString());
                    foreach (DataRow dr in dt.Rows)
                    {
                        idLst.Add(dr["id"].ToString());
                        while (true)
                        {
                            if (sd_err >= 15)
                            {
                                Environment.Exit(0);
                                return;
                            }
                            try
                            {
                                apiShengda.dealData(dr["signature"].ToString(), dr["timestamp"].ToString(), dr["nonce"].ToString(), dr["encrypt"].ToString());
                                sd_err = 0;
                                break;
                            }
                            catch (Exception ex)
                            {
                                if (ex.Message.IndexOf("死锁") != -1)
                                {
                                    sd_err++;
                                    helper.writeLog("盛大同步死锁了,继续执行");
                                    Thread.Sleep(1000);
                                }
                                else
                                {
                                    XLog.SaveLog(0, dr["message"].ToString() + "------" + ex.Message);
                                    break;
                                }
                            }
                        }
                    }
                    if (idLst.Count > 0)
                    {
                        SqlHelper.ExecuteNonQuery("delete from CE_ErpShengdaRequestData where id in (" + string.Join(",", idLst) + ") ;");
                        helper.writeLog("盛大同步完成" + idLst.Count);
                    }
                }
            }
            catch (Exception e)
            {

            }
            finally
            {
                sdIsGet = false;
            }
        }

        bool refundisGet = false;
        int refund_tbt_count = 0;
        int refundtbt_max = 0;
        private void syncRefundTaoBaoCall(object obj)
        {
            if (refundisGet) return;
            refundisGet = true;
            try
            {
                string sql = "select top 50 * from S_RefundTmc order by id asc";
                DataTable dt = SqlHelper.ExecuteDataset(sql).Tables[0];
                if (dt != null && dt.Rows.Count > 0)
                {
                    refundTaobaoThread(dt);
                }
            }
            catch (Exception ex)
            {
                XLog.SaveLog(0, "syncRefundTaoBaoCall" + ex.Message);
            }
            finally
            {
                refundisGet = false;
            }
        }

        private void refundTaobaoThread(object _dt)
        {
            try
            {
                DataTable dt = (DataTable)_dt;
                List<string> idLst = new List<string>();
                helper.writeLog(dt.Rows[0]["id"].ToString());
                foreach (DataRow dr in dt.Rows)
                {
                    idLst.Add(dr["id"].ToString());
                    while (true)
                    {
                        if (refund_tb_err >= 15)
                        {
                            Environment.Exit(0);
                            return;
                        }
                        try
                        {
                            refundTmcHelper.Api_TmcRefundMsg(dr["message"].ToString());
                            refund_tb_err = 0;
                            break;
                        }
                        catch (Exception ex)
                        {
                            if (ex.Message.IndexOf("死锁") != -1)
                            {
                                refund_tb_err++;
                                helper.writeLog("同步死锁了,继续执行");
                                Thread.Sleep(1000);
                            }
                            else
                            {
                                XLog.SaveLog(0, dr["message"].ToString() + "------" + ex.Message);
                                break;
                            }
                        }
                    }
                }
                if (idLst.Count > 0)
                {
                    string sql = "delete from S_RefundTmc where id in (" + string.Join(",", idLst.ToArray()) + ") ;";
                    SqlHelper.ExecuteNonQuery(sql);
                    helper.writeLog("退款同步完成" + idLst.Count);
                }
            }
            catch (Exception ex) { }
            finally
            {
                refund_tbt_count++;
            }
        }


        bool disPop = false;
        /// <summary>
        /// 自动派单
        /// </summary>
        /// <param name="obj"></param>
        private void disTimerCall(object obj)
        {
            if (disPop) return;
            DateTime nowTime = DateTime.Now;
            if (nowTime.Minute % 10 != 0)//超出时间
            {
                disPop = false;
                return;
            }
            disPop = true;
            new Thread(new ThreadStart(delegate ()
            {
                try
                {
                    WriteLog(string.Format("自动派单设计共创"));
                    string sql1 = "select ID, Name, DayOrderReceive, pemDesign, pemShop, DayOrderLimit,OldOrder from view_ErpUser where Name='设计共创'";
                    DataTable dt1 = SqlHelper.ExecuteDataset(sql1).Tables[0];
                    int ID = Convert.ToInt32(dt1.Rows[0]["ID"]);
                    bool OldOrder = Convert.ToBoolean(dt1.Rows[0]["OldOrder"]);
                    string design_sql = string.Format("select * from Ce_ErpDesignInfo where designId > 0 and tarId={0}", 3542);
                    DataTable design_dt = SqlHelper.ExecuteDataset(design_sql).Tables[0];
                    DateTime selfTime = DateTime.Now;
                    Dictionary<string, List<string>> shop_orders = new Dictionary<string, List<string>>();
                    foreach (DataRow row in design_dt.Rows)
                    {
                        List<string> designIds = null;

                        if (shop_orders.ContainsKey(row["shopId"].ToString()))
                        {
                            shop_orders.TryGetValue(row["shopId"].ToString(), out designIds);
                        }
                        else
                        {
                            designIds = new List<string>();

                        }
                        designIds.Add(row["designId"].ToString());
                        shop_orders[row["shopId"].ToString()] = designIds;
                    }

                    StringBuilder sql2 = new StringBuilder();
                    sql2.AppendFormat("select ctid ,shopId,productId from view_ErpTradeCell where orderstate=2 and  designuserid=0  and payment>0 and isrefund=0 and productId>0 and shopId>0 ");
                    if (!OldOrder)
                    {
                        sql2.AppendFormat(" and IsOldCustomer != 1 ");
                    }
                    sql2.AppendFormat(" order by IsUrgency desc,pay_time asc ");
                    DataTable dth = SqlHelper.ExecuteDataset(sql2.ToString()).Tables[0];
                    foreach (DataRow dr in dth.Rows)
                    {
                        try
                        {


                            List<string> designIds = null;

                            if (!shop_orders.ContainsKey(dr["shopId"].ToString()))
                            {
                                continue;
                            }
                            shop_orders.TryGetValue(dr["shopId"].ToString(), out designIds);
                            if (designIds == null || designIds.Count == 0)
                            {
                                continue;
                            }
                            if (!designIds.Contains(dr["productId"]))
                            {
                                continue;
                            }

                            CeErpTradeCell ce = CeErpTradeCell.GetByCtid(dr["ctid"].ToString());

                            designApiResponseVo response = designHelper.API_GetPrintData_CreateOrder(ce, "");
                            if (response.code != 200)
                            {
                                continue;
                            }


                            if (response.msg == "设计共创：成功")
                            {
                                ce.OrderState = Convert.ToInt32(OrderState.待设计);
                                ce.DesignUserId = 3542;
                                ce.WaitDesignTime = DateTime.Now;
                                ce.DispatchSort = 2;
                                ce.Update();

                            }
                            addLog(dr["ctid"].ToString(), 3542, "自动派单:" + response.msg, Convert.ToInt32(OrderState.待抢单));
                        }
                        catch (Exception ex)
                        {
                            WriteLog(string.Format("共创派单出错 | {0} | {1}", DateTime.Now.ToString(), dr["ctid"].ToString() + ex.Message.ToString()));
                        }
                    }
                    bool isStart = false;
                    string syncType = "normal";
                    if (selfTime.Hour > 6 && selfTime.Hour < 9 || (selfTime.Hour == 6 && selfTime.Minute >= 30))
                    {
                        DataTable dt = SqlHelper.ExecuteDataset("SELECT count(*) as number FROM [dbo].[view_ErpUser] WHERE ID in (33,36) and  OnDuty > 0 ").Tables[0];
                        if (dt != null && dt.Rows.Count > 0 && Convert.ToInt32(dt.Rows[0]["number"]) > 0)
                        {
                            isStart = true;
                            syncType = "wx";
                        }
                    }
                    else if (selfTime.Hour >= 9 && selfTime.Hour <= 21 && !(selfTime.Hour == 9 && selfTime.Minute < 10))
                    {
                        isStart = true;
                    }
                    //开始派单状态
                    if (isStart)
                    {

                        string sql = "select tid,ctid,IsOldCustomer,shopid,payment,ProductId,isDianziOrder from view_ErpTradeCell where orderstate=2 and productid<>0 and designuserid=0  and payment>0 and isrefund=0 order by IsUrgency DESC, YEAR ( pay_time ), MONTH ( pay_time ), DAY ( pay_time ), payment DESC;";
                        DataTable dt = SqlHelper.ExecuteDataset(sql).Tables[0];
                        //object result = SqlHelper.ExecuteScalar(sql);
                        if (dt != null && dt.Rows.Count > 0)
                        {
                            bool changeBl = false;
                            //int c = Convert.ToInt32(result);// / 20 + 1;
                            WriteLog(string.Format("派单 | {0} | {1}", DateTime.Now.ToString(), "开始自动派单！" + dt.Rows.Count));
                            int i = 0;
                            foreach (DataRow dr in dt.Rows)
                            {
                                i++;
                                //能派往系统的不派内部
                                designApiResponseVo result = null;

                                try
                                {
                                    if (nowTime.Hour > 12 && nowTime.Hour < 17)
                                    {
                                        //这段时间白班晚班平均分配
                                        if (changeBl)
                                        {
                                            changeBl = false;
                                        }
                                        else
                                        {
                                            changeBl = true;
                                        }

                                    }
                                    else
                                        changeBl = false;
                                    string IsOldCustomer = dr["IsOldCustomer"].ToString();
                                    string isDianziOrder = dr["isDianziOrder"].ToString();
                                    string res = "";
                                    int ProductId = Convert.ToInt32(dr["ProductId"]);
                                    CeErpShop ceErpShop = CeErpShop.Get(dr["shopid"]);
                                    int userId = 0;
                                    if (ceErpShop != null)
                                    {
                                        userId = ceErpShop.UserID;
                                    }
                                    SqlParameter[] sqlParameter = {
                                    new SqlParameter("@inctid", SqlDbType.VarChar,200),
                                    new SqlParameter("@intype", SqlDbType.Int,5),
                                    new SqlParameter("@nowtime", SqlDbType.VarChar,200),
                                    new SqlParameter("@res", SqlDbType.VarChar, 50) };
                                    sqlParameter[0].Value = dr["ctid"].ToString();
                                    sqlParameter[1].Value = changeBl ? 1 : 0;
                                    sqlParameter[2].Value = nowTime.ToString();
                                    sqlParameter[3].Direction = ParameterDirection.Output;
                                    if (isDianziOrder == "1")
                                    {
                                        continue;
                                    }
                                    int[] uv_productIds = new int[] { 14, 43, 2487, 2531, 2654, 2656 };
                                    //指定店铺老客户和指定店铺单价500以上分给指定部门
                                    if (!uv_productIds.Contains(ProductId) && ((IsOldCustomer == "1" && userId == 241) || (userId == 241 && Convert.ToDouble(dr["payment"]) >= 500)))
                                    {
                                        //手绘   logo  画册 海报  宣传单
                                        if ((IsOldCustomer == "1" && (ProductId == 28 || ProductId == 57 || ProductId == 40 || ProductId == 4 || ProductId == 13)))
                                        {
                                            result = commonHelper.checkOrderListDesignInfo(dr["tid"].ToString(), dr["ctid"].ToString());
                                            if (result != null && result.code == 200)
                                            {
                                                continue;
                                            }
                                            int ceErpTradeLogg = CeErpTradeLog.GetByTidAndStatus(dr["ctid"].ToString(), Convert.ToInt32(OrderState.待设计));
                                            if (ceErpTradeLogg == 0)
                                            {
                                                addLog(dr["ctid"].ToString(), 0, "自动派单:" + result.msg, Convert.ToInt32(OrderState.待设计));
                                            }
                                        }
                                        if ("normal".Equals(syncType))
                                        {
                                            SqlHelper.ExecuteNonQueryStoreWithTimeOut("sp_autodispatch_day", sqlParameter, 10);
                                        }

                                    }
                                    else
                                    {
                                        if (userId != 82)
                                        {
                                            result = commonHelper.checkOrderListDesignInfo(dr["tid"].ToString(), dr["ctid"].ToString());
                                            if (result != null && result.code == 200)
                                            {
                                                continue;
                                            }
                                            int ceErpTradeLogg = CeErpTradeLog.GetByTidAndStatus(dr["ctid"].ToString(), Convert.ToInt32(OrderState.待设计));
                                            if (ceErpTradeLogg == 0)
                                            {
                                                addLog(dr["ctid"].ToString(), 0, "自动派单:" + result.msg, Convert.ToInt32(OrderState.待设计));
                                            }
                                        }
                                        if ("normal".Equals(syncType))
                                        {
                                            SqlHelper.ExecuteNonQueryStoreWithTimeOut("sp_autodispatch", sqlParameter, 10);
                                        }
                                        if ("wx".Equals(syncType))
                                        {
                                            SqlHelper.ExecuteNonQueryStoreWithTimeOut("sp_autodispatch_wx", sqlParameter, 10);
                                        }
                                    }
                                    res = sqlParameter[3].Value.ToString();
                                    helper.writeLog("自动派单:" + dr["ctid"].ToString() + "-" + res);
                                    if (res.IndexOf("派单完成") != -1)
                                    {
                                        CeErpSukuraData.createInfo(dr["ctid"].ToString(), 2);
                                        //commonHelper.updateDataTradeCellDesignInfo(dr["ctid"].ToString());
                                    }
                                    else
                                    {
                                    }
                                    continue;
                                }
                                catch (Exception ex)
                                {
                                    helper.writeLog("自动派单出错:" + dr["ctid"].ToString() + ex.Message);
                                    continue;
                                }

                                //Thread.Sleep(10);
                            }

                            WriteLog(string.Format("派单 | {0} | {1}", DateTime.Now.ToString(), dt.Rows.Count + "次循环结束"));
                        }
                        else
                        {
                            WriteLog(string.Format("派单 | {0} | {1}", DateTime.Now.ToString(), "无单可派！"));
                        }
                    }
                }
                catch (Exception ex)
                {
                    disPop = false;
                }
                finally
                {
                    disPop = false;
                }
            })).Start();

        }

        /// <summary>
        /// 每日清除数据
        /// </summary>
        /// <param name="obj"></param>
        private void dayClearTimerCall(object obj)
        {
            new Thread(new ThreadStart(delegate ()
            {
                WriteLog(string.Format("清除 | {0} | {1}", DateTime.Now.ToString(), "开始自动清除数据！"));
                try
                {
                    SqlHelper.ExecuteNonQuery("update CE_ErpUserInfo set DayOrderReceive=0,DayOrderPer=0,OnDuty=0,beonduty=0");
                    WriteLog(string.Format("清除 | {0} | {1}", DateTime.Now.ToString(), "结束自动清除数据！"));
                }
                catch (Exception ed)
                {
                    WriteLog(string.Format("清除 | {0} | {1}", DateTime.Now.ToString(), ed.Message));
                }

            })).Start();

        }

        private void dayToDesign()
        {
            try
            {
                WriteLog(string.Format("自动派单设计共创"));
                string sql1 = "select ID, Name, DayOrderReceive, pemDesign, pemShop, DayOrderLimit,OldOrder from view_ErpUser where Name='设计共创'";
                DataTable dt = SqlHelper.ExecuteDataset(sql1).Tables[0];
                int ID = Convert.ToInt32(dt.Rows[0]["ID"]);
                bool OldOrder = Convert.ToBoolean(dt.Rows[0]["OldOrder"]);
                string design_sql = string.Format("select * from Ce_ErpDesignInfo where designId > 0 and tarId={0}", 3542);
                DataTable design_dt = SqlHelper.ExecuteDataset(design_sql).Tables[0];

                Dictionary<string, List<string>> shop_orders = new Dictionary<string, List<string>>();
                foreach (DataRow row in design_dt.Rows)
                {
                    List<string> designIds = null;

                    if (shop_orders.ContainsKey(row["shopId"].ToString()))
                    {
                        shop_orders.TryGetValue(row["shopId"].ToString(), out designIds);
                    }
                    else
                    {
                        designIds = new List<string>();

                    }
                    designIds.Add(row["designId"].ToString());
                    shop_orders[row["shopId"].ToString()] = designIds;
                }

                StringBuilder sql = new StringBuilder();
                sql.AppendFormat("select ctid ,shopId,productId from view_ErpTradeCell where orderstate=2 and  designuserid=0  and payment>0 and isrefund=0 and productId>0 and shopId>0 ");
                if (!OldOrder)
                {
                    sql.AppendFormat(" and IsOldCustomer != 1 ");
                }
                sql.AppendFormat(" order by IsUrgency desc,pay_time asc ");
                DataTable dth = SqlHelper.ExecuteDataset(sql.ToString()).Tables[0];
                foreach (DataRow dr in dth.Rows)
                {

                    List<string> designIds = null;

                    if (!shop_orders.ContainsKey(dr["shopId"].ToString()))
                    {
                        continue;
                    }
                    shop_orders.TryGetValue(dr["shopId"].ToString(), out designIds);
                    if (designIds != null || designIds.Count == 0)
                    {
                        continue;
                    }
                    if (!designIds.Contains(dr["productId"]))
                    {
                        continue;
                    }

                    CeErpTradeCell ce = CeErpTradeCell.GetByCtid(dr["ctid"].ToString());
                    designApiResponseVo response = designHelper.API_GetPrintData_CreateOrder(ce);
                    if (response.code != 200)
                    {
                        continue;
                    }

                    int ceErpTradeLogg = CeErpTradeLog.GetByTidAndStatus(dr["ctid"].ToString(), Convert.ToInt32(OrderState.待设计));
                    if (ceErpTradeLogg == 0)
                    {
                        ce.OrderState = Convert.ToInt32(OrderState.待设计);
                        ce.DesignUserId = 3542;
                        ce.WaitDesignTime = DateTime.Now;
                        ce.Update();

                        addLog(dr["ctid"].ToString(), 3542, "自动派单设计共创", Convert.ToInt32(OrderState.待设计));
                    }
                }
            }
            catch (Exception ex)
            {
                WriteLog(string.Format("自动派单设计共创 | {0} | {1}", DateTime.Now.ToString(), "发生错误" + ex.Message + "！"));
            }

        }
        private void dayTimerTOdesign()
        {
            DateTime currentTime = DateTime.Now;
            DateTime currentDate = currentTime;
            // 获取指定日期的开始时间
            DateTime startTime = new DateTime(currentDate.Year, currentDate.Month, currentDate.Day, 0, 0, 0);//日
            DateTime endTime = new DateTime(currentDate.Year, currentDate.Month, currentDate.Day, 23, 59, 59).AddSeconds(-1);//日
            WriteLog(string.Format("自动派单设计系统"));                                                                         // 获取指定日期的结束时间（即下一天的开始时间，减去1秒）
            StringBuilder sql1 = new StringBuilder();
            sql1.AppendFormat("select ctid from view_ErpTradeCell where DesignUserId = '2125' and OrderState = '3'  and WaitDesignTime BETWEEN '{0}' AND '{1}' and ctid not in (SELECT ctid FROM CE_ErpToDesignLog where ctime BETWEEN '{0}' AND '{1}') ", startTime.ToString("yyyy-MM-dd HH:mm:ss"), endTime.ToString("yyyy-MM-dd HH:mm:ss"));
            DataTable dth1 = SqlHelper.ExecuteDataset(sql1.ToString()).Tables[0];
            foreach (DataRow dr in dth1.Rows)
            {
                CeErpTradeCell ce = CeErpTradeCell.GetByCtid(dr["ctid"].ToString());
                apiDesign.API_GetPrintData_CreateOrder(ce);

            }

            DateTime now = DateTime.Now;
            DateTime today = DateTime.Today;
            DateTime todayFourPM = today.AddHours(16);
            //等到晚上四点过后开始自动派单给设计系统

            CeErpUser ceErpUser = CeErpUser.GetByUserName("设计系统");
            String pemDesign = "";
            String pemShop = "";
            pemDesign = ceErpUser.pemDesign;
            pemShop = ceErpUser.pemShop;
            String[] pemDesigns = pemDesign.Split(',');
            String[] pemShops = pemShop.Split(',');
            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < pemShops.Length; i++)
            {
                sb.Append("'" + pemShops[i] + "'");
                if (i < pemShops.Length - 1)
                {
                    sb.Append(",");
                }
            }

            string inClause = sb.ToString();
            StringBuilder sbs = new StringBuilder();
            for (int i = 0; i < pemDesigns.Length; i++)
            {
                sbs.Append("'" + pemDesigns[i] + "'");
                if (i < pemDesigns.Length - 1)
                {
                    sbs.Append(",");
                }
            }


            string inClauses = sbs.ToString();

            StringBuilder sql = new StringBuilder();
            sql.AppendFormat("select ctid from view_ErpTradeCell where orderstate=2 and productid in (" + inClauses + ")  and ShopId in (" + inClause + ")and designuserid=0  and payment>0 and isrefund=0 order by IsUrgency desc,pay_time asc");
            /*                sql.AppendFormat("select ctid from view_ErpTradeCell where orderstate=2 and productid in (" + inClauses + ")  and ShopId in (" + inClause + ")and designuserid=2125  and payment>0 and isrefund=0 order by IsUrgency desc,pay_time asc");*/
            DataTable dth = SqlHelper.ExecuteDataset(sql.ToString()).Tables[0];
            foreach (DataRow dr in dth.Rows)
            {
                CeErpTradeCell ce = CeErpTradeCell.GetByCtid(dr["ctid"].ToString());
                /*     CeErpTradeCell ce = CeErpTradeCell.GetByCtid("2041933334263885688");*/
                String id = apiDesign.API_GetPrintData_CreateOrder(ce);
                if (id == "请填写订单的手机号或者微信号才可指派到设计系统" || id == "补差价订单不需要过设计系统")
                {

                    int ceErpTradeLog1 = CeErpTradeLog.GetByTidAndStatus(dr["ctid"].ToString(), Convert.ToInt32(OrderState.待抢单));
                    if (ceErpTradeLog1 == 0)
                    {
                        addLog(dr["ctid"].ToString(), 2125, id, Convert.ToInt32(OrderState.待抢单));
                    }
                    if (id == "请填写订单的手机号或者微信号才可指派到设计系统" && ceErpTradeLog1 == 0)
                    {
                        ce.OrderState = Convert.ToInt32(OrderState.待抢单);
                        ce.DesignUserId = 0;
                        ce.Update();

                    }
                    continue;
                }

                int ceErpTradeLogg = CeErpTradeLog.GetByTidAndStatus(dr["ctid"].ToString(), Convert.ToInt32(OrderState.待设计));
                if (ceErpTradeLogg == 0)
                {
                    ce.OrderState = Convert.ToInt32(OrderState.待设计);
                    ce.DesignUserId = 2125;
                    ce.WaitDesignTime = DateTime.Now;
                    ce.Update();

                    addLog(dr["ctid"].ToString(), 2125, "自动派单设计系统", Convert.ToInt32(OrderState.待设计));
                }
                Thread.Sleep(2000); // 等待一段时间
            }



        }
        bool isDataSync = false;
        //598766 瑜伽 598825 涛莱 598782 竹范 598810 鼎怡 600090 领淘文具
        List<string> shopIds = new List<string>()
        {
            "598766","598825","598782","598810", "600090"
        };

        public void syncDataSendOrder()
        {
            if (isDataSync)
            {
                return;
            }
            DateTime nowTime = DateTime.Now;
            if (nowTime.Minute % 30 != 0)//超出时间
            {
                isDataSync = false;
                return;
            }
            isDataSync = true;
            WriteLog(string.Format("同步订单信息"));
            new Thread(new ThreadStart(delegate ()
            {
                try
                {
                    foreach (string id in shopIds)
                    {
                        apiHelper.Api_SyncOrderByTime(id);
                    }
                    StringBuilder sql = new StringBuilder();
                    sql.AppendFormat("select * from view_dataSendOrderInfo where isSync=0  and payment_cyt > 0");
                    DataTable dth = SqlHelper.ExecuteDataset(sql.ToString()).Tables[0];
                    if (dth != null && dth.Rows.Count > 0)
                    {
                        dataSendOrderBean dataSendOrderBean = null;
                        foreach (DataRow item in dth.Rows)
                        {
                            try
                            {

                                dataSendOrderBean = new dataSendOrderBean();
                                dataSendOrderBean.Date1723191218572 = item["pay_time"].ToString();
                                dataSendOrderBean.RelevanceForm1723191634028 = item["SupplierId"].ToString();
                                dataSendOrderBean.RelevanceForm1723191239149 = item["ShopId"].ToString();
                                dataSendOrderBean.Date1723193880305 = item["FinishDeliveryTime"].ToString();
                                dataSendOrderBean.Date1723193870660 = item["FinishPlaceTime"].ToString();
                                dataSendOrderBean.LongText1723542734262 = item["seller_memo"].ToString();
                                dataSendOrderBean.ShortText1723542735637 = item["OtherMemo"].ToString();
                                dataSendOrderBean.ShortText1723542736542 = item["address"].ToString();
                                dataSendOrderBean.ShortText1723193907492 = item["OutSid"].ToString();
                                dataSendOrderBean.Number1723193919446 = item["payment_cyt"].ToString();
                                dataSendOrderBean.ShortText1723707899761 = item["ctid"].ToString();
                                dataSendOrderBean.Radio1723534706288 = item["IsReturn"].ToString() == "0" ? "未结算" : "打回";
                                dataResponseVo result = dataHelper.CreateBoFahuo(dataSendOrderBean);
                                if (result != null)
                                {
                                    if ("0".Equals(result.errcode))
                                    {
                                        CeErpDataSendOrderInfo.updateAsync(item["ctid"].ToString(), JsonConvert.SerializeObject(dataSendOrderBean));
                                    }
                                    else
                                    {
                                        CeErpDataSendOrderInfo.updateError(item["ctid"].ToString(), result.errmsg, JsonConvert.SerializeObject(dataSendOrderBean));
                                    }
                                }
                            }
                            catch (Exception ex)
                            {
                                WriteLog(string.Format(item["ctid"] + "同步订单信息:" + ex));
                            }

                        }
                        WriteLog(string.Format("同步订单信息结束"));
                    }
                }
                catch (Exception ex)
                {
                    isDataSync = false;
                }
                finally
                {
                    isDataSync = false;
                }
            })).Start();
        }

        bool isOrderSync = false;
        public void sendOrderInfo()
        {
            if (isOrderSync)
            {
                return;
            }
            DateTime nowTime = DateTime.Now;
            isOrderSync = true;
            WriteLog(string.Format("数仓同步订单信息"));
            new Thread(new ThreadStart(delegate ()
            {
                try
                {
                    StringBuilder sql = new StringBuilder();
                    sql.AppendFormat("select top 200 * from CE_ErpSukuraData ");
                    DataTable dth = SqlHelper.ExecuteDataset(sql.ToString()).Tables[0];
                    if (dth != null && dth.Rows.Count > 0)
                    {
                        foreach (DataRow item in dth.Rows)
                        {
                            try
                            {


                                int type = Convert.ToInt32(item["type"]);
                                string tid = item["tid"].ToString();
                                if (type == 0)
                                {
                                    Api_tmc_trade_info_Obj fullObj = JsonConvert.DeserializeObject<Api_tmc_trade_info_Obj>(item["json"].ToString());

                                    if (fullObj == null)
                                    {
                                        CeErpSukuraData.Del(item["ID"].ToString());
                                        continue;
                                    }
                                    Api_tmc_trade_info_Obj.Content content = fullObj.content;
                                    if (content == null)
                                    {
                                        CeErpSukuraData.Del(item["ID"].ToString());
                                        continue;
                                    }
                                    dataHelper.sendErpTradeInfo(new dataSendTradeBean(content));
                                    List<Api_tmc_trade_info_Obj.LinesItem> orderList = content.lines;
                                    foreach (Api_tmc_trade_info_Obj.LinesItem line in orderList)
                                    {
                                        dataHelper.sendErpTradeOrderInfo(new dataSendTradeOrderBean(line, content));
                                    }
                                }
                                if (type == 1)
                                {
                                    CeErpTradeCell entity = CeErpTradeCell.GetByCtid(tid);
                                    if (entity == null)
                                    {
                                        CeErpSukuraData.Del(item["ID"].ToString());
                                        continue;
                                    }
                                    CeErpTrade father = CeErpTrade.Get(entity.tid);
                                    if (father == null)
                                    {
                                        CeErpSukuraData.Del(item["ID"].ToString());
                                        continue;
                                    }
                                    dataHelper.sendErpTradeCellInfo(new dataSendTradeCellBean(entity, father));
                                }
                                if (type == 2)
                                {
                                    commonHelper.updateDataTradeCellDesignInfo(tid);
                                }
                                if (type == 3)
                                {
                                    commonHelper.updateDataTradeCellPlaceInfo(tid);
                                }
                                if (type == 4)
                                {
                                    commonHelper.updateDataTradeCellDeliveInfo(tid);
                                }
                                if (type == 5)
                                {
                                    commonHelper.updateDataTradeCellBackInfo(tid);
                                }
                                if (type == 6)
                                {
                                    commonHelper.updateDataTradeCellCheckGoodInfo(tid);
                                }
                                if (type == 7)
                                {
                                    commonHelper.updateDataTradeCellUrgentInfo(tid);
                                }
                                if (type == 8)
                                {
                                    commonHelper.updateDataTradeCellAfterSaleInfo(tid);
                                }
                                if (type == 9)
                                {
                                    CeErpTradeCell entity = CeErpTradeCell.GetByCtid(tid);
                                    if (entity == null)
                                    {
                                        CeErpSukuraData.Del(item["ID"].ToString());
                                        continue;
                                    }
                                    CeErpReturnCash father = CeErpReturnCash.GetByTid(entity.tid);
                                    if (father == null)
                                    {
                                        CeErpSukuraData.Del(item["ID"].ToString());
                                        continue;
                                    }
                                    commonHelper.updateDataTradeCellCashInfo(entity, father);
                                }
                                if (type == 10)
                                {
                                    CeErpTradeCell entity = CeErpTradeCell.GetByCtid(tid);
                                    if (entity == null)
                                    {
                                        CeErpSukuraData.Del(item["ID"].ToString());
                                        continue;
                                    }

                                    commonHelper.updateDataTradeCellStayInfo(entity);
                                }
                                CeErpSukuraData.Del(item["ID"].ToString());
                            }
                            catch (Exception ex)
                            {
                                CeErpSukuraData.Del(item["ID"].ToString());
                                XLog.SaveLog(0, "sendOrderInfo2:---" + item["tid"].ToString() + "---" + ex.Message);
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    XLog.SaveLog(0, "sendOrderInfo:---" + ex.Message);
                    isOrderSync = false;
                }
                finally
                {
                    isOrderSync = false;
                }

            })).Start();
        }
        public void connetUrl()
        {
            WebClient wc = new WebClient();
            wc.Encoding = Encoding.GetEncoding("utf-8");
            byte[] ret = wc.UploadValues("http://183.250.143.56:8088/supplierBuildFile.aspx", "POST", new NameValueCollection());
            string remoteInfo = Encoding.GetEncoding("utf-8").GetString(ret);
        }

        public static void addLog(string ctid, int userid, string con, int orderState = 0, int aftersaleState = 0)
        {
            CeErpTradeLog log = new CeErpTradeLog();
            log.tid = ctid;
            log.UserId = userid;
            log.Con = con;
            log.OrderState = orderState;
            log.AfterSaleState = aftersaleState;
            log.OperateTime = DateTime.Now;
            log.Create();
        }

        /// <summary>
        /// 更新异常订单状态
        /// </summary>
        /// <param name="obj"></param>
        private void unUsualOrderTimerCall(object obj)
        {
            new Thread(new ThreadStart(delegate ()
            {
                WriteLog(string.Format("更新异常订单 | {0} | {1}", DateTime.Now.ToString(), "开始更新异常订单状态！"));
                try
                {
                    commonHelper.setDeliveryUnusualOrder();
                    //StringBuilder sql = new StringBuilder();
                    //sql.AppendFormat("update ce_erptradecell with(rowlock) set unusualTag=3,UnusualTime=WaitDesignTime where orderstate<5 and unusualTag=0 and datediff(hh,WaitDesignTime,getdate())>(select sjzTime from CE_ErpProductHour where CE_ErpProductHour.ProductID=ce_erptradecell.ProductId);");
                    //sql.AppendFormat("update ce_erptradecell with(rowlock) set unusualTag=4,UnusualTime=FinishDesignTime where orderstate=5 and unusualTag=0 and datediff(hh,FinishDesignTime,getdate())>(select xdTime from CE_ErpProductHour where CE_ErpProductHour.ProductID=ce_erptradecell.ProductId);");
                    //sql.AppendFormat("update ce_erptradecell with(rowlock) set unusualTag=5,UnusualTime=FinishPlaceTime where orderstate=6 and unusualTag=0 and datediff(hh,FinishPlaceTime,getdate())>(select fhTime from CE_ErpProductHour where CE_ErpProductHour.ProductID=ce_erptradecell.ProductId);");
                    //SqlHelper.ExecuteNonQuery(sql.ToString());
                    //WriteLog(string.Format("更新异常订单 | {0} | {1}", DateTime.Now.ToString(), "结束更新异常订单状态！"));

                }
                catch (Exception ex)
                {
                    WriteLog(string.Format("更新异常订单 | {0} | {1}", DateTime.Now.ToString(), "发生错误" + ex.Message + "！"));
                }

            })).Start();
        }

        /// <summary>
        /// 定时刷新退款
        /// </summary>
        /// <param name="obj"></param>
        private void reFundsDataTimerCall(object obj)
        {
            new Thread(new ThreadStart(delegate ()
            {
                //定时刷新退款确认状态，48小时自动确认
                WriteLog(string.Format("刷新退款 | {0} | {1}", DateTime.Now.ToString(), "开始执行！"));
                try
                {
                    commonHelper.autoRefreshRefundState();
                    //StringBuilder sql = new StringBuilder();
                    //sql.AppendFormat("update CE_ErpTradeRefund set RefundState=3 where RefundState=2 and DATEDIFF(hh,modified,getdate())>=72;");
                    //sql.AppendFormat("update ce_erptradecell set AfterSaleState=4,FinishAfterSaleTime=getdate() where AfterSaleState=3 and AfterSaleResSupId=0 and DATEDIFF(hh,AfterSalePreTime,getdate())>=72;");
                    //sql.AppendFormat("update ce_erptradecell set AfterSaleState=4,AfterSaleSupplierState=1,FinishAfterSaleTime=getdate() where AfterSaleState=3 and AfterSaleSupplierState=0 and AfterSaleResSupId>0 and DATEDIFF(hh,AfterSalePreTime,getdate())>=72;");
                    //sql.AppendFormat("update CE_ErpTradeResponsible set VerifyState=1 where VerifyState=0 and DATEDIFF(hh,createdTime,getdate())>=72;");
                    ////DataTable dt = DbHelper.DbConn.ExecuteDataset(sql.ToString()).Tables[0];
                    //SqlHelper.ExecuteNonQuery(sql.ToString());

                    WriteLog(string.Format("2刷新退款 | {0} | {1}", DateTime.Now.ToString(), "执行完成！"));
                }
                catch (Exception ex)
                {
                    WriteLog(string.Format("2刷新退款 | {0} | {1}", DateTime.Now.ToString(), "发生错误" + ex.Message + "！"));
                }
            })).Start();
        }



        #region process
        private bool killProc(string user)
        {
            Process[] pProcess = Process.GetProcesses();
            for (int i = 1; i <= pProcess.Length - 1; i++)
            {
                if (pProcess[i].ProcessName.ToLower() == "w3wp" && GetProcessUserName(pProcess[i].Id) == user)
                {
                    pProcess[i].Kill();
                    helper.writeLog("结束w3wp");
                    return true;
                }
            }
            return false;
        }

        //获得进程的用户名
        private static string GetProcessUserName(int pID)
        {
            string text1 = null;
            SelectQuery query1 = new SelectQuery("Select * from Win32_Process WHERE processID=" + pID);
            ManagementObjectSearcher searcher1 = new ManagementObjectSearcher(query1);
            try
            {
                foreach (ManagementObject disk in searcher1.Get())
                {
                    ManagementBaseObject inPar = null;
                    ManagementBaseObject outPar = null;
                    inPar = disk.GetMethodParameters("GetOwner");
                    outPar = disk.InvokeMethod("GetOwner", inPar, null);
                    text1 = outPar["User"].ToString();
                    break;
                }
            }
            catch
            {
                text1 = "SYSTEM";
            }
            return text1;
        }
        #endregion

        #region private
        private void stripExit_Click(object sender, EventArgs e)
        {
            Application.ExitThread();
            Environment.Exit(0);
        }

        private void stripKis_Click(object sender, EventArgs e)
        {
            WindowState = FormWindowState.Normal;
            this.Show();
        }

        private void MainForm_FormClosed(object sender, FormClosedEventArgs e)
        {

            //释放动态库
            //bxdualsdk_56.bxDual_ReleaseSdk();
            //VzClientSDK.VzLPRClient_Cleanup();
            helper.writeLog("客户端关闭");
            //if (ytjTh != null) ytjTh.Abort();
            //KillSelf();
        }

        //private void KillSelf()
        //{
        //    Process[] pProcess = Process.GetProcesses();
        //    for (int i = 1; i <= pProcess.Length - 1; i++)
        //    {
        //        if (pProcess[i].ProcessName == "AI无人值守称重系统")
        //        {
        //            pProcess[i].Kill();
        //            //更新
        //            break;
        //        }
        //    }
        //}

        private void MainForm_FormClosing(object sender, FormClosingEventArgs e)
        {
            if (e.CloseReason == CloseReason.UserClosing)
            {
                // 取消关闭  
                e.Cancel = true;
                this.Hide();
            }
        }



        #endregion

        private void WriteLog(string msg)
        {
            helper.writeLog(msg);
        }

        private void stripPai_Click(object sender, EventArgs e)
        {
            disTimerCall(null);
        }
    }
}