/******************************
* 说明：下载进度窗口
* 创建人：龚宇超
* 创建日期：2018-02-09
* 修改人：
* 修改日期：
* 修改备注：
* 版本：1.0.0.0
******************************/
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.IO;
using System.Threading;
using System.Net;
using Lskj.Model;
using Lskj.Core;
using Lskj.Business;
using Lskj.Control.BrowserSetting;
using Newtonsoft.Json.Linq;

namespace Lskj.BatchUpload
{
    /// <summary>
    /// 下载进度窗口
    /// </summary>
    public partial class FrmProgress : Form
    {
        public DynamicPowerModel Model;
        /// <summary>
        /// 是否下载完成
        /// </summary>
        private bool isFinished = false;
        /// <summary>
        /// 上传总数
        /// </summary>
        private long total = 0;
        /// <summary>
        /// 当前下载的总数
        /// </summary>
        private long nDownloadedTotal = 0;
        /// <summary>
        /// 上传文件列表
        /// </summary>
        private List<string> UploadFileList = new List<string>();
        private delegate void SetProcessBarCallBack(int current, int total);
        private delegate void ExitCallBack(bool success);
        private delegate void ShowCurrentDownloadFileNameCallBack(string name);
        public FrmProgress(List<string> fileNames)
        {
           
            InitializeComponent();
            total = fileNames.Count;
            this.UploadFileList = fileNames;
            System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false;
            this.lblAll.Text = string.Format("总进度(0/{0})", this.UploadFileList.Count);
        }
        /// <summary>
        /// <para>说明：窗口加载</para>
        /// <para>创建人：龚宇超</para>
        /// <para>创建日期：2018-02-23 </para>
        /// <para>修改人：</para>
        /// <para>修改日期：</para>
        /// <para>修改备注：</para>
        /// <para>版本：1.0</para>
        /// </summary>
        /// <param name="sender">The sender.</param>
        /// <param name="e">The <see cref="EventArgs"/> instance containing the event data.</param>
        private void OnFormLoad(object sender, EventArgs e)
        {
            ThreadPool.QueueUserWorkItem(new WaitCallback(this.ProcDownload));
        }
        /// <summary>
        /// <para>说明：下载文件</para>
        /// <para>创建人：龚宇超</para>
        /// <para>创建日期：2018-02-23 </para>
        /// <para>修改人：</para>
        /// <para>修改日期：</para>
        /// <para>修改备注：</para>
        /// <para>版本：1.0</para>
        /// </summary>
        /// <param name="o">The o.</param>
        private void ProcDownload(object o)
        {
            if (UploadFileList.Count == 0)
            {
                return;
            }

            string sql = @"if isnull((select 1 from Plm_MapNumberTab  where plm_mn_dwgNo='{0}'),0)!=1
                                begin
                                 insert into Plm_MapNumberTab(plm_mn_dwgNo,plm_mn_BillNo,plm_mn_operatorid,plm_mn_operatedate,plm_mn_modid) values('{0}','{1}','{2}',getdate(),'201041')
                                end";
            
            string sql2 = "insert into Plm_FigBindingTab(plm_fb_dwgNo,plm_fb_billdocument_id,plm_fb_stepover,plm_fb_operatorid,plm_fb_operatedate,plm_fb_modid) values('{0}','{1}','1','{2}',getdate(),'201043')";
           
            string sql3 = " update P_fm_FileTab set dwgNo='{0}' where fileId='{1}'";

            //年份后2位+2位月+2位日
            DateTime now = DateTime.Now;
            string date = now.ToString("yyMMdd");

            ERPInfo.Instance.UserId = DBConfig.Instance.NoticeUserID;
            ERPInfo.Instance.UserName = DBConfig.Instance.NoticeUserName;

            int i = 1;
            foreach (string filePath in UploadFileList)
            {
                try
                {
                    string MaximumValue = SqlHelper.ExecuteScalar("select MAX(plm_mn_id) AS max_value FROM Plm_MapNumberTab;") + "";//主表
                    string DetailsMaximumValue = SqlHelper.ExecuteScalar("select MAX(plm_fb_id) AS max_value FROM Plm_FigBindingTab;") + "";//明细表
                    int number = int.Parse(MaximumValue)+1;//最大id
                    int DetailsNumber = int.Parse(DetailsMaximumValue)+1;
                   
                    string filename = Path.GetFileNameWithoutExtension(filePath);
                    string wjm = "TH" + date + number.ToString("D4");
                    string DetailsWjm = "TZ" + date + DetailsNumber.ToString("D4");
                    string ReturnID = string.Empty;
                    bool isUpdate = UploadFile(filePath, DetailsWjm, out string msg, out ReturnID);

                    if (isUpdate)
                    {

                        SqlHelper.ExecuteNonQuery(string.Format(sql, filename, wjm, ERPInfo.Instance.UserId));
                        SqlHelper.ExecuteNonQuery(string.Format(sql2, filename, DetailsWjm, ERPInfo.Instance.UserId));

                        SqlHelper.ExecuteNonQuery(string.Format("update Plm_FigBindingTab set  plm_fb_assid=(select plm_mn_id from Plm_MapNumberTab where plm_mn_dwgNo='{0}') where plm_fb_dwgNo='{0}'", filename));

                        if (!string.IsNullOrWhiteSpace(ReturnID))SqlHelper.ExecuteNonQuery(string.Format(sql3, filename, ReturnID));
                        // SqlHelper.ExecuteNonQuery(string.Format(sql2, filename, "TZ" + date + i.ToString("D4"), ERPInfo.Instance.UserId));
                    }
                    //Thread.Sleep(500);
                  
                }
                catch (Exception ex)
                {
                    //MessageBox.Show(ex.Message);
                }
                finally 
                {
                    this.lblAll.Text = string.Format("总进度({0}/{1})", i, this.UploadFileList.Count);
                    progressBarTotal.Value = (int)(i * 100 / total);
                }
                
                i++;
            }
            if (this.UploadFileList.Count == i)
                Exit(true);
            else
                Exit(false);
        }
        /// <summary>
        /// <para>说明：显示当前上传文件</para>
        /// <para>创建人：龚宇超</para>
        /// <para>创建日期：2018-02-23 </para>
        /// <para>修改人：</para>
        /// <para>修改日期：</para>
        /// <para>修改备注：</para>
        /// <para>版本：1.0</para>
        /// </summary>
        /// <param name="name">The name.</param>
        private void ShowCurrentDownloadFileName(string name)
        {
            if (this.labelCurrentItem.InvokeRequired)
            {
                ShowCurrentDownloadFileNameCallBack cb = new ShowCurrentDownloadFileNameCallBack(ShowCurrentDownloadFileName);
                this.Invoke(cb, new object[] { name });
                this.labelCurrentItem.Text = "正在上传：" + name;
            }
            else
            {
                this.labelCurrentItem.Text = "正在上传：" + name;
            }
        }
        /// <summary>
        /// <para>说明：退出升级程序</para>
        /// <para>创建人：龚宇超</para>
        /// <para>创建日期：2018-02-23 </para>
        /// <para>修改人：</para>
        /// <para>修改日期：</para>
        /// <para>修改备注：</para>
        /// <para>版本：1.0</para>
        /// </summary>
        /// <param name="success">if set to <c>true</c> [success].</param>
        private void Exit(bool success)
        {
            if (this.InvokeRequired)
            {
                ExitCallBack cb = new ExitCallBack(Exit);
                this.Invoke(cb, new object[] { success });
            }
            else
            {
                this.isFinished = success;
                this.DialogResult = success ? DialogResult.OK : DialogResult.Cancel;
                this.Close();
            }
        }
        /// <summary>
        /// 取消
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void buttonOk_Click(object sender, EventArgs e)
        {
            this.DialogResult = DialogResult.Cancel;
            this.Close();
        }
        /// <summary>
        /// 上传文件
        /// </summary>
        /// <param name="filePath"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        private bool UploadFile(string filePath,string  wjm, out string msg, out string ReturnID)
        {
            bool isUpload = false;
            string returnMsg = "";
            string postUrl = "";
            ReturnID = "";
            try
            {
                FileInfo fileInfo = new FileInfo(filePath);
                string fileName = Path.GetFileName(filePath);
                byte[] fileBytes = ConvertFileToBytes(filePath);
                string fileBase64 = Convert.ToBase64String(fileBytes);
                //上传文件到服务器目录
                postUrl = $"{SystemInfo.Instance.OAUrl}Api/FileUploadApi.ashx?moduleId={Model.ModuleCode}&idValue={wjm}&totsize={fileInfo.Length}&position=0&filename={fileName}&method=DoWebUpload";
                HttpTools.setting("application/x-www-form-urlencoded", null, null);
                string result = "";
                CookieCollection cookieCollection = null;
                HttpWebResponse webResponse = HttpTools.Post(postUrl, fileBase64, null, HttpTools.Method.POST, out cookieCollection, out result);
                if (webResponse != null && !string.IsNullOrEmpty(result))
                {
                    JObject jsonObject = (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(result);
                    string isSuccess = jsonObject["success"] + "";
                    if (isSuccess.Equals("True", StringComparison.CurrentCultureIgnoreCase))
                    {
                        string fileId = jsonObject["other"] + "";
                        ReturnID = fileId;
                        string webpath = jsonObject["data"]["WebRelPath"] + "";
                        isUpload = true;
                    }
                    else
                    {
                        if (jsonObject.ContainsKey("msg"))
                        {
                            returnMsg = jsonObject["msg"] + "";
                        }
                        isUpload = false;
                    }
                }
                else
                {
                    returnMsg = "上传请求失败";
                    isUpload = false;
                }
            }
            catch (Exception ex)
            {
                returnMsg = ex.Message;
                isUpload = false;
            }
            msg = returnMsg;
            return isUpload;
        }
        /// <summary>
        /// 附件转换byte[]
        /// </summary>
        /// <param name="filePath">附件路径</param>
        /// <returns>二进制</returns>
        private byte[] ConvertFileToBytes(string filePath)
        {
            byte[] bytContent = null;
            FileStream fs = null;
            BinaryReader br = null;
            try
            {
                fs = new FileStream(filePath, System.IO.FileMode.Open);
            }
            catch (Exception)
            {
                throw;
            }
            finally
            {
                if (fs != null)
                    br = new BinaryReader((Stream)fs);
                if (br != null)
                    bytContent = br.ReadBytes((Int32)fs.Length);
                if (fs != null)
                    fs.Dispose();
            }
            return bytContent;
        }
    }
}