大客新增分配群组

clueSync/everything.go

@@ -526,7 +526,7 @@ func bigCustomer() {
 		for _, v := range dataArr {
 			minemail := ""
 			if gconv.String(v["appoint_email"]) == "" {
-				minemail, _ = EmailSelect("dk")
+				minemail, _ = EmailSelect("dk", "")
 			} else {
 				minemail = gconv.String(v["appoint_email"])
 			}
@@ -699,8 +699,8 @@ func AdvisoryCommittee() {
 }
 
 // 运营部线索
-func SelectionDepartment() {
-	/*if !isRunning() {
+/*func SelectionDepartment() {
+	if !isRunning() {
 		log.Println("不是工作日，任务暂停")
 		return
 	}
@@ -713,15 +713,15 @@ func SelectionDepartment() {
 	cfg.SelectionDepartmentTime = endtime
 	exportToExcel(dataArr, "运营部销售线索", "yy")
 	log.Println("运营部线索定时任务结束")
-	common.WriteSysConfig(&cfg)*/
+	common.WriteSysConfig(&cfg)
 }
-
+*/
 // 特殊留资
 func SpecialSaleLeads() {
-	if !isRunning() {
+	/*if !isRunning() {
 		log.Println("不是工作日，任务暂停")
 		return
-	}
+	}*/
 	saleLeadsConfig := TiDb.Find("saleLeads_config", map[string]interface{}{
 		"status": 0,
 	}, "", "", -1, -1)
@@ -729,7 +729,7 @@ func SpecialSaleLeads() {
 	for _, v := range *saleLeadsConfig {
 		log.Println(fmt.Sprintf("%s留资线索定时任务开始", gconv.String(v["groupName"])))
 		//留来源获取
-		sourceMap := buildSourceMap("运营部")
+		sourceMap := buildSourceMap(gconv.String(v["groupName"]))
 		dataArr, endtime := processLeads(v, sourceMap)
 		//最后一次数据修改
 		TiDb.Update("saleLeads_config", map[string]interface{}{
@@ -983,7 +983,7 @@ func EmailSelect(batch, mailStr string) (string, string) {
 					mailMap[personName] = arr[1]
 				}
 			}
-			for personName, mailStr := range mailArr {
+			for personName, mailStr := range mailMap {
 				isOk := false
 				for _, m := range *bigData {
 					tablePersonName := gconv.String(m["name"])