using System;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore.Design;
|
using WalkingTec.Mvvm.Core;
|
using WalkingTec.Mvvm.Core.Attributes;
|
using cy_scdz.Model;
|
using System.Collections.Generic;
|
using WalkingTec.Mvvm.Core.Extensions;
|
using WalkingTec.Mvvm.Core.Models;
|
using Microsoft.EntityFrameworkCore.Metadata.Builders;
|
using cy_scdz.Model.Set;
|
using cy_scdz.Model.Oder;
|
|
namespace cy_scdz.DataAccess
|
{
|
public partial class DataContext : FrameworkContext
|
{
|
public DbSet<FrameworkUser> FrameworkUsers { get; set; }
|
public DbSet<FrameworkUserRole> FrameworkUserRoles { get; set; }
|
public DbSet<FrameworkUserGroup> FrameworkUserGroups { get; set; }
|
public DbSet<Dictionary> Dictionary { get; set; }
|
|
public DbSet<OderSure> OderSure { get; set; }
|
public DbSet<OrderInfo> BidOder { get; set; }
|
public DbSet<PriceSetting> PriceSettings { get; set; }
|
public DbSet<OrderReceivables> OrderReceivables { get; set; }
|
public DbSet<AdvancePayment> AdvancePayment { get; set; }
|
public DbSet<OrderProduction> orderProductions { get; set; }
|
public DataContext(CS cs)
|
: base(cs)
|
{
|
}
|
|
public DataContext(string cs, DBTypeEnum dbtype) : base(cs, dbtype)
|
{
|
|
}
|
|
public DataContext(string cs, DBTypeEnum dbtype, string version = null) : base(cs, dbtype, version)
|
{
|
|
}
|
public DataContext(DbContextOptions<DataContext> options) : base(options) { }
|
|
public override async Task<bool> DataInit(object allModules, bool IsSpa)
|
{
|
var state = await base.DataInit(allModules, IsSpa);
|
bool emptydb = false;
|
try
|
{
|
emptydb = Set<FrameworkUser>().Count() == 0 && Set<FrameworkUserRole>().Count() == 0;
|
}
|
catch { }
|
if (state == true || emptydb == true)
|
{
|
//when state is true, means it's the first time EF create database, do data init here
|
//当state是true的时候，表示这是第一次创建数据库，可以在这里进行数据初始化
|
var user = new FrameworkUser
|
{
|
ITCode = "admin",
|
Password = Utils.GetMD5String("000000"),
|
IsValid = true,
|
Name = "Admin",
|
|
};
|
|
var userrole = new FrameworkUserRole
|
{
|
UserCode = user.ITCode,
|
RoleCode = "001"
|
};
|
Set<FrameworkUser>().Add(user);
|
Set<FrameworkUserRole>().Add(userrole);
|
await SaveChangesAsync();
|
|
try{
|
Dictionary<string, List<object>> data = new Dictionary<string, List<object>>();
|
new Task(() =>{
|
}).Start();
|
}catch{}
|
}
|
return state;
|
}
|
|
private void SetWorkflowData(string name,string modelname)
|
{
|
using (var dc = this.CreateNew())
|
{
|
dc.Set<Elsa_WorkflowDefinition>().Add(new Elsa_WorkflowDefinition
|
{
|
ID = Guid.NewGuid().ToString("N").ToLower(),
|
DefinitionId = Guid.NewGuid().ToString("N").ToLower(),
|
Name = name,
|
Version = 1,
|
PersistenceBehavior = 1,
|
IsPublished = true,
|
IsLatest = true,
|
CreatedAt = DateTime.Now,
|
Data = $@"{{
|
""$id"": ""1"",
|
""activities"": [
|
{{
|
""$id"": ""2"",
|
""activityId"": ""eb10789a-536b-4335-acfe-ee2bfb888cbc"",
|
""type"": ""WtmApproveActivity"",
|
""displayName"": ""审批"",
|
""persistWorkflow"": false,
|
""loadWorkflowContext"": false,
|
""saveWorkflowContext"": false,
|
""properties"": [
|
{{
|
""$id"": ""3"",
|
""name"": ""ApproveUsers"",
|
""expressions"": {{
|
""$id"": ""4"",
|
""Json"": ""[\""admin\""]""
|
}}
|
}},
|
{{
|
""$id"": ""5"",
|
""name"": ""ApproveRoles"",
|
""expressions"": {{
|
""$id"": ""6""
|
}}
|
}},
|
{{
|
""$id"": ""7"",
|
""name"": ""ApproveGroups"",
|
""expressions"": {{
|
""$id"": ""8""
|
}}
|
}},
|
{{
|
""$id"": ""9"",
|
""name"": ""ApproveManagers"",
|
""expressions"": {{
|
""$id"": ""10""
|
}}
|
}},
|
{{
|
""$id"": ""11"",
|
""name"": ""ApproveSpecials"",
|
""expressions"": {{
|
""$id"": ""12""
|
}}
|
}},
|
{{
|
""$id"": ""13"",
|
""name"": ""Tag"",
|
""expressions"": {{
|
""$id"": ""14""
|
}}
|
}}
|
],
|
""propertyStorageProviders"": {{
|
""$id"": ""15""
|
}}
|
}},
|
{{
|
""$id"": ""16"",
|
""activityId"": ""e52df4f2-2da7-43ac-973a-76618072eec2"",
|
""type"": ""Finish"",
|
""displayName"": ""结束"",
|
""persistWorkflow"": false,
|
""loadWorkflowContext"": false,
|
""saveWorkflowContext"": false,
|
""properties"": [
|
{{
|
""$id"": ""17"",
|
""name"": ""ActivityOutput"",
|
""expressions"": {{
|
""$id"": ""18""
|
}}
|
}},
|
{{
|
""$id"": ""19"",
|
""name"": ""OutcomeNames"",
|
""expressions"": {{
|
""$id"": ""20""
|
}}
|
}}
|
],
|
""propertyStorageProviders"": {{
|
""$id"": ""21""
|
}}
|
}}
|
],
|
""connections"": [
|
{{
|
""$id"": ""22"",
|
""sourceActivityId"": ""eb10789a-536b-4335-acfe-ee2bfb888cbc"",
|
""targetActivityId"": ""e52df4f2-2da7-43ac-973a-76618072eec2"",
|
""outcome"": ""同意""
|
}},
|
{{
|
""$id"": ""23"",
|
""sourceActivityId"": ""eb10789a-536b-4335-acfe-ee2bfb888cbc"",
|
""targetActivityId"": ""e52df4f2-2da7-43ac-973a-76618072eec2"",
|
""outcome"": ""拒绝""
|
}}
|
],
|
""variables"": {{
|
""$id"": ""24"",
|
""data"": {{}}
|
}},
|
""contextOptions"": {{
|
""$id"": ""25"",
|
""contextType"": ""{modelname}"",
|
""contextFidelity"": ""Burst""
|
}},
|
""customAttributes"": {{
|
""$id"": ""26"",
|
""data"": {{}}
|
}}
|
}}"
|
});
|
try
|
{
|
dc.SaveChanges();
|
}
|
catch { }
|
}
|
}
|
|
|
private void SetTestData(Type modelType, Dictionary<string, List<object>> data, int count = 100)
|
{
|
int exist = 0;
|
if (data.ContainsKey(modelType.FullName))
|
{
|
exist = data[modelType.FullName].Count;
|
if(exist > 0)
|
return;
|
}
|
using (var dc = this.CreateNew())
|
{
|
Random r = new Random();
|
data[modelType.FullName] = new List<object>();
|
int retry = 0;
|
List<string> ids = new List<string>();
|
for (int i = 0; i < count-exist; i++)
|
{
|
var modelprops = modelType.GetRandomValuesForTestData();
|
var newobj = modelType.GetConstructor(Type.EmptyTypes).Invoke(null);
|
var idvalue = modelprops.Where(x => x.Key == "ID").Select(x=>x.Value).SingleOrDefault();
|
if (idvalue != null )
|
{
|
if (ids.Contains(idvalue.ToLower()) == false)
|
{
|
ids.Add(idvalue.ToLower());
|
}
|
else
|
{
|
retry++;
|
i--;
|
if (retry > count)
|
{
|
break;
|
}
|
continue;
|
}
|
}
|
foreach (var pro in modelprops)
|
{
|
if (pro.Value == "$fk$")
|
{
|
var fkpro = modelType.GetSingleProperty(pro.Key[0..^2]);
|
var fktype = fkpro?.PropertyType;
|
if (fktype != modelType && typeof(TopBasePoco).IsAssignableFrom(fktype)==true)
|
{
|
try
|
{
|
SetTestData(fktype, data, count);
|
newobj.SetPropertyValue(pro.Key, (data[fktype.FullName][r.Next(0, data[fktype.FullName].Count)] as TopBasePoco).GetID());
|
|
}
|
catch { }
|
}
|
}
|
else
|
{
|
var v = pro.Value;
|
if (v.StartsWith("\""))
|
{
|
v = v[1..];
|
}
|
if (v.EndsWith("\""))
|
{
|
v = v[..^1];
|
}
|
newobj.SetPropertyValue(pro.Key, v);
|
}
|
}
|
if(modelType == typeof(FileAttachment))
|
{
|
newobj.SetPropertyValue("Path", "./wwwroot/logo.png");
|
newobj.SetPropertyValue("SaveMode", "local");
|
newobj.SetPropertyValue("Length", 16728);
|
}
|
if (typeof(IBasePoco).IsAssignableFrom(modelType))
|
{
|
newobj.SetPropertyValue("CreateTime", DateTime.Now);
|
newobj.SetPropertyValue("CreateBy", "admin");
|
}
|
if (typeof(IPersistPoco).IsAssignableFrom(modelType))
|
{
|
newobj.SetPropertyValue("IsValid",true);
|
}
|
try
|
{
|
(dc as DbContext).Add(newobj);
|
data[modelType.FullName].Add(newobj);
|
}
|
catch
|
{
|
retry++;
|
i--;
|
if(retry > count)
|
{
|
break;
|
}
|
}
|
}
|
try
|
{
|
dc.SaveChanges();
|
}
|
catch { }
|
}
|
}
|
}
|
|
/// <summary>
|
/// DesignTimeFactory for EF Migration, use your full connection string,
|
/// EF will find this class and use the connection defined here to run Add-Migration and Update-Database
|
/// </summary>
|
public class DataContextFactory : IDesignTimeDbContextFactory<DataContext>
|
{
|
public DataContext CreateDbContext(string[] args)
|
{
|
return new DataContext("your full connection string", DBTypeEnum.SqlServer);
|
}
|
}
|
|
}
|
