This commit is contained in:
苏尹岚
2020-10-10 17:38:08 +08:00
parent 556fbf8908
commit dd3d1e9d49

View File

@@ -1627,9 +1627,9 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
tmpJDs []*tmpJD tmpJDs []*tmpJD
jdMaps = make(map[int][]string) jdMaps = make(map[int][]string)
jdMaps2 = make(map[int][]int) jdMaps2 = make(map[int][]int)
a = 99999 // a = 99999
) )
sql := `SELECT * FROM tmp_jd LIMIT 1` sql := `SELECT * FROM tmp_jd`
dao.GetRows(db, &tmpJDs, sql, nil) dao.GetRows(db, &tmpJDs, sql, nil)
for _, v := range tmpJDs { for _, v := range tmpJDs {
jdMaps[v.JdStoreID] = append(jdMaps[v.JdStoreID], v.SkuName) jdMaps[v.JdStoreID] = append(jdMaps[v.JdStoreID], v.SkuName)
@@ -1652,7 +1652,6 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
nameIDs = append(nameIDs, v.ID) nameIDs = append(nameIDs, v.ID)
} }
} }
fmt.Println("nameIDs", nameIDs)
sql := ` sql := `
SELECT SUM(a.count) count, c.id SELECT SUM(a.count) count, c.id
FROM order_sku a FROM order_sku a
@@ -1666,7 +1665,6 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
` `
sqlParams := []interface{}{time.Now().AddDate(0, -1, 0)} sqlParams := []interface{}{time.Now().AddDate(0, -1, 0)}
dao.GetRow(db, &tmpCount, sql, sqlParams) dao.GetRow(db, &tmpCount, sql, sqlParams)
fmt.Println(utils.Format4Output(tmpCount, false))
if tmpCount.ID != 0 { if tmpCount.ID != 0 {
jdMaps2[jdStoreID] = append(jdMaps2[jdStoreID], tmpCount.ID) jdMaps2[jdStoreID] = append(jdMaps2[jdStoreID], tmpCount.ID)
} else { } else {
@@ -1674,36 +1672,37 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
} }
} }
} }
for jdStoreID, skuNames := range jdMaps2 { fmt.Println(utils.Format4Output(jdMaps2, false))
storeDetail, _ := dao.GetStoreDetailByVendorStoreID(db, utils.Int2Str(jdStoreID), model.VendorIDJD) // for jdStoreID, skuNames := range jdMaps2 {
var skuBindInfos []*cms.StoreSkuBindInfo // storeDetail, _ := dao.GetStoreDetailByVendorStoreID(db, utils.Int2Str(jdStoreID), model.VendorIDJD)
for _, v := range skuNames { // var skuBindInfos []*cms.StoreSkuBindInfo
var skuBindInfoSkus []*cms.StoreSkuBindSkuInfo // for _, v := range skuNames {
skuBindInfo := &cms.StoreSkuBindInfo{ // var skuBindInfoSkus []*cms.StoreSkuBindSkuInfo
IsFocus: 1, // skuBindInfo := &cms.StoreSkuBindInfo{
IsSale: 1, // IsFocus: 1,
NameID: v, // IsSale: 1,
StoreID: storeDetail.ID, // NameID: v,
} // StoreID: storeDetail.ID,
skus, _ := dao.GetSkus(db, nil, []int{v}, nil, nil, nil) // }
for _, vv := range skus { // skus, _ := dao.GetSkus(db, nil, []int{v}, nil, nil, nil)
skuBindInfoSku := &cms.StoreSkuBindSkuInfo{ // for _, vv := range skus {
SkuID: vv.ID, // skuBindInfoSku := &cms.StoreSkuBindSkuInfo{
Stock: &a, // SkuID: vv.ID,
IsSale: 1, // Stock: &a,
} // IsSale: 1,
skuBindInfoSkus = append(skuBindInfoSkus, skuBindInfoSku) // }
} // skuBindInfoSkus = append(skuBindInfoSkus, skuBindInfoSku)
prices, _ := dao.GetPriceReferSnapshotNoPage(db, []int{0}, nil, []int{v}, utils.Time2Date(time.Now().AddDate(0, 0, -1))) // }
if len(prices) > 0 { // prices, _ := dao.GetPriceReferSnapshotNoPage(db, []int{0}, nil, []int{v}, utils.Time2Date(time.Now().AddDate(0, 0, -1)))
skuBindInfo.UnitPrice = prices[0].MidUnitPrice // if len(prices) > 0 {
} else { // skuBindInfo.UnitPrice = prices[0].MidUnitPrice
skuBindInfo.UnitPrice = 1000 // } else {
} // skuBindInfo.UnitPrice = 1000
skuBindInfos = append(skuBindInfos, skuBindInfo) // }
} // skuBindInfos = append(skuBindInfos, skuBindInfo)
cms.UpdateStoreSkus(ctx, 0, storeDetail.ID, skuBindInfos, true, true) // }
} // cms.UpdateStoreSkus(ctx, 0, storeDetail.ID, skuBindInfos, true, true)
// }
return err return err
} }