大客分配精确到人处理

clueSync/everything.go

@@ -345,16 +345,18 @@ func bigCustomer() {
 	log.Println("大客户线索定时任务开始")
 	dataArr := []map[string]interface{}{}
 	filterArr := []string{"-pc", "-app", "-wx", "-h5"}
-	sourceMap := map[string]string{} //根据留资维表：tidb/Jianyu_subjectdb/d_saleleads_code
-	saleSource := TiDb.SelectBySql(`SELECT source,name FROM d_saleleads_code WHERE department LIKE '%大客户%' AND is_delete = 1`)
+	sourceMap := map[string]map[string]interface{}{} //根据留资维表：tidb/Jianyu_subjectdb/d_saleleads_code
+	saleSource := TiDb.SelectBySql(`SELECT source,name,appoint_email FROM d_saleleads_code WHERE department LIKE '%大客户%' AND is_delete = 1`)
 	if saleSource != nil && len(*saleSource) > 0 {
 		for _, v := range *saleSource {
+			saleSourceMap := v
 			source := common.ObjToString(v["source"])
 			name := common.ObjToString(v["name"])
 			for _, s := range filterArr {
 				name = strings.ReplaceAll(name, s, "")
 			}
-			sourceMap[source] = name
+			saleSourceMap["name"] = name
+			sourceMap[source] = saleSourceMap
 		}
 	}
 	nowTime := time.Now().Format(date.Date_Full_Layout)
@@ -386,8 +388,9 @@ func bigCustomer() {
 					uid = common.ObjToString((*userMapping)["uid"])
 				}
 			}
-			if sourceMap[sources] != "" {
-				source := sourceMap[sources]
+			if sourceMap[sources] != nil {
+				sourceData := sourceMap[sources]
+				source := sourceData["name"]
 				phone := common.ObjToString(v["phone"])
 				if IsInternal(phone) {
 					continue
@@ -428,6 +431,7 @@ func bigCustomer() {
 					"belongTo":         belongTo,
 					"interest":         interest,
 					"data_requirement": data_requirement,
+					"appoint_email":    sourceData["appoint_email"],
 				})
 			}
 			if gconv.Int64(v["createtime"]) > bigSaleTime {
@@ -508,6 +512,7 @@ func bigCustomer() {
 				"data_count":     v["data_count"],
 				"unpayorderinfo": unpayorderinfo,
 				"payorderinfo":   payorderinfo, //增加客户需求
+				"appoint_email":  "",
 			})
 			bigOrderTime = gconv.Time(gconv.String(v["create_time"])).Format(date.Date_Full_Layout)
 		}
@@ -518,7 +523,12 @@ func bigCustomer() {
 	if len(dataArr) > 0 {
 		bigArr := map[string][]map[string]interface{}{}
 		for _, v := range dataArr {
-			minemail, _ := EmailSelect("dk")
+			minemail := ""
+			if gconv.String(v["appoint_email"]) == "" {
+				minemail, _ = EmailSelect("dk")
+			} else {
+				minemail = gconv.String(v["appoint_email"])
+			}
 			bigArr[minemail] = append(bigArr[minemail], v)
 		}
 		for k, vb := range bigArr {