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

- mtwm.SyncLocalStoreCategory中，如果发现store_sku_category_map有记录，但还没有同步，要计算num

Browse Source
This commit is contained in:
gazebo
2019-04-16 19:39:37 +08:00
parent ba3872327a
commit ab6e30d630
1 changed files with 24 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
business/partner/purchase/mtwm/store_sku.go
View File

@@ -173,25 +173,30 @@ func (p *PurchaseHandler) SyncLocalStoreCategory(ctx *jxcontext.Context, db *dao
if err = dao.CreateEntity(db, catMap); err != nil {
return "", err
}
} else if isCheckRemote {
catMap := &model.StoreSkuCategoryMap{
MtwmSyncStatus: model.SyncFlagNewMask,
} else {
if v.VendorCatID == "" || v.VendorCatID == "0" {
num++
}
updateFields := []string{
model.FieldUpdatedAt,
model.FieldLastOperator,
model.FieldMtwmSyncStatus,
}
if identityCatMap[v.MapID] == 1 { // 如果一样，则要刷新ID（对于MTWM其实就是名字）
catMap.MtwmID = v.Name
catMap.MtwmSyncStatus = 0
updateFields = append(updateFields, model.FieldMtwmID)
}
catMap.ID = v.MapID
num++
dao.WrapUpdateULEntity(catMap, ctx.GetUserName())
if _, err = dao.UpdateEntity(db, catMap, updateFields...); err != nil {
return "", err
if isCheckRemote {
catMap := &model.StoreSkuCategoryMap{
MtwmSyncStatus: model.SyncFlagNewMask,
}
updateFields := []string{
model.FieldUpdatedAt,
model.FieldLastOperator,
model.FieldMtwmSyncStatus,
}
if identityCatMap[v.MapID] == 1 { // 如果一样，则要刷新ID（对于MTWM其实就是名字）
catMap.MtwmID = v.Name
catMap.MtwmSyncStatus = 0
updateFields = append(updateFields, model.FieldMtwmID)
}
catMap.ID = v.MapID
num++
dao.WrapUpdateULEntity(catMap, ctx.GetUserName())
if _, err = dao.UpdateEntity(db, catMap, updateFields...); err != nil {
return "", err
}
}
}
}
@@ -219,7 +224,7 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks
if hint, err = p.SyncLocalStoreCategory(ctx, db, storeID, false, skuIDs); err != nil {
return "", err
}
if true { //hint != "0" {
if hint != "0" {
if hint, err = p.SyncStoreCategory(ctx, parentTask, storeID, false); err != nil {
return "", err
}