提交 a010467c authored 作者: hzh's avatar hzh

代码优化

上级 4047b509
...@@ -68,7 +68,9 @@ public interface IBaseService<V, B, T> { ...@@ -68,7 +68,9 @@ public interface IBaseService<V, B, T> {
* *
* @param ids 待删除的主键集合 * @param ids 待删除的主键集合
*/ */
void validIdsBeforeDelete(Collection<Long> ids); default void validIdsBeforeDelete(Collection<Long> ids){
}
/** /**
* 构建查询条件 * 构建查询条件
...@@ -83,7 +85,9 @@ public interface IBaseService<V, B, T> { ...@@ -83,7 +85,9 @@ public interface IBaseService<V, B, T> {
* *
* @param entity 实体 * @param entity 实体
*/ */
void validEntityBeforeSave(T entity); default void validEntityBeforeSave(T entity){
}
default BaseMapperPlus mapper() { default BaseMapperPlus mapper() {
return null; return null;
......
package org.dromara.server.service; package org.dromara.server.service;
import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.server.base.IBaseService;
import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.server.domain.BizUser;
import org.dromara.server.domain.bo.BizUserBo; import org.dromara.server.domain.bo.BizUserBo;
import org.dromara.server.domain.vo.BizUserVo; import org.dromara.server.domain.vo.BizUserVo;
import java.util.Collection;
import java.util.List;
/** /**
* 云上用户信息Service接口 * 云上用户信息Service接口
* *
* @author hzh * @author hzh
* @date 2024-11-14 * @date 2024-11-14
*/ */
public interface IBizUserService { public interface IBizUserService extends IBaseService<BizUserVo, BizUserBo, BizUser> {
/**
* 查询云上用户信息
*
* @param userId 主键
* @return 云上用户信息
*/
BizUserVo queryById(Long userId);
/**
* 分页查询云上用户信息列表
*
* @param bo 查询条件
* @param pageQuery 分页参数
* @return 云上用户信息分页列表
*/
TableDataInfo<BizUserVo> queryPageList(BizUserBo bo, PageQuery pageQuery);
/**
* 查询符合条件的云上用户信息列表
*
* @param bo 查询条件
* @return 云上用户信息列表
*/
List<BizUserVo> queryList(BizUserBo bo);
/**
* 新增云上用户信息
*
* @param bo 云上用户信息
* @return 是否新增成功
*/
Boolean insertByBo(BizUserBo bo);
/**
* 修改云上用户信息
*
* @param bo 云上用户信息
* @return 是否修改成功
*/
Boolean updateByBo(BizUserBo bo);
/**
* 校验并批量删除云上用户信息信息
*
* @param ids 待删除的主键集合
* @param isValid 是否进行有效性校验
* @return 是否删除成功
*/
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
} }
package org.dromara.server.service; package org.dromara.server.service;
import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.server.base.IBaseService;
import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.server.domain.OrderAirport;
import org.dromara.server.domain.bo.OrderAirportBo; import org.dromara.server.domain.bo.OrderAirportBo;
import org.dromara.server.domain.vo.OrderAirportVo; import org.dromara.server.domain.vo.OrderAirportVo;
import java.util.Collection;
import java.util.List; import java.util.List;
/** /**
...@@ -14,58 +13,7 @@ import java.util.List; ...@@ -14,58 +13,7 @@ import java.util.List;
* @author hzh * @author hzh
* @date 2024-11-18 * @date 2024-11-18
*/ */
public interface IOrderAirportService { public interface IOrderAirportService extends IBaseService<OrderAirportVo, OrderAirportBo, OrderAirport> {
/**
* 查询活动机票订单
*
* @param id 主键
* @return 活动机票订单
*/
OrderAirportVo queryById(Long id);
/**
* 分页查询活动机票订单列表
*
* @param bo 查询条件
* @param pageQuery 分页参数
* @return 活动机票订单分页列表
*/
TableDataInfo<OrderAirportVo> queryPageList(OrderAirportBo bo, PageQuery pageQuery);
/**
* 查询符合条件的活动机票订单列表
*
* @param bo 查询条件
* @return 活动机票订单列表
*/
List<OrderAirportVo> queryList(OrderAirportBo bo);
/**
* 新增活动机票订单
*
* @param bo 活动机票订单
* @return 是否新增成功
*/
Boolean insertByBo(OrderAirportBo bo);
/**
* 修改活动机票订单
*
* @param bo 活动机票订单
* @return 是否修改成功
*/
Boolean updateByBo(OrderAirportBo bo);
/**
* 校验并批量删除活动机票订单信息
*
* @param ids 待删除的主键集合
* @param isValid 是否进行有效性校验
* @return 是否删除成功
*/
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
/** /**
* 批量保存订单 * 批量保存订单
* *
......
...@@ -2,12 +2,10 @@ package org.dromara.server.service.impl; ...@@ -2,12 +2,10 @@ package org.dromara.server.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils; import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.server.base.AbstractBaseService;
import org.dromara.server.domain.BizUser; import org.dromara.server.domain.BizUser;
import org.dromara.server.domain.bo.BizUserBo; import org.dromara.server.domain.bo.BizUserBo;
import org.dromara.server.domain.vo.BizUserVo; import org.dromara.server.domain.vo.BizUserVo;
...@@ -15,8 +13,6 @@ import org.dromara.server.mapper.BizUserMapper; ...@@ -15,8 +13,6 @@ import org.dromara.server.mapper.BizUserMapper;
import org.dromara.server.service.IBizUserService; import org.dromara.server.service.IBizUserService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Collection;
import java.util.List;
import java.util.Map; import java.util.Map;
/** /**
...@@ -27,48 +23,17 @@ import java.util.Map; ...@@ -27,48 +23,17 @@ import java.util.Map;
*/ */
@RequiredArgsConstructor @RequiredArgsConstructor
@Service @Service
public class BizUserServiceImpl implements IBizUserService { public class BizUserServiceImpl extends AbstractBaseService<BizUserVo, BizUserBo, BizUser> implements IBizUserService {
private final BizUserMapper baseMapper; private final BizUserMapper baseMapper;
/**
* 查询云上用户信息
*
* @param userId 主键
* @return 云上用户信息
*/
@Override @Override
public BizUserVo queryById(Long userId) { public BaseMapperPlus<BizUser, BizUserVo> mapper() {
return baseMapper.selectVoById(userId); return baseMapper;
} }
/**
* 分页查询云上用户信息列表
*
* @param bo 查询条件
* @param pageQuery 分页参数
* @return 云上用户信息分页列表
*/
@Override @Override
public TableDataInfo<BizUserVo> queryPageList(BizUserBo bo, PageQuery pageQuery) { public LambdaQueryWrapper<BizUser> buildQueryWrapper(BizUserBo bo) {
LambdaQueryWrapper<BizUser> lqw = buildQueryWrapper(bo);
Page<BizUserVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
* 查询符合条件的云上用户信息列表
*
* @param bo 查询条件
* @return 云上用户信息列表
*/
@Override
public List<BizUserVo> queryList(BizUserBo bo) {
LambdaQueryWrapper<BizUser> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private LambdaQueryWrapper<BizUser> buildQueryWrapper(BizUserBo bo) {
Map<String, Object> params = bo.getParams(); Map<String, Object> params = bo.getParams();
LambdaQueryWrapper<BizUser> lqw = Wrappers.lambdaQuery(); LambdaQueryWrapper<BizUser> lqw = Wrappers.lambdaQuery();
lqw.eq(StringUtils.isNotBlank(bo.getUserNo()), BizUser::getUserNo, bo.getUserNo()); lqw.eq(StringUtils.isNotBlank(bo.getUserNo()), BizUser::getUserNo, bo.getUserNo());
...@@ -79,55 +44,4 @@ public class BizUserServiceImpl implements IBizUserService { ...@@ -79,55 +44,4 @@ public class BizUserServiceImpl implements IBizUserService {
return lqw; return lqw;
} }
/**
* 新增云上用户信息
*
* @param bo 云上用户信息
* @return 是否新增成功
*/
@Override
public Boolean insertByBo(BizUserBo bo) {
BizUser add = MapstructUtils.convert(bo, BizUser.class);
validEntityBeforeSave(add);
boolean flag = baseMapper.insert(add) > 0;
if (flag) {
bo.setUserId(add.getUserId());
}
return flag;
}
/**
* 修改云上用户信息
*
* @param bo 云上用户信息
* @return 是否修改成功
*/
@Override
public Boolean updateByBo(BizUserBo bo) {
BizUser update = MapstructUtils.convert(bo, BizUser.class);
validEntityBeforeSave(update);
return baseMapper.updateById(update) > 0;
}
/**
* 保存前的数据校验
*/
private void validEntityBeforeSave(BizUser entity) {
//TODO 做一些数据校验,如唯一约束
}
/**
* 校验并批量删除云上用户信息信息
*
* @param ids 待删除的主键集合
* @param isValid 是否进行有效性校验
* @return 是否删除成功
*/
@Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if (isValid) {
//TODO 做一些业务上的校验,判断是否需要校验
}
return baseMapper.deleteByIds(ids) > 0;
}
} }
...@@ -3,16 +3,14 @@ package org.dromara.server.service.impl; ...@@ -3,16 +3,14 @@ package org.dromara.server.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StreamUtils; import org.dromara.common.core.utils.StreamUtils;
import org.dromara.common.core.utils.StringUtils; import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.ys.model.res.airport.QueryTkOrderModel; import org.dromara.common.ys.model.res.airport.QueryTkOrderModel;
import org.dromara.common.ys.model.res.airport.other.*; import org.dromara.common.ys.model.res.airport.other.*;
import org.dromara.common.ys.service.IAirportService; import org.dromara.common.ys.service.IAirportService;
import org.dromara.server.base.AbstractBaseService;
import org.dromara.server.domain.*; import org.dromara.server.domain.*;
import org.dromara.server.domain.bo.OrderAirportBo; import org.dromara.server.domain.bo.OrderAirportBo;
import org.dromara.server.domain.vo.OrderAirportVo; import org.dromara.server.domain.vo.OrderAirportVo;
...@@ -20,7 +18,6 @@ import org.dromara.server.mapper.*; ...@@ -20,7 +18,6 @@ import org.dromara.server.mapper.*;
import org.dromara.server.service.IOrderAirportService; import org.dromara.server.service.IOrderAirportService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
...@@ -34,7 +31,7 @@ import java.util.concurrent.ScheduledExecutorService; ...@@ -34,7 +31,7 @@ import java.util.concurrent.ScheduledExecutorService;
*/ */
@RequiredArgsConstructor @RequiredArgsConstructor
@Service @Service
public class OrderAirportServiceImpl implements IOrderAirportService { public class OrderAirportServiceImpl extends AbstractBaseService<OrderAirportVo, OrderAirportBo, OrderAirport> implements IOrderAirportService {
private final OrderAirportMapper baseMapper; private final OrderAirportMapper baseMapper;
private final OrderAirportPsgMapper psgMapper; private final OrderAirportPsgMapper psgMapper;
...@@ -47,44 +44,13 @@ public class OrderAirportServiceImpl implements IOrderAirportService { ...@@ -47,44 +44,13 @@ public class OrderAirportServiceImpl implements IOrderAirportService {
private final BizUserMapper userMapper; private final BizUserMapper userMapper;
private final ScheduledExecutorService scheduledExecutorService; private final ScheduledExecutorService scheduledExecutorService;
/**
* 查询活动机票订单
*
* @param id 主键
* @return 活动机票订单
*/
@Override @Override
public OrderAirportVo queryById(Long id) { public BaseMapperPlus<OrderAirport, OrderAirportVo> mapper() {
return baseMapper.selectVoById(id); return baseMapper;
} }
/**
* 分页查询活动机票订单列表
*
* @param bo 查询条件
* @param pageQuery 分页参数
* @return 活动机票订单分页列表
*/
@Override @Override
public TableDataInfo<OrderAirportVo> queryPageList(OrderAirportBo bo, PageQuery pageQuery) { public LambdaQueryWrapper<OrderAirport> buildQueryWrapper(OrderAirportBo bo) {
LambdaQueryWrapper<OrderAirport> lqw = buildQueryWrapper(bo);
Page<OrderAirportVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
* 查询符合条件的活动机票订单列表
*
* @param bo 查询条件
* @return 活动机票订单列表
*/
@Override
public List<OrderAirportVo> queryList(OrderAirportBo bo) {
LambdaQueryWrapper<OrderAirport> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private LambdaQueryWrapper<OrderAirport> buildQueryWrapper(OrderAirportBo bo) {
Map<String, Object> params = bo.getParams(); Map<String, Object> params = bo.getParams();
LambdaQueryWrapper<OrderAirport> lqw = Wrappers.lambdaQuery(); LambdaQueryWrapper<OrderAirport> lqw = Wrappers.lambdaQuery();
lqw.eq(StringUtils.isNotBlank(bo.getPersonCode()), OrderAirport::getPersonCode, bo.getPersonCode()); lqw.eq(StringUtils.isNotBlank(bo.getPersonCode()), OrderAirport::getPersonCode, bo.getPersonCode());
...@@ -122,58 +88,6 @@ public class OrderAirportServiceImpl implements IOrderAirportService { ...@@ -122,58 +88,6 @@ public class OrderAirportServiceImpl implements IOrderAirportService {
return lqw; return lqw;
} }
/**
* 新增活动机票订单
*
* @param bo 活动机票订单
* @return 是否新增成功
*/
@Override
public Boolean insertByBo(OrderAirportBo bo) {
OrderAirport add = MapstructUtils.convert(bo, OrderAirport.class);
validEntityBeforeSave(add);
boolean flag = baseMapper.insert(add) > 0;
if (flag) {
bo.setId(add.getId());
}
return flag;
}
/**
* 修改活动机票订单
*
* @param bo 活动机票订单
* @return 是否修改成功
*/
@Override
public Boolean updateByBo(OrderAirportBo bo) {
OrderAirport update = MapstructUtils.convert(bo, OrderAirport.class);
validEntityBeforeSave(update);
return baseMapper.updateById(update) > 0;
}
/**
* 保存前的数据校验
*/
private void validEntityBeforeSave(OrderAirport entity) {
//TODO 做一些数据校验,如唯一约束
}
/**
* 校验并批量删除活动机票订单信息
*
* @param ids 待删除的主键集合
* @param isValid 是否进行有效性校验
* @return 是否删除成功
*/
@Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if (isValid) {
//TODO 做一些业务上的校验,判断是否需要校验
}
return baseMapper.deleteByIds(ids) > 0;
}
@Override @Override
public void batchSaveOrder(String userId, List<String> orderNoList) { public void batchSaveOrder(String userId, List<String> orderNoList) {
BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId)); BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId));
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论