MedicalInsurance/Business/Local/LocalMedDirDownloadProcess.cs

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

namespace PTMedicalInsurance.Business
{
    class LocalMedDirDownloadProcess : AbstractProcess
    {
        int maxNo = 0;
        /// <summary>
        /// 药品、诊疗目录
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public override CallResult Process(JObject input)
        {
            // sbjgbh传需要查询的社保局编号,济南医疗传370100（或37010101），工伤传37019L（或37019L01）省医保37000000
            if(!string.IsNullOrEmpty(input["ver"].Text()))
            {
                maxNo = int.Parse(input["ver"].Text());
            }
            bool hasMore = true;

            while (hasMore)
            {
                //核心目录
                //var ret = FetchDirectory(TradeEnum.DirectoryDownload, "ylxm_ds", "sxzfbl_ds", "xj_ds");
                //医院项目
                //var ret = FetchDirectory(TradeEnum.DirectoryDownload, "yyxm_ds", "", "xj_ds");
                var ret = FetchDirectory(TradeEnum.DirectoryDownloadExt, "yyxm_ds", "", "xj_ds");
                hasMore = ret.hasMore;

                updateDirectory(ret.data);

                updateLimitPrice(ret.limitData);
                // 多自费项目
                updateSelfPercent(ret.percentData);
            }

            return IrisReturn("更新成功!", null);
        }

        
        private void updateDirectory(JArray data)
        {
            List<HBMedInsuDirectory> list = new List<HBMedInsuDirectory>();
            try
            {
                foreach (var dir in data)
                {
                    HBMedInsuDirectory obj = ConvertToEntity((JObject)dir);
                    list.Add(obj);
                }
                // 保存
                saveToServer(list);
            }
            catch (Exception ex)
            {

            }
        }

        private JObject saveToServer(List<HBMedInsuDirectory> data)
        {
            JObject joIn = new JObject();
            JObject joRtn = new JObject();
            string outParam = "";
            try
            {

                joIn.Add("params", JArray.Parse(JsonHelper.toJsonString(data)));
                joIn.Add("code", "09010035");
                joIn.Add("updateUserID", Global.user.ID);
                InvokeHelper invoker = new InvokeHelper();
                string sInput = joIn.ToString();
                joRtn = invoker.invokeInsuService(sInput, "applyDataToIris");
                outParam = joRtn.ToString();
                return joRtn;
            }
            catch (Exception ex)
            {
                joRtn = JsonHelper.setExceptionJson(-1, "applyDataToIris", ex.Message);
                outParam = joRtn.ToString();
                return joRtn;
            }
        }

        private (bool hasMore, JArray data, JArray percentData, JArray limitData) FetchDirectory(TradeEnum trade, string dsName)
        {
            return FetchDirectory(trade,dsName,null,null);
        }

        private (bool hasMore, JArray data,JArray percentData,JArray limitData) FetchDirectory(TradeEnum trade, string dsName,string percentName,string limitName)
        {
            JObject joInput = new JObject();
            joInput["p_sxh"] = maxNo.ToString(); //全量下载0,后面传最大
            Global.pat.insuplc_admdvs = "370100";
            JObject joRtn = invoker.invokeCenterService(trade, joInput);
            if ("0".Equals(JsonHelper.getDestValue(joRtn, "resultcode")))
            {
                // 是否还有数据
                bool hasMore = "1".Equals(JsonHelper.getDestValue(joRtn, "sfjxxz"));
                JArray data = JArray.Parse(JsonHelper.getDestValue(joRtn, dsName));
                JArray percent = new JArray();
                if (!string.IsNullOrEmpty(percentName))
                {
                    percent = JArray.Parse(JsonHelper.getDestValue(joRtn, percentName));
                }
                else {
                    //自付比例在项目中
                    foreach (var item in data)
                    {
                        if (!string.IsNullOrEmpty(item["zfbl"].Text()))
                        {
                            dynamic percentObj = new JObject();
                            percentObj.ylxmbm = item["gbxmbm"].Text();
                            percentObj.rqlb = item["rqlb"].Text();
                            percentObj.yltclb = item["yltclb"].Text();
                            percentObj.sm = item["sm"].Text();
                            percentObj.qsrq = item["qsrq"].Text();
                            percentObj.zzrq = item["zzrq"].Text();
                            percentObj.xzbz = item["xzbz"].Text();
                            percentObj.sxzfbl = item["zfbl"].Text();
                            percent.Add(percentObj);
                        }
                    }
                }
                JArray limit = new JArray();
                if (!string.IsNullOrEmpty(limitName))
                {
                    limit = JArray.Parse(JsonHelper.getDestValue(joRtn, limitName));
                }
                return (hasMore, data, percent, limit);
            }
            else
            { 
                MessageBox.Show(JsonHelper.getDestValue(joRtn, "err_msg"));
            }

            return (false, new JArray(), new JArray(), new JArray());
        }

        public CallResult DownloadSelfpay(JObject input)
        {

            string code = input["code"].Text();

            //if (!string.IsNullOrEmpty(code))
            //{
                dynamic joInput = new JObject();
                joInput.p_yyxmbm = code;
                joInput.p_rq = "";
                //单个更新比例
                Global.pat.insuplc_admdvs = "370100";
                JObject joRtn = invoker.invokeCenterService(TradeEnum.SelfPayPercent, joInput);
                if ("0".Equals(JsonHelper.getDestValue(joRtn, "resultcode")))
                {
                    JArray percent = new JArray();
                    JArray data = JArray.Parse(JsonHelper.getDestValue(joRtn, "zfbl_ds"));
                    foreach (var item in data)
                    {
                        if (!string.IsNullOrEmpty(item["zfbl"].Text()))
                        {
                            dynamic percentObj = new JObject();
                            percentObj.ylxmbm = code;
                            percentObj.rqlb = item["rqlb"].Text();
                            percentObj.yltclb = "6";
                            percentObj.sm = item["sm"].Text();
                            percentObj.sxzfbl = item["zfbl"].Text();
                            percent.Add(percentObj);
                        }
                    }
                    updateSelfPercent(percent);
                }
            //}

            return Success();

        }

            /// <summary>
            /// 诊断目录下载
            /// </summary>
            /// <param name="input"></param>
            /// <returns></returns>
            public CallResult DownloadDiagnosis(JObject input)
        {
            //sbjgbh传需要查询的社保局编号,济南医疗传370100（或37010101），工伤传37019L（或37019L01）
            if (!string.IsNullOrEmpty(input["ver"].Text()))
            {
                maxNo = int.Parse(input["ver"].Text());
            }
            bool hasMore = true;
            while (hasMore)
            {
                var ret = FetchDirectory(TradeEnum.DirectoryDownloadCore, "ybjb_ds");
                hasMore = ret.hasMore;
                List<HBMedInsuDirectory> list = new List<HBMedInsuDirectory>();
                foreach (var d in ret.data)
                {
                    list.Add(NewDiagnosis((JObject)d));
                }
                saveToServer(list);
            }
            return IrisReturn("下载成功",null);
        }

        /// <summary>
        /// 科室查询
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public CallResult QueryDepartment()
        {
            JObject joInput = new JObject();
            joInput["p_ksbm"] = ""; //全量下载
            Global.pat.insuplc_admdvs = "370100";
            JObject joRtn = invoker.invokeCenterService(TradeEnum.DepartmentQuery, joInput);
            if ("0".Equals(JsonHelper.getDestValue(joRtn, "resultcode")))
            {
                // 是否还有数据
                outParam = JsonHelper.getDestValue(joRtn, "dept_ds");
            }
            return Success();
        }
        private HBMedInsuDirectory NewDiagnosis(JObject obj)
        {
            HBMedInsuDirectory jsonTemp = new HBMedInsuDirectory();
            jsonTemp.updateUserID = Global.user.ID;
            jsonTemp.HospitalDr = Global.inf.hospitalDr;
            jsonTemp.InterfaceDr = Global.inf.interfaceDr;
            jsonTemp.Code = obj["jbbm"].Text();
            jsonTemp.Name = obj["jbmc"].Text();
            jsonTemp.HisType = "4";
            jsonTemp.HisTypeName = "诊断";
            jsonTemp.ValidFlag = "1".Equals(obj["zxbz"].Text()) ? 0 : 1;
            jsonTemp.Note = obj["bz"].Text();
            jsonTemp.PinyinSearchCode = obj["py"].Text();
            jsonTemp.DrugSafetyStandardCode = "";
            return jsonTemp;
        }

        private HBMedInsuDirectory ConvertToEntity(JObject obj)
        {
            string hisType = obj["ypbz"].Text() ?? "2";
            string hisTypeName = hisType.Equals("1") ? "药品" : "诊疗";             HBMedInsuDirectory insu = new HBMedInsuDirectory();

            maxNo = Math.Max(maxNo, int.Parse(obj["sxh"].ToString()));
            insu.ID = "";
            insu.updateUserID = Global.user.ID;
            insu.HospitalDr = Global.inf.hospitalDr;
            insu.InterfaceDr = Global.inf.interfaceDr;
            insu.Code = obj["ylxmbm"].Text();
            insu.Name = obj["ylxmbzmc"].Text();
            insu.NationalCode = obj["gbxmbm"].Text();
            insu.NationalName = obj["gbxmmc"].Text();
            insu.HisType = hisType;
            insu.HisTypeName = hisTypeName;
            insu.LocateCode = obj["pms_id"].Text();
            insu.LocateName = obj["pms_name"].Text();
            insu.DosageFormCode = obj["jxm"].Text();
            insu.DosageFormName = obj["jxm"].Text();
            insu.CategoryCode = obj["listtype"].Text();
            insu.CategoryName = "";
            // 规格
            insu.Specification = obj["bzgg"].Text();
            insu.SpecificationCode = obj["gg"].Text();
            insu.UnitOfPackag = obj["dw"].Text();
            insu.UnitOfValuation = obj["ms_charge_unit"].Text();
            //insu.StartDate = obj["qsrq"].Text();
            //insu.EndDate = obj["zzrq"].Text();
            insu.PinyinSearchCode = obj["py"].Text();
            insu.Instructions = obj["ms_explain"].Text();
            insu.ExceptContent = obj["cwnr"].Text();
            insu.Connotation = obj["xmnh"].Text();    
            insu.ValidFlag = obj["spbz"].Int();
            insu.Note = "";
            insu.VersionNO = obj["sxh"].Text();
            insu.VersionName = obj["sxh"].Text();
            string cancelFlag = obj["zxbz"].Text();
            insu.UseFlag = "1".Equals(cancelFlag)?0:1;
            insu.DrugSafetyStandardCode = obj["ypbwm"].Text();
            insu.ApprovalNO = obj["bzwh"].Text(); ;
            //insu.SpecialFlag = obj[""].Int();
            //insu.LimitFlag = obj[""].Int();
            //insu.LimitRange = obj[""].Text();
            insu.UniqueRecordNO = obj["sxh"].Text();
            insu.Manufacturers = obj["scqy"].Text();
            insu.SelfPercent = obj["zfbl"].Text(); 
            insu.ChargeItemLevelName = obj["mldj"].Text();
            insu.MinPackagingQuantity = obj["zxbzsl"].Text();
            insu.MinPackagingUnit = obj["gjjzxbzdw"].Text();

            insu.UpdateTime = obj["gxsj"].Text();

            if (insu.SelfPercent == "0")
            {
                insu.ChargeItemLevel = "01";
                insu.ChargeItemLevelName = "甲";
            }
            else if (insu.ChargeItemLevelName == "1")
            {
                insu.ChargeItemLevel = "03";
                insu.ChargeItemLevelName = "丙";
            }
            else
            {
                insu.ChargeItemLevel = "02";
                insu.ChargeItemLevelName = "乙";
            }

            return insu;
        }

        private int updateLimitPrice(JArray data)
        {
            if (data?.Count < 1) return 0;
            string errMsg = "";
            JArray joArray = new JArray();

            try
            {
                foreach (var dir in data)
                {
                    dynamic joTmp = new JObject();
                    joTmp.HospitalDr = Global.inf.hospitalDr;
                    joTmp.InterfaceDr = Global.inf.interfaceDr;
                    joTmp.updateUserID = Global.user.ID;
                    joTmp.Code = dir["ylxmbm"].Text();

                    joTmp.PersonnelType = dir["rqlb"].Text();  //人群类别
                    joTmp.LimitType = dir["yltclb"].Text();     //限价类型（统筹类别）
                    joTmp.BeginDate = Utils.ConvertShortDate(dir["qsrq"].Text());
                    joTmp.EndDate = Utils.ConvertShortDate(dir["zzrq"].Text());
                    joTmp.UpLimitAmount = dir["xj"].Text(); //限价
                    joArray.Add(joTmp);
                }
                JObject joRtn = invoker.invokeInsuService(JsonHelper.setIrisInpar("09010084", joArray).ToString(), "更新限价信息");

                if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                {
                    return -1;
                }
                else
                {
                    outParam = joRtn.ToString();
                    return 0;
                }
            }
            catch (Exception ex)
            {
                outParam = "更新项目自费比例：" + ex.Message;
                return -1;
            }
        }

        /// <summary>
        /// 如果存在同一个目录多个比例，则保存在比例扩展表
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        private int updateSelfPercent(JArray data)
        {
            if (data?.Count < 1) return 0;
            string errMsg = "";
            JArray joArray = new JArray();
            
            try
            {
                foreach (var dir in data)
                {
                    dynamic joTmp = new JObject();
                    joTmp.HospitalDr = Global.inf.hospitalDr;
                    joTmp.InterfaceDr = Global.inf.interfaceDr;
                    joTmp.updateUserID = Global.user.ID;
                    joTmp.Code = dir["ylxmbm"].Text();
                    string personType = dir["rqlb"].Text(); //人群类别
                    if (string.IsNullOrEmpty(personType))
                    {
                        personType = "A"; //职工
                    }
                    joTmp.PersonnelType = personType;
                    string proportionType = dir["yltclb"].Text(); //自费类型（统筹类别）
                    if (string.IsNullOrEmpty(proportionType))
                    {
                        proportionType = "6"; //普通门诊
                    }
                    joTmp.ProportionType = proportionType;
                    joTmp.BeginDate = Utils.ConvertShortDate(dir["qsrq"].Text());
                    joTmp.EndDate = Utils.ConvertShortDate(dir["zzrq"].Text());
                    joTmp.Proportion = dir["sxzfbl"].Text();
                    joArray.Add(joTmp);
                 }
                JObject joRtn = invoker.invokeInsuService(JsonHelper.setIrisInpar("09010085", joArray).ToString(), "更新项目自费比例");

                if (JsonHelper.parseIrisRtnValue(joRtn, out errMsg) != 0)
                {
                    return -1;
                }
                else
                {
                    outParam = joRtn.ToString();
                    return 0;
                }
            }
            catch (Exception ex)
            {
                outParam = "更新项目自费比例：" + ex.Message;
                return -1;
            }
        }
    }
}