From dd418b8f751c06cf76cdcfbc4a20b16ee277df09 Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Sat, 22 Nov 2025 10:38:02 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BA=97=E9=93=BA=E8=A3=85=E4=BF=AE=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mall/common/modules/page/ShopPageApp.java | 14 ++ .../number/service/ShopNumberSeqService.java | 2 + .../impl/ShopNumberSeqServiceImpl.java | 40 +++- .../admin/ShopPageAppController.java | 185 ++++++++++++-- .../shop/page/service/ShopPageAppService.java | 5 + .../service/impl/ShopPageAppServiceImpl.java | 226 +++++++++++++++++- sql/shop/dev/20251121_dml.sql | 12 + 7 files changed, 465 insertions(+), 19 deletions(-) create mode 100644 sql/shop/dev/20251121_dml.sql diff --git a/mall-common/src/main/java/com/suisung/mall/common/modules/page/ShopPageApp.java b/mall-common/src/main/java/com/suisung/mall/common/modules/page/ShopPageApp.java index 553e55a5..ae38892a 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/modules/page/ShopPageApp.java +++ b/mall-common/src/main/java/com/suisung/mall/common/modules/page/ShopPageApp.java @@ -1,6 +1,7 @@ package com.suisung.mall.common.modules.page; import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import io.swagger.annotations.ApiModel; @@ -67,5 +68,18 @@ public class ShopPageApp implements Serializable { @ApiModelProperty(value = "是否使用(BOOL):0-否;1-是") private Integer app_is_use; + @ApiModelProperty(value = "模板编号,用于模板市场") + private Integer app_template_id; + @ApiModelProperty(value = "是否收费0否，1是") + private String is_pay; + + @ApiModelProperty(value = "是否发布0否，1是") + private String is_pulish; + + @TableField(exist = false) + private String tpl_label; + + @ApiModelProperty(value = "市场展示图片,用,隔开") + private String app_market_images; } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/number/service/ShopNumberSeqService.java b/mall-shop/src/main/java/com/suisung/mall/shop/number/service/ShopNumberSeqService.java index 34128812..662505bb 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/number/service/ShopNumberSeqService.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/number/service/ShopNumberSeqService.java @@ -37,4 +37,6 @@ public interface ShopNumberSeqService extends IBaseService { List getBatchLibraryProductId(int batchSize); void clearKeyLibraryProductId(); + + List batchCreateShopPageBaseNextNo(int batchSize); } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/number/service/impl/ShopNumberSeqServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/number/service/impl/ShopNumberSeqServiceImpl.java index 4e8c55d8..20b9bb23 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/number/service/impl/ShopNumberSeqServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/number/service/impl/ShopNumberSeqServiceImpl.java @@ -8,6 +8,7 @@ import com.suisung.mall.common.feignService.AccountService; import com.suisung.mall.common.modules.base.ShopBaseProductSpec; import com.suisung.mall.common.modules.library.LibraryProduct; import com.suisung.mall.common.modules.number.ShopNumberSeq; +import com.suisung.mall.common.modules.page.ShopPageBase; import com.suisung.mall.common.modules.product.ShopProductBase; import com.suisung.mall.common.modules.product.ShopProductItem; import com.suisung.mall.common.modules.product.ShopProductSpecItem; @@ -17,6 +18,7 @@ import com.suisung.mall.shop.base.service.ShopBaseProductSpecService; import com.suisung.mall.shop.library.service.LibraryProductService; import com.suisung.mall.shop.number.mapper.ShopNumberSeqMapper; import com.suisung.mall.shop.number.service.ShopNumberSeqService; +import com.suisung.mall.shop.page.service.ShopPageBaseService; import com.suisung.mall.shop.product.service.ShopProductBaseService; import com.suisung.mall.shop.product.service.ShopProductItemService; import com.suisung.mall.shop.product.service.ShopProductSpecItemService; @@ -78,7 +80,8 @@ public class ShopNumberSeqServiceImpl extends BaseServiceImpl batchCreateShopPageBaseNextNo(int batchSize) { + // 定义锁的key，这个key在所有服务实例中必须一致 + String lockKey = "LOCK:" + RedisKey.STOREDATASHOPBASEPAGE; + // 2. 获取分布式锁对象 + RLock lock = redissonClient.getLock(lockKey); + boolean isLocked = false; + long start = 0; + try { + isLocked=lock.tryLock(2,30,TimeUnit.SECONDS); + if (!isLocked) { + // 获取锁失败，可以根据业务逻辑进行重试或抛出异常 + throw new ApiException("系统繁忙，请稍后再试"); + } + log.info("成功获得锁：{}",lockKey); + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.select("max(page_id) as page_id"); + ShopPageBase shopPageBase = shopPageBaseService.getOne(queryWrapper); + if (null != shopPageBase) { + start = shopPageBase.getPage_id(); + } + return LongStream.rangeClosed(start + 1, start + batchSize).boxed().collect(Collectors.toList()); + } catch (InterruptedException e) { + throw new ApiException(e); + }finally { + // 5. 最终检查并释放锁，确保锁一定被释放 + if (lock != null && lock.isLocked() && lock.isHeldByCurrentThread()) { + lock.unlock(); + } + log.info("成功释放锁：{}",lockKey); + } + } + /** * 初始化主键 */ @@ -500,4 +536,6 @@ public class ShopNumberSeqServiceImpl extends BaseServiceImpl items =null; try { - data_arr = cloundService.getAppTpl(accountBaseConfigService.getConfig("service_user_id", 0), accountBaseConfigService.getConfig("service_app_key", ""), null); + // data_arr = cloundService.getAppTpl(accountBaseConfigService.getConfig("service_user_id", 0), accountBaseConfigService.getConfig("service_app_key", ""), null); + if(user.isStore()) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("store_id", user.getStore_id()); + List shopPageAppList= shopPageAppService.list(queryWrapper); + if(shopPageAppList.isEmpty()) { + String resultStr= accountBaseConfigService.getSystemConfig("service_app_tpl"); + JSONObject jsonObject = JSONUtil.parseObj(resultStr); + data_arr = (Map)jsonObject.get("data"); + items_arr = (JSONArray) data_arr.get("items"); + items = JSONUtil.toList(items_arr, Map.class); + }else { + Gson gson = new Gson(); + String gsonStrList= gson.toJson(shopPageAppList); + items = JSONUtil.toList(gsonStrList, Map.class); + } + }else { + String resultStr= accountBaseConfigService.getSystemConfig("service_app_tpl"); + JSONObject jsonObject = JSONUtil.parseObj(resultStr); + data_arr = (Map)jsonObject.get("data"); + items_arr = (JSONArray) data_arr.get("items"); + items = JSONUtil.toList(items_arr, Map.class); + } + } catch (Exception e) { throw new RuntimeException(e); } - JSONArray items_arr = (JSONArray) data_arr.get("items"); - List items = JSONUtil.toList(items_arr, Map.class); Map current_tpl = new HashMap(); @@ -91,19 +113,18 @@ public class ShopPageAppController extends BaseControllerImpl { while (it.hasNext()) { Map item = it.next(); Integer tpl_id = Convert.toInt(item.get("tpl_id")); - String tpl_label = item.get("tpl_label").toString(); - + String tpl_label =CommonUtil.getTplLable(tpl_id); + //String tpl_label = item.get("tpl_label").toString(); + item.put("tpl_label",tpl_label); if (user.isStore()) { //读取店铺信息store_template ShopStoreInfo shopStoreInfo = shopStoreInfoService.get(user.getStore_id()); - if (tpl_id > 1000 || tpl_id == 109 || tpl_id == 105 || tpl_id == 10/* || tpl_id == 107*/) { it.remove(); continue; } - - - if (shopStoreInfo.getStore_template().equals(tpl_label)) { + String appId= String.valueOf(item.get("app_id")); + if (shopStoreInfo.getStore_template().equals(appId)) { current_tpl = item; } } else { @@ -163,7 +184,7 @@ public class ShopPageAppController extends BaseControllerImpl { @ApiOperation(value = "店铺风格表-编辑app模版", notes = "店铺风格表-编辑app模版") @RequestMapping(value = "/editApp", method = RequestMethod.GET) public ModelAndView diy(@RequestParam(name = "tpl_id", defaultValue = "1012") Integer tpl_id) { - UserDto user = getCurrentUser(); + UserDto user = ContextUtil.getCurrentUser(); if (user == null) { throw new ApiUserException(I18nUtil._("用户信息异常！")); } @@ -355,5 +376,135 @@ public class ShopPageAppController extends BaseControllerImpl { return CommonResult.failed(); } + + /** + * 店铺装修复制 + * + * @param sourceStoreId + * @param targetStoreId + * @return + */ + @RequestMapping(value = "/copyDiyByStore", method = RequestMethod.POST) + public CommonResult copyDiyByStore(@RequestParam(name = "sourceStoreId") Integer sourceStoreId, + @RequestParam(name = "targetStoreId") Integer targetStoreId) { + UserDto user = ContextUtil.getCurrentUser(); + if (user == null) { + throw new ApiUserException(I18nUtil._("用户信息异常！")); + } + + return CommonResult.success(shopPageAppService.copyDiyByStore(sourceStoreId, targetStoreId)); + } + + /** + * 店铺装修复制 + * + * @param appId 复制模板的id + * @param newAppName 新模板名称 + * @return + */ + @RequestMapping(value = "/copyDiyByAppId", method = RequestMethod.POST) + public CommonResult copyDiyByAppId(@RequestParam(name = "appId") Integer appId, + @RequestParam(name = "appName") String newAppName) { + UserDto user = ContextUtil.getCurrentUser(); + if (user == null) { + throw new ApiUserException(I18nUtil._("用户信息异常！")); + } + + return CommonResult.success(shopPageAppService.copyDiyByAppId(appId, newAppName)); + } + + /** + * 上传模板市场 + * @param appId 模板的id + * @param isPublish 发布状态 + * @return + */ + @RequestMapping(value = "/pageAppPubish", method = RequestMethod.POST) + public CommonResult pageAppPubish(@RequestParam(name = "appId") Integer appId, + @RequestParam(name = "isPublish") String isPublish) { + UserDto user = ContextUtil.getCurrentUser(); + if (user == null) { + throw new ApiUserException(I18nUtil._("用户信息异常！")); + } + ShopPageApp shopPageApp= shopPageAppService.get(appId); + if(null == shopPageApp){ + return CommonResult.failed("不存在模板"); + } + String storeId= user.getStore_id(); + if(user.isPlatform()){ + shopPageApp.setIs_pulish(isPublish); + shopPageAppService.edit(shopPageApp); + }else { + if(!Objects.equals(storeId, String.valueOf(shopPageApp.getStore_id()))){ + return CommonResult.failed("权限不足"); + } + shopPageApp.setIs_pulish(isPublish); + shopPageAppService.edit(shopPageApp); + } + + return CommonResult.success("操作成功"); + } + + + /** + * 分页查询市场模板 + * @param pageNum + * @param pageSize + * @return + */ + @ApiOperation(value = "店铺风格表-分页查询市场模板", notes = "店铺风格表-分页查询市场模板") + @RequestMapping(value = "/listMarketPage", method = RequestMethod.GET) + public Page listMarketPage(@RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, + @RequestParam(name = "pageSize", defaultValue = "100") Integer pageSize) { + UserDto user = ContextUtil.getCurrentUser(); + if (user == null) { + throw new ApiException("无权限"); + } + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("is_pulish", "1"); + String appName= getParameter("appName"); + if(StringUtils.isNotEmpty(appName)){ + queryWrapper.like("app_name", appName); + } + Page shopPageAppPage= shopPageAppService.lists(queryWrapper,pageNum,pageSize); + List shopPageAppPageList = shopPageAppPage.getRecords(); + for (ShopPageApp shopPageApp : shopPageAppPageList) { + String tpl_label = CommonUtil.getTplLable(shopPageApp.getTpl_id()); + shopPageApp.setTpl_label(tpl_label); + } + shopPageAppPage.setRecords(shopPageAppPageList); + return shopPageAppPage; + } + + /** + * 市场app编辑 + * @param shopPageApp + * @return + */ + @ApiOperation(value = "店铺风格表-市场app编辑", notes = "店铺风格表-市场app编辑") + @RequestMapping(value = "/editPageApp", method = RequestMethod.POST) + public CommonResult editPageApp(@RequestBody ShopPageApp shopPageApp) { + UserDto user = ContextUtil.getCurrentUser(); + if (user == null) { + throw new ApiException("无权限"); + } + if(null==shopPageApp.getApp_id()){ + throw new ApiException("修改的appid不能为空"); + } + ShopPageApp editShopPageApp= shopPageAppService.get(shopPageApp.getApp_id()); + if(null==editShopPageApp){ + return CommonResult.failed("不存在模板"); + } + if(Integer.valueOf(user.getStore_id())!=editShopPageApp.getStore_id()){ + return CommonResult.failed("不能跨店编辑"); + } + editShopPageApp.setApp_name(shopPageApp.getApp_name()); + editShopPageApp.setIs_pulish(shopPageApp.getIs_pulish()); + editShopPageApp.setApp_market_images(shopPageApp.getApp_market_images()); + editShopPageApp.setTpl_image(shopPageApp.getTpl_image()); + shopPageAppService.edit(editShopPageApp); + return CommonResult.success(); + } + } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/page/service/ShopPageAppService.java b/mall-shop/src/main/java/com/suisung/mall/shop/page/service/ShopPageAppService.java index da5981b7..6cba0730 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/page/service/ShopPageAppService.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/page/service/ShopPageAppService.java @@ -1,5 +1,6 @@ package com.suisung.mall.shop.page.service; +import com.suisung.mall.common.api.CommonResult; import com.suisung.mall.common.modules.page.ShopPageApp; import com.suisung.mall.core.web.service.IBaseService; import org.springframework.web.servlet.ModelAndView; @@ -53,4 +54,8 @@ public interface ShopPageAppService extends IBaseService { Map getModuleTpl(); Map getPageModule(Long page_id); + + CommonResult copyDiyByStore(Integer sourceStoreId, Integer tpl_id); + + CommonResult copyDiyByAppId(Integer appId,String a); } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/page/service/impl/ShopPageAppServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/page/service/impl/ShopPageAppServiceImpl.java index 44d32165..f60a72a6 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/page/service/impl/ShopPageAppServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/page/service/impl/ShopPageAppServiceImpl.java @@ -9,6 +9,7 @@ import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.suisung.mall.common.api.CommonResult; import com.suisung.mall.common.api.ResultCode; import com.suisung.mall.common.constant.ConfigConstant; import com.suisung.mall.common.domain.UserDto; @@ -18,26 +19,33 @@ import com.suisung.mall.common.modules.base.ShopBaseProductCategory; import com.suisung.mall.common.modules.base.ShopPageModule; import com.suisung.mall.common.modules.page.ShopPageApp; import com.suisung.mall.common.modules.page.ShopPageBase; +import com.suisung.mall.common.modules.product.ShopPageUserForm; import com.suisung.mall.common.modules.store.ShopStoreInfo; import com.suisung.mall.common.utils.CheckUtil; +import com.suisung.mall.common.utils.ContextUtil; import com.suisung.mall.common.utils.I18nUtil; import com.suisung.mall.core.web.service.CloundService; import com.suisung.mall.core.web.service.impl.BaseServiceImpl; import com.suisung.mall.shop.base.service.AccountBaseConfigService; import com.suisung.mall.shop.base.service.ShopBaseProductCategoryService; import com.suisung.mall.shop.config.CookieUtil; +import com.suisung.mall.shop.number.service.ShopNumberSeqService; import com.suisung.mall.shop.page.mapper.ShopPageAppMapper; import com.suisung.mall.shop.page.service.ShopPageAppService; import com.suisung.mall.shop.page.service.ShopPageBaseService; import com.suisung.mall.shop.page.service.ShopPageModuleService; +import com.suisung.mall.shop.product.service.ShopPageUserFormService; +import com.suisung.mall.shop.product.service.impl.ShopPageUserFormServiceImpl; import com.suisung.mall.shop.store.service.ShopStoreInfoService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.servlet.ModelAndView; +import javax.security.sasl.AuthenticationException; import javax.servlet.http.Cookie; import java.util.*; +import java.util.stream.Collectors; import static com.suisung.mall.common.utils.ContextUtil.getCurrentUser; @@ -73,6 +81,11 @@ public class ShopPageAppServiceImpl extends BaseServiceImpl shopStoreInfoQueryWrapper = new QueryWrapper<>(); + shopStoreInfoQueryWrapper.eq("store_id", sourceStoreId); + List sourceShopStore= shopStoreInfoService.list(shopStoreInfoQueryWrapper); + if(sourceShopStore.isEmpty()){ + return CommonResult.failed("来源店铺不存在"); + } + shopStoreInfoQueryWrapper.clear(); + shopStoreInfoQueryWrapper.eq("store_id", targetStoreId); + List targeShopStore= shopStoreInfoService.list(shopStoreInfoQueryWrapper); + if(targeShopStore.isEmpty()){ + return CommonResult.failed("目标店铺不存在"); + } + + QueryWrapper sourceShopPageAppQueryWrapper = new QueryWrapper<>(); + sourceShopPageAppQueryWrapper.eq("store_id", sourceStoreId); + sourceShopPageAppQueryWrapper.eq("app_is_use",1); + List sourceShopPageApps= shopPageAppService.list(sourceShopPageAppQueryWrapper); + if(sourceShopPageApps.isEmpty()){ + return CommonResult.failed("来源店铺不存在模板"); + } + + sourceShopPageAppQueryWrapper.clear(); + sourceShopPageAppQueryWrapper.eq("store_id", targetStoreId); + List targetShopPageApps= shopPageAppService.list(sourceShopPageAppQueryWrapper); + ShopPageApp shopPageApp=null; + if(targetShopPageApps.isEmpty()){ + shopPageApp= sourceShopPageApps.get(0); + shopPageApp.setStore_id(targetStoreId); + shopPageApp.setApp_id(null); + shopPageAppService.save(shopPageApp); + }else { + shopPageApp=targetShopPageApps.get(0); + shopPageApp.setApp_code(sourceShopPageApps.get(0).getApp_code()); + } + + QueryWrapper sourceShopPageBaseQueryWrapper = new QueryWrapper<>(); + sourceShopPageBaseQueryWrapper.eq("store_id", sourceStoreId); + List sourceShopPageBases= shopPageBaseService.list(sourceShopPageBaseQueryWrapper); + if(sourceShopPageBases.isEmpty()){ + return CommonResult.failed("原店铺不存在模板复制"); + } + QueryWrapper targetShopPageBaseQueryWrapper = new QueryWrapper<>(); + targetShopPageBaseQueryWrapper.eq("store_id", targetStoreId); + List targetShopPageBases= shopPageBaseService.list(targetShopPageBaseQueryWrapper); + + List sourceAppIdList= sourceShopPageBases.stream().map(ShopPageBase::getPage_id).collect(Collectors.toList()); + List newShopPageBaseIdList= shopNumberSeqService.batchCreateShopPageBaseNextNo(sourceAppIdList.size()); + + //删除目标appid + if(!targetShopPageBases.isEmpty()){ + //shopPageAppService.remove(targetShopPageBases.get(0).getApp_id()); + List shopPageBasesIds = targetShopPageBases.stream() + .map(ShopPageBase::getPage_id) + .collect(Collectors.toList()); + shopPageBaseService.removeBatchByIds(shopPageBasesIds); + } + + Map shopPageIdsouceTargetMap=getTargetPageIdMap(sourceAppIdList,newShopPageBaseIdList); + ShopPageApp finalShopPageApp = shopPageApp; + + sourceShopPageBases= sourceShopPageBases.stream().peek(shopPageBase -> { + shopPageBase.setPage_id(shopPageIdsouceTargetMap.get(shopPageBase.getPage_id())); + shopPageBase.setApp_id(finalShopPageApp.getApp_id()); + shopPageBase.setStore_id(targetStoreId); + }).collect(Collectors.toList()); + shopPageBaseService.saveBatch(sourceShopPageBases,sourceShopPageBases.size()); + + //赋值模块 + QueryWrapper shopPageModuleQueryWrapper = new QueryWrapper<>(); + shopPageModuleQueryWrapper.in("page_id", sourceAppIdList); + List sourceShopPageModuleList= shopPageModuleService.list(shopPageModuleQueryWrapper); + if(!sourceShopPageModuleList.isEmpty()){ + sourceShopPageModuleList=sourceShopPageModuleList.stream().peek(shopPageModule -> { + shopPageModule.setPm_id(null); + shopPageModule.setPage_id(shopPageIdsouceTargetMap.get(shopPageModule.getPage_id())); + }).collect(Collectors.toList()); + shopPageModuleService.saveBatch(sourceShopPageModuleList,sourceShopPageModuleList.size()); + } + + //动态表单复制，start + //1有先删除 + List shopPageUserFormsTarget= shopPageUserFormService.list(new QueryWrapper().eq("store_id",targetStoreId)); + if(!shopPageUserFormsTarget.isEmpty()){ + List shopPageUserFormIds=shopPageUserFormsTarget.stream().map(ShopPageUserForm::getId).collect(Collectors.toList()); + shopPageUserFormService.removeBatchByIds(shopPageUserFormIds,shopPageUserFormIds.size()); + } + //查询来源是否有表单，有就复制 + List shopPageUserFormsSource= shopPageUserFormService.list(new QueryWrapper().eq("store_id",sourceStoreId)); + if(!shopPageUserFormsSource.isEmpty()){ + shopPageUserFormsSource=shopPageUserFormsSource.stream().peek(shopPageUserForm -> { + shopPageUserForm.setId(null); + shopPageUserForm.setPage_id(shopPageIdsouceTargetMap.get(shopPageUserForm.getPage_id())); + }).collect(Collectors.toList()); + shopPageUserFormService.saveBatch(shopPageUserFormsSource,shopPageUserFormsSource.size()); + } + //动态表单复制，end + + return CommonResult.failed("diy装修模板复制成功"); + } + + @Override + public CommonResult copyDiyByAppId(Integer appId,String appName) { + UserDto userDto= ContextUtil.getCurrentUser(); + if(userDto==null){ + return CommonResult.failed("用户没有登录"); + } + Integer curentStoreId=Integer.valueOf(userDto.getStore_id()); + QueryWrapper shopStoreInfoQueryWrapper = new QueryWrapper<>(); + shopStoreInfoQueryWrapper.eq("store_id", curentStoreId); + List sourceShopStore= shopStoreInfoService.list(shopStoreInfoQueryWrapper); + if(sourceShopStore.isEmpty()){ + return CommonResult.failed("店铺不存在"); + } + + QueryWrapper sourceShopPageAppQueryWrapper = new QueryWrapper<>(); + sourceShopPageAppQueryWrapper.eq("app_id", appId); + List sourceShopPageApps= shopPageAppService.list(sourceShopPageAppQueryWrapper); + if(sourceShopPageApps.isEmpty()){ + return CommonResult.failed("不存在模板"); + } + ShopPageApp shopPageApp=sourceShopPageApps.get(0); + Integer appTemplateId=shopPageApp.getApp_template_id(); + shopPageApp= sourceShopPageApps.get(0); + shopPageApp.setStore_id(curentStoreId); + shopPageApp.setApp_template_id(appTemplateId); + shopPageApp.setApp_id(null); + shopPageApp.setApp_is_use(0); + shopPageApp.setApp_name(appName); + shopPageApp.setUser_id(userDto.getId()); + shopPageAppService.save(shopPageApp); + + QueryWrapper sourceShopPageBaseQueryWrapper = new QueryWrapper<>(); + sourceShopPageBaseQueryWrapper.eq("app_id", appId); + List sourceShopPageBases= shopPageBaseService.list(sourceShopPageBaseQueryWrapper); + if(sourceShopPageBases.isEmpty()){ + return CommonResult.failed("不存在复制页面模板"); + } + + List sourceAppIdList= sourceShopPageBases.stream().map(ShopPageBase::getPage_id).collect(Collectors.toList()); + List newShopPageBaseIdList= shopNumberSeqService.batchCreateShopPageBaseNextNo(sourceAppIdList.size()); + + Map shopPageIdsouceTargetMap=getTargetPageIdMap(sourceAppIdList,newShopPageBaseIdList); + ShopPageApp finalShopPageApp = shopPageApp; + sourceShopPageBases= sourceShopPageBases.stream().peek(shopPageBase -> { + shopPageBase.setPage_id(shopPageIdsouceTargetMap.get(shopPageBase.getPage_id())); + shopPageBase.setApp_id(finalShopPageApp.getApp_id()); + shopPageBase.setStore_id(curentStoreId); + }).collect(Collectors.toList()); + shopPageBaseService.saveBatch(sourceShopPageBases,sourceShopPageBases.size()); + + //复制模块 + QueryWrapper shopPageModuleQueryWrapper = new QueryWrapper<>(); + shopPageModuleQueryWrapper.in("page_id", sourceAppIdList); + List sourceShopPageModuleList= shopPageModuleService.list(shopPageModuleQueryWrapper); + if(!sourceShopPageModuleList.isEmpty()){ + sourceShopPageModuleList=sourceShopPageModuleList.stream().peek(shopPageModule -> { + shopPageModule.setPm_id(null); + shopPageModule.setPage_id(shopPageIdsouceTargetMap.get(shopPageModule.getPage_id())); + }).collect(Collectors.toList()); + shopPageModuleService.saveBatch(sourceShopPageModuleList,sourceShopPageModuleList.size()); + } + + //动态表单复制，start + //查询来源是否有表单，有就复制 + List shopPageUserFormsSource= shopPageUserFormService.list(new QueryWrapper().eq("page_id",sourceAppIdList)); + if(!shopPageUserFormsSource.isEmpty()){ + shopPageUserFormsSource=shopPageUserFormsSource.stream().peek(shopPageUserForm -> { + shopPageUserForm.setId(null); + shopPageUserForm.setPage_id(shopPageIdsouceTargetMap.get(shopPageUserForm.getPage_id())); + }).collect(Collectors.toList()); + shopPageUserFormService.saveBatch(shopPageUserFormsSource,shopPageUserFormsSource.size()); + } + //动态表单复制，end + + return CommonResult.failed("diy装修模板复制成功"); + } + + + /** + * 生产新的id + * @param sourceShopPageIdList + * @param targetShopPageIdList + * @return + */ + private Map getTargetPageIdMap(List sourceShopPageIdList, List targetShopPageIdList){ + Map resultMap=new HashMap<>(); + for(int i=0; i