浏览代码

feat:增加到期企业修改状态定时任务

zhangxinlei1996 3 年之前
父节点
当前提交
4b5ea5a72c
共有 3 个文件被更改,包括 13 次插入5 次删除
  1. 3 1
      rpc/etc/usercenter.yaml
  2. 7 3
      rpc/internal/config/config.go
  3. 3 1
      rpc/usercenter.go

+ 3 - 1
rpc/etc/usercenter.yaml

@@ -27,4 +27,6 @@ Logx:
   Mode: console #console|file|volume
   Mode: console #console|file|volume
   Path: logs
   Path: logs
   Level: info #info|error|severe
   Level: info #info|error|severe
-  KeepDays: 100
+  KeepDays: 100
+IsRun: true
+CheckEntIsExpire: 00:00

+ 7 - 3
rpc/internal/config/config.go

@@ -5,16 +5,20 @@ import (
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/entity"
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/entity"
 	"github.com/zeromicro/go-zero/core/conf"
 	"github.com/zeromicro/go-zero/core/conf"
 	"github.com/zeromicro/go-zero/core/discov"
 	"github.com/zeromicro/go-zero/core/discov"
+	"github.com/zeromicro/go-zero/core/logx"
 	"github.com/zeromicro/go-zero/zrpc"
 	"github.com/zeromicro/go-zero/zrpc"
 )
 )
 
 
 type Config struct {
 type Config struct {
 	zrpc.RpcServerConf
 	zrpc.RpcServerConf
-	Node             int    // 节点
-	CalleeId         string // 服务名字
 	FileSystemConf   zrpc.RpcClientConf
 	FileSystemConf   zrpc.RpcClientConf
-	Mysql            Mysql
+	CalleeId         string             // 服务名字
 	ResourceEtcdConf zrpc.RpcClientConf //资源中台
 	ResourceEtcdConf zrpc.RpcClientConf //资源中台
+	Node             int                // 节点
+	Mysql            Mysql
+	Logx             logx.LogConf
+	IsRun            bool   //定时任务是否开启
+	CheckEntIsExpire string //定时任务时间
 }
 }
 
 
 var (
 var (

+ 3 - 1
rpc/usercenter.go

@@ -10,6 +10,8 @@ import (
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/internal/svc"
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/internal/svc"
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/pb"
 	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/pb"
 
 
+	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/timetask"
+
 	"github.com/zeromicro/go-zero/core/service"
 	"github.com/zeromicro/go-zero/core/service"
 	"github.com/zeromicro/go-zero/zrpc"
 	"github.com/zeromicro/go-zero/zrpc"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc"
@@ -31,7 +33,7 @@ func main() {
 		}
 		}
 	})
 	})
 	defer s.Stop()
 	defer s.Stop()
-
+	go timetask.Run()
 	fmt.Printf("Starting rpc server at %s...\n", config.ConfigJson.ListenOn)
 	fmt.Printf("Starting rpc server at %s...\n", config.ConfigJson.ListenOn)
 	s.Start()
 	s.Start()
 }
 }