| | |
| | | @Override |
| | | public void invoke(ProductCalibrationExcelParam data, AnalysisContext context) { |
| | | log.info("成品校验解析到第 {} 条数据:{}", ++count, JSON.toJSONString(data)); |
| | | if ("合格".equals(data.getQualified()) || "不合格".equals(data.getQualified())) { |
| | | if ("合格".equals(data.getQualified()) || "待判".equals(data.getQualified()) || "不合格".equals(data.getQualified())) { |
| | | list.add(data); |
| | | } else { |
| | | throw new CoolException("成品校验校验结果异常:" + data); |
| | |
| | | try (SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH)) { |
| | | LocDetlMapper mapper = sqlSession.getMapper(LocDetlMapper.class); |
| | | list.forEach(productCalibrationExcelParam -> { |
| | | mapper.updateQualifiedByRollNo(productCalibrationExcelParam.getRollNo(), productCalibrationExcelParam.getQualified()); |
| | | mapper.updateQualifiedByRollNo(productCalibrationExcelParam.getRollNo(), productCalibrationExcelParam.getQualified().equals("待判") ? null : productCalibrationExcelParam.getQualified()); |
| | | }); |
| | | sqlSession.commit(); |
| | | } |