perf👌 优化job处理方式

This commit is contained in:
zhangwenjian
2021-05-31 23:52:32 +08:00
parent 526a993698
commit b1d3924294
+12 -17
View File
@@ -17,27 +17,22 @@ type SysJob struct {
// RemoveJobForService 调用service实现 // RemoveJobForService 调用service实现
func (e SysJob) RemoveJobForService(c *gin.Context) { func (e SysJob) RemoveJobForService(c *gin.Context) {
e.Context = c v := dto.GeneralDelDto{}
log := e.GetLogger()
db, err := e.GetOrm()
if err != nil {
log.Error(err)
return
}
var v dto.GeneralDelDto
err = c.Bind(&v)
if err != nil {
log.Warnf("参数验证错误, error: %s", err)
e.Error(http.StatusUnprocessableEntity, err, "参数验证失败")
return
}
s := service.SysJob{} s := service.SysJob{}
s.Log = log err := e.MakeContext(c).
s.Orm = db MakeOrm().
Bind(&v).
MakeService(&s.Service).
Errors
if err != nil {
e.Logger.Error(err)
return
}
s.Cron = sdk.Runtime.GetCrontabKey(c.Request.Host) s.Cron = sdk.Runtime.GetCrontabKey(c.Request.Host)
err = s.RemoveJob(&v) err = s.RemoveJob(&v)
if err != nil { if err != nil {
log.Errorf("RemoveJob error, %s", err.Error()) e.Logger.Errorf("RemoveJob error, %s", err.Error())
e.Error(http.StatusInternalServerError, err, "") e.Error(http.StatusInternalServerError, err, "")
return return
} }