xwl2023/Yi.Framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除hangfire（不支持毫秒级别）

Browse Source 
This reverts commit 49a9eb5460.
This commit is contained in:
陈淳
2022-11-29 12:34:45 +08:00
parent 0f2dc4d3ba
commit d97ef84b7e
5 changed files with 0 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
README.md
View File

@@ -161,7 +161,6 @@ WebFirst开发：所有代码生成器已经配置完成，无需任何操作数
- [x] 支持`数据权限`
- [x] 支持 太多了忘了
****
### 目录结构:

12
Yi.Framework.Net6/Yi.Framework.ApiMicroservice/Config/SwaggerDoc.xml
View File

@@ -602,18 +602,6 @@
</summary>
<returns></returns>
</member>
<member name="M:Yi.Framework.ApiMicroservice.Controllers.TestController.HangfireStratJobTest">
<summary>
hangfireJob测试
</summary>
<returns></returns>
</member>
<member name="M:Yi.Framework.ApiMicroservice.Controllers.TestController.HangfireStopJobTest">
<summary>
hangfireJob测试
</summary>
<returns></returns>
</member>
<member name="M:Yi.Framework.ApiMicroservice.Controllers.TestController.TreeTest">
<summary>
树形结构构建测试

27
Yi.Framework.Net6/Yi.Framework.ApiMicroservice/Controllers/TestController.cs
View File

@@ -221,33 +221,6 @@ namespace Yi.Framework.ApiMicroservice.Controllers
return Result.Success("http://localhost:19001/hangfire");
}
/// <summary>
/// hangfireJob测试
/// </summary>
/// <returns></returns>
[HttpGet]
public Result HangfireStratJobTest()
{
Dictionary<string, object> data = new Dictionary<string, object>()
{
{JobConst.method,"get" },
{JobConst.url,"https://www.baidu.com" }
};
RecurringJob.AddOrUpdate<HttpJob>(nameof(HttpJob),(Job)=>Job.Execute2(data), "*/5 * * * * ?");
return Result.Success("http://localhost:19001/hangfire");
}
/// <summary>
/// hangfireJob测试
/// </summary>
/// <returns></returns>
[HttpGet]
public Result HangfireStopJobTest()
{
RecurringJob.RemoveIfExists(nameof(HttpJob));
return Result.Success();
}
/// <summary>
/// 树形结构构建测试
/// </summary>

14
Yi.Framework.Net6/Yi.Framework.ApiMicroservice/Program.cs
View File

@@ -80,15 +80,6 @@ builder.Services.AddSqlsugarServer(DbFiterExtend.Data);
//Quartz<74><7A><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
#endregion
builder.Services.AddQuartzService();
builder.Services.AddHangfire(option =>
{
option.SetDataCompatibilityLevel(CompatibilityLevel.Version_170);//ȫ<><C8AB><EFBFBD><EFBFBD><EFBFBD>ü<EFBFBD><C3BC>ݰ汾<DDB0><E6B1BE><EFBFBD><EFBFBD><EFBFBD>¼<EFBFBD><C2BC><EFBFBD>
option.UseColouredConsoleLogProvider();//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>־
option.UseSimpleAssemblyNameTypeSerializer();//ʹ<>ü򵥳<C3BC><F2B5A5B3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>л<EFBFBD><D0BB><EFBFBD><EFBFBD><EFBFBD>
option.UseRecommendedSerializerSettings();//ʹ<><CAB9><EFBFBD>Ƽ<EFBFBD><C6BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>л<EFBFBD><D0BB><EFBFBD><EFBFBD><EFBFBD>
option.UseMemoryStorage();
});
builder.Services.AddHangfireServer();
#region
//AutoMapperע<72><D7A2>
#endregion
@@ -240,10 +231,6 @@ app.UseDbSeedInitService();
#endregion
app.UseRedisSeedInitService();
app.UseHangfireDashboard();
app.UseEndpoints(endpoints =>
{
#region
@@ -251,7 +238,6 @@ app.UseEndpoints(endpoints =>
#endregion
endpoints.MapHub<MainHub>("/api/hub/main");
endpoints.MapControllers();
endpoints.MapHangfireDashboard();
});
//׼<><D7BC><EFBFBD><EFBFBD><EFBFBD>Ӷ<EFBFBD><D3B6>⻧

24
Yi.Framework.Net6/Yi.Framework.Task/HttpJob.cs
View File

@@ -36,30 +36,6 @@ namespace Yi.Framework.Job
}
_logger.LogWarning("定时任务开始调度：" + nameof(HttpJob) + ":" + DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss") + $"：访问地址为:{url}，结果为:{data}");
Console.WriteLine($"结果:{data}");
});
}
public Task Execute2(Dictionary<string,object> dic)
{
return Task.Run(async () =>
{
//var jobData = context.JobDetail.JobDataMap;
string method = dic[Common.Const.JobConst.method].ToString();
string url = dic[Common.Const.JobConst.url].ToString();
string data = "异常！";
switch (method)
{
case "post":
data = await Common.Helper.HttpHelper.Post(url);
break;
case "get":
data = await Common.Helper.HttpHelper.Get(url);
break;
}
_logger.LogWarning("定时任务开始调度：" + nameof(HttpJob) + ":" + DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss") + $"：访问地址为:{url}，结果为:{data}");
Console.WriteLine($"结果:{data}");
});