采购合同导入
This commit is contained in:
zhanghuibin
parent
6e269c3939
commit
784b372f92
|
|
@ -27,6 +27,7 @@ import com.ruoyi.contract.service.IConPurchaseService;
|
|||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.validation.annotation.Validated;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
import javax.validation.constraints.NotEmpty;
|
||||
|
|
@ -209,4 +210,15 @@ public class ConPurchaseController extends BaseController {
|
|||
public R<Void> updateAllStatic() {
|
||||
return toAjax(iConPurchaseService.updatePurchaseDaysOverdue());
|
||||
}
|
||||
|
||||
// @Log(title = "采购合同", businessType = BusinessType.IMPORT)
|
||||
// @SaCheckPermission("system:purchase:import")
|
||||
@PostMapping("/importData")
|
||||
public R<Integer> importData(MultipartFile file) {
|
||||
try {
|
||||
return R.ok(iConPurchaseService.importPurchase(file));
|
||||
} catch (Exception e) {
|
||||
return R.fail("导入失败");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,114 @@
|
|||
package com.ruoyi.contract.domain.vo;
|
||||
|
||||
import cn.hutool.core.annotation.Alias;
|
||||
import lombok.Data;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* 采购合同导入VO
|
||||
*
|
||||
* @author ruoyi
|
||||
* @date 2024-06-07
|
||||
*/
|
||||
@Data
|
||||
public class ConPurchaseImportVO {
|
||||
|
||||
@Alias("客户名称")
|
||||
private String clientName;
|
||||
|
||||
@Alias("优客项目编号")
|
||||
private String projNumber;
|
||||
|
||||
@Alias("合同编号")
|
||||
private String contractNumber;
|
||||
|
||||
@Alias("项目名称")
|
||||
private String projName;
|
||||
|
||||
@Alias("城市")
|
||||
private String cityName;
|
||||
|
||||
@Alias("发布开始时间")
|
||||
private Date startTime;
|
||||
|
||||
@Alias("发布结束时间")
|
||||
private Date endTime;
|
||||
|
||||
@Alias("发布周期（天）")
|
||||
private String publishDays;
|
||||
|
||||
@Alias("媒体类型")
|
||||
private String mediaType;
|
||||
|
||||
@Alias("媒体位置")
|
||||
private String mediaLocation;
|
||||
|
||||
@Alias("采购数量")
|
||||
private String purchaseQuantity;
|
||||
|
||||
@Alias("频次")
|
||||
private String frequency;
|
||||
|
||||
@Alias("刊例价")
|
||||
private String listPrice;
|
||||
|
||||
@Alias("刊例价单位")
|
||||
private String listPriceUnit;
|
||||
|
||||
@Alias("折扣")
|
||||
private String discount;
|
||||
|
||||
@Alias("净价")
|
||||
private String netPrice;
|
||||
|
||||
@Alias("净价单位")
|
||||
private String netPriceUnit;
|
||||
|
||||
@Alias("制作费")
|
||||
private String productionFee;
|
||||
|
||||
@Alias("合同总金额")
|
||||
private Double contractMoney;
|
||||
|
||||
@Alias("甲方名称")
|
||||
private String firstName;
|
||||
|
||||
@Alias("供应商名称")
|
||||
private String supplierName;
|
||||
|
||||
@Alias("媒介部门")
|
||||
private String mediaDeptName;
|
||||
|
||||
@Alias("发票类型")
|
||||
private String invoiceType;
|
||||
|
||||
@Alias("税率")
|
||||
private String taxRate;
|
||||
|
||||
@Alias("发票内容")
|
||||
private String invoiceContent;
|
||||
|
||||
@Alias("签订日期")
|
||||
private Date signTime;
|
||||
|
||||
@Alias("合同附件")
|
||||
private String contractAccess;
|
||||
|
||||
@Alias("上刊")
|
||||
private String upPrint;
|
||||
|
||||
@Alias("换刊")
|
||||
private String exchangePrint;
|
||||
|
||||
@Alias("下刊")
|
||||
private String nextPrint;
|
||||
|
||||
@Alias("媒体链条")
|
||||
private String mediaLink;
|
||||
|
||||
@Alias("附件")
|
||||
private String attachment;
|
||||
|
||||
@Alias("状态")
|
||||
private String state;
|
||||
}
|
||||
|
|
@ -1,11 +1,11 @@
|
|||
package com.ruoyi.contract.service;
|
||||
|
||||
import com.ruoyi.contract.domain.ConPurchase;
|
||||
import com.ruoyi.contract.domain.bo.conpurchase.ConPurchaseBoExtend;
|
||||
import com.ruoyi.contract.domain.vo.ConPurchaseVo;
|
||||
import com.ruoyi.contract.domain.bo.ConPurchaseBo;
|
||||
import com.ruoyi.common.core.page.TableDataInfo;
|
||||
import com.ruoyi.common.core.domain.PageQuery;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
import java.util.Collection;
|
||||
|
|
@ -98,4 +98,13 @@ public interface IConPurchaseService {
|
|||
* @return 列表内容
|
||||
*/
|
||||
void dynamicexportUpgrade(String fieldName, String mediaFieldName, String ids, HttpServletResponse response);
|
||||
|
||||
/**
|
||||
* 导入采购合同
|
||||
*
|
||||
* @param file 导入文件
|
||||
* @return 结果
|
||||
* @throws Exception
|
||||
*/
|
||||
int importPurchase(MultipartFile file);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -6,6 +6,7 @@ import cn.hutool.core.collection.CollectionUtil;
|
|||
import cn.hutool.core.date.DateUtil;
|
||||
import cn.hutool.core.util.ObjectUtil;
|
||||
import cn.hutool.json.JSONUtil;
|
||||
import cn.hutool.poi.excel.ExcelReader;
|
||||
import cn.hutool.poi.excel.ExcelUtil;
|
||||
import cn.hutool.poi.excel.ExcelWriter;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
|
|
@ -26,6 +27,10 @@ import com.ruoyi.contract.domain.vo.conpurchasevo.ConPurchaseTotalVo;
|
|||
import com.ruoyi.contract.mapper.*;
|
||||
import com.ruoyi.contract.service.*;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import com.ruoyi.contract.domain.vo.ConPurchaseImportVO;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
import java.io.InputStream;
|
||||
import javax.validation.Validator;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
|
@ -38,7 +43,6 @@ import java.io.UnsupportedEncodingException;
|
|||
import java.lang.reflect.Field;
|
||||
import java.net.URLEncoder;
|
||||
import java.util.*;
|
||||
import java.util.concurrent.atomic.AtomicReference;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
|
|
@ -96,6 +100,16 @@ public class ConPurchaseServiceImpl implements IConPurchaseService {
|
|||
|
||||
private final IConMediaTypeService iConMediaTypeService;
|
||||
|
||||
private final ConFirstMapper conFirstMapper;
|
||||
|
||||
private final ConInvoiceMapper conInvoiceMapper;
|
||||
|
||||
private final ConMediaDeptMapper conMediaDeptMapper;
|
||||
|
||||
private final ConPurchaseMediaMapper conPurchaseMediaMapper;
|
||||
|
||||
private final ConMediaTypeMapper conMediaTypeMapper;
|
||||
|
||||
/**
|
||||
* 发票类型id
|
||||
*/
|
||||
|
|
@ -108,6 +122,140 @@ public class ConPurchaseServiceImpl implements IConPurchaseService {
|
|||
@Resource
|
||||
private IConFirstService iConFirstService;
|
||||
|
||||
@Resource
|
||||
private Validator validator;
|
||||
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public int importPurchase(MultipartFile file) {
|
||||
List<ConPurchaseImportVO> list;
|
||||
try (InputStream inputStream = file.getInputStream()) {
|
||||
ExcelReader reader = ExcelUtil.getReader(inputStream);
|
||||
list = reader.readAll(ConPurchaseImportVO.class);
|
||||
} catch (IOException e) {
|
||||
throw new ServiceException("导入采购合同失败");
|
||||
}
|
||||
|
||||
if (CollectionUtil.isEmpty(list)) {
|
||||
throw new ServiceException("导入数据不能为空");
|
||||
}
|
||||
|
||||
for (int i = 0; i < list.size(); i++) {
|
||||
ConPurchaseImportVO vo = list.get(i);
|
||||
try {
|
||||
// 校验必填项
|
||||
if (StringUtils.isBlank(vo.getContractNumber())) {
|
||||
throw new ServiceException("合同编号不能为空");
|
||||
}
|
||||
|
||||
ConPurchase conPurchase = baseMapper.selectOne(new LambdaQueryWrapper<ConPurchase>()
|
||||
.eq(ConPurchase::getContractNumber, vo.getContractNumber()));
|
||||
|
||||
if (conPurchase == null) {
|
||||
// 不存在，新增合同
|
||||
conPurchase = new ConPurchase();
|
||||
// 手动进行字段映射
|
||||
conPurchase.setContractNumber(vo.getContractNumber());
|
||||
conPurchase.setProjNumber(vo.getProjNumber());
|
||||
conPurchase.setProjName(vo.getProjName());
|
||||
conPurchase.setStartTime(vo.getStartTime());
|
||||
conPurchase.setEndTime(vo.getEndTime());
|
||||
conPurchase.setContractMoney(vo.getContractMoney());
|
||||
conPurchase.setInvoiceContent(vo.getInvoiceContent());
|
||||
conPurchase.setSignTime(vo.getSignTime());
|
||||
conPurchase.setUpPrint(vo.getUpPrint());
|
||||
conPurchase.setExchangePrint(vo.getExchangePrint());
|
||||
conPurchase.setNextPrint(vo.getNextPrint());
|
||||
conPurchase.setMediaLink(vo.getMediaLink());
|
||||
String state = "生效".equals(vo.getState()) ? "1" : "0";
|
||||
conPurchase.setState(state);
|
||||
conPurchase.setFirstName(vo.getFirstName());
|
||||
conPurchase.setMediaDeptName(vo.getMediaDeptName());
|
||||
// 供应商名称（乙方名称）
|
||||
conPurchase.setSecondName(vo.getSupplierName());
|
||||
//税率（税点）
|
||||
conPurchase.setTaxPoints(vo.getTaxRate());
|
||||
|
||||
//甲方
|
||||
if (StringUtils.isNotBlank(vo.getFirstName())) {
|
||||
ConFirst conFirst = conFirstMapper.selectOne(new LambdaQueryWrapper<ConFirst>().eq(ConFirst::getFirstName, vo.getFirstName()));
|
||||
if (conFirst != null) {
|
||||
conPurchase.setFirstId(conFirst.getId());
|
||||
}
|
||||
}
|
||||
//媒介部门
|
||||
if (StringUtils.isNotBlank(vo.getMediaDeptName())) {
|
||||
ConMediaDept conMediaDept = conMediaDeptMapper.selectOne(new LambdaQueryWrapper<ConMediaDept>().eq(ConMediaDept::getMediaDeptName, vo.getMediaDeptName()));
|
||||
if (conMediaDept != null) {
|
||||
conPurchase.setMediaDeptId(conMediaDept.getId());
|
||||
}
|
||||
}
|
||||
//发票类型
|
||||
if (StringUtils.isNotBlank(vo.getInvoiceType())) {
|
||||
ConInvoice conInvoice = conInvoiceMapper.selectOne(new LambdaQueryWrapper<ConInvoice>().eq(ConInvoice::getInvoiceName, vo.getInvoiceType()));
|
||||
if (conInvoice != null) {
|
||||
conPurchase.setInvoiceId(conInvoice.getId());
|
||||
}
|
||||
}
|
||||
|
||||
validEntityBeforeSave(conPurchase);
|
||||
baseMapper.insert(conPurchase);
|
||||
}
|
||||
|
||||
// 新增媒体数据
|
||||
ConPurchaseMedia conPurchaseMedia = new ConPurchaseMedia();
|
||||
conPurchaseMedia.setPurchaseId(conPurchase.getId());
|
||||
|
||||
// 媒体类型
|
||||
if (StringUtils.isNotBlank(vo.getMediaType())) {
|
||||
ConMediaType conMediaType = conMediaTypeMapper.selectOne(new LambdaQueryWrapper<ConMediaType>().eq(ConMediaType::getMediaType, vo.getMediaType()));
|
||||
if (conMediaType != null) {
|
||||
conPurchaseMedia.setMediaId(conMediaType.getId());
|
||||
}
|
||||
}
|
||||
//城市
|
||||
if (StringUtils.isNotBlank(vo.getCityName())) {
|
||||
ConCity conCity = conCityMapper.selectList(new LambdaQueryWrapper<ConCity>().likeRight(ConCity::getCityName, vo.getCityName())).stream().findFirst().orElse(null);
|
||||
if (conCity != null) {
|
||||
conPurchaseMedia.setCityId(conCity.getId());
|
||||
String cityIds = iConCityService.selectTreeIds(conCity.getId());
|
||||
conPurchaseMedia.setCityIds(cityIds);
|
||||
}
|
||||
}
|
||||
conPurchaseMedia.setMediaPosition(vo.getMediaLocation());
|
||||
conPurchaseMedia.setAccountNumber(safeParseDouble(vo.getPurchaseQuantity()));
|
||||
conPurchaseMedia.setReleaseFrequency(vo.getFrequency());
|
||||
conPurchaseMedia.setUpTime(vo.getStartTime());
|
||||
conPurchaseMedia.setDownTime(vo.getEndTime());
|
||||
conPurchaseMedia.setPeriod(safeParseDouble(vo.getPublishDays()));
|
||||
conPurchaseMedia.setPrintPrice(safeParseDouble(vo.getListPrice()));
|
||||
conPurchaseMedia.setPrintPriceUnit(vo.getListPriceUnit());
|
||||
conPurchaseMedia.setDiscount(vo.getDiscount());
|
||||
conPurchaseMedia.setMediaFee(safeParseDouble(vo.getNetPrice()));
|
||||
conPurchaseMedia.setProductFee(safeParseDouble(vo.getProductionFee()));
|
||||
|
||||
conPurchaseMediaMapper.insert(conPurchaseMedia);
|
||||
|
||||
|
||||
} catch (Exception e) {
|
||||
log.error("导入采购合同失败", e);
|
||||
}
|
||||
}
|
||||
return list.size();
|
||||
}
|
||||
|
||||
private Double safeParseDouble(String str) {
|
||||
if (StringUtils.isBlank(str) || "-".equals(str)) {
|
||||
return null;
|
||||
}
|
||||
try {
|
||||
return Double.parseDouble(str);
|
||||
} catch (NumberFormatException e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 查询采购合同信息
|
||||
*/
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user