From 27c6695551c7229786ef2cf7dae722886c9edf53 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 09 八月 2024 22:53:44 +0800
Subject: [PATCH] 代理新功能完善
---
src/test/java/com/taoke/autopay/KeyTest.java | 67 ++++++++++++++++++++++++++++++++-
1 files changed, 64 insertions(+), 3 deletions(-)
diff --git a/src/test/java/com/taoke/autopay/KeyTest.java b/src/test/java/com/taoke/autopay/KeyTest.java
index 8a7dbfb..9df8b32 100644
--- a/src/test/java/com/taoke/autopay/KeyTest.java
+++ b/src/test/java/com/taoke/autopay/KeyTest.java
@@ -5,13 +5,14 @@
import com.taoke.autopay.entity.KeyOrder;
import com.taoke.autopay.entity.OrderCountTypeEnum;
import com.taoke.autopay.entity.SystemConfigKeyEnum;
+import com.taoke.autopay.entity.WxUserSettings;
import com.taoke.autopay.exception.KeyOrderException;
import com.taoke.autopay.exception.KeyVerifyException;
import com.taoke.autopay.exception.WxOrderCountException;
import com.taoke.autopay.manager.OrderPayFailProcessor;
-import com.taoke.autopay.service.KeyOrderService;
-import com.taoke.autopay.service.SystemConfigService;
+import com.taoke.autopay.service.*;
import com.taoke.autopay.utils.AlipayOrderUtil;
+import com.taoke.autopay.utils.Constant;
import com.taoke.autopay.utils.TimeUtil;
import com.taoke.autopay.vo.SubmitKeyInfo;
import org.junit.jupiter.api.Test;
@@ -19,6 +20,7 @@
import org.yeshi.utils.UrlUtils;
import javax.annotation.Resource;
+import java.util.Collections;
import java.util.Date;
import java.util.List;
@@ -72,7 +74,7 @@
throw new Exception("鍙ｄ护鍐呭鑾峰彇澶辫触");
}
// 楠岃瘉鍐呭
- DYOrderDto dto = keyOrderService.verifyKey(tradeInfo.getGoodsTitle(), orderStatus, tradeInfo.getItemRealAmount());
+ DYOrderDto dto = keyOrderService.verifyKey(tradeInfo.getGoodsTitle(), orderStatus, tradeInfo.getItemRealAmount(),null, null);
} catch (KeyVerifyException ee) {
throw ee;
} catch (Exception e) {
@@ -135,5 +137,64 @@
}
+ @Resource
+ private ClientInfoService clientInfoService;
+
+ @Test
+ public void test2(){
+ List<Long> clientIds = clientInfoService.getRePayClientIds();
+ if (clientIds!=null&&clientIds.size()>0) {
+ Collections.shuffle(clientIds);
+ // 鏌ヨ璁惧鏈墽琛岀殑鏁伴噺
+ for(Long cuid:clientIds) {
+ KeyOrderMapper.DaoQuery daoQuery = new KeyOrderMapper.DaoQuery();
+ daoQuery.distributeClientUid =cuid;
+ daoQuery.state = KeyOrder.STATE_NOT_PAY;
+ daoQuery.minCreateTime=new Date(System.currentTimeMillis() - 1000*60*30L);
+ long count = keyOrderService.count(daoQuery);
+ if(count <=1){
+ // 鍒嗛厤
+ System.out.println( cuid);
+ }
+ }
+ }
+
+
+ }
+
+ @Resource
+ private WxUserSettingService wxUserSettingService;
+
+ @Resource
+ private WxUserOrderCountService wxUserOrderCountService;
+
+ @Test
+ public void testCount() throws Exception{
+ Long uid = 5413L;
+ int orderType = Constant.ORDER_TYPE_DY;
+ WxUserSettings settings = wxUserSettingService.getUserSettings(uid);
+
+ OrderCountTypeEnum orderCountType = OrderCountTypeEnum.SUBMIT_TOKEN_COUNT;
+ int maxCount = settings.getTotalOrderCountPerDay();
+ switch (orderType) {
+ case Constant.ORDER_TYPE_DY:
+ orderCountType = OrderCountTypeEnum.DY_ORDER_PAY;
+ maxCount = settings.getDyOrderCountPerDay();
+ break;
+ case Constant.ORDER_TYPE_KS:
+ orderCountType = OrderCountTypeEnum.KS_ORDER_PAY;
+ maxCount = settings.getKsOrderCountPerDay();
+ break;
+ }
+
+ try {
+ wxUserOrderCountService.isOrderCountLimit(uid, orderCountType, TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd"), 1, maxCount);
+ } catch (WxOrderCountException e) {
+ e.printStackTrace();
+ throw new KeyVerifyException(KeyVerifyException.CODE_COMMON, "浠婃棩鎻愪氦瓒呰繃" + maxCount + "娆�");
+ }
+
+ }
+
}
--
Gitblit v1.8.0