1
This commit is contained in:
@@ -1914,7 +1914,6 @@ func UpdateStoreVendorMap(ctx *jxcontext.Context, db *dao.DaoDB, storeID, vendor
|
|||||||
valid["address"] = address
|
valid["address"] = address
|
||||||
}
|
}
|
||||||
|
|
||||||
globals.SugarLogger.Debugf("=============== %s", utils.Format4Output(isUpdateStoreNeedSync(valid), false))
|
|
||||||
if isUpdateStoreNeedSync(valid) { // 同步修改门店已经配送门店
|
if isUpdateStoreNeedSync(valid) { // 同步修改门店已经配送门店
|
||||||
_, err = CurVendorSync.SyncStore(ctx, db, vendorID, storeID, false, userName)
|
_, err = CurVendorSync.SyncStore(ctx, db, vendorID, storeID, false, userName)
|
||||||
updateCourierStores(ctx, storeID)
|
updateCourierStores(ctx, storeID)
|
||||||
|
|||||||
@@ -248,7 +248,6 @@ func (v *VendorSync) SyncStore2(ctx *jxcontext.Context, db *dao.DaoDB, vendorIDs
|
|||||||
if len(loopMapInfo.StoreMapList) > 1 {
|
if len(loopMapInfo.StoreMapList) > 1 {
|
||||||
db2 = dao.GetDB()
|
db2 = dao.GetDB()
|
||||||
}
|
}
|
||||||
globals.SugarLogger.Debugf("=========storeMap := %s", utils.Format4Output(storeMap, false))
|
|
||||||
if model.IsSyncStatusNew(storeMap.SyncStatus) {
|
if model.IsSyncStatusNew(storeMap.SyncStatus) {
|
||||||
storeDetail, _ := dao.GetStoreDetail(db, storeMap.StoreID, storeMap.VendorID, storeMap.VendorOrgCode)
|
storeDetail, _ := dao.GetStoreDetail(db, storeMap.StoreID, storeMap.VendorID, storeMap.VendorOrgCode)
|
||||||
if vendorStoreID, err = handler.CreateStore2(db2, storeMap.StoreID, userName, nil, storeDetail); err == nil {
|
if vendorStoreID, err = handler.CreateStore2(db2, storeMap.StoreID, userName, nil, storeDetail); err == nil {
|
||||||
|
|||||||
@@ -238,7 +238,9 @@ func FullSyncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo
|
|||||||
case 1:
|
case 1:
|
||||||
if singleStoreHandler != nil {
|
if singleStoreHandler != nil {
|
||||||
// 同步分类在同步商品
|
// 同步分类在同步商品
|
||||||
_, err = SyncStoreSkuNew(ctx, task, 0, vendorID, storeID, vendorStoreID, "", nil, nil, excludeSkuIDs, false, isContinueWhenError)
|
if !isAdd {
|
||||||
|
_, err = SyncStoreSkuNew(ctx, task, 0, vendorID, storeID, vendorStoreID, "", nil, nil, excludeSkuIDs, false, isContinueWhenError)
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
// 直接同步商品
|
// 直接同步商品
|
||||||
err = syncStoreSkuNew(ctx, task, 0, true, vendorID, storeID, "", nil, nil, excludeSkuIDs, false, isContinueWhenError)
|
err = syncStoreSkuNew(ctx, task, 0, true, vendorID, storeID, "", nil, nil, excludeSkuIDs, false, isContinueWhenError)
|
||||||
|
|||||||
@@ -227,7 +227,6 @@ func (p *PurchaseHandler) DeleteStore(db *dao.DaoDB, storeID int, userName strin
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (p *PurchaseHandler) UpdateStore(db *dao.DaoDB, storeID int, userName string) (err error) {
|
func (p *PurchaseHandler) UpdateStore(db *dao.DaoDB, storeID int, userName string) (err error) {
|
||||||
globals.SugarLogger.Debugf("=========params := %s", utils.Format4Output(storeID, false))
|
|
||||||
var name string
|
var name string
|
||||||
if db == nil {
|
if db == nil {
|
||||||
db = dao.GetDB()
|
db = dao.GetDB()
|
||||||
@@ -272,7 +271,6 @@ func (p *PurchaseHandler) UpdateStore(db *dao.DaoDB, storeID int, userName strin
|
|||||||
"promotion_info": storeDetail.PromoteInfo,
|
"promotion_info": storeDetail.PromoteInfo,
|
||||||
}
|
}
|
||||||
if globals.EnableMtwmStoreWrite {
|
if globals.EnableMtwmStoreWrite {
|
||||||
globals.SugarLogger.Debugf("=========params := %s", utils.Format4Output(params, false))
|
|
||||||
errList.AddErr(mtapi.PoiSave(storeDetail.VendorStoreID, params))
|
errList.AddErr(mtapi.PoiSave(storeDetail.VendorStoreID, params))
|
||||||
}
|
}
|
||||||
if storeDetail.SyncStatus&(model.SyncFlagNewMask|model.SyncFlagStoreStatus) != 0 {
|
if storeDetail.SyncStatus&(model.SyncFlagNewMask|model.SyncFlagStoreStatus) != 0 {
|
||||||
|
|||||||
Reference in New Issue
Block a user