ZLPlugin_LisPacs_MR_NEW/LisPacsDataUpload/Form1.cs

using Common;
using iTextSharp.text;
using iTextSharp.text.pdf;
using LisPacsDataUpload.business;
using LisPacsDataUpload.Models;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Data;
using System.Drawing;
using System.IO;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using System.Xml;

namespace LisPacsDataUpload
{
    public partial class Form1 : Form
    {

        private static int zlhrConstant_true=1;// 是临生免 常量
        //定时器
        private System.Windows.Forms.Timer timer1 = new System.Windows.Forms.Timer();
        //private DateTime Date;
        //private int PageSize = 10;
        //private int PageIndex = 0;
        //PageIndex = PageIndex + 1;
        //        int PageStart = (PageIndex - 1) * PageSize + 1;
        //int PageEnd = PageSize * PageIndex;
        private int UploadPacs;//是否上传pacs
        private string ShowLog = "";
        private int Lis_total = 0;//今日lis上传总数
        private int pacs_total = 0;//今日pacs上传总数
        private string DicPacs = AppDomain.CurrentDomain.BaseDirectory + "Pacs\\";
        private string DicLis = AppDomain.CurrentDomain.BaseDirectory + "Lis\\";

        private int zlhr = 0;// 是否为临生免
        private int lisSource = 1;// 0中联老版lis 1 中联新版lis  2  专业版临生免  3 三方lis
        private int open_multiple_upload_flag = 0;// 开启多个线程上传

        string lis_upload_url = "http://40.26.204.3:8084/phimp-napi/qyhrlischeckreportinfo/save"; //lis 上传接口地址
        string file_url = "http://40.26.204.3:8084/phimp-napi/attachMent/upload";  // 文件上传地址
        private delegate void SetTextCallback(string text);
        //在给textBox1.text赋值的地方调用以下方法即可
        public Form1()
        {
            InitializeComponent();
            this.MinimumSize = new Size(0, 0);
            timer1.Interval = OracleHelper<object>.Time();
            timer1.Enabled = true;
            timer1.Tick += new EventHandler(DataUpload);//添加事件
            timer1.Start();
        }
        private void Form1_Load(object sender, EventArgs e)
        {
            ShowLog = "启动正常。";
            LogHelper.Info(ShowLog);
            this.SetText(ShowLog);
            ShowCheckBox1();
            ShowCheckBox2();
            UploadPacs = OracleHelper<object>.UploadPacs();
            GetLisDefault();
            if (UploadPacs == 1)
            {
                GetPacsDefault();
            }
            //AutoStart();
            DataUpload(sender, e);
        }
        private void ShowCheckBox1()
        {

            try
            {
                string sql_lis = @"select 互认,zlhr,open_multiple_upload,lis_source from 互认配置表";
                DataTable dt_lis = OracleHelper<object>.RunQueryDS(sql_lis);
                int total = int.Parse(dt_lis.Rows[0]["互认"].ToString());
                if (total == 1)
                {
                    checkBox1.Checked = true;
                }
                else
                {
                    checkBox1.Checked = false;
                }
                int zlhrValue = int.Parse(dt_lis.Rows[0]["zlhr"].ToString());
                if (zlhrValue == zlhrConstant_true)
                {
                    zlhr = zlhrValue;
                }
                open_multiple_upload_flag = int.Parse(dt_lis.Rows[0]["open_multiple_upload"].ToString());

                lisSource = int.Parse(dt_lis.Rows[0]["lis_source"].ToString());
            }
            catch (Exception ex)
            {
                LogHelper.Info("ex===" + ex.Message);
            }
            

        }
        private void ShowCheckBox2()
        {
            XmlDocument xmldoc = new XmlDocument();
            string xmlpath = AppDomain.CurrentDomain.BaseDirectory + "Xml.xml";
            xmldoc.Load(xmlpath);
            string str = xmldoc.SelectSingleNode("/root/key").InnerXml;
            if (str == "0")
            {
                checkBox2.Checked = false;
            }
            else
            {
                checkBox2.Checked = true;
            }
        }
        /// <summary>
        /// 开机启动
        /// </summary>
        private void AutoStart()
        {

            try
            {
                XmlDocument xmldoc = new XmlDocument();
                string xmlpath = AppDomain.CurrentDomain.BaseDirectory + "Xml.xml";
                xmldoc.Load(xmlpath);
                string str = xmldoc.SelectSingleNode("/root/key").InnerXml;
                if (str == "0")
                {
                    string regPath = "SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\Run";
                    string path = Application.ExecutablePath.ToLower(); //将当前程序起动路径  
                    string name = System.IO.Path.GetFileName(path);  //获得应用程序名称  
                    var regKey = Microsoft.Win32.Registry.LocalMachine.OpenSubKey(regPath, true);
                    if (regKey != null && regKey.GetValue("LisPacsDataUpload") == null)
                    {
                        regKey = Microsoft.Win32.Registry.LocalMachine.CreateSubKey(regPath);
                        regKey.SetValue("LisPacsDataUpload", path);
                        regKey.Close();
                    }

                    XmlElement element = (XmlElement)xmldoc.SelectSingleNode("/root/key");
                    element.InnerText = "1";
                    xmldoc.Save(xmlpath);
                    ShowLog = "写入注册表成功。";
                    this.SetText(ShowLog);
                    LogHelper.Info("写入注册表成功。");
                }
                else
                {
                    ShowLog = "不允许此操作！";
                    this.SetText(ShowLog);
                    if (checkBox2.Checked)
                    {
                        checkBox2.Checked = false;
                    }
                    else
                    {
                        checkBox2.Checked = true;
                    }
                }

            }
            catch (Exception ex)
            {
                //ShowLog = "不允许此操作！";
                //this.SetText(ShowLog);
                if (checkBox2.Checked)
                {
                    checkBox2.Checked = false;
                }
                else
                {
                    checkBox2.Checked = true;
                }
                ShowLog = "写入注册表异常：" + ex.Message;
                this.SetText(ShowLog);
                LogHelper.Info(ShowLog);

            }
        }

        private void notifyIcon1_MouseClick(object sender, MouseEventArgs e)
        {
            //switch (e.Button)
            //{
            //    case System.Windows.Forms.MouseButtons.Left:    //左击
            //        //判断是否已经最小化于托盘 
            //        if (WindowState == FormWindowState.Minimized)
            //        {
            //            //还原窗体显示 
            //            WindowState = FormWindowState.Normal;
            //            //激活窗体并给予它焦点 
            //            this.Activate();
            //            //任务栏区显示图标 
            //            this.ShowInTaskbar = true;
            //            //托盘区图标隐藏 
            //            notifyIcon1.Visible = false;
            //        }
            //        break;
            //    case System.Windows.Forms.MouseButtons.Right:
            //        //MessageBox.Show("右键");
            //        break;
            //}
        }

        private void open_click(object sender, EventArgs e)
        {
            if (WindowState == FormWindowState.Minimized)
            {
                WindowState = FormWindowState.Normal;
                this.Activate();
                this.ShowInTaskbar = true;
            }
        }

        private void close_click(object sender, EventArgs e)
        {
            //this.Close();
            LogHelper.Info("程序退出。");
            System.Environment.Exit(0);
        }

        private void Form1_SizeChanged(object sender, EventArgs e)
        {
            //判断是否选择的是最小化按钮 
            if (WindowState == FormWindowState.Minimized)
            {
                //托盘显示图标等于托盘图标对象 
                //注意notifyIcon1是控件的名字而不是对象的名字 

                //隐藏任务栏区图标 
                this.ShowInTaskbar = false;
                //图标显示在托盘区 
                notifyIcon1.Visible = true;
            }
        }
        private void DataUpload(object source, EventArgs e)
        {
            LogHelper.Info("开始轮询。");
            DateTime Date = DateTime.Now;
            int time = Date.Hour;
            int StartTime = OracleHelper<object>.StartTime();//18
            if (time == 0)
            {//今日上传数清零
                Lis_total = 0;
                pacs_total = 0;
            }
            else if (time < StartTime && time > 7)//
            {
                ShowLog = "开始轮询时间为[" + StartTime + "]点至明日早上7点，现在是" + time + "点。";
                this.SetText(ShowLog);
                LogHelper.Info(ShowLog);
                if (Directory.Exists(DicLis))
                {
                    Directory.Delete(DicLis, true);
                }
                if (Directory.Exists(DicPacs))
                {
                    Directory.Delete(DicPacs, true);
                }
                DelPDF();
                return;
            }
            LogHelper.Info("zlhr=="+zlhr);
            string name = "LIS1" + Tools.GuidTo16String();
            Thread th = new Thread(new ParameterizedThreadStart(CountUpload));
            th.IsBackground = true;
            th.Name = name;
            th.Start(name);
            System.Threading.Thread.Sleep(5000);
            string name2 = "LIS2" + Tools.GuidTo16String();
            Thread th2 = new Thread(new ParameterizedThreadStart(LisUpload));
            th2.IsBackground = true;
            th2.Name = name2;
            th2.Start(name2);

            // 开启第二个上传
            if (1== open_multiple_upload_flag)
            {
                System.Threading.Thread.Sleep(5000);
                string name3 = "LIS3" + Tools.GuidTo16String();
                Thread th3 = new Thread(new ParameterizedThreadStart(LisUpload2));
                th3.IsBackground = true;
                th3.Name = name3;
                th3.Start(name3);
            }

            if (UploadPacs == 1)//没传影像云的需要上传检查
            {
                LogHelper.Info("没传影像云的需要上传检查");
                Thread thp = new Thread(new ThreadStart(PacsUpload));
                thp.IsBackground = true;
                thp.Name = "PACS" + Tools.GuidTo16String();
                thp.Start();
            }
        }

        private object CountLock = new object();

        private void CountUpload(object Thname)
        {
            try
            {
                lock (CountLock)
                {
                    string Thread_name = "[" + Thname.ToString() + "]";
                    string url = "http://40.26.204.3:8084/phimp-napi/qyhrApplyInfo/upload";
                    int success_count = 0;
                    LogHelper.Info(Thread_name + "上传开单合计开始");


                    string count_sql = @"select * from bill_project_view"
                    ;

                    List<Count> list_count = OracleHelper<Count>.RunQueryList(count_sql);
                    LogHelper.Info("list_count" + list_count);
                    if (list_count.Count < 1)
                    {
                        LogHelper.Info(Thread_name + "本次开单无数据，等待下一次轮询。");
                        LogHelper.Info("执行sql:" + count_sql);
                    }
                    else
                    {
                        for (int i = 0; i < list_count.Count; i++)
                        {
                            if (!isAuthorization())
                            {
                                continue;
                            }

                            Dictionary<string, object> dic_pc = new Dictionary<string, object>();
                            foreach (var property in list_count[i].GetType().GetProperties())
                            {

                                //LogHelper.Info("[count]Name：" + property.Name);
                                //LogHelper.Info("[count]value：" + property.GetValue(list_count[i], null));
                                dic_pc.Add(property.Name, property.GetValue(list_count[i], null));
                            }
                            string json_count = JsonConvert.SerializeObject(dic_pc);
                            string json_count_log = json_count;
                            string vi_count = Tools.GuidTo16String();
                            json_count = Tools.AESEncrypt(json_count, Tools.pwd, vi_count);

                            string res_pacs_pc = Tools.WSCenterData(url, json_count, vi_count, Tools.accessToken, 1);
                            string res_aes_pacs_pc = Tools.AESDecrypt(res_pacs_pc, Tools.pwd, vi_count);
                            ResPacs respacs_pc = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs_pc), Encoding.UTF8);
                            if (respacs_pc.statusCode != "1")
                            {
                                ShowLog = respacs_pc.message + ",[LIS]清单数据上传异常！跳过本条数据上传下一条，偏移量为：" + vi_count;
                                this.SetText(ShowLog);
                                LogHelper.Info(ShowLog);
                                LogHelper.Info("[count]出错入参：" + json_count_log);
                                LogHelper.Info("[LIS]出错入参：" + json_count + "|....|" + Tools.accessToken);
                                LogHelper.Info("[count]出错出参：" + res_aes_pacs_pc);
                                continue;
                            }
                            else
                            {
                                // LogHelper.Info(success_count + "入参：" + json_count_log);
                                //LogHelper.Info(success_count + "出参：" + respacs_pc.message);
                                //修改状态 
                                string sql_upload = @"update 互认开单项目 set 是否上传 = 1,上传时间 = to_date('{1}','yyyy/mm/dd hh24:mi:ss') where 相关id = '{0}'";
                                sql_upload = string.Format(sql_upload, list_count[i].HISAPPLYCODE,  DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int upload_count = OracleHelper<object>.ExecuteNonQuery(sql_upload);
                                LogHelper.Info("清单上传"+ upload_count);
                                success_count++;
                            }
                        }
                        LogHelper.Info("本次清单上传：" + success_count);
                    }
                }
            }
            catch (Exception e)
            {
                LogHelper.Error(e);
            }
        }
        private object LisLock = new object();
        private void LisUpload(object Thname)
        {
            try
            {
                lock (LisLock)
                {
                    string Thread_name = "[" + Thname.ToString() + "]";
                    
                    #region 1、单条上传lis文件及数据
                    LogHelper.Info(Thread_name + "[LIS]开始");
                    string lis_sql = @"select * from( Select rownum rn,b.* From (Select t.* from lis_upload t
                                                       Where 
                                                       t.attachmentId Is Null
                                                       Order By to_date(t.AUDITTIME,'yyyy-mm-dd hh24:mi:ss')
                                                       ) b 
                                           ) where rn <= 150 ";
                    DataTable dt = new DataTable();

                    if (zlhr == zlhrConstant_true)
                    {
                        lis_sql = @"Select t.* from lis_upload t  Where t.attachmentId Is Null
                                                       Order By to_date(t.AUDITTIME,'yyyy-mm-dd hh24:mi:ss') limit 100";
                        dt = OracleHelper<object>.PgQueryDS(lis_sql);
                    }
                    else
                    {
                        dt = OracleHelper<object>.RunQueryDS(lis_sql);
                    }
                    LogHelper.Info("执行sql:" + lis_sql);
                    if (dt.Rows.Count < 1)
                    {
                        LogHelper.Info(Thread_name + "本次[LIS]无数据，等待下一次轮询。");
                    }
                    else
                    {
                        ShowLog = Thread_name + "本次需上传[LIS]数据总条数为[" + dt.Rows.Count + "]条，逐条上传中，请耐心等待。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        int pdfcountAll = 0;
                        int uploaded = 0;
                        for (int i = 0; i < dt.Rows.Count; i++)
                        {
                            //生成pdf
                            string generatePdfUrl = "未生成pdf成功";
                            if (zlhr == zlhrConstant_true)
                            {
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 临生免报告id
                                string sql_zlhr = @"select dr.id as id  from specimen_rec sr, diagnosticreport_rec dr where sr.id = dr.specmids::int
                                  and  dr.status  in ('3003', '3004') and  sr.id = " + requestId;
                                DataTable dt_lis = OracleHelper<object>.PgQueryDS(sql_zlhr);
                                string reportId = dt_lis.Rows[0]["id"].ToString();
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, reportId, reportId,null);
                            }
                            else if(lisSource==3){
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 申请id
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, requestId, requestId,null);
                                if (!generatePdfUrl.Contains(".pdf"))
                                {
                                    LogHelper.Info("生成pdf失败，原因是 = " + generatePdfUrl);
                                    ShowLog = "生成pdf失败，原因是 =" + generatePdfUrl;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                            }
                            else if (lisSource == 10)
                            {
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 申请id
                                string pdfUrl = dt.Rows[i]["pdfUrl"].ToString(); // 三方pdf地址 需要下载

                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, pdfUrl, requestId,null);
                                if (string.IsNullOrEmpty(generatePdfUrl))
                                {
                                    LogHelper.Info("生成pdf失败，原因是 = " + generatePdfUrl);
                                    ShowLog = "生成pdf失败，原因是 =" + generatePdfUrl;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                            }
                            else
                            {
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 申请id
                                //获取标本号 和报表编号
                                string reportNumber = dt.Rows[i]["reportNumber"].ToString(); //报告编号
                                string bbid = dt.Rows[i]["bbid"].ToString();   // 标本id
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, reportNumber, bbid, requestId);
                                if (!generatePdfUrl.Contains(".pdf"))
                                {
                                    LogHelper.Info("生成pdf失败，原因是 = " + generatePdfUrl);
                                    ShowLog = "生成pdf失败，原因是 =" + generatePdfUrl;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                                LogHelper.Info("生成pdf成功，地址为 = " );
                            }
                            //是否授权
                            if (!isAuthorization())
                            {
                                continue;
                            }

                            //最新调整  需要获取 原始pdf 文件  存在场景  有三方lis、中联lis 、 以及专业版临生免 的报告 三种  

                            LogHelper.Info("最后GeneratePdfUrl= ");
                            string attachmentFile = "";
                            if (zlhr == zlhrConstant_true)
                            {
                                attachmentFile = generatePdfUrl;
                            }
                            else
                            {
                                attachmentFile = Tools.FileToBase64Str(generatePdfUrl);
                            }
                            //LogHelper.Info("上传的文件类容==" + attachmentFile);
                            //上传文件
                            string file_json = "{\"attachmentType\":\".pdf\",\"attachmentName\":\"检验报告\",\"businessType\":\"A001\",\"attachmentFile\":\"" + attachmentFile + "\"}";
                            string file_vi = Tools.GuidTo16String();
                            file_json = Tools.AESEncrypt(file_json, Tools.pwd, file_vi);
                            //string file_url = "http://40.26.204.3:8084/phimp-napi/attachMent/upload";
                            //string file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                            string file_res = string.Empty;
                            try
                            {
                                file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                            }
                            catch (Exception e)
                            {

                                //写入后台表机构记录上传错误的数据

                                string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}',{3},{4},0,to_date('{5}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), null, file_json, file_vi, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int err_count = 0;
                                if (zlhr == zlhrConstant_true)
                                {
                                    LogHelper.Info("errSql:" + errSql);
                                    err_count = OracleHelper<object>.PgExecuteNonQuery(errSql);
                                }
                                else
                                {
                                    err_count = OracleHelper<object>.ExecuteNonQuery(errSql);
                                }
                                LogHelper.Info("写入后台表机构记录上传错误的数据" + err_count);
                                LogHelper.Info(e.Message);
                                continue;

                            }

                            string file_res_aes = Tools.AESDecrypt(file_res, Tools.pwd, file_vi);
                            ResFile resfile = Tools.JsonToObject<ResFile>(Tools.FormatStr(file_res_aes), Encoding.UTF8);
                            if (resfile.statusCode != "1")
                            {
                                LogHelper.Info(resfile.message + "，[LIS]PDF文件上传失败！跳过本条数据上传下一条。");
                                LogHelper.Info("入参：" + file_json);
                                LogHelper.Info("出参：" + file_res_aes);
                                ShowLog = "入参：" + file_json + "，出参：" + file_res_aes + "，[LIS]PDF文件上传失败！跳过本条数据上传下一条。";
                                this.SetText(ShowLog);
                                continue;
                            }
                            string sql = @"Insert Into 已上传PDF(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}',0,to_date('{3}','yyyy/mm/dd hh24:mi:ss'))";
                            sql = string.Format(sql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), resfile.mainBody.attachmentId, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                            int file_count = 0;
                            if (zlhr == zlhrConstant_true)
                            {
                                 LogHelper.Info("sql:" + sql);
                                 file_count = OracleHelper<object>.PgExecuteNonQuery(sql);
                            }
                            else
                            {
                                 file_count = OracleHelper<object>.ExecuteNonQuery(sql);
                            }
                            if (file_count < 1)
                            {
                                LogHelper.Info("[LIS]新增表【已上传PDF】失败，跳过本条数据上传下一条！");
                                LogHelper.Info("执行sql:" + sql);
                                ShowLog = "[LIS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + sql;
                                this.SetText(ShowLog);
                                continue;
                            }
                            pdfcountAll += 1;


                            //上传lis数据
                            string item_sql = @"select  a.orgCode,
                                                        a.orgName,
                                                        a.orgThrdCode,
                                                        a.reportId,
                                                        a.reportName,
                                                        a.requestId,
                                                        a.barcode,
                                                        a.sampleNo,
                                                        a.businessNumber,
                                                        a.patientType,
                                                        a.patientName,
                                                        a.patientSex,
                                                        a.patientBirthday,
                                                        a.patientAge,
                                                        a.ageUnit,
                                                        a.patientIdCard,
                                                        a.inpatientAreaName,
                                                        a.roomNo,
                                                        a.bedNo,
                                                        a.phoneNo,
                                                        a.address,
                                                        a.reportType,
                                                        a.reportTypeName,
                                                        a.sampCode,
                                                        a.sampName,
                                                        a.diagnosisCode,
                                                        a.diagnosisName,
                                                        a.resultType,
                                                        a.applyTime,
                                                        a.applyerCode,
                                                        a.applyerName,
                                                        a.applyDeptCode,
                                                        a.applyDeptName,
                                                        a.collectTime,
                                                        a.collectCode,
                                                        a.collectName,
                                                        a.transportCode,
                                                        a.transportName,
                                                        a.transportDeptCode,
                                                        a.transportDeptName,
                                                        a.transportOrgCode,
                                                        a.transportOrgName,
                                                        a.acceptTime,
                                                        a.acceptorCode,
                                                        a.acceptorName,
                                                        a.receiveTime,
                                                        a.receiverCode,
                                                        a.receiverName,
                                                        a.checkTime,
                                                        a.checkerCode,
                                                        a.checkerName,
                                                        a.checkDeptCode,
                                                        a.checkDeptName,
                                                        a.auditTime,
                                                        a.auditorCode,
                                                        a.auditorName,
                                                        a.reportTime,
                                                        a.reportorCode,
                                                        a.reportorName,
                                                        a.sampleNotes,
                                                        a.checkPrice,
                                                        a.attachmentId,
                                                        a.patientId ,
                                                        a.healthNo ,
                                                        a.medicareNo ,
                                                        a.socialNo ,
                                                        a.inpatientAreaCode ,
                                                        a.sampleName ,
                                                        a.execHospitalCode ,
                                                        a.execHospitalName,
                                                        a.sameHospital,
                                                        a.projectCode,
                                                        a.projectName
                                                        from lis_upload a ,已上传PDF b 
                                                           where b.businessnumber = a.BUSINESSNUMBER 
                                                           and b.reportid = a.REPORTID 
                                                           and b.attachmentid is not null
                                                           and b.uploaded = 0
                                                           and b.type = 2
                                                           and a.BUSINESSNUMBER = '{0}'
                                                           and a.REPORTID = '{1}'";
                            item_sql = string.Format(item_sql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString());
                            List<LIS> list = new List<LIS>();
                            if (zlhr == zlhrConstant_true)
                            {
                                list = OracleHelper<LIS>.PgRunQueryList(item_sql);
                            }
                            else
                            {
                                list = OracleHelper<LIS>.RunQueryList(item_sql);
                            }
                            if (list.Count < 1)
                            {
                                LogHelper.Info("查询LIS数据为空，跳过本条数据上传下一条。");
                                LogHelper.Info("执行sql:" + item_sql);
                                continue;
                            }
                            List<Dictionary<string, object>> plist = new List<Dictionary<string, object>>();
                            Dictionary<string, object> dic = new Dictionary<string, object>();
                            foreach (var property in list[0].GetType().GetProperties())
                            {
                                dic.Add(property.Name, property.GetValue(list[0], null));
                            }
                            string lisitems_sql = @"Select * From lis_upload_items t Where t.groupItemCode = '" + list[0].REPORTID + "'";
                            List<LISITEMS> lisitems = new List<LISITEMS>();
                            if (zlhr == zlhrConstant_true)
                            {
                                lisitems = OracleHelper<LISITEMS>.PgRunQueryList(lisitems_sql);
                            }
                            else
                            {
                                lisitems = OracleHelper<LISITEMS>.RunQueryList(lisitems_sql);
                            }
                            if (lisitems.Count < 1)
                            {
                                LogHelper.Info("查询LIS项目指标数据为空，跳过本条数据上传下一条。");
                                LogHelper.Info("执行sql:" + lisitems_sql);
                                continue;
                            }

                            if (zlhr == zlhrConstant_true)
                            {
                                //处理 互认编码的数据 
                                HandleLisItemDataForWebLis(lisitems);
                            }

                            dic.Add("DETAILLIST", lisitems);
                            plist.Add(dic);
                            //是否授权
                            if (!isAuthorization())
                            {
                                continue;
                            }
                            string json_pacs = JsonConvert.SerializeObject(plist);
                            json_pacs = "{\"mainBody\":" + json_pacs + "}";
                            string json_pacs_log = json_pacs;
                            string vi_pacs = Tools.GuidTo16String();
                            json_pacs = Tools.AESEncrypt(json_pacs, Tools.pwd, vi_pacs);
                            string res_pacs = string.Empty;
                            try {
                                res_pacs = Tools.WSCenterData(lis_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                            }
                            catch (Exception e)
                            {

                                //写入后台表机构记录上传错误的数据

                                string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}',{3},{4},0,to_date('{5}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), resfile.mainBody.attachmentId, json_pacs, vi_pacs, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int err_count = 0;
                                if (zlhr == zlhrConstant_true)
                                {
                                    LogHelper.Info("errSql:" + errSql);
                                    err_count = OracleHelper<object>.PgExecuteNonQuery(errSql);
                                }
                                else
                                {
                                    err_count = OracleHelper<object>.ExecuteNonQuery(errSql);
                                }
                                LogHelper.Info("写入后台表机构记录上传错误的数据" + err_count);
                                LogHelper.Info( e.Message);
                                continue;

                            }

                            string res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                            ResPacs respacs = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs), Encoding.UTF8);
                            LogHelper.Info("上传检验报告的接口状态==" + JsonConvert.SerializeObject(respacs));
                            if (respacs.statusCode != "1")
                            {
                                ShowLog = respacs.message + ",[LIS]数据上传异常！跳过本条数据上传下一条，偏移量为：" + vi_pacs;
                                this.SetText(ShowLog);
                                LogHelper.Info(ShowLog);
                                LogHelper.Info("[LIS]出错入参：" + json_pacs_log);
                                LogHelper.Info("[LIS]出错出参：" + res_aes_pacs);
                                continue;
                            }
                            else
                            {
                                Lis_total += 1;
                                uploaded += 1;//(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,UPLOADED) Values('{0}','{1}',2,'{2}',0)
                                string sql_upload = @"update 已上传PDF set UPLOADED = 1,UPLOADE_TIME = to_date('{2}','yyyy/mm/dd hh24:mi:ss') where type = 2
                                                           and BUSINESSNUMBER = '{0}'
                                                           and REPORTID = '{1}'";
                                sql_upload = string.Format(sql_upload, list[0].BUSINESSNUMBER, list[0].REPORTID, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int upload_count = 0;
                                if (zlhr == zlhrConstant_true)
                                {
                                    upload_count = OracleHelper<object>.PgExecuteNonQuery(sql_upload);
                                }
                                else
                                {
                                    upload_count = OracleHelper<object>.ExecuteNonQuery(sql_upload);
                                }
                                if (upload_count < 1)
                                {
                                    LogHelper.Info("[LIS]更新表【已上传PDF】失败，跳过本条数据上传下一条！");
                                    LogHelper.Info("执行sql:" + sql_upload);
                                    ShowLog = "[LIS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + sql_upload;
                                    this.SetText(ShowLog);
                                    continue;
                                }

                            }

                        }

                        ShowLog = Thread_name + "本次已生成、上传[LIS]PDF文件总条数为[" + pdfcountAll + "]条,上传[LIS]总条数为[" + uploaded + "]条。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        GetLisDefault();
                    }


                    #endregion

                    #region 2、补传失败lis数据
                    LogHelper.Info("补传失败lis数据开始");
                    ShowLog = Thread_name + "补传失败lis数据开始";
                    this.SetText(ShowLog);
                    this.SetText("补传失败lis数据开始");
                    int count_pc = 0;
                    string pc_sql = @"select  a.orgCode,
                                                    a.orgName,
                                                    a.orgThrdCode,
                                                    a.reportId,
                                                    a.reportName,
                                                    a.requestId,
                                                    a.barcode,
                                                    a.sampleNo,
                                                    a.businessNumber,
                                                    a.patientType,
                                                    a.patientName,
                                                    a.patientSex,
                                                    a.patientBirthday,
                                                    a.patientAge,
                                                    a.ageUnit,
                                                    a.patientIdCard,
                                                    a.inpatientAreaName,
                                                    a.roomNo,
                                                    a.bedNo,
                                                    a.phoneNo,
                                                    a.address,
                                                    a.reportType,
                                                    a.reportTypeName,
                                                    a.sampCode,
                                                    a.sampName,
                                                    a.diagnosisCode,
                                                    a.diagnosisName,
                                                    a.resultType,
                                                    a.applyTime,
                                                    a.applyerCode,
                                                    a.applyerName,
                                                    a.applyDeptCode,
                                                    a.applyDeptName,
                                                    a.collectTime,
                                                    a.collectCode,
                                                    a.collectName,
                                                    a.transportCode,
                                                    a.transportName,
                                                    a.transportDeptCode,
                                                    a.transportDeptName,
                                                    a.transportOrgCode,
                                                    a.transportOrgName,
                                                    a.acceptTime,
                                                    a.acceptorCode,
                                                    a.acceptorName,
                                                    a.receiveTime,
                                                    a.receiverCode,
                                                    a.receiverName,
                                                    a.checkTime,
                                                    a.checkerCode,
                                                    a.checkerName,
                                                    a.checkDeptCode,
                                                    a.checkDeptName,
                                                    a.auditTime,
                                                    a.auditorCode,
                                                    a.auditorName,
                                                    a.reportTime,
                                                    a.reportorCode,
                                                    a.reportorName,
                                                    a.sampleNotes,
                                                    a.checkPrice,
                                                    a.attachmentId,
                                                    a.patientId ,
                                                    a.healthNo ,
                                                    a.medicareNo ,
                                                    a.socialNo ,
                                                    a.inpatientAreaCode ,
                                                    a.sampleName ,
                                                    a.execHospitalCode ,
                                                    a.execHospitalName,
                                                    a.sameHospital,
                                                    a.projectCode,
                                                    a.projectName
                                                    from lis_upload a ,已上传PDF b 
                                                       where b.businessnumber = a.BUSINESSNUMBER 
                                                       and b.reportid = a.REPORTID 
                                                       and b.attachmentid is not null
                                                       and b.uploaded = 0
                                                       and b.type = 2 ";
                    LogHelper.Info("补传lis数据执行sql:" + pc_sql);
                    List<LIS> list_pc = new List<LIS>();
                    if (zlhr == zlhrConstant_true)
                    {
                        list_pc = OracleHelper<LIS>.PgRunQueryList(pc_sql);
                    }
                    else
                    {
                        list_pc = OracleHelper<LIS>.RunQueryList(pc_sql);
                    }

                    if (list_pc.Count < 1)
                    {
                        LogHelper.Info("查询补传[LIS]数据为空，等待下一次轮询。"+ list_pc.Count);
                        return;
                    }
                    for (int i = 0; i < list_pc.Count; i++)
                    {
                        List<Dictionary<string, object>> plist_pc = new List<Dictionary<string, object>>();
                        Dictionary<string, object> dic_pc = new Dictionary<string, object>();
                        foreach (var property in list_pc[i].GetType().GetProperties())
                        {
                            dic_pc.Add(property.Name, property.GetValue(list_pc[i], null));
                        }
                        string lisitems_sql = @"Select * From lis_upload_items t Where t.groupItemCode = '" + list_pc[i].REPORTID +"'";
                        List<LISITEMS> lisitems = OracleHelper<LISITEMS>.RunQueryList(lisitems_sql);
                        if (zlhr == zlhrConstant_true)
                        {
                            lisitems = OracleHelper<LISITEMS>.PgRunQueryList(lisitems_sql);
                        }
                        else
                        {
                             lisitems = OracleHelper<LISITEMS>.RunQueryList(lisitems_sql);

                        }
                        if (lisitems.Count < 1)
                        {
                            LogHelper.Info("补传查询LIS项目指标数据为空，跳过本条数据上传下一条。");
                            LogHelper.Info("执行sql:" + lisitems_sql);
                            continue;
                        }
                        if (zlhr == zlhrConstant_true)
                        {
                            //处理 互认编码的数据 
                            HandleLisItemDataForWebLis(lisitems);
                        }
                            
                        dic_pc.Add("DETAILLIST", lisitems);
                        plist_pc.Add(dic_pc);
                        //是否授权
                        if (!isAuthorization())
                        {
                            continue;
                        }
                        string json_pacs_pc = JsonConvert.SerializeObject(plist_pc);
                        json_pacs_pc = "{\"mainBody\":" + json_pacs_pc + "}";
                        string json_pacs_log_pc = json_pacs_pc;
                        string vi_pacs_pc = Tools.GuidTo16String();
                        json_pacs_pc = Tools.AESEncrypt(json_pacs_pc, Tools.pwd, vi_pacs_pc);
                        //string url_pacs = "http://40.26.204.3:8084/phimp-napi/qyhrlischeckreportinfo/save";
                        //string res_pacs_pc = Tools.WSCenterData(url, json_pacs_pc, vi_pacs_pc, Tools.accessToken, 1);

                        string res_pacs_pc = string.Empty;
                        try
                        {
                            res_pacs_pc = Tools.WSCenterData(lis_upload_url, json_pacs_pc, vi_pacs_pc, Tools.accessToken, 1);
                        }
                        catch (Exception e)
                        {
                            //写入后台表机构记录上传错误的数据

                            string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}',{3},{4},0,to_date('{5}','yyyy/mm/dd hh24:mi:ss'))";
                            errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), null, json_pacs_pc, vi_pacs_pc, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                            int err_count = 0;
                            if (zlhr == zlhrConstant_true)
                            {
                                LogHelper.Info("errSql:" + errSql);
                                err_count = OracleHelper<object>.PgExecuteNonQuery(errSql);
                            }
                            else
                            {
                                err_count = OracleHelper<object>.ExecuteNonQuery(errSql);
                            }
                            LogHelper.Info("写入后台表机构记录上传错误的数据" + err_count);
                            LogHelper.Info(e.Message);
                            continue;

                        }

                        string res_aes_pacs_pc = Tools.AESDecrypt(res_pacs_pc, Tools.pwd, vi_pacs_pc);
                        ResPacs respacs_pc = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs_pc), Encoding.UTF8);
                        if (respacs_pc.statusCode != "1")
                        {
                            ShowLog = respacs_pc.message + ",补传[LIS]数据上传异常！跳过本条数据上传下一条，偏移量为：" + vi_pacs_pc;
                            this.SetText(ShowLog);
                            LogHelper.Info(ShowLog);
                            LogHelper.Info("[LIS]出错入参：" + json_pacs_log_pc);
                            LogHelper.Info("[LIS]出错出参：" + res_aes_pacs_pc);
                            continue;
                        }
                        else
                        {
                            Lis_total += 1;
                            count_pc += 1;//(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,UPLOADED) Values('{0}','{1}',2,'{2}',0)
                            string sql_upload = @"update 已上传PDF set UPLOADED = 1,UPLOADE_TIME = to_date('{2}','yyyy/mm/dd hh24:mi:ss') where type = 2
                                                       and BUSINESSNUMBER = '{0}'
                                                       and REPORTID = '{1}'";
                            sql_upload = string.Format(sql_upload, list_pc[i].BUSINESSNUMBER, list_pc[i].REPORTID, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                            int upload_count = 0;
                            if (zlhr==zlhrConstant_true)
                            {
                                upload_count = OracleHelper<object>.PgExecuteNonQuery(sql_upload);
                            }
                            else
                            {
                                upload_count = OracleHelper<object>.ExecuteNonQuery(sql_upload);
                            }
                            if (upload_count < 1)
                            {
                                LogHelper.Info("补传[LIS]更新表【已上传PDF】失败，跳过本条数据上传下一条！");
                                LogHelper.Info("执行sql:" + sql_upload);
                                ShowLog = "补传[LIS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + sql_upload;
                                this.SetText(ShowLog);
                                continue;
                            }

                        }
                        ShowLog = Thread_name + "补传第"+i+"条数据成功：医嘱id=" + list_pc[i].REPORTID;
                        this.SetText(ShowLog);
                    }
                    if (count_pc > 0)
                    {
                        ShowLog = Thread_name + "本次补传[LIS]数据为[" + count_pc + "]条，等待下一次轮询。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        GetLisDefault();
                    }

                    #endregion
                }

            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }



        }

        private void HandleLisItemDataForWebLis(List<LISITEMS> items)
        {
            //处理 互认编码的数据
            foreach (LISITEMS item in items)
            {
                string OBVID = item.OBVID;
                string sqlhis = @"select 代码 from zllpmr.字典对码表 where 分类 = '检验互认项目' and 编码 ='{0}'";
                sqlhis = string.Format(sqlhis, OBVID);
                DataTable dtYbCode = OracleHelper<object>.RunQueryDS(sqlhis);
                if (dtYbCode.Rows.Count > 0)
                {
                    //取出诊疗项目id 取获取收费项目的医保编码 并赋值
                    item.STANDARDITEMID = dtYbCode.Rows[0]["代码"].ToString();
                }
            }
        }

        //处理编码的数据 为医保编码数据
        private void HandleLisItemData(List<LISITEMS> items)
        {
            //处理 互认编码的数据
            foreach (LISITEMS item in items)
            {
                string ITEMCODE = item.ITEMCODE;
                string sqlhis = @"Select l.医保编码 From 诊疗项目目录 x,诊疗收费关系 y,收费项目目录 z,保险支付项目 m,互认项目清单 l
                                                  Where y.诊疗项目id = x.id And z.id = y.收费项目id And m.收费细目id = z.Id And l.医保通用编码 = m.项目编码 And Rownum = 1
                                                   And x.类别 = 'C' And m.险类 = 111
                                                   And x.编码 ='{0}'";
                sqlhis = string.Format(sqlhis, ITEMCODE);
                DataTable dtYbCode = OracleHelper<object>.RunQueryDS(sqlhis);
                if (dtYbCode.Rows.Count > 0)
                {
                    //取出诊疗项目id 取获取收费项目的医保编码 并赋值
                    item.STANDARDITEMID = dtYbCode.Rows[0]["医保编码"].ToString();
                }
                // 复制  报告id 
              /*  string ITEMCODE = item.STANDARDITEMID;
                string sqlhis = @"Select l.医保编码 From 诊疗项目目录 x,诊疗收费关系 y,收费项目目录 z,保险支付项目 m,互认项目清单 l
                                                  Where y.诊疗项目id = x.id And z.id = y.收费项目id And m.收费细目id = z.Id And l.医保通用编码 = m.项目编码 And Rownum = 1
                                                   And x.类别 = 'C' And m.险类 = 111
                                                   And x.编码 ='{0}'";
                sqlhis = string.Format(sqlhis, ITEMCODE);
                DataTable dtYbCode = OracleHelper<object>.RunQueryDS(sqlhis);
                if (dtYbCode.Rows.Count > 0)
                {
                    //取出诊疗项目id 取获取收费项目的医保编码 并赋值
                    item.STANDARDITEMID = dtYbCode.Rows[0]["医保编码"].ToString();
                }*/


            }
        }

        private object LisLock2 = new object();
        private void LisUpload2(object Thname)
        {
            try
            {
                lock (LisLock2)
                {
                    string Thread_name = "[" + Thname.ToString() + "]";
                    #region 1、单条上传lis文件及数据
                    LogHelper.Info(Thread_name + "[LIS]开始");
                    string lis_sql = @"select * from( Select rownum rn,b.* From (Select t.* from lis_upload t
                                                       Where 
                                                       t.attachmentId Is Null
                                                       Order By to_date(t.AUDITTIME,'yyyy-mm-dd hh24:mi:ss')
                                                       ) b 
                                           ) where rn <300 and rn >150  ";

                    DataTable dt = new DataTable();
                    if (zlhr == zlhrConstant_true)
                    {
                        /*limit 100  offset 100*/
                        lis_sql = @"Select t.* from lis_upload t  Where t.attachmentId Is Null
                                                       Order By to_date(t.AUDITTIME,'yyyy-mm-dd hh24:mi:ss') limit 100 offset 100";
                        dt = OracleHelper<object>.PgQueryDS(lis_sql);
                    }
                    else
                    {
                        dt = OracleHelper<object>.RunQueryDS(lis_sql);
                    }
                    LogHelper.Info("thread2  " + lis_sql);
                    if (dt.Rows.Count < 1)
                    {
                        LogHelper.Info(Thread_name + " thread2 本次[LIS]无数据，等待下一次轮询。");
                        LogHelper.Info("thread2  执行sql:" + lis_sql);
                    }
                    else
                    {
                        ShowLog = Thread_name + "thread2  本次需上传[LIS]数据总条数为[" + dt.Rows.Count + "]条，逐条上传中，请耐心等待。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        int pdfcountAll = 0;
                        int uploaded = 0;
                        for (int i = 0; i < dt.Rows.Count; i++)
                        {

                            //生成pdf
                            string generatePdfUrl = "未生成pdf成功";
                            if (zlhr == zlhrConstant_true)
                            {
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 临生免报告id
                                string sql_zlhr = @"select dr.id as id  from specimen_rec sr, diagnosticreport_rec dr where sr.id = dr.specmids::int
                                  and  dr.status  in ('3003', '3004') and  sr.id = " + requestId;
                                DataTable dt_lis = OracleHelper<object>.PgQueryDS(sql_zlhr);
                                string reportId = dt_lis.Rows[0]["id"].ToString();
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, reportId, reportId,null);
                            }
                            else if (lisSource == 3)
                            {
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 申请id
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, requestId, requestId, null);
                                if (!generatePdfUrl.Contains(".pdf"))
                                {
                                    LogHelper.Info("生成pdf失败，原因是 = " + generatePdfUrl);
                                    ShowLog = "生成pdf失败，原因是 =" + generatePdfUrl;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                            }
                            else if (lisSource == 10)
                            {
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 申请id
                                string pdfUrl = dt.Rows[i]["pdfUrl"].ToString(); // 三方pdf地址 需要下载

                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, pdfUrl, requestId, null);
                                if (string.IsNullOrEmpty(generatePdfUrl))
                                {
                                    LogHelper.Info("生成pdf失败，原因是 = " + generatePdfUrl);
                                    ShowLog = "生成pdf失败，原因是 =" + generatePdfUrl;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                            }
                            else
                            {
                                string requestId = dt.Rows[i]["requestId"].ToString(); // 申请id
                                //获取标本号 和报表编号
                                string reportNumber = dt.Rows[i]["reportNumber"].ToString(); //报告编号
                                string bbid = dt.Rows[i]["bbid"].ToString();   // 标本id
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, reportNumber, bbid, requestId);
                                if (!generatePdfUrl.Contains(".pdf"))
                                {
                                    LogHelper.Info("生成pdf失败，原因是 = " + generatePdfUrl);
                                    ShowLog = "生成pdf失败，原因是 =" + generatePdfUrl;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                                LogHelper.Info("生成pdf成功，地址为 = " + generatePdfUrl);
                            }
                           
                            //是否授权
                            if (!isAuthorization())
                            {
                                continue;
                            }
                            string attachmentFile = "";
                            if (zlhr == zlhrConstant_true)
                            {
                                attachmentFile = generatePdfUrl;
                            }
                            else
                            {
                                LogHelper.Info("thread2 最后GeneratePdfUrl= " + generatePdfUrl);
                                attachmentFile = Tools.FileToBase64Str(generatePdfUrl);
                            }
                            //上传文件
                            string file_json = "{\"attachmentType\":\".pdf\",\"attachmentName\":\"检验报告\",\"businessType\":\"A001\",\"attachmentFile\":\"" + attachmentFile + "\"}";
                            string file_vi = Tools.GuidTo16String();
                            file_json = Tools.AESEncrypt(file_json, Tools.pwd, file_vi);
                           // string file_url = "http://40.26.204.3:8084/phimp-napi/attachMent/upload";
                            //string file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                            string file_res = string.Empty;
                            try
                            {
                                file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                            }
                            catch (Exception e)
                            {
                                LogHelper.Info("写入后台表机构记录上传错误的数据");
                                //写入后台表机构记录上传错误的数据
                                string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}',{3},{4},0,to_date('{5}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), null, file_json, file_vi, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int err_count = 0;
                                if (zlhr == zlhrConstant_true)
                                {
                                    LogHelper.Info("errSql:" + errSql);
                                    err_count = OracleHelper<object>.PgExecuteNonQuery(errSql);
                                }
                                else
                                {
                                    err_count = OracleHelper<object>.ExecuteNonQuery(errSql);
                                }
                                LogHelper.Info("写入上传错误状态" + err_count);
                                LogHelper.Info(e.Message);
                                continue;

                            }
                            string file_res_aes = Tools.AESDecrypt(file_res, Tools.pwd, file_vi);
                            ResFile resfile = Tools.JsonToObject<ResFile>(Tools.FormatStr(file_res_aes), Encoding.UTF8);
                            if (resfile.statusCode != "1")
                            {
                                LogHelper.Info(resfile.message + "，[LIS]PDF文件上传失败！跳过本条数据上传下一条。thread2 ");
                                LogHelper.Info("入参：" + file_json);
                                LogHelper.Info("出参：" + file_res_aes);
                                ShowLog = "入参：" + file_json + "，出参：" + file_res_aes + "，[LIS]PDF文件上传失败！跳过本条数据上传下一条。";
                                this.SetText(ShowLog);
                                continue;
                            }
                            string sql = @"Insert Into 已上传PDF(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}',0,to_date('{3}','yyyy/mm/dd hh24:mi:ss'))";
                            sql = string.Format(sql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), resfile.mainBody.attachmentId, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                            int file_count = 0;
                            if (zlhr==zlhrConstant_true)
                            {
                                file_count = OracleHelper<object>.PgExecuteNonQuery(sql);
                            }
                            else
                            {
                                file_count = OracleHelper<object>.ExecuteNonQuery(sql);
                            }
                            if (file_count < 1)
                            {
                                LogHelper.Info("thread2  [LIS]新增表【已上传PDF】失败，跳过本条数据上传下一条！");
                                LogHelper.Info("thread2  执行sql:" + sql);
                                ShowLog = "thread2  [LIS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + sql;
                                this.SetText(ShowLog);
                                continue;
                            }
                            pdfcountAll += 1;


                            //上传lis数据
                            string item_sql = @"select  a.orgCode,
                                                        a.orgName,
                                                        a.orgThrdCode,
                                                        a.reportId,
                                                        a.reportName,
                                                        a.requestId,
                                                        a.barcode,
                                                        a.sampleNo,
                                                        a.businessNumber,
                                                        a.patientType,
                                                        a.patientName,
                                                        a.patientSex,
                                                        a.patientBirthday,
                                                        a.patientAge,
                                                        a.ageUnit,
                                                        a.patientIdCard,
                                                        a.inpatientAreaName,
                                                        a.roomNo,
                                                        a.bedNo,
                                                        a.phoneNo,
                                                        a.address,
                                                        a.reportType,
                                                        a.reportTypeName,
                                                        a.sampCode,
                                                        a.sampName,
                                                        a.diagnosisCode,
                                                        a.diagnosisName,
                                                        a.resultType,
                                                        a.applyTime,
                                                        a.applyerCode,
                                                        a.applyerName,
                                                        a.applyDeptCode,
                                                        a.applyDeptName,
                                                        a.collectTime,
                                                        a.collectCode,
                                                        a.collectName,
                                                        a.transportCode,
                                                        a.transportName,
                                                        a.transportDeptCode,
                                                        a.transportDeptName,
                                                        a.transportOrgCode,
                                                        a.transportOrgName,
                                                        a.acceptTime,
                                                        a.acceptorCode,
                                                        a.acceptorName,
                                                        a.receiveTime,
                                                        a.receiverCode,
                                                        a.receiverName,
                                                        a.checkTime,
                                                        a.checkerCode,
                                                        a.checkerName,
                                                        a.checkDeptCode,
                                                        a.checkDeptName,
                                                        a.auditTime,
                                                        a.auditorCode,
                                                        a.auditorName,
                                                        a.reportTime,
                                                        a.reportorCode,
                                                        a.reportorName,
                                                        a.sampleNotes,
                                                        a.checkPrice,
                                                        a.attachmentId,
                                                        a.patientId ,
                                                        a.healthNo ,
                                                        a.medicareNo ,
                                                        a.socialNo ,
                                                        a.inpatientAreaCode ,
                                                        a.sampleName ,
                                                        a.execHospitalCode ,
                                                        a.execHospitalName,
                                                        a.sameHospital,
                                                        a.projectCode,
                                                        a.projectName
                                                        from lis_upload a ,已上传PDF b 
                                                           where b.businessnumber = a.BUSINESSNUMBER 
                                                           and b.reportid = a.REPORTID 
                                                           and b.attachmentid is not null
                                                           and b.uploaded = 0
                                                           and b.type = 2
                                                           and a.BUSINESSNUMBER = '{0}'
                                                           and a.REPORTID = '{1}'";
                            item_sql = string.Format(item_sql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString());
                            List<LIS> list = new List<LIS>();
                            if (zlhr==zlhrConstant_true)
                            {
                                list = OracleHelper<LIS>.PgRunQueryList(item_sql);
                            }
                            else
                            {
                                list = OracleHelper<LIS>.RunQueryList(item_sql);
                            }
                            if (list.Count < 1)
                            {
                                LogHelper.Info("thread2  查询LIS数据为空，跳过本条数据上传下一条。");
                                LogHelper.Info("thread2  执行sql:" + item_sql);
                                continue;
                            }
                            List<Dictionary<string, object>> plist = new List<Dictionary<string, object>>();
                            Dictionary<string, object> dic = new Dictionary<string, object>();
                            foreach (var property in list[0].GetType().GetProperties())
                            {
                                dic.Add(property.Name, property.GetValue(list[0], null));
                            }
                            string lisitems_sql = @"Select* From lis_upload_items t Where t.groupItemCode = '" + list[0].REPORTID + "'";
                           
                            List<LISITEMS> lisitems = new List<LISITEMS>();
                            if (zlhr==zlhrConstant_true)
                            {
                                lisitems = OracleHelper<LISITEMS>.PgRunQueryList(lisitems_sql);
                            }
                            else
                            {
                                lisitems = OracleHelper<LISITEMS>.RunQueryList(lisitems_sql);
                            }
                            if (lisitems.Count < 1)
                            {
                                LogHelper.Info("查询LIS项目指标数据为空，跳过本条数据上传下一条。");
                                LogHelper.Info("执行sql:" + lisitems_sql);
                                continue;
                            }
                            if(zlhr == zlhrConstant_true)
                            {
                                //处理 互认编码的数据 
                                HandleLisItemDataForWebLis(lisitems);
                            }
                            
                            dic.Add("DETAILLIST", lisitems);
                            plist.Add(dic);
                            //是否授权
                            if (!isAuthorization())
                            {
                                continue;
                            }
                            string json_pacs = JsonConvert.SerializeObject(plist);
                            json_pacs = "{\"mainBody\":" + json_pacs + "}";
                            string json_pacs_log = json_pacs;
                            string vi_pacs = Tools.GuidTo16String();
                            json_pacs = Tools.AESEncrypt(json_pacs, Tools.pwd, vi_pacs);
                            //string res_pacs = Tools.WSCenterData(url, json_pacs, vi_pacs, Tools.accessToken, 1);
                            string res_pacs = string.Empty;
                            try
                            {
                                file_res = Tools.WSCenterData(lis_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                            }
                            catch (Exception e)
                            {
                                //写入后台表机构记录上传错误的数据
                                LogHelper.Info("写入后台表机构记录上传错误的数据2");

                               string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}',{3},{4},0,to_date('{5}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), resfile.mainBody.attachmentId, json_pacs, vi_pacs, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int err_count = 0;
                                if (zlhr == zlhrConstant_true)
                                {
                                    LogHelper.Info("errSql:" + errSql);
                                    err_count = OracleHelper<object>.PgExecuteNonQuery(errSql);
                                }
                                else
                                {
                                    err_count = OracleHelper<object>.ExecuteNonQuery(errSql);
                                }
                                LogHelper.Info("写入数据" + err_count);
                                LogHelper.Info(e.Message);
                                continue;
                            }
                            string res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                            ResPacs respacs = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs), Encoding.UTF8);
                            if (respacs.statusCode != "1")
                            {
                                ShowLog = respacs.message + ",thread2 ,[LIS]数据上传异常！跳过本条数据上传下一条，偏移量为：" + vi_pacs;
                                this.SetText(ShowLog);
                                LogHelper.Info(ShowLog);
                                LogHelper.Info("thread2  [LIS]出错入参：" + json_pacs_log);
                                LogHelper.Info("thread2  [LIS]出错出参：" + res_aes_pacs);
                                continue;
                            }
                            else
                            {
                                Lis_total += 1;
                                uploaded += 1;//(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,UPLOADED) Values('{0}','{1}',2,'{2}',0)
                                string sql_upload = @"update 已上传PDF set UPLOADED = 1,UPLOADE_TIME = to_date('{2}','yyyy/mm/dd hh24:mi:ss') where type = 2
                                                           and BUSINESSNUMBER = '{0}'
                                                           and REPORTID = '{1}'";
                                sql_upload = string.Format(sql_upload, list[0].BUSINESSNUMBER, list[0].REPORTID, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int upload_count = 0;
                                if (zlhr==zlhrConstant_true)
                                {
                                    upload_count = OracleHelper<object>.PgExecuteNonQuery(sql_upload);
                                }
                                else
                                {
                                    upload_count = OracleHelper<object>.ExecuteNonQuery(sql_upload);
                                }
                                if (upload_count < 1)
                                {
                                    LogHelper.Info("thread2  [LIS]更新表【已上传PDF】失败，跳过本条数据上传下一条！");
                                    LogHelper.Info("thread2  执行sql:" + sql_upload);
                                    ShowLog = "thread2  [LIS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + sql_upload;
                                    this.SetText(ShowLog);
                                    continue;
                                }

                            }

                        }

                        ShowLog = Thread_name + "thread2  本次已生成、上传[LIS]PDF文件总条数为[" + pdfcountAll + "]条,上传[LIS]总条数为[" + uploaded + "]条。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        GetLisDefault();
                    }
                    #endregion
                }

            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }



        }

        private object PacsLock = new object();
        private void PacsUpload()
        {
            try
            {
                lock (PacsLock)
                {
                    int uploaded = 0;
                    string url_pacs = "http://40.26.204.3:8084/phimp-napi/qyhrpacscheckreportinfo/save";
                    #region 1、生成、上传单条PACS文件及数据
                    LogHelper.Info("[PACS]开始");
                    string sql_pdf = @"select * from (
                                                    Select rownum as rn,b.* From (select t.* from PACS_UPLOAD t 
                                                       Where  t.attachmentId Is Null
                                                       Order By to_date(t.AUDITTIME,'yyyy-mm-dd hh24:mi:ss')
                                                       ) b 
                                           )  Where rn <= 150";
                    DataTable dt = OracleHelper<object>.RunQueryDS(sql_pdf);
                    if (dt.Rows.Count < 1)
                    {
                        LogHelper.Info("本次无数据，或[PACS]PDF已生成并上传。");
                        LogHelper.Info("执行sql:" + sql_pdf);
                    }
                    else
                    {
                        ShowLog = "本次需上传[PACS]数据总条数为[" + dt.Rows.Count + "]条，逐条上传中，请耐心等待。";
                        this.SetText(ShowLog);
                        int countAll = 0;

                        for (int i = 0; i < dt.Rows.Count; i++)
                        {

                            //获取报告数据并生成报告 开始
                            string orgName = dt.Rows[i]["orgName"].ToString();
                            string name = dt.Rows[i]["patientName"].ToString();
                            string sex = dt.Rows[i]["sex"].ToString();
                            string ch = dt.Rows[i]["bedNo"].ToString();
                            string zyh = dt.Rows[i]["zyh"].ToString();
                            string mzh = dt.Rows[i]["mzh"].ToString();//patientType
                            string age = dt.Rows[i]["age"].ToString();
                            string type;
                            string patientType = dt.Rows[i]["patientType"].ToString();
                            string dep = dt.Rows[i]["dep"].ToString();
                            if (patientType == "1")
                            {
                                type = "门诊";
                            }
                            else if (patientType == "2")
                            {
                                type = "住院";
                            }
                            else if (patientType == "3")
                            {
                                type = "体检";
                            }
                            else
                            {
                                type = "其他";
                            }
                            string baseInfo = "姓名：{0}  性别：{1}  年龄：{2}  病人来源：{3}  床号：{4}  住院号：{5}   门诊号：{6}  申请科室：{7}";
                            string findings = dt.Rows[i]["findings"].ToString();
                            string diagnosResult = dt.Rows[i]["diagnosResult"].ToString();
                            string signature = "签名：{0}  日期：{1}";
                            string qname = dt.Rows[i]["auditorName"].ToString();
                            string qdate = dt.Rows[i]["auditTime"].ToString();
                            signature = string.Format(signature, qname, qdate);
                            baseInfo = string.Format(baseInfo, name, sex, age, type, ch, zyh, mzh, dep);
                            string res = CreatePDF(orgName, baseInfo, findings, diagnosResult, signature);
                            if (res == "")
                            {
                                ShowLog = "生成PACS的PDF文件失败。[PACS]上传失败！跳过本条数据上传下一条。";
                                LogHelper.Info(ShowLog);
                                this.SetText(ShowLog);
                                continue;
                            }
                            //获取报告数据并生成报告 结束

                            //是否授权
                            if (!isAuthorization())
                            {
                                continue;
                            }

                            //string path = Application.StartupPath + "\\pacs.pdf";
                            //上传文件
                            string file_json = "{\"attachmentType\":\".pdf\",\"attachmentName\":\"检查报告\",\"businessType\":\"A001\",\"attachmentFile\":\"" + Tools.FileToBase64Str(res) + "\"}";
                            string file_vi = Tools.GuidTo16String();
                            file_json = Tools.AESEncrypt(file_json, Tools.pwd, file_vi);
                            string file_url = "http://40.26.204.3:8084/phimp-napi/attachMent/upload";
                            string file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                            string file_res_aes = Tools.AESDecrypt(file_res, Tools.pwd, file_vi);
                            ResFile resfile = Tools.JsonToObject<ResFile>(Tools.FormatStr(file_res_aes), Encoding.UTF8);
                            if (resfile.statusCode != "1")
                            {
                                //LogHelper.Info(resfile.message + "，[PACS]文件上传失败，跳过本条数据上传下一条。");
                                LogHelper.Info("入参：" + file_json);
                                LogHelper.Info("出参：" + file_res_aes);
                                ShowLog = "入参：" + file_json + "，出参：" + file_res_aes + "，[PACS]文件上传失败，跳过本条数据上传下一条。";
                                this.SetText(ShowLog);
                                continue;
                            }
                            string sql = @"Insert Into 已上传PDF(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',1,'{2}',0, to_date('{3}','yyyy/mm/dd hh24:mi:ss'))";
                            sql = string.Format(sql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), resfile.mainBody.attachmentId, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                            int file_count = OracleHelper<object>.ExecuteNonQuery(sql);
                            if (file_count < 1)
                            {
                                ShowLog = "[PACS]新增表【已上传PDF】失败，跳过本条数据上传下一条。！";
                                LogHelper.Info(ShowLog);
                                this.SetText(ShowLog);
                                continue;
                            }
                            countAll += 1;

                            //上传数据

                            string item_sql = @"select
                                              a.patientAge  ,
                                              a.ageUnit ,
                                              a.patientIdCard ,
                                              a.inTime  ,
                                              a.inpatientAreaName ,
                                              a.roomNo  ,
                                              a.bedNo ,
                                              a.phoneNo ,
                                              a.address ,
                                              a.reportTypeName  ,
                                              a.reportTypeCode  ,
                                              a.diagnosisCode ,
                                              a.diagnosisName ,
                                              a.applyTime ,
                                              a.applyerCode ,
                                              a.applyerName ,
                                              a.applyDeptCode ,
                                              a.applyDeptName ,
                                              a.applyOrgCode  ,
                                              a.applyOrgName  ,
                                              a.receiverTime  ,
                                              a.receiverCode  ,
                                              a.receiverName  ,
                                              a.checkTime ,
                                              a.checkerCode ,
                                              a.checkerName ,
                                              a.checkDeptCode ,
                                              a.checkDeptName ,
                                              a.reportTime  ,
                                              a.reportorCode  ,
                                              a.reportorName  ,
                                              a.auditTime ,
                                              a.auditorCode ,
                                              a.auditorName ,
                                              a.localItemId ,
                                              a.standardItemId  ,
                                              a.itemName  ,
                                              a.purpose ,
                                              a.testPrice ,
                                              a.checkTypeCode ,
                                              a.checkTypeName ,
                                              a.positionCode  ,
                                              a.positionName  ,
                                              a.methodCode  ,
                                              a.methodName  ,
                                              a.isEnganced  ,
                                              a.isMakeShadow  ,
                                              a.process ,
                                              a.findings  ,
                                              a.diagnosResult ,
                                              a.resultType  ,
                                              a.unit  ,
                                              a.machineType ,
                                              a.machineCode ,
                                              a.machineName ,
                                              a.attachmentId  ,
                                              a.studyInstanceUid  ,
                                              a.dicomImgFtpUrl  ,
                                              a.orgCode ,
                                              a.orgName ,
                                              a.pacsYunOrgCode  ,
                                              a.reportId  ,
                                              a.reportName  ,
                                              a.reportType  ,
                                              a.requestId ,
                                              a.businessNumber  ,
                                              a.patientType ,
                                              a.patientName ,
                                              a.patientSex  ,
                                              a.patientBirthday ,
                                              a.regionHr，
                                                a.HEALTHNO,  
                                                a.MEDICARENO ,  
                                                a.ACCESSNUMBER,  
                                                a.CONCLUSION,  
                                                a.BRIEFHISTORY, 
                                                a.ISIMAGESERVICE,  
                                                a.STUDYUID  
                                              from pacs_upload a ,已上传PDF b 
                                                where b.businessnumber = a.BUSINESSNUMBER 
                                                and b.reportid = a.REPORTID 
                                                and b.attachmentid is not null
                                                and b.uploaded = 0
                                                and b.type = 1
                                                and a.BUSINESSNUMBER = '{0}'
                                                and a.REPORTID = '{1}'";
                            item_sql = string.Format(item_sql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString());
                            List<PACS> list = OracleHelper<PACS>.RunQueryList(item_sql);
                            if (list.Count < 1)
                            {
                                LogHelper.Info("查询PACS数据为空，跳过本条数据上传下一条。");
                                LogHelper.Info("执行sql:" + item_sql);
                                continue;
                            }


                            string json_pacs = Tools.ObjectToJson<List<PACS>>(list, Encoding.UTF8);
                            json_pacs = "{\"mainBody\":" + json_pacs + "}";
                            if (!isAuthorization())
                            {
                                continue;
                            }
                            string json_pacs_log = json_pacs;
                            string vi_pacs = Tools.GuidTo16String();
                            json_pacs = Tools.AESEncrypt(json_pacs, Tools.pwd, vi_pacs);
                            string res_pacs = Tools.WSCenterData(url_pacs, json_pacs, vi_pacs, Tools.accessToken, 1);
                            string res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                            //LogHelper.Info("[PACS]上传出参：" + res_aes_pacs);
                            ResPacs respacs = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs), Encoding.UTF8);
                            if (respacs.statusCode != "1")
                            {
                                ShowLog = respacs.message + ",[PACS]数据上传异常！跳过本条数据上传下一条，偏移量为：" + vi_pacs;
                                this.SetText(ShowLog);
                                LogHelper.Info("[PACS]出错入参：" + json_pacs_log);
                                LogHelper.Info("[PACS]出错出参：" + res_aes_pacs);
                                continue;
                            }
                            else
                            {
                                pacs_total += 1;
                                uploaded += 1;//(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,UPLOADED) Values('{0}','{1}',2,'{2}',0)
                                string sql_upload = @"update 已上传PDF set UPLOADED = 1,UPLOADE_TIME = to_date('{2}','yyyy/mm/dd hh24:mi:ss') where type = 1
                                                           and BUSINESSNUMBER = '{0}'
                                                           and REPORTID = '{1}'";
                                sql_upload = string.Format(sql_upload, list[0].BUSINESSNUMBER, list[0].REPORTID, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                                int upload_count = OracleHelper<object>.ExecuteNonQuery(sql_upload);
                                if (upload_count < 1)
                                {
                                    LogHelper.Info("[PACS]更新表【已上传PDF】失败，跳过本条数据上传下一条！");
                                    LogHelper.Info("执行sql:" + sql_upload);
                                    ShowLog = "[PACS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + sql_upload;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                            }
                        }
                        ShowLog = "本次已生成、上传[PACS]PDF文件总条数为[" + countAll + "]条,上传[PACS]总条数为[" + uploaded + "]条。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        GetPacsDefault();

                    }
                    #endregion

                    #region 2、补传失败数据
                    //上传数据
                    LogHelper.Info("PACS补传失败数据");
                        
                    string pc_sql = @"select
                                              a.patientAge  ,
                                              a.ageUnit ,
                                              a.patientIdCard ,
                                              a.inTime  ,
                                              a.inpatientAreaName ,
                                              a.roomNo  ,
                                              a.bedNo ,
                                              a.phoneNo ,
                                              a.address ,
                                              a.reportTypeName  ,
                                              a.reportTypeCode  ,
                                              a.diagnosisCode ,
                                              a.diagnosisName ,
                                              a.applyTime ,
                                              a.applyerCode ,
                                              a.applyerName ,
                                              a.applyDeptCode ,
                                              a.applyDeptName ,
                                              a.applyOrgCode  ,
                                              a.applyOrgName  ,
                                              a.receiverTime  ,
                                              a.receiverCode  ,
                                              a.receiverName  ,
                                              a.checkTime ,
                                              a.checkerCode ,
                                              a.checkerName ,
                                              a.checkDeptCode ,
                                              a.checkDeptName ,
                                              a.reportTime  ,
                                              a.reportorCode  ,
                                              a.reportorName  ,
                                              a.auditTime ,
                                              a.auditorCode ,
                                              a.auditorName ,
                                              a.localItemId ,
                                              a.standardItemId  ,
                                              a.itemName  ,
                                              a.purpose ,
                                              a.testPrice ,
                                              a.checkTypeCode ,
                                              a.checkTypeName ,
                                              a.positionCode  ,
                                              a.positionName  ,
                                              a.methodCode  ,
                                              a.methodName  ,
                                              a.isEnganced  ,
                                              a.isMakeShadow  ,
                                              a.process ,
                                              a.findings  ,
                                              a.diagnosResult ,
                                              a.resultType  ,
                                              a.unit  ,
                                              a.machineType ,
                                              a.machineCode ,
                                              a.machineName ,
                                              a.attachmentId  ,
                                              a.studyInstanceUid  ,
                                              a.dicomImgFtpUrl  ,
                                              a.orgCode ,
                                              a.orgName ,
                                              a.pacsYunOrgCode  ,
                                              a.reportId  ,
                                              a.reportName  ,
                                              a.reportType  ,
                                              a.requestId ,
                                              a.businessNumber  ,
                                              a.patientType ,
                                              a.patientName ,
                                              a.patientSex  ,
                                              a.patientBirthday ,
                                              a.regionHr，
                                                a.HEALTHNO,  
                                                a.MEDICARENO ,  
                                                a.ACCESSNUMBER,  
                                                a.CONCLUSION,  
                                                a.BRIEFHISTORY, 
                                                a.ISIMAGESERVICE,  
                                                a.STUDYUID  
                                              from pacs_upload a ,已上传PDF b 
                                                where b.businessnumber = a.BUSINESSNUMBER 
                                                and b.reportid = a.REPORTID 
                                                and b.attachmentid is not null
                                                and b.uploaded = 0
                                                and b.type = 1";
                    List<PACS> list_pc = OracleHelper<PACS>.RunQueryList(pc_sql);
                    if (list_pc.Count < 1)
                    {
                        LogHelper.Info("查询补传PACS数据为空，等待下一次轮询。");
                        LogHelper.Info("执行sql:" + pc_sql);
                        return;
                    }
                    int count_pc = 0;
                    for (int i = 0; i < list_pc.Count; i++)
                    {
                        if (!isAuthorization())
                        {
                            continue;
                        }
                        string json_pacs = Tools.ObjectToJson<List<PACS>>(list_pc[i], Encoding.UTF8);
                        json_pacs = "{\"mainBody\":[" + json_pacs + "]}";
                        string json_pacs_log = json_pacs;
                        string vi_pacs = Tools.GuidTo16String();
                        json_pacs = Tools.AESEncrypt(json_pacs, Tools.pwd, vi_pacs);
                        string res_pacs = Tools.WSCenterData(url_pacs, json_pacs, vi_pacs, Tools.accessToken, 1);
                        string res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                        //LogHelper.Info("[PACS]上传出参：" + res_aes_pacs);
                        ResPacs respacs = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs), Encoding.UTF8);
                        if (respacs.statusCode != "1")
                        {
                            ShowLog = respacs.message + ",[PACS]数据上传异常！跳过本条数据上传下一条，偏移量为：" + vi_pacs;
                            this.SetText(ShowLog);
                            LogHelper.Info("[PACS]出错入参：" + json_pacs_log);
                            LogHelper.Info("[PACS]出错出参：" + res_aes_pacs);
                            continue;
                        }
                        else
                        {
                            pacs_total += 1;
                            count_pc += 1;
                            string sql_upload = @"update 已上传PDF set UPLOADED = 1,UPLOADE_TIME = to_date('{2}','yyyy/mm/dd hh24:mi:ss') where type = 1
                                                           and BUSINESSNUMBER = '{0}'
                                                           and REPORTID = '{1}'";
                            sql_upload = string.Format(sql_upload, list_pc[i].BUSINESSNUMBER, list_pc[i].REPORTID, DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                            int upload_count = OracleHelper<object>.ExecuteNonQuery(sql_upload);
                            if (upload_count < 1)
                            {
                                LogHelper.Info("[PACS]更新表【已上传PDF】失败，跳过本条数据上传下一条！");
                                LogHelper.Info("执行sql:" + sql_upload);
                                ShowLog = "[PACS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + sql_upload;
                                this.SetText(ShowLog);
                                continue;
                            }
                        }
                    }
                    if (count_pc > 0)
                    {
                        ShowLog = "本次补传[PACS]数据为[" + count_pc + "]条，等待下一次轮询。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        GetPacsDefault();
                    }
                    #endregion
                }

            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }


        }
        /// <summary>
        /// 生成pdf
        /// </summary>
        /// <param name="orgName">印江自治县人民医院</param>
        /// <param name="baseInfo">"姓名：刘蚝  性别：男  年龄：20岁  床号：8床  住院号：20121545   门诊号：65478854"</param>
        /// <param name="findings"></param>
        /// <param name="diagnosResult"></param>
        /// <param name="signature">签名：杨添红  日期：2022.9.7</param>
        private string CreatePDF(string orgName, string baseInfo, string findings, string diagnosResult, string signature)
        {
            string res = "";
            try
            {
                Document document = new Document(HeaderAndFooterEvent.rect);
                //string dic = AppDomain.CurrentDomain.BaseDirectory + "Pacs\\";
                if (!Directory.Exists(DicPacs))
                {
                    Directory.CreateDirectory(DicPacs);
                }
                string path = DicPacs + Guid.NewGuid() + ".pdf";
                //此处使用的是http请求的流，你也可以使用文件流Stream
                FileStream str = new FileStream(path, FileMode.Create);
                PdfWriter writer = PdfWriter.GetInstance(document, str);
                document.Open();
                writer.PageEvent = new HeaderAndFooterEvent();
                HeaderAndFooterEvent.PAGE_NUMBER = false;//实现页眉跟页脚  
                HeaderAndFooterEvent.tpl = writer.DirectContent.CreateTemplate(500, 500); //定义模板                                                                                                                 

                //印江自治县人民医院
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph(orgName, 1, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph("检查报告单", 1, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                document.Add(HeaderAndFooterEvent.AddParagraph(baseInfo, 0, 3f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph("   ", 1, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                document.Add(HeaderAndFooterEvent.AddParagraph(@"诊断意见：" + diagnosResult, 0, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                document.Add(HeaderAndFooterEvent.AddParagraph(@"检查所见：" + findings, 0, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph("   ", 1, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                document.Add(HeaderAndFooterEvent.AddParagraph(signature, 2, 1.5f));
                writer.Flush();
                writer.CloseStream = true;
                document.Close();
                //writer.Close();
                //str.Close();
                res = path;
            }
            catch (Exception ex)
            {
                res = "";
                LogHelper.Error(ex);
            }
            return res;
        }
        private string CreateLisPDF(string orgName, string baseInfo, DataTable dt, string signature, string title)
        {
            string res = "";
            try
            {
                Document document = new Document(HeaderAndFooterEvent.rect);
                //此处使用的是http请求的流，你也可以使用文件流Stream
                //string dic = AppDomain.CurrentDomain.BaseDirectory + "Lis\\";
                if (!Directory.Exists(DicLis))
                {
                    Directory.CreateDirectory(DicLis);
                }
                string path = DicLis + Guid.NewGuid() + ".pdf";
                FileStream str = new FileStream(path, FileMode.Create);
                PdfWriter writer = PdfWriter.GetInstance(document, str);
                document.Open();
                writer.PageEvent = new HeaderAndFooterEvent();
                HeaderAndFooterEvent.PAGE_NUMBER = false;//实现页眉跟页脚  
                HeaderAndFooterEvent.tpl = writer.DirectContent.CreateTemplate(500, 500); //定义模板                                                                                                                 

                //印江自治县人民医院
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph(orgName, 1, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph(title + "报告单", 1, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                document.Add(HeaderAndFooterEvent.AddParagraph(baseInfo, 0, 3f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph("   ", 1, 1.5f));
                //HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                //document.Add(HeaderAndFooterEvent.AddParagraph(@"序号   项目         结果       单位      参考区间", 0, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                HeaderAndFooterEvent.CreateTable(dt, document);
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 12);
                document.Add(HeaderAndFooterEvent.AddParagraph("   ", 1, 1.5f));
                HeaderAndFooterEvent.SetFont(BaseColor.DARK_GRAY, "宋体", 8);
                document.Add(HeaderAndFooterEvent.AddParagraph(signature, 2, 1.5f));
                writer.Flush();
                writer.CloseStream = true;
                document.Close();
                res = path;
            }
            catch (Exception ex)
            {
                LogHelper.Info("CreateLisPDF 生成失败");
                res = "";
                LogHelper.Error(ex);
            }
            return res;
        }
        //token是否过期
        private bool isAuthorization()
        {
            bool result = true;
            if (string.IsNullOrWhiteSpace(Tools.accessToken) || Tools.DateTimes == null || Tools.DateTimes <= DateTime.Now)
            {
                //获取授权
                string vi = Tools.GuidTo16String();
                string url = "http://40.26.204.3:8084/phimp-napi/token";
                string res = Tools.WSCenterData(url, "", vi);
                string res_aes = Tools.AESDecrypt(res, Tools.pwd, vi);
                Authorization ahz = Tools.JsonToObject<Authorization>(Tools.FormatStr(res_aes), Encoding.UTF8);
                if (ahz.statusCode != "1")
                {
                    ShowLog = ahz.message + "，获取Token授权失败！等待下一次轮询。";
                    this.SetText(ShowLog);
                    LogHelper.Info(ShowLog);
                    result = false;
                }
                Tools.accessToken = ahz.mainBody.accessToken;
                Tools.DateTimes = DateTime.Now.AddSeconds(int.Parse(ahz.mainBody.expirationTime));
            }
            return result;
        }
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            if (e.CloseReason == CloseReason.UserClosing)
            {
                //是否取消close操作
                e.Cancel = true;
                this.WindowState = FormWindowState.Minimized;
            }
        }

        private void checkBox1_Click(object sender, EventArgs e)
        {
            int hr = 0;
            string sql = @"update 互认配置表 set 互认 = {0}";
            bool bl = checkBox1.Checked;
            if (checkBox1.Checked)
            {
                hr = 1;
            }
            sql = string.Format(sql, hr);
            int res = OracleHelper<object>.ExecuteNonQuery(sql);
            if (res > 0)
            {
                if (bl)
                {
                    textBox1.Text = "已修改为互认！";
                }
                else
                {
                    textBox1.Text = "已修改为不互认！";
                }

            }
            else
            {
                textBox1.Text = "是否互认修改失败！";
                if (bl)
                {
                    checkBox1.Checked = false;
                }
                else
                {
                    checkBox1.Checked = true;
                }
            }


        }

        private void checkBox2_CheckedChanged(object sender, EventArgs e)
        {
            AutoStart();
        }

        public void GetLisDefault()
        {
            string sql = @"select count(1) listotal from lis_upload  where attachmentId is null";
            DataTable dt = new DataTable();
            if (zlhr==zlhrConstant_true)
            {
                dt = OracleHelper<object>.PgQueryDS(sql);
            }
            else
            {
                 dt = OracleHelper<object>.RunQueryDS(sql);
            }
            string label_lis = dt.Rows[0]["listotal"].ToString() + "条";
            string lis_count = Lis_total + "条";
            this.SetLisText(label_lis);
            this.SetLisCountText(lis_count);
            //获取待上传的数量

            string waitsql = @"select count(1) listotal from lis_upload a ,已上传PDF b 
                                                where b.businessnumber = a.BUSINESSNUMBER 
                                                and b.reportid = a.REPORTID 
                                                and b.attachmentid is not null
                                                and b.uploaded = 0
                                                and b.type = 2";
            DataTable waitdt = new DataTable();
            if (zlhr == zlhrConstant_true)
            {
                waitdt = OracleHelper<object>.PgQueryDS(waitsql);
            }
            else
            {
                waitdt = OracleHelper<object>.RunQueryDS(sql);
            }
            LogHelper.Info("待上传数量为：" + waitdt.Rows[0]["listotal"].ToString() + "条");
        }

        public void GetPacsDefault()
        {
            string sql = @"select count(1) pacstotal from pacs_upload  where attachmentId is null";
            DataTable dt = OracleHelper<object>.RunQueryDS(sql);
            string label_pacs = dt.Rows[0]["pacstotal"].ToString() + "条";
            string pacs_count = pacs_total + "条";
            this.SetPassText(label_pacs);
            this.SetPacsCountText(pacs_count);

        }

        private void SetText(string text)
        {
            // InvokeRequired需要比较调用线程ID和创建线程ID
            // 如果它们不相同则返回true
            if (this.textBox1.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(SetText);
                this.Invoke(d, new object[] { text });
            }
            else
            {
                this.textBox1.Text = text;

            }
        }

        private void SetLisText(string text)
        {
            // InvokeRequired需要比较调用线程ID和创建线程ID
            // 如果它们不相同则返回true
            if (this.textBox1.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(SetLisText);
                this.Invoke(d, new object[] { text });
            }
            else
            {
                this.label_lis.Text = text;

            }
        }

        private void SetPassText(string text)
        {
            // InvokeRequired需要比较调用线程ID和创建线程ID
            // 如果它们不相同则返回true
            if (this.textBox1.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(SetPassText);
                this.Invoke(d, new object[] { text });
            }
            else
            {
                this.label_pacs.Text = text;

            }
        }

        private void SetLisCountText(string text)
        {
            // InvokeRequired需要比较调用线程ID和创建线程ID
            // 如果它们不相同则返回true
            if (this.textBox1.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(SetLisCountText);
                this.Invoke(d, new object[] { text });
            }
            else
            {
                this.lis_count.Text = text;

            }
        }
        private void SetPacsCountText(string text)
        {
            // InvokeRequired需要比较调用线程ID和创建线程ID
            // 如果它们不相同则返回true
            if (this.textBox1.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(SetPacsCountText);
                this.Invoke(d, new object[] { text });
            }
            else
            {
                this.pacs_count.Text = text;

            }
        }

        private void DelPDF()
        {
            //每月1号删除
            if (DateTime.Now.Day != 1)
            {
                return;
            }
            int month = OracleHelper<object>.UploadTime();
            if (month < 1)
            {
                return;
            }
            string sql = @"delete from 已上传PDF a where a.uploaded = 1 And a.Uploade_Time < add_months(Sysdate,-{0})";
            sql = string.Format(sql,month);
            OracleHelper<object>.ExecuteNonQuery(sql);
            
        }
    }
}