DataMaintenance/src/lua/data.go

package lua

import (
	qu "qfw/util"
	"strings"
	"util"
)

func (l *Lua) DataView() {
	defer qu.Catch()
	coll := l.GetString("coll")
	id := l.GetString("id")
	data := &map[string]interface{}{}
	if coll == "bidding" {
		data, _ = util.JYMgo.FindById(coll, id, nil)
	} else {
		if tmp := strings.Split(coll, "-"); len(tmp) == 2 {
			if tmp[0] == "lua" {
				data, _ = util.MgoS.FindById(tmp[1], id, nil)
			} else if tmp[0] == "python" {
				data, _ = util.MgoPy.FindById(tmp[1], id, nil)
			}
		} else {
			data, _ = util.MgoS.FindById(coll, id, nil)
		}
	}
	l.T["data"] = *data
	l.Render("lua/dataview.html", &l.T)
}

func (l *Lua) DataFind() {
	defer qu.Catch()
	l.Render("lua/datafind.html")
}
func (l *Lua) SearchData() {
	defer qu.Catch()
	text := l.GetString("text")
	stype := l.GetString("stype")
	data := []map[string]interface{}{}
	query := map[string]interface{}{
		stype: text,
	}
	if stype == "title" { //根据title找bidding(bidding表有title索引，无href索引)
		query = map[string]interface{}{
			"title": text,
		}
		//1、根据title找bidding
		list_bid, _ := util.JYMgo.Find("bidding", query, nil, nil, false, -1, -1)
		AddVal(*list_bid, "bidding", &data)
	}
	//2、找bidding_file附件信息
	list_file, _ := util.JYMgo.Find("bidding_file", query, nil, nil, false, -1, -1)
	AddVal(*list_file, "bidding_file", &data)
	//3、找spider_repeatdata判重数据表
	list_repeat, _ := util.MgoS.Find("spider_repeatdata", query, nil, nil, false, -1, -1)
	AddVal(*list_repeat, "spider_repeatdata", &data)
	//4、找spider_warn异常数据表
	list_warn, _ := util.MgoS.Find("spider_warn", query, nil, nil, false, -1, -1)
	AddVal(*list_warn, "spider_warn", &data)
	//5、找data_bak表
	list_bak_lua, _ := util.MgoS.Find("data_bak", query, nil, nil, false, -1, -1)
	AddVal(*list_bak_lua, "lua-data_bak", &data)
	list_bak_py, _ := util.MgoPy.Find("data_bak", query, nil, nil, false, -1, -1)
	AddVal(*list_bak_py, "python-data_bak", &data)
	//if len(data) == 0 { //以上都没有找到数据，找列表页数据
	//
	//}
	l.ServeJson(map[string]interface{}{
		"data": data,
	})
}

func AddVal(list []map[string]interface{}, by string, data *[]map[string]interface{}) {
	if listLen := len(list); listLen > 0 {
		for _, l := range list {
			l["by"] = by
		}
		*data = append(*data, list...)
	}
}