|
@@ -1,6 +1,7 @@
|
|
|
package ticket
|
|
|
|
|
|
import (
|
|
|
+ "encoding/json"
|
|
|
"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
|
|
|
"google.golang.org/protobuf/types/known/timestamppb"
|
|
|
"time"
|
|
@@ -8,10 +9,11 @@ import (
|
|
|
|
|
|
func (x *Ticket) Scan(row driver.Rows) error {
|
|
|
var (
|
|
|
- from map[string]string
|
|
|
- createdAt time.Time
|
|
|
- updatedAt time.Time
|
|
|
- err error
|
|
|
+ from map[string]string
|
|
|
+ createdAt time.Time
|
|
|
+ updatedAt time.Time
|
|
|
+ messageIds []string
|
|
|
+ err error
|
|
|
)
|
|
|
|
|
|
if err = row.Scan(
|
|
@@ -24,6 +26,7 @@ func (x *Ticket) Scan(row driver.Rows) error {
|
|
|
&x.Tags,
|
|
|
&createdAt,
|
|
|
&updatedAt,
|
|
|
+ &messageIds,
|
|
|
); err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -36,5 +39,11 @@ func (x *Ticket) Scan(row driver.Rows) error {
|
|
|
x.CreatedAt = timestamppb.New(createdAt)
|
|
|
x.UpdatedAt = timestamppb.New(updatedAt)
|
|
|
|
|
|
+ if len(messageIds) > 0 {
|
|
|
+ if d, err := json.Marshal(messageIds); err == nil {
|
|
|
+ x.Meta["message_ids"] = string(d)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
return nil
|
|
|
}
|