using Kingdee.CDP.WebApi.SDK;
using MES.Service.Models;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Filters;
using NewPdaSqlServer.DB;
using NewPdaSqlServer.Dto;
using NewPdaSqlServer.entity;
using NewPdaSqlServer.util;
using Newtonsoft.Json;
using SqlSugar;
using System.Text;

namespace MES.Service.service.Kingdee;

public class ErpBOMManager : Repository<ErpBOM>
{

    #region 获取BOM
    public bool QueryErpBOM()
    {
        List<ErpBom> bom = GetErpBOM();

        // 检查返回结果是否为空
        if (bom == null || bom.Count == 0)
        {
            throw new NotImplementedException("返回结果为空");
        }
        else
        {
            var baseObjects = MapErpBOMtoMes(bom);

            return UseTransaction(db =>
            {
                return SaveBOMData(db, baseObjects) ? 1 : 0;
            }) > 0;
        }
    }

    private bool SaveBOMData(SqlSugarScope db, List<ErpBOM> kcc)
    {
        Db.Deleteable<ErpBOM>()
          .ExecuteCommand();

        var save = base.InsertRange(kcc);
        if (save) return true;
        throw new NotImplementedException("插入失败");
    }

    public List<ErpBom> GetErpBOM()
    {
        //注意 1：此处不再使用参数形式传入用户名及密码等敏感信息，改为在登录配置文件中设置。
        //注意 2：必须先配置第三方系统登录授权信息后，再进行业务操作，详情参考各语言版本SDK介绍中的登录配置文件说明。
        //读取配置，初始化SDK
        K3CloudApi client = new K3CloudApi();
        //用于记录结果
        StringBuilder Info = new StringBuilder();
        //业务对象标识
        string formId = "ENG_BOM";
        DateTime dt = DateTime.Now;
        //查询字段集合，即返回哪些数据，不能为空，根据不同业务单据填写不同的字段名，以下仅为示例
        //string fieldKeys = "FCod,FFileId,FRelevantObject";
        //string FilterString = "FID='-2146304'";
        string fieldKeys = "FITEMPPROPERTY ,FMATERIALID  ,FITEMNAME ,FTreeEntity_FENTRYID ,FCHILDITEMNAME ,FNUMERATOR , FDENOMINATOR";
        var filterString = new[]
                            {
                                new
                                {
                                    FieldName = "FITEMPPROPERTY",
                                    Compare = "29",
                                    Value = "3",
                                    Left = "(",
                                    Right = ")",
                                    Logic = 0
                                }
                            };
        var param = new QueryParams()
        {
            FormId = formId,
            FieldKeys = fieldKeys,
            FilterString = filterString
        };
        //调用接口
        var result = client.ExecuteBillQuery(param.ToJson());

        return result.Select(s =>
        {
            var entity = new ErpBom
            {
                FITEMPPROPERTY = s[0]?.ToString(),
                FMATERIALID = s[1]?.ToString(),
                FITEMNAME = s[2]?.ToString(),
                FENTRYID = s[3]?.ToString(),
                FCHILDITEMNAME = s[4]?.ToString(),
                FNUMERATOR = s[5]?.ToString(),
                FDENOMINATOR = s[6]?.ToString()
            };
            return entity;
        }).ToList();
    }

    private class QueryParams :BaseEntify
    {
        public string FormId { get; set; }

        public string FieldKeys { get; set; }

        public object[] FilterString { get; set; }
    }

    private List<ErpBOM> MapErpBOMtoMes(List<ErpBom> dtoList)
    {
        var ErpMesBomList = new List<ErpBOM>();

        foreach (var dto in dtoList)
        {
            var kc = new ErpBOM
            {
                ID = Guid.NewGuid(),
                ItemProperty = dto.FITEMPPROPERTY,
                ItemId = Convert.ToInt32(dto.FMATERIALID),
                ItemName = dto.FITEMNAME,
                ChildItemId = Convert.ToInt32(dto.FENTRYID),
                ChildItemName = dto.FCHILDITEMNAME,
                Numerator = Convert.ToDecimal(dto.FNUMERATOR),
                Denominator = Convert.ToDecimal(dto.FDENOMINATOR)

            };

            ErpMesBomList.Add(kc);
        }

        return ErpMesBomList;
    }
    #endregion

}