namespace TaskCore.Test
{
 // This project can output the Class library as a NuGet Package.
 // To enable this option, right-click on the project and select the Properties menu item. In the Build tab select "Produce outputs on build".
 public class BlogsObj : TPlugin
 {
  public BlogsObj()
  {

  }

  public override void TPlugin_Load()
  {
   var sbLog = new StringBuilder(string.Empty);
   try
   {
    sbLog.Append($"這里是BlogsObj，獲取配置文件：{this.XmlConfig.Name}");

    //代碼塊
    //

    new WriteLog()._WriteLog($"{DateTime.Now}測試引用nuget包");

   }
   catch (Exception ex)
   {
    sbLog.Append($"異常信息：{ex.Message}");
   }
   finally
   {

    PublicClass._WriteLog(sbLog.ToString(), this.XmlConfig.Name);
   }
  }
 }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TaskCore.Plugin;

namespace TaskCore.Test
{
 // This project can output the Class library as a NuGet Package.
 // To enable this option, right-click on the project and select the Properties menu item. In the Build tab select "Produce outputs on build".
 public class BlogsObj01 : TPlugin
 {
  public BlogsObj01()
  {

  }

  public override void TPlugin_Load()
  {
   var sbLog = new StringBuilder(string.Empty);
   try
   {
    sbLog.Append($"這里是BlogsObj01，獲取配置文件：{this.XmlConfig.Name}");

    //代碼塊
    //
   }
   catch (Exception ex)
   {
    sbLog.Append($"異常信息：{ex.Message}");
   }
   finally
   {
    //Console.WriteLine($"這里是Blogs，獲取配置文件：{this.XmlConfig.Name}");
    PublicClass._WriteLog(sbLog.ToString(), this.XmlConfig.Name);
   }
  }
 }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TaskCore.Plugin;

namespace TaskCore.Test
{
 // This project can output the Class library as a NuGet Package.
 // To enable this option, right-click on the project and select the Properties menu item. In the Build tab select "Produce outputs on build".
 public class BlogsObj02 : TPlugin
 {
  public BlogsObj02()
  {

  }

  public override void TPlugin_Load()
  {
   //Console.WriteLine($"這里是Blogs，獲取配置文件：{this.XmlConfig.Name}");
   PublicClass._WriteLog($"這里是BlogsObj02，獲取配置文件：{this.XmlConfig.Name}", this.XmlConfig.Name);
  }
 }
}

<!--
 1.xml配置模板
 2.utf-8文件
 3.復(fù)制到程序根目錄下面PluginXml文件夾下
 4.每個任務(wù)建議創(chuàng)建和程序dll名稱相同xml配置文件
-->
<TaskMain>
 <!--固定：執(zhí)行任務(wù)時間計時器（分鐘）-->
 <Timer>1</Timer>
 <!--固定：任務(wù)名稱-->
 <Name>獲取博客信息</Name>
 <!--固定：賬號-->
 <UserName></UserName>
 <!--固定：密碼-->
 <UserPwd></UserPwd>
 <!--固定：key-->
 <ApiKey></ApiKey>
 <!--固定：key-->
 <ApiUrl></ApiUrl>
 <!--固定：是否關(guān)閉任務(wù) 1:是 0：否-->
 <CloseTask>0</CloseTask>
 
<!--固定：描述-->
 <Des>獲取博客信息</Des>
 <!--自定義：其他配置信息-->
 <Other>
 <ShenNiuBuXing3>神牛步行3</ShenNiuBuXing3>
 </Other>
</TaskMain>

<!--
 CrossFiles指定對應(yīng)任務(wù)的dll文件，必須存在的文件
-->
<TaskMain>
 <File>TaskCore.Test.dll</File>
</TaskMain>

{
 "version": "1.0.0-*",
 "buildOptions": {
 "emitEntryPoint": true
 },

 "dependencies": {
 "Microsoft.NETCore.App": {
  //"type": "platform", 跨平臺發(fā)布需要注釋
  "version": "1.0.0"
 },
 "System.IO.FileSystem": "4.0.1",
 "System.Reflection": "4.1.0",
 "System.Text.Encoding.CodePages": "4.0.1",
 "System.Threading.Timer": "4.0.1",
 "System.Xml.XDocument": "4.0.11",
 "TaskCore.Plugin": "1.0.0"
 },

 "frameworks": {
 "netcoreapp1.0": {
  "imports": "dnxcore50"
 }
 },
 //跨平臺發(fā)布需要添加如下節(jié)點
 "runtimes": {
 "ubuntu.16.04-x64": { }, //運行在ubuntu.16.04的64位系統(tǒng)
 "win7-x64": { } //運行在win7的64位系統(tǒng)
 }
}

namespace TaskCore.MainForm
{
 /// <summary>
 /// author 神牛步行3
 /// contact 841202396@qq.com
 /// des TaskCore.MainForm跨平臺插件由神牛步行3提供
 /// </summary>
 public class Program
 {

  private static Dictionary<string, MoAssembly> dicTasks = new Dictionary<string, MoAssembly>();

  public static void Main(string[] args)
  {
   //注冊編碼，防止亂碼
   Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);

   //初始化程序集文件
   _Init();

   //是否繼續(xù)開啟任務(wù)，默認(rèn)沒有待執(zhí)行任務(wù)，不提示
   if (dicTasks.Count <= 0) { _LoopAlert("是否退出？(Y/N)"); return; }
   _LoopAlert("是否開始執(zhí)行任務(wù)？(Y / N)");

   //執(zhí)行任務(wù)
   foreach (var item in dicTasks.Values)
   {
    //使用Task防止異常后相互影響
    Task.Run(() =>
    {
     try
     {

      //創(chuàng)建任務(wù)對象
      var tp = item.Asm.CreateInstance(item.FullName) as TPlugin;
      if (!string.IsNullOrEmpty(tp.XmlConfig.TpError)) { _Alert($"{DateTime.Now.ToString("yyyy/MM/dd HH:mm")}：{tp.XmlConfig.Name} - 異常信息：{tp.XmlConfig.TpError}"); }
      else
      {

       //timer定時器
       var timer = new Timer((param) =>
       {
        var msg = $"{DateTime.Now.ToString("yyyy/MM/dd HH:mm")}：{tp.XmlConfig.Name}";
        try
        {
         var tpObj = param as TPlugin;
         //是否關(guān)閉暫停任務(wù)
         if (tpObj.XmlConfig.CloseTask) { return; }
         _Alert($"{msg} - 開始執(zhí)行...{tp.XmlConfig.Timer}分鐘一次");
         //任務(wù)入口
         tpObj.TPlugin_Load();
        }
        catch (Exception ex) { _Alert($"{msg} - 異常信息：{ex.Message}"); }
       }, tp, 0, 1000 * 60 * tp.XmlConfig.Timer);
      }

     }
     catch (Exception ex)
     {
      _Alert($"{DateTime.Now.ToString("yyyy/MM/dd HH:mm")}：{item.Name} - 異常信息：{ex.Message}");
     }
    });
   }
   _LoopAlert("正在監(jiān)控執(zhí)行的任務(wù)，是否退出？(Y / N)");
  }

  /// <summary>
  /// 初始化程序集文件
  /// </summary>
  private static void _Init()
  {
   try
   {

    _Alert("初始化任務(wù)中...");
    //獲取文件
    var files = PublicClass._GetPluginFile("");
    if (files.Length <= 0) { _Alert("未能找到可用的程序集,請檢查配置"); return; }

    //讀取任務(wù)文件
    _Alert("讀取CrossFiles.xml配置中...");
    var baseAddr = Path.Combine(Directory.GetCurrentDirectory(), "PluginXml", "CrossFiles.xml");
    var doc = XDocument.Load(baseAddr);
    var fileables = files.AsEnumerable();
    var taskFiles = new List<FileInfo>();
    foreach (var item in doc.Root.Nodes())
    {
     var crossFile = item.ToString().ToUpper();
     var choiceFiles = fileables.Where(b => crossFile.Contains(b.Name.ToUpper()));
     if (!choiceFiles.Any()) { continue; }

     taskFiles.AddRange(choiceFiles);
    }

    //展示文件信息
    _Alert($"待遍歷{taskFiles.Count}個文件信息...");
    foreach (var item in taskFiles.OrderBy(b => b.CreationTime))
    {
     var asmName = new AssemblyName($"{item.Name.Replace(".dll", "")}");
     Assembly sm = Assembly.Load(asmName);
     if (sm == null) { continue; }
     var ts = sm.GetTypes();
     //判斷特定的任務(wù)類，加入任務(wù)dic
     foreach (var t in ts.Where(b => b.Name != "TPlugin" && b.GetMethod("TPlugin_Load") != null))
     {

      dicTasks.Add(
       t.FullName,
       new MoAssembly
       {
        Asm = sm,
        FullName = t.FullName,
        Name = t.Name
       });
     }
    }
    _Alert($"獲取待執(zhí)行任務(wù)量：{dicTasks.Count}個");
   }
   catch (Exception ex)
   {
    _Alert($"異常信息：{ ex.Message}");
   }
  }

  /// <summary>
  /// 消息提醒
  /// </summary>
  /// <param name="msg">提示信息</param>
  /// <param name="isReadLine">是否需要用戶輸入指令</param>
  /// <returns>用戶錄入的指令</returns>
  private static string _Alert(string msg = "神牛步行3-消息提醒", bool isReadLine = false)
  {
   Console.WriteLine(msg);
   if (isReadLine) { return Console.ReadLine(); }
   return "";
  }

  private static void _LoopAlert(string msg = "是否開始執(zhí)行任務(wù)？(Y/N)")
  {
   do
   {
    var readKey = _Alert(msg, true);
    if (readKey.ToUpper().Contains("Y")) { break; }
   } while (true);
  }
 }

 public class MoAssembly
 {
  public Assembly Asm { get; set; }
  public string FullName { get; set; }

  public string Name { get; set; }
 }
}

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
using System.Xml.Linq;

namespace TaskCore.Plugin
{
 /// <summary>
 /// 插件基類
 /// </summary>
 public class TPlugin : IDisposable
 {

  public TPlugin()
  {

   XmlConfig = _InitConfig();
  }

  #region 初始化Xml配置文件 _InitConfig +XmlConfig

  /// <summary>
  /// xml配置信息
  /// </summary>
  public XmlConfig XmlConfig;


  /// <summary>
  /// 初始化配置信息
  /// </summary>
  /// <param name="configPath">配置文件對應(yīng)路徑</param>
  /// <returns></returns>
  public virtual XmlConfig _InitConfig(string configPath = "")
  {
   XmlConfig config = new XmlConfig();
   config.Timer = 1;
   config.Name = this.GetType().Name;
   try
   {

    if (string.IsNullOrEmpty(configPath))
    {

     //默認(rèn)各個dllXml配置
     var defaultConfigFolder = "PluginXml";
     var baseAddr = Directory.GetCurrentDirectory();
     configPath = Path.Combine(baseAddr, defaultConfigFolder, config.Name + ".xml");
    }

    var doc = XDocument.Load(configPath);
    config.doc = doc;
    var taskMain = doc.Root;

    config.Timer = Convert.ToInt32(taskMain.Element(XName.Get("Timer", "")).Value);
    config.Name = taskMain.Element(XName.Get("Name", "")).Value;
    config.Des = taskMain.Element(XName.Get("Des", "")).Value;

    config.UserName = taskMain.Element(XName.Get("UserName", "")).Value;
    config.UserPwd = taskMain.Element(XName.Get("UserPwd", "")).Value;
    config.ApiKey = taskMain.Element(XName.Get("ApiKey", "")).Value;
    config.ApiUrl = taskMain.Element(XName.Get("ApiUrl", "")).Value;
    config.CloseTask = taskMain.Element(XName.Get("CloseTask", "")).Value == "1";

   }
   catch (Exception ex)
   {
    config.TpError = ex.Message;
    PublicClass._WriteLog($"{config.Name}初始化配置信息異常：{ex.Message}", "BaseLog");
    throw new Exception(ex.Message);
   }
   return config;
  }
  #endregion

  #region 初始化-開始加載 _Load

  /// <summary>
  /// 初始化-開始起
  /// </summary>
  public virtual void TPlugin_Load()
  {

   PublicClass._WriteLog("測試");
  }

  #endregion

  #region 釋放資源

  public void Dispose()
  {

   GC.SuppressFinalize(this);//不需要再調(diào)用本對象的Finalize方法
  }

  public virtual void Dispose(Action action)
  {

   action();
  }

  #endregion
 }

 #region 配置文件 XmlConfig

 public class XmlConfig
 {
  public XmlConfig()
  {

  }

  /// <summary>
  /// 定制器時間（分鐘）
  /// </summary>
  public int Timer { get; set; }

  /// <summary>
  /// 運行名稱
  /// </summary>
  public string Name { get; set; }

  /// <summary>
  /// 描述(第一次獲取dll描述，后面獲取xml配置文件描述)
  /// </summary>
  public string Des { get; set; }

  /// <summary>
  /// 接口賬號
  /// </summary>
  public string UserName { get; set; }

  /// <summary>
  /// 接口密碼
  /// </summary>
  public string UserPwd { get; set; }

  /// <summary>
  /// 接口秘鑰
  /// </summary>
  public string ApiKey { get; set; }

  /// <summary>
  /// 接口地址
  /// </summary>
  public string ApiUrl { get; set; }

  /// <summary>
  /// 是否關(guān)閉任務(wù)
  /// </summary>
  public bool CloseTask { get; set; }

  /// <summary>
  /// 插件中錯誤
  /// </summary>
  public string TpError { get; set; }


  /// <summary>
  /// xml信息
  /// </summary>
  public XDocument doc { get; set; }
 }

 #endregion
}