出入库回退上下架

src/WMS.Web.Domain/Services/BackRecordService.cs

@@ -0,0 +1,66 @@
+using AutoMapper;
+using Microsoft.EntityFrameworkCore.Storage;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+using WMS.Web.Core.Dto.BackRecord;
+using WMS.Web.Core.Dto.Login;
+using WMS.Web.Core.Internal.Results;
+using WMS.Web.Domain.Entitys;
+using WMS.Web.Domain.Infrastructure;
+using WMS.Web.Domain.IService;
+using WMS.Web.Domain.IService.Public;
+using WMS.Web.Domain.Values;
+
+namespace WMS.Web.Domain.Services
+{
+    /// <summary>
+    /// 出入库回退上下架：服务接口
+    /// </summary>
+    public class BackRecordService: IBackRecordService
+    {
+        private readonly IMapper _mapper;
+        private readonly ILoginService _loginService;
+        public readonly  ITransactionRepositories _transactionRepositories;
+        private readonly IBackRecordRepositories _backRecordRepositories;
+        public BackRecordService(IMapper mapper, ILoginService loginService,
+             ITransactionRepositories transactionRepositories,
+            IBackRecordRepositories backRecordRepositories)
+        {
+            _mapper = mapper;
+            _loginService = loginService;
+            _transactionRepositories = transactionRepositories;
+            _backRecordRepositories = backRecordRepositories;
+        }
+
+        /// <summary>
+        /// 回退上下架
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <param name="loginInfo"></param>
+        /// <returns></returns>
+        public async Task<Result> BackShelf(SaveBackRecordRequest dto, LoginInDto loginInfo)
+        {
+            IDbContextTransaction _transaction = _transactionRepositories.GetTransaction();
+            bool isRollback = false;
+            bool isTransaction = false;
+
+            var entity = new BackRecord();
+            entity.Type = (BackRecordType)dto.Type;
+            entity.Details = _mapper.Map<List<BackRecordDetails>>(dto.Details);
+            entity.Create(loginInfo.UserInfo.StaffId);
+            entity = await _backRecordRepositories.Add(entity, isTransaction);
+
+            //提交事务
+            var isSuccess = _transactionRepositories.CommitTransaction(isRollback, _transaction);
+            if (!isSuccess)
+                return Result.ReFailure(ResultCodes.DateWriteError);
+
+            if (entity != null)
+                return Result.ReSuccess();
+            else
+                return Result.ReFailure(ResultCodes.DateWriteError);
+        }
+    }
+}