MedicalInsurance/Forms/BasicData.cs

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using PTMedicalInsurance.Business;
using PTMedicalInsurance.Helper;
using PTMedicalInsurance.Variables;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using PTMedicalInsurance.FormSetter;
using PTMedicalInsurance.Common;
using OfficeOpenXml;

namespace PTMedicalInsurance.Forms
{
    public partial class BasicData : Form
    {
        //设置实例
        CenterBusiness cBus = new CenterBusiness();
        HisMainBusiness hBus = new HisMainBusiness();
        HisIrisServices hIS = new HisIrisServices();
        MIIrisServices mIS = new MIIrisServices();
        InvokeHelper invoker = new InvokeHelper();

        InsuServices Iis = new InsuServices();

        //1.声明自适应类实例
        AutoResizeForm asc = new AutoResizeForm();

        public JObject joSelectedInsuInfo;
        public int insuInfoIndex = 0;
        public int idInfoIndex = 0;
        int iTotalCount = 0;
        int currentPageIndex = 0;
        private Func<JObject, OutParamWrapper, int> action;
        private DataTable dtAllMapped;
        DataTable dtExport;

        public BasicData()
        {
            InitializeComponent();

            rbgDirecType.SelectedIndex = 0;
            rbgDirecType_C.SelectedIndex = 0;
            rbSingleDown.Checked = true;
            rbOnlyName.Checked = true;

            this.rbgDirecType.ValueChanged += new Sunny.UI.UIRadioButtonGroup.OnValueChanged(this.rbgDirecType_ValueChanged);
            this.pgDownload.PageChanged += new Sunny.UI.UIPagination.OnPageChangeEventHandler(this.pgDownload_PageChanged);
            this.pgCenterDirect.PageChanged += new Sunny.UI.UIPagination.OnPageChangeEventHandler(this.pgCenterDirect_PageChanged);
            Font rowFont = new Font("UTF-8", 8);
            Font columnFont = new Font("UTF-8", 9);
            rbgDirecType.SelectedIndex = 8;
            rbAll.Checked = true;
            //tabControl1.SelectedIndex = 1;

            //this.StartPosition = FormStartPosition.CenterParent;
            asc.controllInitializeSize(this);
            asc.controlAutoSize(this);

            TextCbd.Text = Global.inf.areaCode;

            //查询区域通用目录 
            MIIrisServices mIS = new MIIrisServices();
            JObject joRtnTY = mIS.getInterface_TY(Global.inf.interfaceDr.ToString(), "");
            Global.inf.InsuCurrencyCataLogue = JsonHelper.getDestValue(joRtnTY, "InsuCurrencyCataLogue");  //通用目录编码 6
            Global.inf.hospitalDr_TY = JsonHelper.getDestValue(joRtnTY, "HospitalDr_TY");                  //通用目录所属医院ID

        }
        #region  函数封装

        private void queryInsuDirectory(int currentPage, int pageSize, int directoryType, int interfaceDr, string code)
        {
            try
            {
                string dirCode = "";
                string dirName = "";
                string approvalNO = "";
                string DosageForm = "";
                string Specifications = "";
                string manufacturers = "";
                Sunny.UI.UIDataGridView dgv;
                Sunny.UI.UIPagination pg;
                if (tabControl1.SelectedIndex == 0)
                {
                    dirCode = tbDirectoryCode.Text;
                    dirName = tbDircetoryName.Text;
                    approvalNO = "";
                    dgv = dgvDirectoy;
                    pg = pgDownload;
                }
                else
                {
                    dirName = tbCenterDirectoryFilter.Text;
                    dirCode = tbInsuCode.Text;
                    dgv = dgvCenterDirectory;
                    approvalNO = tbApprovalNO.Text;
                    pg = pgCenterDirect;
                    manufacturers = tbManufacturer.Text;
                    DosageForm = tbDosageForm.Text;
                    Specifications = tbSpecifications.Text;
                }
                JObject joInput = new JObject {

                    { "currentPage" , currentPage },
                    { "pageSize" , pageSize },
                    { "serviceCode" , code },
                    { "directoryType" , directoryType },
                    { "directoryCode" , dirCode },
                    { "directoryName" , dirName },
                    { "approvalNO" , approvalNO },
                    { "dosageForm" , DosageForm },
                    { "specifications" , Specifications },
                    { "manufacturers" , manufacturers },
                    { "directoryDr" , interfaceDr }
                };

                JObject joRtn = mIS.getMIDirectoryByPagination(joInput);

                if (joRtn["errorCode"].ToString() != "0")
                {
                    MessageBox.Show("IRIS数据返回错误:" + joRtn["errorMessage"].ToString());
                    return;
                }
                if (joRtn["result"]["rows"] == null)
                {
                    MessageBox.Show("该节点不存在");
                    return;
                }

                if (joRtn["result"]["total"].ToString() == "0")
                {
                    MessageBox.Show("未查询到数据");
                    dgv.DataSource = null;
                    return;
                }

                DataTable dt = (DataTable)joRtn["result"]["rows"].ToObject(typeof(DataTable));
                int totalCount = int.Parse(joRtn["result"]["total"].ToString());
                pg.TotalCount = totalCount;
                pg.PageSize = pageSize;
                dgv.DataSource = dt;
                dgv.Columns[0].ReadOnly = true;
            }
            catch (Exception ex)
            {
                MessageBox.Show("查询异常：" + ex.Message);
            }
        }

        private void setHeaderTxt(int directoryType, Sunny.UI.UIDataGridView dgv)
        {
            GridViewSetter gvdSetter = new GridViewSetter();
            switch (directoryType)
            {
                case 0://药品
                    {
                        gvdSetter.SetHeaderTextOfDrug(dgv);
                        break;
                    }
                case 1://诊疗
                    {
                        gvdSetter.SetHeaderTextOfMedicalService(dgv);
                        break;
                    }
                case 2://材料
                    {
                        gvdSetter.SetHeaderTextOfMaterials(dgv);
                        break;
                    }
                case 3://疾病诊断
                    {
                        gvdSetter.SetHeaderTextOfDiagnose(dgv);
                        break;
                    }
                case 4://手术
                    {
                        gvdSetter.SetHeaderTextOfDiagnose(dgv);
                        break;
                    }
                case 5://慢性病
                    {
                        gvdSetter.SetHeaderTextOfDiagnose(dgv);
                        break;
                    }
                case 6://DRGs
                    {
                        gvdSetter.SetHeaderTextOfDiagnose(dgv);
                        break; ;
                    }
                case 7://日间手术
                    {
                        gvdSetter.SetHeaderTextOfDiagnose(dgv);
                        break; ;
                    }
                case 8://字典表
                    {
                        gvdSetter.SetHeaderTextOfDictionary(dgv);
                        break;
                    }

                case 9://中药饮片下载
                    {
                        gvdSetter.SetHeaderTextOfChineseMedicine(dgv);
                        break;
                    }
                case 10://医药机构制剂目录下载
                    {
                        gvdSetter.SetHeaderTextOfPreparation(dgv);
                        break;
                    }
                case 11://肿瘤形态学下载
                    {
                        gvdSetter.SetHeaderTextOfTumorMorphology(dgv);
                        break;
                    }
                case 12:
                    {
                        //中医疾病下载
                        gvdSetter.GetChineseDiagnoseJsonByTxt(dgv);
                        // ICPC3
                        //gvdSetter.SetICPCAdmReasonHeader(dgv);
                        break;
                    }
                case 13:
                    {
                        //中医证候下载
                        gvdSetter.GetTCMSyndromeJsonByTxt(dgv);
                        // ICPC3
                        //gvdSetter.SetICPCTreatmentHeader(dgv);
                        break;
                    }

                case 14://民族药品
                    {
                        gvdSetter.GetEthnicMedicineJsonByTxt(dgv);
                        break;
                    }
                case 15://目录信息查询
                    {
                        gvdSetter.GetMedInsuCatalogJsonByTxt(dgv);
                        break;
                    }
                case 16://医疗与医保目录匹配关系查询
                    {
                        gvdSetter.GetMedInsuCorrespondencJsonByTxt(dgv);
                        break;
                    }
                case 17://医药机构目录匹配查询
                    {
                        gvdSetter.GetMedInstCorrespondencJsonByTxt(dgv);
                        break;
                    }
                case 18://医保目录限价查询
                    {
                        gvdSetter.GetMedInsuFixedPriceJsonByTxt(dgv);
                        break;
                    }
                case 19://医保目录先自付比例下载
                    {
                        gvdSetter.GetMedInsuFirstPayProportionJsonByTxt(dgv);
                        break;
                    }
                case 20://医药机构信息
                    {
                        gvdSetter.GetMedicalInstitutionJsonByTxt(dgv);
                        break;
                    }
            }

            gvdSetter.DatagridviewColumnWidthAdaptation(dgv);
        }

        private void queryHISInsuDirectory(int directoryType, int pageIndex, int count, Sunny.UI.UIDataGridView dgv, int interfaceDr)
        {
            string code = "09010042";

            if (tabControl1.SelectedIndex == 0)
            {
                if (rbgDirecType.SelectedIndex == 20)
                {
                    code = "090100XX";
                }
                else if (rbgDirecType.SelectedIndex == 8)
                {
                    code = "09010043";
                }
                else
                {
                    code = "09010042";
                }

                if (rbgDirecType.SelectedIndex <= 13)
                {
                    queryInsuDirectory(pageIndex, count, directoryType + 1, interfaceDr, code);
                    setHeaderTxt(directoryType, dgv);
                }
                else  //几个医保查询该部分数据不存数据库只是临时查询(除医疗机构信息查询外)
                {
                    //生成DataView列
                    //setHeaderTxt(directoryType, dgv);

                    string pages, recordCounts, errorMessage, sOutpar;
                    dynamic joData = GetInput(rbgDirecType.SelectedIndex, out TradeEnum trade);
                    JObject joRtn = cBus.InvokeMedicalInsuranceInquiry(trade, joData);

                    if (joRtn["infcode"].ToString() == "0")
                    {
                        try
                        {
                            Sunny.UI.UIPagination pg;

                            dgv = dgvDirectoy;
                            pg = pgDownload;
                            DataTable dt;

                            if (rbgDirecType.SelectedIndex == 20)
                            {
                                dt = (DataTable)joRtn["output"]["medinsinfo"].ToObject(typeof(DataTable));

                                if (joRtn["output"]["medinsinfo"].ToString() == "")
                                {
                                    MessageBox.Show("查询成功,但返回结果集为空！");
                                    //return;
                                }

                                pg.TotalCount = 50;
                                pg.PageSize = 50;
                            }
                            else
                            {
                                pages = joRtn["output"]["pages"].ToString();                 //页数
                                recordCounts = joRtn["output"]["recordCounts"].ToString();   //总记录条数

                                dt = (DataTable)joRtn["output"]["data"].ToObject(typeof(DataTable));

                                if (recordCounts == "0")
                                {
                                    MessageBox.Show("查询成功,但返回结果集为空！");
                                    //return;
                                }

                                pg.TotalCount = int.Parse(recordCounts);
                                pg.PageSize = int.Parse(TexBYSJL.Text); //int.Parse(pages);
                            }

                            dgv.DataSource = dt;
                            dgv.Columns[0].ReadOnly = true;
                        }
                        catch (Exception ex)
                        {
                            MessageBox.Show("查询异常：" + ex.Message);
                        }
                    }
                    else
                    {
                        errorMessage = "调用交易" + trade.GetCode() + "出现错误，请查看日志！"; //joImportRtn["errorMessage"].ToString();
                        MessageBox.Show(errorMessage);
                        return;
                    }
                }
            }
            else
            {
                queryInsuDirectory(pageIndex, count, directoryType + 1, interfaceDr, code);
                setHeaderTxt(directoryType, dgv);
            }

            GridViewSetter gridSetter = new GridViewSetter();
            gridSetter.DatagridviewColumnWidthAdaptation(dgvCenterDirectory);
        }


        private int queryHISDirectory(int currentPage, int pageSize, out string errMsg)
        {
            errMsg = "";
            string directoryType = string.Empty;
            switch (rbgDirecType_C.SelectedIndex)
            {
                case 0:
                    {
                        directoryType = "drugs";
                        break;
                    }
                case 1:
                    {
                        directoryType = "diagnosi";
                        break;
                    }
                case 2:
                    {
                        directoryType = "consumables";
                        break;
                    }
            }

            JObject joHISRtn = new JObject();
            JObject joRtn = new JObject();
            InvokeHelper invoker = new InvokeHelper();
            string flag = "";
            //全部是先调HIS，然后再匹配医保平台的对照关系
            if (rbAll.Checked)
            {                
                JArray jaPagination = new JArray();
                JArray jaParams = new JArray();
                flag = "All";
                dynamic joParam = new JObject();
                joParam.code = "";
                joParam.descripts = "";
                joParam.FindType = new JArray();
                joParam.TypeID = "";
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.include = "Hosp";
                joParam.groupID = "324";
                joParam.hospID = Global.inf.hisHospitalDr;
                joParam.interfaceDr = Global.inf.interfaceDr;
                joParam.type = directoryType;
                joParam.flag = flag;
                joParam.specInput = txtSpecFilter.Text.Trim();
                jaParams.Add(joParam);

                dynamic joPagination = new JObject();
                joPagination.pageSize = pageSize;
                //joPagination.pageSize = 2;
                joPagination.currentPage = currentPage;
                joPagination.sortColumn = "Code";
                joPagination.sortOrder = "asc";
                jaPagination.Add(joPagination);
                //该服务需要改写，需要跟（CloudMedicalInsurancePlatform.Tables.MapRelation）进行关联
                //joInParams.code = "09010038";
                if (hIS.getHISDir(jaPagination, jaParams, out joHISRtn, out errMsg) != 0)
                {
                    return -1;
                }
                joRtn = mIS.ConvertHISDir(joHISRtn);
                if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                {
                    return -1;
                }
            }

            //已对照是先调云医保，然后再匹配HIS
            if (rbMaped.Checked)
            {                
                JArray jaPagination = new JArray();
                JArray jaParams = new JArray();
                flag = "Maped";
                dynamic joParam = new JObject();
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.HospitalDr = Global.inf.hospitalDr;
                joParam.InterfaceDr = Global.inf.interfaceDr;
                joParam.hisType = directoryType;
                jaParams.Add(joParam);
                dynamic joPagination = new JObject();
                joPagination.pageSize = pageSize;
                joPagination.currentPage = currentPage;
                joPagination.sortColumn = "HisCode";
                joPagination.sortOrder = "asc";
                jaPagination.Add(joPagination);

                JObject joMIRtn = mIS.GetMappedHISDir(jaPagination, jaParams);

                if (JsonHelper.parseIrisRtnValue(joMIRtn, out errMsg) != 0)
                {
                    return -1;
                }

                //传给HIS，进行匹配
                joParam = new JObject();
                joParam.TotalCount = joMIRtn["result"]["TotalCount"];
                joParam.type = directoryType;
                joParam.flag = flag;
                joParam.hospID = Global.inf.hisHospitalDr;
                joParam.interfaceDr = Global.inf.interfaceDr;
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.include = "Hosp";
                joParam.groupID = "324";
                joParam.compareArr = joMIRtn["result"]["Data"];
                jaParams = new JArray();
                jaParams.Add(joParam);
                if (hIS.getHISDir(jaPagination, jaParams, out joRtn, out errMsg) != 0)
                {
                    return -1;
                }
            }

            //if (rbNoMaped.Checked) { flag = "NoMaped"; }

            if (rbNoMaped.Checked)
            {
                JArray jaPagination = new JArray();
                JArray jaParams = new JArray();
                flag = "All";
                dynamic joParam = new JObject();
                joParam.code = "";
                joParam.descripts = "";
                joParam.FindType = new JArray();
                joParam.TypeID = "";
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.include = "Hosp";
                joParam.groupID = "324";
                joParam.hospID = Global.inf.hisHospitalDr;
                joParam.interfaceDr = Global.inf.interfaceDr;
                joParam.type = directoryType;
                joParam.flag = flag;
                joParam.specInput = "";
                jaParams.Add(joParam);

                dynamic joPagination = new JObject();
                joPagination.pageSize = pageSize; 
                //joPagination.pageSize = 2;
                joPagination.currentPage = currentPage;
                joPagination.sortColumn = "Code";
                joPagination.sortOrder = "asc";
                jaPagination.Add(joPagination);
        
                //1.获取全部HIS目录
                if (hIS.getHISDir(jaPagination, jaParams, out joHISRtn, out errMsg) != 0)
                {
                    return -1;
                }

                joRtn = mIS.GetNoMappHISDir(joHISRtn);
                if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                {
                    return -1;
                }
            }

            DataTable dt = (DataTable)joRtn["result"]["Data"].ToObject(typeof(DataTable));
            dtExport = dt;
            int totalCount = int.Parse(joRtn["result"]["TotalCount"].ToString());
            pgHISDirect.TotalCount = totalCount;

            //if (rbNoMaped.Checked)
            //    pgHISDirect.PageSize = pageSize;
            //else
            //    pgHISDirect.PageSize = 50;

            pgHISDirect.PageSize = pageSize;
            dgvHISDirectory.DataSource = null;
            dgvHISDirectory.DataSource = dt;
            dgvHISDirectory.Columns[0].ReadOnly = true;

            GridViewSetter gridSetter = new GridViewSetter();
            gridSetter.SetHeaderTextOfMapping_HisDirectory(dgvHISDirectory);
            gridSetter.DatagridviewColumnWidthAdaptation(dgvHISDirectory);

            return 0;
        }

        private void queryCenterDirectory_09010012(int currentPage, int pageSize)
        {
            string directoryType = string.Empty;
            switch (rbgDirecType_C.SelectedIndex)
            {
                case 0:
                    {
                        directoryType = "drugs";
                        break;
                    }
                case 1:
                    {
                        directoryType = "diagnosi";
                        break;
                    }
                case 2:
                    {
                        directoryType = "consumables";
                        break;
                    }
            }
            dynamic joInParams = new JObject();
            joInParams.pagination = new JArray() as dynamic;
            joInParams.session = new JArray() as dynamic;
            JArray jaParams = new JArray();

            dynamic joParams = new JObject();
            joParams.code = "";
            joParams.descripts = "";
            joParams.FindType = new JArray();
            joParams.TypeID = "";
            joParams.alias = "";
            joParams.include = "Hosp";
            joParams.groupID = "324";
            joParams.hospID = "25";
            joParams.type = directoryType;
            joParams.specInput = "";
            jaParams.Add(joParams);
            joInParams.Add("params", JArray.FromObject(jaParams));
            dynamic joSession = new JObject();
            joSession.userID = "";
            joSession.locID = "";
            joSession.groupID = "";
            joSession.hospID = "";
            joSession.sessionID = "";
            joSession.hospCode = "";
            joSession.language = "";
            joSession.hostName = "";
            joSession.ipv4 = "";
            joSession.ipv6 = "";
            joSession.mac = "";
            joInParams.session.Add(joSession);
            dynamic joPagination = new JObject();
            joPagination.pageSize = pageSize;
            joPagination.currentPage = currentPage;
            joPagination.sortColumn = "Code";
            joPagination.sortOrder = "asc";
            joInParams.pagination.Add(joPagination);
            joInParams.code = "09010012";

            string sInput = joInParams.ToString();
            string sRtn = invoker.invokeInsuService(joInParams, "");

            JObject jsonRtn = JObject.Parse(sRtn);
            if (jsonRtn["result"]["Data"] == null)
            {
                MessageBox.Show("该节点不存在");
                return;
            }

            JObject joRtn = JObject.Parse(sRtn);
            DataTable dt = (DataTable)joRtn["result"]["Data"].ToObject(typeof(DataTable));
            int totalCount = int.Parse(joRtn["result"]["TotalCount"].ToString());
            pgCenterDirect.TotalCount = totalCount;
            pgCenterDirect.PageSize = 50;
            dgvCenterDirectory.DataSource = dt;
        }
        private void Mapping()
        {
            int iHis = dgvHISDirectory.CurrentRow.Index;
            if (dgvCenterDirectory.CurrentRow == null)
            {
                MessageBox.Show("请查询中心目录");
                return;
            }
            int iCenter = dgvCenterDirectory.CurrentRow.Index;
            DataTable dtHis = (DataTable)dgvHISDirectory.DataSource;
            DataTable dtCenter = (DataTable)dgvCenterDirectory.DataSource;

            dgvHISDirectory.Rows[iHis].Cells["insuCode"].Value = dgvCenterDirectory.Rows[iCenter].Cells["Code"].Value.ToString();
            dgvHISDirectory.Rows[iHis].Cells["insuName"].Value = dgvCenterDirectory.Rows[iCenter].Cells["Name"].Value.ToString();


            int hisType = rbgDirecType_C.SelectedIndex + 1;
            string hisTypeName = rbgDirecType_C.Items[hisType - 1].ToString(); ;

            JArray jaParams = new JArray();
            dynamic jsonTemp = new JObject();
            jsonTemp.ID = dtHis.Rows[iHis]["MapID"];
            jsonTemp.HospitalDr = Global.inf.hospitalDr;
            jsonTemp.updateUserID = Global.user.ID;
            jsonTemp.InterfaceDr = Global.inf.interfaceDr;
            jsonTemp.HISCode = dgvHISDirectory.Rows[iHis].Cells["itemCode"].Value;
            jsonTemp.HISName = dgvHISDirectory.Rows[iHis].Cells["itemDesc"].Value;
            jsonTemp.ChargeItemDr = dtHis.Rows[iHis]["ID"];
            jsonTemp.DiretoryDr = dtCenter.Rows[iCenter]["medInsuDirectoryID"];
            //1.已对照  2.已对照但未上传  3 已对照且已上传
            jsonTemp.State = 1;
            jsonTemp.HisType = hisType;
            jsonTemp.HisTypeName = hisTypeName;
            jsonTemp.InsuCode = dgvCenterDirectory.Rows[dgvCenterDirectory.CurrentRow.Index].Cells["Code"].Value;
            jsonTemp.InsuName = dgvCenterDirectory.Rows[dgvCenterDirectory.CurrentRow.Index].Cells["Name"].Value;
            jsonTemp.UpdateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            jaParams.Add(jsonTemp);

            JObject joIn = new JObject();
            joIn.Add(new JProperty("params", jaParams));
            joIn.Add("code", "09010040");
            InvokeHelper invoker = new InvokeHelper();
            JObject joRtn = invoker.invokeInsuService(joIn.ToString(), "插入对照信息");
            //JObject joRtn = JObject.Parse(irisRtn);

            if ((int)joRtn["errorCode"] == 0)
            {
                dgvHISDirectory.Rows[iHis].Cells["flag"].Value = "已对照";
            }
            else
            {
                dgvHISDirectory.Rows[iHis].Cells["flag"].Value = "对照失败";
            }

        }
        private void CancleMapping()
        {
            int iHis = dgvHISDirectory.CurrentRow.Index;
            DataTable dtHis = (DataTable)dgvHISDirectory.DataSource;

            JArray jaParams = new JArray();
            dynamic jsonTemp = new JObject();
            jsonTemp.ID = dtHis.Rows[iHis]["MapID"];
            jsonTemp.HospitalDr = Global.inf.hospitalDr;
            jsonTemp.updateUserID = Global.user.ID;
            jsonTemp.InterfaceDr = Global.inf.interfaceDr;
            jsonTemp.HISCode = dgvHISDirectory.Rows[iHis].Cells["itemCode"].Value;
            jsonTemp.UpdateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            jaParams.Add(jsonTemp);

            JObject joIn = new JObject();
            joIn.Add(new JProperty("params", jaParams));
            joIn.Add("code", "09010041");
            InvokeHelper invoker = new InvokeHelper();
            JObject joRtn = invoker.invokeInsuService(joIn.ToString(), "取消对照");

            if ((int)joRtn["errorCode"] == 0)
            {
                dgvHISDirectory.Rows[iHis].Cells["insuCode"].Value = "";
                dgvHISDirectory.Rows[iHis].Cells["insuName"].Value = "";
                dgvHISDirectory.Rows[iHis].Cells["flag"].Value = "";
            }
            else
            {
                dgvHISDirectory.Rows[iHis].Cells["flag"].Value = "取消失败";
            }
        }

        public void loadTextDebug()
        {
            DataImoport bus = new DataImoport();
            string txtPath = @"E:\insu\Demo\bin\Debug\20230101535395327567680436.txt";
            JObject joImportRtn = bus.importDataToIrisByTxt(txtPath, 50, 2, uiProcessBar1);
        }

        /// <summary>
        /// 医保目录单个版本号的下载
        /// </summary>
        /// <param name="ver"></param>
        /// <param name="directoryType"></param>
        /// <param name="uiProcessBar"></param>
        /// <param name="errorMessage"></param>
        /// <returns></returns>
        public int downloadDicionary(JObject joData, Sunny.UI.UIProcessBar uiProcessBar, string dictCode,out string errorMessage)
        {
            errorMessage = "";
            int iResult = -1;
            try
            {
                JObject joRtn = cBus.DownDictionay(joData);

                if (JsonHelper.parseCenterRtnValue(joRtn, out errorMessage) == 0)
                {
                    DataImoport DI = new DataImoport();
                    JArray jaList = JArray.Parse(JsonHelper.getDestValue(joRtn, "output.list"));
                    JObject joImportRtn = DI.importDictionary(uiProcessBar, jaList, dictCode);
                    if (JsonHelper.parseIrisRtnValue(joImportRtn, out errorMessage) == 0)
                    {
                        iResult = 0;
                    }
                    else
                    {
                        errorMessage = "导入数据出现错误，请查看日志！" + errorMessage;
                    }
                }
                return iResult;
            }
            catch (Exception ex)
            {
                errorMessage = "downloadDicionary提示:" + ex.Message;
                return -1;
            }
        }

        #endregion

        private void Form1_Load(object sender, EventArgs e)
        {
            this.WindowState = FormWindowState.Maximized;

            rbgDirecType.ValueChanged += new Sunny.UI.UIRadioButtonGroup.OnValueChanged(rbgDirecType_ValueChanged);

            LabExplain.Visible = false;
        }
        private void btnDownload_Click(object sender, EventArgs e)
        {
            string errorMessage = string.Empty;
            string ver = tbVer.Text;
            JObject input = new JObject();
            input["ver"] = ver;

            // 目录查询
            switch(rbgDirecType.SelectedIndex)
            {
                case 15:
                    break;
                case 8:  //字典
                    {
                        if (tbDicDate.Text == "")
                        {
                            MessageBox.Show("请输入查询日期！");
                            return;
                        }
                        // 支持批量
                        string[] dictText = tbDicType.Text.Trim().Split(",".ToCharArray());
                        dictText.ToList().ForEach((dict) =>
                        {
                            this.downloadDict(dict);
                        });
                        break;
                    }
                //case 12:
                //    {
                //        downloadMedData(TradeEnum.ICPC3AdmReason, ver, uiProcessBar1);
                //        break;
                //    }
                //case 13:
                //    {
                //        downloadMedData(TradeEnum.ICPC3Treatment, ver, uiProcessBar1);
                //        break;
                //    }
                default:
                    {
                        MedDirDownloadProcess mp = new MedDirDownloadProcess();
                        if (rbSingleDown.Checked)
                        {
                            if (mp.SingleDownload(ver, rbgDirecType.SelectedIndex, uiProcessBar1, out errorMessage) != 0)
                            {
                                MessageBox.Show("医保目录下载失败：" + errorMessage);
                                return;
                            }
                        }
                        if (rbAutoDown.Checked)
                        {
                            mp.VerChangeEvent += Mp_VerChangeEvent;
                            if (mp.AutoDownload(rbgDirecType.SelectedIndex, uiProcessBar1, out errorMessage) != 0)
                            {
                                MessageBox.Show("医保目录下载失败：" + errorMessage);
                                return;
                            }
                        }
                        break;
                    }
            }

            btnQuery_Click(sender, e);
        }

        private void Mp_VerChangeEvent(object sender, string ver)
        {
            tbVer.Text = ver;
        }

        private void downloadDict(string dictCode)
        {
            try
            {
                string errorMessage = "";
                dynamic joData = new JObject();
                joData.type = dictCode;   //字典类型
                joData.parentValue = "";        //父字典键值 
                joData.admdvs = Global.inf.areaCode;        //行政区划  就医地
                joData.date = tbDicDate.Text;  //查询日期 
                joData.vali_flag = "1";   //有效标志 

                if (downloadDicionary(joData, uiProcessBar1,dictCode, out errorMessage) != 0)
                {
                    MessageBox.Show("医保字典下载失败：" + errorMessage);
                }
            }
            catch (Exception e)
            { 
                
            }
        }

        private int downloadMedData(TradeEnum trade,string version,Sunny.UI.UIProcessBar uiProcessBar)
        {
            string errorMessage = "";
            if (rbAutoDown.Checked)
            {
                JObject joMaxVerNO = mIS.getDirectoryMaxVersionNO(rbgDirecType.SelectedIndex);
                string ver = joMaxVerNO["result"]["MaxVersionNO"].ToString();
                if (!string.IsNullOrEmpty(ver))
                {
                    version = ver;
                    tbVer.Text = ver;
                }
            }
            JObject joRtn = cBus.DownDirecotry(trade, version);
            if (JsonHelper.parseCenterRtnValue(joRtn, out errorMessage) == 0)
            {
                //解析
             DataImoport DI = new DataImoport();
                JObject joImportRtn = DI.importMedDataToIris(trade,joRtn,uiProcessBar);
                if (JsonHelper.parseIrisRtnValue(joImportRtn, out errorMessage) == 0)
                {
                    //递归调用
                    if (rbAutoDown.Checked)
                    {
                        downloadMedData(trade, version, uiProcessBar);
                    }
                }
                 return 0;
            }
            MessageBox.Show(errorMessage);
            return -1;
        }

        private void btnQuery_Click(object sender, EventArgs e)
        {
            #region 校验查询条件
            if ((rbgDirecType.SelectedIndex < 0) || (rbgDirecType.SelectedIndex > 20))
            {
                MessageBox.Show("请先选择查询类型！");
                return;
            }

            if (rbgDirecType.SelectedIndex > 13)
            {
                if (rbgDirecType.SelectedIndex != 20)
                {
                    if ((TexDate.Text == "") || (TexDate.Text == "输入日期 2021-01-01"))
                    {
                        MessageBox.Show("查询条件-请输入查询日期！");
                        return;
                    }
                    if ((TexDQYS.Text == "") || (TexDQYS.Text == "当前页数"))
                    {
                        MessageBox.Show("查询条件-请输入当前页数！");
                        return;
                    }
                    if ((TexBYSJL.Text == "") || (TexBYSJL.Text == "本页数据量"))
                    {
                        MessageBox.Show("查询条件-请输入本页数据量！");
                        return;
                    }
                }
                else
                {
                    if ((TexYYMC.Text == "") || (TexYYMC.Text == "输入医院名称模糊查找"))
                    {
                        MessageBox.Show("查询条件-请输入医院名称模糊查找！");
                        return;
                    }
                }

            }
            #endregion

            queryHISInsuDirectory(rbgDirecType.SelectedIndex, 1, 20, dgvDirectoy, Global.inf.interfaceDr);
        }

        private void btnQueryHISDirectory_Click(object sender, EventArgs e)
        {
            this.dgvHISDirectory.SelectionChanged -= this.dgvHISDirectory_SelectionChanged;
            int iCount = 50;
            if (rbNoMaped.Checked)
            {
                iCount = 300;
            }
            string errMsg;
            if (queryHISDirectory(1, iCount, out errMsg) != 0)
            {
                MessageBox.Show(errMsg);
                return;
            }
            this.dgvHISDirectory.SelectionChanged += this.dgvHISDirectory_SelectionChanged;
        }

        private void btnQueryCenterDirectory_Click(object sender, EventArgs e)
        {
            if ((tbCenterDirectoryFilter.Text == "") && (tbInsuCode.Text == "") && (tbApprovalNO.Text == "") && 
                (tbManufacturer.Text == "") && (tbSpecifications.Text == "") && (tbDosageForm.Text == ""))
            {
                return;
            }
            //查询区域通用目录 
            JObject joRtn = mIS.getInterface_TY(Global.inf.interfaceDr.ToString(),"");
            string InsuCurrencyCataLogue = JsonHelper.getDestValue(joRtn, "InsuCurrencyCataLogue");  //通用目录编码 6
            string InterfaceName_TY = JsonHelper.getDestValue(joRtn, "InterfaceName_TY");            //通用目录名称  
            string HospName_TY = JsonHelper.getDestValue(joRtn, "HospitalName");                     //目录名称
            string HospitalDr_TY = JsonHelper.getDestValue(joRtn, "HospitalDr_TY");                  //区域通用目录医院ID

            if (InsuCurrencyCataLogue != "")
            {
                queryHISInsuDirectory(rbgDirecType_C.SelectedIndex, 1, 50, dgvCenterDirectory, int.Parse(InsuCurrencyCataLogue));
                LabExplain.Visible = true;
                LabExplain.Text = "当前接口已设置区域通用目录,数据源：" + HospName_TY + " ,如果确认没有所查目录请联系数据源医院新增维护！";
            }
            else
            {
                queryHISInsuDirectory(rbgDirecType_C.SelectedIndex, 1, 50, dgvCenterDirectory, Global.inf.interfaceDr);
                LabExplain.Visible = true;
                LabExplain.Text = "当前接口未设置区域通用目录,数据源：" + HospName_TY;
            }


        }

        private void pgDownload_PageChanged(object sender, object pagingSource, int pageIndex, int count)
        {
            queryHISInsuDirectory(rbgDirecType.SelectedIndex, pageIndex, count, dgvDirectoy, Global.inf.interfaceDr);
        }

        private void pgHISDirect_PageChanged(object sender, object pagingSource, int pageIndex, int count)
        {
            string errMsg;
            int iCount = 50;
            if (rbNoMaped.Checked) iCount = 300;
           
            if (queryHISDirectory(pageIndex, iCount, out errMsg) != 0)
            {
                MessageBox.Show(errMsg);
                return;
            }
        }

        private void pgCenterDirect_PageChanged(object sender, object pagingSource, int pageIndex, int count)
        {
            queryHISInsuDirectory(rbgDirecType_C.SelectedIndex, pageIndex, count, dgvCenterDirectory, Global.inf.interfaceDr);
        }

        private void rbgDirecType_ValueChanged(object sender, int index, string text)
        {
            //选定项不同调用的接口也不相同,Index值大于
            if (rbgDirecType.SelectedIndex > 13)
            {
                uiGroupBox1.Visible = false;
                uiGroupBox5.Visible = false;
                uiGroupBox2.Visible = true;
                //uiGroupBox3.Visible = true;
                uiProcessBar1.Visible = false;

                uiGroupBox2.Left = rbgDirecType.Width + rbgDirecType.Left + 5;
                uiGroupBox3.Left = uiGroupBox2.Width+rbgDirecType.Width + rbgDirecType.Left + 10;
                dgvDirectoy.DataSource = null;
            }
            else
            {
                uiGroupBox1.Visible = true;
                uiGroupBox5.Visible = true;
                uiGroupBox2.Visible = true;
                //uiGroupBox3.Visible = false;                
                uiProcessBar1.Visible = true;

                uiGroupBox1.Left = rbgDirecType.Width + rbgDirecType.Left + 5;
                uiGroupBox5.Left = uiGroupBox1.Width + rbgDirecType.Width + rbgDirecType.Left + 10;
                uiGroupBox2.Left = uiGroupBox5.Width + uiGroupBox1.Width + rbgDirecType.Width + rbgDirecType.Left + 15;
                uiGroupBox3.Left = uiGroupBox2.Width + uiGroupBox5.Width + uiGroupBox1.Width + rbgDirecType.Width + rbgDirecType.Left + 20;

                uiProcessBar1.Left = rbgDirecType.Width + rbgDirecType.Left + 5;
                uiProcessBar1.Width = uiGroupBox1.Width + uiGroupBox5.Width + uiGroupBox2.Width + 10;
            }

            setHeaderTxt(rbgDirecType.SelectedIndex, dgvDirectoy);
        }

        private void toolStripMenuItem2_Click(object sender, EventArgs e)
        {
            CancleMapping();
        }

        private void tsmiMapping_Click(object sender, EventArgs e)
        {
            Mapping();
        }

        private void dgvHISDirectory_DoubleClick(object sender, EventArgs e)
        {
            int currentPage = pgHISDirect.ActivePage;
            string flag = dgvHISDirectory.Rows[dgvHISDirectory.CurrentRow.Index].Cells["flag"].Value.ToString();
            if (flag == "未对照")
            {
                Mapping();
            }
            else
            if (flag == "已对照")
            {
                CancleMapping();
            }
            if (rbAll.Checked)
            {
                string errMsg;
                if (queryHISDirectory(1, 50, out errMsg) != 0)
                {
                    MessageBox.Show(errMsg);
                    return;
                }
            }
        }

        private void dgvDirectoy_CellDoubleClick(object sender, DataGridViewCellEventArgs e)
        {

        }

        private void dgvDirectoy_CellContentClick(object sender, DataGridViewCellEventArgs e)
        {

        }

        private void uiRadioButton1_CheckedChanged(object sender, EventArgs e)
        {

        }

        private void dgvDirectoy_RowPostPaint(object sender, DataGridViewRowPostPaintEventArgs e)
        {
            //自动编号，与数据无关
            Rectangle rectangle = new Rectangle(e.RowBounds.Location.X,
               e.RowBounds.Location.Y,
               dgvDirectoy.RowHeadersWidth - 4,
               e.RowBounds.Height);
            TextRenderer.DrawText(e.Graphics,
                  (e.RowIndex + 1).ToString(),
                   dgvDirectoy.RowHeadersDefaultCellStyle.Font,
                   rectangle,
                   dgvDirectoy.RowHeadersDefaultCellStyle.ForeColor,
                   TextFormatFlags.VerticalCenter | TextFormatFlags.Right);
        }

        private void rbAll_ValueChanged(object sender, bool value)
        {
            //if (rbAll.Checked)
            //{
            //    btnQueryHISDirectory_Click(null, new EventArgs());
            //}
        }

        private void rbMaped_CheckedChanged(object sender, EventArgs e)
        {
            //if (rbMaped.Checked)
            //{
            //    string errMsg;
            //    if (queryHISDirectory(1, 50, out errMsg) != 0)
            //    {
            //        MessageBox.Show(errMsg);
            //        return;
            //    }
            //}
        }

        private void btAddDir_Click(object sender, EventArgs e)
        {
            AddSingleDirectory addDirectory = new AddSingleDirectory(rbgDirecType.SelectedIndex);
            if (addDirectory.ShowDialog() == DialogResult.OK)
            {
                JObject joRtn = mIS.UpdateDirectoryBySelf(addDirectory.joPamam);
                string error = "";
                if (JsonHelper.parseIrisRtnValue(joRtn, out error) != 0)
                {
                    MessageBox.Show("新增失败：" + error);
                }
                else
                {
                    MessageBox.Show("新增成功");
                }
            }
        }

        private void btEditDir_Click(object sender, EventArgs e)
        {
            DataTable dt = (DataTable)dgvDirectoy.DataSource;
            if ((dt == null) || (dt.Rows.Count < 1))
            {
                MessageBox.Show("表中无数据，请检查！");
                return;
            }
            DataRow dr = dt.Rows[dgvDirectoy.CurrentRow.Index];
            AddSingleDirectory addDirectory = new AddSingleDirectory(rbgDirecType.SelectedIndex, dr);
            if (addDirectory.ShowDialog() == DialogResult.OK)
            {

                JObject joRtn = mIS.UpdateDirectoryBySelf(addDirectory.joPamam);
                string error = "";
                if (JsonHelper.parseIrisRtnValue(joRtn, out error) != 0)
                {
                    MessageBox.Show("修改失败：" + error);
                }
                else
                {
                    MessageBox.Show("修改成功");
                }
            }
        }


        private void btnExit_Click(object sender, EventArgs e)
        {
            Close();
        }



        /// <summary>
        /// 几个医保查询的交易组织入参
        /// </summary>
        /// <param name="Index"></param>
        /// <param name="funNo"></param>
        /// <returns></returns>
        private JObject GetInput(int Index, out TradeEnum trade)
        {
            trade = TradeEnum.MedicalServiceDirectory;
            dynamic joData = new JObject();
            switch (Index)
            {
                case 14://民族药品目
                    {
                        trade = TradeEnum.NationalityDrug;
                        joData.med_list_codg = tbDirectoryCode.Text; //医疗目录编码
                        joData.genname_codg = "";  //通用名编号
                        joData.drug_genname = "";  //药品通用名
                        joData.drug_prodname = tbDircetoryName.Text; //药品商品名
                        joData.reg_name = "";      //注册名称
                        joData.tcmherb_name = "";  //中草药名称
                        joData.mlms_name = "";     //药材名称
                        joData.vali_flag = "";     //有效标志
                        joData.rid = "";           //唯一记录号
                        joData.ver = "";           //版本号
                        joData.ver_name = "";      //版本名称
                        joData.opt_begn_time = ""; //经办开始时间
                        joData.opt_end_time = "";  //经办结束时间
                        joData.updt_time = TexDate.Text;  //更新时间
                        joData.page_num = TexDQYS.Text;   //当前页数
                        joData.page_size = TexBYSJL.Text; //本页数据量

                        break;
                    }
                case 15://目录信息查询
                    {
                        trade = TradeEnum.InsuDirectory;
                        joData.query_date = ""; //查询时间点
                        joData.hilist_code = tbDirectoryCode.Text;  //医保目录编码
                        joData.insu_admdvs = TextCbd.Text;  //参保机构医保区划
                        joData.begndate = ""; //开始日期
                        joData.hilist_name = tbDircetoryName.Text;      //医保目录名称
                        joData.wubi = "";  //五笔助记码
                        joData.pinyin = "";     //拼音助记码
                        joData.med_chrgitm_type = "";     //医疗收费项目类别
                        joData.chrgitm_lv = "";           //收费项目等级
                        joData.lmt_used_flag = "";           //限制使用标志
                        joData.list_type = "";      //目录类别
                        joData.med_use_flag = ""; //医疗使用标志
                        joData.matn_used_flag = "";  //生育使用标志
                        joData.hilist_use_type = "";  //医保目录使用类别
                        joData.lmt_cpnd_type = "";  //限复方使用类型
                        joData.vali_flag = "";  //有效标志
                        joData.updt_time = TexDate.Text;  //更新时间
                        joData.page_num = TexDQYS.Text;   //当前页数
                        joData.page_size = TexBYSJL.Text; //本页数据量

                        break;
                    }
                case 16://医疗与医保目录匹配
                    {
                        trade = TradeEnum.MedicalAndInsuDirectory;
                        joData.query_date = "";         //查询时间点
                        joData.medins_list_codg = "";   //定点医药机构目录编号
                        joData.hilist_code = tbDirectoryCode.Text;        //医保目录编码
                        joData.list_type = "";          //目录类别
                        joData.insu_admdvs = TextCbd.Text;        //参保机构医保区划
                        joData.begndate = "";           //开始日期
                        joData.vali_flag = "";          //有效标志
                        joData.updt_time = TexDate.Text;  //更新时间
                        joData.page_num = TexDQYS.Text;   //当前页数
                        joData.page_size = TexBYSJL.Text; //本页数据量

                        break;
                    }
                case 17://医药机构目录匹配
                    {
                        trade = TradeEnum.MedcineOrgDirectory;
                        joData.query_date = "";         //查询时间点
                        joData.fixmedins_code = "";     //定点医药机构编号
                        joData.medins_list_codg = "";   //定点医药机构目录编号
                        joData.medins_list_name = "";   //定点医药机构目录名称
                        joData.insu_admdvs = TextCbd.Text;        //参保机构医保区划   
                        joData.list_type = "";          //目录类别
                        joData.med_list_codg = tbDirectoryCode.Text;      //医疗目录编码
                        joData.begndate = "";           //开始日期
                        joData.vali_flag = "";          //有效标志
                        joData.updt_time = TexDate.Text;  //更新时间
                        joData.page_num = TexDQYS.Text;   //当前页数
                        joData.page_size = TexBYSJL.Text; //本页数据量

                        break;
                    }
                case 18://医保目录限价
                    {
                        trade = TradeEnum.InsuPriceLimitDirectory;
                        joData.query_date = "";           //查询时间点
                        joData.hilist_code = tbDirectoryCode.Text;          //医保目录编码
                        joData.hilist_lmtpric_type = "";  //医保目录限价类型
                        joData.overlmt_dspo_way = "";     //医保目录超限处理方式
                        joData.insu_admdvs = TextCbd.Text;          //参保机构医保区划
                        joData.begndate = "";             //开始日期
                        joData.enddate = "";              //结束日期
                        joData.vali_flag = "";            //有效标志
                        joData.rid = "";                  //唯一记录号
                        joData.tabname = "";              //表名
                        joData.poolarea_no = "";          //统筹区
                        joData.updt_time = TexDate.Text;  //更新时间
                        joData.page_num = TexDQYS.Text;   //当前页数
                        joData.page_size = TexBYSJL.Text; //本页数据量

                        break;
                    }
                case 19://医保目录先自付比例
                    {
                        trade = TradeEnum.PrepayPercentDirectory;
                        joData.query_date = "";           //查询时间点
                        joData.hilist_code = tbDirectoryCode.Text;          //医保目录编码
                        joData.selfpay_prop_psn_type = "";//医保目录自付比例人员类别
                        joData.selfpay_prop_type = "";    //目录自付比例类别
                        joData.insu_admdvs = TextCbd.Text;          //参保机构医保区划
                        joData.begndate = "";             //开始日期
                        joData.enddate = "";              //结束日期
                        joData.vali_flag = "";            //有效标志
                        joData.rid = "";                  //唯一记录号
                        joData.tabname = "";              //表名
                        joData.poolarea_no = "";          //统筹区
                        joData.updt_time = TexDate.Text;  //更新时间
                        joData.page_num = TexDQYS.Text;   //当前页数
                        joData.page_size = TexBYSJL.Text; //本页数据量

                        break;
                    }
                case 20://医药机构信息
                    {
                        trade = TradeEnum.MedicalOrgination;
                        joData.fixmedins_type = "1"; //定点医疗服务机构类型 1定点医疗机构,2定点零售药店,3工伤定点康复机构,4辅助器具配置机构,5计划生育服务机构
                        joData.fixmedins_name = TexYYMC.Text;  //定点医药机构名称 
                        joData.fixmedins_code = "";  //定点医药机构编号 

                        break;
                    }
            }

            return joData;
        }



        private void uiButton1_Click(object sender, EventArgs e)
        {
            Close();
        }





        /// <summary>
        /// 单条上传目录对照关系
        /// </summary>
        private void SingleUpload()
        {
            if ((dgvHISDirectory.CurrentRow == null))
            {
                MessageBox.Show("请查询HIS目录对照关系");
                return;
            }

            string errorMsg = "", sMLLX = "";
            //单条目录对照关系上传
            int iHis = dgvHISDirectory.CurrentRow.Index;

            DataTable dtHis = (DataTable)dgvHISDirectory.DataSource;
            int hisType = rbgDirecType_C.SelectedIndex + 1;  //1药品 2诊疗 3材料
            //string hisTypeName = rbgDirecType_C.Items[hisType - 1].ToString(); 
            if (hisType == 1)
            {
                sMLLX = "101"; //101西药中成药 102中药饮片 103自制剂 104民族药 201医疗服务项目 301医用耗材 501长护服务项目 105其他 
            }
            else if (hisType == 2)
            {
                sMLLX = "201";
            }
            else if (hisType == 3)
            {
                sMLLX = "301";
            }

            string InsuCode = dtHis.Rows[iHis]["InsuCode"].ToString();
            string InsuName = dtHis.Rows[iHis]["InsuName"].ToString();
            string HisCode = dtHis.Rows[iHis]["itemCode"].ToString();
            string HisName = dtHis.Rows[iHis]["itemDesc"].ToString();
            string UpdateDate = DateTime.Now.ToString("yyyy-MM-dd");
            string MapId = dtHis.Rows[iHis]["MapID"].ToString();
            JArray dataArray = new JArray();
            //调用3301目录对照上传
            JObject joData = new JObject();
            joData.Add("fixmedins_hilist_id", HisCode);
            joData.Add("fixmedins_hilist_name", HisName);
            joData.Add("list_type", sMLLX);            //目录类别
            joData.Add("med_list_codg", InsuCode);     //医疗目录编码
            joData.Add("begndate", "2023-10-01");      //开始日期
            joData.Add("enddate", UpdateDate);         //结束日期
            joData.Add("aprvno", "");
            joData.Add("dosform", "");
            joData.Add("exct_cont", "");
            joData.Add("item_cont", "");
            joData.Add("prcunt", "");
            joData.Add("spec", "");
            joData.Add("pacspec", "");
            joData.Add("memo", "");

            dataArray.Add(joData);
            // 单条与多条保持一致
            JObject joInput = new JObject();
            joInput.Add("data", dataArray);

            InvokeHelper invoker = new InvokeHelper();
            Global.pat.insuplc_admdvs = Global.inf.areaCode;
            JObject joRtn = invoker.invokeCenterService(TradeEnum.DirectoryContrastUpload, joInput);
            if (JsonHelper.parseCenterRtnValue(joRtn, out errorMsg) != 0)
            {
                MessageBox.Show("目录对照关系上传失败：" + errorMsg);
            }
            else
            {
                UpdateUploadStatus(MapId, 3);
                MessageBox.Show("目录对照关系上传成功！");
            }

        }

        /// <summary>
        /// 单条撤销目录对照关系上传
        /// </summary>
        private void SingleCancelUpload()
        {
            if ((dgvHISDirectory.CurrentRow == null) || (rbMaped.Checked != true))
            {
                MessageBox.Show("请查询HIS目录对照关系");
                return;
            }

            string errorMsg = "", sMLLX = "";

            //撤销目录对照关系
            DataTable dtHis = (DataTable)dgvHISDirectory.DataSource;
            int iHis = dgvHISDirectory.CurrentRow.Index;
            string InsuCode = dtHis.Rows[iHis]["InsuCode"].ToString();
            string HisCode = dtHis.Rows[iHis]["HisCode"].ToString();
            string MapId = dtHis.Rows[iHis]["MapID"].ToString();
            int hisType = rbgDirecType_C.SelectedIndex + 1;  //1药品 2诊疗 3材料
            //string hisTypeName = rbgDirecType_C.Items[hisType - 1].ToString(); 
            if (hisType == 1)
            {
                sMLLX = "101"; //101西药中成药 102中药饮片 103自制剂 104民族药 201医疗服务项目 301医用耗材 501长护服务项目 105其他 
            }
            else if (hisType == 2)
            {
                sMLLX = "201";
            }
            else if (hisType == 3)
            {
                sMLLX = "301";
            }

            //调用3302目录对照撤销
            JObject joData = new JObject();
            joData.Add("fixmedins_code", Global.inf.hospitalNO);
            joData.Add("fixmedins_hilist_id", HisCode);
            joData.Add("list_type", sMLLX);            //目录类别
            joData.Add("med_list_codg", InsuCode);     //医疗目录编码          
            JObject joInput = new JObject();
            joInput.Add("data", joData);

            InvokeHelper invoker = new InvokeHelper();
            Global.pat.insuplc_admdvs = Global.inf.areaCode;
            JObject joRtn = invoker.invokeCenterService(TradeEnum.DirectoryContrastCancel, joInput);
            if (JsonHelper.parseCenterRtnValue(joRtn, out errorMsg) != 0)
            {
                MessageBox.Show("目录对照撤销失败：" + errorMsg);
            }
            else
            {
                UpdateUploadStatus(MapId, 2);
                MessageBox.Show("目录对照撤销成功！");
            }
        }

        /// <summary>
        /// 全部上传目录对照关系
        /// </summary>
        private void AllUpLoad()
        {
            if ((dgvHISDirectory.CurrentRow == null))
            {
                MessageBox.Show("请查询HIS目录对照关系");
                return;
            }

            string sInputStr = "", sMLLX = "", errorMsg = "", Msg = "";
            Boolean bOk = true;
            JObject InputjoRtn = new JObject();

            string UpdateDate = DateTime.Now.ToString("yyyy-MM-dd");
            int hisType = rbgDirecType_C.SelectedIndex + 1;  //1药品 2诊疗 3材料
            if (hisType == 1)
            {
                sMLLX = "101"; //101西药中成药 102中药饮片 103自制剂 104民族药 201医疗服务项目 301医用耗材 501长护服务项目 105其他 
            }
            else if (hisType == 2)
            {
                sMLLX = "201";
            }
            else if (hisType == 3)
            {
                sMLLX = "301";
            }
            List<String> mapIdList = new List<string>();
            DataTable dtHis = (DataTable)dgvHISDirectory.DataSource;
            JArray dataArray = new JArray();
            for (int i = 0; i < dtHis.Rows.Count; i++)
            {                
                string InsuCode = dtHis.Rows[i]["InsuCode"].ToString();  //医保目录编码
                string InsuName = dtHis.Rows[i]["InsuName"].ToString();  //医保目录名称
                string HisCode = dtHis.Rows[i]["itemCode"].ToString();   //HIS目录编码
                string HisName = dtHis.Rows[i]["itemDesc"].ToString();   //HIS目录名称
                mapIdList.Add(dtHis.Rows[i]["MapID"].ToString());  //ID

                //调用3301目录对照上传
                JObject joData = new JObject();
                joData.Add("fixmedins_hilist_id", HisCode);
                joData.Add("fixmedins_hilist_name", HisName);
                joData.Add("list_type", sMLLX);            //目录类别
                joData.Add("med_list_codg", InsuCode);     //医疗目录编码
                joData.Add("begndate", "2023-10-01");      //开始日期
                joData.Add("enddate", UpdateDate);         //结束日期
                joData.Add("aprvno", "");
                joData.Add("dosform", "");
                joData.Add("exct_cont", "");
                joData.Add("item_cont", "");
                joData.Add("prcunt", "");
                joData.Add("spec", "");
                joData.Add("pacspec", "");
                joData.Add("memo", "");

                dataArray.Add(joData);
            }

            JObject joInput = new JObject();
            joInput.Add("data", dataArray);
            Global.pat.insuplc_admdvs = Global.inf.areaCode;
            InvokeHelper invoker = new InvokeHelper();
            JObject joRtn = invoker.invokeCenterService(TradeEnum.DirectoryContrastUpload, joInput);
            if (JsonHelper.parseCenterRtnValue(joRtn, out errorMsg) != 0)
            {
                bOk = false;
                Msg = Msg + "<" + joInput.ToString() + "：" + errorMsg + ">";
            }

            if (bOk == false)
            {
                MessageBox.Show("全部目录对照关系上传成功，部分上传异常：" + Msg);
            }
            else
            {
                UpdateUploadStatus(string.Join(",",mapIdList.ToArray()),3);
                MessageBox.Show("全部目录对照关系上传成功！");
            }
        }


        private void UpdateUploadStatus(string ids, int state)
        {
            if (string.IsNullOrEmpty(ids)) return;

            dynamic joInput = new JObject();
            joInput.HospitalDr = Global.inf.hospitalDr;
            joInput.InterfaceDr = Global.inf.interfaceDr;
            joInput.ID = ids;
            joInput.state = state;
            JObject joRtn = invoker.invokeInsuService(JsonHelper.setIrisInpar("09010103", joInput).ToString(), "更新上传状态");
            if (joRtn["errorCode"].Text() != "0")
            {
                Global.writeLog("更新状态失败!" + joRtn["errorMessage"].ToString());
            }
        }

        /// <summary>
        /// 全部撤销目录对照关系上传
        /// </summary>
        private void AllCancelUpload()
        {
            if ((dgvHISDirectory.CurrentRow == null) || (rbMaped.Checked != true))
            {
                MessageBox.Show("请查询HIS目录对照关系");
                return;
            }

            string sMLLX = "", errorMsg = "", Msg = "";
            Boolean bOk = true;
            string UpdateDate = DateTime.Now.ToString("yyyy-MM-dd");
            int hisType = rbgDirecType_C.SelectedIndex + 1;  //1药品 2诊疗 3材料

            if (hisType == 1)
            {
                sMLLX = "101"; //101西药中成药 102中药饮片 103自制剂 104民族药 201医疗服务项目 301医用耗材 501长护服务项目 105其他 
            }
            else if (hisType == 2)
            {
                sMLLX = "201";
            }
            else if (hisType == 3)
            {
                sMLLX = "301";
            }
            DataTable dtHis = (DataTable)dgvHISDirectory.DataSource;
            List<String> mapIdList = new List<string>();

            for (int i = 0; i < dtHis.Rows.Count; i++)
            {                
                string InsuCode = dtHis.Rows[i]["InsuCode"].ToString();
                string HisCode = dtHis.Rows[i]["HisCode"].ToString();
                mapIdList.Add(dtHis.Rows[i]["MapID"].ToString());  //ID

                //调用3302目录对照撤销
                JObject joData = new JObject();
                joData.Add("fixmedins_code", Global.inf.hospitalNO);
                joData.Add("fixmedins_hilist_id", HisCode);
                joData.Add("list_type", sMLLX);            //目录类别
                joData.Add("med_list_codg", InsuCode);     //医疗目录编码          
                JObject joInput = new JObject();
                joInput.Add("data", joData);

                InvokeHelper invoker = new InvokeHelper();
                JObject joRtn = invoker.invokeCenterService(TradeEnum.DirectoryContrastCancel, joInput);
                if (JsonHelper.parseCenterRtnValue(joRtn, out errorMsg) != 0)
                {
                    bOk = false;
                    Msg = Msg + "<" + joInput.ToString()+"：" + errorMsg + ">";
                }
            }

            if (bOk == false)
            {
                MessageBox.Show("全部撤销目录对照关系上传成功，部分撤销异常：" + Msg);
            }
            else
            {
                UpdateUploadStatus(string.Join(",", mapIdList.ToArray()), 2);
                MessageBox.Show("全部撤销目录对照关系上传成功！");
            }

        }

        private void ToolStripMenuItem_Upload_Click(object sender, EventArgs e)
        {
            SingleUpload();
        }

        private void ToolStripMenuItem_CancelUpload_Click(object sender, EventArgs e)
        {
            SingleCancelUpload();
        }

        private void rbgDirecType_C_ValueChanged(object sender, int index, string text)
        {
            tbHISDirectoryFilter.Text = "";
            uiTextBox1.Text = "";
            rbAll.Checked = true;
            rbMaped.Checked = false;
            rbNoMaped.Checked = false;

            tbCenterDirectoryFilter.Text = "";
            tbInsuCode.Text = "";
            tbApprovalNO.Text = "";

            dgvCenterDirectory.DataSource = null;

            btnQueryHISDirectory_Click(null, new EventArgs());
        }

        private void rbNoMaped_CheckedChanged(object sender, EventArgs e)
        {
            //if (rbNoMaped.Checked)
            //{
            //    string errMsg;
            //    if (queryHISDirectory(1, 300, out errMsg) != 0)
            //    {
            //        MessageBox.Show(errMsg);
            //        return;
            //    }
            //}
        }

        private void dgvHISDirectory_RowStateChanged(object sender, DataGridViewRowStateChangedEventArgs e)
        {
            e.Row.HeaderCell.Value = string.Format("{0}", e.Row.Index + 1);
        }

        private void dgvCenterDirectory_RowStateChanged(object sender, DataGridViewRowStateChangedEventArgs e)
        {
            e.Row.HeaderCell.Value = string.Format("{0}", e.Row.Index + 1);
        }


        private void updateLimitPrice()
        {
            SelfpayPercentForm selfpay = new SelfpayPercentForm();
            selfpay.CenterCode = dgvDirectoy.Rows[dgvDirectoy.SelectedIndex].Cells["Code"].Value + "";
            selfpay.ShowDialog();
        }

        

        private void btSignIn_Click(object sender, EventArgs e)
        {
            if (mIS.isSigned(ref Global.curEvt.signno) != true)
            {
                JObject joRtn = new JObject();
                CallResult callResult = new SignInProcess().Process(joRtn);
                string error = "";
                if (JsonHelper.parseIrisRtnValue(JObject.FromObject(callResult.PureData), out error) != 0)
                {
                    MessageBox.Show($"签到失败！{error}");
                }
                else
                {
                    MessageBox.Show("签到成功！");
                }
            }
            else
            {
                MessageBox.Show("今日已签到！");
            }
        }

        private void tsmiSingleUpdateAuxInfo_Click(object sender, EventArgs e)
        {
            string error;
            int iDir = dgvDirectoy.CurrentRow.Index;
            if (dgvDirectoy.CurrentRow == null)
            {
                MessageBox.Show("请查询中心目录");
                return;
            }
            JObject jo = new JObject();
            jo.Add("code", dgvDirectoy.Rows[iDir].Cells["code"].Value.ToString());
            jo.Add("HisType", rbgDirecType.SelectedIndex + 1);
            if (updateAuxInfo(jo,out error) != 0)
            {
                MessageBox.Show(error);
            }
            else
            {
                MessageBox.Show(error);
            }
        }

        public string getDataRowValue(DataRow dr, string columnName)
        {
            if (!dr.Table.Columns.Contains(columnName))
            {
                return "";
            }
            else
            {
                return dr[columnName].ToString();
            }
        }

        //更新目录信息(附属信息)
        private int updateAuxInfo(JObject jo,out string err)
        {
            err = "";          
            tbDirectoryCode.Text = JsonHelper.getDestValue(jo,"code");
            dynamic joData = GetInput(15, out TradeEnum trade);
            JObject joRtn = cBus.InvokeMedicalInsuranceInquiry(trade, joData);

            if (joRtn["infcode"].ToString() == "0")
            {
                DataTable dtAuxInfo = (DataTable)joRtn["output"]["data"].ToObject(typeof(DataTable));

                DateTime dtToday = DateTime.Today;
                string chrgitm_lv = "";
                string begndate = "";
                string enddate = "";
                string list_type = "";
                string med_chrgitm_type = "";
                
                int iAdpater = 0;

                foreach (DataRow  dr in dtAuxInfo.Rows)
                {
                    DateTime dtBegin = getDataRowValue(dr, "begndate") == "" ? Convert.ToDateTime("2000-01-01 00:00:00") : Convert.ToDateTime(getDataRowValue(dr, "begndate"));
                    DateTime dtEnd = getDataRowValue(dr, "enddate") == "" ? Convert.ToDateTime("2099-01-01 00:00:00") : Convert.ToDateTime(getDataRowValue(dr, "enddate"));

                    if ((dtBegin < dtToday) && (dtToday < dtEnd))
                    {
                        iAdpater++;
                        chrgitm_lv = dr["chrgitm_lv"].ToString();
                        begndate = dr["begndate"].ToString();
                        enddate = dr["enddate"].ToString();
                        list_type = dr["list_type"].ToString();
                        med_chrgitm_type = dr["med_chrgitm_type"].ToString();
                    }
                }

                //有且只能有一条数据符合
                if (iAdpater == 1)
                {
                    JObject joPamam = new JObject();
                    joPamam.Add("Code", JsonHelper.getDestValue(jo, "code"));
                    joPamam.Add("HisType", JsonHelper.getDestValue(jo, "HisType"));
                    joPamam.Add("StartDate", begndate);
                    joPamam.Add("EndDate", enddate);
                    joPamam.Add("ChargeItemLevel", chrgitm_lv);
                    joPamam.Add("ListType", list_type);
                    joPamam.Add("ChargeItemType", med_chrgitm_type);

                    JObject joUpdateRtn = mIS.UpdateDirectoryBySelf(joPamam);
                    string error = "";
                    if (JsonHelper.parseIrisRtnValue(joUpdateRtn, out error) != 0)
                    {
                        err = "修改失败：" + error;
                        return -1;
                    }
                    else
                    {
                        err = "修改成功";
                        return 0;
                    }
                }
                else
                {
                    err = "中心返回符合条数的记录不唯一或者为空,请检查！";
                    return -1;
                }
            }
            else
            {
                err = "查询中心数据出错,请检查！";
                return -1;
            }
        }

        //更新目录信息(附属信息)
        private int updateCellingPrice(JObject jo, out string err)
        {
            err = "";
            tbDirectoryCode.Text = JsonHelper.getDestValue(jo, "code");
            dynamic joData = GetInput(18, out TradeEnum trade);
            JObject joRtn = cBus.InvokeMedicalInsuranceInquiry(trade, joData);

            if (joRtn["infcode"].ToString() == "0")
            {
                DataTable dtAuxInfo = (DataTable)joRtn["output"]["data"].ToObject(typeof(DataTable));

                DateTime dtToday = DateTime.Today;
                string cellingPrice = "";
                string begndate = "";
                string enddate = "";


                int iAdpater = 0;

                foreach (DataRow dr in dtAuxInfo.Rows)
                {
                    DateTime dtBegin = getDataRowValue(dr, "begndate") == "" ? Convert.ToDateTime("2000-01-01 00:00:00") : Convert.ToDateTime(getDataRowValue(dr, "begndate"));
                    DateTime dtEnd = getDataRowValue(dr, "enddate") == "" ? Convert.ToDateTime("2099-01-01 00:00:00") : Convert.ToDateTime(getDataRowValue(dr, "enddate"));

                    if ((dtBegin < dtToday) && (dtToday < dtEnd))
                    {
                        iAdpater++;
                        cellingPrice = dr["hilist_pric_uplmt_amt"].ToString();
                        begndate = dr["begndate"].ToString();
                        enddate = dr["enddate"].ToString();

                    }
                }

                //有且只能有一条数据符合
                if (iAdpater == 1)
                {
                    JObject joPamam = new JObject();
                    joPamam.Add("Code", JsonHelper.getDestValue(jo, "code"));
                    joPamam.Add("HisType", JsonHelper.getDestValue(jo, "HisType"));
                    joPamam.Add("StartDate", begndate);
                    joPamam.Add("EndDate", enddate);
                    joPamam.Add("CeilingPrice", cellingPrice);


                    JObject joUpdateRtn = mIS.UpdateDirectoryBySelf(joPamam);
                    string error = "";
                    if (JsonHelper.parseIrisRtnValue(joUpdateRtn, out error) != 0)
                    {
                        err = "修改失败：" + error;
                        return -1;
                    }
                    else
                    {
                        err = "修改成功";
                        return 0;
                    }
                }
                else
                {
                    err = "中心返回符合条数的记录不唯一或者为空,请检查！";
                    return -1;
                }
            }
            else
            {
                err = "查询中心数据出错,请检查！";
                return -1;
            }
        }


        private int updateSelfRatioInfo(JObject jo, out string err)
        {
            err = "";
            tbDirectoryCode.Text = JsonHelper.getDestValue(jo, "code");
            dynamic joData = GetInput(19, out TradeEnum trade);
            JObject joRtn = cBus.InvokeMedicalInsuranceInquiry(trade, joData);

            if (joRtn["infcode"].ToString() == "0")
            {
                DataTable dtRatioInfo = (DataTable)joRtn["output"]["data"].ToObject(typeof(DataTable));

                DateTime dtToday = DateTime.Today;
                string cellingPrice = "";
                string begndate = "";
                string enddate = "";

                int iAdpater = 0;

                var dataArray = JArray.FromObject(joRtn["output"]["data"]);

                DateTime today = DateTime.Today;

                var groupedResult = dataArray
                    .Where(item =>
                    {
                        if (DateTime.TryParse(item["enddate"]?.ToString(), out var endDate))
                        {
                            return endDate.Date >= today.Date;
                        }
                        return false;
                    })
                    .GroupBy(item => item["selfpay_prop_psn_type"]?.ToString());

                JArray joArray = new JArray();
                foreach (var group in groupedResult)
                {

                    foreach (var item in group)
                    {
                        // 将 JsonNode 转换为 JObject
                        JObject jObj = JObject.Parse(item.ToString());
                        dynamic joTmp = new JObject();
                        joTmp.HospitalDr = Global.inf.hospitalDr;
                        joTmp.InterfaceDr = Global.inf.interfaceDr;
                        joTmp.updateUserID = Global.user.ID;
                        joTmp.Code = jObj["hilist_code"];
                        joTmp.PersonnelType = jObj["selfpay_prop_psn_type"];
                        joTmp.ProportionType = jObj["selfpay_prop_type"];
                        joTmp.Proportion = jObj["selfpay_prop"];
                        joTmp.BeginDate = jObj["begndate"];
                        joTmp.EndDate = jObj["enddate"];
                        joTmp.InsuranceAreaCode = jObj["insu_admdvs"];
                        joTmp.PoolAreaNO = jObj["poolarea_no"];
                        joTmp.ValidFlag = jObj["vali_flag"];
                        joTmp.RequiredID = jObj["rid"];
                        joArray.Add(joTmp);
                    }
                }

                string errMsg = "";
                InvokeHelper invoker = new InvokeHelper();
                 joRtn = invoker.invokeInsuService(JsonHelper.setIrisInpar("09010085", joArray).ToString(), "设置自费比例");

                if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                {
                    err = errMsg;
                    return -1;
                }
                else {
                    err = ("更新成功!");
                    return 0;
                }   
            }
            else
            {
                err = "查询中心数据出错,请检查！";
                return -1;
            }
        }

        private void tsmiUpdateCellingPrice_Click(object sender, EventArgs e)
        {
            string error;
            int iDir = dgvDirectoy.CurrentRow.Index;
            if (dgvDirectoy.CurrentRow == null)
            {
                MessageBox.Show("请查询中心目录");
                return;
            }
            JObject jo = new JObject();
            jo.Add("code", dgvDirectoy.Rows[iDir].Cells["code"].Value.ToString());
            jo.Add("HisType", rbgDirecType.SelectedIndex + 1);
            if (updateCellingPrice(jo,out error) != 0)
            {
                MessageBox.Show(error);
            }
            else
            {
                MessageBox.Show(error);
            }
        }

        private void btTripMenu_Click(object sender, EventArgs e)
        {
            uiContextMenuStrip1.Show(((Sunny.UI.UIButton)sender), new Point(0, btTripMenu.Height));
        }

        private void tsmExportAllMappedData_Click(object sender, EventArgs e)
        {
            // 创建 DataLoader 并传递 queryExportData 方法
            DataLoader _dataLoader;
            _dataLoader = new DataLoader(queryExportData_CallBack, this);

            _dataLoader.Start(new object[] { 0 }, (result, errMsg) =>
            {
                // 在这里处理结果和错误信息
                if (result == 0)
                {
                    MessageBox.Show(errMsg);
                }
                else
                {
                    MessageBox.Show(errMsg);
                }
            });
        }

        private int queryExportData(out string errMsg)
        {
            errMsg = "";
            int currentPage = 1; int pageSize = 50;
            string directoryType = string.Empty;
            switch (rbgDirecType_C.SelectedIndex)
            {
                case 0:
                    {
                        directoryType = "drugs";
                        break;
                    }
                case 1:
                    {
                        directoryType = "diagnosi";
                        break;
                    }
                case 2:
                    {
                        directoryType = "consumables";
                        break;
                    }
            }

            JObject joHISRtn = new JObject();
            JObject joRtn = new JObject();
            string flag = "";
            //全部是先调HIS，然后再匹配医保平台的对照关系
            if (rbAll.Checked)
            {
                JArray jaPagination = new JArray();
                JArray jaParams = new JArray();
                flag = "All";
                dynamic joParam = new JObject();
                joParam.code = "";
                joParam.descripts = "";
                joParam.FindType = new JArray();
                joParam.TypeID = "";
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.include = "Hosp";
                joParam.groupID = "324";
                joParam.hospID = Global.inf.hisHospitalDr;
                joParam.interfaceDr = Global.inf.interfaceDr;
                joParam.type = directoryType;
                joParam.flag = flag;
                joParam.specInput = txtSpecFilter.Text.Trim();
                jaParams.Add(joParam);

                dynamic joPagination = new JObject();
                joPagination.pageSize = pageSize;
                //joPagination.pageSize = 2;
                joPagination.currentPage = currentPage;
                joPagination.sortColumn = "Code";
                joPagination.sortOrder = "asc";
                jaPagination.Add(joPagination);
                //该服务需要改写，需要跟（CloudMedicalInsurancePlatform.Tables.MapRelation）进行关联
                //joInParams.code = "09010038";
                if (hIS.getHISDir(jaPagination, jaParams, out joHISRtn, out errMsg) != 0)
                {
                    return -1;
                }

                int count = int.Parse(JsonHelper.getDestValue(joHISRtn, "result.TotalCount"));
                if (count > pageSize)
                {
                    joPagination["pageSize"] = count;
                    jaPagination = new JArray();
                    jaPagination.Add(joPagination);
                    if (hIS.getHISDir(jaPagination, jaParams, out joHISRtn, out errMsg) != 0)
                    {
                        return -1;
                    }
                }
                int defaultCount = 200;
                dtExport = null;
                if (count > defaultCount)
                {
                    JArray jaHisDir = JArray.Parse(JsonHelper.getDestValue(joHISRtn, "result.Data"));
                    JArray jaTmp = new JArray();

                    for (int i = 0; i < count; i++)
                    {

                        JObject joTmp = (JObject)jaHisDir[i];
                        foreach (var property in joTmp.Properties())
                        {
                            if (property.Value.Type == JTokenType.Integer || property.Value.Type == JTokenType.Float)
                            {
                                property.Value = new JValue(property.Value.ToString());
                            }
                        }
                        jaTmp.Add(joTmp);
                        if ((((i + 1) % defaultCount) == 0) || (i + 1 == count))
                        {
                            JObject joConvert = new JObject();
                            joConvert.Add("errorCode", 0);
                            joConvert.Add("errorMessage", "查询成功");
                            JObject joResult = new JObject();
                            if ((i % defaultCount) == 0)
                            {
                                joResult.Add("TotalCount", defaultCount);
                            }
                            else
                            {
                                joResult.Add("TotalCount", (i + 1) % defaultCount);
                            }

                            joResult.Add("Data", jaTmp);
                            joConvert.Add("result", joResult);
                            joRtn = mIS.ConvertHISDir(joConvert);
                            if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                            {
                                return -1;
                            }
                            else
                            {
                                DataTable dtTmp = (DataTable)joRtn["result"]["Data"].ToObject(typeof(DataTable));
                                if (dtExport == null)
                                {
                                    dtExport = dtTmp.Clone();
                                    dtExport.Merge(dtTmp);
                                }
                                else
                                {
                                    dtExport.Merge(dtTmp);
                                }
                                jaTmp = new JArray();
                            }
                        }

                    }
                }
                else
                {
                    joRtn = mIS.ConvertHISDir(joHISRtn);
                    if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                    {
                        return -1;
                    }
                    dtExport = (DataTable)joRtn["result"]["Data"].ToObject(typeof(DataTable));
                }

            }

            //已对照是先调云医保，然后再匹配HIS
            if (rbMaped.Checked)
            {
                JArray jaPagination = new JArray();
                JArray jaParams = new JArray();
                flag = "Maped";
                dynamic joParam = new JObject();
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.HospitalDr = Global.inf.hospitalDr;
                joParam.InterfaceDr = Global.inf.interfaceDr;
                joParam.hisType = directoryType;
                jaParams.Add(joParam);
                dynamic joPagination = new JObject();
                joPagination.pageSize = pageSize;
                joPagination.currentPage = currentPage;
                joPagination.sortColumn = "HisCode";
                joPagination.sortOrder = "asc";
                jaPagination.Add(joPagination);

                JObject joMIRtn = mIS.GetMappedHISDir(jaPagination, jaParams);

                if (JsonHelper.parseIrisRtnValue(joMIRtn, out errMsg) != 0)
                {
                    return -1;
                }

                //传给HIS，进行匹配
                joParam = new JObject();
                joParam.TotalCount = joMIRtn["result"]["TotalCount"];
                joParam.type = directoryType;
                joParam.flag = flag;
                joParam.hospID = Global.inf.hisHospitalDr;
                joParam.interfaceDr = Global.inf.interfaceDr;
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.include = "Hosp";
                joParam.groupID = "324";
                joParam.compareArr = joMIRtn["result"]["Data"];
                jaParams = new JArray();
                jaParams.Add(joParam);
                if (hIS.getHISDir(jaPagination, jaParams, out joRtn, out errMsg) != 0)
                {
                    return -1;
                }
            }

            //if (rbNoMaped.Checked) { flag = "NoMaped"; }

            if (rbNoMaped.Checked)
            {
                JArray jaPagination = new JArray();
                JArray jaParams = new JArray();
                flag = "All";
                dynamic joParam = new JObject();
                joParam.code = "";
                joParam.descripts = "";
                joParam.FindType = new JArray();
                joParam.TypeID = "";
                joParam.alias = tbHISDirectoryFilter.Text;
                joParam.include = "Hosp";
                joParam.groupID = "324";
                joParam.hospID = Global.inf.hisHospitalDr;
                joParam.interfaceDr = Global.inf.interfaceDr;
                joParam.type = directoryType;
                joParam.flag = flag;
                joParam.specInput = "";
                jaParams.Add(joParam);

                dynamic joPagination = new JObject();
                joPagination.pageSize = pageSize;
                //joPagination.pageSize = 2;
                joPagination.currentPage = currentPage;
                joPagination.sortColumn = "Code";
                joPagination.sortOrder = "asc";
                jaPagination.Add(joPagination);

                //1.获取全部HIS目录
                if (hIS.getHISDir(jaPagination, jaParams, out joHISRtn, out errMsg) != 0)
                {
                    return -1;
                }

                joRtn = mIS.GetNoMappHISDir(joHISRtn);
                if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                {
                    return -1;
                }
            }


            return 0;
        }

        private int queryExportData_CallBack(object[] o,out string errMsg, DataLoader.ProgressCallback callback, DataLoader.ProgressMaxCallback maxCallback, BackgroundWorker worker)
        {
            if (queryExportData(out errMsg) != 0)
            {
                return -1;
            }

            //test.Stop();
            this.pgHISDirect.PageChanged += new Sunny.UI.UIPagination.OnPageChangeEventHandler(this.pgHISDirect_PageChanged);
            if (dtExport.Rows.Count > 0)
            {
                string directoryType = string.Empty;
                string sBZ = "";
                switch (rbgDirecType_C.SelectedIndex)
                {
                    case 0:
                        {
                            directoryType = "药品";
                            break;
                        }
                    case 1:
                        {
                            directoryType = "诊疗";
                            break;
                        }
                    case 2:
                        {
                            directoryType = "材料";
                            break;
                        }
                }

                if (rbAll.Checked) sBZ = "全部";
                else
                    if (rbMaped.Checked) sBZ = "已对照";
                else
                    if (rbNoMaped.Checked) sBZ = "未对照";

                string LSH = DateTime.Now.ToString("yyyy-MM-dd"); //DateTime.Now.ToString("MMddHHmmssffff");
                string filename = LSH + "(" + directoryType + ")医保目录" + sBZ + "信息.xls";
                string sFliePathName = Global.curEvt.path + "\\MapRelation\\" + filename;
                //string sFliePathName = @"D:\" + LSH + "(" + directoryType + ")医保目录" + sBZ + "信息.xls";

                //如果不存在目录，则创建目录
                if (!Directory.Exists(Global.curEvt.path + "\\MapRelation"))
                {
                    //创建文件夹
                    DirectoryInfo dirInfo = Directory.CreateDirectory(Global.curEvt.path + "\\MapRelation");
                }
               

                //如存在同名文件不询问直接删除
                if (File.Exists(sFliePathName))
                {
                    File.Delete(sFliePathName);
                }

               

                //新版方法，用的EPPLUS，方便
                ExportToExcel.ExportDataTableToExcel(dtExport, sFliePathName);
                if (true)
                {
                    errMsg = ($"导出成功,文件保存路径：{sFliePathName}");
                    return 0;
                }
                else
                {
                    errMsg = ("导出失败!");
                    return -1;
                }
            }
            else
            {
                errMsg = "查询数据集为空！";
                return -1;
            }

        }

        private void tsmUploadAllMappedData_Click(object sender, EventArgs e)
        {
            AllUpLoad();
        }

        private void tsmCancelAllUploadedData_Click(object sender, EventArgs e)
        {
            AllCancelUpload();
        }

        private void tsmUpdateCellPriceOfAllMapped_Click(object sender, EventArgs e)
        {
            batchUpdateMappedInsuInfo(updateCellPriceWrapper);
        }

        private void tsmUpdateAllMapped_Click(object sender, EventArgs e)
        {
            batchUpdateMappedInsuInfo(updateAuxAndCellPriceWrapper);
        }

        

        private void batchUpdateMappedInsuInfo( Func<JObject, OutParamWrapper, int> _action)
        {
            action = _action;
            string sqlStr = $"select * from HB_MedInsuMapRelation where Interface_Dr='{Global.inf.interfaceDr}' and Hospital_Dr ='{Global.inf.hospitalDr}'";
            JObject joSqlstr = new JObject();
            joSqlstr.Add("sqlStr", sqlStr);
            JObject joRtn = mIS.QueryMappedData(joSqlstr, "查询所有已对照数据");

            iTotalCount = int.Parse(joRtn["result"]["total"].ToString());
            dtAllMapped = (DataTable)joRtn["result"]["data"].ToObject(typeof(DataTable));

            DataLoader _dataLoader;
            _dataLoader = new DataLoader(updateMappedInsuInfo,this);
            _dataLoader.SetProgressBar(ProgressBarStyle.Continuous,"正在更新...",50);

            _dataLoader.Start(new object[] { iTotalCount }, (result, errMsg) =>
            {
                // 在这里处理结果和错误信息
                if (result == 0)
                {
                    MessageBox.Show(errMsg);
                }
                else
                {
                    MessageBox.Show(errMsg);
                }
            });
        }

        private int updateMappedInsuInfo(object[] o,out string errMsg, DataLoader.ProgressCallback callback, DataLoader.ProgressMaxCallback maxCallback, BackgroundWorker worker)
        {
            int iFalse = 0;
            int iCount = 0;
            List<string> errList = new List<string>();

            if (maxCallback != null)
            {
                maxCallback(iTotalCount);
            }

            foreach (DataRow dr in dtAllMapped.Rows)
            {
                JObject jo = new JObject();
                jo.Add("code", dr["InsuCode"].ToString());
                jo.Add("HisType", dr["HisType"].ToString());
                OutParamWrapper outParWarp = new OutParamWrapper();
                if (action(jo, outParWarp) != 0)
                {
                    iFalse++;
                    errList.Add(outParWarp.Value);
                    Global.writeLog(outParWarp.Value);
                }

                iCount++;

                // 检查是否应取消操作
                if (worker.CancellationPending)
                {
                    errMsg = "操作取消！";
                    return -1; // 或者其他表示取消的返回值
                }

                if (callback != null)
                {
                    callback(iCount);
                }
            }

            if (iFalse != 0)
            {
                errMsg = ($"总共{iCount}条数据更新完成，但有{iFalse}条更新发生错误！");
                Global.writeLog($"{errMsg}\r\n{errList}");
            }
            else
            {
                errMsg = ($"全部数据({iCount}条)更新完成");
            }
            return iFalse;
        }

        private int updateAuxAndCellPriceWrapper(JObject jo, OutParamWrapper outParamWrapper)
        {
            string err;
            int iresult = updateAuxAndCellPrice(jo, out err);
            outParamWrapper.Value = err;
            return iresult;
        }

        private int updateCellPriceWrapper(JObject jo, OutParamWrapper outParamWrapper)
        {
            string err;
            int iresult = updateCellingPrice(jo, out err);
            outParamWrapper.Value = err;
            return iresult;
        }

        private int updateSelfRatioWrapper(JObject jo, OutParamWrapper outParamWrapper)
        {
            string err;
            int iresult = updateSelfRatioInfo(jo, out err);
            outParamWrapper.Value = err;
            return iresult;
        }

        private int updateAuxInfoWrapper(JObject jo, OutParamWrapper outParamWrapper)
        {
            string err;
            int iresult = updateAuxInfo(jo, out err);
            outParamWrapper.Value = err;
            return iresult;
        }


        private int updateAuxAndCellPrice(JObject jo, out string error)
        {
            string err ="";
            int iResult=0;
            error = "";
            if (updateAuxInfo(jo, out err) != 0)
            {
                error = $"更新目录信息失败{err}";
                iResult--;
            }

            err = "";
            if (updateCellingPrice(jo, out err) != 0)
            {
                error = $"{error};更新限价信息失败{err}";
                iResult--;
            }

            return iResult; 
        }

        private void tsmUpdateLevelTypeOfAllMappedData_Click(object sender, EventArgs e)
        {
            batchUpdateMappedInsuInfo(updateAuxInfoWrapper);
        }

        private void tsmSingleUpdateInsuInfo_Click(object sender, EventArgs e)
        {
            if ((dgvHISDirectory.CurrentRow == null) || (rbMaped.Checked != true))
            {
                MessageBox.Show("请查询HIS目录对照关系,注意选择已对照！");
                return;
            }

            int iMapped = dgvHISDirectory.CurrentRow.Index;

            string insuCode = dgvHISDirectory.Rows[iMapped].Cells["insuCode"].Value.ToString();
            if (string.IsNullOrEmpty(insuCode))
            {
                MessageBox.Show("未检测到对应的医保目录，请检查该目录是否已对照！");
                return;
            }

            JObject jo = new JObject();
            jo.Add("code", dgvHISDirectory.Rows[iMapped].Cells["insuCode"].Value.ToString());
            jo.Add("HisType", rbgDirecType_C.SelectedIndex + 1);

            string error;
            if (updateAuxAndCellPrice(jo, out error) != 0)
            {
                MessageBox.Show($"更新失败{error}");
            }
            else
            {
                MessageBox.Show("更新成功！");
            }
        }

        private void dgvHISDirectory_SelectionChanged(object sender, EventArgs e)
        {
            int i = dgvHISDirectory.CurrentRow.Index;


            if (dgvHISDirectory.Rows[i].Cells["insuCode"].Value.ToString() != "")
            {
                tbInsuCode.Text = dgvHISDirectory.Rows[i].Cells["insuCode"].Value.ToString();
                tbCenterDirectoryFilter.Text = "";
                tbApprovalNO.Text = "";
            }
            else
            {
                tbInsuCode.Text = "";
                if (rbOnlyName.Checked)
                {
                    tbInsuCode.Text = "";
                    tbApprovalNO.Text = "";
                    tbCenterDirectoryFilter.Text = "%" + dgvHISDirectory.Rows[i].Cells["itemDesc"].Value.ToString() + "%";
                }
                if (rbOnlyApprNO.Checked)
                {
                    tbCenterDirectoryFilter.Text = "";
                    tbInsuCode.Text = "";
                    tbApprovalNO.Text = "%" + dgvHISDirectory.Rows[i].Cells["pprovalNo"].Value.ToString() + "%";
                }
                if (rbBoth.Checked)
                {
                    tbInsuCode.Text = "";
                    tbCenterDirectoryFilter.Text = "%" + dgvHISDirectory.Rows[i].Cells["itemDesc"].Value.ToString() + "%";
                    tbApprovalNO.Text = "%" + dgvHISDirectory.Rows[i].Cells["pprovalNo"].Value.ToString() + "%";
                }

            }


        }

        private void tsmSingleUpdateSelfRatioInfo_Click(object sender, EventArgs e)
        {
            if ((dgvHISDirectory.CurrentRow == null) || (rbMaped.Checked != true))
            {
                MessageBox.Show("请查询HIS目录对照关系,注意选择已对照！");
                return;
            }

            int iMapped = dgvHISDirectory.CurrentRow.Index;

            string insuCode = dgvHISDirectory.Rows[iMapped].Cells["insuCode"].Value.ToString();
            if (string.IsNullOrEmpty(insuCode))
            {
                MessageBox.Show("未检测到对应的医保目录，请检查该目录是否已对照！");
                return;
            }

            JObject jo = new JObject();
            jo.Add("code", dgvHISDirectory.Rows[iMapped].Cells["insuCode"].Value.ToString());
            jo.Add("HisType", rbgDirecType_C.SelectedIndex + 1);

            string error;
            if (updateSelfRatioInfo(jo, out error) != 0)
            {
                MessageBox.Show($"更新失败{error}");
            }
            else
            {
                MessageBox.Show("更新成功！");
            }
        }

        private void tsmUpdateSelfRatioOfAllMapped_Click(object sender, EventArgs e)
        {
            batchUpdateMappedInsuInfo(updateSelfRatioWrapper);
        }

        private string SelectExcelFile()
        {
            //打开窗口选择文件
            OpenFileDialog openFileDialog = new OpenFileDialog
            {
                InitialDirectory = System.Environment.GetFolderPath(Environment.SpecialFolder.Desktop), // 设置初始目录
                Filter = "Excel files (*.xlsx)|*.xlsx", // 设置文件过滤器
                FilterIndex = 1, // 设置默认的文件过滤器索引
                RestoreDirectory = true // 对话框关闭前是否恢复原始目录
            };
            string selectedFilePath = "";
            if (openFileDialog.ShowDialog() == DialogResult.OK)
            {
                selectedFilePath = openFileDialog.FileName;
            }
            return selectedFilePath;
        }

        private int ImportMapRelation(object[] o, out string errMsg, DataLoader.ProgressCallback callback, DataLoader.ProgressMaxCallback maxCallback, BackgroundWorker worker)
        {
            int iFalse = 0;
            string err = "";
            string excelPath = o[0].ToString();
            errMsg = "";
            //加载EXCEL
            using (ExcelPackage package = new ExcelPackage(excelPath))
            {
                ExcelWorksheet worksheet = package.Workbook.Worksheets[0];
                int colCount = worksheet.Dimension.End.Column;  //get Column Count
                int rowCount = worksheet.Dimension.End.Row;     //get row count
                if (maxCallback != null)
                {
                    maxCallback(rowCount);
                }
                //建立索引字典
                Dictionary<string, int> indexDic = new Dictionary<string, int>();
                //通过第一行来确定每列的数据与后台对应关系
                for (int col = 1; col <= colCount; col++)
                {
                    string colHearder = worksheet.Cells[1, col].Value?.ToString().Trim();
                    switch (colHearder)
                    {
                        case "HIS编码":
                            indexDic.Add("HISCode", col);
                            break;
                        case "HIS名称":
                            indexDic.Add("HISName", col);
                            break;
                        case "目录类型":
                            indexDic.Add("HisType", col);
                            break;
                        case "医保编码":
                            indexDic.Add("InsuCode", col);
                            break;
                        case "医保名称":
                            indexDic.Add("InsuName", col);
                            break;
                        default:
                            break;
                    }
                }
                Global.writeLog(JsonConvert.SerializeObject(indexDic));
                JArray jaTmp = new JArray();
                for (int row = 2; row <= rowCount; row++)
                {
                    // 检查是否应取消操作
                    if (worker.CancellationPending)
                    {
                        errMsg = "操作取消！";
                        return -1; // 或者其他表示取消的返回值
                    }

                    if (callback != null)
                    {
                        callback(row);
                    }
                    JObject joTmp = new JObject();
                    //for (int col = 1; col <= colCount; col++)
                    //{
                    joTmp.Add("HospitalDr", Global.inf.hospitalDr);        //医院编号
                    joTmp.Add("InterfaceDr", Global.inf.interfaceDr);      // 接口编号 - HBMedInsuInterface 类型（假设用字符串表示）
                    //joTmp.Add("ChargeItemDr", worksheet.Cells[row, indexDic["ChargeItemDr"]]?.Value?.ToString().Trim());   // 收费项ID - %Integer
                    joTmp.Add("HISCode", worksheet.Cells[row, indexDic["HISCode"]]?.Value?.ToString().Trim());             // HIS编码 - %String
                    joTmp.Add("HISName", worksheet.Cells[row, indexDic["HISName"]]?.Value?.ToString().Trim());             // HIS名称 - %String
                    //joTmp.Add("DiretoryDr", worksheet.Cells[row, indexDic["Direcotry_Dr"]]?.Value?.ToString().Trim());     // 医保目录Dr - HBMedInsuDirectory（字符串处理）
                    joTmp.Add("HisType", worksheet.Cells[row, indexDic["HisType"]]?.Value?.ToString().Trim());             // 医院目录类型 - %String
                    joTmp.Add("State", "1");                 // 状态 -  1.已对照  2.已对照但未上传  3 已对照且已上传
                    joTmp.Add("UpdateDate", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));       // 更新时间 - %DateTime
                    joTmp.Add("InsuCode", worksheet.Cells[row, indexDic["InsuCode"]]?.Value?.ToString().Trim());           // 医保编码 - %String
                    joTmp.Add("InsuName", worksheet.Cells[row, indexDic["InsuName"]]?.Value?.ToString().Trim());           // 医保名称 
                    //}
                    jaTmp.Add(joTmp);
                    //每50条传一次
                    if (((row + 2) % 50 == 0) || ((row + 2) == rowCount))
                    {
                        JObject joIn = new JObject();
                        joIn.Add(new JProperty("params", jaTmp));
                        joIn.Add("code", "09010040");
                        InvokeHelper invoker = new InvokeHelper();
                        JObject joRtn = invoker.invokeInsuService(joIn.ToString(), "导入对照关系");

                        // 更新对照关系表返回的数据
                        if (JsonHelper.parseIrisRtnValue(joRtn, out err) != 0)
                        {
                            iFalse++;
                            errMsg = errMsg + "\r\n" + err;
                        }
                        jaTmp = new JArray();
                    }
                }

            }
            return iFalse ;
        }

        private void tsmImportMapRelation_Click(object sender, EventArgs e)
        {
            object[] o = new object[] { SelectExcelFile() } ;
            DataLoader _dataLoader;
            _dataLoader = new DataLoader(ImportMapRelation, this);
            _dataLoader.SetProgressBar(ProgressBarStyle.Continuous, "正在导入...", 50);

            _dataLoader.Start(o,(result, errMsg) =>
            {
                MessageBox.Show(errMsg);
            });
        }

        private void tsmImportExcelDir_Click(object sender, EventArgs e)
        {
            object[] o = new object[] { SelectExcelFile() };
            DataLoader _dataLoader;
            _dataLoader = new DataLoader(ImportExcelDir, this);
            _dataLoader.SetProgressBar(ProgressBarStyle.Continuous, "正在导入...", 50);

            _dataLoader.Start(o, (result, errMsg) =>
            {
                MessageBox.Show(errMsg);
            });
        }

        private int ImportExcelDir(object[] o, out string errMsg, DataLoader.ProgressCallback callback, DataLoader.ProgressMaxCallback maxCallback, BackgroundWorker worker)
        {
            int iFalse = 0;
            string err = "";
            string excelPath = o[0]?.ToString();
            if (string.IsNullOrEmpty(excelPath))
            {
                errMsg = "文件路径无效。";
                return -1;
            }

            // 定义字段映射：Excel列名 -> JSON字段名
            var columnMapping = new Dictionary<string, string>
            {
                //{ "医院编号", "HospitalDr" },
                //{ "接口编号", "InterfaceDr" },
                { "医保编码", "Code" },
                { "医保名称", "Name" },
                { "医院目录类型", "HisType" },
                { "医院类型名称", "HisTypeName" },
                { "医保本地编码", "LocateCode" },
                { "医保本地名称", "LocateName" },
                { "本位码", "DrugSafetyStandardCode" },
                { "剂型编码", "DosageFormCode" },
                { "剂型名称", "DosageFormName" },
                { "类别编码", "CategoryCode" },
                { "类别名称", "CategoryName" },
                { "规格", "Specification" },
                { "规格代码", "SpecificationCode" },
                { "包装单位", "UnitOfPackag" },
                { "计价单位", "UnitOfValuation" },
                { "开始日期", "StartDate" },
                { "结束日期", "EndDate" },
                { "拼音助记码", "PinyinSearchCode" },
                { "说明", "Instructions" },
                { "除外内容", "ExceptContent" },
                { "项目内涵", "Connotation" },
                { "有效标志", "ValidFlag" },
                { "备注", "Note" },
                { "批准文号", "ApprovalNO" },
                { "版本号", "VersionNO" },
                { "版本名称", "VersionName" },
                { "使用标志", "UseFlag" },
                { "特殊药品标志", "SpecialFlag" },
                { "限制标志", "LimitFlag" },
                { "限制范围", "LimitRange" },
                { "唯一记录号", "UniqueRecordNO" },
                { "厂家", "Manufacturers" },
                { "国家项目编码", "NationalCode" },
                { "国家项目名称", "NationalName" },
                { "更新时间", "UpdateTime" },
                { "收费项目等级", "ChargeItemLevel" },
                { "收费项目等级名称", "ChargeItemLevelName" },
                { "自付比例", "SelfPercent" },
                { "医疗收费项目类别", "ChargeItemType" },
                { "收费标准", "ChargeStandards" },
                { "最高限价", "CeilingPrice" },
                { "包装材质", "PackagingMaterial" },
                { "最小包装数量", "MinPackagingQuantity" },
                { "最小制剂单位", "MinDosageUnit" },
                { "最小包装单位", "MinPackagingUnit" },
                { "累计增负标志", "CumulativeNegativeBurdenFlag" },
                { "目录类型", "ListType" },
                { "目录支付比例", "DirectoryPayPercent" }
            };
            errMsg = "";
            //加载EXCEL
            using (ExcelPackage package = new ExcelPackage(excelPath))
            {
                var worksheet = package.Workbook.Worksheets[0];
                int colCount = worksheet.Dimension?.Columns ?? 0;
                int rowCount = worksheet.Dimension?.Rows ?? 0;

                if (rowCount < 2)
                {
                    errMsg = "Excel 文件中没有有效的数据行。";
                    return -1;
                }

                if (maxCallback != null)
                    maxCallback(rowCount);

                // 建立索引字典
                var indexDic = new Dictionary<string, int>();
                for (int col = 1; col <= colCount; col++)
                {
                    var header = worksheet.Cells[1, col].Value?.ToString().Trim();
                    if (columnMapping.TryGetValue(header, out string jsonField))
                    {
                        indexDic[jsonField] = col;
                    }
                    else
                    {
                        // 可选：记录未识别的列头
                        Global.writeLog($"未知列头: {header}");
                    }
                }

                Global.writeLog(JsonConvert.SerializeObject(indexDic));


                JArray jaTmp = new JArray();
                for (int row = 2; row <= rowCount; row++)
                {
                    Global.writeLog(callback.Target.GetType().Name);
                    // 检查是否应取消操作
                    if ( worker.CancellationPending)
                    {
                        errMsg = "操作取消！";
                        return -1; // 或者其他表示取消的返回值
                    }
                    if (callback != null)
                        callback(row);

                    JObject joTmp = new JObject();

                    foreach (var pair in indexDic)
                    {
                        string fieldName = pair.Key;
                        int colIndex = pair.Value;

                        var cellValue = worksheet.Cells[row, colIndex]?.Value?.ToString().Trim();
                        joTmp.Add(fieldName, cellValue ?? string.Empty);
                    }

                    //手动增加医院ID 和接口ID
                    joTmp.Add("HospitalDr", Global.inf.hospitalDr);        //医院编号
                    joTmp.Add("InterfaceDr", Global.inf.interfaceDr);      // 接口编号

                    jaTmp.Add(joTmp);
                    //每50条传一次
                    if (((row + 2) % 50 == 0) || ((row + 2) == rowCount))
                    {
                        JObject joIn = new JObject();
                        joIn.Add(new JProperty("params", jaTmp));
                        joIn.Add("code", "09010035");
                        InvokeHelper invoker = new InvokeHelper();
                        JObject joRtn = invoker.invokeInsuService(joIn.ToString(), "更新医保目录");

                        // 更新对照关系表返回的数据
                        if (JsonHelper.parseIrisRtnValue(joRtn, out err) != 0)
                        {
                            iFalse++;
                            errMsg = errMsg + "\r\n" + err;
                        }
                        jaTmp = new JArray();
                    }
                }

            }

            if (iFalse == 0)
            {
                errMsg = "全部导入";
            }
            else
            {
                errMsg = "导入有错误，请检查日志";
            }
            return iFalse;
        }
    }

    public class OutParamWrapper
    {
        public string Value { get; set; }
    }

}