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

- UpdateStoresSkus, add IsSale to StoreSkuBindInfo

Browse Source
This commit is contained in:
gazebo
2018-11-27 14:44:08 +08:00
parent dde8bc9d20
commit 78b542d5e0
3 changed files with 128 additions and 120 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -48,6 +48,7 @@ type StoreSkuBindInfo struct {
NameID int `json:"nameID"` NameID int `json:"nameID"`
UnitPrice int `json:"unitPrice"` // 对于是份的SKU就是单价（每斤价格），其它则为总价 UnitPrice int `json:"unitPrice"` // 对于是份的SKU就是单价（每斤价格），其它则为总价
IsFocus int `json:"isFocus"` // -1：不关注，0：忽略，1：关注 IsFocus int `json:"isFocus"` // -1：不关注，0：忽略，1：关注
IsSale int `json:"isSale"` // -1：不可售，0：忽略，1：可售
SubStoreID int `json:"subStoreID"` SubStoreID int `json:"subStoreID"`
Skus []*StoreSkuBindSkuInfo `json:"skus"` Skus []*StoreSkuBindSkuInfo `json:"skus"`
} }
@@ -234,13 +235,14 @@ func GetStoreSkus(ctx *jxcontext.Context, storeID int, isFocus bool, keyword str
return skuNamesInfo, err return skuNamesInfo, err
} }
func UpdateStoreSku(ctx *jxcontext.Context, storeID int, skuBindInfo *StoreSkuBindInfo, userName string) (num int64, err error) { func UpdateStoreSku(ctx *jxcontext.Context, storeID int, skuBindInfo *StoreSkuBindInfo) (num int64, err error) {
return UpdateStoreSkus(ctx, storeID, []*StoreSkuBindInfo{skuBindInfo}, userName) return UpdateStoreSkus(ctx, storeID, []*StoreSkuBindInfo{skuBindInfo})
} }
func UpdateStoreSkus(ctx *jxcontext.Context, storeID int, skuBindInfos []*StoreSkuBindInfo, userName string) (num int64, err error) { func UpdateStoreSkus(ctx *jxcontext.Context, storeID int, skuBindInfos []*StoreSkuBindInfo) (num int64, err error) {
skuIDs, err := updateStoreSkusWithoutSync(ctx, storeID, skuBindInfos, userName) skuIDs, err := updateStoresSkusWithoutSync(ctx, []int{storeID}, skuBindInfos)
if err == nil { num = int64(len(skuIDs))
if err == nil && num > 0 {
db := dao.GetDB() db := dao.GetDB()
_, err = CurVendorSync.SyncStoresSkus(ctx, db, nil, []int{storeID}, skuIDs, false, false) _, err = CurVendorSync.SyncStoresSkus(ctx, db, nil, []int{storeID}, skuIDs, false, false)
return int64(len(skuIDs)), err return int64(len(skuIDs)), err
@@ -248,8 +250,19 @@ func UpdateStoreSkus(ctx *jxcontext.Context, storeID int, skuBindInfos []*StoreS
return 0, err return 0, err
} }
func updateStoreSkusWithoutSync(ctx *jxcontext.Context, storeID int, skuBindInfos []*StoreSkuBindInfo, userName string) (needSyncSkus []int, err error) { func UpdateStoresSkus(ctx *jxcontext.Context, storeIDs []int, skuBindInfos []*StoreSkuBindInfo) (num int64, err error) {
skuIDs, err := updateStoresSkusWithoutSync(ctx, storeIDs, skuBindInfos)
num = int64(len(skuIDs))
if num > 0 {
db := dao.GetDB()
_, err = CurVendorSync.SyncStoresSkus(ctx, db, nil, storeIDs, skuIDs, false, false)
}
return num, err
}
func updateStoresSkusWithoutSync(ctx *jxcontext.Context, storeIDs []int, skuBindInfos []*StoreSkuBindInfo) (needSyncSkus []int, err error) {
db := dao.GetDB() db := dao.GetDB()
userName := ctx.GetUserName()
needSyncIDMap := make(map[int]int) needSyncIDMap := make(map[int]int)
dao.Begin(db) dao.Begin(db)
defer func() { defer func() {
@@ -258,117 +271,115 @@ func updateStoreSkusWithoutSync(ctx *jxcontext.Context, storeID int, skuBindInfo
panic(r) panic(r)
} }
}() }()
for _, skuBindInfo := range skuBindInfos { for _, storeID := range storeIDs {
inSkuBinds := skuBindInfo.Skus for _, skuBindInfo := range skuBindInfos {
var allBinds []*tStoreSkuBindAndSpec inSkuBinds := skuBindInfo.Skus
if err = dao.GetRows(db, &allBinds, ` var allBinds []*tStoreSkuBindAndSpec
if err = dao.GetRows(db, &allBinds, `
SELECT t2.*, t1.id real_sku_id, t1.spec_quality, t1.spec_unit, t3.price sku_name_price, t3.unit sku_name_unit SELECT t2.*, t1.id real_sku_id, t1.spec_quality, t1.spec_unit, t3.price sku_name_price, t3.unit sku_name_unit
FROM sku t1 FROM sku t1
LEFT JOIN store_sku_bind t2 ON t2.sku_id = t1.id AND store_id = ? AND t2.deleted_at = ? LEFT JOIN store_sku_bind t2 ON t2.sku_id = t1.id AND store_id = ? AND t2.deleted_at = ?
JOIN sku_name t3 ON t1.name_id = t3.id AND t3.deleted_at = ? JOIN sku_name t3 ON t1.name_id = t3.id AND t3.deleted_at = ?
WHERE t1.name_id = ? AND t1.deleted_at = ? WHERE t1.name_id = ? AND t1.deleted_at = ?
`, storeID, utils.DefaultTimeValue, utils.DefaultTimeValue, skuBindInfo.NameID, utils.DefaultTimeValue); err == nil { `, storeID, utils.DefaultTimeValue, utils.DefaultTimeValue, skuBindInfo.NameID, utils.DefaultTimeValue); err == nil {
globals.SugarLogger.Debug(utils.Format4Output(allBinds, false)) globals.SugarLogger.Debug(utils.Format4Output(allBinds, false))
inSkuBinsMap := make(map[int]*StoreSkuBindSkuInfo, len(inSkuBinds)) inSkuBinsMap := make(map[int]*StoreSkuBindSkuInfo, len(inSkuBinds))
for _, v := range inSkuBinds { for _, v := range inSkuBinds {
inSkuBinsMap[v.SkuID] = v inSkuBinsMap[v.SkuID] = v
}
unitPrice := 0
if skuBindInfo.UnitPrice != 0 {
unitPrice = skuBindInfo.UnitPrice
} else {
unitPrice = allBinds[0].UnitPrice
if unitPrice == 0 {
unitPrice = allBinds[0].SkuNamePrice
} }
} unitPrice := 0
for _, v := range allBinds { if skuBindInfo.UnitPrice != 0 {
var num int64 unitPrice = skuBindInfo.UnitPrice
inSkuBind := inSkuBinsMap[v.RealSkuID]
// globals.SugarLogger.Debug(utils.Format4Output(inSkuBind, false))
var skuBind *model.StoreSkuBind
if v.ID == 0 {
if skuBindInfo.IsFocus == 1 {
skuBind = &model.StoreSkuBind{
StoreID: storeID,
SkuID: v.RealSkuID,
SubStoreID: skuBindInfo.SubStoreID, // todo 这个应该从用户信息中自动获得
UnitPrice: unitPrice,
Price: jxutils.CaculateSkuPrice(unitPrice, v.SpecQuality, v.SpecUnit, v.SkuNameUnit),
Status: model.StoreSkuBindStatusDontSale, // 缺省不可售？
}
if inSkuBind != nil && inSkuBind.IsSale == 1 {
skuBind.Status = model.StoreSkuBindStatusNormal
}
setStoreSkuBindStatus(skuBind, model.SyncFlagNewMask)
dao.WrapAddIDCULDEntity(skuBind, userName)
globals.SugarLogger.Debug(utils.Format4Output(skuBind, false))
if err = dao.CreateEntity(db, skuBind); err != nil {
dao.Rollback(db)
return nil, err
}
num = 1
}
} else { } else {
skuBind = &v.StoreSkuBind unitPrice = allBinds[0].UnitPrice
if unitPrice == 0 {
if skuBindInfo.IsFocus == -1 { unitPrice = allBinds[0].SkuNamePrice
if num, err = dao.DeleteEntityLogically(db, skuBind, map[string]interface{}{ }
model.FieldStatus: model.StoreSkuBindStatusDeleted, }
model.FieldJdSyncStatus: model.SyncFlagDeletedMask, for _, v := range allBinds {
model.FieldElmSyncStatus: model.SyncFlagDeletedMask, var num int64
model.FieldEbaiSyncStatus: model.SyncFlagDeletedMask, inSkuBind := inSkuBinsMap[v.RealSkuID]
}, userName, nil); err != nil { // globals.SugarLogger.Debug(utils.Format4Output(inSkuBind, false))
dao.Rollback(db) var skuBind *model.StoreSkuBind
return nil, err if v.ID == 0 {
}
} else {
needUpdate := false
if skuBindInfo.IsFocus == 1 { if skuBindInfo.IsFocus == 1 {
skuBind.Status = model.StoreSkuBindStatusDontSale // 缺省不可售？ skuBind = &model.StoreSkuBind{
skuBind.DeletedAt = utils.DefaultTimeValue StoreID: storeID,
needUpdate = true SkuID: v.RealSkuID,
} SubStoreID: skuBindInfo.SubStoreID, // todo 这个应该从用户信息中自动获得
if inSkuBind != nil && inSkuBind.IsSale != 0 { UnitPrice: unitPrice,
if inSkuBind.IsSale == 1 { Price: jxutils.CaculateSkuPrice(unitPrice, v.SpecQuality, v.SpecUnit, v.SkuNameUnit),
skuBind.Status = model.StoreSkuBindStatusNormal Status: model.StoreSkuBindStatusDontSale, // 缺省不可售？
} else {
skuBind.Status = model.StoreSkuBindStatusDontSale
} }
setStoreSkuBindStatus(skuBind, model.SyncFlagSaleMask) if tmpStatus := getSkuSaleStatus(inSkuBind, skuBindInfo); tmpStatus != model.StoreSkuBindStatusNA {
needUpdate = true skuBind.Status = tmpStatus
} }
if skuBindInfo.UnitPrice != 0 { // 这里是否需要加此条件限制 setStoreSkuBindStatus(skuBind, model.SyncFlagNewMask)
skuBind.UnitPrice = unitPrice dao.WrapAddIDCULDEntity(skuBind, userName)
skuBind.Price = jxutils.CaculateSkuPrice(unitPrice, v.SpecQuality, v.SpecUnit, v.SkuNameUnit) globals.SugarLogger.Debug(utils.Format4Output(skuBind, false))
setStoreSkuBindStatus(skuBind, model.SyncFlagPriceMask) if err = dao.CreateEntity(db, skuBind); err != nil {
needUpdate = true
}
if inSkuBind != nil && inSkuBind.EbaiID != 0 {
skuBind.EbaiID = inSkuBind.EbaiID
needUpdate = true
}
if inSkuBind != nil && inSkuBind.ElmID != 0 {
skuBind.ElmID = inSkuBind.ElmID
needUpdate = true
}
if needUpdate {
setStoreSkuBindStatus(skuBind, model.SyncFlagModifiedMask)
dao.WrapUpdateULEntity(skuBind, userName)
if num, err = dao.UpdateEntity(db, skuBind); err != nil {
dao.Rollback(db) dao.Rollback(db)
return nil, err return nil, err
} }
num = 1
}
} else {
skuBind = &v.StoreSkuBind
if skuBindInfo.IsFocus == -1 {
if num, 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); err != nil {
dao.Rollback(db)
return nil, err
}
} else {
needUpdate := false
if skuBindInfo.IsFocus == 1 {
skuBind.Status = model.StoreSkuBindStatusDontSale // 缺省不可售？
skuBind.DeletedAt = utils.DefaultTimeValue
needUpdate = true
}
if tmpStatus := getSkuSaleStatus(inSkuBind, skuBindInfo); tmpStatus != model.StoreSkuBindStatusNA {
skuBind.Status = tmpStatus
setStoreSkuBindStatus(skuBind, model.SyncFlagSaleMask)
needUpdate = true
}
if skuBindInfo.UnitPrice != 0 { // 这里是否需要加此条件限制
skuBind.UnitPrice = unitPrice
skuBind.Price = jxutils.CaculateSkuPrice(unitPrice, v.SpecQuality, v.SpecUnit, v.SkuNameUnit)
setStoreSkuBindStatus(skuBind, model.SyncFlagPriceMask)
needUpdate = true
}
if inSkuBind != nil && inSkuBind.EbaiID != 0 {
skuBind.EbaiID = inSkuBind.EbaiID
needUpdate = true
}
if inSkuBind != nil && inSkuBind.ElmID != 0 {
skuBind.ElmID = inSkuBind.ElmID
needUpdate = true
}
if needUpdate {
setStoreSkuBindStatus(skuBind, model.SyncFlagModifiedMask)
dao.WrapUpdateULEntity(skuBind, userName)
if num, err = dao.UpdateEntity(db, skuBind); err != nil {
dao.Rollback(db)
return nil, err
}
}
} }
} }
if skuBind != nil && num == 1 {
needSyncIDMap[skuBind.SkuID] = 1
}
} }
if skuBind != nil && num == 1 { } else {
needSyncIDMap[skuBind.SkuID] = 1 dao.Rollback(db)
} return nil, err
} }
} else {
dao.Rollback(db)
return nil, err
} }
} }
dao.Commit(db) dao.Commit(db)
@@ -376,23 +387,19 @@ func updateStoreSkusWithoutSync(ctx *jxcontext.Context, storeID int, skuBindInfo
return skuIDs, err return skuIDs, err
} }
func UpdateStoresSkus(ctx *jxcontext.Context, storeIDs []int, skuBindInfos []*StoreSkuBindInfo, userName string) (num int64, err error) { func getSkuSaleStatus(inSkuBind *StoreSkuBindSkuInfo, skuBindInfo *StoreSkuBindInfo) int {
for _, storeID := range storeIDs { tempSale := 0
skuIDs, err2 := updateStoreSkusWithoutSync(ctx, storeID, skuBindInfos, userName) if inSkuBind != nil {
if err = err2; err != nil { tempSale = inSkuBind.IsSale
return 0, err } else {
} tempSale = skuBindInfo.IsSale
num += int64(len(skuIDs))
} }
skuIDs := make([]int, 0) if tempSale == -1 {
for _, v := range skuBindInfos { return model.StoreSkuBindStatusDontSale
for _, v2 := range v.Skus { } else if tempSale == 1 {
skuIDs = append(skuIDs, v2.SkuID) return model.StoreSkuBindStatusNormal
}
} }
db := dao.GetDB() return model.StoreSkuBindStatusNA
_, err = CurVendorSync.SyncStoresSkus(ctx, db, nil, storeIDs, skuIDs, false, false)
return num, err
} }
func updateStoreSkusSaleWithoutSync(ctx *jxcontext.Context, storeID int, skuBindSkuInfos []*StoreSkuBindSkuInfo, userName string) (needSyncSkus []int, err error) { func updateStoreSkusSaleWithoutSync(ctx *jxcontext.Context, storeID int, skuBindSkuInfos []*StoreSkuBindSkuInfo, userName string) (needSyncSkus []int, err error) {

1
business/model/store_sku.go
View File

@@ -1,6 +1,7 @@
package model package model
const ( const (
StoreSkuBindStatusNA = -2
StoreSkuBindStatusDeleted = -1 StoreSkuBindStatusDeleted = -1
StoreSkuBindStatusDontSale = 0 StoreSkuBindStatusDontSale = 0
StoreSkuBindStatusNormal = 1 StoreSkuBindStatusNormal = 1

10
controllers/cms_store_sku.go
View File

@@ -41,7 +41,7 @@ func (c *StoreSkuController) GetStoreSkus() {
// @Title 修改商家商品绑定 // @Title 修改商家商品绑定
// @Description 修改商家商品绑定 // @Description 修改商家商品绑定
// @Param token header string true "认证token" // @Param token header string true "认证token"
// @Param storeID formData int true "需要修改的商品名ID，payload中的相应数据会被忽略" // @Param storeID formData int true 门店ID"
// @Param payload formData string true "json数据，StoreSkuBindInfo对象" // @Param payload formData string true "json数据，StoreSkuBindInfo对象"
// @Success 200 {object} controllers.CallResult // @Success 200 {object} controllers.CallResult
// @Failure 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult
@@ -50,7 +50,7 @@ func (c *StoreSkuController) UpdateStoreSku() {
c.callUpdateStoreSku(func(params *tStoreSkuUpdateStoreSkuParams) (retVal interface{}, errCode string, err error) { c.callUpdateStoreSku(func(params *tStoreSkuUpdateStoreSkuParams) (retVal interface{}, errCode string, err error) {
var skuBindInfo cms.StoreSkuBindInfo var skuBindInfo cms.StoreSkuBindInfo
if err = utils.UnmarshalUseNumber([]byte(params.Payload), &skuBindInfo); err == nil { if err = utils.UnmarshalUseNumber([]byte(params.Payload), &skuBindInfo); err == nil {
retVal, err = cms.UpdateStoreSku(params.Ctx, params.StoreID, &skuBindInfo, params.Ctx.GetUserName()) retVal, err = cms.UpdateStoreSku(params.Ctx, params.StoreID, &skuBindInfo)
} }
return retVal, "", err return retVal, "", err
}) })
@@ -59,7 +59,7 @@ func (c *StoreSkuController) UpdateStoreSku() {
// @Title 批量修改商家商品绑定 // @Title 批量修改商家商品绑定
// @Description 批量修改商家商品绑定 // @Description 批量修改商家商品绑定
// @Param token header string true "认证token" // @Param token header string true "认证token"
// @Param storeID formData int true "需要修改的商品名ID，payload中的相应数据会被忽略" // @Param storeID formData int true "门店ID"
// @Param payload formData string true "json数据，StoreSkuBindInfo对象数组" // @Param payload formData string true "json数据，StoreSkuBindInfo对象数组"
// @Success 200 {object} controllers.CallResult // @Success 200 {object} controllers.CallResult
// @Failure 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult
@@ -68,7 +68,7 @@ func (c *StoreSkuController) UpdateStoreSkus() {
c.callUpdateStoreSkus(func(params *tStoreSkuUpdateStoreSkusParams) (retVal interface{}, errCode string, err error) { c.callUpdateStoreSkus(func(params *tStoreSkuUpdateStoreSkusParams) (retVal interface{}, errCode string, err error) {
var skuBindInfos []*cms.StoreSkuBindInfo var skuBindInfos []*cms.StoreSkuBindInfo
if err = utils.UnmarshalUseNumber([]byte(params.Payload), &skuBindInfos); err == nil { if err = utils.UnmarshalUseNumber([]byte(params.Payload), &skuBindInfos); err == nil {
retVal, err = cms.UpdateStoreSkus(params.Ctx, params.StoreID, skuBindInfos, params.Ctx.GetUserName()) retVal, err = cms.UpdateStoreSkus(params.Ctx, params.StoreID, skuBindInfos)
} }
return retVal, "", err return retVal, "", err
}) })
@@ -121,7 +121,7 @@ func (c *StoreSkuController) UpdateStoresSkus() {
var skuBindInfos []*cms.StoreSkuBindInfo var skuBindInfos []*cms.StoreSkuBindInfo
if err = utils.UnmarshalUseNumber([]byte(params.StoreIDs), &storeIDs); err == nil { if err = utils.UnmarshalUseNumber([]byte(params.StoreIDs), &storeIDs); err == nil {
if err = utils.UnmarshalUseNumber([]byte(params.Payload), &skuBindInfos); err == nil { if err = utils.UnmarshalUseNumber([]byte(params.Payload), &skuBindInfos); err == nil {
retVal, err = cms.UpdateStoresSkus(params.Ctx, storeIDs, skuBindInfos, params.Ctx.GetUserName()) retVal, err = cms.UpdateStoresSkus(params.Ctx, storeIDs, skuBindInfos)
} }
} }
return retVal, "", err return retVal, "", err