提交 677a106b 编写于 作者: W wq1234wq

复制修正

上级 694b3fb3
...@@ -184,6 +184,10 @@ namespace IoTSharp.Controllers ...@@ -184,6 +184,10 @@ namespace IoTSharp.Controllers
var rule = await _context.FlowRules.SingleOrDefaultAsync(c => c.RuleId == flowRule.RuleId && c.Tenant.Id == profile.Tenant); var rule = await _context.FlowRules.SingleOrDefaultAsync(c => c.RuleId == flowRule.RuleId && c.Tenant.Id == profile.Tenant);
if (rule != null) if (rule != null)
{ {
var _customer = await _context.Customer.SingleOrDefaultAsync(c => c.Id == profile.Comstomer);
var _tenant = await _context.Tenant.SingleOrDefaultAsync(c => c.Id == profile.Tenant);
var newrule = new FlowRule(); var newrule = new FlowRule();
newrule.DefinitionsXml = rule.DefinitionsXml; newrule.DefinitionsXml = rule.DefinitionsXml;
newrule.Describes = flowRule.Describes; newrule.Describes = flowRule.Describes;
...@@ -197,9 +201,9 @@ namespace IoTSharp.Controllers ...@@ -197,9 +201,9 @@ namespace IoTSharp.Controllers
newrule.ParentRuleId = rule.RuleId; newrule.ParentRuleId = rule.RuleId;
newrule.CreateId = new Guid(); newrule.CreateId = new Guid();
newrule.SubVersion = rule.SubVersion + 0.01; newrule.SubVersion = rule.SubVersion + 0.01;
newrule.Customer = await _context.Customer.SingleOrDefaultAsync(c => c.Id == profile.Comstomer); newrule.Customer = _customer;
newrule.Tenant = await _context.Tenant.SingleOrDefaultAsync(c => c.Id == profile.Tenant); newrule.Tenant = _tenant;
newrule.Creator = profile.Id.ToString(); newrule.Creator = profile.Id.ToString();
_context.FlowRules.Add(newrule); _context.FlowRules.Add(newrule);
await _context.SaveChangesAsync(); await _context.SaveChangesAsync();
...@@ -225,7 +229,8 @@ namespace IoTSharp.Controllers ...@@ -225,7 +229,8 @@ namespace IoTSharp.Controllers
Outgoing = c.Outgoing, Outgoing = c.Outgoing,
SourceId = c.SourceId, SourceId = c.SourceId,
TargetId = c.TargetId, TargetId = c.TargetId,
Customer = _customer,
Tenant = _tenant,
bpmnid = c.bpmnid, bpmnid = c.bpmnid,
CreateId = newrule.CreateId CreateId = newrule.CreateId
}).ToList(); }).ToList();
...@@ -332,7 +337,7 @@ namespace IoTSharp.Controllers ...@@ -332,7 +337,7 @@ namespace IoTSharp.Controllers
var activity = JsonConvert.DeserializeObject<Activity>(m.Biz); var activity = JsonConvert.DeserializeObject<Activity>(m.Biz);
var CreatorId = Guid.NewGuid(); var CreatorId = Guid.NewGuid();
var CreateDate = DateTime.Now; var CreateDate = DateTime.Now;
var rule = _context.FlowRules.Include(c=>c.Customer).Include(c=>c.Tenant).FirstOrDefault(c => c.RuleId == activity.RuleId); var rule = _context.FlowRules.Include(c => c.Customer).Include(c => c.Tenant).FirstOrDefault(c => c.RuleId == activity.RuleId);
rule.DefinitionsXml = m.Xml; rule.DefinitionsXml = m.Xml;
rule.Creator = profile.Id.ToString(); rule.Creator = profile.Id.ToString();
rule.CreateId = CreatorId; rule.CreateId = CreatorId;
...@@ -359,7 +364,7 @@ namespace IoTSharp.Controllers ...@@ -359,7 +364,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -379,7 +384,7 @@ namespace IoTSharp.Controllers ...@@ -379,7 +384,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -399,7 +404,7 @@ namespace IoTSharp.Controllers ...@@ -399,7 +404,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -423,7 +428,7 @@ namespace IoTSharp.Controllers ...@@ -423,7 +428,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -447,7 +452,7 @@ namespace IoTSharp.Controllers ...@@ -447,7 +452,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -467,7 +472,7 @@ namespace IoTSharp.Controllers ...@@ -467,7 +472,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -487,7 +492,7 @@ namespace IoTSharp.Controllers ...@@ -487,7 +492,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -507,7 +512,7 @@ namespace IoTSharp.Controllers ...@@ -507,7 +512,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -527,7 +532,7 @@ namespace IoTSharp.Controllers ...@@ -527,7 +532,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -565,7 +570,7 @@ namespace IoTSharp.Controllers ...@@ -565,7 +570,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -585,7 +590,7 @@ namespace IoTSharp.Controllers ...@@ -585,7 +590,7 @@ namespace IoTSharp.Controllers
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fw); _context.Flows.AddRange(fw);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -601,11 +606,11 @@ namespace IoTSharp.Controllers ...@@ -601,11 +606,11 @@ namespace IoTSharp.Controllers
FlowStatus = 1, FlowStatus = 1,
CreateId = CreatorId, CreateId = CreatorId,
Createor = profile.Id, Createor = profile.Id,
CreateDate = CreateDate , CreateDate = CreateDate,
Customer = rule.Customer, Customer = rule.Customer,
Tenant = rule.Tenant Tenant = rule.Tenant
}); });
_context.Flows.AddRange(fws); _context.Flows.AddRange(fws);
_context.SaveChanges(); _context.SaveChanges();
} }
...@@ -1112,8 +1117,8 @@ namespace IoTSharp.Controllers ...@@ -1112,8 +1117,8 @@ namespace IoTSharp.Controllers
var result = await _flowRuleProcessor.RunFlowRules(ruleid, d, Guid.Empty, EventType.TestPurpose, testabizId); var result = await _flowRuleProcessor.RunFlowRules(ruleid, d, Guid.Empty, EventType.TestPurpose, testabizId);
var flowRule=_context.FlowRules.SingleOrDefault(c => c.RuleId == ruleid); var flowRule = _context.FlowRules.SingleOrDefault(c => c.RuleId == ruleid);
var flows = _context.Flows.Where(c => c.FlowRule == flowRule).ToList(); var flows = _context.Flows.Where(c => c.FlowRule == flowRule).ToList();
...@@ -1131,8 +1136,9 @@ namespace IoTSharp.Controllers ...@@ -1131,8 +1136,9 @@ namespace IoTSharp.Controllers
{ {
AddDate = c.AddDate, AddDate = c.AddDate,
BizId = c.BizId, BizId = c.BizId,
Data = c.Data, BaseEvent = operevent, Data = c.Data,
Flow = flows.SingleOrDefault(x=>x.FlowId==c.Flow.FlowId BaseEvent = operevent,
Flow = flows.SingleOrDefault(x => x.FlowId == c.Flow.FlowId
), ),
FlowRule = flowRule, FlowRule = flowRule,
NodeStatus = c.NodeStatus, NodeStatus = c.NodeStatus,
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册