|
|
@@ -7,7 +7,6 @@ import (
|
|
|
"log"
|
|
|
mu "mfw/util"
|
|
|
"net"
|
|
|
- "qfw/common/src/qfw/util"
|
|
|
qu "qfw/util"
|
|
|
"qfw/util/elastic"
|
|
|
"qfw/util/redis"
|
|
|
@@ -60,17 +59,17 @@ func (jy *RepairRule) RepairNewSave() {
|
|
|
|
|
|
|
|
|
//调udp生索引
|
|
|
- indexNode := *util.ObjToMap(Sysconfig["indexNode"])
|
|
|
+ indexNode := *qu.ObjToMap(Sysconfig["indexNode"])
|
|
|
param := map[string]interface{}{"coll":JyCollNameOne}
|
|
|
by, _ := json.Marshal(map[string]interface{}{
|
|
|
"gtid": cur_id,
|
|
|
"lteid": cur_id,
|
|
|
- "stype": util.ObjToString(indexNode["stype"]),
|
|
|
+ "stype": qu.ObjToString(indexNode["stype"]),
|
|
|
"param":param,
|
|
|
})
|
|
|
addr := &net.UDPAddr{
|
|
|
IP: net.ParseIP(indexNode["addr"].(string)),
|
|
|
- Port: util.IntAll(indexNode["port"]),
|
|
|
+ Port: qu.IntAll(indexNode["port"]),
|
|
|
}
|
|
|
udptask.Udpclient.WriteUdp(by, mu.OP_TYPE_DATA, addr)
|
|
|
|
|
|
@@ -231,17 +230,17 @@ func (jy *RepairRule) RepairSave() {
|
|
|
//}
|
|
|
|
|
|
//调udp生索引
|
|
|
- indexNode := *util.ObjToMap(Sysconfig["indexNode"])
|
|
|
+ indexNode := *qu.ObjToMap(Sysconfig["indexNode"])
|
|
|
param := map[string]interface{}{"coll":coll}
|
|
|
by, _ := json.Marshal(map[string]interface{}{
|
|
|
"gtid": id,
|
|
|
"lteid": id,
|
|
|
- "stype": util.ObjToString(indexNode["stype"]),
|
|
|
+ "stype": qu.ObjToString(indexNode["stype"]),
|
|
|
"param":param,
|
|
|
})
|
|
|
addr := &net.UDPAddr{
|
|
|
IP: net.ParseIP(indexNode["addr"].(string)),
|
|
|
- Port: util.IntAll(indexNode["port"]),
|
|
|
+ Port: qu.IntAll(indexNode["port"]),
|
|
|
}
|
|
|
udptask.Udpclient.WriteUdp(by, mu.OP_TYPE_DATA, addr)
|
|
|
|
