using Autofac;
|
using AutoMapper;
|
using Newtonsoft.Json;
|
using Quartz;
|
using Serilog;
|
using System;
|
using System.Collections.Generic;
|
using System.Reflection;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Utility.Entity;
|
|
namespace Utility.Job
|
{
|
public class InternalMethodJob : JobBase<LogModel>, IJob
|
{
|
|
public InternalMethodJob() : base(new LogModel())
|
{
|
|
}
|
|
public override async Task NextExecute(IJobExecutionContext context)
|
{
|
// 获取相关参数
|
var className = context.JobDetail.JobDataMap.GetString(Constant.CLASSNAME)?.Trim();
|
var methodName = context.JobDetail.JobDataMap.GetString(Constant.METHODNAME)?.Trim();
|
var methodParameters = context.JobDetail.JobDataMap.GetString(Constant.METHODPARAMETERS);
|
|
try
|
{
|
/// 加载 WMS.BLL 类库
|
Assembly assembly;
|
try
|
{
|
assembly = Assembly.LoadFrom("WMS.BLL.dll");
|
}
|
catch (Exception)
|
{
|
assembly = Assembly.LoadFrom("bin\\Debug\\netcoreapp3.1\\WMS.BLL.dll");
|
}
|
|
// 获取 WMS.BLL的类型
|
Type classType = assembly.GetType("WMS.BLL." + className);
|
|
if (classType == null)
|
{
|
throw new TypeLoadException($"找不到该类型{className}");
|
}
|
#region 容器创建示例 有报错搞不定抽空再弄
|
|
//var builder = new ContainerBuilder();
|
|
//// 注册需要的服务和类型
|
//builder.RegisterAssemblyTypes(Assembly.Load("WMS.IDAL"), Assembly.Load("WMS.DAL"), Assembly.Load("WMS.IBLL"),
|
// Assembly.Load("WMS.BLL"));
|
//builder.RegisterType<Mapper>().As<IMapper>();
|
|
//// 使用 Autofac 容器来解析类的实例
|
//var scope = builder.Build();
|
|
//var instance = scope.Resolve(classType);
|
#endregion
|
|
// 创建实例（如果方法是实例方法） 无注入 必须有空参数的构造函数
|
object instance = Activator.CreateInstance(classType);
|
|
// 获取方法信息
|
MethodInfo methodInfo = classType.GetMethod(methodName);
|
|
if (methodInfo == null)
|
{
|
throw new ArgumentException($"找不到该方法{methodName}");
|
}
|
|
// 调用方法
|
object result = null;
|
if (methodInfo.GetParameters().Length == 0)
|
{
|
// 无参方法
|
result = methodInfo.Invoke(instance, null);
|
}
|
else
|
{
|
// 有参方法
|
var parameters = JsonConvert.DeserializeObject<object[]>(methodParameters); // 解析方法参数
|
result = await (Task<object>)methodInfo.Invoke(instance, parameters);
|
}
|
|
// 处理方法执行结果
|
LogInfo.Result = JsonConvert.SerializeObject(result);
|
}
|
catch (Exception ex)
|
{
|
LogInfo.ErrorMsg = ex.Message;
|
context.JobDetail.JobDataMap[Constant.EXCEPTION] = $"<div class='err-time'>{LogInfo.BeginTime}</div>{JsonConvert.SerializeObject(LogInfo)}";
|
}
|
//_logger.Error(ex, $"执行方法时出错 {methodName}: {ex.Message}");
|
}
|
}
|
}
|
