DengBiao
10 months ago
2 changed files with 3 additions and 1 deletions
Unified View
Diff Options
+ 1
- 1
cloud_issuance/svc/svc_deal_call_back.go
View File
| @@ -61,7 +61,7 @@ func (dealCloudIssuanceCallBackService *DealCloudIssuanceCallBackService) DealCa | |||||
| "content": req.Data.Content, | "content": req.Data.Content, | ||||
| } | } | ||||
| utils.FilePutContents("cloud", utils.SerializeStr(args)) | utils.FilePutContents("cloud", utils.SerializeStr(args)) | ||||
| time.Sleep(time.Millisecond * 300) // 等待300毫秒 | |||||
| time.Sleep(time.Millisecond * 200) // 等待200毫秒 | |||||
| chain := chain_transfer.TurnChain(svc.MasterDb(c), db2.Db, args) | chain := chain_transfer.TurnChain(svc.MasterDb(c), db2.Db, args) | ||||
| utils.FilePutContents("cloud_resp", utils.SerializeStr(chain)) | utils.FilePutContents("cloud_resp", utils.SerializeStr(chain)) | ||||
| if chain.Count != "" { | if chain.Count != "" { | ||||
+ 2
- 0
consume/cloud_issuance_msg_callback.go
View File
| @@ -13,6 +13,7 @@ import ( | |||||
| "fmt" | "fmt" | ||||
| "github.com/gin-gonic/gin" | "github.com/gin-gonic/gin" | ||||
| "github.com/streadway/amqp" | "github.com/streadway/amqp" | ||||
| "time" | |||||
| ) | ) | ||||
| func CloudIssuanceMsgCallBackConsume(queue md.MqQueue) { | func CloudIssuanceMsgCallBackConsume(queue md.MqQueue) { | ||||
| @@ -39,6 +40,7 @@ func CloudIssuanceMsgCallBackConsume(queue md.MqQueue) { | |||||
| if err != nil { | if err != nil { | ||||
| panic(err) | panic(err) | ||||
| } | } | ||||
| time.Sleep(time.Millisecond * 300) // 等待300毫秒 | |||||
| go func() { | go func() { | ||||
| //设置masterId | //设置masterId | ||||
| cloudIssuanceRobotRecords, err := db.CloudIssuanceRobotRecordsGetOneByParams(map[string]interface{}{ | cloudIssuanceRobotRecords, err := db.CloudIssuanceRobotRecordsGetOneByParams(map[string]interface{}{ | ||||