wkc/ccdi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

中介类型修改

Browse Source
This commit is contained in:
wkc
2026-01-29 13:39:47 +08:00
parent 2c146c026a
commit 1b043fa2d6
36 changed files with 4373 additions and 145 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ruoyi-dpc/src/main/java/com/ruoyi/dpc/controller/DpcEmployeeController.java
View File

@@ -15,7 +15,6 @@ import com.ruoyi.dpc.domain.excel.DpcEmployeeExcel;
import com.ruoyi.dpc.domain.vo.DpcEmployeeVO;
import com.ruoyi.dpc.service.IDpcEmployeeService;
import com.ruoyi.dpc.utils.EasyExcelUtil;
import com.ruoyi.dpc.utils.handler.EmployeeStatusSheetWriteHandler;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
@@ -111,12 +110,13 @@ public class DpcEmployeeController extends BaseController {
}
/**
* 下载导入模板
* 下载带字典下拉框的导入模板
* 使用@DictDropdown注解自动添加下拉框
*/
@Operation(summary = "下载导入模板")
@PostMapping("/importTemplate")
public void importTemplate(HttpServletResponse response) {
EasyExcelUtil.importTemplateExcel(response, DpcEmployeeExcel.class, "员工信息", new EmployeeStatusSheetWriteHandler());
EasyExcelUtil.importTemplateWithDictDropdown(response, DpcEmployeeExcel.class, "员工信息");
}
/**

50
ruoyi-dpc/src/main/java/com/ruoyi/dpc/controller/DpcIntermediaryBlacklistController.java
View File

@@ -13,6 +13,8 @@ import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistAddDTO;
import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistEditDTO;
import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistQueryDTO;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryBlacklistExcel;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryEntityExcel;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryPersonExcel;
import com.ruoyi.dpc.domain.vo.DpcIntermediaryBlacklistVO;
import com.ruoyi.dpc.service.IDpcIntermediaryBlacklistService;
import com.ruoyi.dpc.utils.EasyExcelUtil;
@@ -68,13 +70,13 @@ public class DpcIntermediaryBlacklistController extends BaseController {
}
/**
* 获取中介黑名单详细信息
* 获取中介黑名单详细信息（根据类型返回不同结构）
*/
@Operation(summary = "获取中介黑名单详细信息")
@PreAuthorize("@ss.hasPermi('dpc:intermediary:query')")
@GetMapping(value = "/{intermediaryId}")
public AjaxResult getInfo(@PathVariable Long intermediaryId) {
return success(intermediaryService.selectIntermediaryById(intermediaryId));
return success(intermediaryService.selectIntermediaryDetailById(intermediaryId));
}
/**
@@ -111,24 +113,46 @@ public class DpcIntermediaryBlacklistController extends BaseController {
}
/**
* 下载导入模板
* 下载个人中介导入模板（带字典下拉框）
*/
@Operation(summary = "下载导入模板")
@PostMapping("/importTemplate")
public void importTemplate(HttpServletResponse response) {
EasyExcelUtil.importTemplateExcel(response, DpcIntermediaryBlacklistExcel.class, "中介黑名单");
@Operation(summary = "下载个人中介导入模板")
@PostMapping("/importPersonTemplate")
public void importPersonTemplate(HttpServletResponse response) {
EasyExcelUtil.importTemplateWithDictDropdown(response, DpcIntermediaryPersonExcel.class, "个人中介黑名单");
}
/**
* 导入中介黑名单
* 下载机构中介导入模板（带字典下拉框）
*/
@Operation(summary = "导入中介黑名单")
@Operation(summary = "下载机构中介导入模板")
@PostMapping("/importEntityTemplate")
public void importEntityTemplate(HttpServletResponse response) {
EasyExcelUtil.importTemplateWithDictDropdown(response, DpcIntermediaryEntityExcel.class, "机构中介黑名单");
}
/**
* 导入个人中介黑名单
*/
@Operation(summary = "导入个人中介黑名单")
@PreAuthorize("@ss.hasPermi('dpc:intermediary:import')")
@Log(title = "中介黑名单", businessType = BusinessType.IMPORT)
@PostMapping("/importData")
public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception {
List<DpcIntermediaryBlacklistExcel> list = EasyExcelUtil.importExcel(file.getInputStream(), DpcIntermediaryBlacklistExcel.class);
String message = intermediaryService.importIntermediary(list, updateSupport);
@PostMapping("/importPersonData")
public AjaxResult importPersonData(MultipartFile file, boolean updateSupport) throws Exception {
List<DpcIntermediaryPersonExcel> list = EasyExcelUtil.importExcel(file.getInputStream(), DpcIntermediaryPersonExcel.class);
String message = intermediaryService.importPersonIntermediary(list, updateSupport);
return success(message);
}
/**
* 导入机构中介黑名单
*/
@Operation(summary = "导入机构中介黑名单")
@PreAuthorize("@ss.hasPermi('dpc:intermediary:import')")
@Log(title = "中介黑名单", businessType = BusinessType.IMPORT)
@PostMapping("/importEntityData")
public AjaxResult importEntityData(MultipartFile file, boolean updateSupport) throws Exception {
List<DpcIntermediaryEntityExcel> list = EasyExcelUtil.importExcel(file.getInputStream(), DpcIntermediaryEntityExcel.class);
String message = intermediaryService.importEntityIntermediary(list, updateSupport);
return success(message);
}
}

90
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/DpcIntermediaryBlacklist.java
View File

@@ -41,6 +41,96 @@ public class DpcIntermediaryBlacklist implements Serializable {
/** 备注 */
private String remark;
// ============================================================
// 个人类型字段 (以 indiv_ 前缀标识，individual 缩写)
// ============================================================
/** 人员类型（中介、职业背债人、房产中介等） */
private String indivType;
/** 人员子类型（本人、配偶等） */
private String indivSubType;
/** 性别（M男 F女 O其他） */
private String indivGender;
/** 证件类型 */
private String indivCertType;
/** 手机号码（加密存储） */
private String indivPhone;
/** 微信号 */
private String indivWechat;
/** 联系地址 */
private String indivAddress;
/** 所在公司 */
private String indivCompany;
/** 职位/职务 */
private String indivPosition;
/** 关联人员ID */
private String indivRelatedId;
/** 关联关系 */
private String indivRelation;
// ============================================================
// 机构类型字段 (以 corp_ 前缀标识，corporation 缩写)
// ============================================================
/** 统一社会信用代码 */
private String corpCreditCode;
/** 主体类型（有限责任公司、股份有限公司等） */
private String corpType;
/** 企业性质（国企、民企、外企等） */
private String corpNature;
/** 行业分类 */
private String corpIndustryCategory;
/** 所属行业 */
private String corpIndustry;
/** 成立日期 */
private Date corpEstablishDate;
/** 注册地址 */
private String corpAddress;
/** 法定代表人 */
private String corpLegalRep;
/** 法定代表人证件类型 */
private String corpLegalCertType;
/** 法定代表人证件号码 */
private String corpLegalCertNo;
/** 股东1 */
private String corpShareholder1;
/** 股东2 */
private String corpShareholder2;
/** 股东3 */
private String corpShareholder3;
/** 股东4 */
private String corpShareholder4;
/** 股东5 */
private String corpShareholder5;
// ============================================================
// 通用字段
// ============================================================
/** 数据来源（MANUAL手动录入 SYSTEM系统同步 IMPORT批量导入 API接口获取） */
private String dataSource;
/** 创建者 */
@TableField(fill = FieldFill.INSERT)
private String createBy;

239
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/dto/DpcIntermediaryEntityAddDTO.java Normal file
View File

@@ -0,0 +1,239 @@
package com.ruoyi.dpc.domain.dto;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.Size;
import java.io.Serial;
import java.io.Serializable;
import java.util.Date;
/**
* 机构中介黑名单新增 DTO
*
* @author ruoyi
* @date 2026-01-29
*/
public class DpcIntermediaryEntityAddDTO implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/** 机构名称 */
@NotBlank(message = "机构名称不能为空")
@Size(min = 1, max = 100, message = "机构名称长度不能超过100个字符")
private String name;
/** 状态 */
@NotBlank(message = "状态不能为空")
private String status;
/** 备注 */
@Size(max = 500, message = "备注长度不能超过500个字符")
private String remark;
// ============================================================
// 机构专属字段
// ============================================================
/** 统一社会信用代码 */
@Size(max = 18, message = "统一社会信用代码长度不能超过18个字符")
private String corpCreditCode;
/** 主体类型 */
@Size(max = 50, message = "主体类型长度不能超过50个字符")
private String corpType;
/** 企业性质 */
@Size(max = 50, message = "企业性质长度不能超过50个字符")
private String corpNature;
/** 行业分类 */
@Size(max = 100, message = "行业分类长度不能超过100个字符")
private String corpIndustryCategory;
/** 所属行业 */
@Size(max = 100, message = "所属行业长度不能超过100个字符")
private String corpIndustry;
/** 成立日期 */
private Date corpEstablishDate;
/** 注册地址 */
@Size(max = 500, message = "注册地址长度不能超过500个字符")
private String corpAddress;
/** 法定代表人 */
@Size(max = 50, message = "法定代表人长度不能超过50个字符")
private String corpLegalRep;
/** 法定代表人证件类型 */
@Size(max = 30, message = "法定代表人证件类型长度不能超过30个字符")
private String corpLegalCertType;
/** 法定代表人证件号码 */
@Size(max = 30, message = "法定代表人证件号码长度不能超过30个字符")
private String corpLegalCertNo;
/** 股东1 */
@Size(max = 30, message = "股东1长度不能超过30个字符")
private String corpShareholder1;
/** 股东2 */
@Size(max = 30, message = "股东2长度不能超过30个字符")
private String corpShareholder2;
/** 股东3 */
@Size(max = 30, message = "股东3长度不能超过30个字符")
private String corpShareholder3;
/** 股东4 */
@Size(max = 30, message = "股东4长度不能超过30个字符")
private String corpShareholder4;
/** 股东5 */
@Size(max = 30, message = "股东5长度不能超过30个字符")
private String corpShareholder5;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getCorpCreditCode() {
return corpCreditCode;
}
public void setCorpCreditCode(String corpCreditCode) {
this.corpCreditCode = corpCreditCode;
}
public String getCorpType() {
return corpType;
}
public void setCorpType(String corpType) {
this.corpType = corpType;
}
public String getCorpNature() {
return corpNature;
}
public void setCorpNature(String corpNature) {
this.corpNature = corpNature;
}
public String getCorpIndustryCategory() {
return corpIndustryCategory;
}
public void setCorpIndustryCategory(String corpIndustryCategory) {
this.corpIndustryCategory = corpIndustryCategory;
}
public String getCorpIndustry() {
return corpIndustry;
}
public void setCorpIndustry(String corpIndustry) {
this.corpIndustry = corpIndustry;
}
public Date getCorpEstablishDate() {
return corpEstablishDate;
}
public void setCorpEstablishDate(Date corpEstablishDate) {
this.corpEstablishDate = corpEstablishDate;
}
public String getCorpAddress() {
return corpAddress;
}
public void setCorpAddress(String corpAddress) {
this.corpAddress = corpAddress;
}
public String getCorpLegalRep() {
return corpLegalRep;
}
public void setCorpLegalRep(String corpLegalRep) {
this.corpLegalRep = corpLegalRep;
}
public String getCorpLegalCertType() {
return corpLegalCertType;
}
public void setCorpLegalCertType(String corpLegalCertType) {
this.corpLegalCertType = corpLegalCertType;
}
public String getCorpLegalCertNo() {
return corpLegalCertNo;
}
public void setCorpLegalCertNo(String corpLegalCertNo) {
this.corpLegalCertNo = corpLegalCertNo;
}
public String getCorpShareholder1() {
return corpShareholder1;
}
public void setCorpShareholder1(String corpShareholder1) {
this.corpShareholder1 = corpShareholder1;
}
public String getCorpShareholder2() {
return corpShareholder2;
}
public void setCorpShareholder2(String corpShareholder2) {
this.corpShareholder2 = corpShareholder2;
}
public String getCorpShareholder3() {
return corpShareholder3;
}
public void setCorpShareholder3(String corpShareholder3) {
this.corpShareholder3 = corpShareholder3;
}
public String getCorpShareholder4() {
return corpShareholder4;
}
public void setCorpShareholder4(String corpShareholder4) {
this.corpShareholder4 = corpShareholder4;
}
public String getCorpShareholder5() {
return corpShareholder5;
}
public void setCorpShareholder5(String corpShareholder5) {
this.corpShareholder5 = corpShareholder5;
}
}

204
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/dto/DpcIntermediaryPersonAddDTO.java Normal file
View File

@@ -0,0 +1,204 @@
package com.ruoyi.dpc.domain.dto;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.Size;
import java.io.Serial;
import java.io.Serializable;
/**
* 个人中介黑名单新增 DTO
*
* @author ruoyi
* @date 2026-01-29
*/
public class DpcIntermediaryPersonAddDTO implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/** 姓名 */
@NotBlank(message = "姓名不能为空")
@Size(min = 1, max = 100, message = "姓名长度不能超过100个字符")
private String name;
/** 证件号码 */
@NotBlank(message = "证件号码不能为空")
@Size(max = 50, message = "证件号码长度不能超过50个字符")
private String certificateNo;
/** 状态 */
@NotBlank(message = "状态不能为空")
private String status;
/** 备注 */
@Size(max = 500, message = "备注长度不能超过500个字符")
private String remark;
// ============================================================
// 个人专属字段
// ============================================================
/** 人员类型 */
@Size(max = 30, message = "人员类型长度不能超过30个字符")
private String indivType;
/** 人员子类型 */
@Size(max = 50, message = "人员子类型长度不能超过50个字符")
private String indivSubType;
/** 性别 */
@Size(max = 1, message = "性别长度不能超过1个字符")
private String indivGender;
/** 证件类型 */
@Size(max = 30, message = "证件类型长度不能超过30个字符")
private String indivCertType;
/** 手机号码 */
@Size(max = 20, message = "手机号码长度不能超过20个字符")
private String indivPhone;
/** 微信号 */
@Size(max = 50, message = "微信号长度不能超过50个字符")
private String indivWechat;
/** 联系地址 */
@Size(max = 200, message = "联系地址长度不能超过200个字符")
private String indivAddress;
/** 所在公司 */
@Size(max = 100, message = "所在公司长度不能超过100个字符")
private String indivCompany;
/** 职位/职务 */
@Size(max = 100, message = "职位长度不能超过100个字符")
private String indivPosition;
/** 关联人员ID */
@Size(max = 20, message = "关联人员ID长度不能超过20个字符")
private String indivRelatedId;
/** 关联关系 */
@Size(max = 50, message = "关联关系长度不能超过50个字符")
private String indivRelation;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCertificateNo() {
return certificateNo;
}
public void setCertificateNo(String certificateNo) {
this.certificateNo = certificateNo;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getIndivType() {
return indivType;
}
public void setIndivType(String indivType) {
this.indivType = indivType;
}
public String getIndivSubType() {
return indivSubType;
}
public void setIndivSubType(String indivSubType) {
this.indivSubType = indivSubType;
}
public String getIndivGender() {
return indivGender;
}
public void setIndivGender(String indivGender) {
this.indivGender = indivGender;
}
public String getIndivCertType() {
return indivCertType;
}
public void setIndivCertType(String indivCertType) {
this.indivCertType = indivCertType;
}
public String getIndivPhone() {
return indivPhone;
}
public void setIndivPhone(String indivPhone) {
this.indivPhone = indivPhone;
}
public String getIndivWechat() {
return indivWechat;
}
public void setIndivWechat(String indivWechat) {
this.indivWechat = indivWechat;
}
public String getIndivAddress() {
return indivAddress;
}
public void setIndivAddress(String indivAddress) {
this.indivAddress = indivAddress;
}
public String getIndivCompany() {
return indivCompany;
}
public void setIndivCompany(String indivCompany) {
this.indivCompany = indivCompany;
}
public String getIndivPosition() {
return indivPosition;
}
public void setIndivPosition(String indivPosition) {
this.indivPosition = indivPosition;
}
public String getIndivRelatedId() {
return indivRelatedId;
}
public void setIndivRelatedId(String indivRelatedId) {
this.indivRelatedId = indivRelatedId;
}
public String getIndivRelation() {
return indivRelation;
}
public void setIndivRelation(String indivRelation) {
this.indivRelation = indivRelation;
}
}

5
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/excel/DpcEmployeeExcel.java
View File

@@ -2,7 +2,7 @@ package com.ruoyi.dpc.domain.excel;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.annotation.write.style.ColumnWidth;
import com.ruoyi.dpc.utils.converter.EmployeeStatusConverter;
import com.ruoyi.common.annotation.DictDropdown;
import lombok.Data;
import java.io.Serial;
@@ -52,7 +52,8 @@ public class DpcEmployeeExcel implements Serializable {
private Date hireDate;
/** 状态 */
@ExcelProperty(value = "状态", converter = EmployeeStatusConverter.class, index = 6)
@ExcelProperty(value = "状态", index = 6)
@ColumnWidth(10)
@DictDropdown(dictType = "dpc_employee_status")
private String status;
}

96
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/excel/DpcIntermediaryEntityExcel.java Normal file
View File

@@ -0,0 +1,96 @@
package com.ruoyi.dpc.domain.excel;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.annotation.write.style.ColumnWidth;
import com.ruoyi.common.annotation.DictDropdown;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
/**
* 机构中介黑名单Excel导入对象
*
* @author ruoyi
* @date 2026-01-29
*/
@Data
public class DpcIntermediaryEntityExcel implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
@ExcelProperty(value = "机构名称", index = 0)
@ColumnWidth(25)
private String name;
@ExcelProperty(value = "统一社会信用代码", index = 1)
@ColumnWidth(20)
private String corpCreditCode;
@ExcelProperty(value = "主体类型", index = 2)
@ColumnWidth(20)
@DictDropdown(dictType = "dpc_entity_type")
private String corpType;
@ExcelProperty(value = "企业性质", index = 3)
@ColumnWidth(15)
@DictDropdown(dictType = "dpc_enterprise_nature")
private String corpNature;
@ExcelProperty(value = "行业分类", index = 4)
@ColumnWidth(15)
private String corpIndustryCategory;
@ExcelProperty(value = "所属行业", index = 5)
@ColumnWidth(15)
private String corpIndustry;
@ExcelProperty(value = "成立日期", index = 6)
@ColumnWidth(15)
private String corpEstablishDate;
@ExcelProperty(value = "注册地址", index = 7)
@ColumnWidth(40)
private String corpAddress;
@ExcelProperty(value = "法定代表人", index = 8)
@ColumnWidth(15)
private String corpLegalRep;
@ExcelProperty(value = "法定代表人证件类型", index = 9)
@ColumnWidth(20)
private String corpLegalCertType;
@ExcelProperty(value = "法定代表人证件号码", index = 10)
@ColumnWidth(20)
private String corpLegalCertNo;
@ExcelProperty(value = "股东1", index = 11)
@ColumnWidth(15)
private String corpShareholder1;
@ExcelProperty(value = "股东2", index = 12)
@ColumnWidth(15)
private String corpShareholder2;
@ExcelProperty(value = "股东3", index = 13)
@ColumnWidth(15)
private String corpShareholder3;
@ExcelProperty(value = "股东4", index = 14)
@ColumnWidth(15)
private String corpShareholder4;
@ExcelProperty(value = "股东5", index = 15)
@ColumnWidth(15)
private String corpShareholder5;
@ExcelProperty(value = "备注", index = 16)
@ColumnWidth(30)
private String remark;
// 以下字段不在 Excel 中显示，由系统自动设置
// private String status; // 默认：正常（0）
// private String dataSource; // 默认：批量导入（IMPORT）
}

84
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/excel/DpcIntermediaryPersonExcel.java Normal file
View File

@@ -0,0 +1,84 @@
package com.ruoyi.dpc.domain.excel;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.annotation.write.style.ColumnWidth;
import com.ruoyi.common.annotation.DictDropdown;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
/**
* 个人中介黑名单Excel导入对象
*
* @author ruoyi
* @date 2026-01-29
*/
@Data
public class DpcIntermediaryPersonExcel implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
@ExcelProperty(value = "姓名", index = 0)
@ColumnWidth(15)
private String name;
@ExcelProperty(value = "人员类型", index = 1)
@ColumnWidth(15)
private String indivType;
@ExcelProperty(value = "人员子类型", index = 2)
@ColumnWidth(15)
private String indivSubType;
@ExcelProperty(value = "性别", index = 3)
@ColumnWidth(10)
@DictDropdown(dictType = "dpc_indiv_gender")
private String indivGender;
@ExcelProperty(value = "证件类型", index = 4)
@ColumnWidth(15)
@DictDropdown(dictType = "dpc_certificate_type")
private String indivCertType;
@ExcelProperty(value = "证件号码", index = 5)
@ColumnWidth(20)
private String certificateNo;
@ExcelProperty(value = "手机号码", index = 6)
@ColumnWidth(15)
private String indivPhone;
@ExcelProperty(value = "微信号", index = 7)
@ColumnWidth(15)
private String indivWechat;
@ExcelProperty(value = "联系地址", index = 8)
@ColumnWidth(30)
private String indivAddress;
@ExcelProperty(value = "所在公司", index = 9)
@ColumnWidth(20)
private String indivCompany;
@ExcelProperty(value = "职位", index = 10)
@ColumnWidth(15)
private String indivPosition;
@ExcelProperty(value = "关联人员ID", index = 11)
@ColumnWidth(15)
private String indivRelatedId;
@ExcelProperty(value = "关联关系", index = 12)
@ColumnWidth(15)
private String indivRelation;
@ExcelProperty(value = "备注", index = 13)
@ColumnWidth(30)
private String remark;
// 以下字段不在 Excel 中显示，由系统自动设置
// private String status; // 默认：正常（0）
// private String dataSource; // 默认：批量导入（IMPORT）
}

98
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/vo/DpcIntermediaryBlacklistVO.java
View File

@@ -1,6 +1,7 @@
package com.ruoyi.dpc.domain.vo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
@@ -12,6 +13,7 @@ import java.util.Date;
* @author ruoyi
* @date 2026-01-27
*/
@Data
public class DpcIntermediaryBlacklistVO implements Serializable {
@Serial
@@ -54,100 +56,4 @@ public class DpcIntermediaryBlacklistVO implements Serializable {
/** 更新时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
public Long getIntermediaryId() {
return intermediaryId;
}
public void setIntermediaryId(Long intermediaryId) {
this.intermediaryId = intermediaryId;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getCertificateNo() {
return certificateNo;
}
public void setCertificateNo(String certificateNo) {
this.certificateNo = certificateNo;
}
public String getIntermediaryType() {
return intermediaryType;
}
public void setIntermediaryType(String intermediaryType) {
this.intermediaryType = intermediaryType;
}
public String getIntermediaryTypeName() {
return intermediaryTypeName;
}
public void setIntermediaryTypeName(String intermediaryTypeName) {
this.intermediaryTypeName = intermediaryTypeName;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public String getStatusName() {
return statusName;
}
public void setStatusName(String statusName) {
this.statusName = statusName;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getCreateBy() {
return createBy;
}
public void setCreateBy(String createBy) {
this.createBy = createBy;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getUpdateBy() {
return updateBy;
}
public void setUpdateBy(String updateBy) {
this.updateBy = updateBy;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}

126
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/vo/DpcIntermediaryEntityDetailVO.java Normal file
View File

@@ -0,0 +1,126 @@
package com.ruoyi.dpc.domain.vo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.util.Date;
/**
* 机构中介黑名单详情 VO
*
* @author ruoyi
* @date 2026-01-29
*/
@Data
public class DpcIntermediaryEntityDetailVO implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
// ============================================================
// 核心字段
// ============================================================
/** 中介ID */
private Long intermediaryId;
/** 机构名称 */
private String name;
/** 证件号码 */
private String certificateNo;
/** 中介类型 */
private String intermediaryType;
/** 中介类型名称 */
private String intermediaryTypeName;
/** 状态 */
private String status;
/** 状态名称 */
private String statusName;
/** 备注 */
private String remark;
/** 数据来源 */
private String dataSource;
/** 数据来源名称 */
private String dataSourceName;
// ============================================================
// 机构专属字段
// ============================================================
/** 统一社会信用代码 */
private String corpCreditCode;
/** 主体类型 */
private String corpType;
/** 主体类型名称 */
private String corpTypeName;
/** 企业性质 */
private String corpNature;
/** 企业性质名称 */
private String corpNatureName;
/** 行业分类 */
private String corpIndustryCategory;
/** 所属行业 */
private String corpIndustry;
/** 成立日期 */
@JsonFormat(pattern = "yyyy-MM-dd")
private Date corpEstablishDate;
/** 注册地址 */
private String corpAddress;
/** 法定代表人 */
private String corpLegalRep;
/** 法定代表人证件类型 */
private String corpLegalCertType;
/** 法定代表人证件号码 */
private String corpLegalCertNo;
/** 股东1 */
private String corpShareholder1;
/** 股东2 */
private String corpShareholder2;
/** 股东3 */
private String corpShareholder3;
/** 股东4 */
private String corpShareholder4;
/** 股东5 */
private String corpShareholder5;
// ============================================================
// 审计字段
// ============================================================
/** 创建者 */
private String createBy;
/** 创建时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/** 更新者 */
private String updateBy;
/** 更新时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
}

113
ruoyi-dpc/src/main/java/com/ruoyi/dpc/domain/vo/DpcIntermediaryPersonDetailVO.java Normal file
View File

@@ -0,0 +1,113 @@
package com.ruoyi.dpc.domain.vo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.util.Date;
/**
* 个人中介黑名单详情 VO
*
* @author ruoyi
* @date 2026-01-29
*/
@Data
public class DpcIntermediaryPersonDetailVO implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
// ============================================================
// 核心字段
// ============================================================
/** 中介ID */
private Long intermediaryId;
/** 姓名 */
private String name;
/** 证件号码 */
private String certificateNo;
/** 中介类型 */
private String intermediaryType;
/** 中介类型名称 */
private String intermediaryTypeName;
/** 状态 */
private String status;
/** 状态名称 */
private String statusName;
/** 备注 */
private String remark;
/** 数据来源 */
private String dataSource;
/** 数据来源名称 */
private String dataSourceName;
// ============================================================
// 个人专属字段
// ============================================================
/** 人员类型 */
private String indivType;
/** 人员子类型 */
private String indivSubType;
/** 性别 */
private String indivGender;
/** 性别名称 */
private String indivGenderName;
/** 证件类型 */
private String indivCertType;
/** 证件类型名称 */
private String indivCertTypeName;
/** 手机号码 */
private String indivPhone;
/** 微信号 */
private String indivWechat;
/** 联系地址 */
private String indivAddress;
/** 所在公司 */
private String indivCompany;
/** 职位/职务 */
private String indivPosition;
/** 关联人员ID */
private String indivRelatedId;
/** 关联关系 */
private String indivRelation;
// ============================================================
// 审计字段
// ============================================================
/** 创建者 */
private String createBy;
/** 创建时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/** 更新者 */
private String updateBy;
/** 更新时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
}

41
ruoyi-dpc/src/main/java/com/ruoyi/dpc/enums/DataSource.java Normal file
View File

@@ -0,0 +1,41 @@
package com.ruoyi.dpc.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* 数据来源枚举
*
* @author ruoyi
*/
@Getter
@AllArgsConstructor
public enum DataSource {
/** 手动录入 */
MANUAL("MANUAL", "手动录入"),
/** 系统同步 */
SYSTEM("SYSTEM", "系统同步"),
/** 批量导入 */
IMPORT("IMPORT", "批量导入"),
/** 接口获取 */
API("API", "接口获取");
private final String code;
private final String desc;
/**
* 根据编码获取描述
*/
public static String getDescByCode(String code) {
for (DataSource source : values()) {
if (source.getCode().equals(code)) {
return source.getDesc();
}
}
return null;
}
}

35
ruoyi-dpc/src/main/java/com/ruoyi/dpc/enums/EmployeeStatus.java Normal file
View File

@@ -0,0 +1,35 @@
package com.ruoyi.dpc.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* 员工状态枚举
*
* @author ruoyi
*/
@Getter
@AllArgsConstructor
public enum EmployeeStatus {
/** 在职 */
ACTIVE("0", "在职"),
/** 离职 */
INACTIVE("1", "离职");
private final String code;
private final String desc;
/**
* 根据编码获取描述
*/
public static String getDescByCode(String code) {
for (EmployeeStatus status : values()) {
if (status.getCode().equals(code)) {
return status.getDesc();
}
}
return null;
}
}

38
ruoyi-dpc/src/main/java/com/ruoyi/dpc/enums/Gender.java Normal file
View File

@@ -0,0 +1,38 @@
package com.ruoyi.dpc.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* 性别枚举
*
* @author ruoyi
*/
@Getter
@AllArgsConstructor
public enum Gender {
/** 男 */
MALE("M", "男"),
/** 女 */
FEMALE("F", "女"),
/** 其他 */
OTHER("O", "其他");
private final String code;
private final String desc;
/**
* 根据编码获取描述
*/
public static String getDescByCode(String code) {
for (Gender gender : values()) {
if (gender.getCode().equals(code)) {
return gender.getDesc();
}
}
return null;
}
}

35
ruoyi-dpc/src/main/java/com/ruoyi/dpc/enums/IntermediaryStatus.java Normal file
View File

@@ -0,0 +1,35 @@
package com.ruoyi.dpc.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* 中介状态枚举
*
* @author ruoyi
*/
@Getter
@AllArgsConstructor
public enum IntermediaryStatus {
/** 正常 */
NORMAL("0", "正常"),
/** 停用 */
DISABLED("1", "停用");
private final String code;
private final String desc;
/**
* 根据编码获取描述
*/
public static String getDescByCode(String code) {
for (IntermediaryStatus status : values()) {
if (status.getCode().equals(code)) {
return status.getDesc();
}
}
return null;
}
}

35
ruoyi-dpc/src/main/java/com/ruoyi/dpc/enums/IntermediaryType.java Normal file
View File

@@ -0,0 +1,35 @@
package com.ruoyi.dpc.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* 中介类型枚举
*
* @author ruoyi
*/
@Getter
@AllArgsConstructor
public enum IntermediaryType {
/** 个人 */
PERSON("1", "个人"),
/** 机构 */
ENTITY("2", "机构");
private final String code;
private final String desc;
/**
* 根据编码获取描述
*/
public static String getDescByCode(String code) {
for (IntermediaryType type : values()) {
if (type.getCode().equals(code)) {
return type.getDesc();
}
}
return null;
}
}

336
ruoyi-dpc/src/main/java/com/ruoyi/dpc/handler/DictDropdownWriteHandler.java Normal file
View File

@@ -0,0 +1,336 @@
package com.ruoyi.dpc.handler;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.write.handler.SheetWriteHandler;
import com.alibaba.excel.write.metadata.holder.WriteSheetHolder;
import com.alibaba.excel.write.metadata.holder.WriteWorkbookHolder;
import com.ruoyi.common.annotation.DictDropdown;
import com.ruoyi.common.core.domain.entity.SysDictData;
import com.ruoyi.common.utils.DictUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.usermodel.*;
import org.apache.poi.ss.util.CellRangeAddressList;
import java.lang.reflect.Field;
import java.util.*;
/**
* EasyExcel字典下拉框写入处理器
* 在Excel模板生成时，为标注了@DictDropdown注解的字段添加下拉框
*
* @author ruoyi
*/
@Slf4j
public class DictDropdownWriteHandler implements SheetWriteHandler {
/**
* Excel下拉列表直接写入的最大字符数限制
*/
private static final int MAX_DIRECT_LENGTH = 255;
/**
* 实体类Class对象
*/
private final Class<?> modelClass;
/**
* 构造函数
*
* @param modelClass 实体类Class对象
*/
public DictDropdownWriteHandler(Class<?> modelClass) {
this.modelClass = modelClass;
}
@Override
public void afterSheetCreate(WriteWorkbookHolder writeWorkbookHolder, WriteSheetHolder writeSheetHolder) {
// 获取工作簿和工作表
Workbook workbook = writeWorkbookHolder.getWorkbook();
Sheet sheet = writeSheetHolder.getSheet();
// 创建数据验证助手
DataValidationHelper validationHelper = sheet.getDataValidationHelper();
// 解析实体类中的字段及其注解
Map<Integer, DictDropdown> dropdownMap = parseDropdownFields();
// 为每个需要下拉框的字段添加数据验证
for (Map.Entry<Integer, DictDropdown> entry : dropdownMap.entrySet()) {
Integer columnIndex = entry.getKey();
DictDropdown dropdown = entry.getValue();
try {
// 获取字典数据
List<SysDictData> dictDataList = getDictData(dropdown.dictType());
if (dictDataList == null || dictDataList.isEmpty()) {
log.warn("字典类型[{}]没有可用数据，跳过下拉框创建", dropdown.dictType());
continue;
}
// 获取下拉选项列表
String[] dropdownOptions = extractOptions(dictDataList, dropdown.displayType());
if (dropdownOptions.length == 0) {
log.warn("字典类型[{}]提取选项为空，跳过下拉框创建", dropdown.dictType());
continue;
}
// 创建数据验证
DataValidation validation = createDataValidation(
workbook,
sheet,
validationHelper,
columnIndex,
dropdownOptions,
dropdown.hiddenSheetName(),
dropdown.strict()
);
if (validation != null) {
sheet.addValidationData(validation);
log.info("成功为列[{}]添加字典[{}]的下拉框，选项数量：{}", columnIndex, dropdown.dictType(), dropdownOptions.length);
}
} catch (Exception e) {
log.error("为列[{}]添加字典[{}]下拉框失败：{}", columnIndex, dropdown.dictType(), e.getMessage(), e);
}
}
}
/**
* 解析实体类中的字段，获取需要添加下拉框的字段及其注解
*
* @return 字段索引与注解的映射
*/
private Map<Integer, DictDropdown> parseDropdownFields() {
Map<Integer, DictDropdown> result = new HashMap<>();
// 获取所有字段（包括父类的）
List<Field> fields = getAllFields(modelClass);
for (Field field : fields) {
// 检查是否有@DictDropdown注解
DictDropdown dropdown = field.getAnnotation(DictDropdown.class);
if (dropdown == null) {
continue;
}
// 获取列索引
Integer columnIndex = getColumnIndex(field);
if (columnIndex == null) {
log.warn("字段[{}]没有指定@ExcelProperty的index，跳过下拉框创建", field.getName());
continue;
}
result.put(columnIndex, dropdown);
}
return result;
}
/**
* 获取类的所有字段（包括父类的）
*
* @param clazz 类对象
* @return 字段列表
*/
private List<Field> getAllFields(Class<?> clazz) {
List<Field> fields = new ArrayList<>();
while (clazz != null && clazz != Object.class) {
fields.addAll(Arrays.asList(clazz.getDeclaredFields()));
clazz = clazz.getSuperclass();
}
return fields;
}
/**
* 获取字段对应的列索引
*
* @param field 字段对象
* @return 列索引
*/
private Integer getColumnIndex(Field field) {
ExcelProperty excelProperty = field.getAnnotation(ExcelProperty.class);
if (excelProperty != null && excelProperty.index() >= 0) {
return excelProperty.index();
}
return null;
}
/**
* 获取字典数据
*
* @param dictType 字典类型
* @return 字典数据列表
*/
private List<SysDictData> getDictData(String dictType) {
try {
// 先从缓存获取
List<SysDictData> dictDataList = DictUtils.getDictCache(dictType);
if (dictDataList == null || dictDataList.isEmpty()) {
log.warn("从缓存获取字典[{}]数据为空", dictType);
}
return dictDataList;
} catch (Exception e) {
log.error("获取字典[{}]数据失败：{}", dictType, e.getMessage(), e);
return Collections.emptyList();
}
}
/**
* 从字典数据中提取下拉选项
*
* @param dictDataList 字典数据列表
* @param displayType 显示类型
* @return 下拉选项数组
*/
private String[] extractOptions(List<SysDictData> dictDataList, DictDropdown.DisplayType displayType) {
List<String> options = new ArrayList<>();
for (SysDictData dictData : dictDataList) {
String optionValue;
if (displayType == DictDropdown.DisplayType.VALUE) {
optionValue = dictData.getDictValue();
} else {
optionValue = dictData.getDictLabel();
}
if (optionValue != null && !optionValue.isEmpty()) {
options.add(optionValue);
}
}
return options.toArray(new String[0]);
}
/**
* 创建数据验证
*
* @param workbook 工作簿
* @param sheet 工作表
* @param validationHelper 数据验证助手
* @param columnIndex 列索引
* @param options 下拉选项
* @param hiddenSheetName 隐藏Sheet名称
* @param strict 是否严格模式
* @return 数据验证对象
*/
private DataValidation createDataValidation(
Workbook workbook,
Sheet sheet,
DataValidationHelper validationHelper,
int columnIndex,
String[] options,
String hiddenSheetName,
boolean strict
) {
// 计算选项字符串总长度
int totalLength = Arrays.stream(options)
.mapToInt(String::length)
.sum() + options.length - 1; // 加上分隔符
// 设置数据验证的范围（从第2行开始，第1行是表头）
int firstRow = 1; // 从第2行开始（0-based索引）
int lastRow = sheet.getLastRowNum() + 1000; // 扩展到足够多的行
if (lastRow < 100) {
lastRow = 100; // 至少100行
}
CellRangeAddressList addressList = new CellRangeAddressList(firstRow, lastRow, columnIndex, columnIndex);
// 判断是否需要使用隐藏Sheet
if (totalLength > MAX_DIRECT_LENGTH) {
// 使用隐藏Sheet存储选项
return createHiddenSheetValidation(workbook, sheet, validationHelper, addressList, options, hiddenSheetName, strict);
} else {
// 直接创建下拉列表
return createDirectValidation(validationHelper, addressList, options, strict);
}
}
/**
* 使用隐藏Sheet创建数据验证（适用于选项较多的情况）
*
* @param workbook 工作簿
* @param sheet 主工作表
* @param validationHelper 数据验证助手
* @param addressList 单元格范围
* @param options 下拉选项
* @param hiddenSheetName 隐藏Sheet名称
* @param strict 是否严格模式
* @return 数据验证对象
*/
private DataValidation createHiddenSheetValidation(
Workbook workbook,
Sheet sheet,
DataValidationHelper validationHelper,
CellRangeAddressList addressList,
String[] options,
String hiddenSheetName,
boolean strict
) {
try {
// 创建或获取隐藏Sheet
Sheet hiddenSheet = workbook.getSheet(hiddenSheetName);
if (hiddenSheet == null) {
hiddenSheet = workbook.createSheet(hiddenSheetName);
}
// 写入选项到隐藏Sheet
Row row = hiddenSheet.createRow(0);
for (int i = 0; i < options.length; i++) {
Cell cell = row.createCell(i);
cell.setCellValue(options[i]);
}
// 构建公式引用
String formula = String.format("%s!$A$1:$%s$1", hiddenSheetName,
(char) ('A' + options.length - 1));
// 创建列表验证
DataValidationConstraint constraint = validationHelper.createFormulaListConstraint(formula);
// 设置验证属性
DataValidation validation = validationHelper.createValidation(constraint, addressList);
validation.setSuppressDropDownArrow(true);
validation.setErrorStyle(strict ? DataValidation.ErrorStyle.STOP : DataValidation.ErrorStyle.WARNING);
validation.setShowErrorBox(true);
// 隐藏Sheet（在Excel中无法通过界面隐藏，需要通过代码设置）
workbook.setSheetHidden(workbook.getSheetIndex(hiddenSheetName), true);
return validation;
} catch (Exception e) {
log.error("创建隐藏Sheet数据验证失败：{}", e.getMessage(), e);
return null;
}
}
/**
* 直接创建下拉列表验证（适用于选项较少的情况）
*
* @param validationHelper 数据验证助手
* @param addressList 单元格范围
* @param options 下拉选项
* @param strict 是否严格模式
* @return 数据验证对象
*/
private DataValidation createDirectValidation(
DataValidationHelper validationHelper,
CellRangeAddressList addressList,
String[] options,
boolean strict
) {
// 创建显式列表验证
DataValidationConstraint constraint = validationHelper.createExplicitListConstraint(options);
// 创建数据验证
DataValidation validation = validationHelper.createValidation(constraint, addressList);
// 设置验证属性
validation.setSuppressDropDownArrow(true);
validation.setErrorStyle(strict ? DataValidation.ErrorStyle.STOP : DataValidation.ErrorStyle.WARNING);
validation.setShowErrorBox(true);
return validation;
}
}

28
ruoyi-dpc/src/main/java/com/ruoyi/dpc/service/IDpcIntermediaryBlacklistService.java
View File

@@ -6,6 +6,8 @@ import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistAddDTO;
import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistEditDTO;
import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistQueryDTO;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryBlacklistExcel;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryEntityExcel;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryPersonExcel;
import com.ruoyi.dpc.domain.vo.DpcIntermediaryBlacklistVO;
import java.util.List;
@@ -83,4 +85,30 @@ public interface IDpcIntermediaryBlacklistService {
* @return 结果
*/
String importIntermediary(List<DpcIntermediaryBlacklistExcel> excelList, Boolean isUpdateSupport);
/**
* 根据中介类型获取详情（返回不同类型）
*
* @param intermediaryId 中介ID
* @return 个人返回 DpcIntermediaryPersonDetailVO，机构返回 DpcIntermediaryEntityDetailVO
*/
Object selectIntermediaryDetailById(Long intermediaryId);
/**
* 导入个人中介数据
*
* @param excelList Excel实体列表
* @param isUpdateSupport 是否更新支持
* @return 结果
*/
String importPersonIntermediary(List<DpcIntermediaryPersonExcel> excelList, Boolean isUpdateSupport);
/**
* 导入机构中介数据
*
* @param excelList Excel实体列表
* @param isUpdateSupport 是否更新支持
* @return 结果
*/
String importEntityIntermediary(List<DpcIntermediaryEntityExcel> excelList, Boolean isUpdateSupport);
}

20
ruoyi-dpc/src/main/java/com/ruoyi/dpc/service/impl/DpcEmployeeServiceImpl.java
View File

@@ -12,6 +12,7 @@ import com.ruoyi.dpc.domain.dto.DpcEmployeeQueryDTO;
import com.ruoyi.dpc.domain.dto.DpcEmployeeRelativeAddDTO;
import com.ruoyi.dpc.domain.excel.DpcEmployeeExcel;
import com.ruoyi.dpc.domain.vo.DpcEmployeeVO;
import com.ruoyi.dpc.enums.EmployeeStatus;
import com.ruoyi.dpc.mapper.DpcEmployeeMapper;
import com.ruoyi.dpc.mapper.DpcEmployeeRelativeMapper;
import com.ruoyi.dpc.service.IDpcEmployeeService;
@@ -69,13 +70,9 @@ public class DpcEmployeeServiceImpl implements IDpcEmployeeService {
Page<DpcEmployeeVO> resultPage = employeeMapper.selectEmployeePageWithDept(voPage, queryDTO);
// 设置状态描述
resultPage.getRecords().forEach(vo -> {
if ("0".equals(vo.getStatus())) {
vo.setStatusDesc("在职");
} else if ("1".equals(vo.getStatus())) {
vo.setStatusDesc("离职");
}
});
resultPage.getRecords().forEach(vo ->
vo.setStatusDesc(EmployeeStatus.getDescByCode(vo.getStatus()))
);
return resultPage;
}
@@ -335,14 +332,7 @@ public class DpcEmployeeServiceImpl implements IDpcEmployeeService {
DpcEmployeeVO vo = new DpcEmployeeVO();
BeanUtils.copyProperties(employee, vo);
// 设置状态描述
if ("0".equals(employee.getStatus())) {
vo.setStatusDesc("在职");
} else if ("1".equals(employee.getStatus())) {
vo.setStatusDesc("离职");
}
vo.setStatusDesc(EmployeeStatus.getDescByCode(employee.getStatus()));
return vo;
}
}

283
ruoyi-dpc/src/main/java/com/ruoyi/dpc/service/impl/DpcIntermediaryBlacklistServiceImpl.java
View File

@@ -8,13 +8,22 @@ import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistAddDTO;
import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistEditDTO;
import com.ruoyi.dpc.domain.dto.DpcIntermediaryBlacklistQueryDTO;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryBlacklistExcel;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryEntityExcel;
import com.ruoyi.dpc.domain.excel.DpcIntermediaryPersonExcel;
import com.ruoyi.dpc.domain.vo.DpcIntermediaryBlacklistVO;
import com.ruoyi.dpc.domain.vo.DpcIntermediaryEntityDetailVO;
import com.ruoyi.dpc.domain.vo.DpcIntermediaryPersonDetailVO;
import com.ruoyi.dpc.enums.DataSource;
import com.ruoyi.dpc.enums.Gender;
import com.ruoyi.dpc.enums.IntermediaryStatus;
import com.ruoyi.dpc.enums.IntermediaryType;
import com.ruoyi.dpc.mapper.DpcIntermediaryBlacklistMapper;
import com.ruoyi.dpc.service.IDpcIntermediaryBlacklistService;
import jakarta.annotation.Resource;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
import java.util.List;
import java.util.stream.Collectors;
@@ -178,6 +187,265 @@ public class DpcIntermediaryBlacklistServiceImpl implements IDpcIntermediaryBlac
}
}
/**
* 根据中介类型获取详情（返回不同类型）
*
* @param intermediaryId 中介ID
* @return 个人返回 DpcIntermediaryPersonDetailVO，机构返回 DpcIntermediaryEntityDetailVO
*/
@Override
public Object selectIntermediaryDetailById(Long intermediaryId) {
DpcIntermediaryBlacklist intermediary = intermediaryMapper.selectById(intermediaryId);
if (intermediary == null) {
return null;
}
// 根据中介类型返回不同的 VO
if ("1".equals(intermediary.getIntermediaryType())) {
// 个人类型
return convertToPersonDetailVO(intermediary);
} else {
// 机构类型
return convertToEntityDetailVO(intermediary);
}
}
/**
* 导入个人中介数据
*
* @param excelList Excel实体列表
* @param isUpdateSupport 是否更新支持
* @return 结果
*/
@Override
public String importPersonIntermediary(List<DpcIntermediaryPersonExcel> excelList, Boolean isUpdateSupport) {
if (excelList == null || excelList.isEmpty()) {
return "至少需要一条数据";
}
int successNum = 0;
int failureNum = 0;
StringBuilder successMsg = new StringBuilder();
StringBuilder failureMsg = new StringBuilder();
for (int i = 0; i < excelList.size(); i++) {
DpcIntermediaryPersonExcel excel = excelList.get(i);
try {
// 验证数据
validatePersonIntermediaryData(excel);
// 转换为实体
DpcIntermediaryBlacklist intermediary = new DpcIntermediaryBlacklist();
intermediary.setName(excel.getName());
intermediary.setCertificateNo(excel.getCertificateNo());
intermediary.setIntermediaryType("1"); // 个人类型
intermediary.setStatus("0"); // 默认正常
intermediary.setDataSource("IMPORT"); // 批量导入
intermediary.setRemark(excel.getRemark());
// 个人专属字段
intermediary.setIndivType(excel.getIndivType());
intermediary.setIndivSubType(excel.getIndivSubType());
intermediary.setIndivGender(excel.getIndivGender());
intermediary.setIndivCertType(excel.getIndivCertType());
intermediary.setIndivPhone(excel.getIndivPhone());
intermediary.setIndivWechat(excel.getIndivWechat());
intermediary.setIndivAddress(excel.getIndivAddress());
intermediary.setIndivCompany(excel.getIndivCompany());
intermediary.setIndivPosition(excel.getIndivPosition());
intermediary.setIndivRelatedId(excel.getIndivRelatedId());
intermediary.setIndivRelation(excel.getIndivRelation());
// 设置默认证件类型
if (StringUtils.isEmpty(intermediary.getIndivCertType())) {
intermediary.setIndivCertType("身份证");
}
// 检查是否已存在（通过证件号判断）
if (isUpdateSupport && StringUtils.isNotEmpty(excel.getCertificateNo())) {
LambdaQueryWrapper<DpcIntermediaryBlacklist> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(DpcIntermediaryBlacklist::getCertificateNo, excel.getCertificateNo())
.eq(DpcIntermediaryBlacklist::getIntermediaryType, "1");
DpcIntermediaryBlacklist existing = intermediaryMapper.selectOne(wrapper);
if (existing != null) {
intermediary.setIntermediaryId(existing.getIntermediaryId());
intermediaryMapper.updateById(intermediary);
successNum++;
successMsg.append("<br/>").append(successNum).append("、").append(excel.getName()).append(" 更新成功");
continue;
}
}
intermediaryMapper.insert(intermediary);
successNum++;
successMsg.append("<br/>").append(successNum).append("、").append(excel.getName()).append(" 导入成功");
} catch (Exception e) {
failureNum++;
failureMsg.append("<br/>").append(failureNum).append("、第").append(i + 1).append("行导入失败：");
failureMsg.append(e.getMessage());
}
}
if (failureNum > 0) {
failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
throw new RuntimeException(failureMsg.toString());
} else {
successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条");
return successMsg.toString();
}
}
/**
* 导入机构中介数据
*
* @param excelList Excel实体列表
* @param isUpdateSupport 是否更新支持
* @return 结果
*/
@Override
public String importEntityIntermediary(List<DpcIntermediaryEntityExcel> excelList, Boolean isUpdateSupport) {
if (excelList == null || excelList.isEmpty()) {
return "至少需要一条数据";
}
int successNum = 0;
int failureNum = 0;
StringBuilder successMsg = new StringBuilder();
StringBuilder failureMsg = new StringBuilder();
for (int i = 0; i < excelList.size(); i++) {
DpcIntermediaryEntityExcel excel = excelList.get(i);
try {
// 验证数据
validateEntityIntermediaryData(excel);
// 转换为实体
DpcIntermediaryBlacklist intermediary = new DpcIntermediaryBlacklist();
intermediary.setName(excel.getName());
intermediary.setIntermediaryType("2"); // 机构类型
intermediary.setStatus("0"); // 默认正常
intermediary.setDataSource("IMPORT"); // 批量导入
intermediary.setRemark(excel.getRemark());
// 机构专属字段
intermediary.setCorpCreditCode(excel.getCorpCreditCode());
intermediary.setCorpType(excel.getCorpType());
intermediary.setCorpNature(excel.getCorpNature());
intermediary.setCorpIndustryCategory(excel.getCorpIndustryCategory());
intermediary.setCorpIndustry(excel.getCorpIndustry());
// 解析成立日期
if (StringUtils.isNotEmpty(excel.getCorpEstablishDate())) {
try {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
intermediary.setCorpEstablishDate(sdf.parse(excel.getCorpEstablishDate()));
} catch (Exception e) {
// 忽略日期解析错误
}
}
intermediary.setCorpAddress(excel.getCorpAddress());
intermediary.setCorpLegalRep(excel.getCorpLegalRep());
intermediary.setCorpLegalCertType(excel.getCorpLegalCertType());
intermediary.setCorpLegalCertNo(excel.getCorpLegalCertNo());
intermediary.setCorpShareholder1(excel.getCorpShareholder1());
intermediary.setCorpShareholder2(excel.getCorpShareholder2());
intermediary.setCorpShareholder3(excel.getCorpShareholder3());
intermediary.setCorpShareholder4(excel.getCorpShareholder4());
intermediary.setCorpShareholder5(excel.getCorpShareholder5());
// 检查是否已存在（通过统一社会信用代码判断）
if (isUpdateSupport && StringUtils.isNotEmpty(excel.getCorpCreditCode())) {
LambdaQueryWrapper<DpcIntermediaryBlacklist> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(DpcIntermediaryBlacklist::getCorpCreditCode, excel.getCorpCreditCode())
.eq(DpcIntermediaryBlacklist::getIntermediaryType, "2");
DpcIntermediaryBlacklist existing = intermediaryMapper.selectOne(wrapper);
if (existing != null) {
intermediary.setIntermediaryId(existing.getIntermediaryId());
intermediaryMapper.updateById(intermediary);
successNum++;
successMsg.append("<br/>").append(successNum).append("、").append(excel.getName()).append(" 更新成功");
continue;
}
}
intermediaryMapper.insert(intermediary);
successNum++;
successMsg.append("<br/>").append(successNum).append("、").append(excel.getName()).append(" 导入成功");
} catch (Exception e) {
failureNum++;
failureMsg.append("<br/>").append(failureNum).append("、第").append(i + 1).append("行导入失败：");
failureMsg.append(e.getMessage());
}
}
if (failureNum > 0) {
failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
throw new RuntimeException(failureMsg.toString());
} else {
successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条");
return successMsg.toString();
}
}
/**
* 验证个人中介数据
*/
private void validatePersonIntermediaryData(DpcIntermediaryPersonExcel excel) {
if (StringUtils.isEmpty(excel.getName())) {
throw new RuntimeException("姓名不能为空");
}
if (StringUtils.isEmpty(excel.getCertificateNo())) {
throw new RuntimeException("证件号码不能为空");
}
}
/**
* 验证机构中介数据
*/
private void validateEntityIntermediaryData(DpcIntermediaryEntityExcel excel) {
if (StringUtils.isEmpty(excel.getName())) {
throw new RuntimeException("机构名称不能为空");
}
}
/**
* 转换为个人详情 VO
*/
private DpcIntermediaryPersonDetailVO convertToPersonDetailVO(DpcIntermediaryBlacklist intermediary) {
if (intermediary == null) {
return null;
}
DpcIntermediaryPersonDetailVO vo = new DpcIntermediaryPersonDetailVO();
BeanUtils.copyProperties(intermediary, vo);
vo.setIntermediaryTypeName(IntermediaryType.PERSON.getDesc());
vo.setStatusName(IntermediaryStatus.getDescByCode(intermediary.getStatus()));
vo.setDataSourceName(DataSource.getDescByCode(intermediary.getDataSource()));
vo.setIndivGenderName(Gender.getDescByCode(intermediary.getIndivGender()));
return vo;
}
/**
* 转换为机构详情 VO
*/
private DpcIntermediaryEntityDetailVO convertToEntityDetailVO(DpcIntermediaryBlacklist intermediary) {
if (intermediary == null) {
return null;
}
DpcIntermediaryEntityDetailVO vo = new DpcIntermediaryEntityDetailVO();
BeanUtils.copyProperties(intermediary, vo);
vo.setIntermediaryTypeName(IntermediaryType.ENTITY.getDesc());
vo.setStatusName(IntermediaryStatus.getDescByCode(intermediary.getStatus()));
vo.setDataSourceName(DataSource.getDescByCode(intermediary.getDataSource()));
return vo;
}
/**
* 构建查询条件
*/
@@ -228,19 +496,8 @@ public class DpcIntermediaryBlacklistServiceImpl implements IDpcIntermediaryBlac
DpcIntermediaryBlacklistVO vo = new DpcIntermediaryBlacklistVO();
BeanUtils.copyProperties(intermediary, vo);
// 设置中介类型名称
if ("1".equals(intermediary.getIntermediaryType())) {
vo.setIntermediaryTypeName("个人");
} else if ("2".equals(intermediary.getIntermediaryType())) {
vo.setIntermediaryTypeName("机构");
}
// 设置状态名称
if ("0".equals(intermediary.getStatus())) {
vo.setStatusName("正常");
} else if ("1".equals(intermediary.getStatus())) {
vo.setStatusName("停用");
}
vo.setIntermediaryTypeName(IntermediaryType.getDescByCode(intermediary.getIntermediaryType()));
vo.setStatusName(IntermediaryStatus.getDescByCode(intermediary.getStatus()));
return vo;
}

96
ruoyi-dpc/src/main/java/com/ruoyi/dpc/utils/EasyExcelUtil.java
View File

@@ -3,6 +3,7 @@ package com.ruoyi.dpc.utils;
import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.write.handler.WriteHandler;
import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy;
import com.ruoyi.dpc.handler.DictDropdownWriteHandler;
import jakarta.servlet.http.HttpServletResponse;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
@@ -154,4 +155,99 @@ public class EasyExcelUtil {
String encodedFileName = URLEncoder.encode(fileName, StandardCharsets.UTF_8).replaceAll("\\+", "%20");
response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + encodedFileName + ".xlsx");
}
/**
* 下载带字典下拉框的导入模板
* 自动解析实体类中的@DictDropdown注解，为对应字段添加下拉框
*
* @param response 响应对象
* @param clazz 实体类
* @param sheetName 工作表名称
* @param <T> 泛型
*/
public static <T> void importTemplateWithDictDropdown(HttpServletResponse response, Class<T> clazz, String sheetName) {
try {
setResponseHeader(response, sheetName + "模板");
EasyExcel.write(response.getOutputStream(), clazz)
.sheet(sheetName)
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.registerWriteHandler(new DictDropdownWriteHandler(clazz))
.doWrite(List.of());
} catch (IOException e) {
throw new RuntimeException("下载带字典下拉框的导入模板失败", e);
}
}
/**
* 下载带字典下拉框的导入模板（指定文件名）
* 自动解析实体类中的@DictDropdown注解，为对应字段添加下拉框
*
* @param response 响应对象
* @param clazz 实体类
* @param sheetName 工作表名称
* @param fileName 文件名称
* @param <T> 泛型
*/
public static <T> void importTemplateWithDictDropdown(HttpServletResponse response, Class<T> clazz,
String sheetName, String fileName) {
try {
setResponseHeader(response, fileName);
EasyExcel.write(response.getOutputStream(), clazz)
.sheet(sheetName)
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.registerWriteHandler(new DictDropdownWriteHandler(clazz))
.doWrite(List.of());
} catch (IOException e) {
throw new RuntimeException("下载带字典下拉框的导入模板失败", e);
}
}
/**
* 导出Excel（带字典下拉框）
* 导出的数据包含实际值，但模板中有下拉框供后续编辑使用
*
* @param response 响应对象
* @param list 数据列表
* @param clazz 实体类
* @param sheetName 工作表名称
* @param <T> 泛型
*/
public static <T> void exportExcelWithDictDropdown(HttpServletResponse response, List<T> list,
Class<T> clazz, String sheetName) {
try {
setResponseHeader(response, sheetName);
EasyExcel.write(response.getOutputStream(), clazz)
.sheet(sheetName)
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.registerWriteHandler(new DictDropdownWriteHandler(clazz))
.doWrite(list);
} catch (IOException e) {
throw new RuntimeException("导出带字典下拉框的Excel失败", e);
}
}
/**
* 导出Excel（带字典下拉框，指定文件名）
* 导出的数据包含实际值，但模板中有下拉框供后续编辑使用
*
* @param response 响应对象
* @param list 数据列表
* @param clazz 实体类
* @param sheetName 工作表名称
* @param fileName 文件名称
* @param <T> 泛型
*/
public static <T> void exportExcelWithDictDropdown(HttpServletResponse response, List<T> list,
Class<T> clazz, String sheetName, String fileName) {
try {
setResponseHeader(response, fileName);
EasyExcel.write(response.getOutputStream(), clazz)
.sheet(sheetName)
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.registerWriteHandler(new DictDropdownWriteHandler(clazz))
.doWrite(list);
} catch (IOException e) {
throw new RuntimeException("导出带字典下拉框的Excel失败", e);
}
}
}