Services/GoodsService/ApplicationService/GoodsActorService.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using ApplicationService.Dtos;
using Autofac;
using Domain;
using Domain.Entities;
using Domain.Repository;
using IApplicationService;
using IApplicationService.AppEvent;
using IApplicationService.GoodsService;
using IApplicationService.GoodsService.Dtos.Input;
using Infrastructure.EfDataAccess;
using Infrastructure.Elasticsearch;
using InfrastructureBase;
using InfrastructureBase.Object;
using Oxygen.Mesh.Dapr;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ApplicationService
{
    public class GoodsActorService: BaseActorService<GoodsActor>, IGoodsActorService
    {
        private readonly IGoodsRepository repository;
        private readonly IUnitofWork unitofWork;
        private readonly ILocalEventBus localEventBus;
        public GoodsActorService(IGoodsRepository repository, IUnitofWork unitofWork, ILocalEventBus localEventBus)
        {
            this.repository = repository;
            this.unitofWork = unitofWork;
            this.localEventBus = localEventBus;
        }
        public async Task<ApiResult> UpdateGoodsStock(DeductionStockDto input)
        {
            return await ApiResult.Ok(true, "商品库存更新成功!").RunAsync(async () =>
            {
                await SetActorDataIfNotExists(input.GoodsId);
                ActorData.ChangeStock(input.DeductionStock);
            });
        }

        public async Task<ApiResult> DeductionGoodsStock(DeductionStockDto input)
        {
            return await ApiResult.Ok(true, "商品库存减扣成功").RunAsync(async () =>
            {
                await SetActorDataIfNotExists(input.GoodsId);
                ActorData.DeductionStock(input.DeductionStock);
            });
        }
        public async Task<ApiResult> UnDeductionGoodsStock(DeductionStockDto input)
        {
            return await ApiResult.Ok(true, "商品库存回滚成功").RunAsync(async () =>
            {
                await SetActorDataIfNotExists(input.GoodsId);
                ActorData.UnDeductionStock(input.DeductionStock);
            });
        }
        async Task SetActorDataIfNotExists(Guid id)
        {