sendMail.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439
  1. package main
  2. import (
  3. "app.yhyue.com/moapp/jybase/common"
  4. "app.yhyue.com/moapp/jybase/mail"
  5. "fmt"
  6. "github.com/gogf/gf/v2/util/gconv"
  7. "log"
  8. "strings"
  9. )
  10. var (
  11. selfMail = `SELECT a.position_id, a.name, c.mail FROM dwd_d_crm_department_level_succbi a LEFT JOIN jianyu.entniche_user c ON a.ent_user_id = c.id WHERE a.position_id = ?`
  12. infoSelf = `SELECT a.name, a.SZ_PID1, a.SZ_PID2, a.dept_name, b.role_id FROM dwd_d_crm_department_level_succbi a INNER JOIN dwd_f_crm_personnel_management b ON b.position_id = a.position_id WHERE a.position_id = ? AND a.resign = 0`
  13. 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
  14. 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`
  15. 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
  16. WHERE a.dept_name = '销售三部' AND a.resign = 0 AND c.role_id = 3`
  17. 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
  18. WHERE assign_type = 1) GROUP BY b.dept_name`
  19. 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 < ?`
  20. 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`
  21. 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`
  22. 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`
  23. // 所有参与线索分配人员的邮箱
  24. allMail = `SELECT a.name, c.mail FROM dwd_f_crm_personnel_management a INNER JOIN dwd_d_crm_department_level_succbi b ON a.position_id = b.position_id LEFT JOIN jianyu.entniche_user c ON b.ent_user_id = c.id WHERE a.assign_type = 1 AND a.resign = 0`
  25. // 超管
  26. cgMail = `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 = 4 AND b.resign = 0`
  27. )
  28. // @Author jianghan
  29. // @Description 个人预警/上限
  30. // @Date 2024/4/11
  31. func WarningPerl() {
  32. sql := `SELECT count(*) FROM dwd_f_crm_clue_info where position_id = ? and trailstatus <> '08'`
  33. sql1 := `UPDATE dwd_f_crm_personnel_management SET send_mail = (%s) where position_id = ?`
  34. pp := TiDb.SelectBySql(`SELECT name, position_id, send_mail & 1 AS flag_1, (send_mail >> 1) & 1 AS flag_2 FROM dwd_f_crm_personnel_management WHERE resign = 0`)
  35. if pp != nil && len(*pp) > 0 {
  36. for _, m := range *pp {
  37. sendFlag1 := common.IntAll(m["flag_1"]) //预警邮件发送
  38. sendFlag2 := common.IntAll(m["flag_2"]) //上限邮件发送
  39. posid := common.Int64All(m["position_id"])
  40. count := TiDb.CountBySql(sql, posid)
  41. if count >= cfg.AllocationCap && sendFlag2 == 0 {
  42. ExceedLimitByPp(posid) // 发上限邮件
  43. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail | (1 << 1)"), posid)
  44. } else if count >= cfg.WarningValue && sendFlag1 == 0 && sendFlag2 == 0 {
  45. WillWarningByPp(posid) // 发预警邮件
  46. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail | (1 << 0)"), posid)
  47. } else if sendFlag1 == 1 && count < cfg.WarningValue { // 已发邮件
  48. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail & ~(1 << 0)"), posid)
  49. } else if sendFlag2 == 1 && count < cfg.AllocationCap { // 已发邮件
  50. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail & ~(1 << 1)"), posid)
  51. }
  52. }
  53. }
  54. }
  55. // @Author jianghan
  56. // @Description 部门预警/上限 所有人
  57. // @Date 2024/5/9
  58. func WarningDm() {
  59. sql1 := `UPDATE dwd_f_crm_personnel_management SET send_mail = (%s) where position_id = ?`
  60. dm := TiDb.SelectBySql(dmInfo)
  61. send := true // 所有人
  62. for _, m := range *dm {
  63. d1 := common.ObjToString(m["dept_name"])
  64. send1, send2 := true, true // 预警,上限 发送标记
  65. info := TiDb.SelectBySql(dmInfoCount, d1, cfg.WarningValue)
  66. if info != nil && len(*info) > 0 {
  67. send = false
  68. send1 = false
  69. }
  70. info1 := TiDb.SelectBySql(dmInfoCount, d1, cfg.AllocationCap)
  71. if info1 != nil && len(*info1) > 0 {
  72. send2 = false
  73. }
  74. //for _, m1 := range *info {
  75. // count := common.IntAll(m1["num"])
  76. // if count < WarningSize {
  77. // send1 = false
  78. // }
  79. // if count < LimitSize {
  80. // send2 = false
  81. // }
  82. //}
  83. info2 := TiDb.SelectBySql(dmInfoMail, d1)
  84. if info2 == nil || len(*info2) == 0 {
  85. log.Println("未查询到部门领导邮箱", d1)
  86. continue
  87. }
  88. sendFlag1 := common.IntAll((*info2)[0]["flag_1"]) //预警邮件发送
  89. sendFlag2 := common.IntAll((*info2)[0]["flag_2"]) //上限邮件发送
  90. to := getMailAds(common.ObjToString((*info2)[0]["mail"]), common.ObjToString((*info2)[0]["name"]))
  91. posid := common.Int64All((*info2)[0]["position_id"])
  92. var toCc []string // 销管
  93. for _, m2 := range *TiDb.SelectBySql(xgMail) {
  94. if m3 := getMailAds(common.ObjToString(m2["mail"]), common.ObjToString(m2["name"])); m3 != "" {
  95. toCc = append(toCc, m3)
  96. }
  97. }
  98. if d1 != "销售三部" {
  99. toCc = append(toCc, getMailAds("shenbingyi@topnet.net.cn", "沈炳毅"))
  100. }
  101. if send2 && sendFlag2 == 0 { // 上限
  102. ExceedLimitByDm(d1, to, toCc)
  103. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail | (1 << 3)"), posid) // 倒数第四位修改成1
  104. sendFlag2 = 1
  105. } else {
  106. if !send2 && sendFlag2 == 1 {
  107. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail & ~(1 << 3)"), posid) // 倒数第四位修改成0
  108. }
  109. }
  110. if send1 && sendFlag1 == 0 && sendFlag2 == 0 { // 预警
  111. WillWarningByDm(d1, to, toCc)
  112. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail | (1 << 2)"), posid) // 倒数第三位修改成1
  113. } else {
  114. if !send1 && sendFlag1 == 1 {
  115. _, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail & ~(1 << 2)"), posid) // 倒数第三位修改成0
  116. }
  117. }
  118. }
  119. sql := `UPDATE dwd_f_crm_personnel_management SET send_mail = (%s) where position_id IN (SELECT a.position_id FROM dwd_f_crm_personnel_management a WHERE a.role_id = 5 AND a.resign = 0)`
  120. if send {
  121. info3 := TiDb.SelectBySql(xgFlag)
  122. if info3 != nil && len(*info3) > 0 {
  123. sendFlag := common.IntAll((*info3)[0]["flag"])
  124. if sendFlag == 0 {
  125. WillWarningByAll()
  126. TiDb.ExecBySql(fmt.Sprintf(sql, "send_mail | (1 << 4)"))
  127. }
  128. }
  129. } else {
  130. info3 := TiDb.SelectBySql(xgFlag)
  131. if info3 != nil && len(*info3) > 0 {
  132. sendFlag := common.IntAll((*info3)[0]["flag"])
  133. if sendFlag == 1 {
  134. TiDb.ExecBySql(fmt.Sprintf(sql, "send_mail & ~(1 << 4)")) // 修改销管 发送邮件标志 0
  135. }
  136. }
  137. }
  138. }
  139. // @Author jianghan
  140. // @Description 个人私海线索即将达到预警提醒
  141. // @Date 2024/4/10
  142. func WillWarningByPp(posid int64) {
  143. title := "您的私海线索即将达到上限通知"
  144. content := "您的私海线索已超过%d条(不包含成交客户),即将达到私海线索上限%d条(不包含成交客户),请及时将无需跟进的线索退回公海,以避免无法接收新线索。"
  145. toMail := ""
  146. toCc := ""
  147. info := TiDb.SelectBySql(selfMail, posid)
  148. if info != nil && len(*info) > 0 {
  149. toMail = getMailAds(common.ObjToString((*info)[0]["mail"]), common.ObjToString((*info)[0]["name"]))
  150. }
  151. if toMail == "" {
  152. log.Println("未查询到邮箱地址, position id: ", posid)
  153. return
  154. }
  155. toCc = getCc(posid)
  156. content = fmt.Sprintf(content, cfg.WarningValue, cfg.AllocationCap)
  157. sendInfo(toMail, toCc, title, content)
  158. }
  159. func WorkMail(personMap map[string]interface{}, productStr string, orderStatus int64, personName1, personName2, createTimeStr, acceptance_no, phone, company string) {
  160. orderType := fmt.Sprintf(`客户咨询线索(%s)`, productStr)
  161. title := fmt.Sprintf("%s通知", orderType)
  162. if personName1 == gconv.String(personMap["deptPersonName"]) {
  163. personMap["deptPersonMail"] = ""
  164. }
  165. if personName1 == gconv.String(personMap["superiorDepthPersonName"]) {
  166. personMap["superiorDepthPersonMail"] = ""
  167. }
  168. content := ""
  169. if orderStatus == 1 {
  170. content = fmt.Sprintf(`%s,您好,“%s”于%s新增了1条"%s”(工单编号:%s)%s%s,请及时前往【剑鱼PC工作台-任务单-工单管理-我负责的】进行工单处理。`, personName1, personName2, createTimeStr, orderType, acceptance_no, gconv.String(common.If(phone == "", "", fmt.Sprintf(`,客户联系方式为:%s`, phone))), gconv.String(common.If(company == "", "", fmt.Sprintf(`,公司名称:%s`, company))))
  171. } else if orderStatus == 2 {
  172. content = fmt.Sprintf(`%s,您好,“%s”于%s新增了1条"%s”(工单编号:%s)%s%s,请及时前往【电销系统-私海线索】或【客户成功系统-我的个人客户】及时联系客户进行线索跟进。您也可前往【剑鱼PC工作台-任务单-工单管理-我负责的】查看关联工单,系统已自动办结此工单。`, personName1, personName2, createTimeStr, orderType, acceptance_no, gconv.String(common.If(phone == "", "", fmt.Sprintf(`,客户联系方式为:%s`, phone))), gconv.String(common.If(company == "", "", fmt.Sprintf(`,公司名称:%s`, company))))
  173. }
  174. toMail := gconv.String(personMap["mail"])
  175. toCc := fmt.Sprintf("%s%s", gconv.String(common.If(gconv.String(personMap["deptPersonMail"]) == "", "", gconv.String(personMap["deptPersonMail"]))), gconv.String(common.If(gconv.String(personMap["superiorDepthPersonMail"]) == "", "", gconv.String(personMap["superiorDepthPersonMail"]))))
  176. log.Println(toMail, toCc, title, content)
  177. toMail = "wanghao@topnet.net.cn"
  178. toCc = "wanghao@topnet.net.cn"
  179. sendInfo(toMail, toCc, title, content)
  180. }
  181. // @Author jianghan
  182. // @Description 部门人员私海线索即将达到预警提醒
  183. // @Date 2024/4/10
  184. func WillWarningByDm(dname, to string, toCc []string) {
  185. title := "“%s”私海线索即将达到上限通知"
  186. content := "“%s”的所有参与线索分配的电销人员,私海线索都已达到%d条(不包含成交客户),即将达到私海线索上限%d条(不包含成交客户),请及时通知电销人员将无需跟进的线索退回公海,以避免无法接收新线索。"
  187. title = fmt.Sprintf(title, dname)
  188. content = fmt.Sprintf(content, dname, cfg.WarningValue, cfg.AllocationCap)
  189. sendInfo(to, strings.Join(toCc, ","), title, content)
  190. }
  191. // @Author jianghan
  192. // @Description 所有人私海线索即将达到预警提醒
  193. // @Date 2024/4/10
  194. func WillWarningByAll() {
  195. title := "所有电销人员私海线索即将达到上限通知"
  196. content := "所有参与线上线索自动分配的电销人员,私海线索都已达到%d条,请及时提醒销售部门将无需跟进的销售线索退回公海"
  197. var to []string // 销管
  198. for _, m2 := range *TiDb.SelectBySql(xgMail) {
  199. if m3 := getMailAds(common.ObjToString(m2["mail"]), common.ObjToString(m2["name"])); m3 != "" {
  200. to = append(to, m3)
  201. }
  202. }
  203. content = fmt.Sprintf(content, cfg.WarningValue)
  204. sendInfo(strings.Join(to, ","), "", title, content)
  205. }
  206. // @Author jianghan
  207. // @Description 个人私海线索达到上限提醒
  208. // @Date 2024/4/10
  209. func ExceedLimitByPp(posid int64) {
  210. title := "您的私海线索已达上限通知"
  211. content := "您的私海线索已达到私海线索上限%d条(不包含成交客户),当前无法接收新线索,请及时将无需跟进的线索退回公海"
  212. toMail := ""
  213. toCc := ""
  214. content = fmt.Sprintf(content, cfg.AllocationCap)
  215. info := TiDb.SelectBySql(selfMail, posid)
  216. if info != nil && len(*info) > 0 {
  217. toMail = getMailAds(common.ObjToString((*info)[0]["mail"]), common.ObjToString((*info)[0]["name"]))
  218. }
  219. if toMail == "" {
  220. log.Println("未查询到邮箱地址, position id: ", posid)
  221. return
  222. }
  223. toCc = getCc(posid)
  224. sendInfo(toMail, toCc, title, content)
  225. }
  226. // @Author jianghan
  227. // @Description 部门所有人私海线索达到上限提醒
  228. // @Date 2024/4/10
  229. func ExceedLimitByDm(dname, to string, toCc []string) {
  230. title := "“%s”私海线索已达到上限通知"
  231. content := "“%s”的所有参与线索分配的电销人员,私海线索都已达到私海线索上限%d条(不包含成交客户),当前无法接收新线索,请及时通知电销人员将无需跟进的线索退回公海"
  232. title = fmt.Sprintf(title, dname)
  233. content = fmt.Sprintf(content, dname, cfg.AllocationCap)
  234. sendInfo(to, strings.Join(toCc, ","), title, content)
  235. }
  236. // @Author jianghan
  237. // @Description 自动释放私海线索通知
  238. // @Date 2024/4/10
  239. func AutoReleaseNots() {
  240. title := "自动释放私海线索通知"
  241. content := "所有参与线上线索自动分配的电销人员,私海线索都已达到%d条,为避免线上产生的新线索无法分配,系统已自动将线索状态为“商机线索(已建联,包含已拨打未接通)”、“潜在客户”、“沉睡客户”的线索退回公海,如有异议请联系销管处理;"
  242. var to []string
  243. for _, m := range *TiDb.SelectBySql(allMail) {
  244. if m1 := getMailAds(common.ObjToString(m["mail"]), common.ObjToString(m["name"])); m1 != "" {
  245. to = append(to, m1)
  246. }
  247. }
  248. var toCc []string // 销管+高级电销经理+超管
  249. for _, m2 := range *TiDb.SelectBySql(xgMail) {
  250. if m3 := getMailAds(common.ObjToString(m2["mail"]), common.ObjToString(m2["name"])); m3 != "" {
  251. toCc = append(toCc, m3)
  252. }
  253. }
  254. for _, m2 := range *TiDb.SelectBySql(cgMail) {
  255. if m3 := getMailAds(common.ObjToString(m2["mail"]), common.ObjToString(m2["name"])); m3 != "" {
  256. toCc = append(toCc, m3)
  257. }
  258. }
  259. toCc = append(toCc, getMailAds("shenbingyi@topnet.net.cn", "沈炳毅"))
  260. sendInfo(strings.Join(to, ","), strings.Join(toCc, ","), title, fmt.Sprintf(content, cfg.AllocationCap))
  261. }
  262. // @Author jianghan
  263. // @Description 线上线索无法分配通知
  264. // @Date 2024/4/10
  265. func CantBeAssignedNots() {
  266. title := "【紧急】线上线索无法分配通知"
  267. content := "所有参与线上线索自动分配的电销人员,私海线索都已达到%d条,且私海已无“潜在客户”、“沉睡客户”、“商机线索(已建联)”可释放,当前线上线索无法分配,请尽快处理!"
  268. var to []string
  269. for _, m := range *TiDb.SelectBySql(allMail) {
  270. if m1 := getMailAds(common.ObjToString(m["mail"]), common.ObjToString(m["name"])); m1 != "" {
  271. to = append(to, m1)
  272. }
  273. }
  274. var toCc []string // 销管+高级电销经理+超管
  275. for _, m2 := range *TiDb.SelectBySql(xgMail) {
  276. if m3 := getMailAds(common.ObjToString(m2["mail"]), common.ObjToString(m2["name"])); m3 != "" {
  277. toCc = append(toCc, m3)
  278. }
  279. }
  280. for _, m2 := range *TiDb.SelectBySql(cgMail) {
  281. if m3 := getMailAds(common.ObjToString(m2["mail"]), common.ObjToString(m2["name"])); m3 != "" {
  282. toCc = append(toCc, m3)
  283. }
  284. }
  285. toCc = append(toCc, getMailAds("shenbingyi@topnet.net.cn", "沈炳毅"))
  286. sendInfo(strings.Join(to, ","), strings.Join(toCc, ","), title, fmt.Sprintf(content, cfg.AllocationCap))
  287. }
  288. // @Author jianghan
  289. // @Description 客成移交线索失败提醒
  290. // @Date 2024/4/10
  291. func HandOverFail(posid int64, ent string) {
  292. title := "客成线索移交失败通知"
  293. content := "您的私海线索已超过%d条(不包含成交客户),已达到私海线索上限%d条(不包含成交客户),导致“%s”无法从客成到期自动移交至私海,请及时将无需跟进的线索退回公海,超过%d个工作日不处理,该线索将自动退回至公海"
  294. toMail := ""
  295. toCc := ""
  296. info := TiDb.SelectBySql(selfMail, posid)
  297. content = fmt.Sprintf(content, cfg.AllocationCap, cfg.AllocationCap, ent, cfg.ThawDay)
  298. if info != nil && len(*info) > 0 {
  299. toMail = getMailAds(common.ObjToString((*info)[0]["mail"]), common.ObjToString((*info)[0]["name"]))
  300. }
  301. if toMail == "" {
  302. log.Println("未查询到邮箱地址, position id: ", posid)
  303. return
  304. }
  305. toCc = getCc(posid)
  306. sendInfo(toMail, toCc, title, content)
  307. }
  308. // @Author jianghan
  309. // @Description 订单用户创建线索失败提醒
  310. // @Date 2024/4/10
  311. func OrderCreateFail(posid int64, bname string) {
  312. title := "订单用户创建线索失败通知"
  313. content := "您的私海线索已超过%d条(不包含成交客户),已达到私海线索上限%d条(不包含成交客户),导致订单系统的用户“%s”无法进入您的私海,请及时将无需跟进的线索退回公海,超过%d个工作日不处理,该线索将自动进入至公海。"
  314. toMail := ""
  315. toCc := ""
  316. content = fmt.Sprintf(content, cfg.AllocationCap, cfg.AllocationCap, bname, cfg.ThawDay)
  317. info := TiDb.SelectBySql(selfMail, posid)
  318. if info != nil && len(*info) > 0 {
  319. toMail = getMailAds(common.ObjToString((*info)[0]["mail"]), common.ObjToString((*info)[0]["name"]))
  320. }
  321. if toMail == "" {
  322. log.Println("未查询到邮箱地址, position id: ", posid)
  323. return
  324. }
  325. toCc = getCc(posid)
  326. sendInfo(toMail, toCc, title, content)
  327. }
  328. // @Author jianghan
  329. // @Description 非集团公司线索分配失败
  330. // @Date 2024/5/11
  331. func AssFail(posid int64, ent, iname string) {
  332. title := "您跟进的非集团公司线上线索分配失败"
  333. content := "您的私海线索已达到私海线索上限%d条(不包含成交客户),导致您正在跟进的非集团公司“%s”产生的新线索“%s”无法进入您的私海,请及时将无需跟进的线索退回公海,退回后联系您的电销经理将此线索再划转至您的私海。"
  334. toMail := ""
  335. toCc := ""
  336. content = fmt.Sprintf(content, cfg.AllocationCap, ent, iname)
  337. info := TiDb.SelectBySql(selfMail, posid)
  338. if info != nil && len(*info) > 0 {
  339. toMail = getMailAds(common.ObjToString((*info)[0]["mail"]), common.ObjToString((*info)[0]["name"]))
  340. }
  341. if toMail == "" {
  342. log.Println("未查询到邮箱地址, position id: ", posid)
  343. return
  344. }
  345. toCc = getCc(posid)
  346. sendInfo(toMail, toCc, title, content)
  347. }
  348. // @Author jianghan
  349. // @Description 发邮件
  350. // @Date 2024/5/8
  351. func sendInfo(to, cs, title, content string) {
  352. if to == "" {
  353. log.Println("send mail fail", title, to)
  354. return
  355. }
  356. log.Println("发送标题", title)
  357. log.Println("发送人:", to)
  358. log.Println("抄送:", cs)
  359. gmail := &mail.GmailAuth{
  360. SmtpHost: "smtp.exmail.qq.com",
  361. SmtpPort: 465,
  362. User: "public03@topnet.net.cn",
  363. Pwd: "ue9Rg9Sf4CVtdm5a",
  364. }
  365. status := mail.GSendMail_dx("剑鱼标讯", to, cs, "", title, content, "", "", gmail)
  366. if status {
  367. log.Println("send mail success", title, to)
  368. }
  369. }
  370. // @Author jianghan
  371. // @Description 获取抄送人员邮箱
  372. //
  373. // 销售三部 (SZ_PID1=5432)、销售一部(分组)
  374. //
  375. // @Date 2024/5/8
  376. func getCc(posid int64) (to string) {
  377. info := TiDb.SelectBySql(infoSelf, posid)
  378. if info == nil && len(*info) == 0 {
  379. log.Println("未查询到个人信息, positionId: ", posid)
  380. return
  381. }
  382. if common.ObjToString((*info)[0]["dept_name"]) == "销售三部" {
  383. if common.IntAll((*info)[0]["role_id"]) == 1 || common.IntAll((*info)[0]["role_id"]) == 2 {
  384. m := TiDb.SelectBySql(topMail3)
  385. if m != nil && len(*m) > 0 {
  386. to = getMailAds(common.ObjToString((*m)[0]["mail"]), common.ObjToString((*m)[0]["name"]))
  387. }
  388. }
  389. } else if common.ObjToString((*info)[0]["dept_name"]) == "销售三部" {
  390. } else {
  391. if common.IntAll((*info)[0]["role_id"]) == 1 || common.IntAll((*info)[0]["role_id"]) == 2 {
  392. m := TiDb.SelectBySql(topMail, posid)
  393. if m != nil && len(*m) > 0 {
  394. to = getMailAds(common.ObjToString((*m)[0]["mail"]), common.ObjToString((*m)[0]["name"]))
  395. }
  396. //to = getMailAds("shenbingyi@topnet.net.cn", "沈炳毅")
  397. } else if common.IntAll((*info)[0]["role_id"]) == 3 {
  398. to = getMailAds("shenbingyi@topnet.net.cn", "沈炳毅")
  399. }
  400. }
  401. return
  402. }
  403. // @Author jianghan
  404. // @Description 获取配置文件邮箱地址
  405. // @Date 2024/5/13
  406. func getMailAds(mail, name string) string {
  407. log.Println("getMailAds", name, mail)
  408. if cfg.NameToMail != nil && len(cfg.NameToMail) > 0 {
  409. return cfg.NameToMail[name]
  410. } else {
  411. return mail
  412. }
  413. }