YunTongJackYunTask/Reportapi/MyCode.Project.Services/Implementation/PurchaseStockInService.cs

using MyCode.Project.Domain.Message.Request.KingDee;
using MyCode.Project.Domain.Message.Request.KingDee.SaveModel;
using MyCode.Project.Domain.Message.Response.KingDee.K3Result;
using MyCode.Project.Domain.Message.Response.KingDee.K3Result.Model;
using MyCode.Project.Domain.Model;
using MyCode.Project.Domain.Repositories;
using MyCode.Project.Infrastructure.Common;
using MyCode.Project.Infrastructure.Exceptions;
using MyCode.Project.Infrastructure.Extensions;
using MyCode.Project.OutSideService;
using MyCode.Project.Services.IServices;
using System;
using System.Collections.Generic;
using System.Linq;

namespace MyCode.Project.Services.Implementation
{
    /// <summary>
    /// 采购入库单服务实现
    /// 功能：处理采购入库单推送到金蝶云星空的业务逻辑
    /// </summary>
    public class PurchaseStockInService : ServiceBase, IPurchaseStockInService
    {
        private const string BILL_TYPE_CODE = "RKD01_SYS";
        private const string OWNER_TYPE = "BD_OwnerOrg";
        private const string EXCHANGE_TYPE = "HLTX01_SYS";
        private const string STOCK_STATUS = "KCZT01_SYS";
        private const string DEFAULT_ORG = "100";
        private const string DEFAULT_CURRENCY = "PRE001";
        private const string DEFAULT_UNIT = "Pcs";
        private const string ROW_TYPE_STANDARD = "Standard";
        private const string ROW_TYPE_SERVICE = "Service";
        private const string FORM_ID = "STK_InStock";

        private IPushKingDeeGoodsDocInRepository _pushKingDeeGoodsDocInRepository;
        private IBusiOrderGoodsDocInRepository _busiOrderGoodsDocInRepository;
        private IYTKJTShopParameterRepository _yTKJTShopParameterRepository;
        private IKingDeeService _kingDeeService;

        public PurchaseStockInService(
            IPushKingDeeGoodsDocInRepository pushKingDeeGoodsDocInRepository,
            IBusiOrderGoodsDocInRepository busiOrderGoodsDocInRepository,
            IYTKJTShopParameterRepository yTKJTShopParameterRepository,
            IKingDeeService kingDeeService)
        {
            _pushKingDeeGoodsDocInRepository = pushKingDeeGoodsDocInRepository;
            _busiOrderGoodsDocInRepository = busiOrderGoodsDocInRepository;
            _yTKJTShopParameterRepository = yTKJTShopParameterRepository;
            _kingDeeService = kingDeeService;
        }

        /// <summary>
        /// 推送采购入库单到金蝶云星空
        /// </summary>
        /// <param name="id">PushKingDeeGoodsDocIn表的主键ID（Guid格式的字符串）</param>
        /// <returns>返回金蝶API的响应结果（JSON格式）</returns>
        public string PushPurchaseStockInToKingDee(string id)
        {
            var goodsDocIn = _pushKingDeeGoodsDocInRepository
                .Queryable()
                .Where(t => id == t.ID.ToString())
                .First();

            if (goodsDocIn == null)
            {
                throw new BaseException($"未找到ID为 {id} 的采购入库单记录");
            }

            if (goodsDocIn.Status ==2 )
            {
                throw new BaseException($"{goodsDocIn.InOutDate2}+{goodsDocIn.VendCustomerName}的采购入库单已经推送过，状态为：{goodsDocIn.Status}，不允许重复推送");
            }

            var param = _yTKJTShopParameterRepository
                .Queryable()
                .Where(t => t.FDOCUMENTSTATUS == "C")
                .First();

            if (param == null)
            {
                throw new BaseException("没有找到已审核的门店参数配置，请联系管理员检查门店参数表");
            }

            if (param.FPURCHASERECEIVING == "0")
            {
                throw new BaseException("门店参数配置中采购入库单同步功能未启用，请联系管理员检查门店参数配置");
            }

            if (param.FPURCHASERECEIVING == "1")
            {
                var response = PushKingdeePurchaseStockIn(goodsDocIn, param);
                string result = JsonHelper.ToJson(response);

                if (response.IsSuccess)
                {
                    goodsDocIn.Status = 2;
                    _pushKingDeeGoodsDocInRepository.Update(goodsDocIn);
                }

                return result;
            }

            return "";
        }

        private K3CloudResponseStatus PushKingdeePurchaseStockIn(PushKingDeeGoodsDocIn goodsDocIn, YTKJTShopParameter param)
        {
            // 从BusiOrderGoodsDocIn表获取明细数据
            var detailList = _busiOrderGoodsDocInRepository
                .Queryable()
                .Where(t => t.InOutDate2.Value.ToString("yyyy-MM-dd") == goodsDocIn.InOutDate2.Value.ToString("yyyy-MM-dd") && t.VendCode==goodsDocIn.VendCode && t.Status==1 )
                .ToList();

            if (detailList == null || detailList.Count == 0)
            {
                throw new BaseException($"没有找到明细数据，无法推送");
            }
            // 获取第一条明细用于主表信息
            var firstDetail = detailList.FirstOrDefault();
            if (firstDetail == null)
            {
                throw new BaseException($"  明细数据为空，无法推送");
            }

            // 获取采购组织ID
            string purchaseOrgId = param.FPURCHASEORGID?.ToString() ?? param.FSALEORGID?.ToString() ?? DEFAULT_ORG;
            
            // 获取仓库编码
            string warehouseCode =param.FPURCHASINGWAREHOUSECODE ;

            // 构建金蝶API的明细行数据
            var entryList = detailList.Select((n, index) => BuildEntryItem(n, param, purchaseOrgId, warehouseCode)).ToList();

            if (entryList.Count == 0)
            {
                throw new BaseException($"采购入库单明细数据转换失败，无法推送");
            }

            // 构建金蝶API的主表数据
            var model = BuildMainModel(goodsDocIn, firstDetail, param, purchaseOrgId, entryList);

            // 构建金蝶API请求对象
            BillSave billSave = new BillSave()
            {
                Model = model,
                IsAutoSubmitAndAudit = false,
            };

            // 调用金蝶服务保存单据
            var responseStatus = _kingDeeService.Save(FORM_ID, billSave);
            return responseStatus;
        }

        /// <summary>
        /// 构建明细行数据
        /// </summary>
        private FPurchaseStockInEntryItem BuildEntryItem(BusiOrderGoodsDocIn detail, YTKJTShopParameter param, string orgId, string warehouseCode)
        {
            // 根据入库类型动态设置FRowType（如果入库类型包含"服务"或"费用"等关键字，则设置为Service，否则为Standard）
            string rowType = ROW_TYPE_STANDARD;
            if (!string.IsNullOrEmpty(detail.InouttypeName))
            {
                string inoutType = detail.InouttypeName.ToUpper();
                if (inoutType.Contains("服务") || inoutType.Contains("费用") || inoutType.Contains("SERVICE") || inoutType.Contains("FEE"))
                {
                    rowType = ROW_TYPE_SERVICE;
                }
            }

            // 计算折扣后金额（无税金额）
            decimal? allAmountExceptDisCount = detail.BaceCurrencyNoTaxAmount ?? 0;

            return new FPurchaseStockInEntryItem()
            {
                Fcode = detail.SkuBarcode ?? "",
                FRowType = rowType,
                //FMaterialId = new FMaterialId()
                //{
                //    FNumber = detail.SkuBarcode ?? ""
                //},
                //FUnitID = new FUnitID()
                //{
                //    FNumber = detail.UnitName ?? DEFAULT_UNIT
                //},
                //FMaterialDesc = detail.GoodsName ?? "",
                FWWPickMtlQty = 0,
                FRealQty = detail.Quantity ?? 0,
                //FPriceUnitID = new FPriceUnitID()
                //{
                //    FNumber = detail.UnitName ?? DEFAULT_UNIT
                //},
                FPrice = detail.BaceCurrencyNoTaxPrice ?? 0,
                FDisPriceQty = 0,
                FStockID = new FStockID()
                {
                    FNumber = param.FPURCHASINGWAREHOUSECODE
                },
                FStockStatusId = new FStockStatusId()
                {
                    FNumber = STOCK_STATUS
                },
                FGiveAway = false,
                FOWNERTYPEID = OWNER_TYPE,
                FExtAuxUnitQty = 0,
                FCheckInComing = false,
                FIsReceiveUpdateStock = false,
                FInvoicedJoinQty = 0,
                FPriceBaseQty = detail.Quantity ?? 0,
                FRemainInStockUnitId = new FRemainInStockUnitId()
                {
                    FOrgId = param.FPURCHASEORGID.SafeValue().ToString(),
                },
                FBILLINGCLOSE = false,
                FRemainInStockQty = detail.Quantity ?? 0,
                FRemainInStockBaseQty = detail.Quantity ?? 0,
                FAPNotJoinQty = detail.Quantity ?? 0,
                FTaxPrice = detail.BaceCurrencyWithTaxPrice ?? 0, 
               
                FOWNERID = new FOwnerId()
                {
                    FOrgId = orgId
                },
              
             
            };
        }

        private PurchaseStockInModel BuildMainModel(PushKingDeeGoodsDocIn goodsDocIn, BusiOrderGoodsDocIn firstDetail, YTKJTShopParameter param, string orgId, List<FPurchaseStockInEntryItem> entryList)
        {
            //JKCR+年月日+自增ID（三位）
            string dateStr = goodsDocIn.InOutDate2?.ToString("yyyy-MM-dd HH:mm:ss") ?? DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            string FBillNo = GenerateBillNo(goodsDocIn.SortId, goodsDocIn.InOutDate2.Value);
            return new PurchaseStockInModel()
            {
                FBillNo= FBillNo,
                FID = 0,
                FBillTypeID = new FBillTypeID()
                {
                    FNUMBER = BILL_TYPE_CODE
                },
                FDate = dateStr,
                IsVerifyBaseDataField=true,
                FStockOrgId = new FStockOrgId()
                {
                    FOrgId = orgId
                },
                FDemandOrgId = new FDemandOrgId()
                {
                    FOrgId = orgId
                },

             
                FPurchaseOrgId = new FPurchaseOrgId()
                {
                    FOrgId = orgId
                },

                FSupplierId = new FSupplierId()
                {
                    FNumber = firstDetail.VendCode
                },
                FOwnerTypeIdHead = OWNER_TYPE,
                FOwnerIdHead = new FOwnerIdHead()
                {
                    FOrgId = orgId
                },
                FCDateOffsetValue = 0,
                FSplitBillType = "A",
              
                FInStockFin = new FInStockFin()
                {
                  
                    FSettleCurrId = new FSettleCurrId()
                    {
                        FNumber =   DEFAULT_CURRENCY
                    },
                    FIsIncludedTax = true,
                    FPriceTimePoint = "1",
                    FLocalCurrId = new FLocalCurrId()
                    {
                        FNumber =   DEFAULT_CURRENCY
                    },
                    FExchangeTypeId = new FExchangeTypeId()
                    {
                        FNumber = EXCHANGE_TYPE
                    },
                    FExchangeRate = 1m,
                    FISPRICEEXCLUDETAX = true,
                },
                FInStockEntry = entryList
            };
        }

        /**
     * JKXC+年月日+自增ID（三位）--销售出库单
JKXT+年月日+自增ID（三位）--销售退货单
JKCR+年月日+自增ID（三位）--采购入库单
JKCT+年月日+自增ID（三位）--采购退货单
    **/
        private string GenerateBillNo(int Sheet, DateTime date)
        {
            string prefix = "JKCR" + date.ToString("yyyyMMdd");
            string numberPart = (Sheet > 0 ? Sheet.ToString() : "").PadLeft(3, '0');
            numberPart = numberPart.Length > 3 ? numberPart.Substring(numberPart.Length - 3) : numberPart;
            // 组合并确保只取最后3位数字
            string combined = prefix + numberPart;
            return combined;

        }
    }
}