|
@@ -1,7 +1,7 @@
|
|
|
package front
|
|
|
|
|
|
import (
|
|
|
- "crons"
|
|
|
+ "dataValidation/crons"
|
|
|
"dataValidation/util"
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
@@ -11,15 +11,14 @@ import (
|
|
|
"io"
|
|
|
qu "jygit.jydev.jianyu360.cn/data_processing/common_utils"
|
|
|
"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
|
|
|
+ "jygit.jydev.jianyu360.cn/data_processing/common_utils/redis"
|
|
|
"math"
|
|
|
"os"
|
|
|
- "qfw/util/redis"
|
|
|
"sort"
|
|
|
"strconv"
|
|
|
"strings"
|
|
|
"sync"
|
|
|
"time"
|
|
|
- "util"
|
|
|
)
|
|
|
|
|
|
// GroupTaskListByGroup 用户组权限用户组任务列表
|
|
@@ -188,7 +187,7 @@ func (f *Front) GroupUserTaskList() {
|
|
|
}
|
|
|
qu.Debug("Query:", query)
|
|
|
count := util.Mgo.Count(util.TASKCOLLNAME, query)
|
|
|
- list, _ := util.Mgo.Find(util.TASKCOLLNAME, query, map[string]interface{}{"_id": -1}, nil, false, start, limit)
|
|
|
+ list, _ := util.Mgo.Find(util.TASKCOLLNAME, query, map[string]interface{}{"_id": -1}, nil, false, int(start), int(limit))
|
|
|
for _, l := range *list {
|
|
|
if status := qu.ObjToString(l["s_status"]); status == "进行中" { //更新任务进度
|
|
|
giveNum := qu.IntAll(l["i_givenum"])
|