结算守价

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)

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
+}

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)