diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/SecurityUtils.java b/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/SecurityUtils.java index 67f854f..b434369 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/SecurityUtils.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/SecurityUtils.java @@ -49,7 +49,7 @@ public class SecurityUtils { * @return 系统用户名称 */ public static String getCurrentNickName() { - return getCurrentUser().getPreson_name(); + return getCurrentUser().getPresonName(); } /** diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/dto/CurrentUser.java b/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/dto/CurrentUser.java index c305dc5..440752f 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/dto/CurrentUser.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/common/utils/dto/CurrentUser.java @@ -22,7 +22,7 @@ public class CurrentUser implements Serializable { //账号 private String username; //姓名 - private String preson_name; + private String presonName; //用户详细信息 private SysUser user; diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/dept/impl/SysDeptServiceImpl.java b/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/dept/impl/SysDeptServiceImpl.java index 36a46bb..93ea266 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/dept/impl/SysDeptServiceImpl.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/dept/impl/SysDeptServiceImpl.java @@ -168,7 +168,7 @@ public class SysDeptServiceImpl extends ServiceImpl impl dept.setDept_id(IdUtil.getStringId()); CurrentUser user = SecurityUtils.getCurrentUser(); dept.setCreate_id(user.getId()); - dept.setCreate_name(user.getPreson_name()); + dept.setCreate_name(user.getPresonName()); dept.setCreate_time(new Date()); this.save(dept); // 清理缓存 diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/secutiry/impl/OnlineUserService.java b/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/secutiry/impl/OnlineUserService.java index 0b6a493..b63ef55 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/secutiry/impl/OnlineUserService.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/secutiry/impl/OnlineUserService.java @@ -244,7 +244,7 @@ public class OnlineUserService { CurrentUser user = new CurrentUser(); user.setId(userInfo.getUser_id()); user.setUsername(userInfo.getUsername()); - user.setPreson_name((userInfo.getPerson_name())); + user.setPresonName((userInfo.getPerson_name())); user.setUser(userInfo); user.setPermissions(permissionList); diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dao/mapper/PdmBdWorkorderMapper.xml b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dao/mapper/PdmBdWorkorderMapper.xml index f0d8b06..bc0fe33 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dao/mapper/PdmBdWorkorderMapper.xml +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dao/mapper/PdmBdWorkorderMapper.xml @@ -8,12 +8,25 @@ ,ma.material_spec FROM pdm_bd_workorder wo LEFT JOIN md_base_material ma ON ma.material_id = wo.material_id - WHERE 1 = 1 - - AND wo.workorder_code LIKE CONCAT('%', #{query.workorder_code}, '%') - - - AND LOWER(wo.point_code) LIKE LOWER(CONCAT('%', #{query.point_code}, '%')) - + + + workorder_status IN + + #{code} + + + + AND wo.workorder_code LIKE CONCAT('%', #{query.workorder_code}, '%') + + + AND LOWER(wo.point_code) LIKE LOWER(CONCAT('%', #{query.point_code}, '%')) + + + AND wo.create_time = ]]> #{query.begin_time} + + + AND wo.create_time #{query.end_time} + + diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dto/PdmBdWorkorderQuery.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dto/PdmBdWorkorderQuery.java index c97aa64..375c115 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dto/PdmBdWorkorderQuery.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/dto/PdmBdWorkorderQuery.java @@ -3,6 +3,7 @@ package org.nl.wms.pdm.service.dto; import lombok.Data; import java.io.Serializable; +import java.util.List; /** * @author lyd @@ -12,5 +13,8 @@ import java.io.Serializable; public class PdmBdWorkorderQuery implements Serializable { private String workorder_code; private String point_code; + private String begin_time; + private String end_time; + private List more_order_status; } diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/impl/PdmBdWorkorderServiceImpl.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/impl/PdmBdWorkorderServiceImpl.java index 405f59e..dc8b46f 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/impl/PdmBdWorkorderServiceImpl.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pdm/service/impl/PdmBdWorkorderServiceImpl.java @@ -2,6 +2,7 @@ package org.nl.wms.pdm.service.impl; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.IdUtil; +import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -17,6 +18,7 @@ import org.nl.wms.pdm.service.dto.PdmBdWorkorderQuery; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.util.List; import java.util.Set; /** @@ -33,8 +35,6 @@ public class PdmBdWorkorderServiceImpl extends ServiceImpl queryAll(PdmBdWorkorderQuery query, PageQuery page){ -// String workorder_code = ObjectUtil.isNotEmpty(whereJson.get("workorder_code")) ? whereJson.get("workorder_code").toString() : null; -// String point_code = ObjectUtil.isNotEmpty(whereJson.get("point_code")) ? whereJson.get("point_code").toString() : null; IPage pages = new Page<>(page.getPage() + 1, page.getSize()); pages = pdmBdWorkorderMapper.selectPageLeftJoin(pages, query); return pages; diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/controller/SchBaseVehiclematerialgroupController.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/controller/SchBaseVehiclematerialgroupController.java index 73b8333..725d580 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/controller/SchBaseVehiclematerialgroupController.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/controller/SchBaseVehiclematerialgroupController.java @@ -1,5 +1,6 @@ package org.nl.wms.sch.group.controller; +import com.alibaba.fastjson.JSONObject; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; @@ -64,4 +65,11 @@ public class SchBaseVehiclematerialgroupController { schBaseVehiclematerialgroupService.deleteAll(ids); return new ResponseEntity<>(HttpStatus.OK); } + + @PostMapping("/getGroup") + @Log("获取组盘信息管理") + @ApiOperation("获取组盘信息管理") + public ResponseEntity getGroup(@RequestBody JSONObject entity){ + return new ResponseEntity<>(schBaseVehiclematerialgroupService.getGroup(entity), HttpStatus.OK); + } } diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java index 9587046..f4c154d 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java @@ -1,5 +1,6 @@ package org.nl.wms.sch.group.service; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.metadata.IPage; import org.nl.common.domain.query.PageQuery; import com.baomidou.mybatisplus.extension.service.IService; @@ -41,4 +42,11 @@ public interface ISchBaseVehiclematerialgroupService extends IService ids); + + /** + * 根据载具编码返回数据 + * @param entity + * @return + */ + SchBaseVehiclematerialgroup getGroup(JSONObject entity); } diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/SchBaseVehiclematerialgroup.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/SchBaseVehiclematerialgroup.java index 4f71d0a..9e7d1cb 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/SchBaseVehiclematerialgroup.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/SchBaseVehiclematerialgroup.java @@ -146,5 +146,7 @@ public class SchBaseVehiclematerialgroup implements Serializable { private String material_spec; @TableField(exist = false) private String region_name; + @TableField(exist = false) + private String group_bind_material_status_name; } diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java index 741686a..08e994d 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java @@ -1,5 +1,6 @@ package org.nl.wms.sch.group.service.dao.mapper; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.metadata.IPage; import org.nl.wms.sch.group.service.dao.SchBaseVehiclematerialgroup; @@ -12,4 +13,6 @@ import org.nl.wms.sch.group.service.dto.SchBaseVehiclematerialgroupQuery; public interface SchBaseVehiclematerialgroupMapper extends BaseMapper { IPage selectPageLeftJoin(IPage pages, SchBaseVehiclematerialgroupQuery query); + + SchBaseVehiclematerialgroup getGroup(JSONObject entity); } diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml index fb6fb45..8ccaf69 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml @@ -18,5 +18,35 @@ AND vg.workshop_code = #{query.workshop_code} + + AND vg.group_bind_material_status = #{query.group_bind_material_status} + + + AND vg.point_code IN ( + SELECT p.point_code + FROM sch_base_point p + WHERE p.region_code = #{query.region_code} + ) + + + diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dto/SchBaseVehiclematerialgroupQuery.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dto/SchBaseVehiclematerialgroupQuery.java index 50d4648..576d285 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dto/SchBaseVehiclematerialgroupQuery.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dto/SchBaseVehiclematerialgroupQuery.java @@ -14,4 +14,6 @@ import java.io.Serializable; public class SchBaseVehiclematerialgroupQuery implements Serializable { private String vehicle_code; private String workshop_code; + private String region_code; + private String group_bind_material_status; } diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/impl/SchBaseVehiclematerialgroupServiceImpl.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/impl/SchBaseVehiclematerialgroupServiceImpl.java index f729ac1..3a97dec 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/impl/SchBaseVehiclematerialgroupServiceImpl.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/impl/SchBaseVehiclematerialgroupServiceImpl.java @@ -3,6 +3,7 @@ package org.nl.wms.sch.group.service.impl; import cn.hutool.core.date.DateUtil; import cn.hutool.core.lang.Assert; import cn.hutool.core.util.IdUtil; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -73,4 +74,9 @@ public class SchBaseVehiclematerialgroupServiceImpl extends ServiceImpl query(@RequestParam Map whereJson, PageQuery page){ + return new ResponseEntity<>(TableDataInfo.build(schBaseAcsandlmsinteractivelogService.queryAll(whereJson,page)),HttpStatus.OK); + } + + @PostMapping + @Log("新增ACS和LMS交互日志表") + @ApiOperation("新增ACS和LMS交互日志表") + //@SaCheckPermission("@el.check('schBaseAcsandlmsinteractivelog:add')") + public ResponseEntity create(@Validated @RequestBody SchBaseAcsandlmsinteractivelog entity){ + schBaseAcsandlmsinteractivelogService.create(entity); + return new ResponseEntity<>(HttpStatus.CREATED); + } + + @PutMapping + @Log("修改ACS和LMS交互日志表") + @ApiOperation("修改ACS和LMS交互日志表") + //@SaCheckPermission("@el.check('schBaseAcsandlmsinteractivelog:edit')") + public ResponseEntity update(@Validated @RequestBody SchBaseAcsandlmsinteractivelog entity){ + schBaseAcsandlmsinteractivelogService.update(entity); + return new ResponseEntity<>(HttpStatus.NO_CONTENT); + } + + @Log("删除ACS和LMS交互日志表") + @ApiOperation("删除ACS和LMS交互日志表") + //@SaCheckPermission("@el.check('schBaseAcsandlmsinteractivelog:del')") + @DeleteMapping + public ResponseEntity delete(@RequestBody Set ids) { + schBaseAcsandlmsinteractivelogService.deleteAll(ids); + return new ResponseEntity<>(HttpStatus.OK); + } +} diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/ISchBaseAcsandlmsinteractivelogService.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/ISchBaseAcsandlmsinteractivelogService.java new file mode 100644 index 0000000..744c54c --- /dev/null +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/ISchBaseAcsandlmsinteractivelogService.java @@ -0,0 +1,43 @@ +package org.nl.wms.sch.interactivelog.service; + +import com.baomidou.mybatisplus.core.metadata.IPage; +import org.nl.common.domain.query.PageQuery; +import com.baomidou.mybatisplus.extension.service.IService; +import org.nl.wms.sch.interactivelog.service.dao.SchBaseAcsandlmsinteractivelog; + +import java.util.Map; +import java.util.Set; + +/** +* @description 服务接口 +* @author lyd +* @date 2023-05-26 +**/ +public interface ISchBaseAcsandlmsinteractivelogService extends IService { + + /** + * 查询数据分页 + * @param whereJson 条件 + * @param pageable 分页参数 + * @return IPage + */ + IPage queryAll(Map whereJson, PageQuery pageable); + + /** + * 创建 + * @param entity / + */ + void create(SchBaseAcsandlmsinteractivelog entity); + + /** + * 编辑 + * @param entity / + */ + void update(SchBaseAcsandlmsinteractivelog entity); + + /** + * 多选删除 + * @param ids / + */ + void deleteAll(Set ids); +} diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/SchBaseAcsandlmsinteractivelog.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/SchBaseAcsandlmsinteractivelog.java new file mode 100644 index 0000000..40c0464 --- /dev/null +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/SchBaseAcsandlmsinteractivelog.java @@ -0,0 +1,73 @@ +package org.nl.wms.sch.interactivelog.service.dao; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.io.Serializable; + +/** +* @description / +* @author lyd +* @date 2023-05-26 +**/ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("sch_base_acsandlmsinteractivelog") +public class SchBaseAcsandlmsinteractivelog implements Serializable { + + private static final long serialVersionUID = 1L; + + @TableId(value = "log_id", type = IdType.NONE) + @ApiModelProperty(value = "日志标识") + private String log_id; + + @ApiModelProperty(value = "请求名字") + private String request_name; + + @ApiModelProperty(value = "生成任务的请求参数") + private String request_param; + + @ApiModelProperty(value = "下发任务的请求参数") + private String response_param; + + @ApiModelProperty(value = "链路标识") + private String acs_trace_id; + + @ApiModelProperty(value = "请求描述") + private String request_desc; + + @ApiModelProperty(value = "请求类型") + private String request_type; + + @ApiModelProperty(value = "备注") + private String remark; + + @ApiModelProperty(value = "是否处理完成") + private Boolean is_finish; + + @ApiModelProperty(value = "车间编码") + private String workshop_code; + + @ApiModelProperty(value = "创建人") + private String create_id; + + @ApiModelProperty(value = "创建人") + private String create_name; + + @ApiModelProperty(value = "创建时间") + private String create_time; + + @ApiModelProperty(value = "修改人") + private String update_id; + + @ApiModelProperty(value = "修改人") + private String update_name; + + @ApiModelProperty(value = "修改时间") + private String update_time; + +} diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/mapper/SchBaseAcsandlmsinteractivelogMapper.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/mapper/SchBaseAcsandlmsinteractivelogMapper.java new file mode 100644 index 0000000..8a5ef66 --- /dev/null +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/mapper/SchBaseAcsandlmsinteractivelogMapper.java @@ -0,0 +1,12 @@ +package org.nl.wms.sch.interactivelog.service.dao.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.nl.wms.sch.interactivelog.service.dao.SchBaseAcsandlmsinteractivelog; + +/** +* @author lyd +* @date 2023-05-26 +**/ +public interface SchBaseAcsandlmsinteractivelogMapper extends BaseMapper { + +} diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/mapper/SchBaseAcsandlmsinteractivelogMapper.xml b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/mapper/SchBaseAcsandlmsinteractivelogMapper.xml new file mode 100644 index 0000000..44bd41d --- /dev/null +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dao/mapper/SchBaseAcsandlmsinteractivelogMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dto/SchBaseAcsandlmsinteractivelogDto.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dto/SchBaseAcsandlmsinteractivelogDto.java new file mode 100644 index 0000000..ed0fa6f --- /dev/null +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dto/SchBaseAcsandlmsinteractivelogDto.java @@ -0,0 +1,61 @@ +package org.nl.wms.sch.interactivelog.service.dto; + +import lombok.Data; +import java.io.Serializable; + +/** +* @description / +* @author lyd +* @date 2023-05-26 +**/ +@Data +public class SchBaseAcsandlmsinteractivelogDto implements Serializable { + + /** 日志标识 */ + private String log_id; + + /** 请求名字 */ + private String request_name; + + /** 生成任务的请求参数 */ + private String request_param; + + /** 下发任务的请求参数 */ + private String response_param; + + /** 链路标识 */ + private String acs_trace_id; + + /** 请求描述 */ + private String request_desc; + + /** 请求类型 */ + private String request_type; + + /** 备注 */ + private String remark; + + /** 是否处理完成 */ + private Boolean is_finish; + + /** 车间编码 */ + private String workshop_code; + + /** 创建人 */ + private String create_id; + + /** 创建人 */ + private String create_name; + + /** 创建时间 */ + private String create_time; + + /** 修改人 */ + private String update_id; + + /** 修改人 */ + private String update_name; + + /** 修改时间 */ + private String update_time; +} diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dto/SchBaseAcsandlmsinteractivelogQuery.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dto/SchBaseAcsandlmsinteractivelogQuery.java new file mode 100644 index 0000000..3c56b79 --- /dev/null +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/dto/SchBaseAcsandlmsinteractivelogQuery.java @@ -0,0 +1,12 @@ +package org.nl.wms.sch.interactivelog.service.dto; + +import org.nl.common.domain.query.BaseQuery; +import org.nl.wms.sch.interactivelog.service.dao.SchBaseAcsandlmsinteractivelog; + +/** +* @author lyd +* @date 2023-05-26 +**/ +public class SchBaseAcsandlmsinteractivelogQuery extends BaseQuery { + +} diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/impl/SchBaseAcsandlmsinteractivelogServiceImpl.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/impl/SchBaseAcsandlmsinteractivelogServiceImpl.java new file mode 100644 index 0000000..06c3549 --- /dev/null +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/interactivelog/service/impl/SchBaseAcsandlmsinteractivelogServiceImpl.java @@ -0,0 +1,80 @@ +package org.nl.wms.sch.interactivelog.service.impl; + +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.IdUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.nl.common.domain.query.PageQuery; +import org.nl.common.exception.BadRequestException; +import org.nl.common.utils.SecurityUtils; +import org.nl.wms.sch.interactivelog.service.ISchBaseAcsandlmsinteractivelogService; +import org.nl.wms.sch.interactivelog.service.dao.mapper.SchBaseAcsandlmsinteractivelogMapper; +import org.nl.wms.sch.interactivelog.service.dao.SchBaseAcsandlmsinteractivelog; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.Map; +import java.util.Set; + +/** +* @description 服务实现 +* @author lyd +* @date 2023-05-26 +**/ +@Slf4j +@Service +public class SchBaseAcsandlmsinteractivelogServiceImpl extends ServiceImpl implements ISchBaseAcsandlmsinteractivelogService { + + @Autowired + private SchBaseAcsandlmsinteractivelogMapper schBaseAcsandlmsinteractivelogMapper; + + @Override + public IPage queryAll(Map whereJson, PageQuery page){ + LambdaQueryWrapper lam = new LambdaQueryWrapper<>(); + IPage pages = new Page<>(page.getPage() + 1, page.getSize()); + schBaseAcsandlmsinteractivelogMapper.selectPage(pages, lam); + return pages; + } + + @Override + public void create(SchBaseAcsandlmsinteractivelog entity) { + String currentUserId = SecurityUtils.getCurrentUserId(); + String nickName = SecurityUtils.getCurrentNickName(); + String now = DateUtil.now(); + + entity.setLog_id(IdUtil.getSnowflake(1, 1).nextIdStr()); + entity.setCreate_id(currentUserId); + entity.setCreate_name(nickName); + entity.setCreate_time(now); + entity.setUpdate_id(currentUserId); + entity.setUpdate_name(nickName); + entity.setUpdate_time(now); + schBaseAcsandlmsinteractivelogMapper.insert(entity); + } + + @Override + public void update(SchBaseAcsandlmsinteractivelog entity) { + SchBaseAcsandlmsinteractivelog dto = schBaseAcsandlmsinteractivelogMapper.selectById(entity.getLog_id()); + if (dto == null) throw new BadRequestException("被删除或无权限,操作失败!"); + + String currentUserId = SecurityUtils.getCurrentUserId(); + String nickName = SecurityUtils.getCurrentNickName(); + String now = DateUtil.now(); + entity.setUpdate_id(currentUserId); + entity.setUpdate_name(nickName); + entity.setUpdate_time(now); + + schBaseAcsandlmsinteractivelogMapper.updateById(entity); + } + + @Override + public void deleteAll(Set ids) { + // 真删除 + schBaseAcsandlmsinteractivelogMapper.deleteBatchIds(ids); + } + +} diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java index 18d8454..2e0fe47 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java @@ -3,10 +3,18 @@ package org.nl.wms.sch.point.service.dao.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.nl.wms.sch.point.service.dao.SchBasePoint; +import java.util.List; + /** * @author lyd * @date 2023-05-15 **/ public interface SchBasePointMapper extends BaseMapper { + /** + * 批量禁用启用 + * @param pointCodes + * @param used + */ + void batchChangeUsed(List pointCodes, Boolean used); } diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml index 70305a1..66342b0 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml @@ -2,4 +2,14 @@ + + UPDATE sch_base_point + SET is_used = #{used} + + point_code IN + + #{code} + + + diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java index 9d397af..d9f4f43 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java @@ -1,7 +1,9 @@ package org.nl.wms.sch.point.service.impl; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.lang.Assert; import cn.hutool.core.util.ObjectUtil; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; @@ -26,6 +28,7 @@ import java.util.List; import java.util.Map; import java.util.Set; import java.util.function.Consumer; +import java.util.stream.Collectors; /** * @description 服务实现 @@ -149,7 +152,17 @@ public class SchBasePointServiceImpl extends ServiceImpl schBasePoints = JSONArray.parseArray(JSONArray.toJSONString(data), SchBasePoint.class); + // 获取所有pointCode + List pointCodes = schBasePoints.stream() + .map(SchBasePoint::getPoint_code) + .collect(Collectors.toList()); + pointMapper.batchChangeUsed(pointCodes, used); } @Override diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/SchBaseTaskconfig.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/SchBaseTaskconfig.java index cd1885b..e7423ca 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/SchBaseTaskconfig.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dao/SchBaseTaskconfig.java @@ -24,13 +24,19 @@ public class SchBaseTaskconfig implements Serializable { private static final long serialVersionUID = 1L; - @TableId(value = "config_code", type = IdType.NONE) + @TableId(value = "config_id", type = IdType.NONE) + @ApiModelProperty(value = "配置标识") + private String config_id; + @ApiModelProperty(value = "配置编码") private String config_code; @ApiModelProperty(value = "配置名称") private String config_name; + @ApiModelProperty(value = "路由编码") + private String route_plan_code; + @ApiModelProperty(value = "任务取放类型") private String task_qf_type; diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dto/SchBaseTaskconfigDto.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dto/SchBaseTaskconfigDto.java index a559dbd..eb845ba 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dto/SchBaseTaskconfigDto.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/dto/SchBaseTaskconfigDto.java @@ -12,12 +12,18 @@ import java.io.Serializable; @Data public class SchBaseTaskconfigDto implements Serializable { + /** 配置标识 */ + private String config_id; + /** 配置编码 */ private String config_code; /** 配置名称 */ private String config_name; + /** 路由编码 */ + private String route_plan_code; + /** 任务取放类型 */ private String task_qf_type; diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java index 633680f..e77a1a5 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java @@ -56,6 +56,13 @@ public class SchBaseTaskServiceImpl extends ServiceImpl collect = ObjectUtil.isNotEmpty(more_task_status)?Arrays.stream(more_task_status.split(",")).collect(Collectors.toList()):null; + String unFinished = null; + if (collect != null) { + if (collect.contains(TaskStatus.UNFINISHED.getCode())) { + collect = null; + unFinished = TaskStatus.EXECUTING.getCode(); + } + } LambdaQueryWrapper lam = new LambdaQueryWrapper<>(); lam.eq(ObjectUtil.isNotEmpty(task_code), SchBaseTask::getTask_code, task_code) .eq(ObjectUtil.isNotEmpty(vehicle_code), SchBaseTask::getVehicle_code, vehicle_code) @@ -63,6 +70,7 @@ public class SchBaseTaskServiceImpl extends ServiceImpl pages = new Page<>(page.getPage() + 1, page.getSize()); schBaseTaskMapper.selectPage(pages, lam); @@ -180,7 +188,7 @@ public class SchBaseTaskServiceImpl extends ServiceImpl() + .eq(SchBaseTaskconfig::getConfig_code, config_code)); taskDto.setPriority(taskConfig.getPriority()); taskDto.setTask_type(taskConfig.getAcs_task_type()); - taskDto.setRoute_plan_code("normal"); + taskDto.setRoute_plan_code(taskConfig.getRoute_plan_code()); return taskDto; } @@ -159,9 +160,10 @@ public abstract class AbstractTask { // 申请任务 SchBaseTask task = new SchBaseTask(); // 任务实体 String apply_point_code = param.getString("device_code"); - String config_code = "YZSKTask"; + String config_code = "HNMLTask"; // 1、校验数据 - SchBaseTaskconfig taskConfig = taskConfigService.getById(config_code); + SchBaseTaskconfig taskConfig = taskConfigService.getOne(new LambdaQueryWrapper() + .eq(SchBaseTaskconfig::getConfig_code, config_code)); // 最大任务数 Integer tcmn = taskConfig.getTask_create_max_num(); List unFinishTasksByTaskConfig = taskService diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/core/TaskStatus.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/core/TaskStatus.java index a6ad4c5..02ef58d 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/core/TaskStatus.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/core/TaskStatus.java @@ -6,7 +6,8 @@ public enum TaskStatus { ISSUED("3", "下发", "下发"), EXECUTING("4", "执行中", "执行中"), FINISHED("5", "完成", "完成"), - CANCELED("6", "已取消", "已取消"); + CANCELED("6", "已取消", "已取消"), + UNFINISHED("7", "未完成", "未完成"); TaskStatus(String code, String name, String desc) { diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNMLTask.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNMLTask.java index 6169122..65a003e 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNMLTask.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNMLTask.java @@ -18,6 +18,7 @@ import org.nl.wms.sch.task.service.ISchBaseTaskconfigService; import org.nl.wms.sch.task.service.dao.SchBaseTask; import org.nl.wms.sch.task.service.dao.SchBaseTaskconfig; import org.nl.wms.sch.task_manage.AbstractTask; +import org.nl.wms.sch.task_manage.enums.GroupBindMaterialStatusEnum; import org.nl.wms.sch.task_manage.enums.GroupStatusEnum; import org.nl.wms.sch.task_manage.enums.PointStatusEnum; import org.nl.wms.sch.task_manage.task.core.TaskStatus; @@ -79,7 +80,8 @@ public class HNMLTask extends AbstractTask { if (status.equals(TaskStatus.FINISHED)) { // 完成 PdmBdWorkorder workorderCode = ObjectUtil.isNotEmpty(extGroupData.getString("workorder_code")) - ? workorderService.getById(extGroupData.getString("workorder_code")) + ? workorderService.getOne(new LambdaQueryWrapper() + .eq(PdmBdWorkorder::getWorkorder_code, extGroupData.getString("workorder_code"))) : null; // 要把数据存到组盘表 SchBaseVehiclematerialgroup groupEntity = new SchBaseVehiclematerialgroup(); @@ -108,6 +110,7 @@ public class HNMLTask extends AbstractTask { groupEntity.setPcsn( DateUtil.format(DateUtil.date(), "yyyyMMdd")); groupEntity.setInstorage_time(DateUtil.now()); groupEntity.setTask_code(taskObj.getTask_code()); + groupEntity.setGroup_bind_material_status(GroupBindMaterialStatusEnum.BOUND.getValue()); // 绑定 groupEntity.setGroup_status(GroupStatusEnum.IN_STORAGE.getType()); // 暂时不维护。 groupEntity.setIs_delete(false); vehiclematerialgroupService.create(groupEntity); @@ -147,7 +150,8 @@ public class HNMLTask extends AbstractTask { // 获取任务 List tasks = taskService.findTasksByTaskStatus(TASK_CONFIG_CODE, TaskStatus.APPLY); // 配置信息 - SchBaseTaskconfig taskConfig = taskConfigService.getById(TASK_CONFIG_CODE); + SchBaseTaskconfig taskConfig = taskConfigService.getOne(new LambdaQueryWrapper() + .eq(SchBaseTaskconfig::getConfig_code, TASK_CONFIG_CODE)); for (SchBaseTask task : tasks) { List nextRegionStr = Arrays.stream(taskConfig.getNext_region_str().split(",")).collect(Collectors.toList()); String extGroupData = task.getExt_group_data(); diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNQKTask.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNQKTask.java index 8c9613a..e053751 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNQKTask.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/hn/HNQKTask.java @@ -86,7 +86,8 @@ public class HNQKTask extends AbstractTask { private SchBasePoint findStartPoint(List startRegionStr, JSONObject extGroupData) { String workorderCode = extGroupData.getString("workorder_code"); PdmBdWorkorder workOrder = ObjectUtil.isNotEmpty(workorderCode) - ? workorderService.getOne(new LambdaQueryWrapper().eq(PdmBdWorkorder::getWorkorder_code, workorderCode)) + ? workorderService.getOne(new LambdaQueryWrapper() + .eq(PdmBdWorkorder::getWorkorder_code, workorderCode)) : null; String vehicleType = ObjectUtil.isNotEmpty(workOrder) && ObjectUtil.isNotEmpty(workOrder.getVehicle_type()) ? workOrder.getVehicle_type() diff --git a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/yz/YZSKTask.java b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/yz/YZSKTask.java index fb58947..f34fcb4 100644 --- a/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/yz/YZSKTask.java +++ b/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/yz/YZSKTask.java @@ -84,7 +84,8 @@ public class YZSKTask extends AbstractTask { private SchBasePoint findNextPoint(List nextRegionStr, JSONObject extGroupData) { String workorderCode = extGroupData.getString("workorder_code"); PdmBdWorkorder workOrder = ObjectUtil.isNotEmpty(workorderCode) - ? workorderService.getOne(new LambdaQueryWrapper().eq(PdmBdWorkorder::getWorkorder_code, workorderCode)) + ? workorderService.getOne(new LambdaQueryWrapper() + .eq(PdmBdWorkorder::getWorkorder_code, workorderCode)) : null; String vehicleType = ObjectUtil.isNotEmpty(workOrder) && ObjectUtil.isNotEmpty(workOrder.getVehicle_type()) ? workOrder.getVehicle_type() diff --git a/nladmin-ui/src/views/wms/pdm/workerorder/index.vue b/nladmin-ui/src/views/wms/pdm/workerorder/index.vue index 9b20d3a..8ae630c 100644 --- a/nladmin-ui/src/views/wms/pdm/workerorder/index.vue +++ b/nladmin-ui/src/views/wms/pdm/workerorder/index.vue @@ -4,25 +4,60 @@
- - - - - + + + + + + + + + + + + + + + + + +
@@ -228,7 +263,11 @@ - + + + - - @@ -305,6 +316,7 @@ import crudOperation from '@crud/CRUD.operation' import udOperation from '@crud/UD.operation' import pagination from '@crud/Pagination' import crudMdBaseWorkShop from '@/views/wms/basedata/workshop/mdBaseWorkshop' +import ViewDialog from '@/views/wms/sch/point/ViewDialog.vue' const defaultForm = { point_code: null, @@ -340,7 +352,7 @@ const defaultForm = { export default { name: 'SchBasePoint', dicts: ['vehicle_type', 'TrueOrFalse'], - components: { pagination, crudOperation, rrOperation, udOperation }, + components: { ViewDialog, pagination, crudOperation, rrOperation, udOperation }, mixins: [presenter(), header(), form(defaultForm), crud()], cruds() { return CRUD({ @@ -453,6 +465,17 @@ export default { this.crud.notify('操作成功', CRUD.NOTIFICATION_TYPE.SUCCESS) this.crud.toQuery() }) + }, + showButton(point_status) { + if (point_status && point_status === '2') { + return true + } + return false + }, + toView(row) { + if (row) { + this.$refs.viewDialog.setParentData(row) + } } } } diff --git a/nladmin-ui/src/views/wms/sch/task/config/index.vue b/nladmin-ui/src/views/wms/sch/task/config/index.vue index e4e83c2..ff8a4a4 100644 --- a/nladmin-ui/src/views/wms/sch/task/config/index.vue +++ b/nladmin-ui/src/views/wms/sch/task/config/index.vue @@ -151,6 +151,20 @@ + + + + + @@ -211,6 +225,9 @@ + + + + + + +