root/wq-wms-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add:生产下料同步

Browse Source
This commit is contained in:
zhangzq
2026-06-17 13:22:38 +08:00
parent 189ec73c73 7b962b0bfa
commit 64174b4109
32 changed files with 512 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
nladmin-system/wms-server/src/main/java/org/nl/common/utils/SecurityUtils.java
View File

@@ -25,7 +25,7 @@ public class SecurityUtils {
public static CurrentUser getCurrentUser() {
Object loginInfo = StpUtil.getExtra("loginInfo");
if (loginInfo==null){
throw new BadRequestException("用户信息获取失败");
return CurrentUser.getDefaultUser();
}
return JSONObject.parseObject(String.valueOf(loginInfo),CurrentUser.class);
@@ -46,13 +46,7 @@ public class SecurityUtils {
* @return 系统用户名称
*/
public static String getCurrentNickName() {
// CurrentUser user = getCurrentUser();
// if (user!=null){
// return user.getPresonName();
// }
// return null;
//tofix postMan测试，完成后改回
return "admin";
return getCurrentUser().getPresonName();
}
/**
@@ -61,9 +55,7 @@ public class SecurityUtils {
* @return 系统用户Id
*/
public static String getCurrentUserId() {
//return getCurrentUser().getId();
//tofix postMan测试，完成后改回
return "1";
return getCurrentUser().getId();
}
/**
@@ -72,7 +64,6 @@ public class SecurityUtils {
*/
@Deprecated
public static Long getDeptId() {
// return getCurrentUser().getUser().getDept().getId();
return 1L;
}

2
nladmin-system/wms-server/src/main/java/org/nl/common/utils/dto/CurrentUser.java
View File

@@ -40,7 +40,7 @@ public class CurrentUser implements Serializable {
CurrentUser def = new CurrentUser();
def.setId("2");
def.setUsername("default");
def.setPresonName("外部系统用户");
def.setPresonName("默认用户");
return def;
}
}

15
nladmin-system/wms-server/src/main/java/org/nl/config/PrinterProperties.java Normal file
View File

@@ -0,0 +1,15 @@
package org.nl.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@Data
@Configuration
@ConfigurationProperties("printer")
public class PrinterProperties {
private String ip = "192.168.1.100";
private int port = 9100;
}

40
nladmin-system/wms-server/src/main/java/org/nl/wms/ext_manage/controller/MesStructLineController.java Normal file
View File

@@ -0,0 +1,40 @@
package org.nl.wms.ext_manage.controller;
import cn.dev33.satoken.annotation.SaIgnore;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.nl.wms.ext_manage.service.dto.StructLineOfflineDTO;
import org.nl.wms.sch_manage.service.core.tasks.StructOfflineTask;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* MES需求单同步接口
*/
@Slf4j
@RestController
@RequestMapping("api/mes/structLine")
@RequiredArgsConstructor
public class MesStructLineController {
@Autowired
private StructOfflineTask structOfflineTask;
/**
* 结构车间生产下料同步接口
* @param structLineOffline
* @return
*/
@PostMapping("/offline")
@SaIgnore
public ResponseEntity<Object> confirm(@RequestBody StructLineOfflineDTO structLineOffline) {
structOfflineTask.offline(structLineOffline);
return new ResponseEntity<>(HttpStatus.OK);
}
}

3
nladmin-system/wms-server/src/main/java/org/nl/wms/ext_manage/purchase/service/impl/InboundEasSyncServiceImpl.java
View File

@@ -64,16 +64,17 @@ public class InboundEasSyncServiceImpl implements InboundEasSyncService {
easMst.setBill_status(PurchaseBillStatus.CREATED.getCode());
easMst.setModify_date(DateUtil.now());
purchasemstMapper.insert(easMst);
for (Purchasedtl dtl : easDtlList) {
purchasedtlMapper.insert(dtl);
if (dtl.getHouse_code().contains("ZDLK")){
//中鼎立库
easMst.setForwardZD(1);
//TODO 转发中鼎参数待确定
wmsToZDWmdService.syncPurchaseReceiving(new JSONObject());
}
}
purchasemstMapper.insert(easMst);
log.info("EAS采购入库单同步完成, billId: {}, 明细数: {}", billId, easDtlList.size());
JSONObject result = new JSONObject();

51
nladmin-system/wms-server/src/main/java/org/nl/wms/ext_manage/service/dto/StructLineOfflineDTO.java Normal file
View File

@@ -0,0 +1,51 @@
package org.nl.wms.ext_manage.service.dto;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;
import java.math.BigDecimal;
@Data
public class StructLineOfflineDTO {
/**
* 产线编码
*/
@JsonProperty("LineCode")
private String lineCode;
/**
* 下料位置
*/
@JsonProperty("UnloadPort")
private String unloadPort;
/**
* 工单编码
*/
@JsonProperty("OrderCode")
private String orderCode;
/**
* 下料数量
*/
@JsonProperty("UnloadQty")
private BigDecimal unloadQty;
/**
* 物料编码
*/
@JsonProperty("MaterialCode")
private String materialCode;
/**
* 物料名称
*/
@JsonProperty("MaterialName")
private String materialName;
/**
* 创建时间
*/
@JsonProperty("CreatedOn")
private String createdOn;
}

7
nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/purchase/controller/PurchaseController.java
View File

@@ -63,4 +63,11 @@ public class PurchaseController {
purchaseService.issueReturnBill(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
@PostMapping("/print")
@Log("打印采购入库单")
public ResponseEntity<Object> print(@RequestBody Set<String> ids) {
purchaseService.print(ids);
return new ResponseEntity<>(HttpStatus.OK);
}
}

2
nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/purchase/service/PurchaseService.java
View File

@@ -32,5 +32,7 @@ public interface PurchaseService extends IService<Purchasemst> {
List<Purchasedtl> selectListByBillId(String billId);
void print(Set<String> ids);
List<PurchaseMatInfoVo> selectPdaInMat(HashMap of);
}

2
nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/purchase/service/dao/Purchasemst.java
View File

@@ -23,6 +23,8 @@ public class Purchasemst implements Serializable {
private String order_type;
private Integer forwardZD;
private String supplier_code;
private String supplier_name;

1
nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/purchase/service/dao/mapper/xml/PurchasemstMapper.xml
View File

@@ -8,6 +8,7 @@
m.bill_id,
m.order_no,
m.order_type,
m.forwardZD,
m.supplier_code,
m.supplier_name,
m.creator,

40
nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/purchase/service/impl/PurchaseServiceImpl.java
View File

@@ -28,10 +28,15 @@ import org.nl.wms.warehouse_manage.enums.IOSEnum;
import org.nl.wms.warehouse_manage.stockReturn.service.IPmStockReturnService;
import org.nl.wms.warehouse_manage.stockReturn.service.dao.PmStockReturn;
import org.nl.wms.warehouse_manage.stockReturn.service.enums.StockReturnStatusEnum;
import org.nl.config.PrinterProperties;
import org.nl.wms.pm_manage.purchase.util.ZplUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.io.OutputStream;
import java.net.Socket;
import java.nio.charset.StandardCharsets;
import java.util.*;
@Slf4j
@@ -50,6 +55,9 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchasemstMapper, Purchase
@Autowired
private WmsToErpService wmsToErpService;
@Autowired
private PrinterProperties printerProperties;
@Override
public IPage<PurchasemstListVo> queryAll(Map whereJson, PageQuery page) {
return purchasemstMapper.queryAllByPage(
@@ -192,6 +200,38 @@ public class PurchaseServiceImpl extends ServiceImpl<PurchasemstMapper, Purchase
}
}
@Override
public void print(Set<String> ids) {
List<Purchasemst> mstList = purchasemstMapper.selectBatchIds(ids);
if (ObjectUtil.isEmpty(mstList)) {
throw new BadRequestException("未找到选中的单据");
}
StringBuilder allZpl = new StringBuilder();
int labelCount = 0;
for (Purchasemst mst : mstList) {
List<Purchasedtl> dtlList = purchasedtlMapper.selectList(
new LambdaQueryWrapper<Purchasedtl>()
.eq(Purchasedtl::getBill_id, mst.getBill_id()));
for (Purchasedtl dtl : dtlList) {
String zpl = ZplUtil.generateLabel(
dtl.getSku_name(), dtl.getSku_code(),
dtl.getQty() != null ? dtl.getQty().stripTrailingZeros().toPlainString() : "0",
dtl.getUnit(), mst.getBill_id(), dtl.getItem_no());
allZpl.append(zpl);
labelCount++;
}
}
try (Socket socket = new Socket(printerProperties.getIp(), printerProperties.getPort());
OutputStream out = socket.getOutputStream()) {
out.write(allZpl.toString().getBytes(StandardCharsets.UTF_8));
out.flush();
} catch (Exception e) {
log.error("打印失败, 打印机: {}:{}, 标签数: {}", printerProperties.getIp(), printerProperties.getPort(), labelCount, e);
throw new BadRequestException("打印机连接失败: " + e.getMessage());
}
log.info("打印成功, 打印机: {}:{}, 标签数: {}", printerProperties.getIp(), printerProperties.getPort(), labelCount);
}
@Override
public List<PurchaseMatInfoVo> pdaInboundSelectMatInfo(Map whereJson) {
return purchasemstMapper.selectPdaInMat(whereJson);

2
nladmin-system/wms-server/src/main/java/org/nl/wms/pm_manage/purchase/service/vo/PurchasemstListVo.java
View File

@@ -13,6 +13,8 @@ public class PurchasemstListVo {
private String order_type;
private Integer forwardZD;
private String supplier_code;
private String supplier_name;

1
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/ISchBasePointService.java
View File

@@ -83,6 +83,7 @@ public interface ISchBasePointService extends IService<SchBasePoint> {
* @return SchBasePoint
*/
SchBasePoint selectByIdLock(String id);
SchBasePoint selectByCode(String code);
/**
* 释放点位

6
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/AbstractTask.java
View File

@@ -171,11 +171,5 @@ public abstract class AbstractTask {
*/
public abstract void cancel(String task_code);
/**
* 回传mes
* @param task_code 任务号
*/
public abstract void backMes(String task_code);
}

4
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/BackInTask.java
View File

@@ -130,9 +130,7 @@ public class BackInTask extends AbstractTask {
this.cancelTask(taskObj);
}
@Override
public void backMes(String task_code) {
}
@Transactional
public void finishTask(SchBaseTask taskObj) {

4
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/MoveTask.java
View File

@@ -129,9 +129,7 @@ public class MoveTask extends AbstractTask {
this.cancelTask(taskObj);
}
@Override
public void backMes(String task_code) {
}
@Transactional
public void finishTask(SchBaseTask taskObj) {

4
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/PdaPointTask.java
View File

@@ -130,9 +130,7 @@ public class PdaPointTask extends AbstractTask {
this.cancelTask(taskObj);
}
@Override
public void backMes(String task_code) {
}
@Transactional
public void finishTask(SchBaseTask taskObj) {

5
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/StInTask.java
View File

@@ -129,10 +129,7 @@ public class StInTask extends AbstractTask {
this.cancelTask(taskObj);
}
@Override
public void backMes(String task_code) {
}
@Transactional(rollbackFor = Exception.class)
public void finishTask(SchBaseTask taskObj) {

4
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/StOutTask.java
View File

@@ -125,9 +125,7 @@ public class StOutTask extends AbstractTask {
this.cancelTask(taskObj);
}
@Override
public void backMes(String task_code) {
}
@Transactional(rollbackFor = Exception.class)
public void finishTask(SchBaseTask taskObj) {

174
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/StructOfflineTask.java Normal file
View File

@@ -0,0 +1,174 @@
package org.nl.wms.sch_manage.service.core.tasks;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.apache.commons.lang3.StringUtils;
import org.nl.common.exception.BadRequestException;
import org.nl.common.utils.CodeUtil;
import org.nl.common.utils.IdUtil;
import org.nl.common.utils.SecurityUtils;
import org.nl.config.SpringContextHolder;
import org.nl.wms.basedata_manage.service.IMdMeMaterialbaseService;
import org.nl.wms.basedata_manage.service.IStructattrService;
import org.nl.wms.basedata_manage.service.dao.BsrealStorattr;
import org.nl.wms.basedata_manage.service.dao.MdMeMaterialbase;
import org.nl.wms.basedata_manage.service.dao.Sectattr;
import org.nl.wms.basedata_manage.service.dao.Structattr;
import org.nl.wms.basedata_manage.service.dto.StrategyStructParam;
import org.nl.wms.ext_manage.service.dto.StructLineOfflineDTO;
import org.nl.wms.pm_manage.purchase.ListenerHandler.PurchaseListenerParams;
import org.nl.wms.sch_manage.enums.StatusEnum;
import org.nl.wms.sch_manage.enums.TaskStatus;
import org.nl.wms.sch_manage.service.ISchBasePointService;
import org.nl.wms.sch_manage.service.core.AbstractTask;
import org.nl.wms.sch_manage.service.core.AcsTaskDto;
import org.nl.wms.sch_manage.service.dao.SchBasePoint;
import org.nl.wms.warehouse_manage.enums.IOSEnum;
import org.nl.wms.warehouse_manage.inAndOut.service.IInBillService;
import org.nl.wms.warehouse_manage.inAndOut.service.dao.IOStorInvDtl;
import org.nl.wms.warehouse_manage.inAndOut.service.dto.IOStorInvDisDto;
import org.nl.wms.warehouse_manage.inventory.IStInventoryService;
import org.nl.wms.warehouse_manage.service.IMdPbGroupplateService;
import org.nl.wms.warehouse_manage.service.dao.GroupPlate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
import java.util.*;
import static org.nl.wms.warehouse_manage.enums.IOSEnum.GROUP_PLATE_STATUS;
/**
* 焊接区域半成品入库
*/
@Service
public class StructOfflineTask extends AbstractTask {
@Autowired
private IInBillService iInBillService;
@Autowired
private IMdPbGroupplateService iMdPbGroupplateService;
@Autowired
private ISchBasePointService iSchBasePointService;
@Autowired
private IMdMeMaterialbaseService iMdMeMaterialbaseService;
@Autowired
private IStructattrService iStructattrService;
/**
* 生成生产入库任务，任务完成
*/
public void offline(StructLineOfflineDTO offlineDTO){
SchBasePoint schBasePoint = iSchBasePointService.selectByCode(offlineDTO.getUnloadPort());
String storagevehicleCode = schBasePoint.getStoragevehicle_code();
if (StringUtils.isEmpty(storagevehicleCode)){
throw new BadRequestException("下线失败，下料点没有绑定托盘号");
}
final MdMeMaterialbase materialbase = iMdMeMaterialbaseService.getByCode(offlineDTO.getMaterialCode());
if (materialbase == null){
throw new BadRequestException("下线失败，物料编码未同步");
}
final GroupPlate plate = new GroupPlate();
plate.setStoragevehicle_code(storagevehicleCode);
plate.setGroup_id(IdUtil.getStringId());
plate.setCreate_id(SecurityUtils.getCurrentUserId());
plate.setCreate_name("MES");
plate.setCreate_time(DateUtil.now());
plate.setMaterial_code(materialbase.getMaterial_code());
plate.setQty(offlineDTO.getUnloadQty());
plate.setQty_unit_id(materialbase.getQty_unit_id());
plate.setQty_unit_name(materialbase.getQty_unit_id());
plate.setStatus(IOSEnum.GROUP_PLATE_STATUS.code("组盘"));
iMdPbGroupplateService.save(plate);
//强制：下线点对应的区域就是半成品库区编码
final String regionCode = schBasePoint.getRegion_code();
List<Structattr> structattrs = iStructattrService.inBoundSectDiv(StrategyStructParam.builder()
.ioType(StatusEnum.STRATEGY_TYPE.code("入库"))
.sect_code(regionCode)
.storagevehicle_code(plate.getStoragevehicle_code())
.strategyMaters(new ArrayList<>())
.build());
final Structattr structattr = structattrs.get(0);
// 组织主表数据
Map<String, Object> jsonMst = new HashMap<>();
jsonMst.put("stor_id", structattr.getStor_id());
jsonMst.put("bill_status", IOSEnum.BILL_STATUS.code("分配完"));
jsonMst.put("total_qty", plate.getQty());
jsonMst.put("detail_count", 1);
jsonMst.put("bill_type", IOSEnum.BILL_TYPE.code("生产入库"));
jsonMst.put("biz_date", DateUtil.now());
// 组织明细数据
ArrayList<HashMap> tableData = new ArrayList<>();
HashMap<String, Object> dtl = new HashMap<>();
dtl.put("storagevehicle_code", plate.getStoragevehicle_code());
dtl.put("material_id", materialbase.getMaterial_id());
dtl.put("material_code", materialbase.getMaterial_code());
dtl.put("material_name", materialbase.getMaterial_name());
dtl.put("pcsn", plate.getPcsn());
dtl.put("qty_unit_id", materialbase.getQty_unit_id());
dtl.put("qty_unit_name", materialbase.getQty_unit_name());
dtl.put("qty", plate.getQty());
dtl.put("plan_qty", plate.getQty());
// 调用新增
tableData.add(dtl);
jsonMst.put("tableData",tableData);
String iostorinv_id = iInBillService.insertDtl(jsonMst);
// 组织主数据
JSONObject divStructParam= new JSONObject();
divStructParam.put("checked", false);
divStructParam.put("stor_code", structattr.getStor_code());
divStructParam.put("sect_code", structattr.getSect_code());
final JSONObject disRow = new JSONObject();
divStructParam.put("dis_row", disRow);
disRow.put("struct_code",structattr.getStruct_code());
disRow.put("storagevehicle_code", plate.getStoragevehicle_code());
disRow.put("iostorinv_id", iostorinv_id);
// 调用分配，默认自动分配库位
iInBillService.divStruct(divStructParam);
// 下发任务
// 组织 divPoint 参数
Map<String, Object> divPointParam = new HashMap<>();
divPointParam.put("point_code", offlineDTO.getUnloadPort());
ArrayList<HashMap<String, String>> tableMater = new ArrayList<>();
HashMap<String, String> materRow = new HashMap<>();
materRow.put("iostorinv_id", iostorinv_id); // 入库单明细ID
materRow.put("iostorinvdis_id", iostorinvdis_id); // 分配明细ID（如果有）
materRow.put("storagevehicle_code", storagevehicleCode); // 载具编码
tableMater.add(materRow);
divPointParam.put("tableMater", tableMater);
iInBillService.divPoint(divPointParam);
}
@Override
public String create(JSONObject json) {
String task_id = stInTask.create(task_form);
return null;
}
@Override
public AcsTaskDto sendAcsParam(String taskId) {
return null;
}
@Override
protected void updateStatus(String task_code, TaskStatus status) {
}
@Override
public void forceFinish(String task_code) {
}
@Override
public void cancel(String task_code) {
}
}

4
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/VehicleInTask.java
View File

@@ -130,9 +130,7 @@ public class VehicleInTask extends AbstractTask {
this.cancelTask(taskObj);
}
@Override
public void backMes(String task_code) {
}
@Transactional
public void finishTask(SchBaseTask taskObj) {

4
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/core/tasks/VehicleOutTask.java
View File

@@ -125,9 +125,7 @@ public class VehicleOutTask extends AbstractTask {
this.cancelTask(taskObj);
}
@Override
public void backMes(String task_code) {
}
@Transactional(rollbackFor = Exception.class)
public void finishTask(SchBaseTask taskObj) {

8
nladmin-system/wms-server/src/main/java/org/nl/wms/sch_manage/service/impl/SchBasePointServiceImpl.java
View File

@@ -195,6 +195,14 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
return pointMapper.selectByIdLock(id);
}
@Override
public SchBasePoint selectByCode(String code) {
if (StringUtils.isEmpty(code)){
throw new BadRequestException("查询点位失败，编码为空");
}
return this.getOne(new LambdaQueryWrapper<SchBasePoint>().eq(SchBasePoint::getPoint_code,code));
}
@Override
public void unLockPoint(String point_code) {
this.update(

33
nladmin-system/wms-server/src/main/java/org/nl/wms/warehouse_manage/inAndOut/service/impl/InBillServiceImpl.java
View File

@@ -12,6 +12,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.nl.common.domain.query.PageQuery;
import org.nl.common.exception.BadRequestException;
import org.nl.common.utils.CodeUtil;
@@ -28,6 +29,7 @@ import org.nl.wms.basedata_manage.service.dao.mapper.MdPbStoragevehicleinfoMappe
import org.nl.wms.basedata_manage.service.dto.StrategyMater;
import org.nl.wms.basedata_manage.service.dto.StrategyStructParam;
import org.nl.wms.basedata_manage.service.dto.StructattrChangeDto;
import org.nl.wms.sch_manage.enums.StatusEnum;
import org.nl.wms.sch_manage.service.dao.SchBaseTask;
import org.nl.wms.sch_manage.service.core.tasks.StInTask;
import org.nl.wms.warehouse_manage.enums.IOSConstant;
@@ -369,6 +371,7 @@ public class InBillServiceImpl extends ServiceImpl<IOStorInvMapper, IOStorInv> i
String struct_name = "";
//是否自动分配仓位
Boolean checked = mst.getBoolean("checked");
Structattr struct;
if (ObjectUtil.isNotEmpty(checked) && checked) {
//根据载具进行分配货位
List<StrategyMater> maters = new ArrayList<>();
@@ -382,31 +385,25 @@ public class InBillServiceImpl extends ServiceImpl<IOStorInvMapper, IOStorInv> i
}
List<Structattr> structattrs = iStructattrService.inBoundSectDiv(
StrategyStructParam.builder()
.ioType(param.getString("ioType"))
.ioType(StatusEnum.STRATEGY_TYPE.code("入库"))
.sect_code(param.getString("sect_code"))
.stor_code(param.getString("stor_code"))
.storagevehicle_code(param.getString("storagevehicle_code"))
.strategyMaters(maters)
.build());
Structattr struct = structattrs.get(0);
sect_id = struct.getSect_id();
sect_code = struct.getSect_code();
sect_name = struct.getSect_name();
struct_id = struct.getStruct_id();
struct_code = struct.getStruct_code();
struct_name = struct.getStruct_name();
struct = structattrs.get(0);
} else {
Structattr structattr = iStructattrService.findById(map.getString("struct_id"));
MdPbStoragevehicleinfo mdPbStoragevehicleinfo = mdPbStoragevehicleinfoMapper.selectOne(new LambdaQueryWrapper<>(MdPbStoragevehicleinfo.class)
.eq(MdPbStoragevehicleinfo::getStoragevehicle_code, map.get("storagevehicle_code"))
);
sect_id = map.getString("sect_id");
sect_code = map.getString("sect_code");
sect_name = map.getString("sect_name");
struct_id = map.getString("struct_id");
struct_code = map.getString("struct_code");
struct_name = map.getString("struct_name");
if (StringUtils.isEmpty(map.getString("struct_code"))){
throw new BadRequestException("分配失败，手动分配struct_code为空");
}
struct = iStructattrService.findByCode(map.getString("struct_code"));
}
sect_id = struct.getSect_id();
sect_code = struct.getSect_code();
sect_name = struct.getSect_name();
struct_id = struct.getStruct_id();
struct_code = struct.getStruct_code();
struct_name = struct.getStruct_name();
JSONObject dis_map = new JSONObject();
dis_map.put("sect_id", sect_id);
dis_map.put("sect_code", sect_code);

3
nladmin-system/wms-server/src/main/java/org/nl/wms/warehouse_manage/service/dao/mapper/MdPbGroupplateMapper.xml
View File

@@ -96,13 +96,14 @@
<insert id="insertAllData">
INSERT INTO md_pb_groupplate(
group_id,storagevehicle_code,material_id,pcsn,qty,qty_unit_id,qty_unit_name,ext_code,load_port,create_id,create_name,create_time
group_id,storagevehicle_code,material_id,material_code,pcsn,qty,qty_unit_id,qty_unit_name,ext_code,load_port,create_id,create_name,create_time
) values
<foreach collection="data" item="item" separator=",">
(
#{item.group_id},
#{item.storagevehicle_code},
#{item.material_id},
#{item.material_code},
#{item.pcsn},
#{item.qty},
#{item.qty_unit_id},

4
nladmin-system/wms-server/src/main/java/org/nl/wms/welding_manage/controller/device_interaction/InteractionController.java
View File

@@ -24,11 +24,11 @@ public class InteractionController {
}
@PostMapping("/blank")
@Log("产线下料半成品入库请求")
@Log("产线下线半成品入库请求")
public ResponseEntity<Object> blank()
{
return null;
}
}
}

1
nladmin-system/wms-server/src/main/java/org/nl/wms/welding_manage/service/product_group/impl/ProductGroupServiceImpl.java
View File

@@ -58,6 +58,7 @@ public class ProductGroupServiceImpl implements IProductGroupService {
json.put("load_port", dto.getLoadPort());
json.put("storagevehicle_code", dto.getPalletCode());
json.put("material_id", bomData.getMaterialCode());
json.put("material_code", bomData.getMaterialCode());
json.put("pcsn", "");
json.put("qty_unit_id", bomData.getUnit());
json.put("qty_unit_name", bomData.getUnit());