站点维护，人工上报导入

guoshilong

2024-03-28 419882f64115b66112f03c96892cf2d3a4f298a6

站点维护，人工上报导入

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/controller/DbPersonReportController.java

New file
@@ -0,0 +1,64 @@
package cn.gistack.sm.sjztdw.controller;

import cn.gistack.sm.sjztdw.excel.DbExcel;
import cn.gistack.sm.sjztdw.excel.DbExcelImport;
import cn.gistack.sm.sjztdw.service.IDbPersonReportService;
import lombok.AllArgsConstructor;
import org.springblade.core.boot.ctrl.BladeController;
import org.springblade.core.excel.util.ExcelUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.List;

/**
 * 大坝人工上报相关接口
 */
@RestController
@RequestMapping("/sjztdw/dbReport")
@AllArgsConstructor
public class DbPersonReportController extends BladeController {

    private IDbPersonReportService dbPersonReportService;

    /**
     * 导入模板
     */
    @GetMapping("export-template")
    public void exportTemplate(HttpServletResponse response) {
        List<DbExcel> list = new ArrayList<>();

        for (int i = 0; i < 10; i++) {
            DbExcel dbExcel = new DbExcel();
            dbExcel.setMonitorDate(StringUtil.format("2024-03-{}",10+i));
            list.add(dbExcel);
        }
        ExcelUtil.export(response, "人工上报模板", "人工上报数据表", list, DbExcel.class);
    }


    /**
     * 导入数据
     * @param file 导入excel
     * @param resGuid 水库id
     * @param ch 断面
     * @return
     */
    @PostMapping("import-data")
    public R importData(MultipartFile file,String resGuid,String ch) {
        DbExcelImport dbExcelImport = new DbExcelImport(dbPersonReportService,resGuid,ch);
        ExcelUtil.save(file, dbExcelImport, DbExcel.class);
        return R.success("操作成功");
    }




}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/entity/DwsRainResDi.java

New file
@@ -0,0 +1,122 @@
package cn.gistack.sm.sjztdw.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;

import java.util.Date;

/**
 * 水库雨情日统计表
 */
@Data
@TableName("\"dws_rain_res_di\"")
public class DwsRainResDi {

    private static final long serialVersionUID = 1L;


    @TableField(value = "\"st_cd\"")
    //雨情测站编码
    private String stCd;


    @TableField(value = "\"st_nm\"")
    //雨情测站编码
    private String stNm;


    @TableField(value = "\"res_cd\"")
    //雨情测站编码
    private String resCd;

    @TableField(value = "\"res_nm\"")
    //雨情测站编码
    private String resNm;


    @TableField(value = "\"province_cd\"")
    //雨情测站编码
    private String provinceCd;


    @TableField(value = "\"province_nm\"")
    //雨情测站编码
    private String provinceNm;


    @TableField(value = "\"city_cd\"")
    //雨情测站编码
    private String cityCd;


    @TableField(value = "\"city_nm\"")
    //雨情测站编码
    private String cityNm;


    @TableField(value = "\"county_cd\"")
    //雨情测站编码
    private String countyCd;


    @TableField(value = "\"county_nm\"")
    //雨情测站编码
    private String countyNm;


    @TableField(value = "\"town_cd\"")
    //雨情测站编码
    private String townCd;


    @TableField(value = "\"town_nm\"")
    //雨情测站编码
    private String townNm;


    @TableField(value = "\"village_cd\"")
    //雨情测站编码
    private String villageCd;

    @TableField(value = "\"village_nm\"")
    //雨情测站编码
    private String villageNm;


    @TableField(value = "\"flag\"")
    //雨情测站编码
    private String flag;


    @TableField(value = "\"dt\"")
    @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd")
    @DateTimeFormat(pattern="yyyy-MM-dd")
    //日期
    private Date dt;


    @TableField(value = "\"drp\"")
    //日累计降雨
    private String drp;


    @TableField(value = "\"is_tb\"")
    //填报方式            y        n
    private String isTb;








}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/entity/DwsResPressDi.java

New file
@@ -0,0 +1,37 @@
package cn.gistack.sm.sjztdw.entity;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.util.Date;

/**
 * 渗压日数据表
 */
@Data
@TableName("\"dws_res_press_di\"")
public class DwsResPressDi {

    //测点编码
    @TableField(value = "\"cd\"")
    private String cd;

    @TableField(value = "\"cd_nm\"")
    private String cdNm;

    @TableField(value = "\"res_cd\"")
    private String resCd;

    @TableField(value = "\"res_nm\"")
    private String resNm;

    @TableField(value = "\"avg_value\"")
    private String avgValue;

    @TableField(value = "\"dt\"")
    private Date dt;

    @TableField(value = "\"is_tb\"")
    private String isTb;
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/entity/DwsResSlDi.java

New file
@@ -0,0 +1,35 @@
package cn.gistack.sm.sjztdw.entity;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.util.Date;

/**
 * 渗压日数据表
 */
@Data
@TableName("\"dws_res_sl_di\"")
public class DwsResSlDi {

    //测点编码
    @TableField(value = "\"cd\"")
    private String cd;


    @TableField(value = "\"res_cd\"")
    private String resCd;

    @TableField(value = "\"res_reg_code\"")
    private String resRegCode;

    @TableField(value = "\"avg_spqn_value\"")
    private String avgSpqnValue;

    @TableField(value = "\"dt\"")
    private Date dt;

    @TableField(value = "\"is_tb\"")
    private String isTb;
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/entity/DwsWaterResZEightDetailAll.java

New file
@@ -0,0 +1,132 @@
package cn.gistack.sm.sjztdw.entity;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;

import java.util.Date;

@Data
@TableName("\"dws_water_res_z_eight_detail_all\"")
public class DwsWaterResZEightDetailAll {

    @TableField(value = "\"dt\"")
    @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
    private Date dt;

    @TableField(value = "\"tm\"")
    @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
    private Date tm;

    @TableField(value = "\"st_cd\"")
    //雨情测站编码
    private String stCd;


    @TableField(value = "\"st_nm\"")
    //雨情测站编码
    private String stNm;

    @TableField(value = "\"res_cd\"")
    //雨情测站编码
    private String resCd;

    @TableField(value = "\"res_nm\"")
    //雨情测站编码
    private String resNm;

    @TableField(value = "\"res_nm\"")
    private String engScal;

    @TableField(value = "\"res_lon\"")
    private String resLon;

    @TableField(value = "\"res_lat\"")
    private String resLat;


    @TableField(value = "\"province_cd\"")
    //雨情测站编码
    private String provinceCd;


    @TableField(value = "\"province_nm\"")
    //雨情测站编码
    private String provinceNm;


    @TableField(value = "\"city_cd\"")
    //雨情测站编码
    private String cityCd;


    @TableField(value = "\"city_nm\"")
    //雨情测站编码
    private String cityNm;


    @TableField(value = "\"county_cd\"")
    //雨情测站编码
    private String countyCd;


    @TableField(value = "\"county_nm\"")
    //雨情测站编码
    private String countyNm;


    @TableField(value = "\"town_cd\"")
    //雨情测站编码
    private String townCd;


    @TableField(value = "\"town_nm\"")
    //雨情测站编码
    private String townNm;


    @TableField(value = "\"village_cd\"")
    //雨情测站编码
    private String villageCd;

    @TableField(value = "\"village_nm\"")
    //雨情测站编码
    private String villageNm;

    @TableField(value = "\"rz\"")
    //监测水位
    private String rz;

    @TableField(value = "\"pat_dt\"")
    @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
    //分区日期
    private Date parDt;

    @TableField(value = "\"resource_flag\"")
    //来源
    private String resourceFlag;


    @TableField(value = "\"collect_dt\"")
    @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
    //采集时间
    private Date collectDt;

    @TableField(value = "\"low_z\"")
    //下游水位
    private String lowZ;

    @TableField(value = "\"is_tb\"")
    //是否人工
    private String isTb;




}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/excel/DbExcel.java

New file
@@ -0,0 +1,48 @@
package cn.gistack.sm.sjztdw.excel;

import com.alibaba.excel.annotation.ExcelIgnore;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.annotation.format.DateTimeFormat;
import com.alibaba.excel.annotation.write.style.ColumnWidth;
import com.alibaba.excel.annotation.write.style.ContentRowHeight;
import com.alibaba.excel.annotation.write.style.HeadRowHeight;
import lombok.Data;

import java.io.Serializable;
import java.util.Date;

/**
 * 大坝人工上报
 */
@Data
@ColumnWidth(30)
@HeadRowHeight(20)
@ContentRowHeight(18)
public class DbExcel implements Serializable {

    private static final long serialVersionUID = 1L;

    @ExcelProperty("日期")
    @DateTimeFormat("yyyy-MM-dd")
    private String monitorDate;

    @ExcelProperty("降雨量(mm)")
    //SJZT_DW   dws_rain_res_di表 drp
    private String drp;

    //SJZT_DW   dws_water_res_z_eight_detail_all表 rz  字段
    @ExcelProperty("坝前水位(m)")
    private String rz;

    //SJZT_DW   dws_water_res_z_eight_detail_all表 low_z  字段
    @ExcelProperty("下游水位(m)")
    private String lowZ;

    //SJZT_DW  dws_res_press_di      存avg_value
    @ExcelProperty("测压管水位或渗压计值(m)")
    private String avgValue;

    //SJZT_DW dws_res_sl_di  存avg_spqn_value
    @ExcelProperty("渗流量(L)")
    private String avgSpqnValue;
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/excel/DbExcelImport.java

New file
@@ -0,0 +1,26 @@
package cn.gistack.sm.sjztdw.excel;

import cn.gistack.sm.sjztdw.service.IDbPersonReportService;
import lombok.RequiredArgsConstructor;
import org.springblade.core.excel.support.ExcelImporter;

import java.util.List;

/**
 * 导入大坝人工上报数据
 */
@RequiredArgsConstructor
public class DbExcelImport implements ExcelImporter<DbExcel> {

    private final IDbPersonReportService service;

    private final String resGuid;

    private final String ch;

    @Override
    public void save(List<DbExcel> data) {
        service.importDbPersonData(data,resGuid,ch);
    }

}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsRainResDiMapper.java

New file
@@ -0,0 +1,24 @@
package cn.gistack.sm.sjztdw.mapper;

import cn.gistack.common.node.TreeNode;
import cn.gistack.sm.sjztdw.entity.DwsRainResDi;
import cn.gistack.sm.sjztmd.entity.AttAdBase;
import cn.gistack.sm.sjztmd.vo.AttAdBaseVO;
import cn.gistack.sm.sjztmd.vo.PersonVO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.MapKey;
import org.apache.ibatis.annotations.Param;

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

/**
 * AddAdBaseMapper 接口
 *
 * @author Chill
 */
public interface DwsRainResDiMapper extends BaseMapper<DwsRainResDi> {


    Integer updateCustomize(@Param("entity") DwsRainResDi dwsRainResDi);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsRainResDiMapper.xml

New file
@@ -0,0 +1,25 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.gistack.sm.sjztdw.mapper.DwsResPressDiMapper">


    <update id="updateCustomize">
        UPDATE SJZT_DW."dws_res_press_di" SET
        <if test="entity.avgValue != null and entity.avgValue !='' ">
            "avg_value" = #{entity.avgValue}
        </if>
        WHERE 1=1
        <if test="entity.cd != null and entity.cd !=''">
            AND "cd" = #{entity.cd}
        </if>
        <if test="entity.isTb != null and entity.isTb != ''">
            AND "is_tb" = #{entity.isTb}
        </if>
        <if test="entity.dt != null">
            AND "dt" = #{entity.dt}
        </if>
        <if test="entity.resCd != null and entity.resCd !=''">
            AND "res_cd" = #{entity.resCd}
        </if>
    </update>
</mapper>

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsResPressDiMapper.java

New file
@@ -0,0 +1,17 @@
package cn.gistack.sm.sjztdw.mapper;

import cn.gistack.sm.sjztdw.entity.DwsRainResDi;
import cn.gistack.sm.sjztdw.entity.DwsResPressDi;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;

/**
 * AddAdBaseMapper 接口
 *
 * @author Chill
 */
public interface DwsResPressDiMapper extends BaseMapper<DwsResPressDi> {


    Integer updateCustomize(@Param("entity") DwsResPressDi dwsResPressDi);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsResPressDiMapper.xml

New file
@@ -0,0 +1,28 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.gistack.sm.sjztdw.mapper.DwsRainResDiMapper">


    <update id="updateCustomize">

        UPDATE SJZT_DW."dws_rain_res_di" SET
            <if test="entity.drp != null and entity.drp !='' ">
                "drp" = #{entity.drp}
            </if>
        WHERE 1=1
            <if test="entity.isTb != null and entity.isTb != ''">
                AND "is_tb" = #{entity.isTb}
            </if>
            <if test="entity.dt != null">
                AND "dt" = #{entity.dt}
            </if>
            <if test="entity.resCd != null and entity.resCd !=''">
                AND "res_cd" = #{entity.resCd}
            </if>
            <if test="entity.stCd != null and entity.stCd != ''">
                AND "st_cd" = #{entity.stCd}
            </if>


    </update>
</mapper>

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsResSlDiMapper.java

New file
@@ -0,0 +1,17 @@
package cn.gistack.sm.sjztdw.mapper;

import cn.gistack.sm.sjztdw.entity.DwsResPressDi;
import cn.gistack.sm.sjztdw.entity.DwsResSlDi;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;

/**
 * AddAdBaseMapper 接口
 *
 * @author Chill
 */
public interface DwsResSlDiMapper extends BaseMapper<DwsResSlDi> {


    Integer updateCustomize(@Param("entity") DwsResSlDi dwsResSlDi);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsResSlDiMapper.xml

New file
@@ -0,0 +1,30 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.gistack.sm.sjztdw.mapper.DwsResSlDiMapper">


    <update id="updateCustomize">

        UPDATE SJZT_DW."dws_res_sl_di" SET
        <if test="entity.avgSpqnValue != null and entity.avgSpqnValue !='' ">
            "avg_spqn_value" = #{entity.avgSpqnValue}
        </if>
        WHERE 1=1
        <if test="entity.cd != null and entity.cd !=''">
            AND "cd" = #{entity.cd}
        </if>
        <if test="entity.isTb != null and entity.isTb != ''">
            AND "is_tb" = #{entity.isTb}
        </if>
        <if test="entity.dt != null">
            AND "dt" = #{entity.dt}
        </if>
        <if test="entity.resCd != null and entity.resCd !=''">
            AND "res_cd" = #{entity.resCd}
        </if>
        <if test="entity.resRegCode != null and entity.resRegCode !=''">
            AND "res_reg_code" = #{entity.resRegCode}
        </if>

    </update>
</mapper>

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsWaterResZEightDetailAllMapper.java

New file
@@ -0,0 +1,16 @@
package cn.gistack.sm.sjztdw.mapper;

import cn.gistack.sm.sjztdw.entity.DwsWaterResZEightDetailAll;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;

/**
 * AddAdBaseMapper 接口
 *
 * @author Chill
 */
public interface DwsWaterResZEightDetailAllMapper extends BaseMapper<DwsWaterResZEightDetailAll> {


    Integer updateCustomize(@Param("entity") DwsWaterResZEightDetailAll dwsWaterResZEightDetailAll);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/mapper/DwsWaterResZEightDetailAllMapper.xml

New file
@@ -0,0 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.gistack.sm.sjztdw.mapper.DwsWaterResZEightDetailAllMapper">


    <update id="updateCustomize">

        UPDATE SJZT_DW."dws_water_res_z_eight_detail_all" SET
            <if test="entity.rz != null and entity.rz !='' ">
                "rz" = #{entity.rz},
            </if>
            <if test="entity.lowZ != null and entity.lowZ !='' ">
                "low_z" = #{entity.lowZ}
            </if>
        WHERE 1=1
            <if test="entity.isTb != null and entity.isTb != ''">
                AND "is_tb" = #{entity.isTb}
            </if>
            <if test="entity.collectDt != null">
                AND "collect_dt" = #{entity.collectDt}
            </if>
            <if test="entity.resCd != null and entity.resCd !=''">
                AND "res_cd" = #{entity.resCd}
            </if>
            <if test="entity.stCd != null and entity.stCd != ''">
                AND "st_cd" = #{entity.stCd}
            </if>
    </update>
</mapper>

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/IDbPersonReportService.java

New file
@@ -0,0 +1,10 @@
package cn.gistack.sm.sjztdw.service;

import cn.gistack.sm.sjztdw.excel.DbExcel;

import java.util.List;

public interface IDbPersonReportService {

    void importDbPersonData(List<DbExcel> data, String resGuid,String ch);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/IDwsRainResDiService.java

New file
@@ -0,0 +1,8 @@
package cn.gistack.sm.sjztdw.service;

import cn.gistack.sm.sjztdw.entity.DwsRainResDi;
import com.baomidou.mybatisplus.extension.service.IService;

public interface IDwsRainResDiService extends IService<DwsRainResDi> {
    Integer updateCustomize(DwsRainResDi dwsRainResDi);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/IDwsResPressDiService.java

New file
@@ -0,0 +1,9 @@
package cn.gistack.sm.sjztdw.service;

import cn.gistack.sm.sjztdw.entity.DwsRainResDi;
import cn.gistack.sm.sjztdw.entity.DwsResPressDi;
import com.baomidou.mybatisplus.extension.service.IService;

public interface IDwsResPressDiService extends IService<DwsResPressDi> {
    Integer updateCustomize(DwsResPressDi dwsResPressDi);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/IDwsResSlDiService.java

New file
@@ -0,0 +1,8 @@
package cn.gistack.sm.sjztdw.service;

import cn.gistack.sm.sjztdw.entity.DwsResSlDi;
import com.baomidou.mybatisplus.extension.service.IService;

public interface IDwsResSlDiService extends IService<DwsResSlDi> {
    Integer updateCustomize(DwsResSlDi dwsResSlDi);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/IDwsWaterResZEightDetailAllService.java

New file
@@ -0,0 +1,9 @@
package cn.gistack.sm.sjztdw.service;

import cn.gistack.sm.sjztdw.entity.DwsRainResDi;
import cn.gistack.sm.sjztdw.entity.DwsWaterResZEightDetailAll;
import com.baomidou.mybatisplus.extension.service.IService;

public interface IDwsWaterResZEightDetailAllService extends IService<DwsWaterResZEightDetailAll> {
    Integer updateCustomize(DwsWaterResZEightDetailAll dwsWaterResZEightDetailAll);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/impl/DbPersonReportServiceImpl.java

New file
@@ -0,0 +1,243 @@
package cn.gistack.sm.sjztdw.service.impl;

import cn.gistack.sm.sjztdw.entity.DwsRainResDi;
import cn.gistack.sm.sjztdw.entity.DwsResPressDi;
import cn.gistack.sm.sjztdw.entity.DwsResSlDi;
import cn.gistack.sm.sjztdw.entity.DwsWaterResZEightDetailAll;
import cn.gistack.sm.sjztdw.excel.DbExcel;
import cn.gistack.sm.sjztdw.service.*;
import cn.gistack.sm.sjztmd.service.IAttResBaseService;
import cn.gistack.sm.sjztmd.vo.AttResAdVO;
import cn.gistack.sm.sjztods.entity.DsmSpgSpprmp;
import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import cn.gistack.sm.sjztods.service.IDsmSpgSpprmpService;
import cn.gistack.sm.sjztods.service.IDsmSpgSpqnmpService;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.AllArgsConstructor;
import org.apache.logging.log4j.util.Strings;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Date;
import java.util.List;

@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class DbPersonReportServiceImpl implements IDbPersonReportService {
    private IAttResBaseService attResBaseService;
    private IDwsRainResDiService dwsRainResDiService;
    private IDwsWaterResZEightDetailAllService dwsWaterResZEightDetailAllService;
    private IDwsResPressDiService dwsResPressDiService;
    private IDwsResSlDiService dwsResSlDiService;


    private IDsmSpgSpqnmpService dsmSpgSpqnmpService;
    private IDsmSpgSpprmpService dsmSpgSpprmpService;

    @Override
    public void importDbPersonData(List<DbExcel> data, String resGuid,String ch) {

        //获取行政区划
        AttResAdVO resAd = attResBaseService.getResAd(resGuid);

        DsmSpgSpprmp paramSy = new DsmSpgSpprmp();
        paramSy.setCh(ch);
        paramSy.setRscd(resAd.getResRegCode());

        //根据水库注册登记码，断面获取渗压站列表，并按测点编号从小到大排序
        List<DsmSpgSpprmp> dsmSpgSpprmpList = dsmSpgSpprmpService.getList(paramSy);

        //从渗流测点表中根据断面和水库注册登记码获取测点编码
        DsmSpgSpqnmp paramSl = new DsmSpgSpqnmp();
        paramSl.setCh(ch);
        paramSl.setRscd(resAd.getResRegCode());
        List<DsmSpgSpqnmp> dsmSpgSpqnmpList = dsmSpgSpqnmpService.getList(paramSl);

        data.forEach(dbExcel->{

            //存雨情数据
            saveDayRainFall(dbExcel,resAd);

            //存水位数据
            saveWaterLevel(dbExcel,resAd);

            //存渗压数据
            saveSy(dbExcel,resAd,dsmSpgSpprmpList);


            //存渗流数据
            saveSl(dbExcel,resAd,dsmSpgSpqnmpList);

        });
    }

    private void saveSy(DbExcel dbExcel, AttResAdVO resAd,List<DsmSpgSpprmp> list) {

        //excel数据应是按测压管从小到大
        List<String> avgValueList = Arrays.asList(dbExcel.getAvgValue().split(","));

        //有渗压站才添加
        if (list !=null && list.size()>0){
            for (int i = 0; i < avgValueList.size(); i++) {
                String avgValue = avgValueList.get(i);
                DsmSpgSpprmp dsmSpgSpprmp = list.get(i);

                DwsResPressDi dwsResPressDi = new DwsResPressDi();
                //站点编码
                dwsResPressDi.setCd(dsmSpgSpprmp.getMpcd());
                //站点名称
                dwsResPressDi.setCdNm(dsmSpgSpprmp.getMpcd());

                dwsResPressDi.setResCd(resAd.getResGuid());
                dwsResPressDi.setResNm(resAd.getResName());
                dwsResPressDi.setAvgValue(avgValue);

                Date date = dateFormatString(dbExcel.getMonitorDate(), "yyyy-MM-dd");
                dwsResPressDi.setDt(date);
                dwsResPressDi.setIsTb("y");

                Integer result = dwsResPressDiService.updateCustomize(dwsResPressDi);
                if (result<=0){
                    dwsResPressDiService.save(dwsResPressDi);
                }
            }
        }

    }

    private void saveSl(DbExcel dbExcel, AttResAdVO resAd,List<DsmSpgSpqnmp> list) {

        //有渗流站点才添加
        if (list != null && list.size()>0){
            DwsResSlDi dwsResSlDi = new DwsResSlDi();

            if (list != null && list.size()>0){
                dwsResSlDi.setCd(list.get(0).getMpcd());
            }

            dwsResSlDi.setResRegCode(resAd.getResRegCode());
            dwsResSlDi.setResCd(resAd.getResGuid());

            dwsResSlDi.setAvgSpqnValue(dbExcel.getAvgSpqnValue());

            Date date = dateFormatString(dbExcel.getMonitorDate(), "yyyy-MM-dd");

            dwsResSlDi.setDt(date);
            dwsResSlDi.setIsTb("y");


            Integer result = dwsResSlDiService.updateCustomize(dwsResSlDi);
            if (result<=0){
                dwsResSlDiService.save(dwsResSlDi);
            }

        }

    }


    /**
     * 保存雨情数据
     * @param dbExcel
     * @param resAd
     */
    private void saveDayRainFall(DbExcel dbExcel, AttResAdVO resAd) {

        DwsRainResDi dwsRainResDi = new DwsRainResDi();

        dwsRainResDi.setStCd("");
        dwsRainResDi.setStNm("人工上报");
        dwsRainResDi.setResCd(resAd.getResGuid());
        dwsRainResDi.setResNm(resAd.getResName());
        dwsRainResDi.setProvinceCd(resAd.getProvinceCode());
        dwsRainResDi.setProvinceNm(resAd.getProvinceName());
        dwsRainResDi.setCityCd(resAd.getCityCode());
        dwsRainResDi.setCityNm(resAd.getCityName());
        dwsRainResDi.setCountyCd(resAd.getCountyName());
        dwsRainResDi.setTownCd(resAd.getTownCode());
        dwsRainResDi.setTownNm(resAd.getTownName());

        dwsRainResDi.setFlag("人工");

        Date date = dateFormatString(dbExcel.getMonitorDate(), "yyyy-MM-dd");
        dwsRainResDi.setDt(date);
        dwsRainResDi.setIsTb("y");
        dwsRainResDi.setDrp(dbExcel.getDrp());
        //根据参数更新数据，如果受影响的行数为0说明这条数据没有，就添加
        Integer result =  dwsRainResDiService.updateCustomize(dwsRainResDi);

        if (result <= 0){
            dwsRainResDiService.save(dwsRainResDi);
        }

    }

    /**
     * 保存水位数据
     * @param dbExcel
     * @param resAd
     */
    private void saveWaterLevel(DbExcel dbExcel, AttResAdVO resAd) {
        DwsWaterResZEightDetailAll dwsWaterResZEightDetailAll = new DwsWaterResZEightDetailAll();


        dwsWaterResZEightDetailAll.setStCd("");
        dwsWaterResZEightDetailAll.setStNm("人工上报");

        dwsWaterResZEightDetailAll.setResCd(resAd.getResGuid());
        dwsWaterResZEightDetailAll.setResNm(resAd.getResName());
        dwsWaterResZEightDetailAll.setEngScal(resAd.getEngScal());
        dwsWaterResZEightDetailAll.setResLat(resAd.getResLat());
        dwsWaterResZEightDetailAll.setResLon(resAd.getResLon());

        dwsWaterResZEightDetailAll.setProvinceCd(resAd.getProvinceCode());
        dwsWaterResZEightDetailAll.setProvinceNm(resAd.getProvinceName());
        dwsWaterResZEightDetailAll.setCityCd(resAd.getCityCode());
        dwsWaterResZEightDetailAll.setCityNm(resAd.getCityName());
        dwsWaterResZEightDetailAll.setCountyCd(resAd.getCountyName());
        dwsWaterResZEightDetailAll.setTownCd(resAd.getTownCode());
        dwsWaterResZEightDetailAll.setTownNm(resAd.getTownName());

        dwsWaterResZEightDetailAll.setRz(dbExcel.getRz());
        dwsWaterResZEightDetailAll.setLowZ(dbExcel.getLowZ());

        dwsWaterResZEightDetailAll.setResourceFlag("人工");
        dwsWaterResZEightDetailAll.setIsTb("y");

        Date date = dateFormatString(dbExcel.getMonitorDate(), "yyyy-MM-dd 08:00:00");
        dwsWaterResZEightDetailAll.setDt(date);
        dwsWaterResZEightDetailAll.setTm(date);
        dwsWaterResZEightDetailAll.setCollectDt(date);
        dwsWaterResZEightDetailAll.setParDt(date);

        Integer result = dwsWaterResZEightDetailAllService.updateCustomize(dwsWaterResZEightDetailAll);
        if (result<=0){
            dwsWaterResZEightDetailAllService.save(dwsWaterResZEightDetailAll);
        }

    }


    private Date dateFormatString(String date,String format){

        if (StringUtil.isNotBlank(date)){
            try {

                Date parse = new SimpleDateFormat(format).parse(date);
                return parse;

            } catch (ParseException e) {
                e.printStackTrace();
            }
        }
        return null;
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/impl/DwsRainResDiServiceImpl.java

New file
@@ -0,0 +1,17 @@
package cn.gistack.sm.sjztdw.service.impl;

import cn.gistack.sm.sjztdw.entity.DwsRainResDi;
import cn.gistack.sm.sjztdw.mapper.DwsRainResDiMapper;
import cn.gistack.sm.sjztdw.service.IDwsRainResDiService;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
@DS("ztdw")
public class DwsRainResDiServiceImpl extends ServiceImpl<DwsRainResDiMapper, DwsRainResDi> implements IDwsRainResDiService {
    @Override
    public Integer updateCustomize(DwsRainResDi dwsRainResDi) {
        return baseMapper.updateCustomize(dwsRainResDi);
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/impl/DwsResPressDiServiceImpl.java

New file
@@ -0,0 +1,19 @@
package cn.gistack.sm.sjztdw.service.impl;

import cn.gistack.sm.sjztdw.entity.DwsResPressDi;
import cn.gistack.sm.sjztdw.mapper.DwsResPressDiMapper;
import cn.gistack.sm.sjztdw.service.IDwsResPressDiService;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
@DS("ztdw")
public class DwsResPressDiServiceImpl extends ServiceImpl<DwsResPressDiMapper, DwsResPressDi> implements IDwsResPressDiService {


    @Override
    public Integer updateCustomize(DwsResPressDi dwsResPressDi) {
        return baseMapper.updateCustomize(dwsResPressDi);
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/impl/DwsResSlDiServiceImpl.java

New file
@@ -0,0 +1,17 @@
package cn.gistack.sm.sjztdw.service.impl;

import cn.gistack.sm.sjztdw.entity.DwsResSlDi;
import cn.gistack.sm.sjztdw.mapper.DwsResSlDiMapper;
import cn.gistack.sm.sjztdw.service.IDwsResSlDiService;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
@DS("ztdw")
public class DwsResSlDiServiceImpl extends ServiceImpl<DwsResSlDiMapper, DwsResSlDi> implements IDwsResSlDiService {
    @Override
    public Integer updateCustomize(DwsResSlDi dwsResSlDi) {
        return baseMapper.updateCustomize(dwsResSlDi);
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztdw/service/impl/DwsWaterResZEightDetailAllServiceImpl.java

New file
@@ -0,0 +1,17 @@
package cn.gistack.sm.sjztdw.service.impl;

import cn.gistack.sm.sjztdw.entity.DwsWaterResZEightDetailAll;
import cn.gistack.sm.sjztdw.mapper.DwsWaterResZEightDetailAllMapper;
import cn.gistack.sm.sjztdw.service.IDwsWaterResZEightDetailAllService;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
@DS("ztdw")
public class DwsWaterResZEightDetailAllServiceImpl extends ServiceImpl<DwsWaterResZEightDetailAllMapper, DwsWaterResZEightDetailAll> implements IDwsWaterResZEightDetailAllService {
    @Override
    public Integer updateCustomize(DwsWaterResZEightDetailAll dwsWaterResZEightDetailAll) {
        return baseMapper.updateCustomize(dwsWaterResZEightDetailAll);
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/excel/TbProjectExcel.java

@@ -21,19 +21,15 @@
    @ExcelProperty("地市")
    private String  cityName;

    @ExcelIgnore
    @ExcelProperty("县市区")
    private String countyName;

    @ExcelIgnore
    @ExcelProperty("中央投资")
    private Double centerFund;

    @ExcelIgnore
    @ExcelProperty("地方投资")
    private Double localFund;

    @ExcelIgnore
    @ExcelProperty("填报年份")
    private String tbYear;


 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/AttResBaseMapper.xml

@@ -340,6 +340,10 @@
            arb."name" resName,
            arb."guid" resGuid,
            arb."interior_ad_guid",
            arb."eng_scal" engScal,
            arb."res_reg_code" resRegCode,
            arb."center_long" resLon,
            arb."center_lat" resLat,
            case when town."ad_grad" = 4 THEN town."ad_code" ELSE NULL END AS townCode,
            case when town."ad_grad" = 4 THEN town."ad_name" ELSE NULL END AS townName,
            case when town."ad_grad" = 3 THEN town."ad_code"

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/vo/AttResAdVO.java

@@ -15,6 +15,11 @@
     * 水库编号
     */
    private String resGuid;
    private String resName;
    private String resRegCode;
    private String engScal;
    private String resLon;
    private String resLat;

    private String provinceCode;
    private String provinceName;

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/controller/DsmSpgSpprmpController.java

New file
@@ -0,0 +1,41 @@
package cn.gistack.sm.sjztods.controller;

import cn.gistack.sm.sjztods.entity.DsmSpgSpprmp;
import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import cn.gistack.sm.sjztods.service.IDsmSpgSpprmpService;
import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import io.swagger.annotations.Api;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Slf4j
@Api(tags = "渗压站点")
@RestController
@RequestMapping("/sjztods/dsmSpgSpprmp")
@AllArgsConstructor
public class DsmSpgSpprmpController {

    private final IDsmSpgSpprmpService dsmSpgSpprmpService;

    @PostMapping("/insert")
    public R insert(DsmSpgSpprmpVO dsmSpgSpprmp){
        Boolean b = dsmSpgSpprmpService.insertCustomize(dsmSpgSpprmp);
        return R.status(b);
    }

    @PostMapping("/update")
    public R update(DsmSpgSpprmpVO dsmSpgSpprmp){
        Boolean b = dsmSpgSpprmpService.updateCustomize(dsmSpgSpprmp);
        return R.status(b);
    }

    @PostMapping("/remove")
    public R remove(String ids){
        Boolean b = dsmSpgSpprmpService.removeCustomize(ids);
        return R.status(b);
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/controller/DsmSpgSpqnmpController.java

New file
@@ -0,0 +1,44 @@
package cn.gistack.sm.sjztods.controller;

import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import cn.gistack.sm.sjztods.service.IDsmSpgSpqnmpService;
import io.swagger.annotations.Api;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Arrays;

@Slf4j
@Api(tags = "渗流站点")
@RestController
@RequestMapping("/sjztods/dsmSpgSpqnmp")
@AllArgsConstructor
public class DsmSpgSpqnmpController {

    private final IDsmSpgSpqnmpService dsmSpgSpqnmpService;



    @PostMapping("/insert")
    public R insert(DsmSpgSpqnmp dsmSpgSpqnmp){
        Boolean b = dsmSpgSpqnmpService.save(dsmSpgSpqnmp);
        return R.status(b);
    }

    @PostMapping("/update")
    public R update(DsmSpgSpqnmp dsmSpgSpqnmp){
        Boolean b = dsmSpgSpqnmpService.updateCustomize(dsmSpgSpqnmp);
        return R.status(b);
    }

    @PostMapping("/remove")
    public R remove(String ids){
        Boolean b = dsmSpgSpqnmpService.removeCustomize(ids);
        return R.status(b);
    }

}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/entity/DsmSpgPztb.java

New file
@@ -0,0 +1,112 @@
package cn.gistack.sm.sjztods.entity;

import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.util.Date;

/**
 *测压管表
 */
@Data
@TableName("\"dsm_spg_pztb\"")
public class DsmSpgPztb {

    @TableField("\"ch\"")
    //桩号
    private String ch;

    @TableField("\"dm\"")
    //断面
    private String dm;

    @TableField("\"dtuptm\"")
    //资料更新时间
    private Date dtuptm;

    @TableField("\"dvcd\"")
    //仪器编号
    private String dvcd;

    @TableField("\"hycncd\"")
    //水工建筑物编号
    private String hycncd;

    @TableField("\"ipbtel\"")
    //进水段底高程
    private String ipbtel;

    @TableField("\"iptpel\"")
    //进水段顶高程
    private String iptpel;

    @TableField("\"is_tb\"")
    //是否填报
    private String isTb;

    @TableField("\"lgtd\"")
    //经度
    private String lgtd;

    @TableField("\"lttd\"")
    //纬度
    private String lttd;

    @TableField("\"mpcd\"")
    //测点编号
    private String mpcd;

    @TableField("\"msps\"")
    //监测类型
    private String msps;

    @TableField("\"ofax\"")
    //轴距
    private String ofax;

    @TableField("\"rm\"")
    //备注
    private String rm;

    @TableField("\"rscd\"")
    //水库代码
    private String rscd;

    @TableField("\"tbbtel\"")
    //管底高程
    private String tbbtel;

    @TableField("\"tbtpel\"")
    //管口高程
    private String tbtpel;


    public DsmSpgPztb(DsmSpgSpprmpVO dsmSpgSpprmp){

        this.setCh(dsmSpgSpprmp.getCh());
        this.setDm(dsmSpgSpprmp.getDm());
        this.setDtuptm(dsmSpgSpprmp.getDtuptm());
        this.setDvcd(dsmSpgSpprmp.getDvcd());
        this.setHycncd(dsmSpgSpprmp.getHycncd());
        this.setIsTb(dsmSpgSpprmp.getIsTb());
        this.setLgtd(dsmSpgSpprmp.getLgtd());
        this.setLttd(dsmSpgSpprmp.getLttd());
        this.setMpcd(dsmSpgSpprmp.getMpcd());
        this.setMsps(dsmSpgSpprmp.getMsps());
        this.setOfax(dsmSpgSpprmp.getOfax());
        this.setRm(dsmSpgSpprmp.getRm());
        this.setRscd(dsmSpgSpprmp.getRscd());

        this.setTbbtel(dsmSpgSpprmp.getTbbtel());
        this.setTbtpel(dsmSpgSpprmp.getTbtpel());

        this.setIpbtel(dsmSpgSpprmp.getIpbtel());
        this.setIptpel(dsmSpgSpprmp.getIptpel());

    }



}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/entity/DsmSpgSpprmp.java

New file
@@ -0,0 +1,89 @@
package cn.gistack.sm.sjztods.entity;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.util.Date;

/**
 * 渗压测点表
 */
@Data
@TableName("\"dsm_spg_spprmp\"")
public class DsmSpgSpprmp {

    @TableField("\"ch\"")
    //桩号
    private String ch;

    @TableField("\"dm\"")
    //断面
    private String dm;

    @TableField("\"dsel\"")
    //坝面高程
    private String dsel;

    @TableField("\"dtuptm\"")
    //资料更新时间
    private Date dtuptm;

    @TableField("\"dvcd\"")
    //仪器编号
    private String dvcd;

    @TableField("\"el\"")
    //高程
    private String el;

    @TableField("\"hycncd\"")
    //水工建筑物编号
    private String hycncd;


    @TableField("\"indt\"")
    //安装日期
    private String indt;

    @TableField("\"is_tb\"")
    //是否填报
    private String isTb;

    @TableField("\"lgtd\"")
    //经度
    private String lgtd;

    @TableField("\"lttd\"")
    //纬度
    private String lttd;

    @TableField("\"mpcd\"")
    //测点编号
    private String mpcd;

    @TableField("\"msps\"")
    //监测类型
    private String msps;

    @TableField("\"ofax\"")
    //轴距
    private String ofax;

    @TableField("\"pmbtel\"")
    //透水段底高程
    private String pmbtel;

    @TableField("\"pmtpel\"")
    //透水段顶高程
    private String pmtpel;

    @TableField("\"rm\"")
    //备注
    private String rm;

    @TableField("\"rscd\"")
    //水库代码
    private String rscd;

}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/entity/DsmSpgSpqnmp.java

New file
@@ -0,0 +1,73 @@
package cn.gistack.sm.sjztods.entity;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.util.Date;

/**
 * 渗流测点表
 */
@Data
@TableName("\"dsm_spg_spqnmp\"")
public class DsmSpgSpqnmp {

    @TableField("\"ch\"")
    //桩号
    private String ch;

    @TableField("\"dm\"")
    //断面
    private String dm;

    @TableField("\"dtuptm\"")
    //资料更新时间
    private Date dtuptm;

    @TableField("\"dvcd\"")
    //仪器编号
    private String dvcd;

    @TableField("\"el\"")
    //高程
    private String el;

    @TableField("\"hycncd\"")
    //水工建筑物编号
    private String hycncd;


    @TableField("\"indt\"")
    //安装日期
    private String indt;

    @TableField("\"is_tb\"")
    //是否填报
    private String isTb;

    @TableField("\"lgtd\"")
    //经度
    private String lgtd;

    @TableField("\"lttd\"")
    //纬度
    private String lttd;

    @TableField("\"mpcd\"")
    //测点编号
    private String mpcd;

    @TableField("\"ofax\"")
    //轴距
    private String ofax;

    @TableField("\"rm\"")
    //备注
    private String rm;

    @TableField("\"rscd\"")
    //水库代码
    private String rscd;

}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/mapper/DsmPsgPztbMapper.java

New file
@@ -0,0 +1,17 @@
package cn.gistack.sm.sjztods.mapper;

import cn.gistack.sm.sjztods.entity.DsmSpgPztb;
import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;


@DS("ztznwh")
public interface DsmPsgPztbMapper extends BaseMapper<DsmSpgPztb> {


    Boolean updateCustomize(@Param("entity") DsmSpgSpprmpVO dsmSpgSpprmp);

    Boolean removeCustomize(@Param("ids") String ids);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/mapper/DsmPsgPztbMapper.xml

New file
@@ -0,0 +1,31 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.gistack.sm.sjztods.mapper.DsmPsgPztbMapper">

    <update id="updateCustomize">
        UPDATE
            SJZT_DW."dsm_spg_pztb"
        SET
            "ch" = #{entity.ch},
            "ofax" = #{entity.ofax},
            "dvcd" = #{entity.dvcd},
            "dtuptm"=#{entity.dtuptm},
            "tbtpel" = #{entity.tbtpel},
            "tbbtel" = #{entity.tbbtel}
        WHERE
            "mpcd" = #{entity.mpcd}
          and "is_tb" = 'y'
          and "rscd" = #{entity.rscd}
    </update>
    <delete id="removeCustomize">
        DELETE
        FROM
        SJZT_DW."dsm_spg_pztb"
        where
        "is_tb" = 'y'
        AND "mpcd" in
        <foreach collection="ids.split(',')" item="item" index="index" open="(" separator="," close=")">
            #{item}
        </foreach>
    </delete>
</mapper>

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/mapper/DsmSpgSpprmpMapper.java

New file
@@ -0,0 +1,21 @@
package cn.gistack.sm.sjztods.mapper;

import cn.gistack.sm.sjztods.entity.DsmSpgSpprmp;
import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;

@DS("ztznwh")
public interface DsmSpgSpprmpMapper extends BaseMapper<DsmSpgSpprmp> {


    List<DsmSpgSpprmp> getList(@Param("params") DsmSpgSpprmp paramSy);

    Boolean updateCustomize(@Param("entity") DsmSpgSpprmpVO dsmSpgSpprmp);

    Boolean removeCustomize(@Param("ids") String ids);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/mapper/DsmSpgSpprmpMapper.xml

New file
@@ -0,0 +1,49 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.gistack.sm.sjztods.mapper.DsmSpgSpprmpMapper">
    <update id="updateCustomize">

        UPDATE
            SJZT_DW."dsm_spg_spprmp"
        SET
            "ch" = #{entity.ch},
            "ofax" = #{entity.ofax},
            "el" = #{entity.el},
            "dvcd" = #{entity.dvcd},
            "dtuptm"=#{entity.dtuptm}
        WHERE
            "mpcd" = #{entity.mpcd}
          and "is_tb" = 'y'
          and "rscd" = #{entity.rscd}

    </update>
    <delete id="removeCustomize">
        DELETE
        FROM
        SJZT_DW."dsm_spg_spprmp"
        where
        "is_tb" = 'y'
        AND "mpcd" in
        <foreach collection="ids.split(',')" item="item" index="index" open="(" separator="," close=")">
            #{item}
        </foreach>

    </delete>

    <select id="getList" resultType="cn.gistack.sm.sjztods.entity.DsmSpgSpprmp">

        SELECT
            *
        FROM SJZT_ODS."dsm_spg_spprmp"
        where 1=1
        <if test="params.ch != null and params.ch !=''">
            AND "ch" = #{params.ch}
        </if>
        <if test="params.rscd != null and params.rscd !=''">
            AND "rscd" = #{params.rscd}
        </if>
        order by "mpcd"  asc


    </select>
</mapper>

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/mapper/DsmSpgSpqnmpMapper.java

New file
@@ -0,0 +1,19 @@
package cn.gistack.sm.sjztods.mapper;

import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;

@DS("ztznwh")
public interface DsmSpgSpqnmpMapper extends BaseMapper<DsmSpgSpqnmp> {


    Boolean updateCustomize(@Param("entity") DsmSpgSpqnmp dsmSpgSpqnmp);

    List<DsmSpgSpqnmp> getList(@Param("entity") DsmSpgSpqnmp paramSl);

    Boolean removeCustomize(@Param("ids") String ids);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/mapper/DsmSpgSpqnmpMapper.xml

New file
@@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.gistack.sm.sjztods.mapper.DsmSpgSpqnmpMapper">

    <update id="updateCustomize">

        UPDATE
            SJZT_DW."dsm_spg_spqnmp"
        SET
            "ch" = #{entity.ch},
            "ofax" = #{entity.ofax},
            "el" = #{entity.el},
            "dvcd" = #{entity.dvcd},
            "dtuptm"=#{entity.dtuptm}
        WHERE
            "mpcd" = #{entity.mpcd}
              and "is_tb" = 'y'
              and "rscd" = #{entity.rscd}
    </update>

    <delete id="removeCustomize">
        DELETE
        FROM
                   SJZT_DW."dsm_spg_spqnmp"
        where
            "is_tb" = 'y'
            AND "mpcd" in
        <foreach collection="ids.split(',')" item="item" index="index" open="(" separator="," close=")">
            #{item}
        </foreach>
    </delete>


    <select id="getList" resultType="cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp">

        SELECT
        *
        FROM SJZT_ODS."dsm_spg_spqnmp"
        where 1=1
        <if test="params.ch != null and params.ch !=''">
            AND "ch" = #{params.ch}
        </if>
        <if test="params.rscd != null and params.rscd !=''">
            AND "rscd" = #{params.rscd}
        </if>

    </select>
</mapper>

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/DsmSpgSpprmpService.java

New file
@@ -0,0 +1,8 @@
package cn.gistack.sm.sjztods.service;

import cn.gistack.sm.sjztods.entity.DsmSpgSpprmp;
import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import com.baomidou.mybatisplus.extension.service.IService;

public interface DsmSpgSpprmpService extends IService<DsmSpgSpprmp> {
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/IDsmSpgPztbService.java

New file
@@ -0,0 +1,11 @@
package cn.gistack.sm.sjztods.service;

import cn.gistack.sm.sjztods.entity.DsmSpgPztb;
import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import com.baomidou.mybatisplus.extension.service.IService;

public interface IDsmSpgPztbService extends IService<DsmSpgPztb> {
    Boolean updateCustomize(DsmSpgSpprmpVO dsmSpgSpprmp);

    Boolean removeCustomize(String ids);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/IDsmSpgSpprmpService.java

New file
@@ -0,0 +1,18 @@
package cn.gistack.sm.sjztods.service;

import cn.gistack.sm.sjztods.entity.DsmSpgSpprmp;
import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import com.baomidou.mybatisplus.extension.service.IService;

import java.util.List;

public interface IDsmSpgSpprmpService extends IService<DsmSpgSpprmp> {
    Boolean insertCustomize(DsmSpgSpprmpVO dsmSpgSpprmp);

    List<DsmSpgSpprmp> getList(DsmSpgSpprmp paramSy);

    Boolean updateCustomize(DsmSpgSpprmpVO dsmSpgSpprmp);

    Boolean removeCustomize(String ids);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/IDsmSpgSpqnmpService.java

New file
@@ -0,0 +1,14 @@
package cn.gistack.sm.sjztods.service;

import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import com.baomidou.mybatisplus.extension.service.IService;

import java.util.List;

public interface IDsmSpgSpqnmpService extends IService<DsmSpgSpqnmp> {
    Boolean updateCustomize(DsmSpgSpqnmp dsmSpgSpqnmp);

    List<DsmSpgSpqnmp> getList(DsmSpgSpqnmp paramSl);

    Boolean removeCustomize(String ids);
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/impl/DsmSpgPztbServiceImpl.java

New file
@@ -0,0 +1,23 @@
package cn.gistack.sm.sjztods.service.impl;

import cn.gistack.sm.sjztods.entity.DsmSpgPztb;
import cn.gistack.sm.sjztods.mapper.DsmPsgPztbMapper;
import cn.gistack.sm.sjztods.service.IDsmSpgPztbService;
import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
@DS("ztznwh")
public class DsmSpgPztbServiceImpl extends ServiceImpl<DsmPsgPztbMapper, DsmSpgPztb> implements IDsmSpgPztbService {
    @Override
    public Boolean updateCustomize(DsmSpgSpprmpVO dsmSpgSpprmp) {
        return baseMapper.updateCustomize(dsmSpgSpprmp);
    }

    @Override
    public Boolean removeCustomize(String ids) {
        return baseMapper.removeCustomize(ids);
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/impl/DsmSpgSpprmpServiceImpl.java

New file
@@ -0,0 +1,70 @@
package cn.gistack.sm.sjztods.service.impl;

import cn.gistack.sm.sjztods.entity.DsmSpgPztb;
import cn.gistack.sm.sjztods.entity.DsmSpgSpprmp;
import cn.gistack.sm.sjztods.mapper.DsmSpgSpprmpMapper;
import cn.gistack.sm.sjztods.service.IDsmSpgPztbService;
import cn.gistack.sm.sjztods.service.IDsmSpgSpprmpService;
import cn.gistack.sm.sjztods.vo.DsmSpgSpprmpVO;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
import org.springblade.core.tool.utils.DateUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

@Service
@DS("ztznwh")
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class DsmSpgSpprmpServiceImpl extends ServiceImpl<DsmSpgSpprmpMapper, DsmSpgSpprmp> implements IDsmSpgSpprmpService {

    private final IDsmSpgPztbService dsmSpgPztbService;



    @Override
    public Boolean insertCustomize(DsmSpgSpprmpVO dsmSpgSpprmp) {

        //往渗压监测表中插入数据

        dsmSpgSpprmp.setIsTb("y");
        dsmSpgSpprmp.setDtuptm(DateUtil.now());
        boolean save = save(dsmSpgSpprmp);


        //往测压管表中插入数据
        DsmSpgPztb dsmSpgPztb = new DsmSpgPztb(dsmSpgSpprmp);
        boolean save1 = dsmSpgPztbService.save(dsmSpgPztb);


        return save && save1;
    }

    @Override
    public List<DsmSpgSpprmp> getList(DsmSpgSpprmp paramSy) {
        return baseMapper.getList(paramSy);
    }

    @Override
    public Boolean updateCustomize(DsmSpgSpprmpVO dsmSpgSpprmp) {
        dsmSpgSpprmp.setDtuptm(DateUtil.now());

        Boolean update = baseMapper.updateCustomize(dsmSpgSpprmp);
        Boolean update2 = dsmSpgPztbService.updateCustomize(dsmSpgSpprmp);

        return update&&update2;
    }

    @Override
    public Boolean removeCustomize(String ids) {

        Boolean b = baseMapper.removeCustomize(ids);
        Boolean b1 =     dsmSpgPztbService.removeCustomize(ids);


        return b&&b1;
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/impl/DsmSpgSpqnmpServiceImpl.java

New file
@@ -0,0 +1,31 @@
package cn.gistack.sm.sjztods.service.impl;

import cn.gistack.sm.sjztods.entity.DsmSpgSpqnmp;
import cn.gistack.sm.sjztods.mapper.DsmSpgSpqnmpMapper;
import cn.gistack.sm.sjztods.service.IDsmSpgSpqnmpService;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.core.tool.utils.DateUtil;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
@DS("ztznwh")
public class DsmSpgSpqnmpServiceImpl extends ServiceImpl<DsmSpgSpqnmpMapper, DsmSpgSpqnmp> implements IDsmSpgSpqnmpService {
    @Override
    public Boolean updateCustomize(DsmSpgSpqnmp dsmSpgSpqnmp) {
        dsmSpgSpqnmp.setDtuptm(DateUtil.now());
        return baseMapper.updateCustomize(dsmSpgSpqnmp);
    }

    @Override
    public List<DsmSpgSpqnmp> getList(DsmSpgSpqnmp paramSl) {
        return baseMapper.getList(paramSl);
    }

    @Override
    public Boolean removeCustomize(String ids) {
        return baseMapper.removeCustomize(ids);
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/vo/DsmSpgSpprmpVO.java

New file
@@ -0,0 +1,21 @@
package cn.gistack.sm.sjztods.vo;

import cn.gistack.sm.sjztods.entity.DsmSpgSpprmp;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;

@Data
public class DsmSpgSpprmpVO extends DsmSpgSpprmp {

    //管底高程
    private String tbbtel;

    //管口高程
    private String tbtpel;

    //进水段底高程
    private String ipbtel;

    //进水段顶高程
    private String iptpel;
}