|
|
@@ -277,7 +277,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
tmp["isrun"] = "run"
|
|
|
bytes, _ := json.Marshal(tmp)
|
|
|
b := mongodb.Save("ocr_task", string(bytes))
|
|
|
- mongodb.Save("ocr_task_bak", string(bytes))
|
|
|
+ //mongodb.Save("ocr_task_bak", string(bytes))
|
|
|
log.Println("保存id:", b)
|
|
|
case mu.OP_NOOP: //其他节点回应消息打印
|
|
|
log.Println("节点接收成功", string(data), ra.String())
|
|
|
@@ -328,7 +328,8 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
// }
|
|
|
//}
|
|
|
tobyte, _ := json.Marshal(totmp)
|
|
|
- //go config.Udpclient.WriteUdp(tobyte, mu.OP_TYPE_DATA, &net.UDPAddr{
|
|
|
+ mongodb.Save("ocr_flie_over",string(tobyte))
|
|
|
+ //go config.Udpclient.WriteUdp(tobyte, mu.OP_TYPE_DATA, &net.UDPAddr{
|
|
|
// IP: net.ParseIP(qu.ObjToString(config.Sysconfig["toudpip"])),
|
|
|
// Port: qu.IntAll(config.Sysconfig["toudpport"]),
|
|
|
//})
|
|
|
@@ -336,8 +337,8 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
|
|
|
|
|
|
mongodb.Del("ocr_task", bson.M{"_id": ObjectId.(bson.ObjectId)})
|
|
|
tmp["end_time"] = time.Now().Unix()
|
|
|
- mongodb.Save("ocr_flie_over",totmp)
|
|
|
- mongodb.Update("ocr_task_bak", bson.M{"_id": ObjectId.(bson.ObjectId)}, map[string]interface{}{"$set": tmp}, false, false)
|
|
|
+
|
|
|
+ //mongodb.Update("ocr_task_bak", bson.M{"start": ObjectId.(bson.ObjectId)}, map[string]interface{}{"$set": tmp}, false, false)
|
|
|
//}else {
|
|
|
// tmp["isrun"] = "stop"
|
|
|
// mongodb.Update("ocr_task",
|
fengweiqiang