From ed0e5ad132a7e6783fd7c2ab59e18015fa9158ab Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Fri, 26 Mar 2021 14:10:45 +0800
Subject: [PATCH] modify

---
 zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java |   59 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 59 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 60b4d0b..84e51b6 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
@@ -1037,4 +1037,63 @@
         }
     }
 
+    @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;
+    }
+
+    @Autowired
+    private SysProjUseDao sysProjUseDao;
+
+    @Transactional(rollbackFor = Exception.class)
+    public void projUseNew(List<SysProjUse> list) {
+        if (CollUtil.isNotEmpty(list)) {
+            Map<Long, Long> map = new HashMap<>();
+            for (SysProjUse sysProjUse : list) {
+                if(sysProjUse.getType() == "套餐卡") {
+                    sysProjUse.setType("套餐");
+                } else if (StrUtil.isEmpty(sysProjUse.getType())){
+                    sysProjUse.setType("项目");
+                }
+
+                Long oldId = sysProjUse.getId();
+                sysProjUse.setId(null);
+                sysProjUseDao.insert(sysProjUse);
+                map.put(oldId, sysProjUse.getId());
+            }
+        }
+    }
+
 }

--
Gitblit v1.9.1