diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/pda_manage/pda/controller/PdaWashController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/pda_manage/pda/controller/PdaWashController.java index 816e4555..22b91ffc 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/pda_manage/pda/controller/PdaWashController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/pda_manage/pda/controller/PdaWashController.java @@ -30,6 +30,7 @@ import org.nl.wms.masterdata_manage.service.material.IMdMeMaterialbaseService; import org.nl.wms.masterdata_manage.service.material.dao.MdMeMaterialbase; import org.nl.wms.product_manage.service.device.IPdmBiDeviceService; import org.nl.wms.product_manage.service.device.dao.PdmBiDevice; +import org.nl.wms.scheduler_manage.service.extendtask.manage.TaskStatusEnum; import org.nl.wms.scheduler_manage.service.extendtask.wash.WashMachineryTask; import org.nl.wms.scheduler_manage.service.extendtask.wash.WashSendMaterialQZTask; import org.nl.wms.scheduler_manage.service.extendtask.wash.WashSendMaterialTask; @@ -191,8 +192,12 @@ public class PdaWashController { SchBaseTask lastTask = taskService.getOne(new QueryWrapper() .eq("task_type", AcsTaskEnum.TASK_WASH_SEND_MATERIAL.getCode()).orderByDesc("task_code").last("limit 1")); if (lastTask!=null){ - if (DateUtil.between(new Date(), lastTask.getCreate_time(), DateUnit.MINUTE) washTasks(@RequestBody JSONObject query) { List> taskMap = taskService.listMaps(new QueryWrapper() - .eq("task_status", StatusEnum.TASK_FINISH.getCode()).eq("task_step", 2).orderByAsc("task_code")); + .eq("task_status", StatusEnum.TASK_FINISH.getCode()) + .eq("task_type",AcsTaskEnum.TASK_WASH_SEND_MATERIAL.getCode()) + .eq("task_step", 2) + .orderByAsc("task_code")); if (!CollectionUtils.isEmpty(taskMap)){ Set materials = taskMap.stream().map(a->a.get("material_id")).collect(Collectors.toSet()); Map materialMap = materialbaseService.list(new QueryWrapper() @@ -277,7 +285,7 @@ public class PdaWashController { task.put("material_code",materialbase!=null?materialbase.getMaterial_code():""); task.put("material_spec",materialbase!=null?materialbase.getMaterial_spec():""); task.put("net_weight",materialbase!=null?materialbase.getNet_weight():""); - task.put("create_time",task.get("create_time").toString()); + task.put("create_time",task.get("update_time").toString()); task.put("sep_on",i); i++; } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/controller/PdaStBcpInController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/controller/PdaStBcpInController.java index ea09dc85..91aeb170 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/controller/PdaStBcpInController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/controller/PdaStBcpInController.java @@ -60,7 +60,7 @@ public class PdaStBcpInController { @PostMapping("/callVehicle") @Log("呼叫空载具") //("呼叫空载具") - public ResponseEntity callVehicle(JSONObject param) { + public ResponseEntity callVehicle(@RequestBody JSONObject param) { pdaStBcpInService.callVehicle(param.getString("point")); return new ResponseEntity<>(TableDataInfo.build(), HttpStatus.OK); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/service/impl/PdaStBcpInServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/service/impl/PdaStBcpInServiceImpl.java index 6c5a9c53..ea75048d 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/service/impl/PdaStBcpInServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/pda/service/impl/PdaStBcpInServiceImpl.java @@ -157,11 +157,13 @@ public class PdaStBcpInServiceImpl implements PdaStBcpInService { @Override @Transactional public JSONObject callVehicle(String pointCode3) { - if (StringUtils.isEmpty(pointCode3)){ - throw new BadRequestException("请求参数不能为空"); + if (pointCode3 == null){ + pointCode3 = "A1_BCPRKW_SD"; } JSONObject result = new JSONObject(); result.put("message", "下发失败"); + String finalPointCode = pointCode3; + String finalPointCode1 = pointCode3; RedissonUtils.lock(() -> { // 2.判断此入库点是否有正在执行的任务 @@ -169,9 +171,9 @@ public class PdaStBcpInServiceImpl implements PdaStBcpInService { new QueryWrapper().lambda() .eq(SchBaseTask::getIs_delete, false) .lt(SchBaseTask::getTask_status, TaskStatusEnum.FINISHED.getCode()) - .and(qr -> qr.eq(SchBaseTask::getPoint_code1, pointCode3) + .and(qr -> qr.eq(SchBaseTask::getPoint_code1, finalPointCode) .or() - .eq(SchBaseTask::getPoint_code3, pointCode3) + .eq(SchBaseTask::getPoint_code3, finalPointCode) ) ); if (ObjectUtil.isNotEmpty(taskList)) { @@ -196,7 +198,7 @@ public class PdaStBcpInServiceImpl implements PdaStBcpInService { .acs_task_type("7") .task_group_id(IdUtil.getStringId()) .point_code1(attrDao.getStruct_code()) - .point_code3(pointCode3) + .point_code3(finalPointCode1) .vehicle_code(attrDao.getStoragevehicle_code()) .product_area("A1") // 暂时写死 .build(); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/controller/structLvt/StIvtStructivtBcpController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/controller/structLvt/StIvtStructivtBcpController.java index 1160f51b..857ac52d 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/controller/structLvt/StIvtStructivtBcpController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/controller/structLvt/StIvtStructivtBcpController.java @@ -4,6 +4,7 @@ package org.nl.wms.storage_manage.semimanage.controller.structLvt; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageHelper; import io.swagger.annotations.ApiOperation; import org.nl.common.anno.Log; import org.nl.common.domain.query.PageQuery; @@ -77,6 +78,11 @@ public class StIvtStructivtBcpController { @Log("半成品库存导出") //("半成品库存查询") public ResponseEntity download(StructIvtBcpQuery query, PageQuery page, HttpServletResponse response) { + String[] createTime = query.getCreateTime(); + if (createTime!=null && createTime.length==2){ + query.setStart_time(createTime[0]); + query.setEnd_time(createTime[1]); + } List maps = bcpService.queryAll(query); columnInfoService.exportFile("st_ivt_structivt_bcp",maps,response, ListOf.of("struct_code","bill_type","unit_weight","is_pick","ivt_level","is_active","qty_unit_id","stor_id","ivt_level","struct_id","material_id","quality_scode","canuse_qty"), diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dao/mapper/xml/StIvtStructivtBcpMapper.xml b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dao/mapper/xml/StIvtStructivtBcpMapper.xml index 8d3d94fa..d9cde3f3 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dao/mapper/xml/StIvtStructivtBcpMapper.xml +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dao/mapper/xml/StIvtStructivtBcpMapper.xml @@ -170,6 +170,9 @@ and ivt.instorage_time >= #{query.start_time} + + and ivt.bill_type = #{query.bill_type} + and ivt.instorage_time <= #{query.end_time} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StructIvtBcpQuery.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StructIvtBcpQuery.java index 9739a485..bee1d2f3 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StructIvtBcpQuery.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StructIvtBcpQuery.java @@ -26,6 +26,10 @@ public class StructIvtBcpQuery extends BaseQuery { private String is_lock; + private String bill_type; + + private String[] createTime; + private Boolean is_delete = false; diff --git a/mes/qd/src/views/wms/storage_manage/semiproduct/semiproductIvt/index.vue b/mes/qd/src/views/wms/storage_manage/semiproduct/semiproductIvt/index.vue index d2d48e59..1ea118aa 100644 --- a/mes/qd/src/views/wms/storage_manage/semiproduct/semiproductIvt/index.vue +++ b/mes/qd/src/views/wms/storage_manage/semiproduct/semiproductIvt/index.vue @@ -61,6 +61,23 @@ /> + + + + + @@ -88,14 +105,15 @@ - + - - + + +