Commit 6ca99a1e authored by tianhongyang's avatar tianhongyang

Merge branch 'V20230915' of http://192.168.60.201/root/dsk-operate-sys into V20230915

parents 2b319946 790a069f
...@@ -187,15 +187,6 @@ sms: ...@@ -187,15 +187,6 @@ sms:
territory: ap-guangzhou territory: ap-guangzhou
dsk: dsk:
open:
endPoint: pre-openapi.jiansheku.com
accessKeyId: aec7b3ff2y2q8x6t49a7e2c463ce21912
accessKeySecret: ee8a53c7ea04eb3ac311406c8f56f95b
protocol: https
# endPoint: openapi.jiansheku.com
# accessKeyId: aec7b3ff2y2q8x6t49a7e2c463ce21912
# accessKeySecret: ee8a53c7ea04eb3ac311406c8f56f95b
# protocol: https
exportBackUrl: http://47.104.91.229:9099/prod-api/export/backUrl exportBackUrl: http://47.104.91.229:9099/prod-api/export/backUrl
sa-token: sa-token:
......
...@@ -190,12 +190,3 @@ sms: ...@@ -190,12 +190,3 @@ sms:
territory: ap-guangzhou territory: ap-guangzhou
dsk: dsk:
open:
# endPoint: 120.27.13.145:8865
# accessKeyId: aec7b3ff2y2q8x6t49a7e2c463ce21912
# accessKeySecret: ee8a53c7ea04eb3ac311406c8f56f95b
# protocol: http
endPoint: openapi.jiansheku.com
accessKeyId: aec7b3ff2y2q8x6t49a7e2c463ce21912
accessKeySecret: ee8a53c7ea04eb3ac311406c8f56f95b
protocol: https
...@@ -187,15 +187,6 @@ sms: ...@@ -187,15 +187,6 @@ sms:
territory: ap-guangzhou territory: ap-guangzhou
dsk: dsk:
open:
endPoint: pre-openapi.jiansheku.com
accessKeyId: aec7b3ff2y2q8x6t49a7e2c463ce21912
accessKeySecret: ee8a53c7ea04eb3ac311406c8f56f95b
protocol: https
# endPoint: openapi.jiansheku.com
# accessKeyId: aec7b3ff2y2q8x6t49a7e2c463ce21912
# accessKeySecret: ee8a53c7ea04eb3ac311406c8f56f95b
# protocol: https
exportBackUrl: http://47.104.91.229:9099/prod-api/export/backUrl exportBackUrl: http://47.104.91.229:9099/prod-api/export/backUrl
sa-token: sa-token:
......
...@@ -9,8 +9,8 @@ import org.springframework.stereotype.Component; ...@@ -9,8 +9,8 @@ import org.springframework.stereotype.Component;
*@Author: zhangyi *@Author: zhangyi
*@date: 2023/5/15 15:31 *@date: 2023/5/15 15:31
*/ */
@Component //@Component
@ConfigurationProperties(prefix = "dsk.open") //@ConfigurationProperties(prefix = "dsk.open")
public class DskOpenApiConfig { public class DskOpenApiConfig {
public String accessKeyId; public String accessKeyId;
public String accessKeySecret; public String accessKeySecret;
......
package com.dsk.common.utils;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONUtil;
import com.dsk.acc.openapi.api.AccClient;
import com.dsk.acc.openapi.client.Config;
import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.common.config.DskOpenApiConfig;
import com.dsk.common.core.page.TableDataInfo;
import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Map;
@Component
public class DskOpenApiUtil {
@Autowired
private DskOpenApiConfig dskOpenApiConfig;
/**
* <b>application/json请求</b>
* @param path 请求路径
* @param bodyMap 参数体
* @return
*/
public Map<String, Object> requestBody(String path, Map<String, Object> bodyMap){
return request(path, bodyMap, "json");
}
public Map<String, Object> requestBodyLocal(String path, Map<String, Object> bodyMap){
String post = HttpUtil.post("http://127.0.0.1:8766" + path, JSONUtil.toJsonStr(bodyMap));
return CommonUtils.assertAsMap(CommonUtils.parseJSON(post));
}
public Map<String, Object> requestBodyWithHeader(String path, Map<String, Object> bodyMap, Map<String, String> headerMap){
return requestWithHeader(path, bodyMap, "json", headerMap);
}
/**
* <b>application/x-www-form-urlencoded请求</b>
* @param path 请求路径
* @param bodyMap 参数体
* @return
*/
public Map<String, Object> requestForm(String path, Map<String, Object> bodyMap){
return request(path, bodyMap, "form");
}
/**
* <b>开放平台统一请求</b>
* @param path 请求路径
* @param bodyMap 参数体
* @param reqBodyType 请求格式
* @return
*/
public Map<String, Object> request(String path, Map<String, Object> bodyMap, String reqBodyType){
try {
AccClient.init(new Config(dskOpenApiConfig.accessKeyId, dskOpenApiConfig.accessKeySecret)
.setEndpoint(dskOpenApiConfig.endPoint).setProtocol(dskOpenApiConfig.protocol));
Map<String, ?> res = AccClient.request(reqBodyType, path, bodyMap);
if(!res.containsKey("headers") || !res.containsKey("body")) {
throw new RuntimeException(String.format("请求无返回:path=%s",path));
}
Object resBody = res.get("body");
if(resBody == null) {
return null;
}
return CommonUtils.assertAsMap(resBody);
} catch (Exception e) {
throw new RuntimeException(String.format("请求异常:path=%s,err=%s",path,e.getMessage()));
}
}
/**
* <b>开放平台统一请求</b>
* @param path 请求路径
* @param bodyMap 参数体
* @param reqBodyType 请求格式
* @return
*/
public Map<String, Object> requestWithHeader(String path, Map<String, Object> bodyMap, String reqBodyType, Map<String, String> headerMap){
try {
AccClient.init(new Config(dskOpenApiConfig.accessKeyId, dskOpenApiConfig.accessKeySecret)
.setEndpoint(dskOpenApiConfig.endPoint));
Map<String, ?> res = AccClient.request(reqBodyType, path, bodyMap, headerMap);
if(!res.containsKey("headers") || !res.containsKey("body")) {
throw new RuntimeException(String.format("请求无返回:path=%s",path));
}
Object resBody = res.get("body");
if(resBody == null) {
return null;
}
return CommonUtils.assertAsMap(resBody);
} catch (Exception e) {
throw new RuntimeException(String.format("请求异常:path=%s,err=%s",path,e.getMessage()));
}
}
public TableDataInfo responsePage(Map<String, Object> resMap) throws Exception {
Integer code = MapUtils.getInteger(resMap, "code", 300);
Map data = MapUtils.getMap(resMap, "data", null);
if (200 != code) throw new RuntimeException();
Integer count = MapUtils.getInteger(data, "totalCount", 0);
Object list = MapUtils.getObject(data, "list", "");
return new TableDataInfo((List<?>) list, count);
}
}
...@@ -4,7 +4,6 @@ import cn.hutool.core.bean.BeanUtil; ...@@ -4,7 +4,6 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.map.MapUtil; import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.dsk.biz.domain.*; import com.dsk.biz.domain.*;
import com.dsk.biz.domain.bo.BusinessAddDto; import com.dsk.biz.domain.bo.BusinessAddDto;
import com.dsk.biz.domain.bo.BusinessExcelDto; import com.dsk.biz.domain.bo.BusinessExcelDto;
...@@ -13,8 +12,6 @@ import com.dsk.biz.domain.bo.CustomerBusinessSearchDto; ...@@ -13,8 +12,6 @@ import com.dsk.biz.domain.bo.CustomerBusinessSearchDto;
import com.dsk.biz.domain.vo.*; import com.dsk.biz.domain.vo.*;
import com.dsk.biz.utils.ExcelUtils; import com.dsk.biz.utils.ExcelUtils;
import com.dsk.biz.utils.OldFileUtils; import com.dsk.biz.utils.OldFileUtils;
import com.dsk.common.annotation.DataColumn;
import com.dsk.common.annotation.DataPermission;
import com.dsk.common.utils.file.FileUploadUtils; import com.dsk.common.utils.file.FileUploadUtils;
import com.dsk.jsk.service.EnterpriseService; import com.dsk.jsk.service.EnterpriseService;
import com.dsk.biz.mapper.BusinessInfoMapper; import com.dsk.biz.mapper.BusinessInfoMapper;
...@@ -30,7 +27,7 @@ import com.dsk.common.exception.ServiceException; ...@@ -30,7 +27,7 @@ import com.dsk.common.exception.ServiceException;
import com.dsk.common.exception.base.BaseException; import com.dsk.common.exception.base.BaseException;
import com.dsk.common.helper.LoginHelper; import com.dsk.common.helper.LoginHelper;
import com.dsk.common.utils.CheckUtils; import com.dsk.common.utils.CheckUtils;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.common.utils.JsonUtils; import com.dsk.common.utils.JsonUtils;
import com.dsk.common.utils.StringUtils; import com.dsk.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
......
...@@ -5,10 +5,8 @@ import com.dsk.biz.domain.bo.BusinessSearchDto; ...@@ -5,10 +5,8 @@ import com.dsk.biz.domain.bo.BusinessSearchDto;
import com.dsk.biz.domain.vo.BusinessAnalyzeVo; import com.dsk.biz.domain.vo.BusinessAnalyzeVo;
import com.dsk.biz.mapper.BusinessInfoMapper; import com.dsk.biz.mapper.BusinessInfoMapper;
import com.dsk.biz.service.IBusinessOverviewService; import com.dsk.biz.service.IBusinessOverviewService;
import com.dsk.common.annotation.DataColumn;
import com.dsk.common.annotation.DataPermission;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
......
...@@ -184,7 +184,8 @@ public class ExcelUtils<T> { ...@@ -184,7 +184,8 @@ public class ExcelUtils<T> {
createExcelField(); createExcelField();
createWorkbook(); createWorkbook();
createTitle(); createTitle();
createExportDate(); // createExportDate();
createExportMessage();
createSubHead(); createSubHead();
} }
...@@ -207,7 +208,25 @@ public class ExcelUtils<T> { ...@@ -207,7 +208,25 @@ public class ExcelUtils<T> {
sheet.addMergedRegion(new CellRangeAddress(titleRow.getRowNum(), titleRow.getRowNum(), titleRow.getRowNum(), titleLastCol)); sheet.addMergedRegion(new CellRangeAddress(titleRow.getRowNum(), titleRow.getRowNum(), titleRow.getRowNum(), titleLastCol));
} }
} }
public void createExportMessage() {
if (dateStatus) {
subMergedFirstRowNum++;
subMergedLastRowNum++;
int dateLastCol = this.fields.size() - 1;
if (isSubList()) {
dateLastCol = dateLastCol + subFields.size() - 1;
}
Row dateRow = sheet.createRow(rownum);
dateRow.setHeightInPoints(15);
Cell dateCell = dateRow.createCell(0);
CellStyle cellStyle = wb.createCellStyle();
cellStyle.setAlignment(HorizontalAlignment.LEFT);
dateCell.setCellStyle(cellStyle);
dateCell.setCellValue("* 免责声明:本数据内容是大司空接受您的委托,查询公开信息所得结果。大司空不对该查询结果的全面、准确、真实性负责。本数据仅为您的决策提供参考。因使用该数据信息而产生的任何后果,大司空概不负责。如需下载更多数据,请联系工作人员。");
sheet.addMergedRegion(new CellRangeAddress(dateRow.getRowNum(), dateRow.getRowNum(), 0, dateLastCol));
rownum++;
}
}
public void createExportDate() { public void createExportDate() {
if (dateStatus) { if (dateStatus) {
subMergedFirstRowNum++; subMergedFirstRowNum++;
......
...@@ -32,7 +32,7 @@ public class UrbanInvestmentExportVo implements Serializable { ...@@ -32,7 +32,7 @@ public class UrbanInvestmentExportVo implements Serializable {
@Excel(name = "供应商", width = 10) @Excel(name = "供应商", width = 10)
private Integer supplierCount; private Integer supplierCount;
@Excel(name = "债余额" , suffix = "亿元") @Excel(name = "债余额" , suffix = "亿元")
private Double creditBalance; private Double creditBalance;
@Excel(name = "主体评级", width = 15) @Excel(name = "主体评级", width = 15)
......
...@@ -3,7 +3,7 @@ ...@@ -3,7 +3,7 @@
//import cn.hutool.core.bean.BeanUtil; //import cn.hutool.core.bean.BeanUtil;
//import cn.hutool.json.JSONObject; //import cn.hutool.json.JSONObject;
//import com.dsk.common.core.domain.AjaxResult; //import com.dsk.common.core.domain.AjaxResult;
//import com.dsk.common.utils.DskOpenApiUtil; //import com.dsk.system.utils.DskOpenApiUtil;
//import com.dsk.jsk.domain.bo.ComposeQueryDto; //import com.dsk.jsk.domain.bo.ComposeQueryDto;
//import org.springframework.beans.factory.annotation.Autowired; //import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service; //import org.springframework.stereotype.Service;
......
...@@ -6,7 +6,7 @@ import cn.hutool.json.JSONUtil; ...@@ -6,7 +6,7 @@ import cn.hutool.json.JSONUtil;
import com.dsk.acc.openapi.client.util.CommonUtils; import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.common.core.domain.R; import com.dsk.common.core.domain.R;
import com.dsk.common.core.page.TableDataInfo; import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.jsk.domain.*; import com.dsk.jsk.domain.*;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
......
...@@ -4,7 +4,7 @@ import cn.hutool.core.bean.BeanUtil; ...@@ -4,7 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.map.MapUtil; import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.dsk.common.core.domain.R; import com.dsk.common.core.domain.R;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
......
...@@ -3,7 +3,7 @@ package com.dsk.jsk.service; ...@@ -3,7 +3,7 @@ package com.dsk.jsk.service;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import com.dsk.common.core.domain.R; import com.dsk.common.core.domain.R;
import com.dsk.common.core.page.TableDataInfo; import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.jsk.domain.*; import com.dsk.jsk.domain.*;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
......
...@@ -7,7 +7,7 @@ import cn.hutool.json.JSONUtil; ...@@ -7,7 +7,7 @@ import cn.hutool.json.JSONUtil;
import com.dsk.acc.openapi.client.util.CommonUtils; import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.common.core.domain.R; import com.dsk.common.core.domain.R;
import com.dsk.common.core.page.TableDataInfo; import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.jsk.domain.*; import com.dsk.jsk.domain.*;
import com.dsk.jsk.domain.bo.EnterpriseProjectImportantListDto; import com.dsk.jsk.domain.bo.EnterpriseProjectImportantListDto;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
......
...@@ -6,18 +6,14 @@ import cn.hutool.core.util.ObjectUtil; ...@@ -6,18 +6,14 @@ import cn.hutool.core.util.ObjectUtil;
import com.dsk.acc.openapi.client.util.CommonUtils; import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.biz.domain.vo.CustomerStatusListVo; import com.dsk.biz.domain.vo.CustomerStatusListVo;
import com.dsk.biz.service.ICustomerService; import com.dsk.biz.service.ICustomerService;
import com.dsk.biz.utils.ExcelUtils;
import com.dsk.common.constant.CacheConstants; import com.dsk.common.constant.CacheConstants;
import com.dsk.common.constant.Constants;
import com.dsk.common.core.domain.R; import com.dsk.common.core.domain.R;
import com.dsk.common.core.page.TableDataInfo; import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.common.utils.EncodeIdUtil; import com.dsk.common.utils.EncodeIdUtil;
import com.dsk.common.utils.redis.RedisUtils; import com.dsk.common.utils.redis.RedisUtils;
import com.dsk.component.UploadComponent; import com.dsk.component.UploadComponent;
import com.dsk.jsk.domain.*; import com.dsk.jsk.domain.*;
import com.dsk.jsk.domain.bo.UrbanInvestmentPlatformDto;
import com.dsk.jsk.domain.vo.UrbanInvestmentExportVo;
import com.dsk.search.service.BusinessOpportunityRadarService; import com.dsk.search.service.BusinessOpportunityRadarService;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
...@@ -25,11 +21,9 @@ import org.slf4j.Logger; ...@@ -25,11 +21,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils; import org.springframework.util.ObjectUtils;
import java.io.ByteArrayOutputStream;
import java.time.Duration; import java.time.Duration;
import java.util.*; import java.util.*;
......
...@@ -7,7 +7,7 @@ import cn.hutool.json.JSONObject; ...@@ -7,7 +7,7 @@ import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.utils.DateUtils; import com.dsk.common.utils.DateUtils;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
......
...@@ -2,43 +2,30 @@ package com.dsk.jsk.service; ...@@ -2,43 +2,30 @@ package com.dsk.jsk.service;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.biz.utils.ExcelUtils;
import com.dsk.common.constant.CacheConstants; import com.dsk.common.constant.CacheConstants;
import com.dsk.common.constant.Constants;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.core.domain.R; import com.dsk.common.core.domain.R;
import com.dsk.common.core.page.TableDataInfo; import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.exception.ServiceException; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.common.utils.DskOpenApiUtil;
import com.dsk.common.utils.JsonUtils; import com.dsk.common.utils.JsonUtils;
import com.dsk.common.utils.StringUtils;
import com.dsk.component.UploadComponent; import com.dsk.component.UploadComponent;
import com.dsk.jsk.domain.JskCombineBidPageDto; import com.dsk.jsk.domain.JskCombineBidPageDto;
import com.dsk.jsk.domain.JskCombineCertificateDto; import com.dsk.jsk.domain.JskCombineCertificateDto;
import com.dsk.jsk.domain.JskCombineCountDto; import com.dsk.jsk.domain.JskCombineCountDto;
import com.dsk.jsk.domain.JskCombineSearchDto; import com.dsk.jsk.domain.JskCombineSearchDto;
import com.dsk.jsk.domain.vo.JskCombineBidProjectExportVo;
import com.dsk.jsk.domain.vo.JskCombineWinBidProjectExportVo;
import com.dsk.jsk.domain.vo.UrbanInvestmentExportVo;
import com.dsk.jsk.util.RedisCache; import com.dsk.jsk.util.RedisCache;
import com.dsk.system.domain.SysUserFileRecord;
import com.dsk.system.service.ISysUserFileRecordService; import com.dsk.system.service.ISysUserFileRecordService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils; import org.springframework.util.ObjectUtils;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.io.ByteArrayOutputStream;
import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
......
...@@ -2,14 +2,12 @@ package com.dsk.jsk.service.service.impl; ...@@ -2,14 +2,12 @@ package com.dsk.jsk.service.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.common.constant.CacheConstants; import com.dsk.common.constant.CacheConstants;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.helper.LoginHelper; import com.dsk.common.helper.LoginHelper;
import com.dsk.common.utils.DateUtils; import com.dsk.common.utils.DateUtils;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.common.utils.JsonUtils; import com.dsk.common.utils.JsonUtils;
import com.dsk.jsk.domain.*;
import com.dsk.jsk.domain.bo.*; import com.dsk.jsk.domain.bo.*;
import com.dsk.jsk.service.service.EconomicService; import com.dsk.jsk.service.service.EconomicService;
import com.dsk.jsk.util.RedisCache; import com.dsk.jsk.util.RedisCache;
...@@ -18,7 +16,6 @@ import org.springframework.http.HttpStatus; ...@@ -18,7 +16,6 @@ import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.List;
import java.util.Map; import java.util.Map;
/** /**
......
...@@ -5,8 +5,7 @@ import cn.hutool.core.util.ObjectUtil; ...@@ -5,8 +5,7 @@ import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.dsk.acc.openapi.client.util.CommonUtils; import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.jsk.domain.bo.ComposeQueryDto;
import com.dsk.jsk.service.service.RegionalEnterprisesService; import com.dsk.jsk.service.service.RegionalEnterprisesService;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
......
...@@ -4,7 +4,7 @@ import cn.hutool.core.bean.BeanUtil; ...@@ -4,7 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.dsk.acc.openapi.client.util.CommonUtils; import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.jsk.domain.bo.SpecialBondInformationDetailsDto; import com.dsk.jsk.domain.bo.SpecialBondInformationDetailsDto;
import com.dsk.jsk.domain.bo.SpecialBondInformationPageDto; import com.dsk.jsk.domain.bo.SpecialBondInformationPageDto;
import com.dsk.jsk.domain.bo.SpecialPurposeBondsDto; import com.dsk.jsk.domain.bo.SpecialPurposeBondsDto;
......
package com.dsk.jsk.service.service.impl; package com.dsk.jsk.service.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.dsk.acc.openapi.client.util.CommonUtils; import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.biz.domain.vo.CustomerStatusListVo; import com.dsk.biz.domain.vo.CustomerStatusListVo;
import com.dsk.biz.service.ICustomerService; import com.dsk.biz.service.ICustomerService;
import com.dsk.biz.utils.ExcelUtils;
import com.dsk.common.constant.Constants;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.component.UploadComponent; import com.dsk.component.UploadComponent;
import com.dsk.jsk.domain.bo.UrbanInvestmentPlatformDto; import com.dsk.jsk.domain.bo.UrbanInvestmentPlatformDto;
import com.dsk.jsk.domain.vo.ImportantProjectExportVo;
import com.dsk.jsk.domain.vo.UrbanInvestmentExportVo;
import com.dsk.jsk.service.service.UrbanInvestmentPlatformService; import com.dsk.jsk.service.service.UrbanInvestmentPlatformService;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.io.ByteArrayOutputStream;
import java.util.*; import java.util.*;
/** /**
......
...@@ -59,6 +59,7 @@ public class ExportController { ...@@ -59,6 +59,7 @@ public class ExportController {
if (StringUtils.isEmpty(compose.getExportExeclName())){ if (StringUtils.isEmpty(compose.getExportExeclName())){
object.put("exportExeclName","企业基本信息导出"); object.put("exportExeclName","企业基本信息导出");
} }
object.put("exportTemplateName","szh-enterprise-info.xlsx");
return exportService.enterpriseInfoExport(object); return exportService.enterpriseInfoExport(object);
} }
...@@ -76,6 +77,7 @@ public class ExportController { ...@@ -76,6 +77,7 @@ public class ExportController {
if (StringUtils.isEmpty(compose.getExportExeclName())){ if (StringUtils.isEmpty(compose.getExportExeclName())){
object.put("exportExeclName","企业资质信息导出"); object.put("exportExeclName","企业资质信息导出");
} }
object.put("exportTemplateName","szh-cert-info.xlsx");
return exportService.enterpriseAptitudeExport(object); return exportService.enterpriseAptitudeExport(object);
} }
...@@ -124,7 +126,7 @@ public class ExportController { ...@@ -124,7 +126,7 @@ public class ExportController {
} }
//市场经济 城投平台导出 //市场经济 城投平台导出
@PostMapping("/urbanInvestmentPlatform") @PostMapping("/urbanInvestment")
public AjaxResult export(@RequestBody UrbanInvestmentPlatformDto dto) { public AjaxResult export(@RequestBody UrbanInvestmentPlatformDto dto) {
return exportService.export(dto); return exportService.export(dto);
} }
......
package com.dsk.search.service; package com.dsk.search.service;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.map.MapUtil; import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
...@@ -9,21 +8,17 @@ import com.dsk.acc.openapi.client.util.CommonUtils; ...@@ -9,21 +8,17 @@ import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.biz.domain.vo.CustomerStatusListVo; import com.dsk.biz.domain.vo.CustomerStatusListVo;
import com.dsk.biz.service.ICustomerService; import com.dsk.biz.service.ICustomerService;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.exception.ServiceException; import com.dsk.common.exception.ServiceException;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.common.utils.StringUtils; import com.dsk.common.utils.StringUtils;
import com.dsk.jsk.domain.vo.ImportantProjectExportVo; import com.dsk.jsk.domain.vo.ImportantProjectExportVo;
import com.dsk.jsk.service.EnterpriseService; import com.dsk.jsk.service.EnterpriseService;
import com.dsk.system.domain.SysUserFileRecord;
import com.dsk.system.service.ISysUserFileRecordService; import com.dsk.system.service.ISysUserFileRecordService;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
......
...@@ -7,7 +7,7 @@ import com.dsk.acc.openapi.client.util.CommonUtils; ...@@ -7,7 +7,7 @@ import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.biz.utils.ExcelUtils; import com.dsk.biz.utils.ExcelUtils;
import com.dsk.common.constant.Constants; import com.dsk.common.constant.Constants;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.component.UploadComponent; import com.dsk.component.UploadComponent;
import com.dsk.jsk.domain.EnterpriseUipSearchBody; import com.dsk.jsk.domain.EnterpriseUipSearchBody;
import com.dsk.jsk.domain.JskCombineSearchDto; import com.dsk.jsk.domain.JskCombineSearchDto;
...@@ -139,8 +139,6 @@ public class ExportService { ...@@ -139,8 +139,6 @@ public class ExportService {
return AjaxResult.success(); return AjaxResult.success();
} }
@Async
public AjaxResult uipSerachExport(EnterpriseUipSearchBody pageDto) { public AjaxResult uipSerachExport(EnterpriseUipSearchBody pageDto) {
// 分页参数 // 分页参数
pageDto.setPageNum(1); pageDto.setPageNum(1);
...@@ -153,7 +151,7 @@ public class ExportService { ...@@ -153,7 +151,7 @@ public class ExportService {
throw new RuntimeException(); throw new RuntimeException();
} }
List<Object> list = CommonUtils.assertAsArray(MapUtils.getObject(map, "data", "")); List<Object> list = CommonUtils.assertAsArray(MapUtils.getObject(map, "data", ""));
int i = 0; int i = 1;
List<UrbanInvestmentExportVo> resultList = new ArrayList<>(); List<UrbanInvestmentExportVo> resultList = new ArrayList<>();
for (Object obj : list) { for (Object obj : list) {
UrbanInvestmentExportVo vo = new UrbanInvestmentExportVo(); UrbanInvestmentExportVo vo = new UrbanInvestmentExportVo();
...@@ -214,7 +212,6 @@ public class ExportService { ...@@ -214,7 +212,6 @@ public class ExportService {
return AjaxResult.success(); return AjaxResult.success();
} }
@Async
public AjaxResult export(UrbanInvestmentPlatformDto pageDto) { public AjaxResult export(UrbanInvestmentPlatformDto pageDto) {
// 分页参数 // 分页参数
pageDto.setPageNum(1); pageDto.setPageNum(1);
...@@ -228,7 +225,7 @@ public class ExportService { ...@@ -228,7 +225,7 @@ public class ExportService {
throw new RuntimeException(); throw new RuntimeException();
} }
List<Object> list = CommonUtils.assertAsArray(MapUtils.getObject(map, "data", "")); List<Object> list = CommonUtils.assertAsArray(MapUtils.getObject(map, "data", ""));
int i = 0; int i = 1;
List<UrbanInvestmentExportVo> resultList = new ArrayList<>(); List<UrbanInvestmentExportVo> resultList = new ArrayList<>();
for (Object obj : list) { for (Object obj : list) {
UrbanInvestmentExportVo vo = new UrbanInvestmentExportVo(); UrbanInvestmentExportVo vo = new UrbanInvestmentExportVo();
...@@ -256,7 +253,7 @@ public class ExportService { ...@@ -256,7 +253,7 @@ public class ExportService {
//供应商 //供应商
vo.setSupplierCount(MapUtil.getInt(dataMap, "supplierCount")); vo.setSupplierCount(MapUtil.getInt(dataMap, "supplierCount"));
//债卷余额 //债卷余额
vo.setCreditBalance(MapUtil.getDouble(dataMap, "creditBalance")); vo.setCreditBalance(MapUtil.getDouble(dataMap, "bondBalance"));
//主体评级 //主体评级
vo.setBratingSubjectLevel(MapUtil.getStr(dataMap, "bratingSubjectLevel")); vo.setBratingSubjectLevel(MapUtil.getStr(dataMap, "bratingSubjectLevel"));
//行政级别 //行政级别
......
...@@ -3,7 +3,7 @@ package com.dsk.search.service; ...@@ -3,7 +3,7 @@ package com.dsk.search.service;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.dsk.common.core.domain.AjaxResult; import com.dsk.common.core.domain.AjaxResult;
import com.dsk.common.utils.DskOpenApiUtil; import com.dsk.system.utils.DskOpenApiUtil;
import com.dsk.jsk.service.EnterpriseService; import com.dsk.jsk.service.EnterpriseService;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
......
...@@ -185,11 +185,11 @@ ...@@ -185,11 +185,11 @@
dialogExportVisible:false, dialogExportVisible:false,
forData: [ forData: [
{label: '企业名称', prop: 'companyName',slot: true,minWidth: '250'}, {label: '企业名称', prop: 'companyName',slot: true,minWidth: '250'},
// {label: '科技型企业', prop: 'companyName', slot: true,minWidth: '160'}, {label: '科技型企业', prop: 'kjxqy', slot: true,minWidth: '160'},
{label: '成员层级', prop: 'combineMemberLevel',slot: true,minWidth: '100'}, {label: '成员层级', prop: 'combineMemberLevel',slot: true,minWidth: '100'},
// {label: '主营业务', prop: 'projectName', slot: true,minWidth: '260'}, // {label: '主营业务', prop: 'projectName', slot: true,minWidth: '260'},
{label: '法定代表人', prop: 'corporatePerson',slot: true,minWidth: '100'}, {label: '法定代表人', prop: 'corporatePerson',slot: true,minWidth: '100'},
{label: '企业地区', prop: 'address',minWidth: '120'}, {label: '工商注册地', prop: 'address',minWidth: '120'},
{label: '注册资本', prop: 'regCapital',minWidth: '150'}, {label: '注册资本', prop: 'regCapital',minWidth: '150'},
{label: '持股比例', prop: 'stockPercent',minWidth: '100'}, {label: '持股比例', prop: 'stockPercent',minWidth: '100'},
{label: '成立日期', prop: 'registeredDate', slot: true,minWidth: '100'}, {label: '成立日期', prop: 'registeredDate', slot: true,minWidth: '100'},
...@@ -197,6 +197,7 @@ ...@@ -197,6 +197,7 @@
exportTableData:[ exportTableData:[
{ {
companyName:'XXX集团有限公司', companyName:'XXX集团有限公司',
kjxqy:'高新技术企业',
combineMemberLevel:'集团本身', combineMemberLevel:'集团本身',
corporatePerson:'柳xx', corporatePerson:'柳xx',
regCapital:'8000.0万元', regCapital:'8000.0万元',
...@@ -206,6 +207,7 @@ ...@@ -206,6 +207,7 @@
}, },
{ {
companyName:'XXX集团有限公司', companyName:'XXX集团有限公司',
kjxqy:'科技型中小企业',
combineMemberLevel:'一级企业', combineMemberLevel:'一级企业',
corporatePerson:'江xx', corporatePerson:'江xx',
regCapital:'14000.0万元', regCapital:'14000.0万元',
...@@ -299,8 +301,8 @@ ...@@ -299,8 +301,8 @@
this.isSkeleton = false this.isSkeleton = false
this.tableLoading = false this.tableLoading = false
if(res.code === 200){ if(res.code === 200){
this.tableData = res.rows this.tableData = res.data.list
this.tableDataTotal = res.total this.tableDataTotal = res.data.total
}else { }else {
this.tableData = [] this.tableData = []
} }
...@@ -493,6 +495,8 @@ ...@@ -493,6 +495,8 @@
memberListExport(this.dataEXCEL).then(res=>{ memberListExport(this.dataEXCEL).then(res=>{
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
}, },
......
...@@ -327,6 +327,8 @@ ...@@ -327,6 +327,8 @@
exportWinBid(this.dataEXCEL).then(res=>{ exportWinBid(this.dataEXCEL).then(res=>{
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
}, },
......
...@@ -303,6 +303,8 @@ ...@@ -303,6 +303,8 @@
exportBid(this.dataEXCEL).then(res=>{ exportBid(this.dataEXCEL).then(res=>{
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
}, },
......
...@@ -78,7 +78,7 @@ ...@@ -78,7 +78,7 @@
</template> </template>
<div v-else class="flex-box"> <div v-else class="flex-box">
<span class="flex-box ability-total" v-if="isTotal">共有{{ total }}条</span> <span class="flex-box ability-total" v-if="isTotal">共有{{ total }}条</span>
<span class="flex-box ability-excel" v-hasPermi="['combine:info:export:win:bid','combine:info:export:bid']" v-if="isExcel && title ==='集团业绩'|| title ==='集团业绩' " <span class="flex-box ability-excel" v-hasPermi="['combine:info:export:win:bid','combine:info:export:bid']" v-if="isExcel && title ==='集团业绩'|| title ==='集团招标' "
@click="clickEXCEL"><img src="@/assets/images/ability_excel.png">导出EXCEL</span> @click="clickEXCEL"><img src="@/assets/images/ability_excel.png">导出EXCEL</span>
<span class="flex-box ability-excel" v-else @click="clickEXCEL"><img src="@/assets/images/ability_excel.png">导出EXCEL</span> <span class="flex-box ability-excel" v-else @click="clickEXCEL"><img src="@/assets/images/ability_excel.png">导出EXCEL</span>
</div> </div>
......
...@@ -571,7 +571,7 @@ export default { ...@@ -571,7 +571,7 @@ export default {
{label: '实控人', prop: 'actualController', slot: true,minWidth: '140'}, {label: '实控人', prop: 'actualController', slot: true,minWidth: '140'},
{label: '最新报告期', prop: 'latestReportPeriod', slot: true,minWidth: '120'}, {label: '最新报告期', prop: 'latestReportPeriod', slot: true,minWidth: '120'},
{label: '总资产(亿元)', prop: 'totalAssets', slot: true,minWidth: '120'}, {label: '总资产(亿元)', prop: 'totalAssets', slot: true,minWidth: '120'},
{label: '归母净资产', prop: 'belongNetAssets', slot: true,minWidth: '120'}, {label: '归母净资产(亿元)', prop: 'belongNetAssets', slot: true,minWidth: '140'},
], ],
exportTableData:[ exportTableData:[
{ {
...@@ -1006,13 +1006,15 @@ export default { ...@@ -1006,13 +1006,15 @@ export default {
} }
this.dataEXCEL.exportExeclName=this.exportData.title; this.dataEXCEL.exportExeclName=this.exportData.title;
if(value){ if(value){
this.dataEXCEL.exportCount=value this.dataEXCEL.pageSize=value
}else { }else {
this.dataEXCEL.exportCount=2000; this.dataEXCEL.pageSize=2000;
} }
api.uipSerachExport(this.dataEXCEL).then(res => { api.uipSerachExport(this.dataEXCEL).then(res => {
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
}, },
......
...@@ -3054,6 +3054,8 @@ export default { ...@@ -3054,6 +3054,8 @@ export default {
api.aptitudeExport(this.dataEXCEL).then(res => { api.aptitudeExport(this.dataEXCEL).then(res => {
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
} }
...@@ -3061,6 +3063,8 @@ export default { ...@@ -3061,6 +3063,8 @@ export default {
api.infoExport(this.dataEXCEL).then(res => { api.infoExport(this.dataEXCEL).then(res => {
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
} }
......
...@@ -363,7 +363,7 @@ export default { ...@@ -363,7 +363,7 @@ export default {
{label: '实控人', prop: 'actualController', slot: true,minWidth: '140'}, {label: '实控人', prop: 'actualController', slot: true,minWidth: '140'},
{label: '最新报告期', prop: 'latestReportPeriod', slot: true,minWidth: '120'}, {label: '最新报告期', prop: 'latestReportPeriod', slot: true,minWidth: '120'},
{label: '总资产(亿元)', prop: 'totalAssets', slot: true,minWidth: '120'}, {label: '总资产(亿元)', prop: 'totalAssets', slot: true,minWidth: '120'},
{label: '归母净资产', prop: 'belongNetAssets', slot: true,minWidth: '120'}, {label: '归母净资产(亿元)', prop: 'belongNetAssets', slot: true,minWidth: '140'},
], ],
exportTableData:[ exportTableData:[
{ {
...@@ -853,13 +853,15 @@ export default { ...@@ -853,13 +853,15 @@ export default {
} }
this.dataEXCEL.exportExeclName=this.exportData.title; this.dataEXCEL.exportExeclName=this.exportData.title;
if(value){ if(value){
this.dataEXCEL.exportCount=value this.dataEXCEL.pageSize=value
}else { }else {
this.dataEXCEL.exportCount=2000; this.dataEXCEL.pageSize=2000;
} }
urbanInvestmentExport(this.dataEXCEL).then(res=>{ urbanInvestmentExport(this.dataEXCEL).then(res=>{
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
}, },
......
...@@ -698,6 +698,8 @@ export default { ...@@ -698,6 +698,8 @@ export default {
api.radarExport(this.dataEXCEL).then(res => { api.radarExport(this.dataEXCEL).then(res => {
if(res.code === 200){ if(res.code === 200){
this.exportData.exportEXCEL=true; this.exportData.exportEXCEL=true;
}else {
this.$message.error(res.msg);
} }
}) })
}, },
......
...@@ -86,7 +86,7 @@ ...@@ -86,7 +86,7 @@
<el-pagination background :current-page="params.pageNum" :page-size="params.pageSize" :total="tableDataTotal" layout="prev, pager, next, jumper" @current-change="handleCurrentChange" @size-change="handleSizeChange" /> <el-pagination background :current-page="params.pageNum" :page-size="params.pageSize" :total="tableDataTotal" layout="prev, pager, next, jumper" @current-change="handleCurrentChange" @size-change="handleSizeChange" />
</div> </div>
<div class="tables"> <div class="tables">
<div class="empty" v-if="tableDataTotal==0"> <div class="empty" v-if="tableDataTotal==0 && !isSkeleton">
<img class="img" src="@/assets/images/project/empty.png"> <img class="img" src="@/assets/images/project/empty.png">
<div class="p1">暂无数据展示</div> <div class="p1">暂无数据展示</div>
</div> </div>
......
...@@ -418,9 +418,9 @@ public class SysRoleServiceImpl implements ISysRoleService { ...@@ -418,9 +418,9 @@ public class SysRoleServiceImpl implements ISysRoleService {
int rows = userRoleMapper.delete(new LambdaQueryWrapper<SysUserRole>() int rows = userRoleMapper.delete(new LambdaQueryWrapper<SysUserRole>()
.eq(SysUserRole::getRoleId, userRole.getRoleId()) .eq(SysUserRole::getRoleId, userRole.getRoleId())
.eq(SysUserRole::getUserId, userRole.getUserId())); .eq(SysUserRole::getUserId, userRole.getUserId()));
if (rows > 0) { //if (rows > 0) {
cleanOnlineUserByRole(userRole.getRoleId()); // cleanOnlineUserByRole(userRole.getRoleId());
} //}
return rows; return rows;
} }
...@@ -456,9 +456,9 @@ public class SysRoleServiceImpl implements ISysRoleService { ...@@ -456,9 +456,9 @@ public class SysRoleServiceImpl implements ISysRoleService {
int rows = userRoleMapper.delete(new LambdaQueryWrapper<SysUserRole>() int rows = userRoleMapper.delete(new LambdaQueryWrapper<SysUserRole>()
.eq(SysUserRole::getRoleId, roleId) .eq(SysUserRole::getRoleId, roleId)
.in(SysUserRole::getUserId, Arrays.asList(userIds))); .in(SysUserRole::getUserId, Arrays.asList(userIds)));
if (rows > 0) { //if (rows > 0) {
cleanOnlineUserByRole(roleId); // cleanOnlineUserByRole(roleId);
} //}
return rows; return rows;
} }
...@@ -515,9 +515,9 @@ public class SysRoleServiceImpl implements ISysRoleService { ...@@ -515,9 +515,9 @@ public class SysRoleServiceImpl implements ISysRoleService {
if (CollUtil.isNotEmpty(list)) { if (CollUtil.isNotEmpty(list)) {
rows = userRoleMapper.insertBatch(list) ? list.size() : 0; rows = userRoleMapper.insertBatch(list) ? list.size() : 0;
} }
if (rows > 0) { //if (rows > 0) {
cleanOnlineUserByRole(roleId); // cleanOnlineUserByRole(roleId);
} //}
return rows; return rows;
} }
......
package com.dsk.system.utils;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.dsk.acc.openapi.api.AccClient;
import com.dsk.acc.openapi.client.Config;
import com.dsk.acc.openapi.client.util.CommonUtils;
import com.dsk.common.config.DskOpenApiConfig;
import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.exception.ServiceException;
import com.dsk.system.domain.SysConfig;
import com.dsk.system.mapper.SysConfigMapper;
import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;
import javax.annotation.Resource;
import java.lang.reflect.Field;
import java.util.List;
import java.util.Map;
@Component
public class DskOpenApiUtil {
private static Config config;
@Resource
private SysConfigMapper sysConfigMapper;
/**
* <b>application/json请求</b>
*
* @param path 请求路径
* @param bodyMap 参数体
* @return
*/
public Map<String, Object> requestBody(String path, Map<String, Object> bodyMap) {
return request(path, bodyMap, "json");
}
public Map<String, Object> requestBodyLocal(String path, Map<String, Object> bodyMap) {
String post = HttpUtil.post("http://127.0.0.1:8766" + path, JSONUtil.toJsonStr(bodyMap));
return CommonUtils.assertAsMap(CommonUtils.parseJSON(post));
}
public Map<String, Object> requestBodyWithHeader(String path, Map<String, Object> bodyMap, Map<String, String> headerMap) {
return requestWithHeader(path, bodyMap, "json", headerMap);
}
/**
* <b>application/x-www-form-urlencoded请求</b>
*
* @param path 请求路径
* @param bodyMap 参数体
* @return
*/
public Map<String, Object> requestForm(String path, Map<String, Object> bodyMap) {
return request(path, bodyMap, "form");
}
/**
* <b>开放平台统一请求</b>
*
* @param path 请求路径
* @param bodyMap 参数体
* @param reqBodyType 请求格式
* @return
*/
public Map<String, Object> request(String path, Map<String, Object> bodyMap, String reqBodyType) {
try {
if (ObjectUtils.isEmpty(config)) initApiConfig();
AccClient.init(config);
Map<String, ?> res = AccClient.request(reqBodyType, path, bodyMap);
if (!res.containsKey("headers") || !res.containsKey("body")) {
throw new RuntimeException(String.format("请求无返回:path=%s", path));
}
Object resBody = res.get("body");
if (resBody == null) {
return null;
}
return CommonUtils.assertAsMap(resBody);
} catch (Exception e) {
throw new RuntimeException(String.format("请求异常:path=%s,err=%s", path, e.getMessage()));
}
}
/**
* <b>开放平台统一请求</b>
*
* @param path 请求路径
* @param bodyMap 参数体
* @param reqBodyType 请求格式
* @return
*/
public Map<String, Object> requestWithHeader(String path, Map<String, Object> bodyMap, String reqBodyType, Map<String, String> headerMap) {
try {
if (ObjectUtils.isEmpty(config)) initApiConfig();
AccClient.init(config);
Map<String, ?> res = AccClient.request(reqBodyType, path, bodyMap, headerMap);
if (!res.containsKey("headers") || !res.containsKey("body")) {
throw new RuntimeException(String.format("请求无返回:path=%s", path));
}
Object resBody = res.get("body");
if (resBody == null) {
return null;
}
return CommonUtils.assertAsMap(resBody);
} catch (Exception e) {
throw new RuntimeException(String.format("请求异常:path=%s,err=%s", path, e.getMessage()));
}
}
public TableDataInfo responsePage(Map<String, Object> resMap) throws Exception {
Integer code = MapUtils.getInteger(resMap, "code", 300);
Map data = MapUtils.getMap(resMap, "data", null);
if (200 != code) throw new RuntimeException();
Integer count = MapUtils.getInteger(data, "totalCount", 0);
Object list = MapUtils.getObject(data, "list", "");
return new TableDataInfo((List<?>) list, count);
}
private void initApiConfig() throws Exception {
DskOpenApiConfig dskOpenApiConfig = new DskOpenApiConfig();
Class<DskOpenApiConfig> clazz = DskOpenApiConfig.class;
Field[] fields = clazz.getDeclaredFields();
for (int i = 0; i < fields.length; i++) {
fields[i].setAccessible(true);
SysConfig config = sysConfigMapper.selectOne(Wrappers.<SysConfig>lambdaQuery().eq(SysConfig::getConfigKey, "plugIn-".concat(fields[i].getName())));
fields[i].set(dskOpenApiConfig, config.getConfigValue());
}
if (ObjectUtils.isEmpty(dskOpenApiConfig)) {
throw new ServiceException("DskOpenApiConfig 初始化失败!");
}
config = new Config(dskOpenApiConfig.accessKeyId, dskOpenApiConfig.accessKeySecret)
.setEndpoint(dskOpenApiConfig.endPoint);
}
}
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