修复iotdb大批插入数据问题

yangys

2024-11-02 9a9b747962cc00801d8cce4137d1e123d556a79b

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
package com.qianwen.mdc.collect.handler;
 
import java.util.Arrays;
import java.util.Date;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
import com.qianwen.mdc.collect.cache.WorkstationCache;
import com.qianwen.mdc.collect.dto.PackedTelemetryData;
import com.qianwen.mdc.collect.entity.iotdb.DeviceState;
import com.qianwen.mdc.collect.entity.mgr.GlobalWcsOfRps;
import com.qianwen.mdc.collect.enums.FeedbackTimePointEnum;
import com.qianwen.mdc.collect.service.DeviceStateService;
 
@Component
public class DeviceStatusDataHandler implements TelemetryDataHandler {
    private static final Logger log = LoggerFactory.getLogger(DeviceStatusDataHandler.class);
    @Autowired
    private WorkstationCache workstationCache;
 
    @Autowired
    private DeviceStateService deviceStateService;
    @Override
    public void handleData(PackedTelemetryData data) {
        DeviceState state = new DeviceState();
        state.setTime(data.getTime());
        state.setCalendarCode(data.getCalendarCode());
        
        state.setFactoryDate(data.getFactoryDate());
        state.setFactoryMonth(data.getFactoryMonth());
        state.setFactoryWeek(data.getFactoryWeek());
        state.setFactoryYear(data.getFactoryYear());
        state.setIsFixPoint(false);
        state.setIsSync(false);
        state.setIsDeleted(false);
        
        state.setEmployeeId(workstationCache.getBelongToEmployeeForWorkstation(data.getWorkstationId(), new Date(data.getTime())));
        
        state.setFeedbackPointType(FeedbackTimePointEnum.NO_FEED_BACK_POINT.getValue());
        //WorkstationState propertyData = (WorkstationState) Objects.requireNonNull(BeanUtil.copy(entity, WorkstationState.class));
        state.setValueCollect(translateStatus(data.getValue()));
        
        state.setWcs(state.getValueCollect());
        state.setWorkstationId(data.getWorkstationId());
        
        state.setShiftIndex(data.getShiftIndex());
        state.setShiftTimeType(data.getShiftTimeType());
        fillWorkStationCondition(data, state);
       
        deviceStateService.saveDeviceStates(Arrays.asList(state));
        
        log.info("设备状态保存完成");
    }
    
    private void fillWorkStationCondition(PackedTelemetryData data, DeviceState state) {
        GlobalWcsOfRps wcsOfRps = workstationCache.getWorkstationWcsSetting(data.getWorkstationId(), data.getValue());
        log.info("工况以及绩效信息：{}" ,wcsOfRps);
 
        state.setRps(Integer.valueOf(wcsOfRps.getRps()));
        state.setIsPlan(Integer.valueOf(wcsOfRps.getIsPlan()));
        //log.info("获取包装工况以及绩效信息" + JsonUtil.toJson(workstationState));
       
    }
    
    int translateStatus(String statusVal) {
        
        int oriStatus = Integer.valueOf(statusVal);
        
        int result = oriStatus;
        /*
        //西门子828d,   cnc_run_status: 运行状态(0：RESET，1：STOP，2：HOLD，3：START，4：SPENDLE_CW_CCW，5：OTHER)
        switch(oriStatus) {
            case 3://START
                result = 2;
                break;
            case 0://，reset
            case 2://hold
                result = 3;//3待机
                break;
            case 4://    SPENDLE_CW_CCW
                result = 2;
                break;
            case 5://其他
                result = oriStatus;
                break;
            default:
                 result = oriStatus;
        }
        log.info("statusconvert,ori={},result={}",oriStatus,result);
        if(result == 0) {
            result = 2;//
        }*/
        return result;
    }
}