| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | @DS("slave_1") |
|---|
| | | public boolean SynchronizeData(EcOrderParamDTO ecOrderParamDTO) { |
|---|
| | | processPages(100, ecOrderParamDTO); |
|---|
| | | return true; |
|---|
| | |
|---|
| | | for (int pageNum = 1; pageNum <= totalPages; pageNum++) { |
|---|
| | | Page<EcOrder> page = new Page<>(pageNum, pageSize); |
|---|
| | | QueryWrapper<EcOrder> objectQueryWrapper = new QueryWrapper<>(); |
|---|
| | | IPage<EcOrder> resultPage = page(page, objectQueryWrapper); |
|---|
| | | IPage<EcOrder> resultPage = baseMapper.selectPage(page, objectQueryWrapper); |
|---|
| | | List<EcOrder> records = resultPage.getRecords(); |
|---|
| | | List<ECallEventTwoEntity> recordEntityList = BeanUtil.copy(records, ECallEventTwoEntity.class); |
|---|
| | | recordEntityList.forEach(ecOrderEntity -> { |
|---|
| | | // 点落面 设置警格网格信息 |
|---|
| | | setGridInfo(ecOrderEntity); |
|---|
| | | }); |
|---|
| | | boolean b = saveEcOrder(recordEntityList); |
|---|
| | | boolean b = ecOrderService.saveOrUpdateBatch(recordEntityList); |
|---|
| | | System.out.println("更新第" + pageNum + "页" + b); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | @Override |
|---|
| | | @DS("master") |
|---|
| | | public boolean saveEcOrder(List<ECallEventTwoEntity> recordEntityList) { |
|---|
| | | return ecOrderService.saveOrUpdateBatch(recordEntityList); |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
