| 92 | } |
| 93 | |
| 94 | func DeleteORGDataNonRealTime(orgIDs []int) error { |
| 95 | log.Infof("delete orgs (ids: %v) clickhouse data", orgIDs) |
| 96 | var msg string |
| 97 | for _, id := range orgIDs { |
| 98 | if err := servercommon.DropOrg(uint16(id)); err != nil { |
| 99 | log.Errorf("failed to drop org %d ck: %s", id, err.Error()) |
| 100 | msg += fmt.Sprintf("%s. ", err.Error()) |
| 101 | } |
| 102 | } |
| 103 | if msg == "" { |
| 104 | return nil |
| 105 | } |
| 106 | return fmt.Errorf(msg) |
| 107 | } |
| 108 | |
| 109 | func GetORGData(cfg *config.ControllerConfig) (*simplejson.Json, error) { |
| 110 | errResponse, _ := simplejson.NewJson([]byte("{}")) |