|
@@ -1,6 +1,7 @@
|
|
package service
|
|
package service
|
|
|
|
|
|
import (
|
|
import (
|
|
|
|
+ "app.yhyue.com/moapp/message/db"
|
|
"context"
|
|
"context"
|
|
"database/sql"
|
|
"database/sql"
|
|
"encoding/json"
|
|
"encoding/json"
|
|
@@ -854,11 +855,16 @@ func ClueImportSync(this *biservice.ClueImportReq) (string, int) {
|
|
}
|
|
}
|
|
isOks = false
|
|
isOks = false
|
|
} else if strings.HasPrefix(belong_to, "03") {
|
|
} else if strings.HasPrefix(belong_to, "03") {
|
|
|
|
+ changeMap := db.Tidb.FindOne("dwd_d_userbase_belongto_rulecode", map[string]interface{}{"code": belong_to}, "", "")
|
|
|
|
+ changeName := ""
|
|
|
|
+ if changeMap != nil && len(*changeMap) > 0 {
|
|
|
|
+ changeName = gconv.String((*changeMap)["name"])
|
|
|
|
+ }
|
|
if !isOks {
|
|
if !isOks {
|
|
- result += ",“该线索已归属合作渠道一切都好”"
|
|
|
|
|
|
+ result += fmt.Sprintf(`,“该线索已归属合作渠道%s”`, changeName)
|
|
} else {
|
|
} else {
|
|
counts++
|
|
counts++
|
|
- result += fmt.Sprint(counts) + ".第" + fmt.Sprint(k+2) + "行,“该线索已归属合作渠道一切都好”"
|
|
|
|
|
|
+ result += fmt.Sprint(counts) + ".第" + fmt.Sprint(k+2) + fmt.Sprintf(`行,“该线索已归属合作渠道%s”`, changeName)
|
|
}
|
|
}
|
|
isOks = false
|
|
isOks = false
|
|
} else {
|
|
} else {
|