| | |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.time.LocalDateTime; |
| | | import java.time.LocalTime; |
| | | import java.time.format.DateTimeFormatter; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | |
| | | |
| | | @Scheduled(cron = "0 0 4 * * ?") // 每天凌晨4点触发 |
| | | public void pullDataFromOtherSystem() { |
| | | //获取前一天凌晨时间 |
| | | String pattern = "yyyy-MM-dd HH:mm:ss"; |
| | | DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern); |
| | | String dateTime = LocalDateTime.now().minusDays(1).with(LocalTime.of(0, 0, 0)).format(formatter); |
| | | //获取主销售数据 |
| | | List<Map<String, Object>> order = SyncOrder.getMainOrder("2023-08-01 10:00:00 "); |
| | | List<Map<String, Object>> order = SyncOrder.getMainOrder(dateTime); |
| | | List<Sale> list = order.stream().map(orde -> { |
| | | Sale sale = new Sale(); |
| | | sale.setOrderNumber(orde.get("orderNo").toString());//订单编号 |
| | |
| | | }).collect(Collectors.toList()); |
| | | saleService.saveBatch(list); |
| | | for (Sale sale : list) { |
| | | List<Map<String, Object>> innerOrder = SyncOrder.getInnerOrder("2023-08-01 10:00:00", sale.getOrderNumber()); |
| | | List<Map<String, Object>> innerOrder = SyncOrder.getInnerOrder(dateTime, sale.getOrderNumber()); |
| | | List<SaleMaterial> saleMaterials = innerOrder.stream().map(inorder -> { |
| | | SaleMaterial saleMaterial = new SaleMaterial(); |
| | | saleMaterial.setName(inorder.get("productName").toString()); //产品名称 |