|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public Integer create(SalaryParam salaryParam) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | SalaryParam insert = new SalaryParam(); | 
|---|
|  |  |  | insert.setRootDepartId(salaryParam.getRootDepartId()); | 
|---|
|  |  |  | insert.setDepartId(salaryParam.getDepartId()); | 
|---|
|  |  |  | insert.setProcedureId(salaryParam.getProcedureId()); | 
|---|
|  |  |  | insert.setMaterialId(salaryParam.getMaterialId()); | 
|---|
|  |  |  | insert.setDeleted((byte) Constants.ZERO); | 
|---|
|  |  |  | if(findOne(insert) != null){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"同一个物料在相同工序不能重复配置哦!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | insert.setCreateUser(principal.getId()); | 
|---|
|  |  |  | insert.setCreateTime(new Date()); | 
|---|
|  |  |  | insert.setUpdateUser(principal.getId()); | 
|---|
|  |  |  | insert.setUpdateTime(new Date()); | 
|---|
|  |  |  | insert.setRemark(salaryParam.getRemark()); | 
|---|
|  |  |  | insert.setRootDepartId(salaryParam.getRootDepartId()); | 
|---|
|  |  |  | insert.setDepartId(salaryParam.getDepartId()); | 
|---|
|  |  |  | insert.setProcedureId(salaryParam.getProcedureId()); | 
|---|
|  |  |  | insert.setMaterialId(salaryParam.getMaterialId()); | 
|---|
|  |  |  | insert.setSalary(salaryParam.getSalary()); | 
|---|
|  |  |  | insert.setSalary(salaryParam.getSalary().multiply(new BigDecimal("100"))); | 
|---|
|  |  |  | insert.setNum(salaryParam.getNum()); | 
|---|
|  |  |  | insert.setTimes(salaryParam.getTimes()); | 
|---|
|  |  |  | insert.setUnqualified(salaryParam.getUnqualified()); | 
|---|
|  |  |  | 
|---|
|  |  |  | .set(SalaryParam::getUpdateTime,new Date()) | 
|---|
|  |  |  | .set(SalaryParam::getUpdateUser,principal.getId()) | 
|---|
|  |  |  | .set(SalaryParam::getType,salaryParam.getType()) | 
|---|
|  |  |  | .set(SalaryParam::getDepartId,salaryParam.getDepartId()) | 
|---|
|  |  |  | .set(SalaryParam::getMaterialId,salaryParam.getMaterialId()) | 
|---|
|  |  |  | .set(SalaryParam::getProcedureId,salaryParam.getProcedureId()) | 
|---|
|  |  |  | .set(SalaryParam::getSalary,salaryParam.getSalary()) | 
|---|
|  |  |  | //                .set(SalaryParam::getDepartId,salaryParam.getDepartId()) | 
|---|
|  |  |  | //                .set(SalaryParam::getMaterialId,salaryParam.getMaterialId()) | 
|---|
|  |  |  | //                .set(SalaryParam::getProcedureId,salaryParam.getProcedureId()) | 
|---|
|  |  |  | .set(SalaryParam::getSalary,salaryParam.getSalary().multiply(new BigDecimal(100))) | 
|---|
|  |  |  | .set(SalaryParam::getNum,salaryParam.getNum()) | 
|---|
|  |  |  | .set(SalaryParam::getTimes,salaryParam.getTimes()) | 
|---|
|  |  |  | .set(SalaryParam::getUnqualified,salaryParam.getUnqualified()); | 
|---|
|  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public SalaryParam findOne(SalaryParam salaryParam) { | 
|---|
|  |  |  | QueryWrapper<SalaryParam> wrapper = new QueryWrapper<>(salaryParam); | 
|---|
|  |  |  | wrapper.last("limit 1"); | 
|---|
|  |  |  | return salaryParamMapper.selectOne(wrapper); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | public PageData<SalaryParamVO> findPage(PageWrap<SalaryParamDTO> pageWrap) { | 
|---|
|  |  |  | IPage<SalaryParam> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
|---|
|  |  |  | SalaryParamDTO model = pageWrap.getModel(); | 
|---|
|  |  |  | return PageData.from(salaryParamMapper.selectPage(page, model)); | 
|---|
|  |  |  | IPage<SalaryParamVO> salaryParamVOIPage = salaryParamMapper.selectPage(page, model); | 
|---|
|  |  |  | if (!CollectionUtils.isEmpty(salaryParamVOIPage.getRecords())){ | 
|---|
|  |  |  | salaryParamVOIPage.getRecords().forEach(s->s.setSalary(s.getSalary().divide(new BigDecimal(100)))); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return PageData.from(salaryParamVOIPage); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | 
|---|
|  |  |  | || Objects.isNull(s.getDepartName()) | 
|---|
|  |  |  | || Objects.isNull(s.getMaterialCode()) | 
|---|
|  |  |  | || Objects.isNull(s.getProcedureName()) | 
|---|
|  |  |  | || Objects.isNull(s.getNUM())){ | 
|---|
|  |  |  | || Objects.isNull(s.getNum())){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "导入数据内容有误!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | 
|---|
|  |  |  | proceduresWrapper.lambda() | 
|---|
|  |  |  | .eq(Procedures::getName,salaryParamImportDTO.getProcedureName()) | 
|---|
|  |  |  | .eq(Procedures::getRootDepartId,department.getRootId()) | 
|---|
|  |  |  | .eq(Procedures::getDepartId,department.getId()) | 
|---|
|  |  |  | .eq(Procedures::getOrgId,department.getId()) | 
|---|
|  |  |  | .last("limit 1"); | 
|---|
|  |  |  | Procedures procedures = proceduresMapper.selectOne(proceduresWrapper); | 
|---|
|  |  |  | if (Objects.isNull(procedures)){ | 
|---|
|  |  |  | 
|---|
|  |  |  | salaryParam.setProcedureId(procedures.getId()); | 
|---|
|  |  |  | salaryParam.setMaterialId(material.getId()); | 
|---|
|  |  |  | salaryParam.setSalary(salaryParamImportDTO.getSalary()); | 
|---|
|  |  |  | salaryParam.setNum(new BigDecimal(salaryParamImportDTO.getNUM())); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | salaryParam.setNum(new BigDecimal(salaryParamImportDTO.getNum())); | 
|---|
|  |  |  | salaryParam.setTimes(getIntegerTimes(salaryParamImportDTO.getTimesName())); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Integer unqualified = Optional.ofNullable(salaryParamImportDTO.getUnqualified()).map(s -> { | 
|---|
|  |  |  | if ("否".equals(s)) { | 
|---|
|  |  |  | return 0; | 
|---|
|  |  |  | 
|---|
|  |  |  | m = Integer.parseInt(a.substring(hIndex >=0?hIndex+2:0,mIndex)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(sIndex > mIndex){ | 
|---|
|  |  |  | s = Integer.parseInt(a.substring(mIndex >=0?mIndex+2:0,mIndex)); | 
|---|
|  |  |  | s = Integer.parseInt(a.substring(mIndex >= 0 ? mIndex+2 : 0, sIndex)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return  h*3600+m*60+s; | 
|---|
|  |  |  | }catch (Exception e){ | 
|---|