增加编辑和删除功能(研究中心调用)

src/main/java/com/zzsn/event/config/interceptor/WebMvcConfig.java

@@ -16,6 +16,6 @@ public class WebMvcConfig implements WebMvcConfigurer {
 
     @Override
     public void addInterceptors(InterceptorRegistry registry) {
-        registry.addInterceptor(userInfoInterceptor()).addPathPatterns("/**").excludePathPatterns("/third/api/saveEvent");
+        registry.addInterceptor(userInfoInterceptor()).addPathPatterns("/**").excludePathPatterns("/third/api/**");
     }
 }

src/main/java/com/zzsn/event/controller/thirdApi/EventApi.java

@@ -12,19 +12,18 @@ import com.zzsn.event.util.CodeGenerateUtil;
 import com.zzsn.event.util.CronUtil;
 import com.zzsn.event.util.DateUtil;
 import com.zzsn.event.util.RedisUtil;
+import com.zzsn.event.vo.EventVO;
 import com.zzsn.event.vo.KeywordsVO;
 import com.zzsn.event.vo.RegionVO;
 import com.zzsn.event.xxljob.service.IXxlJobInfoService;
+import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.transaction.annotation.Transactional;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
@@ -100,6 +99,77 @@ public class EventApi {
         }
     }
 
+    /**
+     * 新增事件(页面简化版)
+     *
+     * @param addEventVO 事件信息
+     * @author lkg
+     * @date 2024/11/11
+     */
+    @PostMapping("/editEvent")
+    public Result<?> editEvent(@RequestBody ThirdAddEventVO addEventVO) {
+        KeywordsVO keywordsVO = addEventVO.getKeywordsVO();
+        if (keywordsVO != null) {
+            simpleUpdate(addEventVO);
+            keyWordsService.update(Wrappers.<KeyWords>lambdaUpdate().eq(KeyWords::getId, keywordsVO.getId())
+                    .set(KeyWords::getKeyWord, keywordsVO.getKeyword())
+                    .set(KeyWords::getExclusionWord, keywordsVO.getExclusionWord()));
+            CompletableFuture.runAsync(()->{
+                //关键词
+                KeyWordsDTO redisKeywordDTO = new KeyWordsDTO();
+                BeanUtils.copyProperties(keywordsVO, redisKeywordDTO);
+                redisKeywordDTO.setKeyWord(keywordsVO.getKeyword());
+                redisKeywordDTO.setStartTime(addEventVO.getStartTime());
+                redisKeywordDTO.setEndTime(addEventVO.getEndTime());
+                redisKeywordDTO.setSearchEngines(new ArrayList<>(Constants.DEFAULT_SEARCH_ENGINE.values()));
+                redisUtil.set(Constants.KEY_WORDS_TO_REDIS_PREFIX + keywordsVO.getWordsCode(), redisKeywordDTO);
+                //为了立即响应，关键词新增时放入一个首次录入消息队列
+                kafkaTemplate.send(Constants.KEY_WORDS_COLLECT_TOPIC, JSON.toJSONString(redisKeywordDTO));
+            });
+            return Result.OK();
+        } else {
+            return Result.FAIL(500, "关键词不能为空");
+        }
+    }
+
+    /**
+     * 通过id删除
+     *
+     * @param id 事件id
+     * @return
+     */
+    @ApiOperation(value = "事件-通过id删除", notes = "事件-通过id删除")
+    @GetMapping(value = "/deleteEvent")
+    public Result<?> delete(@RequestParam(name = "id") String id) {
+        EventVO eventVO = eventService.queryInfo(id);
+        eventService.deleteMain(id);
+        CompletableFuture.runAsync(() -> {
+            iXxlJobInfoService.deleteByInfosourceCode(eventVO.getEventCode());
+            KeywordsVO keywordsVO = eventVO.getKeywordsVO();
+            if (keywordsVO != null) {
+                String wordsCode = keywordsVO.getWordsCode();
+                keyWordsService.remove(Wrappers.<KeyWords>lambdaQuery().eq(KeyWords::getWordsCode, wordsCode));
+                redisUtil.del(Constants.KEY_WORDS_TO_REDIS_PREFIX + wordsCode);
+                iXxlJobInfoService.deleteByInfosourceCode(wordsCode);
+            }
+        });
+        return Result.OK();
+    }
+
+    public void simpleUpdate(ThirdAddEventVO addEventVO){
+        String eventId = addEventVO.getId();
+        Event event = new Event();
+        BeanUtils.copyProperties(addEventVO, event);
+        event.setUpdateBy(addEventVO.getUsername());
+        event.setUpdateTime(new Date());
+        eventService.updateById(event);
+        CompletableFuture.runAsync(()->{
+            //地域关系绑定
+            List<RegionVO> regionList = addEventVO.getRegionList();
+            addRegionMap(eventId, regionList);
+        });
+    }
+
     @Transactional
     public Event simpleSave(ThirdAddEventVO addEventVO) {
         Event event = new Event();