Compare commits
5 Commits
SanYing_DA
...
beijing_zh
| Author | SHA1 | Date | |
|---|---|---|---|
| 7c1ab8ce69 | |||
| d5e45f63b4 | |||
| 406c7a9733 | |||
| ba8edecb11 | |||
| 9019532c9f |
@ -182,10 +182,18 @@ namespace Epost.BLL
|
|||||||
return dal.GetAreaList();
|
return dal.GetAreaList();
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 获取所有小区
|
#region 获取所有小区
|
||||||
public List<AddressstorageModel> GetAreaList(string block = "")
|
public List<AddressstorageModel> GetAreaList(string block = "", string shelfid = "")
|
||||||
{
|
{
|
||||||
return dal.GetAreaList(block);
|
return dal.GetAreaList(block, shelfid);
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 获取所有小区
|
||||||
|
public List<AddressstorageModel> GetshelfidList(string block = "")
|
||||||
|
{
|
||||||
|
return dal.GetshelfidList(block);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
#region 获取所有通道
|
#region 获取所有通道
|
||||||
|
|||||||
@ -19,13 +19,11 @@ namespace Epost.BLL
|
|||||||
public class CommandBLL
|
public class CommandBLL
|
||||||
{
|
{
|
||||||
CommandDAL dal = new CommandDAL();
|
CommandDAL dal = new CommandDAL();
|
||||||
XgateCacheDAL xageDAL = new XgateCacheDAL();
|
|
||||||
AddressstorageBLL addrBLL = new AddressstorageBLL();
|
AddressstorageBLL addrBLL = new AddressstorageBLL();
|
||||||
public static DataTable Controls = new DataTable();
|
public static DataTable Controls = new DataTable();
|
||||||
public static DataTable Labels = new DataTable();
|
public static DataTable Labels = new DataTable();
|
||||||
JobDownCacheDAL JobCache = new JobDownCacheDAL();
|
|
||||||
OrdersDAL orderDal = new OrdersDAL();
|
|
||||||
ConfigurationOperator txtbll = new ConfigurationOperator();
|
|
||||||
string IP = ConfigurationManager.AppSettings["WebAPIUrl"];
|
string IP = ConfigurationManager.AppSettings["WebAPIUrl"];
|
||||||
|
|
||||||
#region 初始化数据
|
#region 初始化数据
|
||||||
@ -127,7 +125,7 @@ namespace Epost.BLL
|
|||||||
lablemodel.Mode = "10";
|
lablemodel.Mode = "10";
|
||||||
list.Add(lablemodel);
|
list.Add(lablemodel);
|
||||||
}
|
}
|
||||||
|
|
||||||
//result= combll.DISPLAY_JOB(model);
|
//result= combll.DISPLAY_JOB(model);
|
||||||
|
|
||||||
}
|
}
|
||||||
@ -151,23 +149,7 @@ namespace Epost.BLL
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 获取参数中文
|
|
||||||
public string GETDISPLAYJOBPAR_CN(string no, string Lightcolor, string IsTwinkle, string Title, string BigQuantity, string BigUnit, string Quantity, string Unit, string Content, string Rfcode)
|
|
||||||
{
|
|
||||||
string parar = no + "00" + Lightcolor + IsTwinkle + "30CQ" + Title + "\n\n" + BigQuantity + "\n" + BigUnit + "\n" + Quantity + "\n" + Unit + "\n" + Content + "\n00\n\n" + Rfcode + "\n"; ;
|
|
||||||
return parar;
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 获取参数数字
|
|
||||||
public string GETDISPLAYJOBPAR(string no, string Lightcolor, string IsTwinkle, string location, string Quantity, string Rfcode)
|
|
||||||
{
|
|
||||||
string parar = no + Lightcolor + IsTwinkle + "30NQ" + location + "\n" + Quantity + "\n" + Rfcode + "\n";
|
|
||||||
return parar;
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 清除
|
#region 清除
|
||||||
public void clearALL_M()
|
public void clearALL_M()
|
||||||
@ -188,10 +170,7 @@ namespace Epost.BLL
|
|||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
#region M系列
|
|
||||||
|
|
||||||
#region 格式化任务数据
|
#region 格式化任务数据
|
||||||
public bool FORMATE_JOB_DATA(LabelParamModel model)
|
public bool FORMATE_JOB_DATA(LabelParamModel model)
|
||||||
@ -214,39 +193,8 @@ namespace Epost.BLL
|
|||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 进入设置模式
|
|
||||||
public bool ENTER_CONFIG_MODE(LabelParamModel model)
|
|
||||||
{
|
|
||||||
|
|
||||||
|
|
||||||
return dal.ENTER_CONFIG_MODE(model);
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 设置地址 （传参地址 内容）
|
|
||||||
public bool SET_ADDRESS(LabelParamModel model)
|
|
||||||
{
|
|
||||||
return dal.SET_ADDRESS(model);
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 删除地址 （传参地址 内容）
|
|
||||||
public bool DELETE_ADDRESS(LabelParamModel model)
|
|
||||||
{
|
|
||||||
return dal.DELETE_ADDRESS(model);
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 退出设置模式
|
|
||||||
public bool EXIT_CONFIG_MODE(LabelParamModel model)
|
|
||||||
{
|
|
||||||
|
|
||||||
return dal.EXIT_CONFIG_MODE(model);
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 任务指令(传参地址)
|
#region 任务指令(传参地址)
|
||||||
public void DISPLAY_JOB_M(LabelParamModel model, bool clear = false, bool islock = false)
|
public void DISPLAY_JOB_M(LabelParamModel model, bool clear = false, bool islock = false )
|
||||||
{
|
{
|
||||||
List<LabelParamModel> list = new List<LabelParamModel>();
|
List<LabelParamModel> list = new List<LabelParamModel>();
|
||||||
if (clear)
|
if (clear)
|
||||||
@ -259,14 +207,14 @@ namespace Epost.BLL
|
|||||||
clearModel.Command = "REMOVE_JOB";
|
clearModel.Command = "REMOVE_JOB";
|
||||||
clearModel.Timeout = "0.5";
|
clearModel.Timeout = "0.5";
|
||||||
clearModel.Type = model.Type;
|
clearModel.Type = model.Type;
|
||||||
// dal.REMOVE_JOB(clearModel);
|
// dal.REMOVE_JOB(clearModel);
|
||||||
list.Add(clearModel);
|
list.Add(clearModel);
|
||||||
}
|
}
|
||||||
LabelParamModel DisplayModel = new LabelParamModel();
|
LabelParamModel DisplayModel = new LabelParamModel();
|
||||||
DisplayModel.Address = model.Address;
|
DisplayModel.Address = model.Address;
|
||||||
DisplayModel.ControlIP = model.ControlIP;
|
DisplayModel.ControlIP = model.ControlIP;
|
||||||
DisplayModel.Content = model.Content;
|
DisplayModel.Content =model.Content;
|
||||||
DisplayModel.Title = model.Title;
|
DisplayModel.Title =model.Title;
|
||||||
DisplayModel.Loc = model.Loc;
|
DisplayModel.Loc = model.Loc;
|
||||||
DisplayModel.Quantity = model.Quantity;
|
DisplayModel.Quantity = model.Quantity;
|
||||||
DisplayModel.Uid = model.Uid;
|
DisplayModel.Uid = model.Uid;
|
||||||
@ -307,7 +255,6 @@ namespace Epost.BLL
|
|||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
#region 任务指令(传参地址)
|
#region 任务指令(传参地址)
|
||||||
public void LED_ON_M(LabelParamModel model, bool islock = false)
|
public void LED_ON_M(LabelParamModel model, bool islock = false)
|
||||||
{
|
{
|
||||||
@ -353,6 +300,7 @@ namespace Epost.BLL
|
|||||||
dal.DISPLAY_JOBALL(list);
|
dal.DISPLAY_JOBALL(list);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region LED_OFF(传参地址)
|
#region LED_OFF(传参地址)
|
||||||
public void LED_OFF_M(List<JobModel> list)
|
public void LED_OFF_M(List<JobModel> list)
|
||||||
{
|
{
|
||||||
@ -362,17 +310,15 @@ namespace Epost.BLL
|
|||||||
LabelParamModel clearModel = new LabelParamModel();
|
LabelParamModel clearModel = new LabelParamModel();
|
||||||
clearModel.Address = model.Address;
|
clearModel.Address = model.Address;
|
||||||
clearModel.ControlIP = model.ControlIP;
|
clearModel.ControlIP = model.ControlIP;
|
||||||
|
|
||||||
clearModel.Command = "LED_OFF";
|
clearModel.Command = "LED_OFF";
|
||||||
clearModel.Timeout = "0.5";
|
clearModel.Timeout = "0.5";
|
||||||
sendlist.Add(clearModel);
|
sendlist.Add(clearModel);
|
||||||
}
|
}
|
||||||
dal.DISPLAY_JOBALL(sendlist);
|
dal.DISPLAY_JOBALL(sendlist);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#region LED_OFF(传参地址)
|
#region LED_OFF(传参地址)
|
||||||
public void LED_OFF_CLEAR(string ip)
|
public void LED_OFF_CLEAR(string ip)
|
||||||
{
|
{
|
||||||
@ -385,6 +331,7 @@ namespace Epost.BLL
|
|||||||
dal.Send(clearModel);
|
dal.Send(clearModel);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region LED_OFF(传参地址)
|
#region LED_OFF(传参地址)
|
||||||
public void LED_OFF_CLEAR(List<JobModel> offList)
|
public void LED_OFF_CLEAR(List<JobModel> offList)
|
||||||
{
|
{
|
||||||
@ -401,14 +348,13 @@ namespace Epost.BLL
|
|||||||
clearModel.Timeout = "0.5";
|
clearModel.Timeout = "0.5";
|
||||||
list.Add(clearModel);
|
list.Add(clearModel);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
dal.SendALL(list);
|
dal.SendALL(list);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
#region 任务指令(传参地址)
|
#region 任务指令(传参地址)
|
||||||
public bool DISPLAY_JOB(LabelParamModel model)
|
public bool DISPLAY_JOB(LabelParamModel model)
|
||||||
{
|
{
|
||||||
@ -424,6 +370,7 @@ namespace Epost.BLL
|
|||||||
dal.DISPLAY_JOBALL(model);
|
dal.DISPLAY_JOBALL(model);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 初始化
|
#region 初始化
|
||||||
public ResultModel SendALL_Init(List<LabelParamModel> model)
|
public ResultModel SendALL_Init(List<LabelParamModel> model)
|
||||||
{
|
{
|
||||||
@ -431,7 +378,7 @@ namespace Epost.BLL
|
|||||||
return dal.SendALL_Init(model);
|
return dal.SendALL_Init(model);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 移除任务指令(传参地址)
|
#region 移除任务指令(传参地址)
|
||||||
public bool REMOVE_JOB(LabelParamModel model)
|
public bool REMOVE_JOB(LabelParamModel model)
|
||||||
{
|
{
|
||||||
@ -439,6 +386,7 @@ namespace Epost.BLL
|
|||||||
return dal.REMOVE_JOB(model);
|
return dal.REMOVE_JOB(model);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 通道灯命令
|
#region 通道灯命令
|
||||||
public bool DISPLAY_LIGHT(LabelParamModel model)
|
public bool DISPLAY_LIGHT(LabelParamModel model)
|
||||||
{
|
{
|
||||||
@ -455,8 +403,6 @@ namespace Epost.BLL
|
|||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#region 终端解锁指令
|
#region 终端解锁指令
|
||||||
public bool UNLOCK(LabelParamModel model)
|
public bool UNLOCK(LabelParamModel model)
|
||||||
{
|
{
|
||||||
@ -465,30 +411,6 @@ namespace Epost.BLL
|
|||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 扫描枪使能
|
|
||||||
public bool SET_SCANDEVICE_ON(LabelParamModel model)
|
|
||||||
{
|
|
||||||
|
|
||||||
return dal.SET_SCANDEVICE_ON(model);
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 扫描枪不使能
|
|
||||||
public bool SET_SCANDEVICE_OFF(LabelParamModel model)
|
|
||||||
{
|
|
||||||
|
|
||||||
return dal.SET_SCANDEVICE_OFF(model);
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 清除扫描枪
|
|
||||||
public bool SET_SCANDEVICE_CLEAR(LabelParamModel model)
|
|
||||||
{
|
|
||||||
|
|
||||||
return dal.SET_SCANDEVICE_CLEAR(model);
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 休眠
|
#region 休眠
|
||||||
public bool SLEEP(LabelParamModel model)
|
public bool SLEEP(LabelParamModel model)
|
||||||
{
|
{
|
||||||
@ -509,7 +431,7 @@ namespace Epost.BLL
|
|||||||
|
|
||||||
LabelParamModel model = new LabelParamModel();
|
LabelParamModel model = new LabelParamModel();
|
||||||
model.ControlIP = item["ControlIP"].ToString();
|
model.ControlIP = item["ControlIP"].ToString();
|
||||||
FORMATE_JOB_DATA(model);
|
FORMATE_JOB_DATA(model);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -553,7 +475,7 @@ namespace Epost.BLL
|
|||||||
{
|
{
|
||||||
// DataTable dt = addrBLL.getAddresslist(block,area,type);
|
// DataTable dt = addrBLL.getAddresslist(block,area,type);
|
||||||
|
|
||||||
if (offList.Any())
|
if(offList.Any())
|
||||||
{
|
{
|
||||||
List<LabelParamModel> list = new List<LabelParamModel>();
|
List<LabelParamModel> list = new List<LabelParamModel>();
|
||||||
foreach (JobModel item in offList)
|
foreach (JobModel item in offList)
|
||||||
@ -570,7 +492,7 @@ namespace Epost.BLL
|
|||||||
Unlockmodel.ControlIP = item.ControlIP;
|
Unlockmodel.ControlIP = item.ControlIP;
|
||||||
Unlockmodel.Address = item.Address;
|
Unlockmodel.Address = item.Address;
|
||||||
Unlockmodel.Command = "UNLOCK";
|
Unlockmodel.Command = "UNLOCK";
|
||||||
|
|
||||||
Unlockmodel.Type = "N";
|
Unlockmodel.Type = "N";
|
||||||
Unlockmodel.Parameter = "11111000";
|
Unlockmodel.Parameter = "11111000";
|
||||||
list.Add(Unlockmodel);
|
list.Add(Unlockmodel);
|
||||||
@ -612,28 +534,29 @@ namespace Epost.BLL
|
|||||||
|
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 点亮显示标签
|
#region 点亮显示标签
|
||||||
public void ShowBoxMessage_M(ShowMessageModel_M show)
|
public void ShowBoxMessage_M(ShowMessageModel_M show)
|
||||||
{
|
{
|
||||||
//获取作业区对应的显示标签地址
|
//获取作业区对应的显示标签地址
|
||||||
DataTable showaddrDT = addrBLL.GetBoxAddress(show.Block, show.Area, show.Type);
|
DataTable showaddrDT = addrBLL.GetBoxAddress(show.Block,show.Area,show.Type);
|
||||||
if (showaddrDT != null && showaddrDT.Rows.Count > 0)
|
if (showaddrDT != null && showaddrDT.Rows.Count > 0)
|
||||||
{
|
{
|
||||||
foreach (DataRow addritem in showaddrDT.Rows)
|
foreach (DataRow addritem in showaddrDT.Rows)
|
||||||
{
|
{
|
||||||
|
|
||||||
LabelParamModel lablemodel = new LabelParamModel();
|
LabelParamModel lablemodel = new LabelParamModel();
|
||||||
lablemodel.Address = addritem["address"].ToString();
|
lablemodel.Address = addritem["address"].ToString();
|
||||||
lablemodel.ControlIP = addritem["controlip"].ToString();
|
lablemodel.ControlIP = addritem["controlip"].ToString();
|
||||||
lablemodel.Command = "DISPLAY_JOB";
|
lablemodel.Command = "DISPLAY_JOB";
|
||||||
lablemodel.Uid = show.Uid;
|
lablemodel.Uid =show.Uid;
|
||||||
if (string.IsNullOrEmpty(show.Uid))
|
if (string.IsNullOrEmpty(show.Uid))
|
||||||
{ lablemodel.Uid = show.No + addritem["address"].ToString(); }
|
{ lablemodel.Uid = addritem["address"].ToString(); }
|
||||||
|
|
||||||
lablemodel.Mode = show.Color + "0";
|
lablemodel.Mode = show.Color + "0";
|
||||||
if (addritem["addresstype"].ToString() == "2")
|
if (addritem["addresstype"].ToString() == "2")
|
||||||
{
|
{
|
||||||
|
|
||||||
lablemodel.Type = "C";
|
lablemodel.Type = "C";
|
||||||
lablemodel.Loc = show.Location;
|
lablemodel.Loc = show.Location;
|
||||||
lablemodel.Title = show.Title;
|
lablemodel.Title = show.Title;
|
||||||
@ -646,13 +569,13 @@ namespace Epost.BLL
|
|||||||
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
lablemodel.Type = "N";
|
lablemodel.Type = "N";
|
||||||
lablemodel.Quantity = show.Qty;
|
lablemodel.Quantity = show.Qty;
|
||||||
lablemodel.Loc = show.Location;
|
lablemodel.Loc = show.Location;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
DISPLAY_JOB_M(lablemodel, true, show.Islock);
|
DISPLAY_JOB_M(lablemodel, true, show.Islock);
|
||||||
LogHelper.WriteLogInfo("点亮显示标签" + addritem["address"].ToString());
|
LogHelper.WriteLogInfo("点亮显示标签" + addritem["address"].ToString());
|
||||||
|
|
||||||
@ -691,7 +614,7 @@ namespace Epost.BLL
|
|||||||
model.Type = "T";
|
model.Type = "T";
|
||||||
model.Address = item["address"].ToString();
|
model.Address = item["address"].ToString();
|
||||||
model.ControlIP = item["ControlIP"].ToString();
|
model.ControlIP = item["ControlIP"].ToString();
|
||||||
model.Parameter = ConvertHexHelper.ConvertString(item["addresstype"].ToString(), 10, 16).ToString().PadLeft(2, '0') + isoff;
|
model.Parameter = ConvertHexHelper.ConvertString(item["addresstype"].ToString(), 10, 16).ToString().PadLeft(2,'0')+ isoff;
|
||||||
list.Add(model);
|
list.Add(model);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -711,16 +634,24 @@ namespace Epost.BLL
|
|||||||
List<LabelParamModel> list = new List<LabelParamModel>();
|
List<LabelParamModel> list = new List<LabelParamModel>();
|
||||||
foreach (DataRow addritem in showaddrDT.Rows)
|
foreach (DataRow addritem in showaddrDT.Rows)
|
||||||
{
|
{
|
||||||
|
|
||||||
LabelParamModel model = new LabelParamModel();
|
LabelParamModel model = new LabelParamModel();
|
||||||
model.Address = addritem["address"].ToString();
|
model.Address = addritem["address"].ToString();
|
||||||
model.ControlIP = addritem["controlip"].ToString();
|
model.ControlIP = addritem["controlip"].ToString();
|
||||||
model.Parameter = show.No;
|
model.Parameter =show.No;
|
||||||
|
model.Uid = show.Uid;
|
||||||
|
if (string.IsNullOrEmpty(show.Uid))
|
||||||
|
{ model.Uid = addritem["address"].ToString(); }
|
||||||
|
model.Type = "N";
|
||||||
|
if (addritem["addresstype"].ToString() == "2")
|
||||||
|
{
|
||||||
|
model.Type = "C";
|
||||||
|
}
|
||||||
model.Command = "REMOVE_JOB";
|
model.Command = "REMOVE_JOB";
|
||||||
model.Timeout = "0.5";
|
model.Timeout = "0.5";
|
||||||
list.Add(model);
|
list.Add(model);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (list != null && list.Count > 0)
|
if (list != null && list.Count > 0)
|
||||||
{
|
{
|
||||||
LogHelper.WriteLogInfo("熄灭点亮的list———————：" + list.Count);
|
LogHelper.WriteLogInfo("熄灭点亮的list———————：" + list.Count);
|
||||||
@ -728,16 +659,16 @@ namespace Epost.BLL
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#endregion
|
#endregion
|
||||||
#endregion
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -115,6 +115,9 @@
|
|||||||
<Compile Include="UserBLL.cs" />
|
<Compile Include="UserBLL.cs" />
|
||||||
<Compile Include="WmsBLL.cs" />
|
<Compile Include="WmsBLL.cs" />
|
||||||
<Compile Include="WmsTaskBLL.cs" />
|
<Compile Include="WmsTaskBLL.cs" />
|
||||||
|
<Compile Include="Work_DisplayJobThread.cs" />
|
||||||
|
<Compile Include="Work_JobDownThread.cs" />
|
||||||
|
<Compile Include="Work_ScanThread.cs" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<ProjectReference Include="..\Common\Epost.Common.csproj">
|
<ProjectReference Include="..\Common\Epost.Common.csproj">
|
||||||
|
|||||||
@ -30,44 +30,7 @@ namespace Epost.BLL
|
|||||||
UserModelCacheDAL UserCacheDAL = new UserModelCacheDAL();
|
UserModelCacheDAL UserCacheDAL = new UserModelCacheDAL();
|
||||||
private static object lockbox = new object();
|
private static object lockbox = new object();
|
||||||
|
|
||||||
#region 绑定箱号
|
|
||||||
public void BindBoxCode()
|
|
||||||
{
|
|
||||||
lock (lockbox)
|
|
||||||
{
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
|
|
||||||
//查询待绑定的订单/设备
|
|
||||||
DataTable qudt = queueboxBLL.getQueuesbyState();
|
|
||||||
if (qudt != null && qudt.Rows.Count > 0)
|
|
||||||
{
|
|
||||||
foreach (DataRow item in qudt.Rows)
|
|
||||||
{
|
|
||||||
LabelParamModel model = new LabelParamModel();
|
|
||||||
string address = item["address"].ToString();
|
|
||||||
model.Address = address;
|
|
||||||
model.ControlIP = item["controlip"].ToString();
|
|
||||||
// model.Parameter = "0100000100030CQ请扫描箱号/托盘号\n\n\n\n\n\n门店编号：" + item["shopid"].ToString() + "\n\n\n\n";
|
|
||||||
model.Parameter = comBLL.GETDISPLAYJOBPAR_CN("01", "001000", "0", "请扫描箱号/托盘号", "", "", "", "", "门店编号：" + item["shopid"].ToString(), "");
|
|
||||||
comBLL.DISPLAY_JOB_M(model, true, true);
|
|
||||||
queueboxBLL.UpdateQueueState(item["id"].ToString(), "1");
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
//点亮设备
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("绑定箱号异常：" + ex.Message);
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 查询控制器列表
|
#region 查询控制器列表
|
||||||
public DataTable getControlList(int type = 0)
|
public DataTable getControlList(int type = 0)
|
||||||
@ -499,27 +462,14 @@ namespace Epost.BLL
|
|||||||
//点亮当前货位对应设备提示扫箱号
|
//点亮当前货位对应设备提示扫箱号
|
||||||
LabelParamModel model = new LabelParamModel();
|
LabelParamModel model = new LabelParamModel();
|
||||||
model.Address = address;
|
model.Address = address;
|
||||||
model.ControlIP = controlip;
|
model.ControlIP = controlip;
|
||||||
// model.Parameter = "0700000100330CQ请扫描箱号!\n\n\n\n\n\n\n\n\n\n";
|
// model.Parameter = comBLL.GETDISPLAYJOBPAR_CN("07", "000100", "3", "请扫描箱号!", "", "", "", "", "门店号:" + shopid + "\r箱 号：" + boxcode + "\r托盘号:" + traycode, "");
|
||||||
model.Parameter = comBLL.GETDISPLAYJOBPAR_CN("07", "000100", "3", "请扫描箱号!", "", "", "", "", "门店号:" + shopid + "\r箱 号：" + boxcode + "\r托盘号:" + traycode, "");
|
|
||||||
comBLL.DISPLAY_JOB_M(model, true, true);
|
comBLL.DISPLAY_JOB_M(model, true, true);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
#region 修改数量异常提示
|
|
||||||
public void changeNumErr(string address, string controlip)
|
|
||||||
{
|
|
||||||
//点亮当前货位对应设备提示扫箱号
|
|
||||||
LabelParamModel model = new LabelParamModel();
|
|
||||||
model.Address = address;
|
|
||||||
model.ControlIP = controlip;
|
|
||||||
model.Parameter = comBLL.GETDISPLAYJOBPAR_CN("05", "000100", "3", "修改数量超出需求数量！", "", "", "", "", "", "");
|
|
||||||
comBLL.DISPLAY_JOB_M(model, true, false);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 恢复当前标签拣货
|
#region 恢复当前标签拣货
|
||||||
public void displayJob_err(string address, string controlip, JobModel job)
|
public void displayJob_err(string address, string controlip, JobModel job)
|
||||||
@ -530,15 +480,9 @@ namespace Epost.BLL
|
|||||||
lamodel.ControlIP = controlip;
|
lamodel.ControlIP = controlip;
|
||||||
lamodel.Command = "DISPLAY_JOB";
|
lamodel.Command = "DISPLAY_JOB";
|
||||||
string qty = ConvertHexHelper.ConvertString(job.Quantity.ToString(), 10, 16); //拣货数量
|
string qty = ConvertHexHelper.ConvertString(job.Quantity.ToString(), 10, 16); //拣货数量
|
||||||
string CheckQuantity = ConvertHexHelper.ConvertString(job.CheckQuantity.ToString(), 10, 16); //拣货数量
|
string CheckQuantity = ConvertHexHelper.ConvertString(job.CheckQuantity.ToString(), 10, 16); //拣货数量
|
||||||
// lamodel.Parameter = "01" + EnumHelper.EMToDescriptionString(LightColor.Color.Green) + "030NQ" +item.Zone +"\n" + qty;
|
// lamodel.Parameter = comBLL.GETDISPLAYJOBPAR_CN("01", job.ColorCode, "0", job.GoodsName, CheckQuantity, job.WholeUnit, qty, job.Unit, job.Sku, job.UserCode);//item.UserCode
|
||||||
//lamodel.Parameter = "0100" + queueDT.Rows[0]["lightcolor"].ToString() + "030CQ" + item.GoodsName + "\n\n" + CheckQuantity + "\n" + item.WholeUnit + "\n" + qty + "\n" + item.Unit + "\n" + item.Sku + "\n\n\n\n";
|
|
||||||
lamodel.Parameter = comBLL.GETDISPLAYJOBPAR_CN("01", job.ColorCode, "0", job.GoodsName, CheckQuantity, job.WholeUnit, qty, job.Unit, job.Sku, job.UserCode);//item.UserCode
|
|
||||||
|
|
||||||
|
|
||||||
comBLL.DISPLAY_JOB_M(lamodel, true, false);
|
comBLL.DISPLAY_JOB_M(lamodel, true, false);
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
public void BindJobListBySku(string sku)
|
public void BindJobListBySku(string sku)
|
||||||
@ -556,13 +500,11 @@ namespace Epost.BLL
|
|||||||
LocCacheDAL.UpdateLocModelList(new List<OrderListModel> { data }, ELCommend.Update);
|
LocCacheDAL.UpdateLocModelList(new List<OrderListModel> { data }, ELCommend.Update);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
LogHelper.WriteLogInfo("绑定任务异常：" + ex.Message);
|
LogHelper.WriteLogInfo("绑定任务异常：" + ex.Message);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
public bool bindOrder(string sku, string block, string matchid = "", string usercode = "", string area = "", int sort = 0, string lightColor = "010000")
|
public bool bindOrder(string sku, string block, string matchid = "", string usercode = "", string area = "", int sort = 0, string lightColor = "010000")
|
||||||
{
|
{
|
||||||
@ -581,8 +523,6 @@ namespace Epost.BLL
|
|||||||
bool qubo = queueBLL.insertQueueOrders(unmodel);
|
bool qubo = queueBLL.insertQueueOrders(unmodel);
|
||||||
return qubo;
|
return qubo;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public void bindShop(string shopcode, string usercode, List<ResultMessageModel> list, ResultMessageModel data)
|
public void bindShop(string shopcode, string usercode, List<ResultMessageModel> list, ResultMessageModel data)
|
||||||
{
|
{
|
||||||
|
|
||||||
@ -739,12 +679,12 @@ namespace Epost.BLL
|
|||||||
List<JobModel> list = new List<JobModel>();
|
List<JobModel> list = new List<JobModel>();
|
||||||
DataTable OrderDt = dal.GetOrderList_Car(matchid, sku, area, block);
|
DataTable OrderDt = dal.GetOrderList_Car(matchid, sku, area, block);
|
||||||
bool isecho = false;
|
bool isecho = false;
|
||||||
//if (OrderDt == null || OrderDt.Rows.Count == 0)//回显
|
if (OrderDt == null || OrderDt.Rows.Count == 0)//回显
|
||||||
//{
|
{
|
||||||
// OrderDt = dal.GetOrderList_Car(matchid, sku, area, block);
|
OrderDt = dal.GetOrderList_echo(matchid, sku, area, block);
|
||||||
// isecho = true;
|
isecho = true;
|
||||||
|
|
||||||
//}
|
}
|
||||||
if (OrderDt != null && OrderDt.Rows.Count > 0)
|
if (OrderDt != null && OrderDt.Rows.Count > 0)
|
||||||
{
|
{
|
||||||
string usercode = string.Empty;
|
string usercode = string.Empty;
|
||||||
@ -767,14 +707,21 @@ namespace Epost.BLL
|
|||||||
demodel.BatchId = item["BatchId"].ToString();
|
demodel.BatchId = item["BatchId"].ToString();
|
||||||
demodel.ID = item["ID"].ToString();
|
demodel.ID = item["ID"].ToString();
|
||||||
demodel.GoodsName = item["GoodsName"].ToString();
|
demodel.GoodsName = item["GoodsName"].ToString();
|
||||||
|
demodel.GoodsType = item["GoodsType"].ToString();
|
||||||
demodel.Quantity = Convert.ToInt32(item["Quantity"].ToString());
|
demodel.Quantity = Convert.ToInt32(item["Quantity"].ToString());
|
||||||
|
demodel.CheckQuantity = Convert.ToInt32(item["CheckQuantity"].ToString());
|
||||||
demodel.Sku = item["Sku"].ToString();
|
demodel.Sku = item["Sku"].ToString();
|
||||||
demodel.Tolocation = item["Tolocation"].ToString();
|
demodel.Tolocation = item["Tolocation"].ToString();
|
||||||
demodel.Matchid = item["Matchid"].ToString();
|
demodel.Matchid = item["Matchid"].ToString();
|
||||||
demodel.ShopID = item["shopid"].ToString();
|
demodel.ShopID = item["shopid"].ToString();
|
||||||
|
demodel.BoxCode = item["boxcode"].ToString();
|
||||||
|
demodel.LotNo = item["LotNo"].ToString();
|
||||||
demodel.Discount = item["Discount"].ToString();
|
demodel.Discount = item["Discount"].ToString();
|
||||||
|
demodel.ProdArea = item["ProdArea"].ToString();
|
||||||
|
demodel.ColorCode = item["corlorcode"].ToString();
|
||||||
|
demodel.WholeUnit = item["WholeUnit"].ToString();
|
||||||
demodel.Unit = item["Unit"].ToString();
|
demodel.Unit = item["Unit"].ToString();
|
||||||
//demodel.TrayCode = item["bkbarcode"].ToString();
|
demodel.TrayCode = item["bkbarcode"].ToString();
|
||||||
#region 获取库位信息
|
#region 获取库位信息
|
||||||
demodel.Block = item["Block"].ToString();
|
demodel.Block = item["Block"].ToString();
|
||||||
demodel.Area = item["Area"].ToString();
|
demodel.Area = item["Area"].ToString();
|
||||||
@ -795,11 +742,11 @@ namespace Epost.BLL
|
|||||||
demodel.TaskArea = Convert.ToInt32(item["area"].ToString());
|
demodel.TaskArea = Convert.ToInt32(item["area"].ToString());
|
||||||
demodel.TaskBlock = Convert.ToInt32(item["block"].ToString());
|
demodel.TaskBlock = Convert.ToInt32(item["block"].ToString());
|
||||||
demodel.No = "01";
|
demodel.No = "01";
|
||||||
//if (isecho)
|
if (isecho)
|
||||||
//{
|
{
|
||||||
// demodel.No = "04";
|
demodel.No = "04";
|
||||||
// demodel.ColorCode = EnumHelper.EMToDescriptionString(LightColor.Color.Blue);
|
demodel.ColorCode = EnumHelper.EMToDescriptionString(LightColor.Color.Blue);
|
||||||
//}
|
}
|
||||||
list.Add(demodel);
|
list.Add(demodel);
|
||||||
if (!isecho) {
|
if (!isecho) {
|
||||||
//修改数据为已读
|
//修改数据为已读
|
||||||
@ -977,9 +924,9 @@ namespace Epost.BLL
|
|||||||
return dal.getOrderListBysku(block, sku);
|
return dal.getOrderListBysku(block, sku);
|
||||||
}
|
}
|
||||||
|
|
||||||
public bool UpOrderStateBybat(string batchid)
|
public bool UpOrderStateBybat(string id)
|
||||||
{
|
{
|
||||||
return dal.UpOrderStateBybat(batchid);
|
return dal.UpOrderStateBybat(id);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@ -222,7 +222,7 @@ namespace Epost.BLL
|
|||||||
public bool UpdateQueueState()
|
public bool UpdateQueueState()
|
||||||
{
|
{
|
||||||
BoxPickBLL bll = new BoxPickBLL();
|
BoxPickBLL bll = new BoxPickBLL();
|
||||||
//dal.deleteBoxpick();
|
dal.deleteBoxpick();
|
||||||
bool bo= dal.UpdateQueueState();
|
bool bo= dal.UpdateQueueState();
|
||||||
//if (bo)
|
//if (bo)
|
||||||
//{
|
//{
|
||||||
|
|||||||
244
Epost.BLL/Work_DisplayJobThread.cs
Normal file
244
Epost.BLL/Work_DisplayJobThread.cs
Normal file
@ -0,0 +1,244 @@
|
|||||||
|
using Epost.Common;
|
||||||
|
using Epost.DAL.Cache;
|
||||||
|
using Epost.DAL.Enum;
|
||||||
|
using Epost.Model;
|
||||||
|
using Epost.Model.resource;
|
||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Data;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Threading;
|
||||||
|
|
||||||
|
|
||||||
|
namespace Epost.BLL
|
||||||
|
{
|
||||||
|
public class Work_DisplayJobThread
|
||||||
|
{
|
||||||
|
public string tblock, id;
|
||||||
|
public bool OrisShow = false;
|
||||||
|
OrderBLL orderbll = new OrderBLL();
|
||||||
|
OrdersQueueBLL queueBLL = new OrdersQueueBLL();
|
||||||
|
CommandBLL comBLL = new CommandBLL();
|
||||||
|
JobModelCacheDAL JobCache = new JobModelCacheDAL();
|
||||||
|
|
||||||
|
AddressstorageBLL addrBLL = new AddressstorageBLL();
|
||||||
|
WorkIngCacheDAL workbll = new WorkIngCacheDAL();
|
||||||
|
public void Displayjob()
|
||||||
|
{
|
||||||
|
GetWorkList(tblock);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
#region 获取订单信息
|
||||||
|
private void GetWorkList(object block)
|
||||||
|
{
|
||||||
|
string cm = "";
|
||||||
|
cm = "lockdisJob" + block;
|
||||||
|
object c = (Object)cm;
|
||||||
|
lock (c)
|
||||||
|
{
|
||||||
|
while (OrisShow)
|
||||||
|
{
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
|
||||||
|
string workstate = workbll.GetWorkState();
|
||||||
|
if (!string.IsNullOrEmpty(workstate))
|
||||||
|
{
|
||||||
|
OrisShow = true;
|
||||||
|
DisplayJob_M(block.ToString());
|
||||||
|
Thread.Sleep(50);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
OrisShow = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "：程序异常！\r\n" + ex.Message);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
#region 标签控制M系列
|
||||||
|
public void DisplayJob_M(string tblock)
|
||||||
|
{
|
||||||
|
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
string[] nlist = tblock.Split('|');
|
||||||
|
string nblock = nlist[0];
|
||||||
|
string shelfid = nlist[1];
|
||||||
|
List<AddressstorageModel> Arealist = addrBLL.GetAreaList(nblock, shelfid);
|
||||||
|
foreach (AddressstorageModel item in Arealist)
|
||||||
|
{
|
||||||
|
OrdersQueueModel model = new OrdersQueueModel(); ;
|
||||||
|
model.Taskarea = item.area;
|
||||||
|
model.Taskblock = nblock;
|
||||||
|
#region 开始作业
|
||||||
|
DataTable queueDT = queueBLL.getQueueOrderState(model);
|
||||||
|
if (queueDT != null && queueDT.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
//当前区没有作业
|
||||||
|
if (queueDT.Rows[0]["state"].ToString() == "0")
|
||||||
|
{
|
||||||
|
#region 点亮显示器
|
||||||
|
ShowMessageModel_M showmodel = new ShowMessageModel_M();
|
||||||
|
showmodel.Area = shelfid;
|
||||||
|
showmodel.Block = nblock;
|
||||||
|
showmodel.Color = queueDT.Rows[0]["lightcolor"].ToString();//EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
showmodel.Contents = queueDT.Rows[0]["sku"].ToString();
|
||||||
|
showmodel.Title = queueDT.Rows[0]["Shopid"].ToString();
|
||||||
|
showmodel.Islock = true;
|
||||||
|
|
||||||
|
showmodel.IsTwinkle = 0;
|
||||||
|
showmodel.Type = 8;
|
||||||
|
DataTable sudt = orderbll.GetSumList("", queueDT.Rows[0]["sku"].ToString(), nblock);
|
||||||
|
if (sudt != null && sudt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
showmodel.Qty = sudt.Rows[0]["SumQuantity"].ToString();
|
||||||
|
}
|
||||||
|
comBLL.ShowBoxMessage_M(showmodel);//点亮显示标签
|
||||||
|
#endregion
|
||||||
|
displayOrder(queueDT, nblock, item.area, model);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo("标签控制异常：" + ex.Message);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 点亮设备
|
||||||
|
public void displayOrder(DataTable queueDT, string nblock, string narea, OrdersQueueModel model)
|
||||||
|
{
|
||||||
|
List<LabelParamModel> list = new List<LabelParamModel>();
|
||||||
|
model.Id = Convert.ToInt32(queueDT.Rows[0]["id"].ToString());
|
||||||
|
#region 点亮任务
|
||||||
|
List<JobModel> jobList = JobCache.GetPlanJobList();
|
||||||
|
List<JobModel> isJobList = jobList.FindAll(p => p.Block == nblock && p.Area == narea && p.State != 3);
|
||||||
|
ShowMessageModel showmodel = new ShowMessageModel();
|
||||||
|
//获取当前区任务并加入缓存
|
||||||
|
if (!isJobList.Any())
|
||||||
|
{
|
||||||
|
model.State = 1;
|
||||||
|
orderbll.GetOrderList(queueDT.Rows[0]["matchid"].ToString(), nblock, queueDT.Rows[0]["sku"].ToString(), narea, queueDT.Rows[0]["usercode"].ToString());
|
||||||
|
List<JobModel> nowJoblist = jobList.FindAll(p => p.State == 0 && p.Block == model.Taskblock && p.Area == model.Taskarea);
|
||||||
|
if (nowJoblist.Any())
|
||||||
|
{
|
||||||
|
var nowmodel = nowJoblist.FirstOrDefault();
|
||||||
|
|
||||||
|
LogHelper.WriteLogInfo("进入任务点亮=====matchid=" + nowmodel.Matchid + "===orderid===" + nowmodel.OrderID + "=====sku==" + nowmodel.Sku + "========");
|
||||||
|
#region 点亮任务标签
|
||||||
|
foreach (JobModel item in nowJoblist.ToArray())
|
||||||
|
{
|
||||||
|
|
||||||
|
#region 回显设备锁定
|
||||||
|
if (queueDT.Rows[0]["lightcolor"].ToString() == EnumHelper.EMToDescriptionString(LightColor.Color.Blue))
|
||||||
|
{
|
||||||
|
|
||||||
|
LabelParamModel locklamodel = new LabelParamModel();
|
||||||
|
locklamodel.Address = item.Address.ToString();
|
||||||
|
locklamodel.ControlIP = item.ControlIP.ToString();
|
||||||
|
locklamodel.Command = "LOCK";
|
||||||
|
locklamodel.Parameter = "11111000";
|
||||||
|
locklamodel.Type = "N";
|
||||||
|
list.Add(locklamodel);
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
// else
|
||||||
|
//{
|
||||||
|
|
||||||
|
List<JobModel> manyJoblist = nowJoblist.FindAll(m => m.Tolocation == item.Tolocation);
|
||||||
|
int quantity = item.Quantity;
|
||||||
|
LabelParamModel lamodel = new LabelParamModel();
|
||||||
|
lamodel.Address = item.Address.ToString();
|
||||||
|
lamodel.ControlIP = item.ControlIP.ToString();
|
||||||
|
lamodel.Command = "DISPLAY_JOB";
|
||||||
|
#region 同一个货位的数据合并显示
|
||||||
|
//if (manyJoblist.Count > 1)
|
||||||
|
//{
|
||||||
|
// if (manyJoblist.FindAll(m => m.State == 0).Any())
|
||||||
|
// {
|
||||||
|
// foreach (JobModel mitem in manyJoblist)
|
||||||
|
// {
|
||||||
|
// quantity += mitem.Quantity;
|
||||||
|
// mitem.State = 1;
|
||||||
|
// mitem.ManyState = 1;
|
||||||
|
// }
|
||||||
|
|
||||||
|
// }
|
||||||
|
//}
|
||||||
|
#endregion
|
||||||
|
lamodel.Type = "N";
|
||||||
|
lamodel.Quantity = quantity.ToString();
|
||||||
|
lamodel.Uid = "U" + item.ID;
|
||||||
|
lamodel.Mode = queueDT.Rows[0]["lightcolor"].ToString() + "0";
|
||||||
|
list.Add(lamodel);
|
||||||
|
//}
|
||||||
|
item.State = 1;
|
||||||
|
item.ColorCode = queueDT.Rows[0]["lightcolor"].ToString();
|
||||||
|
item.DisplayTime = DateTime.Now;
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
#region 点亮通道灯
|
||||||
|
comBLL.DISPLAY_LIGHT_BLOCK(model.Taskblock, model.Taskarea, "1");
|
||||||
|
#endregion
|
||||||
|
if (list != null && list.Count > 0)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo("添加到点亮的list————————：" + list.Count);
|
||||||
|
comBLL.DISPLAY_JOBALL(list);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{//无任务
|
||||||
|
LogHelper.WriteLogInfo("点亮====无任务=======================");
|
||||||
|
model.State = 3;
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
if (jobList.Any())
|
||||||
|
{
|
||||||
|
|
||||||
|
var finishList = jobList.FindAll(p => p.State == 0);
|
||||||
|
if (!finishList.Any())
|
||||||
|
{
|
||||||
|
queueBLL.UpdateQueueOrderState(model);//缓存队列状态修改
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
|
||||||
|
LogHelper.WriteLogInfo("还有未完成任务" + isJobList.Count);
|
||||||
|
foreach (JobModel item in isJobList)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo("还有未完成任务" + item.Address + item.ID);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
}
|
||||||
1084
Epost.BLL/Work_JobDownThread.cs
Normal file
1084
Epost.BLL/Work_JobDownThread.cs
Normal file
File diff suppressed because it is too large
Load Diff
564
Epost.BLL/Work_ScanThread.cs
Normal file
564
Epost.BLL/Work_ScanThread.cs
Normal file
@ -0,0 +1,564 @@
|
|||||||
|
using Epost.Common;
|
||||||
|
using Epost.DAL.Cache;
|
||||||
|
using Epost.DAL.Enum;
|
||||||
|
using Epost.Model;
|
||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Data;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Text;
|
||||||
|
using System.Threading;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
|
||||||
|
namespace Epost.BLL
|
||||||
|
{
|
||||||
|
public class Work_ScanThread
|
||||||
|
{
|
||||||
|
public string tblock, id;
|
||||||
|
public bool OrisShow = false;
|
||||||
|
OrderBLL orderbll = new OrderBLL();
|
||||||
|
OrdersQueueBLL queueBLL = new OrdersQueueBLL();
|
||||||
|
CommandBLL comBLL = new CommandBLL();
|
||||||
|
JobDownCacheDAL downCacheDAL = new JobDownCacheDAL();
|
||||||
|
JobModelCacheDAL JobCache = new JobModelCacheDAL();
|
||||||
|
AddressstorageBLL addrBLL = new AddressstorageBLL();
|
||||||
|
private static object lockscanList = new object();
|
||||||
|
public static bool OrcheckisShow = false;
|
||||||
|
WorkIngCacheDAL workbll = new WorkIngCacheDAL();
|
||||||
|
SkuInfoBLL skuBLL = new SkuInfoBLL();
|
||||||
|
UserModelCacheDAL UserCacheDAL = new UserModelCacheDAL();
|
||||||
|
public void ScanList()
|
||||||
|
{
|
||||||
|
GetScanList(tblock);
|
||||||
|
}
|
||||||
|
|
||||||
|
#region 获取扫描信息
|
||||||
|
private void GetScanList(object block)
|
||||||
|
{
|
||||||
|
string job = "";
|
||||||
|
job = "lockScan" + block;
|
||||||
|
object cJob = (object)job;
|
||||||
|
lock (cJob)
|
||||||
|
{
|
||||||
|
while (OrisShow)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
string workstate = workbll.GetWorkState();
|
||||||
|
if (!string.IsNullOrEmpty(workstate))
|
||||||
|
{
|
||||||
|
OrisShow = true;
|
||||||
|
JobScanList(block.ToString());
|
||||||
|
Thread.Sleep(50);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
OrisShow = false;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "：ScanList异常！\r\n" + ex.Message);
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
|
#region 扫描处理
|
||||||
|
public ResultModel JobScanList(string tblock)
|
||||||
|
{
|
||||||
|
lock (lockscanList)
|
||||||
|
{
|
||||||
|
string[] nlist = tblock.Split('|');
|
||||||
|
string nblock = nlist[0];
|
||||||
|
string shelfid = nlist[1];
|
||||||
|
|
||||||
|
ResultModel resmodel = new ResultModel();
|
||||||
|
resmodel.result = "0";
|
||||||
|
try
|
||||||
|
{
|
||||||
|
List<AddressstorageModel> Arealist = addrBLL.GetAreaList(nblock, shelfid);
|
||||||
|
foreach (AddressstorageModel item in Arealist)
|
||||||
|
{
|
||||||
|
List<ResultMessageModel> sacnList = downCacheDAL.GetPlanJobDownList().FindAll(m => m.Status == "0" && m.Block == item.block && m.Area == item.area && m.Command == "QUERY_SPECIAL_STATUS");
|
||||||
|
if (sacnList != null && sacnList.Count > 0)
|
||||||
|
{
|
||||||
|
foreach (ResultMessageModel data in sacnList.ToArray())
|
||||||
|
{
|
||||||
|
|
||||||
|
switch (data.Command)
|
||||||
|
{
|
||||||
|
case "QUERY_SPECIAL_STATUS":
|
||||||
|
BindJobList(data);
|
||||||
|
break;
|
||||||
|
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return resmodel;
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
resmodel.result = "-1";
|
||||||
|
resmodel.msg = "扫描异常";
|
||||||
|
LogHelper.WriteLogInfo("扫描异常：" + ex.Message);
|
||||||
|
return resmodel;
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 扫描处理
|
||||||
|
|
||||||
|
public ResultModel BindJobList(ResultMessageModel data)
|
||||||
|
{
|
||||||
|
ResultModel res = new ResultModel();
|
||||||
|
res.result = "0";
|
||||||
|
try
|
||||||
|
{
|
||||||
|
string sblock = data.Block;
|
||||||
|
string scanStr = data.Parameter.Trim();
|
||||||
|
string sarea = data.Area;
|
||||||
|
string name = string.Empty;
|
||||||
|
string matchid = string.Empty;
|
||||||
|
#region 提示请扫描波次号
|
||||||
|
List<UserCodeModel> ulist = UserCacheDAL.GetUserCodeList().FindAll(m => m.Block == sblock && m.Area == sarea);//
|
||||||
|
bool isnum = ConvertHexHelper.IsNum(scanStr.Substring(0, 1));//判断扫描首字母是否是数字
|
||||||
|
|
||||||
|
if (!ulist.Any())
|
||||||
|
{
|
||||||
|
//手动加波次信息
|
||||||
|
DataTable matdt = orderbll.GetMatchOrderList();
|
||||||
|
if (matdt != null && matdt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
UserCodeModel umodel = new UserCodeModel();
|
||||||
|
umodel.Matchid = matdt.Rows[0]["matchid"].ToString();
|
||||||
|
umodel.Block = sblock;
|
||||||
|
umodel.Area = sarea;
|
||||||
|
UserCacheDAL.UpdateUserCodeList(new List<UserCodeModel> { umodel }, EUserCommend.Create);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
ulist = UserCacheDAL.GetUserCodeList().FindAll(m => m.Block == sblock && m.Area == sarea);
|
||||||
|
if (ulist.Any())
|
||||||
|
{ matchid = ulist.FirstOrDefault().Matchid; }
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
if (data.Type == "5")//中分扫描枪
|
||||||
|
{
|
||||||
|
|
||||||
|
zhongfenBind(ulist, scanStr, data);
|
||||||
|
downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
}
|
||||||
|
else if (data.Type == "6")//播种扫描枪
|
||||||
|
{
|
||||||
|
|
||||||
|
xifenBind(ulist, scanStr, data, matchid, isnum);
|
||||||
|
|
||||||
|
downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
return res;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
res.result = "-1";
|
||||||
|
res.msg = "绑定任务异常";
|
||||||
|
LogHelper.WriteLogInfo("绑定任务异常：" + ex.Message);
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 中分
|
||||||
|
|
||||||
|
public void zhongfenBind(List<UserCodeModel> ulist, string scanStr, ResultMessageModel data)
|
||||||
|
{
|
||||||
|
|
||||||
|
//if (ulist.Any())
|
||||||
|
//{
|
||||||
|
// UserCodeModel usermodel = ulist.FirstOrDefault();
|
||||||
|
//if (string.IsNullOrEmpty(usermodel.ZfCode) && scanStr.Substring(0, 1) != "U")//
|
||||||
|
//{
|
||||||
|
// #region 提示先扫描工号
|
||||||
|
// ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
// show.Title = "请先扫描工号！";
|
||||||
|
// show.Contents = "";
|
||||||
|
// show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
// show.Block = sblock;
|
||||||
|
// show.Type =2;
|
||||||
|
// show.Area = sarea;
|
||||||
|
// show.Islock = true;
|
||||||
|
// comBLL.ShowBoxMessage_M(show);
|
||||||
|
// downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
// #endregion
|
||||||
|
//}
|
||||||
|
//else {
|
||||||
|
|
||||||
|
if (scanStr.Substring(0, 1) == "U")
|
||||||
|
{
|
||||||
|
#region 扫描工号
|
||||||
|
if (ulist.Any())
|
||||||
|
{
|
||||||
|
UserCodeModel umodel = ulist.FirstOrDefault();
|
||||||
|
umodel.ZfCode = scanStr;
|
||||||
|
#region 扫描工号
|
||||||
|
ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
show.Title = "请扫描sku开始作业！";
|
||||||
|
show.Contents = "";
|
||||||
|
show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
show.Block = data.Block;
|
||||||
|
show.Area = data.Area;
|
||||||
|
show.Type = 2;
|
||||||
|
show.Islock = true;
|
||||||
|
comBLL.ShowBoxMessage_M(show);
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
#region 中分扫描sku
|
||||||
|
|
||||||
|
DataTable sinfodt = skuBLL.GetSkuInfoList(data.Parameter);
|
||||||
|
//string location = string.Empty;
|
||||||
|
if (sinfodt != null && sinfodt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
scanStr = sinfodt.Rows[0]["sku"].ToString();
|
||||||
|
// location = data.Parameter;// sinfodt.Rows[0]["tolocation"].ToString();
|
||||||
|
}
|
||||||
|
LogHelper.WriteLogInfo("中分" + data.Parameter + "===SKU" + scanStr);
|
||||||
|
DataTable skudt = orderbll.GetSumList("", scanStr, data.Block);
|
||||||
|
if (skudt != null && skudt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
//规格
|
||||||
|
int discount = Convert.ToInt32(skudt.Rows[0]["discount"].ToString());
|
||||||
|
//整件总数
|
||||||
|
int SumCkQuantity = 0;//= Convert.ToInt32(skudt.Rows[0]["SumCkQuantity"].ToString());
|
||||||
|
//散件总数
|
||||||
|
int SumQuantity = Convert.ToInt32(skudt.Rows[0]["SumQuantity"].ToString());
|
||||||
|
if (discount != 1)
|
||||||
|
{
|
||||||
|
if (SumQuantity >= discount)
|
||||||
|
{
|
||||||
|
|
||||||
|
SumCkQuantity = SumQuantity / discount;
|
||||||
|
SumQuantity = SumQuantity % discount;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
show.Title = skudt.Rows[0]["sku_goodsname"].ToString();
|
||||||
|
show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
show.Block = data.Block;
|
||||||
|
show.Islock = true;
|
||||||
|
show.Contents = data.Parameter + "(" + scanStr + ")\r" + "规格：" + discount;
|
||||||
|
show.Qty = SumQuantity.ToString();
|
||||||
|
show.Wholeqty = SumCkQuantity;
|
||||||
|
show.Unit = "件";
|
||||||
|
show.Wholeunit = "箱";
|
||||||
|
show.Type = 2;
|
||||||
|
comBLL.ShowBoxMessage_M(show);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
show.Title = "SKU" + scanStr + "无任务！";
|
||||||
|
show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
show.Block = data.Block;
|
||||||
|
show.Islock = true;
|
||||||
|
show.Contents = "请扫描其他商品！";
|
||||||
|
show.Type = 2;
|
||||||
|
comBLL.ShowBoxMessage_M(show);
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 细分播种
|
||||||
|
public void xifenBind(List<UserCodeModel> ulist, string scanStr, ResultMessageModel data, string matchid, bool isnum)
|
||||||
|
{
|
||||||
|
//if (ulist.Any())
|
||||||
|
//{
|
||||||
|
// UserCodeModel usermodel = ulist.FirstOrDefault();
|
||||||
|
//if (string.IsNullOrEmpty(usermodel.UserCode) && scanStr.Substring(0, 1) != "U")//
|
||||||
|
//{
|
||||||
|
// #region 提示先扫描工号
|
||||||
|
// ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
// show.Title = "请先扫描工号！";
|
||||||
|
// show.Contents = "";
|
||||||
|
// show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
// show.Block = sblock;
|
||||||
|
// show.Area = sarea;
|
||||||
|
// show.Type = 8;
|
||||||
|
// show.Islock = true;
|
||||||
|
// comBLL.ShowBoxMessage_M(show);
|
||||||
|
// downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
// #endregion
|
||||||
|
//}
|
||||||
|
//else
|
||||||
|
//{
|
||||||
|
|
||||||
|
if (scanStr.Substring(0, 1) == "U")
|
||||||
|
{
|
||||||
|
#region 扫描工号
|
||||||
|
if (ulist.Any())
|
||||||
|
{
|
||||||
|
UserCodeModel umodel = ulist.FirstOrDefault();
|
||||||
|
umodel.UserCode = scanStr;
|
||||||
|
#region 扫描工号
|
||||||
|
ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
show.Title = "请扫描sku开始作业！";
|
||||||
|
show.Contents = "";
|
||||||
|
show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
show.Block = data.Block;
|
||||||
|
show.Area = data.Area;
|
||||||
|
show.Type = 8;
|
||||||
|
show.Islock = true;
|
||||||
|
comBLL.ShowBoxMessage_M(show);
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
|
||||||
|
#region 扫描商品
|
||||||
|
|
||||||
|
List<ResultMessageModel> hangList = downCacheDAL.GetPlanJobDownList().FindAll(m => m.Parameter == "888888");
|
||||||
|
|
||||||
|
if (hangList.Any())
|
||||||
|
{
|
||||||
|
|
||||||
|
#region 挂起
|
||||||
|
LogHelper.WriteLogInfo("挂起" + data.Parameter + "-------通道" + data.Block);
|
||||||
|
// LabelParamModel FORMATEModel = new LabelParamModel();
|
||||||
|
// FORMATEModel.ControlIP = data.IP;
|
||||||
|
// comBLL.FORMATE_JOB_DATA(FORMATEModel);
|
||||||
|
|
||||||
|
|
||||||
|
DataTable qdt = queueBLL.getQueuesOrderbyState(data.Block, data.Area, "1");
|
||||||
|
if (qdt != null && qdt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
scanStr = qdt.Rows[0]["sku"].ToString();
|
||||||
|
ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
show.Block = data.Block;
|
||||||
|
show.Area = data.Area;
|
||||||
|
show.Type = 8;
|
||||||
|
|
||||||
|
comBLL.RemoveBoxMessage_M(show);
|
||||||
|
// data.Parameter = scanStr;
|
||||||
|
Hangup_SKU(scanStr, data.Block, data.Area);
|
||||||
|
//删除sku对应缓存
|
||||||
|
List<ResultMessageModel> sdown = downCacheDAL.GetPlanJobDownList().FindAll(p => p.Parameter == scanStr && p.Parameter == qdt.Rows[0]["sku"].ToString()&&p.Block == data.Block);
|
||||||
|
downCacheDAL.UpdateJobDownModelList(sdown, EdownCommend.Execute);
|
||||||
|
}
|
||||||
|
downCacheDAL.UpdateJobDownModelList(hangList, EdownCommend.Execute);
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
}
|
||||||
|
else if (isnum)//sku
|
||||||
|
{
|
||||||
|
#region 扫描SKU
|
||||||
|
//根据扫描商品内码获取商品码
|
||||||
|
data.ScanCode = data.Parameter;
|
||||||
|
DataTable sinfodt = skuBLL.GetSkuInfoList(data.Parameter);
|
||||||
|
string location = string.Empty;
|
||||||
|
if (sinfodt != null && sinfodt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
scanStr = sinfodt.Rows[0]["sku"].ToString();
|
||||||
|
location = data.Parameter;// sinfodt.Rows[0]["tolocation"].ToString();
|
||||||
|
}
|
||||||
|
data.Parameter = scanStr;
|
||||||
|
DataTable skudt = queueBLL.GetOrderQueue(data.Block, data.Area, "3");
|
||||||
|
List<ResultMessageModel> scanlist = downCacheDAL.GetPlanJobDownList().FindAll(m => m.Address == data.Address && m.Parameter == scanStr && m.Parameter != "888888" && m.Block == data.Block && m.Area == data.Area);
|
||||||
|
|
||||||
|
if (scanlist.Count > 1 || (skudt != null && skudt.Rows.Count > 0))
|
||||||
|
{ //重复扫描
|
||||||
|
//ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
//show.Title = scanStr + "重复扫描/已拣配！";
|
||||||
|
//show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
//show.Block = sblock;
|
||||||
|
//show.Area = sarea;
|
||||||
|
//show.Type = 8;
|
||||||
|
//comBLL.ShowBoxMessage_M(show);
|
||||||
|
downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
|
||||||
|
DataTable OrderDt = orderbll.GetOrderList_Car(matchid, scanStr, data.Area, data.Block);
|
||||||
|
if (OrderDt != null && OrderDt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
|
||||||
|
if (ulist.Any())
|
||||||
|
{
|
||||||
|
UserCodeModel umodel = ulist.FirstOrDefault();
|
||||||
|
data.Port = OrderDt.Rows[0]["matchid"].ToString();
|
||||||
|
OrdersQueueModel qmodel = new OrdersQueueModel();
|
||||||
|
qmodel.Sku = scanStr;
|
||||||
|
qmodel.Taskblock = data.Block;
|
||||||
|
qmodel.Taskarea = data.Area;
|
||||||
|
qmodel.UserCode = umodel.UserCode;
|
||||||
|
qmodel.Matchid = umodel.Matchid;
|
||||||
|
qmodel.Shopid = OrderDt.Rows[0]["GoodsName"].ToString();
|
||||||
|
qmodel.Location = location;
|
||||||
|
qmodel.Lightcolor = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
queueBLL.insertQueueOrders(qmodel);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo("未扫描波次信息", LogHelper.Log_Type.ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
#region 回显
|
||||||
|
DataTable echoDt = orderbll.GetOrderList_echo(matchid, scanStr, data.Area, data.Block);
|
||||||
|
if (echoDt != null && echoDt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
|
||||||
|
if (ulist.Any())
|
||||||
|
{
|
||||||
|
UserCodeModel umodel = ulist.FirstOrDefault();
|
||||||
|
data.Port = echoDt.Rows[0]["matchid"].ToString();
|
||||||
|
OrdersQueueModel qmodel = new OrdersQueueModel();
|
||||||
|
qmodel.Sku = scanStr;
|
||||||
|
qmodel.Taskblock = data.Block;
|
||||||
|
qmodel.Taskarea = data.Area;
|
||||||
|
qmodel.UserCode = umodel.UserCode;
|
||||||
|
qmodel.Matchid = umodel.Matchid;
|
||||||
|
// qmodel.Location = location;
|
||||||
|
qmodel.Shopid = echoDt.Rows[0]["GoodsName"].ToString();
|
||||||
|
|
||||||
|
qmodel.Lightcolor = EnumHelper.EMToDescriptionString(LightColor.Color.Green);
|
||||||
|
queueBLL.insertQueueOrders(qmodel);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo("未扫描波次信息", LogHelper.Log_Type.ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
|
||||||
|
//提示无任务
|
||||||
|
ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
show.Title = "商品：" + scanStr + "当前区无任务！";
|
||||||
|
show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
show.Block = data.Block;
|
||||||
|
show.Area = data.Area;
|
||||||
|
show.Type = 8;
|
||||||
|
show.Islock = false;
|
||||||
|
comBLL.ShowBoxMessage_M(show);
|
||||||
|
downCacheDAL.UpdateJobDownModelList(new List<ResultMessageModel> { data }, EdownCommend.Execute);
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region SKU挂起/缺货
|
||||||
|
public void Hangup_SKU(string sku, string block, string area, ResultMessageModel data = null)
|
||||||
|
{
|
||||||
|
List<LabelParamModel> list = new List<LabelParamModel>();
|
||||||
|
//查询当前通道sku是否有任务
|
||||||
|
DataTable dt = orderbll.getOrderListBysku(block, sku);
|
||||||
|
if (dt != null && dt.Rows.Count > 0)
|
||||||
|
{
|
||||||
|
// 将当前通道所有sku正在亮的设备熄灭
|
||||||
|
foreach (DataRow item in dt.Rows)
|
||||||
|
{
|
||||||
|
|
||||||
|
LabelParamModel lamodel = new LabelParamModel();
|
||||||
|
lamodel.Address = item["address"].ToString(); ;
|
||||||
|
lamodel.ControlIP = item["ControlIP"].ToString();
|
||||||
|
lamodel.Command = "REMOVE_JOB";
|
||||||
|
lamodel.Parameter = "";
|
||||||
|
lamodel.Uid = "U" + item["id"].ToString();
|
||||||
|
lamodel.Type = "N";
|
||||||
|
list.Add(lamodel);
|
||||||
|
if (item["oprationstate"].ToString() == "1")
|
||||||
|
{
|
||||||
|
orderbll.UpOrderStateBybat(item["id"].ToString());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (list != null && list.Count > 0)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogInfo("挂起list——" + sku + "——————————————————：" + list.Count);
|
||||||
|
comBLL.DISPLAY_JOBALL(list);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
//删除缓存中sku记录
|
||||||
|
List<JobModel> jobList = JobCache.GetPlanJobList();
|
||||||
|
List<JobModel> relist = jobList.FindAll(m => m.Sku == sku && m.Block == block);
|
||||||
|
JobModel model = new JobModel();
|
||||||
|
if (relist.Any())
|
||||||
|
{
|
||||||
|
model = relist.FirstOrDefault();
|
||||||
|
JobCache.UpdateJobModelList(relist, EcommendType.Complete);
|
||||||
|
//删除Orderqueue中sku的记录
|
||||||
|
bool bo = queueBLL.DelQueueOrder(sku, block);
|
||||||
|
LogHelper.WriteLogInfo("删除queue返回" + bo);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
ShowMessageModel_M show = new ShowMessageModel_M();
|
||||||
|
show.Title = "挂起商品：" + sku + "错误！";
|
||||||
|
show.Color = EnumHelper.EMToDescriptionString(LightColor.Color.Red);
|
||||||
|
show.Block = block;
|
||||||
|
show.Area = area;
|
||||||
|
show.Type = 8;
|
||||||
|
show.Islock = true;
|
||||||
|
comBLL.ShowBoxMessage_M(show);
|
||||||
|
}
|
||||||
|
//downCacheDAL.GetPlanJobDownList().FindAll(p => p.Parameter == sku && p.Block == block);
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -165,7 +165,7 @@ namespace Epost.DAL
|
|||||||
{
|
{
|
||||||
strwhere = " and area='"+area+"'";
|
strwhere = " and area='"+area+"'";
|
||||||
}
|
}
|
||||||
string sql = string.Format("select address,bkaddress,state,type,area,way,shelfid,ControlID,location,layer,slist,block,addresstype,ControlIP,ControlType,info from V_address where type='{1}' and block='{0}' " + strwhere,
|
string sql = string.Format("select address, bkaddress, state, type, area ,way ,shelfid, ControlID ,location ,layer, slist, block, addresstype, ControlIP, ControlType, info from V_address where type='{1}' and block='{0}' " + strwhere,
|
||||||
block,
|
block,
|
||||||
|
|
||||||
type);
|
type);
|
||||||
@ -257,13 +257,19 @@ namespace Epost.DAL
|
|||||||
return db.GetsqlForDT(sql);
|
return db.GetsqlForDT(sql);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 获取所有小区
|
#region 获取所有小区
|
||||||
public List<AddressstorageModel> GetAreaList(string block = "")
|
public List<AddressstorageModel> GetAreaList(string block, string shelfid)
|
||||||
{
|
{
|
||||||
string strwhere = string.Empty;
|
string strwhere = string.Empty;
|
||||||
if (!string.IsNullOrEmpty(block))
|
if (!string.IsNullOrEmpty(block))
|
||||||
{
|
{
|
||||||
strwhere = "and block ='" + block + "'";
|
strwhere += "and block ='" + block + "'";
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!string.IsNullOrEmpty(shelfid))
|
||||||
|
{
|
||||||
|
strwhere += "and shelfid ='" + shelfid + "'";
|
||||||
}
|
}
|
||||||
string sql = string.Format("select area,block from Addressstorage where type=1 " + strwhere + " group by area,block");
|
string sql = string.Format("select area,block from Addressstorage where type=1 " + strwhere + " group by area,block");
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
DataTable dt = db.GetsqlForDT(sql);
|
||||||
@ -271,6 +277,22 @@ namespace Epost.DAL
|
|||||||
return ModelConvertHelper<AddressstorageModel>.ConvertToList(dt);
|
return ModelConvertHelper<AddressstorageModel>.ConvertToList(dt);
|
||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
#region 获取所有小区
|
||||||
|
public List<AddressstorageModel> GetshelfidList(string block)
|
||||||
|
{
|
||||||
|
string strwhere = string.Empty;
|
||||||
|
if (!string.IsNullOrEmpty(block))
|
||||||
|
{
|
||||||
|
strwhere += "and block ='" + block + "'";
|
||||||
|
}
|
||||||
|
|
||||||
|
string sql = string.Format("select shelfid,block from Addressstorage where type=1 " + strwhere + " group by shelfid,block");
|
||||||
|
DataTable dt = db.GetsqlForDT(sql);
|
||||||
|
|
||||||
|
return ModelConvertHelper<AddressstorageModel>.ConvertToList(dt);
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
#region 获取所有通道
|
#region 获取所有通道
|
||||||
public DataTable GetWayList()
|
public DataTable GetWayList()
|
||||||
{
|
{
|
||||||
|
|||||||
94
Epost.DAL/Cache/WorkIngCacheDAL.cs
Normal file
94
Epost.DAL/Cache/WorkIngCacheDAL.cs
Normal file
@ -0,0 +1,94 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.ComponentModel;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Text;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
|
||||||
|
namespace Epost.DAL.Cache
|
||||||
|
{
|
||||||
|
public class WorkIngCacheDAL
|
||||||
|
{
|
||||||
|
private static object lockobj = new object();
|
||||||
|
public static string workingstate = string.Empty;
|
||||||
|
|
||||||
|
|
||||||
|
#region 获取计划任务列表
|
||||||
|
public string GetWorkState()
|
||||||
|
{
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
//读取数据库 处理异常断电等情况------待开发
|
||||||
|
return workingstate;
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
#region 初始化任务列表
|
||||||
|
public void ClearWork()
|
||||||
|
{
|
||||||
|
|
||||||
|
|
||||||
|
workingstate = "";
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
#region Job缓存处理方法
|
||||||
|
/// <summary>
|
||||||
|
/// Job缓存处理方法
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="JobParam"></param>
|
||||||
|
/// <param name="CommendType"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public bool UpdateWorkModel(WorkEcommendType CommendType)
|
||||||
|
{
|
||||||
|
|
||||||
|
lock (lockobj)
|
||||||
|
{
|
||||||
|
|
||||||
|
if (CommendType.Equals(WorkEcommendType.Create))
|
||||||
|
{
|
||||||
|
workingstate = "Start";
|
||||||
|
}
|
||||||
|
|
||||||
|
else if (CommendType.Equals(WorkEcommendType.Complete))
|
||||||
|
{
|
||||||
|
|
||||||
|
workingstate = "";
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
public enum WorkEcommendType
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 开始作业
|
||||||
|
/// </summary>
|
||||||
|
[Description("开始作业")]
|
||||||
|
Create,
|
||||||
|
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 结束作业
|
||||||
|
/// </summary>
|
||||||
|
[Description("结束作业")]
|
||||||
|
Complete
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -111,6 +111,7 @@
|
|||||||
<Compile Include="Cache\ShowMesCacheDAL.cs" />
|
<Compile Include="Cache\ShowMesCacheDAL.cs" />
|
||||||
<Compile Include="Cache\UserLoginCacheDAL.cs" />
|
<Compile Include="Cache\UserLoginCacheDAL.cs" />
|
||||||
<Compile Include="Cache\UserModelCacheDAL.cs" />
|
<Compile Include="Cache\UserModelCacheDAL.cs" />
|
||||||
|
<Compile Include="Cache\WorkIngCacheDAL.cs" />
|
||||||
<Compile Include="Cache\XgateCacheDAL.cs" />
|
<Compile Include="Cache\XgateCacheDAL.cs" />
|
||||||
<Compile Include="CommandDAL.cs" />
|
<Compile Include="CommandDAL.cs" />
|
||||||
<Compile Include="DB.cs" />
|
<Compile Include="DB.cs" />
|
||||||
|
|||||||
@ -48,7 +48,7 @@ namespace Epost.DAL
|
|||||||
string sql = string.Empty;
|
string sql = string.Empty;
|
||||||
if (!string.IsNullOrEmpty(area))
|
if (!string.IsNullOrEmpty(area))
|
||||||
{
|
{
|
||||||
sql = string.Format("select id, Matchid, orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, address, ControlIP,area, block,unit,shopid from v_orders where state = 0 and oprationstate <>3 and sku = '{0}' and block = '{1}' and area='{2}' " + strwhere + "",
|
sql = string.Format("select id, ProdArea, LotNo, Matchid, orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, GoodsType, corlorcode, address, ControlIP,area, block,boxcode,bkbarcode,isnull(checkquantity,0) as checkquantity,wholeunit,unit,shopid,wmsboxcode from v_orders where state = 0 and oprationstate <>3 and sku = '{0}' and block = '{1}' and area='{2}' " + strwhere + " order by layer,slist ",
|
||||||
|
|
||||||
sku,
|
sku,
|
||||||
block, area);
|
block, area);
|
||||||
@ -56,7 +56,7 @@ namespace Epost.DAL
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
sql = string.Format("select id, Matchid, orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, address, ControlIP, area , block,unit,shopid from v_orders where state = 0 and oprationstate <>3 and sku = '{0}' and block = '{1}' " + strwhere + "",
|
sql = string.Format("select id,ProdArea, LotNo, Matchid, orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, GoodsType, corlorcode, address, ControlIP, area , block,boxcode,bkbarcode,isnull(checkquantity,0) as checkquantity,wholeunit,unit,shopid,wmsboxcode from v_orders where state = 0 and oprationstate <>3 and sku = '{0}' and block = '{1}' " + strwhere + " order by layer,slist ",
|
||||||
|
|
||||||
sku,
|
sku,
|
||||||
block);
|
block);
|
||||||
@ -90,7 +90,7 @@ namespace Epost.DAL
|
|||||||
string sql = string.Empty;
|
string sql = string.Empty;
|
||||||
if (!string.IsNullOrEmpty(area))
|
if (!string.IsNullOrEmpty(area))
|
||||||
{
|
{
|
||||||
sql = string.Format("select id,Matchid,orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, address, ControlIP,area, block,bkbarcode,wholeunit,unit,shopid,wmsboxcode from v_orders where state = 0 and sku = '{0}' and block = '{1}' and area='{2}' " + strwhere + "",
|
sql = string.Format("select id,ProdArea, LotNo, Matchid, orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, GoodsType, corlorcode, address, ControlIP,area, block,boxcode,bkbarcode,isnull(checkquantity,0) as checkquantity,wholeunit,unit,shopid,wmsboxcode from v_orders where state = 0 and sku = '{0}' and block = '{1}' and area='{2}' " + strwhere + " order by layer,slist ",
|
||||||
|
|
||||||
sku,
|
sku,
|
||||||
block, area);
|
block, area);
|
||||||
@ -98,7 +98,7 @@ namespace Epost.DAL
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
sql = string.Format("select id,Matchid,orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, address, ControlIP, area , block,bkbarcode,wholeunit,unit,shopid,wmsboxcode from v_orders where state = 0 and sku = '{0}' and block = '{1}' " + strwhere + "",
|
sql = string.Format("select id,ProdArea, LotNo, Matchid, orderid, barcode, BatchId, DownDate, Tolocation, Sku, GoodsName, Discount, Quantity, GoodsType, corlorcode, address, ControlIP, area , block,boxcode,bkbarcode,isnull(checkquantity,0) as checkquantity,wholeunit,unit,shopid,wmsboxcode from v_orders where state = 0 and sku = '{0}' and block = '{1}' " + strwhere + " order by layer,slist ",
|
||||||
|
|
||||||
sku,
|
sku,
|
||||||
block);
|
block);
|
||||||
@ -158,7 +158,7 @@ namespace Epost.DAL
|
|||||||
strwhere += " and matchid = '" + matchid + "'";
|
strwhere += " and matchid = '" + matchid + "'";
|
||||||
}
|
}
|
||||||
|
|
||||||
string sql = string.Format("select sum(Quantity) as SumQuantity, Sum(checkquantity) as SumCkQuantity,boxweight, Discount,unit,wholeunit,matchid ,goodscode,goodsname from v_orders where readtime= (select top 1 readtime from orders where state=0) and (oprationstate = 0 or oprationstate=1) and sku='{0}' and block='{1}' " + strwhere + " group by sku,boxweight, Discount,goodsname,unit,wholeunit,matchid ,goodscode",
|
string sql = string.Format("select sum(Quantity) as SumQuantity, Sum(checkquantity) as SumCkQuantity,boxweight, Discount,unit,wholeunit,matchid ,goodscode,goodsname from v_orders where sku='{0}' and block='{1}' " + strwhere + " group by sku,boxweight, Discount,goodsname,unit,wholeunit,matchid ,goodscode",
|
||||||
sku,
|
sku,
|
||||||
block);
|
block);
|
||||||
LogHelper.WriteLogInfo("获取订单信息-中分" + sql);
|
LogHelper.WriteLogInfo("获取订单信息-中分" + sql);
|
||||||
@ -485,7 +485,7 @@ namespace Epost.DAL
|
|||||||
sql = string.Format(" update orders set oprationstate=1,oprationtime='{0}' where matchid='{1}' and id='{2}'",
|
sql = string.Format(" update orders set oprationstate=1,oprationtime='{0}' where matchid='{1}' and id='{2}'",
|
||||||
DateTime.Now.ToString(),
|
DateTime.Now.ToString(),
|
||||||
orderid,
|
orderid,
|
||||||
|
|
||||||
id);
|
id);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
@ -529,12 +529,12 @@ namespace Epost.DAL
|
|||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 修改订单为未拣货订单--挂起使用
|
#region 修改订单为未拣货订单--挂起使用
|
||||||
public bool UpOrderStateBybat(string batchid)
|
public bool UpOrderStateBybat(string id)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
string sql = string.Format(" update orders set oprationstate=0,oprationtime='' where batchid='{0}' and state<>3",
|
string sql = string.Format(" update orders set oprationstate=0,oprationtime='' where id='{0}' and state<>3",
|
||||||
batchid);
|
id);
|
||||||
long x = db.UpdateSql(sql);
|
long x = db.UpdateSql(sql);
|
||||||
if (x > 0)
|
if (x > 0)
|
||||||
return true;
|
return true;
|
||||||
@ -656,7 +656,6 @@ namespace Epost.DAL
|
|||||||
usercode
|
usercode
|
||||||
);
|
);
|
||||||
long x = db.UpdateSql(upsql);
|
long x = db.UpdateSql(upsql);
|
||||||
LogHelper.WriteLogInfo("修改当前标签拣货状态:" + upsql + ",成功条数：" + x + "");
|
|
||||||
if (x > 0)
|
if (x > 0)
|
||||||
return true;
|
return true;
|
||||||
return false;
|
return false;
|
||||||
@ -1248,7 +1247,7 @@ namespace Epost.DAL
|
|||||||
#region 查询sku对应的所有任务
|
#region 查询sku对应的所有任务
|
||||||
public DataTable getOrderListBysku(string block, string sku)
|
public DataTable getOrderListBysku(string block, string sku)
|
||||||
{
|
{
|
||||||
string sql = string.Format("select * from v_orders where block = '{0}' and sku ='{1}' ",
|
string sql = string.Format("select * from v_orders where block = '{0}' and sku ='{1}' order by layer,slist ",
|
||||||
block,
|
block,
|
||||||
sku);
|
sku);
|
||||||
LogHelper.WriteLogInfo("查询sku对应的所有任务:" + sql);
|
LogHelper.WriteLogInfo("查询sku对应的所有任务:" + sql);
|
||||||
@ -2493,373 +2492,6 @@ namespace Epost.DAL
|
|||||||
}
|
}
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
#region 三迎
|
|
||||||
//========三迎========
|
|
||||||
|
|
||||||
#region 查询扫描的是否为运单号
|
|
||||||
public DataTable GetOrdersMatchidIf(string matchid)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select distinct matchid,shopid,shopname,prino+0 from Orders where matchid='" + matchid + "' order by prino+0 asc");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 查询可分配的货位
|
|
||||||
public DataTable GetAddressNolocation(string block, string area)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select * from Addressstorage where bkaddress='0' and type='1' and block='" + block + "' and area='" + area + "' order by location+1 asc");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 为orders分配货位
|
|
||||||
public bool UpOrderstolocation(string shopid, string tolocation, string matchid)
|
|
||||||
{
|
|
||||||
string sql = string.Format("update Orders set tolocation='" + tolocation + "' where shopid='" + shopid + "' and matchid='" + matchid + "'");
|
|
||||||
long x = db.UpdateSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("为orders分配货位：" + sql + ",成功条数：" + x + "");
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
sql = string.Format("update Addressstorage set bkaddress='" + shopid + "' where location='" + tolocation + "' and bkaddress='0' ");
|
|
||||||
long b = db.UpdateSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("更新Addressstorage货位为已占用：" + sql + ",成功条数：" + b + "");
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 查询是否有正在作业的运单号
|
|
||||||
public DataTable GetOrderMatchidBin(string matchid)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select * from v_orders where tolocation!='' and matchid='" + matchid + "' ");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
|
|
||||||
public DataTable GetOrderMatchidLocation(string block, string area)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select * from v_orders where tolocation!='' and block='" + block + "' and area='" + area + "' ");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
|
|
||||||
public DataTable GetOrderMatchidInfo(string block, string area)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select distinct matchid,ControlIP from v_orders where (tolocation!='' or tolocation is not null) and block='" + block + "' and area='" + area + "' ");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 强制结束修改状态
|
|
||||||
public bool UpOrdersMatchid(string block, string area, string matchid)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
string sql = string.Format("update orders set state='3' where tolocation!='' and matchid='" + matchid + "' ");
|
|
||||||
long x = db.UpdateSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("强制结束修改状态：" + sql + ",成功条数：" + x + "");
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("强制结束修改状态异常：" + ex + "");
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public bool UpBkAddresss(string block, string area)
|
|
||||||
{
|
|
||||||
string sql = string.Format("update Addressstorage set bkaddress='0' where block='" + block + "' and area='" + area + "' ");
|
|
||||||
long x = db.UpdateSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("强制结束修改Addressstorage:" + sql + ",成功条数:" + x + "");
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public bool UpOrdersqueue(string block, string area, string matchid)
|
|
||||||
{
|
|
||||||
string sql = string.Format("update ordersqueue set state='3' where Taskblock='" + block + "' and Taskarea='" + area + "' and matchid='" + matchid + "' ");
|
|
||||||
long x = db.UpdateSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("强制结束修改ordersqueue:" + sql + ",成功条数:" + x + "");
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 查询
|
|
||||||
public DataTable GetSkuQuantity(string sku, string matchid)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select sum(quantity) sumqty from Orders where sku='" + sku + "' and matchid='" + matchid + "' ");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
|
|
||||||
public DataTable GetSku(string sku)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select * from SkuInfo where sku = '" + sku + "' ");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 释放播种位
|
|
||||||
public bool UpdateLocation(string block, string area)
|
|
||||||
{
|
|
||||||
string sql = string.Format("update Addressstorage set bkaddress='0' where block='" + block + "' and area='" + area + "' and type='1' ");
|
|
||||||
long x = db.UpdateSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("运单完成-释放播种位：" + sql + ",条数：" + x + "");
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region MyRegion
|
|
||||||
public bool UpdateWorkState_DPS(string matchid, int truequantity, string sku, int batchid, int checkquantity, string usercode = "")
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
lock (uplock)
|
|
||||||
{
|
|
||||||
int oprationstate = 3;
|
|
||||||
|
|
||||||
string upsql = string.Format("update Orders set oprationstate = '{3}' ,oprationtime='{0}',oprationcode='{5}',truequantity=quantity where matchid='{2}' and id='{4}' ",
|
|
||||||
DateTime.Now.ToString(),
|
|
||||||
truequantity,
|
|
||||||
matchid,
|
|
||||||
oprationstate,
|
|
||||||
batchid,
|
|
||||||
//checkquantity,
|
|
||||||
usercode
|
|
||||||
);
|
|
||||||
LogHelper.WriteLogInfo("-修改orders" + upsql);
|
|
||||||
long x = db.UpdateSql(upsql);
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("修改orders异常：" + upsql, LogHelper.Log_Type.ERROR);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("修改当前标签拣货状态异常：" + ex.Message);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region
|
|
||||||
public DataTable GetOrderinfoNumber(string matchid)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select distinct matchid,clientname,COUNT(distinct shopid) 'shopcount',count(distinct sku) qty from Orders where matchid='" + matchid + "' and isnull(tolocation,0)>0 group by matchid,clientname");
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
return dt;
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region MyRegion
|
|
||||||
public bool ImportOrderinfo(DataTable ds, Dictionary<string, string> diclist)
|
|
||||||
{
|
|
||||||
|
|
||||||
bool bo = db.UpdateData(ds, "orders", diclist);
|
|
||||||
if (bo)
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("添加取消订单失败");
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
|
|
||||||
#region 数据维护
|
|
||||||
public bool DelOrderSku()
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
string sql = string.Format("delete from Orders where sku not in (select sku from SkuInfo) ");
|
|
||||||
long x = db.DeleteSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("数据维护：" + sql + ",成功条数:" + x + "");
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("数据维护异常：" + ex + "", LogHelper.Log_Type.ERROR);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 导入数据清理之前orders
|
|
||||||
public void DelOrdersBeforeDate()
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
string sql = string.Format("insert into Ordershis select * from Orders");
|
|
||||||
long x = db.InsertSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("导入数据清理之前orders：" + sql + ",成功条数：" + x + "");
|
|
||||||
if (x > 0)
|
|
||||||
{
|
|
||||||
sql = string.Format("delete from Orders");
|
|
||||||
x = db.DeleteSql(sql);
|
|
||||||
LogHelper.WriteLogInfo("清理orders数据：" + sql + ",成功条数:" + x + "");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("导入数据清理之前orders异常：" + ex.Message + "", LogHelper.Log_Type.ERROR);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
|
|
||||||
#region 运单用时
|
|
||||||
public List<OrdersModel> GetMatchUserTimeByPage(string strWhere, string orderby, int startIndex, int endIndex, out int recordCount)
|
|
||||||
{
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
StringBuilder strSql = new StringBuilder();
|
|
||||||
strSql.Append("SELECT * FROM ( ");
|
|
||||||
strSql.Append(" SELECT ROW_NUMBER() OVER (");
|
|
||||||
if (!string.IsNullOrEmpty(orderby.Trim()))
|
|
||||||
{
|
|
||||||
strSql.Append("order by T." + orderby);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
strSql.Append("order by matchid asc");
|
|
||||||
}
|
|
||||||
strSql.Append(")AS Row,matchid as matchid,clientname as clientname,count(distinct(shopid)) as ShopCount,MIN(CONVERT(datetime,oprationtime)) AS starttime,MAX(CONVERT(datetime,oprationtime)) AS endtime,DATEDIFF(MINUTE,MIN(CONVERT(datetime,oprationtime)),MAX(CONVERT(datetime,oprationtime))) AS UseTime FROM Ordershis where 1=1 " + strWhere + " GROUP BY matchid,clientname ");
|
|
||||||
strSql.Append(" ) TT");
|
|
||||||
strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
|
|
||||||
List<OrdersModel> list = ModelConvertHelper<OrdersModel>.ConvertToList(db.GetsqlForDT(strSql.ToString()));
|
|
||||||
|
|
||||||
strSql.Remove(0, strSql.Length);
|
|
||||||
strSql.Append("SELECT count(distinct matchid) FROM Ordershis");
|
|
||||||
if (!string.IsNullOrEmpty(strWhere.Trim()))
|
|
||||||
{
|
|
||||||
strSql.AppendFormat(" WHERE 1=1 {0}", strWhere);
|
|
||||||
}
|
|
||||||
|
|
||||||
object obj = db.GetsqlForDT(strSql.ToString()).Rows[0][0];
|
|
||||||
if (obj != null)
|
|
||||||
recordCount = Convert.ToInt32(obj);
|
|
||||||
else
|
|
||||||
recordCount = 0;
|
|
||||||
|
|
||||||
return list;
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLog(GetType(), ex.Message);
|
|
||||||
recordCount = 0;
|
|
||||||
return new List<Model.OrdersModel>();
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public DataTable GetMatchUserTime_DT(string strWhere)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
string sql = string.Format("SELECT matchid as matchid,clientname as clientname,count(distinct(shopid)) as ShopCount,MIN(CONVERT(datetime,oprationtime)) AS starttime,MAX(CONVERT(datetime,oprationtime)) AS endtime,DATEDIFF(MINUTE,MIN(CONVERT(datetime,oprationtime)),MAX(CONVERT(datetime,oprationtime))) AS UseTime FROM Ordershis where 1=1 " + strWhere + " GROUP BY matchid,clientname ");
|
|
||||||
|
|
||||||
return db.GetsqlForDT(sql.ToString());
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLog(GetType(), ex.Message);
|
|
||||||
return new DataTable();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 获取当前区的作业状态
|
|
||||||
public DataTable getQueueState(string block, string area, string state)
|
|
||||||
{
|
|
||||||
string sql = string.Format("select * from OrdersQueue where taskblock='{0}' and taskarea='{1}' and state!='" + state + "' order by sort",
|
|
||||||
block,
|
|
||||||
area);
|
|
||||||
return db.GetsqlForDT(sql);
|
|
||||||
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
#region 判断订单状态为已完成
|
|
||||||
public bool IsFinishWork_box(string boxcode, int endcount, string matchid = "")
|
|
||||||
{
|
|
||||||
string sql = string.Format("select matchid from Orders where (matchid='{0}') and oprationstate<>3",
|
|
||||||
matchid);
|
|
||||||
|
|
||||||
|
|
||||||
LogHelper.WriteLogInfo("判断整箱状态为已完成" + sql);
|
|
||||||
DataTable dt = db.GetsqlForDT(sql);
|
|
||||||
if (dt == null || dt.Rows.Count == endcount)
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("判断整箱状态为已完成true");
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
LogHelper.WriteLogInfo("判断整箱状态为已完成false");
|
|
||||||
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endregion
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -10,7 +10,7 @@
|
|||||||
<WebStackScaffolding_LayoutPageFile>~/Views/Shared/_EpostLayoutPage.cshtml</WebStackScaffolding_LayoutPageFile>
|
<WebStackScaffolding_LayoutPageFile>~/Views/Shared/_EpostLayoutPage.cshtml</WebStackScaffolding_LayoutPageFile>
|
||||||
<WebStackScaffolding_IsAsyncSelected>False</WebStackScaffolding_IsAsyncSelected>
|
<WebStackScaffolding_IsAsyncSelected>False</WebStackScaffolding_IsAsyncSelected>
|
||||||
<WebStackScaffolding_ViewDialogWidth>600</WebStackScaffolding_ViewDialogWidth>
|
<WebStackScaffolding_ViewDialogWidth>600</WebStackScaffolding_ViewDialogWidth>
|
||||||
<NameOfLastUsedPublishProfile>D:\驿传\Epost\T_DAS_PTL\Epost.TestToolsWeb\Properties\PublishProfiles\Toolsweb.pubxml</NameOfLastUsedPublishProfile>
|
<NameOfLastUsedPublishProfile>E:\WORK\代码管理\T系列\播种\Epost.TestToolsWeb\Properties\PublishProfiles\Toolsweb.pubxml</NameOfLastUsedPublishProfile>
|
||||||
<LastActiveSolutionConfig>Debug|Any CPU</LastActiveSolutionConfig>
|
<LastActiveSolutionConfig>Debug|Any CPU</LastActiveSolutionConfig>
|
||||||
<Use64BitIISExpress />
|
<Use64BitIISExpress />
|
||||||
<IISExpressSSLPort />
|
<IISExpressSSLPort />
|
||||||
|
|||||||
@ -9,13 +9,13 @@
|
|||||||
<LastUsedBuildConfiguration>Release</LastUsedBuildConfiguration>
|
<LastUsedBuildConfiguration>Release</LastUsedBuildConfiguration>
|
||||||
<LastUsedPlatform>Any CPU</LastUsedPlatform>
|
<LastUsedPlatform>Any CPU</LastUsedPlatform>
|
||||||
<SiteUrlToLaunchAfterPublish />
|
<SiteUrlToLaunchAfterPublish />
|
||||||
<LaunchSiteAfterPublish>true</LaunchSiteAfterPublish>
|
<LaunchSiteAfterPublish>True</LaunchSiteAfterPublish>
|
||||||
<ExcludeApp_Data>false</ExcludeApp_Data>
|
<ExcludeApp_Data>False</ExcludeApp_Data>
|
||||||
<publishUrl>D:\驿传\SanYing_DAS-T后台</publishUrl>
|
<publishUrl>D:\驿传\T系列</publishUrl>
|
||||||
<DeleteExistingFiles>true</DeleteExistingFiles>
|
<DeleteExistingFiles>True</DeleteExistingFiles>
|
||||||
<PrecompileBeforePublish>true</PrecompileBeforePublish>
|
<PrecompileBeforePublish>True</PrecompileBeforePublish>
|
||||||
<EnableUpdateable>true</EnableUpdateable>
|
<EnableUpdateable>True</EnableUpdateable>
|
||||||
<DebugSymbols>false</DebugSymbols>
|
<DebugSymbols>False</DebugSymbols>
|
||||||
<WDPMergeOption>DonotMerge</WDPMergeOption>
|
<WDPMergeOption>DonotMerge</WDPMergeOption>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
</Project>
|
</Project>
|
||||||
File diff suppressed because it is too large
Load Diff
@ -11,7 +11,7 @@
|
|||||||
</configSections>
|
</configSections>
|
||||||
<connectionStrings>
|
<connectionStrings>
|
||||||
<add name="weijie_dpsEntities" connectionString="metadata=res://*/WJDB.csdl|res://*/WJDB.ssdl|res://*/WJDB.msl;provider=System.Data.SqlClient;provider connection string="data source=.;initial catalog=weijie_dps;user id=sa;password=123456;min pool size=4;max pool size=4;packet size=3072;MultipleActiveResultSets=True;App=EntityFramework"" providerName="System.Data.EntityClient" />
|
<add name="weijie_dpsEntities" connectionString="metadata=res://*/WJDB.csdl|res://*/WJDB.ssdl|res://*/WJDB.msl;provider=System.Data.SqlClient;provider connection string="data source=.;initial catalog=weijie_dps;user id=sa;password=123456;min pool size=4;max pool size=4;packet size=3072;MultipleActiveResultSets=True;App=EntityFramework"" providerName="System.Data.EntityClient" />
|
||||||
<add name="SqlLocDPSConnection" connectionString="server=139.196.36.200;user id=EpostTest;password=antion;database=BaBi_DAS;min pool size=512;max pool size=512;packet size=3072" providerName="System.Data.SqlClient" />
|
<add name="SqlLocDPSConnection" connectionString="server=139.196.36.200;user id=EpostTest;password=antion;database=BJ_ZhongLiang_DAS;min pool size=512;max pool size=512;packet size=3072" providerName="System.Data.SqlClient" />
|
||||||
<add name="MysqlLocDPSConnection" connectionString="Server=localhost;Port=3306;Database=world;User=root; Password=antion;SslMode=None;Pooling=true;Allow User Variables=True;" />
|
<add name="MysqlLocDPSConnection" connectionString="Server=localhost;Port=3306;Database=world;User=root; Password=antion;SslMode=None;Pooling=true;Allow User Variables=True;" />
|
||||||
|
|
||||||
<add name="WMSConnection" connectionString="data source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=139.196.36.200)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=EpostDB)));user id=C##Test;password=test" />
|
<add name="WMSConnection" connectionString="data source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=139.196.36.200)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=EpostDB)));user id=C##Test;password=test" />
|
||||||
@ -27,11 +27,11 @@
|
|||||||
<add key="ControlXML" value="/App_Data/EpostController.xml" />
|
<add key="ControlXML" value="/App_Data/EpostController.xml" />
|
||||||
<add key="LabelXML" value="/App_Data/AddressStorage.xml" />
|
<add key="LabelXML" value="/App_Data/AddressStorage.xml" />
|
||||||
<add key="ResultsXML" value="/App_Data/Results.xml" />
|
<add key="ResultsXML" value="/App_Data/Results.xml" />
|
||||||
<add key="WebAPIUrl" value="http://localhost:63119/api/WebAPI/ProcessingResult"/>
|
<add key="WebAPIUrl" value="http://192.168.3.65:8051/api/WebAPI/ProcessingResult"/>
|
||||||
<add key="ShowMode" value="1" />
|
<add key="ShowMode" value="1" />
|
||||||
<add key="SetupMode" value="\Epost_P\Epost.TestToolsWeb\App_Data\SetupMode.txt" />
|
<add key="SetupMode" value="\Epost_P\Epost.TestToolsWeb\App_Data\SetupMode.txt" />
|
||||||
<add key="CARID" value="HT01" />
|
<add key="CARID" value="HT01" />
|
||||||
<add key="ServerAPIURL" value="http://localhost:63119/api/WebAPI" />
|
<add key="ServerAPIURL" value="http://192.168.3.65:8051/api/WebAPI" />
|
||||||
<add key="SleepTime" value="1" />
|
<add key="SleepTime" value="1" />
|
||||||
</appSettings>
|
</appSettings>
|
||||||
<!--
|
<!--
|
||||||
|
|||||||
Reference in New Issue
Block a user