同步会员信息

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<String> decryptList(@RequestParam("nickname") String nickname) {
+        SellerAccountDTO accountByNick =
+                sellerAccountService.getAccountByNick(nickname);
+        if (accountByNick == null) {
+            return new CommonResult<String>().accountException();
+        }
+        return topTradeService.synchronizeMember(accountByNick);
+    }
+
 }

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<TopTrade, Long>, 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<TopTrade> findBySellerNick(String sellerNick);
 }

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);
 }

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<String> synchronizeMember(SellerAccountDTO accountByNick);
 }

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;
     }
 
 

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;

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<String> synchronizeMember(SellerAccountDTO accountByNick) {
+        List<TopTrade> bySellerNick = topTradeRepository.findBySellerNick(accountByNick.getNickname());
+        for (TopTrade topTrade : bySellerNick) {
+            memberService.createMember(topTrade);
+        }
+        return CommonResult.successfulOperation();
+
+    }
+
 
 }