Function createOrUpdateOrderFromCache

api/controller/pay.go:218–276

createOrUpdateOrderFromCache creates a new order from cache or updates an existing one

(eid int64, orderId string, status int, transactionId string)

// createOrUpdateOrderFromCache creates a new order from cache or updates an existing one
func createOrUpdateOrderFromCache(eid int64, orderId string, status int, transactionId string) (*model.Order, error) {
	// Lock to prevent concurrent operations
	orderMutex.Lock()
	defer orderMutex.Unlock()

	// Check if order exists in database
	dbOrder, err := model.GetOrderByOrderId(eid, orderId)
	if err != nil {
		// Order not found in database, check cache
		cachedOrder, found := getCachedOrder(orderId)
		if !found {
			return nil, fmt.Errorf("order not found in database or cache: %s", orderId)
		}

		xlog.Info("Order found in cache:", orderId)
		// Create order from cached data
		cachedOrder.Status = status
		if transactionId != "" {
			cachedOrder.TransactionId = transactionId
		}

		if status == model.OrderStatusPaid {
			cachedOrder.PayTime = time.Now().UTC().UnixMilli()
		}

		if err = cachedOrder.Create(); err != nil {
			return nil, fmt.Errorf("create order from cache error: %v", err)
		}
		xlog.Info("Successfully created order from cache with status:", status)

		// Remove from cache
		removeCachedOrder(orderId)
		xlog.Info("Removed order from cache")

		return cachedOrder, nil
	}

	// Order exists, update status
	if status == model.OrderStatusPaid {
		err = model.UpdateOrderPaid(eid, orderId, transactionId)
		dbOrder.Status = model.OrderStatusPaid
		dbOrder.TransactionId = transactionId
		dbOrder.PayTime = time.Now().UTC().UnixMilli()
	} else {
		err = model.UpdateOrderStatus(eid, orderId, status)
		dbOrder.Status = status
	}

	if err != nil {
		return nil, fmt.Errorf("update order status error: %v", err)
	}
	xlog.Info("Successfully updated order status to:", status)

	// Remove from cache if exists
	removeCachedOrder(orderId)
	xlog.Info("Attempted to remove order from cache")

	return dbOrder, nil