Skip to content

Commit

Permalink
Merge pull request #4 from mgr9525/dev
Browse files Browse the repository at this point in the history
update ui
  • Loading branch information
mgr9525 authored Oct 13, 2020
2 parents 47f6efc + 560ad7b commit 79b28f4
Show file tree
Hide file tree
Showing 6 changed files with 183 additions and 26 deletions.
2 changes: 2 additions & 0 deletions comm/vars.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,5 +12,7 @@ var (
Gin *gin.Engine
Db *xorm.Engine

Dbold *xorm.Engine

RunTaskLen int = 5
)
2 changes: 1 addition & 1 deletion comm/vuefl.go

Large diffs are not rendered by default.

43 changes: 19 additions & 24 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,19 +2,22 @@ package main

import (
"flag"
"fmt"
"gokins/comm"
"gokins/core"
"gokins/mgr"
"gokins/route"
"gokins/service"
"gokins/service/dbService"
"os"
"path/filepath"

"github.com/gin-gonic/gin"
)

var clearPass = ""
var (
clearPass = ""
mvData = ""
)

func init() {
path, err := os.Executable()
Expand All @@ -32,7 +35,9 @@ func init() {
println("dir:" + dir)
flag.StringVar(&comm.Dir, "d", dir, "数据目录")
flag.StringVar(&comm.Host, "bind", ":8030", "绑定地址")
flag.StringVar(&clearPass, "clp", "", "清除用户密码(请先关闭服务在执行)")
flag.IntVar(&comm.RunTaskLen, "rln", 5, "同时执行的流水线数量(默认5)")
flag.StringVar(&clearPass, "clp", "", "清除某个用户密码(请先关闭服务在执行)")
flag.StringVar(&mvData, "mvdata", "", "转移某个库数据到本地(目前转移的数据:流水线、流水线插件)")
flag.Parse()
comm.Gin = gin.Default()
}
Expand All @@ -42,9 +47,18 @@ func main() {
println("InitDb err:" + err.Error())
return
}
if clearUPass() {
if clearPass != "" {
service.ClearUPass(clearPass)
return
}
if mvData != "" {
service.MoveData(mvData)
return
}

runWeb()
}
func runWeb() {
jwtKey := dbService.GetParam("jwt-key")
jkey := jwtKey.GetString("key")
if jkey == "" {
Expand All @@ -55,28 +69,9 @@ func main() {
core.JwtKey = jkey
route.Init()
mgr.ExecMgr.Start()
err = comm.Gin.Run(comm.Host)
err := comm.Gin.Run(comm.Host)
if err != nil {
println("gin run err:" + err.Error())
}
mgr.Cancel()
}

func clearUPass() bool {
if clearPass != "" {
usr := dbService.FindUserName(clearPass)
if usr == nil {
fmt.Printf("user(%s) not found\n", clearPass)
} else {
usr.Pass = ""
_, err := comm.Db.Cols("pass").Where("id=?", usr.Id).Update(usr)
if err != nil {
fmt.Println("clear password err:" + err.Error())
} else {
fmt.Println("clear password ok")
}
}
return true
}
return false
}
66 changes: 66 additions & 0 deletions service/cmd.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
package service

import (
"fmt"
"gokins/comm"
"gokins/service/dbService"
"os"
"path/filepath"

"github.com/go-xorm/xorm"
)

func ClearUPass(nm string) {
if nm == "" {
return
}
usr := dbService.FindUserName(nm)
if usr == nil {
fmt.Printf("user(%s) not found\n", nm)
} else {
usr.Pass = ""
_, err := comm.Db.Cols("pass").Where("id=?", usr.Id).Update(usr)
if err != nil {
fmt.Println("clear password err:" + err.Error())
} else {
fmt.Println("clear password ok")
}
}
}

func MoveData(pth string) {
if pth == "" {
return
}
pths, err := filepath.Abs(pth)
if err != nil {
fmt.Println("old db path err:" + err.Error())
return
}
stat, err := os.Stat(pths)
if err != nil {
fmt.Println("old db path err:" + err.Error())
return
}
if stat.IsDir() {
pths += "/db.dat"
stat, err = os.Stat(pths)
if err != nil {
fmt.Println("find old db path err:" + err.Error())
return
}
if stat.IsDir() {
fmt.Println("find old db path err:is dir")
return
}
}

db, err := xorm.NewEngine("sqlite3", pths)
if err != nil {
fmt.Println("old db path err:" + err.Error())
return
}
comm.Dbold = db

MoveModels()
}
92 changes: 92 additions & 0 deletions service/mv.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,92 @@
package service

import (
"fmt"
"gokins/comm"
"gokins/model"
"time"

ruisUtil "github.com/mgr9525/go-ruisutil"
)

func MoveModels() {
var olds []*ruisUtil.Map
err := comm.Dbold.SQL("select * from t_model").Find(&olds)
if err != nil {
fmt.Println("find model err:" + err.Error())
return
}
for _, v := range olds {
id, err := v.GetInt("id")
if err != nil {
continue
}
del, err := v.GetInt("del")
if err != nil {
continue
}
clrdir, err := v.GetInt("clrdir")
if err != nil {
continue
}
ne := &model.TModel{}
ne.Uid = v.GetString("uid")
ne.Title = v.GetString("title")
ne.Desc = v.GetString("desc")
ne.Del = int(del)
ne.Clrdir = int(clrdir)
ne.Envs = v.GetString("envs")
ne.Wrkdir = v.GetString("wrkdir")
if tm, ok := v.Get("times").(time.Time); ok {
ne.Times = tm
}
_, err = comm.Db.Insert(ne)
if err == nil {
mvPlugin(id, ne)
}
}
}

func mvPlugin(tid int64, md *model.TModel) {
var olds []*ruisUtil.Map
err := comm.Dbold.SQL("select * from t_plugin where tid=?", tid).Find(&olds)
if err != nil {
fmt.Println("find model err:" + err.Error())
return
}
for _, v := range olds {
del, err := v.GetInt("del")
if err != nil {
continue
}
typ, err := v.GetInt("type")
if err != nil {
continue
}
sort, err := v.GetInt("sort")
if err != nil {
break
}
exend, err := v.GetInt("exend")
if err != nil {
continue
}
ne := &model.TPlugin{}
ne.Tid = md.Id
ne.Title = v.GetString("title")
ne.Type = int(typ)
ne.Del = int(del)
ne.Sort = int(sort)
ne.Exend = int(exend)
ne.Para = v.GetString("para")
ne.Cont = v.GetString("cont")
if tm, ok := v.Get("times").(time.Time); ok {
ne.Times = tm
}
_, err = comm.Db.Insert(ne)
if err != nil {
fmt.Sprintf("insert plug err:" + err.Error())
break
}
}
}
4 changes: 3 additions & 1 deletion uis/vue-admin/src/views/ruis/PlugRunList.vue
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,9 @@
</div>
<div style="flex:1;white-space: break-spaces;word-break: break-all;">
<el-card class="box-card">
<div style="" v-text="logs[selid]&&logs[selid].text"></div>
<div>
<pre style="white-space: pre-line;">{{logs[selid]&&logs[selid].text}}</pre>
</div>
</el-card>
</div>
</div>
Expand Down

0 comments on commit 79b28f4

Please sign in to comment.