| | |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | | import org.springframework.web.multipart.MultipartFile; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | |
|---|
| | | import java.io.InputStream; |
|---|
| | | import java.lang.reflect.Field; |
|---|
| | |
|---|
| | | if (CollectionUtils.isEmpty(salesLedgerImportDtoList)) return AjaxResult.error("销售台账数据为空！"); |
|---|
| | | List<SalesLedgerImportDto> salesLedgerProductImportDtoList = stringListMap.get("销售产品数据"); |
|---|
| | | if (CollectionUtils.isEmpty(salesLedgerProductImportDtoList)) return AjaxResult.error("销售产品数据为空！"); |
|---|
| | | // 客户数据 |
|---|
| | | List<Customer> customers = customerMapper.selectList(new LambdaQueryWrapper<Customer>().in(Customer::getCustomerName, |
|---|
| | | salesLedgerImportDtoList.stream().map(SalesLedgerImportDto::getCustomerName).collect(Collectors.toList()))); |
|---|
| | | // 客户数据 - 参考 listPage 查询私海客户（type = 0） |
|---|
| | | // type = 0（私海客户）或者 type = 1（公海客户）且已被分配，并且是自己领用、自己创建或者共享给自己的客户 |
|---|
| | | Long loginUserId = loginUser.getUser().getUserId(); |
|---|
| | | List<Customer> customers = customerMapper.selectList(new QueryWrapper<Customer>() |
|---|
| | | .in("customer_name", salesLedgerImportDtoList.stream() |
|---|
| | | .map(SalesLedgerImportDto::getCustomerName).collect(Collectors.toList())) |
|---|
| | | .and(wrapper -> wrapper.eq("type", 0) |
|---|
| | | .or(wrapper2 -> wrapper2.eq("type", 1).eq("is_assigned", 1))) |
|---|
| | | .and(wrapper -> wrapper.eq("usage_user", loginUserId) |
|---|
| | | .or(wrapper2 -> wrapper2.eq("create_user", loginUserId) |
|---|
| | | .or(wrapper3 -> wrapper3.exists("select 1 from customer_user cu where cu.customer_id = customer.id and cu.user_id = " + loginUserId))))); |
|---|
| | | // // 规格型号数据 |
|---|
| | | // List<ProductModel> productModels = productModelMapper.selectList(new LambdaQueryWrapper<ProductModel>().in(ProductModel::getModel, |
|---|
| | | // salesLedgerProductImportDtoList.stream().map(SalesLedgerImportDto::getSpecificationModel).collect(Collectors.toList()))); |
|---|
| | |
|---|
| | | if (salesLedger1 != null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 判断业务员是否存在 |
|---|
| | | SysUser salesman = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>() |
|---|
| | | .eq(SysUser::getNickName, salesLedgerImportDto.getSalesman())); |
|---|
| | | if (salesman == null) { |
|---|
| | | throw new RuntimeException("业务员:" + salesLedgerImportDto.getSalesman() + "不存在！"); |
|---|
| | | } |
|---|
| | | SalesLedger salesLedger = new SalesLedger(); |
|---|
| | | BeanUtils.copyProperties(salesLedgerImportDto, salesLedger); |
|---|
| | | salesLedger.setExecutionDate(DateUtils.toLocalDate(salesLedgerImportDto.getExecutionDate())); |
|---|
| | | salesLedger.setDeliveryDate(DateUtils.toLocalDate(salesLedgerImportDto.getDeliveryDate())); |
|---|
| | | // 通过客户名称查询客户ID，客户合同号 |
|---|
| | | salesLedger.setCustomerId(customers.stream() |
|---|
| | | Optional<Customer> customerOptional = customers.stream() |
|---|
| | | .filter(customer -> customer.getCustomerName().equals(salesLedger.getCustomerName())) |
|---|
| | | .findFirst() |
|---|
| | | .map(Customer::getId) |
|---|
| | | .orElse(null)); |
|---|
| | | salesLedger.setCustomerContractNo(customers.stream() |
|---|
| | | .filter(customer -> customer.getCustomerName().equals(salesLedger.getCustomerName())) |
|---|
| | | .findFirst() |
|---|
| | | .map(Customer::getTaxpayerIdentificationNumber) |
|---|
| | | .orElse(null)); |
|---|
| | | .findFirst(); |
|---|
| | | if (customerOptional.isEmpty()) { |
|---|
| | | throw new RuntimeException("客户:" + salesLedger.getCustomerName() + "不存在！或者非私海用户"); |
|---|
| | | } |
|---|
| | | salesLedger.setCustomerId(customerOptional.get().getId()); |
|---|
| | | salesLedger.setCustomerContractNo(customerOptional.get().getTaxpayerIdentificationNumber()); |
|---|
| | | Long aLong = sysUsers.stream() |
|---|
| | | .filter(sysUser -> sysUser.getNickName().equals(salesLedger.getEntryPerson())) |
|---|
| | | .findFirst() |
|---|
| | |
|---|
| | | salesLedgerProduct.setType(1); |
|---|
| | | // 计算不含税总价 |
|---|
| | | salesLedgerProduct.setTaxExclusiveTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice().divide(new BigDecimal(1).add(salesLedgerProduct.getTaxRate().divide(new BigDecimal(100))), 2, RoundingMode.HALF_UP)); |
|---|
| | | list.stream() |
|---|
| | | // 校验产品规格是否存在 |
|---|
| | | Optional<Map<String, Object>> productModelOptional = list.stream() |
|---|
| | | .filter(map -> Objects.equals(map.get("productName"), salesLedgerProduct.getProductCategory()) && Objects.equals(map.get("model"), salesLedgerProduct.getSpecificationModel())) |
|---|
| | | .findFirst() |
|---|
| | | .ifPresent(map -> { |
|---|
| | | salesLedgerProduct.setProductModelId(Long.parseLong(map.get("modelId").toString())); |
|---|
| | | salesLedgerProduct.setProductId(Long.parseLong(map.get("id").toString())); |
|---|
| | | }); |
|---|
| | | .findFirst(); |
|---|
| | | if (productModelOptional.isEmpty()) { |
|---|
| | | throw new RuntimeException("产品大类:" + salesLedgerProduct.getProductCategory() + ",规格型号:" + salesLedgerProduct.getSpecificationModel() + "不存在！"); |
|---|
| | | } |
|---|
| | | Map<String, Object> productModelMap = productModelOptional.get(); |
|---|
| | | salesLedgerProduct.setProductModelId(Long.parseLong(productModelMap.get("modelId").toString())); |
|---|
| | | salesLedgerProduct.setProductId(Long.parseLong(productModelMap.get("id").toString())); |
|---|
| | | // salesLedgerProduct.setProductId(productList.stream() |
|---|
| | | // .filter(product -> product.getProductName().equals(salesLedgerProduct.getProductCategory())) |
|---|
| | | // .findFirst() |
|---|
| | |
|---|
| | | if (salesLedger.getId() == null) { |
|---|
| | | String contractNo = salesLedger.getSalesContractNo(); |
|---|
| | | if (StringUtils.isEmpty(contractNo)) { |
|---|
| | | contractNo = generateSalesContractNo(); |
|---|
| | | contractNo = generateSalesContractNo(salesLedgerDto.getEntryDate()); |
|---|
| | | } |
|---|
| | | salesLedger.setSalesContractNo(contractNo); |
|---|
| | | salesLedgerMapper.insert(salesLedger); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Transactional(readOnly = true) |
|---|
| | | public String generateSalesContractNo() { |
|---|
| | | LocalDate currentDate = LocalDate.now(); |
|---|
| | | public String generateSalesContractNo(Date entryDate) { |
|---|
| | | LocalDate currentDate = entryDate != null ? DateUtils.toLocalDate(entryDate) : LocalDate.now(); |
|---|
| | | String datePart = currentDate.format(DateTimeFormatter.BASIC_ISO_DATE); |
|---|
| | | String lockKey = LOCK_PREFIX + datePart; |
|---|
| | | String lockValue = Thread.currentThread().getId() + "-" + System.nanoTime(); // 唯一标识锁持有者 |
|---|
