// @generated Do not edit this file, which is automatically generated by the generator.

package dbschema

import (
	"fmt"

	"github.com/webx-top/db"
	"github.com/webx-top/db/lib/factory"
	"github.com/webx-top/echo/param"
	
	"time"
)

// ForeverProcess 持久进程
type ForeverProcess struct {
	param   *factory.Param
	trans	*factory.Transaction
	objects []*ForeverProcess
	namer   func(string) string
	connID  int
	
	Id           	uint    	`db:"id,omitempty,pk" bson:"id,omitempty" comment:"ID" json:"id" xml:"id"`
	Uid          	uint    	`db:"uid" bson:"uid" comment:"添加人ID" json:"uid" xml:"uid"`
	Name         	string  	`db:"name" bson:"name" comment:"名称" json:"name" xml:"name"`
	Command      	string  	`db:"command" bson:"command" comment:"命令" json:"command" xml:"command"`
	Workdir      	string  	`db:"workdir" bson:"workdir" comment:"工作目录" json:"workdir" xml:"workdir"`
	Env          	string  	`db:"env" bson:"env" comment:"环境变量" json:"env" xml:"env"`
	Args         	string  	`db:"args" bson:"args" comment:"命令参数" json:"args" xml:"args"`
	Pidfile      	string  	`db:"pidfile" bson:"pidfile" comment:"PID记录文件" json:"pidfile" xml:"pidfile"`
	Logfile      	string  	`db:"logfile" bson:"logfile" comment:"日志记录文件" json:"logfile" xml:"logfile"`
	Errfile      	string  	`db:"errfile" bson:"errfile" comment:"错误记录文件" json:"errfile" xml:"errfile"`
	Respawn      	uint    	`db:"respawn" bson:"respawn" comment:"重试次数(进程被外部程序结束后自动启动)" json:"respawn" xml:"respawn"`
	Delay        	string  	`db:"delay" bson:"delay" comment:"延迟启动(例如1ms/1s/1m/1h)" json:"delay" xml:"delay"`
	Ping         	string  	`db:"ping" bson:"ping" comment:"心跳时间(例如1ms/1s/1m/1h)" json:"ping" xml:"ping"`
	Pid          	int     	`db:"pid" bson:"pid" comment:"PID" json:"pid" xml:"pid"`
	Status       	string  	`db:"status" bson:"status" comment:"进程运行状态" json:"status" xml:"status"`
	Debug        	string  	`db:"debug" bson:"debug" comment:"DEBUG" json:"debug" xml:"debug"`
	Disabled     	string  	`db:"disabled" bson:"disabled" comment:"是否禁用" json:"disabled" xml:"disabled"`
	Created      	uint    	`db:"created" bson:"created" comment:"创建时间" json:"created" xml:"created"`
	Updated      	uint    	`db:"updated" bson:"updated" comment:"修改时间" json:"updated" xml:"updated"`
	Error        	string  	`db:"error" bson:"error" comment:"错误信息" json:"error" xml:"error"`
	Lastrun      	uint    	`db:"lastrun" bson:"lastrun" comment:"上次运行时间" json:"lastrun" xml:"lastrun"`
	Description  	string  	`db:"description" bson:"description" comment:"说明" json:"description" xml:"description"`
	EnableNotify 	uint    	`db:"enable_notify" bson:"enable_notify" comment:"是否启用通知" json:"enable_notify" xml:"enable_notify"`
	NotifyEmail  	string  	`db:"notify_email" bson:"notify_email" comment:"通知人列表" json:"notify_email" xml:"notify_email"`
}

func (this *ForeverProcess) Trans() *factory.Transaction {
	return this.trans
}

func (this *ForeverProcess) Use(trans *factory.Transaction) factory.Model {
	this.trans = trans
	return this
}

func (this *ForeverProcess) SetConnID(connID int) factory.Model {
	this.connID = connID
	return this
}

func (this *ForeverProcess) New(structName string, connID ...int) factory.Model {
	if len(connID) > 0 {
		return factory.NewModel(structName,connID[0]).Use(this.trans)
	}
	return factory.NewModel(structName,this.connID).Use(this.trans)
}

func (this *ForeverProcess) Objects() []*ForeverProcess {
	if this.objects == nil {
		return nil
	}
	return this.objects[:]
}

func (this *ForeverProcess) NewObjects() *[]*ForeverProcess {
	this.objects = []*ForeverProcess{}
	return &this.objects
}

func (this *ForeverProcess) NewParam() *factory.Param {
	return factory.NewParam(factory.DefaultFactory).SetIndex(this.connID).SetTrans(this.trans).SetCollection(this.Name_()).SetModel(this)
}

func (this *ForeverProcess) SetNamer(namer func (string) string) factory.Model {
	this.namer = namer
	return this
}

func (this *ForeverProcess) Short_() string {
	return "forever_process"
}

func (this *ForeverProcess) Struct_() string {
	return "ForeverProcess"
}

func (this *ForeverProcess) Name_() string {
	if this.namer != nil {
		return WithPrefix(this.namer(this.Short_()))
	}
	return WithPrefix(factory.TableNamerGet(this.Short_())(this))
}

func (this *ForeverProcess) SetParam(param *factory.Param) factory.Model {
	this.param = param
	return this
}

func (this *ForeverProcess) Param() *factory.Param {
	if this.param == nil {
		return this.NewParam()
	}
	return this.param
}

func (this *ForeverProcess) Get(mw func(db.Result) db.Result, args ...interface{}) error {
	return this.Param().SetArgs(args...).SetRecv(this).SetMiddleware(mw).One()
}

func (this *ForeverProcess) List(recv interface{}, mw func(db.Result) db.Result, page, size int, args ...interface{}) (func() int64, error) {
	if recv == nil {
		recv = this.NewObjects()
	}
	return this.Param().SetArgs(args...).SetPage(page).SetSize(size).SetRecv(recv).SetMiddleware(mw).List()
}

func (this *ForeverProcess) GroupBy(keyField string, inputRows ...[]*ForeverProcess) map[string][]*ForeverProcess {
	var rows []*ForeverProcess
	if len(inputRows) > 0 {
		rows = inputRows[0]
	} else {
		rows = this.Objects()
	}
	r := map[string][]*ForeverProcess{}
	for _, row := range rows {
		dmap := row.AsMap()
		vkey := fmt.Sprint(dmap[keyField])
		if _, y := r[vkey]; !y {
			r[vkey] = []*ForeverProcess{}
		}
		r[vkey] = append(r[vkey], row)
	}
	return r
}

func (this *ForeverProcess) KeyBy(keyField string, inputRows ...[]*ForeverProcess) map[string]*ForeverProcess {
	var rows []*ForeverProcess
	if len(inputRows) > 0 {
		rows = inputRows[0]
	} else {
		rows = this.Objects()
	}
	r := map[string]*ForeverProcess{}
	for _, row := range rows {
		dmap := row.AsMap()
		vkey := fmt.Sprint(dmap[keyField])
		r[vkey] = row
	}
	return r
}

func (this *ForeverProcess) AsKV(keyField string, valueField string, inputRows ...[]*ForeverProcess) map[string]interface{} {
	var rows []*ForeverProcess
	if len(inputRows) > 0 {
		rows = inputRows[0]
	} else {
		rows = this.Objects()
	}
	r := map[string]interface{}{}
	for _, row := range rows {
		dmap := row.AsMap()
		vkey := fmt.Sprint(dmap[keyField])
		r[vkey] = dmap[valueField]
	}
	return r
}

func (this *ForeverProcess) ListByOffset(recv interface{}, mw func(db.Result) db.Result, offset, size int, args ...interface{}) (func() int64, error) {
	if recv == nil {
		recv = this.NewObjects()
	}
	return this.Param().SetArgs(args...).SetOffset(offset).SetSize(size).SetRecv(recv).SetMiddleware(mw).List()
}

func (this *ForeverProcess) Add() (pk interface{}, err error) {
	this.Created = uint(time.Now().Unix())
	this.Id = 0
	if len(this.Status) == 0 { this.Status = "idle" }
	if len(this.Debug) == 0 { this.Debug = "N" }
	if len(this.Disabled) == 0 { this.Disabled = "N" }
	pk, err = this.Param().SetSend(this).Insert()
	if err == nil && pk != nil {
		if v, y := pk.(uint); y {
			this.Id = v
		} else if v, y := pk.(int64); y {
			this.Id = uint(v)
		}
	}
	return
}

func (this *ForeverProcess) Edit(mw func(db.Result) db.Result, args ...interface{}) error {
	this.Updated = uint(time.Now().Unix())
	if len(this.Status) == 0 { this.Status = "idle" }
	if len(this.Debug) == 0 { this.Debug = "N" }
	if len(this.Disabled) == 0 { this.Disabled = "N" }
	return this.Setter(mw, args...).SetSend(this).Update()
}

func (this *ForeverProcess) Setter(mw func(db.Result) db.Result, args ...interface{}) *factory.Param {
	return this.Param().SetArgs(args...).SetMiddleware(mw)
}

func (this *ForeverProcess) SetField(mw func(db.Result) db.Result, field string, value interface{}, args ...interface{}) error {
	return this.SetFields(mw, map[string]interface{}{
		field: value,
	}, args...)
}

func (this *ForeverProcess) SetFields(mw func(db.Result) db.Result, kvset map[string]interface{}, args ...interface{}) error {
	
	if val, ok := kvset["status"]; ok && val != nil { if v, ok := val.(string); ok && len(v) == 0 { kvset["status"] = "idle" } }
	if val, ok := kvset["debug"]; ok && val != nil { if v, ok := val.(string); ok && len(v) == 0 { kvset["debug"] = "N" } }
	if val, ok := kvset["disabled"]; ok && val != nil { if v, ok := val.(string); ok && len(v) == 0 { kvset["disabled"] = "N" } }
	return this.Setter(mw, args...).SetSend(kvset).Update()
}

func (this *ForeverProcess) Upsert(mw func(db.Result) db.Result, args ...interface{}) (pk interface{}, err error) {
	pk, err = this.Param().SetArgs(args...).SetSend(this).SetMiddleware(mw).Upsert(func(){
		this.Updated = uint(time.Now().Unix())
	if len(this.Status) == 0 { this.Status = "idle" }
	if len(this.Debug) == 0 { this.Debug = "N" }
	if len(this.Disabled) == 0 { this.Disabled = "N" }
	},func(){
		this.Created = uint(time.Now().Unix())
	this.Id = 0
	if len(this.Status) == 0 { this.Status = "idle" }
	if len(this.Debug) == 0 { this.Debug = "N" }
	if len(this.Disabled) == 0 { this.Disabled = "N" }
	})
	if err == nil && pk != nil {
		if v, y := pk.(uint); y {
			this.Id = v
		} else if v, y := pk.(int64); y {
			this.Id = uint(v)
		}
	}
	return 
}

func (this *ForeverProcess) Delete(mw func(db.Result) db.Result, args ...interface{}) error {
	
	return this.Param().SetArgs(args...).SetMiddleware(mw).Delete()
}

func (this *ForeverProcess) Count(mw func(db.Result) db.Result, args ...interface{}) (int64, error) {
	return this.Param().SetArgs(args...).SetMiddleware(mw).Count()
}

func (this *ForeverProcess) Reset() *ForeverProcess {
	this.Id = 0
	this.Uid = 0
	this.Name = ``
	this.Command = ``
	this.Workdir = ``
	this.Env = ``
	this.Args = ``
	this.Pidfile = ``
	this.Logfile = ``
	this.Errfile = ``
	this.Respawn = 0
	this.Delay = ``
	this.Ping = ``
	this.Pid = 0
	this.Status = ``
	this.Debug = ``
	this.Disabled = ``
	this.Created = 0
	this.Updated = 0
	this.Error = ``
	this.Lastrun = 0
	this.Description = ``
	this.EnableNotify = 0
	this.NotifyEmail = ``
	return this
}

func (this *ForeverProcess) AsMap() map[string]interface{} {
	r := map[string]interface{}{}
	r["Id"] = this.Id
	r["Uid"] = this.Uid
	r["Name"] = this.Name
	r["Command"] = this.Command
	r["Workdir"] = this.Workdir
	r["Env"] = this.Env
	r["Args"] = this.Args
	r["Pidfile"] = this.Pidfile
	r["Logfile"] = this.Logfile
	r["Errfile"] = this.Errfile
	r["Respawn"] = this.Respawn
	r["Delay"] = this.Delay
	r["Ping"] = this.Ping
	r["Pid"] = this.Pid
	r["Status"] = this.Status
	r["Debug"] = this.Debug
	r["Disabled"] = this.Disabled
	r["Created"] = this.Created
	r["Updated"] = this.Updated
	r["Error"] = this.Error
	r["Lastrun"] = this.Lastrun
	r["Description"] = this.Description
	r["EnableNotify"] = this.EnableNotify
	r["NotifyEmail"] = this.NotifyEmail
	return r
}

func (this *ForeverProcess) Set(key interface{}, value ...interface{}) {
	switch k := key.(type) {
		case map[string]interface{}:
			for kk, vv := range k {
				this.Set(kk, vv)
			}
		default:
			var (
				kk string
				vv interface{}
			)
			if k, y := key.(string); y {
				kk = k
			} else {
				kk = fmt.Sprint(key)
			}
			if len(value) > 0 {
				vv = value[0]
			}
			switch kk {
				case "Id": this.Id = param.AsUint(vv)
				case "Uid": this.Uid = param.AsUint(vv)
				case "Name": this.Name = param.AsString(vv)
				case "Command": this.Command = param.AsString(vv)
				case "Workdir": this.Workdir = param.AsString(vv)
				case "Env": this.Env = param.AsString(vv)
				case "Args": this.Args = param.AsString(vv)
				case "Pidfile": this.Pidfile = param.AsString(vv)
				case "Logfile": this.Logfile = param.AsString(vv)
				case "Errfile": this.Errfile = param.AsString(vv)
				case "Respawn": this.Respawn = param.AsUint(vv)
				case "Delay": this.Delay = param.AsString(vv)
				case "Ping": this.Ping = param.AsString(vv)
				case "Pid": this.Pid = param.AsInt(vv)
				case "Status": this.Status = param.AsString(vv)
				case "Debug": this.Debug = param.AsString(vv)
				case "Disabled": this.Disabled = param.AsString(vv)
				case "Created": this.Created = param.AsUint(vv)
				case "Updated": this.Updated = param.AsUint(vv)
				case "Error": this.Error = param.AsString(vv)
				case "Lastrun": this.Lastrun = param.AsUint(vv)
				case "Description": this.Description = param.AsString(vv)
				case "EnableNotify": this.EnableNotify = param.AsUint(vv)
				case "NotifyEmail": this.NotifyEmail = param.AsString(vv)
			}
	}
}

func (this *ForeverProcess) AsRow() map[string]interface{} {
	r := map[string]interface{}{}
	r["id"] = this.Id
	r["uid"] = this.Uid
	r["name"] = this.Name
	r["command"] = this.Command
	r["workdir"] = this.Workdir
	r["env"] = this.Env
	r["args"] = this.Args
	r["pidfile"] = this.Pidfile
	r["logfile"] = this.Logfile
	r["errfile"] = this.Errfile
	r["respawn"] = this.Respawn
	r["delay"] = this.Delay
	r["ping"] = this.Ping
	r["pid"] = this.Pid
	r["status"] = this.Status
	r["debug"] = this.Debug
	r["disabled"] = this.Disabled
	r["created"] = this.Created
	r["updated"] = this.Updated
	r["error"] = this.Error
	r["lastrun"] = this.Lastrun
	r["description"] = this.Description
	r["enable_notify"] = this.EnableNotify
	r["notify_email"] = this.NotifyEmail
	return r
}

func (this *ForeverProcess) BatchValidate(kvset map[string]interface{}) error {
	if kvset == nil {
		kvset = this.AsRow()
	}
	return factory.BatchValidate(this.Short_(), kvset)
}

func (this *ForeverProcess) Validate(field string, value interface{}) error {
	return factory.Validate(this.Short_(), field, value)
}