水尺监测入库逻辑调整

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,6 +66,13 @@
        JSONArray jsonArray = jsonObject.getJSONArray("data");
        if (null!= jsonArray && jsonArray.size()>0) {
            for (int i = 0; i < jsonArray.size(); i++) {
                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());
@@ -86,9 +95,11 @@
                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);
            }
        }
    }
}
}