From 2c9c11076949c7739c633204a6b146448b16a4e1 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 25 Mar 2021 18:36:42 +0800
Subject: [PATCH] modify
---
zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java | 72 ++++++++++++++++++++++++++++++++++++
1 files changed, 72 insertions(+), 0 deletions(-)
diff --git a/zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java b/zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java
index 7536626..5b755e5 100644
--- a/zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java
+++ b/zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java
@@ -997,4 +997,76 @@
}
}
+ @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);
+ }
+ }
+
+ @DS("slave")
+ public List<SysProjUse> projUseMoveOld() {
+ List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from sys_proj_use");
+ List<SysProjUse> projUses = mapsToListBean(maps, SysProjUse.class);
+
+ Map<String, Integer> goodProj = getRedisIds("shopping_goods_proj");
+ Map<String, Integer> goodTc = getRedisIds("shopping_goods_tc");
+ Map<String, Integer> vipInfos = getRedisIds("vip_info");
+ for (SysProjUse projUse : projUses) {
+ if (projUse.getTaocanId() != null) {
+ Integer tcId = goodTc.get(projUse.getTaocanId().toString());
+ if (tcId != null) {
+ projUse.setTaocanId(tcId.longValue());
+ } else {
+ projUse.setTaocanId(-projUse.getTaocanId());
+ }
+ }
+
+ if (projUse.getProjId() != null) {
+ Integer projId = goodProj.get(projUse.getProjId().toString());
+ if (projId != null) {
+ projUse.setProjId(projId.longValue());
+ } else {
+ projUse.setProjId(-projUse.getProjId());
+ }
+ }
+
+ Integer vipId = vipInfos.get(projUse.getVipId().toString());
+ if (vipId != null) {
+ projUse.setVipId(vipId.longValue());
+ } else {
+ projUse.setVipId(-projUse.getVipId());
+ }
+ }
+ return projUses;
+ }
+
}
--
Gitblit v1.9.1