using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using TProduct.HttpClient;
|
|
namespace TProduct.DAL
|
{
|
/// <summary>
|
/// 测试项目
|
/// </summary>
|
public class TestProjectBase : BaseLiteSqlDAL_DataSync<Entity.TestProjectBase>
|
{
|
public override ISqlSugarClient Connection
|
{
|
get { return TProduct.DAL.SQLite.ConfigHelper.MainConn; }
|
}
|
|
/// <summary>
|
/// 插入包含扩展信息
|
/// </summary>
|
public List<Entity.TestProjectItemView> InsertEx(Entity.TestProjectBase main,
|
List<Entity.TestProjectItemBundleTree> trees)
|
{
|
if (main == null)
|
return default;
|
|
|
using (ISqlSugarClient db = Connection)
|
{
|
long project_id = 0;
|
|
try
|
{
|
|
if (trees == null || trees.Count() == 0)
|
{
|
db.Ado.BeginTran();
|
project_id = db.Insertable(main).ExecuteReturnSnowflakeId();
|
if (project_id < 1)
|
{
|
db.Ado.RollbackTran();
|
return default;
|
}
|
main.ID = project_id;
|
}
|
else
|
{
|
db.Ado.BeginTran();
|
project_id = db.Insertable(main).ExecuteReturnSnowflakeId();
|
if (project_id < 1)
|
{
|
db.Ado.RollbackTran();
|
return default;
|
}
|
main.ID = project_id;
|
|
|
//
|
foreach (var tree in trees)
|
{
|
if (tree.Items == null || tree.Items.Count <= 0)
|
{
|
continue;
|
}
|
|
tree.Bundle.ProjectID = main.ID;
|
tree.Bundle.ItemCount = tree.Items.Count;
|
|
tree.Bundle.ID = db.Insertable(tree.Bundle).ExecuteReturnSnowflakeId();
|
if (tree.Bundle.ID <= 0)
|
{
|
db.Ado.RollbackTran();
|
return default;
|
}
|
|
for (int i = 0; i < tree.Items.Count; i++)
|
{
|
tree.Items[i].BundleID = tree.Bundle.ID;
|
tree.Items[i].ID = db.Insertable(tree.Items[i]).
|
ExecuteReturnSnowflakeId();
|
if (tree.Items[i].ID <= 0)
|
{
|
db.Ado.RollbackTran();
|
return default;
|
}
|
}
|
|
}
|
}
|
|
db.Ado.CommitTran();
|
|
if (TProduct.CorpConfig.Instance.RealTimeRemoteService.IsSynMainData)
|
{
|
HttpClientHelper.Build("TestProjectBase", "Insert@V1.0").Post<bool>(main);
|
if (trees != null && trees.Count > 0)
|
{
|
var bundles = trees.Select(x => x.Bundle).ToList();
|
if (bundles != null && bundles.Count > 0)
|
{
|
HttpClientHelper.Build("TestProjectItemBundle", "Inserts@V1.0").Post<bool>(bundles);
|
}
|
var items = trees.Where(x => x.Items != null && x.Items.Count > 0).SelectMany(x => x.Items).ToList();
|
if (items != null && items.Count > 0)
|
{
|
HttpClientHelper.Build("TestProjectItem", "Inserts@V1.0").Post<bool>(items);
|
}
|
}
|
}
|
|
|
}
|
catch
|
{
|
db.Ado.RollbackTran();
|
return default;
|
}
|
|
|
return db.Queryable<Entity.TestProjectItemView>().Where(x => x.ProjectID == project_id)?.ToList();
|
}
|
|
|
|
|
}
|
|
/// <summary>
|
/// 编号是否存在
|
/// </summary>
|
public bool IsExistCode(string Code)
|
{
|
using (ISqlSugarClient db = Connection)
|
{
|
return db.Queryable<Entity.TestProjectBase>().Where(x => x.Code == Code).Any();
|
}
|
}
|
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="ID"></param>
|
/// <param name="JudgeResult"></param>
|
/// <returns></returns>
|
public bool UpdateJudgeResult(long ID, int JudgeResult)
|
{
|
using (ISqlSugarClient db = Connection)
|
{
|
var result = db.
|
Updateable(new Entity.TestProjectBase() { ID = ID, JudgeResult = JudgeResult }).
|
UpdateColumns(it => new { it.JudgeResult }).ExecuteCommand();
|
|
if (result > 0 && TProduct.CorpConfig.Instance.RealTimeRemoteService.IsSynMainData)
|
{
|
var dto = GetByID(ID);
|
HttpClientHelper.Build(this.TableName, "Update@V1.0").Put<bool>(dto);
|
}
|
|
return true;
|
}
|
}
|
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="ID"></param>
|
/// <param name="ReportFileNO"></param>
|
/// <returns></returns>
|
public bool UpdateReportFileNO(long ID, string ReportFileNO)
|
{
|
using (ISqlSugarClient db = Connection)
|
{
|
var result = db.
|
Updateable(new Entity.TestProjectBase() { ID = ID, ReportFileNO = ReportFileNO }).
|
UpdateColumns(it => new { it.ReportFileNO }).ExecuteCommand();
|
|
if (result > 0 && TProduct.CorpConfig.Instance.RealTimeRemoteService.IsSynMainData)
|
{
|
var dto = GetByID(ID);
|
HttpClientHelper.Build(this.TableName, "Update@V1.0").Put<bool>(dto);
|
}
|
|
return true;
|
}
|
}
|
|
/// <summary>
|
/// 通拓id列表获取
|
/// </summary>
|
/// <returns></returns>
|
public List<Entity.TestProjectBase> GetByProductType(int ProductType, DateTime StartTime, DateTime EndTime)
|
{
|
using (ISqlSugarClient db = Connection)
|
{
|
return db.Queryable<Entity.TestProjectBase>().Where(x => x.ProductType == ProductType && x.CreateTime >= StartTime && x.CreateTime <= EndTime)?.ToList();
|
}
|
}
|
/// <summary>
|
/// 通拓id列表获取
|
/// </summary>
|
/// <returns></returns>
|
public List<Entity.TestProjectBase> GetByProductType(int ProductType, List<long> ProductID, DateTime StartTime, DateTime EndTime)
|
{
|
if (ProductID == null || ProductID.Count() == 0)
|
{
|
return GetByProductType(ProductType, StartTime, EndTime);
|
}
|
using (ISqlSugarClient db = Connection)
|
{
|
return db.Queryable<Entity.TestProjectBase>().Where(x =>
|
x.ProductType == ProductType
|
&& ProductID.Contains(x.ProductID)
|
&& x.CreateTime >= StartTime
|
&& x.CreateTime <= EndTime)?.ToList();
|
}
|
}
|
|
|
/// <summary>
|
/// 通拓id列表获取
|
/// </summary>
|
/// <returns></returns>
|
public List<Entity.TestProjectBase> GetBySeriesID(long SeriesID)
|
{
|
using (ISqlSugarClient db = Connection)
|
{
|
return db.Queryable<Entity.TestProjectBase>().Where(x => x.SeriesID == SeriesID)?.ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通拓id列表获取
|
/// </summary>
|
/// <returns></returns>
|
public List<Entity.TestProjectBase> GetByProductID(long ProductID)
|
{
|
using (ISqlSugarClient db = Connection)
|
{
|
return db.Queryable<Entity.TestProjectBase>().Where(x => x.ProductID == ProductID)?.ToList();
|
}
|
}
|
|
public void AlertView()
|
{
|
using (ISqlSugarClient db = Connection)
|
{
|
db.Ado.ExecuteCommand("DROP VIEW TestProjectItemView");
|
db.Ado.ExecuteCommand (@"CREATE VIEW TestProjectItemView AS SELECT
|
TestProjectBase.ProductType,
|
TestProjectBase.SeriesID,
|
TestProjectBase.ProductID,
|
TestProjectBase.PartID,
|
TestProjectBase.UseStatus AS ProjectUseStatus,
|
TestProjectBase.CreateUserID AS ProjectCreateUserID,
|
TestProjectBase.CreateTime AS ProjectCreateTime,
|
TestProjectBase.Code AS ProjectCode,
|
TestProjectBase.Name AS ProjectName,
|
TestProjectBase.IsFixed,
|
TestProjectBase.JudgeResult AS ProjectJudgeResult,
|
TestProjectBase.ReportFileNO,
|
TestProjectBase.ProjectParasStr,
|
TestProjectBase.AlarmSettingStr,
|
TestProjectBase.IStationInfoStr,
|
TestProjectBase.IStationID,
|
TestProjectBase.IStationReportFileNO,
|
|
TestProjectItemBundle.ProjectID,
|
TestProjectItemBundle.ID AS BundleID,
|
TestProjectItemBundle.ItemCount,
|
TestProjectItemBundle.TestType,
|
TestProjectItemBundle.TestStandardID,
|
TestProjectItemBundle.TestGradeID,
|
TestProjectItemBundle.BenchID,
|
TestProjectItem.ID AS ItemID,
|
TestProjectItem.Code AS ItemCode,
|
TestProjectItem.Name AS ItemName,
|
TestProjectItem.UseStatus AS ItemUseStatus,
|
TestProjectItem.CreateUserID AS ItemCreateUserID,
|
TestProjectItem.CreateTime AS ItemCreateTime,
|
TestProjectItem.LastTestUserID,
|
TestProjectItem.TestStartTime,
|
TestProjectItem.TestEndTime,
|
TestProjectItem.LogContent AS ItemLogContent,
|
TestProjectItem.JudgeResult AS ItemJudgeResult,
|
TestProjectItem.TestTarget AS ItemTestTarget,
|
TestProjectItem.ItemParas,
|
TestProjectItem.CoordinateParas,
|
TestProjectItem.PointNumber,
|
TestProjectItem.AutoTestInfoStr,
|
TestProjectItem.DurabilityTestInfoStr,
|
TestProjectItem.InstrumentInfoStr,
|
TestProjectItem.ElectricInfoStr,
|
TestProjectItem.TestResult AS ItemTestResult,
|
TestProjectItem.ParallelInfoStr
|
FROM
|
TestProjectBase
|
INNER JOIN TestProjectItemBundle ON TestProjectBase.ID = TestProjectItemBundle.ProjectID
|
INNER JOIN TestProjectItem ON TestProjectItemBundle.ID = TestProjectItem.BundleID");
|
}
|
}
|
|
}
|
}
|
