開(kāi)源跨平臺(tái)運(yùn)行服務(wù)插件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}測(cè)試引用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.每個(gè)任務(wù)建議創(chuàng)建和程序dll名稱相同xml配置文件
-->
<TaskMain>
 <!--固定：執(zhí)行任務(wù)時(shí)間計(jì)時(shí)器（分鐘）-->
 <Timer>1</Timer>
 <!--固定：任務(wù)名稱-->
 <Name>獲取博客信息</Name>
 <!--固定：賬號(hào)-->
 <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指定對(duì)應(yīng)任務(wù)的dll文件，必須存在的文件
-->
<TaskMain>
 <File>TaskCore.Test.dll</File>
</TaskMain>

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

 "dependencies": {
 "Microsoft.NETCore.App": {
 //"type": "platform", 跨平臺(tái)發(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"
 }
 },
 //跨平臺(tái)發(fā)布需要添加如下節(jié)點(diǎn)
 "runtimes": {
 "ubuntu.16.04-x64": { }, //運(yùn)行在ubuntu.16.04的64位系統(tǒng)
 "win7-x64": { } //運(yùn)行在win7的64位系統(tǒng)
 }
}

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

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

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

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

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

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

 //創(chuàng)建任務(wù)對(duì)象
 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定時(shí)器
 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} - 開(kāi)始執(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("未能找到可用的程序集,請(qǐng)檢查配置"); 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}個(gè)文件信息...");
 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}個(gè)");
 }
 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 = "是否開(kāi)始執(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">配置文件對(duì)應(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)各個(gè)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 初始化-開(kāi)始加載 _Load

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

 PublicClass._WriteLog("測(cè)試");
 }

 #endregion

 #region 釋放資源

 public void Dispose()
 {

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

 public virtual void Dispose(Action action)
 {

 action();
 }

 #endregion
 }

 #region 配置文件 XmlConfig

 public class XmlConfig
 {
 public XmlConfig()
 {

 }

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

 /// <summary>
 /// 運(yùn)行名稱
 /// </summary>
 public string Name { get; set; }

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

 /// <summary>
 /// 接口賬號(hào)
 /// </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>
 /// 插件中錯(cuò)誤
 /// </summary>
 public string TpError { get; set; }


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

 #endregion
}