50 lines
1.5 KiB
C#
50 lines
1.5 KiB
C#
using JSMachine.WMS.App.Dto;
|
|
using JSMachine.WMS.App.IService;
|
|
using JSMachine.WMS.Domain.Entity;
|
|
using JSMachine.WMS.Domain.IRepository;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace JSMachine.WMS.App.ServiceImpl
|
|
{
|
|
public class ElevatorCountService : BaseService<ElevatorCountDto, ElevatorCount>, IElevatorCountService
|
|
{
|
|
public ElevatorCountService(IBaseRepository<ElevatorCount> baseRepository) : base(baseRepository)
|
|
{
|
|
}
|
|
|
|
/// <summary>
|
|
/// 计数自增
|
|
/// </summary>
|
|
/// <param name="elevatorNo"></param>
|
|
/// <param name="channel"></param>
|
|
/// <returns></returns>
|
|
public async Task IncrementCount(int elevatorNo, int channel)
|
|
{
|
|
ElevatorCountDto elevatorCount = await GetSingalByExpression(p =>
|
|
p.CreationTime >= DateTime.Now.Date &&
|
|
p.ElevatorNo == elevatorNo &&
|
|
p.ElevatorChannel == channel);
|
|
if (elevatorCount == null)
|
|
{
|
|
elevatorCount = new()
|
|
{
|
|
ElevatorNo = elevatorNo,
|
|
ElevatorChannel = channel,
|
|
Count = 1
|
|
};
|
|
|
|
await Add(elevatorCount);
|
|
}
|
|
else
|
|
{
|
|
elevatorCount.Count++;
|
|
await EditSingal(elevatorCount);
|
|
}
|
|
}
|
|
}
|
|
}
|