From 4048e2d5db07d4a11c0deb49de19306caabf53fa Mon Sep 17 00:00:00 2001
From: jiangyong27 <yong27@163.com>
Date: Thu, 27 Mar 2025 21:15:37 +0800
Subject: [PATCH] plog3

---
 common/dao/staff_pay_log.go   | 46 +++++++++++++++++++++++++++++++++++
 common/model/staff_pay_log.go | 10 ++++++++
 2 files changed, 56 insertions(+)
 create mode 100644 common/dao/staff_pay_log.go
 create mode 100644 common/model/staff_pay_log.go

diff --git a/common/dao/staff_pay_log.go b/common/dao/staff_pay_log.go
new file mode 100644
index 0000000..f6af0e8
--- /dev/null
+++ b/common/dao/staff_pay_log.go
@@ -0,0 +1,46 @@
+package dao
+
+import (
+	"enterprise/common/model"
+	"github.com/spf13/cast"
+	"time"
+)
+
+type StaffPayLogDao struct {
+}
+
+func NewStaffPayLogDao() *StaffPayLogDao {
+	return &StaffPayLogDao{}
+}
+
+func (d *StaffPayLogDao) TableName() string {
+	return "staff_pay_log"
+}
+
+func (d *StaffPayLogDao) Create(o *model.StaffPayLog) (int64, error) {
+	o.CreateTime = time.Now().Unix()
+	res := GetDB().Table(d.TableName()).Create(o)
+	return o.Id, res.Error
+}
+
+func (d *StaffPayLogDao) QueryAdmin(page, size int, corpId int64, staffId string) ([]*model.StaffPayLog, int64, error) {
+	var u []*model.StaffPayLog
+	tx := GetDB().Table(d.TableName())
+	tx.Where("corp_id = ?", corpId)
+
+	if staffId != "" {
+		tx.Where("user_id = ?", cast.ToInt64(staffId))
+	}
+
+	var count int64
+	tx.Count(&count)
+	tx.Order("month DESC")
+
+	tx.Offset((page - 1) * size).Limit(size)
+	res := tx.Find(&u)
+
+	if res.Error != nil {
+		return nil, 0, res.Error
+	}
+	return u, count, nil
+}
diff --git a/common/model/staff_pay_log.go b/common/model/staff_pay_log.go
new file mode 100644
index 0000000..c88766c
--- /dev/null
+++ b/common/model/staff_pay_log.go
@@ -0,0 +1,10 @@
+package model
+
+type StaffPayLog struct {
+	Id         int64
+	StaffId    int64
+	PayType    string
+	Amount     int64
+	Title      string
+	CreateTime int64
+}