Commit 6764defc by guojuxing

达摩情报销商户黑名单

parent edb4b83e
package com.gic.enterprise.dto;
import java.io.Serializable;
import java.util.Date;
/**
* 达摩情报销商户黑名单
* @ClassName:
* @Description: 

* @author guojuxing

* @date 2021/5/18 3:31 PM

*/
public class BlackListDTO implements Serializable{
private static final long serialVersionUID = 9182488694825156872L;
/**
*
*/
private Integer blackListId;
/**
* 商户ID
*/
private Integer enterpriseId;
/**
* 商户名称
*/
private String enterpriseName;
/**
* 公司名称
*/
private String companyName;
/**
* 状态(0:正常;1:删除)
*/
private Integer deleteFlag;
/**
*
*/
private Date createTime;
/**
*
*/
private Date updateTime;
public Integer getBlackListId() {
return blackListId;
}
public BlackListDTO setBlackListId(Integer blackListId) {
this.blackListId = blackListId;
return this;
}
public Integer getEnterpriseId() {
return enterpriseId;
}
public BlackListDTO setEnterpriseId(Integer enterpriseId) {
this.enterpriseId = enterpriseId;
return this;
}
public String getEnterpriseName() {
return enterpriseName;
}
public BlackListDTO setEnterpriseName(String enterpriseName) {
this.enterpriseName = enterpriseName;
return this;
}
public String getCompanyName() {
return companyName;
}
public BlackListDTO setCompanyName(String companyName) {
this.companyName = companyName;
return this;
}
public Integer getDeleteFlag() {
return deleteFlag;
}
public BlackListDTO setDeleteFlag(Integer deleteFlag) {
this.deleteFlag = deleteFlag;
return this;
}
public Date getCreateTime() {
return createTime;
}
public BlackListDTO setCreateTime(Date createTime) {
this.createTime = createTime;
return this;
}
public Date getUpdateTime() {
return updateTime;
}
public BlackListDTO setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
return this;
}
@Override
public String toString() {
return "BlackListDTO{" +
"blackListId=" + blackListId +
", enterpriseId=" + enterpriseId +
", enterpriseName='" + enterpriseName + '\'' +
", companyName='" + companyName + '\'' +
", deleteFlag=" + deleteFlag +
", createTime=" + createTime +
", updateTime=" + updateTime +
'}';
}
}
package com.gic.enterprise.service;
import com.gic.api.base.commons.Page;
import com.gic.api.base.commons.ServiceResponse;
import com.gic.enterprise.dto.BlackListDTO;
import java.util.List;
/**
* 达摩情报销商户黑名单
* @ClassName:
* @Description: 

* @author guojuxing

* @date 2021/5/18 3:41 PM

*/
public interface BlackListApiService {
/**
* 新增黑名单
* @return
*/
ServiceResponse<Void> saveBlackList(Integer enterpriseId);
/**
* 解除黑名单
* @param blackListId
* @return
*/
ServiceResponse<Void> deleteBlackList(Integer blackListId);
/**
* 分页查询
* @param search 商户名称/公司名称
* @param pageNum 默认1
* @param pageSize 默认20
* @return
*/
ServiceResponse<Page<BlackListDTO>> pageBlackList(String search, Integer pageNum, Integer pageSize);
/**
* 查询黑名单的商户列表
* @return
*/
ServiceResponse<List<Integer>> getBlankListEnterprise();
}
package com.gic.enterprise.dao.mapper;
import com.gic.enterprise.entity.TabBlackList;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 达摩情报商户黑名单
* @ClassName:
* @Description: 

* @author guojuxing

* @date 2021/5/18 4:05 PM

*/
public interface TabBlackListMapper {
/**
* 插入一条记录
*
* @param record 实体对象
* @return 更新条目数
*/
int insert(TabBlackList record);
/**
* 动态插入一条记录
*
* @param record 实体对象
* @return 更新条目数
*/
int insertSelective(TabBlackList record);
/**
* 根据主键查询
*
* @param blackListId 主键
* @return 实体对象
*/
TabBlackList selectByPrimaryKey(Integer blackListId);
/**
* 根据主键动态更新记录
*
* @param record 实体对象
* @return 更新条目数
*/
int updateByPrimaryKeySelective(TabBlackList record);
/**
* 根据主键更新记录
*
* @param record 实体对象
* @return 更新条目数
*/
int updateByPrimaryKey(TabBlackList record);
/**
* 查询列表
* @return
*/
List<TabBlackList> listBlackList(@Param("search") String search);
}
\ No newline at end of file
package com.gic.enterprise.entity;
import java.util.Date;
/**
* 达摩情报销商户黑名单
* @ClassName:
* @Description: 

* @author guojuxing

* @date 2021/5/18 3:30 PM

*/
public class TabBlackList {
/**
*
*/
private Integer blackListId;
/**
* 商户ID
*/
private Integer enterpriseId;
/**
* 商户名称
*/
private String enterpriseName;
/**
* 公司名称
*/
private String companyName;
/**
* 状态(0:正常;1:删除)
*/
private Integer deleteFlag;
/**
*
*/
private Date createTime;
/**
*
*/
private Date updateTime;
public Integer getBlackListId() {
return blackListId;
}
public TabBlackList setBlackListId(Integer blackListId) {
this.blackListId = blackListId;
return this;
}
public Integer getEnterpriseId() {
return enterpriseId;
}
public TabBlackList setEnterpriseId(Integer enterpriseId) {
this.enterpriseId = enterpriseId;
return this;
}
public String getEnterpriseName() {
return enterpriseName;
}
public TabBlackList setEnterpriseName(String enterpriseName) {
this.enterpriseName = enterpriseName;
return this;
}
public String getCompanyName() {
return companyName;
}
public TabBlackList setCompanyName(String companyName) {
this.companyName = companyName;
return this;
}
public Integer getDeleteFlag() {
return deleteFlag;
}
public TabBlackList setDeleteFlag(Integer deleteFlag) {
this.deleteFlag = deleteFlag;
return this;
}
public Date getCreateTime() {
return createTime;
}
public TabBlackList setCreateTime(Date createTime) {
this.createTime = createTime;
return this;
}
public Date getUpdateTime() {
return updateTime;
}
public TabBlackList setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
return this;
}
}
\ No newline at end of file
package com.gic.enterprise.service;
import com.gic.enterprise.dto.BlackListDTO;
import com.gic.enterprise.entity.TabBlackList;
import com.gic.enterprise.entity.TabEnterprise;
import com.github.pagehelper.Page;
import java.util.List;
/**
* 达摩情报销商户黑名单
* @ClassName:
* @Description: 

* @author guojuxing

* @date 2021/5/18 4:02 PM

*/
public interface BlackListService {
/**
* 新增黑名单
* @param enterprise
*/
void saveBlackList(TabEnterprise enterprise);
/**
* 移除黑名单
* @param blackListId
*/
void deleteBlackList(Integer blackListId);
/**
* 分页查询
* @param search
* @param pageNum
* @param pageSize
* @return
*/
Page<TabBlackList> pageBlackList(String search, Integer pageNum, Integer pageSize);
/**
* 黑名单商户列表
* @return
*/
List<TabBlackList> getBlankListEnterprise();
}
package com.gic.enterprise.service.impl;
import com.gic.enterprise.constant.DeleteFlagConstants;
import com.gic.enterprise.dao.mapper.TabBlackListMapper;
import com.gic.enterprise.entity.TabBlackList;
import com.gic.enterprise.entity.TabEnterprise;
import com.gic.enterprise.service.BlackListService;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Date;
import java.util.List;
/**
* 达摩情报商户黑名单
* @ClassName:
* @Description: 

* @author guojuxing

* @date 2021/5/18 4:04 PM

*/
@Service("blackListService")
public class BlackListServiceImpl implements BlackListService{
@Autowired
private TabBlackListMapper tabBlackListMapper;
@Override
public void saveBlackList(TabEnterprise enterprise) {
TabBlackList record = new TabBlackList();
record.setEnterpriseId(enterprise.getEnterpriseId());
record.setEnterpriseName(enterprise.getEnterpriseName());
record.setCompanyName(enterprise.getCompanyName());
record.setDeleteFlag(DeleteFlagConstants.NORMAL_STATUS);
Date now = new Date();
record.setCreateTime(now);
record.setUpdateTime(now);
tabBlackListMapper.insert(record);
}
@Override
public void deleteBlackList(Integer blackListId) {
TabBlackList record = new TabBlackList();
record.setUpdateTime(new Date());
record.setDeleteFlag(DeleteFlagConstants.DELETE_STATUS);
record.setBlackListId(blackListId);
tabBlackListMapper.updateByPrimaryKeySelective(record);
}
@Override
public Page<TabBlackList> pageBlackList(String search, Integer pageNum, Integer pageSize) {
if (pageNum == null) {
pageNum = 1;
}
if (pageSize == null) {
pageSize = 20;
}
PageHelper.startPage(pageNum, pageSize);
List<TabBlackList> list = tabBlackListMapper.listBlackList(search);
return (Page<TabBlackList>) list;
}
@Override
public List<TabBlackList> getBlankListEnterprise() {
return tabBlackListMapper.listBlackList(null);
}
}
package com.gic.enterprise.service.outer.impl;
import com.gic.api.base.commons.Page;
import com.gic.api.base.commons.ServiceResponse;
import com.gic.commons.util.PageHelperUtils;
import com.gic.enterprise.dto.BlackListDTO;
import com.gic.enterprise.entity.TabBlackList;
import com.gic.enterprise.entity.TabEnterprise;
import com.gic.enterprise.error.ErrorCode;
import com.gic.enterprise.exception.CommonException;
import com.gic.enterprise.service.BlackListApiService;
import com.gic.enterprise.service.BlackListService;
import com.gic.enterprise.service.EnterpriseService;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
/**
* 达摩情报销商户黑名单
* @ClassName:
* @Description: 

* @author guojuxing

* @date 2021/5/18 3:47 PM

*/
@Service("blackListApiService")
public class BlackListApiServiceImpl implements BlackListApiService{
@Autowired
private BlackListService blackListService;
@Autowired
private EnterpriseService enterpriseService;
@Override
public ServiceResponse<Void> saveBlackList(Integer enterpriseId) {
TabEnterprise enterprise = getEnterprise(enterpriseId);
blackListService.saveBlackList(enterprise);
return ServiceResponse.success();
}
@Override
public ServiceResponse<Void> deleteBlackList(Integer blackListId) {
blackListService.deleteBlackList(blackListId);
return ServiceResponse.success();
}
@Override
public ServiceResponse<Page<BlackListDTO>> pageBlackList(String search, Integer pageNum, Integer pageSize) {
com.github.pagehelper.Page<TabBlackList> page = blackListService.pageBlackList(search, pageNum, pageSize);
Page<BlackListDTO> result = PageHelperUtils.changePageHelperToCurrentPage(page, BlackListDTO.class);
return ServiceResponse.success(result);
}
@Override
public ServiceResponse<List<Integer>> getBlankListEnterprise() {
List<TabBlackList> list = blackListService.getBlankListEnterprise();
if (CollectionUtils.isNotEmpty(list)) {
return ServiceResponse.success(list.stream().map(e -> e.getEnterpriseId()).collect(Collectors.toList()));
}
return ServiceResponse.success(Collections.EMPTY_LIST);
}
private TabEnterprise getEnterprise(Integer enterpriseId) {
TabEnterprise record = enterpriseService.getEnterpriseById(enterpriseId);
if (record == null) {
throw new CommonException(ErrorCode.PARAMETER_ERROR.getCode(), "商户不存在");
}
return record;
}
}
......@@ -134,6 +134,7 @@
<dubbo:service interface="com.gic.enterprise.service.UnionEnterpriseAuthApiService" ref="unionEnterpriseAuthApiService" timeout="6000" />
<dubbo:service interface="com.gic.enterprise.service.UnionEnterpriseAuthResDetailApiService" ref="unionEnterpriseAuthResDetailApiService" timeout="6000" />
<dubbo:service interface="com.gic.enterprise.service.ProductMarketApiService" ref="productMarketApiService" timeout="6000" />
<dubbo:service interface="com.gic.enterprise.service.BlackListApiService" ref="blackListApiService" timeout="6000" />
<dubbo:reference interface="com.gic.mall.share.api.service.ShopApiService" id="shopApiService" timeout="6000" />
......
<?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.gic.enterprise.dao.mapper.TabBlackListMapper">
<resultMap id="BaseResultMap" type="com.gic.enterprise.entity.TabBlackList">
<id column="black_list_id" jdbcType="INTEGER" property="blackListId" />
<result column="enterprise_id" jdbcType="INTEGER" property="enterpriseId" />
<result column="enterprise_name" jdbcType="VARCHAR" property="enterpriseName" />
<result column="company_name" jdbcType="VARCHAR" property="companyName" />
<result column="delete_flag" jdbcType="INTEGER" property="deleteFlag" />
<result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
<result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
</resultMap>
<sql id="Base_Column_List">
black_list_id, enterprise_id, enterprise_name, company_name, delete_flag, create_time,
update_time
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from tab_black_list
where black_list_id = #{blackListId,jdbcType=INTEGER}
</select>
<insert id="insert" parameterType="com.gic.enterprise.entity.TabBlackList">
insert into tab_black_list (black_list_id, enterprise_id, enterprise_name,
company_name, delete_flag, create_time,
update_time)
values (#{blackListId,jdbcType=INTEGER}, #{enterpriseId,jdbcType=INTEGER}, #{enterpriseName,jdbcType=VARCHAR},
#{companyName,jdbcType=VARCHAR}, #{deleteFlag,jdbcType=INTEGER}, #{createTime,jdbcType=TIMESTAMP},
#{updateTime,jdbcType=TIMESTAMP})
</insert>
<insert id="insertSelective" parameterType="com.gic.enterprise.entity.TabBlackList">
insert into tab_black_list
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="blackListId != null">
black_list_id,
</if>
<if test="enterpriseId != null">
enterprise_id,
</if>
<if test="enterpriseName != null">
enterprise_name,
</if>
<if test="companyName != null">
company_name,
</if>
<if test="deleteFlag != null">
delete_flag,
</if>
<if test="createTime != null">
create_time,
</if>
<if test="updateTime != null">
update_time,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="blackListId != null">
#{blackListId,jdbcType=INTEGER},
</if>
<if test="enterpriseId != null">
#{enterpriseId,jdbcType=INTEGER},
</if>
<if test="enterpriseName != null">
#{enterpriseName,jdbcType=VARCHAR},
</if>
<if test="companyName != null">
#{companyName,jdbcType=VARCHAR},
</if>
<if test="deleteFlag != null">
#{deleteFlag,jdbcType=INTEGER},
</if>
<if test="createTime != null">
#{createTime,jdbcType=TIMESTAMP},
</if>
<if test="updateTime != null">
#{updateTime,jdbcType=TIMESTAMP},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.gic.enterprise.entity.TabBlackList">
update tab_black_list
<set>
<if test="enterpriseId != null">
enterprise_id = #{enterpriseId,jdbcType=INTEGER},
</if>
<if test="enterpriseName != null">
enterprise_name = #{enterpriseName,jdbcType=VARCHAR},
</if>
<if test="companyName != null">
company_name = #{companyName,jdbcType=VARCHAR},
</if>
<if test="deleteFlag != null">
delete_flag = #{deleteFlag,jdbcType=INTEGER},
</if>
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
<if test="updateTime != null">
update_time = #{updateTime,jdbcType=TIMESTAMP},
</if>
</set>
where black_list_id = #{blackListId,jdbcType=INTEGER}
</update>
<update id="updateByPrimaryKey" parameterType="com.gic.enterprise.entity.TabBlackList">
update tab_black_list
set enterprise_id = #{enterpriseId,jdbcType=INTEGER},
enterprise_name = #{enterpriseName,jdbcType=VARCHAR},
company_name = #{companyName,jdbcType=VARCHAR},
delete_flag = #{deleteFlag,jdbcType=INTEGER},
create_time = #{createTime,jdbcType=TIMESTAMP},
update_time = #{updateTime,jdbcType=TIMESTAMP}
where black_list_id = #{blackListId,jdbcType=INTEGER}
</update>
<select id="listBlackList" resultMap="BaseResultMap">
select <include refid="Base_Column_List"></include>
from tab_black_list
where delete_flag = 0
<if test="search != null and search != ''">
and (enterprise_name like concat('%', #{search}, '%') or company_name like concat('%', #{search}, '%'))
</if>
order by create_time desc
</select>
</mapper>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment