/
codecheck.go
106 lines (93 loc) · 3.28 KB
/
codecheck.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
// Copyright (C) 2014-2018 Goodrain Co., Ltd.
// RAINBOND, Application Management Platform
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version. For any non-GPL usage of Rainbond,
// one or multiple Commercial Licenses authorized by Goodrain Co., Ltd.
// must be obtained first.
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
package dao
import (
"github.com/goodrain/rainbond/db/model"
"github.com/jinzhu/gorm"
)
//AddModel AddModel
func (c *CodeCheckResultDaoImpl) AddModel(mo model.Interface) error {
result := mo.(*model.CodeCheckResult)
var oldResult model.CodeCheckResult
if ok := c.DB.Where("service_id=?", result.ServiceID).Find(&oldResult).RecordNotFound(); ok {
if err := c.DB.Create(result).Error; err != nil {
return err
}
} else {
update(result, &oldResult)
if err := c.DB.Save(&oldResult).Error; err != nil {
return err
}
return nil
}
return nil
}
//UpdateModel UpdateModel
func (c *CodeCheckResultDaoImpl) UpdateModel(mo model.Interface) error {
result := mo.(*model.CodeCheckResult)
var oldResult model.CodeCheckResult
if ok := c.DB.Where("service_id=?", result.ServiceID).Find(&oldResult).RecordNotFound(); !ok {
update(result, &oldResult)
if err := c.DB.Save(&oldResult).Error; err != nil {
return err
}
}
return nil
}
//CodeCheckResultDaoImpl EventLogMessageDaoImpl
type CodeCheckResultDaoImpl struct {
DB *gorm.DB
}
func update(target, old *model.CodeCheckResult) {
//o,_:=json.Marshal(old)
//t,_:=json.Marshal(target)
//logrus.Infof("before update,stared is %s,target is ",string(o),string(t))
if target.DockerFileReady != old.DockerFileReady {
old.DockerFileReady = !old.DockerFileReady
}
if target.VolumeList != "" && target.VolumeList != "null" {
old.VolumeList = target.VolumeList
}
if target.PortList != "" && target.PortList != "null" {
old.PortList = target.PortList
}
if target.BuildImageName != "" {
old.BuildImageName = target.BuildImageName
}
if target.VolumeMountPath != "" {
old.VolumeMountPath = target.VolumeMountPath
}
if target.InnerPort != "" {
old.InnerPort = target.InnerPort
}
//o2,_:=json.Marshal(old)
//t2,_:=json.Marshal(target)
//logrus.Infof("after update,%s,%s",string(o2),string(t2))
}
//GetCodeCheckResult get event log message
func (c *CodeCheckResultDaoImpl) GetCodeCheckResult(serviceID string) (*model.CodeCheckResult, error) {
var result model.CodeCheckResult
if err := c.DB.Where("service_id=?", serviceID).Find(&result).Error; err != nil {
if err == gorm.ErrRecordNotFound {
//return messageRaw, nil
}
return nil, err
}
return &result, nil
}
// DeleteByServiceID deletes a CodeCheckResult base on serviceID.
func (c *CodeCheckResultDaoImpl) DeleteByServiceID(serviceID string) error {
return c.DB.Where("service_id=?", serviceID).Delete(&model.CodeCheckResult{}).Error
}