Compare commits
4 Commits
e221a8004c
...
bbebde5e72
| Author | SHA1 | Date | |
|---|---|---|---|
| bbebde5e72 | |||
| f4bd2c995b | |||
| 1f095cd085 | |||
| 0b63fa9caa |
@@ -1,5 +1,6 @@
|
||||
package org.nl.wms.basedata_manage.controller;
|
||||
|
||||
import cn.dev33.satoken.annotation.SaIgnore;
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
@@ -39,6 +40,7 @@ public class StructattrController {
|
||||
|
||||
@GetMapping
|
||||
@Log("查询仓位")
|
||||
@SaIgnore
|
||||
public ResponseEntity<Object> query(@RequestParam Map whereJson, PageQuery page) {
|
||||
return new ResponseEntity<>(TableDataInfo.build(structattrService.queryAll(whereJson, page)), HttpStatus.OK);
|
||||
}
|
||||
|
||||
@@ -143,6 +143,7 @@
|
||||
INNER JOIN md_me_materialbase mater ON mater.material_id = ext.material_id
|
||||
<where>
|
||||
1 = 1
|
||||
AND attr.occupancy_state = 3
|
||||
<if test="param.stor_id != null and param.stor_id != ''">
|
||||
AND
|
||||
attr.stor_id = #{param.stor_id}
|
||||
@@ -170,11 +171,12 @@
|
||||
(mater.material_code LIKE CONCAT('%', #{param.material_code},'%') or
|
||||
mater.material_name LIKE CONCAT('%', #{param.material_code},'%') )
|
||||
</if>
|
||||
|
||||
<if test="param.pcsn != null and param.pcsn != ''">
|
||||
AND
|
||||
ext.pcsn LIKE #{param.pcsn}
|
||||
</if>
|
||||
AND 0 = (SELECT COUNT(*) FROM sch_base_task t WHERE t.task_status <![CDATA[ < ]]> '5'
|
||||
AND t.is_delete = '0' AND (t.vehicle_code = ext.storagevehicle_code OR t.vehicle_code2 = ext.storagevehicle_code))
|
||||
</where>
|
||||
ORDER BY ext.create_time Desc
|
||||
</select>
|
||||
@@ -209,6 +211,7 @@
|
||||
INNER JOIN md_me_materialbase mater ON mater.material_id = ext.material_id
|
||||
<where>
|
||||
1 = 1 and ext.`status`='02'
|
||||
AND attr.occupancy_state = 3
|
||||
<if test="param.stor_id != null and param.stor_id != ''">
|
||||
AND
|
||||
attr.stor_id = #{param.stor_id}
|
||||
@@ -256,6 +259,8 @@
|
||||
AND
|
||||
ext.pcsn LIKE #{param.pcsn}
|
||||
</if>
|
||||
AND 0 = (SELECT COUNT(*) FROM sch_base_task t WHERE t.task_status <![CDATA[ < ]]> '5'
|
||||
AND t.is_delete = '0' AND (t.vehicle_code = ext.storagevehicle_code OR t.vehicle_code2 = ext.storagevehicle_code))
|
||||
</where>
|
||||
ORDER BY ext.create_time Desc
|
||||
</select>
|
||||
|
||||
@@ -13,7 +13,6 @@ public class MesBackMaterialRequestDto {
|
||||
|
||||
private String qty_unit_name;
|
||||
|
||||
@NotBlank(message = "数量不可为空")
|
||||
private String qty;
|
||||
|
||||
private String remark;
|
||||
|
||||
@@ -88,7 +88,7 @@ public class WmsToMesServiceImpl implements WmsToMesService {
|
||||
log.info("uploadMes回传接口输出参数为:-------------------" + result.toString());
|
||||
|
||||
|
||||
Integer status = result.getInteger("status");
|
||||
Integer status = result.getInteger("code");
|
||||
if (status != HttpStatus.OK.value()) {
|
||||
throw new BadRequestException(result.getString("message"));
|
||||
}
|
||||
|
||||
@@ -9,6 +9,7 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
||||
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.collections4.CollectionUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.nl.common.base.TableDataInfo;
|
||||
@@ -83,6 +84,7 @@ import static org.nl.wms.warehouse_manage.enums.IOSEnum.GROUP_PLATE_STATUS;
|
||||
* @author Liuxy
|
||||
* @since 2025-06-05
|
||||
*/
|
||||
@Slf4j
|
||||
@Service
|
||||
public class PdaIosInServiceImpl implements PdaIosInService {
|
||||
|
||||
@@ -649,6 +651,7 @@ public class PdaIosInServiceImpl implements PdaIosInService {
|
||||
@Override
|
||||
@Transactional
|
||||
public PdaResponse vehicleInConfirm(JSONObject whereJson) {
|
||||
log.info("vehicleInConfirm - {}", whereJson);
|
||||
//空载具入库
|
||||
Sectattr sectattr = sectattrService.findById(whereJson.getString("sect_code"));
|
||||
if (sectattr == null) {
|
||||
|
||||
@@ -81,6 +81,8 @@
|
||||
vehicle_code,
|
||||
point_code1,
|
||||
point_code2,
|
||||
point_code3,
|
||||
point_code4,
|
||||
(CASE task_status
|
||||
WHEN '0' THEN '生成'
|
||||
WHEN '1' THEN '申请'
|
||||
|
||||
@@ -373,7 +373,7 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
|
||||
@Override
|
||||
public SchBasePoint getPointByExtCode(String deviceCode) {
|
||||
List<SchBasePoint> schBasePointList = pointMapper.selectList(new LambdaQueryWrapper<SchBasePoint>()
|
||||
.eq(SchBasePoint::getExt_point_code, deviceCode));
|
||||
.eq(SchBasePoint::getExt_point_code, deviceCode).or().eq(SchBasePoint::getPoint_code, deviceCode));
|
||||
if(schBasePointList.isEmpty()){
|
||||
return null;
|
||||
}
|
||||
|
||||
@@ -22,13 +22,13 @@ public enum IOSEnum {
|
||||
UPDATE_IVT_TYPE(MapOf.of("入库", "1", "出库", "2")),
|
||||
|
||||
//单据出入库类型
|
||||
IO_TYPE(MapOf.of("入库","0", "出库", "1")),
|
||||
IO_TYPE(MapOf.of("入库", "0", "出库", "1")),
|
||||
|
||||
//单据状态
|
||||
BILL_STATUS(MapOf.of("生成","10", "分配中", "20", "分配完", "30", "完成", "99")),
|
||||
BILL_STATUS(MapOf.of("生成", "10", "分配中", "20", "分配完", "30", "完成", "99")),
|
||||
|
||||
// 入库业务类型
|
||||
BILL_TYPE(MapOf.of("生产入库","0001", "手工入库", "0009")),
|
||||
BILL_TYPE(MapOf.of("生产入库", "0001", "手工入库", "0009")),
|
||||
|
||||
//入库分配明细状态
|
||||
INBILL_DIS_STATUS(MapOf.of("未生成", "00", "生成", "01", "执行中", "02", "完成", "99")),
|
||||
@@ -38,11 +38,11 @@ public enum IOSEnum {
|
||||
|
||||
// 锁类型
|
||||
LOCK_TYPE(MapOf.of("未锁定", "0", "入库锁", "1", "出库锁", "2"
|
||||
, "移入锁", "3", "移出锁", "4", "其他锁","9"
|
||||
, "移入锁", "3", "移出锁", "4", "其他锁", "9"
|
||||
)),
|
||||
|
||||
// 点位状态
|
||||
POINT_STATUS(MapOf.of("无货", "1", "空载具", "2" , "有货", "3" )),
|
||||
POINT_STATUS(MapOf.of("无货", "1", "空载具", "2", "有货", "3")),
|
||||
|
||||
// 单据创建类型
|
||||
CREATE_MODE(MapOf.of("PC产生", "1", "终端产生", "2", "外部接口产生", "3", "手动", "4")),
|
||||
|
||||
@@ -1073,7 +1073,7 @@ public class OutBillServiceImpl extends ServiceImpl<IOStorInvMapper,IOStorInv> i
|
||||
task_form2.put("task_group_id", taskGroupId);
|
||||
task_form2.put("task_group_seq", "2");
|
||||
task_form2.put("create_mode", whereJson.getString("create_mode"));
|
||||
task_form.put("ext_task_code", whereJson.getString("ext_task_code"));
|
||||
task_form2.put("ext_task_code", whereJson.getString("ext_task_code"));
|
||||
|
||||
//这个需求特殊,因为会产生2个task,并且第二个task后结束,因此以第二个task_id为准!!
|
||||
task_id = downEmptyUpFullTask.create(task_form2);
|
||||
|
||||
Reference in New Issue
Block a user