|
|
@@ -245,12 +245,11 @@ func (service *DeduplicationService) DataDeduplicateAndSave(data *deduplication.
|
|
|
infoIdList := strings.Split(data.InfoId, ",")
|
|
|
totalInfoCount := len(infoIdList)
|
|
|
err := orm.Table(tableName).Cols("info_id").Where(selectSql, valueList...).Find(&rs)
|
|
|
- existInfoIdMap := map[string]bool{}
|
|
|
existIdList := []string{}
|
|
|
existIdMap := map[string]bool{}
|
|
|
for _, v := range rs {
|
|
|
existIdMap[v.InfoId] = true
|
|
|
- if existInfoIdMap[v.InfoId] {
|
|
|
+ if existIdMap[v.InfoId] {
|
|
|
continue
|
|
|
}else {
|
|
|
existIdList = append(existIdList,v.InfoId)
|
|
|
@@ -267,8 +266,10 @@ func (service *DeduplicationService) DataDeduplicateAndSave(data *deduplication.
|
|
|
}, "判重查询失败"
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
+ //
|
|
|
+ //for _, v := range rs {
|
|
|
+ //
|
|
|
+ //}
|
|
|
// 新增
|
|
|
var insertList []entity.Deduplication
|
|
|
for _, id := range infoIdList {
|
