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

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Newtonsoft.Json;
using Volo.Abp.Application.Services;
using Volo.Abp.Domain.Repositories;
using Volo.Abp.Uow;
using WmsWebApi.Domain;
using WmsWebApi.EntityFrameworkCore;
using WmsWebApi.ProductRecieve;
using WmsWebApi.Wms;

namespace WmsWebApi.ProductRecieve;

[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;

    public ProductRecieveService(ITsStockDetailRepository tsStockDetailRepository,
                        ITbProductReceiveRepository tbProductReceiveRepository,
                        ITbBillRepository tbBillRepository,
                        ITaPartRepository taPartRepository,
                        ITaStoreLocationRepository taStoreLocationRepository,
                        ITLTransactionRepository tlTransactionRepository,
                        IProductRecieveManager productRecieveManager,
                        TmPgWmsUpdate tmPgWmsUpdate,
                        IConfiguration configuration)
    {
        _tsStockDetailRepository = tsStockDetailRepository;
        _tbProductReceiveRepository = tbProductReceiveRepository;
        _tbBillRepository = tbBillRepository;
        _taPartRepository = taPartRepository;
        _taStoreLocationRepository = taStoreLocationRepository;
        _tlTransactionRepository = tlTransactionRepository;
        _productRecieveManager = productRecieveManager;
        _tmPgWmsUpdate = tmPgWmsUpdate;
        _configuration = configuration;
    }

    [HttpPost("add")]
    public async Task<ReturnResult> AddAsync([FromBody] object content)
    {
        var result = new ReturnResult();
        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;
        }
        
        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>();

            #region 添加BILL
            var tbBill = new TB_BILL
            {
                BillNum = "AGV." + DateTime.Now.ToString("yyyyMMddHHmmss"),
                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",
                AccountDate = DateTime.ParseExact(_PRDto.AccountDate, "yyyyMMdd", System.Globalization.CultureInfo.CurrentCulture)
            };
            _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 = 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);
            }

            //var pParts = boms.Select(p => p.MATNR).ToList().ToString();
            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);
            if (bErr)
            {
                result.TYPE = 'E';
                apiPRdto.ITYPE = result.MESSAGE;
            }
            await _productRecieveManager.AddAsync(apiPRdto);
        }
        catch(Exception ex)
        {
            result.TYPE = 'E';
            result.MESSAGE = ex.Message;
        }

        return result;
    }

}