開源跨平臺運行服務插件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
}