diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/controller/BmVehicleInfoController.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/controller/BmVehicleInfoController.java similarity index 92% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/controller/BmVehicleInfoController.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/controller/BmVehicleInfoController.java index b40eb166..51b546f8 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/controller/BmVehicleInfoController.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/controller/BmVehicleInfoController.java @@ -1,12 +1,12 @@ -package org.nl.wms.base_manage.vehicle.vehicleInfo.controller; +package org.nl.wms.base_manage.vehicle.controller; import com.alibaba.fastjson.JSONObject; import org.nl.common.TableDataInfo; import org.nl.common.anno.Log; import org.nl.common.domain.entity.PageQuery; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.IBmVehicleInfoService; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dto.VehicleQuery; +import org.nl.wms.base_manage.vehicle.service.dto.VehicleQuery; +import org.nl.wms.base_manage.vehicle.service.IBmVehicleInfoService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/IBmVehicleInfoService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/IBmVehicleInfoService.java similarity index 89% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/IBmVehicleInfoService.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/IBmVehicleInfoService.java index f1c7a6f9..19235292 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/IBmVehicleInfoService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/IBmVehicleInfoService.java @@ -1,12 +1,12 @@ -package org.nl.wms.base_manage.vehicle.vehicleInfo.service; +package org.nl.wms.base_manage.vehicle.service; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; import org.nl.common.domain.entity.PageQuery; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.BmVehicleInfo; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dto.VehicleQuery; +import org.nl.wms.base_manage.vehicle.service.dao.BmVehicleInfo; +import org.nl.wms.base_manage.vehicle.service.dto.VehicleQuery; import java.util.List; import java.util.Map; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/BmVehicleInfo.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/BmVehicleInfo.java similarity index 96% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/BmVehicleInfo.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/BmVehicleInfo.java index 16d42cdd..c19547c8 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/BmVehicleInfo.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/BmVehicleInfo.java @@ -1,4 +1,4 @@ -package org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao; +package org.nl.wms.base_manage.vehicle.service.dao; import java.math.BigDecimal; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/mapper/BmVehicleInfoMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/mapper/BmVehicleInfoMapper.java similarity index 65% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/mapper/BmVehicleInfoMapper.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/mapper/BmVehicleInfoMapper.java index 46f3c013..433cd0dc 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/mapper/BmVehicleInfoMapper.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/mapper/BmVehicleInfoMapper.java @@ -1,6 +1,6 @@ -package org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.mapper; +package org.nl.wms.base_manage.vehicle.service.dao.mapper; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.BmVehicleInfo; +import org.nl.wms.base_manage.vehicle.service.dao.BmVehicleInfo; import com.baomidou.mybatisplus.core.mapper.BaseMapper; /** diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/mapper/xml/BmVehicleInfoMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/mapper/xml/BmVehicleInfoMapper.xml similarity index 73% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/mapper/xml/BmVehicleInfoMapper.xml rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/mapper/xml/BmVehicleInfoMapper.xml index 7822961c..140186e0 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dao/mapper/xml/BmVehicleInfoMapper.xml +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dao/mapper/xml/BmVehicleInfoMapper.xml @@ -1,8 +1,8 @@ - + - select * from md_pb_storagevehicleinfo where md_pb_storagevehicleinfo.storagevehicle_code = #{vehicle_code} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dto/VehicleQuery.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dto/VehicleQuery.java similarity index 82% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dto/VehicleQuery.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dto/VehicleQuery.java index 6678a393..6ca8f797 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/dto/VehicleQuery.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/dto/VehicleQuery.java @@ -1,10 +1,10 @@ -package org.nl.wms.base_manage.vehicle.vehicleInfo.service.dto; +package org.nl.wms.base_manage.vehicle.service.dto; import lombok.Data; import org.nl.common.domain.entity.BaseQuery; import org.nl.common.domain.entity.QParam; import org.nl.common.enums.QueryTEnum; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.BmVehicleInfo; +import org.nl.wms.base_manage.vehicle.service.dao.BmVehicleInfo; /* * @author ZZQ diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/impl/BmVehicleInfoServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/impl/BmVehicleInfoServiceImpl.java similarity index 93% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/impl/BmVehicleInfoServiceImpl.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/impl/BmVehicleInfoServiceImpl.java index 55b76f8f..ce710766 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleInfo/service/impl/BmVehicleInfoServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/service/impl/BmVehicleInfoServiceImpl.java @@ -1,4 +1,4 @@ -package org.nl.wms.base_manage.vehicle.vehicleInfo.service.impl; +package org.nl.wms.base_manage.vehicle.service.impl; import cn.hutool.core.date.DateUtil; import cn.hutool.core.map.MapUtil; @@ -12,10 +12,10 @@ import org.nl.common.domain.entity.PageQuery; import org.nl.common.domain.exception.BadRequestException; import org.nl.common.utils.CodeUtil; import org.nl.common.utils.SecurityUtils; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.IBmVehicleInfoService; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.BmVehicleInfo; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.mapper.BmVehicleInfoMapper; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dto.VehicleQuery; +import org.nl.wms.base_manage.vehicle.service.dto.VehicleQuery; +import org.nl.wms.base_manage.vehicle.service.IBmVehicleInfoService; +import org.nl.wms.base_manage.vehicle.service.dao.BmVehicleInfo; +import org.nl.wms.base_manage.vehicle.service.dao.mapper.BmVehicleInfoMapper; import org.nl.wms.system_manage.service.dict.ISysDictService; import org.nl.wms.system_manage.service.dict.dao.Dict; import org.springframework.beans.factory.annotation.Autowired; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/impl/MdPbVehicleMaterServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/impl/MdPbVehicleMaterServiceImpl.java deleted file mode 100644 index fb1629f7..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/impl/MdPbVehicleMaterServiceImpl.java +++ /dev/null @@ -1,29 +0,0 @@ -package org.nl.wms.base_manage.vehicle.vehicleMater.service.impl; - - -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.IMdPbVehicleMaterService; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.mapper.MdPbVehicleMaterMapper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; - -/** - *

- * 载具物料信息表 服务实现类 - *

- * - * @author generator - * @since 2024-04-08 - */ -@Service -public class MdPbVehicleMaterServiceImpl extends ServiceImpl implements IMdPbVehicleMaterService { - - @Autowired - private MdPbVehicleMaterMapper mdPbVehicleMaterMapper; - - @Override - public Integer getQtySumByMaterial(String material_id) { - return mdPbVehicleMaterMapper.getQtySumByMaterial(material_id); - } -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/applyTask/impl/ApplyFlowTask.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/applyTask/impl/ApplyFlowTask.java index 9b93591f..d5a1d1f5 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/applyTask/impl/ApplyFlowTask.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/applyTask/impl/ApplyFlowTask.java @@ -10,11 +10,8 @@ import org.nl.common.publish.BussEventMulticaster; import org.nl.common.utils.MapOf; import org.nl.wms.decision_manage.applyTask.AbstractApplyTask; import org.nl.wms.flow_manage.monitor.event.FlowStartEvent; -import org.nl.wms.md_manage.vehicleGroup.service.IMdPbVehicleMaterService; -import org.nl.wms.md_manage.vehicleGroup.service.dao.MdPbVehicleMater; -import org.nl.wms.md_manage.vehicleGroup.service.dto.MdPbVehicleMaterVo; -import org.nl.wms.md_manage.vehicleGroup.service.dto.MdVehicleGruopDtlVo; -import org.nl.wms.md_manage.vehicleGroup.service.dto.VehicleMaterQuery; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; +import org.nl.wms.md_manage.vehicleMater.service.dto.MdPbVehicleMaterVo; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; @@ -45,7 +42,7 @@ public class ApplyFlowTask extends AbstractApplyTask { if (StringUtils.isEmpty(point_code1)){ throw new BadRequestException("申请任务失败:请求参数数据异常"); } - MdPbVehicleMater mst = iMdPbVehicleMaterService.getGroupMst(vehicle_code); + org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater mst = iMdPbVehicleMaterService.getGroupMst(vehicle_code); if (mst == null){ throw new BadRequestException("申请任务失败:载具"+vehicle_code+"组盘信息不存在"); } @@ -57,7 +54,7 @@ public class ApplyFlowTask extends AbstractApplyTask { JSONObject groupJson = (JSONObject)JSONObject.toJSON(mst); BussEventMulticaster.Publish( new FlowStartEvent("md_group",null,new JSONObject(MapOf.of("point_code1",point_code1))) - .build("md_pb_vehicleMater",mst.getId(),mst.getMst_form_type(),mst.getMst_form_id(),(JSONObject) groupJson) + .build("md_pb_vehicleMater",mst.getId(),mst.getSource_form_type(),mst.getSource_form_id(),(JSONObject) groupJson) .build("md_pb_vehicleMater",item) ); } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/FIFORuleHandler.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/FIFORuleHandler.java index a2c756f8..706f6bca 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/FIFORuleHandler.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/FIFORuleHandler.java @@ -4,7 +4,8 @@ import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; import org.nl.common.domain.exception.BadRequestException; import org.nl.common.utils.MapOf; -import org.nl.wms.md_manage.vehicleGroup.service.IMdPbVehicleMaterService; + +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; import org.nl.wms.stor_manage.struct.service.IStIvtStructattrService; import org.nl.wms.stor_manage.struct.service.dao.StIvtStructattr; import org.nl.wms.decision_manage.handler.Decisioner; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/LimitStorageRuleHandler.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/LimitStorageRuleHandler.java index 6d2ef4db..69ec9034 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/LimitStorageRuleHandler.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/impl/base/LimitStorageRuleHandler.java @@ -3,8 +3,8 @@ package org.nl.wms.decision_manage.handler.impl.base; import com.alibaba.fastjson.JSONArray; import org.nl.common.domain.exception.BadRequestException; import org.nl.wms.stor_manage.struct.service.dao.StIvtStructattr; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.IBmVehicleInfoService; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.BmVehicleInfo; +import org.nl.wms.base_manage.vehicle.service.IBmVehicleInfoService; +import org.nl.wms.base_manage.vehicle.service.dao.BmVehicleInfo; import org.nl.wms.decision_manage.handler.Decisioner; import org.nl.wms.stor_manage.io.service.in.iostor_dtl.IStIvtIostorinvdtlService; import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.StIvtIostorinvdtl; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/StackingTaskHandler.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/StackingTaskHandler.java index 5622bcf0..c9f220a3 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/StackingTaskHandler.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/StackingTaskHandler.java @@ -10,10 +10,11 @@ import org.nl.common.enums.StatusEnum; import org.nl.common.utils.CodeUtil; import org.nl.common.utils.IdUtil; import org.nl.common.utils.SecurityUtils; -import org.nl.wms.md_manage.vehicleGroup.service.IMdPbVehicleMaterService; + import org.nl.wms.dispatch_manage.task.handler.TaskHandler; import org.nl.wms.dispatch_manage.task.service.ISchBaseTaskService; import org.nl.wms.dispatch_manage.task.service.dao.SchBaseTask; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/TaskStatusHandler.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/TaskStatusHandler.java index 69d34f27..5ac2d4b3 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/TaskStatusHandler.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/TaskStatusHandler.java @@ -6,12 +6,14 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import org.nl.common.enums.StatusEnum; import org.nl.common.publish.BussEventMulticaster; import org.nl.common.utils.SecurityUtils; -import org.nl.wms.md_manage.vehicleGroup.service.IMdPbVehicleMaterService; -import org.nl.wms.md_manage.vehicleGroup.service.dao.MdPbVehicleMater; + + import org.nl.wms.dispatch_manage.task.handler.StructEvent; import org.nl.wms.dispatch_manage.task.handler.TaskHandler; import org.nl.wms.dispatch_manage.task.service.ISchBaseTaskService; import org.nl.wms.dispatch_manage.task.service.dao.SchBaseTask; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/controller/early_deferral/AlmEarlyDeferralController.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/controller/early_deferral/AlmEarlyDeferralController.java new file mode 100644 index 00000000..802ab500 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/controller/early_deferral/AlmEarlyDeferralController.java @@ -0,0 +1,116 @@ +package org.nl.wms.early_manage.controller.early_deferral; + + +import cn.hutool.core.date.DateUtil; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; +import org.nl.common.TableDataInfo; +import org.nl.common.domain.entity.PageQuery; +import org.nl.common.utils.IdUtil; +import org.nl.common.utils.SecurityUtils; +import org.nl.wms.base_manage.material.service.IMdMeMaterialbaseService; +import org.nl.wms.base_manage.material.service.dao.MdMeMaterialbase; +import org.nl.wms.early_manage.service.early_deferral.IAlmEarlyDeferralDetailService; +import org.nl.wms.early_manage.service.early_deferral.IAlmEarlyDeferralService; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferral; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferralDetail; +import org.nl.wms.early_manage.service.early_deferral.dto.AlmDeferralQuery; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; + +import java.util.Arrays; +import java.util.List; + +/** + *

+ * 前端控制器 + *

+ * + * @author generator + * @since 2024-05-31 + */ +@RestController +@RequestMapping("/api/almEarlyDeferral") +public class AlmEarlyDeferralController { + + @Autowired + private IAlmEarlyDeferralService almEarlyDeferralService; + @Autowired + private IAlmEarlyDeferralDetailService almEarlyDeferralDetailService; + @Autowired + private IMdMeMaterialbaseService materialbaseService; + + @GetMapping + public ResponseEntity getAll(AlmDeferralQuery query, PageQuery page) { + return new ResponseEntity<>(TableDataInfo.build(almEarlyDeferralService.page(page.build(), query.build())), HttpStatus.OK); + } + + @GetMapping("/dtl/{id}") + public ResponseEntity getDtl(@PathVariable String id) { + List list = almEarlyDeferralDetailService.list(new LambdaQueryWrapper().eq(AlmEarlyDeferralDetail::getDeferral_id, id)); + JSONArray array = new JSONArray(); + for (AlmEarlyDeferralDetail detail : list) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("deferral_id", detail.getDeferral_id()); + jsonObject.put("material_id", detail.getMaterial_id()); + MdMeMaterialbase materialbase = materialbaseService.getById(detail.getMaterial_id()); + jsonObject.put("material_code", materialbase.getMaterial_code()); + jsonObject.put("material_name", materialbase.getMaterial_name()); + jsonObject.put("material_spec", materialbase.getMaterial_spec()); + jsonObject.put("material_model", materialbase.getMaterial_model()); + array.add(jsonObject); + } + return new ResponseEntity<>(array, HttpStatus.OK); + } + + @PostMapping("/saveDtl") + public ResponseEntity saveDtl(@Validated @RequestBody JSONObject dto) { + String id = dto.getString("id"); + LambdaUpdateWrapper luw = new LambdaUpdateWrapper<>(); + luw.eq(AlmEarlyDeferralDetail::getDetail_id, id); + almEarlyDeferralDetailService.remove(luw); + JSONArray jsonArray = dto.getJSONArray("tableData"); + for (int i = 0; i < jsonArray.size(); i++) { + JSONObject jsonObject = jsonArray.getJSONObject(i); + String material_id = jsonObject.getString("material_id"); + AlmEarlyDeferralDetail almEarlyDeferralDetail = new AlmEarlyDeferralDetail(); + almEarlyDeferralDetail.setDetail_id(IdUtil.getStringId()); + almEarlyDeferralDetail.setDeferral_id(id); + almEarlyDeferralDetail.setMaterial_id(material_id); + almEarlyDeferralDetailService.save(almEarlyDeferralDetail); + } + return new ResponseEntity<>(HttpStatus.CREATED); + } + + @DeleteMapping("/delete") + public ResponseEntity delete(@RequestBody String[] ids) { + if (ids.length > 0) { + almEarlyDeferralService.removeByIds(Arrays.asList(ids)); + } + return new ResponseEntity<>(HttpStatus.OK); + } + + @PostMapping + public ResponseEntity create(@Validated @RequestBody JSONObject dto) { + AlmEarlyDeferral almEarlyDeferral = dto.toJavaObject(AlmEarlyDeferral.class); + almEarlyDeferral.setCreate_name(SecurityUtils.getCurrentNickName()); + almEarlyDeferral.setId(IdUtil.getStringId()); + almEarlyDeferral.setCreate_time(DateUtil.now()); + almEarlyDeferralService.save(almEarlyDeferral); + return new ResponseEntity<>(HttpStatus.CREATED); + } + + @PostMapping("/update") + public ResponseEntity update(@Validated @RequestBody JSONObject dto) { + AlmEarlyDeferral almEarlyDeferral = dto.toJavaObject(AlmEarlyDeferral.class); + almEarlyDeferral.setCreate_time(DateUtil.now()); + almEarlyDeferralService.updateById(almEarlyDeferral); + return new ResponseEntity<>(HttpStatus.CREATED); + } +} + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/controller/early_deferral/AlmEarlyDeferralDetailController.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/controller/early_deferral/AlmEarlyDeferralDetailController.java new file mode 100644 index 00000000..84cf554c --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/controller/early_deferral/AlmEarlyDeferralDetailController.java @@ -0,0 +1,22 @@ +package org.nl.wms.early_manage.controller.early_deferral; + + + +import org.springframework.web.bind.annotation.RequestMapping; + +import org.springframework.web.bind.annotation.RestController; + +/** + *

+ * 前端控制器 + *

+ * + * @author generator + * @since 2024-05-31 + */ +@RestController +@RequestMapping("/api/almEarlyDeferralDetail") +public class AlmEarlyDeferralDetailController { + +} + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/EmailNotification.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/EmailNotification.java new file mode 100644 index 00000000..d2809656 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/EmailNotification.java @@ -0,0 +1,17 @@ +package org.nl.wms.early_manage.notification; + +/** + * @Description TODO + * @Author Gengby + * @Date 2024/5/31 + */ +public class EmailNotification extends Notification { + + public EmailNotification() { + } + + @Override + public void send(String message) { + System.out.println("发送邮件内容:" + message); + } +} \ No newline at end of file diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/Notification.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/Notification.java new file mode 100644 index 00000000..713c6792 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/Notification.java @@ -0,0 +1,11 @@ +package org.nl.wms.early_manage.notification; + +/** + * @Description TODO + * @Author Gengby + * @Date 2024/5/31 + */ +public abstract class Notification { + + public abstract void send(String message); +} \ No newline at end of file diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/NotificationFactory.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/NotificationFactory.java new file mode 100644 index 00000000..7797ae85 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/NotificationFactory.java @@ -0,0 +1,19 @@ +package org.nl.wms.early_manage.notification; + +/** + * @Description TODO + * @Author Gengby + * @Date 2024/5/31 + */ +public class NotificationFactory { + public static Notification getNotification(String noticeType) { + switch (noticeType) { + case "1": + return new EmailNotification(); + case "2": + return new WeChatNotification(); + default: + throw new IllegalArgumentException("未知的通知类型: " + noticeType); + } + } +} \ No newline at end of file diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/WeChatNotification.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/WeChatNotification.java new file mode 100644 index 00000000..2c144d87 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/notification/WeChatNotification.java @@ -0,0 +1,18 @@ +package org.nl.wms.early_manage.notification; + +/** + * @Description TODO + * @Author Gengby + * @Date 2024/5/31 + */ +public class WeChatNotification extends Notification { + + + public WeChatNotification() { + } + + @Override + public void send(String message) { + System.out.println("发送微信内容:" + message); + } +} \ No newline at end of file diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/IAlmEarlyDeferralDetailService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/IAlmEarlyDeferralDetailService.java new file mode 100644 index 00000000..e3d88092 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/IAlmEarlyDeferralDetailService.java @@ -0,0 +1,16 @@ +package org.nl.wms.early_manage.service.early_deferral; + +import com.baomidou.mybatisplus.extension.service.IService; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferralDetail; + +/** + *

+ * 服务类 + *

+ * + * @author generator + * @since 2024-05-31 + */ +public interface IAlmEarlyDeferralDetailService extends IService { + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/IAlmEarlyDeferralService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/IAlmEarlyDeferralService.java new file mode 100644 index 00000000..67b24070 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/IAlmEarlyDeferralService.java @@ -0,0 +1,17 @@ +package org.nl.wms.early_manage.service.early_deferral; + + +import com.baomidou.mybatisplus.extension.service.IService; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferral; + +/** + *

+ * 服务类 + *

+ * + * @author generator + * @since 2024-05-31 + */ +public interface IAlmEarlyDeferralService extends IService { + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/AlmEarlyDeferral.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/AlmEarlyDeferral.java new file mode 100644 index 00000000..39821b1d --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/AlmEarlyDeferral.java @@ -0,0 +1,44 @@ +package org.nl.wms.early_manage.service.early_deferral.dao; + +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serializable; + +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *

+ * + *

+ * + * @author generator + * @since 2024-05-31 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("alm_early_deferral") +public class AlmEarlyDeferral implements Serializable { + + private static final long serialVersionUID = 1L; + + private String id; + + private String alm_name; + + private String stor_code; + + private Integer stay_days; + + private String notice_type; + + private String ext_json; + + private Boolean is_used; + + private String remark; + + private String create_name; + + private String create_time; +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/AlmEarlyDeferralDetail.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/AlmEarlyDeferralDetail.java new file mode 100644 index 00000000..0ca2d594 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/AlmEarlyDeferralDetail.java @@ -0,0 +1,29 @@ +package org.nl.wms.early_manage.service.early_deferral.dao; + + +import com.baomidou.mybatisplus.annotation.TableName; +import java.io.Serializable; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *

+ * + *

+ * + * @author generator + * @since 2024-05-31 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("alm_early_deferral_detail") +public class AlmEarlyDeferralDetail implements Serializable { + + private static final long serialVersionUID = 1L; + + private String detail_id; + + private String deferral_id; + + private String material_id; +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/AlmEarlyDeferralDetailMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/AlmEarlyDeferralDetailMapper.java new file mode 100644 index 00000000..2e85b254 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/AlmEarlyDeferralDetailMapper.java @@ -0,0 +1,16 @@ +package org.nl.wms.early_manage.service.early_deferral.dao.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferralDetail; + +/** + *

+ * Mapper 接口 + *

+ * + * @author generator + * @since 2024-05-31 + */ +public interface AlmEarlyDeferralDetailMapper extends BaseMapper { + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/AlmEarlyDeferralMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/AlmEarlyDeferralMapper.java new file mode 100644 index 00000000..6421f8e0 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/AlmEarlyDeferralMapper.java @@ -0,0 +1,16 @@ +package org.nl.wms.early_manage.service.early_deferral.dao.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferral; + +/** + *

+ * Mapper 接口 + *

+ * + * @author generator + * @since 2024-05-31 + */ +public interface AlmEarlyDeferralMapper extends BaseMapper { + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/mapper/xml/StIvtIostorinvOutMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/xml/AlmEarlyDeferralDetailMapper.xml similarity index 58% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/mapper/xml/StIvtIostorinvOutMapper.xml rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/xml/AlmEarlyDeferralDetailMapper.xml index b7534aec..460d4603 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/mapper/xml/StIvtIostorinvOutMapper.xml +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/xml/AlmEarlyDeferralDetailMapper.xml @@ -1,5 +1,5 @@ - - - - - + + + + + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/mapper/xml/MdPbVehicleivtMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/xml/AlmEarlyDeferralMapper.xml similarity index 59% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/mapper/xml/MdPbVehicleivtMapper.xml rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/xml/AlmEarlyDeferralMapper.xml index 52494a18..cfa49e34 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/mapper/xml/MdPbVehicleivtMapper.xml +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dao/mapper/xml/AlmEarlyDeferralMapper.xml @@ -1,5 +1,5 @@ - - - - - + + + + + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dto/AlmDeferralQuery.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dto/AlmDeferralQuery.java new file mode 100644 index 00000000..3f58f078 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/dto/AlmDeferralQuery.java @@ -0,0 +1,26 @@ +package org.nl.wms.early_manage.service.early_deferral.dto; + +import lombok.Data; +import org.nl.common.domain.entity.BaseQuery; +import org.nl.common.domain.entity.QParam; +import org.nl.common.enums.QueryTEnum; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferral; + +/* + * @author ZZQ + * @Date 2023/5/4 19:49 + */ +@Data +public class AlmDeferralQuery extends BaseQuery { + + private String search; + private String stor_code; + + @Override + public void paramMapping() { + super.doP.put("search", QParam.builder().k(new String[]{"alm_name"}).type(QueryTEnum.LK).build()); + super.doP.put("stor_code", QParam.builder().k(new String[]{"stor_code"}).type(QueryTEnum.EQ).build()); + } + + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/impl/AlmEarlyDeferralDetailServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/impl/AlmEarlyDeferralDetailServiceImpl.java new file mode 100644 index 00000000..63cca67f --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/impl/AlmEarlyDeferralDetailServiceImpl.java @@ -0,0 +1,20 @@ +package org.nl.wms.early_manage.service.early_deferral.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.nl.wms.early_manage.service.early_deferral.IAlmEarlyDeferralDetailService; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferralDetail; +import org.nl.wms.early_manage.service.early_deferral.dao.mapper.AlmEarlyDeferralDetailMapper; +import org.springframework.stereotype.Service; + +/** + *

+ * 服务实现类 + *

+ * + * @author generator + * @since 2024-05-31 + */ +@Service +public class AlmEarlyDeferralDetailServiceImpl extends ServiceImpl implements IAlmEarlyDeferralDetailService { + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/impl/AlmEarlyDeferralServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/impl/AlmEarlyDeferralServiceImpl.java new file mode 100644 index 00000000..29dafedf --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/early_deferral/impl/AlmEarlyDeferralServiceImpl.java @@ -0,0 +1,21 @@ +package org.nl.wms.early_manage.service.early_deferral.impl; + + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.nl.wms.early_manage.service.early_deferral.IAlmEarlyDeferralService; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferral; +import org.nl.wms.early_manage.service.early_deferral.dao.mapper.AlmEarlyDeferralMapper; +import org.springframework.stereotype.Service; + +/** + *

+ * 服务实现类 + *

+ * + * @author generator + * @since 2024-05-31 + */ +@Service +public class AlmEarlyDeferralServiceImpl extends ServiceImpl implements IAlmEarlyDeferralService { + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/listen/EarlyEventListener.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/listen/EarlyEventListener.java index 82eb272b..feaaed2c 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/listen/EarlyEventListener.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/service/listen/EarlyEventListener.java @@ -5,7 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import lombok.extern.slf4j.Slf4j; import org.nl.common.publish.AbstraceListener; import org.nl.common.utils.IdUtil; -import org.nl.wms.md_manage.vehicleGroup.service.IMdPbVehicleMaterService; + import org.nl.wms.early_manage.service.early_dtl.IAlmEarlyDtlService; import org.nl.wms.early_manage.service.early_dtl.dao.AlmEarlyDtl; import org.nl.wms.early_manage.service.early_inv.IAlmEarlyInvService; @@ -13,6 +13,7 @@ import org.nl.wms.early_manage.service.early_inv.dao.AlmEarlyInv; import org.nl.wms.early_manage.service.early_msg.IAlmEarlyMsgService; import org.nl.wms.early_manage.service.early_msg.dao.AlmEarlyMsg; import org.nl.wms.early_manage.service.event.EarlyEvent; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/tasks/AutoDeferralNotice.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/tasks/AutoDeferralNotice.java new file mode 100644 index 00000000..47a519a3 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/early_manage/tasks/AutoDeferralNotice.java @@ -0,0 +1,74 @@ +package org.nl.wms.early_manage.tasks; + +import cn.hutool.core.date.DateUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import org.nl.common.utils.IdUtil; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.early_manage.notification.NotificationFactory; +import org.nl.wms.early_manage.service.early_deferral.IAlmEarlyDeferralDetailService; +import org.nl.wms.early_manage.service.early_deferral.IAlmEarlyDeferralService; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferral; +import org.nl.wms.early_manage.service.early_deferral.dao.AlmEarlyDeferralDetail; +import org.nl.wms.early_manage.service.early_msg.IAlmEarlyMsgService; +import org.nl.wms.early_manage.service.early_msg.dao.AlmEarlyMsg; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.List; +import java.util.stream.Collectors; + +/** + * @Description TODO + * @Author Gengby + * @Date 2024/5/31 + */ +@Component +public class AutoDeferralNotice { + + @Autowired + private IAlmEarlyDeferralService almEarlyDeferralService; + @Autowired + private IAlmEarlyDeferralDetailService almEarlyDeferralDetailService; + @Autowired + private IMdPbVehicleMaterService mdPbVehicleMaterService; + @Autowired + private IAlmEarlyMsgService almEarlyMsgService; + + public void run() { + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(AlmEarlyDeferral::getIs_used, "1"); + List list = almEarlyDeferralService.list(lambdaQueryWrapper); + for (AlmEarlyDeferral almEarlyDeferral : list) { + LambdaQueryWrapper lqw = new LambdaQueryWrapper<>(); + lqw.eq(AlmEarlyDeferralDetail::getDeferral_id, almEarlyDeferral.getId()); + List deferralDetails = almEarlyDeferralDetailService.list(lqw); + List materialIds = deferralDetails.stream() + .map(detail -> detail.getMaterial_id()) + .collect(Collectors.toList()); + LambdaQueryWrapper mdPbVehicleMaterLambdaQueryWrapper = new LambdaQueryWrapper<>(); + mdPbVehicleMaterLambdaQueryWrapper.in(MdPbVehicleMater::getMaterial_id, materialIds); + List mdPbVehicleMaters = mdPbVehicleMaterService.list(mdPbVehicleMaterLambdaQueryWrapper); + List filteredMdPbVehicleMaters = mdPbVehicleMaters.stream() + .filter(mater -> { + long daysBetween = DateUtil.betweenDay(DateUtil.parse(mater.getUpdate_time()), DateUtil.parse(DateUtil.now()), true); + return daysBetween > almEarlyDeferral.getStay_days(); + }) + .collect(Collectors.toList()); + for (MdPbVehicleMater filteredMdPbVehicleMater : filteredMdPbVehicleMaters) { + AlmEarlyMsg almEarlyMsg = new AlmEarlyMsg(); + almEarlyMsg.setId(IdUtil.getStringId()); + almEarlyMsg.setEarly_type("2"); + almEarlyMsg.setStor_code(almEarlyDeferral.getStor_code()); + almEarlyMsg.setMaterial_id(filteredMdPbVehicleMater.getMaterial_id()); + almEarlyMsg.setCreate_time(DateUtil.now()); + almEarlyMsg.setQty(filteredMdPbVehicleMater.getQty().intValue()); + almEarlyMsg.setCreate_time(DateUtil.now()); + almEarlyMsg.setVehicle_code(filteredMdPbVehicleMater.getVehicle_code()); + almEarlyMsg.setPcsn(filteredMdPbVehicleMater.getPcsn()); + almEarlyMsgService.save(almEarlyMsg); + NotificationFactory.getNotification(almEarlyDeferral.getNotice_type()).send(""); + } + } + } +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/ActHiExecutionMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/ActHiExecutionMapper.java index 98f0b621..b31a8555 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/ActHiExecutionMapper.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/ActHiExecutionMapper.java @@ -3,6 +3,9 @@ package org.nl.wms.flow_manage.flow.service.history.dao.mapper; import org.nl.wms.flow_manage.flow.service.history.dao.ActHiExecution; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import java.util.List; +import java.util.Map; + /** *

* 流程历史处理表 Mapper 接口 @@ -12,5 +15,11 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; * @since 2024-04-28 */ public interface ActHiExecutionMapper extends BaseMapper { - + /** + * 根据数据表名获取所需字段名称 + * + * @param tableName + * @return + */ + List> getTableColumnNames(String tableName); } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/xml/ActHiExecutionMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/xml/ActHiExecutionMapper.xml index d849a1b2..905e18cf 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/xml/ActHiExecutionMapper.xml +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/history/dao/mapper/xml/ActHiExecutionMapper.xml @@ -1,5 +1,14 @@ - + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/controller/MdGruopDickController.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/controller/MdGruopDickController.java index f93e4838..d23b0e65 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/controller/MdGruopDickController.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/controller/MdGruopDickController.java @@ -4,19 +4,15 @@ package org.nl.wms.md_manage.group_dick.controller; import cn.dev33.satoken.annotation.SaIgnore; import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import org.nl.common.TableDataInfo; import org.nl.common.anno.Log; import org.nl.common.domain.entity.PageQuery; import org.nl.common.utils.RedissonUtils; import org.nl.common.utils.SecurityUtils; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; import org.nl.wms.md_manage.group_dick.service.IMdGruopDickService; import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDick; import org.nl.wms.md_manage.group_dick.service.dto.GroupDickQuery; -import org.nl.wms.md_manage.group_dick.service.dto.MdGruopDtlDto; import org.nl.wms.pm_manage.form_data.service.IPmFormDataService; -import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; @@ -25,10 +21,7 @@ import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import java.util.ArrayList; import java.util.Arrays; -import java.util.List; -import java.util.Map; /** *

diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/IMdGruopDtlService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/IMdGruopDtlService.java deleted file mode 100644 index 6226ab47..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/IMdGruopDtlService.java +++ /dev/null @@ -1,24 +0,0 @@ -package org.nl.wms.md_manage.group_dick.service; - -import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.extension.service.IService; -import org.nl.common.domain.entity.PageQuery; -import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDick; -import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDtl; -import org.nl.wms.md_manage.group_dick.service.dto.GroupDickQuery; -import org.springframework.web.multipart.MultipartFile; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; - -/** - *

- * 载具物料组盘表 服务类 - *

- * - * @author generator - * @since 2024-04-24 - */ -public interface IMdGruopDtlService extends IService { - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/MdGruopDick.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/MdGruopDick.java index 2727b28b..77a30d09 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/MdGruopDick.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/MdGruopDick.java @@ -37,11 +37,6 @@ public class MdGruopDick implements Serializable { */ private String code; - /** - * 父载具 - */ - private String parent_vehicle_code; - /** * 组盘状态 */ @@ -84,10 +79,6 @@ public class MdGruopDick implements Serializable { @TableField(typeHandler = FastjsonTypeHandler.class) private JSONObject form_data; - /** - * 流程实例id - */ - private String proc_inst_id; } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/MdGruopDtl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/MdGruopDtl.java deleted file mode 100644 index a4b363f3..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/MdGruopDtl.java +++ /dev/null @@ -1,74 +0,0 @@ -package org.nl.wms.md_manage.group_dick.service.dao; - -import com.baomidou.mybatisplus.annotation.TableId; -import com.baomidou.mybatisplus.annotation.TableName; -import lombok.Data; -import lombok.EqualsAndHashCode; - -import java.io.Serializable; - -/** - *

- * 载具物料组盘表 - *

- * - * @author generator - * @since 2024-04-24 - */ -@Data -@EqualsAndHashCode(callSuper = false) -@TableName(value = "md_group_dtl") -public class MdGruopDtl implements Serializable { - - /** - * 主键 - */ - @TableId - private String id; - /** - * 主表id - */ - private String dick_id; - - /** - * 载具 - */ - private String vehicle_code; - /** - * 仓位 - */ - private String struct_code; - /** - /** - * 仓库 - */ - private String stor_code; - /** - * 载具 - */ - private String remark; - - /** - * 组盘状态 - */ - private String status; - - /** - * 源单 - */ - private String source_form_type; - /** - * 源单id - */ - private String source_form_id; - - /** - * 修改时间 - */ - private String update_time; - /** - * 修改人 - */ - private String update_name; - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/mapper/MdGruopDtlMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/mapper/MdGruopDtlMapper.java deleted file mode 100644 index 369bd58f..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/mapper/MdGruopDtlMapper.java +++ /dev/null @@ -1,21 +0,0 @@ -package org.nl.wms.md_manage.group_dick.service.dao.mapper; - -import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import org.apache.ibatis.annotations.Param; -import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDick; -import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDtl; -import org.nl.wms.md_manage.group_dick.service.dto.GroupDickQuery; - -import java.util.List; - -/** - *

- * 载具物料组盘表 Mapper 接口 - *

- * - * @author generator - * @since 2024-04-24 - */ -public interface MdGruopDtlMapper extends BaseMapper { - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/mapper/xml/MdGroupMstMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/mapper/xml/MdGroupMstMapper.xml deleted file mode 100644 index 64d91e36..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dao/mapper/xml/MdGroupMstMapper.xml +++ /dev/null @@ -1,5 +0,0 @@ - - - - - diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlDto.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlDto.java index 5493b894..818101b0 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlDto.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlDto.java @@ -1,13 +1,7 @@ package org.nl.wms.md_manage.group_dick.service.dto; -import com.baomidou.mybatisplus.annotation.TableId; -import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; -import lombok.EqualsAndHashCode; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; -import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDtl; - -import java.io.Serializable; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; /** *

diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlVo.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlVo.java index 6738203d..83da78fb 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlVo.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/dto/MdGruopDtlVo.java @@ -1,7 +1,6 @@ package org.nl.wms.md_manage.group_dick.service.dto; import lombok.Data; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; /** *

diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/impl/MdGruopDickServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/impl/MdGruopDickServiceImpl.java index f986f250..c79a4932 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/impl/MdGruopDickServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/impl/MdGruopDickServiceImpl.java @@ -9,15 +9,13 @@ import org.apache.commons.lang3.StringUtils; import org.nl.common.TableDataInfo; import org.nl.common.domain.entity.PageQuery; import org.nl.common.enums.StatusEnum; -import org.nl.common.publish.BussEventMulticaster; import org.nl.common.utils.CodeUtil; import org.nl.common.utils.IdUtil; import org.nl.common.utils.MapOf; import org.nl.common.utils.SecurityUtils; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.IMdPbVehicleMaterService; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; -import org.nl.wms.flow_manage.monitor.event.FlowStartEvent; -import org.nl.wms.md_manage.group_dick.service.IMdGruopDtlService; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; + import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDick; import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDtl; import org.nl.wms.md_manage.group_dick.service.dao.mapper.MdGruopDickMapper; @@ -26,7 +24,6 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.nl.wms.md_manage.group_dick.service.dto.GroupDickQuery; import org.nl.wms.md_manage.group_dick.service.dto.MdGruopDtlVo; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; @@ -50,11 +47,7 @@ import java.util.function.Consumer; @Service public class MdGruopDickServiceImpl extends ServiceImpl implements IMdGruopDickService { - @Autowired - @Lazy - private IMdGruopDickService self; - @Autowired - private IMdGruopDtlService iMdGruopDtlService; + @Autowired private IMdPbVehicleMaterService iMdPbVehicleMaterService; @@ -104,15 +97,7 @@ public class MdGruopDickServiceImpl extends ServiceImpl) proc_inst_id -> { - self.update(new UpdateWrapper() - .set("proc_inst_id",proc_inst_id).eq("id",mdGroupMst.getId())); }) - .build("md_group_dick",mdGroupMst.getId(),mdGroupMst.getSource_form_type(),mdGroupMst.getSource_form_id(),forms) - .build("md_group_dtl",dtlJson) - ,false); } @Override diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/impl/MdGruopDtlServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/impl/MdGruopDtlServiceImpl.java deleted file mode 100644 index f466af58..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/group_dick/service/impl/MdGruopDtlServiceImpl.java +++ /dev/null @@ -1,21 +0,0 @@ -package org.nl.wms.md_manage.group_dick.service.impl; - - -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import org.nl.wms.md_manage.group_dick.service.IMdGruopDtlService; -import org.nl.wms.md_manage.group_dick.service.dao.MdGruopDtl; -import org.nl.wms.md_manage.group_dick.service.dao.mapper.MdGruopDtlMapper; -import org.springframework.stereotype.Service; - -/** - *

- * 载具物料组盘表 服务实现类 - *

- * - * @author generator - * @since 2024-04-24 - */ -@Service -public class MdGruopDtlServiceImpl extends ServiceImpl implements IMdGruopDtlService { - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/controller/MdPbVehicleMaterController.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/controller/MdPbVehicleMaterController.java similarity index 85% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/controller/MdPbVehicleMaterController.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/controller/MdPbVehicleMaterController.java index 6c25bac1..b43c4525 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/controller/MdPbVehicleMaterController.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/controller/MdPbVehicleMaterController.java @@ -1,4 +1,4 @@ -package org.nl.wms.base_manage.vehicle.vehicleMater.controller; +package org.nl.wms.md_manage.vehicleMater.controller; import cn.dev33.satoken.annotation.SaIgnore; @@ -7,9 +7,9 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import org.nl.common.TableDataInfo; import org.nl.common.anno.Log; import org.nl.common.domain.entity.PageQuery; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.IMdPbVehicleMaterService; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dto.VehicleMaterQuery; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.md_manage.vehicleMater.service.dto.VehicleMaterQuery; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/IMdPbVehicleMaterService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/IMdPbVehicleMaterService.java similarity index 51% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/IMdPbVehicleMaterService.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/IMdPbVehicleMaterService.java index 74cf0cbf..c5259e49 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/IMdPbVehicleMaterService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/IMdPbVehicleMaterService.java @@ -1,7 +1,8 @@ -package org.nl.wms.base_manage.vehicle.vehicleMater.service; +package org.nl.wms.md_manage.vehicleMater.service; import com.baomidou.mybatisplus.extension.service.IService; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.md_manage.vehicleMater.service.dto.MdPbVehicleMaterVo; import java.util.List; import java.util.Map; @@ -17,5 +18,9 @@ import java.util.Map; public interface IMdPbVehicleMaterService extends IService { Integer getQtySumByMaterial(String material_id); + MdPbVehicleMater getGroupMst(String vehicle_code); + + List getVehicleMaters(String vehicle_code); + } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/MdPbVehicleMater.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/MdPbVehicleMater.java similarity index 87% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/MdPbVehicleMater.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/MdPbVehicleMater.java index 9947ca97..b15cf22d 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/MdPbVehicleMater.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/MdPbVehicleMater.java @@ -1,4 +1,4 @@ -package org.nl.wms.base_manage.vehicle.vehicleMater.service.dao; +package org.nl.wms.md_manage.vehicleMater.service.dao; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.annotation.TableField; @@ -37,11 +37,6 @@ public class MdPbVehicleMater implements Serializable { */ private String material_id; - /** - * 工序id - */ - private String workprocedure_id; - /** * 批次 */ @@ -90,15 +85,23 @@ public class MdPbVehicleMater implements Serializable { * 修改时间 */ private String update_time; + /** + * 修改时间 + */ + private String update_name; + /** + * 修改时间 + */ + private String create_time; + /** + * 修改时间 + */ + private String create_name; /** * 备注 */ private String remark; - /** - * 关联实例id - */ - private String proc_inst_id; } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/mapper/MdPbVehicleMaterMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/mapper/MdPbVehicleMaterMapper.java similarity index 59% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/mapper/MdPbVehicleMaterMapper.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/mapper/MdPbVehicleMaterMapper.java index 305cc678..7e9414ca 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dao/mapper/MdPbVehicleMaterMapper.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/mapper/MdPbVehicleMaterMapper.java @@ -1,8 +1,11 @@ -package org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.mapper; +package org.nl.wms.md_manage.vehicleMater.service.dao.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Select; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.md_manage.vehicleMater.service.dto.MdPbVehicleMaterVo; + +import java.util.List; /** *

@@ -16,4 +19,6 @@ public interface MdPbVehicleMaterMapper extends BaseMapper { @Select("SELECT SUM(qty) FROM md_pb_vehicleMater WHERE material_id = #{materialId}") Integer getQtySumByMaterial(String material_id); + + List getVehicleMaters(String vehicle_code); } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/mapper/xml/MdPbVehicleivtMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/mapper/xml/MdPbVehicleivtMapper.xml new file mode 100644 index 00000000..5ec127af --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dao/mapper/xml/MdPbVehicleivtMapper.xml @@ -0,0 +1,27 @@ + + + + + + + + + + + + + + + + + + + + + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dto/MdPbVehicleMaterVo.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dto/MdPbVehicleMaterVo.java new file mode 100644 index 00000000..e77a2ab9 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dto/MdPbVehicleMaterVo.java @@ -0,0 +1,27 @@ +package org.nl.wms.md_manage.vehicleMater.service.dto; + +import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler; +import lombok.Data; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; + +import java.math.BigDecimal; + +/** + *

+ * 载具物料信息表 + *

+ * + * @author generator + * @since 2024-04-08 + */ +@Data +public class MdPbVehicleMaterVo extends MdPbVehicleMater { + + private String material_code; + private String material_name; + private String material_spec; + + +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dto/VehicleMaterQuery.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dto/VehicleMaterQuery.java similarity index 76% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dto/VehicleMaterQuery.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dto/VehicleMaterQuery.java index 76972b8b..fb6ec5a4 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/base_manage/vehicle/vehicleMater/service/dto/VehicleMaterQuery.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/dto/VehicleMaterQuery.java @@ -1,11 +1,11 @@ -package org.nl.wms.base_manage.vehicle.vehicleMater.service.dto; +package org.nl.wms.md_manage.vehicleMater.service.dto; import lombok.Data; import org.nl.common.domain.entity.BaseQuery; import org.nl.common.domain.entity.QParam; import org.nl.common.enums.QueryTEnum; -import org.nl.wms.base_manage.vehicle.vehicleInfo.service.dao.BmVehicleInfo; -import org.nl.wms.base_manage.vehicle.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; + /* * @author ZZQ diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/impl/MdPbVehicleMaterServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/impl/MdPbVehicleMaterServiceImpl.java new file mode 100644 index 00000000..4bf65234 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/md_manage/vehicleMater/service/impl/MdPbVehicleMaterServiceImpl.java @@ -0,0 +1,41 @@ +package org.nl.wms.md_manage.vehicleMater.service.impl; + + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; +import org.nl.wms.md_manage.vehicleMater.service.dao.mapper.MdPbVehicleMaterMapper; +import org.nl.wms.md_manage.vehicleMater.service.dto.MdPbVehicleMaterVo; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + *

+ * 载具物料信息表 服务实现类 + *

+ * + * @author generator + * @since 2024-04-08 + */ +@Service +public class MdPbVehicleMaterServiceImpl extends ServiceImpl implements IMdPbVehicleMaterService { + + + @Override + public Integer getQtySumByMaterial(String material_id) { + return this.baseMapper.getQtySumByMaterial(material_id); + } + + @Override + public MdPbVehicleMater getGroupMst(String vehicle_code) { + return this.getOne(new QueryWrapper().eq("vehicle_code",vehicle_code)); + } + + @Override + public List getVehicleMaters(String vehicle_code) { + return this.baseMapper.getVehicleMaters(vehicle_code); + } +} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/IPmFormDataService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/IPmFormDataService.java index c9717635..cd04ac9a 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/IPmFormDataService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/IPmFormDataService.java @@ -1,7 +1,10 @@ package org.nl.wms.pm_manage.form_data.service; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; import com.github.pagehelper.Page; import org.nl.common.domain.entity.PageQuery; +import org.nl.wms.config_manage.form_struc.service.dao.BmFormStruc; import org.nl.wms.pm_manage.form_data.service.dao.PmFormData; import com.baomidou.mybatisplus.extension.service.IService; import org.nl.wms.pm_manage.form_data.service.dto.FormDataQuery; @@ -22,7 +25,7 @@ public interface IPmFormDataService extends IService { Integer syncFormData(String type,String dataString); - List syncAnalyse(SyncFormMapping mapping, String dataString); + JSONObject mappingParse(JSONArray mappingJson, BmFormStruc one, JSONObject sourceData); List getByType(String from_type); @@ -30,6 +33,7 @@ public interface IPmFormDataService extends IService { List queryTree(FormDataQuery query, PageQuery page); + List syncAnalyse(SyncFormMapping formMapping, String sourceString); Object getSonDtlFormData(String id); diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/impl/PmFormDataServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/impl/PmFormDataServiceImpl.java index a26fda8b..76bad973 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/impl/PmFormDataServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/pm_manage/form_data/service/impl/PmFormDataServiceImpl.java @@ -1,6 +1,7 @@ package org.nl.wms.pm_manage.form_data.service.impl; import cn.hutool.core.date.DateUtil; +import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -71,7 +72,6 @@ public class PmFormDataServiceImpl extends ServiceImpl syncAnalyse(SyncFormMapping formMapping, String sourceString) { BmFormStruc one = formStrucService.getOne(new QueryWrapper().eq("form_type", formMapping.getForm_type())); @@ -151,9 +151,8 @@ public class PmFormDataServiceImpl extends ServiceImpl fields, Map fieldMapping, JSONObject sourceData) { + public JSONObject fieldMapping(Set fields, Map fieldMapping, JSONObject sourceData) { Map SpelMap = new HashMap<>(); JSONObject data = new JSONObject(); for (String field : fields) { @@ -210,7 +209,6 @@ public class PmFormDataServiceImpl extends ServiceImpl getByType(String from_type) { Assert.notNull(from_type,"表单类型参数不能为空"); diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/controller/in/StIvtIostorinvInController.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/controller/in/StIvtIostorinvInController.java deleted file mode 100644 index 62f7b373..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/controller/in/StIvtIostorinvInController.java +++ /dev/null @@ -1,59 +0,0 @@ -package org.nl.wms.stor_manage.io.controller.in; - - -import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import org.nl.common.TableDataInfo; -import org.nl.common.domain.entity.PageQuery; -import org.nl.wms.dispatch_manage.task.service.ISchBaseTaskService; -import org.nl.wms.stor_manage.io.service.dto.StorInvQuery; -import org.nl.wms.stor_manage.io.service.in.iostor.IStIvtIostorinvInService; -import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.IStIvtIostorinvdtlService; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.http.HttpStatus; -import org.springframework.http.ResponseEntity; -import org.springframework.web.bind.annotation.*; - -import java.util.List; -import java.util.Map; - -/** - *

- * 出入库单主表 前端控制器 - *

- * - * @author generator - * @since 2024-03-28 - */ -@RestController -@RequestMapping("api/stIvtIostorinvIn") -public class StIvtIostorinvInController { - - @Autowired - IStIvtIostorinvInService iStIvtIostorinvInService; - @Autowired - IStIvtIostorinvdtlService iStIvtIostorinvDtlInService; - @Autowired - ISchBaseTaskService schBaseTaskService; - - - @GetMapping - public ResponseEntity getAll(StorInvQuery query, PageQuery page) { - Page result = iStIvtIostorinvInService.page(page.build(), query.build()); - return new ResponseEntity<>(TableDataInfo.build(result), HttpStatus.OK); - } - @PostMapping - public ResponseEntity save(@RequestBody JSONObject form) { - iStIvtIostorinvInService.save(form); - return new ResponseEntity<>(HttpStatus.OK); - } - - @PostMapping("getIosInvDtl") - public ResponseEntity getDtl(@RequestBody String inv_id) { - List mapList = iStIvtIostorinvDtlInService.getByInv(inv_id); - return new ResponseEntity<>(mapList,HttpStatus.OK); - } - -} - diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/dto/StorInvOutQuery.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/dto/StorInvOutQuery.java deleted file mode 100644 index e5a7ebb0..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/dto/StorInvOutQuery.java +++ /dev/null @@ -1,20 +0,0 @@ -package org.nl.wms.stor_manage.io.service.dto; - -import lombok.Data; -import org.nl.common.domain.entity.BaseQuery; -import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; -import org.nl.wms.stor_manage.io.service.out.iostor.dao.StIvtIostorinvOut; - -/* - * @author ZZQ - * @Date 2023/5/4 19:49 - */ -@Data -public class StorInvOutQuery extends BaseQuery{ - private String form_type; - private String code; - private String status; - private String bill_type; - private String product_code; - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/dto/StorInvQuery.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/dto/StorInvQuery.java index 3178be04..785e2dfc 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/dto/StorInvQuery.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/dto/StorInvQuery.java @@ -2,14 +2,14 @@ package org.nl.wms.stor_manage.io.service.dto; import lombok.Data; import org.nl.common.domain.entity.BaseQuery; -import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; +import org.nl.wms.stor_manage.io.service.iostor.dao.StIvtIostorinv; /* * @author ZZQ * @Date 2023/5/4 19:49 */ @Data -public class StorInvQuery extends BaseQuery{ +public class StorInvQuery extends BaseQuery{ private String form_type; private String code; private String status; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/IStIvtIostorinvInService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/IStIvtIostorinvInService.java deleted file mode 100644 index ea25fe9a..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/IStIvtIostorinvInService.java +++ /dev/null @@ -1,19 +0,0 @@ -package org.nl.wms.stor_manage.io.service.in.iostor; - -import com.alibaba.fastjson.JSONObject; -import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; -import com.baomidou.mybatisplus.extension.service.IService; - -/** - *

- * 出入库单主表 服务类 - *

- * - * @author generator - * @since 2024-03-28 - */ -public interface IStIvtIostorinvInService extends IService { - - void save(JSONObject form); - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/StIvtIostorinvIn.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/StIvtIostorinvIn.java deleted file mode 100644 index 7db83ac6..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/StIvtIostorinvIn.java +++ /dev/null @@ -1,97 +0,0 @@ -package org.nl.wms.stor_manage.io.service.in.iostor.dao; - -import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableName; -import java.io.Serializable; - -import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler; -import lombok.Data; -import lombok.EqualsAndHashCode; - -/** - *

- * 出入库单主表 - *

- * - * @author generator - * @since 2024-03-28 - */ -@Data -@EqualsAndHashCode(callSuper = false) -@TableName(value = "st_ivt_iostorinv_in",autoResultMap = true) -public class StIvtIostorinvIn implements Serializable { - - private static final long serialVersionUID = 1L; - - /** - * 出入单标识 - */ - private String id; - - /** - * 单据编号 - */ - private String code; - /** - * 业务类型 - */ - private String bill_type; - - /** - * 生产区域编码 - */ - private String product_area; - - /** - * 单据状态 - */ - private String status; - /** - * 源单业务日期 - */ - private String source_form_date; - /** - * 源单号 - */ - private String source_form_id; - - /** - * 源单单据类型 - */ - private String source_form_type; - - - /** - * 备注 - */ - private String remark; - - /** - * 制单人 - */ - private String create_name; - - /** - * 制单时间 - */ - private String create_time; - - /** - * 修改人 - */ - private String update_name; - - /** - * 修改时间 - */ - private String update_time; - - /** - * 自定义映射数据 - */ - @TableField(typeHandler = FastjsonTypeHandler.class) - private JSONObject form_data; - - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/mapper/StIvtIostorinvMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/mapper/StIvtIostorinvMapper.java deleted file mode 100644 index db36106a..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/mapper/StIvtIostorinvMapper.java +++ /dev/null @@ -1,16 +0,0 @@ -package org.nl.wms.stor_manage.io.service.in.iostor.dao.mapper; - -import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; -import com.baomidou.mybatisplus.core.mapper.BaseMapper; - -/** - *

- * 出入库单主表 Mapper 接口 - *

- * - * @author generator - * @since 2024-03-28 - */ -public interface StIvtIostorinvMapper extends BaseMapper { - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/impl/StIvtIostorinvInServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/impl/StIvtIostorinvInServiceImpl.java deleted file mode 100644 index db86a1e9..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/impl/StIvtIostorinvInServiceImpl.java +++ /dev/null @@ -1,61 +0,0 @@ -package org.nl.wms.stor_manage.io.service.in.iostor.impl; - -import cn.hutool.core.date.DateUtil; -import com.alibaba.fastjson.JSONObject; -import org.nl.common.enums.StatusEnum; -import org.nl.common.utils.CodeUtil; -import org.nl.common.utils.IdUtil; -import org.nl.common.utils.SecurityUtils; -import org.nl.wms.stor_manage.io.service.in.iostor.IStIvtIostorinvInService; -import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; -import org.nl.wms.stor_manage.io.service.in.iostor.dao.mapper.StIvtIostorinvMapper; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.IStIvtIostorinvdtlService; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.StIvtIostorinvdtl; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; - -import java.util.List; -import java.util.Map; - -/** - *

- * 出入库单主表 服务实现类 - *

- * - * @author generator - * @since 2024-03-28 - */ -@Service -public class StIvtIostorinvInServiceImpl extends ServiceImpl implements IStIvtIostorinvInService { - - @Autowired - private IStIvtIostorinvdtlService iStIvtIostorinvdtlInService; - - @Override - @Transactional - public void save(JSONObject form) { - if (form==null){ - return; - } - List dtls = (List) form.remove("tableData"); - StIvtIostorinvIn mst = form.toJavaObject(StIvtIostorinvIn.class); - mst.setId(IdUtil.getStringId()); - mst.setCreate_name(SecurityUtils.getCurrentNickName()); - mst.setCreate_time(DateUtil.now()); - mst.setCode(CodeUtil.getNewCode("IO_CODE")); - mst.setStatus(StatusEnum.FORM_STATUS.code("生成")); - if (dtls!=null && dtls.size()>0){ - for (int i = 0; i < dtls.size(); i++) { - StIvtIostorinvdtl dtl = new JSONObject(dtls.get(i)).toJavaObject(StIvtIostorinvdtl.class); - dtl.setId(IdUtil.getStringId()); - dtl.setInv_id(mst.getId()); - dtl.setStatus(StatusEnum.FORM_STATUS.code("生成")); - iStIvtIostorinvdtlInService.save(dtl); - } - } - this.save(mst); - } - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlMapper.xml deleted file mode 100644 index ad3de0f4..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlMapper.xml +++ /dev/null @@ -1,23 +0,0 @@ - - - - - - insert into st_ivt_iostorinvdtl() values - - - - diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/impl/StIvtIostorinvdtlServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/impl/StIvtIostorinvdtlServiceImpl.java deleted file mode 100644 index 01cd6423..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/impl/StIvtIostorinvdtlServiceImpl.java +++ /dev/null @@ -1,39 +0,0 @@ -package org.nl.wms.stor_manage.io.service.in.iostor_dtl.impl; - -import org.apache.commons.lang3.StringUtils; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.IStIvtIostorinvdtlService; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.StIvtIostorinvdtl; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.mapper.StIvtIostorinvdtlMapper; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import org.springframework.stereotype.Service; - -import java.util.ArrayList; -import java.util.List; -import java.util.Map; - -/** - *

- * 出入库单明细表 服务实现类 - *

- * - * @author generator - * @since 2024-03-29 - */ -@Service -public class StIvtIostorinvdtlServiceImpl extends ServiceImpl implements IStIvtIostorinvdtlService { - - - @Override - public void batchInsert(List dtls) { - this.baseMapper.batchInsert(dtls); - } - - - @Override - public List getByInv(String inv_id) { - if (StringUtils.isEmpty(inv_id)){ - return new ArrayList<>(); - } - return this.baseMapper.findByInv(inv_id); - } -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/IStIvtIostorinvOutService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/IStIvtIostorinvService.java similarity index 55% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/IStIvtIostorinvOutService.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/IStIvtIostorinvService.java index 6cd305d1..c47fb873 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/IStIvtIostorinvOutService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/IStIvtIostorinvService.java @@ -1,9 +1,8 @@ -package org.nl.wms.stor_manage.io.service.out.iostor; +package org.nl.wms.stor_manage.io.service.iostor; import com.alibaba.fastjson.JSONObject; -import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; import com.baomidou.mybatisplus.extension.service.IService; -import org.nl.wms.stor_manage.io.service.out.iostor.dao.StIvtIostorinvOut; +import org.nl.wms.stor_manage.io.service.iostor.dao.StIvtIostorinv; /** *

@@ -13,7 +12,7 @@ import org.nl.wms.stor_manage.io.service.out.iostor.dao.StIvtIostorinvOut; * @author generator * @since 2024-03-28 */ -public interface IStIvtIostorinvOutService extends IService { +public interface IStIvtIostorinvService extends IService { void save(JSONObject form); diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/StIvtIostorinvOut.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/StIvtIostorinv.java similarity index 86% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/StIvtIostorinvOut.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/StIvtIostorinv.java index 6b623e36..4d03570c 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/StIvtIostorinvOut.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/StIvtIostorinv.java @@ -1,4 +1,4 @@ -package org.nl.wms.stor_manage.io.service.out.iostor.dao; +package org.nl.wms.stor_manage.io.service.iostor.dao; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.annotation.TableField; @@ -19,8 +19,8 @@ import lombok.EqualsAndHashCode; */ @Data @EqualsAndHashCode(callSuper = false) -@TableName(value = "st_ivt_iostorinv_out", autoResultMap = true) -public class StIvtIostorinvOut implements Serializable { +@TableName(value = "st_ivt_iostorinv", autoResultMap = true) +public class StIvtIostorinv implements Serializable { private static final long serialVersionUID = 1L; @@ -97,5 +97,10 @@ public class StIvtIostorinvOut implements Serializable { @TableField(typeHandler = FastjsonTypeHandler.class) private JSONObject form_data; + /** + * 是否为入库单 + */ + private Boolean in_storage; + } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/mapper/StIvtIostorinvOutMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/mapper/StIvtIostorinvOutMapper.java similarity index 65% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/mapper/StIvtIostorinvOutMapper.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/mapper/StIvtIostorinvOutMapper.java index fd6b5f4f..5bea77c8 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/dao/mapper/StIvtIostorinvOutMapper.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/mapper/StIvtIostorinvOutMapper.java @@ -1,8 +1,8 @@ -package org.nl.wms.stor_manage.io.service.out.iostor.dao.mapper; +package org.nl.wms.stor_manage.io.service.iostor.dao.mapper; import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import org.nl.wms.stor_manage.io.service.out.iostor.dao.StIvtIostorinvOut; +import org.nl.wms.stor_manage.io.service.iostor.dao.StIvtIostorinv; /** *

@@ -12,6 +12,6 @@ import org.nl.wms.stor_manage.io.service.out.iostor.dao.StIvtIostorinvOut; * @author generator * @since 2024-03-28 */ -public interface StIvtIostorinvOutMapper extends BaseMapper { +public interface StIvtIostorinvOutMapper extends BaseMapper { } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/mapper/xml/StIvtIostorinvMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/mapper/xml/StIvtIostorinvOutMapper.xml similarity index 61% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/mapper/xml/StIvtIostorinvMapper.xml rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/mapper/xml/StIvtIostorinvOutMapper.xml index 1df581b6..9fd0f76c 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor/dao/mapper/xml/StIvtIostorinvMapper.xml +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/dao/mapper/xml/StIvtIostorinvOutMapper.xml @@ -1,5 +1,5 @@ - + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/impl/StIvtIostorinvOutServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/impl/StIvtIostorinvServiceImpl.java similarity index 77% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/impl/StIvtIostorinvOutServiceImpl.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/impl/StIvtIostorinvServiceImpl.java index 7af4786a..5b211b53 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor/impl/StIvtIostorinvOutServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/impl/StIvtIostorinvServiceImpl.java @@ -1,4 +1,4 @@ -package org.nl.wms.stor_manage.io.service.out.iostor.impl; +package org.nl.wms.stor_manage.io.service.iostor.impl; import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSONObject; @@ -14,11 +14,11 @@ import org.nl.common.utils.MapOf; import org.nl.common.utils.SecurityUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.nl.wms.flow_manage.monitor.event.FlowStartEvent; -import org.nl.wms.stor_manage.io.service.out.iostor.IStIvtIostorinvOutService; -import org.nl.wms.stor_manage.io.service.out.iostor.dao.StIvtIostorinvOut; -import org.nl.wms.stor_manage.io.service.out.iostor.dao.mapper.StIvtIostorinvOutMapper; -import org.nl.wms.stor_manage.io.service.out.iostor_dtl.IStIvtIostorinvdtlOutService; -import org.nl.wms.stor_manage.io.service.out.iostor_dtl.dao.StIvtIostorinvdtlOut; +import org.nl.wms.stor_manage.io.service.iostor.IStIvtIostorinvService; +import org.nl.wms.stor_manage.io.service.iostor.dao.StIvtIostorinv; +import org.nl.wms.stor_manage.io.service.iostor.dao.mapper.StIvtIostorinvOutMapper; +import org.nl.wms.stor_manage.io.service.iostor_dtl.IStIvtIostorinvdtlService; +import org.nl.wms.stor_manage.io.service.iostor_dtl.dao.StIvtIostorinvdtl; import org.nl.wms.stor_manage.struct.service.IStIvtStructattrService; import org.nl.wms.stor_manage.struct.service.dao.StIvtStructattr; import org.springframework.beans.factory.annotation.Autowired; @@ -30,7 +30,6 @@ import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Map; -import java.util.function.Consumer; import java.util.stream.Collectors; /** @@ -42,10 +41,10 @@ import java.util.stream.Collectors; * @since 2024-03-28 */ @Service -public class StIvtIostorinvOutServiceImpl extends ServiceImpl implements IStIvtIostorinvOutService { +public class StIvtIostorinvServiceImpl extends ServiceImpl implements IStIvtIostorinvService { @Autowired - private IStIvtIostorinvdtlOutService iStIvtIostorinvDtlOutService; + private IStIvtIostorinvdtlService iStIvtIostorinvDtlOutService; @Autowired private IStIvtStructattrService iStIvtStructattrService; @@ -56,7 +55,7 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl dtls = (List) form.remove("item"); - StIvtIostorinvOut mst = form.toJavaObject(StIvtIostorinvOut.class); + StIvtIostorinv mst = form.toJavaObject(StIvtIostorinv.class); mst.setId(IdUtil.getStringId()); mst.setCreate_name(SecurityUtils.getCurrentNickName()); mst.setCreate_time(DateUtil.now()); @@ -64,7 +63,7 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl0){ for (int i = 0; i < dtls.size(); i++) { - StIvtIostorinvdtlOut dtl = new JSONObject(dtls.get(i)).toJavaObject(StIvtIostorinvdtlOut.class); + StIvtIostorinvdtl dtl = new JSONObject(dtls.get(i)).toJavaObject(StIvtIostorinvdtl.class); dtl.setId(IdUtil.getStringId()); dtl.setInv_id(mst.getId()); dtl.setStatus(StatusEnum.FORM_STATUS.code("生成")); @@ -82,13 +81,13 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl() + iStIvtIostorinvDtlOutService.update(new UpdateWrapper() .set("vehicle_code",desicion.stream().map(StIvtStructattr::getVehicle_code).collect(Collectors.joining(","))) .eq("id",form.getString("id"))); - int count = iStIvtIostorinvDtlOutService.count(new QueryWrapper() + int count = iStIvtIostorinvDtlOutService.count(new QueryWrapper() .eq("inv_id", form.getString("inv_id")).isNull("vehicle_code")); if (count == 0){ - this.update(new UpdateWrapper() + this.update(new UpdateWrapper() .set("status",StatusEnum.FORM_STATUS.code("已分配")) .eq("id",form.getString("inv_id"))); } @@ -105,11 +104,11 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl() .set("lock_type", StatusEnum.LOCK.code("无")) .in("vehicle_code", Arrays.asList(split))); - iStIvtIostorinvDtlOutService.update(new UpdateWrapper() + iStIvtIostorinvDtlOutService.update(new UpdateWrapper() .set("vehicle_code",null) .eq("id",form.getString("id"))); - this.update(new UpdateWrapper() + this.update(new UpdateWrapper() .set("status",StatusEnum.FORM_STATUS.code("生成")) .eq("id",form.getString("inv_id"))); } @@ -120,12 +119,12 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl dtls = iStIvtIostorinvDtlOutService.list(new QueryWrapper().eq("inv_id", iostorinv.getId())); + List dtls = iStIvtIostorinvDtlOutService.list(new QueryWrapper().eq("inv_id", iostorinv.getId())); List dtlJson = new ArrayList<>(); if (!CollectionUtils.isEmpty(dtls)){ - for (StIvtIostorinvdtlOut dtl : dtls) { + for (StIvtIostorinvdtl dtl : dtls) { dtlJson.add(MapOf.of("form_id",dtl.getId() ,"t",JSONObject.toJSON(dtl) ,"source_form_type",dtl.getSource_form_type() @@ -137,7 +136,7 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl() + this.update(new UpdateWrapper() .set("status",StatusEnum.FORM_STATUS.code("执行中")) .set("update_time",DateUtil.now()) .set("update_name",SecurityUtils.getCurrentNickName()) diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/IStIvtIostorinvdtlService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/IStIvtIostorinvdtlService.java similarity index 74% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/IStIvtIostorinvdtlService.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/IStIvtIostorinvdtlService.java index b4401294..dc3e06c5 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/IStIvtIostorinvdtlService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/IStIvtIostorinvdtlService.java @@ -1,7 +1,7 @@ -package org.nl.wms.stor_manage.io.service.in.iostor_dtl; +package org.nl.wms.stor_manage.io.service.iostor_dtl; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.StIvtIostorinvdtl; import com.baomidou.mybatisplus.extension.service.IService; +import org.nl.wms.stor_manage.io.service.iostor_dtl.dao.StIvtIostorinvdtl; import java.util.List; import java.util.Map; @@ -18,5 +18,7 @@ public interface IStIvtIostorinvdtlService extends IService { void batchInsert(List dtls); + List getByInv(String inv_id); + } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/StIvtIostorinvdtl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/StIvtIostorinvdtl.java similarity index 79% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/StIvtIostorinvdtl.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/StIvtIostorinvdtl.java index 89497488..625f2256 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/StIvtIostorinvdtl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/StIvtIostorinvdtl.java @@ -1,4 +1,4 @@ -package org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao; +package org.nl.wms.stor_manage.io.service.iostor_dtl.dao; import java.math.BigDecimal; @@ -21,9 +21,8 @@ import lombok.EqualsAndHashCode; */ @Data @EqualsAndHashCode(callSuper = false) -@TableName(value = "st_ivt_iostorinvdtl_in",autoResultMap = true) +@TableName(value = "st_ivt_iostorinvdtl", autoResultMap = true) public class StIvtIostorinvdtl implements Serializable { - private static final long serialVersionUID = 1L; /** @@ -36,11 +35,6 @@ public class StIvtIostorinvdtl implements Serializable { */ private String inv_id; - /** - * 出入单标识 - */ - private Boolean in_storage = Boolean.TRUE; - /** * 源单号 */ @@ -76,16 +70,6 @@ public class StIvtIostorinvdtl implements Serializable { */ private BigDecimal qty; - - /** - * 未分配数量(计划数量-载具物料数量) - */ - private BigDecimal unassign_qty; - - /** - * 分配数量 - */ - private BigDecimal assign_qty; /** * 分配的载具 */ diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/mapper/StIvtIostorinvdtlMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/mapper/StIvtIostorinvdtlMapper.java similarity index 70% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/mapper/StIvtIostorinvdtlMapper.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/mapper/StIvtIostorinvdtlMapper.java index 7619e4c3..baa5d864 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/in/iostor_dtl/dao/mapper/StIvtIostorinvdtlMapper.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/mapper/StIvtIostorinvdtlMapper.java @@ -1,11 +1,11 @@ -package org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.mapper; +package org.nl.wms.stor_manage.io.service.iostor_dtl.dao.mapper; import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler; import org.apache.ibatis.annotations.Result; import org.apache.ibatis.annotations.Results; import org.apache.ibatis.annotations.Select; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.StIvtIostorinvdtl; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.nl.wms.stor_manage.io.service.iostor_dtl.dao.StIvtIostorinvdtl; import java.util.List; import java.util.Map; @@ -24,18 +24,18 @@ public interface StIvtIostorinvdtlMapper extends BaseMapper { @Select("SELECT\n" + " sum(md_pb_vehicleMater.qty) as qty,\n" + - " st_ivt_iostorinvdtl_in.*,\n" + + " st_ivt_iostorinvdtl.*,\n" + " md_me_materialbase.material_code,\n" + " md_me_materialbase.material_name,\n" + " md_me_materialbase.material_spec\n" + " FROM\n" + - " st_ivt_iostorinvdtl_in\n" + - " LEFT JOIN md_me_materialbase ON st_ivt_iostorinvdtl_in.material_id = md_me_materialbase.material_id\n" + - " LEFT JOIN md_pb_vehicleMater ON (st_ivt_iostorinvdtl_in.vehicle_code = md_pb_vehicleMater.vehicle_code\n" + - " and st_ivt_iostorinvdtl_in.material_id = md_pb_vehicleMater.material_id)\n" + - " where inv_id = #{inv_id} GROUP BY st_ivt_iostorinvdtl_in.id") + " st_ivt_iostorinvdtl\n" + + " LEFT JOIN md_me_materialbase ON st_ivt_iostorinvdtl.material_id = md_me_materialbase.material_id\n" + + " LEFT JOIN md_pb_vehicleMater ON (st_ivt_iostorinvdtl.vehicle_code = md_pb_vehicleMater.vehicle_code\n" + + " and st_ivt_iostorinvdtl.material_id = md_pb_vehicleMater.material_id)\n" + + " where inv_id = #{inv_id} GROUP BY st_ivt_iostorinvdtl.id") @Results({@Result(property = "form_data",column = "form_data",typeHandler = FastjsonTypeHandler.class)}) List findByInv(String inv_id); - List findByInv2(String inv_id); + } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlMapper.xml new file mode 100644 index 00000000..272f1d42 --- /dev/null +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlMapper.xml @@ -0,0 +1,9 @@ + + + + + + insert into st_ivt_iostorinvdtl() values + + + diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/impl/StIvtIostorinvdtlOutServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/impl/StIvtIostorinvdtlServiceImpl.java similarity index 77% rename from wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/impl/StIvtIostorinvdtlOutServiceImpl.java rename to wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/impl/StIvtIostorinvdtlServiceImpl.java index 6958e03e..e94570f1 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/impl/StIvtIostorinvdtlOutServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor_dtl/impl/StIvtIostorinvdtlServiceImpl.java @@ -1,11 +1,11 @@ -package org.nl.wms.stor_manage.io.service.out.iostor_dtl.impl; +package org.nl.wms.stor_manage.io.service.iostor_dtl.impl; import org.apache.commons.lang3.StringUtils; import org.nl.common.utils.MapOf; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import org.nl.wms.stor_manage.io.service.out.iostor_dtl.IStIvtIostorinvdtlOutService; -import org.nl.wms.stor_manage.io.service.out.iostor_dtl.dao.StIvtIostorinvdtlOut; -import org.nl.wms.stor_manage.io.service.out.iostor_dtl.dao.mapper.StIvtIostorinvdtlOutMapper; +import org.nl.wms.stor_manage.io.service.iostor_dtl.IStIvtIostorinvdtlService; +import org.nl.wms.stor_manage.io.service.iostor_dtl.dao.StIvtIostorinvdtl; +import org.nl.wms.stor_manage.io.service.iostor_dtl.dao.mapper.StIvtIostorinvdtlMapper; import org.nl.wms.stor_manage.struct.service.IStIvtStructattrService; import org.nl.wms.stor_manage.struct.service.dto.StructattrVechielDto; import org.springframework.beans.factory.annotation.Autowired; @@ -26,13 +26,13 @@ import java.util.stream.Collectors; * @since 2024-03-29 */ @Service -public class StIvtIostorinvdtlOutServiceImpl extends ServiceImpl implements IStIvtIostorinvdtlOutService { +public class StIvtIostorinvdtlServiceImpl extends ServiceImpl implements IStIvtIostorinvdtlService { @Autowired private IStIvtStructattrService iStIvtStructattrService; @Override - public void batchInsert(List dtls) { + public void batchInsert(List dtls) { this.baseMapper.batchInsert(dtls); } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/IStIvtIostorinvdtlOutService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/IStIvtIostorinvdtlOutService.java deleted file mode 100644 index 43d5908e..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/IStIvtIostorinvdtlOutService.java +++ /dev/null @@ -1,26 +0,0 @@ -package org.nl.wms.stor_manage.io.service.out.iostor_dtl; - -import com.alibaba.fastjson.JSONObject; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.StIvtIostorinvdtl; -import com.baomidou.mybatisplus.extension.service.IService; -import org.nl.wms.stor_manage.io.service.out.iostor_dtl.dao.StIvtIostorinvdtlOut; - -import java.util.List; -import java.util.Map; - -/** - *

- * 出入库单明细表 服务类 - *

- * - * @author generator - * @since 2024-03-29 - */ -public interface IStIvtIostorinvdtlOutService extends IService { - - void batchInsert(List dtls); - - - List getByInv(String inv_id); - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/StIvtIostorinvdtlOut.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/StIvtIostorinvdtlOut.java deleted file mode 100644 index 762fbf7c..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/StIvtIostorinvdtlOut.java +++ /dev/null @@ -1,114 +0,0 @@ -package org.nl.wms.stor_manage.io.service.out.iostor_dtl.dao; - -import java.math.BigDecimal; - -import cn.hutool.json.JSONObject; -import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableName; -import java.io.Serializable; - -import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler; -import lombok.Data; -import lombok.EqualsAndHashCode; - -/** - *

- * 出入库单明细表 - *

- * - * @author generator - * @since 2024-03-29 - */ -@Data -@EqualsAndHashCode(callSuper = false) -@TableName(value = "st_ivt_iostorinvdtl_out", autoResultMap = true) -public class StIvtIostorinvdtlOut implements Serializable { - private static final long serialVersionUID = 1L; - - /** - * 出入单明细标识 - */ - private String id; - - /** - * 出入单标识 - */ - private String inv_id; - - /** - * 源单号 - */ - private String source_form_id; - - /** - * 源单单据类型 - */ - private String source_form_type; - /** - * 单据明细状态 - */ - private String status; - - /** - * 物料标识 - */ - private String material_id; - - /** - * 批次 - */ - private String pcsn; - - - /** - * 数量计量单位标识 - */ - private String unit_id; - - /** - * 计划数量 - */ - private BigDecimal plan_qty; - - - /** - * 未分配数量(计划数量-载具物料数量) - */ - private BigDecimal unassign_qty; - - /** - * 分配数量 - */ - private BigDecimal assign_qty; - /** - * 分配的载具 - */ - private String vehicle_code; - - /** - * 仓库 - */ - private String stor_code; - /** - * 仓位编码 - */ - private String struct_code; - - /** - * 备注 - */ - private String remark; - /** - * 操作时间 - */ - private String update_time; - - - @TableField(typeHandler = FastjsonTypeHandler.class) - private JSONObject form_data; - - - private Boolean in_storage = Boolean.FALSE; - - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/mapper/StIvtIostorinvdtlOutMapper.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/mapper/StIvtIostorinvdtlOutMapper.java deleted file mode 100644 index 9b8a563d..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/mapper/StIvtIostorinvdtlOutMapper.java +++ /dev/null @@ -1,42 +0,0 @@ -package org.nl.wms.stor_manage.io.service.out.iostor_dtl.dao.mapper; - -import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler; -import org.apache.ibatis.annotations.Result; -import org.apache.ibatis.annotations.Results; -import org.apache.ibatis.annotations.Select; -import org.nl.wms.stor_manage.io.service.in.iostor_dtl.dao.StIvtIostorinvdtl; -import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import org.nl.wms.stor_manage.io.service.out.iostor_dtl.dao.StIvtIostorinvdtlOut; - -import java.util.List; -import java.util.Map; - -/** - *

- * 出入库单明细表 Mapper 接口 - *

- * - * @author generator - * @since 2024-03-29 - */ -public interface StIvtIostorinvdtlOutMapper extends BaseMapper { - - Integer batchInsert(List dtls); - - @Select("SELECT\n" + - " sum(md_pb_vehicleMater.qty) as qty,\n" + - " st_ivt_iostorinvdtl_out.*,\n" + - " md_me_materialbase.material_code,\n" + - " md_me_materialbase.material_name,\n" + - " md_me_materialbase.material_spec\n" + - " FROM\n" + - " st_ivt_iostorinvdtl_out\n" + - " LEFT JOIN md_me_materialbase ON st_ivt_iostorinvdtl_out.material_id = md_me_materialbase.material_id\n" + - " LEFT JOIN md_pb_vehicleMater ON (st_ivt_iostorinvdtl_out.vehicle_code = md_pb_vehicleMater.vehicle_code\n" + - " and st_ivt_iostorinvdtl_out.material_id = md_pb_vehicleMater.material_id)\n" + - " where inv_id = #{inv_id} GROUP BY st_ivt_iostorinvdtl_out.id") - @Results({@Result(property = "form_data",column = "form_data",typeHandler = FastjsonTypeHandler.class)}) - List findByInv(String inv_id); - - -} diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlOutMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlOutMapper.xml deleted file mode 100644 index 1aaf5e5b..00000000 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/out/iostor_dtl/dao/mapper/xml/StIvtIostorinvdtlOutMapper.xml +++ /dev/null @@ -1,9 +0,0 @@ - - - - - - insert into st_ivt_iostorinvdtl_out() values - - - diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/monitor/listener/FlowEndEventListener.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/monitor/listener/FlowEndEventListener.java index 76f154c5..e0442a0f 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/monitor/listener/FlowEndEventListener.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/monitor/listener/FlowEndEventListener.java @@ -1,25 +1,17 @@ package org.nl.wms.stor_manage.monitor.listener; -import cn.hutool.core.date.DateUtil; -import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.nl.common.domain.exception.BadRequestException; import org.nl.common.enums.StatusEnum; import org.nl.common.publish.AbstraceListener; -import org.nl.wms.flow_manage.flow.framework.entity.ExecutionDto; -import org.nl.wms.flow_manage.flow.service.execution.IFlowOperationService; import org.nl.wms.flow_manage.flow.service.history.IActHiExecutionService; import org.nl.wms.flow_manage.flow.service.history.dao.ActHiExecution; import org.nl.wms.flow_manage.monitor.event.FlowEndEvent; -import org.nl.wms.flow_manage.monitor.event.FlowStartEvent; import org.nl.wms.pm_manage.form_data.service.IPmFormDataService; import org.nl.wms.stor_manage.io.service.in.iostor.IStIvtIostorinvInService; import org.nl.wms.stor_manage.io.service.in.iostor.dao.StIvtIostorinvIn; -import org.nl.wms.stor_manage.io.service.out.iostor.IStIvtIostorinvOutService; -import org.nl.wms.stor_manage.io.service.out.iostor.dao.StIvtIostorinvOut; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/dto/StructattrVechielDto.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/dto/StructattrVechielDto.java index 68ddd6e5..ad1a5756 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/dto/StructattrVechielDto.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/dto/StructattrVechielDto.java @@ -1,7 +1,6 @@ package org.nl.wms.stor_manage.struct.service.dto; import lombok.Data; -import org.nl.wms.md_manage.vehicleGroup.service.dao.MdPbVehicleMater; import java.math.BigDecimal; @@ -10,7 +9,7 @@ import java.math.BigDecimal; * @Date 2023/5/4 19:49 */ @Data -public class StructattrVechielDto extends MdPbVehicleMater { +public class StructattrVechielDto extends org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater { private static final long serialVersionUID = 1L; /** diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/impl/StIvtStructattrServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/impl/StIvtStructattrServiceImpl.java index c20c204c..4d27ae22 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/impl/StIvtStructattrServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/struct/service/impl/StIvtStructattrServiceImpl.java @@ -12,9 +12,11 @@ import org.nl.common.domain.entity.PageQuery; import org.nl.common.domain.exception.BadRequestException; import org.nl.common.enums.StatusEnum; import org.nl.common.utils.IdUtil; -import org.nl.wms.md_manage.vehicleGroup.service.IMdPbVehicleMaterService; -import org.nl.wms.md_manage.vehicleGroup.service.dao.MdPbVehicleMater; + + import org.nl.wms.flow_manage.flow.framework.process.nodeType.excess.impl.DecisionHandler; +import org.nl.wms.md_manage.vehicleMater.service.IMdPbVehicleMaterService; +import org.nl.wms.md_manage.vehicleMater.service.dao.MdPbVehicleMater; import org.nl.wms.stor_manage.record.service.IStIvtStructivtflowService; import org.nl.wms.stor_manage.record.service.dao.StIvtStructivtflow; import org.nl.wms.stor_manage.struct.service.dao.StIvtStructattr; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/controller/field_mapping/BmExternalFieldMappingController.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/controller/field_mapping/BmExternalFieldMappingController.java index b4e1de29..7dfc3940 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/controller/field_mapping/BmExternalFieldMappingController.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/controller/field_mapping/BmExternalFieldMappingController.java @@ -1,6 +1,9 @@ package org.nl.wms.sync_manage.controller.field_mapping; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONException; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import org.nl.common.TableDataInfo; import org.nl.common.domain.entity.PageQuery; @@ -73,7 +76,10 @@ public class BmExternalFieldMappingController { public ResponseEntity getTableColumnNames(@PathVariable String table_name) { return new ResponseEntity<>(mappingsService.getTableColumnNames(table_name), HttpStatus.OK); } - + @GetMapping("/getTableColumnNamesdata/{table_name}") + public ResponseEntity getTableColumnNamesdata(@PathVariable String table_name) { + return new ResponseEntity<>(mappingsService.getTableColumnNamesdata(table_name), HttpStatus.OK); + } @GetMapping("/getTableColumnNamesFromMapping/{table_name}") public ResponseEntity getTableColumnNamesFromMapping(@PathVariable String table_name) { return new ResponseEntity<>(mappingsService.getTableColumnNamesFromMapping(table_name), HttpStatus.OK); @@ -88,5 +94,24 @@ public class BmExternalFieldMappingController { public ResponseEntity getExistTableName() { return new ResponseEntity<>(mappingsService.getExistTableName(), HttpStatus.OK); } + @PostMapping("/syncAnalyse") + public ResponseEntity syncAnalyse(@RequestBody JSONObject form){ + String fromType=form.getString("local_table_name"); + JSONArray formMapping = new JSONArray(); + try { + JSONObject jsonObject = new JSONObject(form.getJSONObject("mapping_json")); + for (String key : jsonObject.keySet()) { + JSONObject item = new JSONObject(); + item.put("key", key); + item.put("value", jsonObject.get(key)); + formMapping.add(item); + } + } catch (JSONException e) { + e.printStackTrace(); + } +// JSONArray formMapping=form.getJSONArray("mapping_json"); + String sourceString=form.getString("analyseData"); + return new ResponseEntity<>(mappingsService.toJavaObject(JSONObject.class,fromType,formMapping,sourceString), HttpStatus.OK); + } } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/IBmExternalFieldMappingService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/IBmExternalFieldMappingService.java index 845be08d..356efe12 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/IBmExternalFieldMappingService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/IBmExternalFieldMappingService.java @@ -1,6 +1,7 @@ package org.nl.wms.sync_manage.service.field_mapping; +import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.extension.service.IService; import org.nl.wms.sync_manage.service.field_mapping.dao.BmExternalFieldMapping; import org.nl.wms.sync_manage.service.field_mapping.dto.RequestMappingParam; @@ -26,6 +27,13 @@ public interface IBmExternalFieldMappingService extends IService> getTableColumnNames(String tableName); + /** + * 根据数据表名获取所有字段和注释 + * + * @param tableName + * @return + */ + List> getTableColumnNamesdata(String tableName); /** * 获取数据库中所有表的名称 @@ -56,6 +64,7 @@ public interface IBmExternalFieldMappingService extends IService List toJavaObject(Class clazz,String fromType, JSONArray formMapping, String sourceString); /** * 从映射关系表中获取已配置映射关系的 * @@ -63,4 +72,5 @@ public interface IBmExternalFieldMappingService extends IService { /** - * 根据数据表名获取所有字段名称 + * 根据数据表名获取所有字段名称和值 * * @param tableName * @return */ List> getTableColumnNames(@Param("tableName") String tableName); - + /** + * 根据数据表名获取所有字段和注释 + * + * @param tableName + * @return + */ + List> getTableColumnNamesdata(String tableName); + /** + * 根据数据表名获取所有字段名称 + * + * @param tableName + * @return + */ + List getTablename(@Param("tableName") String tableName); /** * 获取数据库中所有表的名称 * @@ -38,4 +52,5 @@ public interface BmExternalFieldMappingMapper extends BaseMapper getExistTableName(); + } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/dao/mapper/xml/BmExternalFieldMappingMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/dao/mapper/xml/BmExternalFieldMappingMapper.xml index 2ccb40bc..db880457 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/dao/mapper/xml/BmExternalFieldMappingMapper.xml +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/sync_manage/service/field_mapping/dao/mapper/xml/BmExternalFieldMappingMapper.xml @@ -10,7 +10,18 @@ WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = #{tableName} - + +