zq-erp/src/main/java/com/matrix/system/dataMove/DateMoveServiceImpl.java
@@ -1710,4 +1710,48 @@ sysBeauticianStateDao.update(state); } } public void updateVipInfoStaff() { Map<String, Integer> shopStaff = getRedisIds("shop_staff"); List<SysVipInfo> sysVipInfos = sysVipInfoDao.selectStaff(); for (SysVipInfo sysVipInfo : sysVipInfos) { Long staffId = sysVipInfo.getStaffId(); Integer integer = shopStaff.get(staffId.toString()); if (integer == null) { continue; } SysVipInfo update = new SysVipInfo(); update.setStaffId(integer.longValue()); update.setId(sysVipInfo.getId()); sysVipInfoDao.update(update); } } @Transactional(rollbackFor = Exception.class) public void updateProjUseIsCourse() { List<SysProjUse> sysProjUses = sysProjUseDao.selectProjUse(); for (SysProjUse sysProjUs : sysProjUses) { ShoppingGoods shoppingGoods = shoppingGoodsDao.selectById(sysProjUs.getProjId()); SysProjUse update = new SysProjUse(); if (shoppingGoods == null) { continue; } if ("Y".equals(shoppingGoods.getIsCourse())) { update.setIsCourse("Y"); } else { continue; } update.setId(sysProjUs.getId()); sysProjUseDao.update(update); } } } zq-erp/src/main/java/com/matrix/system/hive/dao/SysProjUseDao.java
@@ -132,4 +132,6 @@ List<SysProjUseFlow> selectProjUseFlow(@Param("record") SysProjUseFlow projUseFlow, @Param("pageVo")PaginationVO pageVo); Integer selectProjUseFlowTotal(@Param("record") SysProjUseFlow projUseFlow); List<SysProjUse> selectProjUse(); } zq-erp/src/main/java/com/matrix/system/hive/dao/SysVipInfoDao.java
@@ -208,4 +208,6 @@ List<VipInfoListVo> selectVipAddressBookByList(@Param("record") VipInfoListDto vipInfoListDto); com.matrix.system.app.vo.VipInfoVo selectVipInfoById(@Param("id") Long id); List<SysVipInfo> selectStaff(); } zq-erp/src/main/resources/mybatis/mapper/hive/SysProjUseDao.xml
@@ -859,4 +859,8 @@ </select> <select id="selectProjUse" resultMap="SysProjUseMap"> select * from sys_proj_use where is_course='N' </select> </mapper> zq-erp/src/main/resources/mybatis/mapper/hive/SysVipInfoDao.xml
@@ -1366,5 +1366,9 @@ left join sys_shop_info e on a.SHOP_ID=e.ID where a.ID=#{id} </select> <select id="selectStaff" resultType="com.matrix.system.hive.bean.SysVipInfo"> select * from sys_vip_info where 1000 > staff_id; </select> </mapper> zq-erp/src/test/java/com/matrix/DataMoveTest.java
@@ -4,6 +4,7 @@ import com.matrix.system.hive.bean.SysShopInfo; import com.matrix.system.dataMove.DateMoveServiceImpl; import com.matrix.system.hive.bean.SysVipLevel; import lombok.Data; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; @@ -53,6 +54,11 @@ public void vipLevelMove() { List<SysVipLevel> sysVipLevels = dataMove.vipLevelOld(); dataMove.vipLevelNew(sysVipLevels); } // @Test public void shopStaffMoveTest() throws UnsupportedEncodingException, NoSuchAlgorithmException { dataMove.shopStaffInfoNew(dataMove.shopStaffInfoOld()); } /** @@ -119,11 +125,6 @@ dataMove.shoppingGoodsZhkNew(dataMove.shoppingGoodsZhkOld()); } // @Test public void shopStaffMoveTest() throws UnsupportedEncodingException, NoSuchAlgorithmException { dataMove.shopStaffInfoNew(dataMove.shopStaffInfoOld()); } // @Test public void orderMoveTest() { dataMove.orderNew(dataMove.orderOld()); @@ -134,6 +135,9 @@ dataMove.bedInfoNew(dataMove.bedInfoOld()); } /** * isCourse 不能默认为N */ @Test public void projUseMoveTest() { dataMove.projUseNew(dataMove.projUseMoveOld()); @@ -165,4 +169,14 @@ public void updateServiceOrderStaff() { dataMove.updateServiceOrderStaff(); } @Test public void updateVipInfoStaff() { dataMove.updateVipInfoStaff(); } @Test public void updateProjUseIsCoures() { dataMove.updateProjUseIsCourse(); } }