986 lines
34 KiB
C#
986 lines
34 KiB
C#
|
||
/// <summary>
|
||
///LOGIC CLASS FOR TABLE t_wmsOutPickPort
|
||
///By wm with codesmith.
|
||
///on 06/17/2020
|
||
/// </summary>
|
||
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using DeiNiu.wms.Data.Model;
|
||
using System.Data;
|
||
using System.Transactions;
|
||
using DeiNiu.Utils;
|
||
|
||
namespace DeiNiu.wms.Logical
|
||
{
|
||
[Serializable]
|
||
public class lWmsOutPickPort :lbase
|
||
{
|
||
WmsOutPickPort _obj;
|
||
public lWmsOutPickPort()
|
||
{
|
||
initialize();
|
||
}
|
||
|
||
public WmsOutPickPort getWmsOutPickPort
|
||
{
|
||
get
|
||
{
|
||
if (_obj == null)
|
||
{
|
||
_obj = new WmsOutPickPort();
|
||
|
||
}
|
||
_obj.operater = operId;
|
||
return _obj;
|
||
}
|
||
}
|
||
|
||
public lWmsOutPickPort(int operId)
|
||
: base(operId)
|
||
{
|
||
initialize();
|
||
}
|
||
|
||
WmsWave _wmsWave ;
|
||
|
||
WmsWave wmsWave
|
||
{
|
||
get
|
||
{
|
||
if (_wmsWave == null)
|
||
{
|
||
_wmsWave = new WmsWave();
|
||
|
||
}
|
||
_wmsWave.operater = operId;
|
||
return _wmsWave;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// get all data
|
||
/// </summary>
|
||
public DataSet getAllData()
|
||
{
|
||
return _obj.Query();
|
||
}
|
||
|
||
/// <summary>
|
||
/// get all data
|
||
/// </summary>
|
||
public DataSet getAllActiveData()
|
||
{
|
||
return _obj.QueryActived();
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// get a record by id
|
||
/// </summary>
|
||
public void initialize(int id)
|
||
{
|
||
_obj = id != 0 ? new WmsOutPickPort(id) : new WmsOutPickPort();
|
||
}
|
||
|
||
/// <summary>
|
||
/// get a record by id 0
|
||
/// </summary>
|
||
public void initialize()
|
||
{
|
||
initialize(0);
|
||
}
|
||
|
||
/// <summary>
|
||
/// get a record by id
|
||
/// </summary>
|
||
public void initialize(DataRow dr)
|
||
{
|
||
_obj = new WmsOutPickPort(dr);
|
||
}
|
||
|
||
protected override DeiNiu.Data.BaseObject.BaseModel getModel()
|
||
{
|
||
return _obj;
|
||
}
|
||
|
||
//begin cust db operation, query, excute sql etc.
|
||
|
||
internal int add(WmsOutPickPort obj)
|
||
{
|
||
return obj.Add();
|
||
}
|
||
|
||
|
||
static bool isCreatingWaves =false;
|
||
|
||
|
||
|
||
|
||
internal DataSet getWaveDetails(string waveNo, int rowStart, int rowEnd)
|
||
{
|
||
return _obj.getWaveDetails(waveNo, rowStart, rowEnd);
|
||
}
|
||
|
||
internal DataTable getWaveDetails(string waveNo)
|
||
{
|
||
return _obj.getWaveDetails(waveNo );
|
||
}
|
||
|
||
internal DataSet getWavePages(int state, int rowStart, int rowEnd)
|
||
{
|
||
return wmsWave.queryPages(state, rowStart, rowEnd);
|
||
}
|
||
|
||
|
||
internal DataTable getPickInfo(string waveNo, int volType)
|
||
{
|
||
return _obj.getPickInfo(waveNo, volType);
|
||
}
|
||
|
||
internal DataTable getPickInfo(string waveNo)
|
||
{
|
||
return _obj.getPickInfo(waveNo );
|
||
}
|
||
|
||
internal DataTable getPickSummary(string waveNo, int volType)
|
||
{
|
||
return _obj.getPickSummary(waveNo, volType);
|
||
}
|
||
|
||
// to move to lStockOutPort
|
||
/// <summary>
|
||
/// 出库分拣任务
|
||
/// 按相同的集货区域的拣货单合并拣货
|
||
/// 同一个波次按拣货区域划分为不同的任务
|
||
/// 每个任务有一个或多个拣货明细
|
||
/// 每个任务考虑作为播种亮灯的播种单号
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public bool createPickWaves()
|
||
{
|
||
if (isCreatingWaves)
|
||
{
|
||
// return false;
|
||
LogHelper.debug("lWmsOutPickPort", "wave is creating in ????? ");
|
||
|
||
}
|
||
isCreatingWaves = true;
|
||
|
||
DataTable dt = getWmsOutPickPort.getNewPickTasks(new WaveRule().getCurrentActiveRule(enumWaveRuleType.普通波次));
|
||
if (dt.Rows.Count == 0)
|
||
{
|
||
isCreatingWaves = false;
|
||
return false;
|
||
}
|
||
int lastTranArea = -100, lastPartion = -100, lastVolType = -100, lastOrderType = -100; ;
|
||
string lastPickRequest = "", waveNo = "", jobNo = "",lastWaveNo="";
|
||
bool isNewWave = false, isNewJob = false;
|
||
Dictionary<int, string> waveJobs = new Dictionary<int, string>();
|
||
int waveSize = 0;
|
||
int maxSize = WmsConstants.WAVE_ORDERS_CNT;
|
||
int jobMax = WmsConstants.WAVE_TASK_MAX_CNT;
|
||
LogHelper.debug("lWmsOutPickPort", "start to process new waves...count:" + dt.Rows.Count);
|
||
int jobcnt = 0;
|
||
bool isCreateFlowTask = WmsConstants.OUT_LIGHT_ENABLE ? WmsConstants.DPS_TASK_GENERATION :true ;
|
||
|
||
WmsFlow wmsflow;
|
||
using (TransactionScope scope = new TransactionScope())
|
||
{
|
||
|
||
foreach (DataRow dr in dt.Rows)
|
||
{
|
||
_obj = new WmsOutPickPort(dr);
|
||
|
||
if (lastTranArea == -100)
|
||
{
|
||
lastTranArea = _obj.tranArea;
|
||
}
|
||
|
||
|
||
if (lastPartion == -100)
|
||
{
|
||
lastPartion = _obj.partion;
|
||
}
|
||
|
||
if (lastVolType == -100)
|
||
{
|
||
lastVolType = _obj.volType;
|
||
}
|
||
/*
|
||
if (lastOrderType == -100)
|
||
{
|
||
lastOrderType = _obj.or;
|
||
}
|
||
*/
|
||
if (lastPickRequest != _obj.pickOrderNo)
|
||
{
|
||
waveSize++;
|
||
//TODO:更新拣货状态 1. 整库拣货状态 2. 零库拣货状态
|
||
if (String.IsNullOrEmpty(lastPickRequest))
|
||
{
|
||
lastPickRequest = _obj.pickOrderNo;
|
||
}
|
||
WmsOutPickRequest pr = new WmsOutPickRequest(lastPickRequest);
|
||
pr.state = (int)enumOutStockRequestStatus.正在分拣;
|
||
pr.Update();
|
||
|
||
|
||
}
|
||
isNewWave = String.IsNullOrEmpty(waveNo)
|
||
|| lastTranArea != _obj.tranArea //集货目的地不同，开新波次
|
||
|| waveSize == maxSize; //达到波次最大订单数，开新波次
|
||
|
||
|
||
|
||
if (isNewWave)
|
||
{
|
||
/*if (!string.IsNullOrEmpty(waveNo) && waveJobs.ContainsKey(lastPartion))
|
||
{
|
||
WmsFlow wmsflow = new WmsFlow(jobNo, waveNo);
|
||
if(wmsflow.ID>0){
|
||
wmsflow.taskCnt = jobcnt;
|
||
wmsflow.Update();
|
||
}
|
||
|
||
}*/
|
||
|
||
lastWaveNo = waveNo;
|
||
waveNo = Util.getOrderNo(enumCreateOrderType.waveOrder, _obj.getNextSeq(enumCreateOrderType.waveOrder));
|
||
waveJobs = new Dictionary<int, string>();
|
||
waveSize = 0;
|
||
WmsWave wave = new WmsWave();
|
||
wave.waveNo = waveNo;
|
||
wave.type = _obj.recType;
|
||
wave.operater = operId;
|
||
wave.Add();
|
||
}
|
||
|
||
isNewJob = isNewWave || lastPartion != _obj.partion
|
||
|| jobcnt >= jobMax
|
||
|| !waveJobs.ContainsKey(_obj.partion);
|
||
|
||
if (jobcnt >= maxSize)
|
||
{
|
||
}
|
||
if (isNewJob)
|
||
{
|
||
isCreateFlowTask = WmsConstants.OUT_LIGHT_ENABLE ? WmsConstants.DPS_TASK_GENERATION : true ;
|
||
isCreateFlowTask = isCreateFlowTask || lastVolType > 0;
|
||
// LogHelper.WriteLog(typeof(lWmsOutPickPort), string.Format("1 isCreateFlowTask: {0},lastVolType {1}", isCreateFlowTask, lastVolType));
|
||
|
||
if (isCreateFlowTask && !string.IsNullOrEmpty(jobNo) )
|
||
{
|
||
wmsflow = new WmsFlow(jobNo);
|
||
if (wmsflow.ID > 0)
|
||
{
|
||
wmsflow.taskCnt = jobcnt;// waveJobs[lastPartion].Length;
|
||
wmsflow.Update();
|
||
}
|
||
|
||
}
|
||
|
||
jobcnt = 0;
|
||
jobNo = Util.getOrderNo(enumCreateOrderType.pickJobNo, _obj.getNextSeq(enumCreateOrderType.pickJobNo));
|
||
waveJobs[_obj.partion] = jobNo;
|
||
|
||
isCreateFlowTask = WmsConstants.OUT_LIGHT_ENABLE ? WmsConstants.DPS_TASK_GENERATION :true ;
|
||
isCreateFlowTask = isCreateFlowTask || _obj.volType > 0;
|
||
// LogHelper.WriteLog(typeof(lWmsOutPickPort), string.Format("2 isCreateFlowTask: {0},_obj.volType {1}", isCreateFlowTask, _obj.volType));
|
||
|
||
if (isCreateFlowTask)
|
||
{
|
||
wmsflow = new WmsFlow();
|
||
wmsflow.operater = operId;
|
||
wmsflow.orderNo = waveNo;
|
||
wmsflow.type = (int)Util.getTaskType(_obj.recType);
|
||
wmsflow.task = jobNo;
|
||
wmsflow.fromPartion = _obj.partion;
|
||
wmsflow.toPartion = _obj.tranArea;
|
||
wmsflow.taskPartion = _obj.partion;
|
||
wmsflow.Add();
|
||
|
||
}
|
||
|
||
}
|
||
else
|
||
{
|
||
jobNo = waveJobs[_obj.partion];
|
||
}
|
||
jobcnt++;
|
||
_obj.waveOrder = waveNo;
|
||
_obj.jobNo = jobNo;
|
||
_obj.operater = operId;
|
||
_obj.Update();
|
||
|
||
|
||
|
||
|
||
lastTranArea = _obj.tranArea;
|
||
lastPickRequest = _obj.pickOrderNo;
|
||
lastPartion = _obj.partion;
|
||
lastVolType = _obj.volType;
|
||
}
|
||
|
||
|
||
if (!string.IsNullOrEmpty(waveNo) )
|
||
{
|
||
wmsflow = new WmsFlow(jobNo );
|
||
if (wmsflow.ID > 0)
|
||
{
|
||
wmsflow.taskCnt = jobcnt;
|
||
wmsflow.Update();
|
||
}
|
||
}
|
||
|
||
scope.Complete();
|
||
}
|
||
|
||
LogHelper.debug("lWmsOutPickPort", "end process new waves...");
|
||
|
||
|
||
isCreatingWaves = false;
|
||
|
||
|
||
return true;
|
||
}
|
||
WmsOutDesk _desk;
|
||
WmsOutDesk desk
|
||
{
|
||
get
|
||
{
|
||
if (_desk == null)
|
||
{
|
||
_desk = new WmsOutDesk();
|
||
_desk.operater = operId;
|
||
}
|
||
return _desk;
|
||
}
|
||
}
|
||
WmsOutDesk _seedsDesk;
|
||
WmsOutDesk seedsDesk
|
||
{
|
||
get
|
||
{
|
||
if (_seedsDesk == null)
|
||
{
|
||
_seedsDesk = new WmsOutDesk();
|
||
}
|
||
return _seedsDesk;
|
||
}
|
||
}
|
||
static List<int> lblist = new List<int>();
|
||
static Dictionary<int, int> comLables = new Dictionary<int, int>();
|
||
|
||
void initialDebugSetting()
|
||
{
|
||
|
||
DataTable dt = new Node().QueryByFlag(10001);
|
||
foreach (DataRow dr in dt.Rows)
|
||
{
|
||
Node node = new Node(dr);
|
||
|
||
if (!node.isOn)
|
||
{
|
||
continue;
|
||
}
|
||
try
|
||
{
|
||
string labels = node.description;
|
||
string[] lbs = labels.Split(',');
|
||
foreach (string s in lbs)
|
||
{
|
||
comLables[Convert.ToInt16(s.Trim())] = Convert.ToInt16(node.name.Trim());
|
||
lblist.Add(Convert.ToInt16(s.Trim()));
|
||
}
|
||
}
|
||
catch
|
||
{
|
||
continue;
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|
||
}
|
||
private string waveOrder = "";
|
||
public void newBulkDPSPickWave()
|
||
{
|
||
if (!WmsConstants.OUT_LIGHT_ENABLE)
|
||
{
|
||
return;
|
||
}
|
||
|
||
//播种筛选，
|
||
//适合播种的客户订单合并成一个、多个大订单，统一捡出后进行播种操作
|
||
//1. 单个订单的品种少 、数量少
|
||
//2. 订单数量多
|
||
|
||
//只处理订单零货部分
|
||
//加入播种选项，所有订单零货部分使用摘取+播种方式
|
||
//1.播种点数量可配置， 分别用不同颜色区分
|
||
//2.每个播种点可分播客户的数量配置， 即每个播种点处理零货订单数量（ 例如配置成6个，一次捡6个客户的订单零货部分，送由一个播种点播种）
|
||
//3.波次和播种点的对应关系，一个波次只摘取一个播种点的零货，还是多个播种点的数据？
|
||
//4.
|
||
|
||
|
||
//一个波次可以摘取订单数 = 空闲分播台数量*每个分播台可分播客户数， 分播台的订单用颜色区分
|
||
//
|
||
|
||
LogHelper.debug(typeof(lWmsOutPickPort), "开始新波次。。。。。。。。。。。。。。。。。。");
|
||
|
||
DataTable dtPorts = getWmsOutPickPort.getNewPickTasks(new WaveRule().getCurrentActiveRule(enumWaveRuleType.DPS灯光波次));
|
||
|
||
LogHelper.debug(typeof(lWmsOutPickPort), string.Format("待处理任务数量：{0}", dtPorts.Rows.Count));
|
||
|
||
if (dtPorts.Rows.Count == 0)
|
||
{
|
||
LogHelper.debug(typeof(lWmsOutPickPort), string.Format("无订单需要处理，波次结束"));
|
||
new lWmsOutPickRequest(this.operId).checkRepAndNoStockOrders();
|
||
return;
|
||
}
|
||
desk.restDeskStatus(enumDeskState.空闲);
|
||
desk.restDeskStatus(enumDeskState.空闲, enumDeskType.播种); //播种台状态复位到空闲，是不是可以由播种员实际播种任务进度控制？
|
||
_seedsDesk = desk.getRandomDesk(enumDeskState.空闲, enumDeskType.播种); ;
|
||
_desk = desk.getRandomDesk(enumDeskState.空闲, enumDeskType.复核);
|
||
int labelMaxInWave = WmsConstants.MAX_LABEL_DATA_IN_A_WAVE; //一个标签一个波次只能存储40条数据
|
||
|
||
#if DEBUG
|
||
// if (lblist.Count == 0)
|
||
{
|
||
lblist.Clear();
|
||
initialDebugSetting();
|
||
}
|
||
lblist.Sort();
|
||
|
||
#endif
|
||
|
||
|
||
// List<WmsStockRecord> strecs = null;
|
||
waveOrder = Util.getOrderNo(enumCreateOrderType.dpsOrder, _obj.getNextSeq(enumCreateOrderType.dpsOrder));
|
||
//waveOrder = "WV" + System.DateTime.Now.ToString("yyyyMMddHHmmss");
|
||
Dictionary<int, int> labelCnt = new Dictionary<int, int>();
|
||
Dictionary<int, int> comCnt = new Dictionary<int, int>();
|
||
|
||
Dictionary<int, int> tmplabelCnt = new Dictionary<int, int>();
|
||
Dictionary<int, int> tmpcomCnt = new Dictionary<int, int>();
|
||
bool isReachLimit = false;
|
||
|
||
int waveSize = 0;
|
||
//List<WmsOutPickPort> lstPort;
|
||
List<WmsOutPickLable_tmp> lstLabel;
|
||
List<WmsStockRecord> lstBulk;
|
||
|
||
LogHelper.debug(typeof(lWmsOutPickRequest), string.Format("waveNo {0}", waveOrder));
|
||
|
||
//播种常量，达不到最小订单摘取需求的合并成大订单先统一摘取再分播
|
||
bool isSeedsEnabled = WmsConstants.OUT_BULK_SEEDS_PICK_ON;
|
||
int pickGoodsTypeMin = WmsConstants.OUT_MAX_SEEDS_GOODSTYPE_CNT; //单独摘取订单 最少货物类型
|
||
int pickGoodsCountMin = WmsConstants.OUT_MAX_SEEDS_BULK_CNT_SUM; // 单独摘取订单 最少货物数量
|
||
int seedsCount = seedsDesk.seedsCount; //播种台一次播种订单数量
|
||
decimal sumBulkCnt = 0;
|
||
bool isSeedPickInSameWave = true;
|
||
// bool canSeedPickLessThanseedsCount = false; //单个播种拣选单数量不可少于播种能力
|
||
List<WmsOutPickRequest> seedsRequests = new List<WmsOutPickRequest>();
|
||
Dictionary<string, WmsStockRecord> seedsBulks = new Dictionary<string, WmsStockRecord>();
|
||
|
||
|
||
if (desk.ID == 0) // no free pick desk
|
||
{
|
||
if (isSeedsEnabled)
|
||
{
|
||
_seedsDesk = desk.getRandomDesk(enumDeskState.空闲, enumDeskType.播种);
|
||
if (seedsDesk.ID == 0)
|
||
{
|
||
return;
|
||
}
|
||
}
|
||
else
|
||
{
|
||
return;
|
||
}
|
||
}
|
||
|
||
|
||
int bulkCnt = 0;
|
||
int requestCnt = 0;
|
||
|
||
|
||
//开始处理有零货的订单
|
||
DateTime d0 = DateTime.Now;
|
||
double totoalTime = 0d;
|
||
string lastAddress = "";
|
||
// foreach (WmsOutPickRequest request in requests)
|
||
|
||
WmsOutPickPort wopp;
|
||
string lastPickOrder = "";
|
||
List<WmsOutPickPort> lstPort = new List<WmsOutPickPort>();
|
||
lstBulk = new List<WmsStockRecord>();
|
||
int elebleId = 0, port = 0;
|
||
WmsOutPickRequest request;
|
||
List<WmsOutPickRequest> taskRequests = new List<WmsOutPickRequest>();
|
||
Dictionary<String, List<WmsStockRecord>> tasks = new Dictionary<string, List<WmsStockRecord>>();
|
||
Dictionary<String, List<WmsOutPickPort>> portTasks = new Dictionary<string, List<WmsOutPickPort>>();
|
||
|
||
|
||
|
||
foreach (DataRow dr in dtPorts.Rows)
|
||
{
|
||
DateTime d00 = DateTime.Now;
|
||
|
||
wopp = new WmsOutPickPort(dr);
|
||
|
||
if (lastPickOrder != wopp.pickOrderNo)
|
||
{
|
||
|
||
lastPickOrder = wopp.pickOrderNo;
|
||
_desk = desk.getRandomDesk(enumDeskState.空闲, enumDeskType.复核);
|
||
|
||
if (_desk.ID > 0)
|
||
{
|
||
|
||
request = new WmsOutPickRequest(lastPickOrder);
|
||
request.desk = _desk.color;
|
||
desk.state = (int)enumDeskState.任务中;
|
||
desk.Update();
|
||
taskRequests.Add(request);
|
||
|
||
}
|
||
else
|
||
{
|
||
break;
|
||
}
|
||
|
||
}
|
||
|
||
if (!tasks.Keys.Contains(lastPickOrder))
|
||
{
|
||
tasks[lastPickOrder] = new List<WmsStockRecord>();
|
||
}
|
||
|
||
if (!portTasks.Keys.Contains(lastPickOrder))
|
||
{
|
||
portTasks[lastPickOrder] = new List<WmsOutPickPort>();
|
||
}
|
||
|
||
tasks[lastPickOrder].Add(new WmsStockRecord(dr));
|
||
portTasks[lastPickOrder].Add(wopp);
|
||
|
||
}
|
||
#region savedata
|
||
foreach (WmsOutPickRequest pickRequest in taskRequests)
|
||
{
|
||
|
||
|
||
|
||
|
||
int lastId = 0;
|
||
LogHelper.debug(typeof(lWmsOutPickRequest), " 摘果式 保存整货和零货出库分拣数据");
|
||
lstLabel = new List<WmsOutPickLable_tmp>();
|
||
WmsOutPickLable_tmp wpl;
|
||
foreach (WmsStockRecord rec in tasks[pickRequest.pickOrderNo])
|
||
{
|
||
|
||
// if (rec.count == 0)
|
||
if (rec.count + rec.countOuting < 1) //不支持小数
|
||
{
|
||
continue;
|
||
}
|
||
|
||
if (lblist.Count > 0)
|
||
{
|
||
int id = new Random().Next(lblist.Count);
|
||
//#if DEBUG
|
||
rec.location.elabId = lblist[id]; //new Random().Next(minId, maxId + 1); //测试。。。随机分配标签id 为 1-3
|
||
|
||
while (lblist.Count > 1 && lastId == rec.location.elabId)
|
||
{
|
||
id = new Random().Next(lblist.Count);
|
||
rec.location.elabId = lblist[id];
|
||
}
|
||
|
||
lastId = rec.location.elabId;
|
||
//#endif
|
||
}
|
||
|
||
|
||
|
||
wpl = new WmsOutPickLable_tmp();
|
||
wpl.pickOrderNo = pickRequest.pickOrderNo;
|
||
wpl.recordId = rec.ID;
|
||
wpl.color = pickRequest.desk;
|
||
|
||
wpl.count = rec.count + rec.countOuting;
|
||
wpl.locationId = rec.locationId;
|
||
wpl.elabAddress = rec.location.elabAddress;
|
||
wpl.elabId = rec.location.elabId;
|
||
wpl.port = rec.location.port;
|
||
wpl.orderDetailId = rec.orderDetailId;
|
||
//#if DEBUG
|
||
try
|
||
{
|
||
if (comLables.Count > 0)
|
||
{
|
||
wpl.port = comLables[wpl.elabId]; //rec.location.elabId < 4 ?5 :3; //测试。。。 分配标签端口为3
|
||
}
|
||
}
|
||
catch { }
|
||
//#endif
|
||
wpl.dpsOrder = waveOrder;
|
||
wpl.operater = this.operId;
|
||
lstLabel.Add(wpl);
|
||
|
||
}
|
||
|
||
|
||
//保存整货和零货出库分拣数据
|
||
|
||
try
|
||
{
|
||
using (TransactionScope scope1 = new TransactionScope())
|
||
{
|
||
foreach (WmsOutPickLable_tmp wp in lstLabel) //建立电子拣选临时数据
|
||
{
|
||
wp.Add();
|
||
}
|
||
|
||
foreach (WmsOutPickPort pt in portTasks[pickRequest.pickOrderNo])
|
||
{
|
||
pt.dpsOrder = waveOrder;
|
||
pt.Update();
|
||
}
|
||
|
||
|
||
if (lstLabel.Count > 0)
|
||
{
|
||
pickRequest.waveOrder = waveOrder;
|
||
|
||
pickRequest.state = (int)enumOutStockRequestStatus.正在分拣;
|
||
pickRequest.waveStart = pickRequest.getDateTime();
|
||
pickRequest.operater = this.operId;
|
||
pickRequest.updateBulkPickStatus(pickRequest.pickOrderNo, enumOutStockPickStatus.正在分拣, operId);
|
||
// pickRequest.state =
|
||
pickRequest.Update();
|
||
}
|
||
|
||
waveSize++;
|
||
scope1.Complete();
|
||
}
|
||
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
LogHelper.WriteLog(typeof(lWmsOutPickRequest), e);
|
||
desk.restDeskStatus(enumDeskState.空闲);
|
||
throw e;
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
// totoalTime += ts00.TotalSeconds;
|
||
|
||
|
||
//建立零库电子拣选临时数据
|
||
|
||
new WmsOutPickRequest().saveTempData4Validation(waveOrder);
|
||
|
||
WmsConstants.WAVE_CURRENT_PICK_STATUS.Clear();
|
||
|
||
WmsConstants.WAVE_CURRENT_ORDER = waveOrder;
|
||
|
||
WmsConstants.WAVE_LAST_TIME = DateTime.Now;
|
||
|
||
|
||
//检查待补货出货单状态
|
||
new lWmsOutPickRequest(this.operId).checkRepAndNoStockOrders();
|
||
|
||
}
|
||
|
||
|
||
|
||
/*
|
||
* 分配拣货任务
|
||
*/
|
||
public void taskAssign(int taskBy,int partion,int lineId,int maxLocCnt=0,int maxBoxs=0,
|
||
bool batchOnly=true,enumOutOrderType orderType = enumOutOrderType.销售出库)
|
||
{
|
||
maxLocCnt = maxLocCnt<=0?WmsConstants.MAX_PICK_LOT_CNT:maxLocCnt;
|
||
maxBoxs = maxBoxs <= 0 ? WmsConstants.MAX_PICK_BOX_CNT : maxBoxs;
|
||
|
||
int lotcnt = 0,boxcnt=0;
|
||
WmsOutPickPort wop;
|
||
DataTable dt = getWmsOutPickPort.getAssignedTasks(taskBy, -1, -1, batchOnly,orderType);
|
||
|
||
lotcnt = dt.Rows.Count;
|
||
if (lotcnt >= maxLocCnt)
|
||
{
|
||
LogHelper.debug("lWmsOutPickPort", " user " + taskBy + "no more task assign, task lotcnt :" + lotcnt);
|
||
|
||
return;
|
||
}
|
||
foreach (DataRow dr in dt.Rows)
|
||
{
|
||
wop = new WmsOutPickPort(dr);
|
||
try
|
||
{
|
||
boxcnt += Convert.ToInt32(dr["boxcnt"].ToString());
|
||
}
|
||
catch { }
|
||
if (boxcnt >=maxBoxs )
|
||
{
|
||
LogHelper.debug("lWmsOutPickPort", " user " + taskBy + "no more task assign, task Assigned box cnt :" + boxcnt);
|
||
return;
|
||
}
|
||
|
||
// wop.operater = operId;
|
||
}
|
||
|
||
|
||
dt = getWmsOutPickPort.getFreeTasks(partion, lineId, batchOnly,orderType,taskBy);
|
||
|
||
|
||
lWmsStock lstk = new lWmsStock(operId);
|
||
|
||
|
||
using (TransactionScope scope = new TransactionScope())
|
||
{
|
||
foreach (DataRow dr in dt.Rows)
|
||
{
|
||
wop = new WmsOutPickPort(dr);
|
||
|
||
lotcnt++;
|
||
boxcnt += Convert.ToInt16(dr["boxcnt"].ToString());
|
||
|
||
if (lotcnt > maxLocCnt || boxcnt >maxBoxs )
|
||
{
|
||
break;
|
||
}
|
||
wop.takeBy = taskBy;
|
||
// wop.operater = operId;
|
||
wop.Update();
|
||
LogHelper.debug("lWmsOutPickPort", " user " + taskBy + " task Assign :" + wop.ID);
|
||
|
||
|
||
if (wop.recType != (int)enumStockRecordType.补零出库)
|
||
{
|
||
continue;
|
||
}
|
||
//to create inport data
|
||
int skuId = Convert.ToInt32(dr["skuId"].ToString());
|
||
string goodsId =dr["goodsId"].ToString();
|
||
string batch =dr["batch"].ToString();
|
||
string skucode = dr["skucode"].ToString();
|
||
string prdtime = dr["productDate"].ToString();
|
||
string vltime = dr["validDate"].ToString();
|
||
DataTable dtBulkLocs = lstk.getBulkLocations(skuId, "",goodsId , batch, wop.count);
|
||
foreach (DataRow dr1 in dtBulkLocs.Rows)
|
||
{
|
||
|
||
//todo: to add stock record
|
||
|
||
WmsInUpPort wip = new WmsInUpPort();
|
||
wip.locationId = dr1[0].ToString();
|
||
wip.count =Convert.ToDecimal( dr1[1].ToString());
|
||
wip.orderNo = wop.pickOrderNo;
|
||
wip.skuId = skuId;
|
||
wip.skuCode = skucode;
|
||
wip.batch = batch;
|
||
wip.goodsId = goodsId;
|
||
wip.detailId = wop.pickDetailId;
|
||
wip.recType = (int)enumStockRecordType.补零入库;
|
||
wip.recordId = wop.recordId;
|
||
wip.productDate = prdtime;
|
||
wip.validDate = vltime;
|
||
wip.flowNo = "0";
|
||
|
||
WmsLocation loc = new WmsLocation(wip.locationId);
|
||
|
||
Node nd = new Node( loc.part);
|
||
if (nd.ID > 0)
|
||
{
|
||
wip.partion = nd.flag;
|
||
}
|
||
wip.Add();
|
||
|
||
//create stock,lock the location
|
||
|
||
WmsStock newStk = new WmsStock(wip.locationId, skuId);
|
||
|
||
if (newStk.ID == 0) //new one
|
||
{
|
||
newStk.countIn = wip.count;
|
||
newStk.skuCode = skucode;
|
||
newStk.goodsId = goodsId;
|
||
newStk.skuId = skuId;
|
||
newStk.locationId = wip.locationId ;
|
||
newStk.batch = batch;
|
||
newStk.productDate = wip.productDate;
|
||
newStk.validDate = wip.validDate;
|
||
newStk.maintainDate = newStk.getDateTime();
|
||
newStk.Add();
|
||
}
|
||
|
||
|
||
}
|
||
|
||
|
||
|
||
}
|
||
scope.Complete();
|
||
}
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 取总播种操作
|
||
/// </summary>
|
||
/// <param name="flowNo">取总板号</param>
|
||
/// <param name="outDetailId">销售明细id</param>
|
||
/// <param name="seedCnt">分播数量</param>
|
||
/// <param name="toFlowNo">周转箱号</param>
|
||
/// <returns></returns>
|
||
internal enumRepResult seedsPickOut(string flowNo,string batch, int outDetailId, decimal seedCnt,string toFlowNo)
|
||
{
|
||
WmsOutDetail wod = new WmsOutDetail(outDetailId);
|
||
WmsOutRequest wor = new WmsOutRequest(wod.orderNo);
|
||
wod.pickCount += seedCnt;
|
||
|
||
|
||
// pickport with flowno can be multi records, update the finished seeds count in loop
|
||
|
||
DataTable dt = getWmsOutPickPort.getFlowNoDetails(flowNo,wod.goodsId,batch);
|
||
List<WmsOutPickPort> lst = new List<WmsOutPickPort>();
|
||
|
||
decimal tmpCnt = seedCnt;
|
||
foreach(DataRow dr in dt.Rows)
|
||
{
|
||
WmsOutPickPort wop = new WmsOutPickPort(dr);
|
||
if (wop.state == 1)
|
||
{
|
||
if (wop.seedsOutCount + tmpCnt <= wop.pickCount)
|
||
{
|
||
wop.seedsOutCount += tmpCnt;
|
||
lst.Add(wop);
|
||
tmpCnt= 0;
|
||
break;
|
||
}
|
||
else
|
||
{
|
||
tmpCnt -= wop.pickCount - wop.seedsOutCount;
|
||
wop.seedsOutCount = wop.pickCount;
|
||
wop.state = (int)enumPickState.已分播;
|
||
lst.Add(wop);
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
|
||
if(tmpCnt > 0)
|
||
{
|
||
return enumRepResult.分播数量大于剩余数量;
|
||
}
|
||
|
||
|
||
using (TransactionScope scope = new TransactionScope())
|
||
{
|
||
wod.Update();
|
||
WmsStockRecord wsr = new WmsStockRecord();
|
||
wsr.orderNo = wod.orderNo;
|
||
wsr.orderDetailId = wod.ID;
|
||
wsr.goodsId =wod.goodsId;
|
||
wsr.count = seedCnt;
|
||
wsr.locationId = flowNo;
|
||
wsr.Add();
|
||
|
||
WmsOutPickPort wop = new WmsOutPickPort();
|
||
wop.recordId = wsr.ID;
|
||
wop.pickBy = operId;
|
||
wop.pickTime = wop.getDateTime();
|
||
wop.pickCount = seedCnt;
|
||
wop.pickOrderNo = wor.pickOrderNo;
|
||
wop.state = (int)enumPickState.已分播;
|
||
wop.recType = (int)enumStockRecordType.销售出库;
|
||
wop.seedsFromFlowNo = flowNo;
|
||
wop.flowNo = toFlowNo;
|
||
wop.Add();
|
||
|
||
foreach(WmsOutPickPort tmp in lst)
|
||
{
|
||
tmp.Update();
|
||
}
|
||
scope.Complete();
|
||
}
|
||
|
||
|
||
|
||
return enumRepResult.成功;
|
||
}
|
||
|
||
internal DataTable getSeedsPickDetail(string flowNo, bool isOrderByCust)
|
||
{
|
||
return getWmsOutPickPort.getSeedsPickDetail(flowNo, isOrderByCust);
|
||
}
|
||
|
||
/*
|
||
* 取消拣货任务
|
||
*
|
||
*/
|
||
public int taskRessign(int taskBy, int partion, int lineId, bool batchOnly = true, enumOutOrderType orderType = enumOutOrderType.销售出库)
|
||
{
|
||
DataTable dt = getWmsOutPickPort.getAssignedTasks(taskBy, partion, lineId, batchOnly,orderType);
|
||
int i=0;
|
||
WmsOutPickPort wop;
|
||
using (TransactionScope scope = new TransactionScope())
|
||
{
|
||
foreach (DataRow dr in dt.Rows)
|
||
{
|
||
wop = new WmsOutPickPort(dr);
|
||
|
||
wop.takeBy = 0;
|
||
// wop.operater = operId;
|
||
if (wop.state == (int)enumPickState.未拣)
|
||
{
|
||
wop.Update();
|
||
i++;
|
||
LogHelper.debug("lWmsOutPickPort", " user " + taskBy + " task resign:" + wop.ID);
|
||
}
|
||
|
||
}
|
||
scope.Complete();
|
||
}
|
||
return i;
|
||
}
|
||
|
||
public DataTable getAssignedTasks4Wince(int taskBy, int partion = 0, int lineId = -1, bool batchOnly = true,enumOutOrderType orderType = enumOutOrderType.销售出库)
|
||
{
|
||
return getWmsOutPickPort.getAssignedTasks4Wince(taskBy, partion, lineId, batchOnly, orderType);
|
||
|
||
}
|
||
|
||
public DataTable getAssignedOutTasks(int taskBy, int partion = 0, int lineId = -1, bool batchOnly = true, enumOutOrderType orderType = enumOutOrderType.销售出库)
|
||
{
|
||
return getWmsOutPickPort.getAssignedTasks(taskBy, partion, lineId, batchOnly, orderType);
|
||
|
||
}
|
||
|
||
|
||
public DataTable getPartions(int userID)
|
||
{
|
||
return getWmsOutPickPort.getPartions(userID);
|
||
}
|
||
|
||
internal DataTable getRepTasks(int takeBy, int taskPartion )
|
||
{
|
||
return getWmsOutPickPort.getRepTasks(takeBy, taskPartion );
|
||
}
|
||
}
|
||
|
||
|
||
}
|
||
|