|
|
@@ -14,11 +14,11 @@ var (
|
|
|
topMail = `SELECT a.name, a.ent_user_id, b.mail FROM dwd_d_crm_department_level_succbi a LEFT JOIN jianyu.entniche_user b ON a.ent_user_id = b.id LEFT JOIN 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 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 dwd_d_crm_department_level_succbi a LEFT JOIN jianyu.entniche_user b ON a.ent_user_id = b.id LEFT JOIN 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`
|
|
|
+ WHERE a.dept_name = '销售三部' AND a.resign = 0 AND c.role_id = 8`
|
|
|
dmInfo = `SELECT b.dept_name FROM dwd_d_crm_department_level_succbi b WHERE b.position_id IN (SELECT a.position_id FROM dwd_f_crm_personnel_management a
|
|
|
WHERE assign_type = 1) GROUP BY b.dept_name`
|
|
|
dmInfoCount = `SELECT b.position_id, COUNT(IF(a.trailstatus <> '08', 1, NULL)) as num FROM dwd_f_crm_clue_info a RIGHT JOIN dwd_d_crm_department_level_succbi b ON a.position_id = b.position_id LEFT JOIN dwd_f_crm_personnel_management c ON b.position_id = c.position_id WHERE b.dept_name = ? AND c.resign = 0 AND c.assign_type = 1 GROUP BY a.position_id HAVING num < ?`
|
|
|
- dmInfoMail = `SELECT a.name, a.position_id, (b.send_mail >> 2) & 1 AS flag_1, (b.send_mail >> 3) & 1 AS flag_2, c.mail FROM dwd_d_crm_department_level_succbi a INNER JOIN 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 a.dept_name = ? AND a.resign = 0 AND b.role_id = 3`
|
|
|
+ dmInfoMail = `SELECT a.name, a.position_id, (b.send_mail >> 2) & 1 AS flag_1, (b.send_mail >> 3) & 1 AS flag_2, c.mail FROM dwd_d_crm_department_level_succbi a INNER JOIN 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 a.dept_name = ? AND a.resign = 0 AND b.role_id = ?`
|
|
|
xgFlag = `SELECT a.name, (b.send_mail >> 4) & 1 AS flag FROM dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b ON a.position_id = b.position_id WHERE b.role_id = 5 AND b.resign = 0`
|
|
|
xgMail = `SELECT a.name, c.mail FROM dwd_d_crm_department_level_succbi a INNER JOIN 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`
|
|
|
// 所有参与线索分配人员的邮箱
|
|
|
@@ -83,7 +83,12 @@ func WarningDm() {
|
|
|
// send2 = false
|
|
|
// }
|
|
|
//}
|
|
|
- info2 := TiDb.SelectBySql(dmInfoMail, d1)
|
|
|
+ var info2 *[]map[string]interface{}
|
|
|
+ if d1 == "销售三部" {
|
|
|
+ info2 = TiDb.SelectBySql(dmInfoMail, d1, 8)
|
|
|
+ } else {
|
|
|
+ info2 = TiDb.SelectBySql(dmInfoMail, d1, 3)
|
|
|
+ }
|
|
|
if info2 == nil || len(*info2) == 0 {
|
|
|
log.Println("未查询到部门领导邮箱", d1)
|
|
|
continue
|
