using Tiger.Model;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq.Expressions;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Rhea.Common;
|
using System.Net;
|
using System.Linq;
|
using Newtonsoft.Json;
|
using Tiger.IBusiness;
|
using static Tiger.Business.Biz;
|
using Microsoft.AspNetCore.Http;
|
using System.Collections;
|
using System.Data;
|
using Sundial;
|
|
namespace Tiger.Business.MES
|
{
|
/// <summary>
|
/// 工具管理
|
/// </summary>
|
public partial class SmtTool : ISmtTool
|
{
|
/// <summary>
|
/// 获取未上料列表
|
/// </summary>
|
/// <param name="paras"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<List<SMT_WO_TABLE>>> GetNotLoadingMaterial(SmtLoadingInput paras)
|
{
|
var res = new ApiAction<List<SMT_WO_TABLE>>();
|
List<SMT_WO_TABLE> sList = new List<SMT_WO_TABLE>();
|
try
|
{
|
sList = Db.Queryable<SMT_WO_TABLE, SMT_LOADING>((t, l) =>
|
new JoinQueryInfos(
|
JoinType.Left,
|
t.WORK_ORDER == l.WORK_ORDER
|
&& t.PROD_CODE == l.PROD_CODE
|
&& t.PCB_SURFACE == l.PCB_SURFACE
|
&& t.LINE_CODE == l.LINE_CODE
|
&& t.SLOT_NO == l.SLOT_NO
|
))
|
.Where((t, l) => SqlFunc.IsNullOrEmpty(l.WORK_ORDER) && t.WORK_ORDER == paras.moCode && t.PROD_CODE == paras.prodCode && t.LINE_CODE == paras.lineCode && t.PCB_SURFACE == paras.pcbSurface)
|
.WhereIF(SqlFunc.IsNullOrEmpty(paras.machineCode), (t, l) => t.SMT_CODE == paras.machineCode)
|
.Select((t, l) => t)
|
.ToList();
|
}
|
catch (Exception ex)
|
{
|
res.CatchExceptionWithLog(ex, "查询异常");
|
}
|
res.Data = sList;
|
return await Task.FromResult(res);
|
}
|
/// <summary>
|
/// 导入工单料站表
|
/// </summary>
|
/// <param name="paras"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<List<smtWoTableIn>>> ValidateTableImport(List<smtWoTableIn> paras)
|
{
|
var result = new ApiAction<List<smtWoTableIn>>();
|
try
|
{
|
|
//DataTable dt = JsonConvert.DeserializeObject<DataTable>(paras.ToString());
|
List<smtWoTableIn> currentList = new List<smtWoTableIn>();
|
if (paras?.Count > 0)
|
{
|
//var duplicateWo = paras.GroupBy(p => p.关联工单号)
|
// .Where(g => g.Count() > 1)
|
// .Select(g => g.Key)
|
// .ToList();
|
//if (duplicateWo.Count() > 0)//存在重复数据
|
//{
|
// string WORK_ORDER = string.Empty;
|
// foreach (var item in duplicateWo)
|
// {
|
// WORK_ORDER += item;
|
// }
|
// WORK_ORDER = WORK_ORDER.TrimEnd(';');
|
// result.IsSuccessed = false;
|
// result.Message = $"导入的物料中有重复数据：关联工单：{WORK_ORDER}";
|
//}
|
//else
|
{
|
foreach (var item in paras)
|
{
|
item.处理方式 = "新增";
|
item.原因 = null;
|
if (item.关联工单号 == null || item.关联工单号 == " ")
|
{
|
item.处理方式 = "数据异常";
|
item.原因 += "工单号空或不存在！";
|
}
|
if (item.产品编码 == null || item.产品编码 == " ")
|
{
|
item.处理方式 = "数据异常";
|
item.原因 += $"产品编码为空！";
|
}
|
if (item.物料编码 == null || item.物料编码 == " ")
|
{
|
item.处理方式 = "数据异常";
|
item.原因 += $"物料编码为空！";
|
}
|
if (item.站位号 == null || item.站位号 == " ")
|
{
|
item.处理方式 = "数据异常";
|
item.原因 += $"站位号为空！";
|
}
|
currentList.Add(item);
|
if (await Db.Queryable<SMT_WO_TABLE>().AnyAsync(x => x.WORK_ORDER == item.关联工单号 && x.ITEM_CODE == item.物料编码 && x.SLOT_NO == item.站位号 && x.SMT_CODE == item.贴片机编码))
|
{
|
item.处理方式 = "修改";
|
item.原因 += $"工单{item.关联工单号}，物料编码{item.物料编码}，站位号{item.站位号}，贴片机编码{item.贴片机编码}与数据库重复！";
|
}
|
}
|
//for (int i = 0; i < item..Count; i++)
|
{
|
}
|
|
}
|
}
|
else
|
{
|
result.IsSuccessed = false;
|
result.Message = $"导入的物料不能为空";
|
}
|
result.Data = currentList;
|
|
}
|
catch (Exception ex)
|
{
|
result.CatchException(ex, $"验证导入工单料站表异常");
|
}
|
return result;
|
}
|
/// <summary>
|
/// 导入工单料站表
|
/// </summary>
|
/// <param name="paras"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> SaveValidateTableImport(List<smtWoTableIn> paras)
|
{
|
var result = new ApiAction();
|
try
|
{
|
|
//DataTable dt = JsonConvert.DeserializeObject<DataTable>(paras.ToString());
|
List<SMT_WO_TABLE> currentList = new List<SMT_WO_TABLE>();
|
if (paras.Count > 0)
|
{
|
var db = Biz.Db;
|
foreach (var item in paras)
|
{
|
var workorder = item.关联工单号.ToString();
|
var id = db.Queryable<SMT_WO_TABLE>().Where(s => s.WORK_ORDER == workorder).Select(q => q.ID).First();
|
SMT_WO_TABLE table = new SMT_WO_TABLE();
|
table.ID = item.处理方式?.ToString() == "新增" ? Guid.NewGuid().ToString() : id;
|
table.CREATE_TIME = DateTime.Now;
|
table.UPDATE_TIME = DateTime.Now;
|
table.WORK_ORDER = item.关联工单号.ToString();
|
table.PROD_CODE = item.产品编码?.ToString();
|
table.ITEM_CODE = item.物料编码?.ToString();
|
table.SUBITEM_CODE = item.替代料?.ToString();
|
table.UNIT = item.单位?.ToString();
|
table.UNIT_QTY = item.单位用量.ToInt32();
|
table.LINE_CODE = item.产线编码?.ToString();
|
table.SMT_CODE = item.贴片机编码?.ToString();
|
table.SMT_STENCIL = item.钢网编码?.ToString();
|
table.SLOT_NO = item.站位号?.ToString();
|
table.LOCATION = item.贴片位置?.ToString();
|
table.FEEDER_CODE = item.飞达编码?.ToString();
|
table.FEEDER_TYPE = item.飞达类型?.ToString();
|
table.PCB_SURFACE = item.加工面?.ToString();
|
table.LOAD_SEQ = item.上料顺序.ToInt32();
|
table.REMARK = item.备注?.ToString();
|
table.VALIDATION_TYPE = item.处理方式?.ToString();
|
table.VALIDATION_RESULT = item.原因?.ToString();
|
currentList.Add(table);
|
}
|
var add = currentList.Where(q => q.VALIDATION_TYPE == "新增").ToList();
|
var upd = currentList.Where(q => q.VALIDATION_TYPE == "修改").ToList();
|
if (add.Count > 0)
|
{
|
Biz.Db.Insertable(add).ExecuteCommand();
|
}
|
if (upd.Count > 0)
|
{
|
Biz.Db.Updateable(upd).ExecuteCommand();
|
}
|
|
}
|
|
}
|
catch (Exception ex)
|
{
|
result.CatchException(ex, $"验证导入工单料站表异常");
|
}
|
return result;
|
}
|
}
|
}
|
