| | |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
| | | import com.gs.xiaomi.config.DataAcquisitionConfiguration; |
| | | import com.gs.xiaomi.dto.*; |
| | | import com.gs.xiaomi.entity.DeliveryDetail; |
| | |
| | | List<EtHeader> etHeaders = result.getEtHeaders(); |
| | | |
| | | etHeaders.forEach(etHeader -> { |
| | | |
| | | LambdaQueryWrapper<DeliveryMain> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(DeliveryMain::getZzasn, etHeader.getZzasn()); |
| | | |
| | | DeliveryMain one = deliveryMainService.getOne(queryWrapper, false); |
| | | |
| | | if (one != null) { |
| | | deliveryMainService.removeById(one.getId()); |
| | | |
| | | LambdaUpdateWrapper<DeliveryDetail> updateWrapper = new LambdaUpdateWrapper<>(); |
| | | updateWrapper.eq(DeliveryDetail::getPid, one.getId()); |
| | | deliveryDetailService.remove(updateWrapper); |
| | | |
| | | //PackageDetail |
| | | LambdaUpdateWrapper<PackageDetail> updateWrapper1 = new LambdaUpdateWrapper<>(); |
| | | updateWrapper1.eq(PackageDetail::getPid, one.getId()); |
| | | packageDetailService.remove(updateWrapper1); |
| | | |
| | | //LogisticsPackage |
| | | LambdaUpdateWrapper<LogisticsPackage> updateWrapper2 = new LambdaUpdateWrapper<>(); |
| | | updateWrapper2.eq(LogisticsPackage::getPid, one.getId()); |
| | | logisticsPackageService.remove(updateWrapper2); |
| | | } |
| | | |
| | | DeliveryMain deliveryMain = new DeliveryMain(); |
| | | |
| | | BeanUtil.copyProperties(etHeader, deliveryMain); |
| | |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | public boolean manualSynchronizationByDate(NumbericalDto numbericalDto) { |
| | | try { |
| | | BizDocument doc = new BizDocument(); |
| | | doc.setLifnr(DataAcquisitionConfiguration.LIFNR); |
| | | doc.setBizDate(numbericalDto.getDate()); |
| | | getXM104(doc); |
| | | return true; |
| | | } catch (Exception e) { |
| | | log.error("【手动读取ASN异常】 异常: {}", e.getMessage(), e); |
| | | return false; |
| | | } |
| | | } |
| | | } |