xg

clueSync/sendMail.go

@@ -12,18 +12,18 @@ var (
 	selfMail = `SELECT a.position_id, a.name, c.mail FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a LEFT JOIN jianyu.entniche_user c ON a.ent_user_id = c.id WHERE a.position_id = ?`
 	infoSelf = `SELECT a.name, a.SZ_PID1, a.SZ_PID2, a.dept_name, b.role_id FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a INNER JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management b ON b.position_id = a.position_id WHERE a.position_id = ? AND a.resign = 0`
 	topMail  = `SELECT a.name, a.ent_user_id, b.mail FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a LEFT JOIN jianyu.entniche_user b ON a.ent_user_id = b.id LEFT JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management c ON a.position_id = c.position_id AND c.resign = 0 
-                	WHERE a.SZ_PID3 IN (SELECT a.SZ_PID3 FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a WHERE a.position_id = 2222419) AND c.role_id = 3`
+                	WHERE a.SZ_PID3 IN (SELECT a.SZ_PID3 FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a WHERE a.position_id = ?) AND c.role_id = 3`
 	topMail3 = `SELECT a.name, a.ent_user_id, b.mail FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a LEFT JOIN jianyu.entniche_user b ON a.ent_user_id = b.id LEFT JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management c ON a.position_id = c.position_id 
                     WHERE a.dept_name = '销售三部' AND a.resign = 0 AND c.role_id = 3`
 	dmInfo = `SELECT b.dept_name FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi b WHERE b.position_id IN (SELECT a.position_id FROM Jianyu_subjectdb_test.dwd_f_crm_personnel_management a
 		WHERE assign_type = 1) GROUP BY b.dept_name`
 	dmInfoCount = `SELECT COUNT(*) as num FROM Jianyu_subjectdb_test.dwd_f_crm_clue_info b WHERE b.position_id IN (SELECT a.position_id FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a WHERE dept_name = ? AND resign = 0) GROUP BY b.position_id HAVING num < ?`
 	dmInfoMail  = `SELECT a.name, a.position_id, c.mail, (b.send_mail >> 2) & 1 AS flag_1, (b.send_mail >> 3) & 1 AS flag_2 FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a INNER JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management b ON a.position_id = b.position_id INNER JOIN jianyu.entniche_user c ON a.ent_user_id = c.id WHERE a.dept_name = ? AND a.resign = 0 AND b.role_id = 3`
-	xgMail      = `SELECT a.name, c.mail FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a INNER JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management b ON a.position_id = b.position_id INNER JOIN jianyu.entniche_user c ON a.ent_user_id = c.id WHERE b.role_id = 5 AND b.resign = 0`
+	xgMail      = `SELECT a.name, c.mail FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a INNER JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management b ON a.position_id = b.position_id LEFT JOIN jianyu.entniche_user c ON a.ent_user_id = c.id WHERE b.role_id = 5 AND b.resign = 0`
 	// 所有参与线索分配人员的邮箱
 	allMail = `SELECT c.mail, c.name FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a INNER JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management b ON a.position_id = b.position_id INNER JOIN jianyu.entniche_user c ON a.ent_user_id =	c.id WHERE b.assign_type = 1 AND b.resign = 0`
 	// 超管
-	cgMail = `SELECT c.mail, c.name FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a INNER JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management b ON a.position_id = b.position_id INNER JOIN jianyu.entniche_user c ON c.id = a.ent_user_id WHERE b.role_id = 4 AND b.resign = 0`
+	cgMail = `SELECT a.name, c.mail FROM Jianyu_subjectdb_test.dwd_d_crm_department_level_succbi a INNER JOIN Jianyu_subjectdb_test.dwd_f_crm_personnel_management b ON a.position_id = b.position_id LEFT JOIN jianyu.entniche_user c ON a.ent_user_id = c.id WHERE b.role_id = 4 AND b.resign = 0`
 )
 
 // @Author jianghan
@@ -345,7 +345,7 @@ func sendInfo(to, cs, title, content string) {
 func getCc(posid int64) (to string) {
 	info := TiDb.SelectBySql(infoSelf, posid)
 	if info == nil && len(*info) == 0 {
-		log.Println("为查询到个人信息, positionId: ", posid)
+		log.Println("未查询到个人信息, positionId: ", posid)
 		return
 	}
 	if common.ObjToString((*info)[0]["dept_name"]) == "销售三部" {