feat():添加禁用和启用接口

master
zhang chengzhi 2024-08-09 15:57:53 +08:00
parent 4e6cbfb409
commit b2c38d4c11
1 changed files with 16 additions and 23 deletions

View File

@ -7,12 +7,10 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.cloud.pay.domain.OrderPayCustomer; import com.muyu.cloud.pay.domain.OrderPayCustomer;
import com.muyu.cloud.pay.domain.OrderPayInfo; import com.muyu.cloud.pay.domain.OrderPayInfo;
import com.muyu.cloud.pay.domain.req.CustomerListReq; import com.muyu.cloud.pay.domain.req.CustomerListReq;
import com.muyu.cloud.pay.domain.resp.CustomerOrderPaySimpleResp;
import com.muyu.cloud.pay.domain.resp.CustomerResp; import com.muyu.cloud.pay.domain.resp.CustomerResp;
import com.muyu.cloud.pay.mapper.OrderPayCustomerMapper; import com.muyu.cloud.pay.mapper.OrderPayCustomerMapper;
import com.muyu.cloud.pay.service.OrderPayCustomerService; import com.muyu.cloud.pay.service.OrderPayCustomerService;
import com.muyu.cloud.pay.service.OrderPayInfoService; import com.muyu.cloud.pay.service.OrderPayInfoService;
import com.muyu.common.core.enums.SysPayType;
import com.muyu.common.core.enums.SystemYesNo; import com.muyu.common.core.enums.SystemYesNo;
import com.muyu.common.core.exception.ServiceException; import com.muyu.common.core.exception.ServiceException;
import com.muyu.common.core.utils.StringUtils; import com.muyu.common.core.utils.StringUtils;
@ -22,11 +20,8 @@ import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.rmi.ServerException;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
@ -67,14 +62,14 @@ public class OrderPayCustomerServiceImpl extends ServiceImpl<OrderPayCustomerMap
); );
List<OrderPayCustomer> orderPayCustomerList = this.list(queryWrapper); List<OrderPayCustomer> orderPayCustomerList = this.list(queryWrapper);
return orderPayCustomerList.stream() return orderPayCustomerList.stream()
.map(orderPayCustomer -> CustomerResp.customerBuild( .map(orderPayCustomer -> CustomerResp.customerBuild(
orderPayCustomer, orderPayCustomer,
() -> orderPayService.selectOrderPayByAppAndLimit(orderPayCustomer.getAppCode(),5) () -> orderPayService.selectOrderPayByAppAndLimit(orderPayCustomer.getAppCode(), 5)
.stream() .stream()
.map(OrderPayInfo::buildCustomerOrderPaySimpleResp) .map(OrderPayInfo::buildCustomerOrderPaySimpleResp)
.toList()) .toList())
) )
.toList(); .toList();
@ -82,7 +77,7 @@ public class OrderPayCustomerServiceImpl extends ServiceImpl<OrderPayCustomerMap
@Override @Override
public List<String> getCustomerAllList() { public List<String> getCustomerAllList() {
List<String> naocsServiceAllList = nacosServerService.naocsServiceAllList(); List<String> naocsServiceAllList = nacosServerService.naocsServiceAllList();
LambdaQueryWrapper<OrderPayCustomer> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<OrderPayCustomer> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.select(OrderPayCustomer::getAppCode); queryWrapper.select(OrderPayCustomer::getAppCode);
List<OrderPayCustomer> orderPayCustomerList = this.list(queryWrapper); List<OrderPayCustomer> orderPayCustomerList = this.list(queryWrapper);
@ -96,7 +91,7 @@ public class OrderPayCustomerServiceImpl extends ServiceImpl<OrderPayCustomerMap
@Override //禁用客户 @Override //禁用客户
public void disable(Long orderCustomerId) { public void disable(Long orderCustomerId) {
this.settingStatus(orderCustomerId, SystemYesNo.NO.getCode()); this.settingStatus(orderCustomerId, SystemYesNo.NO.getCode());
} }
@Override //启用客户 @Override //启用客户
@ -104,9 +99,9 @@ this.settingStatus(orderCustomerId, SystemYesNo.NO.getCode());
this.settingStatus(orderCustomerId, SystemYesNo.YES.getCode()); this.settingStatus(orderCustomerId, SystemYesNo.YES.getCode());
} }
public void settingStatus(Long orderCustomerId,String status){ public void settingStatus(Long orderCustomerId, String status) {
UpdateWrapper<OrderPayCustomer> updateWrapper = new UpdateWrapper<>(); UpdateWrapper<OrderPayCustomer> updateWrapper = new UpdateWrapper<>();
updateWrapper.eq("id",orderCustomerId).set("status",status); updateWrapper.eq("id", orderCustomerId).set("status", status);
this.update(updateWrapper); this.update(updateWrapper);
} }
@ -116,22 +111,20 @@ this.settingStatus(orderCustomerId, SystemYesNo.NO.getCode());
String appCode = orderPayCustomer.getAppCode(); String appCode = orderPayCustomer.getAppCode();
List<String> naocsServiceAllList = nacosServerService.naocsServiceAllList(); List<String> naocsServiceAllList = nacosServerService.naocsServiceAllList();
log.info("进行服务合法性判断:[{}-->{}]",appCode,naocsServiceAllList); log.info("进行服务合法性判断:[{}-->{}]", appCode, naocsServiceAllList);
if (!naocsServiceAllList.contains(appCode)){ if (!naocsServiceAllList.contains(appCode)) {
throw new ServiceException("客户编码违法"); throw new ServiceException("客户编码违法");
} }
LambdaQueryWrapper<OrderPayCustomer> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<OrderPayCustomer> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(OrderPayCustomer::getAppCode,appCode); queryWrapper.eq(OrderPayCustomer::getAppCode, appCode);
long isAppCodeOnly = this.count(queryWrapper); long isAppCodeOnly = this.count(queryWrapper);
log.info("进行服务code唯一性校验:[{}-{}]",appCode,isAppCodeOnly); log.info("进行服务code唯一性校验:[{}-{}]", appCode, isAppCodeOnly);
if (this.count(queryWrapper) >0){ if (this.count(queryWrapper) > 0) {
throw new ServiceException("客户编码重复"); throw new ServiceException("客户编码重复");
} }
return super.save(orderPayCustomer); return super.save(orderPayCustomer);
} }
} }