接受订单信息

gic-evaluate-service/src/main/java/com/gic/evaluate/service/outer/impl/EvaluateMsgLogApiServiceImpl.java

@@ -95,6 +95,7 @@ public class EvaluateMsgLogApiServiceImpl implements EvaluateMsgLogApiService {
         for (Integer enterpriseId : enterpriseIds) {
             GicMQClient client = GICMQClientUtil.getClientInstance();
             try {
+                logger.info("定时发送 企业：{}", enterpriseId.toString());
                 client.sendMessage("queueSendMemberMessage", enterpriseId.toString());
             } catch (Exception e) {
                 logger.info("发送队列错误", e);
@@ -132,6 +133,7 @@ public class EvaluateMsgLogApiServiceImpl implements EvaluateMsgLogApiService {
     }
 
     private void sendMsg(Integer enterpriseId, TabEvaluateMsgLog log) {
+
         // 发送信息
         MQNoticeSendDTO notice = new MQNoticeSendDTO();
 
@@ -161,7 +163,12 @@ public class EvaluateMsgLogApiServiceImpl implements EvaluateMsgLogApiService {
         // 事件需要的事件级变量 ，具体变量参考附件
         notice.setValueMap(valueMap);
 
-        this.noticeRouterApiService.putNoticeSendRouter(notice);
+        ServiceResponse<Void> voidServiceResponse = this.noticeRouterApiService.putNoticeSendRouter(notice);
+        if (voidServiceResponse.isSuccess()) {
+            logger.info("发送评价提醒成功 orderId：{}", log.getOrderId());
+        } else {
+            logger.warn("发送评价提醒失败 orderId：{}, msg:{}", log.getOrderId(), voidServiceResponse.getMessage());
+        }
     }