timed_tasks/download_file/src/util/util.go

package util

import (
	mu "mfw/util"
	"mongodb"
	qu "qfw/util"
	"sync"
)

var (
	Config  map[string]interface{}
	Mgo     *mongodb.MongodbSim
	MgoB    *mongodb.MongodbSim
	Coll    string
	StartID string //bidding_processing_ids表ID
	//udp
	Udpclient mu.UdpClient //udp对象
	UdpPort   string
	NextAddr  string
	NextPort  int
	NextStype string
	//mail
	UdptaskMap = &sync.Map{}
	Tomail     string
	Api        string
	//ocr
	OcrServerAddr string //ocr服务治理中心
)

func GetIdInterval(id string) (gtid, lteid string) {
	defer qu.Catch()
	qu.Debug("获取id段...")
	query := map[string]interface{}{
		"_id": map[string]interface{}{
			"$gt": mongodb.StringTOBsonId(id),
		},
		"dataprocess": 8,
	}
	list, _ := MgoB.Find(Coll, query, map[string]interface{}{"_id": 1}, nil, false, -1, -1)
	dataLength := len(*list)
	if dataLength == 0 { //无新ID段
		return
	}

	gtid = qu.ObjToString((*list)[0]["gtid"])              //起始id
	lteid = qu.ObjToString((*list)[dataLength-1]["lteid"]) //结束id
	//成功获取id区间
	if gtid < lteid {
		StartID = mongodb.BsonIdToSId((*list)[dataLength-1]["_id"])
		qu.Debug("当前轮ID区间：", gtid, lteid, "表ID：", StartID)
		return
	}
	return "", ""
}