修改发送站内信的异常打印

clx-performance-web/src/main/java/com/clx/performance/service/impl/SendInternalMessageServiceImpl.java

@@ -192,7 +192,12 @@ public class SendInternalMessageServiceImpl implements SendInternalMessageServic
         //向消息中心发送消息
         log.info("站内信发送参数，发送参数：{}", message);
         Result<Object> result = configuredOpenClient.doAction(new MessageAction(message));
-        log.info("站内信发送成功，发送结果：{}", result.toString());
+        if(result.succeed()){
+            log.info("站内信发送成功，发送结果：{}", result);
+        }else{
+            log.error("站内信发送失败，发送结果：{}", result);
+        }
+
     }
 
 
@@ -209,8 +214,7 @@ public class SendInternalMessageServiceImpl implements SendInternalMessageServic
             return pageDataResult.getData().getRecords().stream().map(
                     PageProductUserVo::getUserNo).collect(Collectors.toList());
         }else{
-
-            log.info("结束查询承运平台下的所有用户信息,响应结果：{}", JSON.toJSONString(pageDataResult));
+            log.error("结束查询承运平台下的所有用户信息,响应结果：{}", JSON.toJSONString(pageDataResult));
             return null;
         }
     }

clx-performance-web/src/main/java/com/clx/performance/service/impl/breakcontract/BreakContractOwnerRecordServiceImpl.java

@@ -17,6 +17,7 @@ import com.clx.performance.param.pc.breakcontract.carrier.BreakContractOwnerReco
 import com.clx.performance.param.pc.breakcontract.carrier.PageBreakContractOwnerRecordParam;
 import com.clx.performance.param.pc.breakcontract.owner.PageOwnerBreakContractOwnerRecordParam;
 import com.clx.performance.param.pc.owner.OwnerConfirmBreakContractSettlementParam;
+import com.clx.performance.service.SendInternalMessageService;
 import com.clx.performance.service.breakcontract.BreakContractOwnerRecordService;
 import com.clx.performance.service.breakcontract.BreakContractSettlementLogService;
 import com.clx.performance.service.impl.UniqueOrderNumService;
@@ -36,6 +37,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
+import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
 
@@ -70,6 +72,8 @@ public class BreakContractOwnerRecordServiceImpl  implements BreakContractOwnerR
 
     private final BreakContractSettlementLogService breakContractSettlementLogService;
 
+    private final SendInternalMessageService sendInternalMessageService;
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void saveRecord(BreakContractOwnerRecordAddParam param) {
@@ -119,6 +123,11 @@ public class BreakContractOwnerRecordServiceImpl  implements BreakContractOwnerR
             generateBreakContractSettlement(record.getId());
         }
 
+        //货主违约通知 站内信
+        sendInternalMessageService.sendInternalMessageMq(InternalMessageTemplateEnum.PlatformType.CARRIER.getCode(),
+                InternalMessageTemplateEnum.BusinessType.WAIT_APPROVED_ITEM.getCode(),
+                InternalMessageTemplateEnum.CUSTOM_OWNER_TRIGGER_BREAK_CONTRACT_CODE, Collections.singletonList(breakNo),null);
+
     }
 
     @Override
@@ -187,6 +196,11 @@ public class BreakContractOwnerRecordServiceImpl  implements BreakContractOwnerR
         //保存违约记录
         breakContractOwnerRecordDao.saveEntity(record);
 
+        //货主违约通知 站内信
+        sendInternalMessageService.sendInternalMessageMq(InternalMessageTemplateEnum.PlatformType.CARRIER.getCode(),
+                InternalMessageTemplateEnum.BusinessType.WAIT_APPROVED_ITEM.getCode(),
+                InternalMessageTemplateEnum.CUSTOM_OWNER_TRIGGER_BREAK_CONTRACT_CODE, Collections.singletonList(breakNo),null);
+
     }