|
|
@@ -15,29 +15,37 @@ import (
|
|
|
var udpclient mu.UdpClient //udp对象
|
|
|
var nextNodes []map[string]interface{}
|
|
|
|
|
|
-var startDate, endDate, ip, port, stype string
|
|
|
+var startDate, endDate, ip, port, stype, sid, eid string
|
|
|
|
|
|
func main() {
|
|
|
//2015-11-03,2017-04-01
|
|
|
//2017-04-01,2017-06-01
|
|
|
//2017-06-01,2018-06-01
|
|
|
//2018-06-01,2019-02-20
|
|
|
+ flag.StringVar(&sid, "sid", "", "开始id")
|
|
|
+ flag.StringVar(&eid, "eid", "", "结束id")
|
|
|
flag.StringVar(&startDate, "start", "", "开始日期2006-01-02")
|
|
|
flag.StringVar(&endDate, "end", "", "结束日期2006-01-02")
|
|
|
flag.StringVar(&ip, "ip", "127.0.0.1", "ip")
|
|
|
flag.StringVar(&port, "port", "", "dup端口")
|
|
|
flag.StringVar(&stype, "stype", "", "stype")
|
|
|
flag.Parse()
|
|
|
- log.Println(startDate, endDate, ip, port, stype)
|
|
|
- start, _ := time.ParseInLocation(qu.Date_Short_Layout, startDate, time.Local)
|
|
|
- end, _ := time.ParseInLocation(qu.Date_Short_Layout, endDate, time.Local)
|
|
|
- sid := bson.NewObjectIdWithTime(start)
|
|
|
- eid := bson.NewObjectIdWithTime(end)
|
|
|
+ var startid, endid bson.ObjectId
|
|
|
+ if sid != "" && eid != "" {
|
|
|
+ startid = qu.StringTOBsonId(sid)
|
|
|
+ endid = qu.StringTOBsonId(eid)
|
|
|
+ } else {
|
|
|
+ start, _ := time.ParseInLocation(qu.Date_Short_Layout, startDate, time.Local)
|
|
|
+ end, _ := time.ParseInLocation(qu.Date_Short_Layout, endDate, time.Local)
|
|
|
+ startid = bson.NewObjectIdWithTime(start)
|
|
|
+ endid = bson.NewObjectIdWithTime(end)
|
|
|
+ }
|
|
|
+ log.Println(startid, startid, ip, port, stype)
|
|
|
udpclient = mu.UdpClient{Local: ":1470", BufSize: 1024}
|
|
|
udpclient.Listen(processUdpMsg)
|
|
|
by, _ := json.Marshal(map[string]interface{}{
|
|
|
- "gtid": sid,
|
|
|
- "lteid": eid,
|
|
|
+ "gtid": startid,
|
|
|
+ "lteid": endid,
|
|
|
"stype": stype,
|
|
|
})
|
|
|
udpclient.WriteUdp(by, mu.OP_TYPE_DATA, &net.UDPAddr{
|
