fix: 税邦云回调日志 v1

hnqz-common/hnqz-common-security/src/main/java/com/qunzhixinxi/hnqz/common/security/component/GlobalExceptionHandlerResolver.java

@@ -48,7 +48,8 @@ public class GlobalExceptionHandlerResolver {
 	@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
 	public R handleGlobalException(Exception e) {
 		log.error("全局异常信息 ex={}", e.getMessage(), e);
-		e.printStackTrace();
+		log.error("全局异常信息", e);
+		log.error("全局异常信息 >>> " + e.getMessage());
 		return R.failed(e.getLocalizedMessage());
 	}
 

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/service/impl/WmScorePackageSettleNoteServiceImpl.java

@@ -827,6 +827,8 @@ public class WmScorePackageSettleNoteServiceImpl extends ServiceImpl<WmScorePack
 	public R settleNotify(String streamId, Integer settleStatus, Boolean izSingle) {
 
 
+		log.info("=== 税邦云 回调处理开始 ===");
+
 		WmScorePackageSettleNote query = new WmScorePackageSettleNote();
 		query.setStreamId(streamId);
 		List<WmScorePackageSettleNote> noteList = this.baseMapper.selectList(Wrappers.query(query));
@@ -866,6 +868,7 @@ public class WmScorePackageSettleNoteServiceImpl extends ServiceImpl<WmScorePack
 			log.info("回调成功，流水号异常： {}", streamId);
 		}
 
+		log.info("=== 税邦云 回调处理结束 ===");
 		return R.ok(noteList);
 	}
 

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/service/retry/impl/PartyARetryServiceImpl.java

@@ -96,7 +96,7 @@ public class PartyARetryServiceImpl implements PartyARetryService {
 
 		Assert.notEmpty(noteList);
 		String token = login();
-
+		log.info("推送三方开始");
 		// 封装证据链
 		// TaskSettleBatch tsb = new TaskSettleBatch();
 		//
@@ -104,30 +104,34 @@ public class PartyARetryServiceImpl implements PartyARetryService {
 		// tsb.setScorePackageStatusId(Integer.valueOf(noteList.get(0).getPackageStatusId()));
 		// tsb.setPackageId(Integer.valueOf(noteList.get(0).getPackageId()));
 
-		List<WmTaskContent> tsb = noteList.stream().map(note -> {
-			WmTask task = wmTaskService.getById(note.getTaskId());
-			return wmTaskContentService.getById(task.getTaskContentId());
-		}).collect(Collectors.toList());
-
-		Map<String, Object> params = new HashMap<>();
-		params.put("token", token);
-		params.put("code", "2000");
-		params.put("data", JSONUtil.toJsonStr(tsb));
-		params.put("success_msg", "SUCCESS");
-		ResponseEntity<String> resp = getResp(params, PartyARetryService.WENWEN_SETTLEMENT_RESULTS_URL);
-		if (HttpStatus.OK.equals(resp.getStatusCode())) {
-			String body = resp.getBody();
-			JSONObject jsonObject = JSONUtil.parseObj(body);
-			String status = jsonObject.getStr("status");
-			JSONObject data = jsonObject.getJSONObject("data");
-			if (!"success".equals(status)) {
-				String msg = data.getStr("message");
-				log.error("问问风湿结算回调失败:{}", msg);
-				throw new RuntimeException("问问风湿结算回调失败");
+		try {
+			List<WmTaskContent> tsb = noteList.stream().map(note -> {
+				WmTask task = wmTaskService.getById(note.getTaskId());
+				return wmTaskContentService.getById(task.getTaskContentId());
+			}).collect(Collectors.toList());
+
+			Map<String, Object> params = new HashMap<>();
+			params.put("token", token);
+			params.put("code", "2000");
+			params.put("data", JSONUtil.toJsonStr(tsb));
+			params.put("success_msg", "SUCCESS");
+			ResponseEntity<String> resp = getResp(params, PartyARetryService.WENWEN_SETTLEMENT_RESULTS_URL);
+			if (HttpStatus.OK.equals(resp.getStatusCode())) {
+				String body = resp.getBody();
+				JSONObject jsonObject = JSONUtil.parseObj(body);
+				String status = jsonObject.getStr("status");
+				JSONObject data = jsonObject.getJSONObject("data");
+				if (!"success".equals(status)) {
+					String msg = data.getStr("message");
+					log.error("问问风湿结算回调失败:{}", msg);
+					throw new RuntimeException("问问风湿结算回调失败");
+				}
+			} else {
+				log.error("问问风湿认证回调请求失败");
+				throw new RuntimeException("问问风湿认证回调请求失败");
 			}
-		} else {
-			log.error("问问风湿认证回调请求失败");
-			throw new RuntimeException("问问风湿认证回调请求失败");
+		}finally {
+			log.info("推送三方开始");
 		}
 
 	}