Compare commits
2 Commits
ac108a570e
...
708ad618b3
| Author | SHA1 | Date |
|---|---|---|
 刘先源
|
708ad618b3 | 2 weeks ago |
|
刘先源
|
a891c3b201 | 2 weeks ago |
23 changed files with 551 additions and 23 deletions
@ -0,0 +1,48 @@ |
|||
package org.nl.wms.ext.controller; |
|||
|
|||
|
|||
import cn.dev33.satoken.annotation.SaIgnore; |
|||
import com.alibaba.fastjson.JSONObject; |
|||
import lombok.RequiredArgsConstructor; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.nl.common.logging.annotation.Log; |
|||
import org.nl.wms.ext.service.ErpToWmsService; |
|||
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; |
|||
|
|||
/** |
|||
* <p> |
|||
* ERP调用WMS 控制层 |
|||
* </p> |
|||
* |
|||
* @author Liuxy |
|||
* @since 2025-06-04 |
|||
*/ |
|||
@RestController |
|||
@RequiredArgsConstructor |
|||
@RequestMapping("/api/lms") |
|||
@Slf4j |
|||
public class ErpToWmsController { |
|||
|
|||
@Autowired |
|||
private ErpToWmsService erpToWmsService; |
|||
|
|||
@PostMapping("/inventory") |
|||
@Log("erp查询库存") |
|||
@SaIgnore |
|||
public ResponseEntity<Object> confirm(@RequestBody JSONObject whereJson) { |
|||
return new ResponseEntity<>(erpToWmsService.erpQueryIvt(whereJson),HttpStatus.OK); |
|||
} |
|||
|
|||
@PostMapping("/task") |
|||
@Log("下发出库单据") |
|||
@SaIgnore |
|||
public ResponseEntity<Object> sendTask(@RequestBody JSONObject whereJson) { |
|||
return new ResponseEntity<>(erpToWmsService.sendTask(whereJson),HttpStatus.OK); |
|||
} |
|||
} |
|||
@ -0,0 +1,19 @@ |
|||
package org.nl.wms.ext.enuums; |
|||
|
|||
/** |
|||
* @author Liuyx |
|||
* @date 2025年06月03日 |
|||
* @desc 外部系统常量 |
|||
*/ |
|||
public class EXTConstant { |
|||
|
|||
/** |
|||
* 回传ERP接口地址 |
|||
*/ |
|||
public final static String UPLOAD_ERP_API = "CamstarApi/MomRollBakeInBound"; |
|||
|
|||
/** |
|||
* 物料同步ERP接口地址 |
|||
*/ |
|||
public final static String MATERIAL_SYNC_ERP_API = "CamstarApi/MomRollBakeInBound"; |
|||
} |
|||
@ -0,0 +1,42 @@ |
|||
package org.nl.wms.ext.service; |
|||
|
|||
import com.alibaba.fastjson.JSONObject; |
|||
import org.nl.wms.ext.service.util.ErpResponse; |
|||
|
|||
/** |
|||
* <p> |
|||
* ERP调用WMS 服务类 |
|||
* </p> |
|||
* |
|||
* @author Liuxy |
|||
* @since 2025-06-04 |
|||
*/ |
|||
public interface ErpToWmsService { |
|||
|
|||
/** |
|||
* erp查询库存 |
|||
* @param whereJson { |
|||
* mater_code： 物料编码（可为空） |
|||
* stor_code： 仓库编码（可为空） |
|||
* point_code： 货位编码（可为空） |
|||
* } |
|||
* @return ErpResponse |
|||
*/ |
|||
ErpResponse erpQueryIvt(JSONObject whereJson); |
|||
|
|||
/** |
|||
* 下发出库单据 |
|||
* @param whereJson： { |
|||
* stor_code：仓库编码 |
|||
* mater_code：物料编码 |
|||
* batch_no：批次号（可为空） |
|||
* quantity：数量 |
|||
* unit_code：计量单位 |
|||
* unit_name：计量单位名称 |
|||
* inv_code：单据号（可为空） |
|||
* task_type ：业务类型（可为空） |
|||
* } |
|||
* @return ErpResponse |
|||
*/ |
|||
ErpResponse sendTask(JSONObject whereJson); |
|||
} |
|||
@ -0,0 +1,45 @@ |
|||
package org.nl.wms.ext.service.impl; |
|||
|
|||
import com.alibaba.fastjson.JSONObject; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.nl.wms.basedata_manage.service.dao.mapper.MdPbStoragevehicleextMapper; |
|||
import org.nl.wms.ext.service.ErpToWmsService; |
|||
import org.nl.wms.ext.service.util.ErpResponse; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
/** |
|||
* <p> |
|||
* ERP调用WMS 实现类 |
|||
* </p> |
|||
* |
|||
* @author Liuxy |
|||
* @since 2025-06-04 |
|||
*/ |
|||
@Service |
|||
@Slf4j |
|||
public class ErpToWmsServiceImpl implements ErpToWmsService { |
|||
|
|||
/** |
|||
* 载具扩展属性mapper |
|||
*/ |
|||
@Autowired |
|||
private MdPbStoragevehicleextMapper mdPbStoragevehicleextMapper; |
|||
|
|||
@Override |
|||
public ErpResponse erpQueryIvt(JSONObject whereJson) { |
|||
log.info("erpQueryIvt查询物料接口输入参数为：-------------------" + whereJson.toString()); |
|||
ErpResponse erpResponse = ErpResponse.requestParamOk(mdPbStoragevehicleextMapper.erpQueryIvt(whereJson)); |
|||
log.info("erpQueryIvt查询物料接口输出参数为：-------------------" + erpResponse.toString()); |
|||
return erpResponse; |
|||
} |
|||
|
|||
@Override |
|||
public ErpResponse sendTask(JSONObject whereJson) { |
|||
log.info("sendTask下发出库任务接口输入参数为：-------------------" + whereJson.toString()); |
|||
|
|||
|
|||
log.info("sendTask下发出库任务接口输出参数为：-------------------" + ErpResponse.requestOk().toString()); |
|||
return ErpResponse.requestOk(); |
|||
} |
|||
} |
|||
@ -0,0 +1,72 @@ |
|||
package org.nl.wms.ext.service.util; |
|||
|
|||
import cn.hutool.http.HttpStatus; |
|||
import com.alibaba.fastjson.JSONObject; |
|||
import lombok.Builder; |
|||
import lombok.Data; |
|||
|
|||
import java.util.List; |
|||
|
|||
/** |
|||
* <p> |
|||
* ERP调用WMS 返回结果 |
|||
* </p> |
|||
* |
|||
* @author Liuxy |
|||
* @since 2025-06-04 |
|||
*/ |
|||
@Data |
|||
@Builder |
|||
public class ErpResponse { |
|||
|
|||
/** |
|||
* 状态码 |
|||
*/ |
|||
private Integer status; |
|||
|
|||
/** |
|||
* 信息 |
|||
*/ |
|||
private String message; |
|||
|
|||
/** |
|||
* 返回数据 |
|||
*/ |
|||
private List<JSONObject> data; |
|||
|
|||
/** |
|||
* 不带数据反馈 |
|||
* @return ErpResponse |
|||
*/ |
|||
public static ErpResponse requestOk() { |
|||
return ErpResponse.builder() |
|||
.status(HttpStatus.HTTP_OK) |
|||
.message("请求成功!") |
|||
.build(); |
|||
} |
|||
|
|||
/** |
|||
* 带数据反馈 |
|||
* @return ErpResponse |
|||
*/ |
|||
public static ErpResponse requestParamOk(List<JSONObject> list) { |
|||
return ErpResponse.builder() |
|||
.status(HttpStatus.HTTP_OK) |
|||
.message("请求成功!") |
|||
.data(list) |
|||
.build(); |
|||
} |
|||
|
|||
/** |
|||
* 报错信息反馈 |
|||
* @return ErpResponse |
|||
*/ |
|||
public static ErpResponse requestError(String message) { |
|||
return ErpResponse.builder() |
|||
.status(HttpStatus.HTTP_BAD_REQUEST) |
|||
.message(message) |
|||
.build(); |
|||
} |
|||
|
|||
} |
|||
|
|||
@ -0,0 +1,28 @@ |
|||
<?xml version="1.0" encoding="UTF-8"?> |
|||
<included> |
|||
<springProperty scope="context" name="logPath" source="logging.file.path" defaultValue="logs"/> |
|||
<property name="LOG_HOME" value="${logPath}"/> |
|||
<!-- 按照每天生成日志文件 --> |
|||
<appender name="FILE_ERPTOWMS" class="ch.qos.logback.core.rolling.RollingFileAppender"> |
|||
<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy"> |
|||
<!--日志文件输出的文件名--> |
|||
<FileNamePattern>${LOG_HOME}/ErpToWms/%d{yyyy-MM-dd}.%i.log</FileNamePattern> |
|||
<!--日志文件保留天数--> |
|||
<maxHistory>15</maxHistory> |
|||
<!--单个日志最大容量 至少10MB才能看得出来--> |
|||
<maxFileSize>200MB</maxFileSize> |
|||
<!--所有日志最多占多大容量--> |
|||
<totalSizeCap>2GB</totalSizeCap> |
|||
</rollingPolicy> |
|||
<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> |
|||
<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符--> |
|||
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> |
|||
<charset>${log.charset}</charset> |
|||
</encoder> |
|||
|
|||
</appender> |
|||
<!-- 打印sql --> |
|||
<logger name="org.nl.wms.ext.service.impl.ErpToWmsServiceImpl" level="info" additivity="false"> |
|||
<appender-ref ref="FILE_ERPTOWMS"/> |
|||
</logger> |
|||
</included> |
|||
Loading…
Reference in new issue