diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java b/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java index acce4100..b7a7dd38 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/common/enums/AcsTaskEnum.java @@ -46,7 +46,7 @@ public enum AcsTaskEnum { TASK_STRUCT_HR_EMP_IN("29","入库-海柔半成品-空托盘"), TASK_STRUCT_HR_EMP_OUT("30","出库-海柔半成品-空托盘"), TASK_STRUCT_CP_CHECK("13","成品-盘点"), - TASK_WASH_LACK("20","清洗机-缺料请求"), + TASK_WASH_SEND_MATERIAL("20","清洗机-上料请求"), TASK_WASH_EMP("21","清洗机-空框请求"), TASK_WASH_FULL_AUTO("22","清洗机-满料请求自动"),//去半成品入库:参数不全也去异常处理位 TASK_WASH_FULL_QZ("23","清洗机-强制搬出"),//去异常位: diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/common/utils/ListOf.java b/mes/hd/nladmin-system/src/main/java/org/nl/common/utils/ListOf.java new file mode 100644 index 00000000..25e49f51 --- /dev/null +++ b/mes/hd/nladmin-system/src/main/java/org/nl/common/utils/ListOf.java @@ -0,0 +1,24 @@ +package org.nl.common.utils; + + +import org.apache.poi.ss.formula.functions.T; + +import java.io.Serializable; +import java.util.ArrayList; +import java.util.HashMap; + +/* + * @author ZZQ + * @Date 2022/11/29 2:55 下午 + */ +public class ListOf implements Serializable { + + + public static ArrayList of(K... key){ + ArrayList list = new ArrayList<>(); + for (K k : key) { + list.add(k); + } + return list; + } +} diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext_manage/acs/service/impl/AcsToWmsServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext_manage/acs/service/impl/AcsToWmsServiceImpl.java index d47ffee9..124884d4 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext_manage/acs/service/impl/AcsToWmsServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/ext_manage/acs/service/impl/AcsToWmsServiceImpl.java @@ -425,9 +425,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService{ } catch (Exception e) { result.put("status", HttpStatus.BAD_REQUEST.value()); result.put("message", e.getMessage()); + return result; } result.put("status", HttpStatus.OK.value()); - result.put("message", ""); + result.put("message", "下发成功!"); return result; } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/controller/vehicle/MdPbStoragevehicleinfoController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/controller/vehicle/MdPbStoragevehicleinfoController.java index 6b0bbd6b..57cd0aa8 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/controller/vehicle/MdPbStoragevehicleinfoController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/controller/vehicle/MdPbStoragevehicleinfoController.java @@ -30,8 +30,6 @@ import java.util.Map; @RequestMapping("api/storagevehicleinfo") public class MdPbStoragevehicleinfoController { - @Autowired - private IMdPbStoragevehicleinfoService storagevehicleinfoService; @Autowired private IMdPbStoragevehicleinfoService istoragevehicleinfoService; @@ -50,7 +48,7 @@ public class MdPbStoragevehicleinfoController { @Log("查询载具") //("查询载具") public ResponseEntity query(VehicleQuery whereJson, PageQuery page){ - return new ResponseEntity<>(TableDataInfo.build(storagevehicleinfoService.queryAll(whereJson,page)),HttpStatus.OK); + return new ResponseEntity<>(TableDataInfo.build(istoragevehicleinfoService.queryAll(whereJson,page)),HttpStatus.OK); } @PostMapping @@ -65,7 +63,7 @@ public class MdPbStoragevehicleinfoController { //("修改载具") //@PreAuthorize("@el.check('mdPbStoragevehicleinfo:edit')") public ResponseEntity update(@Validated @RequestBody JSONObject dto){ - storagevehicleinfoService.update(dto); + istoragevehicleinfoService.update(dto); return new ResponseEntity<>(HttpStatus.NO_CONTENT); } @@ -74,7 +72,7 @@ public class MdPbStoragevehicleinfoController { //@PreAuthorize("@el.check('mdPbStoragevehicleinfo:del')") @DeleteMapping public ResponseEntity delete(@RequestBody Long[] ids) { - storagevehicleinfoService.deleteAll(ids); + istoragevehicleinfoService.deleteAll(ids); return new ResponseEntity<>(HttpStatus.OK); } @@ -83,7 +81,7 @@ public class MdPbStoragevehicleinfoController { //("修改点位启用状态") //@PreAuthorize("@el.check('store:edit')") public ResponseEntity changeActive(@RequestBody JSONObject json) { - storagevehicleinfoService.changeActive(json); + istoragevehicleinfoService.changeActive(json); return new ResponseEntity<>(HttpStatus.NO_CONTENT); } @@ -92,7 +90,7 @@ public class MdPbStoragevehicleinfoController { //("获取起始载具号") //@PreAuthorize("@el.check('store:edit')") public ResponseEntity getVehicle(@PathVariable String code) { - JSONObject json = storagevehicleinfoService.getVehicle(code); + JSONObject json = istoragevehicleinfoService.getVehicle(code); return new ResponseEntity<>(json,HttpStatus.OK); } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/dao/MdPbStoragevehicleinfo.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/dao/MdPbStoragevehicleinfo.java index cc9eb4f2..9caf61b2 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/dao/MdPbStoragevehicleinfo.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/dao/MdPbStoragevehicleinfo.java @@ -101,6 +101,13 @@ public class MdPbStoragevehicleinfo implements Serializable { */ private BigDecimal vehicle_width; + + /** + * 载具重量(kg) + */ + private BigDecimal vehicle_weight; + + /** * 载具长度 */ diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/impl/MdPbStoragevehicleinfoServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/impl/MdPbStoragevehicleinfoServiceImpl.java index 254d7341..9db0e491 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/impl/MdPbStoragevehicleinfoServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/masterdata_manage/service/vehicle/impl/MdPbStoragevehicleinfoServiceImpl.java @@ -165,10 +165,6 @@ public class MdPbStoragevehicleinfoServiceImpl extends ServiceImplLIMIT_WEIGHT){ - throw new BadRequestException("选择的储料仓物料总重量大于"+LIMIT_WEIGHT+"公斤"); + throw new BadRequestException("选择的储料仓物料总重量大于"+LIMIT_WEIGHT/1000+"公斤"); } Param limit_time = paramService.getOne(new QueryWrapper().eq("code", "pda_wash_time")); //开启清洗上料时间限制 - if (limit_time!=null &&limit_time.getValue().equals("1")){ + if (limit_time!=null && !limit_time.getValue().equals("0")){ SchBaseTask lastTask = taskService.getOne(new QueryWrapper() - .eq("task_type", AcsTaskEnum.REQUEST_WASH_SEND_MATERIAL.getCode()).orderByDesc("task_code").last("limit 1")); - String materialId = lastTask.getMaterial_id(); - if (!list.get(0).getMaterial_id().equals(materialId)){ - long between = DateUtil.between(new Date(), lastTask.getCreate_time(), DateUnit.MINUTE); - if (between<5){ - throw new BadRequestException("不同物料任务间隔小于5分钟,任务:"+lastTask.getTask_code()); + .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)() .eq("struct_code", struct_code)); - if (!CollectionUtils.isEmpty(kzDevice)){ - List workorders = workorderService.list(new QueryWrapper() - .eq("workprocedure_id", ENGRAVE_WORKPRODURE) - .in("device_code", kzDevice) - .eq("workorder_status", WorkerOrderEnum.PRODUCTING.getCode())); - if (workorders.size()!=kzDevice.size()){ - throw new BadRequestException("当前刻字工单不在生产状态"); - } - if (workorders.stream().map(PdmProduceWorkorder::getMaterial_id).collect(Collectors.toSet()).size()>1){ - throw new BadRequestException("所选刻字机的物料规格不是同一种"); - } - - if(!workorders.get(0).getMaterial_id().equals(stIvtStructivt.getMaterial_id())){ - throw new BadRequestException("半成品库存物料规格与刻字机工单物料不一致"); - } - List list = taskService.list(new QueryWrapper() - .lt("task_status", StatusEnum.TASK_FINISH.getCode()) - .in("task_type", AcsTaskEnum.TASK_STRUCT_OUT.getCode(),AcsTaskEnum.TASK_Engrave_CALL.getCode(), AcsTaskEnum.TASK_Engrave_EMPTY.getCode())); - if (!CollectionUtils.isEmpty(list)){ - throw new BadRequestException("存在正在执行的刻字上料相关任务:"+list.stream().map(SchBaseTask::getTask_code).collect(Collectors.joining(","))); - } +// if (!CollectionUtils.isEmpty(kzDevice)){ +// List workorders = workorderService.list(new QueryWrapper() +// .eq("workprocedure_id", ENGRAVE_WORKPRODURE) +// .in("device_code", kzDevice) +// .eq("workorder_status", WorkerOrderEnum.PRODUCTING.getCode())); +// if (workorders.size()!=kzDevice.size()){ +// throw new BadRequestException("当前刻字工单不在生产状态"); +// } +// if (workorders.stream().map(PdmProduceWorkorder::getMaterial_id).collect(Collectors.toSet()).size()>1){ +// throw new BadRequestException("所选刻字机的物料规格不是同一种"); +// } +// +// if(!workorders.get(0).getMaterial_id().equals(stIvtStructivt.getMaterial_id())){ +// throw new BadRequestException("半成品库存物料规格与刻字机工单物料不一致"); +// } +// } + List list = taskService.list(new QueryWrapper() + .lt("task_status", StatusEnum.TASK_FINISH.getCode()) + .in("task_type", AcsTaskEnum.TASK_STRUCT_OUT.getCode(),AcsTaskEnum.TASK_Engrave_CALL.getCode(), AcsTaskEnum.TASK_Engrave_EMPTY.getCode())); + if (!CollectionUtils.isEmpty(list)){ + throw new BadRequestException("存在正在执行的刻字上料相关任务:"+list.stream().map(SchBaseTask::getTask_code).collect(Collectors.joining(","))); } JSONObject form = new JSONObject(); form.put("stor_id", IOSEnum.STOR_CODE.code("半成品仓库"));//st_ivt_sectattr紫铜车间-半成品库区 diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/Engrave/EngraveSendEmpTask.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/Engrave/EngraveSendEmpTask.java index 062d5031..c669cbb2 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/Engrave/EngraveSendEmpTask.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/Engrave/EngraveSendEmpTask.java @@ -122,11 +122,12 @@ public class EngraveSendEmpTask extends AbstractAcsTask { task.put("priority", "1"); task.put("finished_type", "1"); task.put("agv_system_type", AcsTaskEnum.AGV_SYSTEM_XC.getCode()); - SchBaseTask schBaseTask = task.toJavaObject(SchBaseTask.class); + Param one = paramService.getOne(new QueryWrapper().eq("code", "engrave_priority")); if (one!=null){ - schBaseTask.setPriority(one.getValue()); + task.put("priority",one.getValue()); } + SchBaseTask schBaseTask = task.toJavaObject(SchBaseTask.class); taskService.save(schBaseTask); // 找终点 try { diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashCallEmptyTask.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashCallEmptyTask.java index 4c2e69e9..5fbb72c5 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashCallEmptyTask.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashCallEmptyTask.java @@ -117,11 +117,11 @@ public class WashCallEmptyTask extends AbstractAcsTask { } // 查找任务状态 JSONObject task = packageTask(param.getString("device_code")); - SchBaseTask schBaseTask = task.toJavaObject(SchBaseTask.class); Param one = paramService.getOne(new QueryWrapper().eq("code", "wash_priority")); if (one!=null){ - schBaseTask.setPriority(one.getValue()); + task.put("priority",one.getValue()); } + SchBaseTask schBaseTask = task.toJavaObject(SchBaseTask.class); taskService.save(schBaseTask); // 找终点 try { @@ -207,7 +207,7 @@ public class WashCallEmptyTask extends AbstractAcsTask { .eq(StIvtStructattr::getLock_type, IOSEnum.LOCK_TYPE.code("未锁定")) .eq(StIvtStructattr::getIs_used,true) .orderByDesc(StIvtStructattr::getXqty) - .orderByAsc(StIvtStructattr::getYqty),false + .orderByAsc(StIvtStructattr::getZqty),false ); if (ObjectUtil.isEmpty(attrDao)) throw new BadRequestException("未找到空载具!"); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashMachineryTask.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashMachineryTask.java index 93730b2f..51d37c40 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashMachineryTask.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashMachineryTask.java @@ -125,8 +125,8 @@ public class WashMachineryTask extends AbstractAcsTask { } JSONObject task = new JSONObject(); task.put("task_id", IdUtil.getStringId()); - task.put("task_name", AcsTaskEnum.REQUEST_WASH_SEND_MATERIAL.getDesc()); - task.put("task_type", AcsTaskEnum.REQUEST_WASH_SEND_MATERIAL.getCode()); + task.put("task_name", AcsTaskEnum.TASK_WASH_SEND_MATERIAL.getDesc()); + task.put("task_type", AcsTaskEnum.TASK_WASH_SEND_MATERIAL.getCode()); task.put("task_code", CodeUtil.getNewCode("TASK_CODE")); task.put("task_status", StatusEnum.TASK_PUBLISH.getCode()); task.put("point_code3", "A1_SKQXJ_01_S");//A1_SKQXJ_01_X diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashSendMaterialTask.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashSendMaterialTask.java index 2d93ad22..487021b6 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashSendMaterialTask.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/extendtask/wash/WashSendMaterialTask.java @@ -83,14 +83,13 @@ public class WashSendMaterialTask extends AbstractAcsTask { throw new BadRequestException(String.format("设备%s存在未完成任务"+list.stream().map(SchBaseTask::getTask_id).collect(Collectors.toList()).toString(), param.getString("device_code"))); } SchBaseTask order = taskService.getById(param.getString("task_id")); - MdMeMaterialbase byId = materialbaseService.getById(order.getMaterial_id()); JSONObject form = new JSONObject(); form.put("bill_type","0001"); form.put("point_code",start_point_code); form.put("stor_id", IOSEnum.STOR_CODE.code("半成品仓库"));//半成品仓库 form.put("total_qty",param.getString("wegiht")); form.put("material_id",order.getMaterial_id()); - form.put("unit_weight",byId.getNet_weight()); + form.put("unit_weight",param.getString("net_weight")); form.put("storagevehicle_code",param.getString("vechile_code")); form.put("product_code","A1"); form.put("auto_send",true); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/dao/SchBasePoint.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/dao/SchBasePoint.java index 7bd80c52..5410f918 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/dao/SchBasePoint.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/dao/SchBasePoint.java @@ -224,5 +224,10 @@ public class SchBasePoint implements Serializable { */ private String control_point; + /** + * 点位优先级默认1 + */ + private String priority; + } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/impl/SchBasePointServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/impl/SchBasePointServiceImpl.java index 6a750e3f..0222fecc 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/impl/SchBasePointServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/scheduler_manage/service/point/impl/SchBasePointServiceImpl.java @@ -138,6 +138,7 @@ public class SchBasePointServiceImpl extends ServiceImpl Integer.parseInt(row.getWork_status()) > Integer.parseInt(IOSEnum.WORK_STATUS.code("生成"))); - - if (is_create_task) throw new BadRequestException("任务已执行或已完成,不可取消!"); + .anyMatch(row -> Integer.parseInt(row.getWork_status()) > Integer.parseInt(IOSEnum.WORK_STATUS.code("执行中"))); + if (is_create_task) throw new BadRequestException("单据已完成,不可取消!"); + List collect = disDaoList.stream().map(StIvtIostorinvdisCp::getTask_id).collect(Collectors.toList()); + List tasks = iSchBaseTaskService.list(new QueryWrapper() + .lt("task_status", StatusEnum.TASK_CANNEL.getCode()) + .in("task_id", collect)); + if (!CollectionUtils.isEmpty(tasks)){ + throw new BadRequestException("搬运:"+tasks.stream().map(SchBaseTask::getTask_code).collect(Collectors.joining(","))+"任务以生成,不可取消!请先取消任务再操作"); + } // 2.更新库存,删除任务 for (StIvtIostorinvdisCp disDao : disDaoList) { // 更新库存、更新仓位 @@ -370,6 +377,7 @@ public class StIvtIostorinvCpOutServiceImpl extends ServiceImpl) disDao::setTask_id) @@ -586,6 +595,7 @@ public class StIvtIostorinvCpOutServiceImpl extends ServiceImpl) disDao::setTask_id) @@ -865,9 +875,17 @@ public class StIvtIostorinvCpOutServiceImpl extends ServiceImpl().lambda() + .set(SchBaseTask::getTask_status,TaskStatusEnum.CANCEL.getCode()) + .eq(SchBaseTask::getTask_id, task_id) + ); + if (disDao!=null){ + JSONObject param = new JSONObject(); + param.put("iostorinvdis_id",disDao.getIostorinvdis_id()); + delTask(param); + } // 更新发货点位 iSchBasePointService.update( diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moreOrLess/impl/StIvtMoreorlessdtlCpServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moreOrLess/impl/StIvtMoreorlessdtlCpServiceImpl.java index 794bc034..8984a16f 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moreOrLess/impl/StIvtMoreorlessdtlCpServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/service/moreOrLess/impl/StIvtMoreorlessdtlCpServiceImpl.java @@ -11,7 +11,6 @@ import org.nl.common.utils.IdUtil; import org.nl.modules.common.exception.BadRequestException; import org.nl.modules.system.util.CodeUtil; import org.nl.wms.masterdata_manage.service.vehicle.IMdPbStoragevehicleinfoService; -import org.nl.wms.masterdata_manage.service.vehicle.dao.MdPbStoragevehicleinfo; import org.nl.wms.masterdata_manage.storage.service.storage.IStIvtSectattrService; import org.nl.wms.masterdata_manage.storage.service.storage.IStIvtStructattrService; import org.nl.wms.masterdata_manage.storage.service.storage.dao.StIvtSectattr; diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/util/impl/DivRuleCpServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/util/impl/DivRuleCpServiceImpl.java index 24059895..d2d2b867 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/util/impl/DivRuleCpServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/productmanage/util/impl/DivRuleCpServiceImpl.java @@ -2,6 +2,7 @@ package org.nl.wms.storage_manage.productmanage.util.impl; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import org.nl.common.utils.RedissonUtils; @@ -56,18 +57,22 @@ public class DivRuleCpServiceImpl implements DivRuleCpService { switch (whereJson.getString("rule_type")) { case RuleUtil.PRODUCTION_IN_1 : - attrDao = iStIvtStructattrService.getOne( - new QueryWrapper().lambda() - .eq(StIvtStructattr::getStor_id, stor_id) - .eq(StIvtStructattr::getSect_id, sect_id) - .eq(StIvtStructattr::getIs_used, IOSEnum.IS_USED.code("是")) - .eq(StIvtStructattr::getLock_type, IOSEnum.LOCK_TYPE.code("未锁定")) - .and(qr -> qr.eq(StIvtStructattr::getStoragevehicle_code,"") - .or().isNull(StIvtStructattr::getStoragevehicle_code) - ) - .ne(StIvtStructattr::getIs_emptyvehicle, true) - .orderByDesc(StIvtStructattr::getXqty) - .orderByAsc(StIvtStructattr::getYqty) + LambdaQueryWrapper wrapper = new QueryWrapper().lambda() + .eq(StIvtStructattr::getStor_id, stor_id) + .eq(StIvtStructattr::getSect_id, sect_id) + .eq(StIvtStructattr::getIs_used, IOSEnum.IS_USED.code("是")) + .eq(StIvtStructattr::getLock_type, IOSEnum.LOCK_TYPE.code("未锁定")) + .and(qr -> qr.eq(StIvtStructattr::getStoragevehicle_code, "") + .or().isNull(StIvtStructattr::getStoragevehicle_code) + ) + .ne(StIvtStructattr::getIs_emptyvehicle, true) + .orderByDesc(StIvtStructattr::getXqty); + if (IOSEnum.STOR_CODE.code("半成品仓库").equals(stor_id)){ + wrapper.orderByAsc(StIvtStructattr::getYqty); + }else { + wrapper.orderByAsc(StIvtStructattr::getZqty); + } + attrDao = iStIvtStructattrService.getOne(wrapper , false); break; case RuleUtil.PRODUCTION_IN_2 : 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 90c06c92..e60ccb62 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 @@ -7,6 +7,7 @@ import com.alibaba.fastjson.JSONObject; import io.swagger.annotations.ApiOperation; import org.nl.common.anno.Log; import org.nl.common.domain.query.PageQuery; +import org.nl.common.utils.ListOf; import org.nl.common.utils.MapOf; import org.nl.wms.storage_manage.basedata.service.record.dto.StIvtStructivtflowVo; import org.nl.wms.storage_manage.productmanage.service.structIvt.dto.CpIvtQuery; @@ -79,7 +80,8 @@ public class StIvtStructivtBcpController { List maps = bcpService.queryAll(query); String s = JSON.toJSONString(maps); List bcpVos = JSONArray.parseArray(s, StIvtStructivtBcpVo.class); - columnInfoService.exportFile(bcpVos,response, MapOf.of("stor_name","仓库名称","material_name","物料名称","material_spec","物料规格")); + columnInfoService.exportFile(bcpVos,response, ListOf.of("is_pick","ivt_level","is_active","qty_unit_id","stor_id","ivt_level","struct_id","material_id","quality_scode"), + MapOf.of("stor_name","仓库名称","material_name","物料名称","material_spec","物料规格","material_code","物料编号","storagevehicle_code","载具编号","vehicle_weight","载具单重(g)")); return new ResponseEntity<>(HttpStatus.OK); } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/iostorInv/impl/StIvtIostorinvBcpServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/iostorInv/impl/StIvtIostorinvBcpServiceImpl.java index fc1804b1..89cebeec 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/iostorInv/impl/StIvtIostorinvBcpServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/iostorInv/impl/StIvtIostorinvBcpServiceImpl.java @@ -219,6 +219,9 @@ public class StIvtIostorinvBcpServiceImpl extends ServiceImpl 1=1 diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StIvtStructivtBcpVo.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StIvtStructivtBcpVo.java index 4c4ea8d0..3a23fec4 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StIvtStructivtBcpVo.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanage/service/structIvt/dto/StIvtStructivtBcpVo.java @@ -98,5 +98,6 @@ public class StIvtStructivtBcpVo { private String sect_name; private String stor_name; private String storagevehicle_code; + private String vehicle_weight; } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/controller/structLvt/StIvtStructivtHrBcpController.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/controller/structLvt/StIvtStructivtHrBcpController.java index af13f58f..ccb86b16 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/controller/structLvt/StIvtStructivtHrBcpController.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/controller/structLvt/StIvtStructivtHrBcpController.java @@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import org.nl.common.anno.Log; import org.nl.common.domain.query.PageQuery; +import org.nl.common.utils.ListOf; import org.nl.common.utils.MapOf; import org.nl.wms.storage_manage.semimanage.service.structIvt.dto.StIvtStructivtBcpVo; import org.nl.wms.storage_manage.semimanagehr.service.structIvt.IStIvtStructivtHrBcpService; @@ -72,7 +73,9 @@ public class StIvtStructivtHrBcpController { List maps = bcpService.queryAll(query); String s = JSON.toJSONString(maps); List bcpVos = JSONArray.parseArray(s, StIvtStructivtBcpVo.class); - columnInfoService.exportFile(bcpVos,response, MapOf.of("stor_name","仓库名称","material_name","物料名称","material_spec","物料规格")); + columnInfoService.exportFile(bcpVos,response, + ListOf.of(""), + MapOf.of("stor_name","仓库名称","material_name","物料名称","material_spec","物料规格")); return new ResponseEntity<>(HttpStatus.OK); } } diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/check/impl/StIvtCheckmstHrBcpServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/check/impl/StIvtCheckmstHrBcpServiceImpl.java index dfd99ba5..278cdb9a 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/check/impl/StIvtCheckmstHrBcpServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/check/impl/StIvtCheckmstHrBcpServiceImpl.java @@ -164,7 +164,7 @@ public class StIvtCheckmstHrBcpServiceImpl extends ServiceImpl row.getStatus().equals(CHECKEnum.BILL_STATUS.code("完成"))); + .allMatch(row -> row.getStatus().equals(CHECKEnum.BILL_STATUS.code("完成"))); if (is_status) { // 完成单据 @@ -410,9 +410,9 @@ public class StIvtCheckmstHrBcpServiceImpl extends ServiceImpl ObjectUtil.isNotEmpty(row.getCheck_result())) - .anyMatch(row -> row.getCheck_result().equals(CHECKEnum.CHECK_RESULT.code("正常"))); + .allMatch(row -> row.getCheck_result().equals(CHECKEnum.CHECK_RESULT.code("正常"))); - mstDao.setIs_nok(is_check); + mstDao.setIs_nok(!is_check); this.updateById(mstDao); diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvEmpBcpServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvEmpBcpServiceImpl.java index 13ad6406..aecb3f03 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvEmpBcpServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvEmpBcpServiceImpl.java @@ -95,10 +95,10 @@ public class StIvtIostorinvEmpBcpServiceImpl implements IStIvtIostorinvEmpBcpSe SchBaseTask taskDao = new SchBaseTask(); PointEvent event = PointEvent.builder() .type(AcsTaskEnum.TASK_STRUCT_HR_EMP_IN) - .acs_task_type("7") + .acs_task_type("17") .task_group_id(IdUtil.getStringId()) .point_code1(device_code) - .point_code3(barcode) + .point_code3(arrtDao.getStruct_code()) .vehicle_code(barcode) .product_area("A3") .callback((Consumer) taskDao::setTask_id) @@ -192,7 +192,7 @@ public class StIvtIostorinvEmpBcpServiceImpl implements IStIvtIostorinvEmpBcpSe SchBaseTask taskDao = new SchBaseTask(); PointEvent event = PointEvent.builder() .type(AcsTaskEnum.TASK_STRUCT_HR_EMP_OUT) - .acs_task_type("7") + .acs_task_type("16") .task_group_id(IdUtil.getStringId()) .point_code1(arrtDao.getStruct_code()) .point_code3(device_code) diff --git a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvHrBcpInServiceImpl.java b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvHrBcpInServiceImpl.java index 3a1b69a3..24a1a325 100644 --- a/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvHrBcpInServiceImpl.java +++ b/mes/hd/nladmin-system/src/main/java/org/nl/wms/storage_manage/semimanagehr/service/iostorInv/impl/StIvtIostorinvHrBcpInServiceImpl.java @@ -347,7 +347,7 @@ public class StIvtIostorinvHrBcpInServiceImpl extends ServiceImpl().lambda() .eq(StIvtStructattr::getStruct_code, mst.getStruct_code()) .set(StIvtStructattr::getLock_type, IOSEnum.LOCK_TYPE.code("未锁定")) + .set(StIvtStructattr::getTask_code, "") .set(StIvtStructattr::getInv_code,"") .set(StIvtStructattr::getStoragevehicle_code, "")); @@ -437,7 +438,7 @@ public class StIvtIostorinvHrBcpOutServiceImpl extends ServiceImpl void exportFile(List data, HttpServletResponse response, Map customizMap) { + public void exportFile(List data, HttpServletResponse response,List passParam, Map customizMap) { if (CollectionUtils.isEmpty(data)){ throw new BindException("导出失败,没有导出数据"+data.size()); } @@ -58,6 +58,11 @@ public class ColumnInfoService { } } Map map = this.TableColumn(tableName.value()); + if (!CollectionUtils.isEmpty(passParam)){ + for (Object s : passParam) { + map.remove(s); + } + } map.putAll(customizMap); if (CollectionUtils.isEmpty(map)){ throw new BindException("导出失败,表结构信息失败"+tableName.value()); diff --git a/mes/hd/nladmin-system/src/main/resources/config/application-prod.yml b/mes/hd/nladmin-system/src/main/resources/config/application-prod.yml index 16582f94..9759eeae 100644 --- a/mes/hd/nladmin-system/src/main/resources/config/application-prod.yml +++ b/mes/hd/nladmin-system/src/main/resources/config/application-prod.yml @@ -22,7 +22,7 @@ spring: druid: db-type: com.alibaba.druid.pool.DruidDataSource driverClassName: net.sf.log4jdbc.sql.jdbcapi.DriverSpy - url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_mes}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false + url: jdbc:log4jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_lms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false # url: jdbc:log4jdbc:mysql://${DB_HOST:localhost}:${DB_PORT:3306}/${DB_NAME:hl_one_mes}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false username: ${DB_USER:root} # password: ${DB_PWD:123456} @@ -199,4 +199,4 @@ sa-token: # - redis://127.0.0.1:6379 es: index: mes_log -schedulerFile: C:\mes\scheduler.xml +schedulerFile: C:\lms\scheduler.xml diff --git a/mes/qd/src/layout/components/Sidebar/Logo.vue b/mes/qd/src/layout/components/Sidebar/Logo.vue index f266e559..ba96c841 100644 --- a/mes/qd/src/layout/components/Sidebar/Logo.vue +++ b/mes/qd/src/layout/components/Sidebar/Logo.vue @@ -34,7 +34,7 @@ export default { }, data() { return { - title: '海亮mes系统', + title: '海亮lms系统', logo: Logo, title_param: 'platform' } diff --git a/mes/qd/src/views/login.vue b/mes/qd/src/views/login.vue index a501e8dc..26ce01d4 100644 --- a/mes/qd/src/views/login.vue +++ b/mes/qd/src/views/login.vue @@ -2,7 +2,7 @@ + + + + + + + + + + + +