任务提交 号码黑名单接口完成

common/fire-dto/src/main/java/com/fire/dto/BlacklistPhone.java

@@ -1,12 +1,16 @@
 package com.fire.dto;
 
+import com.baomidou.mybatisplus.annotation.TableName;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 @ApiModel(value = "电话号码黑名单实体")
 @Data
+@TableName("blacklist_phone")
+@NoArgsConstructor
 public class BlacklistPhone {
 
     @ApiModelProperty(value = "号码")
@@ -15,5 +19,4 @@ public class BlacklistPhone {
     @ApiModelProperty(value = "说明")
     private String note;
 
-
 }

modules/admin/src/main/java/com/fire/admin/mapper/BlacklistPhoneMapper.java

@@ -0,0 +1,24 @@
+package com.fire.admin.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fire.dto.BlacklistPhone;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+
+/**
+ * @author: admin
+ * @Description:
+ * @date: 2021-05-19 14:03
+ * @Modified By:
+ */
+public interface BlacklistPhoneMapper extends BaseMapper<BlacklistPhone> {
+
+    IPage<BlacklistPhone> getBlacklistPhone(Page page, @Param("phoneNo") String phoneNo);
+
+    int delPhones (@Param("phones") List<String> phones);
+
+}

modules/admin/src/main/java/com/fire/admin/request/BlacklistPhonePageParam.java

@@ -0,0 +1,22 @@
+package com.fire.admin.request;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @author: admin
+ * @Description:
+ * @date: 2021-05-19 16:19
+ * @Modified By:
+ */
+@ApiModel("银行卡分页请求参数")
+@Getter
+@Setter
+public class BlacklistPhonePageParam extends Page {
+
+    @ApiModelProperty("黑名单号码")
+    private String phoneNo;
+}

modules/admin/src/main/java/com/fire/admin/rest/BlackPhoneNoRest.java

@@ -0,0 +1,52 @@
+package com.fire.admin.rest;
+
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fire.admin.request.BlacklistPhonePageParam;
+import com.fire.admin.service.BlacklistPhoneService;
+import com.fire.dto.BlacklistPhone;
+import com.fire.dto.response.BaseRestResponse;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+
+@Api(tags = "号码黑名单")
+@Slf4j
+@RestController
+@RequestMapping("/blackPhoneNo")
+public class BlackPhoneNoRest {
+
+    @Autowired
+    private BlacklistPhoneService blacklistPhoneService;
+
+    @PostMapping("/search")
+    @ApiOperation(value = "模糊查询号码黑名单")
+    public IPage<BlacklistPhone> search(@RequestBody BlacklistPhonePageParam blacklistPhonePageParam) {
+        return blacklistPhoneService.getBlacklistPhone(blacklistPhonePageParam,blacklistPhonePageParam.getPhoneNo());
+    }
+
+    @PostMapping("/del")
+    @ApiOperation(value = "删除黑名单号码")
+    public BaseRestResponse<String> del(@RequestBody List<String> phoneNos) {
+        return new BaseRestResponse<>(blacklistPhoneService.deleteBlacklistPhone(phoneNos));
+    }
+
+
+    @PostMapping("/add")
+    @ApiOperation(value = "增加黑名单号码")
+    public  BaseRestResponse<String> add(@RequestBody List<BlacklistPhone> blacklistPhone) {
+        return new BaseRestResponse<>(blacklistPhoneService.saveBlacklistPhone(blacklistPhone));
+    }
+
+
+
+
+}
+

modules/admin/src/main/java/com/fire/admin/service/BlacklistPhoneService.java

@@ -0,0 +1,24 @@
+package com.fire.admin.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fire.dto.BlacklistPhone;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+import java.util.List;
+
+/**
+ * @author: admin
+ * @Description:
+ * @date: 2021-05-19 13:56
+ * @Modified By:
+ */
+public interface BlacklistPhoneService extends IService<BlacklistPhone> {
+
+    IPage<BlacklistPhone> getBlacklistPhone(Page page, String phoneNo);
+
+    String saveBlacklistPhone(List<BlacklistPhone> blacklist);
+
+    String deleteBlacklistPhone(List<String> phoneNos);
+
+}

modules/admin/src/main/java/com/fire/admin/service/impl/BlacklistPhoneServiceImpl.java

@@ -0,0 +1,63 @@
+package com.fire.admin.service.impl;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fire.admin.mapper.BlacklistPhoneMapper;
+import com.fire.admin.service.BlacklistPhoneService;
+import com.fire.dto.BlacklistPhone;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.messaging.support.MessageBuilder;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+import static com.fire.common.constants.RocketTopic.UPDATE_TOPIC;
+import static com.fire.common.constants.RocketTags.BLACKLIST_TAG;
+
+/**
+ * @author: admin
+ * @Description:
+ * @date: 2021-05-19 14:01
+ * @Modified By:
+ */
+@Service
+@Slf4j
+public class BlacklistPhoneServiceImpl extends ServiceImpl<BlacklistPhoneMapper, BlacklistPhone> implements BlacklistPhoneService {
+
+    @Resource
+    private RocketMQTemplate rocketMQTemplate;
+
+    @Override
+    public IPage<BlacklistPhone> getBlacklistPhone(Page page, String phoneNo) {
+
+        return baseMapper.getBlacklistPhone(page,phoneNo);
+    }
+
+
+    @Override
+    public String saveBlacklistPhone(List<BlacklistPhone> blacklist) {
+        for (BlacklistPhone no : blacklist) {
+            BlacklistPhone blacklistPhone = new BlacklistPhone();
+            blacklistPhone.setPhoneNo(no.getPhoneNo());
+            blacklistPhone.setNote(no.getNote());
+            baseMapper.insert(blacklistPhone);
+        }
+        //向MQ推送消息
+        rocketMQTemplate.send(UPDATE_TOPIC + ":" + BLACKLIST_TAG, MessageBuilder.withPayload(BLACKLIST_TAG).build());
+        return "sucess";
+    }
+
+
+
+    @Override
+    public String deleteBlacklistPhone(List<String> phoneNos) {
+        int res = baseMapper.delPhones(phoneNos);
+        log.info("删除情况:" + res);
+        //向MQ推送消息
+        rocketMQTemplate.send(UPDATE_TOPIC + ":" + BLACKLIST_TAG, MessageBuilder.withPayload(BLACKLIST_TAG).build());
+        return "sucess";
+    }
+}

modules/admin/src/main/resources/mapper/BlacklistPhoneMapper.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fire.admin.mapper.BlacklistPhoneMapper">
+
+    <resultMap id="blacklistPhoneMap" type="com.fire.dto.BlacklistPhone">
+        <result column="phone_no" property="phoneNo"/>
+        <result column="note" property="note"/>
+    </resultMap>
+
+
+    <select id="getBlacklistPhone" resultMap="blacklistPhoneMap">
+        SELECT *
+        FROM blacklist_phone
+        WHERE phone_no like CONCAT('%',#{phoneNo},'%')
+    </select>
+
+    <delete id="delPhones">
+        DELETE
+        FROM blacklist_phone
+        WHERE phone_no in
+        <foreach collection="phones" index="index" item="phone" open="(" separator="," close=")">
+        #{phone}
+        </foreach>
+    </delete>
+
+</mapper>