442 lines
14 KiB
C#
442 lines
14 KiB
C#
|
using System;
|
|||
|
|
using System.Collections.Concurrent;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.IO;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Messaging;
|
|||
|
|
using System.Net;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
using System.Xml;
|
|||
|
|
using System.Xml.Linq;
|
|||
|
|
using BLWWS_BLL;
|
|||
|
|
using ConsoleApp1;
|
|||
|
|
using Newtonsoft.Json;
|
|||
|
|
using RestSharp;
|
|||
|
|
|
|||
|
|
namespace ConsoleApp1
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
public class portinfo
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 名称
|
|||
|
|
/// </summary>
|
|||
|
|
public string LodgerNmae { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 身份证
|
|||
|
|
/// </summary>
|
|||
|
|
public string IDNumber { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 性别 0女 1男
|
|||
|
|
/// </summary>
|
|||
|
|
public Nullable<int> Sex { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 创建时间
|
|||
|
|
/// </summary>
|
|||
|
|
public Nullable<System.DateTime> CheckInDate { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 消息来源
|
|||
|
|
/// </summary>
|
|||
|
|
public int Sourcedian { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 图片
|
|||
|
|
/// </summary>
|
|||
|
|
public string picture { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 备注
|
|||
|
|
/// </summary>
|
|||
|
|
public string remark { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 图片时间
|
|||
|
|
/// </summary>
|
|||
|
|
public Nullable<System.DateTime> pictureDate { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 酒店code
|
|||
|
|
/// </summary>
|
|||
|
|
public string HotelCode { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 房间号
|
|||
|
|
/// </summary>
|
|||
|
|
public string roomid { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 电话号码
|
|||
|
|
/// </summary>
|
|||
|
|
public string phonenumber { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 开房时间
|
|||
|
|
/// </summary>
|
|||
|
|
public DateTime CheckTime { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 退房时间
|
|||
|
|
/// </summary>
|
|||
|
|
public DateTime checkOutTime { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 密钥
|
|||
|
|
/// </summary>
|
|||
|
|
public string key { get; set; }
|
|||
|
|
public int pmsinfoid { get; set; }
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
public class XMSData
|
|||
|
|
{
|
|||
|
|
public string hotelid { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 订单账号（酒店唯一）
|
|||
|
|
/// </summary>
|
|||
|
|
public string accnt { get; set; }
|
|||
|
|
|
|||
|
|
public string groupid { get; set; }
|
|||
|
|
public string name { get; set; }
|
|||
|
|
public Dictionary<string, string> original { get; set; }
|
|||
|
|
public extrasData extras { get; set; }
|
|||
|
|
}
|
|||
|
|
public class originalData
|
|||
|
|
{
|
|||
|
|
//public string name { get; set; }
|
|||
|
|
//public string mobile { get; set; }
|
|||
|
|
//public string roomno { get; set; }
|
|||
|
|
//public string type { get; set; }
|
|||
|
|
//public string rtc { get; set; }
|
|||
|
|
//public string rmnum { get; set; }
|
|||
|
|
//public string sta { get; set; }
|
|||
|
|
}
|
|||
|
|
// "arr":"1750586400000",
|
|||
|
|
// "rtc":"CPC",
|
|||
|
|
// "sta":"R",
|
|||
|
|
// "rmnum":"1",
|
|||
|
|
// "roomno":"",
|
|||
|
|
// "mobile":"1212345678",
|
|||
|
|
// "name":"李二",
|
|||
|
|
// "type":"CPC",
|
|||
|
|
// "dep":"1750651200000"
|
|||
|
|
public class extrasData
|
|||
|
|
{
|
|||
|
|
public string name { get; set; }
|
|||
|
|
public string mobile { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 房间号
|
|||
|
|
/// </summary>
|
|||
|
|
public string roomno { get; set; }
|
|||
|
|
public string type { get; set; }
|
|||
|
|
public string rtc { get; set; }
|
|||
|
|
public string rmnum { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 订单状态
|
|||
|
|
///Q：问询
|
|||
|
|
///X：取消预订
|
|||
|
|
///N：noshow
|
|||
|
|
///R：预订
|
|||
|
|
///I：在住
|
|||
|
|
///O：本日结账
|
|||
|
|
///S：挂账退房
|
|||
|
|
///D：昨日结账
|
|||
|
|
///H：历史订单
|
|||
|
|
/// </summary>
|
|||
|
|
public string sta { get; set; }
|
|||
|
|
public string arr { get; set; }
|
|||
|
|
public string dep { get; set; }
|
|||
|
|
}
|
|||
|
|
internal class Program
|
|||
|
|
{
|
|||
|
|
public static long GetCurrentTimeStamp(DateTime dt)
|
|||
|
|
{
|
|||
|
|
TimeSpan ts = dt - new DateTime(1970, 1, 1, 8, 0, 0, DateTimeKind.Local);
|
|||
|
|
long current_timestamp = Convert.ToInt64(ts.TotalSeconds);
|
|||
|
|
return current_timestamp;
|
|||
|
|
}
|
|||
|
|
public class PMSDataBase
|
|||
|
|
{
|
|||
|
|
public string hotel_code { get; set; } = "";
|
|||
|
|
public string time { get; set; } = "";
|
|||
|
|
public string sign { get; set; } = "";
|
|||
|
|
public string hotel_id { get; set; } = "";
|
|||
|
|
public string order_no { get; set; } = "";
|
|||
|
|
public string room_no { get; set; } = "";
|
|||
|
|
public string check_out_original { get; set; }
|
|||
|
|
}
|
|||
|
|
static void Main(string[] args)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
var DQQQ = File.ReadAllText("1.txt");
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
//<items><item customer="安赞同" idcard="2110**********222X" sex="女" country="0" checkindate="2025-06-19 16:26:14" checkoutdate="2025-06-20 12:00:00"/></items>
|
|||
|
|
|
|||
|
|
XDocument doc32 = XDocument.Parse(DQQQ);
|
|||
|
|
XElement Root1 = doc32.Root;
|
|||
|
|
string orderno = Root1.Attribute("orderno")?.Value;
|
|||
|
|
string cost = Root1.Attribute("cost")?.Value;
|
|||
|
|
|
|||
|
|
//是否有早餐
|
|||
|
|
string breakfast = Root1.Attribute("breakfast")?.Value;
|
|||
|
|
//押金
|
|||
|
|
string deposit = Root1.Attribute("deposit")?.Value;
|
|||
|
|
|
|||
|
|
var LESuuu = Root1.Elements("item");
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
var NNNjkl = JsonConvert.DeserializeObject<Dictionary<string, Dictionary<string, object>>>(DQQQ);
|
|||
|
|
PMSDataBase data = new PMSDataBase()
|
|||
|
|
{
|
|||
|
|
hotel_code = "2079",
|
|||
|
|
time = "1751426235",
|
|||
|
|
sign = "a68b2596ce7c1ca970e82a00626c16e3",
|
|||
|
|
hotel_id = "1101",
|
|||
|
|
order_no = "",
|
|||
|
|
room_no = "1102",
|
|||
|
|
check_out_original = ""
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
string BaseURL = "https://f.blv-oa.com:8099/rcu_pms_api/v1";
|
|||
|
|
var client123 = new RestClient(BaseURL);
|
|||
|
|
var request123 = new RestRequest("/order/checkOut", Method.POST);
|
|||
|
|
request123.AddJsonBody(data);
|
|||
|
|
var Response = client123.Execute(request123).Content;
|
|||
|
|
string content12345 = Response;
|
|||
|
|
|
|||
|
|
|
|||
|
|
long lllhhh = GetCurrentTimeStamp(DateTime.Now);
|
|||
|
|
decimal DDD = Convert.ToDecimal(32432423.34343);
|
|||
|
|
decimal lll = DDD / 1024;
|
|||
|
|
decimal a = Math.Round(lll, 2);
|
|||
|
|
Console.WriteLine("aaaaaaaaaaaa");
|
|||
|
|
|
|||
|
|
string content = "";
|
|||
|
|
|
|||
|
|
|
|||
|
|
string PPP = File.ReadAllText("3.txt");
|
|||
|
|
byte[] photo = Tools.HEXString2ByteArray(PPP);
|
|||
|
|
|
|||
|
|
//分辨率 判断
|
|||
|
|
using (var ms = new MemoryStream(photo))
|
|||
|
|
{
|
|||
|
|
ms.Write(photo, 0, photo.Length);
|
|||
|
|
using (System.Drawing.Image image = System.Drawing.Image.FromStream(ms, false, false)) // 不加载图像数据
|
|||
|
|
{
|
|||
|
|
bool bf = image.RawFormat.Equals(System.Drawing.Imaging.ImageFormat.Jpeg);
|
|||
|
|
Console.WriteLine(image.Height);
|
|||
|
|
Console.WriteLine(image.Width);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
string sss111 = File.ReadAllText("3.txt");
|
|||
|
|
var OOO = JsonConvert.DeserializeObject<XMSData>(sss111);
|
|||
|
|
string Url111 = "http://pms.boonlive-rcu.com:8989";
|
|||
|
|
var client1 = new RestClient(Url111);
|
|||
|
|
//var request1 = new RestRequest("api/XMSOrderPush?xrsecret=Ip202rSR132zJGKH", Method.POST);
|
|||
|
|
var request1 = new RestRequest("api/XMSOrderPush", Method.POST);
|
|||
|
|
request1.AddQueryParameter("xrsecret", "Ip202rSR132zJGKH");
|
|||
|
|
request1.AddJsonBody(OOO);
|
|||
|
|
var response = client1.Execute(request1);
|
|||
|
|
var content111 = response.Content;
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
////string url = "http://face.blv-oa.com/Interface/checkinInterface?key=abc&data={"LodgerNmae":"王悦","IDNumber":"1133397752487743488","Sex":0,"picture":"http://pms.boonlive-rcu.com:89/pic/1133397752487743488_1384391.jpg","HotelCode":"2079","roomid":"1906","phonenumber":"19847388255","CheckTime":"2025-06-20 11:19:04","pmsinfoid":1905524}";
|
|||
|
|
//string url = File.ReadAllText("2.txt");
|
|||
|
|
//var NNN1= JsonConvert.DeserializeObject<portinfo>(url);
|
|||
|
|
|
|||
|
|
//return;
|
|||
|
|
//var client1 = new RestClient(url);
|
|||
|
|
//var request1 = new RestRequest(Method.POST);
|
|||
|
|
//request1.AddJsonBody(null);
|
|||
|
|
//var Response = client1.Execute(request1).Content;
|
|||
|
|
//content = Response;
|
|||
|
|
|
|||
|
|
//string result = string.Empty;
|
|||
|
|
//HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
|
|||
|
|
//req.ContentType = "application/json";
|
|||
|
|
//req.Method = "POST";
|
|||
|
|
////req.Timeout = 10000;//设置请求超时时间，单位为毫秒
|
|||
|
|
//byte[] data = Encoding.UTF8.GetBytes("");
|
|||
|
|
//req.ContentLength = data.Length;
|
|||
|
|
//using (Stream reqStream = req.GetRequestStream())
|
|||
|
|
//{
|
|||
|
|
// reqStream.Write(data, 0, data.Length);
|
|||
|
|
//}
|
|||
|
|
//HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
|
|||
|
|
//using (Stream stream = resp.GetResponseStream())
|
|||
|
|
//{
|
|||
|
|
// using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
|
|||
|
|
// {
|
|||
|
|
// result = reader.ReadToEnd();//获取响应内容
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
}
|
|||
|
|
Console.ReadKey();
|
|||
|
|
|
|||
|
|
|
|||
|
|
string xmlString = File.ReadAllText("1.txt");
|
|||
|
|
XDocument doc1 = XDocument.Parse(xmlString);
|
|||
|
|
XElement Root = doc1.Root;
|
|||
|
|
string NNN = Root.Attribute("orderno")?.Value;
|
|||
|
|
|
|||
|
|
var LES = Root.Elements("item");
|
|||
|
|
foreach (var item in LES)
|
|||
|
|
{
|
|||
|
|
string customer = item.Attribute("customer").Value;
|
|||
|
|
string sex = item.Attribute("sex").Value;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
//ServiceReference1.blwwsSoapClient c = new ServiceReference1.blwwsSoapClient();
|
|||
|
|
//c.Test();
|
|||
|
|
//string token = GetToken_G();
|
|||
|
|
//Console.WriteLine(token);
|
|||
|
|
//ConcurrentDictionary<string, string> GlobalData = new ConcurrentDictionary<string, string>();
|
|||
|
|
//GlobalData.AddOrUpdate("A", token, (k, v) => { return token; });
|
|||
|
|
//GlobalData.AddOrUpdate("A", token, (k, v) => { return token; });
|
|||
|
|
//GlobalData.AddOrUpdate("A", token, (k, v) => { return token; });
|
|||
|
|
//GlobalData.AddOrUpdate("A", token, (k, v) => { return token; });
|
|||
|
|
Console.ReadKey();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
static public string UserCode = "KKJK";
|
|||
|
|
static public string UserKey = "KKJK0428";
|
|||
|
|
static public string BaseUrl = "https://armitage-ipms.shijicloud.com";
|
|||
|
|
public static string GetToken_G()
|
|||
|
|
{
|
|||
|
|
Dictionary<string, string> Params = new Dictionary<string, string>();
|
|||
|
|
Params.Add("userCode", UserCode);
|
|||
|
|
Params.Add("key", UserKey);
|
|||
|
|
|
|||
|
|
var tokenstr = Send_Http_Request_Params("/iPMSAPI/iPMSApiService/api/applySecurityToken", Params);
|
|||
|
|
|
|||
|
|
Console.WriteLine(tokenstr);
|
|||
|
|
if (!string.IsNullOrEmpty(tokenstr))
|
|||
|
|
{
|
|||
|
|
var dic = JsonConvert.DeserializeObject<Dictionary<string, string>>(tokenstr);
|
|||
|
|
string token = dic["securityToken"];
|
|||
|
|
return token;
|
|||
|
|
}
|
|||
|
|
return "";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public static string Send_Http_Request_Params(string Url, Dictionary<string, string> Params)
|
|||
|
|
{
|
|||
|
|
var client1 = new RestClient(BaseUrl);
|
|||
|
|
var request1 = new RestRequest(Url, Method.POST);
|
|||
|
|
|
|||
|
|
foreach (KeyValuePair<string, string> item in Params)
|
|||
|
|
{
|
|||
|
|
request1.AddParameter(item.Key, item.Value);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var response = client1.Execute(request1);
|
|||
|
|
var content = response.Content;
|
|||
|
|
return content;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
public static string queueName2 = @".\private$\faceServerToWeb";
|
|||
|
|
public static MessageQueue mq2 = null;
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 从消息队列中读取命令，并执行
|
|||
|
|
/// </summary>
|
|||
|
|
public static void ReceiveCmdLoop()
|
|||
|
|
{
|
|||
|
|
while (true)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
//判断队列是否存在
|
|||
|
|
if (MessageQueue.Exists(queueName2))
|
|||
|
|
{
|
|||
|
|
mq2 = new MessageQueue(queueName2);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
//创建队列
|
|||
|
|
mq2 = MessageQueue.Create(queueName2);
|
|||
|
|
}
|
|||
|
|
//给管理员队列权力
|
|||
|
|
mq2.SetPermissions("Administrator", MessageQueueAccessRights.FullControl);
|
|||
|
|
//匿名登录
|
|||
|
|
mq2.SetPermissions("ANONYMOUS LOGON", MessageQueueAccessRights.FullControl);
|
|||
|
|
mq2.SetPermissions("Everyone", MessageQueueAccessRights.FullControl);
|
|||
|
|
|
|||
|
|
while (true)
|
|||
|
|
{
|
|||
|
|
Message msgRx = mq2.Receive();
|
|||
|
|
msgRx.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
|
|||
|
|
|
|||
|
|
string strRx = msgRx.Body.ToString();
|
|||
|
|
|
|||
|
|
|
|||
|
|
Thread.Sleep(1300); //阻塞当前线程1秒，让其他线程运行
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
Thread.Sleep(5000); //阻塞当前线程5秒，再重新启动
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 向消息队列中发送消息
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="sendMsg">消息</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public static string QueueSend(string sendMsg)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
if (mq2 == null)
|
|||
|
|
{
|
|||
|
|
if (MessageQueue.Exists(queueName2))
|
|||
|
|
{
|
|||
|
|
mq2 = new MessageQueue(queueName2);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
mq2 = MessageQueue.Create(queueName2);
|
|||
|
|
}
|
|||
|
|
mq2.SetPermissions("Administrator", MessageQueueAccessRights.FullControl);
|
|||
|
|
mq2.SetPermissions("ANONYMOUS LOGON", MessageQueueAccessRights.FullControl);
|
|||
|
|
mq2.SetPermissions("Everyone", MessageQueueAccessRights.FullControl);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
Message msgTx = new Message
|
|||
|
|
{
|
|||
|
|
Body = "",
|
|||
|
|
Formatter = new XmlMessageFormatter(new Type[] { typeof(string) })
|
|||
|
|
};
|
|||
|
|
mq2.Send(msgTx);
|
|||
|
|
return "Succeed push msg to MQ !";
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
mq2 = null;
|
|||
|
|
return ex.ToString();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|