69 lines
2.1 KiB
Go
69 lines
2.1 KiB
Go
package cron
|
||
|
||
type Tenant struct{}
|
||
|
||
type TenantHandle func() (string, func())
|
||
|
||
// ContractDeadline 合同处理
|
||
func (this *Tenant) ContractDeadline() TenantHandle {
|
||
return func() (string, func()) {
|
||
return "0 0 0 * * ?", func() {
|
||
//now := time.Now()
|
||
//
|
||
//mSysTenant := model.NewSysTenant()
|
||
//
|
||
//out := make([]*model.SysTenant, 0)
|
||
//
|
||
//err := model.Find(mSysTenant, &out, &model.ModelWhereOrder{Where: model.NewWhereIn("status", []model.SysTenantStatus{
|
||
// model.SysTenantStatusForNormal, model.SysTenantStatusForWellExpire,
|
||
//})}, &model.ModelWhereOrder{Where: model.NewWhereCondition("deadline", ">=", now.AddDate(0, 0, -7))})
|
||
//
|
||
//if err != nil {
|
||
// logger.ErrorF("Cron Tenant ContractDeadline Error：%v", err)
|
||
// return
|
||
//}
|
||
//well := make([]uint64, 0)
|
||
//expired := make([]uint64, 0)
|
||
//expiredKey := make([]string, 0)
|
||
//
|
||
//for _, v := range out {
|
||
// // 超过协议时间
|
||
// if v.Deadline.After(now) {
|
||
// expired = append(expired, v.ID)
|
||
// expiredKey = append(expiredKey, v.Key)
|
||
// continue
|
||
// }
|
||
// if v.Status == model.SysTenantStatusForNormal {
|
||
// well = append(well, v.ID)
|
||
// }
|
||
//}
|
||
//if err = orm.GetDB().Transaction(func(tx *gorm.DB) error {
|
||
// if len(well) > 0 {
|
||
// if err = model.UpdatesWhere(mSysTenant, map[string]interface{}{
|
||
// "status": model.SysTenantStatusForWellExpire, "updated_at": now,
|
||
// }, []*model.ModelWhere{model.NewWhereIn("id", well)}, tx); err != nil {
|
||
// return err
|
||
// }
|
||
// }
|
||
// if len(expired) > 0 {
|
||
// if err = model.UpdatesWhere(mSysTenant, map[string]interface{}{
|
||
// "status": model.SysTenantStatusForExpired, "updated_at": now,
|
||
// }, []*model.ModelWhere{model.NewWhereIn("id", expired)}, tx); err != nil {
|
||
// return err
|
||
// }
|
||
// service.Publish(config.EventForRedisListDestroy, config.RedisKeyForTenant, expiredKey)
|
||
// }
|
||
// return nil
|
||
//}); err != nil {
|
||
// logger.ErrorF("Cron Tenant ContractDeadline Transaction Error：%v", err)
|
||
// return
|
||
//}
|
||
return
|
||
}
|
||
}
|
||
}
|
||
|
||
func NewTenant() *Tenant {
|
||
return &Tenant{}
|
||
}
|