|
|
@@ -4,6 +4,7 @@ import (
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
|
qu "qfw/util"
|
|
|
+ "strings"
|
|
|
"sync"
|
|
|
"time"
|
|
|
"util"
|
|
|
@@ -676,9 +677,11 @@ func GetSpiderWarnErrData() {
|
|
|
errArr := []*ErrRemark{}
|
|
|
list, _ := util.MgoS.Find("regatherdata", query, nil, map[string]interface{}{"href": 1, "error": 1}, false, 0, 3)
|
|
|
for _, l := range *list {
|
|
|
+ errText := qu.ObjToString(l["error"])
|
|
|
+ errText = strings.Replace(errText, "<string>:", "", 1)
|
|
|
errArr = append(errArr, &ErrRemark{
|
|
|
Href: qu.ObjToString(l["href"]),
|
|
|
- Remark: qu.ObjToString(l["error"]),
|
|
|
+ Remark: errText,
|
|
|
})
|
|
|
}
|
|
|
//one, _ := util.MgoS.FindOne("regatherdata", query) //查询该错误信息类型的一条href
|
|
|
@@ -943,7 +946,11 @@ func CreateTaskProcess() {
|
|
|
//错误描述
|
|
|
descript := info.Remark + "：共" + fmt.Sprint(err.Num) + "条\n"
|
|
|
for _, errRemark := range err.Err {
|
|
|
- descript += errRemark.Remark + "：" + errRemark.Href + "\n"
|
|
|
+ if stype == "regather" { //特殊处理运行异常描述
|
|
|
+ descript += errRemark.Remark + "：" + errRemark.Href + "\n"
|
|
|
+ } else {
|
|
|
+ descript += errRemark.Href + "\n"
|
|
|
+ }
|
|
|
}
|
|
|
task.DescribeMap[info.ErrType] = descript
|
|
|
}
|
