|
|
@@ -235,20 +235,25 @@ func (p *ProjectTask) taskZl(udpInfo map[string]interface{}) {
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
+ pici := time.Now().Unix()
|
|
|
if q != nil {
|
|
|
//生成查询语句执行
|
|
|
p.enter(db, coll, q)
|
|
|
}
|
|
|
- nextNode(gtid, lteid, "project")
|
|
|
+ nextNode(gtid, lteid, "project", pici)
|
|
|
}
|
|
|
|
|
|
//通知下个节点nextNode
|
|
|
-func nextNode(gtid, lteid, stype string) {
|
|
|
+func nextNode(gtid, lteid, stype string, pici int64) {
|
|
|
by, _ := json.Marshal(map[string]interface{}{
|
|
|
"gtid": gtid,
|
|
|
"lteid": lteid,
|
|
|
"stype": stype,
|
|
|
+ "query": map[string]interface{}{
|
|
|
+ "pici": pici,
|
|
|
+ },
|
|
|
})
|
|
|
+ log.Println("nextnode", string(by))
|
|
|
for _, v := range NextNode {
|
|
|
if node, ok := v.(map[string]interface{}); ok {
|
|
|
udpclient.WriteUdp(by, mu.OP_TYPE_DATA, &net.UDPAddr{
|
