84 lines
4.1 KiB
C#
84 lines
4.1 KiB
C#
using System;
|
|
using System.Data;
|
|
using System.Data.OracleClient;
|
|
using WX.CRM.Common;
|
|
|
|
namespace WX.CRM.DAL.Sms
|
|
{
|
|
public class BATCHMSG_DAL
|
|
{
|
|
public void ImpotDt(System.Data.DataSet ds, int timeOut = 300)
|
|
{
|
|
var tb1 = ds.Tables["SMS_BATCHMSG"];
|
|
var tb2 = ds.Tables["RES_IMPORTRES_DETAIL"];
|
|
if (tb1 != null)
|
|
OracleHelper.BulkToDB(tb1, "SMS_BATCHMSG", timeOut);
|
|
if (tb2 != null)
|
|
OracleHelper.BulkToDB(tb2, "RES_IMPORTRES_DETAIL", timeOut);
|
|
}
|
|
|
|
public void ImpotDtResCode(System.Data.DataSet ds, int timeOut = 300)
|
|
{
|
|
var tb1 = ds.Tables["SMS_RESCODE"];
|
|
if (tb1 != null)
|
|
OracleHelper.BulkToDB(tb1, "SMS_RESCODE", timeOut);
|
|
}
|
|
|
|
public void DoImportDt(decimal p_batchid)
|
|
{
|
|
System.Data.OracleClient.OracleParameter[] p =
|
|
{
|
|
new System.Data.OracleClient.OracleParameter("p_batchid", System.Data.OracleClient.OracleType.Number)
|
|
};
|
|
p[0].Value = p_batchid;
|
|
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_SMS.sms_importmsgdetail", p);
|
|
}
|
|
|
|
public void ExecLog(string p_pkids, string p_SENDSTR, string p_CLIENTCODE, decimal? p_MSGSOURCEID, string p_RETURNMSG, short p_SENDSUCCESS)
|
|
{
|
|
OracleParameter[] p2 =
|
|
{
|
|
|
|
new OracleParameter(){ ParameterName = "p_pkids", OracleType = OracleType.VarChar,Value = p_pkids },
|
|
new OracleParameter(){ ParameterName = "p_SENDSTR", OracleType = OracleType.VarChar,Value = p_SENDSTR },
|
|
new OracleParameter(){ ParameterName = "p_CLIENTCODE", OracleType = OracleType.VarChar,Value = p_CLIENTCODE },
|
|
new OracleParameter(){ ParameterName = "p_MSGSOURCEID", OracleType = OracleType.Number,Value = p_MSGSOURCEID },
|
|
new OracleParameter(){ParameterName = "p_RETURNMSG", OracleType = OracleType.VarChar,Value = p_RETURNMSG },
|
|
new OracleParameter(){ ParameterName = "p_SENDSUCCESS", OracleType = OracleType.Number, Value = p_SENDSUCCESS}
|
|
};
|
|
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, " pack_sms.execlog", p2);
|
|
}
|
|
|
|
#region 客户详细页短信查询
|
|
public DataSet GetMessageList(ref Pager pager, string resid, int? rn, DateTime? stime, DateTime? etime)
|
|
{
|
|
OracleConnection conn = new OracleConnection(OracleHelper.AYCRMConn);
|
|
if (conn.State == ConnectionState.Closed)
|
|
conn.Open();
|
|
try
|
|
{
|
|
using (OracleTransaction trans = conn.BeginTransaction())
|
|
{
|
|
OracleParameter[] p = new[] {
|
|
new OracleParameter{ ParameterName="p_rows", OracleType = OracleType.Number,Value=rn },
|
|
new OracleParameter{ ParameterName="p_resid", OracleType = OracleType.VarChar,Value=resid },
|
|
new OracleParameter{ ParameterName="p_stime", OracleType = OracleType.DateTime,Value=stime },
|
|
new OracleParameter{ ParameterName="p_etime", OracleType = OracleType.DateTime,Value=etime },
|
|
new OracleParameter{ ParameterName="p_pageIndex", OracleType = OracleType.Number, Value=pager.page },
|
|
new OracleParameter{ ParameterName="p_pageSize", OracleType = OracleType.Number, Value=pager.rows },
|
|
new OracleParameter{ParameterName="p_data",OracleType=OracleType.Cursor,Direction = ParameterDirection.Output}
|
|
};
|
|
var ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_SMS.GetAllMessageByResId", p);
|
|
trans.Commit();
|
|
if (null != ds && ds.Tables[0].Rows.Count > 0)
|
|
pager.totalRows = Convert.ToInt32(ds.Tables[0].Rows[0]["ROWCOUNT"]);
|
|
return ds;
|
|
}
|
|
}
|
|
catch { throw; }
|
|
finally { conn.Close(); }
|
|
}
|
|
#endregion
|
|
}
|
|
}
|