From b2ffa5e35c99ea26a296cd7997960f6e8b95c3ca Mon Sep 17 00:00:00 2001 From: ninftao <13586541001@163.com> Date: Mon, 13 Dec 2021 17:26:48 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E4=BC=9A=E5=91=98=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/hchbox/controller/TopTradeController.java | 11 +++++++++++ .../repository/master/TopTradeRepository.java | 9 +++++++++ .../java/com/hchbox/service/MemberService.java | 7 +++++++ .../java/com/hchbox/service/TopTradeService.java | 7 +++++++ .../com/hchbox/service/impl/MemberServiceImpl.java | 14 ++++++++++++-- .../com/hchbox/service/impl/ShopServiceImpl.java | 1 - .../hchbox/service/impl/TopTradeServiceImpl.java | 11 +++++++++++ 7 files changed, 57 insertions(+), 3 deletions(-) diff --git a/service/trade-service-source/trade-service-source-core/src/main/java/com/hchbox/controller/TopTradeController.java b/service/trade-service-source/trade-service-source-core/src/main/java/com/hchbox/controller/TopTradeController.java index 1a12fcd..f2b5cd3 100644 --- a/service/trade-service-source/trade-service-source-core/src/main/java/com/hchbox/controller/TopTradeController.java +++ b/service/trade-service-source/trade-service-source-core/src/main/java/com/hchbox/controller/TopTradeController.java @@ -146,4 +146,15 @@ public class TopTradeController { return topTradeService.synchronizeOrders(accountByNick, tradeCache.size()); } + @PostMapping("/synchronizeMember") + @ApiOperation("同步会员信息") + public CommonResult decryptList(@RequestParam("nickname") String nickname) { + SellerAccountDTO accountByNick = + sellerAccountService.getAccountByNick(nickname); + if (accountByNick == null) { + return new CommonResult().accountException(); + } + return topTradeService.synchronizeMember(accountByNick); + } + } diff --git a/service/trade-service-source/trade-service-source-dao/src/main/java/com/hchbox/repository/master/TopTradeRepository.java b/service/trade-service-source/trade-service-source-dao/src/main/java/com/hchbox/repository/master/TopTradeRepository.java index f0c2a8f..ce524a3 100644 --- a/service/trade-service-source/trade-service-source-dao/src/main/java/com/hchbox/repository/master/TopTradeRepository.java +++ b/service/trade-service-source/trade-service-source-dao/src/main/java/com/hchbox/repository/master/TopTradeRepository.java @@ -9,6 +9,7 @@ import org.springframework.data.jpa.repository.Query; import org.springframework.stereotype.Repository; import java.util.Date; +import java.util.List; /** * @author Enzo @@ -74,4 +75,12 @@ public interface TopTradeRepository extends JpaRepository, JpaSp @Modifying @Query(value = "update TopTrade t set t.status = ?1,t.endTime = ?3 where t.tid = ?2") void updateOrderStatusSuccessfulTransaction(String orderStatus, Long tid, DateTime date); + + + /** + * 昵称查找订单集合 + * @param sellerNick + * @return + */ + List findBySellerNick(String sellerNick); } diff --git a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/MemberService.java b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/MemberService.java index 1bd7424..cab4d3a 100644 --- a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/MemberService.java +++ b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/MemberService.java @@ -67,4 +67,11 @@ public interface MemberService { * @param sellerNick */ void updateMemberBySellerNick(String buyerNick, String sellerNick); + + /** + * 创建会员 + * @param topTrade + * @return + */ + Boolean createMember(TopTrade topTrade); } diff --git a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/TopTradeService.java b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/TopTradeService.java index beb60fb..e5d0386 100644 --- a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/TopTradeService.java +++ b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/TopTradeService.java @@ -148,4 +148,11 @@ public interface TopTradeService { * @return */ Boolean orderEvaluation(TaoBaoTradeMessage message); + + /** + * 同步会员信息 + * @param accountByNick + * @return + */ + CommonResult synchronizeMember(SellerAccountDTO accountByNick); } diff --git a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/MemberServiceImpl.java b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/MemberServiceImpl.java index 641709c..778e7da 100644 --- a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/MemberServiceImpl.java +++ b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/MemberServiceImpl.java @@ -359,9 +359,19 @@ public class MemberServiceImpl implements MemberService { " set buyer_rate = :buyerRate, update_time = :updateTime where seller_nick = :sellerNick and buyer_nick = :buyerNick"; hashMap.put("buyerRate", Boolean.TRUE); hashMap.put("buyerNick", buyerNick); - hashMap.put("sellerNick",sellerNick); + hashMap.put("sellerNick", sellerNick); hashMap.put("updateTime", DateUtil.date()); - namedParameterJdbcTemplate.update(updateString,hashMap); + namedParameterJdbcTemplate.update(updateString, hashMap); + } + + @Override + public Boolean createMember(TopTrade topTrade) { + Member member = memberRepository. + findBySellerNickAndBuyerNick(topTrade.getSellerNick(), topTrade.getBuyerNick()); + if (member == null) { + return initMember(topTrade); + } + return Boolean.FALSE; } diff --git a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/ShopServiceImpl.java b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/ShopServiceImpl.java index 336ecd2..fa4b8a8 100644 --- a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/ShopServiceImpl.java +++ b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/ShopServiceImpl.java @@ -2,7 +2,6 @@ package com.hchbox.service.impl; import cn.hutool.core.io.file.FileReader; import com.hchbox.entity.master.Shop; -import com.hchbox.model.param.CommonResult; import com.hchbox.repository.master.ShopRepository; import com.hchbox.service.ShopService; import lombok.RequiredArgsConstructor; diff --git a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/TopTradeServiceImpl.java b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/TopTradeServiceImpl.java index 8b184ef..095df4f 100644 --- a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/TopTradeServiceImpl.java +++ b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/service/impl/TopTradeServiceImpl.java @@ -703,5 +703,16 @@ public class TopTradeServiceImpl implements TopTradeService { return Boolean.FALSE; } + @Override + @DS(DataSourceConfiguration.SHARDING_DATASOURCE_NAME) + public CommonResult synchronizeMember(SellerAccountDTO accountByNick) { + List bySellerNick = topTradeRepository.findBySellerNick(accountByNick.getNickname()); + for (TopTrade topTrade : bySellerNick) { + memberService.createMember(topTrade); + } + return CommonResult.successfulOperation(); + + } + }