1 changed files with 8 additions and 2 deletions
Unified View
Diff Options
+ 8
- 2
consume/egg_energy_platform_revenue_data_consume.go
View File
| @@ -61,9 +61,15 @@ func EggEnergyDealPlatformRevenueDataConsume(queue md.MqQueue) { | |||||
| func handleEggEnergyDealPlatformRevenueDataConsume(msgData []byte) error { | func handleEggEnergyDealPlatformRevenueDataConsume(msgData []byte) error { | ||||
| time.Sleep(time.Duration(100) * time.Millisecond) //休眠100毫秒 | time.Sleep(time.Duration(100) * time.Millisecond) //休眠100毫秒 | ||||
| var msgStr string | |||||
| err := json.Unmarshal(msgData, &msgStr) | |||||
| if err != nil { | |||||
| return err | |||||
| } | |||||
| // 1.解析mq中queue的数据结构体 | // 1.解析mq中queue的数据结构体 | ||||
| var msg *md2.EggEnergyStructForPlatformRevenueData | var msg *md2.EggEnergyStructForPlatformRevenueData | ||||
| err := json.Unmarshal(msgData, &msg) | |||||
| err = json.Unmarshal([]byte(msgStr), &msg) | |||||
| if err != nil { | if err != nil { | ||||
| return err | return err | ||||
| } | } | ||||
| @@ -111,7 +117,7 @@ func handleEggEnergyDealPlatformRevenueDataConsume(msgData []byte) error { | |||||
| BeforeEnergyTotalNums: calcPriceIncreaseFormulaResp.BeforeEnergyTotalNums, | BeforeEnergyTotalNums: calcPriceIncreaseFormulaResp.BeforeEnergyTotalNums, | ||||
| AfterEnergyTotalNums: calcPriceIncreaseFormulaResp.AfterEnergyTotalNums, | AfterEnergyTotalNums: calcPriceIncreaseFormulaResp.AfterEnergyTotalNums, | ||||
| } | } | ||||
| err4 := egg_energy.DealAvailableEggEnergyCoin(session, int(enum.CapitalInjection), eggEnergyCoreData, dealAvailableEggEnergyCoinReq) | |||||
| err4 := egg_energy.DealAvailableEggEnergyCoin(session, int(enum.PlatformProfitability), eggEnergyCoreData, dealAvailableEggEnergyCoinReq) | |||||
| if err4 != nil { | if err4 != nil { | ||||
| fmt.Println("ActivityCoinAutoExchangeEggPersonEnergy:::::err111:::", err4) | fmt.Println("ActivityCoinAutoExchangeEggPersonEnergy:::::err111:::", err4) | ||||
| _ = session.Rollback() | _ = session.Rollback() | ||||