|
@@ -47,15 +47,13 @@ func (a ruleChainService) Get(vendorId, recordId string) (models.RuleChain, erro
|
|
|
|
|
|
func (a ruleChainService) Create(ruleChain *models.RuleChain) error {
|
|
|
ruleChain.RecordId = guid.S()
|
|
|
- if len(ruleChain.Cell) > 0 {
|
|
|
- marshal, _ := json.Marshal(ruleChain.Cell)
|
|
|
- ruleChain.Configuration = fmt.Sprintf("%s", marshal)
|
|
|
- err := a.create(ruleChain)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
+
|
|
|
+ err := a.create(ruleChain)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
}
|
|
|
- err := a.model.RuleChain.Create(ruleChain)
|
|
|
+
|
|
|
+ err = a.model.RuleChain.Create(ruleChain)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -72,6 +70,11 @@ func (a ruleChainService) Create(ruleChain *models.RuleChain) error {
|
|
|
}
|
|
|
|
|
|
func (a ruleChainService) create(ruleChain *models.RuleChain) error {
|
|
|
+ if len(ruleChain.Cell) == 0 {
|
|
|
+ return nil
|
|
|
+ }
|
|
|
+ marshal, _ := json.Marshal(ruleChain.Cell)
|
|
|
+ ruleChain.Configuration = fmt.Sprintf("%s", marshal)
|
|
|
|
|
|
nodeMap := make(map[string]models.RuleNode)
|
|
|
var inputNodeId string
|