服务商

jiangping

2023-12-29 f9691d544e62d6c04dbfe45d05a6c7bc5e004291

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package com.doumee.core.dingding;
 
import com.alibaba.fastjson.JSONObject;
import com.doumee.core.constants.Constants;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.HttpsUtil;
import com.doumee.dao.business.model.BikeRepair;
import com.doumee.dao.business.model.Sites;
import com.doumee.dao.business.web.request.RepairRequest;
import org.apache.commons.codec.binary.Base64;
 
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.math.BigDecimal;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
/**
 * Created by IntelliJ IDEA.
 *
 * @Author : Rk
 * @create 2022/12/7 11:16
 */
public class DingDingNotice {
 
 
    /**
     * 钉钉机器人 加签
     * @param timestamp
     * @param secret
     * @return
     * @throws Exception
     */
    public static String getSign(Long timestamp, String secret)  throws Exception{
        String stringToSign = timestamp + "\n" + secret;
        Mac mac = Mac.getInstance("HmacSHA256");
        mac.init(new SecretKeySpec(secret.getBytes("UTF-8"), "HmacSHA256"));
        byte[] signData = mac.doFinal(stringToSign.getBytes("UTF-8"));
        String sign = URLEncoder.encode(new String(Base64.encodeBase64(signData)),"UTF-8");
        return sign;
    }
 
 
    /**
     * 钉钉通知 - 车辆异常上报
     * @param repairRequest
     * @param ddUrl
     * @throws Exception
     */
    public static void bikeRepair(RepairRequest repairRequest, String ddUrl , String secret)  throws Exception{
        Long timestamp = System.currentTimeMillis();
        Map<String,Object> content = new HashMap<>();
        content.put("msgtype","text");
        Map<String,String> text = new HashMap<>();
        text.put("content","【故障上报】车辆编号："+repairRequest.getBikeCode()+"，位置："+repairRequest.getAddr()+"，联系电话："+repairRequest.getLinkphone()+"，请及时查看处理。");
        content.put("text",text);
        HttpsUtil.post(ddUrl+"&timestamp="+timestamp+"&sign="+getSign(timestamp,secret), JSONObject.toJSONString(content),"application/json",false);
    }
    /**
     * 钉钉通知 - 站点通信异常上报
     * @param ddUrl
     * @throws Exception
     */
    public static void siteNoLink(List<Sites> siteList, String ddUrl , String secret)  throws Exception{
        Long timestamp = System.currentTimeMillis();
        Map<String,Object> content = new HashMap<>();
        content.put("msgtype","text");
        Map<String,String> text = new HashMap<>();
        String  desc = "";
        if(siteList.size() == 1){
            desc = "【站点异常上报】站点【"+siteList.get(0).getId()+"】，自【"+ DateUtil.getPlusTime2(siteList.get(0).getLastLinkDate())+"】后未收到通讯请求,请及时查看处理\n";
        }else{
               desc = "【站点异常上报】 以下站点通讯发生异常，请及时查看处理：\n";
            for (Sites site : siteList){
                desc += "站点【"+site.getId()+"】，自【"+ DateUtil.getPlusTime2(site.getLastLinkDate())+"】后未收到通讯请求\n";
            }
        }
 
        text.put("content",desc);
        content.put("text",text);
        HttpsUtil.post(ddUrl+"&timestamp="+timestamp+"&sign="+getSign(timestamp,secret), JSONObject.toJSONString(content),"application/json",false);
    }
 
 
    /**
     * 钉钉通知 - 站点储车告警
     * @param siteName
     * @param ddUrl
     * @param secret
     * @param type 0=超出 1=低于
     * @param warnVal 报警值
     * @throws Exception
     */
    public static void reservesNotice(String siteName, String ddUrl , String secret, Integer type, BigDecimal warnVal)  throws Exception{
        Long timestamp = System.currentTimeMillis();
        Map<String,Object> content = new HashMap<>();
        content.put("msgtype","text");
        Map<String,String> text = new HashMap<>();
        //text.put("content","【站点储车告警】"+siteName+"，储车量超过80%/低于20%，请及时进行车辆调配");
 
        text.put("content","【站点储车告警】"+siteName+"，储车量"+(type.equals(Constants.ZERO)?"超出":"低于")+warnVal+"%，请及时进行车辆调配");
        content.put("text",text);
        HttpsUtil.post(ddUrl+"&timestamp="+timestamp+"&sign="+getSign(timestamp,secret), JSONObject.toJSONString(content),"application/json",false);
    }
}