删除信息接口改造，支持指定人删除

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageProducerController.java

@@ -44,8 +44,9 @@ public class BizMessageProducerController {
     @ApiOperation("删除信息.")
     @DeleteMapping
     @ResponseStatus(code = HttpStatus.OK)
-    public BaseResponse<Map<String,Integer>> deleteMessageByCode(@ApiParam(value = "消息内容", required = true)@RequestParam("code") String code) {
+    public BaseResponse<Boolean> deleteMessageByCode(@RequestParam(value = "code",required = true) String code,
+                                                                 @RequestParam(value = "userId",required = false)String userId) {
 
-        return BaseResponse.success(service.deleteMessageByCode(code));
+        return BaseResponse.success(service.deleteMessageByCode(code,userId));
     }
 }

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java

@@ -25,5 +25,5 @@ public interface BizMessageMapper extends BaseMapper<BizMessage> {
 
     Integer deleteMessageByServicecdoe(List<String> magIds);
 
-    Integer deleteAuthorizeByServicecdoe(List<String> magIds);
+    Integer deleteAuthorizeByServicecdoe(@Param("magId")String magId,@Param("userIds")List<String> userIds);
 }

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml

@@ -94,9 +94,12 @@
 
     <delete id="deleteAuthorizeByServicecdoe" parameterType="java.lang.String">
         delete from biz_message_authorize
-        where message_id in
+        where message_id = #{magId}
-        <foreach item="id" collection="magIds" open="(" separator="," close=")">
+        <if test="userIds!=null ">
-            #{id}
+          and user_id in
-        </foreach>
+            <foreach item="id" collection="userIds" open="(" separator="," close=")">
+                #{id}
+            </foreach>
+        </if>
     </delete>
 </mapper>

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageProducerService.java

@@ -10,5 +10,5 @@ public interface BizMessageProducerService {
 
     Optional<BizMessage> produce(BizMessageRawDTO messageRaw);
 
-    Map<String,Integer> deleteMessageByCode(String questId);
+    Boolean deleteMessageByCode(String questId,String userId);
 }

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java

@@ -26,10 +26,7 @@ import org.springframework.util.Assert;
 
 import java.io.IOException;
 import java.io.StringWriter;
-import java.util.HashMap;
+import java.util.*;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
 import java.util.stream.Collectors;
 
 /**
@@ -168,20 +165,19 @@ public class BizMessageProducerServiceImpl implements BizMessageProducerService
      * @return
      */
     @Override
-    public Map<String,Integer> deleteMessageByCode(String questId) {
+    public Boolean deleteMessageByCode(String questId,String userId) {
         List<BizMessage> messageList =  messageMapper.findMessageByLikeCode(questId);
         log.info(" 删除查询结果 messageList： "+messageList);
         List<String> magIds = messageList.stream().map(BizMessage::getId).distinct().collect(Collectors.toList());
         Map<String,Integer> map = new HashMap<>();
-        Integer m = new Integer(0);
-        Integer a = new Integer(0);
         if(magIds!=null&&magIds.size()>0) {
-             m = messageMapper.deleteMessageByServicecdoe(magIds);
+            List<String> userIds = new ArrayList<>();
-             a = messageMapper.deleteAuthorizeByServicecdoe(magIds);
+            userIds.add(userId);
+            magIds.forEach(magid->{
+                messageMapper.deleteAuthorizeByServicecdoe(magid,userIds);
+            });
         }
-        map.put("deleteMessage", m);
+        return true;
-        map.put("deleteAuthorize", a);
-        return map;
     }
 
 }