From b2c38d4c11fdfb95f2a7da1544e34f0ea69be8c1 Mon Sep 17 00:00:00 2001 From: zhang chengzhi <3144712872@qq.com> Date: Fri, 9 Aug 2024 15:57:53 +0800 Subject: [PATCH] =?UTF-8?q?feat():=E6=B7=BB=E5=8A=A0=E7=A6=81=E7=94=A8?= =?UTF-8?q?=E5=92=8C=E5=90=AF=E7=94=A8=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/OrderPayCustomerServiceImpl.java | 39 ++++++++----------- 1 file changed, 16 insertions(+), 23 deletions(-) diff --git a/cloud-pay-server/src/main/java/com/muyu/cloud/pay/service/impl/OrderPayCustomerServiceImpl.java b/cloud-pay-server/src/main/java/com/muyu/cloud/pay/service/impl/OrderPayCustomerServiceImpl.java index bc7b4b6..4eab478 100644 --- a/cloud-pay-server/src/main/java/com/muyu/cloud/pay/service/impl/OrderPayCustomerServiceImpl.java +++ b/cloud-pay-server/src/main/java/com/muyu/cloud/pay/service/impl/OrderPayCustomerServiceImpl.java @@ -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.OrderPayInfo; 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.mapper.OrderPayCustomerMapper; import com.muyu.cloud.pay.service.OrderPayCustomerService; 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.exception.ServiceException; 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.stereotype.Service; -import java.rmi.ServerException; -import java.util.ArrayList; import java.util.List; import java.util.Set; -import java.util.function.Function; import java.util.stream.Collectors; /** @@ -67,14 +62,14 @@ public class OrderPayCustomerServiceImpl extends ServiceImpl orderPayCustomerList = this.list(queryWrapper); - return orderPayCustomerList.stream() + return orderPayCustomerList.stream() .map(orderPayCustomer -> CustomerResp.customerBuild( - orderPayCustomer, - () -> orderPayService.selectOrderPayByAppAndLimit(orderPayCustomer.getAppCode(),5) - .stream() - .map(OrderPayInfo::buildCustomerOrderPaySimpleResp) - .toList()) - ) + orderPayCustomer, + () -> orderPayService.selectOrderPayByAppAndLimit(orderPayCustomer.getAppCode(), 5) + .stream() + .map(OrderPayInfo::buildCustomerOrderPaySimpleResp) + .toList()) + ) .toList(); @@ -82,7 +77,7 @@ public class OrderPayCustomerServiceImpl extends ServiceImpl getCustomerAllList() { - List naocsServiceAllList = nacosServerService.naocsServiceAllList(); + List naocsServiceAllList = nacosServerService.naocsServiceAllList(); LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.select(OrderPayCustomer::getAppCode); List orderPayCustomerList = this.list(queryWrapper); @@ -96,7 +91,7 @@ public class OrderPayCustomerServiceImpl extends ServiceImpl updateWrapper = new UpdateWrapper<>(); - updateWrapper.eq("id",orderCustomerId).set("status",status); + updateWrapper.eq("id", orderCustomerId).set("status", status); this.update(updateWrapper); } @@ -116,22 +111,20 @@ this.settingStatus(orderCustomerId, SystemYesNo.NO.getCode()); String appCode = orderPayCustomer.getAppCode(); List naocsServiceAllList = nacosServerService.naocsServiceAllList(); - log.info("进行服务合法性判断:[{}-->{}]",appCode,naocsServiceAllList); - if (!naocsServiceAllList.contains(appCode)){ + log.info("进行服务合法性判断:[{}-->{}]", appCode, naocsServiceAllList); + if (!naocsServiceAllList.contains(appCode)) { throw new ServiceException("客户编码违法"); } LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(OrderPayCustomer::getAppCode,appCode); + queryWrapper.eq(OrderPayCustomer::getAppCode, appCode); long isAppCodeOnly = this.count(queryWrapper); - log.info("进行服务code唯一性校验:[{}-{}]",appCode,isAppCodeOnly); - if (this.count(queryWrapper) >0){ + log.info("进行服务code唯一性校验:[{}-{}]", appCode, isAppCodeOnly); + if (this.count(queryWrapper) > 0) { throw new ServiceException("客户编码重复"); } return super.save(orderPayCustomer); } - - }