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