SetStoresMapSyncStatus

business/jxstore/cms/store.go

@@ -1167,7 +1167,7 @@ func UpdateStoreVendorMap(ctx *jxcontext.Context, db *dao.DaoDB, storeID, vendor
 		}
 	}
 	// 暂时不开放isSync
-	if payload["isSync"] != nil {
+	if isSync, ok := payload["isSync"].(int); ok && isSync == 0 {
 		delete(payload, "isSync")
 	}
 	if db == nil {

business/jxstore/misc/misc.go

@@ -232,6 +232,7 @@ func doDailyWork() {
 	cms.SyncStoresCourierInfo(jxcontext.AdminCtx, nil, false, true)
 	netprinter.RebindAllPrinters(jxcontext.AdminCtx, false, true)
 
+	dao.SetStoresMapSyncStatus(dao.GetDB(), nil, nil, model.SyncFlagStoreStatus)
 	cms.CurVendorSync.SyncStore2(jxcontext.AdminCtx, dao.GetDB(), nil, nil, true, true)
 
 	syncStoreSku()

business/model/dao/store.go

@@ -256,6 +256,30 @@ func GetStoresMapList2(db *DaoDB, vendorIDs, storeIDs, storeStatuss []int, statu
 	return nil, err
 }
 
+func SetStoresMapSyncStatus(db *DaoDB, vendorIDs, storeIDs []int, syncStatus int8) (err error) {
+	sql := `
+	UPDATE store_map t1
+	JOIN store t2 ON t2.id = t1.store_id AND t2.deleted_at = ?
+	SET t1.sync_status = t1.sync_status | ?
+	WHERE t1.deleted_at = ?
+	`
+	sqlParams := []interface{}{
+		syncStatus,
+		utils.DefaultTimeValue,
+		utils.DefaultTimeValue,
+	}
+	if len(vendorIDs) > 0 {
+		sql += " AND t1.vendor_id IN (" + GenQuestionMarks(len(vendorIDs)) + ")"
+		sqlParams = append(sqlParams, vendorIDs)
+	}
+	if len(storeIDs) > 0 {
+		sql += " AND t1.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
+		sqlParams = append(sqlParams, storeIDs)
+	}
+	_, err = ExecuteSQL(db, sql, sqlParams...)
+	return err
+}
+
 func GetStoresMapList(db *DaoDB, vendorIDs, storeIDs, storeStatuss []int, status, isSync int, pricePack string) (storeMapList []*model.StoreMap, err error) {
 	return GetStoresMapList2(db, vendorIDs, storeIDs, storeStatuss, status, isSync, pricePack, false)
 }