|
|
|
@ -447,10 +447,10 @@ namespace OpenAuth.App.ServiceApp
|
|
|
|
|
{
|
|
|
|
|
JobName = $"{task.Id}",
|
|
|
|
|
JobType = 0, // 本地任务
|
|
|
|
|
JobCall = "OpenAuth.App.ServiceApp.FlyTaskJob",
|
|
|
|
|
JobCall = "OpenAuth.App.OpenJob.FlyTaskJob",
|
|
|
|
|
JobCallParams = "{\"taskId\":\"" + task.Id + "\"}",
|
|
|
|
|
Cron = task.PeriodicFormula,
|
|
|
|
|
Status = 1, // 开启运行 todo 关于修改后关闭问题
|
|
|
|
|
Status = 1, // 开启运行
|
|
|
|
|
Remark = "定时任务",
|
|
|
|
|
};
|
|
|
|
|
var jobId = _openJobApp.Add(record);
|
|
|
|
@ -1185,7 +1185,6 @@ namespace OpenAuth.App.ServiceApp
|
|
|
|
|
Wpml = wpml
|
|
|
|
|
};
|
|
|
|
|
await Repository.ChangeRepository<SugarRepositiry<LasaTaskAssign>>().InsertAsync(taskAssign);
|
|
|
|
|
// todo 更新任务状态?
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task PendingFlyTask(string taskId)
|
|
|
|
@ -2414,7 +2413,7 @@ namespace OpenAuth.App.ServiceApp
|
|
|
|
|
ExpandoObject();
|
|
|
|
|
var x = SnowFlakeSingle.instance;
|
|
|
|
|
//var pushUrl = $"rtmp://box.wisestcity.com:1935/live/{x.NextId()}";
|
|
|
|
|
var pushUrl = "rtmp://box.wisestcity.com:1935/live/8";
|
|
|
|
|
var pushUrl = "rtmp://box.wisestcity.com:1935/live/11";
|
|
|
|
|
json.rtmp_url = req.RtmpUrl;
|
|
|
|
|
json.push_url = pushUrl;
|
|
|
|
|
json.imgsz = 640;
|
|
|
|
|