fix

zhanzhiqin

2022-05-17 2e206ace04c399a81773dc4256a22c5510422161

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
package com.sandu.ximon.admin.utils;
 
import com.sandu.common.util.SpringContextHolder;
import com.sandu.ximon.admin.manager.iot.frame.A5Frame;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
import com.sandu.ximon.admin.service.DeviceOperationLogService;
import com.sandu.ximon.admin.service.InnerFrameDataService;
import com.sandu.ximon.dao.domain.Pole;
import com.sandu.ximon.dao.mapper.PoleBindingMapper;
 
import java.util.ArrayList;
import java.util.List;
 
/**
 * @author ZZQ
 * @date 2022/5/13 15:06
 */
public class StoreOperationRecordsUtils {
    /**
     * 保存硬件控制帧数据
     *
     * @param mac
     * @param innerFrameTpye
     * @param a5Frame
     * @param commonFrame
     */
    public static void storeInnerFrameData(String mac, String innerFrameTpye, A5Frame a5Frame, CommonFrame commonFrame) {
        String reportInnerFrame = "";
        if (commonFrame != null) {
            reportInnerFrame = commonFrame.getConnectType() + commonFrame.getFunctionCode() + commonFrame.getOrderType() + commonFrame.getPayloadLength() + commonFrame.getPayload();
        }
        String requstInnerFrame = a5Frame.getConnectType() + a5Frame.getFunctionCode() + a5Frame.getOrderType() + a5Frame.getPayloadLength() + a5Frame.getPayload();
        String syncType;
        if ("FE".equals(a5Frame.getConnectType())) {
            syncType = "同步";
        } else {
            syncType = "异步";
        }
        SpringContextHolder.getBean(InnerFrameDataService.class).storeInnerFrameData(mac, innerFrameTpye, syncType, requstInnerFrame, reportInnerFrame);
    }
 
    /**
     * 保存操作数据
     *
     * @param deviceCodeList
     * @param deviceName
     * @param operation
     * @param content
     */
    public static void storeOperationData(List deviceCodeList, String deviceName, String operation, String content) {
        if (deviceCodeList == null) {
            deviceCodeList = new ArrayList<>();
        }
        List<String> poleCodeList = new ArrayList<>();
        for (Object str : deviceCodeList) {
            Pole pole = SpringContextHolder.getBean(PoleBindingMapper.class).getPoleByBinding(null, String.valueOf(str), null);
            if (pole != null) {
                poleCodeList.add(pole.getDeviceCode());
            } else {
                poleCodeList.add("");
            }
        }
        SpringContextHolder.getBean(DeviceOperationLogService.class)
                .saveDeviceOperationLog(deviceCodeList.toString(), deviceName, operation, content, poleCodeList.toString());
    }
 
    /**
     * 登录专属
     *
     * @param userId
     * @param UserName
     * @param operation
     * @param content
     */
    public static void storeOperationLoginData(Long userId, String UserName, String operation, String content) {
        SpringContextHolder.getBean(DeviceOperationLogService.class)
                .storeOperationLoginData(userId, UserName, operation, content);
    }
}