From 13a843bcbb1bb4fbf48c943910294a81a679ddbd Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Mon, 12 Apr 2021 15:38:36 +0800
Subject: [PATCH] modify

---
 zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java |   45 ++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 44 insertions(+), 1 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 c6ccb3d..84a8cec 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
@@ -1222,7 +1222,7 @@
                         }
 
                         beauticianState.setCount(1);
-                        beauticianState.setExtract("数据迁移");
+//                        beauticianState.setcreate("数据迁移");
                         newBeautician.add(beauticianState);
                     }
                 }
@@ -1364,5 +1364,48 @@
         redisClient.saveMapValue("shop_staff", shopStaff);
     }
 
+    @DS("slave")
+    public List<MoneyCardUse> moneyCardUseOld() {
+        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from money_card_use");
+        List<MoneyCardUse> moneyCardUses = mapsToListBean(maps, MoneyCardUse.class);
+
+        Map<String, Integer> goodCzk = getRedisIds("shopping_goods_czk");
+        Map<String, Integer> vipInfos = getRedisIds("vip_info");
+        for (MoneyCardUse moneyCardUse : moneyCardUses) {
+            moneyCardUse.setIsVipCar("N");
+
+            Integer vipId = null;
+            if (moneyCardUse.getVipId() != null) {
+                vipId = vipInfos.get(moneyCardUse.getVipId().toString());
+                if (vipId != null) {
+                    moneyCardUse.setVipId(vipId.longValue());
+                } else {
+                    moneyCardUse.setVipId(-moneyCardUse.getVipId());
+                }
+            }
+
+            if (moneyCardUse.getGoodsId() != null) {
+                Integer goodsId = goodCzk.get(moneyCardUse.getGoodsId().toString());
+                if (goodsId != null) {
+                    moneyCardUse.setGoodsId(goodsId.longValue());
+                } else {
+                    moneyCardUse.setGoodsId(-moneyCardUse.getGoodsId());
+                }
+            }
+        }
+
+        return moneyCardUses;
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public void moneyCardUseNew(List<MoneyCardUse> list) {
+        if (CollUtil.isNotEmpty(list)) {
+            for (MoneyCardUse moneyCardUse : list) {
+                moneyCardUse.setId(null);
+                moneyCardUse.setSource("美度-数据迁移");
+                moneyCardUseDao.insert(moneyCardUse);
+            }
+        }
+    }
 
 }

--
Gitblit v1.9.1