From 255be172e7bf58083c7cc205ad91eea37d8e729e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= Date: Sat, 11 Jun 2022 13:24:18 +0800 Subject: [PATCH] - update model --- go.mod | 4 ++++ go.sum | 9 ++++++++- jobs_beego_orm.go | 15 ++++++++++++++ jobs_beego_orm_model/task.go | 28 ++++++++++++++++++++++++++ jobs_beego_orm_model/task_ip.go | 12 +++++++++++ jobs_beego_orm_model/task_log.go | 15 ++++++++++++++ jobs_beego_orm_model/task_log_run.go | 20 +++++++++++++++++++ jobs_common.go | 9 +++++++++ jobs_gorm_model/task.go | 30 ++++++++++++++++++++++++++++ jobs_gorm_model/task_ip.go | 12 +++++++++++ jobs_gorm_model/task_log.go | 15 ++++++++++++++ jobs_gorm_model/task_log_run.go | 20 +++++++++++++++++++ jobs_xorm_model/task.go | 28 ++++++++++++++++++++++++++ jobs_xorm_model/task_ip.go | 12 +++++++++++ jobs_xorm_model/task_log.go | 15 ++++++++++++++ jobs_xorm_model/task_log_run.go | 20 +++++++++++++++++++ jobs_zorm_model/task.go | 28 ++++++++++++++++++++++++++ jobs_zorm_model/task_ip.go | 12 +++++++++++ jobs_zorm_model/task_log.go | 15 ++++++++++++++ jobs_zorm_model/task_log_run.go | 20 +++++++++++++++++++ 20 files changed, 338 insertions(+), 1 deletion(-) create mode 100644 jobs_beego_orm.go create mode 100644 jobs_beego_orm_model/task.go create mode 100644 jobs_beego_orm_model/task_ip.go create mode 100644 jobs_beego_orm_model/task_log.go create mode 100644 jobs_beego_orm_model/task_log_run.go create mode 100644 jobs_common.go create mode 100644 jobs_gorm_model/task.go create mode 100644 jobs_gorm_model/task_ip.go create mode 100644 jobs_gorm_model/task_log.go create mode 100644 jobs_gorm_model/task_log_run.go create mode 100644 jobs_xorm_model/task.go create mode 100644 jobs_xorm_model/task_ip.go create mode 100644 jobs_xorm_model/task_log.go create mode 100644 jobs_xorm_model/task_log_run.go create mode 100644 jobs_zorm_model/task.go create mode 100644 jobs_zorm_model/task_ip.go create mode 100644 jobs_zorm_model/task_log.go create mode 100644 jobs_zorm_model/task_log_run.go diff --git a/go.mod b/go.mod index 6d0b7b0..961a614 100644 --- a/go.mod +++ b/go.mod @@ -4,6 +4,7 @@ go 1.18 require ( gitee.com/chunanyong/zorm v1.5.5 + github.com/beego/beego/v2 v2.0.3 github.com/robfig/cron/v3 v3.0.1 go.dtapp.net/goip v1.0.17 go.dtapp.net/gouuid v1.0.0 @@ -22,13 +23,16 @@ require ( github.com/gogo/protobuf v1.3.2 // indirect github.com/golang/protobuf v1.5.2 // indirect github.com/golang/snappy v0.0.4 // indirect + github.com/hashicorp/golang-lru v0.5.4 // indirect github.com/jinzhu/inflection v1.0.0 // indirect github.com/jinzhu/now v1.1.5 // indirect github.com/json-iterator/go v1.1.12 // indirect github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect github.com/modern-go/reflect2 v1.0.2 // indirect + github.com/pkg/errors v0.9.1 // indirect github.com/saracen/go7z v0.0.0-20191010121135-9c09b6bd7fda // indirect github.com/saracen/solidblock v0.0.0-20190426153529-45df20abab6f // indirect + github.com/shiena/ansicolor v0.0.0-20200904210342-c7312218db18 // indirect github.com/syndtr/goleveldb v1.0.0 // indirect github.com/ulikunitz/xz v0.5.10 // indirect go.dtapp.net/gorequest v1.0.19 // indirect diff --git a/go.sum b/go.sum index d42378e..eaf3f49 100644 --- a/go.sum +++ b/go.sum @@ -27,6 +27,8 @@ github.com/aryann/difflib v0.0.0-20170710044230-e206f873d14a/go.mod h1:DAHtR1m6l github.com/aws/aws-lambda-go v1.13.3/go.mod h1:4UKl9IzQMoD+QF79YdCuzCwp8VbmG4VAQwij/eHl5CU= github.com/aws/aws-sdk-go v1.27.0/go.mod h1:KmX6BPdI08NWTb3/sm4ZGu5ShLoqVDhKgpiN924inxo= github.com/aws/aws-sdk-go-v2 v0.18.0/go.mod h1:JWVYvqSMppoMJC0x5wdwiImzgXTI9FuZwxzkQq9wy+g= +github.com/beego/beego/v2 v2.0.3 h1:vLrjDsn3JcxvIUqduDs4i0BdWuu5v7YN2FRKQcTWIDI= +github.com/beego/beego/v2 v2.0.3/go.mod h1:svcOCy6uDaGYHwcO3nppzKwFigeXm8WHkZfgnvemYNM= github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8= github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA= github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q= @@ -173,6 +175,8 @@ github.com/hashicorp/go-version v1.2.0/go.mod h1:fltr4n8CU8Ke44wwGCBoEymUuxUHl09 github.com/hashicorp/go.net v0.0.1/go.mod h1:hjKkEWcCURg++eb33jQU7oqQcI9XDCnUzHA0oac0k90= github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8= github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8= +github.com/hashicorp/golang-lru v0.5.4 h1:YDjusn29QI/Das2iO9M0BHnIbxPeyuCHsjMW+lJfyTc= +github.com/hashicorp/golang-lru v0.5.4/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4= github.com/hashicorp/logutils v1.0.0/go.mod h1:QIAnNjmIWmVIIkWDTG1z5v++HQmx9WQRO+LraFDTW64= github.com/hashicorp/mdns v1.0.0/go.mod h1:tL+uN++7HEJ6SQLQ2/p+z2pH24WQKWjBPkE0mNTz8vQ= github.com/hashicorp/memberlist v0.1.3/go.mod h1:ajVTdAv/9Im8oMAAj5G31PhhMCZJV2pPBoIllUwCN7I= @@ -265,6 +269,7 @@ github.com/lib/pq v1.1.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo= github.com/lib/pq v1.2.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo= github.com/lib/pq v1.3.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo= github.com/lib/pq v1.10.2/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o= +github.com/lib/pq v1.10.5 h1:J+gdV2cUmX7ZqL2B0lFcW0m+egaHC2V3lpO8nWxyYiQ= github.com/lightstep/lightstep-tracer-common/golang/gogo v0.0.0-20190605223551-bc2310a04743/go.mod h1:qklhhLq1aX+mtWk9cPHPzaBjWImj5ULL6C7HFJtXQMM= github.com/lightstep/lightstep-tracer-go v0.18.1/go.mod h1:jlF1pusYV4pidLvZ+XD0UBX0ZE6WURAspgAczcDHrL4= github.com/lyft/protoc-gen-validate v0.0.13/go.mod h1:XbGvPuh87YZc5TdIa2/I4pLk0QoUACkjt2znoq26NVQ= @@ -383,6 +388,8 @@ github.com/saracen/solidblock v0.0.0-20190426153529-45df20abab6f h1:1cJITU3JUI8q github.com/saracen/solidblock v0.0.0-20190426153529-45df20abab6f/go.mod h1:LyBTue+RWeyIfN3ZJ4wVxvDuvlGJtDgCLgCb6HCPgps= github.com/satori/go.uuid v1.2.0/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0= github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529/go.mod h1:DxrIzT+xaE7yg65j358z/aeFdxmN0P9QXhEzd20vsDc= +github.com/shiena/ansicolor v0.0.0-20200904210342-c7312218db18 h1:DAYUYH5869yV94zvCES9F51oYtN5oGlwjxJJz7ZCnik= +github.com/shiena/ansicolor v0.0.0-20200904210342-c7312218db18/go.mod h1:nkxAfR/5quYxwPZhyDxgasBMnRtBZd0FCEpawpjMUFg= github.com/shopspring/decimal v0.0.0-20180709203117-cd690d0c9e24/go.mod h1:M+9NzErvs504Cn4c5DxATwIqPbtswREoFCre64PpcG4= github.com/shopspring/decimal v0.0.0-20200227202807-02e2044944cc/go.mod h1:DKyhrW/HYNuLGql+MJL6WCR6knT2jwCFRcu2hWCYk4o= github.com/shopspring/decimal v1.2.0/go.mod h1:DKyhrW/HYNuLGql+MJL6WCR6knT2jwCFRcu2hWCYk4o= @@ -407,8 +414,8 @@ github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXf github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4= github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= -github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY= github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.7.1 h1:5TQK59W5E3v0r2duFAb7P95B6hEeOyEnHRa8MjYSMTY= github.com/syndtr/goleveldb v1.0.0 h1:fBdIW9lB4Iz0n9khmH8w27SJ3QEJ7+IgjPEwGSZiFdE= github.com/syndtr/goleveldb v1.0.0/go.mod h1:ZVVdQEZoIme9iO1Ch2Jdy24qqXrMMOU6lpPAyBWyWuQ= github.com/tmc/grpc-websocket-proxy v0.0.0-20170815181823-89b8d40f7ca8/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U= diff --git a/jobs_beego_orm.go b/jobs_beego_orm.go new file mode 100644 index 0000000..d2beebb --- /dev/null +++ b/jobs_beego_orm.go @@ -0,0 +1,15 @@ +package gojobs + +import "github.com/beego/beego/v2/client/orm" + +type JobsBeegoOrm struct { + Db *orm.Ormer +} + +func NewJobsBeegoOrm(db *orm.Ormer) *JobsBeegoOrm { + var ( + jobsBeegoOrm = &JobsBeegoOrm{} + ) + jobsBeegoOrm.Db = db + return jobsBeegoOrm +} diff --git a/jobs_beego_orm_model/task.go b/jobs_beego_orm_model/task.go new file mode 100644 index 0000000..ce52715 --- /dev/null +++ b/jobs_beego_orm_model/task.go @@ -0,0 +1,28 @@ +package jobs_beego_orm_model + +// Task 任务 +type Task struct { + Id uint `orm:"auto" json:"id"` // 记录编号 + Status string `json:"status"` // 状态码 + Params string `json:"params"` // 参数 + ParamsType string `json:"params_type"` // 参数类型 + StatusDesc string `json:"status_desc"` // 状态描述 + Frequency int64 `json:"frequency"` // 频率（秒单位） + Number int64 `json:"number"` // 当前次数 + MaxNumber int64 `json:"max_number"` // 最大次数 + RunId string `json:"run_id"` // 执行编号 + CustomId string `json:"custom_id"` // 自定义编号 + CustomSequence int64 `json:"custom_sequence"` // 自定义顺序 + Type string `json:"type"` // 类型 + CreatedIp string `json:"created_ip"` // 创建外网IP + SpecifyIp string `json:"specify_ip"` // 指定外网IP + UpdatedIp string `json:"updated_ip"` // 更新外网IP + Result string `json:"result"` // 结果 + CreatedAt string `orm:"auto_now_add;type(text)" json:"created_at"` // 创建时间 + UpdatedAt string `orm:"auto_now;type(text)" json:"updated_at"` // 更新时间 + DeletedAt string `orm:"on_delete(set_null)" json:"deleted_at"` // 删除时间 +} + +func (m *Task) TableName() string { + return "task" +} diff --git a/jobs_beego_orm_model/task_ip.go b/jobs_beego_orm_model/task_ip.go new file mode 100644 index 0000000..a97a1e2 --- /dev/null +++ b/jobs_beego_orm_model/task_ip.go @@ -0,0 +1,12 @@ +package jobs_beego_orm_model + +// TaskIp 任务Ip +type TaskIp struct { + Id int64 `orm:"auto" json:"id"` + TaskType string `json:"task_type"` // 任务编号 + Ips string `json:"ips"` // 任务IP +} + +func (m *TaskIp) TableName() string { + return "task_ip" +} diff --git a/jobs_beego_orm_model/task_log.go b/jobs_beego_orm_model/task_log.go new file mode 100644 index 0000000..74cf595 --- /dev/null +++ b/jobs_beego_orm_model/task_log.go @@ -0,0 +1,15 @@ +package jobs_beego_orm_model + +// TaskLog 任务日志模型 +type TaskLog struct { + Id uint `orm:"auto" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + StatusCode int `json:"status_code"` // 状态码 + Desc string `json:"desc"` // 结果 + Version int `json:"version"` // 版本 + CreatedAt string `orm:"auto_now_add;type(text)" json:"created_at"` // 创建时间 +} + +func (m *TaskLog) TableName() string { + return "task_log" +} diff --git a/jobs_beego_orm_model/task_log_run.go b/jobs_beego_orm_model/task_log_run.go new file mode 100644 index 0000000..e3037da --- /dev/null +++ b/jobs_beego_orm_model/task_log_run.go @@ -0,0 +1,20 @@ +package jobs_beego_orm_model + +// TaskLogRun 任务执行日志模型 +type TaskLogRun struct { + Id uint `orm:"auto" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + RunId string `json:"run_id"` // 执行编号 + OutsideIp string `json:"outside_ip"` // 外网ip + InsideIp string `json:"inside_ip"` // 内网ip + Os string `json:"os"` // 系统类型 + Arch string `json:"arch"` // 系统架构 + Gomaxprocs int `json:"gomaxprocs"` // CPU核数 + GoVersion string `json:"go_version"` // GO版本 + MacAddrs string `json:"mac_addrs"` // Mac地址 + CreatedAt string `orm:"auto_now_add;type(text)" json:"created_at"` // 创建时间 +} + +func (m *TaskLogRun) TableName() string { + return "task_log_run" +} diff --git a/jobs_common.go b/jobs_common.go new file mode 100644 index 0000000..00ad596 --- /dev/null +++ b/jobs_common.go @@ -0,0 +1,9 @@ +package gojobs + +const ( + TASK_IN = "IN" // 任务运行 + TASK_SUCCESS = "SUCCESS" // 任务完成 + TASK_ERROR = "ERROR" // 任务异常 + TASK_TIMEOUT = "TIMEOUT" // 任务超时 + TASK_WAIT = "WAIT" // 任务等待 +) diff --git a/jobs_gorm_model/task.go b/jobs_gorm_model/task.go new file mode 100644 index 0000000..a81d385 --- /dev/null +++ b/jobs_gorm_model/task.go @@ -0,0 +1,30 @@ +package jobs_gorm_model + +import "gorm.io/gorm" + +// Task 任务 +type Task struct { + Id uint `gorm:"primaryKey" json:"id"` // 记录编号 + Status string `json:"status"` // 状态码 + Params string `json:"params"` // 参数 + ParamsType string `json:"params_type"` // 参数类型 + StatusDesc string `json:"status_desc"` // 状态描述 + Frequency int64 `json:"frequency"` // 频率（秒单位） + Number int64 `json:"number"` // 当前次数 + MaxNumber int64 `json:"max_number"` // 最大次数 + RunId string `json:"run_id"` // 执行编号 + CustomId string `json:"custom_id"` // 自定义编号 + CustomSequence int64 `json:"custom_sequence"` // 自定义顺序 + Type string `json:"type"` // 类型 + CreatedIp string `json:"created_ip"` // 创建外网IP + SpecifyIp string `json:"specify_ip"` // 指定外网IP + UpdatedIp string `json:"updated_ip"` // 更新外网IP + Result string `json:"result"` // 结果 + CreatedAt string `gorm:"type:text" json:"created_at"` // 创建时间 + UpdatedAt string `gorm:"type:text" json:"updated_at"` // 更新时间 + DeletedAt gorm.DeletedAt `gorm:"type:text;index" json:"deleted_at"` // 删除时间 +} + +func (m *Task) TableName() string { + return "task" +} diff --git a/jobs_gorm_model/task_ip.go b/jobs_gorm_model/task_ip.go new file mode 100644 index 0000000..8de9ee8 --- /dev/null +++ b/jobs_gorm_model/task_ip.go @@ -0,0 +1,12 @@ +package jobs_gorm_model + +// TaskIp 任务Ip +type TaskIp struct { + Id int64 `gorm:"primaryKey" json:"id"` + TaskType string `json:"task_type"` // 任务编号 + Ips string `json:"ips"` // 任务IP +} + +func (m *TaskIp) TableName() string { + return "task_ip" +} diff --git a/jobs_gorm_model/task_log.go b/jobs_gorm_model/task_log.go new file mode 100644 index 0000000..28c54be --- /dev/null +++ b/jobs_gorm_model/task_log.go @@ -0,0 +1,15 @@ +package jobs_gorm_model + +// TaskLog 任务日志模型 +type TaskLog struct { + Id uint `gorm:"primaryKey" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + StatusCode int `json:"status_code"` // 状态码 + Desc string `json:"desc"` // 结果 + Version int `json:"version"` // 版本 + CreatedAt string `gorm:"type:text" json:"created_at"` // 创建时间 +} + +func (m *TaskLog) TableName() string { + return "task_log" +} diff --git a/jobs_gorm_model/task_log_run.go b/jobs_gorm_model/task_log_run.go new file mode 100644 index 0000000..668ce3a --- /dev/null +++ b/jobs_gorm_model/task_log_run.go @@ -0,0 +1,20 @@ +package jobs_gorm_model + +// TaskLogRun 任务执行日志模型 +type TaskLogRun struct { + Id uint `gorm:"primaryKey" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + RunId string `json:"run_id"` // 执行编号 + OutsideIp string `json:"outside_ip"` // 外网ip + InsideIp string `json:"inside_ip"` // 内网ip + Os string `json:"os"` // 系统类型 + Arch string `json:"arch"` // 系统架构 + Gomaxprocs int `json:"gomaxprocs"` // CPU核数 + GoVersion string `json:"go_version"` // GO版本 + MacAddrs string `json:"mac_addrs"` // Mac地址 + CreatedAt string `gorm:"type:text" json:"created_at"` // 创建时间 +} + +func (m *TaskLogRun) TableName() string { + return "task_log_run" +} diff --git a/jobs_xorm_model/task.go b/jobs_xorm_model/task.go new file mode 100644 index 0000000..19dc53b --- /dev/null +++ b/jobs_xorm_model/task.go @@ -0,0 +1,28 @@ +package jobs_xorm_model + +// Task 任务 +type Task struct { + Id uint `xorm:"pk autoincr" json:"id"` // 记录编号 + Status string `json:"status"` // 状态码 + Params string `json:"params"` // 参数 + ParamsType string `json:"params_type"` // 参数类型 + StatusDesc string `json:"status_desc"` // 状态描述 + Frequency int64 `json:"frequency"` // 频率（秒单位） + Number int64 `json:"number"` // 当前次数 + MaxNumber int64 `json:"max_number"` // 最大次数 + RunId string `json:"run_id"` // 执行编号 + CustomId string `json:"custom_id"` // 自定义编号 + CustomSequence int64 `json:"custom_sequence"` // 自定义顺序 + Type string `json:"type"` // 类型 + CreatedIp string `json:"created_ip"` // 创建外网IP + SpecifyIp string `json:"specify_ip"` // 指定外网IP + UpdatedIp string `json:"updated_ip"` // 更新外网IP + Result string `json:"result"` // 结果 + CreatedAt string `xorm:"created" json:"created_at"` // 创建时间 + UpdatedAt string `xorm:"created" json:"updated_at"` // 更新时间 + DeletedAt string `xorm:"deleted" json:"deleted_at"` // 删除时间 +} + +func (m *Task) TableName() string { + return "task" +} diff --git a/jobs_xorm_model/task_ip.go b/jobs_xorm_model/task_ip.go new file mode 100644 index 0000000..26c5ac5 --- /dev/null +++ b/jobs_xorm_model/task_ip.go @@ -0,0 +1,12 @@ +package jobs_xorm_model + +// TaskIp 任务Ip +type TaskIp struct { + Id int64 `xorm:"pk autoincr" json:"id"` + TaskType string `json:"task_type"` // 任务编号 + Ips string `json:"ips"` // 任务IP +} + +func (m *TaskIp) TableName() string { + return "task_ip" +} diff --git a/jobs_xorm_model/task_log.go b/jobs_xorm_model/task_log.go new file mode 100644 index 0000000..cb63491 --- /dev/null +++ b/jobs_xorm_model/task_log.go @@ -0,0 +1,15 @@ +package jobs_xorm_model + +// TaskLog 任务日志模型 +type TaskLog struct { + Id uint `xorm:"pk autoincr" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + StatusCode int `json:"status_code"` // 状态码 + Desc string `json:"desc"` // 结果 + Version int `json:"version"` // 版本 + CreatedAt string `xorm:"created" json:"created_at"` // 创建时间 +} + +func (m *TaskLog) TableName() string { + return "task_log" +} diff --git a/jobs_xorm_model/task_log_run.go b/jobs_xorm_model/task_log_run.go new file mode 100644 index 0000000..2175a8e --- /dev/null +++ b/jobs_xorm_model/task_log_run.go @@ -0,0 +1,20 @@ +package jobs_xorm_model + +// TaskLogRun 任务执行日志模型 +type TaskLogRun struct { + Id uint `xorm:"pk autoincr" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + RunId string `json:"run_id"` // 执行编号 + OutsideIp string `json:"outside_ip"` // 外网ip + InsideIp string `json:"inside_ip"` // 内网ip + Os string `json:"os"` // 系统类型 + Arch string `json:"arch"` // 系统架构 + Gomaxprocs int `json:"gomaxprocs"` // CPU核数 + GoVersion string `json:"go_version"` // GO版本 + MacAddrs string `json:"mac_addrs"` // Mac地址 + CreatedAt string `xorm:"created" json:"created_at"` // 创建时间 +} + +func (m *TaskLogRun) TableName() string { + return "task_log_run" +} diff --git a/jobs_zorm_model/task.go b/jobs_zorm_model/task.go new file mode 100644 index 0000000..baf194c --- /dev/null +++ b/jobs_zorm_model/task.go @@ -0,0 +1,28 @@ +package jobs_zorm_model + +// Task 任务 +type Task struct { + Id uint `zorm:"primaryKey" json:"id"` // 记录编号 + Status string `json:"status"` // 状态码 + Params string `json:"params"` // 参数 + ParamsType string `json:"params_type"` // 参数类型 + StatusDesc string `json:"status_desc"` // 状态描述 + Frequency int64 `json:"frequency"` // 频率（秒单位） + Number int64 `json:"number"` // 当前次数 + MaxNumber int64 `json:"max_number"` // 最大次数 + RunId string `json:"run_id"` // 执行编号 + CustomId string `json:"custom_id"` // 自定义编号 + CustomSequence int64 `json:"custom_sequence"` // 自定义顺序 + Type string `json:"type"` // 类型 + CreatedIp string `json:"created_ip"` // 创建外网IP + SpecifyIp string `json:"specify_ip"` // 指定外网IP + UpdatedIp string `json:"updated_ip"` // 更新外网IP + Result string `json:"result"` // 结果 + CreatedAt string `zorm:"type:text" json:"created_at"` // 创建时间 + UpdatedAt string `zorm:"type:text" json:"updated_at"` // 更新时间 + DeletedAt string `zorm:"index;deleted" json:"deleted_at"` // 删除时间 +} + +func (m *Task) TableName() string { + return "task" +} diff --git a/jobs_zorm_model/task_ip.go b/jobs_zorm_model/task_ip.go new file mode 100644 index 0000000..8256304 --- /dev/null +++ b/jobs_zorm_model/task_ip.go @@ -0,0 +1,12 @@ +package jobs_zorm_model + +// TaskIp 任务Ip +type TaskIp struct { + Id int64 `zorm:"primaryKey" json:"id"` + TaskType string `json:"task_type"` // 任务编号 + Ips string `json:"ips"` // 任务IP +} + +func (m *TaskIp) TableName() string { + return "task_ip" +} diff --git a/jobs_zorm_model/task_log.go b/jobs_zorm_model/task_log.go new file mode 100644 index 0000000..d9b12f5 --- /dev/null +++ b/jobs_zorm_model/task_log.go @@ -0,0 +1,15 @@ +package jobs_zorm_model + +// TaskLog 任务日志模型 +type TaskLog struct { + Id uint `zorm:"primaryKey" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + StatusCode int `json:"status_code"` // 状态码 + Desc string `json:"desc"` // 结果 + Version int `json:"version"` // 版本 + CreatedAt string `zorm:"type:text" json:"created_at"` // 创建时间 +} + +func (m *TaskLog) TableName() string { + return "task_log" +} diff --git a/jobs_zorm_model/task_log_run.go b/jobs_zorm_model/task_log_run.go new file mode 100644 index 0000000..bdfad44 --- /dev/null +++ b/jobs_zorm_model/task_log_run.go @@ -0,0 +1,20 @@ +package jobs_zorm_model + +// TaskLogRun 任务执行日志模型 +type TaskLogRun struct { + Id uint `zorm:"primaryKey" json:"id"` // 记录编号 + TaskId uint `json:"task_id"` // 任务编号 + RunId string `json:"run_id"` // 执行编号 + OutsideIp string `json:"outside_ip"` // 外网ip + InsideIp string `json:"inside_ip"` // 内网ip + Os string `json:"os"` // 系统类型 + Arch string `json:"arch"` // 系统架构 + Gomaxprocs int `json:"gomaxprocs"` // CPU核数 + GoVersion string `json:"go_version"` // GO版本 + MacAddrs string `json:"mac_addrs"` // Mac地址 + CreatedAt string `zorm:"type:text" json:"created_at"` // 创建时间 +} + +func (m *TaskLogRun) TableName() string { + return "task_log_run" +}