放假备份。完成集中控制器对接。

Van333

2022-12-29 727a69f859060093e685582fa10e5de82dcc138a

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
package com.sandu.ximon.admin.manager.iot.frame.inner.request;
 
import com.sandu.ximon.admin.manager.iot.frame.inner.IRequestInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.C3ChargingEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.MQTTConnectTypeEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.util.CRC32Utils;
import com.sandu.ximon.admin.manager.iot.rrpc.util.SupplementUtils;
import com.sandu.ximon.dao.domain.C3mChargingCharge;
 
import java.text.DecimalFormat;
import java.util.List;
 
/**
 * @author ZZQ
 * @date 2022/8/15 11:23
 */
public class C3SetRateReqInnerFrame implements IRequestInnerFrame {
    private final String payload;
 
 
    public C3SetRateReqInnerFrame(String c3Mac, List<C3mChargingCharge> list) {
        StringBuffer buffer = new StringBuffer();
 
        for (C3mChargingCharge bean : list) {
            //时间
            String hour = SupplementUtils.suppleZero(hex10To16(bean.getHour()), 2);
            String min = SupplementUtils.suppleZero(hex10To16(bean.getMin()), 2);
 
            //费率
            double chargeValue = bean.getCharge() * 10;
            String chargeHex = hex10To16(
                    Integer.parseInt(new DecimalFormat("0").format(chargeValue)));
            String charge;
            if (chargeHex.length() > 2) {
                charge = "FF";
            } else {
                charge = SupplementUtils.suppleZero(chargeHex, 2);
            }
 
            buffer = buffer.append(hour);
            buffer = buffer.append(min);
            buffer = buffer.append(charge);
        }
 
        //添加默认的无效费率
        for (int i = 0; i < (5 - list.size()); i++) {
            //时间
            buffer = buffer.append("FFFF");
            //费率
            buffer = buffer.append("FF");
        }
 
        this.payload = c3Mac + buffer;
    }
 
    @Override
    public String getEncodeFrame() {
        String functionCode = C3ChargingEnum.SetRate.getCode();
        String payloadLength = "0013";
        String frame = functionCode + payloadLength + payload;
        return MQTTConnectTypeEnum.SYNCHRONIZATION.getCode() + frame.toUpperCase() + CRC32Utils.getCRC32(frame.toUpperCase());
    }
 
    /**
     * 十进制转16进制
     *
     * @param value
     * @return
     */
    private String hex10To16(int value) {
        return String.format("%02X", value);
    }
 
}