|
|
@@ -67,7 +67,7 @@ func (service *DeduplicationService) DataDeduplicateInsert(data *deduplication.R
|
|
|
log.Println(totalInfoCount, "本批次去重后总量")
|
|
|
log.Println(totalInfoCount-totalExist, "newCount")
|
|
|
if data.IsInsert {
|
|
|
- insertSql := fmt.Sprintf("insert IGNORE into %s (info_id,ent_id,person_id) values ", tableName)
|
|
|
+ insertSql := fmt.Sprintf("insert IGNORE into %s (info_id,ent_id,person_id,account_id,data_desc) values ", tableName)
|
|
|
parmList := []string{}
|
|
|
existIdMap := map[string]bool{}
|
|
|
for _, v := range rs {
|
|
|
@@ -84,8 +84,8 @@ func (service *DeduplicationService) DataDeduplicateInsert(data *deduplication.R
|
|
|
continue
|
|
|
}
|
|
|
log.Println("新增", id)
|
|
|
- parmList = append(parmList, "(?,?,?)")
|
|
|
- insertList = append(insertList, id, data.EntId, data.PersonId)
|
|
|
+ parmList = append(parmList, "(?,?,?,?,?)")
|
|
|
+ insertList = append(insertList, id, data.EntId, data.PersonId, "", 0)
|
|
|
if len(insertList) >= 100 {
|
|
|
insertSql = fmt.Sprintf("%s %s", insertSql, strings.Join(parmList, ","))
|
|
|
tmp := []interface{}{insertSql}
|
