测试代码

yangys

2024-05-30 a3686cfa49bf53fb91a2ceb960cf15b3ebdac641

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/SuperNewCollectServiceImpl.java

@@ -23,7 +23,7 @@
public class SuperNewCollectServiceImpl implements ISuperNewCollectService {
    private final SuperCollectJsonMapper collectJsonMapper;
    private static final Logger log = LoggerFactory.getLogger(SuperNewCollectServiceImpl.class);
    private static final Map<Integer, String> PROCESS_PARAM_MAP = new HashMap();
    private static final Map<Integer, String> PROCESS_PARAM_MAP = new HashMap<>();

    static {
        PROCESS_PARAM_MAP.put(1, "STATE");
@@ -39,16 +39,17 @@
        this.collectJsonMapper = collectJsonMapper;
    }

    
    @Override
    public void insertData(Set<String> workstationIds) {
        List<NewParamSaveDTO> data = workstationIds.stream().map(workstationId -> {
            Map<String, Object> realTimeData = WorkstationCache.getWorkstationAllCollect(workstationId);
            Map<String, Object> realTimeData = WorkstationCache.getWorkstationAllCollect(workstationId);//实时数据，
            if (Func.isNotEmpty(realTimeData)) {
                int size = realTimeData.size();
                long time = DateUtil.now().getTime();
                Map<String, String> valuesMap = new HashMap<>(size);
                realTimeData.forEach((n, telemetry) -> {
                    if (!n.toUpperCase().contains(CollectConstant.ALARM)) {
                    if (!n.toUpperCase().contains(CollectConstant.ALARM)) {//去除ALARM数据
                        TelemetryDataResponseDTO dto = (TelemetryDataResponseDTO) telemetry;
                        String v = dto.getV();
                        if (Func.isNotEmpty(v) && v.length() <= CollectConstant.MAX_VALUE.intValue() && !v.contains("timestamp")) {