Browse Source
Merge branch 'master' of https://code.fnuoos.com/go_rely_warehouse/zyos_go_mq_consume
master
2 changed files with 12 additions and 9 deletions
Unified View
Diff Options
+ 9
- 9
consume/init.go
View File
| @@ -86,13 +86,13 @@ func initConsumes() { | |||||
| //jobs[consumeMd.CanalB2cOrderForNumericalStatementConsumeFunName] = CanalB2cOrderForNumericalStatementConsume | //jobs[consumeMd.CanalB2cOrderForNumericalStatementConsumeFunName] = CanalB2cOrderForNumericalStatementConsume | ||||
| //////////////////////////////////////// oneCircles ///////////////////////////////////////////////////// | //////////////////////////////////////// oneCircles ///////////////////////////////////////////////////// | ||||
| jobs[consumeMd.OneCirclesSignInGreenEnergyFunName] = OneCirclesSignInGreenEnergyConsume | |||||
| jobs[consumeMd.OneCirclesStartLevelDividendFunName] = OneCirclesStartLevelDividendConsume | |||||
| jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyConsume | |||||
| jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamConsume | |||||
| jobs[consumeMd.OneCirclesSettlementPublicGiveActivityCoinFunName] = OneCirclesSettlementPublicGiveActivityCoinConsume | |||||
| jobs[consumeMd.OneCirclesAddPublicPlatoonUserRelationCommissionFunName] = OneCirclesAddPublicPlatoonUserRelationCommissionConsume | |||||
| jobs[consumeMd.OneCirclesSignInUpdateRecordsGreenEnergyFunName] = OneCirclesSignInUpdateRecordsGreenEnergyConsume | |||||
| //jobs[consumeMd.OneCirclesSignInGreenEnergyFunName] = OneCirclesSignInGreenEnergyConsume | |||||
| //jobs[consumeMd.OneCirclesStartLevelDividendFunName] = OneCirclesStartLevelDividendConsume | |||||
| //jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyConsume | |||||
| //jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamConsume | |||||
| //jobs[consumeMd.OneCirclesSettlementPublicGiveActivityCoinFunName] = OneCirclesSettlementPublicGiveActivityCoinConsume | |||||
| //jobs[consumeMd.OneCirclesAddPublicPlatoonUserRelationCommissionFunName] = OneCirclesAddPublicPlatoonUserRelationCommissionConsume | |||||
| //jobs[consumeMd.OneCirclesSignInUpdateRecordsGreenEnergyFunName] = OneCirclesSignInUpdateRecordsGreenEnergyConsume | |||||
| //////////////////////////////////////// withdraw ///////////////////////////////////////////////////// | //////////////////////////////////////// withdraw ///////////////////////////////////////////////////// | ||||
| //jobs[consumeMd.WithdrawConsumeFunName] = WithdrawConsume | //jobs[consumeMd.WithdrawConsumeFunName] = WithdrawConsume | ||||
| @@ -106,8 +106,8 @@ func initConsumes() { | |||||
| //jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款 | //jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款 | ||||
| ////////////////////////////////////// SuperCloudIssuance ///////////////////////////////////////////////////// | ////////////////////////////////////// SuperCloudIssuance ///////////////////////////////////////////////////// | ||||
| //jobs[consumeMd.SuperCloudIssuanceMsgCallBackFunName] = SuperCloudIssuanceMsgCallBackConsume | |||||
| //jobs[consumeMd.SuperCloudIssuanceAsyncMLoginFunName] = SuperCloudIssuanceAsyncMLoginConsume | |||||
| jobs[consumeMd.SuperCloudIssuanceMsgCallBackFunName] = SuperCloudIssuanceMsgCallBackConsume | |||||
| jobs[consumeMd.SuperCloudIssuanceAsyncMLoginFunName] = SuperCloudIssuanceAsyncMLoginConsume | |||||
| ////////////////////////////////////// DMS ///////////////////////////////////////////////////// | ////////////////////////////////////// DMS ///////////////////////////////////////////////////// | ||||
| //jobs[consumeMd.CanalGimMessageConsumeFunName] = CanalGimMessageConsume | //jobs[consumeMd.CanalGimMessageConsumeFunName] = CanalGimMessageConsume | ||||
+ 3
- 0
super_cloud_issuance/svc/svc_deal_call_back.go
View File
| @@ -14,6 +14,7 @@ import ( | |||||
| "errors" | "errors" | ||||
| "fmt" | "fmt" | ||||
| "github.com/gin-gonic/gin" | "github.com/gin-gonic/gin" | ||||
| "math/rand" | |||||
| "time" | "time" | ||||
| ) | ) | ||||
| @@ -63,6 +64,7 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi | |||||
| "master_id": c.GetString("mid"), | "master_id": c.GetString("mid"), | ||||
| "content": req.Data.Content, | "content": req.Data.Content, | ||||
| } | } | ||||
| time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000))) | |||||
| utils.FilePutContents("cloud", utils.SerializeStr(args)) | utils.FilePutContents("cloud", utils.SerializeStr(args)) | ||||
| chain := chain_transfer.TurnChain(MasterDb(c), db.Db, db2.ZhimengDb, args) | chain := chain_transfer.TurnChain(MasterDb(c), db.Db, db2.ZhimengDb, args) | ||||
| utils.FilePutContents("cloud", utils.SerializeStr(chain)) | utils.FilePutContents("cloud", utils.SerializeStr(chain)) | ||||
| @@ -243,6 +245,7 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi | |||||
| "master_id": dealSuperCloudIssuanceCallBackService.Context.GetString("mid"), | "master_id": dealSuperCloudIssuanceCallBackService.Context.GetString("mid"), | ||||
| "content": req.Data.Content, | "content": req.Data.Content, | ||||
| } | } | ||||
| time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000))) | |||||
| utils.FilePutContents("cloud_source", utils.SerializeStr(args)) | utils.FilePutContents("cloud_source", utils.SerializeStr(args)) | ||||
| chain := chain_transfer.TurnChain(MasterDb(dealSuperCloudIssuanceCallBackService.Context), db.Db, db2.ZhimengDb, args) | chain := chain_transfer.TurnChain(MasterDb(dealSuperCloudIssuanceCallBackService.Context), db.Db, db2.ZhimengDb, args) | ||||
| utils.FilePutContents("cloud_source", utils.SerializeStr(chain)) | utils.FilePutContents("cloud_source", utils.SerializeStr(chain)) | ||||