告警批复实体类，service

sgj

7 天以前 71fe4f1f6a75c86640a726b9c230e8aaae2a28e7

告警批复实体类，service

 fzzy-igdss-core/src/main/java/com/fzzy/igds/domain/SnapReply.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,71 @@
package com.fzzy.igds.domain;


import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fzzy.igds.constant.Constant;
import lombok.Data;
import lombok.EqualsAndHashCode;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.io.Serializable;



/**
 * æŠ“拍告警批复
 *
 * @author sgj
 * @since 2026/04/07

 */
@Data
@Entity
@Table(name = "d_snap_reply")
@TableName("d_snap_reply")
@EqualsAndHashCode(callSuper = false)
public class SnapReply extends BizBaseEntity implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @Id
    @Column(name = "id", columnDefinition = "varchar(40) COMMENT '主键'")
    @TableField("id")
    private String id;

    @Column(name = "dept_id", columnDefinition = "varchar(40) COMMENT '所属库区'")
    @TableField("dept_id")
    private String deptId;

    @Column(name = "content", columnDefinition = "varchar(200) COMMENT '告警内容'")
    @TableField("content")
    private String content;

    //未来（1-30）天出库正常，不进行提醒
    @Column(name = "days", columnDefinition = "int(2) COMMENT '不提醒天数'")
    @TableField("days")
    private Integer days;


    @Column(name = "reply_text", columnDefinition = "varchar(200) COMMENT '批复文本信息'")
    @TableField("reply_text")
    private String replyText;


//    @Column(name = "is_push", columnDefinition = "varchar(2) COMMENT '是否推送公众号信息'")
//    @TableField("is_push")
//    private String isPush = Constant.YN_N;


    @Column(name = "is_handle", columnDefinition = "varchar(2) COMMENT '是否处理'")
    @TableField("is_handle")
    private String isHandle = Constant.YN_N;


}

 fzzy-igdss-core/src/main/java/com/fzzy/igds/mapper/SnapReplyMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,10 @@
package com.fzzy.igds.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.fzzy.igds.domain.SnapReply;
import org.apache.ibatis.annotations.Mapper;

@Mapper
public interface SnapReplyMapper extends BaseMapper<SnapReply> {

}

 fzzy-igdss-core/src/main/java/com/fzzy/igds/service/SnapReplyService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,142 @@
package com.fzzy.igds.service;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fzzy.igds.data.BaseResp;
import com.fzzy.igds.data.IgdsBaseParam;
import com.fzzy.igds.domain.SnapReply;
import com.fzzy.igds.mapper.SnapReplyMapper;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

@Slf4j
@Service
public class SnapReplyService {

    @Resource
    private SnapReplyMapper snapReplyMapper;


    /**
     * åˆ†é¡µæŸ¥è¯¢æ•°æ®
     *
     * @param page
     * @param param
     */
    public void listPage(Page<SnapReply> page, IgdsBaseParam param) {
        QueryWrapper<SnapReply> queryWrapper = new QueryWrapper<>();

        param.setCompanyId(ContextUtil.getCompanyId());
        queryWrapper.eq("company_id", param.getCompanyId());

        //库区检索
        if (StringUtils.isNotBlank(param.getDeptId())) {
            queryWrapper.eq("dept_id", param.getDeptId());
        }

        //是否处理检索
        if (StringUtils.isNotBlank(param.getName())) {
            queryWrapper.eq("is_handle", param.getName());
        }

        queryWrapper.orderByDesc("create_time");
        snapReplyMapper.selectPage(page, queryWrapper);
    }

    /**
     * æŸ¥è¯¢æ‰€æœ‰æ•°æ®
     *
     * @param param
     * @return
     * @author sgj
     * @date 2026/04/07
     */
    public List<SnapReply> getListByParam(IgdsBaseParam param) {
        if (null == param) {
            param = new IgdsBaseParam();
        }

        QueryWrapper<SnapReply> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("company_id", ContextUtil.getCompanyId());

        if (StringUtils.isNotBlank(param.getDeptId())) {
            queryWrapper.eq("dept_id", param.getDeptId());
        }

        if (StringUtils.isNotBlank(param.getName())) {
            queryWrapper.eq("is_handle", param.getName());
        }

        queryWrapper.orderByDesc("create_time");

        return snapReplyMapper.selectList(queryWrapper);
    }

    /**
     * æ ¹æ®ID查询详情
     *
     * @param id
     * @return
     * @author sgj
     * @date 2026/04/07
     */
    public SnapReply getById(String id) {
        return snapReplyMapper.selectById(id);
    }

    /**
     * æŒä¹…化保存
     *
     * @param snapReply
     * @author sgj
     * @date 2026/04/07
     */
    public void addData(SnapReply snapReply) {
        if (StringUtils.isBlank(snapReply.getId())) {
            snapReply.setId(ContextUtil.generateId());
        }
        if (StringUtils.isBlank(snapReply.getCompanyId())) {
            snapReply.setCompanyId(ContextUtil.getCompanyId());
        }

        snapReply.setUpdateBy(ContextUtil.getLoginUserName());
        snapReply.setUpdateTime(new Date());
        snapReply.setCreateBy(ContextUtil.getLoginUserName());
        snapReply.setCreateTime(new Date());
        snapReplyMapper.insert(snapReply);
    }

    /**
     * æ›´æ–°æ•°æ®
     *
     * @param snapReply
     * @return
     * @author sgj
     * @date 2026/04/07
     */
    public BaseResp updateData(SnapReply snapReply) {
        snapReply.setUpdateBy(ContextUtil.getLoginUserName());
        snapReply.setUpdateTime(new Date());
        return snapReplyMapper.updateById(snapReply) > 0 ? BaseResp.success() : BaseResp.error("更新失败");
    }

    /**
     * åˆ é™¤æ•°æ®
     *
     * @param snapReply
     * @return
     * @author sgj
     * @date 2026/04/07
     */
    public BaseResp deleteData(SnapReply snapReply) {
        return snapReplyMapper.deleteById(snapReply) > 0 ? BaseResp.success() : BaseResp.error("删除失败");
    }

}

 fzzy-igdss-web/src/main/java/com/fzzy/regulatory/SnapReplyController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,56 @@
package com.fzzy.regulatory;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fzzy.igds.constant.RespCodeEnum;
import com.fzzy.igds.data.IgdsBaseParam;
import com.fzzy.igds.data.PageResponse;
import com.fzzy.igds.domain.SnapReply;
import com.fzzy.igds.response.BaseResponse;
import com.fzzy.regulatory.manager.SnapReplyManager;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;

@Slf4j
@Controller
@RequestMapping("/regulatory/snapReply")
public class SnapReplyController {

    private static final String prefix = "regulatory";

    @Resource
    private SnapReplyManager snapReplyManager;


    /**
     * åˆ†é¡µæŸ¥è¯¢æ•°æ®
     *
     * @param param
     * @return
     */
    @PostMapping("/pageData")
    @ResponseBody
    public PageResponse<Page<SnapReply>> pageData(IgdsBaseParam param) {
        Page<SnapReply> snapRecordPage = snapReplyManager.pageData(param);
        return new PageResponse<>(RespCodeEnum.CODE_0000, snapRecordPage);
    }


    /**
     * å‘Šè­¦æ‰¹å¤
     *
     * @param snapReply
     * @return
     */
    @PostMapping("/updateData")
    @ResponseBody
    public BaseResponse updateData(SnapReply snapReply) {
        return snapReplyManager.updateData(snapReply);
    }

}

 fzzy-igdss-web/src/main/java/com/fzzy/regulatory/manager/SnapReplyManager.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,67 @@
package com.fzzy.regulatory.manager;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fzzy.igds.constant.RespCodeEnum;
import com.fzzy.igds.data.BaseResp;
import com.fzzy.igds.data.IgdsBaseParam;
import com.fzzy.igds.domain.SnapReply;
import com.fzzy.igds.response.BaseResponse;
import com.fzzy.igds.service.SnapReplyService;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.ArrayList;

@Slf4j
@Component
public class SnapReplyManager {

    @Resource
    private SnapReplyService snapReplyService;


    /**
     * åˆ†é¡µæŸ¥è¯¢æ•°æ®
     *
     * @param param
     * @return
     */
    public Page<SnapReply> pageData(IgdsBaseParam param) {
        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }
        Page<SnapReply> corePage = new Page<>(param.getPage(), param.getLimit());
        snapReplyService.listPage(corePage, param);
        if (null == corePage.getRecords() || corePage.getRecords().isEmpty()) {
            return corePage.setRecords(new ArrayList<>());
        }
        return corePage;
    }


    /**
     * å‘Šè­¦æ‰¹å¤
     *
     * @param snapReply
     * @return
     */
    public BaseResponse updateData(SnapReply snapReply) {
        if (null == snapReply) {
            return new BaseResponse(RespCodeEnum.CODE_2000.getCode(),"参数不能为空");
        }
        if(StringUtils.isBlank(snapReply.getReplyText())){
            return new BaseResponse(RespCodeEnum.CODE_2000.getCode(),"批复内容不能为空");
        }
        BaseResp baseResp = snapReplyService.updateData(snapReply);
        if (!BaseResp.isSuccess(baseResp)) {
            return new BaseResponse(RespCodeEnum.CODE_1111.getCode(),"更新失败");
        }
        return new BaseResponse(RespCodeEnum.CODE_0000.getCode(),"更新成功");
    }


}