From 7dbb4381129baa1e3d7bc66d898461311eb2915c Mon Sep 17 00:00:00 2001 From: zhangqinbin <181961702@qq.com> Date: Thu, 20 Jan 2022 09:03:22 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BizMessageProducerController.java | 10 ++++++++ .../bizmessage/dao/BizMessageMapper.java | 5 ++++ .../dao/mapper/BizMessageMapper.xml | 19 ++++++++++++++ .../service/BizMessageProducerService.java | 2 ++ .../impl/BizMessageProducerServiceImpl.java | 25 +++++++++++++++++++ 5 files changed, 61 insertions(+) diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageProducerController.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageProducerController.java index 964013a..2db2cb8 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageProducerController.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageProducerController.java @@ -6,6 +6,7 @@ import com.chinaunicom.mall.ebtp.extend.bizmessage.vo.DescribeSiteMsgDetailVO; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; +import io.swagger.models.auth.In; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; @@ -13,6 +14,8 @@ import org.springframework.http.HttpStatus; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; +import java.util.Map; + @Slf4j @Api(value = "创建消息", description = "创建消息") @RestController @@ -37,4 +40,11 @@ public class BizMessageProducerController { }).orElseGet(DescribeSiteMsgDetailVO::new); } + @ApiOperation("删除信息.") + @DeleteMapping + @ResponseStatus(code = HttpStatus.OK) + public Map deleteMessageByCode(@ApiParam(value = "消息内容", required = true)String code) { + + return service.deleteMessageByCode(code); + } } diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java index f3e4724..d7e5463 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java @@ -21,4 +21,9 @@ public interface BizMessageMapper extends BaseMapper { List findAuthorizeList(BizMessageAuthorize vo); + List findMessageByLikeCode(String code); + + Integer deleteMessageByServicecdoe(List magIds); + + Integer deleteAuthorizeByServicecdoe(List magIds); } diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml index 9858806..a7f556b 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml @@ -80,4 +80,23 @@ and state = #{state} + + + + + delete from biz_message where id in + + #{id} + + + + + delete from biz_message_authorize + where message_id in + + #{id} + + \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageProducerService.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageProducerService.java index 0efd5de..da43a30 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageProducerService.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageProducerService.java @@ -3,10 +3,12 @@ package com.chinaunicom.mall.ebtp.extend.bizmessage.service; import com.chinaunicom.mall.ebtp.extend.bizmessage.dto.BizMessageRawDTO; import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessage; +import java.util.Map; import java.util.Optional; public interface BizMessageProducerService { Optional produce(BizMessageRawDTO messageRaw); + Map deleteMessageByCode(String questId); } diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java index 89226a0..d127831 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java @@ -1,6 +1,7 @@ package com.chinaunicom.mall.ebtp.extend.bizmessage.service.impl; import cn.hutool.core.lang.Snowflake; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.chinaunicom.mall.ebtp.extend.bizmessage.dao.BizMessageAuthorizeMapper; import com.chinaunicom.mall.ebtp.extend.bizmessage.dao.BizMessageCategoryMapper; @@ -25,8 +26,11 @@ import org.springframework.util.Assert; import java.io.IOException; import java.io.StringWriter; +import java.util.HashMap; +import java.util.List; import java.util.Map; import java.util.Optional; +import java.util.stream.Collectors; /** * 消息生产服务 @@ -159,4 +163,25 @@ public class BizMessageProducerServiceImpl implements BizMessageProducerService return StringUtils.EMPTY; } + /** + * @param questId + * @return + */ + @Override + public Map deleteMessageByCode(String questId) { + List messageList = messageMapper.findMessageByLikeCode(questId); + log.info(" 删除查询结果 messageList： "+messageList); + List magIds = messageList.stream().map(BizMessage::getId).distinct().collect(Collectors.toList()); + Map map = new HashMap<>(); + Integer m = new Integer(0); + Integer a = new Integer(0); + if(magIds!=null&&magIds.size()>0) { + m = messageMapper.deleteMessageByServicecdoe(magIds); + a = messageMapper.deleteAuthorizeByServicecdoe(magIds); + } + map.put("deleteMessage", m); + map.put("deleteAuthorize", a); + return map; + } + }