7b0e99c0 by xu

Merge branch 'develop-v1.0.6' into feature-tds-v1.0.0

# Conflicts:
#	src/main/java/com/csbr/qingcloud/portal/service/EnterpriseService.java
#	src/main/java/com/csbr/qingcloud/portal/service/impl/EnterpriseServiceImpl.java
2 parents 235cd65b 1c39bdbd
Showing 22 changed files with 950 additions and 0 deletions
package com.csbr.qingcloud.portal.controller;
import com.csbr.qingcloud.portal.domain.vo.dataExchange.*;
import com.csbr.qingcloud.portal.service.EnterpriseAttachmentService;
import com.csbr.qingcloud.portal.service.EnterpriseService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @program:
* @description: 数据所交互控制器-控制器
* @author: makejava
* @create: 2025-03-24 17:29
**/
@RestController
@RequestMapping("/data-exchange")
@Tag(name = "数据所交互控制器-控制器")
public class DataExchangeController {
@Resource
private EnterpriseService enterpriseService;
@Resource
private EnterpriseAttachmentService enterpriseAttachmentService;
@PostMapping("/enterprise-data")
@Operation(summary= "开发主体查询")
public JSExchageCommonRes<JSExchagePageListVO<JSEnterpriseRSVO>> enterpriseData(@RequestBody @Valid JSBaseRQVO<JSEnterpriseQueryVO> queryVO) {
JSExchageCommonRes<JSExchagePageListVO<JSEnterpriseRSVO>> pageVO = enterpriseService.enterpriseData(queryVO);
return pageVO;
}
@PostMapping("/enterprise-attach")
@Operation(summary= "开发主体附件查询")
public JSExchageCommonRes<JSExchagePageListVO<JSAttachRSVO>> enterpriseAttach(@RequestBody @Valid JSBaseRQVO<JSAttachQueryVO> queryVO) {
JSExchageCommonRes<JSExchagePageListVO<JSAttachRSVO>> pageVO = enterpriseAttachmentService.enterpriseAttach(queryVO);
return pageVO;
}
//endregion
}
package com.csbr.qingcloud.portal.controller;
import com.csbr.cloud.common.response.CommonRes;
import csbr.cloud.entity.annotation.SystemLog;
import csbr.cloud.entity.domain.base.vo.PageListVO;
import com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentQueryVO;
import com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentRQVO;
import com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentRSVO;
import com.csbr.qingcloud.portal.service.EnterpriseAttachmentService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @program:
* @description: 开发主体附件信息-控制器
* @author: makejava
* @create: 2025-09-05 13:50
**/
@RestController
@RequestMapping("/enterprise-attachment")
@Tag(name = "开发主体附件信息-控制器")
public class EnterpriseAttachmentController {
@Resource
private EnterpriseAttachmentService enterpriseAttachmentService;
//region 基本操作
@PostMapping("/save")
@SystemLog(value = "开发主体附件信息-新增")
@Operation(summary = "开发主体附件信息-新增")
public CommonRes<Boolean> saveEnterpriseAttachment(@RequestBody @Valid EnterpriseAttachmentRQVO vo) {
enterpriseAttachmentService.saveEnterpriseAttachment(vo);
return CommonRes.success(true);
}
@PutMapping("/update")
@SystemLog(value = "开发主体附件信息-修改")
@Operation(summary = "开发主体附件信息-修改")
public CommonRes<Boolean> updateEnterpriseAttachment(@RequestBody @Valid EnterpriseAttachmentRQVO vo) {
enterpriseAttachmentService.updateEnterpriseAttachment(vo);
return CommonRes.success(true);
}
@DeleteMapping("/delete")
@SystemLog(value = "开发主体附件信息-批量删除")
@Operation(summary = "开发主体附件信息-批量删除")
public CommonRes<Boolean> removeByGuids(@RequestBody List<String> guids) {
enterpriseAttachmentService.removeByGuids(guids);
return CommonRes.success(true);
}
@PostMapping("/page-list")
@SystemLog(value = "开发主体附件信息-分页")
@Operation(summary = "开发主体附件信息-分页")
public CommonRes<PageListVO<EnterpriseAttachmentRSVO>> pageList(@RequestBody @Valid EnterpriseAttachmentQueryVO queryVO) {
PageListVO<EnterpriseAttachmentRSVO> pageVO = enterpriseAttachmentService.pageList(queryVO);
return CommonRes.success(pageVO);
}
@GetMapping("/detail")
@SystemLog(value = "开发主体附件信息-详情")
@Operation(
summary = "开发主体附件信息-详情",
parameters = {
@Parameter(name = "guid", description = "开发主体附件信息唯一标识", required = true)}
)
public CommonRes<EnterpriseAttachmentRSVO> getEnterpriseAttachmentDetail(@RequestParam String guid) {
EnterpriseAttachmentRSVO vo = enterpriseAttachmentService.getEnterpriseAttachmentDetail(guid);
return CommonRes.success(vo);
}
@GetMapping("/get-fileUrl")
@SystemLog(value = "开发主体附件信息-查询文件Url地址")
@Operation(
summary = "开发主体附件信息-查询文件Url地址",
parameters = {
@Parameter(name = "fileId", description = "文件Id", required = true)},
hidden = true
)
public CommonRes<String> getFileUrl(@RequestParam String fileId) {
String fileUrl = enterpriseAttachmentService.getEnterpriseAttachmentUrl(fileId);
return CommonRes.success(fileUrl);
}
//endregion
}
package com.csbr.qingcloud.portal.domain.vo;
import csbr.cloud.entity.domain.base.dto.BasePageDTO;
import io.swagger.v3.oas.annotations.media.Schema;
import jdk.jfr.Name;
import lombok.EqualsAndHashCode;
import lombok.Data;
import java.math.BigDecimal;
import java.util.Date;
/**
* @program:
* @description: 开发主体附件信息查询参数
* @author: makejava
* @create: 2025-09-05 13:50
**/
@EqualsAndHashCode(callSuper = true)
@Data
@Schema(title = "开发主体附件信息查询参数")
public class EnterpriseAttachmentQueryVO extends BasePageDTO {
/**
* 企业认证唯一标识
*/
@Name("企业认证唯一标识")
private String enterpriseGuid;
}
package com.csbr.qingcloud.portal.domain.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import com.fasterxml.jackson.annotation.JsonFormat;
import jakarta.validation.constraints.Size;
import lombok.Data;
import java.math.BigDecimal;
import java.util.Date;
/**
* @program:
* @description: 开发主体附件信息新增、修改参数
* @author: makejava
* @create: 2025-09-05 13:50
**/
@Data
@Schema(title = "开发主体附件信息新增、修改参数")
public class EnterpriseAttachmentRQVO {
/**
* 系统唯一标识
*/
@Schema(description = "系统唯一标识")
@Size(max = 32, message = "系统唯一标识长度超过32")
private String guid;
/**
* 企业唯一标识
*/
@Schema(description = "企业唯一标识")
@Size(max = 32, message = "企业唯一标识长度超过32")
private String tenantGuid;
/**
* 企业认证唯一标识
*/
@Schema(description = "企业认证唯一标识")
@Size(max = 32, message = "企业认证唯一标识长度超过32")
private String enterpriseGuid;
/**
* 文件名称
*/
@Schema(description = "文件名称")
@Size(max = 50, message = "文件名称长度超过50")
private String fileName;
/**
* 文件类型【详情 开发主体附件类型数据字典】
*/
@Schema(description = "文件类型【详情 开发主体附件类型数据字典】")
@Size(max = 10, message = "文件类型【详情 开发主体附件类型数据字典】长度超过10")
private String fileType;
/**
* 文件大小
*/
@Schema(description = "文件大小")
private BigDecimal fileSize;
/**
* 文件地址
*/
@Schema(description = "文件地址")
@Size(max = 500, message = "文件地址长度超过500")
private String fileUrl;
/******** 库表存储属性 需处理 *****/
/******** 自定义扩展 *****/
/******** 子对象 *****/
}
package com.csbr.qingcloud.portal.domain.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.math.BigDecimal;
import java.util.Date;
/**
* @program:
* @description: 开发主体附件信息返回参数
* @author: makejava
* @create: 2025-09-05 13:50
**/
@Data
@Schema(title = "开发主体附件信息返回参数")
public class EnterpriseAttachmentRSVO {
/**
* 系统唯一标识
*/
@Schema(description = "系统唯一标识")
private String guid;
/**
* 企业唯一标识
*/
@Schema(description = "企业唯一标识")
private String tenantGuid;
/**
* 企业认证唯一标识
*/
@Schema(description = "企业认证唯一标识")
private String enterpriseGuid;
/**
* 文件名称
*/
@Schema(description = "文件名称")
private String fileName;
/**
* 文件类型【详情 开发主体附件类型数据字典】
*/
@Schema(description = "文件类型【详情 开发主体附件类型数据字典】")
private String fileType;
/**
* 文件大小
*/
@Schema(description = "文件大小")
private BigDecimal fileSize;
/**
* 文件地址
*/
@Schema(description = "文件地址")
private String fileUrl;
/******** 库表存储属性 需处理 *****/
/******** 自定义扩展 *****/
/******** 子对象 *****/
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
/**
* @program:
* @description: 江苏开发主体附件查询参数
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏开发主体附件查询参数")
public class JSAttachQueryVO extends JSPageQueryVO {
/**
* 如有需要则填写开发主体名称
*/
@Schema(title = "如有需要则填写开发主体名称")
private String entityName;
/**
* 如有需要则填写统一社会信用代码
*/
@Schema(title = "如有需要则填写统一社会信用代码")
private String uscc;
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.math.BigDecimal;
/**
* @program:
* @description: 江苏开发主体附件返回参数
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏开发主体附件返回参数")
public class JSAttachRSVO {
/**
* 文件ID
*/
@Schema(description = "文件ID")
private String fileId;
/**
* 文件名称
*/
@Schema(description = "文件名称")
private String fileName;
/**
* 文件类型【详情 开发主体附件类型数据字典】
*/
@Schema(description = "文件类型【详情 开发主体附件类型数据字典】")
private String fileType;
/**
* 文件大小
*/
@Schema(description = "文件大小")
private BigDecimal fileSize;
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
/**
* @program:
* @description: 江苏开发主体查询参数
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏开发主体查询参数")
public class JSBaseRQVO<T> {
/**
* 请求方法名
*/
@Schema(title = "请求方法名")
private String method;
/**
* 请求参数
*/
@Schema(title = "请求参数")
private T bizParam;
private String appKey;
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.util.List;
import java.util.Map;
/**
* @program:
* @description: 江苏数交所开发主体申请的领域列表参数
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏数交所开发主体申请的领域列表参数")
public class JSDomainRSVO {
/**
* 领域代码
*/
@Schema(description = "领域代码")
private String domainId;
/**
* 领域名称
*/
@Schema(description = "领域名称")
private String domainName;
/**
* 场景列表,scenarioName,scenarioCode
*/
@Schema(description = "场景列表")
private List<Map<String,String>> scenarioList;
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.util.Date;
/**
* @program:
* @description: 江苏开发主体查询参数
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏开发主体查询参数")
public class JSEnterpriseQueryVO extends JSPageQueryVO {
/**
* 如有需要则填写开发主体名称
*/
@Schema(title = "如有需要则填写开发主体名称")
private String entityName;
/**
* 如有需要则填写统一社会信用代码
*/
@Schema(title = "如有需要则填写统一社会信用代码")
private String uscc;
/**
* 产品更新起始时间
*/
private Date productUpdateStartTime;
/**
* 产品更新截止时间
*/
private Date productUpdateEndTime;
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.util.List;
/**
* @program:
* @description: 江苏开发主体返回参数
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏开发主体返回参数")
public class JSEnterpriseRSVO {
/**
* 主体名称
*/
@Schema(title = "主体名称")
private String institutionName;
/**
* 统一社会信用代码
*/
@Schema(title = "统一社会信用代码")
private String institutionCode;
/**
* 组织机构性质
*/
@Schema(title = "组织机构性质")
private String institutionType;
/**
* 国家
*/
@Schema(title = "国家")
private String country;
/**
* 注册地
*/
@Schema(title = "注册地")
private String region;
/**
* 详细地址
*/
@Schema(title = "详细地址")
private String detailedAddress;
/**
* 法人名称
*/
@Schema(title = "法人名称")
private String corpnName;
/**
* 领域列表
*/
@Schema(title = "领域列表")
private List<JSDomainRSVO> domainList;
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.io.Serializable;
/**
* @program:
* @description: 江苏数交所返回结果
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏数交所返回结果")
public class JSExchageCommonRes<T> implements Serializable {
/**
* 返回码,0为成功,其它为失败
*/
@Schema(description = "返回码,0为成功,其它为失败")
private Integer code;
/**
* 返回描述
*/
@Schema(description = "返回描述")
private String message;
/**
* 数据
*/
@Schema(description = "数据")
private T data;
public JSExchageCommonRes(Integer code,T data){
this.code = code;
this.data = data;
}
public JSExchageCommonRes(Integer code,String message){
this.code = code;
this.message = message;
}
/**
* 返回成功
* @param data
* @param <T>
* @return
*/
public static <T> JSExchageCommonRes<T> success(T data) {
return new JSExchageCommonRes<T>(0,data);
}
/**
* 返回失败
* @param message
* @return
*/
public static JSExchageCommonRes fail(String message) {
return new JSExchageCommonRes(-1,message);
}
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* @program:
* @description: 江苏数交所返回分页数据
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏数交所返回分页数据")
public class JSExchagePageListVO<T> implements Serializable {
/**
* 请求流水号
*/
@Schema(description = "请求流水号")
private String respFlowId;
/**
* 返回记录总数
*/
@Schema(description = "返回记录总数")
private Integer total;
/**
* 查询结果列表
*/
@Schema(description = "查询结果列表")
private List<T> data;
}
package com.csbr.qingcloud.portal.domain.vo.dataExchange;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
/**
* @program:
* @description: 江苏数交所分页参数
* @author: makejava
* @create: 2025-09-05 10:35
**/
@Data
@Schema(title = "江苏数交所分页参数")
public class JSPageQueryVO {
/**
* 请替换为实际的请求流水号
*/
@Schema(title = "请替换为实际的请求流水号")
private String reqFlowId;
/**
* 页码
*/
private Integer pageNum =1;
/**
* 每页条数
*/
private Integer pageSize = 20;
}
package com.csbr.qingcloud.portal.mybatis.entity;
import com.baomidou.mybatisplus.annotation.FieldStrategy;
import com.baomidou.mybatisplus.annotation.TableField;
import csbr.cloud.entity.domain.base.dao.BaseDO;
import jdk.jfr.Name;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.math.BigDecimal;
import java.util.Date;
/**
* @program:
* @description: 开发主体附件信息实体
* @author: makejava
* @create: 2025-09-05 13:50
**/
@Data
@EqualsAndHashCode(callSuper = true)
@Accessors(chain = true)
@Name("开发主体附件信息")
public class MfEnterpriseAttachment extends BaseDO {
/**
* 企业唯一标识
*/
@Name("企业唯一标识")
private String tenantGuid;
/**
* 企业认证唯一标识
*/
@Name("企业认证唯一标识")
private String enterpriseGuid;
/**
* 文件ID
*/
@Name("文件ID")
private String fileId;
/**
* 文件名称
*/
@Name("文件名称")
private String fileName;
/**
* 文件类型【详情 开发主体附件类型数据字典】
*/
@Name("文件类型【详情 开发主体附件类型数据字典】")
private String fileType;
/**
* 文件大小
*/
@Name("文件大小")
private BigDecimal fileSize;
/**
* 文件地址
*/
@Name("文件地址")
private String fileUrl;
}
package com.csbr.qingcloud.portal.mybatis.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseAttachment;
/**
* @program:
* @description: 开发主体附件信息 Mapper 接口
* @author: makejava
* @create: 2025-09-05 13:50
**/
@Mapper
public interface MfEnterpriseAttachmentMapper extends BaseMapper<MfEnterpriseAttachment> {
}
package com.csbr.qingcloud.portal.mybatis.service;
import com.csbr.cloud.base.service.CsbrService;
import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseAttachment;
/**
* @program:
* @description: 开发主体附件信息逻辑层接口
* @author: makejava
* @create: 2025-09-05 13:50
**/
public interface MfEnterpriseAttachmentService extends CsbrService<MfEnterpriseAttachment> {
}
package com.csbr.qingcloud.portal.mybatis.service.impl;
import com.csbr.cloud.mybatis.service.impl.CsbrServiceImpl;
import com.csbr.qingcloud.portal.mybatis.mapper.MfEnterpriseAttachmentMapper;
import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseAttachment;
import com.csbr.qingcloud.portal.mybatis.service.MfEnterpriseAttachmentService;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
/**
* @program:
* @description: 开发主体附件信息逻辑层接口实现
* @author: makejava
* @create: 2025-09-05 13:50
**/
@Service
public class MfEnterpriseAttachmentServiceImpl extends CsbrServiceImpl<MfEnterpriseAttachmentMapper, MfEnterpriseAttachment> implements MfEnterpriseAttachmentService {
@Resource
private MfEnterpriseAttachmentMapper mfEnterpriseAttachmentMapper;
}
package com.csbr.qingcloud.portal.service;
import com.csbr.qingcloud.portal.domain.vo.dataExchange.*;
import csbr.cloud.entity.domain.base.vo.PageListVO;
import com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentQueryVO;
import com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentRQVO;
import com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentRSVO;
import java.util.List;
/**
* @program:
* @description: 开发主体附件信息业务逻辑接口
* @author: makejava
* @create: 2025-09-05 13:50
**/
public interface EnterpriseAttachmentService {
/**
* 开发主体附件信息分页查询
* @author makejava
* @date 2025-09-05 13:50
* @param queryVO
* @return com.csbr.cloud.mybatis.entity.PageListVO<com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentRSVO>
*/
PageListVO<EnterpriseAttachmentRSVO> pageList(EnterpriseAttachmentQueryVO queryVO);
/**
* 开发主体附件信息获取详情数据
* @author makejava
* @date 2025-09-05 13:50
* @param guid
* @return com.csbr.qingcloud.portal.domain.vo.EnterpriseAttachmentRSVO
*/
EnterpriseAttachmentRSVO getEnterpriseAttachmentDetail(String guid);
/**
* 开发主体附件信息数据新增
* @author makejava
* @date 2025-09-05 13:50
* @param rqVO
* @return boolean
*/
void saveEnterpriseAttachment(EnterpriseAttachmentRQVO rqVO);
/**
* 开发主体附件信息数据修改
* @author makejava
* @date 2025-09-05 13:50
* @param rqVO
* @return boolean
*/
void updateEnterpriseAttachment(EnterpriseAttachmentRQVO rqVO);
/**
* 开发主体附件信息数据删除
* @author makejava
* @date 2025-09-05 13:50
* @param guids
* @return void
*/
void removeByGuids(List<String> guids);
/**
* 开发主体附件信息数据删除、并有相关的处理操作
* @author makejava
* @date 2025-09-05 13:50
* @param guids
* @return void
*/
void removeHandleByGuids(List<String> guids);
/**
* 数交所附件同步
* @param queryVO
* @return
*/
JSExchageCommonRes<JSExchagePageListVO<JSAttachRSVO>> enterpriseAttach(JSBaseRQVO<JSAttachQueryVO> queryVO);
/**
* 根据文件Id查询附件地址
* @param fileId
* @return
*/
String getEnterpriseAttachmentUrl(String fileId);
}
......@@ -107,6 +107,13 @@ public interface EnterpriseService {
EnterpriseRSVO getEnterpriseDetailByLogonUser(String logonUser);
/**
* 开发主体分页查询
* @param queryVO
* @return
*/
JSExchageCommonRes<JSExchagePageListVO<JSEnterpriseRSVO>> enterpriseData(JSBaseRQVO<JSEnterpriseQueryVO> queryVO);
/**
* 按名称或者统一社会信用代码查企业信息详情
* @param tenantName
* @param uscc
......
......@@ -21,6 +21,7 @@ import com.csbr.cloud.workflow.domain.vo.appove.FlowRQBaseVO;
import com.csbr.cloud.workflow.util.ApprovalFlowUtil;
import com.csbr.cloud.workflow.util.FlowAbstractImpl;
import com.csbr.qingcloud.portal.domain.vo.*;
import com.csbr.qingcloud.portal.domain.vo.dataExchange.*;
import com.csbr.qingcloud.portal.feign.ConfigureFeign;
import com.csbr.qingcloud.portal.feign.PersonelFeign;
import com.csbr.qingcloud.portal.feign.WorkflowFeign;
......@@ -629,6 +630,60 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris
}
@Override
public JSExchageCommonRes<JSExchagePageListVO<JSEnterpriseRSVO>> enterpriseData(JSBaseRQVO<JSEnterpriseQueryVO> queryVO) {
JSExchageCommonRes<JSExchagePageListVO<JSEnterpriseRSVO>> vo = beforeEnterpriseData(queryVO);
if(ObjectUtils.isNotEmpty(vo)){
return vo;
}
LambdaQueryWrapper<MfEnterprise> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(MfEnterprise::getBizApproveState,ApprovalStateEnum.PASSED.getValue());
queryWrapper.eq(MfEnterprise::getZqName,queryVO.getAppKey());
queryWrapper.orderByDesc(MfEnterprise::getCreateTime);
JSEnterpriseQueryVO bizParam = queryVO.getBizParam();
EnterpriseQueryVO enterpriseQueryVO = new EnterpriseQueryVO();
enterpriseQueryVO.setPageIndex(Long.valueOf(bizParam.getPageNum()));
enterpriseQueryVO.setPageSize(Long.valueOf(bizParam.getPageSize()));
PageListVO<MfEnterprise> enterprisePageListVO = mfEnterpriseService.csbrPageList(enterpriseQueryVO, queryWrapper);
JSExchagePageListVO<JSEnterpriseRSVO> pageListVO = new JSExchagePageListVO<JSEnterpriseRSVO>();
pageListVO.setRespFlowId(bizParam.getReqFlowId());
afterEnterpriseData(enterprisePageListVO, pageListVO);
return JSExchageCommonRes.success(pageListVO);
}
private void afterEnterpriseData(PageListVO<MfEnterprise> enterprisePageListVO, JSExchagePageListVO<JSEnterpriseRSVO> pageListVO) {
pageListVO.setTotal(enterprisePageListVO.getTotalRows().intValue());
List<MfEnterprise> records = enterprisePageListVO.getRecords();
List<JSEnterpriseRSVO> rsvos = new ArrayList<>();
for (MfEnterprise record : records) {
JSEnterpriseRSVO enterpriseRSVO = new JSEnterpriseRSVO();
enterpriseRSVO.setInstitutionName(record.getTenantName());
enterpriseRSVO.setInstitutionCode(record.getSocialCreditCode());
enterpriseRSVO.setCountry("中国");
enterpriseRSVO.setRegion(record.getDistrict());
enterpriseRSVO.setCorpnName(record.getJuridicalPerson());
rsvos.add(enterpriseRSVO);
}
pageListVO.setData(rsvos);
}
private JSExchageCommonRes<JSExchagePageListVO<JSEnterpriseRSVO>> beforeEnterpriseData(JSBaseRQVO<JSEnterpriseQueryVO> queryVO) {
if(ObjectUtils.isEmpty(queryVO)){
return JSExchageCommonRes.fail("查询参数为空。");
}
if(ObjectUtils.isEmpty(queryVO.getBizParam())){
return JSExchageCommonRes.fail("请求参数为空。");
}
JSEnterpriseQueryVO bizParam = queryVO.getBizParam();
if(bizParam.getPageNum()<1){
return JSExchageCommonRes.fail("页码参数无效,查询页码从1开始");
}
if(bizParam.getPageSize()<1 || bizParam.getPageSize()> 20 ){
return JSExchageCommonRes.fail("每页条数无效,最大20");
}
return null;
}
@Override
public EnterpriseRSVO getEnterpriseDetailByNameOrUscc(String tenantName, String uscc) {
if(StringUtils.isBlank(tenantName) && StringUtils.isBlank(uscc)){
throw new CsbrSystemException(SystemError.DATA_INPUT_ERROR,"开发主体名称和统一社会信用代码不能同时为空。");
......
Styling with Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!