|
|
|
|
@ -4,18 +4,23 @@ import cn.hutool.core.bean.BeanUtil;
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
|
import cn.hutool.core.io.file.FileWriter;
|
|
|
|
|
import cn.hutool.core.util.ReflectUtil;
|
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
|
|
import com.glxp.sale.admin.constant.BasicProcessStatus;
|
|
|
|
|
import com.glxp.sale.admin.constant.ConstantStatus;
|
|
|
|
|
import com.glxp.sale.admin.dao.basic.UdiInfoDao;
|
|
|
|
|
import com.glxp.sale.admin.dao.basic.UdiRelevanceDao;
|
|
|
|
|
import com.glxp.sale.admin.dao.thrsys.ThrCorpDao;
|
|
|
|
|
import com.glxp.sale.admin.dao.thrsys.ThrProductsDao;
|
|
|
|
|
import com.glxp.sale.admin.entity.basic.*;
|
|
|
|
|
import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity;
|
|
|
|
|
import com.glxp.sale.admin.entity.thrsys.ThrCorpEntity;
|
|
|
|
|
import com.glxp.sale.admin.entity.thrsys.ThrProductsEntity;
|
|
|
|
|
import com.glxp.sale.admin.req.basic.*;
|
|
|
|
|
import com.glxp.sale.admin.req.info.FilterCompanyProductRelevanceRequest;
|
|
|
|
|
import com.glxp.sale.admin.req.thrsys.FilterThrCorpRequest;
|
|
|
|
|
import com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest;
|
|
|
|
|
import com.glxp.sale.admin.res.basic.BasicUnitMaintainExportResponse;
|
|
|
|
|
import com.glxp.sale.admin.res.basic.UdiExportJsonResponse;
|
|
|
|
|
import com.glxp.sale.admin.res.basic.UdiRelevanceExportJsonResponse;
|
|
|
|
|
import com.glxp.sale.admin.res.basic.UdiRelevanceResponse;
|
|
|
|
|
@ -57,35 +62,73 @@ public class BasicGenExcelService {
|
|
|
|
|
private CompanyProductRelevanceService companyProductRelevanceService;
|
|
|
|
|
@Resource
|
|
|
|
|
ThrProductsDao thrProductsDao;
|
|
|
|
|
@Resource
|
|
|
|
|
ThrCorpDao thrCorpDao;
|
|
|
|
|
|
|
|
|
|
//往来单位
|
|
|
|
|
@Async
|
|
|
|
|
public void exportCorp(String genKey, CorpsExportRequest corpsExportRequest) {
|
|
|
|
|
|
|
|
|
|
CorpExportLogEntity corpExportLogEntity = corpExportLogService.selectByGenKey(genKey);
|
|
|
|
|
List<BasicUnitMaintainEntity> exportData = new ArrayList<>();
|
|
|
|
|
BasicUnitMaintainExportResponse exportData = new BasicUnitMaintainExportResponse();
|
|
|
|
|
|
|
|
|
|
List<BasicUnitMaintainEntity> unitMaintainEntities = new ArrayList<>();
|
|
|
|
|
if (corpsExportRequest.getIds() != null && corpsExportRequest.getIds().size() > 0) {
|
|
|
|
|
List<Integer> ids = corpsExportRequest.getIds();
|
|
|
|
|
ids.forEach(id -> {
|
|
|
|
|
BasicUnitMaintainFilterRequest request = new BasicUnitMaintainFilterRequest();
|
|
|
|
|
request.setId(id);
|
|
|
|
|
List<BasicUnitMaintainEntity> basicUnitMaintainEntities = basicUnitMaintainService.filterList(request);
|
|
|
|
|
exportData.addAll(basicUnitMaintainEntities);
|
|
|
|
|
unitMaintainEntities.addAll(basicUnitMaintainEntities);
|
|
|
|
|
getThrCorpList(exportData, basicUnitMaintainEntities);
|
|
|
|
|
});
|
|
|
|
|
} else { //一键导出
|
|
|
|
|
BasicUnitMaintainFilterRequest filterRequest = new BasicUnitMaintainFilterRequest();
|
|
|
|
|
BeanUtils.copyProperties(corpsExportRequest, filterRequest);
|
|
|
|
|
filterRequest.setPage(null);
|
|
|
|
|
List<BasicUnitMaintainEntity> basicUnitMaintainEntities = basicUnitMaintainService.filterList(filterRequest);
|
|
|
|
|
exportData.addAll(basicUnitMaintainEntities);
|
|
|
|
|
unitMaintainEntities.addAll(basicUnitMaintainEntities);
|
|
|
|
|
getThrCorpList(exportData, basicUnitMaintainEntities);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
exportData.setCorpList(unitMaintainEntities);
|
|
|
|
|
FileWriter writer = new FileWriter(corpExportLogEntity.getFilePath());
|
|
|
|
|
writer.write(JSONUtil.toJsonStr(exportData));
|
|
|
|
|
corpExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS);
|
|
|
|
|
corpExportLogService.updateCorpExportLog(corpExportLogEntity);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 查询第三方往来单位信息
|
|
|
|
|
*
|
|
|
|
|
* @param exportData
|
|
|
|
|
* @param basicUnitMaintainEntities
|
|
|
|
|
*/
|
|
|
|
|
private void getThrCorpList(BasicUnitMaintainExportResponse exportData, List<BasicUnitMaintainEntity> basicUnitMaintainEntities) {
|
|
|
|
|
if (CollUtil.isNotEmpty(basicUnitMaintainEntities)) {
|
|
|
|
|
List<ThrCorpEntity> thrCorpEntities = new ArrayList<>();
|
|
|
|
|
Field[] fields = ReflectUtil.getFields(BasicUnitMaintainEntity.class);
|
|
|
|
|
basicUnitMaintainEntities.forEach(basicUnitMaintainEntity -> {
|
|
|
|
|
for (Field field : fields) {
|
|
|
|
|
if (field.getName().contains("thirdId")) {
|
|
|
|
|
String value = String.valueOf(ReflectUtil.getFieldValue(basicUnitMaintainEntity, field));
|
|
|
|
|
if (StrUtil.isNotBlank(value)) {
|
|
|
|
|
FilterThrCorpRequest thrCorpRequest = new FilterThrCorpRequest();
|
|
|
|
|
thrCorpRequest.setThirdSysFk("thirdId");
|
|
|
|
|
thrCorpRequest.setUnitId(value);
|
|
|
|
|
List<ThrCorpEntity> result = thrCorpDao.filterThrCorps(thrCorpRequest);
|
|
|
|
|
if (CollUtil.isNotEmpty(result)) {
|
|
|
|
|
thrCorpEntities.addAll(result);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
if (CollUtil.isNotEmpty(thrCorpEntities)) {
|
|
|
|
|
exportData.setThrCorpEntities(thrCorpEntities);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Async
|
|
|
|
|
public void uploadCorpSmp(String genKey, CorpsExportRequest corpsExportRequest) {
|
|
|
|
|
PostCorpsRequest postCorpsRequest = new PostCorpsRequest();
|
|
|
|
|
|
MrZhai
3 years ago