|
|
@@ -10,6 +10,7 @@ import (
|
|
|
"log"
|
|
|
"strconv"
|
|
|
"strings"
|
|
|
+ "time"
|
|
|
)
|
|
|
|
|
|
//定义orm引擎
|
|
|
@@ -210,7 +211,7 @@ func (service *DeduplicationService) DataDeduplicateByAccountId(data *deduplicat
|
|
|
}
|
|
|
// 根据账户id进行判重并存入数据
|
|
|
func (service *DeduplicationService) DataDeduplicateAndSave(data *deduplication.ByAccountRequest) (*deduplication.Info, string) {
|
|
|
- log.Println("开始=====")
|
|
|
+ log.Println("开始=====",time.Now())
|
|
|
orm := Engine.NewSession()
|
|
|
defer orm.Close()
|
|
|
// 模运算取企业id 企业id是int 类型的直接对100取模
|
|
|
@@ -286,6 +287,8 @@ func (service *DeduplicationService) DataDeduplicateAndSave(data *deduplication.
|
|
|
log.Println(totalInfoCount,count,"88888888")
|
|
|
log.Println(len(insertList))
|
|
|
go SaveMysql(tableName,insertList)
|
|
|
+ log.Println("结束=====",time.Now())
|
|
|
+
|
|
|
return &deduplication.Info{
|
|
|
TotalCount: int64(totalInfoCount),
|
|
|
ExistCount: int64(count),
|
