using Cowain.Bake.Common;
using Cowain.Bake.Common.Core;
using System;
using System.IO;
using System.Threading.Tasks;
using Unity;
using Unity.Resolution;

namespace Cowain.Bake.Communication.FTP
{
    public class FTPUpload
    {
        string _localFolderPath;
        string _remoteFolderPath;
        FtpHelper ftpClient;
        public string Name { get; set; }
        public IUnityContainer _unityContainer { get; set; }
        public FTPUpload(IUnityContainer unityContainer)
        {
            _unityContainer = unityContainer;

            ftpClient = _unityContainer.Resolve<FtpHelper>(new ParameterOverride("ipAddr","10.19.30.19"), new ParameterOverride("port", 21),
                new ParameterOverride("userName", (object)"admin"), new ParameterOverride("password", (object)"123456"));
            ftpClient.Connect();       
        }

        public void Stop()
        {
            ftpClient.Close();
        }

        public void Start(string src, string desc)
        {
            _localFolderPath = src;
            _remoteFolderPath = desc;
            Task.WaitAny();
            Task.Run(async () =>
            {
                while(true)
                {
                    await Task.Delay(1000);
                    if (Global.AppExit)
                    {
                        ftpClient.Close();
                        return;
                    }

                    UploadToFTPService();
                }            
            });
        }

        //string localFolderPath  = @"E:\svn\CutingStack\CuttingStackingMachine\成都蜂巢6074\tex";    //本地要上传的文件位置   (界面可配)
        //string remoteFolderPath = "/";   //MOM服务要上传到的位置  (界面可配)
        void UploadToFTPService()
        {
            // 获取文件夹及其子文件夹中的所有文件
            string[] files = Directory.GetFiles(_localFolderPath, "*", SearchOption.AllDirectories);
            //string[] files = Directory.GetFiles(localFolderPath);
            try
            {
                // 遍历每个文件
                foreach (string file in files)
                {
                    if (IsUpload(file))
                    {
                        if (ftpClient.UpLoad(file, _remoteFolderPath))
                        {
                            SetFileReadAccess(file, true); //上传的文件做标识(设为可读)
                        }
                    }        
                }
            }
            catch(Exception ex)
            {
                LogHelper.Instance.Error($"上传文件失败,localFolderPath:{_localFolderPath},remoteFolderPath:{_remoteFolderPath},异常:{ex.Message}");
            }  
        }

        //是否上传:可读为假就上传，为真不上传
        bool IsUpload(string filePath)
        {
            return !IsFileReadable(filePath); //默认为假，不可读(可写)
        }

        //读为可读
        public void SetFileReadAccess(string filePath, bool readOnly)
        {
            FileInfo fInfo = new FileInfo(filePath);         
            fInfo.IsReadOnly = readOnly;
        }

        public bool IsFileReadable(string filePath)
        {
            try
            {
                FileAttributes attributes = File.GetAttributes(filePath);
                bool isReadable = (attributes & FileAttributes.ReadOnly) == FileAttributes.ReadOnly;
                return isReadable;
            }
            catch (Exception ex)
            {
                Console.WriteLine($"判断文件可读性时出现错误: {ex.Message}");
                return false;
            }
        }
    }
}