|
@@ -115,12 +115,17 @@ public class CallIndicationAggregate {
|
|
});
|
|
});
|
|
|
|
|
|
RespDTO<IndicationDTO> respDTO = cdssCoreClient.indication(indicationPushVO);
|
|
RespDTO<IndicationDTO> respDTO = cdssCoreClient.indication(indicationPushVO);
|
|
|
|
+ Integer callCount = 0;
|
|
|
|
+ while (callCount <= 3 && RespDTOUtil.respIsNG(respDTO)) {
|
|
|
|
+ respDTO = cdssCoreClient.indication(indicationPushVO);
|
|
|
|
+ callCount++;
|
|
|
|
+ }
|
|
if (RespDTOUtil.respIsOK(respDTO)) {
|
|
if (RespDTOUtil.respIsOK(respDTO)) {
|
|
IndicationDTO data = respDTO.data;
|
|
IndicationDTO data = respDTO.data;
|
|
//出参
|
|
//出参
|
|
- entry.getValue().forEach(result -> {
|
|
|
|
|
|
+ for (ResultRule result : entry.getValue()) {
|
|
result.setOutputParams(FastJsonUtils.getBeanToJson(respDTO.data));
|
|
result.setOutputParams(FastJsonUtils.getBeanToJson(respDTO.data));
|
|
- });
|
|
|
|
|
|
+ }
|
|
List<BillMsg> msgList = Lists.newLinkedList();
|
|
List<BillMsg> msgList = Lists.newLinkedList();
|
|
switch (ruleType) {
|
|
switch (ruleType) {
|
|
case 1:
|
|
case 1:
|
|
@@ -187,6 +192,7 @@ public class CallIndicationAggregate {
|
|
} else {
|
|
} else {
|
|
for (ResultRule result : entry.getValue()) {
|
|
for (ResultRule result : entry.getValue()) {
|
|
result.setInputParams(FastJsonUtils.getBeanToJson(indicationPushVO));
|
|
result.setInputParams(FastJsonUtils.getBeanToJson(indicationPushVO));
|
|
|
|
+ result.setOutputParams(FastJsonUtils.getBeanToJson(respDTO));
|
|
result.setSuccess(0);
|
|
result.setSuccess(0);
|
|
result.setMessage("远程调用推理接口失败");
|
|
result.setMessage("远程调用推理接口失败");
|
|
retList.add(result);
|
|
retList.add(result);
|