diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go index 6df00277d..25e67d2fc 100644 --- a/business/jxcallback/orderman/order.go +++ b/business/jxcallback/orderman/order.go @@ -383,6 +383,7 @@ func ModifyOrderSkusStock(db *dao.DaoDB, order *model.GoodsOrder, isAdd bool) (e dao.SetStoreSkuSyncStatus(db, order.VendorID, []int{order.FromStoreID}, []int{sku.SkuID}, model.SyncFlagStockMask) } } + checkDefendPriceOrder(db, jxutils.GetSaleStoreIDFromOrder(order), sku.SkuID) } storeSku.Stock = stock dao.UpdateEntity(db, storeSku, "Stock") @@ -399,6 +400,17 @@ func filterOrderInfo(order *model.GoodsOrder) { order.ConsigneeAddress = strings.ReplaceAll(order.ConsigneeAddress, "·", "") } +func checkDefendPriceOrder(db *dao.DaoDB, storeID, skuID int) { + var ( + issue = 0 + ) + if time.Now().Hour() >= 22 { + issue = utils.Str2Int(time.Now().AddDate(0, 0, 1).Format("20060102")) + } else { + issue = utils.Str2Int(time.Now().Format("20060102")) + } +} + func (c *OrderManager) updateOrderSkuOtherInfo(order *model.GoodsOrder, db *dao.DaoDB, storePayPercentage, changePriceType int) (err error) { globals.SugarLogger.Debugf("updateOrderSkuOtherInfo orderID:%s, VendorStoreID:%s", order.VendorOrderID, order.VendorStoreID) jxStoreID := jxutils.GetShowStoreIDFromOrder(order) diff --git a/business/model/dao/dao_order.go b/business/model/dao/dao_order.go index 3c4fe209c..90b7f8aa1 100644 --- a/business/model/dao/dao_order.go +++ b/business/model/dao/dao_order.go @@ -1396,3 +1396,26 @@ func GetSupplySupportStoreSkus(db *DaoDB, fromDate, toDate time.Time, fromStoreI } return orderSkus, err } + +func GetPriceDefendOrder(db *DaoDB, storeIDs, skuIDs, issues []int) (priceDefendOrders []*model.PriceDefendOrder, err error) { + sql := ` + SELECT * + FROM price_defend_order + WHERE 1 = 1 + ` + sqlParams := []interface{}{} + if len(storeIDs) > 0 { + sql += " AND store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")" + sqlParams = append(sqlParams, storeIDs) + } + if len(skuIDs) > 0 { + sql += " AND sku_id IN (" + GenQuestionMarks(len(skuIDs)) + ")" + sqlParams = append(sqlParams, skuIDs) + } + if len(issues) > 0 { + sql += " AND issue IN (" + GenQuestionMarks(len(issues)) + ")" + sqlParams = append(sqlParams, issues) + } + err = GetRows(db, &priceDefendOrders, sql, sqlParams) + return priceDefendOrders, err +} diff --git a/business/partner/purchase/jx/localjx/order.go b/business/partner/purchase/jx/localjx/order.go index 77e0e748f..61a880098 100644 --- a/business/partner/purchase/jx/localjx/order.go +++ b/business/partner/purchase/jx/localjx/order.go @@ -273,6 +273,7 @@ func buildDefendPriceOrder(ctx *jxcontext.Context, jxOrder *JxOrderInfo, address DefendPrice: jxOrder.Skus[0].Price, IsBuyNowPrice: jxOrder.IsBuyNowPrice, Issue: issue, + IsSuccess: model.NO, //默认是不成功 } priceDefendOrder.ActualPayPrice = int64(priceDefendOrder.Count) * priceDefendOrder.DefendPrice dao.CreateEntity(db, &priceDefendOrder)