Merge branch 'master' of http://git.izouma.com/xiongzhu/9th

src/test/java/com/izouma/nineth/service/OrderServiceTest.java

@@ -5,12 +5,13 @@ import com.huifu.adapay.core.exception.BaseAdaPayException;
 import com.huifu.adapay.model.Payment;
 import com.izouma.nineth.ApplicationTests;
 import com.izouma.nineth.TokenHistory;
-import com.izouma.nineth.domain.Asset;
-import com.izouma.nineth.domain.Collection;
-import com.izouma.nineth.domain.Order;
+import com.izouma.nineth.domain.*;
+import com.izouma.nineth.dto.UserBankCard;
 import com.izouma.nineth.enums.AssetStatus;
+import com.izouma.nineth.enums.AuthStatus;
 import com.izouma.nineth.enums.OrderStatus;
 import com.izouma.nineth.repo.*;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.EncoderException;
 import org.apache.commons.collections.MapUtils;
 import org.junit.Test;
@@ -20,8 +21,10 @@ import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.stream.Collectors;
 
+@Slf4j
 public class OrderServiceTest extends ApplicationTests {
     @Autowired
     private OrderService     orderService;
@@ -37,6 +40,10 @@ public class OrderServiceTest extends ApplicationTests {
     private CollectionRepo   collectionRepo;
     @Autowired
     private UserRepo         userRepo;
+    @Autowired
+    private IdentityAuthRepo identityAuthRepo;
+    @Autowired
+    private UserBankCardRepo userBankCardRepo;
 
     @Test
     public void create() throws EncoderException, WxPayException {
@@ -124,4 +131,35 @@ public class OrderServiceTest extends ApplicationTests {
             }
         }
     }
+
+    @Test
+    public void fixPay() {
+        String s = "\n订单ID\t金额\t手续费\t版税\t收款用户ID\t收款人\t银行卡号\t银行";
+        for (Long orderId : new Long[]{5417L, 5919L, 5923L, 8166L}) {
+            try {
+                Order order = orderRepo.findById(orderId).get();
+                List<Asset> assets = assetRepo.findByTokenIdOrderByCreatedAt(assetRepo.findById(order.getAssetId())
+                        .get()
+                        .getTokenId());
+                Asset asset = assets.stream().filter(a -> a.getStatus() == AssetStatus.TRANSFERRED).findAny().get();
+                User user = userRepo.findById(asset.getUserId()).get();
+                Optional<IdentityAuth> identityAuth = identityAuthRepo.findByUserIdAndDelFalse(user.getId()).stream()
+                        .filter(i -> i.getStatus() == AuthStatus.SUCCESS).findAny();
+                Optional<UserBankCard> bankCard = userBankCardRepo.findByUserId(user.getId()).stream().findAny();
+                s += "\n"
+                        + orderId + "\t"
+                        + order.getTotalPrice().subtract(order.getGasPrice()) + "\t"
+                        + order.getServiceCharge() + "\t"
+                        + order.getRoyalties() + "\t"
+                        + user.getId() + "\t"
+                        + identityAuth.map(IdentityAuth::getRealName).orElse("") + "\t"
+                        + bankCard.map(UserBankCard::getBankNo).orElse("") + "\t"
+                        + bankCard.map(UserBankCard::getBankName).orElse("");
+            } catch (Exception e) {
+
+            }
+
+        }
+        log.info(s);
+    }
 }