From 7c038921c9242db70ea751ac45f6cdc6c35e4a2e Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期二, 15 七月 2025 14:59:07 +0800
Subject: [PATCH] 商家端活动申请

---
 framework/src/main/java/cn/lili/modules/lmk/service/impl/ActivityServiceImpl.java |  127 ++++++++++++++++++++++++++++++++++++-----
 1 files changed, 110 insertions(+), 17 deletions(-)

diff --git a/framework/src/main/java/cn/lili/modules/lmk/service/impl/ActivityServiceImpl.java b/framework/src/main/java/cn/lili/modules/lmk/service/impl/ActivityServiceImpl.java
index d911a32..2557297 100644
--- a/framework/src/main/java/cn/lili/modules/lmk/service/impl/ActivityServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/lmk/service/impl/ActivityServiceImpl.java
@@ -3,16 +3,19 @@
 import cn.lili.base.Result;
 import cn.lili.common.enums.ActivityCoverTypeEnum;
 import cn.lili.common.enums.ActivityStatusEnum;
+import cn.lili.common.security.context.UserContext;
 import cn.lili.modules.lmk.domain.entity.Activity;
+import cn.lili.modules.lmk.domain.form.ActivityAuditRecordForm;
 import cn.lili.modules.lmk.domain.form.ActivityForm;
+import cn.lili.modules.lmk.domain.query.ActivityAuditRecordQuery;
 import cn.lili.modules.lmk.domain.query.ActivityMembersQuery;
 import cn.lili.modules.lmk.domain.query.ActivityQuery;
+import cn.lili.modules.lmk.domain.vo.ActivityAuditRecordVO;
 import cn.lili.modules.lmk.domain.vo.ActivityVO;
 import cn.lili.modules.lmk.mapper.ActivityMapper;
-import cn.lili.modules.lmk.mapper.ActivityReportMapper;
+import cn.lili.modules.lmk.service.ActivityAuditRecordService;
 import cn.lili.modules.lmk.service.ActivityService;
 import cn.lili.modules.lmk.service.LmkFileService;
-import cn.lili.modules.lmk.service.MyActivityService;
 import cn.lili.modules.member.entity.vo.MemberVO;
 import cn.lili.utils.COSUtil;
 import cn.lili.utils.PageUtil;
@@ -34,27 +37,32 @@
 
     private final LmkFileService lmkFileService;
 
-    private final MyActivityService activityService;
-
-    private final ActivityReportMapper activityReportMapper;
     private final COSUtil cOSUtil;
 
+    private final ActivityAuditRecordService activityAuditRecordService;
+
+
     @Override
-    public Result add(ActivityForm form) {
+    public Result add(ActivityForm form,Boolean isManager) {
+
         Activity entity = ActivityForm.getEntityByForm(form, null);
+
         //榛樿鏂板娲诲姩涓�
         entity.setStatus(ActivityStatusEnum.NOT_STARTED.getType());
         //榛樿涓嶄负鎺ㄨ崘
         entity.setRecommend(false);
         //榛樿鏈彂甯�
         entity.setPublish(false);
-
+        //璁剧疆鐢宠浜篿d
+        entity.setMemberId(UserContext.getCurrentUserId());
+        entity.setStoreId(UserContext.getCurrentUser().getStoreId());
         baseMapper.insert(entity);
+        mangerSaveOrUpdate(isManager,entity);
         return Result.ok("娣诲姞鎴愬姛");
     }
 
     @Override
-    public Result update(ActivityForm form) {
+    public Result update(ActivityForm form,Boolean isManager) {
 
         Activity entity = baseMapper.selectById(form.getId());
         //鍒ゆ柇淇敼鍓嶇殑灏侀潰绫诲瀷鏄惁涓烘枃鏈紝鏂囨湰涓嶉渶瑕佸垹闄ゆ枃浠�
@@ -70,27 +78,76 @@
         Assert.notNull(entity, "璁板綍涓嶅瓨鍦�");
         BeanUtils.copyProperties(form, entity);
 
+        mangerSaveOrUpdate(isManager,entity);
         baseMapper.updateById(entity);
+
         return Result.ok("淇敼鎴愬姛");
     }
-
+    //鍒ゆ柇璇锋眰鏉ユ簮鏄钩鍙扮杩樻槸灏忕▼搴忕
+    public void mangerSaveOrUpdate(Boolean isManager,Activity entity){
+        ActivityAuditRecordForm activityAuditRecordForm;
+        //娣诲姞瀹℃牳璁板綍
+        if (isManager){
+            //鐩存帴閫氳繃
+            activityAuditRecordForm = ActivityAuditRecordForm.getFormByManager(entity.getId());
+        }else {
+            activityAuditRecordForm = ActivityAuditRecordForm.getFormByBuyer(entity.getId());
+        }
+        activityAuditRecordService.addOrUpdateAuditActivity(activityAuditRecordForm);
+    }
     @Override
     public Result remove(List<String> ids) {
-        baseMapper.deleteBatchIds(ids);
+        //鍒ゆ柇娲诲姩id鏄惁宸茬粡瀛樺湪鎶ュ悕浜哄憳
+        for(String id : ids){
+            if (isPublishActivity(id)){
+                return Result.error("瀛樺湪娲诲姩宸插彂甯冨垹闄ゅ墠璇蜂笅鏋惰娲诲姩锛�");
+            }
+            if(haveApplicationMembers(id)){
+                return Result.error("瀛樺湪娲诲姩宸叉湁鎶ュ悕浜哄憳锛屾棤娉曞垹闄わ紒");
+            }
+
+        }
+        //鏈粡杩噐eturn鍒欏垹闄�
+        for (String id : ids){
+            delActivityAndInformation(id);
+        }
+
         return Result.ok("鍒犻櫎鎴愬姛");
     }
+    //鍒ゆ柇娲诲姩鏄惁瀛樺湪鎶ュ悕浜哄憳
+    public Boolean haveApplicationMembers(String id){
+        ActivityMembersQuery activityMembersQuery = new ActivityMembersQuery();
+        activityMembersQuery.setId(id);
+        return (long) activityMembersPage(activityMembersQuery).get("total") > 0;
+    }
+    //鍒ゆ柇浜掑姩鏄惁鍙戝竷
+    public Boolean isPublishActivity(String id){
+        Activity activity = baseMapper.selectById(id);
+        return activity.getPublish();
+    }
 
-    @Override
-    public Result removeById(String id) {
-        //TODO 鍏堝垽鏂椿鍔ㄦ槸鍚︽湁鎶ュ悕浜哄憳
-        //鏈夌殑璇濅笉鍙垹闄� 鑱斾腑闂磋〃鏌ヨ
-        //鍒犻櫎锛屽悓鏃跺垽鏂瀵硅薄鐨勫皝闈㈡槸鍚﹀瓨鍦� 锛屽瓨鍦ㄥ垯鍦ㄤ簯鏈嶅姟鍣ㄥ垹闄�
+    //鍒犻櫎娲诲姩鍚屾椂鍒犻櫎娲诲姩鐨勭浉鍏充俊鎭�
+    public void delActivityAndInformation(String id){
         ActivityVO vo = baseMapper.getById(id);
         if (StringUtils.isNotEmpty(vo.getCover())){
             lmkFileService.deleteObject(vo.getCover());
         }
         baseMapper.deleteById(id);
+        //鍒犻櫎瀹℃牳璁板綍
+        activityAuditRecordService.delActivityAuditById(id);
+    }
+    @Override
+    public Result removeById(String id) {
+        //鍏堝垽鏂椿鍔ㄦ槸鍚︽湁鎶ュ悕浜哄憳
+        if (isPublishActivity(id)){
+            return Result.error("璇ユ椿鍔ㄥ凡鍙戝竷鍒犻櫎鍓嶈涓嬫灦璇ユ椿鍔紒");
+        }
 
+        if(haveApplicationMembers(id)){
+            return Result.error("璇ユ椿鍔ㄥ凡鏈夋姤鍚嶄汉鍛橈紝鏃犳硶鍒犻櫎锛�");
+        }
+        //鍒犻櫎锛屽悓鏃跺垽鏂瀵硅薄鐨勫皝闈㈡槸鍚﹀瓨鍦� 锛屽瓨鍦ㄥ垯鍦ㄤ簯鏈嶅姟鍣ㄥ垹闄�
+        delActivityAndInformation(id);
         return Result.ok("鍒犻櫎鎴愬姛");
     }
 
@@ -108,6 +165,29 @@
     }
 
     @Override
+    public Result getMyApplyActivityPage(ActivityQuery query){
+
+        //浼犲叆褰撳墠璇锋眰鐢ㄦ埛鐨刬d
+        String storeId = UserContext.getCurrentUser().getStoreId();
+        if (storeId == null){
+            query.setMemberId(UserContext.getCurrentUserId());
+        }else {
+            query.setStoreId(storeId);
+        }
+
+        //鏇村叿鐢ㄦ埛id鑾峰緱娲诲姩
+        IPage<ActivityVO> page = PageUtil.getPage(query, ActivityVO.class);
+        baseMapper.storeGetPage(page, query);
+        for (ActivityVO vo : page.getRecords()) {
+            if (!ActivityCoverTypeEnum.TEXT.getType().equals(vo.getCoverType())){
+                vo.setUrl(cOSUtil.getPreviewUrl(vo.getCover()));
+            }
+        }
+
+        return Result.ok().data(page.getRecords()).total(page.getTotal());
+    }
+
+    @Override
     public Result detail(String id) {
         ActivityVO vo = baseMapper.getById(id);
         Assert.notNull(vo, "璁板綍涓嶅瓨鍦�");
@@ -115,6 +195,7 @@
     }
     @Override
     public Result getCanReportPage(ActivityQuery query){
+        //鏌ヨ鍒扮殑缁撴灉宸茬粡瀹℃牳涓斿彂甯�
         IPage<ActivityVO> page = PageUtil.getPage(query, ActivityVO.class);
         //宸插彂甯冪殑娲诲姩
         baseMapper.getCanReportPage(page, query);
@@ -163,10 +244,22 @@
             if((long)activityMembersPage(activityMembersQuery).get("total") > 0){
                 return Result.error("璇ユ椿鍔ㄦ棤娉曚笅鏋讹紝宸插瓨鍦ㄦ姤鍚嶄汉鍛�");
             }
+            return Result.ok();
+        }else {
+            //鍒ゆ柇璇ユ椿鍔ㄦ槸鍚﹀鏍搁�氳繃
+           if(activityAuditRecordService.getActivityActivityIsAudit(form.getId())){
+               baseMapper.updateById(entity);
+               return Result.ok();
+           }else {
+               return Result.error("娲诲姩鏈�氳繃瀹℃牳");
+           }
+
+
 
         }
-        baseMapper.updateById(entity);
-        return Result.ok();
+
+
+
     }
 
     @Override

--
Gitblit v1.8.0