From b2cb2cf3d7df0b308853c4be928e8f41d18138f1 Mon Sep 17 00:00:00 2001
From: jiangyong27 <yong27@163.com>
Date: Sun, 7 Apr 2024 17:08:39 +0800
Subject: [PATCH] notify

---
 common/model/user_config.go |  1 +
 worker/staff.go             | 10 ++++++++++
 2 files changed, 11 insertions(+)

diff --git a/common/model/user_config.go b/common/model/user_config.go
index eb65d93..9d720fb 100644
--- a/common/model/user_config.go
+++ b/common/model/user_config.go
@@ -10,6 +10,7 @@ var (
 	StaffSalaryExpDiscount     = "staff.salary.exp.discount"     //试用期薪资折扣
 	StaffSalarySocialInsurence = "staff.salary.social.insurence" //社保扣除金额
 	StaffSalaryPerDay          = "staff.salary.per.day"          //按天计算的工资
+	StaffSalaryNotify          = "staff.salary.notify"           //是否发送工资单
 )
 var (
 	UserConfigStatusNormal  = 1
diff --git a/worker/staff.go b/worker/staff.go
index 59abdf5..c458b15 100644
--- a/worker/staff.go
+++ b/worker/staff.go
@@ -28,6 +28,11 @@ func (s *Staff) SendStaffSalaryBill(month string) {
 		if staffSalary.BaseSalary < 0.1 {
 			continue
 		}
+		userConfig, err := dao.NewUserConfigDao().GetByUsername(staffSalary.Username)
+		if err != nil {
+			log.Errorf("db error :%s", err.Error())
+			continue
+		}
 		message := make([]string, 0)
 		message = append(message, fmt.Sprintf("【工资单】[%s][%s]", staffSalary.Username, month))
 		message = append(message, fmt.Sprintf("基本工资：%.2f", staffSalary.BaseSalary))
@@ -42,6 +47,11 @@ func (s *Staff) SendStaffSalaryBill(month string) {
 		if err := global.SendMessage([]string{"jiangyong"}, strings.Join(message, "\n")); err != nil {
 			log.Errorf("send message error :%s", err.Error())
 		}
+		if userConfig != nil && cast.ToBool(userConfig.Get(model.StaffSalaryNotify)) == true {
+			if err := global.SendMessage([]string{"liangbin"}, strings.Join(message, "\n")); err != nil {
+				log.Errorf("send message error :%s", err.Error())
+			}
+		}
 	}
 }