From 41d297b755a2b73174220e7e64ec0ec150fa0ed0 Mon Sep 17 00:00:00 2001 From: Guoqs <123@jsowell.com> Date: Tue, 18 Jun 2024 09:36:02 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=94=AF=E4=BB=98=E5=AE=9D=E5=B0=8F?= =?UTF-8?q?=E7=A8=8B=E5=BA=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/uniapp/PersonPileController.java | 22 +++++++++++++++++++ .../com/jsowell/service/MemberService.java | 5 +++-- .../java/com/jsowell/service/PileService.java | 13 +++++++++++ .../pile/AdapayMemberController.java | 3 +++ .../jsowell/adapay/service/AdapayService.java | 6 ++--- .../service/AliAppletRemoteService.java | 2 +- .../jsowell/pile/domain/MemberBasicInfo.java | 5 +++++ .../pile/dto/MemberRegisterAndLoginDTO.java | 5 +++++ .../mapper/pile/MemberBasicInfoMapper.xml | 7 +++++- 9 files changed, 60 insertions(+), 8 deletions(-) diff --git a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/PersonPileController.java b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/PersonPileController.java index 5750e52c9..eb59ed0da 100644 --- a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/PersonPileController.java +++ b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/PersonPileController.java @@ -249,4 +249,26 @@ public class PersonPileController extends BaseController { /** * 个人桩启动充电 */ + + /** + * 取消预约 + */ + public RestApiResponse canal(HttpServletRequest request, @RequestBody QueryPersonPileDTO dto) { + logger.info("取消预约params:{}", JSON.toJSONString(dto)); + RestApiResponse response = null; + try { + String memberId = getMemberIdByAuthorization(request); + dto.setMemberId(memberId); + pileService.canalReserved(dto); + response = new RestApiResponse<>(); + } catch (BusinessException e) { + logger.error("取消预约error", e); + response = new RestApiResponse<>(e.getCode(), e.getMessage()); + } catch (Exception e) { + logger.error("取消预约error", e); + response = new RestApiResponse<>(e); + } + logger.info("取消预约result:{}", response); + return response; + } } diff --git a/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java b/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java index 43c43b28c..99e6342d3 100644 --- a/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java +++ b/jsowell-admin/src/main/java/com/jsowell/service/MemberService.java @@ -247,9 +247,10 @@ public class MemberService { String decrypt = Factory.Util.AES().decrypt(dto.getMobileNumberCiphertext()); String mobileNumber = JSON.parseObject(decrypt).getString("mobile"); + // 获取buyer_id + // 根据appid查询merchantId - String firstLevelMerchantId = pileMerchantInfoService.getFirstLevelMerchantIdByWxAppId(dto.getAppId()); - firstLevelMerchantId = "1"; + String firstLevelMerchantId = pileMerchantInfoService.getFirstLevelMerchantIdByAliAppId(dto.getAppId()); // 查询手机号码是否注册过 MemberRegisterAndLoginDTO loginDTO = MemberRegisterAndLoginDTO.builder() diff --git a/jsowell-admin/src/main/java/com/jsowell/service/PileService.java b/jsowell-admin/src/main/java/com/jsowell/service/PileService.java index d35ead69d..28f4ddcfe 100644 --- a/jsowell-admin/src/main/java/com/jsowell/service/PileService.java +++ b/jsowell-admin/src/main/java/com/jsowell/service/PileService.java @@ -555,4 +555,17 @@ public class PileService { } return 1; } + + /** + * 查询充电桩预约记录 + */ + + + /** + * 取消预约充电 + * @param dto + */ + public void canalReserved(QueryPersonPileDTO dto) { + + } } diff --git a/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/AdapayMemberController.java b/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/AdapayMemberController.java index 0cbd09004..9ec4eae0d 100644 --- a/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/AdapayMemberController.java +++ b/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/AdapayMemberController.java @@ -5,9 +5,11 @@ import com.huifu.adapay.core.exception.BaseAdaPayException; import com.jsowell.adapay.dto.*; import com.jsowell.adapay.service.AdapayService; import com.jsowell.adapay.vo.AdapayAccountBalanceVO; +import com.jsowell.common.annotation.Log; import com.jsowell.common.core.controller.BaseController; import com.jsowell.common.core.domain.AjaxResult; import com.jsowell.common.core.page.PageResponse; +import com.jsowell.common.enums.BusinessType; import com.jsowell.common.enums.ykc.ReturnCodeEnum; import com.jsowell.common.exception.BusinessException; import com.jsowell.common.util.StringUtils; @@ -183,6 +185,7 @@ public class AdapayMemberController extends BaseController { * http://localhost:8080/adapay/member/drawCash */ @PostMapping("/drawCash") + @Log(title = "汇付余额提现到银行卡", businessType = BusinessType.UPDATE) public AjaxResult drawCash(@RequestBody WithdrawDTO dto) { AjaxResult result; try { diff --git a/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayService.java b/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayService.java index 758adc1c1..76c3f846a 100644 --- a/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayService.java +++ b/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayService.java @@ -107,7 +107,6 @@ public class AdapayService { if (memberBasicInfo == null) { throw new BusinessException(ReturnCodeEnum.CODE_GET_OPEN_ID_BY_CODE_ERROR); } - String openId = memberBasicInfo.getOpenId(); // 支付场景 String type = dto.getType(); @@ -139,7 +138,7 @@ public class AdapayService { createAdaPaymentParam.setDescription(JSON.toJSONString(map)); // 异步通知地址，url为http/https路径，服务器POST回调，URL 上请勿附带参数 createAdaPaymentParam.setNotify_url(ADAPAY_CALLBACK_URL); - createAdaPaymentParam.setExpend(JSON.toJSONString(ImmutableMap.of("open_id", openId))); + createAdaPaymentParam.setExpend(JSON.toJSONString(ImmutableMap.of("open_id", memberBasicInfo.getOpenId()))); // 延时分账 if (StringUtils.isNotBlank(payMode)) { @@ -197,7 +196,6 @@ public class AdapayService { if (memberBasicInfo == null) { throw new BusinessException(ReturnCodeEnum.CODE_GET_OPEN_ID_BY_CODE_ERROR); } - String openId = memberBasicInfo.getOpenId(); // 支付场景 String type = dto.getType(); @@ -230,7 +228,7 @@ public class AdapayService { createAdaPaymentParam.setNotify_url(ADAPAY_CALLBACK_URL); // alipay_lite参数 buyer_id String(100) Y 买家的支付宝用户 id - createAdaPaymentParam.setExpend(JSON.toJSONString(ImmutableMap.of("buyer_id", openId))); + createAdaPaymentParam.setExpend(JSON.toJSONString(ImmutableMap.of("buyer_id", memberBasicInfo.getBuyerId()))); // 延时分账 if (StringUtils.isNotBlank(payMode)) { diff --git a/jsowell-pile/src/main/java/com/jsowell/alipay/service/AliAppletRemoteService.java b/jsowell-pile/src/main/java/com/jsowell/alipay/service/AliAppletRemoteService.java index 9d5a0e535..5f6ac8046 100644 --- a/jsowell-pile/src/main/java/com/jsowell/alipay/service/AliAppletRemoteService.java +++ b/jsowell-pile/src/main/java/com/jsowell/alipay/service/AliAppletRemoteService.java @@ -9,6 +9,7 @@ import com.alipay.api.AlipayConfig; import com.alipay.api.DefaultAlipayClient; import com.alipay.api.internal.util.AlipayEncrypt; import com.alipay.api.request.AlipaySystemOauthTokenRequest; +import com.alipay.easysdk.base.oauth.Client; import com.alipay.easysdk.base.oauth.models.AlipaySystemOauthTokenResponse; import com.alipay.easysdk.factory.Factory; import com.jsowell.alipay.config.AliPayConfig; @@ -43,7 +44,6 @@ public class AliAppletRemoteService { String accessToken = token.getAccessToken(); - // Factory.Util.AES().decrypt(); return ""; } diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberBasicInfo.java b/jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberBasicInfo.java index 130700029..b3d915084 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberBasicInfo.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberBasicInfo.java @@ -42,6 +42,11 @@ public class MemberBasicInfo extends BaseEntity { */ private String openId; + /** + * 支付宝买家user_id + */ + private String buyerId; + /** * 车牌号 */ diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/dto/MemberRegisterAndLoginDTO.java b/jsowell-pile/src/main/java/com/jsowell/pile/dto/MemberRegisterAndLoginDTO.java index 382f98e68..b9e3f231e 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/dto/MemberRegisterAndLoginDTO.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/dto/MemberRegisterAndLoginDTO.java @@ -34,4 +34,9 @@ public class MemberRegisterAndLoginDTO extends BaseDTO{ * 微信用户openId */ private String openId; + + /** + * 支付宝buyer_id + */ + private String buyerId; } diff --git a/jsowell-pile/src/main/resources/mapper/pile/MemberBasicInfoMapper.xml b/jsowell-pile/src/main/resources/mapper/pile/MemberBasicInfoMapper.xml index 87d9c5997..0197bb577 100644 --- a/jsowell-pile/src/main/resources/mapper/pile/MemberBasicInfoMapper.xml +++ b/jsowell-pile/src/main/resources/mapper/pile/MemberBasicInfoMapper.xml @@ -8,6 +8,7 @@ + @@ -32,7 +33,8 @@ - id, member_id, open_id, license_plate_number, nick_name,logic_card, physics_card, status, avatar_url, mobile_number, merchant_id, remark, + id, member_id, open_id, buyer_id, license_plate_number, nick_name,logic_card, physics_card, status, avatar_url, + mobile_number, merchant_id, remark, create_time, create_by, update_time, update_by, del_flag @@ -59,6 +61,7 @@ member_id, open_id, + buyer_id, license_plate_number, nick_name, logic_card, @@ -76,6 +79,7 @@ #{memberId}, #{openId}, + #{buyerId}, #{licensePlateNumber}, #{nickName}, #{logicCard}, @@ -97,6 +101,7 @@ member_id = #{memberId}, open_id = #{openId}, + buyer_id = #{buyerId}, license_plate_number = #{licensePlateNumber}, nick_name = #{nickName}, logic_card = #{logicCard},