using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.IO;
using System.Data;
using Oracle.ManagedDataAccess.Client;
using System.Text.RegularExpressions;
namespace ConsoleApp1
{
class Program
{
static void Main(string[] args)
{
string ConnectionString = "這里是連接沒有問題";//寫連接串
OracleConnection conn = new OracleConnection(ConnectionString);//創建一個新連接
try
{
conn.Open();
OracleCommand cmd = new OracleCommand(" select a.phone_no AS NO,a.message as sms , a.mess_id as fsid ,a.item_no as itno from message_rec_temp a where a.send_flag ='0'and a.send_way ='平臺1'", conn);
OracleDataAdapter sda = new OracleDataAdapter(cmd);
DataTable ds = new DataTable();
sda.Fill(ds);
Console.WriteLine(ds.Rows.Count);
for (int i = 0; i < ds.Rows.Count; i++)
{
Console.WriteLine(i);
Console.WriteLine(ds.Rows[i][0]);
Console.WriteLine(ds.Rows[i][1]);
string MobileNum = ds.Rows[i][0].ToString();
string content = ds.Rows[i][1].ToString();
string mseid = ds.Rows[i][2].ToString();
string itno = ds.Rows[i][3].ToString();
//Text.PostSendMessage(MobileNum, content);
// DateTime dt = DateTime.Now;
// string dt24 = dt.ToString("yyyy-MM-dd HH:mm:ss");
string reas = Text.PostSendMessage(MobileNum, content);
// string reas = "result=0&description=發送短信成功&taskid=10111820286222";
Console.WriteLine(reas);
string[] strArray = reas.Split(new string[] { "&", "&" }, StringSplitOptions.RemoveEmptyEntries);
Console.WriteLine(strArray[1]);
bool isContains = true;
if (strArray[1].Contains("成功"))
{
isContains = true;
}
else
{
isContains = false;
}
//var index = StringA.IndexOf("result=0")；
// bool isContains = reas.IndexOf("成功", StringComparison.OrdinalIgnoreCase) > 0;//true a.send_datetime =sysdate
if (isContains is true)
{
cmd.CommandText = "update message_rec_temp a set a.send_datetime = sysdate, a.send_flag ='1', a.memo= '" + reas + "' where a.phone_no ='" + MobileNum + "'and a.mess_id ='" + mseid + "'and a.ITEM_NO ='" + itno + "' and a.send_flag='0'";
cmd.ExecuteNonQuery();
Console.WriteLine("成功包含");
}
else
{
cmd.CommandText = " update message_rec_temp a set a.memo= '" + reas + "' where a.PHONE_NO ='" + MobileNum + "'and a.MESS_ID ='" + mseid + "' and a.send_flag='0'";
cmd.ExecuteNonQuery();
}
}
Console.ReadKey();
}
catch (Exception ee)
{
//System.Diagnostics.Debug.WriteLine(ee.Message); //如果有錯誤，輸出錯誤資訊
Console.WriteLine(ee.Message);
}
finally
{
conn.Close(); //關閉連接
}
}
class Text//發送這里也是正常的
{
public static string PostSendMessage(string MobileNum, string content)
{
string url = "http://js.ums86.com:8899/sms/Api/Send.do";
string Spcode = ""; //企業賬號
string LoginName = ""; //用戶名
string Password = ""; //密碼
string MessageContent = content; //短信內容
string UserNumber = MobileNum; //手機號
string SerialNumber = DateTime.Now.ToString("yyyyMMddHHmmssfff") + "001"; //流水號
string ScheduleTime = ""; //預約發送時間
string ExtendAccessNum = ""; //接入號擴展號
StringBuilder sb = new StringBuilder();
sb.Append("SpCode=" + Spcode + "&LoginName=" + LoginName + "&Password=" + Password + "&MessageContent=" + MessageContent + "&UserNumber=" + UserNumber + "&SerialNumber=" + SerialNumber + "&ScheduleTime=" + ScheduleTime + "&ExtendAccessNum=" + ExtendAccessNum + "&f=1");
byte[] bData = Encoding.GetEncoding("GBK").GetBytes(sb.ToString());
HttpWebRequest hwRequest;
HttpWebResponse hwResponse;
string strResult = string.Empty;
try
{
hwRequest = (HttpWebRequest)WebRequest.Create(url);
hwRequest.Method = "POST";
hwRequest.ContentType = "application/x-www-form-urlencoded";
hwRequest.ContentLength = bData.Length;
Stream smWrite = hwRequest.GetRequestStream();
smWrite.Write(bData, 0, bData.Length);
smWrite.Close();
hwResponse = (HttpWebResponse)hwRequest.GetResponse();
StreamReader srReader = new StreamReader(hwResponse.GetResponseStream(), Encoding.Default);
strResult = srReader.ReadToEnd();
srReader.Close();
hwResponse.Close();
}
catch
{; }
return strResult;
}
}
}
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/263939.html
標籤：開發
上一篇：Let R be a relation with attributes ABCD. Consider the SQL conjunctive query
下一篇：mysql索引