sczx_group/sczx_sync
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
eric
2025-09-23 13:08:52 +08:00
parent d15216828c
commit 5816bd6360
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/com/sczx/sync/controller/ReceiveBatteryController.java
View File

@ -58,7 +58,7 @@ public class ReceiveBatteryController {
try { try {
return receiveService.recceiveMeals(receive); return receiveService.recceiveMeals(receive);
} catch (Exception e) { } catch (Exception e) {
log.error("处理电池类型数据时发生异常", e); log.error("处理租电数据时发生异常", e);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "处理失败: " + e.getMessage()); errorResponse.put("msg", "处理失败: " + e.getMessage());
@ -66,11 +66,11 @@ public class ReceiveBatteryController {
} }
}, taskExecutor) }, taskExecutor)
.thenApply(result -> { .thenApply(result -> {
log.info("电池类型数据处理完成，返回结果: {}", result); log.info("租电数据处理完成，返回结果: {}", result);
return ResponseEntity.ok(result); return ResponseEntity.ok(result);
}) })
.exceptionally(throwable -> { .exceptionally(throwable -> {
log.error("异步处理电池类型数据时发生异常", throwable); log.error("异步处理租电数据时发生异常", throwable);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "系统异常"); errorResponse.put("msg", "系统异常");
@ -86,7 +86,7 @@ public class ReceiveBatteryController {
try { try {
return receiveService.recceiveUserInfo(receive); return receiveService.recceiveUserInfo(receive);
} catch (Exception e) { } catch (Exception e) {
log.error("处理电池类型数据时发生异常", e); log.error("处理用户数据时发生异常", e);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "处理失败: " + e.getMessage()); errorResponse.put("msg", "处理失败: " + e.getMessage());
@ -94,11 +94,11 @@ public class ReceiveBatteryController {
} }
}, taskExecutor) }, taskExecutor)
.thenApply(result -> { .thenApply(result -> {
log.info("电池类型数据处理完成，返回结果: {}", result); log.info("用户数据处理完成，返回结果: {}", result);
return ResponseEntity.ok(result); return ResponseEntity.ok(result);
}) })
.exceptionally(throwable -> { .exceptionally(throwable -> {
log.error("异步处理电池类型数据时发生异常", throwable); log.error("异步处理用户数据时发生异常", throwable);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "系统异常"); errorResponse.put("msg", "系统异常");
@ -114,7 +114,7 @@ public class ReceiveBatteryController {
try { try {
return receiveService.recceiveCompanyInfo(receive); return receiveService.recceiveCompanyInfo(receive);
} catch (Exception e) { } catch (Exception e) {
log.error("处理电池类型数据时发生异常", e); log.error("处理运营商数据时发生异常", e);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "处理失败: " + e.getMessage()); errorResponse.put("msg", "处理失败: " + e.getMessage());
@ -122,11 +122,11 @@ public class ReceiveBatteryController {
} }
}, taskExecutor) }, taskExecutor)
.thenApply(result -> { .thenApply(result -> {
log.info("电池类型数据处理完成，返回结果: {}", result); log.info("运营商数据处理完成，返回结果: {}", result);
return ResponseEntity.ok(result); return ResponseEntity.ok(result);
}) })
.exceptionally(throwable -> { .exceptionally(throwable -> {
log.error("异步处理电池类型数据时发生异常", throwable); log.error("异步处理运营商数据时发生异常", throwable);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "系统异常"); errorResponse.put("msg", "系统异常");
@ -142,7 +142,7 @@ public class ReceiveBatteryController {
try { try {
return receiveService.recceiveStoreInfo(receive); return receiveService.recceiveStoreInfo(receive);
} catch (Exception e) { } catch (Exception e) {
log.error("处理电池类型数据时发生异常", e); log.error("处理门店数据时发生异常", e);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "处理失败: " + e.getMessage()); errorResponse.put("msg", "处理失败: " + e.getMessage());
@ -150,11 +150,11 @@ public class ReceiveBatteryController {
} }
}, taskExecutor) }, taskExecutor)
.thenApply(result -> { .thenApply(result -> {
log.info("电池类型数据处理完成，返回结果: {}", result); log.info("门店数据处理完成，返回结果: {}", result);
return ResponseEntity.ok(result); return ResponseEntity.ok(result);
}) })
.exceptionally(throwable -> { .exceptionally(throwable -> {
log.error("异步处理电池类型数据时发生异常", throwable); log.error("异步处理门店数据时发生异常", throwable);
Map<String, String> errorResponse = new HashMap<>(); Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("code", "9999"); errorResponse.put("code", "9999");
errorResponse.put("msg", "系统异常"); errorResponse.put("msg", "系统异常");