开源跨平台运行服务插件TaskCore.MainForm

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.复制到程序根目录下面PluginXml文件夹下
 4.每个任务建议创建和程序dll名称相同xml配置文件
-->
<TaskMain>
 <!--固定：执行任务时间计时器（分钟）-->
 <Timer>1</Timer>
 <!--固定：任务名称-->
 <Name>获取博客信息</Name>
 <!--固定：账号-->
 <UserName></UserName>
 <!--固定：密码-->
 <UserPwd></UserPwd>
 <!--固定：key-->
 <ApiKey></ApiKey>
 <!--固定：key-->
 <ApiUrl></ApiUrl>
 <!--固定：是否关闭任务 1:是 0：否-->
 <CloseTask>0</CloseTask>
 
<!--固定：描述-->
 <Des>获取博客信息</Des>
 <!--自定义：其他配置信息-->
 <Other>
 <ShenNiuBuXing3>神牛步行3</ShenNiuBuXing3>
 </Other>
</TaskMain>

<!--
 CrossFiles指定对应任务的dll文件，必须存在的文件
-->
<TaskMain>
 <File>TaskCore.Test.dll</File>
</TaskMain>

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

 "dependencies": {
 "Microsoft.NETCore.App": {
  //"type": "platform", 跨平台发布需要注释
  "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"
 }
 },
 //跨平台发布需要添加如下节点
 "runtimes": {
 "ubuntu.16.04-x64": { }, //运行在ubuntu.16.04的64位系统
 "win7-x64": { } //运行在win7的64位系统
 }
}

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();

   //是否继续开启任务，默认没有待执行任务，不提示
   if (dicTasks.Count <= 0) { _LoopAlert("是否退出？(Y/N)"); return; }
   _LoopAlert("是否开始执行任务？(Y / N)");

   //执行任务
   foreach (var item in dicTasks.Values)
   {
    //使用Task防止异常后相互影响
    Task.Run(() =>
    {
     try
     {

      //创建任务对象
      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;
         //是否关闭暂停任务
         if (tpObj.XmlConfig.CloseTask) { return; }
         _Alert($"{msg} - 开始执行...{tp.XmlConfig.Timer}分钟一次");
         //任务入口
         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("正在监控执行的任务，是否退出？(Y / N)");
  }

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

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

    //读取任务文件
    _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();
     //判断特定的任务类，加入任务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($"获取待执行任务量：{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 = "是否开始执行任务？(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">配置文件对应路径</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))
    {

     //默认各个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);//不需要再调用本对象的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>
  /// 是否关闭任务
  /// </summary>
  public bool CloseTask { get; set; }

  /// <summary>
  /// 插件中错误
  /// </summary>
  public string TpError { get; set; }


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

 #endregion
}