账期：回笼资金导入

@@ -11,6 +11,8 @@ import javax.validation.constraints.NotBlank;
 import com.lframework.xingyun.sc.bo.ledger.recapitalize.GetRecapitalizeBo;
 import com.lframework.xingyun.sc.bo.ledger.recapitalize.GetRecapitalizeBo;
 import com.lframework.xingyun.sc.bo.ledger.recapitalize.QueryRecapitalizeBo;
 import com.lframework.xingyun.sc.bo.ledger.recapitalize.QueryRecapitalizeBo;
 import com.lframework.xingyun.sc.entity.Recapitalize;
 import com.lframework.xingyun.sc.entity.Recapitalize;
+import com.lframework.xingyun.sc.excel.ledger.RecapitalizeImportListener;
+import com.lframework.xingyun.sc.excel.ledger.RecapitalizeImportModel;
 import com.lframework.xingyun.sc.service.ledger.RecapitalizeService;
 import com.lframework.xingyun.sc.service.ledger.RecapitalizeService;
 import com.lframework.xingyun.sc.vo.ledger.recapitalize.CreateRecapitalizeVo;
 import com.lframework.xingyun.sc.vo.ledger.recapitalize.CreateRecapitalizeVo;
 import com.lframework.xingyun.sc.vo.ledger.recapitalize.QueryRecapitalizeVo;
 import com.lframework.xingyun.sc.vo.ledger.recapitalize.QueryRecapitalizeVo;
@@ -125,23 +127,23 @@ public class RecapitalizeController extends DefaultBaseController {
         return InvokeResultBuilder.success();
         return InvokeResultBuilder.success();
     }
     }
 
 
-//    @ApiOperation("下载导入模板")
-//    @HasPermission({"account-manage:recoup-funds:import"})
-//    @GetMapping("/import/template")
-//    public void downloadImportTemplate(HttpServletResponse response) throws IOException {
-//        ExcelUtil.exportXls("回笼资金导入模板", CustomerCreditChangeImportModel.class);
-//    }
-//
-//    @ApiOperation("导入")
-//    @HasPermission({"account-manage:recoup-funds:import"})
-//    @PostMapping("/import")
-//    public InvokeResult<Void> importExcel(@NotBlank(message = "ID不能为空") String id,
-//                                                @NotNull(message = "请上传文件") MultipartFile file) {
-//
-//        CustomerCreditChangeImportListener listener = new CustomerCreditChangeImportListener();
-//        listener.setTaskId(id);
-//        ExcelUtil.read(file, CustomerCreditChangeImportModel.class, listener).sheet().doRead();
-//
-//        return InvokeResultBuilder.success();
-//    }
+    @ApiOperation("下载导入模板")
+    @HasPermission({"account-manage:recoup-funds:import"})
+    @GetMapping("/import/template")
+    public void downloadImportTemplate(HttpServletResponse response) throws IOException {
+        ExcelUtil.exportXls("回笼资金导入模板", RecapitalizeImportModel.class);
+    }
+
+    @ApiOperation("导入")
+    @HasPermission({"account-manage:recoup-funds:import"})
+    @PostMapping("/import")
+    public InvokeResult<Void> importExcel(@NotBlank(message = "ID不能为空") String id,
+                                          @NotNull(message = "请上传文件") MultipartFile file) {
+
+        RecapitalizeImportListener listener = new RecapitalizeImportListener();
+        listener.setTaskId(id);
+        ExcelUtil.read(file, RecapitalizeImportModel.class, listener).sheet().doRead();
+
+        return InvokeResultBuilder.success();
+    }
 }
 }

+package com.lframework.xingyun.sc.excel.ledger;
+
+import com.alibaba.excel.context.AnalysisContext;
+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.starter.web.inner.entity.SysDept;
+import com.lframework.starter.web.inner.service.system.SysDeptService;
+import com.lframework.xingyun.basedata.entity.Customer;
+import com.lframework.xingyun.basedata.service.customer.CustomerService;
+import com.lframework.xingyun.sc.service.ledger.RecapitalizeService;
+import com.lframework.xingyun.sc.vo.ledger.recapitalize.CreateRecapitalizeVo;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.time.format.DateTimeParseException;
+import java.util.List;
+
+@Slf4j
+public class RecapitalizeImportListener extends ExcelImportListener<RecapitalizeImportModel> {
+
+  @Override
+  protected void doInvoke(RecapitalizeImportModel data, AnalysisContext context) {
+    CustomerService customerService = ApplicationUtil.getBean(CustomerService.class);
+    SysDeptService sysDeptService = ApplicationUtil.getBean(SysDeptService.class);
+    if (StringUtil.isBlank(data.getRecapitalizeDateStr())) {
+      throw new DefaultClientException(
+              "第" + context.readRowHolder().getRowIndex() + "行“资金回笼日期”不能为空");
+    } else {
+      String dateStr = data.getRecapitalizeDateStr().trim();
+      try {
+        LocalDate localDate = LocalDate.parse(dateStr, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        data.setRecapitalizeDate(localDate);
+      } catch (DateTimeParseException e) {
+        try {
+          LocalDate localDate = LocalDate.parse(dateStr, DateTimeFormatter.ofPattern("yyyy/M/d"));
+          data.setRecapitalizeDate(localDate);
+        } catch (DateTimeParseException ex) {
+          try {
+            // 支持 "2025年12月3日" 或 "2025年12月03日"
+            LocalDate localDate = LocalDate.parse(dateStr, DateTimeFormatter.ofPattern("yyyy'年'M'月'd'日'"));
+            data.setRecapitalizeDate(localDate);
+          } catch (DateTimeParseException ex2) {
+            throw new DefaultClientException(
+                    "第" + context.readRowHolder().getRowIndex() + "行”资金回笼日期“格式错误！");
+          }
+        }
+      }
+    }
+
+    if (StringUtil.isBlank(data.getOrderingUnitName())) {
+      throw new DefaultClientException(
+              "第" + context.readRowHolder().getRowIndex() + "行“订货单位名称”不能为空");
+    } else {
+      Customer customer = customerService.getByName(data.getOrderingUnitName());
+      if (customer == null) {
+        throw new DefaultClientException(
+                "第" + context.readRowHolder().getRowIndex() + "行“订货单位名称”不存在");
+      } else {
+        data.setOrderingUnit(customer.getId());
+      }
+    }
+
+    if (StringUtil.isBlank(data.getReturnedAmountStr())) {
+      throw new DefaultClientException(
+              "第" + context.readRowHolder().getRowIndex() + "行“回笼金额”不能为空");
+    } else {
+      try {
+        BigDecimal bigDecimal = new BigDecimal(data.getReturnedAmountStr());
+        data.setReturnedAmount(bigDecimal);
+      } catch (NumberFormatException e) {
+        throw new DefaultClientException(
+                "第" + context.readRowHolder().getRowIndex() + "行“回笼金额”格式错误");
+      }
+    }
+
+    if (StringUtil.isBlank(data.getDeptName())) {
+      throw new DefaultClientException(
+              "第" + context.readRowHolder().getRowIndex() + "行“办事处名称”不能为空");
+    } else {
+      List<SysDept> deptByName = sysDeptService.getDeptByName(data.getDeptName());
+      if (CollectionUtils.isEmpty(deptByName)) {
+        throw new DefaultClientException(
+                "第" + context.readRowHolder().getRowIndex() + "行“办事处”不存在");
+      } else {
+        if (deptByName.size() > 1) {
+          throw new DefaultClientException(
+                  "第" + context.readRowHolder().getRowIndex() + "行“办事处”存在多个同名区域");
+        } else {
+          SysDept sysDept = deptByName.get(0);
+          data.setDeptId(sysDept.getId());
+        }
+      }
+    }
+
+    if (StringUtil.isBlank(data.getFactoryTypeName())) {
+      throw new DefaultClientException(
+              "第" + context.readRowHolder().getRowIndex() + "行“厂别”不能为空");
+    } else {
+      if (data.getFactoryTypeName().equals("安徽楚江高精铜带有限公司")) {
+        data.setFactoryType("GJ");
+      } else if (data.getFactoryTypeName().equals("安徽楚江科技新材料股份有限公司")) {
+        data.setFactoryType("XC");
+      } else {
+        throw new DefaultClientException(
+                "第" + context.readRowHolder().getRowIndex() + "行“厂别”不存在");
+      }
+    }
+
+  }
+
+  @Override
+  protected void afterAllAnalysed(AnalysisContext context) {
+    RecapitalizeService recapitalizeService = ApplicationUtil.getBean(RecapitalizeService.class);
+    List<RecapitalizeImportModel> datas = this.getDatas();
+    for (int i = 0; i < datas.size(); i++) {
+      RecapitalizeImportModel data = datas.get(i);
+      CreateRecapitalizeVo vo = new CreateRecapitalizeVo();
+      vo.setRecapitalizeDate(data.getRecapitalizeDate());
+      vo.setOrderingUnit(data.getOrderingUnit());
+      vo.setReturnedAmount(data.getReturnedAmount());
+      vo.setDeptId(data.getDeptId());
+      vo.setFactoryType(data.getFactoryType());
+      recapitalizeService.create(vo);
+      this.setSuccessProcess(i);
+    }
+  }
+
+  @Override
+  protected void doComplete() {
+  }
+}

+package com.lframework.xingyun.sc.excel.ledger;
+
+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;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+@Data
+public class RecapitalizeImportModel implements ExcelModel {
+
+    @ExcelIgnore
+    private String id;
+
+    /**
+     * 资金回笼日期
+     */
+    @ExcelRequired
+    @ExcelProperty("资金回笼日期")
+    private String recapitalizeDateStr;
+
+    /**
+     * 资金回笼日期
+     */
+    @ExcelIgnore
+    private LocalDate recapitalizeDate;
+
+    /**
+     * 订货单位名称
+     */
+    @ExcelRequired
+    @ExcelProperty("订货单位名称")
+    private String orderingUnitName;
+
+    /**
+     * 订货单位ID
+     */
+    @ExcelIgnore
+    private String orderingUnit;
+
+    /**
+     * 回笼金额
+     */
+    @ExcelRequired
+    @ExcelProperty("回笼金额")
+    private String returnedAmountStr;
+
+    /**
+     * 回笼金额
+     */
+    @ExcelIgnore
+    private BigDecimal returnedAmount;
+
+    /**
+     * 办事处名称
+     */
+    @ExcelRequired
+    @ExcelProperty("办事处名称")
+    private String deptName;
+
+    /**
+     * 办事处ID
+     */
+    @ExcelIgnore
+    private String deptId;
+
+    /**
+     * 厂别
+     */
+    @ExcelRequired
+    @ExcelProperty("厂别")
+    private String factoryTypeName;
+
+    /**
+     * 厂别编码
+     */
+    @ExcelIgnore
+    private String factoryType;
+
+}

@@ -67,6 +67,7 @@ public class RecapitalizeServiceImpl extends BaseMpServiceImpl<RecapitalizeMappe
         data.setFactoryType(vo.getFactoryType());
         data.setFactoryType(vo.getFactoryType());
 
 
         getBaseMapper().insert(data);
         getBaseMapper().insert(data);
+        //todo fys 需要对台账处理
 
 
         OpLogUtil.setVariable("id", data.getId());
         OpLogUtil.setVariable("id", data.getId());
         OpLogUtil.setExtra(vo);
         OpLogUtil.setExtra(vo);