Commit 6777bb2b authored by alex yao's avatar alex yao

Merge remote-tracking branch 'origin/release_gdghg' into release_gdghg

parents c1348e99 c10541d0
package cn.com.poc.ai_data_audit.constants;
/**
* @Author:Roger Wu
* @name:DataAuditConstants
* @Date:2025-10-30 0:02
*/
public interface DataAuditConstants {
interface status {
public final String status_process = "process";
public final String status_end = "end";
public final String status_fail = "fail";
}
}
package cn.com.poc.ai_data_audit.convert;
import cn.com.poc.ai_data_audit.model.BizAiDataAuditFileModel;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditFileEntity;
import cn.com.poc.ai_data_audit.dto.BizAiDataAuditFileDto;
public class BizAiDataAuditFileConvert {
public static BizAiDataAuditFileEntity modelToEntity(BizAiDataAuditFileModel model){
BizAiDataAuditFileEntity entity = new BizAiDataAuditFileEntity();
entity.setDataAuditFileId(model.getDataAuditFileId());
entity.setTaskId(model.getTaskId());
entity.setOrginalTemplateCode(model.getOrginalTemplateCode());
entity.setOrginalTemplateName(model.getOrginalTemplateName());
entity.setUploadFileName(model.getUploadFileName());
entity.setUploadFileUrl(model.getUploadFileUrl());
entity.setIsDeleted(model.getIsDeleted());
entity.setCreator(model.getCreator());
entity.setCreatedTime(model.getCreatedTime());
entity.setModifier(model.getModifier());
entity.setModifiedTime(model.getModifiedTime());
entity.setSysVersion(model.getSysVersion());
return entity;
}
public static BizAiDataAuditFileModel entityToModel(BizAiDataAuditFileEntity entity){
BizAiDataAuditFileModel model = new BizAiDataAuditFileModel();
model.setDataAuditFileId(entity.getDataAuditFileId());
model.setTaskId(entity.getTaskId());
model.setOrginalTemplateCode(entity.getOrginalTemplateCode());
model.setOrginalTemplateName(entity.getOrginalTemplateName());
model.setUploadFileName(entity.getUploadFileName());
model.setUploadFileUrl(entity.getUploadFileUrl());
model.setIsDeleted(entity.getIsDeleted());
model.setCreator(entity.getCreator());
model.setCreatedTime(entity.getCreatedTime());
model.setModifier(entity.getModifier());
model.setModifiedTime(entity.getModifiedTime());
model.setSysVersion(entity.getSysVersion());
return model;
}
public static BizAiDataAuditFileDto entityToDto(BizAiDataAuditFileEntity entity){
BizAiDataAuditFileDto dto = new BizAiDataAuditFileDto();
dto.setDataAuditFileId(entity.getDataAuditFileId());
dto.setTaskId(entity.getTaskId());
dto.setOrginalTemplateCode(entity.getOrginalTemplateCode());
dto.setOrginalTemplateName(entity.getOrginalTemplateName());
dto.setUploadFileName(entity.getUploadFileName());
dto.setUploadFileUrl(entity.getUploadFileUrl());
dto.setIsDeleted(entity.getIsDeleted());
dto.setCreator(entity.getCreator());
dto.setCreatedTime(entity.getCreatedTime());
dto.setModifier(entity.getModifier());
dto.setModifiedTime(entity.getModifiedTime());
dto.setSysVersion(entity.getSysVersion());
return dto;
}
public static BizAiDataAuditFileEntity dtoToEntity(BizAiDataAuditFileDto dto){
BizAiDataAuditFileEntity entity = new BizAiDataAuditFileEntity();
entity.setDataAuditFileId(dto.getDataAuditFileId());
entity.setTaskId(dto.getTaskId());
entity.setOrginalTemplateCode(dto.getOrginalTemplateCode());
entity.setOrginalTemplateName(dto.getOrginalTemplateName());
entity.setUploadFileName(dto.getUploadFileName());
entity.setUploadFileUrl(dto.getUploadFileUrl());
entity.setIsDeleted(dto.getIsDeleted());
entity.setCreator(dto.getCreator());
entity.setCreatedTime(dto.getCreatedTime());
entity.setModifier(dto.getModifier());
entity.setModifiedTime(dto.getModifiedTime());
entity.setSysVersion(dto.getSysVersion());
return entity;
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.convert;
import cn.com.poc.ai_data_audit.model.BizAiDataAuditTaskModel;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditTaskEntity;
import cn.com.poc.ai_data_audit.dto.BizAiDataAuditTaskDto;
public class BizAiDataAuditTaskConvert {
public static BizAiDataAuditTaskEntity modelToEntity(BizAiDataAuditTaskModel model){
BizAiDataAuditTaskEntity entity = new BizAiDataAuditTaskEntity();
entity.setDataAuditTaskId(model.getDataAuditTaskId());
entity.setDataAuditTaskName(model.getDataAuditTaskName());
entity.setMemberId(model.getMemberId());
entity.setStatus(model.getStatus());
entity.setFileNum(model.getFileNum());
entity.setAuditResult(model.getAuditResult());
entity.setIsDeleted(model.getIsDeleted());
entity.setCreator(model.getCreator());
entity.setCreatedTime(model.getCreatedTime());
entity.setModifier(model.getModifier());
entity.setModifiedTime(model.getModifiedTime());
entity.setSysVersion(model.getSysVersion());
return entity;
}
public static BizAiDataAuditTaskModel entityToModel(BizAiDataAuditTaskEntity entity){
BizAiDataAuditTaskModel model = new BizAiDataAuditTaskModel();
model.setDataAuditTaskId(entity.getDataAuditTaskId());
model.setDataAuditTaskName(entity.getDataAuditTaskName());
model.setMemberId(entity.getMemberId());
model.setStatus(entity.getStatus());
model.setFileNum(entity.getFileNum());
model.setAuditResult(entity.getAuditResult());
model.setIsDeleted(entity.getIsDeleted());
model.setCreator(entity.getCreator());
model.setCreatedTime(entity.getCreatedTime());
model.setModifier(entity.getModifier());
model.setModifiedTime(entity.getModifiedTime());
model.setSysVersion(entity.getSysVersion());
return model;
}
public static BizAiDataAuditTaskDto entityToDto(BizAiDataAuditTaskEntity entity){
BizAiDataAuditTaskDto dto = new BizAiDataAuditTaskDto();
dto.setDataAuditTaskId(entity.getDataAuditTaskId());
dto.setDataAuditTaskName(entity.getDataAuditTaskName());
dto.setMemberId(entity.getMemberId());
dto.setStatus(entity.getStatus());
dto.setFileNum(entity.getFileNum());
dto.setAuditResult(entity.getAuditResult());
dto.setIsDeleted(entity.getIsDeleted());
dto.setCreator(entity.getCreator());
dto.setCreatedTime(entity.getCreatedTime());
dto.setModifier(entity.getModifier());
dto.setModifiedTime(entity.getModifiedTime());
dto.setSysVersion(entity.getSysVersion());
return dto;
}
public static BizAiDataAuditTaskEntity dtoToEntity(BizAiDataAuditTaskDto dto){
BizAiDataAuditTaskEntity entity = new BizAiDataAuditTaskEntity();
entity.setDataAuditTaskId(dto.getDataAuditTaskId());
entity.setDataAuditTaskName(dto.getDataAuditTaskName());
entity.setMemberId(dto.getMemberId());
entity.setStatus(dto.getStatus());
entity.setFileNum(dto.getFileNum());
entity.setAuditResult(dto.getAuditResult());
entity.setIsDeleted(dto.getIsDeleted());
entity.setCreator(dto.getCreator());
entity.setCreatedTime(dto.getCreatedTime());
entity.setModifier(dto.getModifier());
entity.setModifiedTime(dto.getModifiedTime());
entity.setSysVersion(dto.getSysVersion());
return entity;
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.dto;
public class BizAiDataAuditFileDto {
private static final long serialVersionUID = 1L;
/** data_audit_file_id
*
*/
private java.lang.Integer dataAuditFileId;
public java.lang.Integer getDataAuditFileId(){
return this.dataAuditFileId;
}
public void setDataAuditFileId(java.lang.Integer dataAuditFileId){
this.dataAuditFileId = dataAuditFileId;
}
/** task_id
*任务id
*/
private java.lang.Integer taskId;
public java.lang.Integer getTaskId(){
return this.taskId;
}
public void setTaskId(java.lang.Integer taskId){
this.taskId = taskId;
}
/** orginal_template_code
*原始模板代码
*/
private java.lang.String orginalTemplateCode;
public java.lang.String getOrginalTemplateCode(){
return this.orginalTemplateCode;
}
public void setOrginalTemplateCode(java.lang.String orginalTemplateCode){
this.orginalTemplateCode = orginalTemplateCode;
}
/** orginal_template_name
*原始模板名称
*/
private java.lang.String orginalTemplateName;
public java.lang.String getOrginalTemplateName(){
return this.orginalTemplateName;
}
public void setOrginalTemplateName(java.lang.String orginalTemplateName){
this.orginalTemplateName = orginalTemplateName;
}
/** upload_file_name
*上传文件名称
*/
private java.lang.String uploadFileName;
public java.lang.String getUploadFileName(){
return this.uploadFileName;
}
public void setUploadFileName(java.lang.String uploadFileName){
this.uploadFileName = uploadFileName;
}
/** upload_file_url
*上传文件链接
*/
private java.lang.String uploadFileUrl;
public java.lang.String getUploadFileUrl(){
return this.uploadFileUrl;
}
public void setUploadFileUrl(java.lang.String uploadFileUrl){
this.uploadFileUrl = uploadFileUrl;
}
/** is_deleted
*是否删除 1、Y 是 2、N 否
*/
private java.lang.String isDeleted;
public java.lang.String getIsDeleted(){
return this.isDeleted;
}
public void setIsDeleted(java.lang.String isDeleted){
this.isDeleted = isDeleted;
}
/** CREATOR
*创建人
*/
private java.lang.String creator;
public java.lang.String getCreator(){
return this.creator;
}
public void setCreator(java.lang.String creator){
this.creator = creator;
}
/** CREATED_TIME
*创建时间
*/
private java.util.Date createdTime;
public java.util.Date getCreatedTime(){
return this.createdTime;
}
public void setCreatedTime(java.util.Date createdTime){
this.createdTime = createdTime;
}
/** MODIFIER
*修改人
*/
private java.lang.String modifier;
public java.lang.String getModifier(){
return this.modifier;
}
public void setModifier(java.lang.String modifier){
this.modifier = modifier;
}
/** MODIFIED_TIME
*修改时间
*/
private java.util.Date modifiedTime;
public java.util.Date getModifiedTime(){
return this.modifiedTime;
}
public void setModifiedTime(java.util.Date modifiedTime){
this.modifiedTime = modifiedTime;
}
/** SYS_VERSION
*乐观锁,版本号
*/
private java.lang.Integer sysVersion;
public java.lang.Integer getSysVersion(){
return this.sysVersion;
}
public void setSysVersion(java.lang.Integer sysVersion){
this.sysVersion = sysVersion;
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.dto;
public class BizAiDataAuditTaskDto {
private static final long serialVersionUID = 1L;
/** data_audit_task_id
*
*/
private java.lang.Integer dataAuditTaskId;
public java.lang.Integer getDataAuditTaskId(){
return this.dataAuditTaskId;
}
public void setDataAuditTaskId(java.lang.Integer dataAuditTaskId){
this.dataAuditTaskId = dataAuditTaskId;
}
/** data_audit_task_name
*任务名称
*/
private java.lang.String dataAuditTaskName;
public java.lang.String getDataAuditTaskName(){
return this.dataAuditTaskName;
}
public void setDataAuditTaskName(java.lang.String dataAuditTaskName){
this.dataAuditTaskName = dataAuditTaskName;
}
/** member_id
*会员id
*/
private java.lang.Integer memberId;
public java.lang.Integer getMemberId(){
return this.memberId;
}
public void setMemberId(java.lang.Integer memberId){
this.memberId = memberId;
}
/** status
*状态
*/
private java.lang.String status;
public java.lang.String getStatus(){
return this.status;
}
public void setStatus(java.lang.String status){
this.status = status;
}
/** file_num
*上传的文件数量
*/
private java.lang.Integer fileNum;
public java.lang.Integer getFileNum(){
return this.fileNum;
}
public void setFileNum(java.lang.Integer fileNum){
this.fileNum = fileNum;
}
/** audit_result
*识别结果
*/
private java.lang.String auditResult;
public java.lang.String getAuditResult(){
return this.auditResult;
}
public void setAuditResult(java.lang.String auditResult){
this.auditResult = auditResult;
}
/** is_deleted
*是否删除 1、Y 是 2、N 否
*/
private java.lang.String isDeleted;
public java.lang.String getIsDeleted(){
return this.isDeleted;
}
public void setIsDeleted(java.lang.String isDeleted){
this.isDeleted = isDeleted;
}
/** CREATOR
*创建人
*/
private java.lang.String creator;
public java.lang.String getCreator(){
return this.creator;
}
public void setCreator(java.lang.String creator){
this.creator = creator;
}
/** CREATED_TIME
*创建时间
*/
private java.util.Date createdTime;
public java.util.Date getCreatedTime(){
return this.createdTime;
}
public void setCreatedTime(java.util.Date createdTime){
this.createdTime = createdTime;
}
/** MODIFIER
*修改人
*/
private java.lang.String modifier;
public java.lang.String getModifier(){
return this.modifier;
}
public void setModifier(java.lang.String modifier){
this.modifier = modifier;
}
/** MODIFIED_TIME
*修改时间
*/
private java.util.Date modifiedTime;
public java.util.Date getModifiedTime(){
return this.modifiedTime;
}
public void setModifiedTime(java.util.Date modifiedTime){
this.modifiedTime = modifiedTime;
}
/** SYS_VERSION
*乐观锁,版本号
*/
private java.lang.Integer sysVersion;
public java.lang.Integer getSysVersion(){
return this.sysVersion;
}
public void setSysVersion(java.lang.Integer sysVersion){
this.sysVersion = sysVersion;
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.dto;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
/**
* @Author:Roger Wu
* @name:FileUploadComfirmDto
* @Date:2025-10-29 22:26
*/
public class FileUploadConfirmDto {
// private List<MultipartFile> multipartFileList;
//上传的文件
private List<FileUploadDto> fileUploadDtoList;
//匹配的文件列表
private List<FileUploadReturnDto> fileUploadReturnDtoList;
// public List<MultipartFile> getMultipartFileList() {
// return multipartFileList;
// }
//
// public void setMultipartFileList(List<MultipartFile> multipartFileList) {
// this.multipartFileList = multipartFileList;
// }
public List<FileUploadDto> getFileUploadDtoList() {
return fileUploadDtoList;
}
public void setFileUploadDtoList(List<FileUploadDto> fileUploadDtoList) {
this.fileUploadDtoList = fileUploadDtoList;
}
public List<FileUploadReturnDto> getFileUploadReturnDtoList() {
return fileUploadReturnDtoList;
}
public void setFileUploadReturnDtoList(List<FileUploadReturnDto> fileUploadReturnDtoList) {
fileUploadReturnDtoList = fileUploadReturnDtoList;
}
}
package cn.com.poc.ai_data_audit.dto;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
/**
* @Author:Roger Wu
* @name:FileUploadDto
* @Date:2025-10-29 21:26
*/
public class FileUploadDto {
// private List<MultipartFile> multipartFileList;
//
// public List<MultipartFile> getMultipartFileList() {
// return multipartFileList;
// }
//
// public void setMultipartFileList(List<MultipartFile> multipartFileList) {
// this.multipartFileList = multipartFileList;
// }
private String fileName;
private String fileUrl;
public String getFileName() {
return fileName;
}
public void setFileName(String fileName) {
this.fileName = fileName;
}
public String getFileUrl() {
return fileUrl;
}
public void setFileUrl(String fileUrl) {
this.fileUrl = fileUrl;
}
}
package cn.com.poc.ai_data_audit.dto;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
/**
* @Author:Roger Wu
* @name:FileUploadDto
* @Date:2025-10-29 21:26
*/
public class FileUploadReturnDto {
String orginalTemplateName;
String orginalTemplateCode;
String uploadFileName;
// String uploadFileUrl;
public String getOrginalTemplateName() {
return orginalTemplateName;
}
public void setOrginalTemplateName(String orginalTemplateName) {
this.orginalTemplateName = orginalTemplateName;
}
public String getOrginalTemplateCode() {
return orginalTemplateCode;
}
public void setOrginalTemplateCode(String orginalTemplateCode) {
this.orginalTemplateCode = orginalTemplateCode;
}
public String getUploadFileName() {
return uploadFileName;
}
public void setUploadFileName(String uploadFileName) {
this.uploadFileName = uploadFileName;
}
// public String getUploadFileUrl() {
// return uploadFileUrl;
// }
//
// public void setUploadFileUrl(String uploadFileUrl) {
// this.uploadFileUrl = uploadFileUrl;
// }
}
package cn.com.poc.ai_data_audit.entity;
public class BizAiDataAuditFileEntity {
private static final long serialVersionUID = 1L;
/** data_audit_file_id
*
*/
private java.lang.Integer dataAuditFileId;
public java.lang.Integer getDataAuditFileId(){
return this.dataAuditFileId;
}
public void setDataAuditFileId(java.lang.Integer dataAuditFileId){
this.dataAuditFileId = dataAuditFileId;
}
/** task_id
*任务id
*/
private java.lang.Integer taskId;
public java.lang.Integer getTaskId(){
return this.taskId;
}
public void setTaskId(java.lang.Integer taskId){
this.taskId = taskId;
}
/** orginal_template_code
*原始模板代码
*/
private java.lang.String orginalTemplateCode;
public java.lang.String getOrginalTemplateCode(){
return this.orginalTemplateCode;
}
public void setOrginalTemplateCode(java.lang.String orginalTemplateCode){
this.orginalTemplateCode = orginalTemplateCode;
}
/** orginal_template_name
*原始模板名称
*/
private java.lang.String orginalTemplateName;
public java.lang.String getOrginalTemplateName(){
return this.orginalTemplateName;
}
public void setOrginalTemplateName(java.lang.String orginalTemplateName){
this.orginalTemplateName = orginalTemplateName;
}
/** upload_file_name
*上传文件名称
*/
private java.lang.String uploadFileName;
public java.lang.String getUploadFileName(){
return this.uploadFileName;
}
public void setUploadFileName(java.lang.String uploadFileName){
this.uploadFileName = uploadFileName;
}
/** upload_file_url
*上传文件链接
*/
private java.lang.String uploadFileUrl;
public java.lang.String getUploadFileUrl(){
return this.uploadFileUrl;
}
public void setUploadFileUrl(java.lang.String uploadFileUrl){
this.uploadFileUrl = uploadFileUrl;
}
/** is_deleted
*是否删除 1、Y 是 2、N 否
*/
private java.lang.String isDeleted;
public java.lang.String getIsDeleted(){
return this.isDeleted;
}
public void setIsDeleted(java.lang.String isDeleted){
this.isDeleted = isDeleted;
}
/** CREATOR
*创建人
*/
private java.lang.String creator;
public java.lang.String getCreator(){
return this.creator;
}
public void setCreator(java.lang.String creator){
this.creator = creator;
}
/** CREATED_TIME
*创建时间
*/
private java.util.Date createdTime;
public java.util.Date getCreatedTime(){
return this.createdTime;
}
public void setCreatedTime(java.util.Date createdTime){
this.createdTime = createdTime;
}
/** MODIFIER
*修改人
*/
private java.lang.String modifier;
public java.lang.String getModifier(){
return this.modifier;
}
public void setModifier(java.lang.String modifier){
this.modifier = modifier;
}
/** MODIFIED_TIME
*修改时间
*/
private java.util.Date modifiedTime;
public java.util.Date getModifiedTime(){
return this.modifiedTime;
}
public void setModifiedTime(java.util.Date modifiedTime){
this.modifiedTime = modifiedTime;
}
/** SYS_VERSION
*乐观锁,版本号
*/
private java.lang.Integer sysVersion;
public java.lang.Integer getSysVersion(){
return this.sysVersion;
}
public void setSysVersion(java.lang.Integer sysVersion){
this.sysVersion = sysVersion;
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.entity;
public class BizAiDataAuditTaskEntity {
private static final long serialVersionUID = 1L;
/** data_audit_task_id
*
*/
private java.lang.Integer dataAuditTaskId;
public java.lang.Integer getDataAuditTaskId(){
return this.dataAuditTaskId;
}
public void setDataAuditTaskId(java.lang.Integer dataAuditTaskId){
this.dataAuditTaskId = dataAuditTaskId;
}
/** data_audit_task_name
*任务名称
*/
private java.lang.String dataAuditTaskName;
public java.lang.String getDataAuditTaskName(){
return this.dataAuditTaskName;
}
public void setDataAuditTaskName(java.lang.String dataAuditTaskName){
this.dataAuditTaskName = dataAuditTaskName;
}
/** member_id
*会员id
*/
private java.lang.Integer memberId;
public java.lang.Integer getMemberId(){
return this.memberId;
}
public void setMemberId(java.lang.Integer memberId){
this.memberId = memberId;
}
/** status
*状态
*/
private java.lang.String status;
public java.lang.String getStatus(){
return this.status;
}
public void setStatus(java.lang.String status){
this.status = status;
}
/** file_num
*上传的文件数量
*/
private java.lang.Integer fileNum;
public java.lang.Integer getFileNum(){
return this.fileNum;
}
public void setFileNum(java.lang.Integer fileNum){
this.fileNum = fileNum;
}
/** audit_result
*识别结果
*/
private java.lang.String auditResult;
public java.lang.String getAuditResult(){
return this.auditResult;
}
public void setAuditResult(java.lang.String auditResult){
this.auditResult = auditResult;
}
/** is_deleted
*是否删除 1、Y 是 2、N 否
*/
private java.lang.String isDeleted;
public java.lang.String getIsDeleted(){
return this.isDeleted;
}
public void setIsDeleted(java.lang.String isDeleted){
this.isDeleted = isDeleted;
}
/** CREATOR
*创建人
*/
private java.lang.String creator;
public java.lang.String getCreator(){
return this.creator;
}
public void setCreator(java.lang.String creator){
this.creator = creator;
}
/** CREATED_TIME
*创建时间
*/
private java.util.Date createdTime;
public java.util.Date getCreatedTime(){
return this.createdTime;
}
public void setCreatedTime(java.util.Date createdTime){
this.createdTime = createdTime;
}
/** MODIFIER
*修改人
*/
private java.lang.String modifier;
public java.lang.String getModifier(){
return this.modifier;
}
public void setModifier(java.lang.String modifier){
this.modifier = modifier;
}
/** MODIFIED_TIME
*修改时间
*/
private java.util.Date modifiedTime;
public java.util.Date getModifiedTime(){
return this.modifiedTime;
}
public void setModifiedTime(java.util.Date modifiedTime){
this.modifiedTime = modifiedTime;
}
/** SYS_VERSION
*乐观锁,版本号
*/
private java.lang.Integer sysVersion;
public java.lang.Integer getSysVersion(){
return this.sysVersion;
}
public void setSysVersion(java.lang.Integer sysVersion){
this.sysVersion = sysVersion;
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.model;
import java.io.Serializable;
import cn.com.yict.framemax.data.model.BaseModelClass;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Id;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Version;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
/**
* Model class for biz_ai_data_audit_file
*
*/
@Entity
@Table(name = "biz_ai_data_audit_file")
@DynamicInsert
@DynamicUpdate
public class BizAiDataAuditFileModel extends BaseModelClass implements Serializable {
private static final long serialVersionUID = 1L;
/** data_audit_file_id
*
*/
private java.lang.Integer dataAuditFileId;
@Column(name = "data_audit_file_id",length = 10)
@Id @GeneratedValue(strategy = GenerationType.AUTO)
public java.lang.Integer getDataAuditFileId(){
return this.dataAuditFileId;
}
public void setDataAuditFileId(java.lang.Integer dataAuditFileId){
this.dataAuditFileId = dataAuditFileId;
super.addValidField("dataAuditFileId");
}
/** task_id
*任务id
*/
private java.lang.Integer taskId;
@Column(name = "task_id",length = 10)
public java.lang.Integer getTaskId(){
return this.taskId;
}
public void setTaskId(java.lang.Integer taskId){
this.taskId = taskId;
super.addValidField("taskId");
}
/** orginal_template_code
*原始模板代码
*/
private java.lang.String orginalTemplateCode;
@Column(name = "orginal_template_code",length = 255)
public java.lang.String getOrginalTemplateCode(){
return this.orginalTemplateCode;
}
public void setOrginalTemplateCode(java.lang.String orginalTemplateCode){
this.orginalTemplateCode = orginalTemplateCode;
super.addValidField("orginalTemplateCode");
}
/** orginal_template_name
*原始模板名称
*/
private java.lang.String orginalTemplateName;
@Column(name = "orginal_template_name",length = 255)
public java.lang.String getOrginalTemplateName(){
return this.orginalTemplateName;
}
public void setOrginalTemplateName(java.lang.String orginalTemplateName){
this.orginalTemplateName = orginalTemplateName;
super.addValidField("orginalTemplateName");
}
/** upload_file_name
*上传文件名称
*/
private java.lang.String uploadFileName;
@Column(name = "upload_file_name",length = 255)
public java.lang.String getUploadFileName(){
return this.uploadFileName;
}
public void setUploadFileName(java.lang.String uploadFileName){
this.uploadFileName = uploadFileName;
super.addValidField("uploadFileName");
}
/** upload_file_url
*上传文件链接
*/
private java.lang.String uploadFileUrl;
@Column(name = "upload_file_url",length = 500)
public java.lang.String getUploadFileUrl(){
return this.uploadFileUrl;
}
public void setUploadFileUrl(java.lang.String uploadFileUrl){
this.uploadFileUrl = uploadFileUrl;
super.addValidField("uploadFileUrl");
}
/** is_deleted
*是否删除 1、Y 是 2、N 否
*/
private java.lang.String isDeleted;
@Column(name = "is_deleted",length = 1)
public java.lang.String getIsDeleted(){
return this.isDeleted;
}
public void setIsDeleted(java.lang.String isDeleted){
this.isDeleted = isDeleted;
super.addValidField("isDeleted");
}
/** CREATOR
*创建人
*/
private java.lang.String creator;
@Column(name = "CREATOR",length = 225)
public java.lang.String getCreator(){
return this.creator;
}
public void setCreator(java.lang.String creator){
this.creator = creator;
super.addValidField("creator");
}
/** CREATED_TIME
*创建时间
*/
private java.util.Date createdTime;
@Column(name = "CREATED_TIME",length = 19)
public java.util.Date getCreatedTime(){
return this.createdTime;
}
public void setCreatedTime(java.util.Date createdTime){
this.createdTime = createdTime;
super.addValidField("createdTime");
}
/** MODIFIER
*修改人
*/
private java.lang.String modifier;
@Column(name = "MODIFIER",length = 225)
public java.lang.String getModifier(){
return this.modifier;
}
public void setModifier(java.lang.String modifier){
this.modifier = modifier;
super.addValidField("modifier");
}
/** MODIFIED_TIME
*修改时间
*/
private java.util.Date modifiedTime;
@Column(name = "MODIFIED_TIME",length = 19)
public java.util.Date getModifiedTime(){
return this.modifiedTime;
}
public void setModifiedTime(java.util.Date modifiedTime){
this.modifiedTime = modifiedTime;
super.addValidField("modifiedTime");
}
/** SYS_VERSION
*乐观锁,版本号
*/
private java.lang.Integer sysVersion;
@Column(name = "SYS_VERSION",length = 10)
@Version
public java.lang.Integer getSysVersion(){
return this.sysVersion;
}
public void setSysVersion(java.lang.Integer sysVersion){
this.sysVersion = sysVersion;
super.addValidField("sysVersion");
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.model;
import java.io.Serializable;
import cn.com.yict.framemax.data.model.BaseModelClass;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Id;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.Version;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
/**
* Model class for biz_ai_data_audit_task
*
*/
@Entity
@Table(name = "biz_ai_data_audit_task")
@DynamicInsert
@DynamicUpdate
public class BizAiDataAuditTaskModel extends BaseModelClass implements Serializable {
private static final long serialVersionUID = 1L;
/** data_audit_task_id
*
*/
private java.lang.Integer dataAuditTaskId;
@Column(name = "data_audit_task_id",length = 10)
@Id @GeneratedValue(strategy = GenerationType.AUTO)
public java.lang.Integer getDataAuditTaskId(){
return this.dataAuditTaskId;
}
public void setDataAuditTaskId(java.lang.Integer dataAuditTaskId){
this.dataAuditTaskId = dataAuditTaskId;
super.addValidField("dataAuditTaskId");
}
/** data_audit_task_name
*任务名称
*/
private java.lang.String dataAuditTaskName;
@Column(name = "data_audit_task_name",length = 255)
public java.lang.String getDataAuditTaskName(){
return this.dataAuditTaskName;
}
public void setDataAuditTaskName(java.lang.String dataAuditTaskName){
this.dataAuditTaskName = dataAuditTaskName;
super.addValidField("dataAuditTaskName");
}
/** member_id
*会员id
*/
private java.lang.Integer memberId;
@Column(name = "member_id",length = 10)
public java.lang.Integer getMemberId(){
return this.memberId;
}
public void setMemberId(java.lang.Integer memberId){
this.memberId = memberId;
super.addValidField("memberId");
}
/** status
*状态
*/
private java.lang.String status;
@Column(name = "status",length = 255)
public java.lang.String getStatus(){
return this.status;
}
public void setStatus(java.lang.String status){
this.status = status;
super.addValidField("status");
}
/** file_num
*上传的文件数量
*/
private java.lang.Integer fileNum;
@Column(name = "file_num",length = 10)
public java.lang.Integer getFileNum(){
return this.fileNum;
}
public void setFileNum(java.lang.Integer fileNum){
this.fileNum = fileNum;
super.addValidField("fileNum");
}
/** audit_result
*识别结果
*/
private java.lang.String auditResult;
@Column(name = "audit_result",length = 1073741824)
public java.lang.String getAuditResult(){
return this.auditResult;
}
public void setAuditResult(java.lang.String auditResult){
this.auditResult = auditResult;
super.addValidField("auditResult");
}
/** is_deleted
*是否删除 1、Y 是 2、N 否
*/
private java.lang.String isDeleted;
@Column(name = "is_deleted",length = 1)
public java.lang.String getIsDeleted(){
return this.isDeleted;
}
public void setIsDeleted(java.lang.String isDeleted){
this.isDeleted = isDeleted;
super.addValidField("isDeleted");
}
/** CREATOR
*创建人
*/
private java.lang.String creator;
@Column(name = "CREATOR",length = 225)
public java.lang.String getCreator(){
return this.creator;
}
public void setCreator(java.lang.String creator){
this.creator = creator;
super.addValidField("creator");
}
/** CREATED_TIME
*创建时间
*/
private java.util.Date createdTime;
@Column(name = "CREATED_TIME",length = 19)
public java.util.Date getCreatedTime(){
return this.createdTime;
}
public void setCreatedTime(java.util.Date createdTime){
this.createdTime = createdTime;
super.addValidField("createdTime");
}
/** MODIFIER
*修改人
*/
private java.lang.String modifier;
@Column(name = "MODIFIER",length = 225)
public java.lang.String getModifier(){
return this.modifier;
}
public void setModifier(java.lang.String modifier){
this.modifier = modifier;
super.addValidField("modifier");
}
/** MODIFIED_TIME
*修改时间
*/
private java.util.Date modifiedTime;
@Column(name = "MODIFIED_TIME",length = 19)
public java.util.Date getModifiedTime(){
return this.modifiedTime;
}
public void setModifiedTime(java.util.Date modifiedTime){
this.modifiedTime = modifiedTime;
super.addValidField("modifiedTime");
}
/** SYS_VERSION
*乐观锁,版本号
*/
private java.lang.Integer sysVersion;
@Column(name = "SYS_VERSION",length = 10)
@Version
public java.lang.Integer getSysVersion(){
return this.sysVersion;
}
public void setSysVersion(java.lang.Integer sysVersion){
this.sysVersion = sysVersion;
super.addValidField("sysVersion");
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.repository;
import cn.com.yict.framemax.data.repository.Repository;
import cn.com.poc.ai_data_audit.model.BizAiDataAuditFileModel;
public interface BizAiDataAuditFileRepository extends Repository<BizAiDataAuditFileModel,java.lang.Integer> {
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.repository;
import cn.com.yict.framemax.data.repository.Repository;
import cn.com.poc.ai_data_audit.model.BizAiDataAuditTaskModel;
public interface BizAiDataAuditTaskRepository extends Repository<BizAiDataAuditTaskModel,java.lang.Integer> {
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.rest;
import cn.com.yict.framemax.core.rest.BaseRest;
import cn.com.poc.ai_data_audit.dto.BizAiDataAuditFileDto;
import cn.com.yict.framemax.data.model.PagingInfo;
import java.util.Collection;
import java.util.List;
import cn.com.yict.framemax.web.permission.Access;
import cn.com.yict.framemax.web.permission.Permission;
import org.springframework.web.bind.annotation.RequestBody;
@Permission(Access.Safety)
public interface BizAiDataAuditFileRest extends BaseRest {
List<BizAiDataAuditFileDto> getFileList(@RequestBody BizAiDataAuditFileDto example) throws Exception;
BizAiDataAuditFileDto getById(@RequestBody java.lang.Integer id) throws Exception;
List<BizAiDataAuditFileDto> getList(@RequestBody BizAiDataAuditFileDto example, PagingInfo pagingInfo) throws Exception;
BizAiDataAuditFileDto save(@RequestBody BizAiDataAuditFileDto dto) throws Exception;
BizAiDataAuditFileDto update(@RequestBody BizAiDataAuditFileDto dto) throws Exception;
void deletedById(@RequestBody java.lang.Integer id) throws Exception;
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.rest;
import cn.com.yict.framemax.core.rest.BaseRest;
import cn.com.poc.ai_data_audit.dto.BizAiDataAuditTaskDto;
import cn.com.yict.framemax.data.model.PagingInfo;
import java.util.Collection;
import java.util.List;
import cn.com.yict.framemax.web.permission.Access;
import cn.com.yict.framemax.web.permission.Permission;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
@Permission(Access.Safety)
public interface BizAiDataAuditTaskRest extends BaseRest {
List<BizAiDataAuditTaskDto> getTaskList() throws Exception;
BizAiDataAuditTaskDto getByTaskId(@RequestParam Integer taskId) throws Exception;
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.rest;
import cn.com.poc.ai_data_audit.dto.FileUploadConfirmDto;
import cn.com.poc.ai_data_audit.dto.FileUploadDto;
import cn.com.poc.ai_data_audit.dto.FileUploadReturnDto;
import cn.com.yict.framemax.core.rest.BaseRest;
import cn.com.yict.framemax.web.permission.Access;
import cn.com.yict.framemax.web.permission.Permission;
import org.springframework.web.bind.annotation.RequestBody;
import java.util.List;
/**
* @Author:Roger Wu
* @name:DataAuditRest
* @Date:2025-10-29 21:23
*/
@Permission(Access.Safety)
public interface DataAuditRest extends BaseRest {
public List<FileUploadReturnDto> fileUpload(@RequestBody List<FileUploadDto> fileUploadDtoList) throws Exception;
void createDataAuditTask(@RequestBody FileUploadConfirmDto fileUploadConfirmDto) throws Exception;
}
package cn.com.poc.ai_data_audit.rest.impl;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cn.com.poc.ai_data_audit.rest.BizAiDataAuditFileRest;
import cn.com.poc.ai_data_audit.service.BizAiDataAuditFileService;
import cn.com.poc.ai_data_audit.dto.BizAiDataAuditFileDto;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditFileEntity;
import cn.com.yict.framemax.data.model.PagingInfo;
import cn.com.poc.ai_data_audit.convert.BizAiDataAuditFileConvert;
import java.util.stream.Collectors;
import org.springframework.util.Assert;
@Component
public class BizAiDataAuditFileRestImpl implements BizAiDataAuditFileRest {
@Resource
private BizAiDataAuditFileService service;
@Override
public List<BizAiDataAuditFileDto> getFileList(BizAiDataAuditFileDto dto) throws Exception {
return service
.findByExample(BizAiDataAuditFileConvert.dtoToEntity(dto),null)
.stream()
.map(BizAiDataAuditFileConvert::entityToDto)
.collect(Collectors.toList());
}
public BizAiDataAuditFileDto getById(java.lang.Integer id) throws Exception{
Assert.notNull(id);
return BizAiDataAuditFileConvert.entityToDto(service.get(id));
}
public List<BizAiDataAuditFileDto> getList(BizAiDataAuditFileDto dto,PagingInfo pagingInfo) throws Exception{
return service
.findByExample(BizAiDataAuditFileConvert.dtoToEntity(dto),pagingInfo)
.stream()
.map(BizAiDataAuditFileConvert::entityToDto)
.collect(Collectors.toList());
}
public BizAiDataAuditFileDto save(BizAiDataAuditFileDto dto) throws Exception{
Assert.notNull(dto);
BizAiDataAuditFileEntity entity = BizAiDataAuditFileConvert.dtoToEntity(dto);
return BizAiDataAuditFileConvert.entityToDto(service.save(entity));
}
public BizAiDataAuditFileDto update(BizAiDataAuditFileDto dto) throws Exception{
Assert.notNull(dto);
BizAiDataAuditFileEntity entity = BizAiDataAuditFileConvert.dtoToEntity(dto);
return BizAiDataAuditFileConvert.entityToDto(service.update(entity));
}
public void deletedById(java.lang.Integer id) throws Exception{
Assert.notNull(id);
service.deletedById(id);
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.rest.impl;
import java.util.List;
import javax.annotation.Resource;
import cn.com.poc.common.utils.BlContext;
import org.springframework.stereotype.Component;
import cn.com.poc.ai_data_audit.rest.BizAiDataAuditTaskRest;
import cn.com.poc.ai_data_audit.service.BizAiDataAuditTaskService;
import cn.com.poc.ai_data_audit.dto.BizAiDataAuditTaskDto;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditTaskEntity;
import cn.com.poc.ai_data_audit.convert.BizAiDataAuditTaskConvert;
import java.util.stream.Collectors;
import org.springframework.util.Assert;
@Component
public class BizAiDataAuditTaskRestImpl implements BizAiDataAuditTaskRest {
@Resource
private BizAiDataAuditTaskService bizAiDataAuditTaskService;
@Override
public List<BizAiDataAuditTaskDto> getTaskList() throws Exception {
BizAiDataAuditTaskEntity bizAiDataAuditTaskEntity = new BizAiDataAuditTaskEntity();
Integer memberId = BlContext.getCurrentUser().getUserId().intValue();
if (memberId == null) {
return null;
}
bizAiDataAuditTaskEntity.setMemberId(memberId);
List<BizAiDataAuditTaskEntity> bizAiDataAuditTaskEntityList = bizAiDataAuditTaskService.findByExample(bizAiDataAuditTaskEntity, null);
for (BizAiDataAuditTaskEntity aiDataAuditTaskEntity : bizAiDataAuditTaskEntityList) {
aiDataAuditTaskEntity.setAuditResult(null);
}
return bizAiDataAuditTaskEntityList.stream().map(BizAiDataAuditTaskConvert::entityToDto).collect(Collectors.toList());
}
@Override
public BizAiDataAuditTaskDto getByTaskId(Integer taskId) throws Exception {
Assert.notNull(taskId, "taskId can not be null");
BizAiDataAuditTaskEntity bizAiDataAuditTaskEntity = bizAiDataAuditTaskService.get(taskId);
if (bizAiDataAuditTaskEntity == null) {
throw new Exception("the task can not be found");
}
return BizAiDataAuditTaskConvert.entityToDto(bizAiDataAuditTaskEntity);
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.rest.impl;
import cn.com.poc.ai_data_audit.rest.DataAuditRest;
import cn.com.poc.ai_data_audit.dto.BizAiDataAuditFileDto;
import cn.com.poc.ai_data_audit.dto.FileUploadConfirmDto;
import cn.com.poc.ai_data_audit.dto.FileUploadDto;
import cn.com.poc.ai_data_audit.dto.FileUploadReturnDto;
import cn.com.poc.ai_data_audit.service.BizAiDataAuditTaskService;
import cn.com.poc.common.service.BosConfigService;
import cn.com.poc.common.utils.StringUtils;
import cn.com.poc.thirdparty.resource.demand.ai.aggregate.MinerUOcrService;
import cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU.MinerUOcrResponse;
import cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU.MinerUOcrResult;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @Author:Roger Wu
* @name:FileUploadDtoImpl
* @Date:2025-10-29 21:29
*/
@Component
public class DataAuditRestImpl implements DataAuditRest {
@Resource
private BizAiDataAuditTaskService bizAiDataAuditTaskService;
@Resource
private MinerUOcrService minerUOcrService;
@Override
public List<FileUploadReturnDto> fileUpload(List<FileUploadDto> fileUploadDtoList) throws Exception {
if (CollectionUtils.isEmpty(fileUploadDtoList)) {
throw new Exception("please upload files");
}
// 获取单个文件的文件名
List<String> fileNames = fileUploadDtoList.stream()
.map(item -> item.getFileName())
.collect(Collectors.toList());
Map<String, String> fileNameMap = new HashMap<>();
// fileNameMap.put("DOC-01","Work Permit Application Details");
// fileNameMap.put("DOC-02","Work Permit Extension Details");
fileNameMap.put("DOC-03", "Work Method Statement");
fileNameMap.put("DOC-04", "Safety Method Statement or Safety Plan");
fileNameMap.put("DOC-05", "Risk Assessment");
fileNameMap.put("DOC-06", "Work Programme");
fileNameMap.put("DOC-07", "Location Plan");
fileNameMap.put("DOC-08", "HKIA Contractor Safety (Construction & Maintenance) Training Record");
fileNameMap.put("DOC-09", "HKIA BRAAS Check Form or BRAAS Exemption Declaration Form");
fileNameMap.put("DOC-10", "Premises Endorser Declaration Form for Work Permit Application");
fileNameMap.put("DOC-11", "OCWIP");
fileNameMap.put("DOC-12", "Insurance");
fileNameMap.put("DOC-13", "Pay-in-Slip for Work Permit Processing Fee");
fileNameMap.put("DOC-14", "HKIA APM Safety Video Training and Examination Record");
fileNameMap.put("DOC-15", "Aerodrome Safety Risk Assessment");
fileNameMap.put("DOC-16", "System Change Request (SCR)");
fileNameMap.put("DOC-17", "CCTV Equipment Configuration Request Form");
fileNameMap.put("DOC-18", "Permit to Dig");
fileNameMap.put("DOC-19", "Temporary Traffic Management Plan");
//执行文件名匹配
//执行类型匹配
MinerUOcrResponse minerUOcrResponse = new MinerUOcrResponse();
// minerUOcrResponse.setFile();
// minerUOcrResponse.setOutput_dir();
// minerUOcrResponse.setLang_list();
// minerUOcrResponse.setBackend();
// minerUOcrResponse.setParse_method();
// minerUOcrResponse.setFormula_enable();
// minerUOcrResponse.setTable_enable();
// minerUOcrResponse.setServer_url();
// minerUOcrResponse.setReturn_md();
// minerUOcrResponse.setReturn_middle_json();
// minerUOcrResponse.setReturn_model_output();
// minerUOcrResponse.setReturn_content_list();
// minerUOcrResponse.setReturn_images();
// minerUOcrResponse.setResponse_format_zip();
// minerUOcrResponse.setStart_page_id();
// minerUOcrResponse.setEnd_page_id();
MinerUOcrResult minerUOcrResult = minerUOcrService.fileParse(minerUOcrResponse);
return new ArrayList<FileUploadReturnDto>();
}
@Override
public void createDataAuditTask(FileUploadConfirmDto fileUploadConfirmDto) throws Exception {
String taskName = "Data Audit Task";
bizAiDataAuditTaskService.createDataAuditTask(taskName, fileUploadConfirmDto);
}
}
package cn.com.poc.ai_data_audit.service;
import cn.com.yict.framemax.core.service.BaseService;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditFileEntity;
import cn.com.yict.framemax.data.model.PagingInfo;
import java.util.Collection;
import java.util.List;
public interface BizAiDataAuditFileService extends BaseService {
BizAiDataAuditFileEntity get(java.lang.Integer id) throws Exception;
List<BizAiDataAuditFileEntity> findByExample(BizAiDataAuditFileEntity example,PagingInfo pagingInfo) throws Exception;
BizAiDataAuditFileEntity save(BizAiDataAuditFileEntity entity) throws Exception;
BizAiDataAuditFileEntity update(BizAiDataAuditFileEntity entity) throws Exception;
void deletedById(java.lang.Integer id) throws Exception;
void batchSavedFile(List<BizAiDataAuditFileEntity> bizAiDataAuditFileEntityList) throws Exception;
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.service;
import cn.com.poc.ai_data_audit.dto.FileUploadConfirmDto;
import cn.com.yict.framemax.core.service.BaseService;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditTaskEntity;
import cn.com.yict.framemax.data.model.PagingInfo;
import java.util.Collection;
import java.util.List;
public interface BizAiDataAuditTaskService extends BaseService {
BizAiDataAuditTaskEntity get(Integer id) throws Exception;
List<BizAiDataAuditTaskEntity> findByExample(BizAiDataAuditTaskEntity example, PagingInfo pagingInfo) throws Exception;
void createDataAuditTask(String taskName, FileUploadConfirmDto fileUploadConfirmDto) throws Exception;
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.service.impl;
import cn.com.yict.framemax.core.service.impl.BaseServiceImpl;
import cn.com.poc.ai_data_audit.service.BizAiDataAuditFileService;
import cn.com.poc.ai_data_audit.model.BizAiDataAuditFileModel;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditFileEntity;
import cn.com.poc.ai_data_audit.convert.BizAiDataAuditFileConvert;
import cn.com.poc.ai_data_audit.repository.BizAiDataAuditFileRepository;
import cn.com.yict.framemax.data.model.PagingInfo;
import org.springframework.stereotype.Service;
import org.apache.commons.collections4.CollectionUtils;
import java.util.ArrayList;
import java.util.stream.Collectors;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.util.Assert;
@Service
public class BizAiDataAuditFileServiceImpl extends BaseServiceImpl
implements BizAiDataAuditFileService {
@Resource
private BizAiDataAuditFileRepository repository;
public BizAiDataAuditFileEntity get(java.lang.Integer id) throws Exception{
Assert.notNull(id);
BizAiDataAuditFileModel model = this.repository.get(id);
if (model == null){
return null;
}
if ("Y".equals(model.getIsDeleted())){
return null;
}
return BizAiDataAuditFileConvert.modelToEntity(model);
}
public List<BizAiDataAuditFileEntity> findByExample(BizAiDataAuditFileEntity example,PagingInfo pagingInfo) throws Exception{
List<BizAiDataAuditFileEntity> result = new ArrayList<BizAiDataAuditFileEntity>();
BizAiDataAuditFileModel model = new BizAiDataAuditFileModel();
if (example != null){
model = BizAiDataAuditFileConvert.entityToModel(example);
}
model.setIsDeleted("N");
List<BizAiDataAuditFileModel> models = this.repository.findByExample(model,pagingInfo);
if (CollectionUtils.isNotEmpty(models)) {
result = models.stream().map(BizAiDataAuditFileConvert::modelToEntity).collect(Collectors.toList());
}
return result;
}
public BizAiDataAuditFileEntity save(BizAiDataAuditFileEntity entity) throws Exception{
Assert.notNull(entity);
entity.setDataAuditFileId(null);
entity.setIsDeleted("N");
BizAiDataAuditFileModel model = BizAiDataAuditFileConvert.entityToModel(entity);
BizAiDataAuditFileModel saveModel = this.repository.save(model);
return BizAiDataAuditFileConvert.modelToEntity(saveModel);
}
public BizAiDataAuditFileEntity update(BizAiDataAuditFileEntity entity) throws Exception{
Assert.notNull(entity);
Assert.notNull(entity.getDataAuditFileId(),"update pk can not be null");
BizAiDataAuditFileModel model = this.repository.get(entity.getDataAuditFileId());
if (entity.getTaskId() != null){
model.setTaskId(entity.getTaskId());
}
if (entity.getOrginalTemplateCode() != null){
model.setOrginalTemplateCode(entity.getOrginalTemplateCode());
}
if (entity.getOrginalTemplateName() != null){
model.setOrginalTemplateName(entity.getOrginalTemplateName());
}
if (entity.getUploadFileName() != null){
model.setUploadFileName(entity.getUploadFileName());
}
if (entity.getUploadFileUrl() != null){
model.setUploadFileUrl(entity.getUploadFileUrl());
}
if (entity.getIsDeleted() != null){
model.setIsDeleted(entity.getIsDeleted());
}
if (entity.getCreator() != null){
model.setCreator(entity.getCreator());
}
if (entity.getCreatedTime() != null){
model.setCreatedTime(entity.getCreatedTime());
}
if (entity.getModifier() != null){
model.setModifier(entity.getModifier());
}
if (entity.getModifiedTime() != null){
model.setModifiedTime(entity.getModifiedTime());
}
if (entity.getSysVersion() != null){
model.setSysVersion(entity.getSysVersion());
}
BizAiDataAuditFileModel saveModel = this.repository.save(model);
return BizAiDataAuditFileConvert.modelToEntity(saveModel);
}
public void deletedById(java.lang.Integer id) throws Exception{
Assert.notNull(id);
BizAiDataAuditFileModel model = this.repository.get(id);
if (model != null){
if ("N".equals(model.getIsDeleted())){
model.setIsDeleted("Y");
this.repository.save(model);
}
}
}
@Override
public void batchSavedFile(List<BizAiDataAuditFileEntity> bizAiDataAuditFileEntityList) throws Exception {
if (CollectionUtils.isEmpty(bizAiDataAuditFileEntityList)) {
throw new Exception("please upload files");
}
bizAiDataAuditFileEntityList.stream().map(item-> {
try {
return save(item);
} catch (Exception e) {
throw new RuntimeException(e);
}
});
}
}
\ No newline at end of file
package cn.com.poc.ai_data_audit.service.impl;
import cn.com.poc.ai_data_audit.constants.DataAuditConstants;
import cn.com.poc.ai_data_audit.dto.FileUploadConfirmDto;
import cn.com.poc.ai_data_audit.dto.FileUploadDto;
import cn.com.poc.ai_data_audit.dto.FileUploadReturnDto;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditFileEntity;
import cn.com.poc.ai_data_audit.service.BizAiDataAuditFileService;
import cn.com.poc.common.service.BosConfigService;
import cn.com.poc.common.utils.BlContext;
import cn.com.yict.framemax.core.service.impl.BaseServiceImpl;
import cn.com.poc.ai_data_audit.service.BizAiDataAuditTaskService;
import cn.com.poc.ai_data_audit.model.BizAiDataAuditTaskModel;
import cn.com.poc.ai_data_audit.entity.BizAiDataAuditTaskEntity;
import cn.com.poc.ai_data_audit.convert.BizAiDataAuditTaskConvert;
import cn.com.poc.ai_data_audit.repository.BizAiDataAuditTaskRepository;
import cn.com.yict.framemax.data.model.PagingInfo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.apache.commons.collections4.CollectionUtils;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.util.Assert;
@Service
public class BizAiDataAuditTaskServiceImpl extends BaseServiceImpl
implements BizAiDataAuditTaskService {
@Resource
private BizAiDataAuditTaskRepository repository;
@Resource
private BosConfigService bosConfigService;
@Resource
private BizAiDataAuditFileService bizAiDataAuditFileService;
@Override
public BizAiDataAuditTaskEntity get(java.lang.Integer id) throws Exception {
Assert.notNull(id);
BizAiDataAuditTaskModel model = this.repository.get(id);
if (model == null) {
return null;
}
if ("Y".equals(model.getIsDeleted())) {
return null;
}
if (BlContext.getCurrentUser().getUserId().intValue() != model.getMemberId()) {
return null;
}
return BizAiDataAuditTaskConvert.modelToEntity(model);
}
@Override
public List<BizAiDataAuditTaskEntity> findByExample(BizAiDataAuditTaskEntity example, PagingInfo pagingInfo) throws Exception {
List<BizAiDataAuditTaskEntity> result = new ArrayList<BizAiDataAuditTaskEntity>();
BizAiDataAuditTaskModel model = new BizAiDataAuditTaskModel();
if (example != null) {
model = BizAiDataAuditTaskConvert.entityToModel(example);
}
model.setIsDeleted("N");
List<BizAiDataAuditTaskModel> models = this.repository.findByExample(model, pagingInfo);
if (CollectionUtils.isNotEmpty(models)) {
result = models.stream().map(BizAiDataAuditTaskConvert::modelToEntity).collect(Collectors.toList());
}
return result;
}
public BizAiDataAuditTaskEntity save(BizAiDataAuditTaskEntity entity) throws Exception {
Assert.notNull(entity);
entity.setDataAuditTaskId(null);
entity.setIsDeleted("N");
BizAiDataAuditTaskModel model = BizAiDataAuditTaskConvert.entityToModel(entity);
BizAiDataAuditTaskModel saveModel = this.repository.save(model);
return BizAiDataAuditTaskConvert.modelToEntity(saveModel);
}
public BizAiDataAuditTaskEntity update(BizAiDataAuditTaskEntity entity) throws Exception {
Assert.notNull(entity);
Assert.notNull(entity.getDataAuditTaskId(), "update pk can not be null");
BizAiDataAuditTaskModel model = this.repository.get(entity.getDataAuditTaskId());
if (entity.getDataAuditTaskName() != null) {
model.setDataAuditTaskName(entity.getDataAuditTaskName());
}
if (entity.getMemberId() != null) {
model.setMemberId(entity.getMemberId());
}
if (entity.getStatus() != null) {
model.setStatus(entity.getStatus());
}
if (entity.getFileNum() != null) {
model.setFileNum(entity.getFileNum());
}
if (entity.getIsDeleted() != null) {
model.setIsDeleted(entity.getIsDeleted());
}
if (entity.getCreator() != null) {
model.setCreator(entity.getCreator());
}
if (entity.getCreatedTime() != null) {
model.setCreatedTime(entity.getCreatedTime());
}
if (entity.getModifier() != null) {
model.setModifier(entity.getModifier());
}
if (entity.getModifiedTime() != null) {
model.setModifiedTime(entity.getModifiedTime());
}
if (entity.getSysVersion() != null) {
model.setSysVersion(entity.getSysVersion());
}
BizAiDataAuditTaskModel saveModel = this.repository.save(model);
return BizAiDataAuditTaskConvert.modelToEntity(saveModel);
}
public void deletedById(java.lang.Integer id) throws Exception {
Assert.notNull(id);
BizAiDataAuditTaskModel model = this.repository.get(id);
if (model != null) {
if ("N".equals(model.getIsDeleted())) {
model.setIsDeleted("Y");
this.repository.save(model);
}
}
}
@Override
public void createDataAuditTask(String taskName, FileUploadConfirmDto fileUploadConfirmDto) throws Exception {
if (CollectionUtils.isEmpty(fileUploadConfirmDto.getFileUploadReturnDtoList())) {
throw new Exception("Please select the file you wish to upload!");
}
List<FileUploadReturnDto> fileUploadReturnDtoList = fileUploadConfirmDto.getFileUploadReturnDtoList();
Map<String, String> fileCodeNameMap = fileUploadReturnDtoList.stream().collect(Collectors.toMap(FileUploadReturnDto::getOrginalTemplateCode, FileUploadReturnDto::getUploadFileName));
Map<String, String> fileNameCodeMap = fileUploadReturnDtoList.stream().collect(Collectors.toMap(FileUploadReturnDto::getUploadFileName, FileUploadReturnDto::getOrginalTemplateCode));
Map<String, String> fileuploadNameCodeMap = fileUploadReturnDtoList.stream().collect(Collectors.toMap(FileUploadReturnDto::getUploadFileName, FileUploadReturnDto::getOrginalTemplateCode));
if (StringUtils.isBlank(fileCodeNameMap.get("DOC-01")) && StringUtils.isBlank(fileCodeNameMap.get("DOC-02"))) {
throw new Exception("DOC-01 or DOC-02 can not be null");
}
Map<String, String> fileMap = new HashMap<>();
for (FileUploadDto fileUploadDto : fileUploadConfirmDto.getFileUploadDtoList()) {
fileMap.put(fileUploadDto.getFileName(), fileUploadDto.getFileUrl());
}
//生成task
BizAiDataAuditTaskModel model = new BizAiDataAuditTaskModel();
model.setDataAuditTaskName(taskName);
model.setMemberId(BlContext.getCurrentUser().getUserId().intValue());
model.setStatus(DataAuditConstants.status.status_process);
model.setFileNum(fileUploadConfirmDto.getFileUploadDtoList().size());
BizAiDataAuditTaskModel savedModel = repository.save(model);
List<BizAiDataAuditFileEntity> bizAiDataAuditFileEntityList = new ArrayList<BizAiDataAuditFileEntity>();
for (Map.Entry<String, String> entry : fileMap.entrySet()) {
BizAiDataAuditFileEntity bizAiDataAuditFileEntity = new BizAiDataAuditFileEntity();
bizAiDataAuditFileEntity.setTaskId(savedModel.getDataAuditTaskId());
bizAiDataAuditFileEntity.setOrginalTemplateCode(StringUtils.isBlank(fileuploadNameCodeMap.get(entry.getKey())) ? null : "other");
bizAiDataAuditFileEntity.setOrginalTemplateName(fileNameCodeMap.get(bizAiDataAuditFileEntity.getOrginalTemplateCode()));
bizAiDataAuditFileEntity.setUploadFileName(entry.getKey());
bizAiDataAuditFileEntity.setUploadFileUrl(entry.getValue());
bizAiDataAuditFileEntityList.add(bizAiDataAuditFileEntity);
}
bizAiDataAuditFileService.batchSavedFile(bizAiDataAuditFileEntityList);
}
}
\ No newline at end of file
...@@ -105,8 +105,13 @@ public class AiDialoguesServiceImpl implements AiDialoguesService { ...@@ -105,8 +105,13 @@ public class AiDialoguesServiceImpl implements AiDialoguesService {
@Override @Override
public String create(AiDialoguesTypeEnum type, String fileUrl, Long userId) throws Exception { public String create(AiDialoguesTypeEnum type, String fileUrl, Long userId) throws Exception {
if (type.getType().equals(AiDialoguesTypeEnum.CAR_INSURANCE.getType())) {
String appid = fmxParamConfigService.getParam("car_insurance_appid"); Map<AiDialoguesTypeEnum, String> appbuilderMap = new HashMap();
appbuilderMap.put(AiDialoguesTypeEnum.CAR_INSURANCE, "car_insurance_appid");
appbuilderMap.put(AiDialoguesTypeEnum.CAR_RECOMMEND, "car_recommend_appid");
if (appbuilderMap.containsKey(type)) {
String appid = fmxParamConfigService.getParam(appbuilderMap.get(type));
String relationId = appBuilderService.conversation(appid); String relationId = appBuilderService.conversation(appid);
if (StringUtils.isBlank(relationId)) { if (StringUtils.isBlank(relationId)) {
throw new BusinessException("创建对话失败"); throw new BusinessException("创建对话失败");
...@@ -128,6 +133,7 @@ public class AiDialoguesServiceImpl implements AiDialoguesService { ...@@ -128,6 +133,7 @@ public class AiDialoguesServiceImpl implements AiDialoguesService {
return bizAiDialoguesService.create(type.getType(), fileUrl, userId); return bizAiDialoguesService.create(type.getType(), fileUrl, userId);
} }
@Override @Override
public AiDialoguesRecordDto dialoguesDetail(String dialoguesId, Long userId) throws Exception { public AiDialoguesRecordDto dialoguesDetail(String dialoguesId, Long userId) throws Exception {
logger.info("get ai dialogues detail dialoguesId:{}, userId:{}", dialoguesId, userId); logger.info("get ai dialogues detail dialoguesId:{}, userId:{}", dialoguesId, userId);
...@@ -344,7 +350,7 @@ public class AiDialoguesServiceImpl implements AiDialoguesService { ...@@ -344,7 +350,7 @@ public class AiDialoguesServiceImpl implements AiDialoguesService {
long inputTimeStamp = System.currentTimeMillis(); long inputTimeStamp = System.currentTimeMillis();
try { try {
if (dialoguesType.equals(AiDialoguesTypeEnum.CAR_INSURANCE.getType())) {//AppBuilder if (dialoguesType.equals(AiDialoguesTypeEnum.CAR_INSURANCE.getType()) || dialoguesType.equals(AiDialoguesTypeEnum.CAR_RECOMMEND.getType())) {//AppBuilder
BizAiDialogues3rdRelationEntity bizAiDialogues3rdRelationEntity = new BizAiDialogues3rdRelationEntity(); BizAiDialogues3rdRelationEntity bizAiDialogues3rdRelationEntity = new BizAiDialogues3rdRelationEntity();
bizAiDialogues3rdRelationEntity.setDialoguesId(dialoguesId); bizAiDialogues3rdRelationEntity.setDialoguesId(dialoguesId);
bizAiDialogues3rdRelationEntity.setPlatform(DialoguesPlatformEnum.AppBuilder.getPlatform()); bizAiDialogues3rdRelationEntity.setPlatform(DialoguesPlatformEnum.AppBuilder.getPlatform());
......
package cn.com.poc.ai_dialogues.constant; package cn.com.poc.ai_dialogues.constant;
import java.util.ArrayList;
import java.util.List;
/** /**
* @author alex.yao * @author alex.yao
* @date 2025/6/19 * @date 2025/6/19
...@@ -32,6 +35,9 @@ public enum AiDialoguesTypeEnum { ...@@ -32,6 +35,9 @@ public enum AiDialoguesTypeEnum {
CAR_INSURANCE("car_insurance","车辆保险"), CAR_INSURANCE("car_insurance","车辆保险"),
CAR_RECOMMEND("car_recommend","车辆推荐"),
; ;
private final String type; private final String type;
...@@ -60,4 +66,5 @@ public enum AiDialoguesTypeEnum { ...@@ -60,4 +66,5 @@ public enum AiDialoguesTypeEnum {
} }
return null; return null;
} }
} }
package cn.com.poc.thirdparty.resource.demand.ai.aggregate;
import cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU.MinerUOcrResponse;
import cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU.MinerUOcrResult;
/**
* @author alex.yao
* @date 2025/7/28
*/
public interface MinerUOcrService {
/**
* 文件OCR
*
* @param response
* @return
*/
MinerUOcrResult fileParse(MinerUOcrResponse response);
}
package cn.com.poc.thirdparty.resource.demand.ai.aggregate.impl;
import cn.com.poc.thirdparty.resource.demand.ai.aggregate.LegalService;
import cn.com.poc.thirdparty.resource.demand.ai.aggregate.MinerUOcrService;
import cn.com.poc.thirdparty.resource.demand.ai.entity.legal.LegalFileResponse;
import cn.com.poc.thirdparty.resource.demand.ai.entity.legal.LegalFileResult;
import cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU.MinerUOcrResponse;
import cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU.MinerUOcrResult;
import cn.com.poc.thirdparty.resource.demand.ai.route.DgtoolsApiRoute;
import cn.com.poc.thirdparty.resource.demand.dgTools.DgtoolsAbstractHttpClient;
import cn.com.poc.thirdparty.resource.demand.member.service.DemandAuthService;
import org.apache.http.Header;
import org.apache.http.message.BasicHeader;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
* @author alex.yao
* @date 2025/7/28
*/
@Service
public class MinerUOcrServiceImpl implements MinerUOcrService {
@Resource
private DgtoolsAbstractHttpClient dgToolsAbstractHttpClient;
@Resource
private DemandAuthService demandAuthService;
@Override
public MinerUOcrResult fileParse(MinerUOcrResponse response){
String url = DgtoolsApiRoute.DgtoolsAI.LEGAL_FILE;
List<Header> headers = new ArrayList<Header>() {{
add(DgtoolsApiRoute.JSON_HEADER);
add(DgtoolsApiRoute.AI_HEADER);
add(new BasicHeader(DgtoolsApiRoute.HEADER_X_PLATFORM_AUTHORIZATION, demandAuthService.getToken()));
}};
return null;
}
}
package cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU;
/**
* @Author:Roger Wu
* @name:Form
* @Date:2025-10-30 2:27
*/
public class Form {
private String md_content;
public String getMd_content() {
return md_content;
}
public void setMd_content(String md_content) {
this.md_content = md_content;
}
}
package cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU;
import org.springframework.web.multipart.MultipartFile;
import java.io.File;
import java.lang.reflect.Array;
/**
* @Author:Roger Wu
* @name:MinerUOcrResponse
* @Date:2025-10-30 2:22
*/
public class MinerUOcrResponse {
private File file;
private String output_dir;
private Array lang_list;
private String backend;
private String parse_method;
private String formula_enable;
private String table_enable;
private String server_url;
private String return_md;
private String return_middle_json;
private String return_model_output;
private String return_content_list;
private String return_images;
private String response_format_zip;
private Integer start_page_id;
private Integer end_page_id;
public File getFile() {
return file;
}
public void setFile(File file) {
this.file = file;
}
public String getOutput_dir() {
return output_dir;
}
public void setOutput_dir(String output_dir) {
this.output_dir = output_dir;
}
public Array getLang_list() {
return lang_list;
}
public void setLang_list(Array lang_list) {
this.lang_list = lang_list;
}
public String getBackend() {
return backend;
}
public void setBackend(String backend) {
this.backend = backend;
}
public String getParse_method() {
return parse_method;
}
public void setParse_method(String parse_method) {
this.parse_method = parse_method;
}
public String getFormula_enable() {
return formula_enable;
}
public void setFormula_enable(String formula_enable) {
this.formula_enable = formula_enable;
}
public String getTable_enable() {
return table_enable;
}
public void setTable_enable(String table_enable) {
this.table_enable = table_enable;
}
public String getServer_url() {
return server_url;
}
public void setServer_url(String server_url) {
this.server_url = server_url;
}
public String getReturn_md() {
return return_md;
}
public void setReturn_md(String return_md) {
this.return_md = return_md;
}
public String getReturn_middle_json() {
return return_middle_json;
}
public void setReturn_middle_json(String return_middle_json) {
this.return_middle_json = return_middle_json;
}
public String getReturn_model_output() {
return return_model_output;
}
public void setReturn_model_output(String return_model_output) {
this.return_model_output = return_model_output;
}
public String getReturn_content_list() {
return return_content_list;
}
public void setReturn_content_list(String return_content_list) {
this.return_content_list = return_content_list;
}
public String getReturn_images() {
return return_images;
}
public void setReturn_images(String return_images) {
this.return_images = return_images;
}
public String getResponse_format_zip() {
return response_format_zip;
}
public void setResponse_format_zip(String response_format_zip) {
this.response_format_zip = response_format_zip;
}
public Integer getStart_page_id() {
return start_page_id;
}
public void setStart_page_id(Integer start_page_id) {
this.start_page_id = start_page_id;
}
public Integer getEnd_page_id() {
return end_page_id;
}
public void setEnd_page_id(Integer end_page_id) {
this.end_page_id = end_page_id;
}
}
package cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU;
/**
* @Author:Roger Wu
* @name:MinerUOcrResult
* @Date:2025-10-30 2:26
*/
public class MinerUOcrResult {
private String backend;
private String version;
private Results results;
public String getBackend() {
return backend;
}
public void setBackend(String backend) {
this.backend = backend;
}
public String getVersion() {
return version;
}
public void setVersion(String version) {
this.version = version;
}
public Results getResults() {
return results;
}
public void setResults(Results results) {
this.results = results;
}
}
package cn.com.poc.thirdparty.resource.demand.ai.entity.orc.minerU;
/**
* @Author:Roger Wu
* @name:Results
* @Date:2025-10-30 2:27
*/
public class Results {
private Form form;
public Form getForm() {
return form;
}
public void setForm(Form form) {
this.form = form;
}
}
######mysql数据配置示例#######
hibernate.dialect=org.hibernate.dialect.MySQL5InnoDBDialect
hibernate.show_sql=true
hibernate.format_sql=true
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://192.168.21.31:3306/gsst_modellink_sit?useSSL=false&useUnicode=true&allowMultiQueries=true&serverTimezone=Asia/Shanghai&characterEncoding=UTF-8
jdbc.username=modellink_root
jdbc.password=56a6a2854424
ds.maxActive=20
ds.minIdle=1
ds.initialSize=1
ds.validationQuery=select 1 from dual
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment