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

- UpdateStoreSkus

Browse Source
This commit is contained in:
gazebo
2018-09-20 11:24:17 +08:00
parent 2177707034
commit 65e5587cba
2 changed files with 116 additions and 104 deletions
Download Patch File Download Diff File Expand all files Collapse all files

211
business/jxstore/cms/store_sku.go
View File

@@ -6,6 +6,7 @@ import (
"strings" "strings"
"git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/jxutils"
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/model/dao" "git.rosy.net.cn/jx-callback/business/model/dao"
) )
@@ -214,133 +215,135 @@ func GetStoreSkus(storeID int, isFocused bool, keyword string, params map[string
} }
func UpdateStoreSku(storeID int, skuBindInfo *StoreSkuBindInfo, userName string) (num int64, err error) { func UpdateStoreSku(storeID int, skuBindInfo *StoreSkuBindInfo, userName string) (num int64, err error) {
return UpdateStoreSkus(storeID, []*StoreSkuBindInfo{skuBindInfo}, userName)
}
func UpdateStoreSkus(storeID int, skuBindInfos []*StoreSkuBindInfo, userName string) (num int64, err error) {
db := dao.GetDB() db := dao.GetDB()
skuBinds := skuBindInfo.Skus needSyncIDMap := make(map[int]int)
var existBinds []*tStoreSkuBindAndSpec dao.Begin(db)
addNum, delNum, updateNum := 0, 0, 0 defer func() {
if err = dao.GetRows(db, &existBinds, ` if r := recover(); r != nil {
dao.Rollback(db)
panic(r)
}
}()
for _, skuBindInfo := range skuBindInfos {
skuBinds := skuBindInfo.Skus
var existBinds []*tStoreSkuBindAndSpec
if err = dao.GetRows(db, &existBinds, `
SELECT t1.*, t2.spec_quality, t2.spec_unit SELECT t1.*, t2.spec_quality, t2.spec_unit
FROM store_sku_bind t1 FROM store_sku_bind t1
JOIN sku t2 ON t1.sku_id = t2.id JOIN sku t2 ON t1.sku_id = t2.id
WHERE store_id = ? WHERE store_id = ?
AND t2.name_id = ?`, storeID, skuBindInfo.NameID); err == nil { AND t2.name_id = ?`, storeID, skuBindInfo.NameID); err == nil {
skuIDs := make([]int, len(existBinds)) existBindsMap := make(map[int]*model.StoreSkuBind, len(existBinds))
for k, v := range existBinds { unitPrice := 0
skuIDs[k] = v.SkuID
}
existBindsMap := make(map[int]*model.StoreSkuBind, len(existBinds))
dao.Begin(db)
defer func() {
if r := recover(); r != nil {
dao.Rollback(db)
panic(r)
}
}()
unitPrice := 0
if skuBindInfo.UnitPrice != 0 {
unitPrice = skuBindInfo.UnitPrice
} else {
unitPrice = existBinds[0].UnitPrice
}
for _, v := range existBinds {
if skuBindInfo.UnitPrice != 0 { if skuBindInfo.UnitPrice != 0 {
v.UnitPrice = unitPrice unitPrice = skuBindInfo.UnitPrice
v.Price = calStoreSkuPrice(unitPrice, v.SpecQuality, v.SpecUnit) } else {
v.JdSyncStatus |= model.SyncFlagPriceMask unitPrice = existBinds[0].UnitPrice
v.ElmSyncStatus |= model.SyncFlagPriceMask
v.EbaiSyncStatus |= model.SyncFlagPriceMask
dao.WrapUpdateULEntity(v, userName)
if _, err2 := dao.UpdateEntity(db, &v.StoreSkuBind); err2 != nil {
dao.Rollback(db)
return 0, err2
}
} }
existBindsMap[v.SkuID] = &v.StoreSkuBind for _, v := range existBinds {
} if skuBindInfo.UnitPrice != 0 {
for _, v := range skuBinds { v.UnitPrice = unitPrice
skuBind, ok := existBindsMap[v.SkuID] v.Price = calStoreSkuPrice(unitPrice, v.SpecQuality, v.SpecUnit)
if !ok { v.JdSyncStatus |= model.SyncFlagPriceMask
if v.IsFocus == 1 { v.ElmSyncStatus |= model.SyncFlagPriceMask
sku := &model.Sku{} v.EbaiSyncStatus |= model.SyncFlagPriceMask
sku.ID = v.SkuID dao.WrapUpdateULEntity(v, userName)
if err2 := dao.GetEntity(db, sku); err2 != nil { if _, err2 := dao.UpdateEntity(db, &v.StoreSkuBind); err2 != nil {
dao.Rollback(db) dao.Rollback(db)
return 0, err2 return 0, err2
} }
skuBind = &model.StoreSkuBind{ needSyncIDMap[v.ID] = 1
StoreID: storeID,
SkuID: v.SkuID,
SubStoreID: v.SubStoreID, // todo 这个应该从用户信息中自动获得
UnitPrice: unitPrice,
Price: calStoreSkuPrice(unitPrice, sku.SpecQuality, sku.SpecUnit),
Status: model.StoreSkuBindStatusDontSale,
}
dao.WrapAddIDCULDEntity(skuBind, userName)
}
} else {
if v.IsFocus != -1 {
dao.WrapUpdateULEntity(skuBind, userName)
} }
existBindsMap[v.SkuID] = &v.StoreSkuBind
} }
if skuBind != nil { for _, v := range skuBinds {
if v.IsSale != 0 { skuBind, ok := existBindsMap[v.SkuID]
if v.IsSale == 1 { if !ok {
skuBind.Status = model.StoreSkuBindStatusNormal if v.IsFocus == 1 {
} else { sku := &model.Sku{}
skuBind.Status = model.StoreSkuBindStatusDontSale sku.ID = v.SkuID
} if err2 := dao.GetEntity(db, sku); err2 != nil {
skuBind.JdSyncStatus |= model.SyncFlagSaleMask dao.Rollback(db)
skuBind.ElmSyncStatus |= model.SyncFlagSaleMask return 0, err2
skuBind.EbaiSyncStatus |= model.SyncFlagSaleMask
}
if ok {
if v.IsFocus == -1 {
delNum++
_, err = dao.DeleteEntityLogically(db, skuBind, map[string]interface{}{
model.FieldStatus: model.StoreSkuBindStatusDeleted,
model.FieldJdSyncStatus: model.SyncFlagDeletedMask,
model.FieldElmSyncStatus: model.SyncFlagDeletedMask,
model.FieldEbaiSyncStatus: model.SyncFlagDeletedMask,
}, userName, nil)
} else {
// todo 如果修改ebai与elm ID怎么处理呢？
if v.IsFocus == 1 {
skuBind.DeletedAt = utils.DefaultTimeValue
} }
updateNum++ skuBind = &model.StoreSkuBind{
skuBind.JdSyncStatus |= model.SyncFlagModifiedMask StoreID: storeID,
skuBind.ElmSyncStatus |= model.SyncFlagModifiedMask SkuID: v.SkuID,
skuBind.EbaiSyncStatus |= model.SyncFlagModifiedMask SubStoreID: v.SubStoreID, // todo 这个应该从用户信息中自动获得
_, err = dao.UpdateEntity(db, skuBind) UnitPrice: unitPrice,
Price: calStoreSkuPrice(unitPrice, sku.SpecQuality, sku.SpecUnit),
Status: model.StoreSkuBindStatusDontSale,
}
dao.WrapAddIDCULDEntity(skuBind, userName)
} }
} else { } else {
if v.EbaiID != 0 { if v.IsFocus != -1 {
skuBind.EbaiID = v.EbaiID dao.WrapUpdateULEntity(skuBind, userName)
} }
if v.ElmID != 0 { }
skuBind.ElmID = v.ElmID if skuBind != nil {
if v.IsSale != 0 {
if v.IsSale == 1 {
skuBind.Status = model.StoreSkuBindStatusNormal
} else {
skuBind.Status = model.StoreSkuBindStatusDontSale
}
skuBind.JdSyncStatus |= model.SyncFlagSaleMask
skuBind.ElmSyncStatus |= model.SyncFlagSaleMask
skuBind.EbaiSyncStatus |= model.SyncFlagSaleMask
} }
addNum++ if ok {
skuBind.JdSyncStatus = model.SyncFlagNewMask if v.IsFocus == -1 {
skuBind.ElmSyncStatus = model.SyncFlagNewMask _, err = dao.DeleteEntityLogically(db, skuBind, map[string]interface{}{
skuBind.EbaiSyncStatus = model.SyncFlagNewMask model.FieldStatus: model.StoreSkuBindStatusDeleted,
err = dao.CreateEntity(db, skuBind) model.FieldJdSyncStatus: model.SyncFlagDeletedMask,
model.FieldElmSyncStatus: model.SyncFlagDeletedMask,
model.FieldEbaiSyncStatus: model.SyncFlagDeletedMask,
}, userName, nil)
needSyncIDMap[skuBind.ID] = 1
} else {
// todo 如果修改ebai与elm ID怎么处理呢？
if v.IsFocus == 1 {
skuBind.DeletedAt = utils.DefaultTimeValue
}
skuBind.JdSyncStatus |= model.SyncFlagModifiedMask
skuBind.ElmSyncStatus |= model.SyncFlagModifiedMask
skuBind.EbaiSyncStatus |= model.SyncFlagModifiedMask
_, err = dao.UpdateEntity(db, skuBind)
needSyncIDMap[skuBind.ID] = 1
}
} else {
if v.EbaiID != 0 {
skuBind.EbaiID = v.EbaiID
}
if v.ElmID != 0 {
skuBind.ElmID = v.ElmID
}
skuBind.JdSyncStatus = model.SyncFlagNewMask
skuBind.ElmSyncStatus = model.SyncFlagNewMask
skuBind.EbaiSyncStatus = model.SyncFlagNewMask
err = dao.CreateEntity(db, skuBind)
needSyncIDMap[skuBind.ID] = 1
}
}
if err != nil {
dao.Rollback(db)
return 0, err
} }
} }
if err != nil {
dao.Rollback(db)
return 0, err
}
}
if skuBindInfo.UnitPrice != 0 {
num = int64(addNum + len(existBinds))
} else { } else {
num = int64(addNum + delNum + updateNum) dao.Rollback(db)
return 0, err
} }
dao.Commit(db)
err = CurVendorSync.SyncStoreSku(db, storeID, skuIDs, false, userName)
} }
return num, err dao.Commit(db)
skuIDs := jxutils.IntMap2List(needSyncIDMap)
err = CurVendorSync.SyncStoreSku(db, storeID, skuIDs, false, userName)
return int64(len(skuIDs)), err
} }
// 计算SKU价格，unitPrice为一斤的单价，specQuality为质量，单位为克 // 计算SKU价格，unitPrice为一斤的单价，specQuality为质量，单位为克

9
business/jxutils/jxutils_cms.go
View File

@@ -90,3 +90,12 @@ func ConvertDistanceToLogLat(lng, lat, distance, angle float64) (newLng, newLat
newLat = lat + (distance*math.Cos(angle*math.Pi/180))/oneDu //将距离转换成纬度的计算公式 newLat = lat + (distance*math.Cos(angle*math.Pi/180))/oneDu //将距离转换成纬度的计算公式
return newLng, newLat return newLng, newLat
} }
func IntMap2List(intMap map[int]int) []int {
retVal := make([]int, len(intMap))
index := 0
for k := range intMap {
retVal[index] = k
}
return retVal
}