namespace AsiaINFO.SMS.DBFactory
|
{
|
using AsiaINFO.DBHelpers.MSSqlDB;
|
using AsiaINFO.SMS.Entity;
|
using DBFactory;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.SqlClient;
|
using System.Linq;
|
|
public class MTFactory
|
{
|
private static bool checkPhoneNumberFormat(string phoneNumber)
|
{
|
bool flag = true;
|
return (((phoneNumber != null) && (phoneNumber.Length == 11)) && flag);
|
}
|
|
public static List<SMS_MT_INFO> GetSMSInfo(string smsContent, string[] phoneNumberArray, string subNumber, string wapPushAddr, string sendTime, string subnumber, string needdowntime, int batchid, int priority)
|
{
|
List<SMS_MT_INFO> result = new List<SMS_MT_INFO>();
|
int sign = System.Configuration.ConfigurationManager.AppSettings["signlen"] == null ? 0 : Int32.Parse(System.Configuration.ConfigurationManager.AppSettings["signlen"].ToString());
|
if ((smsContent.Length + sign) <= 70)
|
{
|
foreach (string str in phoneNumberArray)
|
{
|
if (checkPhoneNumberFormat(str))
|
{
|
SMS_MT_INFO smsInfo = new SMS_MT_INFO(priority, batchid, Guid.NewGuid().ToString(), str, '1', smsContent, subNumber, wapPushAddr, sendTime, 1, 1, NEED_DOWN_TIME: needdowntime);
|
result.Add(smsInfo);
|
}
|
}
|
}
|
else
|
{
|
Dictionary<int, string> dictionary = SplitSmsContent(smsContent, 0x43, sign);
|
foreach (string str2 in phoneNumberArray)
|
{
|
if (checkPhoneNumberFormat(str2))
|
{
|
foreach (KeyValuePair<int, string> pair in dictionary)
|
{
|
SMS_MT_INFO info2 = new SMS_MT_INFO(priority, batchid, Guid.NewGuid().ToString(), str2, '1', pair.Value, subNumber, wapPushAddr, sendTime, dictionary.Count, pair.Key);
|
result.Add(info2);
|
}
|
}
|
}
|
}
|
return result;
|
}
|
//public static void AddSMSInfo(string smsContent, string[] phoneNumberArray, string subNumber, string wapPushAddr, string sendTime, string subnumber, string needdowntime, int batchid,int priority)
|
//{
|
// int sign = System.Configuration.ConfigurationManager.AppSettings["signlen"] == null ? 0 : Int32.Parse(System.Configuration.ConfigurationManager.AppSettings["signlen"].ToString());
|
// if ((smsContent.Length + sign) <= 70)
|
// {
|
// foreach (string str in phoneNumberArray)
|
// {
|
// if (checkPhoneNumberFormat(str))
|
// {
|
// SMS_MT_INFO smsInfo = new SMS_MT_INFO(priority,batchid, Guid.NewGuid().ToString(), str, '1', smsContent, subNumber, wapPushAddr, sendTime, 1, 1, NEED_DOWN_TIME: needdowntime);
|
// AddSMSInfo(smsInfo);
|
// }
|
// }
|
// }
|
// else
|
// {
|
// Dictionary<int, string> dictionary = SplitSmsContent(smsContent, 0x43, sign);
|
// foreach (string str2 in phoneNumberArray)
|
// {
|
// if (checkPhoneNumberFormat(str2))
|
// {
|
// foreach (KeyValuePair<int, string> pair in dictionary)
|
// {
|
// SMS_MT_INFO info2 = new SMS_MT_INFO(priority, batchid, Guid.NewGuid().ToString(), str2, '1', pair.Value, subNumber, wapPushAddr, sendTime, dictionary.Count, pair.Key);
|
// AddSMSInfo(info2);
|
// }
|
// }
|
// }
|
// }
|
//}
|
|
public static void AddSMSInfo(string smsContent, string[] phoneNumberArray, string subNumber, string wapPushAddr, string sendTime, string subnumber, string needdowntime, int batchid, int priority)
|
{
|
//´Ë´¦²»³¤¶ÌÐŵķָî
|
foreach (string str in phoneNumberArray)
|
{
|
if (checkPhoneNumberFormat(str))
|
{
|
SMS_MT_INFO smsInfo = new SMS_MT_INFO(priority, batchid, Guid.NewGuid().ToString(), str, '1', smsContent, subNumber, wapPushAddr, sendTime, 1, 1, NEED_DOWN_TIME: needdowntime);
|
AddSMSInfo(smsInfo);
|
}
|
}
|
}
|
|
|
|
public static int AddReportWait(ReportInfo report, int ismg)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] {
|
DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, Guid.NewGuid().ToString()),
|
DBHelper.MakeInParam("@MSGID", SqlDbType.VarChar, 50, report.MSGID),
|
DBHelper.MakeInParam("@MOBILE_NO", SqlDbType.VarChar, 0x15, report.MOBILE_NO),
|
DBHelper.MakeInParam("@MOBILE_NO_TYPE", SqlDbType.Char, 1, ismg),
|
DBHelper.MakeInParam("@REPORT_SUCCESS", SqlDbType.VarChar, 1, Convert.ToInt32(report.SUCCESS)),
|
DBHelper.MakeInParam("@REPORT_TIME", SqlDbType.DateTime, 20, report.REPORT_TIME),
|
DBHelper.MakeInParam("@REPORT_STAT", SqlDbType.VarChar, 20, report.STAT) };
|
string commandText = "INSERT INTO SMS_REPORT_WAIT(GUID,MSGID,MOBILE_NO,MOBILE_NO_TYPE,REPORT_SUCCESS,REPORT_TIME,REPORT_STAT) VALUES(@GUID,@MSGID,@MOBILE_NO,@MOBILE_NO_TYPE,@REPORT_SUCCESS,@REPORT_TIME,@REPORT_STAT)";
|
return DBHelper.ExecuteNonQuery(CommandType.Text, commandText, commandParameters);
|
}
|
|
public static void Delete_MTWait_CM(string guid)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, guid) };
|
string commandText = "usp_del_MT_CM";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void Delete_MTWait_CU(string guid)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, guid) };
|
string commandText = "usp_del_MT_CU";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void Delete_MTWait_TEL(string guid)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, guid) };
|
string commandText = "usp_del_MT_TEL";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static DataTable GetItemList_MTWait_CM(int rows)
|
{
|
//first
|
|
string commandText = "usp_getMT_CM";
|
|
//log4netService.Info("»ñÈ¡´ý·¢ËÍÊý¾Ý£ºÐÐÊý:" + rows);
|
return DBHelper.ExecuteDataset(CommandType.StoredProcedure, commandText).Tables[0];
|
}
|
|
public static DataTable GetSendMsg()
|
{
|
string commandText = "usp_getSend";
|
return DBHelper.ExecuteDataset(CommandType.StoredProcedure, commandText).Tables[0];
|
}
|
public static void UpdateSendMsg(int batchid)
|
{
|
string commandText = "usp_updteSend";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText,
|
new SqlParameter[] { new SqlParameter("@batchid", batchid) });
|
|
}
|
public static void SendMTTOWait()
|
{
|
string commandText = @"usp_addMTTOWAIT";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText);
|
}
|
|
public static DataTable GetSendMsgNo(int batchid)
|
{
|
string commandText = "usp_getSendNo";
|
SqlParameter[] commandParameters = new SqlParameter[] { new SqlParameter("@batchid", batchid) };
|
return DBHelper.ExecuteDataset(CommandType.StoredProcedure, commandText, commandParameters).Tables[0];
|
|
}
|
|
private static Dictionary<int, string> SplitSmsContent(string smsContent, int eachSmsLength, int sign)
|
{
|
Func<char, int> func = null;
|
Dictionary<int, string> dict = new Dictionary<int, string>();
|
int i = -1;
|
int index = 0;
|
List<string> list = (from s in smsContent
|
group s by ++i / eachSmsLength into g
|
select new string(g.ToArray<char>())).ToList<string>();
|
string str = list[list.Count - 1];
|
if ((str.Length + sign) > 0x43)
|
{
|
if (func == null)
|
{
|
func = s => ++i / (eachSmsLength - sign);
|
}
|
List<string> list2 = (from g in Enumerable.GroupBy<char, int>(str, func) select new string(g.ToArray<char>())).ToList<string>();
|
list.RemoveAt(list.Count - 1);
|
foreach (string str2 in list2)
|
{
|
list.Add(str2);
|
}
|
}
|
list.ForEach(delegate(string s)
|
{
|
dict.Add(++index, s);
|
});
|
return dict;
|
}
|
|
|
public static void AddSMSInfo(DBFactory.SMS_MT_INFO smsInfo)
|
{
|
string commandText = @"usp_addSmsInfo";
|
SqlParameter[] commandParameters = new SqlParameter[] {
|
DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, smsInfo.Guid),
|
DBHelper.MakeInParam("@SERV_NO", SqlDbType.VarChar, 8, smsInfo.SubNumber),
|
DBHelper.MakeInParam("@MOBILE_NO", SqlDbType.VarChar, 0x15, smsInfo.PhoneNumber),
|
DBHelper.MakeInParam("@MOBILE_NO_TYPE", SqlDbType.Char, 1, smsInfo.MobileNoType),
|
DBHelper.MakeInParam("@SMS_CONTENT", SqlDbType.VarChar, 1000, smsInfo.SmsContent),
|
DBHelper.MakeInParam("@INTO_TIME", SqlDbType.DateTime, 50, smsInfo.SendTime),
|
DBHelper.MakeInParam("@WAPURL", SqlDbType.VarChar, 0xff, smsInfo.WapPushAddr),
|
DBHelper.MakeInParam("@MSGSUM", SqlDbType.Int, 0x10, smsInfo.MsgSum),
|
new SqlParameter("@LONG_SERV_NO",smsInfo.LONG_SERV_NO),
|
new SqlParameter("@SERV_CODE",smsInfo.SERV_CODE),
|
new SqlParameter("@NEED_DOWN_TIME",smsInfo.NEED_DOWN_TIME),
|
new SqlParameter("@batchid",smsInfo.BatchID),
|
new SqlParameter("@Priority",smsInfo.Priority),
|
DBHelper.MakeInParam("@MSGSUB", SqlDbType.Int, 0x10, smsInfo.MsgSub) };
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
|
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="smscontent"></param>
|
/// <param name="mobile"></param>
|
public static void SendSMS(string smscontent, string mobile)
|
{
|
string sql = @"
|
|
insert into SMS_send(smscontent,sendtime,submittime,subnumber,status)
|
values(@content,getdate(),GETDATE(),'01',0)
|
declare @batchid int
|
set @batchid=@@identity
|
--¸ü¶àµÄÊÖ»úºÅÂë
|
insert into [SMS_SEND_NO](batchid,mobileNo) values(@batchid,@mobile)";
|
SqlParameter[] commandParameters = new SqlParameter[] {
|
DBHelper.MakeInParam("@content", SqlDbType.VarChar, 500, smscontent),
|
DBHelper.MakeInParam("@mobile", SqlDbType.VarChar, 50, mobile)
|
};
|
DBHelper.ExecuteNonQuery(CommandType.Text, sql, commandParameters);
|
}
|
|
|
|
|
|
|
public static DataTable GetItemList_MTWait_CU(int rows)
|
{
|
string commandText = "usp_getMT_CU";
|
|
return DBHelper.ExecuteDataset(CommandType.StoredProcedure, commandText).Tables[0];
|
}
|
|
public static DataTable GetItemList_MTWait_TEL(int rows)
|
{
|
string commandText = "usp_getMT_TEL";
|
return DBHelper.ExecuteDataset(CommandType.StoredProcedure, commandText).Tables[0];
|
}
|
|
public static void Update_MTWait_CM(string guid, string out_gateway_id)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@OUT_GATEWAY_ID", SqlDbType.VarChar, 20, out_gateway_id), DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, guid) };
|
string commandText = "usp_updateCMWAIT";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void Update_MTWait_CM_REPLACE(string out_gateway_id_src, string out_gateway_id_des)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@OUT_GATEWAY_ID_DES", SqlDbType.VarChar, 20, out_gateway_id_des), DBHelper.MakeInParam("@OUT_GATEWAY_ID_SRC", SqlDbType.VarChar, 20, out_gateway_id_src) };
|
string commandText = "usp_updateCMWAITReplace";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void Update_MTWait_CU(string guid, string out_gateway_id)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@OUT_GATEWAY_ID", SqlDbType.VarChar, 20, out_gateway_id), DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, guid) };
|
string commandText = "usp_updateCU";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void Update_MTWait_CU_REPLACE(string out_gateway_id_src, string out_gateway_id_des)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@OUT_GATEWAY_ID_DES", SqlDbType.VarChar, 20, out_gateway_id_des), DBHelper.MakeInParam("@OUT_GATEWAY_ID_SRC", SqlDbType.VarChar, 20, out_gateway_id_src) };
|
string commandText = "usp_updateCUReplace";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void Update_MTWait_TEL(string guid, string out_gateway_id)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@OUT_GATEWAY_ID", SqlDbType.VarChar, 20, out_gateway_id), DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, guid) };
|
string commandText = "usp_updateTEL";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void Update_MTWait_TEL_REPLACE(string out_gateway_id_src, string out_gateway_id_des)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@OUT_GATEWAY_ID_DES", SqlDbType.VarChar, 20, out_gateway_id_des), DBHelper.MakeInParam("@OUT_GATEWAY_ID_SRC", SqlDbType.VarChar, 20, out_gateway_id_src) };
|
string commandText = "usp_updateTELReplace";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static int UpdateMTInfo(ReportInfo report)
|
{
|
|
//log4netService.Debug(Newtonsoft.Json.JsonConvert.SerializeObject(report));
|
|
if ((report.MOBILE_NO != null) && (report.MOBILE_NO.Length > 0))
|
{
|
//log4netService.Debug("start to running updatereortmobile...");
|
SqlParameter[] parameterArray = new SqlParameter[] {
|
DBHelper.MakeInParam("@REPORT_SUCCESS", SqlDbType.VarChar, 1, Convert.ToInt32(report.SUCCESS)),
|
DBHelper.MakeInParam("@REPORT_TIME", SqlDbType.DateTime, 20, report.REPORT_TIME),
|
DBHelper.MakeInParam("@REPORT_STAT", SqlDbType.VarChar, 20, report.STAT),
|
DBHelper.MakeInParam("@REPORT_DONWTIME", SqlDbType.VarChar, 20, report.DONE_TIME),
|
DBHelper.MakeInParam("@MSGID", SqlDbType.VarChar, 50, report.MSGID),
|
DBHelper.MakeInParam("@MOBILE_NO", SqlDbType.VarChar, 320, report.MOBILE_NO) };
|
//log4netService.Debug(Newtonsoft.Json.JsonConvert.SerializeObject(parameterArray));
|
string str = "usp_updateReportMobile";
|
return DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, str, parameterArray);
|
}
|
SqlParameter[] commandParameters = new SqlParameter[] {
|
DBHelper.MakeInParam("@REPORT_SUCCESS", SqlDbType.VarChar, 1, Convert.ToInt32(report.SUCCESS)),
|
DBHelper.MakeInParam("@REPORT_TIME", SqlDbType.DateTime, 20, report.REPORT_TIME),
|
DBHelper.MakeInParam("@REPORT_STAT", SqlDbType.VarChar, 20, report.STAT),
|
DBHelper.MakeInParam("@REPORT_DONWTIME", SqlDbType.VarChar, 20, report.DONE_TIME),
|
DBHelper.MakeInParam("@MSGID", SqlDbType.VarChar, 50, report.MSGID) };
|
string commandText = "usp_updateReport";
|
return DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
public static void UpdateMTInfo(SubmitInfo submit)
|
{
|
SqlParameter[] commandParameters = new SqlParameter[] { DBHelper.MakeInParam("@MSGID", SqlDbType.VarChar, 50, submit.RespMsgID),
|
DBHelper.MakeInParam("@FACT_DOWN_TIME", SqlDbType.DateTime, 20, submit.SubmitTime),
|
DBHelper.MakeInParam("@SUBMIT_RESULT", SqlDbType.Int, 0x20, submit.Result), DBHelper.MakeInParam("@SUBMIT_RESEND", SqlDbType.Int, 0x20, submit.ReSend), DBHelper.MakeInParam("@GUID", SqlDbType.VarChar, 50, submit.MTWait.Guid) };
|
string commandText = "usp_updateMTSubmit";
|
DBHelper.ExecuteNonQuery(CommandType.StoredProcedure, commandText, commandParameters);
|
}
|
|
|
public static void UpdateUnSendMsg()
|
{
|
string sql = "UPDATE SMS_MT_CM_WAIT set OUT_GATEWAY_ID=NULL,updatetime=getdate() where OUT_GATEWAY_ID IS NOT NULL and OUT_GATEWAY_ID!='' and datediff(mi,DOWN_TIME,getdate())>=5";
|
DBHelper.ExecuteNonQuery(CommandType.Text, sql);
|
}
|
|
public static Dictionary<int, string> SplitContent(string smsContent)
|
{
|
int sign = System.Configuration.ConfigurationManager.AppSettings["signlen"] == null ? 0 : Int32.Parse(System.Configuration.ConfigurationManager.AppSettings["signlen"].ToString());
|
return SplitSmsContent(smsContent, 0x43, sign);
|
}
|
|
public static bool checkSplitSMSContent(string smsContent)
|
{
|
int sign = System.Configuration.ConfigurationManager.AppSettings["signlen"] == null ? 0 : Int32.Parse(System.Configuration.ConfigurationManager.AppSettings["signlen"].ToString());
|
if ((smsContent.Length + sign) <= 70)
|
{
|
return false;
|
}
|
else
|
{
|
return true;
|
//Dictionary<int, string> dictionary = SplitSmsContent(smsContent, 0x43, sign);
|
}
|
}
|
}
|
}
|
