liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2024-10-09 11:28:11 +08:00
parent 7d5e9a86b5
commit 6c565be170
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
business/model/dao/store_sku.go
View File

@@ -1236,12 +1236,13 @@ func GetTopSkusByStoreIDs(db *DaoDB, storeIDs []int) (storeSkuNameExt []*StoreSk
sqlParams = append(sqlParams, model.StoreSkuBindStatusNormal, utils.DefaultTimeValue, model.ActSkuDirectDown, model.ActSkuSecKill, sqlParams = append(sqlParams, model.StoreSkuBindStatusNormal, utils.DefaultTimeValue, model.ActSkuDirectDown, model.ActSkuSecKill,
utils.DefaultTimeValue, model.SkuStatusNormal, utils.DefaultTimeValue, model.SkuStatusNormal, utils.DefaultTimeValue, model.StoreStatusDisabled, utils.DefaultTimeValue, model.SkuStatusNormal, utils.DefaultTimeValue, model.SkuStatusNormal, utils.DefaultTimeValue, model.StoreStatusDisabled,
storeIDs, utils.DefaultTimeValue, model.StoreSkuBindStatusNormal, 30) storeIDs, utils.DefaultTimeValue, model.StoreSkuBindStatusNormal, 30)
globals.SugarLogger.Debugf("----------sql := %s", sql)
globals.SugarLogger.Debugf("----------sqlparam := %s", utils.Format4Output(sqlParams, false))
err = GetRows(db, &storeSkuNameExt, sql, sqlParams...) err = GetRows(db, &storeSkuNameExt, sql, sqlParams...)
var skuNamesInfo = &StoreSkuNamesInfo{ var skuNamesInfo = &StoreSkuNamesInfo{
SkuNames: storeSkuNameExt, SkuNames: storeSkuNameExt,
} }
for _, v := range storeSkuNameExt { var skuIdList = make([]int, 0, 0)
var skus []*StoreSkuExt
sql2 := ` sql2 := `
SELECT a.id sku_id,a.*,t4.created_at bind_created_at, t4.updated_at bind_updated_at, t4.last_operator bind_last_operator, t4.deleted_at bind_deleted_at, SELECT a.id sku_id,a.*,t4.created_at bind_created_at, t4.updated_at bind_updated_at, t4.last_operator bind_last_operator, t4.deleted_at bind_deleted_at,
t4.sub_store_id, t4.price bind_price, IF(t4.unit_price IS NOT NULL, t4.unit_price, t1.price) unit_price, t4.status store_sku_status, t4.auto_sale_at, t4.sub_store_id, t4.price bind_price, IF(t4.unit_price IS NOT NULL, t4.unit_price, t1.price) unit_price, t4.status store_sku_status, t4.auto_sale_at,
@@ -1255,6 +1256,8 @@ func GetTopSkusByStoreIDs(db *DaoDB, storeIDs []int) (storeSkuNameExt []*StoreSk
WHERE a.id = ? WHERE a.id = ?
AND a.deleted_at = ? AND a.deleted_at = ?
` `
for _, v := range storeSkuNameExt {
var skus []*StoreSkuExt
sqlParams2 := []interface{}{ sqlParams2 := []interface{}{
utils.DefaultTimeValue, utils.DefaultTimeValue,
utils.DefaultTimeValue, utils.DefaultTimeValue,
@@ -1267,8 +1270,10 @@ func GetTopSkusByStoreIDs(db *DaoDB, storeIDs []int) (storeSkuNameExt []*StoreSk
} }
err = GetRows(db, &skus, sql2, sqlParams2...) err = GetRows(db, &skus, sql2, sqlParams2...)
v.Skus = skus v.Skus = skus
err = UpdateActPrice4StoreSkuNameNew(db, storeIDs, []int{v.SkuID}, skuNamesInfo, model.VendorIDJX) skuIdList = append(skuIdList, v.SkuID)
} }
err = UpdateActPrice4StoreSkuNameNew(db, storeIDs, skuIdList, skuNamesInfo, model.VendorIDJX)
return storeSkuNameExt, err return storeSkuNameExt, err
} }