using System;
using System.Collections.Generic;
using System.Globalization;
using System.IO;
using System.Linq;
using CsvHelper;
using CsvHelper.Configuration;
using HH.WCS.Mobox3.RiDong.generalMethod;
using HH.WCS.Mobox3.RiDong.models;

namespace HH.WCS.Mobox3.RiDong.util;

/// <summary>
/// System.IO.Directory类帮助方法类
/// </summary>
public static class DirectoryHelper
{
    /// <summary>
    /// 获取指定路径内的文件
    /// </summary>
    public static void GainData()
    {
        string folderPath = "D:\\FTP\\AS400";
        // string folderPath = "C:\\ftp\\AS400";
        // string folderPath = "D:\\Work Tools\\Project Files\\Studio Projects Files\\日东项目\\ftp\\AS400";

        if (!Directory.Exists(folderPath))
        {
            Console.WriteLine($"指定的文件夹 {folderPath} 不存在。");
            return;
        }
        bool delete = false;
        string[] files = Directory.GetFiles(folderPath, "*.csv");
        foreach (string file in files)
        {
            // 读取处理文件
            ProcessCsvFile(file, ref delete);

            // 删除文件
            if (delete)
            {
                File.Delete(file);
            }
        }
    }


    /// <summary>
    /// 读取数据并进行处理
    /// </summary>
    /// <param name="filePath"></param>
    /// <param name="delete"></param>
    private static void ProcessCsvFile(string filePath, ref bool delete)
    {
        var fileName = Path.GetFileName(filePath);

        var config = new CsvConfiguration(CultureInfo.InvariantCulture)
        {
            //Delimiter = ";",          // 自定义分隔符
            IgnoreBlankLines = true,   // 忽略空行
            AllowComments = true,       // 允许注释行
            BadDataFound = null,
            HasHeaderRecord = false
        };

        try
        {
            using (var reader = new StreamReader(filePath))
            using (var csv = new CsvReader(reader, config))
            {
                if (fileName.StartsWith("MO"))
                {
                    // LogHelper.Info($"ftp文件读取{fileName}");
                    List<MaterialOut> materialOuts = new List<MaterialOut>();

                    while (csv.Read())
                    {
                        // if (csv.GetField<string>(100) == "")
                        // {
                            MaterialOut materialOut = new MaterialOut
                            {
                                S_TRANSACTION = csv.GetField<string>(0),
                                S_TRAN_SUB_SEQ = csv.GetField<string>(1),
                                S_TRANSACTION_TYPE = csv.GetField<int>(2),
                                S_SO = csv.GetField<string>(3),
                                S_ORDER_LINE = csv.GetField<int>(4),
                                S_END_USER = csv.GetField<string>(5),
                                S_INT_ITEM_CODE = csv.GetField<string>(6),
                                S_INT_PRODUCT_CODE = csv.GetField<string>(7),
                                S_COLOR_CODE = csv.GetField<string>(8),
                                S_WAREHOUSE_CODE = csv.GetField<string>(9),
                                S_STORE = csv.GetField<string>(10),
                                S_LOT = csv.GetField<string>(11),
                                S_LOR_QUANTITYOT = csv.GetField<int>(12),
                                D_CREATION_DATE = csv.GetField<string>(13),
                                // T_CREATION_TIME = csv.GetField<DateTime>(14),
                                S_USER_NAME = csv.GetField<string>(15),
                                S_ORIG_TRANSACTION = csv.GetField<string>(16),
                                D_RESULT_DATE = csv.GetField<string>(17),
                                // T_RESULT_TIME = csv.GetField<DateTime>(18),
                                S_WMST = csv.GetField<string>(19),
                                S_ACTUAL_QUANTITY = csv.GetField<string>(20),
                                D_COMPLETE_DATE = csv.GetField<string>(21),
                                // T_COMPLETE_TIME = csv.GetField<DateTime>(22)
                            };

                            if (AdoSqlMethod<MaterialOut>.QueryCount(p =>
                                    p.S_TRANSACTION == materialOut.S_TRANSACTION) == 0)
                            {
                                var first = materialOuts.FirstOrDefault(p =>
                                    p.S_TRANSACTION == materialOut.S_TRANSACTION &&
                                    p.S_LOT == materialOut.S_LOT &&
                                    p.S_INT_PRODUCT_CODE == materialOut.S_INT_PRODUCT_CODE);

                                if (first != null)
                                {
                                    first.S_LOR_QUANTITYOT += materialOut.S_LOR_QUANTITYOT;
                                }
                                else
                                {
                                    materialOuts.Add(materialOut);
                                }
                            }
                            
                            if (materialOut.S_TRANSACTION_TYPE == 211)
                            {
                                var outboundOrder = AdoSqlMethod<OutboundOrder>.QueryFirst(p=>p.S_NO == materialOut.S_TRANSACTION && p.N_B_STATE == 0);
                            
                                if (outboundOrder != null)
                                {
                                    // 修改为取消，重新写方法
                                    if (AdoSqlMethod<OutboundOrder>.UpdateFirstOutBoundStart(outboundOrder,
                                            $"update TN_Outbound_Order SET N_B_STATE = 5, SET FTP_CANCEL = 'Y' WHERE N_B_STATE = 0 and S_NO = {materialOut.S_TRANSACTION}"))
                                    {
                                        // 修改成功
                                    }
                                    else
                                    {
                                        // 修改失败
                                        AdoSqlMethod<OutboundOrder>.UpdateFirstOutBoundStart(outboundOrder,
                                            $"update TN_Outbound_Order SET FTP_CANCEL = 'N' WHERE S_NO = {materialOut.S_TRANSACTION}");
                                    }
                                }
                            }
                        // }
                    }

                    if(materialOuts.Count > 0)
                        // 将数据添加进数据库中，然后对于的数据需要生成任务
                        AdoSqlMethod<MaterialOut>.AddList(materialOuts);
                   
                    // 写入领用单（要过滤的，用文件名当作单号，已经处理的不要重复处理，正常情况下处理完就删除了，测试时候关闭自动删除）
                    delete = true;
                }
                else if (fileName.StartsWith("DO")) 
                {
                    List<DoOut> doOuts = new List<DoOut>();

                    while (csv.Read())
                    {
                        // if (csv.GetField<string>(100) == "")
                        // {
                            DoOut doOut = new DoOut
                            {
                                S_TRANSACTION = csv.GetField<string>(0),
                                S_TRAN_SUB_SEQ = csv.GetField<string>(1),
                                S_TRANSACTION_TYPE = csv.GetField<int>(2),
                                S_SO = csv.GetField<string>(3),
                                S_ORDER_LINE = csv.GetField<int>(4),
                                S_END_USER = csv.GetField<string>(5),
                                S_INT_ITEM_CODE = csv.GetField<string>(6),
                                S_INT_PRODUCT_CODE = csv.GetField<string>(7),
                                S_COLOR_CODE = csv.GetField<string>(8),
                                S_WAREHOUSE_CODE = csv.GetField<string>(9),
                                S_STORE = csv.GetField<string>(10),
                                S_LOT = csv.GetField<string>(11),
                                S_LOR_QUANTITYOT = csv.GetField<int>(12),
                                S_PRODUCT_SIGN = csv.GetField<string>(13),
                                D_CREATION_DATE = csv.GetField<string>(14),
                                // T_CREATION_TIME = csv.GetField<DateTime>(15),
                                D_SEND_DATE = csv.GetField<string>(16),
                                // T_SEND_TIME = csv.GetField<DateTime>(17),
                                S_USER_NAME = csv.GetField<string>(18),
                                S_ORIG_TRANSACTION = csv.GetField<string>(19),
                                D_RESULT_DATE = csv.GetField<string>(20),
                                // T_RESULT_TIME = csv.GetField<DateTime>(21),
                                S_WMST = csv.GetField<string>(22),
                                S_ACTUAL_QUANTITY = csv.GetField<string>(23),
                                D_COMPLETE_DATE = csv.GetField<string>(24),
                                // T_COMPLETE_TIME = csv.GetField<DateTime>(25),
                            };
                        
                            if (AdoSqlMethod<DoOut>.QueryCount(p =>
                                    p.S_TRANSACTION == doOut.S_TRANSACTION) == 0 && doOut.S_TRANSACTION_TYPE == 210)
                            {
                                var first = doOuts.FirstOrDefault(p =>
                                    p.S_TRANSACTION == doOut.S_TRANSACTION && p.S_LOT == doOut.S_LOT &&
                                    p.S_INT_PRODUCT_CODE == doOut.S_INT_PRODUCT_CODE && p.S_SO == doOut.S_SO);

                                if (first != null)
                                {
                                    first.S_LOR_QUANTITYOT += doOut.S_LOR_QUANTITYOT;
                                }
                                else
                                {
                                    doOuts.Add(doOut);
                                }
                            }
                        
                            if (doOut.S_TRANSACTION_TYPE == 211)
                            {
                                var outboundOrder = AdoSqlMethod<OutboundOrder>.QueryFirst(p=>p.S_NO == doOut.S_TRANSACTION && p.N_B_STATE == 0);
                        
                                if (outboundOrder != null)
                                {
                                    // 修改为取消，重新写方法
                                    if (AdoSqlMethod<OutboundOrder>.UpdateFirstOutBoundStart(outboundOrder,
                                            $"update TN_Outbound_Order SET N_B_STATE = 5, SET FTP_CANCEL = 'Y' WHERE N_B_STATE = 0 and S_NO = {doOut.S_TRANSACTION}"))
                                    {
                                        // 修改成功
                                    }
                                    else
                                    {
                                        // 修改失败
                                        AdoSqlMethod<OutboundOrder>.UpdateFirstOutBoundStart(outboundOrder,
                                            $"update TN_Outbound_Order SET FTP_CANCEL = 'N' WHERE S_NO = {doOut.S_TRANSACTION}");
                                    }
                                }
                            }
                        // }
                    }

                    if (doOuts.Count > 0)
                    {
                        // 将数据添加进数据库中，然后对于的数据需要生成任务
                        AdoSqlMethod<DoOut>.AddList(doOuts);
                    }
                    // 任务生成成功，打标记，然后将文件进行删除
                    // 写入出库单
                    delete = true;
                }
                else if (fileName.StartsWith("PRD"))
                {
                    List<TN_Material> tnMaterials = new List<TN_Material>();

                    while (csv.Read())
                    {
                        var type = csv.GetField<string>(19);
                        var type2 = "";

                        if (type == "C")
                        {
                            type2 = "制品";
                        }
                        else if (type == "R")
                        {
                            type2 = "原料";
                        }

                        var tnMaterial = new TN_Material()
                        {
                            // 规格编码
                            S_MATERIAL_CODE = csv.GetField<string>(4),
                            // 物料编码
                            S_ITEM_CODE = csv.GetField<string>(0),
                            // 规格
                            S_MATERIAL = csv.GetField<string>(5),
                            S_MATERIAL_TYPE = type2,
                            // F_WEIGHT = item.WEIGHT,
                        };

                        if (AdoSqlMethod<TN_Material>.QueryCount(p => p.S_ITEM_CODE == tnMaterial.S_ITEM_CODE) == 0)
                        {
                            // AdoSqlMethod<Item>.QueryFirst(p=>p.INTERNAL_ITEM_CODE == tnMaterial.INTERNAL_ITEM_CODE);
                            tnMaterials.Add(tnMaterial);
                        }
                    }

                    // 将数据添加进数据库中
                    AdoSqlMethod<TN_Material>.AddList(tnMaterials);

                    // 任务生成成功，打标记，然后将文件进行删除
                    // 写入出库单
                    delete = true;
                }
                else if (fileName.StartsWith("ITM"))
                {
                    int readNumber = 0;
                    int updateNumber = 0;

                    while (csv.Read())
                    {
                        readNumber++;

                        var INTERNAL_ITEM_CODE = csv.GetField<string>(2);

                        var tnMaterials = AdoSqlMethod<TN_Material>.QueryList(p =>
                            p.S_MATERIAL_CODE == INTERNAL_ITEM_CODE);

                        string name = csv.GetField<string>(0);

                        if (tnMaterials.Count > 0)
                        {
                            foreach (var tnMaterial in tnMaterials)
                            {
                                tnMaterial.S_ITEM_NAME = name;
                            }

                            AdoSqlMethod<TN_Material>.UpdateList(tnMaterials, p => new { p.S_ITEM_NAME });
                            updateNumber++;
                        }
                    }

                    if (readNumber == updateNumber)
                    {
                        // 读取的数据条数和操作的数据条数一致删除
                        delete = true;
                    }
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"处理文件 {filePath} 时出现异常: {ex.Message}");
        }
    }
}