| | |
| | | import com.vincent.rsf.server.system.constant.GlobalConfigCode; |
| | | import com.vincent.rsf.server.system.entity.Config; |
| | | import com.vincent.rsf.server.system.service.ConfigService; |
| | | import feign.FeignException; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | |
| | | } catch (JsonProcessingException e) { |
| | | log.warn("云仓上报请求体反序列化失败,id={}:{}", logRecord.getId(), e.getMessage()); |
| | | setFailResult(logRecord, requestBody, "反序列化失败: " + e.getMessage(), nextRetry, now, effectiveMaxRetry); |
| | | } catch (FeignException e) { |
| | | String responseBody = e.contentUTF8(); |
| | | String fullMsg = "status=" + e.status() + ",message=" + e.getMessage() |
| | | + (responseBody == null || responseBody.isEmpty() ? "" : ",responseBody=" + responseBody); |
| | | log.warn("云仓上报请求失败,id={},bizRef={}:{}", logRecord.getId(), logRecord.getBizRef(), fullMsg); |
| | | setFailResult(logRecord, requestBody, "请求异常: " + fullMsg, nextRetry, now, effectiveMaxRetry); |
| | | } catch (Exception e) { |
| | | log.warn("云仓上报请求失败,id={},bizRef={}:{}", logRecord.getId(), logRecord.getBizRef(), e.getMessage()); |
| | | setFailResult(logRecord, requestBody, "请求异常: " + e.getMessage(), nextRetry, now, effectiveMaxRetry); |