rerun #16

Merged
milano15662 merged 1 commits from develop into master 2022-03-25 08:27:56 +00:00
1 changed files with 11 additions and 7 deletions

View File

@ -1,7 +1,6 @@
package appier
import (
"context"
"fmt"
"github.com/Selly-Modules/redisdb"
@ -34,25 +33,30 @@ func (s SyncToService) syncData() {
// handleSyncDataToServiceAppier ...
func handleSyncDataToServiceAppier(pattern string, typeData string) {
fmt.Println("keyProductPattern", pattern)
for {
keys, values := redisdb.GetWithPrefixPattern(pattern)
if len(keys) == 0 {
fmt.Println("No keys data")
return
}
if len(values) == 0 {
fmt.Println("No values DATA")
return
}
processSyncToServiceAppier(typeData, values)
// Del keys
for _, key := range keys {
redisdb.DelKey(context.Background(), key)
}
//// Del keys
//for _, key := range keys {
// redisdb.DelKey(context.Background(), key)
//}
}
}
// processSyncToServiceAppier ...
func processSyncToServiceAppier(typeData string, values []string) {
fmt.Println("Sends")
for {
if len(values) <= 20 {
syncDataByList(typeData, values)