using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Auth.HttpContextUser;
|
using CoreCms.Net.Caching.AutoMate.RedisCache;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.IRepository;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.Model.FromBody;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using Nito.AsyncEx;
|
|
namespace CoreCms.Net.Web.WebApi.Controllers
|
{
|
/// <summary>
|
/// 签到控制器
|
/// </summary>
|
[Route("api/[controller]/[action]")]
|
[ApiController]
|
public class CheckInController : ControllerBase
|
{
|
private readonly ICoreCmsUserCheckInDetailsServices _userCheckInDetailsServices;
|
private readonly IHttpContextUser _user;
|
private readonly IRedisOperationRepository _redisOperationRepository;
|
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public CheckInController(IHttpContextUser user, ICoreCmsUserCheckInDetailsServices userCheckInDetailsServices, IRedisOperationRepository redisOperationRepository)
|
{
|
_user = user;
|
_userCheckInDetailsServices = userCheckInDetailsServices;
|
_redisOperationRepository = redisOperationRepository;
|
}
|
|
|
/// <summary>
|
/// 用户签到
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Authorize]
|
public async Task<WebApiCallBack> DoUserCheckIn([FromBody] FMDoUserCheckIn entity)
|
{
|
var jm = new WebApiCallBack();
|
|
var lockKey = "LOCK_DoUserCheckIn:user_" + _user.ID;
|
var lockHolder = Guid.NewGuid().ToString("N"); //锁持有者
|
var redisUserLock = await _redisOperationRepository.LockTakeAsync(lockKey, lockHolder, TimeSpan.FromSeconds(5));
|
if (redisUserLock)
|
{
|
try
|
{
|
var isHave = await _userCheckInDetailsServices.ExistsAsync(p => p.userId == _user.ID && p.checkInData == entity.date);
|
if (isHave)
|
{
|
jm.msg = "今日您已签到";
|
return jm;
|
}
|
var detail = new CoreCmsUserCheckInDetails
|
{
|
userId = _user.ID,
|
checkInData = entity.date,
|
createTime = DateTime.Now
|
};
|
var callBack = await _userCheckInDetailsServices.DoCheckIn(detail);
|
jm.status = callBack.code == 0;
|
jm.msg = callBack.msg;
|
jm.data = callBack.data;
|
return jm;
|
}
|
catch (Exception e)
|
{
|
jm.msg = "数据处理异常";
|
jm.otherData = e;
|
}
|
finally
|
{
|
await _redisOperationRepository.LockReleaseAsync(lockKey, lockHolder);
|
}
|
}
|
else
|
{
|
jm.msg = "当前请求太频繁_请稍后再试";
|
}
|
return jm;
|
}
|
|
/// <summary>
|
/// 获取用户总签到次数
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Authorize]
|
public async Task<WebApiCallBack> GetUserCheckCount()
|
{
|
var jm = new WebApiCallBack
|
{
|
status = true,
|
data = await _userCheckInDetailsServices.GetCountAsync(p => p.userId == _user.ID),
|
msg = "获取成功"
|
};
|
return jm;
|
}
|
|
/// <summary>
|
/// 获取用户按月签到数据
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Authorize]
|
public async Task<WebApiCallBack> GetUserCheckByMonth([FromBody] FMGetUserCheckInByMonth entity)
|
{
|
var jm = new WebApiCallBack();
|
|
var dt = new DateTime(entity.year, entity.month, 1);
|
|
var min = dt.AddDays(-1);
|
var max = dt.AddMonths(1);
|
|
var list = await _userCheckInDetailsServices.QueryListByClauseAsync(p => p.userId == _user.ID && p.checkInData > min && p.checkInData < max);
|
|
var stringArr = list.Select(item => item.checkInData.ToString("yyyy-MM-dd")).ToList();
|
|
jm.status = true;
|
jm.data = stringArr;
|
jm.msg = "获取成功";
|
|
return jm;
|
}
|
}
|
}
|
