aa
This commit is contained in:
@@ -691,3 +691,22 @@ func GetActMtwmVendors(db *DaoDB, storeIDs, skuIDs []int) (actMtwmVendors []*mod
|
|||||||
err = GetRows(db, &actMtwmVendors, sql, sqlParams)
|
err = GetRows(db, &actMtwmVendors, sql, sqlParams)
|
||||||
return actMtwmVendors, err
|
return actMtwmVendors, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetActEbaiVendorSkus(db *DaoDB, storeIDs, skuIDs []int) (actEbaiVendorSku []*model.ActEbaiVendorSku, err error) {
|
||||||
|
sql := `
|
||||||
|
SELECT *
|
||||||
|
FROM act_ebai_vendor_sku
|
||||||
|
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)
|
||||||
|
}
|
||||||
|
err = GetRows(db, &actEbaiVendorSku, sql, sqlParams)
|
||||||
|
return actEbaiVendorSku, err
|
||||||
|
}
|
||||||
|
|||||||
@@ -1445,6 +1445,15 @@ func UpdateActPrice4StoreSkuNameNew(db *DaoDB, storeIDs, skuIDs []int, skuNamesI
|
|||||||
}
|
}
|
||||||
mtactMap[v.StoreID][v.SkuID] = v
|
mtactMap[v.StoreID][v.SkuID] = v
|
||||||
}
|
}
|
||||||
|
ebaiactList, _ := GetActEbaiVendorSkus(db, storeIDs, skuIDs)
|
||||||
|
ebaiactMap := make(map[int]map[int]*model.ActEbaiVendorSku)
|
||||||
|
for _, v := range ebaiactList {
|
||||||
|
if ebaiactMap[v.StoreID] == nil {
|
||||||
|
ebaiactskuMap := make(map[int]*model.ActEbaiVendorSku)
|
||||||
|
ebaiactMap[v.StoreID] = ebaiactskuMap
|
||||||
|
}
|
||||||
|
ebaiactMap[v.StoreID][v.SkuID] = v
|
||||||
|
}
|
||||||
for _, skuName := range skuNamesInfo.SkuNames {
|
for _, skuName := range skuNamesInfo.SkuNames {
|
||||||
if len(skuName.Skus) > 0 {
|
if len(skuName.Skus) > 0 {
|
||||||
for _, v := range skuName.Skus {
|
for _, v := range skuName.Skus {
|
||||||
@@ -1481,6 +1490,18 @@ func UpdateActPrice4StoreSkuNameNew(db *DaoDB, storeIDs, skuIDs []int, skuNamesI
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (actVendorID == -1 || actVendorID == model.VendorIDEBAI) && v.ActPrice == 0 {
|
||||||
|
if ebaiactMap != nil {
|
||||||
|
ebaiact := ebaiactMap[skuName.StoreID][v.SkuID]
|
||||||
|
if ebaiact != nil {
|
||||||
|
v.ActPrice = int(jxutils.StandardPrice2Int(ebaiact.ActPrice))
|
||||||
|
v.ActType = model.ActSkuDirectDown
|
||||||
|
v.ActID = int(utils.Str2Int64(ebaiact.ActID) % 1000)
|
||||||
|
v.EarningPrice = 0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if globals.IsStoreSkuAct {
|
if globals.IsStoreSkuAct {
|
||||||
v.VendorInfoMap = make(map[int]*StoreSkuVendorInfo)
|
v.VendorInfoMap = make(map[int]*StoreSkuVendorInfo)
|
||||||
for _, storeMap := range storeMapMap[skuName.StoreID] {
|
for _, storeMap := range storeMapMap[skuName.StoreID] {
|
||||||
|
|||||||
Reference in New Issue
Block a user