|
@@ -2,6 +2,8 @@ package history
|
|
|
|
|
|
import (
|
|
|
"cmplatform/util"
|
|
|
+ "context"
|
|
|
+
|
|
|
// "context"
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
@@ -164,9 +166,9 @@ func (this *HistoryData) HistoryTask(history_id string) {
|
|
|
cus.GetData("history", i_dataSource) //获取数据
|
|
|
//cus.RemoveRepeatData() //数据去重
|
|
|
cus.saveBeforeData(history_id, isFilter, noticeFilter, dataTable, entId, iContact, xlsxData)
|
|
|
- // if err := util.MgoSave.C.Database(util.MgoSave.DbName).Collection(cus.saveTempColl).Drop(context.Background()); err != nil { // 删除临时表
|
|
|
- // log.Error("临时表删除失败", zap.Error(err), zap.String("coll", cus.saveTempColl))
|
|
|
- // }
|
|
|
+ if err := util.MgoSave.C.Database(util.MgoSave.DbName).Collection(cus.saveTempColl).Drop(context.Background()); err != nil { // 删除临时表
|
|
|
+ log.Error("临时表删除失败", zap.Error(err), zap.String("coll", cus.saveTempColl))
|
|
|
+ }
|
|
|
//cus.AssembelAndSaveData(history_id, isFilter, noticeFilter, dataTable, entId, iContact, xlsxData) //组装、保存数据
|
|
|
if dataTable == 2 {
|
|
|
//使用pc商机管理的企业,数据存入mysql表,扣除数据量
|