|
|
@@ -20,7 +20,7 @@ var (
|
|
|
toaddr = []*net.UDPAddr{} //下节点对象
|
|
|
ChSign = make(chan os.Signal)
|
|
|
|
|
|
- sid, eid string //测试使用
|
|
|
+ sid, eid string //测试使用
|
|
|
)
|
|
|
|
|
|
func init() {
|
|
|
@@ -59,7 +59,7 @@ func DealSign() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func mainT() {
|
|
|
+func main() {
|
|
|
//udp跑增量 id段 project
|
|
|
//udp跑全量 ql
|
|
|
//udp跑历史数据 信息id1,id2/或id段 ls
|
|
|
@@ -78,7 +78,7 @@ func mainT() {
|
|
|
}
|
|
|
|
|
|
//测试组人员使用
|
|
|
-func main() {
|
|
|
+func mainT() {
|
|
|
//sid = "5dfbd43ce9d1f601e43fa402"
|
|
|
//eid = "5e0954b30cf41612e061d0c8"
|
|
|
|
|
|
@@ -104,10 +104,11 @@ func main() {
|
|
|
}
|
|
|
P_QL.loadSite()
|
|
|
task(mapinfo)
|
|
|
+ SingleThread <- true
|
|
|
time.Sleep(20 * time.Second)
|
|
|
}
|
|
|
|
|
|
-func task(mapInfo map[string]interface{}) {
|
|
|
+func task(mapInfo map[string]interface{}) {
|
|
|
SingleThread <- true
|
|
|
tasktype, _ := mapInfo["stype"].(string)
|
|
|
log.Println("tasktype:", tasktype)
|
|
|
@@ -131,7 +132,7 @@ func task(mapInfo map[string]interface{}) {
|
|
|
P_QL.pici = time.Now().Unix()
|
|
|
P_QL.taskZl(mapInfo)
|
|
|
}()
|
|
|
- case "updateInfo": //招标字段变更
|
|
|
+ case "updateInfo": //招标字段变更
|
|
|
go func() {
|
|
|
defer func() {
|
|
|
<-SingleThread
|
|
|
@@ -187,7 +188,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
P_QL.pici = time.Now().Unix()
|
|
|
P_QL.taskZl(mapInfo)
|
|
|
}()
|
|
|
- case "updateInfo": //招标字段变更
|
|
|
+ case "updateInfo": //招标字段变更
|
|
|
go func() {
|
|
|
defer func() {
|
|
|
<-SingleThread
|
