报价：同行报价信息导入

+package com.lframework.xingyun.sc.excel.quotationPeer;
+
+import com.alibaba.excel.context.AnalysisContext;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.lframework.starter.common.exceptions.impl.DefaultClientException;
+import com.lframework.starter.common.utils.StringUtil;
+import com.lframework.starter.web.core.components.excel.ExcelImportListener;
+import com.lframework.starter.web.core.utils.ApplicationUtil;
+import com.lframework.xingyun.basedata.entity.BreedRelationship;
+import com.lframework.xingyun.basedata.service.breed.BreedRelationshipService;
+import com.lframework.xingyun.sc.procurement.service.quotation.SalesmanQuotationPeerService;
+import com.lframework.xingyun.sc.procurement.vo.quotation.CreateSalesmanQuotationPeerVo;
+import lombok.extern.slf4j.Slf4j;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 同行报价信息导入监听器
+ */
+@Slf4j
+public class PeerImportListener extends ExcelImportListener<PeerImportModel> {
+
+    @Override
+    protected void doInvoke(PeerImportModel data, AnalysisContext context) {
+        int rowIndex = context.readRowHolder().getRowIndex();
+        BreedRelationshipService breedRelationshipService = ApplicationUtil.getBean(BreedRelationshipService.class);
+
+        if (StringUtil.isNotBlank(data.getPeerName())) {
+            data.setPeerName(data.getPeerName().trim());
+        } else {
+            throw new DefaultClientException("第" + rowIndex + "行“同行名称”不能为空");
+        }
+
+        BreedRelationship breedRelationship = breedRelationshipService.getOne(
+                Wrappers.lambdaQuery(BreedRelationship.class)
+                        .eq(BreedRelationship::getProductName, data.getPeerProductName())
+                        .last("LIMIT 1"));
+        if (breedRelationship == null) {
+            throw new DefaultClientException("第" + rowIndex + "行“品名”不存在于品种关系中");
+        }
+        data.setPeerProductId(breedRelationship.getId());
+
+        data.setPeerPriceValue(parsePrice(data.getPeerPrice(), rowIndex));
+    }
+
+    @Override
+    protected void afterAllAnalysed(AnalysisContext context) {
+        SalesmanQuotationPeerService salesmanQuotationPeerService = ApplicationUtil.getBean(SalesmanQuotationPeerService.class);
+        List<PeerImportModel> datas = this.getDatas();
+        if (datas.isEmpty()) {
+            return;
+        }
+        for (int i = 0; i < datas.size(); i++) {
+            PeerImportModel peerImportModel = datas.get(i);
+            CreateSalesmanQuotationPeerVo vo = new CreateSalesmanQuotationPeerVo();
+            vo.setPeerName(peerImportModel.getPeerName());
+            vo.setPeerProductId(peerImportModel.getPeerProductId());
+            vo.setPeerPrice(peerImportModel.getPeerPriceValue());
+            vo.setRemark(peerImportModel.getRemark());
+            salesmanQuotationPeerService.create(vo);
+            this.setSuccessProcess(i);
+        }
+    }
+
+    @Override
+    protected void doComplete() {
+
+    }
+
+    /**
+     * 解析同行报价，并按统一口径返回行级错误
+     */
+    private BigDecimal parsePrice(String value, int rowIndex) {
+        if (StringUtil.isBlank(value)) {
+            throw new DefaultClientException("第" + rowIndex + "行“同行报价”不能为空");
+        }
+
+        BigDecimal decimalValue;
+        try {
+            decimalValue = new BigDecimal(value.trim());
+        } catch (NumberFormatException e) {
+            throw new DefaultClientException("第" + rowIndex + "行“同行报价”格式有误");
+        }
+
+        BigDecimal normalizedValue = decimalValue.stripTrailingZeros();
+        int scale = Math.max(normalizedValue.scale(), 0);
+        if (scale > 10) {
+            throw new DefaultClientException("第" + rowIndex + "行“同行报价”最多允许10位小数");
+        }
+
+        return decimalValue;
+    }
+}

+package com.lframework.xingyun.sc.excel.quotationPeer;
+
+import com.alibaba.excel.annotation.ExcelIgnore;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.lframework.starter.web.core.annotations.excel.ExcelRequired;
+import com.lframework.starter.web.core.components.excel.ExcelModel;
+import lombok.Data;
+
+/**
+ * 同行报价信息导入模型
+ */
+@Data
+public class PeerImportModel implements ExcelModel {
+
+    /**
+     * 同行名称
+     */
+    @ExcelRequired
+    @ExcelProperty("同行名称")
+    private String peerName;
+
+    /**
+     * 同行品种名称
+     */
+    @ExcelRequired
+    @ExcelProperty("同行品种名称")
+    private String peerProductName;
+
+    /**
+     * 同行报价
+     */
+    @ExcelRequired
+    @ExcelProperty("同行报价")
+    private String peerPrice;
+
+    @ExcelProperty("备注")
+    private String remark;
+
+    /**
+     * 导入时解析出的同行品种ID
+     */
+    @ExcelIgnore
+    private String peerProductId;
+
+    /**
+     * 导入时解析出的采同行报价
+     */
+    @ExcelIgnore
+    private java.math.BigDecimal peerPriceValue;
+}

@@ -6,6 +6,9 @@ import com.lframework.starter.web.core.components.resp.InvokeResult;
 import com.lframework.starter.web.core.components.resp.InvokeResultBuilder;
 import com.lframework.starter.web.core.components.resp.PageResult;
 import com.lframework.starter.web.core.controller.DefaultBaseController;
+import com.lframework.starter.web.core.utils.ExcelUtil;
+import com.lframework.xingyun.sc.excel.quotationPeer.PeerImportListener;
+import com.lframework.xingyun.sc.excel.quotationPeer.PeerImportModel;
 import com.lframework.xingyun.sc.procurement.entity.SalesmanQuotationPeer;
 import com.lframework.xingyun.sc.procurement.service.quotation.SalesmanQuotationPeerService;
 import com.lframework.xingyun.sc.procurement.vo.quotation.CreateSalesmanQuotationPeerVo;
@@ -15,8 +18,10 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiOperation;
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
 import javax.validation.Valid;
 import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -24,6 +29,8 @@ import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+import java.io.IOException;
 
 /**
  * 同行报价信息 Controller
@@ -99,4 +106,30 @@ public class SalesmanQuotationPeerController extends DefaultBaseController {
         salesmanQuotationPeerService.update(vo);
         return InvokeResultBuilder.success();
     }
+
+    /**
+     * 下载导入模板
+     */
+    @ApiOperation("下载导入模板")
+    @HasPermission({"procure-manage:sales-price-peer:import"})
+    @GetMapping("/import/template")
+    public void downloadImportTemplate(HttpServletResponse response) throws IOException {
+        ExcelUtil.exportXls("同行报价信息导入模板", PeerImportModel.class);
+    }
+
+    /**
+     * 导入
+     */
+    @ApiOperation("导入")
+    @HasPermission({"procure-manage:sales-price-peer:import"})
+    @PostMapping("/import")
+    public InvokeResult<Void> importExcel(@NotBlank(message = "ID不能为空") String id,
+                                          @NotNull(message = "请上传文件") MultipartFile file) {
+
+        PeerImportListener listener = new PeerImportListener();
+        listener.setTaskId(id);
+        ExcelUtil.read(file, PeerImportModel.class, listener).sheet().doRead();
+
+        return InvokeResultBuilder.success();
+    }
 }