|
@@ -97,6 +97,7 @@ func initPrivatePublicKey() {
|
|
}
|
|
}
|
|
|
|
|
|
func ChanMonitor() {
|
|
func ChanMonitor() {
|
|
|
|
+
|
|
var (
|
|
var (
|
|
saveData []map[string]interface{}
|
|
saveData []map[string]interface{}
|
|
upData []map[string]interface{}
|
|
upData []map[string]interface{}
|
|
@@ -174,7 +175,7 @@ func ChanMonitor() {
|
|
public.BaseMysql.SelectBySql(fmt.Sprintf(`UPDATE anonymous_identity
|
|
public.BaseMysql.SelectBySql(fmt.Sprintf(`UPDATE anonymous_identity
|
|
SET fid = CASE %s ELSE fid END,
|
|
SET fid = CASE %s ELSE fid END,
|
|
trustedId = CASE %s ELSE trustedId END
|
|
trustedId = CASE %s ELSE trustedId END
|
|
- WHERE guestUID IN (%s);`, strings.Join(column1, " "), strings.Join(column2, " "), strings.Join(ids, " ")))
|
|
|
|
|
|
+ WHERE guestUID IN (%s);`, strings.Join(column1, " "), strings.Join(column2, " "), strings.Join(ids, ",")))
|
|
upData = []map[string]interface{}{}
|
|
upData = []map[string]interface{}{}
|
|
}
|
|
}
|
|
}
|
|
}
|