证书管理

airport-admin/src/main/java/com/sundot/airport/web/controller/ledger/LedgerCertificateInfoController.java

@@ -0,0 +1,132 @@
+package com.sundot.airport.web.controller.ledger;
+
+import java.util.List;
+import javax.servlet.http.HttpServletResponse;
+import org.springframework.security.access.prepost.PreAuthorize;
+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.sundot.airport.common.annotation.Log;
+import com.sundot.airport.common.core.controller.BaseController;
+import com.sundot.airport.common.core.domain.AjaxResult;
+import com.sundot.airport.common.enums.BusinessType;
+import com.sundot.airport.ledger.domain.LedgerCertificateInfo;
+import com.sundot.airport.ledger.service.ILedgerCertificateInfoService;
+import com.sundot.airport.common.utils.poi.ExcelUtil;
+import com.sundot.airport.common.core.page.TableDataInfo;
+import com.sundot.airport.ledger.utils.CertificateExcelImportUtil;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.ss.usermodel.WorkbookFactory;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * 证书信息Controller
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+@RestController
+@RequestMapping("/ledger/certificate")
+public class LedgerCertificateInfoController extends BaseController {
+    @Autowired
+    private ILedgerCertificateInfoService certificateInfoService;
+
+    /**
+     * 查询证书信息列表
+     */
+    @PreAuthorize("@ss.hasPermi('ledger:certificate:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(LedgerCertificateInfo ledgerCertificateInfo) {
+        startPage();
+        List<LedgerCertificateInfo> list = certificateInfoService.selectCertificateInfoList(ledgerCertificateInfo);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出证书信息列表
+     */
+    @PreAuthorize("@ss.hasPermi('ledger:certificate:export')")
+    @Log(title = "证书信息", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, LedgerCertificateInfo ledgerCertificateInfo) {
+        List<LedgerCertificateInfo> list = certificateInfoService.selectCertificateInfoList(ledgerCertificateInfo);
+        ExcelUtil<LedgerCertificateInfo> util = new ExcelUtil<LedgerCertificateInfo>(LedgerCertificateInfo.class);
+        util.exportExcel(response, list, "证书信息数据");
+    }
+
+    /**
+     * 获取证书信息详细信息
+     */
+    @PreAuthorize("@ss.hasPermi('ledger:certificate:query')")
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Long id) {
+        return success(certificateInfoService.selectCertificateInfoById(id));
+    }
+
+    /**
+     * 新增证书信息
+     */
+    @PreAuthorize("@ss.hasPermi('ledger:certificate:add')")
+    @Log(title = "证书信息", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody LedgerCertificateInfo ledgerCertificateInfo) {
+        return toAjax(certificateInfoService.insertCertificateInfo(ledgerCertificateInfo));
+    }
+
+    /**
+     * 修改证书信息
+     */
+    @PreAuthorize("@ss.hasPermi('ledger:certificate:edit')")
+    @Log(title = "证书信息", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody LedgerCertificateInfo ledgerCertificateInfo) {
+        return toAjax(certificateInfoService.updateCertificateInfo(ledgerCertificateInfo));
+    }
+
+    /**
+     * 删除证书信息
+     */
+    @PreAuthorize("@ss.hasPermi('ledger:certificate:remove')")
+    @Log(title = "证书信息", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Long[] ids) {
+        return toAjax(certificateInfoService.deleteCertificateInfoByIds(ids));
+    }
+
+    /**
+     * 导入证书数据(支持动态复审时间列)
+     *
+     */
+    @PreAuthorize("@ss.hasPermi('ledger:certificate:import')")
+    @Log(title = "证书信息", businessType = BusinessType.IMPORT)
+    @PostMapping("/importData")
+    public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception {
+        // 使用自定义工具类解析Excel,支持动态复审时间列
+        Workbook workbook = WorkbookFactory.create(file.getInputStream());
+        List<LedgerCertificateInfo> certificateList = CertificateExcelImportUtil.parseCertificateExcel(workbook);
+        workbook.close();
+        
+        if (certificateList == null || certificateList.isEmpty()) {
+            return error("导入数据为空或格式不正确");
+        }
+        
+        String operName = getUsername();
+        String message = certificateInfoService.importCertificate(certificateList, updateSupport, operName);
+        return success(message);
+    }
+
+    /**
+     * 下载导入模板
+     */
+    @PostMapping("/importTemplate")
+    public void importTemplate(HttpServletResponse response) {
+        ExcelUtil<LedgerCertificateInfo> util = new ExcelUtil<LedgerCertificateInfo>(LedgerCertificateInfo.class);
+        util.importTemplateExcel(response, "证书信息数据");
+    }
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerCertificateInfo.java

@@ -0,0 +1,349 @@
+package com.sundot.airport.ledger.domain;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+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.sundot.airport.common.annotation.Excel;
+import com.sundot.airport.common.core.domain.BaseEntity;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+/**
+ * 证书信息对象 ledger_certificate_info
+ *
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+@TableName("ledger_certificate_info")
+public class LedgerCertificateInfo extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 租户号
+     */
+    @Excel(name = "租户号")
+    private String tenantId;
+
+    /**
+     * 单位
+     */
+    @Excel(name = "单位")
+    private String unitName;
+
+    /**
+     * 用户ID(关联sys_user表)
+     */
+    @TableField("user_id")
+    private Long userId;
+
+    /**
+     * 姓名
+     */
+    @Excel(name = "姓名")
+    private String personName;
+
+    /**
+     * 性别
+     */
+    @Excel(name = "性别", readConverterExp = "男=男,女=女")
+    private String gender;
+
+    /**
+     * 出生日期
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "出生日期", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date birthDate;
+
+    /**
+     * 身份证号
+     */
+    @Excel(name = "身份证号")
+    private String idCard;
+
+    /**
+     * 证书等级
+     */
+    @Excel(name = "证书等级")
+    private String certLevel;
+
+    /**
+     * 发证日期
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "发证日期", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date issueDate;
+
+    /**
+     * 证书编号
+     */
+    @Excel(name = "证书编号")
+    private String certNo;
+
+    /**
+     * 理论考核成绩
+     */
+    @Excel(name = "理论考核成绩")
+    private BigDecimal theoryScore;
+
+    /**
+     * 实操考核成绩
+     */
+    @Excel(name = "实操考核成绩")
+    private BigDecimal practiceScore;
+
+    /**
+     * 评定成绩
+     */
+    @Excel(name = "评定成绩")
+    private BigDecimal evalScore;
+
+    /**
+     * 用工形式
+     */
+    @Excel(name = "用工形式")
+    private String employmentType;
+
+    /**
+     * 服务期(月)
+     */
+    @Excel(name = "服务期（月）")
+    private Integer serviceMonths;
+
+    /**
+     * 到期日期
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "到期日期", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date expiryDate;
+
+    /**
+     * 状态
+     */
+    @Excel(name = "状态")
+    private String status;
+
+    /**
+     * 到期天数
+     */
+    @Excel(name = "到期天数")
+    private Integer expireDays;
+
+    /**
+     * 备注
+     */
+    @Excel(name = "备注")
+    private String remark;
+
+    /**
+     * 复审记录列表(非数据库字段)
+     */
+    @TableField(exist = false)
+    private List<LedgerCertificateReviewRecord> reviewRecords;
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setTenantId(String tenantId) {
+        this.tenantId = tenantId;
+    }
+
+    public String getTenantId() {
+        return tenantId;
+    }
+
+    public void setUnitName(String unitName) {
+        this.unitName = unitName;
+    }
+
+    public String getUnitName() {
+        return unitName;
+    }
+
+    public void setUserId(Long userId) {
+        this.userId = userId;
+    }
+
+    public Long getUserId() {
+        return userId;
+    }
+
+    public void setPersonName(String personName) {
+        this.personName = personName;
+    }
+
+    public String getPersonName() {
+        return personName;
+    }
+
+    public void setGender(String gender) {
+        this.gender = gender;
+    }
+
+    public String getGender() {
+        return gender;
+    }
+
+    public void setBirthDate(Date birthDate) {
+        this.birthDate = birthDate;
+    }
+
+    public Date getBirthDate() {
+        return birthDate;
+    }
+
+    public void setIdCard(String idCard) {
+        this.idCard = idCard;
+    }
+
+    public String getIdCard() {
+        return idCard;
+    }
+
+    public void setCertLevel(String certLevel) {
+        this.certLevel = certLevel;
+    }
+
+    public String getCertLevel() {
+        return certLevel;
+    }
+
+    public void setIssueDate(Date issueDate) {
+        this.issueDate = issueDate;
+    }
+
+    public Date getIssueDate() {
+        return issueDate;
+    }
+
+    public void setCertNo(String certNo) {
+        this.certNo = certNo;
+    }
+
+    public String getCertNo() {
+        return certNo;
+    }
+
+    public void setTheoryScore(BigDecimal theoryScore) {
+        this.theoryScore = theoryScore;
+    }
+
+    public BigDecimal getTheoryScore() {
+        return theoryScore;
+    }
+
+    public void setPracticeScore(BigDecimal practiceScore) {
+        this.practiceScore = practiceScore;
+    }
+
+    public BigDecimal getPracticeScore() {
+        return practiceScore;
+    }
+
+    public void setEvalScore(BigDecimal evalScore) {
+        this.evalScore = evalScore;
+    }
+
+    public BigDecimal getEvalScore() {
+        return evalScore;
+    }
+
+    public void setEmploymentType(String employmentType) {
+        this.employmentType = employmentType;
+    }
+
+    public String getEmploymentType() {
+        return employmentType;
+    }
+
+    public void setServiceMonths(Integer serviceMonths) {
+        this.serviceMonths = serviceMonths;
+    }
+
+    public Integer getServiceMonths() {
+        return serviceMonths;
+    }
+
+    public void setExpiryDate(Date expiryDate) {
+        this.expiryDate = expiryDate;
+    }
+
+    public Date getExpiryDate() {
+        return expiryDate;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setExpireDays(Integer expireDays) {
+        this.expireDays = expireDays;
+    }
+
+    public Integer getExpireDays() {
+        return expireDays;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setReviewRecords(List<LedgerCertificateReviewRecord> reviewRecords) {
+        this.reviewRecords = reviewRecords;
+    }
+
+    public List<LedgerCertificateReviewRecord> getReviewRecords() {
+        return reviewRecords;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+                .append("id", getId())
+                .append("tenantId", getTenantId())
+                .append("unitName", getUnitName())
+                .append("userId", getUserId())
+                .append("personName", getPersonName())
+                .append("gender", getGender())
+                .append("birthDate", getBirthDate())
+                .append("idCard", getIdCard())
+                .append("certLevel", getCertLevel())
+                .append("issueDate", getIssueDate())
+                .append("certNo", getCertNo())
+                .append("theoryScore", getTheoryScore())
+                .append("practiceScore", getPracticeScore())
+                .append("evalScore", getEvalScore())
+                .append("employmentType", getEmploymentType())
+                .append("serviceMonths", getServiceMonths())
+                .append("expiryDate", getExpiryDate())
+                .append("status", getStatus())
+                .append("expireDays", getExpireDays())
+                .append("remark", getRemark())
+                .toString();
+    }
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerCertificateReviewRecord.java

@@ -0,0 +1,135 @@
+package com.sundot.airport.ledger.domain;
+
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.sundot.airport.common.annotation.Excel;
+import com.sundot.airport.common.core.domain.BaseEntity;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+/**
+ * 证书复审记录对象 certificate_review_record
+ *
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+@TableName("ledger_certificate_review_record")
+public class LedgerCertificateReviewRecord extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 证书ID(关联certificate_info.id)
+     */
+    @Excel(name = "证书ID")
+    private Long certId;
+
+    /**
+     * 复审次序(1第一次 2第二次...)
+     */
+    @Excel(name = "复审次序")
+    private Integer reviewSeq;
+
+    /**
+     * 复审时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @Excel(name = "复审时间", width = 30, dateFormat = "yyyy-MM-dd")
+    private Date reviewTime;
+
+    /**
+     * 复审结果
+     */
+    @Excel(name = "复审结果")
+    private String reviewResult;
+
+    /**
+     * 复审人
+     */
+    @Excel(name = "复审人")
+    private String reviewer;
+
+    /**
+     * 备注
+     */
+    @Excel(name = "备注")
+    private String remark;
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setCertId(Long certId) {
+        this.certId = certId;
+    }
+
+    public Long getCertId() {
+        return certId;
+    }
+
+    public void setReviewSeq(Integer reviewSeq) {
+        this.reviewSeq = reviewSeq;
+    }
+
+    public Integer getReviewSeq() {
+        return reviewSeq;
+    }
+
+    public void setReviewTime(Date reviewTime) {
+        this.reviewTime = reviewTime;
+    }
+
+    public Date getReviewTime() {
+        return reviewTime;
+    }
+
+    public void setReviewResult(String reviewResult) {
+        this.reviewResult = reviewResult;
+    }
+
+    public String getReviewResult() {
+        return reviewResult;
+    }
+
+    public void setReviewer(String reviewer) {
+        this.reviewer = reviewer;
+    }
+
+    public String getReviewer() {
+        return reviewer;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+                .append("id", getId())
+                .append("certId", getCertId())
+                .append("reviewSeq", getReviewSeq())
+                .append("reviewTime", getReviewTime())
+                .append("reviewResult", getReviewResult())
+                .append("reviewer", getReviewer())
+                .append("remark", getRemark())
+                .toString();
+    }
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/dto/LedgerCertificateImportDTO.java

@@ -0,0 +1,231 @@
+package com.sundot.airport.ledger.dto;
+
+import java.util.Date;
+
+import com.sundot.airport.common.annotation.Excel;
+import com.sundot.airport.common.core.domain.BaseEntity;
+
+/**
+ * 证书信息导入对象(用于Excel导入)
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+public class LedgerCertificateImportDTO extends BaseEntity {
+    
+    @Excel(name = "序号")
+    private Integer rowNum;
+    
+    @Excel(name = "单位")
+    private String unitName;
+    
+    @Excel(name = "姓名")
+    private String personName;
+    
+    @Excel(name = "性别")
+    private String gender;
+    
+    @Excel(name = "出生日期", dateFormat = "yyyy-MM-dd")
+    private Date birthDate;
+    
+    @Excel(name = "身份证号")
+    private String idCard;
+    
+    @Excel(name = "证书等级")
+    private String certLevel;
+    
+    @Excel(name = "发证日期", dateFormat = "yyyy-MM-dd")
+    private Date issueDate;
+    
+    @Excel(name = "证书编号")
+    private String certNo;
+    
+    @Excel(name = "理论考核成绩")
+    private Double theoryScore;
+    
+    @Excel(name = "实操考核成绩")
+    private Double practiceScore;
+    
+    @Excel(name = "评定成绩")
+    private Double evalScore;
+    
+    @Excel(name = "用工形式")
+    private String employmentType;
+    
+    @Excel(name = "服务期（月）")
+    private Integer serviceMonths;
+    
+    @Excel(name = "到期日期", dateFormat = "yyyy-MM-dd")
+    private Date expiryDate;
+    
+    @Excel(name = "状态")
+    private String status;
+    
+    @Excel(name = "到期天数")
+    private Integer expireDays;
+    
+    @Excel(name = "备注")
+    private String remark;
+    
+    // 注意:复审时间不在这里定义,因为数量不固定
+    // 在导入时需要动态解析"第1次复审时间"、"第2次复审时间"等列
+    
+    /**
+     * 动态字段:存储所有复审时间
+     * Key: 复审次序(1,2,3...)
+     * Value: 复审时间
+     */
+    private java.util.Map<Integer, Date> reviewTimeMap;
+
+    public Integer getRowNum() {
+        return rowNum;
+    }
+
+    public void setRowNum(Integer rowNum) {
+        this.rowNum = rowNum;
+    }
+
+    public String getUnitName() {
+        return unitName;
+    }
+
+    public void setUnitName(String unitName) {
+        this.unitName = unitName;
+    }
+
+    public String getPersonName() {
+        return personName;
+    }
+
+    public void setPersonName(String personName) {
+        this.personName = personName;
+    }
+
+    public String getGender() {
+        return gender;
+    }
+
+    public void setGender(String gender) {
+        this.gender = gender;
+    }
+
+    public Date getBirthDate() {
+        return birthDate;
+    }
+
+    public void setBirthDate(Date birthDate) {
+        this.birthDate = birthDate;
+    }
+
+    public String getIdCard() {
+        return idCard;
+    }
+
+    public void setIdCard(String idCard) {
+        this.idCard = idCard;
+    }
+
+    public String getCertLevel() {
+        return certLevel;
+    }
+
+    public void setCertLevel(String certLevel) {
+        this.certLevel = certLevel;
+    }
+
+    public Date getIssueDate() {
+        return issueDate;
+    }
+
+    public void setIssueDate(Date issueDate) {
+        this.issueDate = issueDate;
+    }
+
+    public String getCertNo() {
+        return certNo;
+    }
+
+    public void setCertNo(String certNo) {
+        this.certNo = certNo;
+    }
+
+    public Double getTheoryScore() {
+        return theoryScore;
+    }
+
+    public void setTheoryScore(Double theoryScore) {
+        this.theoryScore = theoryScore;
+    }
+
+    public Double getPracticeScore() {
+        return practiceScore;
+    }
+
+    public void setPracticeScore(Double practiceScore) {
+        this.practiceScore = practiceScore;
+    }
+
+    public Double getEvalScore() {
+        return evalScore;
+    }
+
+    public void setEvalScore(Double evalScore) {
+        this.evalScore = evalScore;
+    }
+
+    public String getEmploymentType() {
+        return employmentType;
+    }
+
+    public void setEmploymentType(String employmentType) {
+        this.employmentType = employmentType;
+    }
+
+    public Integer getServiceMonths() {
+        return serviceMonths;
+    }
+
+    public void setServiceMonths(Integer serviceMonths) {
+        this.serviceMonths = serviceMonths;
+    }
+
+    public Date getExpiryDate() {
+        return expiryDate;
+    }
+
+    public void setExpiryDate(Date expiryDate) {
+        this.expiryDate = expiryDate;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public Integer getExpireDays() {
+        return expireDays;
+    }
+
+    public void setExpireDays(Integer expireDays) {
+        this.expireDays = expireDays;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public java.util.Map<Integer, Date> getReviewTimeMap() {
+        return reviewTimeMap;
+    }
+
+    public void setReviewTimeMap(java.util.Map<Integer, Date> reviewTimeMap) {
+        this.reviewTimeMap = reviewTimeMap;
+    }
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerCertificateInfoMapper.java

@@ -0,0 +1,86 @@
+package com.sundot.airport.ledger.mapper;
+
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+import com.sundot.airport.ledger.domain.LedgerCertificateInfo;
+
+/**
+ * 证书信息Mapper接口
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+public interface LedgerCertificateInfoMapper {
+    /**
+     * 查询证书信息
+     * 
+     * @param id 证书信息主键
+     * @return 证书信息
+     */
+    public LedgerCertificateInfo selectCertificateInfoById(Long id);
+
+    /**
+     * 查询证书信息列表
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 证书信息集合
+     */
+    public List<LedgerCertificateInfo> selectCertificateInfoList(LedgerCertificateInfo ledgerCertificateInfo);
+
+    /**
+     * 新增证书信息
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 结果
+     */
+    public int insertCertificateInfo(LedgerCertificateInfo ledgerCertificateInfo);
+
+    /**
+     * 修改证书信息
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 结果
+     */
+    public int updateCertificateInfo(LedgerCertificateInfo ledgerCertificateInfo);
+
+    /**
+     * 删除证书信息
+     * 
+     * @param id 证书信息主键
+     * @return 结果
+     */
+    public int deleteCertificateInfoById(Long id);
+
+    /**
+     * 批量删除证书信息
+     * 
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteCertificateInfoByIds(Long[] ids);
+
+    /**
+     * 根据身份证号查询证书信息
+     * 
+     * @param idCard 身份证号
+     * @return 证书信息
+     */
+    public LedgerCertificateInfo selectCertificateInfoByIdCard(String idCard);
+
+    /**
+     * 根据证书编号查询证书信息
+     * 
+     * @param certNo 证书编号
+     * @return 证书信息
+     */
+    public LedgerCertificateInfo selectCertificateInfoByCertNo(String certNo);
+
+    /**
+     * 根据用户ID和证书编号查询证书信息
+     * 
+     * @param userId 用户ID
+     * @param certNo 证书编号
+     * @return 证书信息
+     */
+    public LedgerCertificateInfo selectCertificateInfoByUserIdAndCertNo(@Param("userId") Long userId, @Param("certNo") String certNo);
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerCertificateReviewRecordMapper.java

@@ -0,0 +1,76 @@
+package com.sundot.airport.ledger.mapper;
+
+import java.util.List;
+import com.sundot.airport.ledger.domain.LedgerCertificateReviewRecord;
+
+/**
+ * 证书复审记录Mapper接口
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+public interface LedgerCertificateReviewRecordMapper {
+    /**
+     * 查询证书复审记录
+     * 
+     * @param id 证书复审记录主键
+     * @return 证书复审记录
+     */
+    public LedgerCertificateReviewRecord selectCertificateReviewRecordById(Long id);
+
+    /**
+     * 查询证书复审记录列表
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 证书复审记录集合
+     */
+    public List<LedgerCertificateReviewRecord> selectCertificateReviewRecordList(LedgerCertificateReviewRecord ledgerCertificateReviewRecord);
+
+    /**
+     * 根据证书ID查询复审记录列表
+     * 
+     * @param certId 证书ID
+     * @return 证书复审记录集合
+     */
+    public List<LedgerCertificateReviewRecord> selectCertificateReviewRecordByCertId(Long certId);
+
+    /**
+     * 新增证书复审记录
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 结果
+     */
+    public int insertCertificateReviewRecord(LedgerCertificateReviewRecord ledgerCertificateReviewRecord);
+
+    /**
+     * 修改证书复审记录
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 结果
+     */
+    public int updateCertificateReviewRecord(LedgerCertificateReviewRecord ledgerCertificateReviewRecord);
+
+    /**
+     * 删除证书复审记录
+     * 
+     * @param id 证书复审记录主键
+     * @return 结果
+     */
+    public int deleteCertificateReviewRecordById(Long id);
+
+    /**
+     * 批量删除证书复审记录
+     * 
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteCertificateReviewRecordByIds(Long[] ids);
+
+    /**
+     * 根据证书ID删除所有复审记录
+     * 
+     * @param certId 证书ID
+     * @return 结果
+     */
+    public int deleteCertificateReviewRecordByCertId(Long certId);
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/service/ILedgerCertificateInfoService.java

@@ -0,0 +1,70 @@
+package com.sundot.airport.ledger.service;
+
+import java.util.List;
+import com.sundot.airport.ledger.domain.LedgerCertificateInfo;
+
+/**
+ * 证书信息Service接口
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+public interface ILedgerCertificateInfoService {
+    /**
+     * 查询证书信息
+     * 
+     * @param id 证书信息主键
+     * @return 证书信息
+     */
+    public LedgerCertificateInfo selectCertificateInfoById(Long id);
+
+    /**
+     * 查询证书信息列表
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 证书信息集合
+     */
+    public List<LedgerCertificateInfo> selectCertificateInfoList(LedgerCertificateInfo ledgerCertificateInfo);
+
+    /**
+     * 新增证书信息
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 结果
+     */
+    public int insertCertificateInfo(LedgerCertificateInfo ledgerCertificateInfo);
+
+    /**
+     * 修改证书信息
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 结果
+     */
+    public int updateCertificateInfo(LedgerCertificateInfo ledgerCertificateInfo);
+
+    /**
+     * 批量删除证书信息
+     * 
+     * @param ids 需要删除的证书信息主键集合
+     * @return 结果
+     */
+    public int deleteCertificateInfoByIds(Long[] ids);
+
+    /**
+     * 删除证书信息信息
+     * 
+     * @param id 证书信息主键
+     * @return 结果
+     */
+    public int deleteCertificateInfoById(Long id);
+
+    /**
+     * 导入证书数据
+     * 
+     * @param certificateList 证书数据列表
+     * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据
+     * @param operName 操作用户
+     * @return 结果
+     */
+    public String importCertificate(List<LedgerCertificateInfo> certificateList, Boolean isUpdateSupport, String operName);
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/service/ILedgerCertificateReviewRecordService.java

@@ -0,0 +1,76 @@
+package com.sundot.airport.ledger.service;
+
+import java.util.List;
+import com.sundot.airport.ledger.domain.LedgerCertificateReviewRecord;
+
+/**
+ * 证书复审记录Service接口
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+public interface ILedgerCertificateReviewRecordService {
+    /**
+     * 查询证书复审记录
+     * 
+     * @param id 证书复审记录主键
+     * @return 证书复审记录
+     */
+    public LedgerCertificateReviewRecord selectCertificateReviewRecordById(Long id);
+
+    /**
+     * 查询证书复审记录列表
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 证书复审记录集合
+     */
+    public List<LedgerCertificateReviewRecord> selectCertificateReviewRecordList(LedgerCertificateReviewRecord ledgerCertificateReviewRecord);
+
+    /**
+     * 根据证书ID查询复审记录列表
+     * 
+     * @param certId 证书ID
+     * @return 证书复审记录集合
+     */
+    public List<LedgerCertificateReviewRecord> selectCertificateReviewRecordByCertId(Long certId);
+
+    /**
+     * 新增证书复审记录
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 结果
+     */
+    public int insertCertificateReviewRecord(LedgerCertificateReviewRecord ledgerCertificateReviewRecord);
+
+    /**
+     * 修改证书复审记录
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 结果
+     */
+    public int updateCertificateReviewRecord(LedgerCertificateReviewRecord ledgerCertificateReviewRecord);
+
+    /**
+     * 批量删除证书复审记录
+     * 
+     * @param ids 需要删除的证书复审记录主键集合
+     * @return 结果
+     */
+    public int deleteCertificateReviewRecordByIds(Long[] ids);
+
+    /**
+     * 删除证书复审记录信息
+     * 
+     * @param id 证书复审记录主键
+     * @return 结果
+     */
+    public int deleteCertificateReviewRecordById(Long id);
+
+    /**
+     * 根据证书ID删除所有复审记录
+     * 
+     * @param certId 证书ID
+     * @return 结果
+     */
+    public int deleteCertificateReviewRecordByCertId(Long certId);
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerLedgerCertificateInfoServiceImpl.java

@@ -0,0 +1,380 @@
+package com.sundot.airport.ledger.service.impl;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import com.sundot.airport.common.core.domain.entity.SysUser;
+import com.sundot.airport.common.utils.DateUtils;
+import com.sundot.airport.ledger.mapper.LedgerCertificateInfoMapper;
+import com.sundot.airport.ledger.mapper.LedgerCertificateReviewRecordMapper;
+import com.sundot.airport.ledger.domain.LedgerCertificateInfo;
+import com.sundot.airport.ledger.domain.LedgerCertificateReviewRecord;
+import com.sundot.airport.ledger.service.ILedgerCertificateInfoService;
+import com.sundot.airport.system.service.ISysUserService;
+
+/**
+ * 证书信息Service业务层处理
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+@Service
+public class LedgerLedgerCertificateInfoServiceImpl implements ILedgerCertificateInfoService {
+    @Autowired
+    private LedgerCertificateInfoMapper ledgerCertificateInfoMapper;
+
+    @Autowired
+    private LedgerCertificateReviewRecordMapper ledgerCertificateReviewRecordMapper;
+
+    @Autowired
+    private ISysUserService sysUserService;
+
+    /**
+     * 查询证书信息
+     * 
+     * @param id 证书信息主键
+     * @return 证书信息
+     */
+    @Override
+    public LedgerCertificateInfo selectCertificateInfoById(Long id) {
+        LedgerCertificateInfo ledgerCertificateInfo = ledgerCertificateInfoMapper.selectCertificateInfoById(id);
+        if (ledgerCertificateInfo != null) {
+            // 查询复审记录
+            List<LedgerCertificateReviewRecord> reviewRecords = ledgerCertificateReviewRecordMapper.selectCertificateReviewRecordByCertId(id);
+            ledgerCertificateInfo.setReviewRecords(reviewRecords);
+        }
+        return ledgerCertificateInfo;
+    }
+
+    /**
+     * 查询证书信息列表
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 证书信息
+     */
+    @Override
+    public List<LedgerCertificateInfo> selectCertificateInfoList(LedgerCertificateInfo ledgerCertificateInfo) {
+        return ledgerCertificateInfoMapper.selectCertificateInfoList(ledgerCertificateInfo);
+    }
+
+    /**
+     * 新增证书信息
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 结果
+     */
+    @Override
+    @Transactional
+    public int insertCertificateInfo(LedgerCertificateInfo ledgerCertificateInfo) {
+        ledgerCertificateInfo.setCreateTime(DateUtils.getNowDate());
+        int rows = ledgerCertificateInfoMapper.insertCertificateInfo(ledgerCertificateInfo);
+        
+        // 保存复审记录
+        saveReviewRecords(ledgerCertificateInfo.getId(), ledgerCertificateInfo.getReviewRecords());
+        
+        return rows;
+    }
+
+    /**
+     * 修改证书信息
+     * 
+     * @param ledgerCertificateInfo 证书信息
+     * @return 结果
+     */
+    @Override
+    @Transactional
+    public int updateCertificateInfo(LedgerCertificateInfo ledgerCertificateInfo) {
+        ledgerCertificateInfo.setUpdateTime(DateUtils.getNowDate());
+        int rows = ledgerCertificateInfoMapper.updateCertificateInfo(ledgerCertificateInfo);
+        
+        // 先删除旧的复审记录，再保存新的
+        ledgerCertificateReviewRecordMapper.deleteCertificateReviewRecordByCertId(ledgerCertificateInfo.getId());
+        saveReviewRecords(ledgerCertificateInfo.getId(), ledgerCertificateInfo.getReviewRecords());
+        
+        return rows;
+    }
+
+    /**
+     * 批量删除证书信息
+     * 
+     * @param ids 需要删除的证书信息主键
+     * @return 结果
+     */
+    @Override
+    @Transactional
+    public int deleteCertificateInfoByIds(Long[] ids) {
+        // 删除复审记录
+        for (Long id : ids) {
+            ledgerCertificateReviewRecordMapper.deleteCertificateReviewRecordByCertId(id);
+        }
+        return ledgerCertificateInfoMapper.deleteCertificateInfoByIds(ids);
+    }
+
+    /**
+     * 删除证书信息信息
+     * 
+     * @param id 证书信息主键
+     * @return 结果
+     */
+    @Override
+    @Transactional
+    public int deleteCertificateInfoById(Long id) {
+        // 删除复审记录
+        ledgerCertificateReviewRecordMapper.deleteCertificateReviewRecordByCertId(id);
+        return ledgerCertificateInfoMapper.deleteCertificateInfoById(id);
+    }
+
+    /**
+     * 导入证书数据
+     * 
+     * @param certificateList 证书数据列表
+     * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据
+     * @param operName 操作用户
+     * @return 结果
+     */
+    @Override
+    @Transactional
+    public String importCertificate(List<LedgerCertificateInfo> certificateList, Boolean isUpdateSupport, String operName) {
+        if (certificateList == null || certificateList.isEmpty()) {
+            throw new RuntimeException("导入证书数据不能为空！");
+        }
+        
+        int successNum = 0;
+        int failureNum = 0;
+        StringBuilder successMsg = new StringBuilder();
+        StringBuilder failureMsg = new StringBuilder();
+        
+        // 第一步: 收集所有姓名，批量查询用户信息
+        List<String> personNames = certificateList.stream()
+                .map(LedgerCertificateInfo::getPersonName)
+                .filter(name -> name != null && !name.trim().isEmpty())
+                .distinct()
+                .collect(Collectors.toList());
+        
+        // 批量查询用户信息
+        List<SysUser> users = sysUserService.selectUsersByNames(personNames);
+        
+        // 构建姓名到用户的映射 Map<姓名, SysUser>
+        Map<String, SysUser> userMap = new HashMap<>();
+        for (SysUser user : users) {
+            // 优先使用 nickName（用户名称），如果没有则使用 userName（登录名称）
+            String key = user.getNickName() != null && !user.getNickName().isEmpty() 
+                    ? user.getNickName() : user.getUserName();
+            userMap.put(key, user);
+        }
+        
+        // 第二步: 找出未找到用户的姓名
+        List<String> notFoundNames = new ArrayList<>();
+        for (String name : personNames) {
+            if (!userMap.containsKey(name)) {
+                notFoundNames.add(name);
+            }
+        }
+        
+        // 如果有未找到的用户，报错提醒
+        if (!notFoundNames.isEmpty()) {
+            throw new RuntimeException("以下人员未在系统中找到：" + String.join("、", notFoundNames));
+        }
+        
+        // 第三步: 为每个证书设置 userId
+        for (LedgerCertificateInfo certificate : certificateList) {
+            String personName = certificate.getPersonName();
+            SysUser user = userMap.get(personName);
+            if (user != null) {
+                certificate.setUserId(user.getUserId());
+            }
+        }
+        
+        // 第四步: 批量查询已存在的证书信息（根据 userId 和 certNo）
+        Map<String, LedgerCertificateInfo> existingCertMap = new HashMap<>();
+        for (LedgerCertificateInfo certificate : certificateList) {
+            if (certificate.getUserId() != null && certificate.getCertNo() != null) {
+                LedgerCertificateInfo existCert = ledgerCertificateInfoMapper.selectCertificateInfoByUserIdAndCertNo(
+                        certificate.getUserId(), certificate.getCertNo());
+                if (existCert != null) {
+                    String key = certificate.getUserId() + "_" + certificate.getCertNo();
+                    existingCertMap.put(key, existCert);
+                }
+            }
+        }
+        
+        // 第五步: 处理每个证书的导入（新增或更新）
+        for (LedgerCertificateInfo certificate : certificateList) {
+            try {
+                String key = certificate.getUserId() + "_" + certificate.getCertNo();
+                LedgerCertificateInfo existCert = existingCertMap.get(key);
+                
+                if (existCert != null) {
+                    // 存在则更新
+                    if (isUpdateSupport) {
+                        certificate.setId(existCert.getId());
+                        certificate.setUpdateBy(operName);
+                        ledgerCertificateInfoMapper.updateCertificateInfo(certificate);
+                        
+                        // 更新复审记录
+                        ledgerCertificateReviewRecordMapper.deleteCertificateReviewRecordByCertId(existCert.getId());
+                        saveReviewRecords(existCert.getId(), certificate.getReviewRecords());
+                        
+                        successNum++;
+                        successMsg.append("<br/>").append(successNum).append("、")
+                                .append(certificate.getPersonName()).append(" 的证书编号 ")
+                                .append(certificate.getCertNo()).append(" 更新成功");
+                    } else {
+                        failureNum++;
+                        failureMsg.append("<br/>").append(failureNum).append("、")
+                                .append(certificate.getPersonName()).append(" 的证书编号 ")
+                                .append(certificate.getCertNo()).append(" 已存在");
+                    }
+                } else {
+                    // 不存在则新增
+                    certificate.setCreateBy(operName);
+                    ledgerCertificateInfoMapper.insertCertificateInfo(certificate);
+                    
+                    // 保存复审记录
+                    saveReviewRecords(certificate.getId(), certificate.getReviewRecords());
+                    
+                    successNum++;
+                    successMsg.append("<br/>").append(successNum).append("、")
+                            .append(certificate.getPersonName()).append(" 的证书编号 ")
+                            .append(certificate.getCertNo()).append(" 导入成功");
+                }
+                
+                // 第六步: 同步更新用户表的证书等级（5<4<3<2<1，数字越小等级越高）
+                syncUserQualificationLevel(certificate.getUserId(), certificate.getCertLevel());
+                
+            } catch (Exception e) {
+                failureNum++;
+                String msg = "<br/>" + failureNum + "、" + certificate.getPersonName() + " 的证书编号 " 
+                        + certificate.getCertNo() + " 导入失败：";
+                failureMsg.append(msg + e.getMessage());
+            }
+        }
+        
+        if (failureNum > 0) {
+            failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
+            throw new RuntimeException(failureMsg.toString());
+        } else {
+            successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
+        }
+        return successMsg.toString();
+    }
+
+    /**
+     * 保存复审记录
+     * 
+     * @param certId 证书ID
+     * @param reviewRecords 复审记录列表
+     */
+    private void saveReviewRecords(Long certId, List<LedgerCertificateReviewRecord> reviewRecords) {
+        if (reviewRecords != null && !reviewRecords.isEmpty()) {
+            for (int i = 0; i < reviewRecords.size(); i++) {
+                LedgerCertificateReviewRecord record = reviewRecords.get(i);
+                record.setCertId(certId);
+                record.setReviewSeq(i + 1); // 设置复审次序
+                record.setCreateTime(DateUtils.getNowDate());
+                ledgerCertificateReviewRecordMapper.insertCertificateReviewRecord(record);
+            }
+        }
+    }
+
+    /**
+     * 同步更新用户表的证书等级
+     * 等级规则: 5<4<3<2<1 (数字越小等级越高)
+     * 如果出现更高等级，就更新用户表
+     * 
+     * @param userId 用户ID
+     * @param newCertLevel 新证书等级
+     */
+    private void syncUserQualificationLevel(Long userId, String newCertLevel) {
+        if (userId == null || newCertLevel == null || newCertLevel.trim().isEmpty()) {
+            return;
+        }
+        
+        try {
+            // 查询用户当前资质等级
+            SysUser user = sysUserService.selectUserById(userId);
+            if (user == null) {
+                return;
+            }
+            
+            String currentLevel = user.getQualificationLevel();
+            
+            // 如果用户当前没有等级，直接设置
+            if (currentLevel == null || currentLevel.trim().isEmpty()) {
+                updateUserQualificationLevel(userId, newCertLevel);
+                return;
+            }
+            
+            // 比较等级高低（数字越小等级越高）
+            int currentLevelNum = parseLevelToNumber(currentLevel);
+            int newLevelNum = parseLevelToNumber(newCertLevel);
+            
+            // 如果新等级更高，则更新用户表
+            if (newLevelNum < currentLevelNum) {
+                updateUserQualificationLevel(userId, newCertLevel);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+    
+    /**
+     * 将等级字符串转换为数字进行比较
+     * 支持格式: "一级"、"LEVEL_ONE"、"1" 等
+     * 
+     * @param level 等级字符串
+     * @return 等级数字，无法解析返回 Integer.MAX_VALUE
+     */
+    private int parseLevelToNumber(String level) {
+        if (level == null || level.trim().isEmpty()) {
+            return Integer.MAX_VALUE;
+        }
+        
+        level = level.trim();
+        
+        // 中文等级
+        if (level.contains("一") || level.equals("1")) return 1;
+        if (level.contains("二") || level.equals("2")) return 2;
+        if (level.contains("三") || level.equals("3")) return 3;
+        if (level.contains("四") || level.equals("4")) return 4;
+        if (level.contains("五") || level.equals("5")) return 5;
+        
+        // 英文等级
+        if (level.toUpperCase().contains("ONE")) return 1;
+        if (level.toUpperCase().contains("TWO")) return 2;
+        if (level.toUpperCase().contains("THREE")) return 3;
+        if (level.toUpperCase().contains("FOUR")) return 4;
+        if (level.toUpperCase().contains("FIVE")) return 5;
+        
+        // 尝试直接解析为数字
+        try {
+            int num = Integer.parseInt(level);
+            return num >= 1 && num <= 5 ? num : Integer.MAX_VALUE;
+        } catch (NumberFormatException e) {
+            return Integer.MAX_VALUE;
+        }
+    }
+    
+    /**
+     * 更新用户的资质等级
+     * 
+     * @param userId 用户ID
+     * @param qualificationLevel 资质等级
+     */
+    private void updateUserQualificationLevel(Long userId, String qualificationLevel) {
+        try {
+            SysUser user = new SysUser();
+            user.setUserId(userId);
+            user.setQualificationLevel(qualificationLevel);
+            sysUserService.updateUserProfile(user);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerLedgerCertificateReviewRecordServiceImpl.java

@@ -0,0 +1,111 @@
+package com.sundot.airport.ledger.service.impl;
+
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.sundot.airport.common.utils.DateUtils;
+import com.sundot.airport.ledger.mapper.LedgerCertificateReviewRecordMapper;
+import com.sundot.airport.ledger.domain.LedgerCertificateReviewRecord;
+import com.sundot.airport.ledger.service.ILedgerCertificateReviewRecordService;
+
+/**
+ * 证书复审记录Service业务层处理
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+@Service
+public class LedgerLedgerCertificateReviewRecordServiceImpl implements ILedgerCertificateReviewRecordService {
+    @Autowired
+    private LedgerCertificateReviewRecordMapper ledgerCertificateReviewRecordMapper;
+
+    /**
+     * 查询证书复审记录
+     * 
+     * @param id 证书复审记录主键
+     * @return 证书复审记录
+     */
+    @Override
+    public LedgerCertificateReviewRecord selectCertificateReviewRecordById(Long id) {
+        return ledgerCertificateReviewRecordMapper.selectCertificateReviewRecordById(id);
+    }
+
+    /**
+     * 查询证书复审记录列表
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 证书复审记录
+     */
+    @Override
+    public List<LedgerCertificateReviewRecord> selectCertificateReviewRecordList(LedgerCertificateReviewRecord ledgerCertificateReviewRecord) {
+        return ledgerCertificateReviewRecordMapper.selectCertificateReviewRecordList(ledgerCertificateReviewRecord);
+    }
+
+    /**
+     * 根据证书ID查询复审记录列表
+     * 
+     * @param certId 证书ID
+     * @return 证书复审记录集合
+     */
+    @Override
+    public List<LedgerCertificateReviewRecord> selectCertificateReviewRecordByCertId(Long certId) {
+        return ledgerCertificateReviewRecordMapper.selectCertificateReviewRecordByCertId(certId);
+    }
+
+    /**
+     * 新增证书复审记录
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 结果
+     */
+    @Override
+    public int insertCertificateReviewRecord(LedgerCertificateReviewRecord ledgerCertificateReviewRecord) {
+        ledgerCertificateReviewRecord.setCreateTime(DateUtils.getNowDate());
+        return ledgerCertificateReviewRecordMapper.insertCertificateReviewRecord(ledgerCertificateReviewRecord);
+    }
+
+    /**
+     * 修改证书复审记录
+     * 
+     * @param ledgerCertificateReviewRecord 证书复审记录
+     * @return 结果
+     */
+    @Override
+    public int updateCertificateReviewRecord(LedgerCertificateReviewRecord ledgerCertificateReviewRecord) {
+        ledgerCertificateReviewRecord.setUpdateTime(DateUtils.getNowDate());
+        return ledgerCertificateReviewRecordMapper.updateCertificateReviewRecord(ledgerCertificateReviewRecord);
+    }
+
+    /**
+     * 批量删除证书复审记录
+     * 
+     * @param ids 需要删除的证书复审记录主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCertificateReviewRecordByIds(Long[] ids) {
+        return ledgerCertificateReviewRecordMapper.deleteCertificateReviewRecordByIds(ids);
+    }
+
+    /**
+     * 删除证书复审记录信息
+     * 
+     * @param id 证书复审记录主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCertificateReviewRecordById(Long id) {
+        return ledgerCertificateReviewRecordMapper.deleteCertificateReviewRecordById(id);
+    }
+
+    /**
+     * 根据证书ID删除所有复审记录
+     * 
+     * @param certId 证书ID
+     * @return 结果
+     */
+    @Override
+    public int deleteCertificateReviewRecordByCertId(Long certId) {
+        return ledgerCertificateReviewRecordMapper.deleteCertificateReviewRecordByCertId(certId);
+    }
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/utils/CertificateExcelImportUtil.java

@@ -0,0 +1,304 @@
+package com.sundot.airport.ledger.utils;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import com.sundot.airport.common.utils.poi.ExcelUtil;
+import com.sundot.airport.ledger.domain.LedgerCertificateInfo;
+import com.sundot.airport.ledger.domain.LedgerCertificateReviewRecord;
+import org.apache.poi.ss.usermodel.*;
+
+/**
+ * 证书Excel导入工具类
+ * 利用现有的ExcelUtil和@Excel注解实现动态列识别
+ * 
+ * @author ruoyi
+ * @date 2026-06-29
+ */
+public class CertificateExcelImportUtil {
+    
+    // 匹配格式: "第N次复审时间" 或 "第一次复审时间"
+    // 支持阿拉伯数字(1,2,3...999)和中文数字(一,二,三...九百九十九)
+    private static final Pattern REVIEW_TIME_PATTERN = Pattern.compile("第([\\d]+|[一二三四五六七八九十百千]+)次复审时间");
+    
+    /**
+     * 解析Excel文件,提取证书信息和复审记录
+     * 使用现有的ExcelUtil进行基本字段解析,额外处理动态的复审时间列
+     * 
+     * @param workbook Excel工作簿
+     * @return 证书信息列表(包含复审记录)
+     */
+    public static List<LedgerCertificateInfo> parseCertificateExcel(Workbook workbook) {
+        try {
+            // 将Workbook转换为InputStream以便重用ExcelUtil
+            // 注意:这里我们需要重新从workbook获取输入流,所以采用另一种方式
+            // 直接使用ExcelUtil,但它不支持动态列,所以我们需要扩展
+            
+            Sheet sheet = workbook.getSheetAt(0);
+            if (sheet == null) {
+                return new ArrayList<>();
+            }
+            
+            // 第一步:使用ExcelUtil解析基本字段(利用@Excel注解)
+            // 由于ExcelUtil需要InputStream,我们创建一个临时的
+            java.io.ByteArrayOutputStream baos = new java.io.ByteArrayOutputStream();
+            workbook.write(baos);
+            java.io.ByteArrayInputStream bais = new java.io.ByteArrayInputStream(baos.toByteArray());
+            
+            ExcelUtil<LedgerCertificateInfo> excelUtil = new ExcelUtil<>(LedgerCertificateInfo.class);
+            List<LedgerCertificateInfo> certificateList = excelUtil.importExcel(bais, 0);
+            bais.close();
+            
+            // 第二步:解析复审时间列(动态列,不在@Excel注解中)
+            parseReviewTimeColumns(sheet, certificateList);
+            
+            return certificateList;
+            
+        } catch (Exception e) {
+            System.err.println("解析Excel失败: " + e.getMessage());
+            e.printStackTrace();
+            return new ArrayList<>();
+        }
+    }
+    
+    /**
+     * 解析复审时间列(动态列)
+     * 
+     * @param sheet Excel工作表
+     * @param certificateList 已解析的证书列表
+     */
+    private static void parseReviewTimeColumns(Sheet sheet, List<LedgerCertificateInfo> certificateList) {
+        if (certificateList == null || certificateList.isEmpty()) {
+            return;
+        }
+        
+        // 读取表头,找到所有"第N次复审时间"列的位置
+        Row headerRow = sheet.getRow(0);
+        if (headerRow == null) {
+            return;
+        }
+        
+        // 建立复审时间列映射: key=复审次序, value=列索引
+        Map<Integer, Integer> reviewTimeColumns = new HashMap<>();
+        for (int i = 0; i < headerRow.getLastCellNum(); i++) {
+            Cell cell = headerRow.getCell(i);
+            if (cell != null) {
+                String columnName = getCellValue(cell);
+                if (columnName != null) {
+                    // 去除所有空白字符(包括换行符\n、制表符\t、空格等)
+                    String cleanColumnName = columnName.replaceAll("\\s+", "");
+                    Matcher matcher = REVIEW_TIME_PATTERN.matcher(cleanColumnName);
+                    if (matcher.find()) {
+                        int seq = chineseToNumber(matcher.group(1));
+                        reviewTimeColumns.put(seq, i);
+                    }
+                }
+            }
+        }
+        
+        // 如果没有复审时间列,直接返回
+        if (reviewTimeColumns.isEmpty()) {
+            return;
+        }
+        
+        // 为每个证书提取复审记录
+        for (int i = 0; i < certificateList.size(); i++) {
+            LedgerCertificateInfo cert = certificateList.get(i);
+            // ExcelUtil已经从第1行开始读取数据,所以这里是 i+1
+            Row dataRow = sheet.getRow(i + 1);
+            if (dataRow == null) {
+                continue;
+            }
+            
+            List<LedgerCertificateReviewRecord> reviewRecords = new ArrayList<>();
+            for (Map.Entry<Integer, Integer> entry : reviewTimeColumns.entrySet()) {
+                int seq = entry.getKey();
+                int colIndex = entry.getValue();
+                
+                Cell cell = dataRow.getCell(colIndex);
+                Date reviewTime = parseDate(cell);
+                
+                if (reviewTime != null) {
+                    LedgerCertificateReviewRecord record = new LedgerCertificateReviewRecord();
+                    record.setReviewSeq(seq);
+                    record.setReviewTime(reviewTime);
+                    reviewRecords.add(record);
+                }
+            }
+            
+            cert.setReviewRecords(reviewRecords);
+        }
+    }
+    
+    /**
+     * 获取单元格值(复用ExcelUtil的逻辑)
+     */
+    private static String getCellValue(Cell cell) {
+        if (cell == null) {
+            return null;
+        }
+        
+        try {
+            switch (cell.getCellType()) {
+                case STRING:
+                    return cell.getStringCellValue().trim();
+                case NUMERIC:
+                    if (org.apache.poi.ss.usermodel.DateUtil.isCellDateFormatted(cell)) {
+                        // 日期类型格式化为 yyyy-MM-dd
+                        java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd");
+                        return sdf.format(cell.getDateCellValue());
+                    } else {
+                        double value = cell.getNumericCellValue();
+                        if (value == Math.floor(value)) {
+                            return String.valueOf((long) value);
+                        } else {
+                            return String.valueOf(value);
+                        }
+                    }
+                case BOOLEAN:
+                    return String.valueOf(cell.getBooleanCellValue());
+                case FORMULA:
+                    try {
+                        // 尝试获取数值结果
+                        return String.valueOf(cell.getNumericCellValue());
+                    } catch (Exception e) {
+                        // 如果失败，尝试获取字符串结果
+                        try {
+                            return cell.getStringCellValue().trim();
+                        } catch (Exception ex) {
+                            return cell.getCellFormula();
+                        }
+                    }
+                case BLANK:
+                    return "";
+                default:
+                    return null;
+            }
+        } catch (IllegalStateException e) {
+            // 处理类型不匹配的情况：尝试以字符串方式读取
+            try {
+                return cell.getStringCellValue().trim();
+            } catch (Exception ex) {
+                // 如果还是失败，返回null
+                return null;
+            }
+        } catch (Exception e) {
+            // 其他异常也返回null
+            return null;
+        }
+    }
+    
+    /**
+     * 解析日期
+     */
+    private static Date parseDate(Cell cell) {
+        if (cell == null) {
+            return null;
+        }
+        
+        // 如果是日期格式的单元格，直接返回 Date 对象
+        try {
+            if (org.apache.poi.ss.usermodel.DateUtil.isCellDateFormatted(cell)) {
+                return cell.getDateCellValue();
+            }
+        } catch (Exception e) {
+            throw new RuntimeException("日期格式错误，e:", e);
+        }
+
+        
+        String value = getCellValue(cell);
+        if (value == null || value.isEmpty()) {
+            return null;
+        }
+        
+        // 尝试解析常见日期格式
+        String[] patterns = {
+            "yyyy-MM-dd",
+            "yyyy/MM/dd",
+            "yyyy年MM月dd日",
+            "MM/dd/yyyy",
+            "MM-dd-yyyy",
+            "dd-MMM-yyyy",  // 01-十二月-2012
+            "dd/MMM/yyyy",  // 01/Dec/2012
+            "yyyy-MM-dd HH:mm:ss",
+            "yyyy/MM/dd HH:mm:ss"
+        };
+        
+        for (String pattern : patterns) {
+            try {
+                java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat(pattern, java.util.Locale.CHINA);
+                sdf.setLenient(false); // 严格模式
+                return sdf.parse(value);
+            } catch (Exception e) {
+                // 继续尝试下一个格式
+            }
+        }
+
+        return null;
+    }
+    
+    /**
+     * 中文数字转阿拉伯数字
+     * 支持: 一~九, 十, 十一~九十九, 一百~九百九十九等
+     */
+    private static int chineseToNumber(String chinese) {
+        // 如果是阿拉伯数字,直接返回
+        try {
+            return Integer.parseInt(chinese);
+        } catch (NumberFormatException e) {
+            // 不是阿拉伯数字,继续处理中文数字
+        }
+        
+        // 简单映射(个位数)
+        Map<String, Integer> basicMap = new HashMap<>();
+        basicMap.put("一", 1);
+        basicMap.put("二", 2);
+        basicMap.put("三", 3);
+        basicMap.put("四", 4);
+        basicMap.put("五", 5);
+        basicMap.put("六", 6);
+        basicMap.put("七", 7);
+        basicMap.put("八", 8);
+        basicMap.put("九", 9);
+        basicMap.put("十", 10);
+        
+        // 如果是个位数或十,直接返回
+        if (basicMap.containsKey(chinese)) {
+            return basicMap.get(chinese);
+        }
+        
+        // 处理复合数字: 十一~十九
+        if (chinese.startsWith("十") && chinese.length() == 2) {
+            String secondChar = chinese.substring(1);
+            if (basicMap.containsKey(secondChar)) {
+                return 10 + basicMap.get(secondChar);
+            }
+        }
+        
+        // 处理: 二十~九十九
+        if (chinese.length() == 2 && chinese.endsWith("十")) {
+            String firstChar = chinese.substring(0, 1);
+            if (basicMap.containsKey(firstChar)) {
+                return basicMap.get(firstChar) * 10;
+            }
+        }
+        
+        // 处理: 二十一~九十九
+        if (chinese.length() == 3 && chinese.charAt(1) == '十') {
+            String firstChar = chinese.substring(0, 1);
+            String thirdChar = chinese.substring(2, 3);
+            if (basicMap.containsKey(firstChar) && basicMap.containsKey(thirdChar)) {
+                return basicMap.get(firstChar) * 10 + basicMap.get(thirdChar);
+            }
+        }
+        
+        // 如果不支持中文数字格式,返回0
+        System.err.println("不支持的中文数字格式: " + chinese + ", 请使用阿拉伯数字");
+        return 0;
+    }
+}

airport-ledger/src/main/resources/mapper/personnel/LedgerCertificateInfoMapper.xml

@@ -0,0 +1,188 @@
+<?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.sundot.airport.ledger.mapper.LedgerCertificateInfoMapper">
+    
+    <resultMap type="LedgerCertificateInfo" id="CertificateInfoResult">
+        <id     property="id"              column="id"              />
+        <result property="tenantId"        column="tenant_id"       />
+        <result property="unitName"        column="unit_name"       />
+        <result property="userId"          column="user_id"         />
+        <result property="personName"      column="person_name"     />
+        <result property="gender"          column="gender"          />
+        <result property="birthDate"       column="birth_date"      />
+        <result property="idCard"          column="id_card"         />
+        <result property="certLevel"       column="cert_level"      />
+        <result property="issueDate"       column="issue_date"      />
+        <result property="certNo"          column="cert_no"         />
+        <result property="theoryScore"     column="theory_score"    />
+        <result property="practiceScore"   column="practice_score"  />
+        <result property="evalScore"       column="eval_score"      />
+        <result property="employmentType"  column="employment_type" />
+        <result property="serviceMonths"   column="service_months"  />
+        <result property="expiryDate"      column="expiry_date"     />
+        <result property="status"          column="status"          />
+        <result property="expireDays"      column="expire_days"     />
+        <result property="remark"          column="remark"          />
+        <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="delFlag"         column="del_flag"        />
+    </resultMap>
+
+    <sql id="selectCertificateInfoVo">
+        select id, tenant_id, unit_name, user_id, person_name, gender, birth_date, id_card, 
+               cert_level, issue_date, cert_no, theory_score, practice_score, eval_score, 
+               employment_type, service_months, expiry_date, status, expire_days, remark,
+               create_by, create_time, update_by, update_time, del_flag
+        from ledger_certificate_info
+    </sql>
+
+    <select id="selectCertificateInfoList" parameterType="LedgerCertificateInfo" resultMap="CertificateInfoResult">
+        <include refid="selectCertificateInfoVo"/>
+        <where>  
+            del_flag = '0'
+            <if test="tenantId != null and tenantId != ''"> and tenant_id = #{tenantId}</if>
+            <if test="unitName != null and unitName != ''"> and unit_name like concat('%', #{unitName}, '%')</if>
+            <if test="personName != null and personName != ''"> and person_name like concat('%', #{personName}, '%')</if>
+            <if test="gender != null and gender != ''"> and gender = #{gender}</if>
+            <if test="idCard != null and idCard != ''"> and id_card = #{idCard}</if>
+            <if test="certLevel != null and certLevel != ''"> and cert_level = #{certLevel}</if>
+            <if test="certNo != null and certNo != ''"> and cert_no = #{certNo}</if>
+            <if test="employmentType != null and employmentType != ''"> and employment_type = #{employmentType}</if>
+            <if test="status != null and status != ''"> and status = #{status}</if>
+            <if test="params.beginBirthDate != null and params.beginBirthDate != ''">
+                and date_format(birth_date,'%Y%m%d') &gt;= date_format(#{params.beginBirthDate},'%Y%m%d')
+            </if>
+            <if test="params.endBirthDate != null and params.endBirthDate != ''">
+                and date_format(birth_date,'%Y%m%d') &lt;= date_format(#{params.endBirthDate},'%Y%m%d')
+            </if>
+            <if test="params.beginIssueDate != null and params.beginIssueDate != ''">
+                and date_format(issue_date,'%Y%m%d') &gt;= date_format(#{params.beginIssueDate},'%Y%m%d')
+            </if>
+            <if test="params.endIssueDate != null and params.endIssueDate != ''">
+                and date_format(issue_date,'%Y%m%d') &lt;= date_format(#{params.endIssueDate},'%Y%m%d')
+            </if>
+            <if test="params.beginExpiryDate != null and params.beginExpiryDate != ''">
+                and date_format(expiry_date,'%Y%m%d') &gt;= date_format(#{params.beginExpiryDate},'%Y%m%d')
+            </if>
+            <if test="params.endExpiryDate != null and params.endExpiryDate != ''">
+                and date_format(expiry_date,'%Y%m%d') &lt;= date_format(#{params.endExpiryDate},'%Y%m%d')
+            </if>
+        </where>
+        order by create_time desc
+    </select>
+    
+    <select id="selectCertificateInfoById" parameterType="Long" resultMap="CertificateInfoResult">
+        <include refid="selectCertificateInfoVo"/>
+        where id = #{id} and del_flag = '0'
+    </select>
+
+    <select id="selectCertificateInfoByIdCard" parameterType="String" resultMap="CertificateInfoResult">
+        <include refid="selectCertificateInfoVo"/>
+        where id_card = #{idCard} and del_flag = '0' limit 1
+    </select>
+
+    <select id="selectCertificateInfoByCertNo" parameterType="String" resultMap="CertificateInfoResult">
+        <include refid="selectCertificateInfoVo"/>
+        where cert_no = #{certNo} and del_flag = '0' limit 1
+    </select>
+
+    <select id="selectCertificateInfoByUserIdAndCertNo" resultMap="CertificateInfoResult">
+        <include refid="selectCertificateInfoVo"/>
+        where user_id = #{userId} and cert_no = #{certNo} and del_flag = '0' limit 1
+    </select>
+        
+    <insert id="insertCertificateInfo" parameterType="LedgerCertificateInfo" useGeneratedKeys="true" keyProperty="id">
+        insert into ledger_certificate_info
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="tenantId != null and tenantId != ''">tenant_id,</if>
+            <if test="unitName != null and unitName != ''">unit_name,</if>
+            <if test="userId != null">user_id,</if>
+            <if test="personName != null and personName != ''">person_name,</if>
+            <if test="gender != null and gender != ''">gender,</if>
+            <if test="birthDate != null">birth_date,</if>
+            <if test="idCard != null and idCard != ''">id_card,</if>
+            <if test="certLevel != null and certLevel != ''">cert_level,</if>
+            <if test="issueDate != null">issue_date,</if>
+            <if test="certNo != null and certNo != ''">cert_no,</if>
+            <if test="theoryScore != null">theory_score,</if>
+            <if test="practiceScore != null">practice_score,</if>
+            <if test="evalScore != null">eval_score,</if>
+            <if test="employmentType != null and employmentType != ''">employment_type,</if>
+            <if test="serviceMonths != null">service_months,</if>
+            <if test="expiryDate != null">expiry_date,</if>
+            <if test="status != null and status != ''">status,</if>
+            <if test="expireDays != null">expire_days,</if>
+            <if test="remark != null and remark != ''">remark,</if>
+            <if test="createBy != null and createBy != ''">create_by,</if>
+            create_time,
+            del_flag
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="tenantId != null and tenantId != ''">#{tenantId},</if>
+            <if test="unitName != null and unitName != ''">#{unitName},</if>
+            <if test="userId != null">#{userId},</if>
+            <if test="personName != null and personName != ''">#{personName},</if>
+            <if test="gender != null and gender != ''">#{gender},</if>
+            <if test="birthDate != null">#{birthDate},</if>
+            <if test="idCard != null and idCard != ''">#{idCard},</if>
+            <if test="certLevel != null and certLevel != ''">#{certLevel},</if>
+            <if test="issueDate != null">#{issueDate},</if>
+            <if test="certNo != null and certNo != ''">#{certNo},</if>
+            <if test="theoryScore != null">#{theoryScore},</if>
+            <if test="practiceScore != null">#{practiceScore},</if>
+            <if test="evalScore != null">#{evalScore},</if>
+            <if test="employmentType != null and employmentType != ''">#{employmentType},</if>
+            <if test="serviceMonths != null">#{serviceMonths},</if>
+            <if test="expiryDate != null">#{expiryDate},</if>
+            <if test="status != null and status != ''">#{status},</if>
+            <if test="expireDays != null">#{expireDays},</if>
+            <if test="remark != null and remark != ''">#{remark},</if>
+            <if test="createBy != null and createBy != ''">#{createBy},</if>
+            sysdate(),
+            '0'
+         </trim>
+    </insert>
+
+    <update id="updateCertificateInfo" parameterType="LedgerCertificateInfo">
+        update ledger_certificate_info
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="tenantId != null and tenantId != ''">tenant_id = #{tenantId},</if>
+            <if test="unitName != null and unitName != ''">unit_name = #{unitName},</if>
+            <if test="userId != null">user_id = #{userId},</if>
+            <if test="personName != null and personName != ''">person_name = #{personName},</if>
+            <if test="gender != null and gender != ''">gender = #{gender},</if>
+            <if test="birthDate != null">birth_date = #{birthDate},</if>
+            <if test="idCard != null and idCard != ''">id_card = #{idCard},</if>
+            <if test="certLevel != null and certLevel != ''">cert_level = #{certLevel},</if>
+            <if test="issueDate != null">issue_date = #{issueDate},</if>
+            <if test="certNo != null and certNo != ''">cert_no = #{certNo},</if>
+            <if test="theoryScore != null">theory_score = #{theoryScore},</if>
+            <if test="practiceScore != null">practice_score = #{practiceScore},</if>
+            <if test="evalScore != null">eval_score = #{evalScore},</if>
+            <if test="employmentType != null and employmentType != ''">employment_type = #{employmentType},</if>
+            <if test="serviceMonths != null">service_months = #{serviceMonths},</if>
+            <if test="expiryDate != null">expiry_date = #{expiryDate},</if>
+            <if test="status != null and status != ''">status = #{status},</if>
+            <if test="expireDays != null">expire_days = #{expireDays},</if>
+            <if test="remark != null and remark != ''">remark = #{remark},</if>
+            <if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
+            update_time = sysdate()
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteCertificateInfoById" parameterType="Long">
+        update ledger_certificate_info set del_flag = '2' where id = #{id}
+    </delete>
+
+    <delete id="deleteCertificateInfoByIds" parameterType="Long">
+        update ledger_certificate_info set del_flag = '2' where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>

airport-ledger/src/main/resources/mapper/personnel/LedgerCertificateReviewRecordMapper.xml

@@ -0,0 +1,112 @@
+<?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.sundot.airport.ledger.mapper.LedgerCertificateReviewRecordMapper">
+    
+    <resultMap type="LedgerCertificateReviewRecord" id="CertificateReviewRecordResult">
+        <id     property="id"            column="id"              />
+        <result property="certId"        column="cert_id"         />
+        <result property="reviewSeq"     column="review_seq"      />
+        <result property="reviewTime"    column="review_time"     />
+        <result property="reviewResult"  column="review_result"   />
+        <result property="reviewer"      column="reviewer"        />
+        <result property="remark"        column="remark"          />
+        <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="delFlag"       column="del_flag"        />
+    </resultMap>
+
+    <sql id="selectCertificateReviewRecordVo">
+        select id, cert_id, review_seq, review_time, review_result, reviewer, remark,
+               create_by, create_time, update_by, update_time, del_flag
+        from certificate_review_record
+    </sql>
+
+    <select id="selectCertificateReviewRecordList" parameterType="LedgerCertificateReviewRecord" resultMap="CertificateReviewRecordResult">
+        <include refid="selectCertificateReviewRecordVo"/>
+        <where>  
+            del_flag = '0'
+            <if test="certId != null"> and cert_id = #{certId}</if>
+            <if test="reviewSeq != null"> and review_seq = #{reviewSeq}</if>
+            <if test="reviewResult != null and reviewResult != ''"> and review_result = #{reviewResult}</if>
+            <if test="reviewer != null and reviewer != ''"> and reviewer like concat('%', #{reviewer}, '%')</if>
+            <if test="params.beginReviewTime != null and params.beginReviewTime != ''">
+                and date_format(review_time,'%Y%m%d') &gt;= date_format(#{params.beginReviewTime},'%Y%m%d')
+            </if>
+            <if test="params.endReviewTime != null and params.endReviewTime != ''">
+                and date_format(review_time,'%Y%m%d') &lt;= date_format(#{params.endReviewTime},'%Y%m%d')
+            </if>
+        </where>
+        order by cert_id asc, review_seq asc
+    </select>
+    
+    <select id="selectCertificateReviewRecordById" parameterType="Long" resultMap="CertificateReviewRecordResult">
+        <include refid="selectCertificateReviewRecordVo"/>
+        where id = #{id} and del_flag = '0'
+    </select>
+
+    <select id="selectCertificateReviewRecordByCertId" parameterType="Long" resultMap="CertificateReviewRecordResult">
+        <include refid="selectCertificateReviewRecordVo"/>
+        where cert_id = #{certId} and del_flag = '0'
+        order by review_seq asc
+    </select>
+        
+    <insert id="insertCertificateReviewRecord" parameterType="LedgerCertificateReviewRecord" useGeneratedKeys="true" keyProperty="id">
+        insert into certificate_review_record
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="certId != null">cert_id,</if>
+            <if test="reviewSeq != null">review_seq,</if>
+            <if test="reviewTime != null">review_time,</if>
+            <if test="reviewResult != null and reviewResult != ''">review_result,</if>
+            <if test="reviewer != null and reviewer != ''">reviewer,</if>
+            <if test="remark != null and remark != ''">remark,</if>
+            <if test="createBy != null and createBy != ''">create_by,</if>
+            create_time,
+            del_flag
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="certId != null">#{certId},</if>
+            <if test="reviewSeq != null">#{reviewSeq},</if>
+            <if test="reviewTime != null">#{reviewTime},</if>
+            <if test="reviewResult != null and reviewResult != ''">#{reviewResult},</if>
+            <if test="reviewer != null and reviewer != ''">#{reviewer},</if>
+            <if test="remark != null and remark != ''">#{remark},</if>
+            <if test="createBy != null and createBy != ''">#{createBy},</if>
+            sysdate(),
+            '0'
+         </trim>
+    </insert>
+
+    <update id="updateCertificateReviewRecord" parameterType="LedgerCertificateReviewRecord">
+        update certificate_review_record
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="certId != null">cert_id = #{certId},</if>
+            <if test="reviewSeq != null">review_seq = #{reviewSeq},</if>
+            <if test="reviewTime != null">review_time = #{reviewTime},</if>
+            <if test="reviewResult != null and reviewResult != ''">review_result = #{reviewResult},</if>
+            <if test="reviewer != null and reviewer != ''">reviewer = #{reviewer},</if>
+            <if test="remark != null and remark != ''">remark = #{remark},</if>
+            <if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
+            update_time = sysdate()
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteCertificateReviewRecordById" parameterType="Long">
+        update certificate_review_record set del_flag = '2' where id = #{id}
+    </delete>
+
+    <delete id="deleteCertificateReviewRecordByIds" parameterType="Long">
+        update certificate_review_record set del_flag = '2' where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+    <delete id="deleteCertificateReviewRecordByCertId" parameterType="Long">
+        update certificate_review_record set del_flag = '2' where cert_id = #{certId}
+    </delete>
+</mapper>