HisClientReceiveToKC/IL.BizComponent/MediII.Adapter.BizComponent.DFP/BizComponent_DFT.cs

using System;
using System.Data;
using System.Collections.Generic;
using System.Linq;
using System.Text;
//using MediII.Adapter.BaseBiz;
using System.Data.Common;
using System.Transactions;
using Microsoft.Practices.EnterpriseLibrary.Data;
//using MediII.Adapter.Model.UE;
using System.Globalization;
using MediII.Adapter.BizComponent.Base;
using IL.Common;
using System.Xml;

namespace MediII.Adapter.BizComponent.DFT
{
    public class BizComponent_DFT : BaseBizComponent, IBizComponent
    {
        const string Insert = "B01"; //增加个人纪录
        //const string Update = "B02"; //更新个人记录
        //const string Delete = "B03"; //删除个人记录


        //数据库连接
        protected Database ctx;
        protected Database Scanctx;
        public BizComponent_DFT()
        {
            DatabaseProviderFactory factory = new DatabaseProviderFactory();
            ctx = factory.Create("HealthCare");
            Scanctx = factory.CreateDefault();
        }
        ////HealthCareContainer HealthCareContainer = new HealthCareContainer();
        //private Database ctx = null;
        //public BizComponent_PMU(Database dbCtx)
        //{
        //    ctx = dbCtx;
        //}
        public override string DoProcess(string m, string msgType, string ID)
        {
            string strMsgType = null;
            var resultCode = string.Empty;
            var result = string.Empty;
            //try
            //{
            //try
            // {
            //取得消息类型 MAD新增 MUP更新 MDL删除 "MDC"作废 "MAC"恢复
            OperateXmlUtil helper = new OperateXmlUtil();
            WebService server = new WebService();
            string orgCode = System.Configuration.ConfigurationManager.AppSettings["orgCode"];
            var cert = System.Configuration.ConfigurationManager.AppSettings["cert"];                                             
            //string qurysql = "select count(*) from dbo.his_doct where DOCT_CODE=@DOCT_CODE";
            //DbCommand command = ctx.GetSqlStringCommand(qurysql.ToString());
            //string pkid = helper.XpathRead(m, "//*[@root='2.16.156.10011.1.4']", "extension");
            //ctx.AddInParameter(command, "DOCT_CODE", System.Data.DbType.String, pkid);
            //int counts = Convert.ToInt32(ctx.ExecuteScalar(command));

            string msgBody = helper.GetMsgBody(orgCode);
            string msgHead = helper.GetMsgHead("getItemDict", cert);


            string rtnMsg = server.TestInterface(msgHead, msgHead);
            //存储访问记录
            MessageHelper.SaveSendMsg(Scanctx, ID, "DFT^B01[B01]", msgHead, msgBody, rtnMsg);
            //消息判断是否成功
            if (!helper.isSuccess(rtnMsg, ref resultCode, ref result))
            {
                throw new Exception(result);
            }
            
            XmlNodeList root = helper.XpathRead(rtnMsg, "//returnContents//returnContent");
            if (root.Count <= 0)
                return string.Empty;
            
            using (TransactionScope scope = new TransactionScope(TransactionScopeOption.RequiresNew))
            {
                var usql = @"update item_his_original set yn_code=@yn_code,item_name=@item_name,fee_code=@fee_code,fee_name=@fee_code,spell_code=@spell_code,price=@price,status=@status,status_date=@status_date where item_code=@item_code";
                var sql = @"insert into item_his_original(item_code,yn_code,item_name,fee_code,fee_name,spell_code,price,status,status_date) Values(@item_code,@yn_code,@item_name,@fee_code,@fee_name,@spell_code,@price,@status,@status_date);";
                foreach (XmlElement xe in root)
                {
                    var iSet = GetDOCT(xe.SelectSingleNode("item_code").InnerText);
                    if (iSet <= 0)
                    {
                        var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
                        ctx.AddInParameter(cmd, "item_code", System.Data.DbType.String, xe.SelectSingleNode("item_code").InnerText);
                        ctx.AddInParameter(cmd, "yn_code", System.Data.DbType.String, xe.SelectSingleNode("yn_code").InnerText);
                        ctx.AddInParameter(cmd, "item_name", System.Data.DbType.String, xe.SelectSingleNode("item_name").InnerText);
                        ctx.AddInParameter(cmd, "fee_code", System.Data.DbType.String, xe.SelectSingleNode("fee_code").InnerText);
                        ctx.AddInParameter(cmd, "fee_name", System.Data.DbType.String, xe.SelectSingleNode("fee_name").InnerText);
                        ctx.AddInParameter(cmd, "spell_code", System.Data.DbType.String, xe.SelectSingleNode("spell_code").InnerText);
                        ctx.AddInParameter(cmd, "price", System.Data.DbType.Decimal, xe.SelectSingleNode("price").InnerText);
                        ctx.AddInParameter(cmd, "status", System.Data.DbType.String, xe.SelectSingleNode("status").InnerText);
                        var date = xe.SelectSingleNode("status_date").InnerText;
                        DateTime time = DateTime.Now;
                        if (!string.IsNullOrWhiteSpace(date))
                        {
                            if (!DateTime.TryParse(date, out time))
                            {
                                time = DateTime.Now;
                            }
                        }
                        ctx.AddInParameter(cmd, "status_date", System.Data.DbType.DateTime, time);
                        SqlDataAccess.DBExecuteNonQuery(ctx, cmd);
                    }
                    else
                    {
                        var cmd = SqlDataAccess.GetSqlStringCommand(ctx, usql);
                        ctx.AddInParameter(cmd, "item_code", System.Data.DbType.String, xe.SelectSingleNode("item_code").InnerText);
                        ctx.AddInParameter(cmd, "yn_code", System.Data.DbType.String, xe.SelectSingleNode("yn_code").InnerText);
                        ctx.AddInParameter(cmd, "item_name", System.Data.DbType.String, xe.SelectSingleNode("item_name").InnerText);
                        ctx.AddInParameter(cmd, "fee_code", System.Data.DbType.String, xe.SelectSingleNode("fee_code").InnerText);
                        ctx.AddInParameter(cmd, "fee_name", System.Data.DbType.String, xe.SelectSingleNode("fee_name").InnerText);
                        ctx.AddInParameter(cmd, "spell_code", System.Data.DbType.String, xe.SelectSingleNode("spell_code").InnerText);
                        ctx.AddInParameter(cmd, "price", System.Data.DbType.Decimal, xe.SelectSingleNode("price").InnerText);
                        ctx.AddInParameter(cmd, "status", System.Data.DbType.String, xe.SelectSingleNode("status").InnerText);
                        var date = xe.SelectSingleNode("status_date").InnerText;
                        DateTime time = DateTime.Now;
                        if (!string.IsNullOrWhiteSpace(date))
                        {
                            if (!DateTime.TryParse(date, out time))
                            {
                                time = DateTime.Now;
                            }
                        }
                        ctx.AddInParameter(cmd, "status_date", System.Data.DbType.DateTime, time);
                        SqlDataAccess.DBExecuteNonQuery(ctx, cmd);
                    }
                }
                var ScanSql = @"update HL7_Scan set OtherNo1=CONVERT(varchar(100), GETDATE(), 120),TaskStatus=1 where ID=@ID";
                var ucmd = SqlDataAccess.GetSqlStringCommand(Scanctx, ScanSql);
                Scanctx.AddInParameter(ucmd, "ID", System.Data.DbType.String, ID);
                SqlDataAccess.DBExecuteNonQuery(Scanctx, ucmd);
                scope.Complete();
            }
            return string.Empty;
        }
        public void AddData(string message,string id)
        {
            #region 新增
            string sql = @"INSERT INTO dbo.his_doct
                                    ( DOCT_CODE ,
                                    DOCT_NAME ,
                                    HIS_DEPT_CODE ,
                                    HIS_DEPT_NAME ,
                                    status
                                    )
                            VALUES  ( @DOCT_CODE,
                                    @DOCT_NAME ,
                                    @HIS_DEPT_CODE ,
                                    @HIS_DEPT_NAME ,
                                    @status)";
            DbCommand command = ctx.GetSqlStringCommand(sql.ToString());

            SetEntity(message, command, id);
            SqlDataAccess.ExecuteNonQuery(ctx, command);
            #endregion
        }
        public void UpDateData(string message, string id)
        {
            #region 修改
            string sql1 = @"update dbo.his_doct set 
                                    DOCT_NAME =@DOCT_NAME,
                                    HIS_DEPT_CODE =@HIS_DEPT_CODE,
                                    HIS_DEPT_NAME =@HIS_DEPT_NAME,
                                    status=@status
                                where DOCT_CODE=@DOCT_CODE";
            DbCommand command1 = ctx.GetSqlStringCommand(sql1.ToString());

            SetEntity(message, command1, id);
            SqlDataAccess.ExecuteNonQuery(ctx, command1);
            #endregion
        }

        public void SetEntity(string message,DbCommand command,string id)
        {
            string value = string.Empty;
            OperateXmlUtil xmlHelper = new OperateXmlUtil();

            ctx.AddInParameter(command, "DOCT_CODE", System.Data.DbType.String, id);
            var valueNode = xmlHelper.XpathRead(message, "//*[name()='healthCarePrincipalPerson']").Item(0);

            foreach (XmlNode xe in valueNode.ChildNodes)
            {
                if (xe.Name == "name")
                {
                    value = xe.LastChild.LastChild.Attributes["value"].Value;
                    ctx.AddInParameter(command, "DOCT_NAME", System.Data.DbType.String, value);

                    break;
                }
            }

            value = xmlHelper.XpathRead(message, "//*[@root='2.16.156.10011.1.26']", "extension");
            ctx.AddInParameter(command, "HIS_DEPT_CODE", System.Data.DbType.AnsiString, value);

            valueNode = xmlHelper.XpathRead(message, "//*[name()='affiliatedPrincipalOrganization']").Item(0);
            foreach (XmlNode xe in valueNode.ChildNodes)
            {
                if (xe.Name == "name")
                {
                    value = xe.LastChild.LastChild.Attributes["value"].Value;
                    ctx.AddInParameter(command, "HIS_DEPT_NAME", System.Data.DbType.String, value);

                    break;
                }
            }
            ctx.AddInParameter(command, "status", System.Data.DbType.String, "在用");
            //ctx.ExecuteNonQuery(command);
        }

        public int GetDOCT(string DOCT_Code)
        {
            var sql = "SELECT count(1) FROM dbo.item_his_original WITH(NOLOCK) WHERE item_code=@item_code";
            var cmd = ctx.DBGetSqlStringCommand(sql);
            ctx.AddInParameter(cmd, "item_code", DbType.String, DOCT_Code);
            var obj = int.Parse(StrHelepr.Obj2StrTrim(ctx.DBExecuteScalar(cmd)));
            return obj;
        }
       



      

    }

}
#region 此为老版本代码
/*
Employee Module_Employee = new Employee();

strMsgType = pmuB01.EVN.EventTypeCode.Value;

#region STG
STF stf = pmuB01.STF;

Module_Employee.EmpNo = Convert.ToInt16(stf.PrimaryKeyValueSTF.Identifier.Value);// 员工代号
Module_Employee.EmpCode = stf.GetStaffIDCode(0).ID.Value;// 员工代码
Module_Employee.EmpName = stf.GetStaffName(0).GivenName.Value;// 姓名
Module_Employee.EngName = stf.GetStaffName(0).GivenName.Value;// 英文姓名
Module_Employee.IdNo = stf.DriverSLicenseNumberStaff.DriverSLicenseNumber.Value.Trim() ;// 身份证号 <<<<<<<<<<<<<<<<<<<<<< 目前ISNULL

#region 性别转换
// 1:男 2:女
Module_Employee.Sex = His.MediIITransfer.MediII2Ue.GetSex(stf.AdministrativeSex.Value);
#endregion

Module_Employee.Birthday = His.Time.TryParseExact(stf.DateTimeOfBirth.TimeOfAnEvent.Value, "yyyyMMddhhmmss");

#region 婚姻状况
// 婚姻状况 (0:未婚,1:已婚,2:离婚)
switch (stf.MaritalStatus.Text.Value)
{
    case "S"://S	独身
    case "P"://P	同性恋
    case "G"://G	同居
    case "B"://B	未婚
    case "U"://U	未知
    case "O"://O	其他
    case "T"://T	未报告
        Module_Employee.MaritalStatus = "0";
        break;
    case "M"://M	结婚
    case "A":  //A	分居
    case "W"://W	丧偶
    case "R"://R	已登记同性恋
    case "E"://E	合法分居
    // case "C"://C	普通法律
    case "I"://I	诉讼中
        Module_Employee.MaritalStatus = "1";
        break;

    case "D"://D	离婚
        Module_Employee.MaritalStatus = "2";
        break;
    default:
        Module_Employee.MaritalStatus = "0";
        break;
}
#endregion

Module_Employee.HomeAdrArea = 0;// 住处区域代码 <<<<<<<<<<<<<<<<<<<<<<<<<<<
Module_Employee.HomeAdrDesc = stf.GetOfficeHomeAddress(0).StreetAddress.StreetOrMailingAddress.Value;// 住处地址
Module_Employee.HomeTel1 = stf.GetPhone(0).PhoneNumber.Value;// 住处电话1
Module_Employee.HomeTel2 = "0"; // 住处电话2(不同步)

Module_Employee.MobilePhone = stf.GetPhone(0).PhoneNumber.Value; // 移动电话

Module_Employee.NativeAdrArea = 0;// 户籍区域代码(不同步)
Module_Employee.NativeAdrDesc = "";// 户籍地址(不同步)
Module_Employee.NativeTel = "";// 户籍电话(不同步)

Module_Employee.ConName = "";// 联系人姓名（不同步）
Module_Employee.ConTel1 = "";// 络人电话（不同步）
Module_Employee.ConTel2 = "";// 络人电话（不同步）

Module_Employee.ConAdrArea = 0;// 联系人区域代码（不同步）
Module_Employee.ConAdrDesc = "";// 联系人地址（不同步）

Module_Employee.Affiliation = "";// 与联系人关系(不同步)

try
{
     string sHireDate =stf.GetInstitutionActivationDate(0).Date.TimeOfAnEvent.Value;
    DateTime dtHireDate = His.Time.TryParseExact(sHireDate, "yyyyMMddhhmmss");

    Module_Employee.HireDate = dtHireDate == His.Time.MaxDateTime ? Convert.ToDateTime("1911-01-01 00:00:00") : dtHireDate; // 到职日期

}
catch
{
    Module_Employee.HireDate = Convert.ToDateTime("1911-01-01 00:00:00");
}
               
Module_Employee.Zone = "A";// 归属院区(联众会开栏位**********)<<<<<<<<<<<<<<<<<<<<<<

string tmp = stf.GetDepartment(0).Identifier.Value;

try
{
    string sDepartNo = His.MediIITransfer.MediII2Ue.GetDepartNo(stf.GetDepartment(0).Identifier.Value);
    Module_Employee.DepartNo = Convert.ToInt16(sDepartNo);// 部门代码
}
catch (Exception ex)
{
    Module_Employee.DepartNo = -1;
}

Module_Employee.EmpType = stf.GetStaffType(0).Value;

#region 员工分类

switch (stf.GetStaffType(0).Value) // 员工分类
{
    case "1"://1	医生
        Module_Employee.EmpType = "1";
        break;
    case "2"://2	护士
        Module_Employee.EmpType = "2";
        break;
    case "3"://3	财务人员
        Module_Employee.EmpType = "3";
        break;
    case "4"://4	药剂人员
        Module_Employee.EmpType = "4";
        break;
    case "5"://5	技师（检验）
    case "6"://6	技师（影像）
    case "7"://7	管理人员
    case "8"://8	其他卫生技术人员
    case "9"://9	其他人员
        Module_Employee.EmpType = "0";
        break;
}
#endregion
string tmp2 = stf.JobCodeClass.JobCode.Value;

try
{
    Module_Employee.Title = Convert.ToInt16(stf.JobCodeClass.JobCode.Value);// 职称
}
catch (Exception ex)
{
    Module_Employee.Title = -1;
}


Module_Employee.ChiefNo = Convert.ToInt16(stf.GetHospitalService(0).Identifier.Value);// 职位
string tmp3 = stf.GetDepartment(0).Identifier.Value;

try
{
    string sWorkDepartNo = His.MediIITransfer.MediII2Ue.GetDepartNo(stf.GetDepartment(0).Identifier.Value);
    Module_Employee.WorkDepartNo = Convert.ToInt16(sWorkDepartNo);// 工作单位代号  <<<<<<<<<<<<<

}
catch
{
    Module_Employee.WorkDepartNo = -1;
}

Module_Employee.SimpleTel = stf.GetPhone(0).PhoneNumber.Value;// 速拨码
Module_Employee.SubTel = stf.GetPhone(0).PhoneNumber.Value;// 分机

string sPassword = stf.GetBackupPersonID(0).Identifier.Value;

Module_Employee.Password = sPassword == null ? "" : sPassword;
Module_Employee.PasswordTime = DateTime.Now; // <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
Module_Employee.PressCard = 0;// 工作卡号(暫時不填)


string  sActiveInactiveFlag = stf.ActiveInactiveFlag.Value; // A,在职;I,离职
Module_Employee.ResignDate = sActiveInactiveFlag == "A" ? His.Time.MaxDateTime : His.Time.MaxDateTime; 

int iIntParse;
int.TryParse(stf.PreferredMethodOfContact.Identifier.Value, out iIntParse);
if (iIntParse != 0)
{
    Module_Employee.UpdateUser = Convert.ToInt16(iIntParse);// 最后修改人
}

Module_Employee.UpdateTime = DateTime.Now;

Module_Employee.EMail = "";// 电子信箱(不同步)

Module_Employee.Remark = "";// 备注说明(不同步)

Module_Employee.Team = 0;// 组别

#endregion

#region 測試

string sErrMsg;
if (string.IsNullOrEmpty(Module_Employee.IdNo))
{
    sErrMsg = "【身份证】无法为空";
    SetACK(m, "ACK", strMsgType, "ACK", sErrMsg);
}

if (string.IsNullOrEmpty(Module_Employee.HomeAdrDesc))
{
    Module_Employee.HomeAdrDesc = "";
}

if (string.IsNullOrEmpty(Module_Employee.HomeTel1))
{
    Module_Employee.HomeTel1 = "";
}

if (string.IsNullOrEmpty(Module_Employee.HomeTel1))
{
    Module_Employee.HomeTel1 = ""; // 住处电话1
}

if (string.IsNullOrEmpty(Module_Employee.MobilePhone))
{
    Module_Employee.MobilePhone = ""; // 移动电话1
}

if (string.IsNullOrEmpty(Module_Employee.MobilePhone))
{
    Module_Employee.MobilePhone = ""; // 移动电话1
}


//Module_Employee.HireDate = His.Time.TryParseExact(sHireDate, "yyyyMMdd"); // 到职日期
//Module_Employee.Title = Convert.ToInt16(stf.JobCodeClass.JobCode.Value);// 职称

//Module_Employee.ChiefNo = Convert.ToInt16(stf.GetHospitalService(0).Identifier.Value);// 职位

if (string.IsNullOrEmpty(Module_Employee.MobilePhone))
{
    Module_Employee.SimpleTel = "";// 速拨码
}

if (string.IsNullOrEmpty(Module_Employee.MobilePhone))
{
    Module_Employee.SubTel = "";// 分机
}

if (string.IsNullOrEmpty(Module_Employee.Password))
{
    sErrMsg = "【密碼】无法为空";
    SetACK(m, "ACK", strMsgType, "ACK", sErrMsg);
}

//if (Module_Employee.HireDate == DateTime.MinValue)
//{
//    Module_Employee.HireDate = His.Time.MaxDateTime;
//}
if (Module_Employee.PasswordTime == DateTime.MinValue)
{
    Module_Employee.PasswordTime = His.Time.MaxDateTime;
}
if (Module_Employee.UpdateTime == DateTime.MinValue)
{
    Module_Employee.UpdateTime = His.Time.MaxDateTime;
}

if (Module_Employee.ResignDate == DateTime.MinValue)
{
    Module_Employee.ResignDate = His.Time.MaxDateTime;
}


//Module_Employee.ResignDate = His.Time.TryParseExact(sResignDate, "yyyyMMdd"); // 离职日期
#endregion


// 開始存入資料庫
int iEmpNo = Convert.ToInt16(stf.PrimaryKeyValueSTF.Identifier.Value);// 员工代号
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.RequiresNew))
{
    switch (strMsgType)
    {
        case Insert:
        case Update:
            EmployeeDelete(iEmpNo, ref HealthCareContainer, scope, ref Module_Employee);
            EmployeeInsert(iEmpNo, ref HealthCareContainer, scope, ref Module_Employee);
            break;
        case Delete:
            EmployeeDelete(iEmpNo, ref HealthCareContainer, scope, ref Module_Employee);
            break;
    }

    #region 存入資料庫

    try
    {
        HealthCareContainer.SaveChanges();
    }
    catch (System.Data.Entity.Validation.DbEntityValidationException ex)
    {
        scope.Dispose();
        throw ex;
    }
    #endregion

    scope.Complete();


}
*/
//        return string.Empty;

//    }
//    catch (Exception ex)
//    {
//        string errMsg = string.Empty;
//        if (ex.InnerException == null)
//        {
//            errMsg = ex.Message + "\r\n" + ex.StackTrace;
//        }
//        else
//        {
//            errMsg = ex.Message + "\r\n" + ex.InnerException.Message + "\r\n" + ex.InnerException.StackTrace;
//        }
//        return errMsg;
//    }
//}
// catch (System.Data.Entity.Validation.DbEntityValidationException ex)
//{
//var tmp = ex.EntityValidationErrors.FirstOrDefault().ValidationErrors;
//string errString = "";
//foreach (var item in tmp)
//{
//    errString += item.ErrorMessage;
//}
//string ack = SetACK(m, "ACK", mType, "ACK", ex.EntityValidationErrors.ToString());
//throw new Exception(string.Format("{0}\r\n{1}", ex.EntityValidationErrors.ToString()));

//return ex.Message;
//}
//}


/*

public void EmployeeInsert(int iEmpNo, ref HealthCareContainer HealthCareContainer, TransactionScope scope, ref Employee Module_Employee)
{
    try
    {
        HealthCareContainer.Employee.Add(Module_Employee);

    }
    catch (Exception ex)
    {
        scope.Dispose();
        throw ex;
    }
}

public void EmployeeDelete(int iEmpNo, ref HealthCareContainer HealthCareContainer, TransactionScope scope, ref Employee Module_Employee)
{
    try
    {
        IEnumerable<Employee> EmployeeList = HealthCareContainer.Employee.Where(x => x.EmpNo == iEmpNo);
        if (EmployeeList.Count() != 0)
        {
            Employee Module_Employee_Del = EmployeeList.FirstOrDefault();
            HealthCareContainer.Employee.Remove(Module_Employee_Del);
            HealthCareContainer.SaveChanges();
        }

    }
    catch (Exception ex)
    {
        scope.Dispose();
        throw ex;
    }
}
*/
// }
//}
#endregion