using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
using HH.WCS.Mobox3.DSZSH.api;
|
using HH.WCS.Mobox3.DSZSH.device;
|
using HH.WCS.Mobox3.DSZSH.models;
|
using HH.WCS.Mobox3.DSZSH.util;
|
using HH.WCS.Mobox3.DSZSH.wms;
|
|
using Newtonsoft.Json;
|
|
namespace HH.WCS.Mobox3.DSZSH.core {
|
public class Monitor {
|
public class ItemData {
|
public string item_code { get; set; }
|
public string batch_no { get; set;}
|
public string cntr_code { get; set; }
|
}
|
|
public static void CheckInbound() {
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
|
try {
|
// 查产线是否有物料信息
|
foreach (var prod in Settings.ProductionLines) {
|
if (int.Parse(prod.Id) > 1) break; // TEST
|
|
//var prodDevice = new ProductionLineDevice(prod); // TODO 待需求确定后再处理
|
//TcpClientHelper.Link("127.0.0.1", 8550); // 用于测试
|
TcpClientHelper.Link(prod.PlcIp, prod.PlcPort);
|
|
// TCPClient传递信息的时候，不要用断点阻塞程序
|
// {"item_code":"CG1001","batch_no":"BN1001","cntr_code":"CN2505111"}
|
if (!TcpClientHelper.TryReadProductionLine(out byte[] read)) {
|
info = $"测试{prod.Id}号产线{prod.PlcIp}:{prod.PlcPort}：读取产线信息失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
// 3. 将寄存器值转换为字节数组
|
//byte[] bytes = TcpClientHelper.ConvertRegistersToBytes(registers);
|
|
// 4. 将字节数组转换为字符串
|
string result = TcpClientHelper.ConvertBytesToString(read);
|
|
//var itemData = BitConverter.ToString(read);
|
LogHelper.Info($"读取的产线信息{result}");
|
var data = JsonConvert.DeserializeObject<ItemData>(result);
|
|
LogHelper.Info(JsonConvert.SerializeObject(data));
|
|
//var itemCode = data.item_code;
|
//var batchNo = data.batch_no;
|
var cntrCode = data.cntr_code;
|
|
var startLocCode = prod.OffLoc[0]; // 用于测试
|
//var startLocCode = "CX01"; // 用于测试
|
|
WCSCore.CreateInboundTask(startLocCode, cntrCode);
|
}
|
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
}
|
|
}
|
|
public static void CheckOutboundOrder() {
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
|
const string taskName = TaskName.C成品胶出库;
|
|
try {
|
var orderList = db.Queryable<TN_Outbound_Order>()
|
.Where(c => c.N_B_STATE == 1)
|
.OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc)
|
.ToList();
|
|
if (orderList.Count == 0) {
|
info = $"轮询：{taskName}：暂无待执行的{taskName}单";
|
LogHelper.Info(info);
|
return;
|
}
|
|
Console.WriteLine(JsonConvert.SerializeObject(orderList)); // TEST
|
|
var detailList = new List<TN_Outbound_Detail>();
|
foreach (var order in orderList) {
|
var doingCount = db.Queryable<TN_Outbound_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中
|
var allCount = db.Queryable<TN_Outbound_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO);
|
info = $"轮询：{taskName}：统计{taskName}单'{order.S_NO}'任务已下发：{doingCount}/{allCount}";
|
LogHelper.Info(info);
|
|
if (doingCount == allCount) {
|
order.N_B_STATE = 2; // 所有任务都已执行
|
db.Updateable<TN_Outbound_Order>(order).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
continue;
|
}
|
|
var lastDetail = db.Queryable<TN_Outbound_Detail>()
|
.Where(d => d.S_OO_NO == order.S_NO && d.N_B_STATE == 2) // [NOTE] 或者改成查task
|
.First();
|
|
if (lastDetail != null) {
|
info = $"轮询：{taskName}：{taskName}单'{order.S_NO}'上一个任务仍在进行中：" + JsonConvert.SerializeObject(lastDetail);
|
LogHelper.Info(info);
|
continue;
|
}
|
|
var outboundDetail = db.Queryable<TN_Outbound_Detail>()
|
.Where(a => a.S_OO_NO == order.S_NO && a.N_B_STATE == 1) // 已下发
|
.First();
|
|
if (outboundDetail == null) {
|
info = $"轮询：{taskName}：仍有任务未执行完成，但当前没有已下发的任务";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
detailList.Add(outboundDetail);
|
}
|
|
if (detailList.Count == 0) {
|
// 上面流程已经打印过日志
|
return;
|
}
|
|
foreach (var detail in detailList) {
|
var startLoc = db.Queryable<TN_Location>()
|
.LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where((l, c) => c.S_CNTR_CODE == detail.S_CNTR_CODE) // 根据容器号搜索起点货位
|
.Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y") // 筛选：未上锁
|
.Where(l => l.N_CURRENT_NUM == 1)
|
.First();
|
|
if (startLoc == null) {
|
info = $"轮询：{taskName}：没有找到合适的起点货位！";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
var endLoc = db.Queryable<TN_Location>()
|
.Where(a => a.S_AREA_CODE == detail.S_END_AREA)
|
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y")
|
.Where(a => a.N_CURRENT_NUM == 0).First();
|
|
if (endLoc == null) {
|
info = $"轮询：{taskName}：没有找到合适的终点货位！单号'{detail.S_OO_NO}'要求终点库区为'{detail.S_END_AREA}'";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
detail.N_B_STATE = 2;
|
|
var cntId = detail.S_CNTR_CODE;
|
|
var erp_no = string.IsNullOrEmpty(detail.S_BS_NO) ? "" : detail.S_BS_NO;
|
var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName, detail.S_OO_NO, erp_no);
|
|
LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁
|
LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Updateable<TN_Outbound_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"轮询：{taskName}：修改明细表状态为完成--失败！";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY,
|
it.N_CURRENT_NUM, // 起点货位绑定后，将货位状态更新
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新起点货位{startLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY,
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新终点货位{endLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
tran.CommitTran();
|
info = $"生成任务'{taskName}'成功，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
|
LogHelper.Info(info);
|
//continue;
|
}
|
|
// 如果当前出库单明细是ERP下发的，任务创建完成反馈货位信息
|
if (detail.S_BS_TYPE == "ERP") {
|
//var createTaskReturnErpTask = Task.Run(() => {
|
// CreateTaskReturnErp(task);
|
//});
|
CreateTaskReturnErp(task);
|
}
|
|
}
|
|
|
//// BEG 查找6个月以前的任务表和任务动作表
|
//var oldTaskList = db.Queryable<TN_Task>()
|
// .Where(t => t.T_MODIFY < DateTime.Now.AddMonths(-6))
|
// .Where(t => t.N_B_STATE == 3 && t.S_B_STATE == "完成")
|
// .ToList();
|
|
//var oldTaskActionList = db.Queryable<TN_Task, TN_Task_Action>((t, a) => t.S_CODE == a.S_TASK_CODE)
|
// .Where(t => t.T_MODIFY < DateTime.Now.AddMonths(-6))
|
// .Where(t => t.N_B_STATE == 3 && t.S_B_STATE == "完成")
|
// .Select((t, a) => a)
|
// .ToList();
|
//// END
|
|
//using (var tran = db.Ado.UseTran()) {
|
// // 在出库轮询中处理，查找任务单是否有半年前且已经完成的任务，如果有则删除
|
// // 这个操作不影响正常流程，如果失败也不需要回滚
|
// //if (db.Deleteable<TN_Task>()
|
// // .Where(t => t.T_MODIFY < DateTime.Now.AddMonths(-6))
|
// // .Where(t => t.N_B_STATE == 3 && t.S_B_STATE == "完成")
|
// // .ExecuteCommand() <= 0) {
|
// // info = $"轮询{taskName}单时尝试删除半年前的任务失败";
|
// // LogHelper.Info(info);
|
// //}
|
// if (db.Deleteable<TN_Task>(oldTaskList).ExecuteCommand() <= 0
|
// && db.Deleteable<TN_Task_Action>(oldTaskActionList).ExecuteCommand() <= 0) {
|
// info = $"轮询{taskName}单时尝试删除半年前的任务失败";
|
// LogHelper.Info(info);
|
// }
|
//}
|
|
}
|
catch (Exception ex) {
|
info = $"轮询：{taskName}：发生了异常：{ex.Message}";
|
LogHelper.InfoEx(ex);
|
}
|
}
|
|
public static void CheckCheckOrder() {
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
|
const string taskName = TaskName.C抽检_出库;
|
|
try {
|
var orderList = db.Queryable<TN_Spot_Check>()
|
.Where(c => c.N_B_STATE == 1)
|
.OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc)
|
.ToList();
|
|
if (orderList.Count == 0) {
|
LogHelper.Info($"轮询：{taskName}：暂无待执行的{taskName}单");
|
return;
|
}
|
|
var detailList = new List<TN_SpotCheck_Detail>();
|
foreach (var order in orderList) {
|
var doingCount = db.Queryable<TN_SpotCheck_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中
|
var allCount = db.Queryable<TN_SpotCheck_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO);
|
LogHelper.Info($"轮询：{taskName}：统计{taskName}单'{order.S_NO}'任务已下发：{doingCount}/{allCount}");
|
|
if (doingCount == allCount) {
|
order.N_B_STATE = 2; // 所有任务都已执行
|
db.Updateable<TN_Spot_Check>(order).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
continue;
|
}
|
|
var checkDetailList = db.Queryable<TN_SpotCheck_Detail>()
|
.Where(a => a.S_OO_NO == order.S_NO && a.N_B_STATE == 1) // 已下发
|
.ToList();
|
|
if (checkDetailList.Count == 0) {
|
LogHelper.Info($"轮询：{taskName}：仍有任务未执行完成，但当前没有已下发的任务");
|
continue;
|
}
|
|
foreach (var checkDetail in checkDetailList) {
|
detailList.Add(checkDetail);
|
}
|
}
|
|
foreach (var detail in detailList) {
|
var startLoc = db.Queryable<TN_Location>()
|
.LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where((l, c) => c.S_CNTR_CODE == detail.S_CNTR_CODE)
|
.First();
|
|
if (startLoc == null) {
|
LogHelper.Info($"轮询：{taskName}：没有找到合适的起点货位！");
|
continue;
|
}
|
|
var endLoc = db.Queryable<TN_Location>()
|
.Where(l => l.S_AREA_CODE == detail.S_END_AREA)
|
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y") // 筛选：未上锁
|
.Where(a => a.N_CURRENT_NUM == 0).First();
|
|
if (endLoc == null) {
|
LogHelper.Info($"轮询：{taskName}：没有找到合适的终点货位！");
|
continue;
|
}
|
|
detail.N_B_STATE = 2;
|
|
var cntId = detail.S_CNTR_CODE;
|
var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName, detail.S_OO_NO);
|
|
LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁
|
LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Updateable<TN_SpotCheck_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
LogHelper.Info($"轮询：{taskName}：修改{taskName}单明细表状态为完成--失败！");
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY,
|
it.N_CURRENT_NUM, // 起点货位绑定后，将货位状态更新
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新起点货位{startLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY,
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新终点货位{endLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
tran.CommitTran();
|
info = $"生成任务'{taskName}'成功，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
}
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
}
|
}
|
|
public static void CheckShiftOrder() {
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
|
const string taskName = TaskName.Y移库;
|
|
try {
|
var orderList = db.Queryable<TN_Relocation_List>()
|
.Where(c => c.N_B_STATE == 1)
|
.OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc)
|
.ToList();
|
|
if (orderList.Count == 0) {
|
LogHelper.Info($"轮询：{taskName}：暂无待执行的{taskName}单");
|
return;
|
}
|
|
var detailList = new List<TN_RelocationList_Detail>();
|
foreach (var order in orderList) {
|
var doingCount = db.Queryable<TN_RelocationList_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中
|
var allCount = db.Queryable<TN_RelocationList_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO);
|
LogHelper.Info($"轮询：{taskName}：统计{taskName}单={order.S_NO}任务已下发：{doingCount}/{allCount}");
|
|
if (doingCount == allCount) {
|
order.N_B_STATE = 2; // 所有任务都已执行
|
db.Updateable<TN_Relocation_List>(order).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
continue;
|
}
|
|
var checkDetailList = db.Queryable<TN_RelocationList_Detail>()
|
.Where(a => a.S_OO_NO == order.S_NO && a.N_B_STATE == 1) // 已下发
|
.ToList();
|
|
if (checkDetailList.Count == 0) {
|
LogHelper.Info($"轮询：{taskName}：仍有任务未执行完成，但当前没有已下发的任务");
|
continue;
|
}
|
|
foreach (var checkDetail in checkDetailList) {
|
detailList.Add(checkDetail);
|
}
|
}
|
|
foreach (var detail in detailList) {
|
var startLoc = db.Queryable<TN_Location>()
|
.LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where((l, c) => c.S_CNTR_CODE == detail.S_CNTR_CODE)
|
.Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y") // 筛选：未上锁
|
.Where(l => l.N_CURRENT_NUM == 1)
|
.First();
|
|
if (startLoc == null) {
|
info = $"轮询：{taskName}：没有找到容器号={detail.S_CNTR_CODE}的起点货位！需要满足：未上锁、当前容器数量=1";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
var endLoc = db.Queryable<TN_Location>()
|
.Where(l => l.S_AREA_CODE == detail.S_END_AREA)
|
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y") // 筛选：未上锁
|
.Where(a => a.N_CURRENT_NUM == 0).First();
|
|
if (endLoc == null) {
|
info = $"轮询：{taskName}：没有找到终点货位={detail.S_END_AREA}的终点货位！需要满足：未上锁、当前容器数量=0";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
detail.N_B_STATE = 2;
|
|
var cntId = detail.S_CNTR_CODE;
|
var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName, detail.S_OO_NO);
|
|
LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁
|
LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Updateable<TN_RelocationList_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
LogHelper.Info($"轮询：{taskName}：修改{taskName}单明细表状态为完成--失败！");
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY,
|
it.N_CURRENT_NUM, // 起点货位绑定后，将货位状态更新
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新起点货位{startLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY,
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新终点货位{endLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
tran.CommitTran();
|
info = $"生成任务'{taskName}'成功，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
}
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
}
|
}
|
|
public static void CreateTaskReturnErp(TN_Task task) {
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
var httpH = new HttpHelper();
|
|
try {
|
var plan = db.Queryable<TN_Outbound_Plan>()
|
.Where(p => p.JHDH == task.S_BS_NO)
|
.First();
|
|
if (plan == null) {
|
info = $"计划单号{task.S_BS_NO}不存在！";
|
LogHelper.Info(info);
|
}
|
|
var cgDetail = db.Queryable<TN_CG_Detail>()
|
.Where(d => d.S_CNTR_CODE == task.S_CNTR_CODE)
|
.First();
|
|
if (cgDetail == null) {
|
info = $"物料编码不存在！";
|
LogHelper.Info(info);
|
}
|
|
var model = new OtherModel.CreateTaskReturnErpInfo {
|
jhdh = plan.JHDH , // 计划单号（唯一标识）
|
ckzt = plan.CKZT , // 出库状态（需要返回）
|
jhlb = plan.JHLB , // 计划类别
|
ckdh = plan.CKDH , // 参考单号
|
cph = plan.CPH , // 车牌号
|
ysfs = plan.YSFS , // 运输方式
|
cpzt = plan.CPZT , // 产品状态
|
mddw = plan.MDDW , // 买断单位
|
cpdm = plan.CPDM , // 产品代码
|
cplb = plan.CPLB , // 产品类别
|
cplbmx = plan.CPLBMX , // 产品类别明细
|
pp = plan.PP , // 品牌
|
dj = plan.DJ , // 等级（需要返回）
|
gh = plan.GH , // 罐号
|
ph = plan.PH , // 批号（需要返回）
|
bzlx = plan.BZLX , // 包装类型
|
pzdh = plan.PZDH , // 派装单号
|
pzd_dw = plan.PZD_DW , // 派装单单位
|
pzd_dybh = plan.PZD_DYBH , // 派装单调运编号
|
pzjs = plan.PZJS , // 派装件数
|
pzsl = plan.PZSL , // 派装数量
|
pz_rq = plan.PZ_RQ , // 派装日期(yyyy-mm-dd)
|
pz_czrq = plan.PZ_CZRQ , // 派装操作日期
|
pz_zfbj = plan.PZ_ZFBJ , // 派装作废标记
|
pz_zfrq = plan.PZ_ZFRQ , // 派装作废日期
|
pz_bz = plan.PZ_BZ , // 派装备注
|
ckdbh = plan.CKDBH , // 出库单编号
|
//sfjs = plan.SFJS , // 实发件数（需要返回）
|
//sfsl = plan.SFSL , // 实发数量（需要返回）
|
//sfcs = plan.SFCS , // 实发车数（需要返回）
|
//zcsj = plan.ZCSJ , // 装车时间（需要返回）
|
//jldw = plan.JLDW , // 计量单位（需要返回）
|
//fhrq = plan.FHRQ , // 发货日期（需要返回）
|
//ckdm = plan.CKDM , // 仓库代码（需要返回）
|
//fhr = plan.FHR , // 发货人（需要返回）
|
//czydm = plan.CZYDM , // 操作员（需要返回）
|
shr_username = plan.SHR_USERNAME , // 审核人
|
shrq = plan.SHRQ , // 审核日期
|
zfbj = plan.ZFBJ , // 作废标记
|
zfrq = plan.ZFRQ , // 作废日期
|
jsdw = plan.JSDW , // 结算单位
|
shdw = plan.SHDW , // 收货单位
|
ysdw = plan.YSDW , // 运输单位
|
lxr = plan.LXR , // 联系人
|
//ry_zxg = plan.RY_ZXG , // 装卸工（需要返回）
|
//ry_ccsj = plan.RY_CCSJ , // 叉车司机（需要返回）
|
erphx_jhdh = plan.ERPHX_JHDH , // erp交货单号
|
erphx_wlbm = plan.ERPHX_WLBM , // erp物料编码
|
erphx_wlmc = plan.ERPHX_WLMC , // erp物料名称
|
erphx_cjrq = plan.ERPHX_CJRQ , // erp创建日期
|
hw = plan.HW , // 货位（需要返回）
|
hwzt = plan.HWZT // 货位状态（需要返回）
|
};
|
model.hw = task.S_START_LOC;
|
model.hwzt = "待出库";
|
model.ph = cgDetail.S_BATCH_NO;
|
|
var jsonInfo = JsonConvert.SerializeObject(model);
|
var result = httpH.WebPost(Settings.ErpApiUrl + "CreateTaskReturn", jsonInfo);
|
|
LogHelper.InfoApi($"创建任务完成反馈ERP接口，结果={result}，调用参数：", model);
|
|
plan.HW = model.hw;
|
plan.HWZT = model.hwzt;
|
plan.PH = model.ph;
|
var success = db.Updateable<TN_Outbound_Plan>(plan).UpdateColumns(p => new { p.HW, p.HWZT, p.PH }).ExecuteCommand() > 0;
|
info = "更新出库计划单记录表" + (success ? "成功" : "失败");
|
LogHelper.Info(info);
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
}
|
}
|
}
|
}
|
