From f5a3da2053ca25722cf85f9f5612c78ac69827e1 Mon Sep 17 00:00:00 2001
From: jiangyong27 <yong27@163.com>
Date: Sat, 21 Sep 2024 18:46:51 +0800
Subject: [PATCH] entrydate2

---
 conf/server.conf.dev |  4 ++--
 worker/staff.go      | 35 +++++++++++++++++++++++++++++++++++
 worker/worker.go     |  3 +++
 3 files changed, 40 insertions(+), 2 deletions(-)

diff --git a/conf/server.conf.dev b/conf/server.conf.dev
index 1e79919..f6d1483 100644
--- a/conf/server.conf.dev
+++ b/conf/server.conf.dev
@@ -4,8 +4,8 @@ address = "0.0.0.0:9283"
 log_level = 6
 
 [mysql]
-host = "14.22.116.197"
-port = 9305
+host = "192.168.2.50"
+port = 13308
 user = "root"
 pass = "ZW5aaGVuMIIBIj"
 db   = "enterprise"
diff --git a/worker/staff.go b/worker/staff.go
index c5678f4..485929c 100644
--- a/worker/staff.go
+++ b/worker/staff.go
@@ -18,6 +18,41 @@ import (
 type Staff struct {
 }
 
+func (s *Staff) MontorWorkAge() {
+	staffs, err := dao.NewStaffInfoDao().Query(model.StaffInfoStatusNormal)
+	if err != nil {
+		log.Errorf("db error :%s", err.Error())
+		return
+	}
+
+	nowDate := time.Now()
+	for _, staff := range staffs {
+		//离职的忽略
+		if staff.LeaveDate != "" {
+			continue
+		}
+
+		entryDate, _ := time.ParseInLocation("2006-01-02", staff.EntryDate, time.Local)
+		spanMonth := (nowDate.Year()-entryDate.Year())*12 + int(nowDate.Month()) - int(entryDate.Month())
+
+		log.Infof("staff[%s] entryDate[%s] spanMonth[%.1f]", staff.Username, staff.EntryDate, float64(spanMonth)/12.0)
+		if nowDate.Day() != entryDate.Day() || spanMonth%6 != 0 {
+			continue
+		}
+		message := make([]string, 0)
+		message = append(message, fmt.Sprintf("【员工半年提醒】[%s]", staff.Realname))
+		message = append(message, fmt.Sprintf("入职时间：%s", staff.EntryDate))
+		message = append(message, fmt.Sprintf("入职年限：%.1f", float64(spanMonth)/12))
+		message = append(message, fmt.Sprintf("基本工资：%s", staff.Salary))
+		message = append(message, fmt.Sprintf("身份证号：%s", staff.Idno))
+
+		if err := global.SendMessage([]string{"jiangyong"}, strings.Join(message, "\n")); err != nil {
+			log.Errorf("send message error :%s", err.Error())
+		}
+
+	}
+}
+
 func (s *Staff) SendStaffSalaryBill(month string) {
 	staffSalarys, err := dao.NewStaffSalaryDao().Query(month)
 	if err != nil {
diff --git a/worker/worker.go b/worker/worker.go
index 3956fa6..cf9f5a2 100644
--- a/worker/worker.go
+++ b/worker/worker.go
@@ -17,6 +17,9 @@ func Init() error {
 	cron.Every(1).Day().At("01:00").Do(func() {
 		go staff.SyncStaffInfo()
 	})
+	cron.Every(1).Day().At("09:00").Do(func() {
+		go staff.MontorWorkAge()
+	})
 
 	//同步每日考勤数据
 	cron.Every(1).Day().At("05:00").Do(func() {