Merge branch 'dev_fifo_z' into dev_2.5_optimize

# Conflicts:
#	src/main/java/com/glxp/api/entity/collect/IoCollectSet.java
#	src/main/java/com/glxp/api/service/inout/IoSplitFifoInvService.java
#	src/main/resources/schemas/schema_v2.4.sql
dev_2.5_optimize
wangwei 4 months ago
commit 46c3304a47

@ -434,9 +434,9 @@ public class LoginController extends BaseController {
@Value("${WEB_SUB_TITLE}")
private String WEB_SUB_TITLE;
@Value("${WEB_VERSION}")
@Value("${WEB_VERSION:}")
private String WEB_VERSION;
@Value("${WEB_LOGO}")
@Value("${WEB_LOGO:}")
private String WEB_LOGO;

@ -0,0 +1,134 @@
package com.glxp.api.controller.basic;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.github.pagehelper.PageInfo;
import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import com.glxp.api.controller.BaseController;
import com.glxp.api.entity.basic.SysWorkplaceRegion;
import com.glxp.api.entity.system.SysPdfTemplateRelevanceLabelEntity;
import com.glxp.api.entity.system.SystemPDFTemplateEntity;
import com.glxp.api.req.basic.SysWorkplaceFreightRequest;
import com.glxp.api.req.basic.SysWorkplaceRegionRequest;
import com.glxp.api.res.PageSimpleResponse;
import com.glxp.api.res.basic.SysWorkplaceFreightPrintResponse;
import com.glxp.api.res.basic.SysWorkplaceRegionResponse;
import com.glxp.api.service.basic.SysWorkplaceRegionService;
import com.glxp.api.util.JasperUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.*;
/**
* @author : zhuzhu
* @date : 2025/2/18 11:04
* @modyified By :
*/
@Slf4j
@RestController
public class SysWorkplaceRegionController extends BaseController {
@Resource
SysWorkplaceRegionService SysWorkplaceRegionService;
@GetMapping("/udiwms/sysWorkplaceRegion/getList")
public BaseResponse getUserBindWork(SysWorkplaceRegionRequest request) {
List<SysWorkplaceRegionResponse> regionResponses = SysWorkplaceRegionService.filterList(request);
PageInfo<SysWorkplaceRegionResponse> pageInfo = new PageInfo<>(regionResponses);
PageSimpleResponse<SysWorkplaceRegionResponse> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(regionResponses);
return ResultVOUtils.success(pageSimpleResponse);
}
@PostMapping("/udiwms/sysWorkplaceRegion/addRegion")
public BaseResponse addRegion(@RequestBody SysWorkplaceRegion sysWorkplaceRegion) {
SysWorkplaceRegion one = SysWorkplaceRegionService.isExist(sysWorkplaceRegion);
if (one != null){
return ResultVOUtils.error(500,"区域名称已存在或区域编码重复");
}
sysWorkplaceRegion.setId(IdUtil.getSnowflakeNextId());
sysWorkplaceRegion.setCreateTime(new Date());
sysWorkplaceRegion.setUpdateTime(new Date());
sysWorkplaceRegion.setCreateUser(getUserId() + "");
sysWorkplaceRegion.setUpdateUser(getUserId() + "");
SysWorkplaceRegionService.save(sysWorkplaceRegion);
return ResultVOUtils.success();
}
@PostMapping("/udiwms/sysWorkplaceRegion/editRegion")
public BaseResponse editRegion(@RequestBody SysWorkplaceRegionRequest request) {
SysWorkplaceRegion one = SysWorkplaceRegionService.getOne(new LambdaQueryWrapper<SysWorkplaceRegion>().eq(SysWorkplaceRegion::getRegionName,request.getRegionName()));
if (one != null){
return ResultVOUtils.error(500,"区域名称重复");
}
SysWorkplaceRegion sysWorkplaceRegion = new SysWorkplaceRegion();
sysWorkplaceRegion.setRegionName(request.getRegionName());
sysWorkplaceRegion.setId(request.getId());
sysWorkplaceRegion.setUpdateTime(new Date());
sysWorkplaceRegion.setUpdateUser(getUserId() + "");
SysWorkplaceRegionService.updateById(sysWorkplaceRegion);
return ResultVOUtils.success();
}
@PostMapping("/udiwms/sysWorkplaceRegion/delRegion")
public BaseResponse editRegion(@RequestBody SysWorkplaceRegion sysWorkplaceRegion) {
SysWorkplaceRegionService.removeById(sysWorkplaceRegion);
return ResultVOUtils.success();
}
@PostMapping("/udiwms/WorkplaceFreight/printRegion")
public BaseResponse printFreight(@RequestBody SysWorkplaceRegionRequest sysWorkplaceRegionRequest, HttpServletRequest request, HttpServletResponse response) throws Exception {
// SysPdfTemplateRelevanceLabelEntity sysPdfTemplateRelevanceLabelEntity = systemPDFModuleService.selectByLabelId(sysWorkplaceFreightRequest.getLabelId() + "");
// if (null == sysPdfTemplateRelevanceLabelEntity) {
// return ResultVOUtils.error(ResultEnum.DATA_NOT, "所属模块错误");
// }
//
// SystemPDFTemplateEntity systemPDFTemplateEntity = systemPDFTemplateService.selectById(String.valueOf(sysPdfTemplateRelevanceLabelEntity.getTemplateId()));
// if (null == systemPDFTemplateEntity) {
// return ResultVOUtils.error(ResultEnum.DATA_NOT, "模板错误");
// }
//
//// List<SysWorkplaceQueue> sysWorkplaceQueues = sysWorkplaceQueueService.list(new LambdaQueryWrapper<SysWorkplaceQueue>().eq(SysWorkplaceQueue::getWorkPlaceIdFk, sysWorkplaceFreightRequest.getWorkplaceId()));
// List<SysWorkplaceFreightPrintResponse> responses = sysWorkplaceFreightService.getList(sysWorkplaceFreightRequest);
//
// Map<String, Object> data = new HashMap<>(1);
// List<Object> list = new ArrayList<>();
// int i = 1;
// if (responses != null && responses.size() > 0) {
// for (SysWorkplaceFreightPrintResponse obj : responses) {
// if (obj.getQueueCode() != null && obj.getQueueCode()!= ""){
// Map<String, Object> supData = new HashMap<>();
// supData.put("name", obj.getRemark() + "");
// supData.put("code", obj.getQueueCode());
// supData.put("workplaceName", obj.getWorkPlaceName());
// list.add(supData);
// i++;
// }
// }
// }
// data.put("data",list);
// String param = JSON.toJSONString(data);
// JasperUtils.jasperReport(request, response, param, filePath + "pdf/template/" + systemPDFTemplateEntity.getPath(), "pdf");
//
return ResultVOUtils.error(ResultEnum.DATA_NOT, "模板错误");
}
}

@ -131,6 +131,7 @@ public class IoPurChangeService {
purPlanEntity.setApplyBillNo(purApplyEntity.getBillNo());
purPlanEntity.setApplyRemark(purApplyEntity.getRemark());
purPlanEntity.setPageType(purApplyEntity.getPageType());
purPlanEntity.setProductType(purApplyEntity.getProductType());
if (basicBusTypeChangeEntity.getBusBeforeTime() != null) {
purPlanEntity.setCreateTime(MsDateUtil.timeProcess(purApplyEntity.getCreateTime(), basicBusTypeChangeEntity.getBusBeforeTime()));
purPlanEntity.setUpdateTime(MsDateUtil.timeProcess(purApplyEntity.getCreateTime(), basicBusTypeChangeEntity.getBusBeforeTime()));
@ -240,6 +241,7 @@ public class IoPurChangeService {
purOrderEntity.setBillType(ConstantStatus.BUS_ORDER_CGDD);
purOrderEntity.setPurPlanId(purPlanEntity.getBillNo());
purOrderEntity.setPageType(purPlanEntity.getPageType());
purOrderEntity.setProductType(purPlanEntity.getProductType());
if (basicBusTypeChangeEntity.getBusBeforeTime() != null) {
purOrderEntity.setCreateTime(MsDateUtil.timeProcess(new Date(), basicBusTypeChangeEntity.getBusBeforeTime()));
purOrderEntity.setUpdateTime(new Date());

@ -17,4 +17,6 @@ public interface SysWorkplaceFreightMapper extends BaseMapper<SysWorkplaceFreigh
List<SysWorkplaceFreightResponse> filterList(SysWorkplaceFreightRequest request);
List<SysWorkplaceFreightPrintResponse> getList(SysWorkplaceFreightRequest sysWorkplaceFreightRequest);
SysWorkplaceFreight selectMaxCode();
}

@ -0,0 +1,19 @@
package com.glxp.api.dao.basic;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.glxp.api.entity.basic.SysWorkplaceRegion;
import com.glxp.api.req.basic.SysWorkplaceRegionRequest;
import com.glxp.api.res.basic.SysWorkplaceRegionResponse;
import java.util.List;
/**
* @author : zhangsan
* @date : 2025/2/18 11:02
* @modyified By :
*/
public interface SysWorkplaceRegionMapper extends BaseMapper<SysWorkplaceRegion> {
List<SysWorkplaceRegionResponse> filterList(SysWorkplaceRegionRequest request);
}

@ -27,6 +27,14 @@ public class SysWorkplaceLayer implements Serializable {
@ApiModelProperty(value = "货位编码")
private String code;
/**
*
*/
@TableField(value = "name")
@ApiModelProperty(value = "")
private String name;
/**
*
*/

@ -0,0 +1,70 @@
package com.glxp.api.entity.basic;
import java.io.Serializable;
import java.util.Date;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@ApiModel(description = "sys_workplace_region")
@Data
@TableName(value = "sys_workplace_region")
public class SysWorkplaceRegion implements Serializable {
/**
*
*/
@TableId(value = "id", type = IdType.INPUT)
@ApiModelProperty(value = "")
private Long id;
/**
*
*/
@TableField(value = "regionCode")
@ApiModelProperty(value = "区域编号")
private Integer regionCode;
/**
*
*/
@TableField(value = "regionName")
@ApiModelProperty(value = "区域名称")
private String regionName;
/**
*
*/
@TableField(value = "updateTime")
@ApiModelProperty(value = "")
private Date updateTime;
/**
*
*/
@TableField(value = "createTime")
@ApiModelProperty(value = "")
private Date createTime;
/**
*
*/
@TableField(value = "updateUser")
@ApiModelProperty(value = "")
private String updateUser;
/**
*
*/
@TableField(value = "createUser")
@ApiModelProperty(value = "")
private String createUser;
private static final long serialVersionUID = 1L;
}

@ -50,6 +50,8 @@ public class SysWorkplaceLayerRequest extends ListPageRequest {
private String name;
private String layerName;

@ -0,0 +1,26 @@
package com.glxp.api.req.basic;
import com.baomidou.mybatisplus.annotation.TableField;
import com.glxp.api.util.page.ListPageRequest;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author : zhuzhu
* @date : 2025/2/18 11:08
* @modyified By :
*/
@Data
public class SysWorkplaceRegionRequest extends ListPageRequest {
private Integer regionCode;
private String regionName;
private Long id;
private String LabelId;
}

@ -76,5 +76,7 @@ public class SysWorkplaceLayerResponse {
@ApiModelProperty(value = "")
private Integer height;
private String name;
private List<SysWorkplaceQueue> sysWorkplaceQueues;
}

@ -0,0 +1,41 @@
package com.glxp.api.res.basic;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* @author : zhuzhu
* @date : 2025/2/18 11:09
* @modyified By :
*/
@Data
public class SysWorkplaceRegionResponse {
private Long id;
/**
*
*/
private Integer regionCode;
/**
*
*/
private String regionName;
private Date updateTime;
private Date createTime;
private String updateUser;
private String createUser;
}

@ -97,4 +97,5 @@ public class PurApplyResponse {
private Integer pageType;
private Integer productType;
}

@ -72,17 +72,17 @@ public class SysWorkplaceFreightService extends ServiceImpl<SysWorkplaceFreightM
public String createQueueCode() {
String code;
SysWorkplaceFreight sysWorkplaceQueue = sysWorkplaceFreightMapper.selectOne(new LambdaQueryWrapper<SysWorkplaceFreight>().orderByDesc(SysWorkplaceFreight::getCode).last("LIMIT 1"));
SysWorkplaceFreight sysWorkplaceQueue = sysWorkplaceFreightMapper.selectMaxCode();
if (sysWorkplaceQueue == null){
//没有数据 新增
code = "DMQ00" + 1;
}else {
String code1 = sysWorkplaceQueue.getCode();
String withoutDMQ = code1.replace("DMQ", "");
String withoutDMQ = code1.replace("DMQ00", "");
Integer result = Integer.parseInt(withoutDMQ.trim());
result += 1;
String sixDigitResult = String.format("%03d", result);
code = "DMQ" + sixDigitResult;
// String sixDigitResult = String.format("%03d", result);
code = "DMQ00" + result;
}
return code;
}

@ -1,5 +1,6 @@
package com.glxp.api.service.basic;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
@ -100,6 +101,9 @@ public class SysWorkplaceLayerService extends ServiceImpl<SysWorkplaceLayerMappe
sysWorkplaceQueueService.addLayer(sysWorkplaceQueueRequest, userId);
}
workplaceLayer.setQueueNum(newQueueNum);
if (StrUtil.isNotEmpty(request.getLayerName())){
workplaceLayer.setName(request.getLayerName());
}
// workplaceLayer.setHeight(50);
workplaceLayer.setUpdateTime(new Date());
workplaceLayer.setUpdateUser(userId + "");
@ -110,6 +114,9 @@ public class SysWorkplaceLayerService extends ServiceImpl<SysWorkplaceLayerMappe
BeanUtils.copyProperties(request, sysWorkplaceLayer);
initLayer(sysWorkplaceLayer, userId);
sysWorkplaceLayer.setHeight(50);
if (StrUtil.isNotEmpty(request.getLayerName())){
workplaceLayer.setName(request.getLayerName());
}
sysWorkplaceLayerMapper.insert(sysWorkplaceLayer);
//增加卡槽
Integer queueNum = request.getQueueNum();

@ -254,5 +254,9 @@ public class SysWorkplaceQueueService extends ServiceImpl<SysWorkplaceQueueMappe
return sortedRespList;
}
public String selectMaxCodeByLayerCode(String layerCode) {
return sysWorkplaceQueueMapper.selectMaxCode(layerCode);
}
}

@ -0,0 +1,40 @@
package com.glxp.api.service.basic;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.glxp.api.dao.basic.SysWorkplaceRegionMapper;
import com.glxp.api.entity.basic.SysWorkplaceRegion;
import com.glxp.api.req.basic.SysWorkplaceRegionRequest;
import com.glxp.api.res.basic.SysWorkplaceRegionResponse;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
@Service
public class SysWorkplaceRegionService extends ServiceImpl<SysWorkplaceRegionMapper, SysWorkplaceRegion> {
@Resource
SysWorkplaceRegionMapper sysWorkplaceRegionMapper;
public List<SysWorkplaceRegionResponse> filterList(SysWorkplaceRegionRequest request) {
if (null == request) {
return Collections.emptyList();
}
if (null != request.getPage() && null != request.getLimit()) {
PageHelper.offsetPage((request.getPage() - 1) * request.getLimit(), request.getLimit());
}
return super.baseMapper.filterList(request);
}
public SysWorkplaceRegion isExist(SysWorkplaceRegion sysWorkplaceRegion) {
return getOne(new LambdaQueryWrapper<SysWorkplaceRegion>()
.eq(SysWorkplaceRegion::getRegionCode, sysWorkplaceRegion.getRegionCode())
.or()
.eq(SysWorkplaceRegion::getRegionName, sysWorkplaceRegion.getRegionName()));
}
}

@ -1,6 +1,7 @@
package com.glxp.api.service.collect;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
@ -8,6 +9,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import com.glxp.api.dao.collect.IoCollectLedGroupMapper;
import com.glxp.api.entity.basic.SysWorkplaceQueue;
import com.glxp.api.entity.collect.IoCollectLedGroup;
@ -15,10 +17,12 @@ import com.glxp.api.entity.collect.IoCollectOrder;
import com.glxp.api.entity.collect.IoCollectOrderBiz;
import com.glxp.api.entity.collect.SysOrderLed;
import com.glxp.api.entity.thrsys.CodeRel;
import com.glxp.api.entity.thrsys.ThrManufacturerEntity;
import com.glxp.api.enums.led.LedColorStatusEnum;
import com.glxp.api.exception.JsonException;
import com.glxp.api.req.collect.CollectLedGroupRequest;
import com.glxp.api.req.collect.LedGroupRequest;
import com.glxp.api.res.PageSimpleResponse;
import com.glxp.api.res.collect.IoCollectLedGroupResponse;
import com.glxp.api.service.basic.SysWorkplaceQueueService;
import com.glxp.api.util.IntUtil;
@ -73,6 +77,7 @@ public class IoCollectLedGroupService extends ServiceImpl<IoCollectLedGroupMappe
IoCollectOrderBizService collectOrderBizService;
public BaseResponse<String> openLed(List<IoCollectOrderBiz> collectOrderBizs) {
log.error("获取灯组==============");
LedGroupRequest ledGroupRequest = new LedGroupRequest();
for (IoCollectOrderBiz collectOrderBiz : collectOrderBizs) {
@ -113,11 +118,17 @@ public class IoCollectLedGroupService extends ServiceImpl<IoCollectLedGroupMappe
String json = JSONUtil.toJsonStr(ledGroupRequest);
log.error("json:{}" + json);
String result = okHttpCli.doPostJson("http://192.168.0.166:9099/wms/associate/lighttagsled", json);
BaseResponse<String> response =
JSONObject.parseObject(result, new TypeReference<BaseResponse<String>>() {
});
return response;
try {
String result = okHttpCli.doPostJson("http://192.168.0.166:9099/wms/associate/lighttagsled", json);
BaseResponse<String> response =
JSONObject.parseObject(result, new TypeReference<BaseResponse<String>>() {
});
return response;
} catch (Exception e) {
log.error("灯组获取异常", e);
return ResultVOUtils.error(500, "连接灯组异常!");
}
}

@ -5,6 +5,8 @@ import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.glxp.api.annotation.Log;
import com.glxp.api.common.util.ResultVOUtils;
import com.glxp.api.constant.Constant;
import com.glxp.api.constant.ConstantStatus;
import com.glxp.api.constant.ConstantType;
@ -35,6 +37,7 @@ import com.glxp.api.util.IntUtil;
import com.glxp.api.util.OrderNoTypeBean;
import com.glxp.api.util.udi.FilterUdiUtils;
import com.glxp.api.util.udi.UdiCalCountUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@ -54,6 +57,7 @@ import static com.glxp.api.constant.ConstantStatus.ORDER_STATUS_CHECK_PROCESS;
*/
@Service
@Transactional(rollbackFor = Exception.class)
@Slf4j
public class IoCheckInoutService {
@Resource
@ -138,13 +142,19 @@ public class IoCheckInoutService {
public void check(String orderId) {
IoOrderEntity orderEntity = orderService.findByBillNo(orderId);
//过滤非未校验或校验异常
log.error("修改订单当前状态 带校验");
if (orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_CHECK_PROCESS &&
orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_CHECK && orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_CHECK_FAIL)
return;
orderEntity.setStatus(ORDER_STATUS_CHECK_PROCESS);
orderEntity.setDealStatus(ConstantStatus.ORDER_DEAL_POST);
orderService.update(orderEntity);
try {
orderEntity.setStatus(ORDER_STATUS_CHECK_PROCESS);
orderEntity.setDealStatus(ConstantStatus.ORDER_DEAL_POST);
int update = orderService.update(orderEntity);
log.error("修改订单结果========:::::::" + update);
} catch (Exception e) {
e.printStackTrace();
}
log.error("修改订单");
BasicBussinessTypeEntity bussinessTypeEntity = basicBussinessTypeService.findByAction(orderEntity.getAction());
if (!bussinessTypeEntity.isCheckEnable()) {
unCheckFirstFinish(orderEntity);
@ -529,7 +539,7 @@ public class IoCheckInoutService {
* @param orderEntity
*/
public void unCheckFirstFinish(IoOrderEntity orderEntity) {
log.error("进入了 一次校验(无需校验)完成");
List<IoOrderDetailCodeEntity> orderDetailCodeEntities = orderDetailCodeService.findByOrderId(orderEntity.getBillNo());
if (CollUtil.isEmpty(orderDetailCodeEntities)) {
@ -543,8 +553,10 @@ public class IoCheckInoutService {
if (orderEntity.getFromType() != ConstantStatus.FROM_UDISP) {
if (orderEntity.getFromType() != ConstantStatus.FROM_COPY
&& orderEntity.getFromType() != ConstantStatus.FROM_CHANGE) {
log.error("进入了 一次校验(无需校验)完成 2");
orderDetailBizService.deleteByOrderId(orderEntity.getBillNo());
}
log.error("进入了 一次校验(无需校验)完成 3");
orderDetailResultService.deleteByOrderId(orderEntity.getBillNo());
if (!orderDetailBizService.isExit(orderEntity.getBillNo())) {
orderDetailCodeEntities.forEach(orderDetailCodeEntity ->
@ -557,6 +569,7 @@ public class IoCheckInoutService {
orderDetailBizService.insert(orderDetailBizEntity);
});
log.error("进入了 一次校验(无需校验)完成 4");
}
orderDetailCodeEntities.forEach(orderDetailCodeEntity ->
{
@ -574,10 +587,12 @@ public class IoCheckInoutService {
orderDetailResultService.insert(orderDetailResultEntity);
});
log.error("进入了 一次校验(无需校验)完成 5");
}
//临时表转正式表
List<IoCodeTempEntity> codeTempEntities = codeTempService.findByOrderId(orderEntity.getBillNo());
log.error("进入了 一次校验(无需校验)完成 6");
for (IoCodeTempEntity codeTempEntity : codeTempEntities) {
IoCodeEntity codeEnttity = new IoCodeEntity();
BeanUtils.copyProperties(codeTempEntity, codeEnttity);
@ -593,6 +608,7 @@ public class IoCheckInoutService {
codeEnttity.setId(null);
codeService.insert(codeEnttity);
}
log.error("进入了 一次校验(无需校验)完成 7");
codeTempService.deleteByBillNo(orderEntity.getBillNo());
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK_SUCCESS);
orderEntity.setDealStatus(ConstantStatus.ORDER_DEAL_POST);

@ -26,6 +26,7 @@ import com.glxp.api.service.collect.IoSplitFifoInvRelService;
import com.glxp.api.service.thrsys.SysWorkplacePutRelService;
import com.glxp.api.util.IntUtil;
import org.apache.xpath.operations.Bool;
import org.aspectj.weaver.ast.Var;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
@ -159,17 +160,19 @@ public class IoSplitFifoInvService extends ServiceImpl<IoSplitFifoInvMapper, IoS
if (queues.size() == 0) {
throw new JsonException(500, "请增加取货槽");
}
// 直接根据 workPlaceCode 增加一个槽位
SysWorkplaceQueue workplaceQueue = queues.get(0);
// 使用流来过滤掉匹配的元素
List<SysWorkplaceQueue> filteredQueues = queues.stream().filter(queue -> {
IoSplitFifoInv one = getOne(new LambdaQueryWrapper<IoSplitFifoInv>().eq(IoSplitFifoInv::getWorkPlaceQueueCode, queue.getCode()));
return one == null; // 只保留那些没有匹配的槽位
}).sorted((queue1, queue2) -> queue1.getCode().compareTo(queue2.getCode())).collect(Collectors.toList());
if (filteredQueues.size() > 0) {
//还有剩余的槽位 可分配
SysWorkplaceQueue sysWorkplaceQueue = filteredQueues.get(0);
return sysWorkplaceQueue.getCode();
} else {
// // 使用流来过滤掉匹配的元素
// List<SysWorkplaceQueue> filteredQueues = queues.stream()
// .filter(queue -> {
// IoSplitFifoInv one = getOne(
// new LambdaQueryWrapper<IoSplitFifoInv>()
// .eq(IoSplitFifoInv::getWorkPlaceQueueCode, queue.getCode())
// );
// return one == null; // 只保留那些没有匹配的槽位
// })
// .sorted((queue1, queue2) -> queue1.getCode().compareTo(queue2.getCode()))
// .collect(Collectors.toList());
//增加一个槽位
SysWorkplaceLayer layer = sysWorkplaceLayerService.getOne(new LambdaQueryWrapper<SysWorkplaceLayer>().eq(SysWorkplaceLayer::getCode, workplaceQueue.getLayerCode()));
SysWorkplaceLayerRequest sysWorkplaceLayerRequest = new SysWorkplaceLayerRequest();
@ -178,8 +181,8 @@ public class IoSplitFifoInvService extends ServiceImpl<IoSplitFifoInvMapper, IoS
sysWorkplaceLayerRequest.setWorkPlaceIdFk(workPlaceCode);
sysWorkplaceLayerRequest.setQueueNum(layer.getQueueNum() + 1);
sysWorkplaceLayerService.addSysWorkplaceLayer(sysWorkplaceLayerRequest, Long.valueOf(userId));
}
return setQueueCode(workPlaceCode, userId);
String queueCode = sysWorkplaceQueueService.selectMaxCodeByLayerCode(workplaceQueue.getLayerCode());
return queueCode;
}
@Resource

@ -66,4 +66,10 @@
</where>
order by swf.code,swl.code, swq.code
</select>
<select id="selectMaxCode" resultType="com.glxp.api.entity.basic.SysWorkplaceFreight">
SELECT *
from sys_workplace_freight
ORDER BY CAST(SUBSTRING(code, 6) AS UNSIGNED) DESC
LIMIT 1
</select>
</mapper>

@ -171,7 +171,7 @@
</where>
</select>
<select id="selectMaxCode" resultType="java.lang.String">
select max(code) as code
SELECT MAX(CAST(SUBSTRING_INDEX(code, '-', -1) AS UNSIGNED)) AS code
from sys_workplace_queue
<where>
<if test="layerCode != null and layerCode != ''">
@ -187,7 +187,7 @@
AND layerCode = #{layerCode}
</if>
</where>
ORDER BY code DESC
ORDER BY CAST(SUBSTRING_INDEX(code, '-', -1) AS UNSIGNED) DESC
LIMIT 1
</select>

@ -0,0 +1,16 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.glxp.api.dao.basic.SysWorkplaceRegionMapper">
<select id="filterList" resultType="com.glxp.api.res.basic.SysWorkplaceRegionResponse">
select swr.*
from sys_workplace_region swr
<where>
<if test="regionCode != '' and regionCode != null">
AND swr.regionCode =#{regionCode}
</if>
<if test="regionName != null and regionName != ''">
AND swr.regionName like concat('%', #{regionName}, '%')
</if>
</where>
</select>
</mapper>

@ -675,22 +675,25 @@
</if>
<if test="filterType != null and filterType == 1 and productsType == 1">
AND (thirdId <![CDATA[<>]]> '' or thirdId1 <![CDATA[<>]]> '' or thirdId2 <![CDATA[<>]]> '' or
thirdId3 <![CDATA[<>]]> '' or thirdId4 <![CDATA[<>]]> '')
thirdId3 <![CDATA[<>]]> '' or thirdId4 <![CDATA[<>]]> '')
and basic_products.originUuid <![CDATA[<>]]> ''
</if>
<if test="filterType != null and filterType == 1 and productsType == 2">
AND (thirdId <![CDATA[<>]]> '' or thirdId1 <![CDATA[<>]]> '' or thirdId2 <![CDATA[<>]]> '' or
thirdId3 <![CDATA[<>]]> '' or thirdId4 <![CDATA[<>]]> '')
and mainId <![CDATA[<>]]> ''
AND (thirdId is not null or thirdId1 is not null)
</if>
<if test="filterType != null and filterType == 1 and productsType == 2">
AND basic_products.nameCode is not null
</if>
<if test="filterType != null and filterType == 2 and productsType == 1">
AND basic_products.originUuid is NULL
</if>
<if test="filterType != null and filterType == 2 and productsType == 2">
AND ((thirdId = '' or thirdId is null) or (thirdId1 = '' or thirdId1 is null)
or (thirdId2 = '' or thirdId2 is null) or (thirdId3 = '' or thirdId3 is null)
or (thirdId4 = '' or thirdId4 is null))
AND (mainId = '' or mainId is null)
AND ((thirdId = '' or thirdId is null) or (thirdId1 = '' or thirdId1 is null)
)
</if>
<if test="filterType != null and filterType == 2 and productsType == 2">
AND ( (mainId = '' or mainId is null) or (basic_products.nameCode = '' or basic_products.nameCode is null)
)
</if>
<if test="filterType != null and filterType == 3">
AND (mainId is NULL or mainId = '')

@ -5236,6 +5236,37 @@ CALL Pro_Temp_ColumnWork('io_collect_set', 'ipcMaxCount',
'int NULL DEFAULT NULL COMMENT ''PDA扫码数量''',
1);
CALL Pro_Temp_ColumnWork('io_collect_set', 'fixedCount',
'int NULL DEFAULT NULL COMMENT ''高拍仪扫码数量''',
1);
CALL Pro_Temp_ColumnWork('io_collect_set', 'autoDecode',
'tinyint NULL DEFAULT NULL COMMENT ''高拍仪是否自动解码 1:自动 0:手动''',
1);
CALL Pro_Temp_ColumnWork('io_collect_set', 'outputMode',
'tinyint NULL DEFAULT NULL COMMENT ''高拍仪输出顺序 0不排序1从左到右2从右到左3从上到下4从下到上。''',
1);
CREATE TABLE IF NOT EXISTS `sys_workplace_region`
(
`id` bigint NOT NULL,
`regionCode` int NULL DEFAULT NULL COMMENT '区域编号',
`regionName` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '区域名称',
`updateTime` datetime NULL DEFAULT NULL,
`createTime` datetime NULL DEFAULT NULL,
`updateUser` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
`createUser` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB
AUTO_INCREMENT = 8052
CHARACTER SET = utf8mb4
COLLATE = utf8mb4_0900_ai_ci
COMMENT = '槽位区域表'
ROW_FORMAT = Dynamic;
ALTER TABLE rel_code_batch
MODIFY COLUMN `batchNo` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '批次号';
CREATE TABLE IF NOT EXISTS `inv_product_batch` (
`id` int NOT NULL AUTO_INCREMENT,

Loading…
Cancel
Save