水尺监测入库逻辑调整

zrj

2024-06-06 607796545d4654b93a4df8f2a0ddd08aa0c1061e

水尺监测入库逻辑调整

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/hk/service/impl/HkStaffGaugeMonServiceImpl.java

@@ -9,12 +9,14 @@
import cn.gistack.sm.hk.vo.HkStaffGaugeMonVO;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

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

import static cn.gistack.sm.hk.constant.HkConstant.waterGaugeURLs;
@@ -64,30 +66,39 @@
        JSONArray jsonArray = jsonObject.getJSONArray("data");
        if (null!= jsonArray && jsonArray.size()>0) {
            for (int i = 0; i < jsonArray.size(); i++) {
                HkStaffGaugeMon hkStaffGaugeMon = new HkStaffGaugeMon();
                // 设置数据
                hkStaffGaugeMon.setId(IdUtils.getIdBy36());
                hkStaffGaugeMon.setGaugeMonId(jsonArray.getJSONObject(i).getString("id"));
                hkStaffGaugeMon.setWaterGaugeName(jsonArray.getJSONObject(i).getString("waterGaugeName"));
                hkStaffGaugeMon.setWaterGaugeCode(jsonArray.getJSONObject(i).getString("waterGaugeCode"));
                hkStaffGaugeMon.setCameraIndexCode(jsonArray.getJSONObject(i).getString("cameraIndexCode"));
                hkStaffGaugeMon.setCameraName(jsonArray.getJSONObject(i).getString("cameraName"));
                hkStaffGaugeMon.setLocation(jsonArray.getJSONObject(i).getString("location"));
                hkStaffGaugeMon.setMarkPic(jsonArray.getJSONObject(i).getString("markPic"));
                hkStaffGaugeMon.setMarkData(jsonArray.getJSONObject(i).getString("markData"));
                hkStaffGaugeMon.setCreateTime(jsonArray.getJSONObject(i).getDate("createTime"));
                hkStaffGaugeMon.setConfigUpdateTime(jsonArray.getJSONObject(i).getDate("configUpdateTime"));
                hkStaffGaugeMon.setUpdateTime(jsonArray.getJSONObject(i).getDate("updateTime"));
                hkStaffGaugeMon.setDeleteStatus(jsonArray.getJSONObject(i).getInteger("deleteStatus"));
                hkStaffGaugeMon.setCurrentPic(jsonArray.getJSONObject(i).getString("currentPic"));
                hkStaffGaugeMon.setAlarmHeight(jsonArray.getJSONObject(i).getDouble("alarmHeight"));
                hkStaffGaugeMon.setRemark1(jsonArray.getJSONObject(i).getString("remark1"));
                hkStaffGaugeMon.setRemark2(jsonArray.getJSONObject(i).getString("remark2"));
                hkStaffGaugeMon.setRemark3(jsonArray.getJSONObject(i).getString("remark3"));
                hkStaffGaugeMon.setRemark4(jsonArray.getJSONObject(i).getString("remark4"));
                hkStaffGaugeMon.setRemark5(jsonArray.getJSONObject(i).getString("remark5"));
                // 保存
                save(hkStaffGaugeMon);
                String cameraIndexCode = jsonArray.getJSONObject(i).getString("cameraIndexCode");
                Date updateTime = jsonArray.getJSONObject(i).getDate("updateTime");
                // 查询去重
                QueryWrapper<HkStaffGaugeMon> wrapper = new QueryWrapper<>();
                wrapper.eq("camera_index_code",cameraIndexCode).eq("update_time",updateTime);
                List<HkStaffGaugeMon> list = list(wrapper);
                if (list.size()==0) {
                    HkStaffGaugeMon hkStaffGaugeMon = new HkStaffGaugeMon();
                    // 设置数据
                    hkStaffGaugeMon.setId(IdUtils.getIdBy36());
                    hkStaffGaugeMon.setGaugeMonId(jsonArray.getJSONObject(i).getString("id"));
                    hkStaffGaugeMon.setWaterGaugeName(jsonArray.getJSONObject(i).getString("waterGaugeName"));
                    hkStaffGaugeMon.setWaterGaugeCode(jsonArray.getJSONObject(i).getString("waterGaugeCode"));
                    hkStaffGaugeMon.setCameraIndexCode(jsonArray.getJSONObject(i).getString("cameraIndexCode"));
                    hkStaffGaugeMon.setCameraName(jsonArray.getJSONObject(i).getString("cameraName"));
                    hkStaffGaugeMon.setLocation(jsonArray.getJSONObject(i).getString("location"));
                    hkStaffGaugeMon.setMarkPic(jsonArray.getJSONObject(i).getString("markPic"));
                    hkStaffGaugeMon.setMarkData(jsonArray.getJSONObject(i).getString("markData"));
                    hkStaffGaugeMon.setCreateTime(jsonArray.getJSONObject(i).getDate("createTime"));
                    hkStaffGaugeMon.setConfigUpdateTime(jsonArray.getJSONObject(i).getDate("configUpdateTime"));
                    hkStaffGaugeMon.setUpdateTime(jsonArray.getJSONObject(i).getDate("updateTime"));
                    hkStaffGaugeMon.setDeleteStatus(jsonArray.getJSONObject(i).getInteger("deleteStatus"));
                    hkStaffGaugeMon.setCurrentPic(jsonArray.getJSONObject(i).getString("currentPic"));
                    hkStaffGaugeMon.setAlarmHeight(jsonArray.getJSONObject(i).getDouble("alarmHeight"));
                    hkStaffGaugeMon.setRemark1(jsonArray.getJSONObject(i).getString("remark1"));
                    hkStaffGaugeMon.setRemark2(jsonArray.getJSONObject(i).getString("remark2"));
                    hkStaffGaugeMon.setRemark3(jsonArray.getJSONObject(i).getString("remark3"));
                    hkStaffGaugeMon.setRemark4(jsonArray.getJSONObject(i).getString("remark4"));
                    hkStaffGaugeMon.setRemark5(jsonArray.getJSONObject(i).getString("remark5"));
                    hkStaffGaugeMon.setSysCreateTime(new Date());
                    // 保存
                    save(hkStaffGaugeMon);
                }
            }
        }
    }