wyk/juipnet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

麒麟动态

Browse Source
This commit is contained in:
“wanyongkang”
2024-01-17 14:21:23 +08:00
parent a6f40cd80d
commit b342c64fdb
10 changed files with 494 additions and 254 deletions
Download Patch File Download Diff File Expand all files Collapse all files

430
Services/Hncore.Pass.Vpn/Service/AgentClient4Service.cs
View File

@@ -14,6 +14,9 @@ using System.Linq;
using System.Net;
using System.Net.Http;
using System.Threading.Tasks;
using System.Security.Cryptography;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
namespace Hncore.Pass.Vpn.Service
{
//金桥
@@ -112,35 +115,39 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<ApiResult> NewAccount(string packageKey, string account, string pwd, int connCount = 1, int accountType = 1, int payCount = 1)
{
var client = CreateHttpClient();
var map = new Dictionary<string, string>(){
{"taocanName",packageKey },
{"username",account },
{"password",pwd },
{"maxonline",connCount.ToString()},
{"type",accountType.ToString()}
};
var title = GetOpTitle("NewAccount", account);
LogHelper.Info(title, map.ToJson());
try
{
var resp = await client.PostAsForm(this.SingleAddUrl, map);
var content = await resp.Content.ReadAsStringAsync();
if (content.Has() && content.IndexOf("{alert(\"成功\")") != -1)
{
return new ApiResult(ResultCode.C_SUCCESS);
}
else
{
LogHelper.Error(title, content);
return new ApiResult(ResultCode.C_INVALID_ERROR, "开户失败");
}
var width = "";
var combos = "";
if(packageKey.Contains("-")){
string[] arrStr = packageKey.Split('-');
width = arrStr[0];
combos = arrStr[1];
}
catch (Exception ex)
Dictionary<string, string> map = new Dictionary<string, string>(){
{"width",width },
{"combos",combos },
{"account",account },
{"password",pwd },
{"conn_max",connCount.ToString() },
{"t_id","666" },
};
map = signAct(map);
var client = CreateHttpClient();
var resp = await client.PostAsForm("https://www.ip6b.com/openapi/Create_Dynamic", map);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
if (status == "200")
{
return new ApiResult(ResultCode.C_SUCCESS);
}
else
{
LogHelper.Error(title, ex.Message);
return new ApiResult(ResultCode.C_INVALID_ERROR, "开户失败");
}
}
/// <summary>
@@ -194,31 +201,32 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<ApiResult> NewReAccount(string packageKey, string account, int connCount, int payCount = 1)
{
var client = CreateHttpClient();
var map = new Dictionary<string, string>(){
{"taocanName",packageKey },
{"username",account },
{"iscz","3" },
};
var title = GetOpTitle("NewReAccount", account);
LogHelper.Info(title, map.ToJson());
try
{
var resp = await client.PostAsForm(this.SingleReAddUrl, map);
var content = await resp.Content.ReadAsStringAsync();
if (content.Has() && content.IndexOf("alert(\"成功\")") != -1)
{
return new ApiResult(1);
}
else
{
LogHelper.Error(title, content);
return new ApiResult(ResultCode.C_INVALID_ERROR, "续费失败");
}
var width = "";
var combos = "";
if(packageKey.Contains("-")){
string[] arrStr = packageKey.Split('-');
width = arrStr[0];
combos = arrStr[1];
}
catch (Exception ex)
Dictionary<string, string> map = new Dictionary<string, string>(){
{"combos",combos },
{"account",account },
};
map = signAct(map);
var client = CreateHttpClient();
var resp = await client.PostAsForm("https://www.ip6b.com/openapi/Renew_Dynamic", map);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
if (status == "200")
{
return new ApiResult(1);
}
else
{
LogHelper.Error(title, ex.Message);
return new ApiResult(ResultCode.C_INVALID_ERROR, "续费失败");
}
}
@@ -266,86 +274,21 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<ApiResult<OriginAccountModel>> GetAccountInfo(string account,bool isTest=false)
{
var client = CreateHttpClient();
var title = GetOpTitle("GetAccountInfo", account);
var info = "";
try
{
var url = this.searchAccountUrl + account;
if (isTest)
var trData = new OriginAccountModel
{
url = this.searchTestAccountUrl + account;
}
var resp = await client.GetAsync(url);
var content = await resp.Content.ReadAsStringAsync();
var parser = new HtmlParser();
var document = await parser.ParseDocumentAsync(content);
////table class="table table-bordered"
var trs = document.QuerySelectorAll("table.table tr").ToList();
// var trs= table.QuerySelectorAll("tr").ToList();
var retData = new List<OriginAccountModel>();
if (trs.Count() > 1)
{
//var tr = trs.Skip(1).FirstOrDefault();
foreach(var tr in trs.Skip(1))
{
var tds = tr.QuerySelectorAll("td").ToList();
var tdAccount = tds[1].FirstChild.TextContent;
if (tdAccount != account)
continue;
info = string.Join("", tds.Select(m => m.OuterHtml));
//<td >会员账号</td><td >类型</td><td >套餐</td><td >注册日期 过期日期</td><td>专线IP </td><td >连接数</td><td >余额</td><td >激活</td><td >备注</td>
var dateText = tds[4].InnerHtml;
var endtext = dateText.Split("<br>")[1].Split('\n');
var trData = new OriginAccountModel
{
Account = account,
Pwd = tds[1].QuerySelector("font").TextContent,
AccountType = tds[2].TextContent,
Package = tds[3].TextContent,
RegistTime = dateText.Split("<br>")[0],
EndTime = endtext[0].Replace("\n", "").Replace("\t", ""),
RestTime = endtext[1].Replace("\n", "").Replace("\t", ""),
ConnectCount = tds[6].TextContent,
Amount = tds[7].TextContent,
IsActive = tds[8].TextContent,
Remark = tds[9].TextContent,
};
trData.RealEndTime = DateTime.Parse(trData.EndTime);
if (trData.RestTime.Contains("已过期"))
{
trData.RestTime = "已过期";
}else
{
// "6.14:32"
var timeStr = trData.RestTime.Replace("天", ".").Replace("时", ":").Replace("分", "");
var restTime = TimeSpan.Parse(timeStr);
trData.RealEndTime = DateTime.Now.Add(restTime);
}
var href = tr.LastElementChild.QuerySelector("a")?.Attributes["href"]?.Value;
if (href.Has())
{
var start = href.LastIndexOf('/');
var end = href.IndexOf(".html");
if (start != -1 && end != -1)
{
trData.Id = href.Substring(start + 1, end - start).TrimEnd('.');
}
}
return new ApiResult<OriginAccountModel>(trData);
}
}
}
catch (Exception ex)
{
LogHelper.Error(title, ex.Message+"-->info:"+ info);
return new ApiResult<OriginAccountModel>(ResultCode.C_INVALID_ERROR, "查询失败");
}
Id = "",
Account = account,
Pwd = "",
AccountType = "",
Package = "",
ConnectCount = "",
RegistTime = "",
EndTime = "",
RestTime = "",
Amount = "",
Remark = "",
};
return new ApiResult<OriginAccountModel>(trData);
return new ApiResult<OriginAccountModel>(ResultCode.C_INVALID_ERROR, "没有查询到信息");
@@ -359,41 +302,27 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<bool> UpdateAccountPwd(string account, string pwd)
{
var ret = await this.GetAccountInfo(account);
if (ret.Code != ResultCode.C_SUCCESS)
{
return false;
}
var accountModel = ret.Data;
if (accountModel == null)
{
return false;
}
var client = CreateHttpClient();
var map = new Dictionary<string, string>(){
{"username",account },
{"password",pwd },
{"submit","提交" },
Dictionary<string, string> map = new Dictionary<string, string>(){
{"password",pwd },
{"account",account },
};
LogHelper.Info(GetOpTitle("UpdateAccountPwd", account), map.ToJson());
try
map = signAct(map);
var client = CreateHttpClient();
var resp = await client.PostAsForm("https://www.ip6b.com/openapi/Reset_Password_Dynamic", map);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
if (status == "200")
{
var resp = await client.PostAsForm(this.UpdateUrl + accountModel.Id + ".html", map);
var content = await resp.Content.ReadAsStringAsync();
if (content.Has() && content.IndexOf("更新成功") != -1)
{
return true;
}
else
{
LogHelper.Error(GetOpTitle("UpdateAccountPwd", account), content);
}
return true;
}
catch (Exception ex)
else
{
LogHelper.Error(GetOpTitle("UpdateAccountPwd", account), ex);
return false;
}
return false;
}
/// <summary>
/// 退款
@@ -403,30 +332,24 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<ApiResult> Refund(string account, string packageKey, int days)
{
var client = CreateHttpClient();
var map = new Dictionary<string, string>(){
{"refundUser",account },
{"refundReason","hl" },
Dictionary<string, string> map = new Dictionary<string, string>(){
{"account",account },
};
var title = GetOpTitle("Refund", account);
LogHelper.Info(title, map.ToJson());
try
map = signAct(map);
var client = CreateHttpClient();
var resp = await client.PostAsForm("https://www.ip6b.com/openapi/Refount_Account_Order", map);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
if (status == "200")
{
var resp = await client.PostAsForm(this.RefundUrl, map);
var content = await resp.Content.ReadAsStringAsync();
if (content.Has() && content.IndexOf("alert(\"退款成功\")") != -1)
{
return new ApiResult(1);
}
else
{
LogHelper.Error(title, content);
return new ApiResult(ResultCode.C_INVALID_ERROR, "退款失败");
}
return new ApiResult(1);
}
catch (Exception ex)
else
{
LogHelper.Error(title, ex.Message);
return new ApiResult(ResultCode.C_INVALID_ERROR, "退款失败");
}
}
@@ -438,50 +361,50 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<ApiResult<List<OriginAccountOnlineModel>>> OnLine(string account)
{
//虚拟在线
var onlines = await base.OnLine(account);
Dictionary<string, string> map = new Dictionary<string, string>(){
{"account",account },
{"page","1" },
{"page_count","100" },
};
if (onlines.Code == ResultCode.C_SUCCESS && onlines.Data.Count > 0)
return onlines;
var retData = new List<OriginAccountOnlineModel>();
var client = CreateHttpClient();
int page = 1;
var url = string.Format(this.ClientOnlineUrl, page);
var resp = await client.GetAsync(url);
map = signAct(map);
var client = CreateHttpClient();
var resp = await client.PostAsForm("https://www.ip6b.com/openapi/Get_Dynamic_Online", map);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
var parser = new HtmlParser();
var document = await parser.ParseDocumentAsync(content);
var table = document.QuerySelectorAll("table");
var pageP = table?.Next("p")?.FirstOrDefault();
if (pageP != null)
var retData = new List<OriginAccountOnlineModel>();
if (status == "200")
{
var total = 0;
if (pageP.TextContent.Has())
foreach (var tr in jo["res"]["data"])
{
var start = pageP.TextContent.IndexOf('(');
var end = pageP.TextContent.IndexOf("页)");
var pageStr = pageP.TextContent.Substring(start + 2, end - start - 1);
int.TryParse(pageStr, out total);
}
if (total > 1)
{
await Enumerable.Range(1, total).ForEachAsync(async (int i) =>
JObject jsondata = (JObject)JsonConvert.DeserializeObject(tr.ToJson());
var trData = new OriginAccountOnlineModel
{
var ret = await ClientOnLine(account, i);
retData.AddRange(ret);
});
}
else
{
retData = await ClientOnLine(account, 1);
Account = account,
ServerIP = "",
LoginTime = "",
OnlineTime = "",
LoginIP = jsondata["user_ip"].ToString(),
UpStream = "",
DownStream = "",
Id= jsondata["id"].ToString(),
};
retData.Add(trData);
}
return new ApiResult<List<OriginAccountOnlineModel>>(retData);
}
else
{
retData = await ClientOnLine(account, 1);
return new ApiResult<List<OriginAccountOnlineModel>>(ResultCode.C_INVALID_ERROR, "查询失败");
}
return new ApiResult<List<OriginAccountOnlineModel>>(retData);
}
public async Task<List<OriginAccountOnlineModel>> ClientOnLine(string account,int page=1)
@@ -546,25 +469,24 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<bool> KillOut( string id)
{
var flag = await base.KillOut(id);
if (flag) return true;
Dictionary<string, string> map = new Dictionary<string, string>(){
{"sid",id },
};
var client = CreateHttpClient();
var title = GetOpTitle("KillOut", id);
var info = "";
try
map = signAct(map);
var client = CreateHttpClient();
var resp = await client.PostAsForm("https://www.ip6b.com/openapi/Kick_Off_Dynamic_Line", map);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
var retData = new List<OriginAccountOnlineModel>();
if (status == "200")
{
var url = string.Format(this.KillUrlClient, id);
var resp = await client.GetAsync(url);
var content = await resp.Content.ReadAsStringAsync();
if (content.Has() && content.IndexOf("已经向客户端发送断开消息") != -1)
{
return true;
}
}
catch (Exception ex)
{
LogHelper.Error(title, ex.Message + "-->info:" + info);
return true;
}
return false;
}
@@ -576,16 +498,54 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<bool> Exist(string account)
{
var client = CreateHttpClient();
var title = GetOpTitle("Exist", account);
LogHelper.Info(title, account);
var testRet = await this.NewAccount("free", account, "1234", 1, 0);
if (testRet.Code == ResultCode.C_SUCCESS)
{
await DeleteAccount(account);
Dictionary<string, string> map = new Dictionary<string, string>();
map.Add("account", account);
map = signAct(map);
var client = CreateHttpClient();
var resp = await client.PostAsForm("https://www.ip6b.com/openapi/Dynamic_Account_Exists", map);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
if (jo["code"].ToString() == "404") {
return false;
}
}
return true;
}
private static Dictionary<string, string> signAct(Dictionary<string, string> body)
{
var authStr="";
body.Add("st",DateTime.Now.GetUnixTimeStamp().ToString());
body.Add("appid","49330ae23dad78f9");
body = body.OrderBy(kv => kv.Key).ToDictionary(kv => kv.Key, p => p.Value);
foreach (var item in body)
{
authStr=authStr+item.Value;
}
body.Add("sign",Md5(Md5(authStr)+"ddb4311a227fb118cacd63cc68416ab5"));
return body;
}
//Md5摘要
private static string Md5(string text)
{
MD5 md5 = new MD5CryptoServiceProvider();
byte[] fromData = System.Text.Encoding.UTF8.GetBytes(text);
byte[] targetData = md5.ComputeHash(fromData);
string byte2String = null;
for (int i = 0; i < targetData.Length; i++)
{
byte2String += targetData[i].ToString("x2");
}
return byte2String;
}
}
}