更新

consume/zhios_order_total_second.go

@@ -134,6 +134,7 @@ func handleZhiosOrderTotalSecond(msg []byte) error {
 					}
 				}
 				isupdate := 0
+				before := userStatistics.Amount
 				if ordData.State == 4 && ordData.IsTotal == 1 {
 					isupdate = 1
 					isTotal = 2
@@ -151,6 +152,8 @@ func handleZhiosOrderTotalSecond(msg []byte) error {
 				}
 				if update == 0 && isupdate == 1 {
 					sess.Rollback()
+					fmt.Println("================zhe", before, utils.SerializeStr(userStatistics))
+					fmt.Println("================zhe", utils.SerializeStr(ordData))
 					return errors.New("失败2")
 				}
 				if v.CreateAt > 1711086661 {
@@ -285,7 +288,7 @@ func handleZhiosOrderTotalSecond(msg []byte) error {
 					}
 					if has == 0 {
 						sess.Rollback()
-						return errors.New("失败")
+						return errors.New("失败a")
 					}
 				}
 				if ordData.State == 4 && (ordData.IsTotal == 1 || ordData.IsTotal == 3) {