using System.Data;
using System.Text;
using Kurisu.SqlSugar.Services;
using Dlhis.Entity.Basic.Entity;
using Dlhis.ScheduledTask.SyncSapInfo.Dto;
using Dlhis.ScheduledTask.SyncSapInfo.Comparers;
using Dlhis.ScheduledTask.SyncSapInfo.Services;
using Kurisu.AspNetCore.Scope;
using Dlhis.Entity.Basic.Enums;
using Dlhis.Sys.Api;
using Dlhis.Sys.Api.Response;
using SqlSugar;
using Dlhis.Basic.Api;

namespace Dlhis.ScheduledTask.SyncSapInfo.Job;

public class SyncPersonJob
{
    private readonly ILogger _logger;
    private readonly IJinkoSapService _jinkoSapService;
    private readonly ITenantApi _tenantApi;
    private readonly IDevicePermissionApi _devicePermissionApi;
    private List<PositionEntity> _positions;
    private List<TenantResponse> _tenants;
    private List<SapPersonDepartmentStatus> _departmentChanges;
    private List<SapPersonJobStatus> _jobChanges;

    public SyncPersonJob(ILogger<SyncPersonJob> logger, IJinkoSapService jinkoSapService,
        ITenantApi tenantApi, IDevicePermissionApi devicePermissionApi)
    {
        _logger = logger;
        _jinkoSapService = jinkoSapService;
        _tenantApi = tenantApi;
        _devicePermissionApi = devicePermissionApi;
    }

    public async Task RunAsync()
    {
        var personResp = await _jinkoSapService.GetPersonsAsync();
        var persons = personResp.Person.Items;
        _departmentChanges = personResp.DepartmentInfo.Items;
        _jobChanges = personResp.JobStatusInfo.Items;

        _logger.LogInformation("获取SAP人员数量为:{count}", persons.Count);
        if (persons.Count > 0)
        {
            Scoped.Temp.Value.Create(sp =>
            {
                var dbContext = sp.GetService<IDbContext>();
                _positions = dbContext.Queryable<PositionEntity>().ToList();
                var modifiedPersons = GetModifiedPerson(dbContext, persons.OrderByDescending(x => x.ZSTATUS).ThenBy(x => x.ZRZRQ).ToList());
                _logger.LogInformation("SAP人员差异数量为:{count}", modifiedPersons.Count);
                if (modifiedPersons.Count > 0)
                {
                    var failedRecords = SavePerson(modifiedPersons);
                }
            });
        }
    }

    private async Task<int> SavePerson(List<SapPersonItem> persons)
    {
        var tenantResult = await _tenantApi.GetTenantsInternalAsync();
        _tenants = tenantResult.Data;

        var failure = 0;
        var workCodes = persons.Select(x => x.ZWORKCODE).ToList();
        var chunks = workCodes.Chunk(4000).ToList();

        await Scoped.Temp.Value.Create(async sp =>
        {
            var dbContext = sp.GetService<IDbContext>();

            foreach (var searchCodes in chunks)
            {
                _logger.LogInformation("SAP分批处理Chunk数量:{count}", searchCodes.Count());
                var dtoResult = await _devicePermissionApi.GetPermissionUsersInfoAsync();
                var dto = dtoResult.Data;

                var existsWorkCodes = dbContext.Queryable<GainfoSapEntity>()
                                        .Where(x => searchCodes.Contains(x.ename))
                                        .Select(x => x.ename)
                                        .ToList();

                var originUpdates = persons.Where(x => existsWorkCodes.Contains(x.ZWORKCODE)).ToList();
                var existsUpdateWorkCodes = originUpdates.Select(x => x.ZWORKCODE).ToList();
                var originInserts = persons.Where(x => searchCodes.Contains(x.ZWORKCODE)).Where(x => !existsUpdateWorkCodes.Contains(x.ZWORKCODE)).ToList();

                int i = 0;
                var currentTotal = originUpdates.Count + originInserts.Count;

                var updates = ToGainfoSap(originUpdates);
                _logger.LogInformation("SAP分批更新数:{count}", updates.Count);
                var inserts = ToGainfoSap(originInserts);
                _logger.LogInformation("SAP分批新增数:{count}", inserts.Count);

                foreach (var item in inserts)
                {
                    i++;
                    try
                    {
                        InsertPerson(dbContext, item);
                        _logger.LogInformation("执行新增成功 工号:{code},姓名:{name}", item.ename, item.gname);
                    }
                    catch (Exception ex)
                    {
                        failure++;
                        _logger.LogError(ex, "执行新增失败:{message}", ex.Message);
                    }

                }

                foreach (var item in updates)
                {
                    i++;
                    try
                    {
                        UpdatePerson(dbContext, item);
                        _logger.LogInformation("执行更新成功 工号:{code},姓名:{name}", item.ename, item.gname);
                    }
                    catch (Exception ex)
                    {
                        failure++;
                        _logger.LogError(ex, "执行更新失败:{message}", ex.Message);
                    }
                }

                var rResult = await _devicePermissionApi.RePermissionUsersInfoAsync(dto);
                var r = rResult.Data;

                _logger.LogInformation("生成下发任务数量:{count}", r);
            }
        });

        return 0;
    }

    private void InsertPerson(IDbContext db, GainfoSapEntity item)
    {
        db.Client.Insertable(item).ExecuteCommand();

        var info = new GainfoEntity
        {
            No = Guid.NewGuid().ToString(),
            SapNo = item.PERNR,
            Type = item.@class,
            Name = item.gname,
            Code = item.ename,
            CountryNo = item.country,
            IdClass = item.idcls,
            IdNo = item.idno,
            Native = item.native,
            Gender = item.sex == "F" ? GenderEnumType.Female : GenderEnumType.Male,
            Birthday = (DateTime)item.birthday,
            Address = item.address,
            DepartmentNo = item.appellation,
            Nation = item.nation,
            Phone = item.phone,
            Degree = item.email,
            Position = item.web,
            Remark = item.remark,
            Werks = item.WERKS,
            Workplace = _tenants.FirstOrDefault(x => x.Name == item.ZZ_GZDJDNM)?.Code ?? item.ZZ_GZDJDNM,
            Factory = _tenants.FirstOrDefault(x => x.Name == item.ZZ_GZDCQNM)?.Code ?? item.ZZ_GZDCQNM,
        };

        if (item.isowner == "T")
        {
            db.Client.Insertable(info).ExecuteCommand();
        }
        else
        {
            db.Client.Insertable(info).AS("GainfoLeave").ExecuteCommand();
        }
    }

    private static void UpdatePerson(IDbContext db, GainfoSapEntity item)
    {
        var gainfoSap = db.Queryable<GainfoSapEntity>().Where(x => x.ename == item.ename).First();
        db.Updateable<GainfoSapEntity>().SetColumns(g => new GainfoSapEntity
        {
            PERNR = item.PERNR,
            gname = item.gname,
            web = item.web,
            phone = item.phone,
            appellation = item.appellation,
            isowner = item.isowner,
            remark = item.remark,
            email = item.email,
            WERKS = item.WERKS,
            ZZ_GZDJDNM = item.ZZ_GZDJDNM,
            ZZ_GZDCQNM = item.ZZ_GZDCQNM,
        })
        .Where(x => x.ename == item.ename)
        .ExecuteCommand();

        var gainfo = db.Queryable<GainfoEntity>().Where(x => x.Code == item.ename).First();
        if (item.isowner == "T")
        {
            db.Updateable<GainfoEntity>().SetColumns(g => new GainfoEntity
            {
                SapNo = item.PERNR,
                Name = item.gname,
                Position = item.web,
                Phone = item.phone,
                DepartmentNo = item.appellation,
                Remark = item.remark,
                Degree = item.email,
                Werks = item.WERKS,
                Workplace = item.ZZ_GZDJDNM,
                Factory = item.ZZ_GZDCQNM
            })
            .Where(x => x.Code == item.ename)
            .ExecuteCommand();
        }
        else
        {
            db.Client.Deleteable(gainfo).ExecuteCommand();
            db.Client.Insertable(gainfo).AS("GainfoLeave").ExecuteCommand();
        }
    }

    private List<SapPersonItem> GetModifiedPerson(IDbContext db, List<SapPersonItem> sapList)
    {
        var last = LoadData(db);
        if (last.Count <= 0)
        {
            return sapList;
        }

        var now = DateTime.Now;
        foreach (var item in sapList)
        {
            var a = _jobChanges.FirstOrDefault(x => x.ZWORKCODE == item.ZWORKCODE);
            if (a != null)
            {
                if (a.BEGDA >= now && a.ENDDA <= now)
                {
                    if (a.STAT2 == "0")
                    {
                        item.STAT2 = "0";
                        item.ZSTATUS = "5";
                    }
                }
            }

            var b = _departmentChanges.FirstOrDefault(x => x.ZWORKCODE == item.ZWORKCODE);
            if (b != null)
            {
                if (b.BEGDA >= now && b.ENDDA <= now)
                {
                    item.ORGEH = b.ORGEH;
                    item.WERKS = b.WERKS;
                }
            }
        }

        var needRemove = sapList.Intersect(last, new SapPersonComparer());
        return sapList.Except(needRemove, new SapPersonComparer()).ToList();
    }


    private static List<SapPersonItem> LoadData(IDbContext db)
    {
        var gainfo = db.Queryable<GainfoSapEntity>().ToList();

        return gainfo.Select(x => new SapPersonItem
        {
            NAME = x.gname,
            ZWORKCODE = x.ename,
            ZZ_SFZH = x.idno,
            GBDAT = x.birthday?.ToString("yyyy-MM-dd") ?? "0000-00-00",
            ZZ_KLX = x.ZZ_KLX,
            ZXUELI = x.email?.Trim() ?? string.Empty,
            ORGEH = x.appellation,
            ZMOBILE = x.phone,
            ZSTATUS = x.ZSTATUS,
            ZRZRQ = x.createdate?.ToString("yyyy-MM-dd"),
            PERNR = x.PERNR,
            WERKS = x.WERKS,
            KOSTL = x.KOSTL,
            ZZ_ZD = x.ZZ_ZD,
            Z_ZJ = x.Z_ZJ,
            STELL = x.STELL,
            STELL_NM = x.STELL_NM,
            ZLZRQ = x.ZLZRQ?.ToString("yyyy-MM-dd"),
            MASSN = x.MASSN,
            MNTXT = x.MNTXT,
        })
        .ToList();
    }


    private List<GainfoSapEntity> ToGainfoSap(List<SapPersonItem> data)
    {
        return data.Select(person =>
        {
            GainfoSapEntity o = null;
            try
            {
                var position = _positions.FirstOrDefault(x => x.No == person.PLANS);

                var rzrq = SafeParseDate(person.ZRZRQ);
                var lzrq = SafeParseDate(person.ZLZRQ);
                var rmk = "";
                if (rzrq != null)
                    rmk = $"入职时间:{rzrq.Value.ToString("yyyy-MM-dd", System.Globalization.CultureInfo.InvariantCulture)} ";

                if (lzrq != null && lzrq.Value.ToString("yyyy-MM-dd") != "1900-01-01")
                    rmk += $"离职时间:{lzrq.Value.ToString("yyyy-MM-dd", System.Globalization.CultureInfo.InvariantCulture)} ";

                if (!string.IsNullOrWhiteSpace(person.MGTXT))
                    rmk += $"变更原因:{person.MGTXT}";

                var native = GetNative(person.ZZ_SFZH);
                var sex = person.GESCH == "2" ? "F" : "M";

                person.ZZ_SFZH = person.ZZ_SFZH?.TrimStart();
                o = new GainfoSapEntity
                {
                    gname = person.NAME,
                    ename = person.ZWORKCODE,
                    idno = SubString(person.ZZ_SFZH, 18),
                    birthday = SafeParseDate(person.GBDAT).Value,
                    ZZ_KLX = person.ZZ_KLX,
                    email = person.ZXUELI,
                    appellation = person.ORGEH,
                    phone = person.ZMOBILE,
                    ZSTATUS = person.ZSTATUS,
                    createdate = Convert.ToDateTime(person.ZRZRQ),
                    PERNR = person.PERNR,
                    WERKS = person.WERKS,
                    KOSTL = person.KOSTL,
                    ZZ_ZD = person.ZZ_ZD,
                    Z_ZJ = person.Z_ZJ,
                    STELL = person.STELL,
                    STELL_NM = person.STELL_NM,
                    ZLZRQ = SafeParseDate(person.ZLZRQ).Value,
                    MASSN = person.MASSN,
                    MNTXT = person.MNTXT,
                    remark = rmk,
                    native = native,
                    sex = sex,
                    web = SubString(position?.Name ?? "", 30),
                    logdate = DateTime.Now,
                    isowner = int.Parse(person.ZSTATUS) < 5 ? "T" : "F",
                    @class = "C",
                    country = person.ZZ_COUNNM,
                    log_ip = "127.0.0.1",
                    log_shift = "1",
                    log_id = "XX",
                    address = "",
                    occupation = "99",
                    nation = "01",
                    ZZ_COUNNM = person.ZZ_COUNNM,
                    ZZ_GZDJDNM = person.ZZ_GZDJDNM,
                    ZZ_GZDCQNM = person.ZZ_GZDCQNM,
                };

                return o;
            }
            catch (Exception ex)
            {
                throw;
            }

        }).ToList();
    }

    private string GetNative(string idno)
    {
        if (string.IsNullOrWhiteSpace(idno) || idno.Length < 6) return null;
        idno = idno.TrimStart();
        return idno.Substring(0, 6);
    }

    private DateTime? SafeParseDate(string str)
    {
        if (string.IsNullOrEmpty(str))
        {
            str = "1900-01-01";
        }

        if ("0000-00-00".Equals(str))
        {
            str = "1900-01-01";
        }

        if (DateTime.TryParse(str, out var d))
        {
            return d;
        }
        return null;
    }

    private string SubString(string s, int len)
    {
        if (string.IsNullOrWhiteSpace(s))
        {
            return s?.Trim() ?? "";
        }
        s = s.Trim();
        var bs = Encoding.UTF8.GetBytes(s);
        if (bs.Length <= len)
        {
            return s;
        }
        var bytes = new byte[len];
        Buffer.BlockCopy(bs, 0, bytes, 0, len);
        return Encoding.UTF8.GetString(bytes);
    }
}