From e84f10d7e0512875c48b5b81f8b3ae49d6cd6693 Mon Sep 17 00:00:00 2001 From: DengBiao <2319963317@qq.com> Date: Mon, 25 Dec 2023 14:03:49 +0800 Subject: [PATCH] update --- cloud_issuance/svc/svc_deal_call_back.go | 2 +- consume/cloud_issuance_msg_callback.go | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/cloud_issuance/svc/svc_deal_call_back.go b/cloud_issuance/svc/svc_deal_call_back.go index d5c331c..0447d46 100644 --- a/cloud_issuance/svc/svc_deal_call_back.go +++ b/cloud_issuance/svc/svc_deal_call_back.go @@ -61,7 +61,7 @@ func (dealCloudIssuanceCallBackService *DealCloudIssuanceCallBackService) DealCa "content": req.Data.Content, } 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) utils.FilePutContents("cloud_resp", utils.SerializeStr(chain)) if chain.Count != "" { diff --git a/consume/cloud_issuance_msg_callback.go b/consume/cloud_issuance_msg_callback.go index baaeeb3..c801f46 100644 --- a/consume/cloud_issuance_msg_callback.go +++ b/consume/cloud_issuance_msg_callback.go @@ -13,6 +13,7 @@ import ( "fmt" "github.com/gin-gonic/gin" "github.com/streadway/amqp" + "time" ) func CloudIssuanceMsgCallBackConsume(queue md.MqQueue) { @@ -39,6 +40,7 @@ func CloudIssuanceMsgCallBackConsume(queue md.MqQueue) { if err != nil { panic(err) } + time.Sleep(time.Millisecond * 300) // 等待300毫秒 go func() { //设置masterId cloudIssuanceRobotRecords, err := db.CloudIssuanceRobotRecordsGetOneByParams(map[string]interface{}{