| | |
| | | import io.swagger.annotations.ApiImplicitParams; |
| | | import io.swagger.annotations.ApiOperation; |
| | | |
| | | import java.io.BufferedInputStream; |
| | | import java.io.File; |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.io.*; |
| | | import java.math.BigDecimal; |
| | | import java.net.URLEncoder; |
| | | import java.nio.file.Files; |
| | | import java.nio.file.Paths; |
| | | import java.time.LocalDateTime; |
| | |
| | | // changeDispatch.setUserName(item.getReservationName()); |
| | | // changeDispatch.setIsDelete(Constants.ZERO); |
| | | // result = dispatchClient.saveRecord(changeDispatch).getData(); |
| | | }else { |
| | | orderClient.updateArrivalTime(order.getId(),orderReasinDto.getArriveTime()); |
| | | |
| | | } |
| | | ChannelHandlerContext context = NettyChannelMap.getData(String.valueOf(orderReasinDto.getWorkerId())); |
| | | if (null != context) { |
| | |
| | | // return R.ok(list); |
| | | // } |
| | | |
| | | @ApiOperation(value = "导入模板下载", tags = {"管理后台"}) |
| | | @PostMapping(value = "/importTemplate") |
| | | public R<String> importTemplate(HttpServletResponse response) throws Exception { |
| | | List<FrozenBuckleImportDTO> list = new ArrayList<>(); |
| | | FrozenBuckleImportDTO bean = new FrozenBuckleImportDTO(); |
| | | |
| | | list.add(bean); |
| | | |
| | | // 这里URLEncoder.encode可以防止中文乱码 |
| | | String fileName = URLEncoder.encode("订单导入模板", "UTF-8"); |
| | | response.setContentType("application/vnd.ms-excel"); |
| | | response.setCharacterEncoding("utf-8"); |
| | | response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx"); |
| | | EasyExcel.write(response.getOutputStream(), FrozenBuckleImportDTO.class).sheet("订单导入模板").doWrite(list); |
| | | return R.ok("下载成功!"); |
| | | } |
| | | |
| | | /** |
| | | * 管理后台-订单导入 |
| | | */ |
| | |
| | | // 设置sheet,默认读取第一个 |
| | | .sheet() |
| | | // 设置标题(字段列表)所在行数 |
| | | .headRowNumber(2) |
| | | .headRowNumber(1) |
| | | .doRead(); |
| | | System.err.println(successArrayList); |
| | | |
| | |
| | | Site site = sites.stream().filter(e -> e.getSiteName().equals(frozenBuckleImportDTO.getSiteName())).findFirst().orElse(null); |
| | | if(Objects.nonNull(site)){ |
| | | order.setSiteId(site.getId()); |
| | | }else { |
| | | return R.fail("站点信息不存在"); |
| | | } |
| | | // 师傅信息 |
| | | if (StringUtils.hasLength(order.getServerName())) { |
| | |
| | | if(Objects.nonNull(masterWorker)){ |
| | | order.setServerId(masterWorker.getId()); |
| | | order.setServerPhone(masterWorker.getPhone()); |
| | | }else { |
| | | return R.fail("师傅信息不存在"); |
| | | } |
| | | order.setAcceptTime(new Date()); |
| | | // 待上门 |
| | |
| | | if(Objects.nonNull(recoveryServe)){ |
| | | order.setServeId(recoveryServe.getId()); |
| | | order.setServePrice(recoveryServe.getDefaultPrice()); |
| | | }else { |
| | | return R.fail("回收服务不存在"); |
| | | } |
| | | RecoveryServePrice one = recoveryServePriceService.lambdaQuery().eq(RecoveryServePrice::getCity, order.getCityCode()).eq(RecoveryServePrice::getRecoveryServeId, order.getServeId()).eq(BaseEntity::getIsDelete, 0).one(); |
| | | if (one==null) { |