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

通知及下架禁止开通

Browse Source
This commit is contained in:
“wanyongkang”
2021-09-25 17:44:19 +08:00
parent fd04ec0d5a
commit 478adb6831
5 changed files with 55 additions and 117 deletions
Download Patch File Download Diff File Expand all files Collapse all files

144
Services/Hncore.Pass.Vpn/Service/AgentClient5Service.cs
View File

@@ -102,6 +102,10 @@ namespace Hncore.Pass.Vpn.Service
{
var resp = await client.PostAsForm(this.SingleAddUrl, map);
var content = await resp.Content.ReadAsStringAsync();
Console.WriteLine("====================================在线=================================================");
Console.WriteLine(content);
Console.WriteLine("=====================================================================================");
if (content.Has() && content.IndexOf("{alert(\"成功\")") != -1)
{
return new ApiResult(ResultCode.C_SUCCESS);
@@ -308,105 +312,47 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<ApiResult<List<OriginAccountOnlineModel>>> OnLine(string account)
{
//虚拟在线
var onlines= await base.OnLine(account);
if (onlines.Code == ResultCode.C_SUCCESS && onlines.Data.Count > 0)
return onlines;
var secretId = "626B6170693231";
var secretKey = "6b3fdfc206841f44c6609bf19c182a6a";
var url = "http://bkapi.pptp.biz/userapi3/?secretId="+secretId+"&secretKey="+secretKey+"&type=get_user_onlinelog&user="+account;
var client = CreateHttpClient();
var title = GetOpTitle("OnLine", account);
var info = "";
try
var resp = await client.GetAsync(url);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
var retData = new List<OriginAccountOnlineModel>();
if (status =="1")
{
var url = this.ClientOnlineUrl + account;
var resp = await client.GetAsync(url);
var content = await resp.Content.ReadAsStringAsync();
var parser = new HtmlParser();
var document = await parser.ParseDocumentAsync(content);
var trs = document.QuerySelectorAll("table.table tr").ToList();
var url2 = this.OnlineUrl + account;
var resp2 = await client.GetAsync(url2);
var content2 = await resp2.Content.ReadAsStringAsync();
var parser2 = new HtmlParser();
var document2 = await parser2.ParseDocumentAsync(content2);
var trs2 = document2.QuerySelectorAll("table.table tr").ToList();
var retData = new List<OriginAccountOnlineModel>();
if (trs.Count() > 1)
{
foreach (var tr in trs.Skip(1))
if(jo.ContainsKey("data")){
foreach (var tr in jo["data"])
{
var tds = tr.QuerySelectorAll("td").ToList();
var tdAccount = tds[1].FirstChild.TextContent;
// if (tdAccount != account)
// continue;
info = string.Join("", tds.Select(m => m.OuterHtml));
//序号 会员账号 登录时间 在线时长 客户端IP地址 操作
JObject jsondata = (JObject)JsonConvert.DeserializeObject(tr.ToJson());
var trData = new OriginAccountOnlineModel
{
Account = account,
LoginTime = tds[2].TextContent,
OnlineTime = tds[3].TextContent,
LoginIP = tds[4].TextContent,
Account = account,
ServerIP = jsondata["server_ip"].ToString(),
LoginTime = "",
OnlineTime = jsondata["online_time"].ToString(),
LoginIP = jsondata["client_ip"].ToString(),
UpStream = "",
DownStream = "",
Id= "&user="+account+"&address="+jsondata["address"].ToString()+"&server_ip="+jsondata["server_ip"].ToString(),
};
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('.');
}
}
retData.Add(trData);
}
}
if (trs2.Count() > 1)
{
foreach (var tr in trs2.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));
//序号 会员账号 登录时间 在线时长 客户端IP地址 操作
var trData = new OriginAccountOnlineModel
{
Account = account,
LoginTime = tds[3].TextContent,
OnlineTime = tds[4].TextContent,
LoginIP = tds[5].TextContent,
};
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('.');
}
}
retData.Add(trData);
}
}
return new ApiResult<List<OriginAccountOnlineModel>>(retData);
}
catch (Exception ex)
{
LogHelper.Error(title, ex.Message + "-->info:" + info);
} else {
return new ApiResult<List<OriginAccountOnlineModel>>(ResultCode.C_INVALID_ERROR, "查询失败");
}
}
/// <summary>
/// 踢号
@@ -416,24 +362,21 @@ namespace Hncore.Pass.Vpn.Service
/// <returns></returns>
public override async Task<bool> KillOut(string id)
{
var flag = await this.KillOutClient(id);
var secretId = "626B6170693231";
var secretKey = "6b3fdfc206841f44c6609bf19c182a6a";
var url = "http://bkapi.pptp.biz/userapi3/?secretId="+secretId+"&secretKey="+secretKey+"&type=user_online_offline"+id;
var client = CreateHttpClient();
var title = GetOpTitle("KillOut", id);
var info = "";
try
var resp = await client.GetAsync(url);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
if (status =="1")
{
var url = string.Format(this.KillUrl, 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;
}
@@ -477,9 +420,6 @@ namespace Hncore.Pass.Vpn.Service
var status = jo["code"].ToString();
Console.WriteLine("====================================在线=================================================");
Console.WriteLine(content);
Console.WriteLine("=====================================================================================");

4
Services/Hncore.Pass.Vpn/Service/ProductOrderService.cs
View File

@@ -236,6 +236,10 @@ FROM product_order where {where} GROUP BY Channel,ProductName order by Channel,
return new ApiResult<ProductOrderEntity>(ResultCode.C_INVALID_ERROR, "产品不存在或者下架");
}
if (productEntity.Status == 0)
{
return new ApiResult<ProductOrderEntity>(ResultCode.C_INVALID_ERROR, "产品不存在或者下架");
}
if (productEntity.Status == 0)
{
return new ApiResult<ProductOrderEntity>(ResultCode.C_INVALID_ERROR, "服务不在线");
}