597 lines
28 KiB
C#
Raw Normal View History

2025-08-13 11:14:39 +08:00
using DocumentFormat.OpenXml.EMMA;
using DocumentFormat.OpenXml.Office2010.Excel;
using Learun.Application.TwoDevelopment.ZZDT_EC;
using Learun.Util;
using Learun.Util.SqlSugar;
using Org.BouncyCastle.Ocsp;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web.Http;
namespace Learun.Application.Web.AppApi
{
/// <summary>
/// 关联关系的接口By YuXH。只需要给rel data的操作rel type的操作放到mvc的API即可暂时不需要给插件端开放
/// </summary>
[RoutePrefix("api/RelApi")]
[HandlerApiLogin(FilterMode.Ignore)]
public class RelApiController : WebApiControllerBase
{
#region
private ec_reltypeIBLL ec_reltypeIBLL = new ec_reltypeBLL();
private ec_enginedata_relIBLL ec_relDataBLL = new ec_enginedata_relBLL();
#endregion
#region refDef本身
/// <summary>
/// 根据关联关系的名字拿关联关系的Id
/// </summary>
/// <param name="RelName"></param>
/// <param name="projId"></param>
/// <returns></returns>
[HttpGet]
public IHttpActionResult GetRelDefByName(string RelName, string projId)
{
var data = ec_reltypeIBLL.GetList("{\"ProjectId\":\"" + projId + "\", \"RelTypeName\": \"" + RelName + "\"}").FirstOrDefault();
return Success(data);
}
/// <summary>
/// 所有Rel
/// </summary>
/// <param name="RelName"></param>
/// <param name="projId"></param>
/// <returns></returns>
[HttpGet]
public IHttpActionResult GetRelDefs(string projId)
{
var data = ec_reltypeIBLL.GetList("{\"ProjectId\":\"" + projId + "\"}");
return Success(data);
}
#endregion
#region engineData_rel
/// <summary>
/// 增加 对象和对象之间的关系。(BY YUXH)
/// 请求的Body中带上Json格式的ec_enginedata_relEntity数据集合End2IDs里放多个
/// </summary>
/// <param name="ProjectId"></param>
/// <returns></returns>
[HttpPost]
[HandlerApiLogin(FilterMode.Enforce)]
public IHttpActionResult SaveRelDataBatch(string ProjectId)
{
var asyncContent = Request.Content.ReadAsStringAsync().Result;
try
{
var entityCol = asyncContent.ToObject<IEnumerable<ec_enginedata_relEntity>>();
foreach (var relData in entityCol)
{
if (relData.End2IDs == null || relData.End2IDs.Count == 0)
{
relData.End2IDs = new List<string>
{
relData.RelEngineData2ID
};
}
2025-09-15 22:58:22 +08:00
ec_relDataBLL.SaveEntitys(ProjectId, relData.RelTypeID, relData.RelEngineData1ID, relData.End2IDs,relData.OPCPixel);
2025-08-13 11:14:39 +08:00
}
return Success("创建成功");
}
catch (Exception ex)
{
return Fail(ex.Message);
}
}
/// <summary>
/// 根据主键,删除某条关联关系
/// </summary>
/// <param name="ProjectId"></param>
/// <param name="RelDataId"></param>
/// <returns></returns>
[HttpGet]
[HandlerApiLogin(FilterMode.Enforce)]
public IHttpActionResult RemoveRelData(string ProjectId, string RelDataId)
{
ec_relDataBLL.DeleteEntity(ProjectId, RelDataId);
return Success("delete成功");
}
/// <summary>
/// 主力查询
/// </summary>
/// <param name="ProjectId"></param>
/// <param name="RelTypeId"></param>
/// <param name="ID1">1端的ID</param>
/// <param name="seq"></param>
/// <returns></returns>
[HttpGet]
[HandlerApiLogin(FilterMode.Ignore)]
public IHttpActionResult GetRelCollection(string ProjectId, string RelTypeId, string ID1 = "", int seq = 0)
{
if (!string.IsNullOrEmpty(ID1))
{
//查单一记录
var res = ec_relDataBLL.GetList("{ProjectId:\"" + ProjectId + "\",RelTypeID:\"" + RelTypeId + "\",RelEngineDataID:\"" + ID1 + "\"}");
return Success(res);
}
else
{
var res = ec_relDataBLL.GetList("{ProjectId:\"" + ProjectId + "\",RelTypeID:\"" + RelTypeId + "\"}");
return Success(res);
}
}
#endregion
#region Cable连接关系
/// <summary>
/// 查询电缆两侧的连接关系(BY YUXH)
/// </summary>
/// <param name="ProjectId"></param>
/// <param name="IDs">集合图纸id电缆句柄</param>
/// <returns></returns>
[HttpPost]
[HandlerApiLogin(FilterMode.Enforce)]
public IHttpActionResult GetCableConn(string ProjectId, [FromBody] List<CableConnRel> CablePixelIDs)
{
if (CablePixelIDs == null) { return Success(""); }
var RelTypeServ = new ec_reltypeBLL();
var relBll = new ec_enginedata_relBLL();
//relType是不是有
var RelTypeID = RelTypeServ.GetList("{\"ProjectId\":\"" + ProjectId + "\", \"RelType\": \"" + (int)enum_RelType._电缆 + "\"}").Select(x => x.RelTypeID).FirstOrDefault();
if (RelTypeID == null || RelTypeID.Count() == 0)
{
return Fail($"项目的关联类型中找不到“设备_电缆”,其RelType应该为0。");
}
var res = new List<CableConnRes>();
//var asyncContent = Request.Content.ReadAsStringAsync().Result;
try
{
//var relDataCol = asyncContent.ToObject<IEnumerable<CableConnRel>>();
foreach (var CablePixelID in CablePixelIDs)
{
res.Add(relBll.GetCableConn(CablePixelID, ProjectId));
}
return Success(res);
}
catch (Exception ex)
{
return Fail(ex.Message);
}
}
/// <summary>
/// 查询电缆整个链路上的连接(BY YUXH)
/// </summary>
/// <param name="ProjectId"></param>
/// <param name="CablePixelIDs">集合图纸id电缆句柄</param>
/// <returns></returns>
[HttpPost]
[HandlerApiLogin(FilterMode.Enforce)]
public IHttpActionResult GetCableWay(string ProjectId, [FromBody] List<CableConnRel> CablePixelIDs)
{
if (CablePixelIDs == null) { return Success(""); }
//serv
var pixelServ = new ec_enginedata_pixelService();
var RelTypeServ = new ec_reltypeBLL();
//relType是不是有
var RelTypeID = RelTypeServ.GetList("{\"ProjectId\":\"" + ProjectId + "\", \"RelType\": \"" + (int)enum_RelType._电缆 + "\"}").Select(x => x.RelTypeID).FirstOrDefault();
if (RelTypeID == null || RelTypeID.Count() == 0)
{
return Fail($"项目的关联类型中找不到“设备_电缆”,其RelType应该为0。");
}
var res = new LinkedList<object>();
//var asyncContent = Request.Content.ReadAsStringAsync().Result;
try
{
//var relDataCol = asyncContent.ToObject<IEnumerable<CableConnRel>>();
foreach (var CablePixelID in CablePixelIDs)
{
var CableWay = new LinkedList<object>();
//根据句柄和图纸先把工程id查出来先
var drawingID = CablePixelID.DrawingID;
var pixelID = CablePixelID.CablePixelID;
var EngineDataIDs = pixelServ.GetList("{\"ProjectId\":\"" + ProjectId + "\",\"PixelCode\":\"" + pixelID + "\",\"DrawingFileID\":\"" + drawingID + "\"}", ProjectId).Distinct();
2025-08-13 11:14:39 +08:00
if (EngineDataIDs != null && EngineDataIDs.Count() == 1)
{
var engineDataPixel = EngineDataIDs.First();
var CableID = engineDataPixel.EngineDataID;
ec_enginedata_relEntity End1;
ec_enginedata_relEntity End2;
string End1ID = "", End1Type = "", End1Tag = "";
string End2ID = "", End2Type = "", End2Tag = "";
//查单一记录
var existRel = ec_relDataBLL.GetList("{ProjectId:\"" + ProjectId + "\",RelType:\"" + (int)enum_RelType._电缆 + "\",RelEngineDataID:\"" + CableID + "\"}");
if (existRel.Count(x => x.RelEngineData1ID == CableID) == 1) // 电缆在end1代表该行记录的end2 是 设备
{
End2 = existRel.Where(x => x.RelEngineData1ID == CableID).FirstOrDefault();
End2ID = End2.RelEngineData2ID;
End2Type = End2.Type2;
End2Tag = End2.TagNumber2;
}
if (existRel.Count(x => x.RelEngineData2ID == CableID) == 1) // 电缆在end2代表该行记录的end1 是 设备
{
End1 = existRel.Where(x => x.RelEngineData2ID == CableID).FirstOrDefault();
End1ID = End1.RelEngineData1ID;
End1Type = End1.Type1;
End1Tag = End1.TagNumber1;
}
CableWay.AddLast(
new
{
ObjectTypeName = engineDataPixel.ObjectTypeName,
TagNumber = engineDataPixel.TagNumber,
ID = CableID,
}); //电缆自己
//上游去找
while (End1ID != "") //条件满足就循环,不满足跳出
{
var obj = new
{
ObjectTypeName = End1Type,
TagNumber = End1Tag,
ID = End1ID,
};
if (CableWay.Contains(obj))
{
End1ID = "";
continue; //避免回路
}
else
{
CableWay.AddFirst(obj); //上游
}
//查单一记录
existRel = ec_relDataBLL.GetList("{ProjectId:\"" + ProjectId + "\",RelType:\"" + (int)enum_RelType._电缆 + "\",RelEngineDataID:\"" + End1ID + "\"}");
if (existRel.Count(x => x.RelEngineData2ID == End1ID) == 1) // 在end2代表该行记录的end1 是 再上游的
{
End1 = existRel.Where(x => x.RelEngineData2ID == End1ID).FirstOrDefault();
End1ID = End1.RelEngineData1ID;
End1Type = End1.Type1;
End1Tag = End1.TagNumber1;
}
else if (existRel.Count(x => x.RelEngineData2ID == End1ID) == 0)
{
End1 = null;
End1ID = "";//没有上游了 可以停下了
}
//else if (existRel.Count(x => x.RelEngineData2ID == End1) > 1)
//{
//暂时不考虑
//}
}
//下游去找
while (End2ID != "") //条件满足就循环,不满足跳出
{
var obj = new
{
ObjectTypeName = End2Type,
TagNumber = End2Tag,
ID = End2ID,
};
if (CableWay.Contains(obj))
{
End2ID = "";
continue; //避免回路
}
else
{
CableWay.AddLast(obj); //下游
}
//查单一记录
existRel = ec_relDataBLL.GetList("{ProjectId:\"" + ProjectId + "\",RelType:\"" + (int)enum_RelType._电缆 + "\",RelEngineDataID:\"" + End2ID + "\"}");
if (existRel.Count(x => x.RelEngineData1ID == End2ID) == 1) // 在end2代表该行记录的end1 是 再上游的
{
End2 = existRel.Where(x => x.RelEngineData1ID == End2ID).FirstOrDefault();
End2ID = End2.RelEngineData2ID;
End2Type = End2.Type2;
End2Tag = End2.TagNumber2;
}
else if (existRel.Count(x => x.RelEngineData1ID == End2ID) == 0)
{
End2 = null;
End2ID = "";//没有上游了 可以停下了
}
//else if (existRel.Count(x => x.RelEngineData2ID == End1) > 1)
//{
//暂时不考虑
//}
}
}
else
{
return Fail($"根据句柄{pixelID}查询出的ec_enginedata_pixel有多个ID记录。");
}
res.AddLast(CableWay);
}
return Success(res);
}
catch (Exception ex)
{
return Fail(ex.Message);
}
}
/// <summary>
/// 查询电缆整个链路上的连接(BY YUXH)
/// </summary>
/// <param name="ProjectId"></param>
/// <param name="CablePixelIDs">集合图纸id电缆句柄</param>
/// <returns></returns>
[HttpPost]
[HandlerApiLogin(FilterMode.Enforce)]
public IHttpActionResult GetCableAllWay(string ProjectId, [FromBody] List<CableConnRel> CablePixelIDs)
{
if (CablePixelIDs == null) { return Success(""); }
var relServ = new ec_enginedata_relService();
var res = relServ.GetCableWay(ProjectId, CablePixelIDs);
return Success(res);
}
/// <summary>
/// 保存电缆连接关系专门不走SaveRelDataBatch。创建电缆时传2个连接修改电缆连接时传1个
/// </summary>
/// <param name="ProjectId"></param>
/// <param name="relDataCol">集合图纸id电缆句柄设备句柄是否起始</param>
/// <returns></returns>
[HttpPost]
[HandlerApiLogin(FilterMode.Enforce)]
public IHttpActionResult SaveCableConn(string ProjectId, [FromBody] IEnumerable<CableConnRel> relDataCol)
{
//起始设备 终止设备的属性定义
if (relDataCol == null) { return Success(""); }
//serv
var pixelServ = new ec_enginedata_pixelService();
var RelTypeServ = new ec_reltypeBLL();
//relType是不是有
var RelTypeID = RelTypeServ.GetList("{\"ProjectId\":\"" + ProjectId + "\", \"RelType\": \"" + (int)enum_RelType._电缆 + "\"}").Select(x => x.RelTypeID).FirstOrDefault();
if (RelTypeID == null || RelTypeID.Count() == 0)
{
return Fail($"项目的关联类型中找不到“设备_电缆”,其RelType应该为0。");
}
//var asyncContent = Request.Content.ReadAsStringAsync().Result;
try
{
List<CableConnRel> relDataColNotOPC = new List<CableConnRel>();
#region OPC_CABLE_CONN
if (relDataCol.Count() % 2 == 0)
{
for (int i = 0; i < relDataCol.Count(); i += 2)
{
// 取当前 2 个元素
var pairData = relDataCol.Skip(i).Take(2).ToList();
if (pairData.First().CablePixelID != pairData.Last().CablePixelID)
{
return Fail("无效。2个电缆的句柄不是同一个电缆的。");
}
var tbRelName = ProjectSugar.TableName<ec_enginedata_relEntity>(ProjectId);
var tbPixelName = ProjectSugar.TableName<ec_enginedata_pixelEntity>(ProjectId);
var tbName = ProjectSugar.TableName<ec_objecttypeEntity>(ProjectId);
var opcTypeId = SqlSugarHelper.Db.Queryable<ec_objecttypeEntity>().AS(tbName).ToList().FirstOrDefault(x => x.ObjectTypeName == GlobalObject.objectType_OPC);
if (opcTypeId == null) return Fail("未定义OPC对象类型。");
var tagTbName = ProjectSugar.TableName<ec_enginedataEntity>(ProjectId);
var tag = SqlSugarHelper.Db.Queryable<ec_enginedataEntity>().AS(tagTbName).
InnerJoin<ec_enginedata_pixelEntity>((a, b) => a.EngineDataID == b.EngineDataID && b.DrawingFileID == pairData.First().DrawingID).
AS<ec_enginedata_pixelEntity>(tbPixelName).
Where((a, b) => b.PixelCode == pairData.First().TagPixelID).First();
var tag2 = SqlSugarHelper.Db.Queryable<ec_enginedataEntity>().AS(tagTbName).
InnerJoin<ec_enginedata_pixelEntity>((a, b) => a.EngineDataID == b.EngineDataID && b.DrawingFileID == pairData.First().DrawingID).
AS<ec_enginedata_pixelEntity>(tbPixelName).
Where((a, b) => b.PixelCode == pairData.Last().TagPixelID).First();
var cable = SqlSugarHelper.Db.Queryable<ec_enginedataEntity>().AS(tagTbName).
InnerJoin<ec_enginedata_pixelEntity>((a, b) => a.EngineDataID == b.EngineDataID && b.DrawingFileID == pairData.First().DrawingID).
AS<ec_enginedata_pixelEntity>(tbPixelName).
Where((a, b) => b.PixelCode == pairData.Last().CablePixelID).First();
bool hasOPC = false;
if (tag != null && tag2 != null && cable != null)
{
if (tag.ObjectTypeID == opcTypeId.ObjectTypeID)
{
//有opc
hasOPC = true;
//现有记录
Console.WriteLine("");
var relTbName = ProjectSugar.TableName<ec_enginedata_relEntity>(ProjectId);
var existCableOPCRel = SqlSugarHelper.Db.Queryable<ec_enginedata_relEntity>().AS(relTbName).
Where(x => x.RelTypeID == RelTypeID && x.OPCPixel == pairData.First().TagPixelID).ToList();
SqlSugarHelper.Db.Deleteable<ec_enginedata_relEntity>(existCableOPCRel).AS(tbRelName).
ExecuteCommand();
var model = new ec_enginedata_relEntity();
model.Create();
model.RelTypeID = RelTypeID;
model.RelEngineData1ID = tag.EngineDataID;//OPC
model.RelEngineData2ID = cable.EngineDataID;
model.OPCPixel = pairData.First().TagPixelID;
SqlSugarHelper.Db.Insertable<ec_enginedata_relEntity>(model).AS(tbRelName).ExecuteCommand();
var model2 = new ec_enginedata_relEntity();
model2.Create();
model2.RelTypeID = RelTypeID;
model2.RelEngineData1ID = cable.EngineDataID;
model2.RelEngineData2ID = tag2.EngineDataID;// equip
model2.OPCPixel = pairData.First().TagPixelID;
SqlSugarHelper.Db.Insertable<ec_enginedata_relEntity>(model2).AS(tbRelName).ExecuteCommand();
}
if (tag2.ObjectTypeID == opcTypeId.ObjectTypeID)
{
hasOPC = true;
//现有记录
Console.WriteLine("");
var relTbName = ProjectSugar.TableName<ec_enginedata_relEntity>(ProjectId);
var existCableOPCRel = SqlSugarHelper.Db.Queryable<ec_enginedata_relEntity>().AS(relTbName).
Where(x => x.RelTypeID == RelTypeID && x.OPCPixel == pairData.Last().TagPixelID).ToList();
SqlSugarHelper.Db.Deleteable<ec_enginedata_relEntity>(existCableOPCRel).AS(tbRelName).
ExecuteCommand();
var model = new ec_enginedata_relEntity();
model.Create();
model.RelTypeID = RelTypeID;
model.RelEngineData1ID = cable.EngineDataID;
model.RelEngineData2ID = tag2.EngineDataID; //OPC
model.OPCPixel = pairData.Last().TagPixelID;
SqlSugarHelper.Db.Insertable<ec_enginedata_relEntity>(model).AS(tbRelName).ExecuteCommand();
var model2 = new ec_enginedata_relEntity();
model2.Create();
model2.RelTypeID = RelTypeID;
model2.RelEngineData1ID = tag.EngineDataID; // equip
model2.RelEngineData2ID = cable.EngineDataID;
model2.OPCPixel = pairData.Last().TagPixelID;
SqlSugarHelper.Db.Insertable<ec_enginedata_relEntity>(model2).AS(tbRelName).ExecuteCommand();
}
}
if (hasOPC == false)
{
relDataColNotOPC.AddRange(pairData);
}
}
2025-09-15 22:58:22 +08:00
2025-08-13 11:14:39 +08:00
relDataCol = relDataColNotOPC;
}
else
{
}
#endregion
if (relDataCol == null)
{
return Success("创建成功");
}
//var relDataCol = asyncContent.ToObject<IEnumerable<CableConnRel>>();
foreach (var relData in relDataCol.Where(x => x.NeedRemove == true))
{
if (string.IsNullOrEmpty(relData.TagPixelID) || string.IsNullOrEmpty(relData.CablePixelID))
{
return Fail($"位号图元 或 电缆图元的句柄不能为空。");
}
//根据句柄和图纸先把工程id查出来先
//获取工程数据图元数据
var EngineDataIDs = pixelServ.GetList("{\"ProjectId\":\"" + ProjectId + "\",\"PixelCode\":\"" + relData.TagPixelID + "\",\"DrawingFileID\":\"" + relData.DrawingID + "\"}", ProjectId).
2025-08-13 11:14:39 +08:00
Select(x => x.EngineDataID).Distinct();
var CableIDs = pixelServ.GetList("{\"ProjectId\":\"" + ProjectId + "\",\"PixelCode\":\"" + relData.CablePixelID + "\",\"DrawingFileID\":\"" + relData.DrawingID + "\"}", ProjectId).
2025-08-13 11:14:39 +08:00
Select(x => x.EngineDataID).Distinct();
if (EngineDataIDs != null && EngineDataIDs.Count() == 1 && CableIDs != null && CableIDs.Count() == 1)
{
var TagID = EngineDataIDs.First();
var CableID = CableIDs.First();
if (relData.IsEnd1)
{
ec_relDataBLL.DeleteEntity(ProjectId, RelTypeID, "", CableID);
}
else
{
ec_relDataBLL.DeleteEntity(ProjectId, RelTypeID, CableID, "");
}
}
else
{
return Fail($"根据句柄{relData.CablePixelID} 和 {relData.TagPixelID}查询出的ec_enginedata_pixel有多个工程ID记录。");
}
}
foreach (var relData in relDataCol.Where(x => x.NeedRemove == false))
{
//根据句柄和图纸先把工程id查出来先
//获取工程数据图元数据
2025-09-15 22:58:22 +08:00
var EngineDataIDs = pixelServ.GetList("{\"ProjectId\":\"" + ProjectId + "\",\"PixelCode\":\"" + relData.TagPixelID + "\",\"DrawingFileID\":\"" + relData.DrawingID + "\"}", ProjectId).
2025-08-13 11:14:39 +08:00
Select(x => x.EngineDataID).Distinct();
var CableIDs = pixelServ.GetList("{\"ProjectId\":\"" + ProjectId + "\",\"PixelCode\":\"" + relData.CablePixelID + "\",\"DrawingFileID\":\"" + relData.DrawingID + "\"}", ProjectId).
2025-08-13 11:14:39 +08:00
Select(x => x.EngineDataID).Distinct();
if (EngineDataIDs != null && EngineDataIDs.Count() == 1 && CableIDs != null && CableIDs.Count() == 1)
{
var TagID = EngineDataIDs.First();
var CableID = CableIDs.First();
2025-09-15 22:58:22 +08:00
if (relData.IsEnd1)//电缆的起始端连接信息设备在end1电缆在end2
2025-08-13 11:14:39 +08:00
{
2025-09-15 22:58:22 +08:00
ec_relDataBLL.SaveEntitys(ProjectId, RelTypeID, new List<string> { TagID }, CableID, relData.TagPixelID, true);
2025-08-13 11:14:39 +08:00
}
else
{
2025-09-15 22:58:22 +08:00
ec_relDataBLL.SaveEntitys(ProjectId, RelTypeID, CableID, new List<string> { TagID }, relData.TagPixelID, true);
2025-08-13 11:14:39 +08:00
}
}
else
{
if (EngineDataIDs == null || EngineDataIDs.Count() == 0)
{
return Fail($"根据句柄 {relData.TagPixelID} 查询出的工程ID,只有0个ID记录。");
}
if (CableIDs == null || CableIDs.Count() == 0)
{
return Fail($"根据句柄 {relData.CablePixelID} 查询出的工程ID,只有0个ID记录。");
}
if (EngineDataIDs != null || EngineDataIDs.Count() > 1)
{
return Fail($"根据句柄 {relData.TagPixelID} 查询出的工程ID,多于1个记录共有{EngineDataIDs.Count()}个。");
}
if (CableIDs != null || CableIDs.Count() > 1)
{
return Fail($"根据句柄 {relData.CablePixelID} 查询出的工程ID,多于1个记录共有{CableIDs.Count()}个。");
}
}
}
this.Logger.Info("SaveCableConn OK");
return Success("创建成功");
}
catch (Exception ex)
{
this.Logger.Error(ex.Message + " ||| " + ex.StackTrace);
return Fail(ex.Message);
}
}
#endregion
}
}