|
@@ -641,7 +641,7 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
|
|
|
mapActivityeBill := make(map[string]bool)
|
|
|
for _, v := range listBillByActivity {
|
|
|
- mapActivityeBill[fmt.Sprint("UID_", v.UserId, "SID_", v.SourceId)] = true
|
|
|
+ mapActivityeBill[fmt.Sprint("UID_", v.Mobile, "SID_", v.SourceId)] = true
|
|
|
}
|
|
|
|
|
|
mapArticleBillDel := make(map[string]bool)
|
|
@@ -660,7 +660,11 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
}
|
|
|
|
|
|
for _, v := range signUpDetailList {
|
|
|
- if mapActivityeBill[fmt.Sprint("UID_", v.UserId, "SID_", v.ActivityId)] { // 如果内容存在就不插入
|
|
|
+ if v.UserId == 0 && v.Mobile != "" {
|
|
|
+ v.UserId = mapUserMobileUserId[v.Mobile] // 空降的部分联系人 userid 为0这里做一下修复
|
|
|
+ }
|
|
|
+
|
|
|
+ if mapActivityeBill[fmt.Sprint("UID_", v.Mobile, "SID_", v.ActivityId)] { // 如果内容存在就不插入
|
|
|
continue
|
|
|
}
|
|
|
item := new(rai_serve.CygxRaiServeBill)
|
|
@@ -672,9 +676,6 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
item.ServeTypeId = 2
|
|
|
item.ServeTypeName = "线下活动"
|
|
|
}
|
|
|
- if v.UserId == 0 && v.Mobile != "" {
|
|
|
- v.UserId = mapUserMobileUserId[v.Mobile] // 空降的部分联系人 userid 为0这里做一下修复
|
|
|
- }
|
|
|
|
|
|
item.UserId = v.UserId
|
|
|
item.Mobile = v.Mobile
|