MedicalInsurance/Business/Inpatient/IPModifyRegistionProcess.cs

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using PTMedicalInsurance.Common;
using PTMedicalInsurance.Forms;
using PTMedicalInsurance.Helper;
using PTMedicalInsurance.Variables;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace PTMedicalInsurance.Business
{
    class IPModifyRegistionProcess : AbstractProcess
    {
        InpatientRegistration frmReg = new InpatientRegistration() ;
        JObject joHisRtnInfo;

        public override CallResult Process(JObject input)
        {
            JObject joReg = new JObject();
            //显示登记面板
            if (ShowForm(out joReg) == 0)
            {
                //上传给中心
                JObject joRegOut = invoker.invokeCenterService(TradeEnum.InpatientInfoChange, joReg);
                //将中心返回的结果返回HIS,调用HIS服务进行保存
                if (JsonHelper.parseCenterRtnValue(joRegOut, out errMsg) == 0)
                {
                    // 基线版扩展
                    joRegOut.Extend("validflag", 1);
                    joRegOut.Extend("regstate", 1);
                    joRegOut.Extend("type", 1);
                    joRegOut.Extend("ExpContent", "");

                    ////更新患者本次就诊用的参保信息，如果不读卡不用插入
                    //if (hBus.insertPatCurInsuInfo(patInfo, out outParam) != 0)
                    //{
                    //    if (DialogResult.Yes == MessageBox.Show(outParam, " 是否继续？ ", MessageBoxButtons.YesNo))
                    //    {

                    //    }
                    //    else
                    //    {
                    //        return Exception("插入患者本次就诊用的参保信息，请联系管理员！", outParam);
                    //    }
                    //}

                    // 保存时需要公共参数
                   
                    JObject joRegInput = JObject.Parse(JsonHelper.setCenterInpar("", joReg));

                    //更新医保平台
                    if (mIS.UpdateInpatRegisterInfo(joRegInput, out outParam) != 0)
                    {
                        return Exception("云平台保存登记信息", outParam);
                    }

                    JObject joTmp = new JObject();
                    joTmp.Add("mdtrtinfo", joReg["adminfo"]);
                    //返回登记信息，插入HIS
                    if (hIS.returnRegisterInfo(JObject.Parse(JsonHelper.setCenterInpar("2401", joTmp)), joRegOut, out outParam) != 0)
                    {
                        return Exception("HIS平台保存登记信息", outParam);
                    }

                    return IrisReturn("登记修改成功", null);
                }
                else
                {
                    return Exception("展示登记界面", errMsg);
                }
            }
            else
            {
                return Exception("展示登记界面", joReg.ToString());
            }
        }

        private int LoadInsuInfoToUI(out string err)
        {
            JObject joPatInfo = new JObject();
            JObject joOutput = new JObject();
            JObject joBaseInfo = new JObject();

            if (mIS.QueryPatCurInsuInfo(out err) != 0)
            {
                return -1;
            }
            else
            {
                JToken jt = JToken.Parse(JsonHelper.getDestValue(JObject.Parse(err), "result.data"));
                if (jt is JArray)
                {
                    if ((jt as JArray).Count != 1)
                    {
                        err = "查询到登记信息条数不为1！请联系管理员！";
                        return -1;
                    }
                    JObject joRtn = (JObject)(jt as JArray)[0];
                    joBaseInfo.Add("psn_name", JsonHelper.getDestValue(joRtn, "PatientName"));
                    joBaseInfo.Add("psn_no", JsonHelper.getDestValue(joRtn, "PersonalNO"));
                    joBaseInfo.Add("gend", JsonHelper.getDestValue(joRtn, "InsuType"));
                    joBaseInfo.Add("brdy", JsonHelper.getDestValue(joRtn, "Brdy"));
                    
                    joBaseInfo.Add("age", JsonHelper.getDestValue(joRtn, "Age"));
                   
                }
                else
                {
                    err = "返回的信息不是数组！请联系管理员！";
                    return -1;
                }
            }

            if (mIS.queryRegisterInfo(1, out err) != 0)
            {
                return -1;
            }
            else
            {
                //组织本次获得的相关信息
                JObject joRtn = JObject.Parse(JsonHelper.getDestValue(JObject.Parse(err),"data"));
                joBaseInfo.Add("psn_cert_type", JsonHelper.getDestValue(joRtn, "CertificateType"));
                joBaseInfo.Add("certno", JsonHelper.getDestValue(joRtn, "CertificateNO"));

                Global.pat.psn_no = JsonHelper.getDestValue(joRtn, "PersonalNO");
                Global.pat.mdtrtcertType = JsonHelper.getDestValue(joRtn, "CertificateType");
                Global.pat.certNO = JsonHelper.getDestValue(joRtn, "CertificateNO");
                Global.pat.insuplc_admdvs = JsonHelper.getDestValue(joRtn, "InsuranceAreaCode");
                Global.pat.insuType = JsonHelper.getDestValue(joRtn, "Insutype");
                Global.pat.name = JsonHelper.getDestValue(joRtn, "PatientName");
                Global.pat.mdtrtcertType = JsonHelper.getDestValue(joRtn, "CertificateType");
                Global.pat.mdtrtcertNO = JsonHelper.getDestValue(joRtn, "CertificateNO");

                joPatInfo.Add("baseinfo", joBaseInfo);
                joPatInfo.Add("insuinfo", new JArray());
                joOutput.Add("output", joPatInfo);
                Global.pat.insuType = JsonHelper.getDestValue(joRtn, "InsuType");
                Global.pat.medType = JsonHelper.getDestValue(joRtn, "MedicalType");
                Global.pat.DiseasecCode = JsonHelper.getDestValue(joRtn, "DiseasecCode");

                DataTable dt = (DataTable)frmReg.dblkcbxInsuranceType.DataSource;
                // 设置默认值（险种类别）
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    if (dt.Rows[i]["Code"].ToString() == Global.pat.insuType)
                    {
                        frmReg.dblkcbxInsuranceType.Text = dt.Rows[i]["Name"].ToString();
                        frmReg.insuType = dt.Rows[i]["Code"].ToString();
                        break;
                    }
                }
                // 设置默认值（医疗类别）
                DataTable dtMedType = (DataTable)frmReg.dblkcbxMedicalType.DataSource;
                for (int i = 0; i < dtMedType.Rows.Count; i++)
                {
                    if (dtMedType.Rows[i]["Code"].ToString() == Global.pat.medType)
                    {
                        frmReg.dblkcbxMedicalType.Text = dtMedType.Rows[i]["Name"].ToString();
                        frmReg.med_type = dtMedType.Rows[i]["Code"].ToString();
                        break;
                    }
                }

                //
                // 设置默认值（病种）
                DataTable dtDisease = (DataTable)frmReg.dblkcbxDisease.DataSource;
                for (int i = 0; i < dtDisease.Rows.Count; i++)
                {
                    if (dtDisease.Rows[i]["Code"].ToString() == Global.pat.DiseasecCode)
                    {
                        frmReg.dblkcbxDisease.Text = dtDisease.Rows[i]["Name"].ToString();
                        frmReg.diseCodg = dtDisease.Rows[i]["Code"].ToString();
                        break;
                    }
                }
                frmReg.initBaseInfo(joOutput);
                return 0;
            }
            
            frmReg.initBaseInfo(joOutput);
            return 0;
        }

        /// <summary>
        /// 显示住院患者登记面板，返回登记入参
        /// </summary>
        /// <param name="regInfo"></param>
        /// <returns></returns>
        private int ShowForm( out JObject jo)
        {

            if (LoadInsuInfoToUI(out errMsg) != 0)
            {
                jo = JsonHelper.setExceptionJson(-1, "", errMsg);
                return -1;
            }

            if (LoadDiagnose(out errMsg) != 0)
            {
                jo = JsonHelper.setExceptionJson(-1,"",errMsg);
                return -1;
            }
            LoadTypeInfo();
            if (GetRegisterInparam(out errMsg) != 0)
            {
                jo = JsonHelper.setExceptionJson(-1, "", errMsg);
                return -1;
            }
            else
            {
                jo = JObject.Parse(errMsg);
                return 0;
            }
        }

        private int LoadDiagnose(out string err)
        {
            //调用服务获取门诊诊断信息
            string diagnoses;
            if (hIS.getPatDiagnoses(Global.pat, out err) != 0)
            {
                return -1;
            }
            JObject joRtn = JObject.Parse(err);
            joHisRtnInfo = JObject.Parse(err);
            DataTable dtDiagnoses = JsonConvert.DeserializeObject<DataTable>(JsonHelper.getDestValue(joRtn, "diseinfo"));
            // 添加新列 diag_type_name
            if (!dtDiagnoses.Columns.Contains("diag_type_name"))
            {
                dtDiagnoses.Columns.Add("diag_type_name", typeof(string));
            }

            // 定义诊断类型映射关系
            Dictionary<string, string> diagTypeNameMap = new Dictionary<string, string>
            {
                { "1", "西医主要诊断" },
                { "2", "西医其他诊断" },
                { "3", "中医主病诊断" },
                { "4", "中医主证诊断" }
            };

            // 设置 diag_type_name
            foreach (DataRow row in dtDiagnoses.Rows)
            {
                // 从 DataRow 获取 diag_type 字段的值，并转为字符串
                string diagType = row["diag_type"]?.ToString();

                // 使用 TryGetValue 来获取对应的中文名称
                string typeName;
                if (diagTypeNameMap.TryGetValue(diagType, out typeName))
                {
                    row["diag_type_name"] = typeName;
                }
                else
                {
                    row["diag_type_name"] = "未知类型";
                }
            }

            // 使用 LINQ 查询
            var query = dtDiagnoses.AsEnumerable();
            var selectRows = query
                .Where(r => r["diaTypeCode"].ToString() == "ADD");
            // 
            DataTable dtInPatDiagnoses = selectRows != null && selectRows.Any()
            ? selectRows.CopyToDataTable()
            : null;

            selectRows = query
                .Where(r => r["diaTypeCode"].ToString() == "OPD" || r["diaTypeCode"].ToString() == "PRE");

            DataTable dtOutPatDiagnoses = selectRows != null && selectRows.Any()
            ? selectRows.CopyToDataTable()
            : null;

            if ((dtInPatDiagnoses != null) &&(dtInPatDiagnoses.Rows.Count > 0))
            {
                frmReg.DtDiagnose = dtInPatDiagnoses;
            }
            else if ((dtOutPatDiagnoses != null) && (dtOutPatDiagnoses.Rows.Count > 0))
            {
                frmReg.DtDiagnose = dtOutPatDiagnoses;
            }
            else
            {
                err = "未检测到诊断！";
                return -1;
            }
            return 0;
        }

        private void LoadTypeInfo()
        {
            string code = "";

            FetchDefault(frmReg.dblkcbxInsuranceType,Global.pat.insuType,out code);
            frmReg.insuType = code;

            //结算方式
            FetchDefault(frmReg.dblkcbxSettelmentWay,"01", out code);
            frmReg.psn_setlway = code;

            //（离院）方式
            FetchDefault(frmReg.dblkcbxExitway, "1", out code);
            frmReg.iptTypeCode = code;

            // 设置默认值（医疗类别）
            FetchDefault(frmReg.dblkcbxMedicalType, Global.pat.medType, out code);
            frmReg.med_type = code;
        }

        private void FetchDefault(PTControl.DBLookupCombox dblkcbx,string defaultCode,out string code)
        {
            code = "";
            DataTable dt = (DataTable)dblkcbx.DataSource;
            DataRow selectedRow = dt.AsEnumerable()
                .FirstOrDefault(row => row.Field<string>("Code") == defaultCode);

            if (selectedRow != null)
            {
                dblkcbx.Text = selectedRow.Field<string>("Name");
                code = selectedRow.Field<string>("Code");
            }
        }

        private int GetRegisterInparam(out string err)
        {
            if (tools.ShowAppDiaglog(frmReg) == DialogResult.OK)
            {
                JObject ExportObj = new JObject();
                ExportObj.Add("local_dise", frmReg.local_dise_code);  //本地病种编码
                ExportObj.Add("sin_dise_codg", "");              //单病种编码
                ExportObj.Add("cla_trt_flag", frmReg.claTrtFlag);       //分级诊疗标志
                ExportObj.Add("unif_pay_std_typ", frmReg.unifPayStdType);           //包干标准类型
                ExportObj.Add("bydise_setl_disediag_codg", "");  //按病种付费疾病诊断代码
                ExportObj.Add("bydise_setl_oprn_oprt_code", ""); //按病种付费手册操作代码
                ExportObj.Add("trum_flag", frmReg.traumaFlag);          //外伤标志
                ExportObj.Add("medcasno", "");                   //病案号
                ExportObj.Add("ipt_type", frmReg.iptTypeCode);          //住院类型
                ExportObj.Add("rel_ttp_flag", frmReg.relTtpFlag);       //涉及第三方标志
                ExportObj.Add("mdtrt_grp_type", frmReg.mdtrtGrpType);   //就诊人群类型
                ExportObj.Add("iden_crit_falg", frmReg.dangerFlag);
                ExportObj.Add("setl_way", frmReg.psn_setlway);  //结算方式
                                                                // 合并已有内容
                if (!string.IsNullOrEmpty(Global.pat.ExpContent))
                {
                    try
                    {
                        JObject jo = JObject.Parse(Global.pat.ExpContent);
                        ExportObj.Merge(jo, new JsonMergeSettings
                        {
                            MergeArrayHandling = MergeArrayHandling.Union
                        });
                    }
                    catch
                    {
                        Global.writeLog("转换失败:ExpContent内容不是JSON格式:" + Global.pat.ExpContent);
                    }

                }

                Global.pat.ExpContent = ExportObj.ToString();

                JObject joMdtrtinfo = new JObject();
                joMdtrtinfo.Add("mdtrt_id",Global.pat.mdtrtID);          // 就诊ID
                joMdtrtinfo.Add("psn_no", Global.pat.psn_no);             // 人员编号
                joMdtrtinfo.Add("coner_name", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.coner_name"));                   // 联系人姓名
                joMdtrtinfo.Add("tel", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.tel"));                    // 联系电话
                joMdtrtinfo.Add("begntime", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.begntime"));      // 开始时间
                joMdtrtinfo.Add("endtime", "");       // 结束时间
                joMdtrtinfo.Add("mdtrt_cert_type", Global.pat.mdtrtcertType);                // 就诊凭证类型（如：医保卡）
                joMdtrtinfo.Add("med_type", frmReg.med_type);                       // 医疗类别（如：门诊手术）
                joMdtrtinfo.Add("ipt_otp_no", Global.pat.adm_Dr.ToString());          //住院/门诊号
                joMdtrtinfo.Add("medrcdno", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.medrcdno"));          //病历号
                joMdtrtinfo.Add("atddr_no", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.atddr_no"));          //主治医生编码
                joMdtrtinfo.Add("chfpdr_name", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.chfpdr_name"));          //主诊医师姓名
                joMdtrtinfo.Add("insutype", frmReg.insuType);

                string mainDiagName = JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.dscg_maindiag_name");
                string admDiagDescripts = JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.adm_diag_dscr");
                if (string.IsNullOrEmpty(admDiagDescripts))
                {
                    admDiagDescripts = mainDiagName;
                }


                joMdtrtinfo.Add("adm_diag_dscr", admDiagDescripts);          //入院诊断描述
                joMdtrtinfo.Add("adm_dept_codg", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.adm_dept_codg"));          //入院科室编码
                joMdtrtinfo.Add("adm_dept_name", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.adm_dept_name"));          //入院科室名称
                joMdtrtinfo.Add("adm_bed", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.adm_bed"));          //入院床位
                joMdtrtinfo.Add("dscg_maindiag_code", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.dscg_maindiag_code"));          //住院主诊断代码
                joMdtrtinfo.Add("dscg_maindiag_name", mainDiagName);          //住院主诊断名称
                joMdtrtinfo.Add("main_cond_dscr", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.main_cond_dscr"));          //主要病情描述

                joMdtrtinfo.Add("dise_codg", (frmReg.diseCodg == "\u0000") ? "" : frmReg.diseCodg);          //病种编码
                joMdtrtinfo.Add("dise_name", (frmReg.diseName == "\u0000") ? "" : frmReg.diseName);          //病种名称
                joMdtrtinfo.Add("oprn_oprt_code", frmReg.oprn_oprt_code ?? "");          //手术操作代码
                joMdtrtinfo.Add("oprn_oprt_name", frmReg.oprn_oprt_name ?? "");          //手术操作名称
                joMdtrtinfo.Add("fpsc_no", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.fpsc_no"));          //计划生育服务证号
                joMdtrtinfo.Add("matn_type", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.matn_type"));          //生育类别
                joMdtrtinfo.Add("birctrl_type", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.birctrl_type"));          //计划生育手术类别
                joMdtrtinfo.Add("latechb_flag", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.latechb_flag"));          //晚育标志
                joMdtrtinfo.Add("geso_val", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.geso_val"));          //孕周数
                joMdtrtinfo.Add("fetts", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.fetts"));          //胎次
                joMdtrtinfo.Add("fetus_cnt", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.fetus_cnt"));          //胎儿数
                joMdtrtinfo.Add("pret_flag", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.pret_flag"));          //早产标志
                joMdtrtinfo.Add("birctrl_matn_date", "");          //计划生育手术或生育日期 JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.birctrl_matn_date") 20230228医保中心校验传正确时间或空
                joMdtrtinfo.Add("dise_type_code", JsonHelper.getDestValue(joHisRtnInfo, "mdtrtinfo.dise_type_code"));          //病种类型
                joMdtrtinfo.Add("exp_content", ExportObj);          //字段扩展
                joMdtrtinfo.Add("ttp_pay_prop", "");                 // 第三方自付比例（例如20%）

                JObject joReg = new JObject();
                joReg.Add("adminfo", joMdtrtinfo);
                JArray jaDiseInfo = JArray.Parse(JsonConvert.SerializeObject(frmReg.DtDiagnose));
                foreach (JObject jo in jaDiseInfo)
                {
                    jo.Add("mdtrt_id", Global.pat.mdtrtID);
                }
                joReg.Add("diseinfo", jaDiseInfo);
                err = joReg.ToString();
                return 0;
            }
            else
            {
                err = "收费员取消操作！";
                return -1;
            }           
        }
    }
}