代码修改

clueSync/jobutil.go

@@ -82,9 +82,10 @@ func WorkDataHandle(company, phone, demand, name, product string, acceptanceData
 			//线索变更
 			ok, data, saleData = FindPosition(positionId, "", false)
 			if !ok {
+				log.Println(positionId, "用户查询失败")
 				return false
 			}
-			UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "", "", company, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
+			UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", company, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
 		} else {
 			trailstatus := gconv.String((*uCount)["trailstatus"])
 			IS_TRANSFER := gconv.Int64((*uCount)["IS_TRANSFER"])
@@ -96,7 +97,7 @@ func WorkDataHandle(company, phone, demand, name, product string, acceptanceData
 					"clue_id": clueId,
 				}, "position_id", "")
 				if customerMap != nil && len(*customerMap) > 0 {
-					UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "", "", company, name, gconv.String((*uCount)["name"]), phone, "", "", "", "", "", "", gconv.String((*uCount)["seat_number"]), "", gconv.Int64((*uCount)["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
+					UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", company, name, gconv.String((*uCount)["name"]), phone, "", "", "", "", "", "", gconv.String((*uCount)["seat_number"]), "", gconv.Int64((*uCount)["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
 					data = map[string]interface{}{
 						"type":        "kc",
 						"position_id": (*customerMap)["position_id"],
@@ -120,16 +121,18 @@ func WorkDataHandle(company, phone, demand, name, product string, acceptanceData
 				//变更销售员
 				ok, data, saleData = FindPosition(positionId, "", false)
 				if !ok {
+					log.Println(positionId, "用户查询失败")
 					return false
 				}
-				UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "", "", company, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
+				UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", company, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
 			} else {
 				//线索变更
 				ok, data, saleData = FindPosition(positionId, trailstatus, false)
 				if !ok {
+					log.Println(positionId, "用户查询失败")
 					return false
 				}
-				UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "", "", company, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
+				UpdateClue(*uCount, saleData, "", "", uId, "5", "169", "新增线索", "主动咨询客服留资客户", company, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), "", gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, true, demand)
 			}
 		}
 	} else {
@@ -141,12 +144,13 @@ func WorkDataHandle(company, phone, demand, name, product string, acceptanceData
 		SaveClue("", "", uId, "5", "169", "", "", cluename, name, gconv.String(data["name"]), phone, "", "", "", "", "", "", gconv.String(data["seat_number"]), gconv.Int64(data["position_id"]), "", "", "", []string{}, "", isGroup, isCommerce, false, demand)
 	}
 	//工单生成
-	AddOrderWork(acceptanceData, data, product, phone, company)
+	ok1 := AddOrderWork(acceptanceData, data, product, phone, company)
+	log.Println("工单创建", ok1, gconv.String(acceptanceData["acceptance_no"]))
 	return true
 }
 func AddOrderWork(acceptanceData map[string]interface{}, userData map[string]interface{}, product, phone, company string) bool {
 	nowTime := time.Now().Format(date.Date_Full_Layout)
-	work_order_no := fmt.Sprintf("GD%s%s", time.Now().Format(date.Date_Short_Layout), FindNumber("gd"))
+	work_order_no := fmt.Sprintf("GD%s%s", time.Now().Format(date.Date_yyyyMMdd), FindNumber("gd"))
 	productArr := []string{}
 	for _, v := range strings.Split(product, ",") {
 		switch ProductMap[v] {
@@ -183,7 +187,6 @@ func AddOrderWork(acceptanceData map[string]interface{}, userData map[string]int
 	}
 	ok3 := WorkOrder.Insert("order_work", orderWorkMap)
 	if ok3 > 0 {
-
 		WorkOrder.Update("order_acceptance", map[string]interface{}{
 			"id": acceptanceData["id"],
 		}, map[string]interface{}{
@@ -261,7 +264,7 @@ FROM
 			entniche_department_user a
 			INNER JOIN entniche_user_role b ON a.dept_id = ? 
 			AND a.user_id = b.user_id 
-			AND b.role_id =2
+			AND b.role_id !=""
 			INNER JOIN entniche_user c ON a.user_id = c.id`, deptId)
 	if depthMap != nil && len(*depthMap) > 0 {
 		person["deptPersonName"] = gconv.String((*depthMap)[0]["name"])
@@ -275,7 +278,7 @@ FROM
 	INNER JOIN entniche_department_user a ON d.id = ? 
 	AND d.pid = a.dept_id
 	INNER JOIN entniche_user_role b ON a.user_id = b.user_id 
-	AND b.role_id = 1
+	AND b.role_id !=""
 	INNER JOIN entniche_user c ON a.user_id = c.id`, deptId)
 	if superiorDepthMap != nil && len(*superiorDepthMap) > 0 {
 		person["superiorDepthPersonName"] = gconv.String((*superiorDepthMap)[0]["name"])
@@ -318,8 +321,7 @@ FROM
 	dwd_d_crm_department_level_succbi a
 	INNER JOIN dwd_f_crm_personnel_management b ON a.resign = 0
 	AND a.ent_id = 25917
-	AND a.resign = 0
-	AND a.dept_name LIKE "%销售一部/电销部%"
+	AND a.dept_name LIKE "%电销部%"
 	AND a.position_id = b.position_id`)
 	userData3 := TiDb.SelectBySql(`SELECT
 	a.position_id,

clueSync/sendMail.go

@@ -169,6 +169,7 @@ func WillWarningByPp(posid int64) {
 }
 
 func WorkMail(personMap map[string]interface{}, productStr string, orderStatus int64, personName1, personName2, createTimeStr, acceptance_no, phone, company string) {
+	log.Println("邮箱发送", personMap, productStr, orderStatus, personName1, personName2, createTimeStr, acceptance_no, phone, company)
 	orderType := fmt.Sprintf(`客户咨询线索(%s)`, productStr)
 	title := fmt.Sprintf("%s通知", orderType)
 	if personName1 == gconv.String(personMap["deptPersonName"]) {