Java报告推送失败补偿机制;钉钉群通知消息核心代码

简介: Java报告推送失败补偿机制,超过次数后使用钉钉通知开发自动补偿实现:要求方法调用的过程中,失败的时候,系统有办法进行自动重试,重试达到一定次数后,钉钉通知开发。实现设计:注解,反射,定时任务

Java报告推送失败补偿机制,超过次数后使用钉钉通知开发

自动补偿实现:

要求方法调用的过程中,失败的时候,系统有办法进行自动重试,重试达到一定次数后,钉钉通知开发。

实现设计:注解,反射,定时任务

自动一般涉及到定时任务。

钉钉群通知消息核心代码

钉钉群通知消息核心代码

application-local.yml

自动一般涉及到定时任务。
钉钉群通知消息核心代码
钉钉群通知消息核心代码
在这里插入图片描述
application-local.yml
messa

钉钉订单监听消息

@Slf4j
@Component
@SuppressWarnings("PMD")
public class DingOrderDistributeMessageListener implements MessageListener {
    @Autowired
    private MessageConfig messageConfig;
    @Override
    public Action consume(Message message, ConsumeContext consumeContext) {
        try {
            boolean notifyOpen = messageConfig.getNotifyDistributeOpen();
            if (!notifyOpen) {
                log.info("订单分配通知开关已关闭/未配置 messageOpen:{}", notifyOpen);
                return Action.CommitMessage;
            }
            // 订单钉钉通知群url
            String dingWebHookUrl = messageConfig.getDingDistributeUrl();
            // 密钥
            String orderSecret = messageConfig.getDingDistributeSecret();
            // 钉钉消息体
            String messageBody = messageConfig.getDingDistributeMessageBody();
            if (StringUtils.isEmpty(messageBody) || StringUtils.isEmpty(dingWebHookUrl)
                    || StringUtils.isEmpty(orderSecret)) {
                log.info("发送订单分配钉钉消息, 消息配置项未配置");
                return Action.CommitMessage;
            }
            // 请求体
            String requestBody = new String(message.getBody(), StandardCharsets.UTF_8);
            // 报告消息体
            DingOrderDistributeMessage orderMessage = JSONObject.parseObject(requestBody,
                    DingOrderDistributeMessage.class);
            // 请求消息
            String sendMessage = String.format(messageBody, "\n", orderMessage.getCode() + "\n",
                    orderMessage.getDeviceType() + "\n", orderMessage.getAppVersion() + "\n",
                    orderMessage.getGoodsName() + "\n", orderMessage.getPayAmount() + "\n",
                    orderMessage.getPayType() + "\n", orderMessage.getPlaceTime() + "\n",
                    orderMessage.getDistributeTime() + "\n", orderMessage.getAdminUserName());
            List<String> mobileList = new ArrayList<>();
            if (StringUtils.isNotEmpty(orderMessage.getAdminUserPhone())) {
                mobileList.add(orderMessage.getAdminUserPhone());
            }
            String dingMessage = DingMessageUtil.generateMessageBody(sendMessage, false, mobileList);
            // 发送钉钉消息
            DingMessageUtil.sendMessage(orderSecret, dingMessage, dingWebHookUrl);
            return Action.CommitMessage;
        } catch (Exception e) {
            log.error("发送报告钉钉消息出现异常:{}", e);
            return Action.ReconsumeLater;
        }
    }
}

MessageConfig 是个实体类

@ConfigurationProperties(prefix = "message.config")
@Component
@Data
public class MessageConfig {
    @ApiModelProperty("钉钉报告机密钥")
    private String dingReportSecret;
    @ApiModelProperty("钉钉报告地址")
    private String dingReportUrl;
    @ApiModelProperty("钉钉报告密钥")
    private String dingOrderSecret;
    @ApiModelProperty("钉钉订单消息图片地址")
    private String dingOrderPicUrl;
    @ApiModelProperty("钉钉订单消息头部")
    private String dingOrderTitle;
    @ApiModelProperty("订单钉钉报告地址")
    private String dingOrderUrl;
    @ApiModelProperty("订单路由地址")
    private String orderRouteUrl;
    @ApiModelProperty("钉钉订单消息体")
    private String dingOrderMessageBody;
    @ApiModelProperty("钉钉报告消息体")
    private String dingReportMessageBody;
    @ApiModelProperty("消息开关")
    private Boolean notifyOpen;
    @ApiModelProperty("钉钉日报")
    private String dingDailyReportMessageBody;
    @ApiModelProperty("订单分配通知开关")
    private Boolean notifyDistributeOpen;
    @ApiModelProperty("分配订单通知密钥")
    private String dingDistributeSecret;
    @ApiModelProperty("分配通知地址")
    private String dingDistributeUrl;
    @ApiModelProperty("订单分配消息主体")
    private String dingDistributeMessageBody;
}

微服务实际去调用这钉钉消息

    public void sendOrderDistributeMessage(Order order, String adminUserName, String adminUserPhone,
                                           Date distributeTime) {
        log.info("发送订单分配钉钉消息 order:{}, adminUserName:{}, adminUserPhone:{}, distributeTime:{}", order,
                adminUserName, adminUserPhone, distributeTime);
        // 适配部分下单在支付通知才回填支付方式
        Order dbOrder = orderService.getByOrderNo(order.getOrderNo());
        OrderItemGoods goods = orderService.getOrderItemGoodsByOrderNo(order.getOrderNo());
        DingOrderDistributeMessage orderMessage = new DingOrderDistributeMessage();
        orderMessage.setGoodsName(goods.getGoodsName());
        String suffix = "元";
        String payType = dbOrder.getPayTypeChannel().getName();
        PayTypeChannel payTypeChannel = dbOrder.getPayTypeChannel();
        switch (payTypeChannel) {
            case APPLE_IN:
                payType = "苹果支付";
                break;
            case WX_MWEB:
            case WX_APP:
            case WX_JSAPI:
            case WX_MICROPAY:
            case WX_NATIVE:
                payType = "微信";
                break;
            case SSCM:
                suffix = "上上贝";
                payType = "上上贝";
                break;
            case ALIPAY_PC:
            case ALIPAY_QR:
            case ALIPAY_WAP:
            case ALIPAY_MOBILE:
                payType = "支付宝";
                break;
            default:
                break;
        }
        orderMessage.setPayType(payType);
        orderMessage.setPayAmount(AmountUtils.changeFen2Yuan(order.getPayAmount()) + suffix);
        orderMessage.setPlaceTime(DateUtils.formatYYYYMMDDHHMMSS(order.getPlaceTime()));
        User user = userRemoteService.getById(order.getPlaceUserId()).getData();
        orderMessage.setUserName(user.getUsername());
        orderMessage.setCode(user.getCode());
        orderMessage.setOrderNo(order.getOrderNo());
        List<UserChannel> userChannelList = userRemoteService.getUserChannelList().getData();
        Map<String, String> userChannelMap = userChannelList.stream()
                .collect(Collectors.toMap(UserChannel::getChannelCode, UserChannel::getChannelName));
        orderMessage.setDeviceType(userChannelMap.get(user.getChannelCode()));
        orderMessage.setAppVersion(user.getVersionName());
        orderMessage.setDistributeTime(DateUtils.formatYYYYMMDDHHMMSS(distributeTime));
        orderMessage.setAdminUserName(adminUserName);
        orderMessage.setAdminUserPhone(adminUserPhone);
        mqSend.sendDingOrderDistributeMessage(orderMessage);
    }
    /**
     *  发送钉钉订单分配消息
     * @param orderMessage
     */
    void sendDingOrderDistributeMessage(DingOrderDistributeMessage orderMessage);
    @Override
    public void sendDingOrderDistributeMessage(DingOrderDistributeMessage orderMessage) {
        String message = JSON.toJSONString(orderMessage);
        LOGGER.info("sendPayOrderMessage take success send message to mq message = {}", message);
        producerUtil.sendAsyncMsg(orderConfig.getOrderTopic(), orderConfig.getOrderTopicDistributeDingTag(),
                message, orderMessage.getOrderNo());
    }
相关文章
|
小程序 API
钉钉小程序端https和http发送的实例代码
钉钉小程序端https和http发送的实例代码
385 1
|
7月前
|
数据采集 人工智能 数据挖掘
【钉钉杯大学生大数据挑战赛】初赛B 航班数据分析与预测 Python代码实现Baseline
本文提供了参加"钉钉杯大学生大数据挑战赛"初赛B的航班数据分析与预测项目的Python代码实现Baseline。内容包括题目背景、思路分析、训练集和测试集的预处理、模型训练与预测、特征重要性分析,以及代码下载链接。预处理步骤涉及读取数据、时间信息处理、前序航班延误时间计算、天气信息匹配等。模型训练使用了Gradient Boosting Classifier,并对模型的准确率和特征重要性进行了评估。
123 0
|
10月前
|
Java API
java提交钉钉审批的一个流程例子
java提交钉钉审批的一个流程例子
292 0
|
移动开发 Java Maven
【Java用法】使用Java开发连接钉钉应用实现钉钉通知的功能
【Java用法】使用Java开发连接钉钉应用实现钉钉通知的功能
311 0
|
消息中间件 存储 安全
|
SQL 监控 机器人
钉钉告警机器人Java接入指南
本文讲实现Java代码调用钉钉机器人API,发送指定告警消息的效果,以满足用户对于系统的实时监控。 API:https://open.dingtalk.com/document/orgapp/custom-robots-send-group-messages 每个机器人每分钟最多发送20条消息到群里,如果超过20条,会限流10分钟。 重要 如果有大量发消息的场景(譬如系统监控报警)可以将这些信息进行整合,通过markdown消息以摘要的形式发送到群
1789 1
|
监控 Java 中间件
拦截应用 error日志并发送到钉钉群|Java 开发实战
现在应用都需要对日志进行监控或者报警,现在普遍的做法是采用EKL收集日志,然后再由Grafana进行内容展示和及告警策略等,那如果项目架构比较简单(单体应用),又不想搞那么多中间件依赖怎么办,这里有一种简单的方式可以实现~
488 0
拦截应用 error日志并发送到钉钉群|Java 开发实战
|
Shell 开发工具 数据安全/隐私保护
Git提交之后自动打版本并钉钉通知
Git提交之后自动打版本并钉钉通知
496 0
Git提交之后自动打版本并钉钉通知
|
Java
全网首发:OPPO推送:服务器端的参考代码,JAVA版
全网首发:OPPO推送:服务器端的参考代码,JAVA版
378 0
|
机器人 Java
钉钉通知Java
钉钉发送群消息是常用的业务场景,现在详细来说下 建好钉钉群,建好机器人 这些参数在建立机器人后会自动给你的,这两参数比较重要,然代码识别知道哪个钉钉群和哪个机器人需要发送消息。 首先测试钉钉方法
233 0