using CommonUtil;
|
using EasyCaching.Core;
|
using Link.DbModel;
|
using Link.DTOModel;
|
using Link.IService;
|
using Microsoft.AspNetCore.Mvc;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel.DataAnnotations;
|
using System.Linq;
|
using System.Net;
|
using System.Text;
|
using System.Text.RegularExpressions;
|
|
namespace Link.Api.Controllers
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class IndexController : BaseController
|
{
|
/// <summary>
|
/// 短链接口
|
/// </summary>
|
private readonly ILkLinkService _lkLinkService;
|
|
/// <summary>
|
/// 短链访问记录接口
|
/// </summary>
|
private readonly ILkAccessHistoryService _lkAccessHistoryService;
|
|
/// <summary>
|
/// 短链访问统计接口
|
/// </summary>
|
private readonly ILkAccessStatisticService _lkAccessStatisticService;
|
|
/// <summary>
|
/// 缓存容器
|
/// </summary>
|
private readonly IEasyCachingProvider _provider;
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
/// <param name="provider"></param>
|
/// <param name="lkLkinkService"></param>
|
/// <param name="lkAccessHistoryService"></param>
|
/// <param name="lkAccessStatisticService"></param>
|
public IndexController(IEasyCachingProvider provider, ILkLinkService lkLkinkService, ILkAccessHistoryService lkAccessHistoryService, ILkAccessStatisticService lkAccessStatisticService)
|
{
|
_provider = provider;
|
_lkLinkService = lkLkinkService;
|
_lkAccessHistoryService = lkAccessHistoryService;
|
_lkAccessStatisticService = lkAccessStatisticService;
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
[HttpGet("/{id}")]
|
[ProducesResponseType((int)HttpStatusCode.Redirect)]
|
[ProducesResponseType((int)HttpStatusCode.NotFound)]
|
public IActionResult Index([Required]string id)
|
{
|
string mobEncry = "";//加密手机号
|
if (id.Length > 7)
|
{
|
try
|
{
|
mobEncry = id.Substring(id.Length - 7, 7);
|
mobEncry = MobileDecry(mobEncry);
|
}
|
catch
|
{
|
|
}
|
id = id.Substring(0, id.Length - 7);
|
}
|
if (id == "favicon.ico")
|
{
|
return NotFound();
|
}
|
LkLink link = null;
|
var linkCache = _provider.Get<LkLink>($"LINK_{id}");
|
if (!linkCache.HasValue)
|
{
|
//var where = ExpressionUtil.Create<LkLink>().And(j => j.Key == id)
|
// .And(j => j.ExpireTime >= DateTime.Now)
|
// .ToExpression();
|
var where = ExpressionUtil.Create<LkLink>().And(j => j.Key == id)
|
.ToExpression();
|
link = _lkLinkService.GetFirst(where);
|
}
|
else
|
{
|
link = linkCache.Value;
|
}
|
if (link.IsNull())
|
{
|
return NotFound();
|
}
|
|
//if (link.IsNull() || link.ExpireTime < DateTime.Now)
|
//{
|
// return NotFound();
|
//}
|
|
var result = _lkAccessStatisticService.UseTran(() =>
|
{
|
string ip = GetClientIp();
|
|
DateTime minTime = DateTime.Now.Date;
|
DateTime maxTime = minTime.AddHours(23).AddMinutes(59).AddSeconds(59);
|
var historyWhere = ExpressionUtil.Create<LkAccessHistory>().And(j => j.Key == id)
|
.And(j => j.CreateTime >= minTime)
|
.And(j => j.CreateTime <= maxTime)
|
.And(j => j.Ip == ip)
|
.ToExpression();
|
var statistic = _lkAccessStatisticService.GetFirst(j => j.Key == id);
|
if (!statistic.IsNull())
|
{
|
StringBuilder updateSql = new StringBuilder();
|
updateSql.Append($"UPDATE lk_access_statistic SET pv=pv+1,update_time=NOW() ");
|
|
bool isExist = _lkAccessHistoryService.IsExist(historyWhere);
|
if (!isExist)
|
{
|
updateSql.Append($",uv=uv+1 ");
|
}
|
updateSql.Append($" WHERE id={statistic.Id};");
|
//更新访问统计
|
_lkAccessStatisticService.ExecuteCommand(updateSql.ToString());
|
}
|
UserAgentDTO agent = GetUserAgent();
|
var history = new LkAccessHistory
|
{
|
CreateTime = DateTime.Now,
|
Ip = ip,
|
Key = id,
|
EquipmentCode = agent.EquipmentCode,
|
EquipmentName = agent.EquipmentName,
|
Nick = link.Nick,
|
Mob = mobEncry
|
};
|
//插入访问历史
|
_lkAccessHistoryService.Insert(history);
|
});
|
|
return Redirect(link.OriginUrl);
|
}
|
|
/// <summary>
|
/// 获取远程客户端IP
|
/// </summary>
|
/// <returns></returns>
|
private string GetClientIp()
|
{
|
if (Request.Headers.ContainsKey("X-Forwarded-For"))
|
{
|
return Request.Headers["X-Forwarded-For"].ToString();
|
}
|
|
string ip = Request.HttpContext.Connection.RemoteIpAddress.ToString();
|
return ip == "::1" ? "127.0.0.1" : ip;
|
}
|
|
/// <summary>
|
/// 获取请求设备信息
|
/// </summary>
|
/// <returns></returns>
|
private UserAgentDTO GetUserAgent()
|
{
|
UserAgentDTO agentInfo = new UserAgentDTO();
|
if (Request.Headers.ContainsKey("User-Agent"))
|
{
|
string agent = Request.Headers["User-Agent"].ToString();
|
CommonUtil.LogUtil.Info(agent, "Agent");
|
Dictionary<string, string> agentList = GetAgentList();
|
foreach (var item in agentList)
|
{
|
Regex rx = new Regex(item.Value, RegexOptions.Compiled | RegexOptions.IgnoreCase);
|
MatchCollection match = rx.Matches(agent);
|
if (match.Count > 0)
|
{
|
agentInfo.EquipmentCode = item.Key.Split('|')[0];
|
agentInfo.EquipmentName = item.Key.Split('|')[1];
|
return agentInfo;
|
}
|
}
|
|
}
|
agentInfo.EquipmentCode = "other";
|
agentInfo.EquipmentName = "其他";
|
return agentInfo;
|
}
|
|
private Dictionary<string, string> GetAgentList()
|
{
|
Dictionary<string, string> dic = new Dictionary<string, string>();
|
dic.Add("mi|小米", "/*mi.*Build/QKQ1");
|
dic.Add("huawei|华为", "/*HUAWEI");
|
dic.Add("iphone|苹果", "/*iPhone");
|
dic.Add("windows|WindowsPC", "/*Windows");
|
dic.Add("samsung|三星", "/*Android.*SM.*Build/QP1A");
|
return dic;
|
}
|
|
/// <summary>
|
/// 解密
|
/// </summary>
|
/// <param name="s"></param>
|
/// <returns></returns>
|
private string MobileDecry(string s)
|
{
|
s = s.Replace("_", "/").Replace("-", "+").PadRight((s.Length + 3) / 4 * 4, '=');
|
byte[] bytes = Convert.FromBase64String(s).Reverse().Concat(new byte[8]).Take(8).ToArray();
|
string re = BitConverter.ToInt64(bytes, 0).ToString();
|
return re.Length == 11 ? re : s;
|
}
|
}
|
}
|
