From d388e2788b7ef088d7cd40f901b0acdcec460bc3 Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Thu, 01 Apr 2021 00:19:23 +0800
Subject: [PATCH] modify

---
 zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java |  458 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 444 insertions(+), 14 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 3b8a9d1..086cf75 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
@@ -13,7 +13,9 @@
 import com.matrix.system.hive.bean.*;
 import com.matrix.system.hive.dao.*;
 import com.matrix.system.hive.service.SysVipInfoService;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.EmptyResultDataAccessException;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -54,6 +56,8 @@
     private ShoppingGoodsDao shoppingGoodsDao;
     @Autowired
     private ShoppingGoodsAssembleDao shoppingGoodsAssembleDao;
+    @Autowired
+    private MoneyCardUseDao moneyCardUseDao;
 
     @Autowired
     private RedisClient redisClient;
@@ -775,15 +779,20 @@
         Map<String, Integer> goodCZK = getRedisIds("shopping_goods_czk");
         Map<String, Integer> goodZHK = getRedisIds("shopping_goods_zhk");
         Map<String, Integer> shopIds = getRedisIds("shopId");
-        Map<String, Integer> sysUsers = getRedisIds("sys_users");
+//        Map<String, Integer> sysUsers = getRedisIds("sys_users");
         Map<String, Integer> vipInfos = getRedisIds("vip_info");
+        Map<String, Integer> shopStaff = getRedisIds("shop_staff");
         for (SysOrder order : orders) {
             List<Map<String, Object>> itemsMap = jdbcTemplate.queryForList("select * from sys_order_item where ORDER_ID=" + order.getId());
 
             Integer shopId = shopIds.get(order.getShopId().toString());
             order.setShopId(shopId.longValue());
 
-            Integer statffId = sysUsers.get(order.getStaffId().toString());
+            if ("已付款".equals(order.getStatu()) || "欠款".equals(order.getStatu())) {
+                order.setPayTime(order.getOrderTime());
+            }
+
+            Integer statffId = shopStaff.get(order.getStaffId().toString());
             if (statffId != null) {
                 order.setStaffId(statffId.longValue());
             } else {
@@ -904,14 +913,14 @@
                     } else {
                         achieve.setAchieveType("美疗师业绩");
                     }
-                    Integer beaultId = sysUsers.get(achieve.getBeaultId().toString());
+                    Integer beaultId = shopStaff.get(achieve.getBeaultId().toString());
                     if (beaultId != null) {
                         achieve.setBeaultId(beaultId.longValue());
                     } else {
                         achieve.setBeaultId(-achieve.getBeaultId());
                     }
 
-                    Integer saleId = sysUsers.get(achieve.getSaleId().toString());
+                    Integer saleId = shopStaff.get(achieve.getSaleId().toString());
                     if (saleId != null) {
                         achieve.setSaleId(saleId.longValue());
                     } else {
@@ -944,6 +953,7 @@
         flow.setVipId(sysOrder.getVipId());
         flow.setShopId(sysOrder.getShopId());
         flow.setCompanyId(sysOrder.getCompanyId());
+        flow.setPayMethod(type);
         return flow;
     }
 
@@ -968,24 +978,40 @@
                 sysOrderDao.insert(sysOrder);
                 orderIds.put(oldOrderId, sysOrder.getId());
 
-                for (SysOrderItem item : sysOrder.getItems()) {
-                    Long oldItemId = item.getId();
-                    item.setOrderId(sysOrder.getId());
-                    item.setId(null);
-                    sysOrderItemDao.insert(item);
-                    itemIds.put(oldItemId, item.getId());
+                if (CollUtil.isNotEmpty(sysOrder.getItems())) {
+                    for (SysOrderItem item : sysOrder.getItems()) {
+                        Long oldItemId = item.getId();
+                        item.setOrderId(sysOrder.getId());
+                        item.setId(null);
+                        sysOrderItemDao.insert(item);
+                        itemIds.put(oldItemId, item.getId());
+                    }
                 }
 
-                for (SysOrderFlow flow : sysOrder.getFlows()) {
-                    flow.setOrderId(oldOrderId);
-                    sysOrderFlowDao.insert(flow);
+                if (CollUtil.isNotEmpty(sysOrder.getFlows())) {
+                    for (SysOrderFlow flow : sysOrder.getFlows()) {
+                        if ("储值卡".equals(flow.getPayMethod())) {
+                            MoneyCardUse moneyCardUse = new MoneyCardUse();
+                            moneyCardUse.setIsVipCar("Y");
+                            moneyCardUse.setVipId(flow.getVipId());
+                            List<MoneyCardUse> moneyCardUses = moneyCardUseDao.selectVipCardUse(moneyCardUse);
+                            if (CollUtil.isNotEmpty(moneyCardUses)) {
+                                flow.setCardId(moneyCardUses.get(0).getId());
+                            }
+                        }
+                        flow.setOrderId(sysOrder.getId());
+                        flow.setCreateBy("数据迁移");
+                        sysOrderFlowDao.insert(flow);
+                    }
                 }
 
                 if (CollUtil.isNotEmpty(sysOrder.getAchieveNews())) {
                     for (AchieveNew achieveNew : sysOrder.getAchieveNews()) {
-                        achieveNew.setOrderId(oldOrderId);
+                        achieveNew.setOrderId(sysOrder.getId());
                         Long item = itemIds.get(achieveNew.getOrderItemId());
+                        achieveNew.setT9("数据迁移");
                         achieveNew.setOrderItemId(item);
+                        achieveNew.setId(null);
                     }
 
                     achieveNewDao.batchInsert(sysOrder.getAchieveNews());
@@ -1032,4 +1058,408 @@
         }
     }
 
+    @DS("slave")
+    public List<SysProjUse> projUseMoveOld() {
+        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select\n" +
+                                                                            "\t\ta.ID,\n" +
+                                                                            "\t\ta.VIP_ID,\n" +
+                                                                            "\t\ta.TAOCAN_ID,\n" +
+                                                                            "\t\ta.FAIL_TIME,\n" +
+                                                                            "\t\ta.SOURCE,\n" +
+                                                                            "\t\ta.STATUS,\n" +
+                                                                            "\t\ta.ORDER_ITEM_ID,\n" +
+                                                                            "\t\ta.PLATFORM_FLAG,\n" +
+                                                                            "\t\ta.type,\n" +
+                                                                            "\t\ta.balance,\n" +
+                                                                            "\t\ta.remark,\n" +
+                                                                            "        b.name projName,\n" +
+                                                                            "        sum(a.SURPLUS_COUNT) SURPLUS_COUNT\n" +
+                                                                            "\t\tfrom sys_proj_use a\n" +
+                                                                            "\t\tleft join shopping_goods b on a.TAOCAN_ID= b.ID\n" +
+                                                                            "where TAOCAN_ID IS NOT NULL\n" +
+                                                                            "GROUP BY PLATFORM_FLAG\n" +
+                                                                            "order by a.status");
+        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");
+        Map<String, Integer> order_item = getRedisIds("order_item");
+        for (SysProjUse projUse : projUses) {
+            projUse.setType("套餐");
+            if (projUse.getTaocanId() != null) {
+                Integer tcId = goodTc.get(projUse.getTaocanId().toString());
+                if (tcId != null) {
+                    projUse.setProjId(tcId.longValue());
+                } else {
+                    projUse.setProjId(-projUse.getTaocanId());
+                }
+            }
+
+            Integer vipId = vipInfos.get(projUse.getVipId().toString());
+            if (vipId != null) {
+                projUse.setVipId(vipId.longValue());
+            } else {
+                projUse.setVipId(-projUse.getVipId());
+            }
+
+            if (projUse.getOrderItemId() != null && projUse.getOrderItemId() != 1) {
+                Integer itemID = order_item.get(projUse.getOrderItemId().toString());
+                if (itemID != null) {
+                    projUse.setOrderItemId(itemID.longValue());
+                } else {
+                    projUse.setOrderItemId(-projUse.getOrderItemId());
+                }
+            }
+
+            if ("无效".equals(projUse.getStatus())) {
+                projUse.setIsOver("Y");
+            }
+
+            List<Map<String, Object>> projInfos = jdbcTemplate.queryForList("select a.*, b.PROJ_NAME from sys_proj_use a\n" +
+                                                                                "left join sys_proj_info b on a.PROJ_ID=b.ID\n" +
+                                                                                "where PLATFORM_FLAG='" + projUse.getPlatformFlag()+"'");
+
+            List<SysProjUse> projInfoUses = mapsToListBean(projInfos, SysProjUse.class);
+            for (SysProjUse projInfoUse : projInfoUses) {
+                if (projInfoUse.getProjId() != null) {
+                    Integer projId = goodProj.get(projInfoUse.getProjId().toString());
+                    if (projId != null) {
+                        projInfoUse.setProjId(projId.longValue());
+                    } else {
+                        projInfoUse.setProjId(-projInfoUse.getProjId());
+                    }
+                }
+
+                Integer vipId2 = vipInfos.get(projInfoUse.getVipId().toString());
+                if (vipId2 != null) {
+                    projInfoUse.setVipId(vipId2.longValue());
+                } else {
+                    projInfoUse.setVipId(-projInfoUse.getVipId());
+                }
+                projInfoUse.setType("项目");
+            }
+
+            projUse.setTaocanProjUse(projInfoUses);
+        }
+
+        List<Map<String, Object>> projUsesInfoMap = jdbcTemplate.queryForList("select a.*, b.PROJ_NAME from sys_proj_use a left join sys_proj_info b on a.PROJ_ID=b.id where TAOCAN_ID is null");
+        List<SysProjUse> sysProjUses = mapsToListBean(projUsesInfoMap, SysProjUse.class);
+        for (SysProjUse sysProjUse : sysProjUses) {
+            sysProjUse.setType("项目");
+            sysProjUse.setDeductionNum(1);
+
+            if (sysProjUse.getProjId() != null) {
+                Integer projId = goodProj.get(sysProjUse.getProjId().toString());
+                if (projId != null) {
+                    sysProjUse.setProjId(projId.longValue());
+                } else {
+                    sysProjUse.setProjId(-sysProjUse.getProjId());
+                }
+            }
+
+            Integer vipId2 = vipInfos.get(sysProjUse.getVipId().toString());
+            if (vipId2 != null) {
+                sysProjUse.setVipId(vipId2.longValue());
+            } else {
+                sysProjUse.setVipId(-sysProjUse.getVipId());
+            }
+
+            if (sysProjUse.getOrderItemId() != null && sysProjUse.getOrderItemId() != 1) {
+                Integer itemID = order_item.get(sysProjUse.getOrderItemId().toString());
+                if (itemID != null) {
+                    sysProjUse.setOrderItemId(itemID.longValue());
+                } else {
+                    sysProjUse.setOrderItemId(-sysProjUse.getOrderItemId());
+                }
+            }
+            projUses.add(sysProjUse);
+        }
+        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) {
+                Long oldId = sysProjUse.getId();
+                sysProjUse.setId(null);
+                sysProjUse.setCreateBy("数据迁移");
+                sysProjUse.setTaocanId(null);
+
+                List<SysProjUse> taocanProjUses = sysProjUse.getTaocanProjUse();
+                if (CollUtil.isNotEmpty(taocanProjUses)) {
+                    sysProjUse.setIsCourse("N");
+                    sysProjUseDao.insert(sysProjUse);
+                    for (SysProjUse taocanProjUse : taocanProjUses) {
+                        taocanProjUse.setTaocanId(sysProjUse.getId());
+                        Long projOldId = taocanProjUse.getId();
+                        taocanProjUse.setId(null);
+                        taocanProjUse.setCreateBy("数据迁移");
+                        taocanProjUse.setDeductionNum(1);
+                        sysProjUseDao.insert(taocanProjUse);
+                        map.put(projOldId, taocanProjUse.getId());
+                    }
+                } else {
+                    sysProjUseDao.insert(sysProjUse);
+                }
+
+                map.put(oldId, sysProjUse.getId());
+            }
+
+            redisClient.saveMapValue("proj_use", map);
+        }
+    }
+
+    @DS("slave")
+    public List<SysProjServices> serviceOrderOld() {
+        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from sys_proj_services");
+        List<SysProjServices> list = mapsToListBean(maps, SysProjServices.class);
+
+
+        Map<String, Integer> vipInfos = getRedisIds("vip_info");
+        Map<String, Integer> bedInfos = getRedisIds("bed_info");
+        Map<String, Integer> sysUsers = getRedisIds("sys_users");
+        Map<String, Integer> projUses = getRedisIds("proj_use");
+        Map<String, Integer> goodProj = getRedisIds("shopping_goods_proj");
+        Map<String, Integer> shopIds = getRedisIds("shopId");
+        for (SysProjServices sysProjServices : list) {
+            List<Map<String, Object>> beauticiansMap = jdbcTemplate.queryForList("select * from sys_beautician_state where SERVICES_ID=" + sysProjServices.getId());
+//            Map<String, Object> bedStatesMap = jdbcTemplate.queryForMap("select * from sys_bed_state where SERVICE_ID=" + sysProjServices.getId());
+//            List<Map<String, Object>> achieveMaps = jdbcTemplate.queryForList("select * from achieve_new where service_order_id=" + sysProjServices.getId());
+
+
+            SysBedState query = new SysBedState();
+            query.setServiceId(sysProjServices.getId());
+            List<SysBedState> queryBeds = sysBedStateDao.selectByModel(query);
+            SysBedState bedStates = null;
+            if (CollUtil.isNotEmpty(queryBeds)) {
+                bedStates = queryBeds.get(0);
+            }
+            List<SysBeauticianState> beauticians = mapsToListBean(beauticiansMap, SysBeauticianState.class);
+            List<AchieveNew> achieveNews = achieveNewDao.selectAchieveByServiceOrderId(sysProjServices.getId());
+//            SysBedState bedStates = mapToBane(bedStatesMap, SysBedState.class);
+
+            Integer shopId = shopIds.get(sysProjServices.getShopId().toString());
+            if (shopId != null) {
+                sysProjServices.setShopId(shopId.longValue());
+            } else {
+                sysProjServices.setShopId(-sysProjServices.getShopId());
+            }
+
+            if (sysProjServices.getBedId() != null) {
+                Integer bedId = bedInfos.get(sysProjServices.getBedId().toString());
+                if (bedId != null) {
+                    sysProjServices.setBedId(bedId.longValue());
+                    bedStates.setBedId(bedId.longValue());
+                } else {
+                    sysProjServices.setBedId(-sysProjServices.getBedId());
+                    bedStates.setBedId(-sysProjServices.getBedId());
+                }
+                sysProjServices.setBedState(bedStates);
+            }
+
+            if (sysProjServices.getBeauticianId() != null) {
+                Integer beautyId = sysUsers.get(sysProjServices.getBeauticianId().toString());
+                if (beautyId != null) {
+                    sysProjServices.setBeauticianId(beautyId.longValue());
+                } else {
+                    sysProjServices.setBeauticianId(-sysProjServices.getBeauticianId());
+                }
+            }
+
+            if (sysProjServices.getDevisionId() != null) {
+                Integer devisionId = sysUsers.get(sysProjServices.getDevisionId().toString());
+                if (devisionId != null) {
+                    sysProjServices.setDevisionId(devisionId.longValue());
+                } else {
+                    sysProjServices.setDevisionId(-sysProjServices.getDevisionId());
+                }
+            }
+
+            if (sysProjServices.getCreateStaffId() != null) {
+                Integer staffId = sysUsers.get(sysProjServices.getCreateStaffId().toString());
+                if (staffId != null) {
+                    sysProjServices.setCreateStaffId(staffId.longValue());
+                } else {
+                    sysProjServices.setCreateStaffId(-sysProjServices.getCreateStaffId());
+                }
+            }
+            Integer vipId = null;
+            if (sysProjServices.getVipId() != null) {
+                vipId = vipInfos.get(sysProjServices.getVipId().toString());
+                if (vipId != null) {
+                    sysProjServices.setVipId(vipId.longValue());
+                } else {
+                    sysProjServices.setVipId(-sysProjServices.getVipId());
+                }
+            }
+
+            if (CollUtil.isNotEmpty(beauticians)) {
+                List<SysBeauticianState> newBeautician = new ArrayList<>();
+                for (SysBeauticianState beautician : beauticians) {
+                    List<Map<String, Object>> beaProjMaps = jdbcTemplate.queryForList("select distinct proj_id from service_bea_proj where ser_proj_id is not null and bea_state_id=" + beautician.getId());
+                    for (Map<String, Object> beaProjMap : beaProjMaps) {
+                        SysBeauticianState beauticianState = new SysBeauticianState();
+                        BeanUtils.copyProperties(beautician, beauticianState);
+                        String puseIdStr = beaProjMap.get("proj_id").toString();
+                        Integer puseId = projUses.get(puseIdStr);
+                        beauticianState.setPuseId(puseId != null ? puseId.longValue() : -Long.parseLong(puseIdStr));
+
+                        SysProjUse sysProjUse = sysProjUseDao.selectById(Long.parseLong(puseIdStr));
+//                        Map<String, Object> projUseMap = jdbcTemplate.queryForMap("select * from sys_proj_use where id=" + puseIdStr);
+                        if (sysProjUse != null) {
+                            Integer goodsProjId = goodProj.get(sysProjUse.getProjId().toString());
+                            beauticianState.setProjId(goodsProjId != null ? goodsProjId.longValue() : -Long.parseLong(sysProjUse.getProjId().toString()));
+                        }
+
+                        beauticianState.setCount(1);
+                        beauticianState.setExtract("数据迁移");
+                        newBeautician.add(beauticianState);
+                    }
+                }
+                sysProjServices.setServiceItems(newBeautician);
+            }
+
+            if (CollUtil.isNotEmpty(achieveNews)) {
+                for (AchieveNew achieveNew : achieveNews) {
+                    achieveNew.setShopId(shopId != null ? shopId.longValue() : -achieveNew.getShopId());
+                    achieveNew.setVipId(vipId != null ? vipId.longValue() : -achieveNew.getVipId());
+
+                    Integer saleIdInt = sysUsers.get(achieveNew.getSaleId() == null ? "" : achieveNew.getSaleId().toString());
+                    achieveNew.setSaleId(saleIdInt == null ? -achieveNew.getSaleId() : saleIdInt);
+
+                    Integer beaultyIdInt = sysUsers.get(achieveNew.getBeaultId() == null ? "" : achieveNew.getBeaultId().toString());
+                    achieveNew.setBeaultId(beaultyIdInt == null ? -achieveNew.getBeaultId() : beaultyIdInt);
+
+                    if (achieveNew.getShoppingGoodsId() != null) {
+                        Integer goodsId = goodProj.get(achieveNew.getShoppingGoodsId().toString());
+                        achieveNew.setShoppingGoodsId(goodsId == null ? -achieveNew.getShoppingGoodsId() : goodsId.longValue());
+                    }
+
+                    achieveNew.setT9("数据迁移");
+                }
+            }
+            sysProjServices.setAchieveNews(achieveNews);
+
+        }
+
+
+        return list;
+    }
+
+    @Autowired
+    private SysProjServicesDao sysProjServicesDao;
+    @Autowired
+    private SysBeauticianStateDao sysBeauticianStateDao;
+    @Autowired
+    private SysBedStateDao sysBedStateDao;
+
+    @Transactional(rollbackFor = Exception.class)
+    public void serviceOrderNew(List<SysProjServices> list) {
+        if (CollUtil.isNotEmpty(list)) {
+            Map<Long, Long> maps = new HashMap<>();
+            Map<Long, Long> beautyMaps = new HashMap<>();
+            for (SysProjServices sysProjServices : list) {
+                Long oldId = sysProjServices.getId();
+                sysProjServices.setId(null);
+                sysProjServices.setComment("数据迁移");
+                sysProjServices.setCompanyId(companyId);
+                sysProjServicesDao.insert(sysProjServices);
+                Long newId = sysProjServices.getId();
+                List<SysBeauticianState> serviceItems = sysProjServices.getServiceItems();
+                if (CollUtil.isNotEmpty(serviceItems)) {
+                    for (SysBeauticianState serviceItem : serviceItems) {
+                        serviceItem.setServicesId(newId);
+                        Long beautyOldId = serviceItem.getId();
+                        serviceItem.setId(null);
+                        serviceItem.setExtract("数据迁移");
+                        sysBeauticianStateDao.insert(serviceItem);
+                        beautyMaps.put(beautyOldId, serviceItem.getId());
+                    }
+                }
+                SysBedState bedState = sysProjServices.getBedState();
+                if (bedState != null) {
+                    bedState.setId(null);
+                    bedState.setServiceId(newId);
+                    sysBedStateDao.insert(bedState);
+                }
+
+                List<AchieveNew> achieveNews = sysProjServices.getAchieveNews();
+                if (CollUtil.isNotEmpty(achieveNews)) {
+                    for (AchieveNew achieveNew : achieveNews) {
+                        achieveNew.setId(null);
+                        achieveNew.setOrderItemId(beautyMaps.get(achieveNew.getOrderItemId()));
+                        achieveNew.setServiceOrderId(newId);
+                        achieveNew.setCompanyId(companyId);
+                    }
+                    achieveNewDao.batchInsert(achieveNews);
+                }
+                maps.put(oldId, newId);
+            }
+
+            redisClient.saveMapValue("service_order", maps);
+        }
+    }
+
+    @DS("slave")
+    public List<SysUsers> shopStaffInfoOld() throws UnsupportedEncodingException, NoSuchAlgorithmException {
+        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from sys_shopstaff_info");
+        Map<String, Integer> sysUsersMap = getRedisIds("sys_users");
+        Map<String, Integer> shopMap = getRedisIds("shopId");
+        Map<Long, Long> staffMap = new HashMap<>();
+
+        List<SysUsers> list = new ArrayList<>();
+        // EmptyResultDataAccessException
+        for (Map<String, Object> map : maps) {
+            try {
+                Map<String, Object> staffUser = jdbcTemplate.queryForMap("select * from users where staff_id=" + map.get("id"));
+                Integer id = sysUsersMap.get(staffUser.get("id").toString());
+                staffMap.put(Long.parseLong(map.get("id").toString()), id.longValue());
+            } catch (EmptyResultDataAccessException e) {
+                SysUsers sysUsers = new SysUsers();
+                sysUsers.setSuAccount((String) map.get("staff_no"));
+                sysUsers.setSuId((Long) map.get("id"));
+                sysUsers.setSuName((String) map.get("staff_name"));
+                sysUsers.setSuSex((String) map.get("sex"));
+                sysUsers.setSuUserType("employee");
+                sysUsers.setSuAccountStatus(AppConstance.ACCOUNT_STATUS_INACTIVATED);
+                sysUsers.setSuValid("N");
+                sysUsers.setCompanyId(companyId);
+                Long aaa = (Long) map.get("shop_id");
+                if (aaa != null) {
+                    Integer shopId = shopMap.get(aaa.toString());
+                    if (shopId != null) {
+                        sysUsers.setShopId(Long.parseLong(shopId.toString()));
+                    }
+                }
+                sysUsers.setSuRegisterTime(new Date());
+                sysUsers.setCreateBy(AppConstance.SYSTEM_USER);
+                sysUsers.setUpdateBy(AppConstance.SYSTEM_USER);
+                sysUsers.setSuPassword(PasswordUtil.getEncrypUserPwd(sysUsers));
+                list.add(sysUsers);
+            }
+        }
+        redisClient.saveMapValue("shop_staff", staffMap);
+        return list;
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    public void shopStaffInfoNew(List<SysUsers> list) {
+        Map<String, Integer> shopStaff = getRedisIds("shop_staff");
+        for (SysUsers sysUsers : list) {
+            Long oldId = sysUsers.getSuId();
+            sysUsers.setSuId(null);
+            sysUsersDao.insert(sysUsers);
+            shopStaff.put(oldId.toString(), sysUsers.getSuId().intValue());
+        }
+
+        redisClient.saveMapValue("shop_staff", shopStaff);
+    }
+
+
 }

--
Gitblit v1.9.1