lkness/bi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
1340691923@qq.com 2022-03-04 12:10:02 +08:00
parent b4650a18b7
commit 079aa5d652
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
platform-basic-libs/service/consumer_data/reportdata2ck.go
View File

@ -60,7 +60,6 @@ func (this *ReportData2CK) Flush() (err error) {
dims, _ := TableColumnMap.Load(tableName) dims, _ := TableColumnMap.Load(tableName)
for _, dim := range dims.([]*model2.ColumnWithType) { for _, dim := range dims.([]*model2.ColumnWithType) {
val := parser.GetValueByType(this.buffer[bufferIndex][tableName], dim) val := parser.GetValueByType(this.buffer[bufferIndex][tableName], dim)
logs.Logger.Sugar().Errorf("dim.SourceName",dim.SourceName,val)
rowArr = append(rowArr, val) rowArr = append(rowArr, val)
} }
@ -109,13 +108,11 @@ func (this *ReportData2CK) Flush() (err error) {
defer stmt.Close() defer stmt.Close()
haveFail := false haveFail := false
for _, row := range rowsMap[tableName.(string)] { for _, row := range rowsMap[tableName.(string)] {
logs.Logger.Sugar().Errorf("bytesbuffer.String()",insertSql)
if _, err := stmt.Exec(row...); err != nil { if _, err := stmt.Exec(row...); err != nil {
logs.Logger.Error("CK入库失败", zap.Error(err)) logs.Logger.Error("CK入库失败", zap.Error(err))
haveFail = true haveFail = true
} }
logs.Logger.Sugar().Errorf("bytesbuffer.String() args",row...)
} }
if !haveFail { if !haveFail {
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {