增加管路预测数据

sfd

2025-05-19 8e2bbb3ac8d259d0edbecf0d75db5d606bc80d0e

增加管路预测数据

 aps-modules/aps-core/src/main/java/com/aps/core/controller/mainPlan/ApsGasPipelinePredictionController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,127 @@
package com.aps.core.controller.mainPlan;

import java.util.List;

import com.aps.common.core.web.page.TableDataInfo;
import com.aps.core.domain.ApsGasPipelineMo;
import com.aps.core.domain.ApsGasPipelinePrediction;
import com.aps.core.service.IApsGasPipelinePredictionService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.aps.common.log.annotation.Log;
import com.aps.common.log.enums.BusinessType;
import com.aps.common.security.annotation.RequiresPermissions;
import com.aps.common.core.web.controller.BaseController;
import com.aps.common.core.web.domain.AjaxResult;
import com.aps.common.core.utils.poi.ExcelUtil;
import org.springframework.web.multipart.MultipartFile;

/**
 * ç®¡è·¯æ‰‹å·¥æ°”体预测数据Controller
 * 
 * @author ruoyi
 * @date 2025-05-19
 */

@Tag(name = "管路手工气体预测数据", description = "管路手工气体预测数据接口")
@RestController
@RequestMapping("/gasPipelinePrediction")
public class ApsGasPipelinePredictionController extends BaseController
{
    @Autowired
    private IApsGasPipelinePredictionService apsGasPipelinePredictionService;

    /**
     * æŸ¥è¯¢ç®¡è·¯æ‰‹å·¥æ°”体预测数据列表
     */
    @Operation(summary = "查询管路手工气体预测数据列表", description = "分页查询")
//    @RequiresPermissions("gasPipeline:prediction:list")
    @GetMapping("/list")
    public TableDataInfo list(ApsGasPipelinePrediction apsGasPipelineMo)
    {
        startPage();
        List<ApsGasPipelinePrediction> list = apsGasPipelinePredictionService.selectApsGasPipelinePredictionList(apsGasPipelineMo);
        return getDataTable(list);
    }


    @Operation(summary = "导入手工气体预测数据", description = "批量导入")
    @Log(title = "导入手工气体预测数据", businessType = BusinessType.IMPORT)
//    @RequiresPermissions("gasPipeline:mo:import")
    @PostMapping("/importData")
    public AjaxResult importData(MultipartFile file) throws Exception {

        int i = apsGasPipelinePredictionService.batchInsertApsGasPipelinePrediction(file);
        return  toAjax(i);
    }
    /**
     * å¯¼å‡ºç®¡è·¯æ‰‹å·¥æ°”体预测数据列表
     */
    @Operation(summary = "导出管路手工气体预测数据列表", description = "导出")
    @RequiresPermissions("gasPipeline:prediction:export")
    @Log(title = "管路手工气体预测数据", businessType = BusinessType.EXPORT)
    @PostMapping("/export")
    public void export(HttpServletResponse response, ApsGasPipelinePrediction apsGasPipelinePrediction)
    {
        List<ApsGasPipelinePrediction> list = apsGasPipelinePredictionService.selectApsGasPipelinePredictionList(apsGasPipelinePrediction);
        ExcelUtil<ApsGasPipelinePrediction> util = new ExcelUtil<ApsGasPipelinePrediction>(ApsGasPipelinePrediction.class);
        util.exportExcel(response, list, "管路手工气体预测数据数据");
    }

    /**
     * èŽ·å–管路手工气体预测数据详细信息
     */
    @Operation(summary = "获取管路手工气体预测数据详细信息", description = "根据id获取")
    @RequiresPermissions("gasPipeline:prediction:query")
    @GetMapping(value = "/{id}")
    public AjaxResult getInfo(@PathVariable("id") Long id)
    {
        return success(apsGasPipelinePredictionService.selectApsGasPipelinePredictionById(id));
    }

    /**
     * æ–°å¢žç®¡è·¯æ‰‹å·¥æ°”体预测数据
     */
    @Operation(summary = "新增管路手工气体预测数据", description = "单个新增")
    @RequiresPermissions("gasPipeline:prediction:add")
    @Log(title = "管路手工气体预测数据", businessType = BusinessType.INSERT)
    @PostMapping
    public AjaxResult add(@RequestBody ApsGasPipelinePrediction apsGasPipelinePrediction)
    {
        return toAjax(apsGasPipelinePredictionService.insertApsGasPipelinePrediction(apsGasPipelinePrediction));
    }

    /**
     * ä¿®æ”¹ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     */
    @Operation(summary = "修改管路手工气体预测数据", description = "单个修改")
    @RequiresPermissions("gasPipeline:prediction:edit")
    @Log(title = "管路手工气体预测数据", businessType = BusinessType.UPDATE)
    @PutMapping
    public AjaxResult edit(@RequestBody ApsGasPipelinePrediction apsGasPipelinePrediction)
    {
        return toAjax(apsGasPipelinePredictionService.updateApsGasPipelinePrediction(apsGasPipelinePrediction));
    }

    /**
     * åˆ é™¤ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     */
    @Operation(summary = "删除管路手工气体预测数据", description = "批量删除")
//    @RequiresPermissions("gasPipeline:prediction:remove")
    @Log(title = "管路手工气体预测数据", businessType = BusinessType.DELETE)
    @DeleteMapping("/{ids}")
    public AjaxResult remove(@PathVariable Long[] ids)
    {
        return toAjax(apsGasPipelinePredictionService.deleteApsGasPipelinePredictionByIds(ids));
    }
}

 aps-modules/aps-core/src/main/java/com/aps/core/domain/ApsGasPipelinePrediction.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,52 @@
package com.aps.core.domain;

import com.aps.common.core.annotation.Excel;
import com.aps.common.core.web.domain.BaseEntity;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import org.springframework.data.annotation.Id;

import java.math.BigDecimal;
import java.sql.Timestamp;

/**
 * ç®¡è·¯æ‰‹å·¥æ°”体预测数据对象 aps_gas_pipeline_prediction
 * 
 * @author ruoyi
 * @date 2025-05-19
 */
@Data
@Schema(description = "管路手工气体预测数据实体类")
public class ApsGasPipelinePrediction extends BaseEntity
{
    private static final long serialVersionUID = 1L;

    @Id
    @JsonFormat(shape = JsonFormat.Shape.STRING)
    /** ID */
    @Schema(description = "ID")
    private Long id;

    /** ç”Ÿäº§åŸºåœ° */
    @Excel(name = "生产基地")
    @Schema(description = "生产基地")
    private String factory;

    /** æ–™å· */
    @Excel(name = "料号")
    @Schema(description = "料号")
    private String materialCode;

    /** é¢„测日期 */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @Excel(name = "预测日期", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss")
    @Schema(description = "预测日期")
    private Timestamp predictDate;

    /** æ•°é‡ */
    @Excel(name = "数量")
    @Schema(description = "数量")
    private BigDecimal predictQuantity;

}

 aps-modules/aps-core/src/main/java/com/aps/core/mapper/ApsGasPipelinePredictionMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,65 @@
package com.aps.core.mapper;

import com.aps.core.domain.ApsGasPipelinePrediction;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;

import java.util.List;

/**
 * ç®¡è·¯æ‰‹å·¥æ°”体预测数据Mapper接口
 * 
 * @author ruoyi
 * @date 2025-05-19
 */
public interface ApsGasPipelinePredictionMapper extends BaseMapper<ApsGasPipelinePrediction> 
{
    /**
     * æŸ¥è¯¢ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param id ç®¡è·¯æ‰‹å·¥æ°”体预测数据主键
     * @return ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     */
    public ApsGasPipelinePrediction selectApsGasPipelinePredictionById(Long id);

    /**
     * æŸ¥è¯¢ç®¡è·¯æ‰‹å·¥æ°”体预测数据列表
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç®¡è·¯æ‰‹å·¥æ°”体预测数据集合
     */
    public List<ApsGasPipelinePrediction> selectApsGasPipelinePredictionList(ApsGasPipelinePrediction apsGasPipelinePrediction);

    /**
     * æ–°å¢žç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç»“æžœ
     */
    public int insertApsGasPipelinePrediction(ApsGasPipelinePrediction apsGasPipelinePrediction);

    /**
     * ä¿®æ”¹ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç»“æžœ
     */
    public int updateApsGasPipelinePrediction(ApsGasPipelinePrediction apsGasPipelinePrediction);

    /**
     * åˆ é™¤ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param id ç®¡è·¯æ‰‹å·¥æ°”体预测数据主键
     * @return ç»“æžœ
     */
    public int deleteApsGasPipelinePredictionById(Long id);

    /**
     * æ‰¹é‡åˆ é™¤ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param ids éœ€è¦åˆ é™¤çš„数据主键集合
     * @return ç»“æžœ
     */
    public int deleteApsGasPipelinePredictionByIds(Long[] ids);

    void deleteAll();
}

 aps-modules/aps-core/src/main/java/com/aps/core/service/IApsGasPipelinePredictionService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
package com.aps.core.service;

import java.util.List;
import com.aps.core.domain.ApsGasPipelinePrediction;
import org.springframework.web.multipart.MultipartFile;

/**
 * ç®¡è·¯æ‰‹å·¥æ°”体预测数据Service接口
 * 
 * @author ruoyi
 * @date 2025-05-19
 */
public interface IApsGasPipelinePredictionService 
{
    /**
     * æŸ¥è¯¢ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param id ç®¡è·¯æ‰‹å·¥æ°”体预测数据主键
     * @return ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     */
    public ApsGasPipelinePrediction selectApsGasPipelinePredictionById(Long id);

    /**
     * æŸ¥è¯¢ç®¡è·¯æ‰‹å·¥æ°”体预测数据列表
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç®¡è·¯æ‰‹å·¥æ°”体预测数据集合
     */
    public List<ApsGasPipelinePrediction> selectApsGasPipelinePredictionList(ApsGasPipelinePrediction apsGasPipelinePrediction);

    /**
     * æ–°å¢žç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç»“æžœ
     */
    public int insertApsGasPipelinePrediction(ApsGasPipelinePrediction apsGasPipelinePrediction);

    /**
     * ä¿®æ”¹ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç»“æžœ
     */
    public int updateApsGasPipelinePrediction(ApsGasPipelinePrediction apsGasPipelinePrediction);

    /**
     * æ‰¹é‡åˆ é™¤ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param ids éœ€è¦åˆ é™¤çš„管路手工气体预测数据主键集合
     * @return ç»“æžœ
     */
    public int deleteApsGasPipelinePredictionByIds(Long[] ids);

    /**
     * åˆ é™¤ç®¡è·¯æ‰‹å·¥æ°”体预测数据信息
     * 
     * @param id ç®¡è·¯æ‰‹å·¥æ°”体预测数据主键
     * @return ç»“æžœ
     */
    public int deleteApsGasPipelinePredictionById(Long id);

    int batchInsertApsGasPipelinePrediction(MultipartFile file);
}

 aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsGasPipelineMoServiceImpl.java

@@ -119,12 +119,14 @@
            for (int i = 1; i <= rows; i++) {
                Row row = sheet.getRow(i);
                String mo = row.getCell(0).getStringCellValue();
                if (StringUtils.isEmpty(mo)){
                    continue;
                }
                String factory = row.getCell(1).getStringCellValue();
                String materialNum = row.getCell(2).getStringCellValue();
                double quantity = row.getCell(3).getNumericCellValue();
                Date planEnd = row.getCell(4).getDateCellValue();
                if (StringUtils.isNotBlank(mo) &&
                    StringUtils.isNotBlank(factory) &&
                if (StringUtils.isNotBlank(factory) &&
                    StringUtils.isNotBlank(materialNum) &&
                    planEnd != null) {
                    ApsGasPipelineMo apsGasPipelineMo = new ApsGasPipelineMo();

 aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsGasPipelinePredictionServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,152 @@
package com.aps.core.service.impl;

import cn.hutool.core.util.IdUtil;
import com.aps.common.core.utils.DateUtils;
import com.aps.common.security.utils.SecurityUtils;
import com.aps.core.domain.ApsGasPipelinePrediction;
import com.aps.core.mapper.ApsGasPipelinePredictionMapper;
import com.aps.core.service.IApsGasPipelinePredictionService;
import io.micrometer.common.util.StringUtils;
import lombok.SneakyThrows;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.ss.usermodel.WorkbookFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.math.BigDecimal;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * ç®¡è·¯æ‰‹å·¥æ°”体预测数据Service业务层处理
 * 
 * @author ruoyi
 * @date 2025-05-19
 */
@Service
public class ApsGasPipelinePredictionServiceImpl implements IApsGasPipelinePredictionService
{
    @Autowired
    private ApsGasPipelinePredictionMapper apsGasPipelinePredictionMapper;

    /**
     * æŸ¥è¯¢ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param id ç®¡è·¯æ‰‹å·¥æ°”体预测数据主键
     * @return ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     */
    @Override
    public ApsGasPipelinePrediction selectApsGasPipelinePredictionById(Long id)
    {
        return apsGasPipelinePredictionMapper.selectApsGasPipelinePredictionById(id);
    }

    /**
     * æŸ¥è¯¢ç®¡è·¯æ‰‹å·¥æ°”体预测数据列表
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     */
    @Override
    public List<ApsGasPipelinePrediction> selectApsGasPipelinePredictionList(ApsGasPipelinePrediction apsGasPipelinePrediction)
    {
        return apsGasPipelinePredictionMapper.selectApsGasPipelinePredictionList(apsGasPipelinePrediction);
    }

    /**
     * æ–°å¢žç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç»“æžœ
     */
    @Override
    public int insertApsGasPipelinePrediction(ApsGasPipelinePrediction apsGasPipelinePrediction)
    {
        apsGasPipelinePrediction.setCreateTime(DateUtils.getNowDate());
        return apsGasPipelinePredictionMapper.insertApsGasPipelinePrediction(apsGasPipelinePrediction);
    }

    /**
     * ä¿®æ”¹ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param apsGasPipelinePrediction ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * @return ç»“æžœ
     */
    @Override
    public int updateApsGasPipelinePrediction(ApsGasPipelinePrediction apsGasPipelinePrediction)
    {
        apsGasPipelinePrediction.setUpdateTime(DateUtils.getNowDate());
        return apsGasPipelinePredictionMapper.updateApsGasPipelinePrediction(apsGasPipelinePrediction);
    }

    /**
     * æ‰¹é‡åˆ é™¤ç®¡è·¯æ‰‹å·¥æ°”体预测数据
     * 
     * @param ids éœ€è¦åˆ é™¤çš„管路手工气体预测数据主键
     * @return ç»“æžœ
     */
    @Override
    public int deleteApsGasPipelinePredictionByIds(Long[] ids)
    {
        return apsGasPipelinePredictionMapper.deleteApsGasPipelinePredictionByIds(ids);
    }

    /**
     * åˆ é™¤ç®¡è·¯æ‰‹å·¥æ°”体预测数据信息
     * 
     * @param id ç®¡è·¯æ‰‹å·¥æ°”体预测数据主键
     * @return ç»“æžœ
     */
    @Override
    public int deleteApsGasPipelinePredictionById(Long id)
    {
        return apsGasPipelinePredictionMapper.deleteApsGasPipelinePredictionById(id);
    }

    @SneakyThrows
    @Override
    public int batchInsertApsGasPipelinePrediction(MultipartFile file) {
        Workbook workbook = WorkbookFactory.create(file.getInputStream());

        Sheet sheet = workbook.getSheetAt(0);
        int rows = sheet.getLastRowNum();
        if (rows > 0) {
            List<ApsGasPipelinePrediction> list = new ArrayList<>();

            /*数据列从1开始*/
            for (int i = 1; i <= rows; i++) {
                Row row = sheet.getRow(i);
                String materialCode = row.getCell(0).getStringCellValue();
                if (StringUtils.isEmpty(materialCode)){
                    continue;
                }
                String factory = row.getCell(1).getStringCellValue();
                double quantity = row.getCell(2).getNumericCellValue();
                Date date = row.getCell(3).getDateCellValue();
                if (StringUtils.isNotBlank(factory) &&
                    date != null) {
                    ApsGasPipelinePrediction item = new ApsGasPipelinePrediction();
                    item.setId(IdUtil.getSnowflakeNextId());
                    item.setFactory(factory);
                    item.setMaterialCode(materialCode);
                    item.setCreateBy(SecurityUtils.getUsername());
                    item.setCreateTime(DateUtils.getNowDate());
                    item.setPredictQuantity(new BigDecimal(quantity));
                    item.setPredictDate(new Timestamp(date.getTime()));
                    list.add(item);
                }
            }
            if (!list.isEmpty()) {
                apsGasPipelinePredictionMapper.deleteAll();
                apsGasPipelinePredictionMapper.insert(list);
            }
            return list.size();
        }
        return 0;
    }
}

 aps-modules/aps-core/src/main/resources/mapper/core/ApsGasPipelinePredictionMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,91 @@
<?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="com.aps.core.mapper.ApsGasPipelinePredictionMapper">
    
    <resultMap type="com.aps.core.domain.ApsGasPipelinePrediction" id="ApsGasPipelinePredictionResult">
        <result property="id"    column="id"    />
        <result property="factory"    column="factory"    />
        <result property="materialCode"    column="material_code"    />
        <result property="predictDate"    column="predict_date"    />
        <result property="createBy"    column="create_by"    />
        <result property="createTime"    column="create_time"    />
        <result property="updateBy"    column="update_by"    />
        <result property="updateTime"    column="update_time"    />
        <result property="predictQuantity"    column="predict_quantity"    />
    </resultMap>

    <sql id="selectApsGasPipelinePredictionVo">
        select id, factory, material_code, predict_date, create_by, create_time, update_by, update_time, predict_quantity from aps_gas_pipeline_prediction
    </sql>

    <select id="selectApsGasPipelinePredictionList" parameterType="ApsGasPipelinePrediction" resultMap="ApsGasPipelinePredictionResult">
        <include refid="selectApsGasPipelinePredictionVo"/>
        <where>  
            <if test="factory != null  and factory != ''"> and factory = #{factory}</if>
            <if test="materialCode != null  and materialCode != ''"> and material_code = #{materialCode}</if>
            <if test="predictDate != null  and predictDate != ''"> and predict_date = #{predictDate}</if>
            <if test="predictQuantity != null  and predictQuantity != ''"> and predict_quantity = #{predictQuantity}</if>
        </where>
    </select>
    
    <select id="selectApsGasPipelinePredictionById" parameterType="Long" resultMap="ApsGasPipelinePredictionResult">
    </select>

    <insert id="insertApsGasPipelinePrediction" parameterType="ApsGasPipelinePrediction">
        insert into aps_gas_pipeline_prediction
        <trim prefix="(" suffix=")" suffixOverrides=",">
            <if test="id != null">id,</if>
            <if test="factory != null">factory,</if>
            <if test="materialCode != null">material_code,</if>
            <if test="predictDate != null">predict_date,</if>
            <if test="createBy != null">create_by,</if>
            <if test="createTime != null">create_time,</if>
            <if test="updateBy != null">update_by,</if>
            <if test="updateTime != null">update_time,</if>
            <if test="predictQuantity != null">predict_quantity,</if>
         </trim>
        <trim prefix="values (" suffix=")" suffixOverrides=",">
            <if test="id != null">#{id},</if>
            <if test="factory != null">#{factory},</if>
            <if test="materialCode != null">#{materialCode},</if>
            <if test="predictDate != null">#{predictDate},</if>
            <if test="createBy != null">#{createBy},</if>
            <if test="createTime != null">#{createTime},</if>
            <if test="updateBy != null">#{updateBy},</if>
            <if test="updateTime != null">#{updateTime},</if>
            <if test="predictQuantity != null">#{predictQuantity},</if>
         </trim>
    </insert>

    <update id="updateApsGasPipelinePrediction" parameterType="ApsGasPipelinePrediction">
        update aps_gas_pipeline_prediction
        <trim prefix="SET" suffixOverrides=",">
            <if test="factory != null">factory = #{factory},</if>
            <if test="materialCode != null">material_code = #{materialCode},</if>
            <if test="predictDate != null">predict_date = #{predictDate},</if>
            <if test="createBy != null">create_by = #{createBy},</if>
            <if test="createTime != null">create_time = #{createTime},</if>
            <if test="updateBy != null">update_by = #{updateBy},</if>
            <if test="updateTime != null">update_time = #{updateTime},</if>
            <if test="predictQuantity != null">predict_quantity = #{predictQuantity},</if>
        </trim>
        where id = #{id}
    </update>

    <delete id="deleteApsGasPipelinePredictionById" parameterType="Long">
        delete from aps_gas_pipeline_prediction where id = #{id}
    </delete>

    <delete id="deleteApsGasPipelinePredictionByIds" parameterType="String">
        delete from aps_gas_pipeline_prediction where id in 
        <foreach item="id" collection="array" open="(" separator="," close=")">
            #{id}
        </foreach>
    </delete>

    <delete id="deleteAll" >
        delete from aps_gas_pipeline_prediction
    </delete>
</mapper>