56 lines
2.0 KiB
C#
56 lines
2.0 KiB
C#
|
using langguanApi.Common.Redis;
|
|||
|
|
using langguanApi.Common.WebSocket;
|
|||
|
|
using langguanApi.Extensions.AutoDI;
|
|||
|
|
using langguanApi.Model.Entity;
|
|||
|
|
using Mapster;
|
|||
|
|
using StackExchange.Redis;
|
|||
|
|
|
|||
|
|
namespace langguanApi.Service
|
|||
|
|
{
|
|||
|
|
[ServiceInjection(InjectionType.Transient)]
|
|||
|
|
public class GpsHistoryService : BaseService<GpsHistory>
|
|||
|
|
{
|
|||
|
|
private readonly PushService _pushService;
|
|||
|
|
private IDatabase _redis;
|
|||
|
|
private IConfiguration _config;
|
|||
|
|
public GpsHistoryService(IConfiguration config, PushService pushService,
|
|||
|
|
RedisHelper redisHelper) : base(config, nameof(Model.Entity.GpsHistory))
|
|||
|
|
{
|
|||
|
|
_pushService = pushService;
|
|||
|
|
_redis = redisHelper._database;
|
|||
|
|
_config = config;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 新加gps历史记录
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="input"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task AddGpsHistory(GpsHistoryDTO input)
|
|||
|
|
{
|
|||
|
|
var entity = input.Adapt<GpsHistory>();
|
|||
|
|
var redisKey = RedisKeylist.GetBatchid(entity.DeviceId);
|
|||
|
|
///如果redis中不存在该设备的批次号，则生成一个批次号
|
|||
|
|
if (!await _redis.KeyExistsAsync(redisKey))
|
|||
|
|
{
|
|||
|
|
int time = _config.GetValue<int>("BatchId");
|
|||
|
|
long utc = DateTime.UtcNow.Ticks;
|
|||
|
|
await _redis.StringSetAsync(redisKey, utc, TimeSpan.FromMinutes(time));
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
//如果存在了，就把批次号延期30分钟
|
|||
|
|
await _redis.KeyExpireAsync(redisKey, TimeSpan.FromMinutes(30));
|
|||
|
|
}
|
|||
|
|
entity.BatchId = (long)await _redis.StringGetAsync(redisKey);
|
|||
|
|
await base.CreateAsync(entity);
|
|||
|
|
await _pushService.SendMessageToAll(new
|
|||
|
|
{
|
|||
|
|
entity.Lat,
|
|||
|
|
entity.DeviceId,
|
|||
|
|
entity.Lon,
|
|||
|
|
entity.BatchId
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|