|
@@ -31,21 +31,20 @@ type Lua struct {
|
|
|
dataFind xweb.Mapper `xweb:"/lua/datafind"` //数据查找页面
|
|
|
searchData xweb.Mapper `xweb:"/lua/searchdata"` //通过title、href查找
|
|
|
dataView xweb.Mapper `xweb:"/lua/dataview"` //查看数据详情
|
|
|
-
|
|
|
}
|
|
|
|
|
|
func (l *Lua) SpiderWarn() {
|
|
|
defer qu.Catch()
|
|
|
if l.Method() == "POST" {
|
|
|
defer qu.Catch()
|
|
|
- level, _ := l.GetInteger("level")
|
|
|
+ repeat, _ := l.GetInteger("repeat")
|
|
|
start, _ := l.GetInteger("start")
|
|
|
limit, _ := l.GetInteger("length")
|
|
|
draw, _ := l.GetInteger("draw")
|
|
|
startTime, _ := l.GetInt("starttime")
|
|
|
searchStr := l.GetString("search[value]")
|
|
|
search := strings.TrimSpace(searchStr)
|
|
|
- qu.Debug(startTime, start, limit, draw, level)
|
|
|
+ qu.Debug(startTime, start, limit, draw)
|
|
|
sort := `{"%s":%d}`
|
|
|
orderIndex := l.GetString("order[0][column]")
|
|
|
orderName := l.GetString(fmt.Sprintf("columns[%s][data]", orderIndex))
|
|
@@ -57,24 +56,15 @@ func (l *Lua) SpiderWarn() {
|
|
|
query := map[string]interface{}{
|
|
|
"ok": false,
|
|
|
}
|
|
|
+ if repeat != -1 {
|
|
|
+ query["repeat"] = repeat == 1
|
|
|
+ }
|
|
|
if startTime > 0 {
|
|
|
query["comeintime"] = map[string]interface{}{
|
|
|
"$gte": startTime,
|
|
|
"$lt": startTime + 86400,
|
|
|
}
|
|
|
}
|
|
|
- if level != -1 {
|
|
|
- query["level"] = level
|
|
|
- //错误中区分中文错误和其他错误
|
|
|
- if level == 2 {
|
|
|
- query["info"] = "Field Value Not Contains Chinese"
|
|
|
- } else if level == 3 {
|
|
|
- query["level"] = 2
|
|
|
- query["info"] = map[string]interface{}{
|
|
|
- "$ne": "Field Value Not Contains Chinese",
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
if search != "" {
|
|
|
query["$or"] = []interface{}{
|
|
|
map[string]interface{}{"site": map[string]interface{}{"$regex": search}},
|
|
@@ -107,7 +97,7 @@ func (l *Lua) SpiderEdit() {
|
|
|
id := l.GetString("id")
|
|
|
data := map[string]interface{}{}
|
|
|
bidId := ""
|
|
|
- one, _ := MgoS.FindById("spider_warn_err", id, map[string]interface{}{"data": 1, "field": 1, "level": 1})
|
|
|
+ one, _ := MgoS.FindById("spider_warn_err", id, map[string]interface{}{"data": 1, "field": 1})
|
|
|
if one != nil && len(*one) > 0 {
|
|
|
data, _ = (*one)["data"].(map[string]interface{})
|
|
|
detail := qu.ObjToString((data)["detail"])
|
|
@@ -124,17 +114,17 @@ func (l *Lua) SpiderEdit() {
|
|
|
1、异常类型为错误时,原信息未入bidding库
|
|
|
2、异常类型为警告时,原信息也已经入bidding库
|
|
|
*/
|
|
|
- if qu.IntAll((*one)["level"]) == 1 {
|
|
|
- bidData, _ := JYMgo.FindOne("bidding", map[string]interface{}{"s_sha": sha})
|
|
|
- if bidData != nil && len(*bidData) > 0 {
|
|
|
- bidId = mongodb.BsonIdToSId((*bidData)["_id"])
|
|
|
- data = *bidData
|
|
|
- } else {
|
|
|
- qu.Debug("异常信息id:", id)
|
|
|
- l.Render("com/err.html")
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
+ //if qu.IntAll((*one)["level"]) == 1 {
|
|
|
+ // bidData, _ := JYMgo.FindOne("bidding", map[string]interface{}{"s_sha": sha})
|
|
|
+ // if bidData != nil && len(*bidData) > 0 {
|
|
|
+ // bidId = mongodb.BsonIdToSId((*bidData)["_id"])
|
|
|
+ // data = *bidData
|
|
|
+ // } else {
|
|
|
+ // qu.Debug("异常信息id:", id)
|
|
|
+ // l.Render("com/err.html")
|
|
|
+ // return
|
|
|
+ // }
|
|
|
+ //}
|
|
|
delete(data, "_id")
|
|
|
delete(data, "detail")
|
|
|
delete(data, "contenthtml")
|
|
@@ -187,7 +177,6 @@ func (l *Lua) SpiderSave() {
|
|
|
}
|
|
|
FormatNumber(update) //解决超大金额转成科学计数法的问题
|
|
|
}
|
|
|
- qu.Debug(modifyinfo)
|
|
|
if stype == 1 { //修复更新
|
|
|
if bid == "" {
|
|
|
rep = "bidding id 为空"
|