wenkai.chen/tnb.server
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调整相关类命名空间，及接口命名规范

Browse Source
This commit is contained in:
DEVICE8\12494
2023-04-26 09:58:10 +08:00
parent b1f04f8a43
commit 26d6e12e35
16 changed files with 138 additions and 92 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Consts/DictionaryConstants.cs
View File

@@ -4,7 +4,7 @@ using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tnb.ProductionMgr.Entitys.新文件夹
namespace Tnb.ProductionMgr.Entitys.Consts
{
public class DictionaryConstants
{

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/EquipmentListOutput.cs
View File

@@ -5,7 +5,7 @@ using System.Text;
using System.Threading.Tasks;
using Tnb.ProductionMgr.Entitys.Entity;
namespace Tnb.ProductionMgr.Entitys.Dto.PrdManage
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 设备列表输出参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/MoCrInput.cs
View File

@@ -4,7 +4,7 @@ using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tnb.ProductionPlanMgr.Entitys.Dto.WorkOrder
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 生产工单下发输入参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/MoldListOutput.cs
View File

@@ -5,7 +5,7 @@ using System.Text;
using System.Threading.Tasks;
using Tnb.ProductionMgr.Entitys.Entity;
namespace Tnb.ProductionMgr.Entitys.Dto.WorkOrder
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 模具列表输出参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/PrdTaskOperInput.cs
View File

@@ -4,7 +4,7 @@ using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tnb.ProductionMgr.Entitys.Dto.PrdManage
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 生产操作记录查询参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/PrdTaskOperOutput.cs
View File

@@ -5,7 +5,7 @@ using System.Text;
using System.Threading.Tasks;
using Tnb.ProductionMgr.Entitys.Entity;
namespace Tnb.ProductionMgr.Entitys.Dto.PrdManage
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 生产操作记录输出类

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/PrdTaskReleaseUpInput.cs
View File

@@ -4,7 +4,7 @@ using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tnb.ProductionMgr.Entitys.Dto.PrdManage
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 生产任务单下发输入参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/PrdTaskSortOutput.cs
View File

@@ -5,7 +5,7 @@ using System.Text;
using System.Threading.Tasks;
using Tnb.ProductionMgr.Entitys.Entity;
namespace Tnb.ProductionMgr.Entitys.Dto.PrdManage
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 生产任务重新排序输出参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/ProductionSchedulingCrInput.cs
View File

@@ -4,7 +4,7 @@ using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tnb.ProductionMgr.Entitys.Dto.WorkOrder
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 生产工单排产输入参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/TaskOperRecordOutput.cs
View File

@@ -5,7 +5,7 @@ using System.Text;
using System.Threading.Tasks;
using Tnb.ProductionMgr.Entitys.Entity;
namespace Tnb.ProductionMgr.Entitys.Dto.PrdManage
namespace Tnb.ProductionMgr.Entitys.Dto
{
public class TaskOperRecordOutput
{

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Dto/PrdManage/TransferPlatformUpInput.cs
View File

@@ -5,7 +5,7 @@ using System.Security.Principal;
using System.Text;
using System.Threading.Tasks;
namespace Tnb.ProductionMgr.Entitys.Dto.PrdManage
namespace Tnb.ProductionMgr.Entitys.Dto
{
/// <summary>
/// 转移机台输入参数

2
ProductionMgr/Tnb.ProductionMgr.Entitys/Mapper/Mapper.cs
View File

@@ -1,5 +1,5 @@
using Mapster;
using Tnb.ProductionMgr.Entitys.Dto.WorkOrder;
using Tnb.ProductionMgr.Entitys.Dto;
using Tnb.ProductionMgr.Entitys.Entity;
namespace Tnb.ProductionMgr.Entitys.Mapper

4
ProductionMgr/Tnb.ProductionMgr.Interfaces/IPrdMoService.cs
View File

@@ -1,6 +1,6 @@
using Tnb.ProductionPlanMgr.Entitys.Dto.WorkOrder;
using Tnb.ProductionMgr.Entitys.Dto;
namespace Tnb.ProductionPlanMgr.Interfaces
namespace Tnb.ProductionMgr.Interfaces
{
/// <summary>
/// 工单生成

176
ProductionMgr/Tnb.ProductionMgr/PrdMoService.cs
View File

@@ -1,27 +1,17 @@
using System.Dynamic;
using Aop.Api.Domain;
using JNPF.Common.Core.Manager;
using JNPF.Common.Extension;
using JNPF.Common.Filter;
using JNPF.Common.Core.Manager;
using JNPF.Common.Security;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.FriendlyException;
using JNPF.Logging;
using JNPF.Systems.Entitys.System;
using JNPF.Systems.Interfaces.System;
using Mapster;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using NPOI.OpenXmlFormats.Shared;
using Senparc.Weixin.Work.AdvancedAPIs.OaDataOpen;
using SqlSugar;
using Tnb.ProductionMgr.Entitys.Dto.PrdManage;
using Tnb.ProductionMgr.Entitys.Dto.WorkOrder;
using Tnb.ProductionMgr.Entitys.Consts;
using Tnb.ProductionMgr.Entitys.Dto;
using Tnb.ProductionMgr.Entitys.Entity;
using Tnb.ProductionMgr.Entitys.新文件夹;
using Tnb.ProductionPlanMgr.Entitys.Dto.WorkOrder;
using Tnb.ProductionPlanMgr.Interfaces;
using Tnb.ProductionMgr.Interfaces;
namespace Tnb.ProductionPlanMgr
{
@@ -71,7 +61,7 @@ namespace Tnb.ProductionPlanMgr
/// <br/> }
/// <br/>]
/// </remarks>
[HttpGet("moldlist/{itemId}")]
[HttpGet("{itemId}")]
public async Task<dynamic> GetMoldListByItemId(string itemId)
{
var db = _repository.AsSugarClient();
@@ -95,7 +85,7 @@ namespace Tnb.ProductionPlanMgr
/// </summary>
/// <param name="moldId"></param>
/// <returns></returns>
[HttpGet("equipments/{moldId}")]
[HttpGet("{moldId}")]
public async Task<dynamic> GetEquipmentListByMoldId(string moldId)
{
var items = await _repository.AsSugarClient().Queryable<EqpEquipment>()
@@ -132,7 +122,7 @@ namespace Tnb.ProductionPlanMgr
/// <br/> }
/// <br/>]
/// </remarks>
[HttpGet("sort/{eqpId}")]
[HttpGet("{eqpId}")]
public async Task<dynamic> PrdTaskSort(string eqpId)
{
var taskStatusDic = await _dictionaryDataService.GetDicByTypeId(DictionaryConstants.PrdTaskStatusTypeId);
@@ -158,7 +148,7 @@ namespace Tnb.ProductionPlanMgr
/// </summary>
/// <param name="taskId">任务ID</param>
/// <returns></returns>
[HttpGet("record/{taskId}")]
[HttpGet("{taskId}")]
public async Task<dynamic> GetMoOperRecord(string taskId)
{
var list = await _repository.AsSugarClient().Queryable<PrdTaskLog>().Where(it => it.id == taskId).ToListAsync();
@@ -177,7 +167,7 @@ namespace Tnb.ProductionPlanMgr
/// </summary>
/// <param name="input">生产工单下发输入参数</param>
/// <returns></returns>
[HttpPut("workorder-issue")]
[HttpPut]
public async Task<dynamic> WorkOrderIssue(MoCrInput input)
{
if (input is null)
@@ -205,7 +195,7 @@ namespace Tnb.ProductionPlanMgr
/// </summary>
/// <param name="input">关联同组工单输入参数</param>
/// <returns></returns>
[HttpPost("relevancy")]
[HttpPost]
public async Task<dynamic> RelevancySameGroupMo(MoCrInput input)
{
(bool executeRes, string errMsg) multi = (true, "");
@@ -255,7 +245,7 @@ namespace Tnb.ProductionPlanMgr
/// </summary>
/// <param name="input">取消关联输入参数</param>
/// <returns></returns>
[HttpPost("CanelRelevancy")]
[HttpPost]
public async Task<dynamic> CanelRelevancy(MoCrInput input)
{
return await _repository.AsSugarClient().Updateable<PrdMo>()
@@ -284,7 +274,7 @@ namespace Tnb.ProductionPlanMgr
/// </param>
/// <returns></returns>
[HttpPost("scheduling")]
[HttpPost]
public async Task<dynamic> ProductionScheduling(ProductionSchedulingCrInput input)
{
var row = -1;
@@ -292,51 +282,131 @@ namespace Tnb.ProductionPlanMgr
{
input.id ??= SnowflakeIdHelper.NextId();
var entity = input.Adapt<PrdTask>();
entity.status = "ToBeScheduled"; //任务单状态默认，待排产
entity.status = DictionaryConstants.ToBeStartedEnCode; //任务单状态默认，待排产
entity.create_id = _userManager.UserId;
entity.create_time = DateTime.Now;
entity.prd_task_id = input.id;
var db = _repository.AsSugarClient();
try
{
await db.Ado.BeginTranAsync();
row = await db.Storageable(entity).ExecuteCommandAsync();
var taskLogEntity = input.Adapt<PrdTaskLog>();
taskLogEntity.id ??= SnowflakeIdHelper.NextId();
taskLogEntity.task_id = input.id;
taskLogEntity.status ??= "ToBeStarted";
taskLogEntity.create_id = _userManager.UserId;
taskLogEntity.create_time = DateTime.Now;
taskLogEntity.operator_name = _userManager.RealName;
//任务状态变更时插入操作记录
if (!db.Queryable<PrdTaskLog>().Where(it => it.task_id == input.id && it.status == taskLogEntity.status).Any())
List<PrdMo> entities = new();
//根据工单Id查询同组工单号，进行同组工单排产处理
var combineMoCodes = await db.Queryable<PrdMo>().Where(it => it.id == input.mo_id).Select(it => it.combine_mo_code).Distinct().ToListAsync();
if (combineMoCodes?.Count > 0)
{
row = await db.Insertable(taskLogEntity).ExecuteCommandAsync();
entities = await db.Queryable<PrdMo>().Where(it => combineMoCodes.Contains(it.combine_mo_code)).ToListAsync();
}
await db.Ado.BeginTranAsync();
//同组工单排产
if (entities.Count > 0)
{
var icmoEntities = entities.Adapt<List<PrdTask>>();
icmoEntities.ForEach(x =>
{
x.id = SnowflakeIdHelper.NextId();
x.status = DictionaryConstants.ToBeStartedEnCode; //任务单状态默认，待排产
x.create_id = _userManager.UserId;
x.create_time = DateTime.Now;
x.prd_task_id = input.id;
});
row = await db.Storageable(entities).ExecuteCommandAsync();
var icmoRecords = icmoEntities.Adapt<List<PrdTaskLog>>();
icmoRecords.ForEach(x =>
{
x.id ??= SnowflakeIdHelper.NextId();
x.task_id = input.id;
x.status ??= "ToBeStarted";
x.create_id = _userManager.UserId;
x.create_time = DateTime.Now;
x.operator_name = _userManager.RealName;
});
var icmoIds = icmoRecords.Select(it => it.id).ToList();
var statusMany = icmoRecords.Select(it => it.status).ToList();
//任务状态变更时插入操作记录
var logEntities = await db.Queryable<PrdTaskLog>().Where(it => !icmoIds.Contains(it.id) && !statusMany.Contains(it.status)).ToListAsync();
row = await db.Insertable(logEntities).ExecuteCommandAsync();
}
else
{
row = await db.Storageable(entity).ExecuteCommandAsync();
var taskLogEntity = input.Adapt<PrdTaskLog>();
taskLogEntity.id ??= SnowflakeIdHelper.NextId();
taskLogEntity.task_id = input.id;
taskLogEntity.status ??= "ToBeStarted";
taskLogEntity.create_id = _userManager.UserId;
taskLogEntity.create_time = DateTime.Now;
taskLogEntity.operator_name = _userManager.RealName;
//任务状态变更时插入操作记录
if (!db.Queryable<PrdTaskLog>().Where(it => it.task_id == input.id && it.status == taskLogEntity.status).Any())
{
row = await db.Insertable(taskLogEntity).ExecuteCommandAsync();
}
}
if (row > 0)
{
var obj = (await db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id));
obj.input_qty += entity.scheduled_qty;
var moStatus = "";
//判断，已排产数量>=计划数量时将状态改为 已排产
if (obj.input_qty >= obj.plan_qty)
if (combineMoCodes?.Count > 0)
{
moStatus = MoStatus.AlreadyId;
var moList = await db.Queryable<PrdMo>().Where(it => combineMoCodes.Contains(it.combine_mo_code)).ToListAsync();
var icmoList = moList.Adapt<List<PrdTask>>();
var combinePlanQty = icmoList.Sum(x => x.plan_qty); //合并工单后的计划数量
var combineScheduledQty = icmoList.Sum(x => x.scheduled_qty); //合并后的已排产数量
if (combineScheduledQty < combinePlanQty)
{
icmoList.ForEach(x =>
{
var item = moList.Find(xx => xx.id == x.mo_id);
if (item != null)
{
item.input_qty += x.scheduled_qty;
item.mo_status = MoStatus.WaitProductId;
}
});
}
else
{
//如果已排产数量大于计划数量，修改工单状态为，待开工
if (combineScheduledQty >= combinePlanQty)
{
icmoList.ForEach(x =>
{
var item = moList.Find(xx => xx.id == x.mo_id);
if (item != null)
{
item.input_qty += x.scheduled_qty;
item.mo_status = MoStatus.AlreadyId;
}
});
}
}
row = await db.Updateable(moList).ExecuteCommandAsync();
}
else
{
//修改工单状态为待排产，同事修改已排产数量
moStatus = MoStatus.WaitProductId;
var obj = (await db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id));
obj.input_qty += entity.scheduled_qty;
var moStatus = "";
//判断，已排产数量>=计划数量时将状态改为 已排产
if (obj.input_qty >= obj.plan_qty)
{
moStatus = MoStatus.AlreadyId;
}
else
{
//修改工单状态为待排产，同事修改已排产数量
moStatus = MoStatus.WaitProductId;
}
row = await db.Updateable<PrdMo>().SetColumns(it => new PrdMo
{
mo_status = moStatus,
input_qty = obj.input_qty
})
.Where(it => it.id == entity.mo_id).ExecuteCommandAsync();
}
row = await db.Updateable<PrdMo>().SetColumns(it => new PrdMo
{
mo_status = moStatus,
input_qty = obj.input_qty
})
.Where(it => it.id == entity.mo_id).ExecuteCommandAsync();
}
await db.Ado.CommitTranAsync();
@@ -353,7 +423,7 @@ namespace Tnb.ProductionPlanMgr
/// 生产任务下发
/// </summary>
/// <returns></returns>
[HttpPost("task-release")]
[HttpPost]
public async Task<dynamic> PrdTaskRelease(PrdTaskReleaseUpInput input)
{
if (input is null)
@@ -379,7 +449,7 @@ namespace Tnb.ProductionPlanMgr
.SetColumns(it => new PrdTask { eqp_id = input.eqp_id })
.Where(it => it.id == input.icmo_id)
.ExecuteCommandHasChangeAsync();
}
}
#endregion
}

3
ProductionMgr/Tnb.ProductionMgr/WorkOrderSchedulingService.cs
View File

@@ -12,11 +12,10 @@ using JNPF.DynamicApiController;
using JNPF.Systems.Entitys.System;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using NPOI.SS.UserModel;
using SqlSugar;
using Tnb.ProductionMgr.Entitys.Entity;
namespace Tnb.ProductionPlanMgr
namespace Tnb.ProductionMgr
{
/// <summary>
/// 生产排产

23
ProductionMgr/Tnb.ProductionMgr/internals/BaseService.cs
View File

@@ -1,23 +0,0 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using JNPF;
using JNPF.Common.Core.Manager;
using JNPF.DependencyInjection;
using JNPF.Systems.Entitys.System;
using SqlSugar;
namespace Tnb.ProductionPlanMgr
{
public class BaseService : ITransient
{
private readonly Dictionary<string, ISqlSugarClient> _dbContextDic = new(StringComparer.OrdinalIgnoreCase);
static BaseService()
{
}
}
}