using Jp.WinAutoService.Common;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net.Http;
using System.ServiceProcess;
using System.Text;
using System.Threading;
using Pcb.Business;
using Pcb.Business.BizCore.BizCashLog;
using Pcb.Business.BizCore.BizMember;
using Pcb.Business.BizCore.BizMemberCoupon;
using Pcb.Business.BizCore.BizMemberCoupon.Interfaces;
using Pcb.Business.BizCore.BizMemberIntegralLog;
using Pcb.Business.BizCore.BizOrderMain;
using Pcb.Business.BizCore.BizPcbOrder;
using Pcb.Common;
using Pcb.Domain;
using Pcb.Business.BizCore;
using Pcb.Common.Enum;

namespace Jp.WinAutoService
{
    /// <summary>
    /// 捷配window自动运行服务
    /// 可根据自主需求添加线程，独立处理对应的业务逻辑即可
    /// add by sunyichao 2018-09-07
    /// </summary>
    public partial class WinServerAutoRun : ServiceBase
    {
        #region 服务相关变量

        /// <summary>
        /// 任务标志，为true时执行任务
        /// </summary>
        public static bool flag = false;

        /// <summary>
        /// 订单自动确认收货线程
        /// </summary>
        Thread orderAutoReceive = null;

        /// <summary>
        /// ds
        /// </summary>
        Thread orderAutoReceive2 = null;



        //业务类对象
        LogisticBaseInfoAsycAdminBiz _logisticbiz = new LogisticBaseInfoAsycAdminBiz();
        OrderWaitSyncBiz orderSync = new OrderWaitSyncBiz();

        #endregion

        /// <summary>
        /// 服务构造函数
        /// </summary>
        public WinServerAutoRun()
        {
            InitializeComponent();
        }


        /// <summary>
        /// 服务开启执行函数
        /// </summary>
        /// <param name="args"></param>
        protected override void OnStart(string[] args)
        {
            flag = true;
            try
            {
                orderAutoReceive = new Thread(new ThreadStart(DoCreateOrderShipInfoAsyc));
                orderAutoReceive.Name = "JpDoCreateOrderShipInfoAsycThread";
                orderAutoReceive.Start();
                //接口失败后调用
                orderAutoReceive2 = new Thread(new ThreadStart(DoPinbanAsyc));
                orderAutoReceive2.Name = "DoPinbanAsycThread";
                orderAutoReceive2.Start();
            }
            catch (Exception ex)
            {
                SaveEventLog(ex.Message + "\r\n" + ex.Source + "\r\n" + ex.StackTrace, Thread.CurrentThread.Name);
            }

        }


        /// <summary>
        /// 服务停止时执行函数
        /// </summary>
        protected override void OnStop()
        {
            flag = false;

            try
            {
                if (orderAutoReceive != null)
                {
                    SaveEventLog("线程终止。。。", "JpDoCreateOrderShipInfoAsycThread");
                    //orderAutoReceive.Abort();
                    orderAutoReceive = null;
                }

            }
            catch (Exception)
            {
                throw;
            }
        }


        /// <summary>
        /// 自动同步外单入库
        /// add by sunyichao 2018-10-25
        /// </summary>
        public void DoOrderAutoSync()
        {
            DataTable list = null;
            while (flag)
            {
                try
                {
                    list = orderSync.GetWaitSyncOrder();
                    if (list.Rows.Count > 0)
                    {
                        foreach (DataRow item in list.Rows)
                        {
                            #region 外贸入库处理

                            string businessOrderNo = item["BusinessOrderNo"].ToString();
                            string businessGroupNo = item["BusinessGroupNo"].ToString();
                            int receiveNum = item["ReceiveNum"].ToString().ToInt2();

                            var orderService = new PcbWayOrder.OrderServiceClient();
                            var orderNService = new PcbWayOrderN.OrderNServiceClient();
                            var pcbService = new PcbWayPcb.PCBServiceClient();

                            bool flag2 = orderService.UpdateActualReceiveNumByOrderNo(businessOrderNo, receiveNum, businessGroupNo, "");

                            var mod_detail = orderService.GetOrderDetailByNo(businessOrderNo);
                            //添加板子、钢网、万能版等收货日志 add by sunyichao 2016-11-14
                            int logId = orderNService.AddOrderReceiveLog(new PcbWayOrderN.OrderReceiveLog()
                            {
                                GroupNo = businessGroupNo,
                                ProId = mod_detail.ProId,
                                ProType = mod_detail.ProType,
                                BomRelationId = 0,
                                ReceiveNum = receiveNum,
                                CreateBy = 56,//外贸物流专员
                                CreateTime = DateTime.Now,
                                Remark = "PCB收货：子订单编号【" + businessOrderNo + "】，当前已收 " + receiveNum + " PCS。"
                            });


                            //添加板子、钢网、万能版等添加订单日志 add by sunyichao 2016-11-14
                            bool logFlag = orderService.AddLog(new PcbWayOrder.OrderMainLog()
                            {
                                OrderId = mod_detail.MainId,
                                Note = "PCB收货：子订单编号【" + businessOrderNo + "】，当前已收 " + receiveNum + " PCS。",
                                CreateTime = DateTime.Now
                            });


                            if (flag2)
                            {
                                if (mod_detail.ActualReceiveNum >= mod_detail.BuyNum)
                                {

                                    pcbService.AddPcbOrderLog(new PcbWayPcb.OrderLog()
                                    {
                                        AdminId = 56,
                                        OrderId = mod_detail.ProId,
                                        AddTime = DateTime.Now,
                                        SendFlag = 0,
                                        Note = "子订单" + mod_detail.ProName + "：入库完成###。",
                                        LogType = 0,
                                        PointType = 80
                                    });
                                }


                                //验证是否全部入库
                                var isAllReceived = orderService.CheckGroupNoIsAllReceivedByOrderNo(businessOrderNo);
                                if (isAllReceived)
                                {
                                    //全部入库收货完成添加订单收货日志 add by sunyichao 2016-11-14
                                    logFlag = orderService.AddLog(new PcbWayOrder.OrderMainLog()
                                    {
                                        OrderId = mod_detail.MainId,
                                        Note = "订单包G" + mod_detail.MainId + "：已全部收货完成。",
                                        CreateTime = DateTime.Now
                                    });

                                }

                            }

                            #endregion

                            //修改数据状态
                            orderSync.UpdateStatusById(item["Id"].ToInt2());
                        }

                        SaveEventLog("订单自动同步入库任务完成，共处理" + list.Rows.Count + "条数据，休眠1分钟。。。", Thread.CurrentThread.Name);
                        Thread.Sleep(60000);
                    }
                    else
                    {
                        SaveEventLog("暂无可同步外单，休眠1分钟。。。", Thread.CurrentThread.Name);
                        Thread.Sleep(60000);
                    }
                }
                catch (Exception ex)
                {
                    //服务程序错误时，线程休眠，十分钟后重新请求 add by sunyichao 2018-11-13
                    SaveEventLog("同步程序错误。。。\r\n" + ex.Message + "\r\n" + ex.Source + "\r\n" + ex.StackTrace + "\r\n休眠10分钟", Thread.CurrentThread.Name);
                    Thread.Sleep(60000 * 10);
                }
            }
        }

        /// <summary>
        /// 保存事件日志
        /// </summary>
        /// <param name="message"></param>
        private void SaveEventLog(string message, string suffix)
        {
            string filePath = ServerConfig.LogPath + "EventLogV" + suffix + ".txt";
            FileStream fileStream = new FileStream(filePath, FileMode.OpenOrCreate, FileAccess.Write);
            StreamWriter streamWriter = new StreamWriter(fileStream);
            streamWriter.BaseStream.Seek(0, SeekOrigin.End);
            streamWriter.WriteLine("" + DateTime.Now.ToString() + "【Flag=" + flag + "】：" + message);
            streamWriter.Flush();
            streamWriter.Close();
            fileStream.Close();
        }

        /// <summary>
        /// 同步发货信息到财务系统
        /// add by hongkai 2020-3-26
        /// </summary>
        public void DoCreateOrderShipInfoAsyc()
        {
            DataTable dt = null;
            while (flag)
            {
                try
                {
                    dt = _logisticbiz.GetNeedReceiveOrders(ServerConfig.TopForHandle);
                    if (dt.Rows.Count > 0)
                    {
                        foreach (DataRow dr in dt.Rows)
                        {
                            int result = _logisticbiz.CreateOrderShipInfo(dr["Id"].ToInt2());
                            if (result > 0)
                            {
                                _logisticbiz.SetStatusSql(dr["Id"].ToInt2(), EnumLogisticBaseInfoAsycStatus.Sended.GetHashCode());
                            }
                            else
                            {
                                _logisticbiz.SetStatusSql(dr["Id"].ToInt2(), EnumLogisticBaseInfoAsycStatus.SendFail.GetHashCode());
                                SaveEventLog("同步发货信息到财务系统任务失败，同步编号是" + dr["Id"].ToInt2(), Thread.CurrentThread.Name);
                            }
                        }

                        SaveEventLog("同步发货信息到财务系统任务完成，共处理" + dt.Rows.Count + "条数据，休眠" + ServerConfig.TimeForSeconds / 60000 + "分钟。。。", Thread.CurrentThread.Name);
                        Thread.Sleep(ServerConfig.TimeForSeconds);
                    }
                    else
                    {
                        if (Thread.CurrentThread.IsAlive)
                        {
                            SaveEventLog("暂无可同步订单，休眠" + ServerConfig.TimeForSeconds / 60000 + "分钟。。。", Thread.CurrentThread.Name);
                            Thread.Sleep(ServerConfig.TimeForSeconds);
                        }
                    }
                }
                catch (Exception ex)
                {
                    SaveEventLog("同步发货信息任务异常1..." + ex.Message + "\r\n" + ex.Source + "\r\n" + ex.StackTrace, Thread.CurrentThread.Name);
                    Thread.Sleep(ServerConfig.TimeForSeconds);
                }
            }

        }
        /// <summary>
        /// 重新调用接口表
        /// add by dyb 2020-05-15
        /// </summary>
        public void DoPinbanAsyc()
        {
            while (flag)
            {
                var bll = new WebInterfaceRequestBaseBiz();
                var msg = bll.AutoCall();
                MngLog.Error("服务DoPinbanAsyc：" + msg);
                LogHelper.Info("bbb");
                Thread.Sleep(300000);
            }
        }
    }
}