ZLPlugin_LisPacs_MR_NEW/LisPacsDataUpload/Form1.cs

using Common;
using iTextSharp.text;
using iTextSharp.text.pdf;
using LisPacsDataUpload.business;
using LisPacsDataUpload.Models;
using LisPacsDataUpload.services;
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 int UploadLis;//是否上传 Lis
        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 pacsSource = 1;// 0中联老版pacs      2  专业版pacs    3 三方pacs
        private int open_multiple_upload_flag = 0;// 开启多个线程上传

        string lis_upload_url = "http://40.26.204.3:8084/phimp-napi/qyhrlischeckreportinfo/save"; //lis 上传接口地址
        string pacs_upload_url = "http://40.26.204.3:8084/phimp-napi/qyhrpacscheckreportinfo/save"; //pacs 上传地址

        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();
            UploadLis = OracleHelper<object>.UploadLis();
            if (UploadLis == 1)
            {
                GetLisDefault();
            }
            if (UploadPacs == 1)
            {
                GetPacsDefault();
            }
            //AutoStart();
            DataUpload(sender, e);
        }
        private void ShowCheckBox1()
        {

            try
            {
                string sql_lis = @"select 互认,zlhr,open_multiple_upload,lis_source ,pacs_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());
                pacsSource = int.Parse(dt_lis.Rows[0]["pacs_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);
            if (UploadLis == 1)
            {
                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 = "LIS1" + 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 = "LIS2" + Tools.GuidTo16String();
                    Thread th3 = new Thread(new ParameterizedThreadStart(LisUpload2));
                    th3.IsBackground = true;
                    th3.Name = name3;
                    th3.Start(name3);
                }
            }
            //  这里特俗 直接借用时间点控制是否补传
            if (StartTime == 7)
            {
                System.Threading.Thread.Sleep(5000);
                string namecompletUpload = "LisCompletUpload" + Tools.GuidTo16String();
                Thread thredcompletUpload = new Thread(new ParameterizedThreadStart(LisCompletUpload));
                thredcompletUpload.IsBackground = true;
                thredcompletUpload.Name = namecompletUpload;
                thredcompletUpload.Start(namecompletUpload);
            }

            if (UploadPacs == 1)//没传影像云的需要上传检查
            {
                LogHelper.Info("没传影像云的需要上传检查");
                Thread thp = new Thread(new ThreadStart(PacsUploadNew));
                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 bill_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_pacs_pc = string.Empty;
                            string res_aes_pacs_pc = string.Empty;
                            try
                            {
                                res_pacs_pc = Tools.WSCenterData(bill_url, json_count, vi_count, Tools.accessToken, 1);
                                res_aes_pacs_pc = Tools.AESDecrypt(res_pacs_pc, Tools.pwd, vi_count);
                            }
                            catch (Exception e)
                            {
                                LogHelper.Error(e,"开单项目上传异常");
                                LogHelper.Error(e, "开单项目上传异常 res_aes_pacs_pc"+ res_aes_pacs_pc);
                                continue;
                            }
                            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 object LisLockComplet = 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
                                                       ) 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 t.AUDITTIME desc 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++)
                        {
                            string reportId = dt.Rows[i]["reportId"].ToString();
                            string requestId = dt.Rows[i]["requestId"].ToString();
                            
                            //生成pdf
                            string generatePdfUrl = "未生成pdf成功";
                            if (zlhr == zlhrConstant_true)
                            {
                                // 临生免报告id  requestId
                                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 id = dt_lis.Rows[0]["id"].ToString();
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, id, id, null);
                            }
                            else if(lisSource==3){
                                 // 申请id requestId
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, reportId, requestId, null);
                                if (!generatePdfUrl.Contains(".pdf"))
                                {
                                    LogHelper.Info("生成pdf失败，原因是 = " + generatePdfUrl);
                                    ShowLog = "生成pdf失败，原因是 =" + generatePdfUrl;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                            }
                            else if (lisSource == 10)
                            {
                                 // 申请id requestId
                                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
                            {
                                // 申请id requestId
                                //获取标本号 和报表编号
                                //报告编号  reportNumber
                                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;
                                }
                            }
                            //是否授权
                            if (!isAuthorization())
                            {
                                continue;
                            }

                            //最新调整  需要获取 原始pdf 文件  存在场景  有三方lis、中联lis 、 以及专业版临生免 的报告 三种  
                            string attachmentFile = "";
                            if (zlhr == zlhrConstant_true)
                            {
                                attachmentFile = generatePdfUrl;
                            }
                            else
                            {
                                LogHelper.Info("generatePdfUrl=" + generatePdfUrl);
                                attachmentFile = Tools.FileToBase64Str(generatePdfUrl);
                            }
                            //LogHelper.Info("上传的文件类容==" + attachmentFile);
                            //上传文件
                            string file_json = "{\"attachmentType\":\".pdf\",\"attachmentName\":\"检验报告\",\"businessType\":\"A001\",\"attachmentFile\":\"" + attachmentFile + "\"}";
                            string file_json_string = file_json;
                            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;
                            string file_res_aes = string.Empty;
                            try
                            {
                                file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                                file_res_aes = Tools.AESDecrypt(file_res, Tools.pwd, file_vi);
                            }catch (Exception e)
                            {
                                LogHelper.Info("1上传报告异常");
                                LogHelper.Info("file_res=="+ file_res);
                                //写入后台表机构记录上传错误的数据
                                string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,REASON,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}','{3}','{4}','{5}',0,to_date('{6}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), null, null,e.Message, 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;

                            }
                            LogHelper.Info("file_res_aes==="+ file_res_aes);
                            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;

                            string businessNumber = dt.Rows[i]["businessNumber"].ToString();
                            //string reportId = dt.Rows[i]["reportId"].ToString();
                            //上传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,
                                                        b.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, businessNumber, reportId);
                            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;
                            string res_aes_pacs = string.Empty;
                            try {
                                res_pacs = Tools.WSCenterData(lis_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                                res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                            }
                            catch (Exception e)
                            {
                                //写入后台表机构记录上传错误的数据
                                string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,REASON,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}','{3}','{4}','{5}',0,to_date('{6}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, businessNumber, reportId, resfile.mainBody.attachmentId,null,e.Message, 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;
                            }
                            ResPacs respacs = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs), Encoding.UTF8);
                            LogHelper.Info(reportId+":lis1上传检验报告的接口状态==" + JsonConvert.SerializeObject(respacs));
                            if (respacs.statusCode != "1")
                            {
                                ShowLog = respacs.message + ",[LIS]数据上传异常！跳过本条数据上传下一条，偏移量为：reportId=" + reportId;
                                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 * from lis_complet_upload ";
                    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;
                        string res_aes_pacs_pc = string.Empty;
                        try
                        {
                            res_pacs_pc = Tools.WSCenterData(lis_upload_url, json_pacs_pc, vi_pacs_pc, Tools.accessToken, 1);
                             res_aes_pacs_pc = Tools.AESDecrypt(res_pacs_pc, Tools.pwd, vi_pacs_pc);
                        }
                        catch (Exception e)
                        {
                            //写入后台表机构记录上传错误的数据

                            string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,REASON,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}','{3}','{4}','{5}',0,to_date('{6}','yyyy/mm/dd hh24:mi:ss'))";
                            errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), null, null,e.Message, 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;
                        }
                        
                        ResPacs respacs_pc = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs_pc), Encoding.UTF8);
                        if (respacs_pc.statusCode != "1")
                        {
                            ShowLog = respacs_pc.message + ",补传[LIS]数据上传异常！跳过本条数据上传下一条，偏移量为：reportId=" + list_pc[i].REPORTID;
                            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 LisCompletUpload(object Thname)
        {
            try
            {
                lock (LisLockComplet)
                {
                    string Thread_name = "[" + Thname.ToString() + "]";
                    #region 2、补传失败lis数据
                    LogHelper.Info("LisCompletUpload补传lis数据开始");
                    ShowLog = Thread_name + "LisCompletUpload补传lis数据开始";
                    this.SetText(ShowLog);
                    this.SetText("补传lis数据开始");
                    int count_pc = 0;
                    string pc_sql = @"select * from lis_complet_upload  ";
                    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 + "}";
                        //LogHelper.Info("上传data" +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;
                        string res_aes_pacs_pc = string.Empty;
                        try
                        {
                            res_pacs_pc = Tools.WSCenterData(lis_upload_url, json_pacs_pc, vi_pacs_pc, Tools.accessToken, 1);
                             res_aes_pacs_pc = Tools.AESDecrypt(res_pacs_pc, Tools.pwd, vi_pacs_pc);
                        }
                        catch (Exception e)
                        {
                            //写入后台表机构记录上传错误的数据

                            string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,REASON,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}','{3}','{4}','{5}',0,to_date('{6}','yyyy/mm/dd hh24:mi:ss'))";
                            errSql = string.Format(errSql, list_pc[i].BUSINESSNUMBER, list_pc[i].REPORTID, null, null,e.Message, 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;

                        }
                        ResPacs respacs_pc = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs_pc), Encoding.UTF8);
                        if (respacs_pc.statusCode != "1")
                        {
                            ShowLog = respacs_pc.message + ",补传[LIS]数据上传异常！跳过本条数据上传下一条，偏移量为：REPORTID=" + list_pc[i].REPORTID;
                            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
                                                       ) 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++)
                        {
                            string businessNumber = dt.Rows[i]["businessNumber"].ToString();
                            string reportId = dt.Rows[i]["reportId"].ToString();

                            string requestId = dt.Rows[i]["requestId"].ToString();
                            //生成pdf
                            string generatePdfUrl = "未生成pdf成功";
                            if (zlhr == zlhrConstant_true)
                            {
                                // 临生免报告id requestId
                                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 id = dt_lis.Rows[0]["id"].ToString();
                                generatePdfUrl = PdfUtils.GeneratePdf(lisSource, id, id, null);
                            }
                            else if (lisSource == 3)
                            {
                                 // 申请id requestId
                                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)
                            {
                                // 申请id requestId 
                                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
                            {
                                // 申请id requestId
                                //获取标本号 和报表编号
                                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_json_string = file_json;
                            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;
                            string file_res_aes = string.Empty;
                            try
                            {
                                file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                                 file_res_aes = Tools.AESDecrypt(file_res, Tools.pwd, file_vi);
                            }
                            catch (Exception e)
                            {
                                LogHelper.Info("写入后台表机构记录上传错误的数据");
                                //写入后台表机构记录上传错误的数据
                                string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,REASON,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}','{3}','{4}','{5}',0,to_date('{6}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, businessNumber, reportId, null, null,e.Message, 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;

                            }
                            
                            ResFile resfile = Tools.JsonToObject<ResFile>(Tools.FormatStr(file_res_aes), Encoding.UTF8);
                            if (resfile.statusCode != "1")
                            {
                                LogHelper.Info(resfile.message + "，[LIS]PDF文件上传失败！跳过本条数据上传下一条。thread2 reportId="+ reportId);
                                LogHelper.Info("入参：" + file_json);
                                LogHelper.Info("出参：" + file_res_aes);
                                ShowLog = "入参：" + file_json + "，出参：" + file_res_aes + "，[LIS]PDF文件上传失败！跳过本条数据上传下一条。" + reportId;
                                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, businessNumber, reportId, 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,
                                                        b.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, businessNumber, reportId);
                            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;
                            string res_aes_pacs = string.Empty;
                            try
                            {
                                file_res = Tools.WSCenterData(lis_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                                 res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                            }
                            catch (Exception e)
                            {
                                //写入后台表机构记录上传错误的数据
                                LogHelper.Info("写入后台表机构记录上传错误的数据2");

                               string errSql = @"Insert Into 互认报告上传异常记录(BUSINESSNUMBER,REPORTID,TYPE,ATTACHMENTID,REQUEST_DATA,REASON,IV,UPLOADED,UPLOADE_TIME) Values('{0}','{1}',2,'{2}','{3}','{4}','{5}',0,to_date('{6}','yyyy/mm/dd hh24:mi:ss'))";
                                errSql = string.Format(errSql, dt.Rows[i]["businessNumber"].ToString(), dt.Rows[i]["reportId"].ToString(), resfile.mainBody.attachmentId,null, e.Message, 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;
                            }
                            
                            ResPacs respacs = Tools.JsonToObject<ResPacs>(Tools.FormatStr(res_aes_pacs), Encoding.UTF8);
                            LogHelper.Info(reportId + ":lis2上传检验报告的接口状态==" + JsonConvert.SerializeObject(respacs));
                            if (respacs.statusCode != "1")
                            {
                                ShowLog = respacs.message + ",thread2 ,[LIS]数据上传异常！跳过本条数据上传下一条，偏移量为：REPORTID=" + list[0].REPORTID;
                                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
                                                       ) 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=string.Empty;
                            string file_res_aes = string.Empty;
                            try
                            {
                                file_res = Tools.WSCenterData(file_url, file_json, file_vi, Tools.accessToken, 1);
                                 file_res_aes = Tools.AESDecrypt(file_res, Tools.pwd, file_vi);
                            }
                            catch (Exception e)
                            {
                                LogHelper.Error(e, "pacs 报告生成上传失败");
                                continue;
                            }
                            
                            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 ,
                                              b.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_pacs = string.Empty;
                            string res_aes_pacs = string.Empty;
                            try
                            {
                                res_pacs = Tools.WSCenterData(url_pacs, json_pacs, vi_pacs, Tools.accessToken, 1);
                                 res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                            }
                            catch (Exception e)
                            {
                                LogHelper.Error(e, "pacs 报告上传失败");
                                continue;
                            }
                            
                            //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 ,
                                              b.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_pacs = string.Empty;
                        string res_aes_pacs = string.Empty;
                        try
                        {
                            res_pacs = Tools.WSCenterData(url_pacs, json_pacs, vi_pacs, Tools.accessToken, 1);
                             res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                        }
                        catch (Exception e)
                        {
                            LogHelper.Error(e, "pacs 报告补传失败");
                            continue;
                        }
                        
                        //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);
            }


        }

        private void PacsUploadNew()
        {
            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]开始");
                    
                    DataTable dt = PacsUploadServiceImpl.getPacsDataTable();
                    if (dt.Rows.Count > 0)
                    {
                        ShowLog = "本次需上传[PACS]数据总条数为[" + dt.Rows.Count + "]条，逐条上传中，请耐心等待。";
                        this.SetText(ShowLog);
                        int countAll = 0;
                        for (int i = 0; i < dt.Rows.Count; i++)
                        {
                           string reportId =  dt.Rows[i]["reportId"].ToString();
                            string businessNumber = dt.Rows[i]["businessNumber"].ToString();
                            string YZID = dt.Rows[i]["YZID"].ToString();
                            string reportNumber = dt.Rows[i]["reportNumber"].ToString();
                            #region 获取报告数据并生成报告 开始
                            /*
                            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;
                            }
                            //获取报告数据并生成报告 结束*/
                            #endregion
                            // 这里需要获取原始报告
                            string res = "";
                            if (pacsSource==0)
                            {
                                res = PdfUtils.GeneratePacsPdf(pacsSource,reportNumber, null, YZID);
                            }
                            if (!res.Contains(".pdf"))
                            {
                                LogHelper.Info("生成pdf失败，原因是 = " + res);
                                ShowLog = "生成pdf失败，原因是 =" + res;
                                this.SetText(ShowLog);
                                continue;
                            }
                            LogHelper.Info("生成pdf成功，地址为 = " + res);

                            //是否授权
                            if (!isAuthorization())
                            {
                                continue;
                            }
                            string base64FileContent = Tools.FileToBase64Str(res);

                            ResFile resfile = PdfUtils.uploadFileToPlatform(file_url, base64FileContent);
                            if (resfile.statusCode != "1")
                            {
                                LogHelper.Info(resfile.message + "，[PACS]文件上传失败，跳过本条数据上传下一条。报告id = "+ reportId);
                                ShowLog = reportId+" 报告上传失败，[PACS]文件上传失败，跳过本条数据上传下一条。";
                                this.SetText(ShowLog);
                                continue;
                            }
                            int file_count = PacsUploadServiceImpl.insertPdfForPacs(businessNumber, reportId,resfile.mainBody.attachmentId);
                            if (file_count < 1)
                            {
                                ShowLog = "[PACS]新增表【已上传PDF】失败，跳过本条数据上传下一条。！";
                                LogHelper.Info(ShowLog);
                                this.SetText(ShowLog);
                                continue;
                            }
                            countAll += 1;

                            //上传数据
                            List<PACS> list = PacsUploadServiceImpl.beginUploadPacsData(businessNumber,reportId);
                            if (list.Count < 1)
                            {
                                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 pacs_upload_items t Where t.yzxgid = " + list[0].YZID + "";
                            List<PacsItems> pacsItems = new List<PacsItems>();
                            if (zlhr == zlhrConstant_true)
                            {
                                pacsItems = OracleHelper<PacsItems>.PgRunQueryList(lisitems_sql);
                            }
                            else
                            {
                                pacsItems = OracleHelper<PacsItems>.RunQueryList(lisitems_sql);
                            }
                            if (pacsItems.Count < 1)
                            {
                                LogHelper.Info("查询pacs检查项目明细数据为空，跳过本条数据上传下一条。");
                                LogHelper.Info("执行sql:" + lisitems_sql);
                                continue;
                            }
                            /*if (zlhr == zlhrConstant_true)
                            {
                                //处理 互认编码的数据 
                                HandleLisItemDataForWebLis(lisitems);
                            }*/

                            dic.Add("ITEMLIST", pacsItems);
                            plist.Add(dic);
                            if (!isAuthorization())
                            {
                                continue;
                            }
                            string json_pacs = JsonConvert.SerializeObject(plist);
                            //string json_pacs = Tools.ObjectToJson<List<PACS>>(plist, Encoding.UTF8);
                           // LogHelper.Info("pacs参数="+ json_pacs);
                            json_pacs = "{\"mainBody\":" + json_pacs + "}";

                            LogHelper.Info("pacs参数=" + 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(pacs_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                            string res_pacs = string.Empty;
                            string res_aes_pacs = string.Empty;
                            try
                            {
                                res_pacs = Tools.WSCenterData(pacs_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                                 res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                            }
                            catch (Exception e)
                            {
                                LogHelper.Error(e, "pacs 报告上传失败");
                                continue;
                            }
                            
                            //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;
                                int upload_count = PacsUploadServiceImpl.updatePdfForPacs(businessNumber,reportId);
                                if (upload_count < 1)
                                {
                                    LogHelper.Info("[PACS]更新表【已上传PDF】失败，跳过本条数据上传下一条！"+ reportId);
                                    ShowLog = "[PACS]新增表【已上传PDF】失败，跳过本条数据上传下一条！执行sql：" + reportId;
                                    this.SetText(ShowLog);
                                    continue;
                                }
                            }
                        }
                        ShowLog = "本次已生成、上传[PACS]PDF文件总条数为[" + countAll + "]条,上传[PACS]总条数为[" + uploaded + "]条。";
                        this.SetText(ShowLog);
                        LogHelper.Info(ShowLog);
                        GetPacsDefault();

                    }
                    #endregion
                    #region 2、补传失败数据
                    //上传数据
                    LogHelper.Info("PACS补传数据");

                    ShowLog = "PACS补传数据开始";
                    this.SetText(ShowLog);

                    List<PACS> list_pc = PacsUploadServiceImpl.completUploadPacsData();
                    if (list_pc.Count < 1)
                    {
                        return;
                    }
                    int count_pc = 0;
                    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 pacsitems_sql = @"Select * From pacs_upload_items t Where t.yzxgid = " + list_pc[i].YZID + "";
                        List<PacsItems> pacsItems = new List<PacsItems>();
                        if (zlhr == zlhrConstant_true)
                        {
                            pacsItems = OracleHelper<PacsItems>.PgRunQueryList(pacsitems_sql);
                        }
                        else
                        {
                            pacsItems = OracleHelper<PacsItems>.RunQueryList(pacsitems_sql);
                        }
                        if (pacsItems.Count < 1)
                        {
                            LogHelper.Info("查询pacs检查项目明细数据为空，跳过本条数据上传下一条。");
                            LogHelper.Info("执行sql:" + pacsitems_sql);
                            continue;
                        }

                        dic_pc.Add("ITEMLIST", pacsItems);
                        plist_pc.Add(dic_pc);
                        if (!isAuthorization())
                        {
                            continue;
                        }
                        string json_pacs = JsonConvert.SerializeObject(plist_pc);
                        //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(pacs_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                        string res_pacs = string.Empty;
                        string res_aes_pacs = string.Empty;
                        try
                        {
                            res_pacs = Tools.WSCenterData(pacs_upload_url, json_pacs, vi_pacs, Tools.accessToken, 1);
                             res_aes_pacs = Tools.AESDecrypt(res_pacs, Tools.pwd, vi_pacs);
                        }
                        catch (Exception e)
                        {
                            LogHelper.Error(e, "pacs 报告上传失败");
                            continue;
                        }
                        
                        //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;
            string res_aes = string.Empty;
            try
            {
                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);
                    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));
                }
            }
            catch (Exception e)
            {
                result = false;
                LogHelper.Info("isAuthorization Exception=" + result);
                LogHelper.Info(res_aes+"获取token异常" + e.Message);
                return result;
            }
            LogHelper.Info("isAuthorization="+ result);
            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);
            
        }
    }
}