添加"订单"的基础业务接口和实现

This commit is contained in:
longbinbin
2024-12-03 14:58:55 +08:00
parent e599004c92
commit 4bac7d10f9
21 changed files with 488 additions and 90 deletions

View File

@ -51,7 +51,7 @@ public class AdminUserServiceImpl implements AdminUserService {
PageHelper.startPage(adminUserListReqVO.getPageNum(), adminUserListReqVO.getPageSize());
List<AdminUserListRespVO> list = adminUserMapper.list(adminUserListReqVO);
PageInfo<AdminUserListRespVO> pageInfo = new PageInfo(list);
return ApiResponse.buildSuccessResponse(pageInfo);
return ApiResponse.success(pageInfo);
}
@Override
@ -64,32 +64,32 @@ public class AdminUserServiceImpl implements AdminUserService {
// addOrUpdateAdminUserReqVO.setPassword(password);
int add = adminUserMapper.add(addOrUpdateAdminUserReqVO);
if (add > 0) {
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
} else {
int update = adminUserMapper.update(addOrUpdateAdminUserReqVO);
if (update > 0) {
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
}
return ApiResponse.buildCommonErrorResponse("失败");
return ApiResponse.commonError("失败");
}
@Override
public ApiResponse delete(String id) {
if (adminUserMapper.delete(id) > 0) {
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
return ApiResponse.buildCommonErrorResponse("失败");
return ApiResponse.commonError("失败");
}
@Override
public ApiResponse resetPassword(ResetPasswordReqVO resetPasswordReqVO) {
resetPasswordReqVO.setPassword(DigestUtil.md5Hex(resetPasswordReqVO.getPassword()));
if (adminUserMapper.resetPassword(resetPasswordReqVO) > 0) {
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
return ApiResponse.buildCommonErrorResponse("失败");
return ApiResponse.commonError("失败");
}
@ -100,10 +100,10 @@ public class AdminUserServiceImpl implements AdminUserService {
String password = loginReqVO.getPassword();
LoginEntity login = adminUserMapper.login(account);
if (login == null) {
return ApiResponse.buildCommonErrorResponse("账号不存在或密码错误");
return ApiResponse.commonError("账号不存在或密码错误");
}
if (!login.getPassword().equals(DigestUtil.md5Hex(password))) {
return ApiResponse.buildCommonErrorResponse("账号不存在或密码错误");
return ApiResponse.commonError("账号不存在或密码错误");
}
String roleId = login.getRoleId();
@ -135,7 +135,7 @@ public class AdminUserServiceImpl implements AdminUserService {
loginRespVO.setName(login.getStaffName());
loginRespVO.setTypeName(login.getTypeName());
loginRespVO.setMenuNodeList(MenuList);
return ApiResponse.buildSuccessResponse(loginRespVO);
return ApiResponse.success(loginRespVO);
}
@Override
@ -145,13 +145,13 @@ public class AdminUserServiceImpl implements AdminUserService {
String passwordByAccount = adminUserMapper.getPasswordByAccount(updatePasswordReqVO.getId());
String pwd = DigestUtil.md5Hex(updatePasswordReqVO.getPwd());
if (!passwordByAccount.equals(pwd)) {
return ApiResponse.buildCommonErrorResponse("密码错误!修改失败");
return ApiResponse.commonError("密码错误!修改失败");
}
String newPwd = DigestUtil.md5Hex(updatePasswordReqVO.getNewPwd());
updatePasswordReqVO.setNewPwd(newPwd);
if (adminUserMapper.updatePassword(updatePasswordReqVO) > 0) {
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
return ApiResponse.buildCommonErrorResponse("失败");
return ApiResponse.commonError("失败");
}
}

View File

@ -7,6 +7,7 @@ import com.ycwl.basic.model.pc.broker.entity.BrokerEntity;
import com.ycwl.basic.model.pc.broker.req.BrokerReqQuery;
import com.ycwl.basic.model.pc.broker.resp.BrokerRespVO;
import com.ycwl.basic.service.pc.BrokerService;
import com.ycwl.basic.utils.SnowFlakeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -44,6 +45,7 @@ public class BrokerServiceImpl implements BrokerService {
public int addOrUpdate(BrokerEntity broker) {
Long id = broker.getId();
if(id==null){
broker.setId(SnowFlakeUtil.getLongId());
return brokerMapper.add(broker);
}else {
return brokerMapper.update(broker);

View File

@ -8,6 +8,7 @@ import com.ycwl.basic.model.pc.device.req.DeviceReqQuery;
import com.ycwl.basic.model.pc.device.resp.DeviceRespVO;
import com.ycwl.basic.service.pc.DeviceService;
import com.ycwl.basic.utils.ApiResponse;
import com.ycwl.basic.utils.SnowFlakeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -26,36 +27,37 @@ public class DeviceServiceImpl implements DeviceService {
PageHelper.startPage(deviceReqQuery.getPageNum(), deviceReqQuery.getPageSize());
List<DeviceRespVO> list = deviceMapper.list(deviceReqQuery);
PageInfo<DeviceRespVO> pageInfo = new PageInfo<>(list);
return ApiResponse.buildSuccessResponse(pageInfo);
return ApiResponse.success(pageInfo);
}
@Override
public ApiResponse<List<DeviceRespVO>> list(DeviceReqQuery deviceReqQuery) {
return ApiResponse.buildSuccessResponse(deviceMapper.list(deviceReqQuery));
return ApiResponse.success(deviceMapper.list(deviceReqQuery));
}
@Override
public ApiResponse<DeviceRespVO> getById(Long id) {
return ApiResponse.buildSuccessResponse(deviceMapper.getById(id));
return ApiResponse.success(deviceMapper.getById(id));
}
@Override
public ApiResponse addOrUpdate(DeviceAddOrUpdateReq deviceReqQuery) {
Long id = deviceReqQuery.getId();
if (id == null) {
return ApiResponse.buildSuccessResponse(deviceMapper.add(deviceReqQuery));
deviceReqQuery.setId(SnowFlakeUtil.getLongId());
return ApiResponse.success(deviceMapper.add(deviceReqQuery));
} else {
return ApiResponse.buildSuccessResponse(deviceMapper.update(deviceReqQuery));
return ApiResponse.success(deviceMapper.update(deviceReqQuery));
}
}
@Override
public ApiResponse deleteById(Long id) {
return ApiResponse.buildSuccessResponse(deviceMapper.deleteById(id));
return ApiResponse.success(deviceMapper.deleteById(id));
}
@Override
public ApiResponse updateStatus(Long id) {
return ApiResponse.buildSuccessResponse(deviceMapper.updateStatus(id));
return ApiResponse.success(deviceMapper.updateStatus(id));
}
}

View File

@ -3,15 +3,12 @@ package com.ycwl.basic.service.impl.pc;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.ycwl.basic.mapper.pc.FaceSampleMapper;
import com.ycwl.basic.model.pc.face.entity.FaceEntity;
import com.ycwl.basic.model.pc.face.req.FaceReqQuery;
import com.ycwl.basic.model.pc.face.resp.FaceRespVO;
import com.ycwl.basic.model.pc.faceSample.entity.FaceSampleEntity;
import com.ycwl.basic.model.pc.faceSample.req.FaceSampleReqQuery;
import com.ycwl.basic.model.pc.faceSample.resp.FaceSampleRespVO;
import com.ycwl.basic.service.pc.FaceSampleService;
import com.ycwl.basic.service.pc.FaceService;
import com.ycwl.basic.utils.ApiResponse;
import com.ycwl.basic.utils.SnowFlakeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -31,52 +28,53 @@ public class FaceSampleServiceImpl implements FaceSampleService {
PageHelper.startPage(faceSampleReqQuery.getPageNum(),faceSampleReqQuery.getPageSize());
List<FaceSampleRespVO> list = faceSampleMapper.list(faceSampleReqQuery);
PageInfo<FaceSampleRespVO> pageInfo = new PageInfo<>(list);
return ApiResponse.buildSuccessResponse(pageInfo);
return ApiResponse.success(pageInfo);
}
@Override
public ApiResponse<List<FaceSampleRespVO>> list(FaceSampleReqQuery faceSampleReqQuery) {
return ApiResponse.buildSuccessResponse(faceSampleMapper.list(faceSampleReqQuery));
return ApiResponse.success(faceSampleMapper.list(faceSampleReqQuery));
}
@Override
public ApiResponse<FaceSampleRespVO> getById(Long id) {
return ApiResponse.buildSuccessResponse(faceSampleMapper.getById(id));
return ApiResponse.success(faceSampleMapper.getById(id));
}
@Override
public ApiResponse<Integer> add(FaceSampleEntity faceSample) {
faceSample.setId(SnowFlakeUtil.getLongId());
int i = faceSampleMapper.add(faceSample);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("添加失败");
return ApiResponse.commonError("添加失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> deleteById(Long id) {
int i = faceSampleMapper.deleteById(id);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("删除失败");
return ApiResponse.commonError("删除失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> deleteByIds(List<Long> ids) {
int i = faceSampleMapper.deleteByIds(ids);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("删除失败");
return ApiResponse.commonError("删除失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> update(FaceSampleEntity faceSample) {
int i = faceSampleMapper.update(faceSample);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("修改失败");
return ApiResponse.commonError("修改失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
}

View File

@ -8,6 +8,7 @@ import com.ycwl.basic.model.pc.face.req.FaceReqQuery;
import com.ycwl.basic.model.pc.face.resp.FaceRespVO;
import com.ycwl.basic.service.pc.FaceService;
import com.ycwl.basic.utils.ApiResponse;
import com.ycwl.basic.utils.SnowFlakeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -27,52 +28,53 @@ public class FaceServiceImpl implements FaceService {
PageHelper.startPage(faceReqQuery.getPageNum(),faceReqQuery.getPageSize());
List<FaceRespVO> list = faceMapper.list(faceReqQuery);
PageInfo<FaceRespVO> pageInfo = new PageInfo<>(list);
return ApiResponse.buildSuccessResponse(pageInfo);
return ApiResponse.success(pageInfo);
}
@Override
public ApiResponse<List<FaceRespVO>> list(FaceReqQuery faceReqQuery) {
return ApiResponse.buildSuccessResponse(faceMapper.list(faceReqQuery));
return ApiResponse.success(faceMapper.list(faceReqQuery));
}
@Override
public ApiResponse<FaceRespVO> getById(Long id) {
return ApiResponse.buildSuccessResponse(faceMapper.getById(id));
return ApiResponse.success(faceMapper.getById(id));
}
@Override
public ApiResponse<Integer> add(FaceEntity face) {
face.setId(SnowFlakeUtil.getLongId());
int i = faceMapper.add(face);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("添加失败");
return ApiResponse.commonError("添加失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> deleteById(Long id) {
int i = faceMapper.deleteById(id);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("删除失败");
return ApiResponse.commonError("删除失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> deleteByIds(List<Long> ids) {
int i = faceMapper.deleteByIds(ids);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("删除失败");
return ApiResponse.commonError("删除失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> update(FaceEntity face) {
int i = faceMapper.update(face);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("修改失败");
return ApiResponse.commonError("修改失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
}

View File

@ -8,6 +8,7 @@ import com.ycwl.basic.model.pc.member.req.MemberReqQuery;
import com.ycwl.basic.model.pc.member.resp.MemberRespVO;
import com.ycwl.basic.service.pc.MemberService;
import com.ycwl.basic.utils.ApiResponse;
import com.ycwl.basic.utils.SnowFlakeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -27,44 +28,45 @@ public class MemberServiceImpl implements MemberService {
PageHelper.startPage(memberReqQuery.getPageNum(), memberReqQuery.getPageSize());
List<MemberRespVO> list = memberMapper.list(memberReqQuery);
PageInfo<MemberRespVO> pageInfo = new PageInfo<>(list);
return ApiResponse.buildSuccessResponse(pageInfo);
return ApiResponse.success(pageInfo);
}
@Override
public ApiResponse<List<MemberRespVO>> list(MemberReqQuery memberReqQuery) {
return ApiResponse.buildSuccessResponse(memberMapper.list(memberReqQuery));
return ApiResponse.success(memberMapper.list(memberReqQuery));
}
@Override
public ApiResponse<MemberRespVO> getById(Long id) {
return ApiResponse.buildSuccessResponse(memberMapper.getById(id));
return ApiResponse.success(memberMapper.getById(id));
}
@Override
public ApiResponse<Integer> add(MemberEntity member) {
member.setId(SnowFlakeUtil.getLongId());
int i = memberMapper.add(member);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("添加失败");
return ApiResponse.commonError("添加失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> deleteById(Long id) {
int i = memberMapper.deleteById(id);
if (i == 0) {
return ApiResponse.buildCommonErrorResponse("删除失败");
return ApiResponse.commonError("删除失败");
}
return ApiResponse.buildSuccessResponse(i);
return ApiResponse.success(i);
}
@Override
public ApiResponse<Integer> update(MemberEntity member) {
int update = memberMapper.update(member);
if (update == 0) {
return ApiResponse.buildCommonErrorResponse("更新失败");
return ApiResponse.commonError("更新失败");
}
return ApiResponse.buildSuccessResponse(update);
return ApiResponse.success(update);
}
}

View File

@ -5,6 +5,7 @@ import com.ycwl.basic.model.pc.menu.MenuNode;
import com.ycwl.basic.model.pc.menu.entity.MenuEntity;
import com.ycwl.basic.service.pc.MenuService;
import com.ycwl.basic.utils.ApiResponse;
import com.ycwl.basic.utils.SnowFlakeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.ArrayList;
@ -40,16 +41,17 @@ public class MenuServiceImpl implements MenuService {
}
}
}
return ApiResponse.buildSuccessResponse(MenuList);
return ApiResponse.success(MenuList);
}
@Override
public ApiResponse<Integer> add(MenuEntity menu) {
menu.setId(SnowFlakeUtil.getId());
int add = menuMapper.add(menu);
if(add>0){
return ApiResponse.buildSuccessResponse(add);
return ApiResponse.success(add);
}else {
return ApiResponse.buildCommonErrorResponse("添加失败");
return ApiResponse.commonError("添加失败");
}
}
@ -57,9 +59,9 @@ public class MenuServiceImpl implements MenuService {
public ApiResponse<Integer> update(MenuEntity menu) {
int update = menuMapper.update(menu);
if(update>0){
return ApiResponse.buildSuccessResponse(update);
return ApiResponse.success(update);
}else {
return ApiResponse.buildCommonErrorResponse("更新失败");
return ApiResponse.commonError("更新失败");
}
}
@ -67,9 +69,9 @@ public class MenuServiceImpl implements MenuService {
public ApiResponse<Integer> deleteById(Long id) {
int deleteById = menuMapper.deleteById(id);
if(deleteById>0){
return ApiResponse.buildSuccessResponse(deleteById);
return ApiResponse.success(deleteById);
}else {
return ApiResponse.buildCommonErrorResponse("删除失败");
return ApiResponse.commonError("删除失败");
}
}
}

View File

@ -0,0 +1,85 @@
package com.ycwl.basic.service.impl.pc;
import cn.hutool.core.bean.BeanUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.ycwl.basic.mapper.pc.OrderMapper;
import com.ycwl.basic.model.pc.order.entity.OrderItemEntity;
import com.ycwl.basic.model.pc.order.req.OrderAddOrUpdateReq;
import com.ycwl.basic.model.pc.order.req.OrderItemDTO;
import com.ycwl.basic.model.pc.order.req.OrderReqQuery;
import com.ycwl.basic.model.pc.order.resp.OrderRespVO;
import com.ycwl.basic.service.pc.OrderService;
import com.ycwl.basic.utils.ApiResponse;
import com.ycwl.basic.utils.SnowFlakeUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.List;
/**
* @Authorlongbinbin
* @Date2024/12/3 13:54
*/
@Slf4j
@Service
public class OrderServiceImpl implements OrderService {
@Autowired
private OrderMapper orderMapper;
@Override
public ApiResponse<PageInfo<OrderRespVO>> pageQuery(OrderReqQuery query) {
PageHelper.startPage(query.getPageNum(), query.getPageSize());
List<OrderRespVO> list = orderMapper.list(query);
PageInfo<OrderRespVO> pageInfo = new PageInfo<>(list);
return ApiResponse.success(pageInfo);
}
@Override
public ApiResponse<List<OrderRespVO>> list(OrderReqQuery query) {
return ApiResponse.success(orderMapper.list(query));
}
@Override
public ApiResponse<OrderRespVO> detail(Long orderId) {
return ApiResponse.success(orderMapper.getById(orderId));
}
@Override
@Transactional(rollbackFor = Exception.class)
public ApiResponse<Integer> add(OrderAddOrUpdateReq order) {
Long orderId = SnowFlakeUtil.getLongId();
order.setId(orderId);
int add = orderMapper.add(order);
if (add == 0) {
return ApiResponse.commonError("订单添加失败");
}else {
List<OrderItemDTO> orderItemList = order.getOrderItemList();
List<OrderItemEntity> orderItems = new ArrayList<>();
orderItemList.forEach(orderItemDTO -> {
OrderItemEntity orderItemEntity = new OrderItemEntity();
BeanUtil.copyProperties(orderItemDTO, orderItemEntity);
orderItemEntity.setOrderId(orderId);
});
int addOrderItems = orderMapper.addOrderItems(orderItems);
if (addOrderItems == 0) {
log.error("订单明细添加失败");
return ApiResponse.commonError("订单添加失败");
}
return ApiResponse.success(add);
}
}
@Override
public ApiResponse<Integer> update(OrderAddOrUpdateReq query) {
int update = orderMapper.update(query);
if (update == 0) {
return ApiResponse.commonError("订单更新失败");
}
return ApiResponse.success(update);
}
}

View File

@ -42,7 +42,7 @@ public class RoleServiceImpl implements RoleService {
// }
List<RoleListRespVO> list = roleMapper.list(roleListReqVO);
PageInfo<RoleListRespVO> pageInfo = new PageInfo(list);
return ApiResponse.buildSuccessResponse(pageInfo);
return ApiResponse.success(pageInfo);
}
@Override
@ -55,7 +55,7 @@ public class RoleServiceImpl implements RoleService {
if(addOrUpdateRoleReqVO.getMenuIdList()!=null&addOrUpdateRoleReqVO.getMenuIdList().size()>0) {
menuMapper.addRoleMenu(roleId, addOrUpdateRoleReqVO.getMenuIdList());
}
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
}else {
if(roleMapper.update(addOrUpdateRoleReqVO)>0){
@ -63,19 +63,19 @@ public class RoleServiceImpl implements RoleService {
if(addOrUpdateRoleReqVO.getMenuIdList()!=null&addOrUpdateRoleReqVO.getMenuIdList().size()>0){
menuMapper.addRoleMenu(addOrUpdateRoleReqVO.getId(),addOrUpdateRoleReqVO.getMenuIdList());
}
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
}
return ApiResponse.buildCommonErrorResponse("失败");
return ApiResponse.commonError("失败");
}
@Override
public ApiResponse delete(String id) {
if(roleMapper.delete(id)>0){
menuMapper.deleteRoleMenuByRoleId(id);
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
return ApiResponse.buildCommonErrorResponse("失败");
return ApiResponse.commonError("失败");
}
@Override
@ -95,16 +95,16 @@ public class RoleServiceImpl implements RoleService {
}
}
}
return ApiResponse.buildSuccessResponse(MenuList);
return ApiResponse.success(MenuList);
}
@Override
public ApiResponse updateStatus(String id) {
if(roleMapper.updateStatus(id)>0){
redisTemplate.opsForValue().set(ROLE_STATUS+id,roleMapper.getRoleStatus(id));
return ApiResponse.buildSuccessResponse(null);
return ApiResponse.success(null);
}
return ApiResponse.buildCommonErrorResponse("失败");
return ApiResponse.commonError("失败");
}
}

View File

@ -0,0 +1,22 @@
package com.ycwl.basic.service.pc;
import com.github.pagehelper.PageInfo;
import com.ycwl.basic.model.pc.order.entity.OrderEntity;
import com.ycwl.basic.model.pc.order.req.OrderAddOrUpdateReq;
import com.ycwl.basic.model.pc.order.req.OrderReqQuery;
import com.ycwl.basic.model.pc.order.resp.OrderRespVO;
import com.ycwl.basic.utils.ApiResponse;
import java.util.List;
/**
* @Authorlongbinbin
* @Date2024/12/3 13:51
*/
public interface OrderService {
ApiResponse<PageInfo<OrderRespVO>> pageQuery(OrderReqQuery query);
ApiResponse<List<OrderRespVO>> list(OrderReqQuery query);
ApiResponse<OrderRespVO> detail(Long orderId);
ApiResponse<Integer> add(OrderAddOrUpdateReq query);
ApiResponse<Integer> update(OrderAddOrUpdateReq query);
}