using HH.WCS.NongFuChaYuan.OtherService;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
|
namespace HH.WCS.NongFuChaYuan.WmsService
|
{
|
/// <summary>
|
/// 工单、设备状态管理
|
/// </summary>
|
public class WCSHelper
|
{
|
static WCSHelper()
|
{
|
}
|
|
|
|
#region 大明山WCS业务处理
|
|
|
/// <summary>
|
/// 大明上-查询工单信息--执行中
|
/// </summary>
|
/// <param name="orderType"></param>
|
/// <returns></returns>
|
public static List<WorkOrder> GetDaMingShanAnalysisOrderWork(string orderType)
|
{
|
var order = new SqlHelper<WorkOrder>().GetList(a => a.S_ORDER_TYPE == orderType && a.S_WorkState == "执行中");
|
return order;
|
}
|
|
/// <summary>
|
/// 大明山-查询工单信息
|
/// </summary>
|
/// <param name="orderType"></param>
|
/// <returns></returns>
|
public static List<WorkOrder> GetDaMingShanAnalysisOrderWorkType(string orderType, string newbatch, string deviceName)
|
{
|
var order = new SqlHelper<WorkOrder>().GetList(a => a.S_ORDER_TYPE == orderType && a.S_BatchNo == newbatch && a.S_PLineNo == deviceName);
|
return order;
|
}
|
|
/// <summary>
|
/// 插入工单信息
|
/// </summary>
|
/// <param name="wmsTask"></param>
|
/// <returns></returns>
|
internal static bool DaMingShanInsertWork(WorkOrder wmsTask)
|
{
|
var db = new SqlHelper<WorkOrder>().GetInstance();
|
return db.Insertable(wmsTask).ExecuteCommand() > 0;
|
}
|
|
|
/// <summary>
|
/// 更改工单信息：托规、批次号、物料层数
|
/// </summary>
|
/// <param name="task"></param>
|
/// <param name="status"></param>
|
/// <returns></returns>
|
internal static bool UpdateWorkInfo(WorkOrder task, string batchNo = "", string itemLayer = "")
|
{
|
var res = false;
|
var db = new SqlHelper<WorkOrder>().GetInstance();
|
//task.S_TrayRules = trayRule;
|
task.S_BatchNo = batchNo;
|
task.S_ItemLayer = itemLayer;
|
db.Updateable(task).UpdateColumns(it => new { it.S_BatchNo, it.S_ItemLayer }).ExecuteCommand();
|
return res;
|
}
|
/// <summary>
|
/// 查询托盘信息-全部-为了对比当前是否为正常下线
|
/// </summary>
|
/// <param name="lineNo"></param>
|
/// <returns></returns>
|
public static List<DaMingShanTrayInfo> GetDaMingShanTrayInfoAllList(string deviceName)
|
{
|
var order = new SqlHelper<DaMingShanTrayInfo>().GetList(a => a.deviceName == deviceName);
|
return order;
|
}
|
|
/// <summary>
|
/// 创建数据中间表表
|
/// </summary>
|
/// <returns></returns>
|
public static void CreateMiddleTable()
|
{
|
//var order = new SqlHelper<ChunAnTrayInfo>().CreateTable();//富勒传输托盘信息表
|
//var order1 = new SqlHelper<ChunAnDeviceState>().CreateTable();//设备信号时间中间表
|
var order2 = new SqlHelper<DaMingShanAnalysisMoveLib>().CreateTable();//成品下线库位中间表
|
}
|
|
|
/// <summary>
|
/// 淳安-插入设备信息
|
/// </summary>
|
/// <param name="wmsTask"></param>
|
/// <returns></returns>
|
internal static bool DaMingShangInsertDeviceState(DaMingShanDeviceState deviceState)
|
{
|
var db = new SqlHelper<DaMingShanDeviceState>().GetInstance();
|
return db.Insertable(deviceState).ExecuteCommand() > 0;
|
}
|
/// <summary>
|
/// 淳安-更改设备状态:时间-状态
|
/// </summary>
|
/// <param name="deviceInfo"></param>
|
/// <param name="status">0-默认无动作 1-第一次收到下线信号</param>
|
/// <param name="dateTime">第一次收到信号时更新时间；取货完成复位时间</param>
|
/// <returns></returns>
|
internal static bool UpdateDaMingShanDeviceState(DaMingShanDeviceState deviceInfo, string status, string dateTime, string extData = "")
|
{
|
var res = false;
|
var db = new SqlHelper<DaMingShanDeviceState>().GetInstance();
|
deviceInfo.DeviceState = status;
|
deviceInfo.DeviceTime = dateTime;
|
db.Updateable(deviceInfo).UpdateColumns(it => new { it.DeviceState, it.DeviceTime }).ExecuteCommand();
|
return res;
|
}
|
/// <summary>
|
/// 查询当前设备信息
|
/// </summary>
|
/// <param name="lineNo"></param>
|
/// <returns></returns>
|
public static DaMingShanDeviceState GetDaMingShanDeviceState(string deviceName)
|
{
|
var order = new SqlHelper<DaMingShanDeviceState>().Get(a => a.DeviceName == deviceName, a => a.DeviceTime, true);
|
return order;
|
}
|
/// <summary>
|
/// 查询托盘信息-下线时间之前的数据
|
/// </summary>
|
/// <param name="lineNo"></param>
|
/// <returns></returns>
|
public static List<DaMingShanTrayInfo> GetDaMingShanTrayInfoList(string positionCode, string deviceName)
|
{
|
var exp = Expressionable.Create<DaMingShanTrayInfo>();
|
exp.And(it => it.deviceName == deviceName);
|
exp.AndIF(!string.IsNullOrEmpty(positionCode), it => it.positionCode == positionCode);
|
//var order = new SqlHelper<DaMingShanTrayInfo>().GetList(a => Convert.ToDateTime(a.dateTime.Trim()) < Convert.ToDateTime(dateTime) && a.deviceName == deviceName);
|
var order = new SqlHelper<DaMingShanTrayInfo>().GetList(exp.ToExpression());
|
return order;
|
}
|
/// <summary>
|
/// 大明山-查询工单信息--执行中或者暂停
|
/// </summary>
|
/// <param name="lineNo"></param>
|
/// <returns></returns>
|
public static WorkOrder GetWorkOrder(string lineNo)
|
{
|
var order = new SqlHelper<WorkOrder>().Get(a => a.S_PLineNo.Trim() == lineNo && (a.S_WorkState == "执行中"), a => a.T_CREATE, true);
|
return order;
|
}
|
|
/// <summary>
|
/// 大明山-查询工单信息--执行中或者暂停
|
/// </summary>
|
/// <param name="lineNo"></param>
|
/// <returns></returns>
|
public static PGWorkOrder GetPGWorkOrder(string lineNo)
|
{
|
var order = new SqlHelper<PGWorkOrder>().Get(a => a.S_PLineNo.Trim() == lineNo && (a.S_WorkState == "执行中"), a => a.T_CREATE, true);
|
return order;
|
}
|
|
public static List<WorkOrder> GetWorkOrder1(string lineNo)
|
{
|
var db = new SqlHelper<WorkOrder>().GetInstance();
|
var order = db.Queryable<WorkOrder>().Where(a => a.S_PLineNo.Trim() == lineNo && a.S_WorkState == "执行中").ToList();
|
return order;
|
}
|
|
public static ItemRel GetItemrel(string itemcode, string itemmodel)
|
{
|
var db = new SqlHelper<ItemRel>().GetInstance();
|
var order = db.Queryable<ItemRel>().Where(a => a.S_ITEM_CODE == itemcode && a.S_ITEM_MODEL == itemmodel).First();
|
|
return order;
|
}
|
|
|
internal static bool DaMingShanInsertAnalysisMoveLib(DaMingShanAnalysisMoveLib info)
|
{
|
var db = new SqlHelper<DaMingShanAnalysisMoveLib>().GetInstance();
|
var oldinfo = db.Queryable<DaMingShanAnalysisMoveLib>().Where(a => a.DeviceName == info.DeviceName && a.Batch == info.Batch && a.RowNo == info.RowNo).First();
|
if (oldinfo == null)
|
{
|
return db.Insertable(info).ExecuteCommand() > 0;
|
}
|
else
|
{
|
return true;
|
}
|
}
|
|
/// <summary>
|
/// 通过产线号结束自动移库工单 并删除中间表信息
|
/// </summary>
|
/// <param name="WorkOrder"></param>
|
internal void EndYiKuWorkOrder(string S_PLineNo, string BatchNo, string oldbatch)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var info = db.Deleteable<DaMingShanAnalysisMoveLib>().Where(a => a.DeviceName == S_PLineNo && a.Batch == oldbatch).ExecuteCommand();
|
var workorder = db.Queryable<WorkOrder>().Where(a => a.S_PLineNo == S_PLineNo && a.S_BatchNo == BatchNo && a.S_WorkState.Trim() == "执行中" && a.S_ORDER_TYPE.Trim() == "自动移库").ToList();
|
workorder.ForEach(a =>
|
{
|
a.S_WorkState = "已完成";
|
db.Updateable(a).UpdateColumns(it => new { it.S_WorkState }).ExecuteCommand();
|
});
|
}
|
|
internal static void UpdateDaMingShanInsertAnalysisMoveLib(string endbit)
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
var oldinfo = db.Queryable<Location>().Where(a => a.S_LOC_CODE.Trim() == endbit).First();
|
if (oldinfo != null)
|
{
|
string rowNo = oldinfo.N_ROW;
|
var info = db.Queryable<Location>().Where(a => a.N_ROW == rowNo && a.N_CURRENT_NUM > 0).First();
|
if (info == null)
|
{
|
//删除中间表对应的数据
|
var Libinfo = db.Queryable<DaMingShanAnalysisMoveLib>().Where(a => a.RowNo == rowNo).First();
|
if (Libinfo != null)
|
{
|
db.Deleteable<DaMingShanAnalysisMoveLib>().Where(a => a.RowNo == rowNo).ExecuteCommand();
|
}
|
}
|
}
|
}
|
#endregion
|
}
|
}
|
