This commit is contained in:
jiangyong27 2025-05-29 15:11:13 +08:00
parent dffe776ef5
commit 00fd66ae53
3 changed files with 4 additions and 7 deletions

View File

@ -17,7 +17,7 @@ func (d *ExternalCorpOrder) TableName() string {
return "cp_order"
}
func (d *ExternalCorpOrder) QueryOwnerOrder(owner string, corpId int64, startTime, endTime int64) ([]*model.ExternalCorpOrder, error) {
func (d *ExternalCorpOrder) QueryOwnerOrder(owner string, startTime, endTime int64) ([]*model.ExternalCorpOrder, error) {
orderTable := d.TableName()
tx := corpDB.Table(orderTable)
@ -26,9 +26,6 @@ func (d *ExternalCorpOrder) QueryOwnerOrder(owner string, corpId int64, startTim
if owner != "" {
tx.Where("cp_user.username = ?", owner)
}
if corpId != 0 {
tx.Where("cp_user.corp_id = ?", corpId)
}
if startTime > 0 {
tx.Where(orderTable+".pay_time >= ?", startTime)

View File

@ -32,11 +32,11 @@ func (s *Salary1002) Calculate(salary *model.StaffSalary) map[string]interface{}
monthTime, _ := time.ParseInLocation("200601", salary.Month, time.Local)
startTime := monthTime.Unix()
endTime := monthTime.AddDate(0, 1, 0).Unix() - 1
orders, err := dao.NewExternalCorpOrder().QueryOwnerOrder(s.user.Username, s.user.CorpId, startTime, endTime)
orders, err := dao.NewExternalCorpOrder().QueryOwnerOrder(s.user.Username, startTime, endTime)
if err != nil {
log.Errorf("db error:%s", err.Error())
}
totalOrders, err := dao.NewExternalCorpOrder().QueryOwnerOrder("", s.user.CorpId, startTime, endTime)
totalOrders, err := dao.NewExternalCorpOrder().QueryOwnerOrder("", startTime, endTime)
if err != nil {
log.Errorf("db error:%s", err.Error())
}

View File

@ -33,7 +33,7 @@ func (s *Staff1002) Monitor(user *model.StaffUser) {
}
// 1.订单
orders, err := dao.NewExternalCorpOrder().QueryOwnerOrder(user.Username, user.CorpId, 0, 0)
orders, err := dao.NewExternalCorpOrder().QueryOwnerOrder(user.Username, 0, 0)
if err != nil {
log.Errorf("db error:%s", err.Error())
return