Browse Source

2026-01-21

接口日志管理和系统日志管理页面
1、手动重试时要校验needRetryFlag 为Y的单据才能手动重试;
2、手动重试时要增加一个校验:传输状态(synced_flag)必须是“待传输”且传输消息(synced_error_msg)必须有值,才可以重试
3、手动重试成功后要将needRetryFlag 改为N;
master
fengyuan_yang 1 month ago
parent
commit
0c038e1798
  1. 4
      src/main/java/com/gaotao/modules/sys/service/impl/InterfaceLogServiceImpl.java
  2. 4
      src/main/java/com/gaotao/modules/sys/service/impl/SystemLogServiceImpl.java
  3. 4
      src/main/resources/mapper/sys/InterfaceLogDao.xml
  4. 4
      src/main/resources/mapper/sys/SystemLogDao.xml

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

@ -511,9 +511,9 @@ public class InterfaceLogServiceImpl implements InterfaceLogService {
String transactionId = (String) apiLog.get("transactionId"); String transactionId = (String) apiLog.get("transactionId");
Integer retryCount = apiLog.get("retryCount") != null ? (Integer) apiLog.get("retryCount") : 0; Integer retryCount = apiLog.get("retryCount") != null ? (Integer) apiLog.get("retryCount") : 0;
// 校验needRetryFlag必须为Y
// 校验needRetryFlag必须为1允许重试
String needRetryFlag = apiLog.get("needRetryFlag") != null ? apiLog.get("needRetryFlag").toString() : ""; String needRetryFlag = apiLog.get("needRetryFlag") != null ? apiLog.get("needRetryFlag").toString() : "";
if (!"Y".equalsIgnoreCase(needRetryFlag)) {
if (!"1".equals(needRetryFlag)) {
logger.error("该记录不允许手动重试,needRetryFlag: {}", needRetryFlag); logger.error("该记录不允许手动重试,needRetryFlag: {}", needRetryFlag);
return R.error("存在已传输的记录!"); return R.error("存在已传输的记录!");
} }

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

@ -489,9 +489,9 @@ public class SystemLogServiceImpl implements SystemLogService {
String transactionId = (String) apiLog.get("transactionId"); String transactionId = (String) apiLog.get("transactionId");
Integer retryCount = apiLog.get("retryCount") != null ? (Integer) apiLog.get("retryCount") : 0; Integer retryCount = apiLog.get("retryCount") != null ? (Integer) apiLog.get("retryCount") : 0;
// 校验needRetryFlag必须为Y
// 校验needRetryFlag必须为1允许重试
String needRetryFlag = apiLog.get("needRetryFlag") != null ? apiLog.get("needRetryFlag").toString() : ""; String needRetryFlag = apiLog.get("needRetryFlag") != null ? apiLog.get("needRetryFlag").toString() : "";
if (!"Y".equalsIgnoreCase(needRetryFlag)) {
if (!"1".equals(needRetryFlag)) {
logger.error("该记录不允许手动重试,needRetryFlag: {}", needRetryFlag); logger.error("该记录不允许手动重试,needRetryFlag: {}", needRetryFlag);
return R.error("存在已传输的记录!"); return R.error("存在已传输的记录!");
} }

4
src/main/resources/mapper/sys/InterfaceLogDao.xml

@ -187,10 +187,10 @@
AND request_group_id = #{requestGroupId} AND request_group_id = #{requestGroupId}
</update> </update>
<!-- 更新needRetryFlag为N(手动重试成功后-->
<!-- 更新needRetryFlag为0(手动重试成功后,0表示不允许重试-->
<update id="updateNeedRetryFlag"> <update id="updateNeedRetryFlag">
UPDATE api_log UPDATE api_log
SET need_retry_flag = 'N'
SET need_retry_flag = '0'
WHERE site = #{site} WHERE site = #{site}
AND bu_no = #{buNo} AND bu_no = #{buNo}
AND request_id = #{requestId} AND request_id = #{requestId}

4
src/main/resources/mapper/sys/SystemLogDao.xml

@ -187,10 +187,10 @@
AND request_group_id = #{requestGroupId} AND request_group_id = #{requestGroupId}
</update> </update>
<!-- 更新needRetryFlag为N(手动重试成功后-->
<!-- 更新needRetryFlag为0(手动重试成功后,0表示不允许重试-->
<update id="updateNeedRetryFlag"> <update id="updateNeedRetryFlag">
UPDATE api_log UPDATE api_log
SET need_retry_flag = 'N'
SET need_retry_flag = '0'
WHERE site = #{site} WHERE site = #{site}
AND bu_no = #{buNo} AND bu_no = #{buNo}
AND request_id = #{requestId} AND request_id = #{requestId}

Loading…
Cancel
Save