ZLPlugin_LisPacs_MR_NEW/ZLPlugin_LisPacs_MR/LisPacs_MR_Bll.cs

using ADODB;
using System;
using System.Collections.Generic;
using ZLPlugin_LisPacs_MR.Domain.Units;
using ZLPlugin_LisPacs_MR.Model;
using static System.Windows.Forms.AxHost;

namespace ZLPlugin_LisPacs_MR
{
    public class LisPacs_MR_Bll
    {
        /// <summary>
        /// lis是否有互认项目
        /// </summary>
        /// <returns></returns>
        public static void IsLisProject(string zlid, out string code, out int total)
        {
            code = "";
            total = 0;
            string sql = @"Select to_char(Replace(wm_concat(distinct(l.医保编码)),',','#')) Code,Count(1) total
                                    From 诊疗项目目录 x,诊疗收费关系 y,收费项目目录 z,保险支付项目 m,ZLLPMR.互认项目清单 l
                                    Where y.诊疗项目id = x.Id 
                                    And z.Id = y.收费项目id 
                                    And m.收费细目id = z.Id 
                                    And l.医保通用编码 = m.项目编码 
                                    And m.险类 = 111
                                    and x.类别 = 'C'
                                    And x.Id = {0}";
            sql = string.Format(sql, zlid);
            Log.Info("sql1:" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();
                code = rd.Fields["CODE"].Value.ToString();
                total = int.Parse(rd.Fields["TOTAL"].Value.ToString());
            }

        }

        public static void IsPacsProject(string zlid, out int total,out string type)
        {
            total = 0;
            type = "";
            string sql = @"Select Count(1) As total,b.代码 code From 诊疗项目目录 a,ZLLPMR.字典对码表 b
                                  Where 分类 ='检查互认项目' 
                                  and a.类别 = 'D' And b.编码  = '{0}'
                                  group by b.代码";
            sql = string.Format(sql, zlid);
            Log.Info("sql2:" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();
                total = int.Parse(rd.Fields["TOTAL"].Value.ToString());
                type = rd.Fields["CODE"].Value.ToString();
            }

        }

        public static void HandleYzData(List<YZData> list,  long patientId,long limit_day ,out string message)
        {
            Log.Info("enter HandleYzData = "+ list.Count);
            message = "";
            //存在互认的医嘱
            int existHuRemYz = 0;
            for (var i = 0; i < list.Count; i++)
            {
                if (list[i].诊疗类别 == "C" && list[i].相关ID != "0.0")
                {
                    LisPacs_MR_Bll.GetHuRenYzData(patientId, list[i].诊疗项目ID, list[i].诊疗类别, limit_day,out  existHuRemYz);
                    if (existHuRemYz>=1)
                    {

                        message = list[i].医嘱内容;
                        //return message;
                    }

                }
                else if (list[i].诊疗类别 == "D" && list[i].相关ID == "0.0")
                {
                    LisPacs_MR_Bll.GetHuRenYzData(patientId, list[i].诊疗项目ID, list[i].诊疗类别, limit_day, out existHuRemYz);
                    if (existHuRemYz >= 1)
                    {

                        message = list[i].医嘱内容;
                        //return message;
                    }
                }
            }
            Log.Info("end HandleYzData = " + message);
            //return message;
        }
        /// <summary>
        /// 返回诊疗项目ID
        /// </summary>
        /// <param name="rsAdvice"></param>
        /// <returns></returns>
        public static void GetTreatmentId(List<YZData> list,out string codeNo,out List<Codes> listlis, out List<Codes> listPacs,out string billProjectNames)
        {
            codeNo = "";
            billProjectNames = "";
            listlis = new List<Codes>();
            listPacs = new List<Codes>();
            for (var i = 0; i < list.Count; i++)
            {
                if (list[i].诊疗类别 == "C" && list[i].相关ID != "0.0")
                {
                    string code = "";
                    int total = 0;
                    IsLisProject(list[i].诊疗项目ID, out code, out total);
                    if (total > 0)
                    {
                        Codes codes = new Codes();
                        codes.id = list[i].相关ID;  //原先是 取id 不行 
                        codes.code = code;
                        codes.yzid = list[i].ID;
                        codes.zlxmid = list[i].诊疗项目ID;
                        codes.yzContent = list[i].医嘱内容;
                        codes.doctorName = list[i].开嘱医生;
                        listlis.Add(codes);
                        //lis += list[i].诊疗项目ID + ",";
                        //lis_id += list[i].ID + ",";
                        codeNo += code + "#";
                        billProjectNames += list[i].医嘱内容 + "、";
                    }

                }
                else if (list[i].诊疗类别 == "D" && list[i].相关ID != "0.0")
                {
                    //pacs = list[i].诊疗项目ID + ",";
                    //pacs_id = list[i].ID + ",";
                    int total = 0;
                    string type = "";
                    //IsPacsProject(list[i].诊疗项目ID, out total, out  type);
                    String param = list[i].诊疗项目ID + "_" + list[i].标本部位 + "_" + list[i].检查方法;
                    IsPacsProject(param, out total, out  type);
                    if (total >0)
                    {
                        Codes codes = new Codes();
                        codes.id = list[i].相关ID;
                        codes.type = type;
                        codes.code = type;
                        codes.yzid = list[i].ID;
                        codes.zlxmid = list[i].诊疗项目ID;
                        codes.zxksid = list[i].执行科室ID;
                        codes.part = list[i].标本部位;
                        codes.method = list[i].检查方法;
                        codes.yzContent = list[i].医嘱内容 + "_" + list[i].标本部位 + "_" + list[i].检查方法;
                        codes.doctorName = list[i].开嘱医生;
                        listPacs.Add(codes);
                        codeNo += type + "#";
                        billProjectNames += list[i].医嘱内容 + "_" + list[i].标本部位 + "_" + list[i].检查方法 + "、";
                    }

                }
            }
            //lis = lis.Length > 0 ? lis.Substring(0, lis.Length - 1) : lis;
            codeNo = codeNo.Length > 0 ? codeNo.Substring(0, codeNo.Length - 1) : codeNo;
            billProjectNames = billProjectNames.Length > 0 ? billProjectNames.Substring(0, billProjectNames.Length - 1) : billProjectNames;
            //pacs = pacs.Length > 0 ? pacs.Substring(0, pacs.Length - 1) : pacs;
            //lis_id = lis_id.Length > 0 ? lis_id.Substring(0, lis_id.Length - 1) : lis_id;
            //pacs_id = pacs_id.Length > 0 ? pacs_id.Substring(0, pacs_id.Length - 1) : pacs_id;
        }
        /// <summary>
        /// 住院
        /// </summary>
        /// <param name="lngPatientID"></param>
        /// <param name="ZYID"></param>
        /// <param name="standardItemId"></param>
        /// <returns></returns>
        public static Recordset GetZYPostJson(long lngPatientID, long ZYID, string no,int type,string totalPrice, string xgid,string userName,string userCode)
        {
            string sql = @"select * from (Select distinct  a.姓名 ""PatientName"",
                                    b.身份证号 ""PatientIdCard"",
                                    e.机构编码 ""jzOrgCode"",
                                    e.机构名称 ""jzOrgName"",
                                    '{7}' ""jzDoctorCode"",
                                    '{6}' ""jzDoctorName"",
                                    d.编码 ""jzDeptCode"",
                                    d.名称 ""jzDeptName"",
                                    a.住院号 ""businessNumber"",
                                    '{2}' ""standardItemId"",
                                    '' ""reportStartTime"",
                                    '' ""reportEndTime"",
                                    '{3}' ""hrType"",
                                    TO_CHAR(SYSDATE, 'YYYY-MM-DD HH24:MI:SS') ""applyTime"",
                                    '{4}' ""hisApplyCode"",
                                    '2' ""patientType"",
                                     '{5}'   ""totalAmount""
                                    From 病案主页 a,病人信息 b,部门表 d,ZLLPMR.互认配置表 e
                                    Where b.病人id = a.病人id
                                    And d.Id = a.当前病区id
                                    And a.病人id = {0} And a.主页id = {1} ) ";
            sql = string.Format(sql, lngPatientID, ZYID, no,type, xgid, totalPrice, userName,userCode);
            Log.Info("GetZYPostJson==" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            return rd;
        }
        /// <summary>
        /// 门诊
        /// </summary>
        /// <param name="lngPatientID"></param>
        /// <param name="ZYID"></param>
        /// <param name="standardItemId"></param>
        /// <returns></returns>
        public static Recordset GetMZPostJson(long ZYID, string no,int type, string totalAmount, string xgId, string userName, string userCode)
        {
            string sql = @"Select distinct a.姓名 ""PatientName"",
                                    b.身份证号 ""PatientIdCard"",
                                    e.机构编码 ""jzOrgCode"",
                                    e.机构名称 ""jzOrgName"",
                                    '{6}' ""jzDoctorCode"",
                                    '{5}' ""jzDoctorName"",
                                    d.编码 ""jzDeptCode"",
                                    d.名称 ""jzDeptName"",
                                    a.门诊号 ""businessNumber"",
                                    '{1}' ""standardItemId"",
                                    '' ""reportStartTime"",
                                    '' ""reportEndTime"",
                                    '{2}' ""hrType"",
                                    TO_CHAR(SYSDATE, 'YYYY-MM-DD HH24:MI:SS') ""applyTime"",
                                    '{3}' ""hisApplyCode"",
                                    '1' ""patientType"",
                                    '{4}' ""totalAmount""
                                    From 病人挂号记录 a,病人信息 b, 人员表 c,部门表 d,ZLLPMR.互认配置表 e
                                    Where b.病人id = a.病人id
                                    And c.姓名 = a.执行人
                                    And d.Id = a.执行部门id
                                    And a.id = {0}";
            sql = string.Format(sql, ZYID, no,type, xgId, totalAmount, userName, userCode);
            Log.Info("GetMZPostJson==" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            return rd;
        }

        public static string GetMZTotalPrice(long lngPatientID, string YZID)
        {
            string sql = @"Select sum(a.实收金额) 金额 from 门诊费用记录 a,病人医嘱记录 b where a.医嘱序号 = b.id and b.病人id ={0} and b.id = {1}";
            sql = string.Format(sql, lngPatientID, YZID);
            Log.Info("GetMZTotalPrice==" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();
                return rd.Fields["金额"].Value.ToString();
            }
            return "";
        }


        public static decimal GetTotalPriceForLisByZLXM(string zlxmid)
        {
            string sql = @"Select nvl(sum(现价),'0') 金额 from 收费价目 where  终止日期 > sysdate  and 收费细目id in (select 收费项目id from 诊疗收费关系 where 诊疗项目id = {0} )";
            sql = string.Format(sql, zlxmid);
            Log.Info("GetTotalPriceForLisByZLXM==" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();
                decimal amount = Convert.ToDecimal(rd.Fields["金额"].Value.ToString());
                return amount;
            }
            return 0;
        }

        public static decimal GetTotalPriceForLisByZlxmIds(string zlxmids)
        {
            string sql = @"Select nvl(sum(现价),'0') 金额 from 收费价目 where  终止日期 > sysdate  and 收费细目id in (select 收费项目id from 诊疗收费关系 where 诊疗项目id in ({0}) )";
            sql = string.Format(sql, zlxmids);
            Log.Info("GetTotalPriceForLisByZLXM==" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();
                decimal amount = Convert.ToDecimal(rd.Fields["金额"].Value.ToString());
                return amount;
            }
            return 0;
        }


        //获取诊疗项目ids
        public static string GetZlxmIdFromList(List<Codes> list)
        {
            string zlxmids="";
            for (var i = 0; i < list.Count; i++)
            {
                zlxmids += list[i].zlxmid + ",";
            }
            zlxmids = zlxmids.Length > 0 ? zlxmids.Substring(0, zlxmids.Length - 1) : zlxmids;
            return zlxmids;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="zlxmid"> 诊疗项目id</param>
        /// <param name="zlksid"> 执行科室id</param>
        /// <param name="part"> 部位</param>
        /// <param name="method"> 方法</param>
        /// <param name="patientResource"> 病人来源   门诊  1  还是住院  2   0  这里区分 不等于1  或者不等于 2  所有</param>
        /// <returns></returns>
        public static decimal GetTotalPriceForPacsByZLXM(string zlxmid,string zlksid ,string part,string method, int patientResource)
        {
            string sql = @"select nvl(sum(a.现价* b.收费数量),'0') 金额 from 收费价目 a,(
                    select * from 诊疗收费关系  where 诊疗项目id = {0} and ( 适用科室id  is null or  适用科室id = {1} ）and 检查部位 = '{2}' and 检查方法 = '{3}'  and 病人来源 <> {4}
                    union all
                    select * from 诊疗收费关系  where 诊疗项目id = {0} and 固有对照 = 1 and 适用科室id = {1} and 病人来源 <> {4}
                    ) b where a.收费细目id = b.收费项目id and   a.终止日期 > sysdate ";
            sql = string.Format(sql, zlxmid,zlksid, part, method, patientResource);
            Log.Info("GetTotalPriceForPacsByZLXM==" + sql);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();

                decimal amount = Convert.ToDecimal(rd.Fields["金额"].Value.ToString());
                return amount;
            }
            return 0;
        }


        


        public static string GetZYTotalPrice(string zlxmid)
        {
            string sql = @"Select sum(现价) 金额 from 收费价目 where 收费细目id in (select 收费项目id from 诊疗收费关系 where 诊疗项目id = {0} )";
            sql = string.Format(sql, zlxmid);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();
                return rd.Fields["金额"].Value.ToString();
            }
            return "";
        }

        /// <summary>
        /// 判断之前是否开个互认医嘱
        /// </summary>
        /// <param name="patientId"></param>
        /// <param name="zlId"></param>
        /// <param name="zlType"></param>
        /// <param name="limitDay"></param>
        /// <param name="existHuRemYz"></param>
        public static void GetHuRenYzData( long patientId ,string zlId,string zlType, long limitDay,out int existHuRemYz)
        {
            Log.Info("GetHuRenYzData");
            existHuRemYz = 0;
            try
            {
                string sql = @"Select count(1)  count
                                    From 病人医嘱记录 where 病人id={0}  and  诊疗项目id = {1} and 诊疗类别 ='{2}' and 开嘱时间 > sysdate -{3} and 医嘱内容 like '%【互认】' ";
                sql = string.Format(sql, patientId, zlId, zlType, limitDay);
                Log.Info(sql);
                Recordset rd = new Recordset();
                Tools.QueryTable(sql, out rd);
                if (!rd.EOF)
                {
                    rd.MoveFirst();
                    existHuRemYz = int.Parse(rd.Fields["count"].Value.ToString());
                }
            }catch(Exception ex)
            {
                Log.Info("GetHuRenYzData Exception" + ex.Message);
                existHuRemYz = 0;
            }
        }


        /// <summary>
        /// 插入互认开单项目数据
        /// </summary>
        /// <param name="computerName"></param>
        /// <param name="lngPatientID"></param>
        /// <param name="billName"></param>
        /// <param name="lngSendID"></param>
        /// <param name="ip"></param>
        /// <param name="no"></param>
        /// <param name="yzID"></param>
        /// <param name="type"></param>
        /// <param name="operatorName"></param>
        /// <returns></returns>
        public static int InsertHuRenBillProject(string computerName, long lngPatientID, string billName,long lngSendID, string ip, string no, string yzXgID, string type, string operatorName,string patientSource)
        {
            string sql = @"Insert Into 互认开单项目(计算机名,患者id,开单项目,开单时间,发送号,计算机IP,单据号,相关id,类别,开单人,病人来源) 
                            Values('{0}','{1}','{2}',to_date('{3}','yyyy-mm-dd hh24:mi:ss'),{4},'{5}','{6}','{7}','{8}','{9}','{10}')";
            sql = string.Format(sql, computerName, lngPatientID, billName, DateTime.Now, lngSendID, ip, no, yzXgID, type, operatorName, patientSource);
            Log.Info("InsertLis:" + sql);
            int res = Tools.ExecuteSql(sql);
            return res;
        }

        public static int InsertLis(LISItem lis, long lngPatientID, long lngClinicID, string date, string no,long yzXgID)
        {
            string sql = @"Insert Into ZLLPMR.互认_LIS(LISCHECKREPORTID,REPORTNAME,ORGNAME,REPORTTIME,病人ID,主页ID,TIME,OPERATORNO,医嘱id) 
                            Values('{0}','{1}','{2}',to_date('{3}','yyyy/mm/dd hh24:mi:ss'),{4},{5},to_date('{6}','yyyy/mm/dd hh24:mi:ss'),'{7}',{8})";
            sql = string.Format(sql, lis.LisCheckReportId, lis.ReportName, lis.OrgName, lis.ReportTime, lngPatientID, lngClinicID, date, no, yzXgID);
            Log.Info("InsertLis:" + sql);
            int res = Tools.ExecuteSql(sql);
            return res;
        }



        public static void InsertLisItem(ItemListItem item, string id, long lngPatientID, long lngClinicID, string date)
        {
            string sql = @"Insert Into ZLLPMR.互认_LISITEMS(LISCHECKREPORTID,ITEMCODE,ITEMNAME,RESULT,UNIT,HINT,RANGE,STANDARDITEMID,TIME) 
                            Values('{0}','{1}','{2}','{3}','{4}','{5}','{6}','{7}',to_date('{8}','yyyy/mm/dd hh24:mi:ss'))";
            sql = string.Format(sql, id, item.ItemCode, item.ItemName, item.Result, item.Unit, item.Hint, item.Range, item.StandardItemId, date);
            //Log.Info("InsertLisItem:" + sql);
            Tools.ExecuteSql(sql);
        }

        public static int InsertPacs(PACSItem item, long lngPatientID, long lngClinicID, string no,long yzid)
        {
            string sql = @"Insert Into ZLLPMR.互认_PACS(PACSCHECKREPORTID,ITEMNAME,REPORTTIME,CHECKTYPENAME,POSITIONNAME,STANDARDITEMID,DIAGNOSRESULT,ORGNAME,病人ID,主页ID,TIME,OPERATORNO,医嘱id,REPORTTYPECODE) 
                            Values('{0}','{1}',to_date('{2}','yyyy/mm/dd hh24:mi:ss'),'{3}','{4}','{5}','{6}','{7}',{8},{9},sysdate,'{10}','{11}','{12}')";
            //var lis = result.ResultText[0].LIS[0];
            sql = string.Format(sql, item.PacsCheckReportId, item.ItemName, item.ReportTime, item.CheckTypeName, item.PositionName, item.StandardItemId, Tools.FormatStr(item.DiagnosResult), item.OrgName, lngPatientID, lngClinicID, no, yzid, item.reportTypeCode);
            Log.Info("InsertPacs==>"+sql);
            return Tools.ExecuteSql(sql);
        }

        public static int GetLis(string id)
        {
            int total = 0;
            string sql = @"Select Count(1) as TOTAL From ZLLPMR.互认_LIS Where LISCHECKREPORTID = '{0}'";
            sql = string.Format(sql, id);
            Recordset rd = new Recordset();
            Tools.QueryTable(sql, out rd);
            if (!rd.EOF)
            {
                rd.MoveFirst();
                total = int.Parse(rd.Fields["TOTAL"].Value.ToString());
            }
            return total;
        }
        public static void SaveData(Results result, long lngPatientID, long lngClinicID, string no, List<Codes> listlis, List<Codes> listpacs,out long lis_id,out long pacs_id)
        {
            lis_id = -1;
            pacs_id = -1;
            //Log.Info("666");
            var lis = result.ResultText[0].LIS;
            var pacs = result.ResultText[0].PACS;
            bool state = true;
            if (lis != null)
            {
                //Log.Info("777");
                for (int i = 0; i < lis.Count; i++)
                {
                    //long yzid = null;
                    //string code = lis[i].ItemList[0].StandardItemId;
                    for (int j = 0; j < lis[i].ItemList.Count; j++)
                    {
                        //Log.Info("state:" + state);
                        if (!state)
                        {
                            break;
                        }
                        foreach (var items in listlis)
                        {
                                string date = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                                //Log.Info("items.code:" + items.code);
                                //Log.Info("items.id:" + items.id);
                                int res = InsertLis(lis[i], lngPatientID, lngClinicID, date, no, long.Parse(items.id));
                                //Log.Info("res:" + res);
                                if (res > 0)
                                {
                                    if (lis_id == -1)
                                    {
                                        lis_id = long.Parse(items.id);
                                    }
                                    //Log.Info("res1");
                                    for (int k = 0; k < lis[i].ItemList.Count; k++)
                                    {
                                        //Log.Info("8888");
                                        InsertLisItem(lis[i].ItemList[k], lis[i].LisCheckReportId, lngPatientID, lngClinicID, date);
                                    }
                                }
                                state = false;
                          //  }
                        }
                      
                    }

                    


                }
            }
            if (pacs != null)
            {
                long id =long.Parse(listpacs[0].id);
                for (int i = 0; i < pacs.Count; i++)
                {
                    
                    foreach (var items in listpacs)
                    {
                        if (pacs[i].reportTypeCode == items.type)
                        {
                            
                            id = long.Parse(items.id);
                            break;
                        }
                    }
                    int res = InsertPacs(pacs[i], lngPatientID, lngClinicID, no, id);
                    if (res > 0)
                    {
                        if (pacs_id == -1)
                        {
                            pacs_id = id;
                        }
                    }
                }
                
            }


        }

        /// <summary>
        ///  保存互认数据  原来只支持一单 
        /// </summary>
        /// <param name="result"></param>
        /// <param name="lngPatientID"></param>
        /// <param name="lngClinicID"></param>
        /// <param name="no"></param>
        /// <param name="listlis"></param>
        /// <param name="listpacs"></param>
        /// <param name="lis_id"></param>
        /// <param name="pacs_id"></param>
        public static void SaveDataNew(Results result, long lngPatientID, long lngClinicID, string no, List<Codes> listlis, List<Codes> listpacs, out long lis_id, out long pacs_id)
        {
            lis_id = -1;
            pacs_id = -1;
            var lis = result.ResultText[0].LIS;
            var pacs = result.ResultText[0].PACS;
            
            if (lis != null)
            {
                for (int i = 0; i < lis.Count; i++)
                {
                    bool state = true;
                    for (int j = 0; j < lis[i].ItemList.Count; j++)
                    {
                        if (!state)
                        {
                            break;
                        }
                        foreach (var items in listlis)
                        {
                            
                            if (items.code.Contains(lis[i].ItemList[j].StandardItemId))
                            {
                                //insert 互认_lis
                                string date = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                                string xgid = items.id;
                                int res = InsertLis(lis[i], lngPatientID, lngClinicID, date, no, long.Parse(xgid));
                                if (res > 0)
                                {
                                    if (lis_id == -1)
                                    {
                                        lis_id = long.Parse(xgid);
                                    }
                                    for (int k = 0; k < lis[i].ItemList.Count; k++)
                                    {
                                        InsertLisItem(lis[i].ItemList[k], lis[i].LisCheckReportId, lngPatientID, lngClinicID, date);
                                    }
                                }
                                state = false;
                            }
                            
                        }
                    }
                }
            }
            if (pacs != null)
            {
                long id = long.Parse(listpacs[0].id);
                for (int i = 0; i < pacs.Count; i++)
                {
                    foreach (var items in listpacs)
                    {
                        if (pacs[i].reportTypeCode == items.type)
                        {

                            id = long.Parse(items.id);
                            break;
                        }
                    }
                    int res = InsertPacs(pacs[i], lngPatientID, lngClinicID, no, id);
                    if (res > 0)
                    {
                        if (pacs_id == -1)
                        {
                            pacs_id = id;
                        }
                    }
                }

            }
        }



        public static void SaveDataNew2(Results result, long lngPatientID, long lngClinicID, string no, List<Codes> listlis, List<Codes> listpacs, out long lis_id, out long pacs_id)
        {
            lis_id = -1;
            pacs_id = -1;
            var lis = result.ResultText[0].LIS;
            var pacs = result.ResultText[0].PACS;

            if (lis != null)
            {
                Log.Info("lis.Count=" + lis.Count);
                foreach (var items in listlis)
                {
                    Log.Info("items.id=" + items.id);
                    bool state = true;
                    for (int i = 0; i < lis.Count; i++)
                    {
                        Log.Info("state=" + state);
                        if (!state)
                        {
                            break;
                        }
                        bool flag = true;
                        for (int j = 0; j < lis[i].ItemList.Count; j++)
                        {
                            Log.Info("flag=" + flag);
                            //这里判断指标不能循环多次
                            if (!flag)
                            {
                                break;
                            }
                            if (items.code.Contains(lis[i].ItemList[j].StandardItemId))
                            {
                                string date = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                                long xgid = long.Parse(items.id);
                                int res = InsertLis(lis[i], lngPatientID, lngClinicID, date, no, xgid);
                                if (res > 0)
                                {
                                    lis_id= xgid;
                                    for (int k = 0; k < lis[i].ItemList.Count; k++)
                                    {
                                        InsertLisItem(lis[i].ItemList[k], lis[i].LisCheckReportId, lngPatientID, lngClinicID, date);
                                    }
                                }
                                flag = false;
                                state = false;
                            }
                        }

                    }
                }
            }
            if (pacs != null)
            {
                Log.Info("pacs.Count=" + pacs.Count);
                foreach (var items in listpacs)
                {
                    for (int i = 0; i < pacs.Count; i++)
                    {
                        long id = long.Parse(items.id);
                        if (pacs[i].StandardItemId.Contains(items.code))
                        {
                            int res = InsertPacs(pacs[i], lngPatientID, lngClinicID, no, id);
                            if (res > 0)
                            {
                                pacs_id=id;
                            }
                            break;
                        }

                    }
                }
            }

        }
            /// <summary>
            /// 是否互认
            /// </summary>
            /// <returns></returns>
            public static void IsAgree(out int res,out int date,out int yzzState)
        {
            res = 1;
            date = 20000;
            yzzState = 0;
            try
            {
                string sql = @"Select 互认 As AGREE,WAITINGDATE From zllpmr.互认配置表";
                Recordset rd = new Recordset();
                Tools.QueryTable(sql, out rd);
                if (!rd.EOF)
                {
                    rd.MoveFirst();
                    res = int.Parse(rd.Fields["AGREE"].Value.ToString());
                    date = int.Parse(rd.Fields["WAITINGDATE"].Value.ToString());
                    //yzzState = int.Parse(rd.Fields["一张纸"].Value.ToString());
                }
            }
            catch (Exception ex)
            {
                Log.Info(ex.Message);
                Log.Info(ex.StackTrace);
            }
        }

        public static void getUrlYzzCancelMedical(out string url)
        {
            url = "";
            try
            {
                string sql = @"Select 一张纸URL  From zllpmr.互认配置表";
                Recordset rd = new Recordset();
                Tools.QueryTable(sql, out rd);
                if (!rd.EOF)
                {
                    rd.MoveFirst();
                    url = int.Parse(rd.Fields["一张纸URL"].Value.ToString());
                }
            }
            catch (Exception ex)
            {
                Log.Info(ex.Message);
                Log.Info(ex.StackTrace);
            }
        }

        /// <summary>
        /// 是否互认
        /// </summary>
        /// <returns></returns>
        public static void ExistHuRemYz(out long limit_day)
        {
            limit_day = 1;
            try
            {
                string sql = @"Select limit_day From zllpmr.互认配置表";
                Recordset rd = new Recordset();
                Tools.QueryTable(sql, out rd);
                if (!rd.EOF)
                {
                    rd.MoveFirst();
                    limit_day = long.Parse(rd.Fields["limit_day"].Value.ToString());
                    
                }
            }
            catch (Exception ex)
            {
                Log.Info(ex.Message);
                Log.Info(ex.StackTrace);
            }
        }

        /// <summary>
        /// 仅一张纸使用,查询发送的医嘱
        /// </summary>
        /// <param name="ZYID"></param>
        /// <param name="no"></param>
        /// <param name="type"></param>
        /// <returns></returns>
        public static List<YZData> GetYZList(long fsh)
        {
            string sql = @"select 
                                to_char(b.ID) as id ,
                                decode(b.相关id,null,'0.0',to_char(b.相关id)) as 相关id,
                                to_char(b.前提id ) as 前提id,
                                to_char(b.病人来源 ) as 病人来源,
                                to_char(b.病人id )as 病人id,
                                to_char(b.主页id )as 主页id,
                                to_char(b.挂号单 )as 挂号单,
                                to_char(b.婴儿 )as 婴儿,
                                to_char(b.姓名  )as 姓名,
                                to_char(b.性别  )as 性别,
                                to_char(b.年龄 )as 年龄,
                                to_char(b.病人科室id )as 病人科室id,
                                to_char(b.序号 )as 序号,
                                to_char(b.医嘱状态 )as 医嘱状态,
                                to_char(b.医嘱期效  )as 医嘱期效,
                                to_char(b.诊疗类别  )as 诊疗类别,
                                to_char(b.诊疗项目ID  )as 诊疗项目ID,
                                to_char(b.标本部位  )as 标本部位,
                                to_char(b.检查方法 )as 检查方法,
                                to_char(b.收费细目id )as 收费细目id,
                                to_char(b.天数 )as 天数,
                                to_char(b.单次用量 )as 单次用量,
                                to_char(b.总给予量 )as 总给予量,
                                to_char(b.医嘱内容 )as 医嘱内容,
                                to_char(b.医生嘱托 )as 医生嘱托,
                                to_char(b.执行科室ID )as 执行科室ID,
                                to_char(b.执行频次 )as 执行频次,
                                to_char(b.频率次数 )as 频率次数,
                                to_char(b.频率间隔 )as 频率间隔,
                                to_char(b.间隔单位 )as 间隔单位,
                                to_char(b.执行时间方案 )as 执行时间方案,
                                to_char(b.计价特性 )as 计价特性,
                                to_char(b.执行性质 )as 执行性质,
                                to_char(b.执行标记 )as 执行标记,
                                to_char(b.可否分零 )as 可否分零,
                                to_char(b.紧急标志 )as 紧急标志,
                                to_char(b.开始执行时间,'yyyy-mm-dd hh24:mi:ss' )as 开始执行时间,
                                to_char(b.执行终止时间 ,'yyyy-mm-dd hh24:mi:ss' )as 执行终止时间,
                                to_char(b.开嘱科室ID )as 开嘱科室ID,
                                to_char(b.开嘱医生 )as 开嘱医生,
                                to_char(b.开嘱时间 ,'yyyy-mm-dd hh24:mi:ss' )as 开嘱时间,
                                to_char(b.摘要) as 摘要
                         from 病人医嘱发送 a,病人医嘱记录 b 
                         where b.id = a.医嘱id and  发送号 = {0} and 诊疗类别 in('D','C')
                         and NOT EXISTS(select 1 from 病人医嘱记录 where id = b.id and 诊疗类别 = 'D' and 相关id is  null)";
            // and NOT EXISTS(select 1 from 病人医嘱记录 where id = b.id and 诊疗类别 = 'D' and 相关id is not null)
            sql = string.Format(sql, fsh);
            Recordset recordset = new Recordset();
            Tools.QueryTable(sql, out recordset);
            List<YZData> list = new List<YZData>();
            while (!recordset.EOF)
            {
                YZData yz = new YZData();
                yz.ID = recordset.Fields["ID"].Value.ToString();
                yz.相关ID = recordset.Fields["相关ID"].Value.ToString();// yz.3767642yz.,
                yz.前提ID = recordset.Fields["前提ID"].Value.ToString();// yz.0.0yz.,
                yz.病人来源 = recordset.Fields["病人来源"].Value.ToString();// yz.2yz.,
                yz.病人ID = recordset.Fields["病人ID"].Value.ToString();// yz.46688yz.,
                yz.主页ID = recordset.Fields["主页ID"].Value.ToString();// yz.1yz.,
                yz.挂号单 = recordset.Fields["挂号单"].Value.ToString();// yz.yz.,
                yz.婴儿 = recordset.Fields["婴儿"].Value.ToString();// yz.0.0yz.,
                yz.姓名 = recordset.Fields["姓名"].Value.ToString();// yz.王少清yz.,
                yz.性别 = recordset.Fields["性别"].Value.ToString();// yz.男yz.,
                yz.年龄 = recordset.Fields["年龄"].Value.ToString();// yz.86yz.,
                yz.病人科室ID = recordset.Fields["病人科室ID"].Value.ToString();// yz.232yz.,
                yz.序号 = recordset.Fields["序号"].Value.ToString();// yz.87yz.,
                yz.医嘱状态 = recordset.Fields["医嘱状态"].Value.ToString();// yz.-1yz.,
                yz.医嘱期效 = recordset.Fields["医嘱期效"].Value.ToString();// yz.1yz.,
                yz.诊疗类别 = recordset.Fields["诊疗类别"].Value.ToString();// yz.Cyz.,
                yz.诊疗项目ID = recordset.Fields["诊疗项目ID"].Value.ToString();// yz.1890yz.,
                yz.标本部位 = recordset.Fields["标本部位"].Value.ToString();// yz.静脉血yz.,
                yz.检查方法 = recordset.Fields["检查方法"].Value.ToString();// yz.yz.,
                yz.收费细目ID = recordset.Fields["收费细目ID"].Value.ToString();// yz.0.0yz.,
                yz.天数 = recordset.Fields["天数"].Value.ToString();// yz.0.0yz.,
                yz.单次用量 = recordset.Fields["单次用量"].Value.ToString();// yz.0.0yz.,
                yz.总给予量 = recordset.Fields["总给予量"].Value.ToString();// yz.1yz.,
                yz.医嘱内容 = recordset.Fields["医嘱内容"].Value.ToString();// yz.肝功能yz.,
                yz.医生嘱托 = recordset.Fields["医生嘱托"].Value.ToString();// yz.yz.,
                yz.执行科室ID = recordset.Fields["执行科室ID"].Value.ToString();// yz.167yz.,
                list.Add(yz);
                recordset.MoveNext();
            }
            return list;
        }
        /// <summary>
        /// 作废医嘱
        /// </summary>
        public static void CancelYz(long 病人id, long 主医嘱id, int lis, int pacs)
        {
            string sql = @"select distinct c.no
                              from 病人医嘱记录 a, 病人医嘱发送 b, 门诊费用记录 c
                             where b.医嘱id = a.id
                               and c.医嘱序号 = b.医嘱id
                               and a.病人id = {0}
                               and (a.id = {1} or a.相关id = {1})";
            sql = string.Format(sql, 病人id, 主医嘱id);
            Recordset recordset = new Recordset();
            Tools.QueryTable(sql, out recordset);
            string json = "{\"input\":{\"operator_name\":\"\",\"operator_code\":\"\",\"operator_time\":\"\",\"del_list\":[";
            while (!recordset.EOF)
            {
                string no = recordset.Fields["NO"].Value.ToString();
                json += "{\"fee_source\":1,\"fee_bill_type\":1,\"fee_no\":\""+ no + "\",\"del_type\":2,\"serial_num\":\"\",\"exe_sta_nums\":\"\",\"fee_ids\":\"\"},";
                recordset.MoveNext();
            }
            json = json.Substring(0,json.Length - 1);
            json += "]}}";
            //原始调用过程没有作用 改用数据处理平台中转
            //Tools.ExecuteStoredProc(病人id, 主医嘱id, json, lis, pacs);
            int lisMessage = 0;
            int pacsMessage = 0;
            //调有 http 
            Dictionary<string, string> body = new Dictionary<string, string>();
            body.Add("patientId", 病人id.ToString());
            body.Add("medicalOrderId", 主医嘱id.ToString());
            body.Add("jsonIn", json);
            if (lis>0)
            {
                lisMessage = 1;
            }
            if (pacs>0)
            {
                pacsMessage = 1;
            }
            body.Add("lisMessage", lisMessage.ToString());
            body.Add("pacsMessage", pacsMessage.ToString());

            string url = "http://172.30.0.66:7000/cancelMedicalForYzz";
            getUrlYzzCancelMedical(out url);
            Log.Info("url="+ url);
           string resultString = HttpUtils.WSCenterData(url, body.ToString());
           Log.Info("resultString==" + resultString);

        }



        /*public List<BillProjectUpload> GetBillProjects(long lngSendID,string hostName,string patientId)
        {

            List<BillProjectUpload> billList =   new List<BillProjectUpload>();
            List<YZData> list = GetYZList(lngSendID);
            for (var i = 0; i < list.Count; i++)
            {
                if (list[i].诊疗类别 == "C" && list[i].相关ID != "0.0")
                {
                    string code = "";
                    int total = 0;
                    IsLisProject(list[i].诊疗项目ID, out code, out total);
                    if (total > 0)
                    {
                        //进来才说明是互认项目
                        BillProjectUpload billProject = new BillProjectUpload();
                        billProject.billProjectName = list[i].医嘱内容;
                        billProject.billName = list[i].开嘱医生;
                        billProject.billTime = DateTime.Now.ToString("yyyy-MM-DD HH:mm:ss");
                        billProject.billType = "C";
                        billProject.computerName = hostName;
                        billProject.patientId = patientId;
                        billProject.medicId = list[i].ID;
                        billList.Add(billProject);
                    }
                }
                else if (list[i].诊疗类别 == "D" && list[i].相关ID != "0.0")
                {
                    
                    int total = 0;
                    string type = "";
                    
                    String param = list[i].诊疗项目ID + "_" + list[i].标本部位 + "_" + list[i].检查方法;
                    IsPacsProject(param, out total, out type);
                    if (total > 0)
                    {
                        //进来才说明是互认项目
                        BillProjectUpload billProject = new BillProjectUpload();
                        billProject.billProjectName = list[i].医嘱内容;
                        billProject.billName = Infos.UserInfo.编号;
                        billProject.billTime = DateTime.Now.ToString("yyyy-MM-DD HH:mm:ss");
                        billProject.billType = "D";
                        billProject.computerName = hostName;
                        billProject.patientId = patientId;
                        billProject.medicId = list[i].ID;
                        billList.Add(billProject);
                    }

                }
            }

            if(billList.Count>0)
            {
                //保存开单数据
            }

            return billList;
        }*/
    }
}