modify

Helius

2021-03-25 ea0cba161d97031f5ea64d2f21ea2ea1c0d5c12e

modify

 zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java

@@ -997,4 +997,39 @@
        }
    }

    @DS("slave")
    public List<SysBedInfo> bedInfoOld() {
        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from sys_bed_info");
        List<SysBedInfo> beds = mapsToListBean(maps, SysBedInfo.class);

        Map<String, Integer> shopIds = getRedisIds("shopId");
        for (SysBedInfo bed : beds) {
            Integer shopId = shopIds.get(bed.getShopId().toString());
            if (shopId != null) {
                bed.setShopId(shopId.longValue());
            } else {
                bed.setShopId(-bed.getShopId());
            }
        }
        return beds;
    }

    @Autowired
    private SysBedInfoDao sysBedInfoDao;

    @Transactional(rollbackFor = Exception.class)
    public void bedInfoNew(List<SysBedInfo> list) {
        if (CollUtil.isNotEmpty(list)) {
            Map<Long, Long> map = new HashMap<>();
            for (SysBedInfo bed : list) {
                Long oldId = bed.getId();
                bed.setId(null);
                sysBedInfoDao.insert(bed);
                map.put(oldId, bed.getId());
            }

            redisClient.saveMapValue("bed_info", map);
        }
    }

}

 zq-erp/src/test/java/com/matrix/DataMoveTest.java

@@ -117,8 +117,13 @@
        dataMove.shoppingGoodsZhkNew(dataMove.shoppingGoodsZhkOld());
    }

    @Test
//    @Test
    public void orderMoveTest() {
        dataMove.orderNew(dataMove.orderOld());
    }

    @Test
    public void bedInfoMoveTest() {
        dataMove.bedInfoNew(dataMove.bedInfoOld());
    }
}