| | |
|---|
| | | |
|---|
| | | import cn.hutool.core.util.ObjectUtil; |
|---|
| | | import cn.hutool.core.util.StrUtil; |
|---|
| | | import com.alibaba.excel.EasyExcel; |
|---|
| | | import com.alibaba.excel.ExcelWriter; |
|---|
| | | import com.alibaba.excel.write.metadata.WriteSheet; |
|---|
| | | import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; |
|---|
| | |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | | |
|---|
| | | import javax.servlet.ServletException; |
|---|
| | | import javax.servlet.http.HttpServletResponse; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.net.URLEncoder; |
|---|
| | | import java.time.LocalDate; |
|---|
| | | import java.time.LocalDateTime; |
|---|
| | | import java.time.format.DateTimeFormatter; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.ConcurrentHashMap; |
|---|
| | | import java.util.concurrent.atomic.AtomicInteger; |
|---|
| | | import java.util.function.Function; |
|---|
| | | import java.util.function.Predicate; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | //获取检验下单数据 |
|---|
| | | @Override |
|---|
| | | public Map<String, Object> selectInsOrderParameter(IPage<InsOrder> page, SampleOrderDto sampleOrderDto) { |
|---|
| | | Map<String, Object> map = new HashMap<>(); |
|---|
| | | map.put("head", PrintChina.printChina(SampleOrderDto.class)); |
|---|
| | | //判断全部,个人,组织的权限 |
|---|
| | | Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("selectInsOrderParameter"); |
|---|
| | | User user = userMapper.selectById(map1.get("userId")); |
|---|
| | | User user = userMapper.selectById(map1.get("userId"));//当前登录的人 |
|---|
| | | Integer roleId = user.getRoleId(); |
|---|
| | | //获取当前人所属实验室id |
|---|
| | | String departLimsId = user.getDepartLimsId(); |
|---|
| | | String laboratory = null; |
|---|
| | | if (ObjectUtils.isNotEmpty(departLimsId) && !departLimsId.equals("")) { |
|---|
| | | String[] split = departLimsId.split(","); |
|---|
| | | //查询对应架构名称(通信实验室,电力实验室,检测办) |
|---|
| | | String departLims = baseMapper.seldepLimsId(Integer.parseInt(split[split.length - 1])); |
|---|
| | | if (departLims.contains("实验室")) { |
|---|
| | | laboratory = departLims; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //判断是否是全部权限 |
|---|
| | | Power power = powerMapper.selectOne(Wrappers.<Power>lambdaQuery().eq(Power::getRoleId, roleId).eq(Power::getMenuMethod, "selectAllInsOrder")); |
|---|
| | | if (ObjectUtils.isEmpty(power)) { |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | Map<String, Object> map = new HashMap<>(); |
|---|
| | | map.put("head", PrintChina.printChina(SampleOrderDto.class)); |
|---|
| | | map.put("body", insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto))); |
|---|
| | | map.put("body", insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto), laboratory)); |
|---|
| | | return map; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public int upInsOrder(Integer orderId, Integer sampleId, String appointed, Integer userId) { |
|---|
| | | public int upInsOrder(Integer orderId, Integer sampleId, String appointed, Integer userId,String sonLaboratory) { |
|---|
| | | InsOrder insOrder = new InsOrder(); |
|---|
| | | insOrder.setId(orderId); |
|---|
| | | insOrder.setAppointed(LocalDate.parse(appointed)); |
|---|
| | |
|---|
| | | insSampleUser.setState(0); |
|---|
| | | insSampleUser.setUserId(userId); |
|---|
| | | insSampleUser.setInsSampleId(orderId); |
|---|
| | | insSampleUser.setSonLaboratory(sonLaboratory); |
|---|
| | | insSampleUserMapper.insert(insSampleUser); |
|---|
| | | } |
|---|
| | | return 1; |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | insProductService.saveBatch(insProductes); |
|---|
| | | } |
|---|
| | | //判断热循环项目的添加和温升试验项目的添加 |
|---|
| | | else if (product.getInspectionItem().equals("热循环") || product.getInspectionItem().equals("温升试验")) { |
|---|
| | | List<InsProduct> insProductess = new ArrayList<>(); |
|---|
| | | product.setId(null); |
|---|
| | | product.setInsSampleId(sampleId); |
|---|
| | | insProductess.add(product); |
|---|
| | | List<InsProduct> insProductes = new ArrayList<>(); |
|---|
| | | List<InsProduct> insProducts = new ArrayList<>(); |
|---|
| | | String[] strings = product.getAsk().split(";"); |
|---|
| | | //循环次数 |
|---|
| | | int count = Integer.parseInt(strings[strings.length - 1]); |
|---|
| | | for (int i = 0; i < strings.length - 1; i++) { |
|---|
| | | String[] split = strings[i].split(","); |
|---|
| | | InsProduct insProduct = new InsProduct(); |
|---|
| | | insProduct.setInspectionItem("1");//检验父项--循环次数 |
|---|
| | | insProduct.setInspectionItemSubclass(split[0]);//检验子项--环境温度/导线温度/耐张温度/接续温度 |
|---|
| | | insProduct.setInspectionItemSubclassEn(split[1]);//检验子项英文--环境温度/导线温度/耐张温度/接续温度 |
|---|
| | | insProduct.setAsk(null);//检验要求 |
|---|
| | | insProduct.setTell(null);//检验描述 |
|---|
| | | insProduct.setInsSampleId(sampleId); |
|---|
| | | insProduct.setState(1); |
|---|
| | | insProduct.setFactory(product.getFactory()); |
|---|
| | | insProduct.setLaboratory(product.getLaboratory()); |
|---|
| | | insProduct.setSampleType(product.getSampleType()); |
|---|
| | | insProduct.setSample(product.getSample()); |
|---|
| | | insProduct.setModel(product.getModel()); |
|---|
| | | insProduct.setSonLaboratory(product.getSonLaboratory()); |
|---|
| | | insProduct.setUnit("℃");//单位 |
|---|
| | | insProduct.setManHourGroup(product.getManHourGroup()); |
|---|
| | | insProduct.setInspectionItemType("0"); |
|---|
| | | insProduct.setInspectionValueType("1"); |
|---|
| | | insProducts.add(insProduct); |
|---|
| | | } |
|---|
| | | //热循环才有多次循环次数 |
|---|
| | | if (product.getInspectionItem().equals("热循环")) { |
|---|
| | | //热循环还要加上直流电阻 |
|---|
| | | for (InsProduct insProduct : insProducts) { |
|---|
| | | InsProduct insProduct1 = new InsProduct(); |
|---|
| | | BeanUtils.copyProperties(insProduct, insProduct1); |
|---|
| | | insProduct1.setInspectionItemClass("直流电阻");//检验子子项--直流电阻 |
|---|
| | | insProduct1.setInspectionItemClassEn("DC resistance");//检验子子项英文--直流电阻 |
|---|
| | | insProduct1.setUnit("Ω/km");//单位 |
|---|
| | | insProductes.add(insProduct1); |
|---|
| | | insProductess.add(insProduct1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (count > 1) { |
|---|
| | | //循环超过1次 |
|---|
| | | for (int j = 2; j <= count; j++) { |
|---|
| | | for (InsProduct insProduct : insProductes) { |
|---|
| | | InsProduct insProduct1 = new InsProduct(); |
|---|
| | | BeanUtils.copyProperties(insProduct, insProduct1); |
|---|
| | | insProduct1.setInspectionItem(j + "");//循环次数 |
|---|
| | | insProductess.add(insProduct1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | insProductService.saveBatch(insProductess); |
|---|
| | | } else { |
|---|
| | | if (!is) { |
|---|
| | | switch (type) { |
|---|
| | |
|---|
| | | map.put("head", PrintChina.printChina(CostStatisticsDto.class)); |
|---|
| | | Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("costStatistics"); |
|---|
| | | if (map1.get("look") == 1) costStatisticsDto.setCreateUser(map1.get("userId")); |
|---|
| | | IPage<CostStatisticsDto> costStatisticsDtoIPage = insOrderMapper.selectCostStatistics(page, QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59")); |
|---|
| | | List<CostStatisticsDto> costStatisticsDtoList = costStatisticsDtoIPage.getRecords(); |
|---|
| | | for (CostStatisticsDto statisticsDto : costStatisticsDtoList) { |
|---|
| | | statisticsDto.setNum(1); |
|---|
| | | } |
|---|
| | | List<CostStatisticsDto> costStatisticsDtoList1 = deduplicateAndSumCounts(costStatisticsDtoList); |
|---|
| | | costStatisticsDtoIPage.setRecords(costStatisticsDtoList1); |
|---|
| | | map.put("body", costStatisticsDtoIPage); |
|---|
| | | return map; |
|---|
| | | } |
|---|
| | | private static List<CostStatisticsDto> deduplicateAndSumCounts(List<CostStatisticsDto> list) { |
|---|
| | | // 使用一个 Map 来存放已经出现过的 inspectionItem + entrustCode + sample 的组合 |
|---|
| | | Map<String, CostStatisticsDto> map = new HashMap<>(); |
|---|
| | | // 遍历列表进行去重和计数 |
|---|
| | | for (CostStatisticsDto dto : list) { |
|---|
| | | String key = dto.getInspectionItem() + dto.getEntrustCode() + dto.getSample(); |
|---|
| | | if (map.containsKey(key)) { |
|---|
| | | // 如果已经存在，则累加数量 |
|---|
| | | CostStatisticsDto existingDto = map.get(key); |
|---|
| | | existingDto.setNum(existingDto.getNum() + dto.getNum()); |
|---|
| | | existingDto.setPrice(existingDto.getPrice().add(dto.getPrice())); |
|---|
| | | IPage<CostStatisticsDto> dtoIPage = insOrderMapper.selectCostStatistics(page, QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59")); |
|---|
| | | List<CostStatisticsDto> collect = dtoIPage.getRecords().stream().map(dto -> { |
|---|
| | | Set<String> uniqueTags = new HashSet<>(); |
|---|
| | | if (dto.getInspectionItem().contains(",")) { |
|---|
| | | for (String s : dto.getInspectionItem().split(",")) { |
|---|
| | | uniqueTags.add(s.split("@")[0]); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | // 如果不存在，则放入 Map 中 |
|---|
| | | map.put(key, dto); |
|---|
| | | uniqueTags.add(dto.getInspectionItem().split("@")[0]); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // 将 Map 中的值转为 List 返回 |
|---|
| | | return new ArrayList<>(map.values()); |
|---|
| | | dto.setInspectionItem(uniqueTags.toString()); |
|---|
| | | return dto; |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | dtoIPage.setRecords(collect); |
|---|
| | | map.put("body", dtoIPage); |
|---|
| | | return map; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59")); |
|---|
| | | double totalPrice = costStatisticsDtos.stream() |
|---|
| | | .filter(dto -> dto.getPrice() != null) // 过滤掉价格为 null 的对象 |
|---|
| | | .mapToDouble(value -> value.getPrice().doubleValue()) |
|---|
| | | .mapToDouble(value -> value.getPrice().doubleValue() * value.getNum()) |
|---|
| | | .sum(); |
|---|
| | | map.put("total",totalPrice); |
|---|
| | | map.put("total", totalPrice); |
|---|
| | | return map; |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | return sampleProductDto3s; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void export(CostStatisticsDto costStatisticsDto,HttpServletResponse response) throws IOException { |
|---|
| | | //查询导出的费用统计数据 |
|---|
| | | String dates = costStatisticsDto.getDates(); |
|---|
| | | String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(","); |
|---|
| | | costStatisticsDto.setDates(null); |
|---|
| | | List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59")); |
|---|
| | | costStatisticsDtos = costStatisticsDtos.stream().map(dto -> { |
|---|
| | | Set<String> uniqueTags = new HashSet<>(); |
|---|
| | | if (dto.getInspectionItem().contains(",")) { |
|---|
| | | for (String s : dto.getInspectionItem().split(",")) { |
|---|
| | | uniqueTags.add(s.split("@")[0]); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | uniqueTags.add(dto.getInspectionItem().split("@")[0]); |
|---|
| | | } |
|---|
| | | dto.setInspectionItem(uniqueTags.toString()); |
|---|
| | | return dto; |
|---|
| | | }).collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | response.setContentType("application/vnd.ms-excel"); |
|---|
| | | response.setCharacterEncoding("UTF-8"); |
|---|
| | | // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系 |
|---|
| | | String fileName = URLEncoder.encode("样品费用统计导出", "UTF-8"); |
|---|
| | | response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx"); |
|---|
| | | try { |
|---|
| | | // 新建ExcelWriter |
|---|
| | | ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream()).registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).build(); |
|---|
| | | |
|---|
| | | WriteSheet mainSheet = EasyExcel.writerSheet( "样品费用统计导出").head(CostStatisticsDto.class).build(); |
|---|
| | | excelWriter.write(costStatisticsDtos, mainSheet); |
|---|
| | | |
|---|
| | | // 关闭流 |
|---|
| | | excelWriter.finish(); |
|---|
| | | } catch (IOException e) { |
|---|
| | | throw new RuntimeException("导出失败"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
