using SI.Common;
using System;


public class SqlQuery
{
    
    private Sql _QueryHCare;

    private Sql QueryHCare
    {
        get
        {
            if (_QueryHCare == null)
            {
                try
                {
                    _QueryHCare = new Sql("HealthCare");
                }
                catch
                {
                    _QueryHCare = new Sql("HealthCare");
                }
            }
            return _QueryHCare;
        }
    }

    /* 查询操作
     * QueryHCare.Command.Clear();
     * QueryHCare.Command.Add("select * from table");
     * QueryHCare.ParamByName("StartTime").SetDate(StartTime);
     * QueryHCare.ExecuteQuery();
     * 
     * 
     */
    public SqlQuery()
	{
        
	}

    public int SaveQuery(ReciveEntity msg)
    {
        string SqlStr = @"insert into HL7_Receive(ID,
SourceID,
MsgConID,
MsgContent,
ReceivingTime,
IP,
ReplyMsg,
TaskStatus,
MessageID, 
MessageType ,Sequeue,Remark
)
values(
@ID,
@SourceID,
@MsgConID,
@MsgContent,
@ReceivingTime,
@IP,
@ReplyMsg,
1, 
@MessageID, 
@MessageType ,@Sequeue,@Remark
)";
        try
        {
            QueryHCare.Command.Clear();
            QueryHCare.Command.Add(SqlStr);
            QueryHCare.ParamByName("ID").SetString(Guid.NewGuid());
            QueryHCare.ParamByName("SourceID").SetString("MediII");
            QueryHCare.ParamByName("MsgConID").SetString(msg.MsgConID);
            QueryHCare.ParamByName("MsgContent").SetText(msg.MsgContent);
            QueryHCare.ParamByName("ReceivingTime").SetDateTime(DateTime.Now); //为什么用系统时间，返回消息需要带时间，为统一比对
            QueryHCare.ParamByName("IP").SetString(msg.IP);
            QueryHCare.ParamByName("ReplyMsg").SetText(msg.ReplyMsg);
            QueryHCare.ParamByName("MessageID").SetString(msg.MessageID);
            QueryHCare.ParamByName("MessageType").SetString(msg.MessageType);
            QueryHCare.ParamByName("Sequeue").SetInt32(msg.Sequeue);
            QueryHCare.ParamByName("Remark").SetText(msg.Remark);

            return QueryHCare.ExecuteNonQuery();
        }
        catch
        {
            return 0;
        }
    }
}