marvzhang
2020-02-09 09:02:13 +08:00
parent 4a62542eb1
commit 12b03cba8a
2 changed files with 16 additions and 2 deletions

View File

@@ -78,6 +78,10 @@ func (spider *Spider) Add() error {
spider.CreateTs = time.Now()
spider.UpdateTs = time.Now()
if !spider.ProjectId.Valid() {
spider.ProjectId = bson.ObjectIdHex(constants.ObjectIdNull)
}
if err := c.Insert(&spider); err != nil {
return err
}

View File

@@ -295,7 +295,12 @@ func UploadSpider(c *gin.Context) {
if cmd != "" {
spider.Cmd = cmd
}
_ = spider.Add()
if err := spider.Add(); err != nil {
log.Error("add spider error: " + err.Error())
debug.PrintStack()
HandleError(http.StatusInternalServerError, c, err)
return
}
} else {
if name != "" {
spider.Name = name
@@ -311,7 +316,12 @@ func UploadSpider(c *gin.Context) {
}
// 更新file_id
spider.FileId = fid
_ = spider.Save()
if err := spider.Add(); err != nil {
log.Error("add spider error: " + err.Error())
debug.PrintStack()
HandleError(http.StatusInternalServerError, c, err)
return
}
}
// 发起同步