PGWmsWebApi/src/WmsWebApi.Application/ProductRecieve/ProductRecieveService.cs

using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using Polly;
using Polly.Retry;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Volo.Abp.Application.Services;
using Volo.Abp.Domain.Repositories;
using Volo.Abp.Uow;
using WmsWebApi.BackgroundJobs;
using WmsWebApi.Domain;
using WmsWebApi.EntityFrameworkCore;
using WmsWebApi.Jsons;
using WmsWebApi.Wms;
using WmsWebApi.WMS;

namespace WmsWebApi.ProductRecieve;

/// <summary>
/// Agv完工收货入库
/// </summary>
[Route("/api/pr")]
public class ProductRecieveService : ApplicationService, IProductRecieveService
{
    private readonly ITsStockDetailRepository _tsStockDetailRepository;
    private readonly ITbProductReceiveRepository _tbProductReceiveRepository;
    private readonly ITbBillRepository _tbBillRepository;
    private readonly ITLTransactionRepository _tlTransactionRepository;
    private readonly IProductRecieveManager _productRecieveManager;
    private readonly TmPgWmsUpdate _tmPgWmsUpdate;
    private readonly ITaPartRepository _taPartRepository;
    private readonly ITaStoreLocationRepository _taStoreLocationRepository;
    private readonly IConfiguration _configuration;
    private readonly Volo.Abp.Uow.IUnitOfWorkManager _unitOfWorkManager;
    private readonly IBackgroundJobRequestRetry _backgroundJobRequestRetry;
    private readonly IProductRecieveJsonRepository _productRecieveJsonRepository;
    private readonly AsyncRetryPolicy _asyncRetryPolicy;

    /// <summary>
    /// 是否是请求重试
    /// </summary>
    public bool IsRequestRetry { get; set; } = false;

    public ProductRecieveService(ITsStockDetailRepository tsStockDetailRepository,
                        ITbProductReceiveRepository tbProductReceiveRepository,
                        ITbBillRepository tbBillRepository,
                        ITaPartRepository taPartRepository,
                        ITaStoreLocationRepository taStoreLocationRepository,
                        ITLTransactionRepository tlTransactionRepository,
                        IProductRecieveManager productRecieveManager,
                        TmPgWmsUpdate tmPgWmsUpdate,
                        IConfiguration configuration,
                        IUnitOfWorkManager unitOfWorkManager,
                        IBackgroundJobRequestRetry backgroundJobRequestRetry,
                        IProductRecieveJsonRepository productRecieveJsonRepository)
    {
        _tsStockDetailRepository = tsStockDetailRepository;
        _tbProductReceiveRepository = tbProductReceiveRepository;
        _tbBillRepository = tbBillRepository;
        _taPartRepository = taPartRepository;
        _taStoreLocationRepository = taStoreLocationRepository;
        _tlTransactionRepository = tlTransactionRepository;
        _productRecieveManager = productRecieveManager;
        _tmPgWmsUpdate = tmPgWmsUpdate;
        _configuration = configuration;
        _unitOfWorkManager = unitOfWorkManager;
        _backgroundJobRequestRetry = backgroundJobRequestRetry;
        _productRecieveJsonRepository = productRecieveJsonRepository;
        _asyncRetryPolicy = Policy.Handle<Exception>()
            .WaitAndRetryAsync(new[] {
                TimeSpan.FromSeconds(1),
                TimeSpan.FromSeconds(5),
                TimeSpan.FromSeconds(5),
                TimeSpan.FromSeconds(5)
            }, (exception, timeSpan, retryCount, context) =>
            {
                Logger.LogInformation($"执行失败，第 {retryCount} 次重试");
            });
    }

    [HttpPost("add/IF01")]
    public async Task<ReturnResult> AddAsync([FromBody] object content)
    {
        var result = new ReturnResult();
        result.MESSAGE = String.Empty;
        PRDto _PRDto;
        //bool bUpdate = false,bOtherWork = false, bDel = false,bNotFind = false, bPartGroup = false;
        bool bErr = false;
        try
        {
            _PRDto = JsonConvert.DeserializeObject<PRDto>(content.ToString());
        }
        catch (Exception ex)
        {
            result.TYPE = 'E';
            result.MESSAGE = "Json格式不正确，详细信息：" + ex.Message;
            return result;
        }

        WmsWebApiProductRecieveDTO apiPRdto = new WmsWebApiProductRecieveDTO()
        {
            AccountDate = _PRDto.AccountDate,
            BillType = _PRDto.BillType,
            ReceiveDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
            GUID = _PRDto.GUID,
            OperName = _PRDto.OperName,
            BillTime = _PRDto.BillTime,
            SourceBillNum = _PRDto.SourceBillNum,
            JSON = content.ToString()
        };
        apiPRdto.SetId(GuidGenerator);

        try
        {
            List<TB_BILL> _billList = new List<TB_BILL>();
            List<TB_PRODUCT_RECEIVE> _recieveList = new List<TB_PRODUCT_RECEIVE>();
            List<TS_STOCK_DETAIL> _stockList = new List<TS_STOCK_DETAIL>();
            List<TS_STOCK_DETAIL> _stockUpdateList = new List<TS_STOCK_DETAIL>();
            List<TS_STOCK_DETAIL> _stockDelList = new List<TS_STOCK_DETAIL>();
            List<TL_TRANSACTION> _transList = new List<TL_TRANSACTION>();
            List<TS_UNI_API> listTSUNIAPI = new List<TS_UNI_API>();

            #region 添加BILL
            var tbBill = new TB_BILL
            {
                BillNum = "AGV." + DateTime.Now.ToString("yyyyMMddHHmmss"),
                SourceBillNum = _PRDto.SourceBillNum,
                SourceBillNum2 = _PRDto.SourceBillNum,
                BillTime = DateTime.Now,
                StartTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                FinishTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                OperName = _PRDto.OperName,
                DetailQty = _PRDto.items.Count,
                BillType = 201,
                SubBillType = 10100,
                State = 2,
                Remark = "AGVProductRecieve"
            };
            try
            {
                tbBill.AccountDate = DateTime.ParseExact(_PRDto.AccountDate, "yyyyMMdd", System.Globalization.CultureInfo.CurrentCulture);
            }
            catch (Exception)
            {
                tbBill.AccountDate = DateTime.Parse(_PRDto.AccountDate);
            }
            _billList.Add(tbBill);
            #endregion

            foreach (var item in _PRDto.items)
            {
                //判断物料信息
                var part = await _taPartRepository.FirstOrDefaultAsync(p => p.PartCode == item.PartCode);
                if (part == null)
                {
                    //result.TYPE = 'E';
                    bErr = true;
                    result.MESSAGE += $"err:物料 {item.PartCode} 不在WinWMS管理!";
                    continue;
                }
                if (string.IsNullOrEmpty(part.DefaultReceiveLocCode))
                {
                    bErr = true;
                    result.MESSAGE += $"err:物料 {item.PartCode} 未设置收货库位!";
                    continue;
                }

                var partLoc = await _taStoreLocationRepository.FirstOrDefaultAsync(p => p.LocCode == part.DefaultReceiveLocCode);
                if (partLoc == null)
                {
                    bErr = true;
                    result.MESSAGE += $"err:物料 {item.PartCode} 的默认收货库位未配置ERP库位!";
                    continue;
                }

                var _barcode = $"{item.PartCode}_{item.Batch}";
                //插入productrecieve
                var tbRecieve = new TB_PRODUCT_RECEIVE
                {
                    BillNum = tbBill.BillNum,
                    BarCode = _barcode,
                    PartCode = item.PartCode,
                    Batch = item.Batch,
                    FromLocCode = "",
                    //ToLocCode = part.DefaultReceiveLocCode,
                    Remark = part.QLevel,
                    Qty = item.Qty,
                    GoodQty = item.Qty,
                    State = 2,
                    ReceiveDate = DateTime.Now,
                    ProduceDate = DateTime.Now,
                    //LineId = tmp.ZLTLX,         //领/退类型
                    //ShiftName = tmp.ZLLDJ,      //单据号 
                    //TeamName = tmp.ZEILE,       //物料凭证中的项目
                    //Unit = tmp.ZDJLX,           //单据类型
                    //TraceBackCode = tmp.MEINS,  //基本计量单位
                };
                tbRecieve.ToLocCode = _configuration.GetConnectionString("AgvInLoc");

                _recieveList.Add(tbRecieve);
                //插入ts_stock_detail
                var tsStock = new TS_STOCK_DETAIL
                {
                    BarCode = _barcode,
                    PartCode = item.PartCode,
                    Batch = item.Batch,
                    EqptCode = "",
                    LocCode = part.DefaultReceiveLocCode,
                    AreaCode = partLoc.AreaCode,//"FG",
                    Qty = item.Qty,
                    UpdateQty = item.Qty,
                    VendId = "",
                    ProduceDate = DateTime.Now,
                    OverdueDate = (DateTime.Now).AddDays(part.ValidityDays),
                    ReceiveDate = DateTime.Now,
                    VendBatch = item.Batch,
                    Remark = "",
                    State = EnumStockState.合格,
                    Amount = 0,
                    VinState = 0,

                };

                var stock = await _tsStockDetailRepository.FirstOrDefaultAsync(p => p.BarCode == _barcode
                                                                                && p.LocCode == part.DefaultReceiveLocCode
                                                                                && p.State == EnumStockState.合格);

                if (stock == null)
                {
                    _stockList.Add(tsStock);
                }
                else
                {
                    _stockUpdateList.Add(tsStock);
                }

                //插入tl_transaction
                var tlTrans = new TL_TRANSACTION
                {
                    OperName = "AGV",
                    LogTime = tbBill.AccountDate ?? DateTime.Now,
                    BillNum = tbBill.BillNum,
                    BillType = tbBill.BillType,
                    SubBillType = tbBill.SubBillType,
                    PartCode = item.PartCode,
                    Batch = item.Batch,
                    Qty = item.Qty,
                    BarCode = _barcode,
                    LocCode = part.DefaultReceiveLocCode,
                    EqptCode = "",
                    Remark = "In",
                    State = 2,
                    TransType = 1
                };
                _transList.Add(tlTrans);
            }
            if (!bErr)
            {
                if (_recieveList.Count > 0)
                {
                    await _tbBillRepository.AddManyAsync(_billList);
                    await _tbProductReceiveRepository.AddAsync(_recieveList);
                }
                if (_stockList != null && _stockList.Count() > 0)
                    await _tsStockDetailRepository.AddAsync(_stockList);
                if (_stockUpdateList != null && _stockUpdateList.Count() > 0)
                    await _tmPgWmsUpdate.UpdateTsStock(_stockUpdateList);
                await _tlTransactionRepository.AddAsync(_transList);
            }
            await CurrentUnitOfWork.SaveChangesAsync();
        }
        catch (Exception ex)
        {
            bErr = true;
            apiPRdto.EnumRetryStatus = Enums.EnumRetryStatus.WaitRetry;
            result.TYPE = 'E';
            result.MESSAGE = ex.Message;

            if (IsRequestRetry == false) 
            {
                //await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.ProductRecieveAdd, content.ToString());
            }

            throw new Exception($"接口异常，请稍后重试：{ex.GetBaseException().Message}", ex);
        }
        finally 
        {
            if (IsRequestRetry == false)
            {
                Logger.LogInformation(apiPRdto.JSON);

                if (bErr)
                {
                    result.TYPE = 'E';
                    apiPRdto.ITYPE = result.MESSAGE;
                }
                else 
                {
                    result.MESSAGE = "成功";
                    apiPRdto.ITYPE = "成功";
                }
                try
                {
                    await AddWmsWebApiProductRecieveDTONowUnitOfWorkAsync(apiPRdto);
                }
                catch (Exception)
                {
                    try
                    {
                        await _asyncRetryPolicy.ExecuteAsync(async () => await AddJsonNowUnitOfWorkAsync(apiPRdto));
                    }
                    catch (Exception ex)
                    {
                        Logger.LogError("ProductRecieve JSON记录失败");
                        Logger.LogError(apiPRdto.JSON);
                        Logger.LogError(ex.Message);
                    }
                }
            }
        }

        if (bErr == false)
        {
            result.MESSAGE = "接收成功！";
        }
        return result;
    }

    private async Task AddWmsWebApiProductRecieveDTONowUnitOfWorkAsync(WmsWebApiProductRecieveDTO wmsWebApiProductRecieveDTO)
    {
        if (wmsWebApiProductRecieveDTO == null) { return; }

        using (var uow = _unitOfWorkManager.Begin(requiresNew: true, isTransactional: false))
        {
            await _productRecieveManager.AddAsync(wmsWebApiProductRecieveDTO);
            await uow.SaveChangesAsync();
        }
    }

    private async Task AddJsonNowUnitOfWorkAsync(WmsWebApiProductRecieveDTO wmsWebApiProductRecieveDTO)
    {
        if (wmsWebApiProductRecieveDTO == null) { return; }

        using (var uow = _unitOfWorkManager.Begin(requiresNew: true, isTransactional: false))
        {
            await _productRecieveJsonRepository.InsertAsync(wmsWebApiProductRecieveDTO);
            await uow.SaveChangesAsync();
        }
    }
}