先锋实名

This commit is contained in:
“wanyongkang”
2021-08-14 09:38:12 +08:00
parent 998d3634a5
commit 240df7e66e
4 changed files with 172 additions and 101 deletions

View File

@@ -51,6 +51,10 @@ namespace Hncore.Pass.Vpn.Service
public override async Task<ApiResult> NewAccount(string packageKey, string account, string pwd, int connCount = 1, int accountType = 1, int payCount = 1)
{
if(packageKey == "free"){
return await NewTestAccount(packageKey, account, pwd, 1, accountType, 1);
}
var secretId = "626B6170693231";
var secretKey = "6b3fdfc206841f44c6609bf19c182a6a";
@@ -74,6 +78,47 @@ namespace Hncore.Pass.Vpn.Service
}
/// <summary>
/// 新开
/// </summary>
/// <param name="packageId"></param>
/// <param name="account"></param>
/// <param name="pwd"></param>
/// <returns></returns>
public async Task<ApiResult> NewTestAccount(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()},
{"tel","17719092232"}
};
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, "开户失败");
}
}
catch (Exception ex)
{
LogHelper.Error(title, ex.Message);
return new ApiResult(ResultCode.C_INVALID_ERROR, "开户失败");
}
}
/// <summary>
/// 续费
/// </summary>
@@ -141,6 +186,53 @@ namespace Hncore.Pass.Vpn.Service
return false;
}
}
/// <summary>
/// 得到账号信息
/// </summary>
/// <param name="productId"></param>
/// <param name="account"></param>
/// <returns></returns>
public override async Task<ApiResult<OriginAccountModel>> GetAccountInfo(string account,bool isTest=false)
{
var secretId = "626B6170693231";
var secretKey = "6b3fdfc206841f44c6609bf19c182a6a";
var url = "http://bkapi.pptp.biz/userapi/?secretId="+secretId+"&secretKey="+secretKey+"&type=getuserinfo&user="+account;
var client = CreateHttpClient();
var resp = await client.GetAsync(url);
var content = await resp.Content.ReadAsStringAsync();
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
Console.WriteLine("---------------------------------------------------------------");
Console.WriteLine(jo);
Console.WriteLine("---------------------------------------------------------------");
if (status =="1")
{
var trData = new OriginAccountModel
{
Account = account,
Pwd = "",
AccountType = "",
Package = "",
RegistTime = "",
EndTime = jo["expiretime"].ToString(),
RestTime = "",
ConnectCount = jo["logincount"].ToString(),
Amount = "",
IsActive = "",
Remark = "",
};
return new ApiResult<OriginAccountModel>(trData);
}
return new ApiResult<OriginAccountModel>(ResultCode.C_INVALID_ERROR, "没有查询到信息");
}
/// <summary>
/// 修改账号密码
@@ -151,42 +243,26 @@ 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 secretId = "626B6170693231";
var secretKey = "6b3fdfc206841f44c6609bf19c182a6a";
var url = "http://bkapi.pptp.biz/userapi/?secretId="+secretId+"&secretKey="+secretKey+"&type=setuser&user="+account+"&&new_pwd="+pwd;
var client = CreateHttpClient();
var map = new Dictionary<string, string>(){
{"username",account },
{"password",pwd },
{"maxOnline",ret.Data.ConnectCount },
};
LogHelper.Info(GetOpTitle("UpdateAccountPwd", account), map.ToJson());
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.UpdateUrl, accountModel.Id);
var resp = await client.PostAsForm(url, map);
var content = await resp.Content.ReadAsStringAsync();
if (content.Has() && content.IndexOf("更新成功") != -1)
{
return true;
}
else
{
LogHelper.Error(GetOpTitle("UpdateAccountPwd", account), content);
}
return true;
} else {
return false;
}
catch (Exception ex)
{
LogHelper.Error(GetOpTitle("UpdateAccountPwd", account), ex);
}
return false;
}
/// <summary>
/// 退款
@@ -400,6 +476,11 @@ namespace Hncore.Pass.Vpn.Service
JObject jo = (JObject)JsonConvert.DeserializeObject(content);
var status = jo["code"].ToString();
Console.WriteLine("====================================在线=================================================");
Console.WriteLine(content);
Console.WriteLine("=====================================================================================");
if (status =="1")