1

13693261870

2023-04-26 d254c34b538e190fd5a9355d757f64bd495bdda9

1

 src/main/java/com/yssh/controller/SuYuanController.java

@@ -102,5 +102,15 @@
    public Result getMonitorData(@PathVariable("name") String name){
        List<SuYuanMonitorData> list = suYuanService.getMonitorData(name);
        return Result.OK(list);
    }

    @ApiOperation(value = "更新Vocs名称", notes = "更新Vocs名称")
    @ApiOperationSupport(order = 7)
    @GetMapping("/updateVocsName")
    public Result updateVocsName(@RequestParam(value = "date", required = true) @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") Date date,
                                 @RequestParam(value = "id", required = true) String id,
                                 @RequestParam(value = "vocsName", required = true) String vocsName
    ) {
        return Result.OK(suYuanService.updateVocsName(date, id, vocsName));
    }
}

 src/main/java/com/yssh/dao/SuYuanMapper.java

@@ -1,5 +1,6 @@
package com.yssh.dao;

import java.util.Date;
import java.util.List;
import java.util.Map;

@@ -36,4 +37,6 @@
    
    //获取本月指定监测站点监测值对大的数据
    Map<String, Object> getMonthValueDataMax(@Param("tableNames") List<String> tableNames, @Param("id") String id);

    int updateVocsName(String table, String id, String vocsName);
}

 src/main/java/com/yssh/service/IDictRecordService.java

@@ -2,6 +2,7 @@

import com.yssh.entity.DictRecord;

import java.util.Date;
import java.util.List;

/**
@@ -45,5 +46,4 @@
     * 创建字典记录信息表
     */
    int createDictRecoTable();

}

 src/main/java/com/yssh/service/ISuYuanService.java

@@ -32,4 +32,6 @@
    public List<SuYuanMonitorData> getMonitorData(String name);

    //public List<Temporary> temporary(String name, Date date);

    public int updateVocsName(Date date, String id, String vocsName);
}

 src/main/java/com/yssh/service/impl/DictRecordServiceImpl.java

@@ -1,5 +1,6 @@
package com.yssh.service.impl;

import java.util.Date;
import java.util.List;

import lombok.Synchronized;
@@ -25,6 +26,7 @@

    /**
     * 查询字典记录列表
     *
     * @param dictRecord 字典记录
     * @return 字典记录
     */
@@ -35,6 +37,7 @@

    /**
     * 新增字典记录
     *
     * @param dictRecord 字典记录
     * @return 结果
     */
@@ -45,6 +48,7 @@

    /**
     * 删除字典记录对象
     *
     * @param ids 需要删除的数据ID
     * @return 结果
     */
@@ -56,6 +60,7 @@

    /**
     * 删除字典记录信息
     *
     * @param id 字典记录ID
     * @return 结果
     */
@@ -73,5 +78,4 @@
    public int createDictRecoTable() {
        return dictRecordMapper.createDictRecoTable();
    }

}

 src/main/java/com/yssh/service/impl/SuYuanServiceImpl.java

@@ -1,5 +1,6 @@
package com.yssh.service.impl;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
@@ -54,6 +55,8 @@
    
    @Autowired
    private FeedbackMapper feedbackMapper;

    private SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHH");
    
    //@Transactional
    @Override
@@ -122,7 +125,11 @@
        }
        List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
        AtomicInteger i = new AtomicInteger(0);
        list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
        list.stream().forEach(s -> {
            s.setName(checkPoint.getName());
            i.getAndIncrement();
            s.setVocsName(checkPoint.getName() + "-" + i.longValue());
        });
        if (StringUtils.isNotEmpty(list)) {
            Collections.sort(list);
            DistanceSuYuan max = list.get(0);
@@ -151,7 +158,11 @@
        }
        List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
        AtomicInteger i = new AtomicInteger(0);
        list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
        list.stream().forEach(s -> {
            s.setName(checkPoint.getName());
            i.getAndIncrement();
            s.setVocsName(checkPoint.getName() + "-" + i.longValue());
        });
        if (StringUtils.isNotEmpty(list)) {
            Collections.sort(list);
            DistanceSuYuan max = list.get(0);
@@ -180,7 +191,11 @@
        }
        List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
        AtomicInteger i = new AtomicInteger(0);
        list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
        list.stream().forEach(s -> {
            s.setName(checkPoint.getName());
            i.getAndIncrement();
            s.setVocsName(checkPoint.getName() + "-" + i.longValue());
        });
        if (StringUtils.isNotEmpty(list)) {
            Collections.sort(list);
            DistanceSuYuan max = list.get(0);
@@ -209,7 +224,11 @@
        }
        List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
        AtomicInteger i = new AtomicInteger(0);
        list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
        list.stream().forEach(s -> {
            s.setName(checkPoint.getName());
            i.getAndIncrement();
            s.setVocsName(checkPoint.getName() + "-" + i.longValue());
        });
        if (StringUtils.isNotEmpty(list)) {
            Collections.sort(list);
            DistanceSuYuan max = list.get(0);
@@ -230,8 +249,19 @@
        }
        List<DictRecord> recordList = dictRecordMapper.selectDictRecordList(new DictRecord());
        List<String> tableNames = new ArrayList<String>();
        recordList.stream().forEach(s -> {tableNames.add(s.getTableName());});
        recordList.stream().forEach(s -> {
            tableNames.add(s.getTableName());
        });
        return suYuanMapper.getMonitorData(tableNames, checkPoint.getX() + "_" + checkPoint.getY() + "_" + checkPoint.getZ());
    }

    @Override
    public int updateVocsName(Date date, String id, String vocsName) {
        String table = "su_yuan_" + dateFormat.format(new Date());
        if (isTableExists(table) == 0) {
            return 0;
        }

        return suYuanMapper.updateVocsName(table, id, vocsName);
    }
}

 src/main/resources/mapping/SuYuanMapper.xml

@@ -191,4 +191,8 @@
    <update id="update" >
        UPDATE ${tableName} SET c = #{value} WHERE id = #{id}
    </update>

    <update id="updateVocsName">
        update ${table} set vocsName = #{vocsName} where id = #{id};
    </update>
</mapper>