- 将OpenRemoteStoreByJxStatus加入每日调度

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
 }

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}
 					}
 				}
 			}