| | |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.PlatformTransactionManager; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.StringUtils; |
| | | |
| | |
| | | private NumberGenerator<Structure> numberGenerator; |
| | | private DictUtils dictUtils; |
| | | private IfsFeignClient ifsFeignClient; |
| | | @Autowired |
| | | private PlatformTransactionManager transactionManager; |
| | | |
| | | private RedisTemplate redisTemplate; |
| | | @Autowired |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void importExcel(List<StructureData> list) { |
| | | list.forEach(System.out::println); |
| | | String key = "syncStructure_lock" + SecurityUtils.getUser().getId(); |
| | | if (redisTemplate.hasKey(key)) { |
| | | throw new RuntimeException("有导入任务正在处理"); |
| | |
| | | structure.setBomTypeDb("M"); |
| | | structure.setIfsSync(false); |
| | | structure.setAlternativeNo("*"); |
| | | structure.setSharpenerNo(data.getSharpenerNo()); |
| | | structure.setCaveNum(data.getCaveNum()); |
| | | structure.setGramWeight(data.getGramWeight()); |
| | | structure.setMoldingCycle(data.getMoldingCycle()); |
| | | structure.setMachine(data.getMachine()); |
| | | structure.setScale(data.getScale()); |
| | | structure.setDryingTime(data.getDryingTime()); |
| | | structure.setDryingTemperature(data.getDryingTemperature()); |
| | | structure.setPackingInfo(data.getPackingInfo()); |
| | | structure.setCustom(data.getCustom()); |
| | | baseMapper.insert(structure); |
| | | } |
| | | List<Part> childParts = partMapper.selectList(Wrappers.<Part>lambdaQuery().eq(Part::getPartNo, data.getSonPartNo())); |
| | |
| | | QueryWrapper<StructureComponent> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.lambda().select(StructureComponent::getLineItemNo).eq(StructureComponent::getStructureId,structure.getId()).orderByDesc(StructureComponent::getLineItemNo); |
| | | List<StructureComponent> structureComponents = structureComponentMapper.selectList(queryWrapper); |
| | | component.setQpa(new BigDecimal(1));// todo: 产品结构导入数量,还缺一个行号 |
| | | component.setQpa(new BigDecimal(data.getTotalNUm()));// todo: 产品结构导入数量,还缺一个行号 |
| | | Console.log("值===》"+structureComponents); |
| | | if(structureComponents.size()<1){ |
| | | component.setLineItemNo(1); |