|
@@ -1,20 +1,20 @@
|
|
package front
|
|
package front
|
|
|
|
|
|
import (
|
|
import (
|
|
|
|
+ "dataValidation/util"
|
|
"encoding/json"
|
|
"encoding/json"
|
|
"fmt"
|
|
"fmt"
|
|
"github.com/shopspring/decimal"
|
|
"github.com/shopspring/decimal"
|
|
"go.mongodb.org/mongo-driver/bson"
|
|
"go.mongodb.org/mongo-driver/bson"
|
|
|
|
+ qu "jygit.jydev.jianyu360.cn/data_processing/common_utils"
|
|
|
|
+ "jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
|
|
"math"
|
|
"math"
|
|
- mgo "mongodb"
|
|
|
|
- qu "qfw/util"
|
|
|
|
"regexp"
|
|
"regexp"
|
|
"sort"
|
|
"sort"
|
|
"strconv"
|
|
"strconv"
|
|
"strings"
|
|
"strings"
|
|
"sync"
|
|
"sync"
|
|
"time"
|
|
"time"
|
|
- "util"
|
|
|
|
)
|
|
)
|
|
|
|
|
|
var (
|
|
var (
|
|
@@ -28,13 +28,13 @@ func (f *Front) RemarkList() {
|
|
sourceinfo := qu.ObjToString(f.GetString("s_sourceinfo"))
|
|
sourceinfo := qu.ObjToString(f.GetString("s_sourceinfo"))
|
|
if f.Method() == "POST" {
|
|
if f.Method() == "POST" {
|
|
//user := f.GetSession("user").(map[string]interface{})
|
|
//user := f.GetSession("user").(map[string]interface{})
|
|
- start, _ := f.GetInteger("start")
|
|
|
|
- limit, _ := f.GetInteger("length")
|
|
|
|
- draw, _ := f.GetInteger("draw")
|
|
|
|
|
|
+ start, _ := f.GetInt("start")
|
|
|
|
+ limit, _ := f.GetInt("length")
|
|
|
|
+ draw, _ := f.GetInt("draw")
|
|
searchStr := f.GetString("search[value]")
|
|
searchStr := f.GetString("search[value]")
|
|
search := strings.TrimSpace(searchStr)
|
|
search := strings.TrimSpace(searchStr)
|
|
query := map[string]interface{}{"s_usertaskid": tid}
|
|
query := map[string]interface{}{"s_usertaskid": tid}
|
|
- ckdata, err := f.GetInteger("i_ckdata")
|
|
|
|
|
|
+ ckdata, err := f.GetInt("i_ckdata")
|
|
if err != nil {
|
|
if err != nil {
|
|
ckdata = -1
|
|
ckdata = -1
|
|
}
|
|
}
|
|
@@ -49,7 +49,7 @@ func (f *Front) RemarkList() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
field := map[string]interface{}{"v_baseinfo.title": 1, "b_istag": 1, "i_ckdata": 1}
|
|
field := map[string]interface{}{"v_baseinfo.title": 1, "b_istag": 1, "i_ckdata": 1}
|
|
- info, _ := util.Mgo.Find(sourceinfo, query, `{"_id": 1}`, field, false, start, limit)
|
|
|
|
|
|
+ info, _ := util.Mgo.Find(sourceinfo, query, `{"_id": 1}`, field, false, int(start), int(limit))
|
|
count := util.Mgo.Count(sourceinfo, query)
|
|
count := util.Mgo.Count(sourceinfo, query)
|
|
f.ServeJson(map[string]interface{}{
|
|
f.ServeJson(map[string]interface{}{
|
|
"draw": draw,
|
|
"draw": draw,
|
|
@@ -138,7 +138,7 @@ func getDetail(id, coll, stype string, fs []map[string]interface{}) map[string]i
|
|
} else {
|
|
} else {
|
|
baseInfo["detail"] = qu.ObjToString(baseInfo["title"]) + "</br>" + qu.ObjToString(baseInfo["detail"])
|
|
baseInfo["detail"] = qu.ObjToString(baseInfo["title"]) + "</br>" + qu.ObjToString(baseInfo["detail"])
|
|
}
|
|
}
|
|
- baseInfo["_id"] = mgo.BsonIdToSId(baseInfo["_id"])
|
|
|
|
|
|
+ baseInfo["_id"] = mongodb.BsonIdToSId(baseInfo["_id"])
|
|
purchasingTag, _ := baseInfo["purchasinglist_alltag"].(bool)
|
|
purchasingTag, _ := baseInfo["purchasinglist_alltag"].(bool)
|
|
rep["purchasingTag"] = purchasingTag
|
|
rep["purchasingTag"] = purchasingTag
|
|
href := qu.ObjToString(baseInfo["href"])
|
|
href := qu.ObjToString(baseInfo["href"])
|
|
@@ -652,7 +652,7 @@ func GetNextDataId(id, coll, tid string) string {
|
|
nextIdQuery := map[string]interface{}{
|
|
nextIdQuery := map[string]interface{}{
|
|
//"b_istag": false,
|
|
//"b_istag": false,
|
|
"_id": map[string]interface{}{
|
|
"_id": map[string]interface{}{
|
|
- "$gt": mgo.StringTOBsonId(id),
|
|
|
|
|
|
+ "$gt": mongodb.StringTOBsonId(id),
|
|
},
|
|
},
|
|
}
|
|
}
|
|
if tid != "" {
|
|
if tid != "" {
|
|
@@ -660,7 +660,7 @@ func GetNextDataId(id, coll, tid string) string {
|
|
}
|
|
}
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
- return mgo.BsonIdToSId((*one)[0]["_id"])
|
|
|
|
|
|
+ return mongodb.BsonIdToSId((*one)[0]["_id"])
|
|
} else {
|
|
} else {
|
|
//delete(nextIdQuery, "_id")
|
|
//delete(nextIdQuery, "_id")
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
@@ -678,7 +678,7 @@ func GetLastDataId(id, coll, tid string) string {
|
|
nextIdQuery := map[string]interface{}{
|
|
nextIdQuery := map[string]interface{}{
|
|
//"b_istag": false,
|
|
//"b_istag": false,
|
|
"_id": map[string]interface{}{
|
|
"_id": map[string]interface{}{
|
|
- "$lt": mgo.StringTOBsonId(id),
|
|
|
|
|
|
+ "$lt": mongodb.StringTOBsonId(id),
|
|
},
|
|
},
|
|
}
|
|
}
|
|
if tid != "" {
|
|
if tid != "" {
|
|
@@ -686,7 +686,7 @@ func GetLastDataId(id, coll, tid string) string {
|
|
}
|
|
}
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":1}`, true, 0, 1)
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":1}`, true, 0, 1)
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
- return mgo.BsonIdToSId((*one)[0]["_id"])
|
|
|
|
|
|
+ return mongodb.BsonIdToSId((*one)[0]["_id"])
|
|
} else {
|
|
} else {
|
|
//delete(nextIdQuery, "_id")
|
|
//delete(nextIdQuery, "_id")
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":-1}`, true, 0, 1)
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":-1}`, true, 0, 1)
|
|
@@ -704,7 +704,7 @@ func GetLastDataId(id, coll, tid string) string {
|
|
func GetNextDataId1(id, coll, tid, tag string) string {
|
|
func GetNextDataId1(id, coll, tid, tag string) string {
|
|
nextIdQuery := map[string]interface{}{
|
|
nextIdQuery := map[string]interface{}{
|
|
"_id": map[string]interface{}{
|
|
"_id": map[string]interface{}{
|
|
- "$gt": mgo.StringTOBsonId(id),
|
|
|
|
|
|
+ "$gt": mongodb.StringTOBsonId(id),
|
|
},
|
|
},
|
|
//"b_check": false,
|
|
//"b_check": false,
|
|
}
|
|
}
|
|
@@ -722,7 +722,7 @@ func GetNextDataId1(id, coll, tid, tag string) string {
|
|
qu.Debug(nextIdQuery)
|
|
qu.Debug(nextIdQuery)
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
- return mgo.BsonIdToSId((*one)[0]["_id"])
|
|
|
|
|
|
+ return mongodb.BsonIdToSId((*one)[0]["_id"])
|
|
} else {
|
|
} else {
|
|
//delete(nextIdQuery, "_id")
|
|
//delete(nextIdQuery, "_id")
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":1}`, `{"_id":1}`, true, 0, 1)
|
|
@@ -739,7 +739,7 @@ func GetNextDataId1(id, coll, tid, tag string) string {
|
|
func GetLastDataId1(id, coll, tid, tag string) string {
|
|
func GetLastDataId1(id, coll, tid, tag string) string {
|
|
nextIdQuery := map[string]interface{}{
|
|
nextIdQuery := map[string]interface{}{
|
|
"_id": map[string]interface{}{
|
|
"_id": map[string]interface{}{
|
|
- "$lt": mgo.StringTOBsonId(id),
|
|
|
|
|
|
+ "$lt": mongodb.StringTOBsonId(id),
|
|
},
|
|
},
|
|
//"b_check": false,
|
|
//"b_check": false,
|
|
}
|
|
}
|
|
@@ -756,7 +756,7 @@ func GetLastDataId1(id, coll, tid, tag string) string {
|
|
}
|
|
}
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":1}`, true, 0, 1)
|
|
one, _ := util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":1}`, true, 0, 1)
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
if len(*one) == 1 && len((*one)[0]) > 0 {
|
|
- return mgo.BsonIdToSId((*one)[0]["_id"])
|
|
|
|
|
|
+ return mongodb.BsonIdToSId((*one)[0]["_id"])
|
|
} else {
|
|
} else {
|
|
//delete(nextIdQuery, "_id")
|
|
//delete(nextIdQuery, "_id")
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":1}`, true, 0, 1)
|
|
//one, _ = util.Mgo.Find(coll, nextIdQuery, `{"_id":-1}`, `{"_id":1}`, true, 0, 1)
|
|
@@ -776,9 +776,9 @@ func (f *Front) CheckList() {
|
|
user := f.GetSession("user").(map[string]interface{})
|
|
user := f.GetSession("user").(map[string]interface{})
|
|
iRole := qu.ObjToString(user["i_role"])
|
|
iRole := qu.ObjToString(user["i_role"])
|
|
gid := qu.ObjToString(user["s_groupid"])
|
|
gid := qu.ObjToString(user["s_groupid"])
|
|
- start, _ := f.GetInteger("start")
|
|
|
|
- limit, _ := f.GetInteger("length")
|
|
|
|
- draw, _ := f.GetInteger("draw")
|
|
|
|
|
|
+ start, _ := f.GetInt("start")
|
|
|
|
+ limit, _ := f.GetInt("length")
|
|
|
|
+ draw, _ := f.GetInt("draw")
|
|
status := f.GetString("s_status")
|
|
status := f.GetString("s_status")
|
|
searchStr := f.GetString("search[value]")
|
|
searchStr := f.GetString("search[value]")
|
|
search := strings.TrimSpace(searchStr)
|
|
search := strings.TrimSpace(searchStr)
|
|
@@ -801,13 +801,13 @@ func (f *Front) CheckList() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
count := util.Mgo.Count(util.TASKCOLLNAME, query)
|
|
count := util.Mgo.Count(util.TASKCOLLNAME, query)
|
|
- list, _ := util.Mgo.Find(util.TASKCOLLNAME, query, bson.M{"_id": -1}, nil, false, start, limit)
|
|
|
|
|
|
+ list, _ := util.Mgo.Find(util.TASKCOLLNAME, query, bson.M{"_id": -1}, nil, false, int(start), int(limit))
|
|
for _, l := range *list {
|
|
for _, l := range *list {
|
|
if status := qu.ObjToString(l["s_status"]); status == "进行中" { //更新任务进度
|
|
if status := qu.ObjToString(l["s_status"]); status == "进行中" { //更新任务进度
|
|
giveNum := qu.IntAll(l["i_givenum"])
|
|
giveNum := qu.IntAll(l["i_givenum"])
|
|
sourceinfo := qu.ObjToString(l["s_sourceinfo"])
|
|
sourceinfo := qu.ObjToString(l["s_sourceinfo"])
|
|
|
|
|
|
- tagNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_usertaskid": mgo.BsonIdToSId(l["_id"]), "b_istag": true})
|
|
|
|
|
|
+ tagNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_usertaskid": mongodb.BsonIdToSId(l["_id"]), "b_istag": true})
|
|
progressFloat := float64(tagNum) / float64(giveNum)
|
|
progressFloat := float64(tagNum) / float64(giveNum)
|
|
value, _ := strconv.ParseFloat(fmt.Sprintf("%.4f", progressFloat), 64)
|
|
value, _ := strconv.ParseFloat(fmt.Sprintf("%.4f", progressFloat), 64)
|
|
decimalValue := decimal.NewFromFloat(value)
|
|
decimalValue := decimal.NewFromFloat(value)
|
|
@@ -830,9 +830,9 @@ func (f *Front) CheckData() {
|
|
tid := f.GetString("tid")
|
|
tid := f.GetString("tid")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
if f.Method() == "POST" {
|
|
if f.Method() == "POST" {
|
|
- start, _ := f.GetInteger("start")
|
|
|
|
- limit, _ := f.GetInteger("length")
|
|
|
|
- draw, _ := f.GetInteger("draw")
|
|
|
|
|
|
+ start, _ := f.GetInt("start")
|
|
|
|
+ limit, _ := f.GetInt("length")
|
|
|
|
+ draw, _ := f.GetInt("draw")
|
|
query := make(map[string]interface{})
|
|
query := make(map[string]interface{})
|
|
query["b_istag"] = true
|
|
query["b_istag"] = true
|
|
query["s_usertaskid"] = tid
|
|
query["s_usertaskid"] = tid
|
|
@@ -854,7 +854,7 @@ func (f *Front) CheckData() {
|
|
count := util.Mgo.Count(sourceinfo, query)
|
|
count := util.Mgo.Count(sourceinfo, query)
|
|
fields := map[string]interface{}{"v_baseinfo.title": 1, "v_baseinfo.buyer": 1, "v_baseinfo.s_winner": 1, "v_baseinfo.budget": 1,
|
|
fields := map[string]interface{}{"v_baseinfo.title": 1, "v_baseinfo.buyer": 1, "v_baseinfo.s_winner": 1, "v_baseinfo.budget": 1,
|
|
"v_baseinfo.bidamount": 1, "b_check": 1, "i_ckdata": 1, "s_login": 1, "b_istag": 1, "s_excp": 1, "s_excp_info": 1}
|
|
"v_baseinfo.bidamount": 1, "b_check": 1, "i_ckdata": 1, "s_login": 1, "b_istag": 1, "s_excp": 1, "s_excp_info": 1}
|
|
- info, _ := util.Mgo.Find(sourceinfo, query, `{"_id": 1}`, fields, false, start, limit)
|
|
|
|
|
|
+ info, _ := util.Mgo.Find(sourceinfo, query, `{"_id": 1}`, fields, false, int(start), int(limit))
|
|
f.ServeJson(map[string]interface{}{
|
|
f.ServeJson(map[string]interface{}{
|
|
"draw": draw,
|
|
"draw": draw,
|
|
"data": *info,
|
|
"data": *info,
|
|
@@ -886,11 +886,11 @@ func (f *Front) CheckJyData() {
|
|
tid := f.GetString("tid")
|
|
tid := f.GetString("tid")
|
|
stype := f.GetString("stype")
|
|
stype := f.GetString("stype")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
- datatype, _ := f.GetInteger("datatype")
|
|
|
|
|
|
+ datatype, _ := f.GetInt("datatype")
|
|
if f.Method() == "POST" {
|
|
if f.Method() == "POST" {
|
|
- start, _ := f.GetInteger("start")
|
|
|
|
- limit, _ := f.GetInteger("length")
|
|
|
|
- draw, _ := f.GetInteger("draw")
|
|
|
|
|
|
+ start, _ := f.GetInt("start")
|
|
|
|
+ limit, _ := f.GetInt("length")
|
|
|
|
+ draw, _ := f.GetInt("draw")
|
|
query := make(map[string]interface{})
|
|
query := make(map[string]interface{})
|
|
if tid != "" {
|
|
if tid != "" {
|
|
// 任务数据质检
|
|
// 任务数据质检
|
|
@@ -1024,7 +1024,7 @@ func (f *Front) CheckJyData() {
|
|
count := util.Mgo.Count(sourceinfo, query)
|
|
count := util.Mgo.Count(sourceinfo, query)
|
|
fields := map[string]interface{}{"v_baseinfo.title": 1, "v_baseinfo.buyer": 1, "v_baseinfo.s_winner": 1, "v_baseinfo.budget": 1,
|
|
fields := map[string]interface{}{"v_baseinfo.title": 1, "v_baseinfo.buyer": 1, "v_baseinfo.s_winner": 1, "v_baseinfo.budget": 1,
|
|
"v_baseinfo.bidamount": 1, "b_check": 1, "i_ckdata": 1, "s_login": 1, "b_istag": 1, "s_excp": 1, "s_excp_info": 1}
|
|
"v_baseinfo.bidamount": 1, "b_check": 1, "i_ckdata": 1, "s_login": 1, "b_istag": 1, "s_excp": 1, "s_excp_info": 1}
|
|
- info, _ := util.Mgo.Find(sourceinfo, query, `{"_id": 1}`, fields, false, start, limit)
|
|
|
|
|
|
+ info, _ := util.Mgo.Find(sourceinfo, query, `{"_id": 1}`, fields, false, int(start), int(limit))
|
|
f.ServeJson(map[string]interface{}{
|
|
f.ServeJson(map[string]interface{}{
|
|
"draw": draw,
|
|
"draw": draw,
|
|
"data": *info,
|
|
"data": *info,
|
|
@@ -1332,7 +1332,7 @@ func (f *Front) CheckResult() {
|
|
tid := f.GetString("tid")
|
|
tid := f.GetString("tid")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
stype := f.GetString("stype")
|
|
stype := f.GetString("stype")
|
|
- datatype, _ := f.GetInteger("datatype")
|
|
|
|
|
|
+ datatype, _ := f.GetInt("datatype")
|
|
var allNum int
|
|
var allNum int
|
|
projcet, _ := util.Mgo.FindById(util.PROJECTCOLLNAME, pid, map[string]interface{}{"v_fields": 1})
|
|
projcet, _ := util.Mgo.FindById(util.PROJECTCOLLNAME, pid, map[string]interface{}{"v_fields": 1})
|
|
//tagCount := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "b_istag": true})
|
|
//tagCount := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "b_istag": true})
|
|
@@ -1691,9 +1691,9 @@ func (f *Front) JyMarkList() {
|
|
defer qu.Catch()
|
|
defer qu.Catch()
|
|
stype := f.GetString("stype") //all:全量标注;notag:达标数据标注;tag:未达标数据标注
|
|
stype := f.GetString("stype") //all:全量标注;notag:达标数据标注;tag:未达标数据标注
|
|
if f.Method() == "POST" {
|
|
if f.Method() == "POST" {
|
|
- start, _ := f.GetInteger("start")
|
|
|
|
- limit, _ := f.GetInteger("length")
|
|
|
|
- draw, _ := f.GetInteger("draw")
|
|
|
|
|
|
+ start, _ := f.GetInt("start")
|
|
|
|
+ limit, _ := f.GetInt("length")
|
|
|
|
+ draw, _ := f.GetInt("draw")
|
|
sourceInfo := f.GetString("s_sourceinfo") //数据源表
|
|
sourceInfo := f.GetString("s_sourceinfo") //数据源表
|
|
istag := f.GetString("b_istag") //
|
|
istag := f.GetString("b_istag") //
|
|
field := f.GetString("field") //字段
|
|
field := f.GetString("field") //字段
|
|
@@ -1788,7 +1788,7 @@ func (f *Front) JyMarkList() {
|
|
}
|
|
}
|
|
count := util.Mgo.Count(sourceInfo, query)
|
|
count := util.Mgo.Count(sourceInfo, query)
|
|
fields := map[string]interface{}{"v_baseinfo.title": 1, "b_istag": 1, "i_ckdata": 1}
|
|
fields := map[string]interface{}{"v_baseinfo.title": 1, "b_istag": 1, "i_ckdata": 1}
|
|
- list, _ := util.Mgo.Find(sourceInfo, query, map[string]interface{}{"_id": 1}, fields, false, start, limit)
|
|
|
|
|
|
+ list, _ := util.Mgo.Find(sourceInfo, query, map[string]interface{}{"_id": 1}, fields, false, int(start), int(limit))
|
|
//checkedNum, allNum := GetCheckedAndAllDataInfo(query, coll) //已标和总数信息
|
|
//checkedNum, allNum := GetCheckedAndAllDataInfo(query, coll) //已标和总数信息
|
|
f.ServeJson(map[string]interface{}{"draw": draw, "data": *list, "recordsFiltered": count, "recordsTotal": count})
|
|
f.ServeJson(map[string]interface{}{"draw": draw, "data": *list, "recordsFiltered": count, "recordsTotal": count})
|
|
} else {
|
|
} else {
|
|
@@ -1944,7 +1944,7 @@ func (f *Front) JyUserDataMark() {
|
|
tmp, _ := util.Mgo.FindById(sourceInfo, infoId, map[string]interface{}{"v_baseinfo": 1, "v_taginfo": 1, "i_ckdata": 1})
|
|
tmp, _ := util.Mgo.FindById(sourceInfo, infoId, map[string]interface{}{"v_baseinfo": 1, "v_taginfo": 1, "i_ckdata": 1})
|
|
delete((*tmp), "_id")
|
|
delete((*tmp), "_id")
|
|
(*tmp)["updatetime"] = time.Now().Unix()
|
|
(*tmp)["updatetime"] = time.Now().Unix()
|
|
- _ = util.Mgo.Update(util.AllToColl, map[string]interface{}{"_id": mgo.StringTOBsonId(infoId)}, map[string]interface{}{"$set": tmp}, true, false)
|
|
|
|
|
|
+ _ = util.Mgo.Update(util.AllToColl, map[string]interface{}{"_id": mongodb.StringTOBsonId(infoId)}, map[string]interface{}{"$set": tmp}, true, false)
|
|
}
|
|
}
|
|
/*
|
|
/*
|
|
} else {
|
|
} else {
|
|
@@ -2101,7 +2101,7 @@ func (f *Front) UserDataMark() {
|
|
tmp, _ := util.Mgo.FindById(sourceInfo, infoId, map[string]interface{}{"v_baseinfo": 1, "v_taginfo": 1, "i_ckdata": 1})
|
|
tmp, _ := util.Mgo.FindById(sourceInfo, infoId, map[string]interface{}{"v_baseinfo": 1, "v_taginfo": 1, "i_ckdata": 1})
|
|
delete((*tmp), "_id")
|
|
delete((*tmp), "_id")
|
|
(*tmp)["updatetime"] = time.Now().Unix()
|
|
(*tmp)["updatetime"] = time.Now().Unix()
|
|
- _ = util.Mgo.Update(util.AllToColl, map[string]interface{}{"_id": mgo.StringTOBsonId(infoId)}, map[string]interface{}{"$set": tmp}, true, false)
|
|
|
|
|
|
+ _ = util.Mgo.Update(util.AllToColl, map[string]interface{}{"_id": mongodb.StringTOBsonId(infoId)}, map[string]interface{}{"$set": tmp}, true, false)
|
|
}
|
|
}
|
|
/*
|
|
/*
|
|
} else {
|
|
} else {
|
|
@@ -2585,7 +2585,7 @@ func SaveLog(s_infoid, s_usertaskid, username, userid, role, projectname, s_styp
|
|
func (f *Front) CheckDataPurchase() {
|
|
func (f *Front) CheckDataPurchase() {
|
|
defer qu.Catch()
|
|
defer qu.Catch()
|
|
if f.Method() == "POST" {
|
|
if f.Method() == "POST" {
|
|
- datatype, _ := f.GetInteger("datatype")
|
|
|
|
|
|
+ datatype, _ := f.GetInt("datatype")
|
|
stype := f.GetString("stype")
|
|
stype := f.GetString("stype")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
sourceinfo := f.GetString("s_sourceinfo")
|
|
tid := f.GetString("taskid")
|
|
tid := f.GetString("taskid")
|