Browse Source

2025-12-17

erp接口调整
master
fengyuan_yang 4 weeks ago
parent
commit
15ef0370ab
  1. 11
      src/main/java/com/gaotao/modules/erp/service/impl/ErpInterfaceServiceImpl.java
  2. 10
      src/main/java/com/gaotao/modules/sys/service/impl/InterfaceLogServiceImpl.java
  3. 10
      src/main/java/com/gaotao/modules/sys/service/impl/SystemLogServiceImpl.java
  4. 34
      src/main/resources/mapper/sys/ApiLogIdDao.xml

11
src/main/java/com/gaotao/modules/erp/service/impl/ErpInterfaceServiceImpl.java

@ -222,7 +222,16 @@ public class ErpInterfaceServiceImpl implements ErpInterfaceService {
headEntity.setRequestId(requestId);
headEntity.setRequestGroupId(requestGroupId);
headEntity.setOrderref1(firstLog.getDocumentNo());
headEntity.setOrderref2(firstLog.getTransactionType());
String txType = firstLog.getTransactionType();
String txTypeName = "";
if ("O".equals(txType)) {
txTypeName = "领料";
} else if ("I".equals(txType)) {
txTypeName = "退料";
} else {
txTypeName = txType != null ? txType : "";
}
headEntity.setOrderref2(txTypeName);
headEntity.setOrderref3(formatDate(firstLog.getTransactionDate()));
headEntity.setOrderref4(firstLog.getDocumentNoType());
headEntity.setOrderref5("");

10
src/main/java/com/gaotao/modules/sys/service/impl/InterfaceLogServiceImpl.java

@ -78,13 +78,15 @@ public class InterfaceLogServiceImpl implements InterfaceLogService {
// 构造返回的JSON结构
Map<String, Object> result = new LinkedHashMap<>();
// 处理主表数据将orderref1-20映射为"接口参数1"-"接口参数20"
// 处理主表数据使用getFieldName映射字段名
if (head != null) {
for (int i = 1; i <= 20; i++) {
String key = "orderref" + i;
Object value = head.get(key);
if (value != null && !value.toString().trim().isEmpty()) {
result.put("接口参数" + i, value);
// 使用getFieldName获取实际的字段名
String fieldName = getFieldName(i, true);
result.put(fieldName, value);
}
}
}
@ -100,7 +102,9 @@ public class InterfaceLogServiceImpl implements InterfaceLogService {
String key = "orderref" + i;
Object value = detail.get(key);
if (value != null && !value.toString().trim().isEmpty()) {
detailResult.put("接口参数" + i, value);
// 使用getFieldName获取实际的字段名
String fieldName = getFieldName(i, false);
detailResult.put(fieldName, value);
}
}

10
src/main/java/com/gaotao/modules/sys/service/impl/SystemLogServiceImpl.java

@ -78,13 +78,15 @@ public class SystemLogServiceImpl implements SystemLogService {
// 构造返回的JSON结构
Map<String, Object> result = new LinkedHashMap<>();
// 处理主表数据将orderref1-20映射为"接口参数1"-"接口参数20"
// 处理主表数据使用getFieldName映射字段名
if (head != null) {
for (int i = 1; i <= 20; i++) {
String key = "orderref" + i;
Object value = head.get(key);
if (value != null && !value.toString().trim().isEmpty()) {
result.put("接口参数" + i, value);
// 使用getFieldName获取实际的字段名
String fieldName = getFieldName(i, true);
result.put(fieldName, value);
}
}
}
@ -100,7 +102,9 @@ public class SystemLogServiceImpl implements SystemLogService {
String key = "orderref" + i;
Object value = detail.get(key);
if (value != null && !value.toString().trim().isEmpty()) {
detailResult.put("接口参数" + i, value);
// 使用getFieldName获取实际的字段名
String fieldName = getFieldName(i, false);
detailResult.put(fieldName, value);
}
}

34
src/main/resources/mapper/sys/ApiLogIdDao.xml

@ -3,37 +3,9 @@
<mapper namespace="com.gaotao.modules.sys.dao.ApiLogIdDao">
<!-- 获取并自增request_id -->
<select id="getAndIncrementRequestId" resultType="string">
DECLARE @currentId NVARCHAR(50);
DECLARE @nextId NVARCHAR(50);
-- 获取当前request_id
SELECT @currentId = request_id
FROM api_log_id WITH(UPDLOCK, ROWLOCK)
WHERE interface_name = #{interfaceName};
-- 如果不存在,初始化为 'REQ000001'
IF @currentId IS NULL
BEGIN
SET @currentId = 'REQ000001';
INSERT INTO api_log_id (interface_name, request_id)
VALUES (#{interfaceName}, 'REQ000002');
END
ELSE
BEGIN
-- 提取数字部分并自增
DECLARE @numPart INT;
SET @numPart = CAST(SUBSTRING(@currentId, 4, LEN(@currentId)) AS INT) + 1;
SET @nextId = 'REQ' + RIGHT('000000' + CAST(@numPart AS VARCHAR), 6);
-- 更新为下一个ID
UPDATE api_log_id
SET request_id = @nextId
WHERE interface_name = #{interfaceName};
END
SELECT @currentId AS request_id;
<!-- 获取并自增request_id,调用存储过程GetNextRequestId -->
<select id="getAndIncrementRequestId" resultType="string" statementType="CALLABLE">
{CALL GetNextRequestId(#{interfaceName})}
</select>
<!-- 初始化接口的request_id -->

Loading…
Cancel
Save