|
|
@@ -37,7 +37,7 @@ func everythingSync() {
|
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
|
for _, v := range *data {
|
|
|
channel_code := gconv.String("channel_code")
|
|
|
- channelName := UserChannel[channel_code]
|
|
|
+ channeName := UserChannel[channel_code]
|
|
|
user_id := common.ObjToString(v["user_id"])
|
|
|
position_id := common.Int64All(v["position_id"])
|
|
|
phone := common.ObjToString(v["phone"])
|
|
|
@@ -105,14 +105,14 @@ func everythingSync() {
|
|
|
}
|
|
|
}
|
|
|
if state == 1 {
|
|
|
- sales_leads_source = fmt.Sprintf("%s登录", channelName)
|
|
|
+ sales_leads_source = fmt.Sprintf("%s登录", channeName)
|
|
|
if is_assign == 1 || is_transfer == 1 || owner != "" {
|
|
|
user_mold = 1
|
|
|
} else {
|
|
|
user_mold = 2
|
|
|
}
|
|
|
} else if state == 2 {
|
|
|
- sales_leads_source = fmt.Sprintf("%s注册", channelName)
|
|
|
+ sales_leads_source = fmt.Sprintf("%s注册", channeName)
|
|
|
if is_assign == 1 || is_transfer == 1 || owner != "" {
|
|
|
user_mold = 3
|
|
|
} else {
|
|
|
@@ -160,7 +160,7 @@ func everythingSync() {
|
|
|
"clue_id": clueId,
|
|
|
"position_id": common.If(position_id > 0, position_id, -1),
|
|
|
"change_type": "退出公海",
|
|
|
- "new_value": fmt.Sprintf("通过合作渠道%s", channelName) + fmt.Sprint(common.If(user_mold == 1 || user_mold == 2, "登录", "注册")),
|
|
|
+ "new_value": fmt.Sprintf("通过合作渠道%s", channeName) + fmt.Sprint(common.If(user_mold == 1 || user_mold == 2, "登录", "注册")),
|
|
|
"createtime": nowTime,
|
|
|
"BCPCID": common.GetRandom(32),
|
|
|
"operator_id": -1,
|
|
|
@@ -173,9 +173,9 @@ func everythingSync() {
|
|
|
log.Println("三方渠道数据定时任务结束")
|
|
|
}
|
|
|
|
|
|
-func saveEverything(user_id, phone, item, sourceName, sourceCode, channelName string) bool {
|
|
|
- if channelName == "" {
|
|
|
- channelName = "一切都好"
|
|
|
+func saveEverything(user_id, phone, item, sourceName, sourceCode, channeName string) bool {
|
|
|
+ if channeName == "" {
|
|
|
+ channeName = "一切都好"
|
|
|
}
|
|
|
nowTime, isOk := time.Now().Format(dates.Date_Full_Layout), false
|
|
|
user_mold, is_assign, is_transfer, last_login_time, registe_time, mailbox, source, order_type, sales_leads_source := 4, 0, 0, "", "", "", "", "", ""
|
|
|
@@ -311,7 +311,7 @@ func saveEverything(user_id, phone, item, sourceName, sourceCode, channelName st
|
|
|
"clue_id": clueId,
|
|
|
"position_id": common.If(position_id > 0, position_id, -1),
|
|
|
"change_type": "退出公海",
|
|
|
- "new_value": fmt.Sprintf("通过合作渠道%s登录", channelName),
|
|
|
+ "new_value": fmt.Sprintf("通过合作渠道%s登录", channeName),
|
|
|
"createtime": nowTime,
|
|
|
"BCPCID": common.GetRandom(32),
|
|
|
"operator_id": -1,
|
WH01243