Skip to content
切换导航条
切换导航条
当前项目
正在载入...
登录
孙克
/
smf-core
转到一个项目
切换导航栏
切换导航栏固定状态
项目
群组
代码片段
帮助
项目
活动
版本库
流水线
图表
问题
0
合并请求
0
维基
网络
创建新的问题
作业
提交
问题看板
文件
提交
网络
比较
分支
标签
Commit 6979b273
由
LN
编写于
2023-12-21 15:08:40 +0800
浏览文件
选项
浏览文件
标签
下载
电子邮件补丁
差异文件
cancelAndDisable 先禁用库位,再取消存在的 任务
1 个父辈
320759a4
隐藏空白字符变更
内嵌
并排
正在显示
1 个修改的文件
包含
32 行增加
和
16 行删除
src/main/java/com/neotel/smfcore/core/device/rest/DeviceController.java
src/main/java/com/neotel/smfcore/core/device/rest/DeviceController.java
查看文件 @
6979b27
...
@@ -640,31 +640,47 @@ public class DeviceController {
...
@@ -640,31 +640,47 @@ public class DeviceController {
public
ResultBean
cancelAndDisable
(
HttpServletRequest
request
)
{
public
ResultBean
cancelAndDisable
(
HttpServletRequest
request
)
{
String
posName
=
request
.
getParameter
(
"posName"
);
String
posName
=
request
.
getParameter
(
"posName"
);
if
(
StringUtils
.
isNotBlank
(
posName
))
{
if
(
StringUtils
.
isNotBlank
(
posName
))
{
//首先禁用库位,有任务的话取消
StoragePos
pos
=
storagePosManager
.
getByPosName
(
posName
);
if
(
pos
!=
null
)
{
pos
.
setEnabled
(
false
);
storagePosManager
.
save
(
pos
);
dataCache
.
updateDisablePos
(
pos
);
log
.
info
(
" cancelAndDisable 禁用库位["
+
posName
+
"]"
);
DeviceMessageUtil
.
addEnabledPosMessage
(
pos
,
SecurityUtils
.
getCurrentUsername
());
Storage
storage
=
dataCache
.
getStorageById
(
pos
.
getStorageId
());
if
(
storage
!=
null
)
{
dataCache
.
reloadStorage
(
storage
,
""
);
}
}
DataLog
task
=
null
;
DataLog
task
=
null
;
List
<
DataLog
>
allTasks
=
taskService
.
getAllTasks
();
List
<
DataLog
>
allTasks
=
taskService
.
getAllTasks
();
for
(
DataLog
dataLog
:
allTasks
)
{
for
(
DataLog
dataLog
:
allTasks
)
{
if
(
posName
.
equals
(
dataLog
.
getPosName
())
&&
dataLog
.
isCheckOutTask
()
&&
!
dataLog
.
isFinished
())
{
if
(
posName
.
equals
(
dataLog
.
getPosName
())
&&
!
dataLog
.
isFinished
())
{
task
=
dataLog
;
task
=
dataLog
;
break
;
break
;
}
}
}
}
if
(
task
!=
null
)
{
if
(
task
!=
null
)
{
boolean
result
=
taskService
.
cancelTask
(
task
);
boolean
result
=
taskService
.
cancelTask
(
task
);
if
(
result
)
{
log
.
info
(
"cancelAndDisable 任务["
+
task
.
getId
()
+
"] posName["
+
task
.
getPosName
()
+
"] Reel Id["
+
task
.
getBarcode
()
+
"]取消 结果: "
+
result
);
StoragePos
pos
=
storagePosManager
.
getByPosName
(
posName
);
return
ResultBean
.
newOkResult
(
""
);
if
(
pos
!=
null
)
{
// if (result) {
pos
.
setEnabled
(
false
);
// StoragePos pos = storagePosManager.getByPosName(posName);
storagePosManager
.
save
(
pos
);
// if (pos != null) {
dataCache
.
updateDisablePos
(
pos
);
// pos.setEnabled(false);
log
.
info
(
"任务["
+
task
.
getId
()
+
"] posName["
+
task
.
getPosName
()
+
"] Reel Id["
+
task
.
getBarcode
()
+
"]取消成功,禁用库位["
+
task
.
getPosName
()
+
"]"
);
// storagePosManager.save(pos);
DeviceMessageUtil
.
addEnabledPosMessage
(
pos
,
SecurityUtils
.
getCurrentUsername
());
// dataCache.updateDisablePos(pos);
Storage
storage
=
dataCache
.
getStorageById
(
pos
.
getStorageId
());
// log.info("任务[" + task.getId() + "] posName[" + task.getPosName() + "] Reel Id[" + task.getBarcode() + "]取消成功,禁用库位[" + task.getPosName() + "]");
if
(
storage
!=
null
)
{
// DeviceMessageUtil.addEnabledPosMessage(pos, SecurityUtils.getCurrentUsername());
dataCache
.
reloadStorage
(
storage
,
""
);
// Storage storage = dataCache.getStorageById(pos.getStorageId());
}
// if (storage != null) {
}
// dataCache.reloadStorage(storage, "");
return
ResultBean
.
newOkResult
(
""
);
// }
}
// }
// return ResultBean.newOkResult("");
// }
}
else
{
}
else
{
return
ResultBean
.
newErrorResult
(
1
,
"smfcore.task.notExist"
,
"Task does not exist"
);
return
ResultBean
.
newErrorResult
(
1
,
"smfcore.task.notExist"
,
"Task does not exist"
);
}
}
...
...
编写
预览
支持
Markdown
格式
附加文件
你添加了
0
人
到此讨论。请谨慎行事。
Finish editing this message first!
Cancel
请
注册
或
登录
后发表评论