diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index a8c9fbbfb..51fd244ed 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -1593,7 +1593,7 @@ func sendStoreStatusInfo2Mobile(mobile, title, txtAlarm string) { } } -func SaveAndSendAlarmVendorSnapshot(ctx *jxcontext.Context, vendorIDs, storeIDs []int) (err error) { +func SaveAndSendAlarmVendorSnapshot(ctx *jxcontext.Context, vendorIDs, storeIDs []int, isAsync bool) (err error) { curSnapshotAt := getCurrentSnapshotAt(time.Now()) db := dao.GetDB() var curSnapshotList, prevSnapshotList []*model.VendorStoreSnapshot @@ -1617,6 +1617,8 @@ func SaveAndSendAlarmVendorSnapshot(ctx *jxcontext.Context, vendorIDs, storeIDs return nil, err }, 4) tasksch.ManageTask(task).Run() - _, err = task.GetResult(0) + if !isAsync { + _, err = task.GetResult(0) + } return err } diff --git a/business/jxstore/cms/sync_store.go b/business/jxstore/cms/sync_store.go index 5d58de7c7..8aac73b73 100644 --- a/business/jxstore/cms/sync_store.go +++ b/business/jxstore/cms/sync_store.go @@ -37,7 +37,9 @@ func OpenRemoteStoreByJxStatus(ctx *jxcontext.Context, vendorIDs, storeIDs []int storeDetail, err := dao.GetStoreDetail(db, storeMap.StoreID, storeMap.VendorID) if err == nil && storeDetail.Status == model.StoreStatusOpened { if err = handler.UpdateStoreStatus(ctx, storeMap.StoreID, storeMap.VendorStoreID, model.StoreStatusOpened); err == nil { - retVal = []int{0} + storeMap.Status = model.StoreStatusOpened + dao.UpdateEntity(db, storeMap, model.FieldStatus) + retVal = []int{1} } } }