add

src/test/java/http/cases/PkTest/pk_开奖_批量用户开奖测试.java

@@ -221,9 +221,10 @@ public class pk_开奖_批量用户开奖测试 extends DuibaTestBase {
         try {
 
             Boolean result1 = jdbc.update("delete from act_com_conf.tb_bet_option where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result4 = jdbc.update("delete from act_record.tb_bet_record where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result5 = jdbc.update("delete from bet_activity.tb_bet_result where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result2 = jdbc.update("delete from act_com_conf.tb_bet_group_relation where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result3 = jdbc.update("delete from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%'");
-            Boolean result4 = jdbc.update("delete from act_record.tb_bet_record where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
 
             clear(consumerIds);
 

src/test/java/http/cases/PkTest/pk_开奖_瓜分优惠券.java

+/**
+ * Copyright (C), 2015-2018
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试_AccessTest
+ * Author:   qianwenjun
+ * Date:     2018/8/9 20:13
+ * Description:
+ */
+package http.cases.PkTest;
+
+
+import base.DuibaLog;
+import base.DuibaTestBase;
+import com.alibaba.fastjson.JSONObject;
+import http.model.BetMngVo;
+import http.service.Activity.PkService;
+import http.service.Manager.PkActivityService;
+import io.restassured.response.Response;
+import org.joda.time.DateTime;
+import org.joda.time.format.DateTimeFormat;
+import org.joda.time.format.DateTimeFormatter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.testng.Assert;
+import org.testng.annotations.AfterClass;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
+
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * 〈〉
+ *
+ * @author qianwenjun
+ * @create 2018/8/9
+ * @since 1.0.0
+ */
+public class pk_开奖_瓜分优惠券 extends DuibaTestBase {
+
+    @Autowired
+    PkService pkService;
+    @Autowired
+    PkActivityService pkActivityService;
+
+
+    private static DuibaLog logger = DuibaLog.getLogger();
+
+    private String groupId = "6,7";
+
+    private Integer user01 = 4812;//appid=18816
+    private String consumerId01 = "100108112";//activity_order_con.tb_trade_center_activity_order_0848
+    private Integer user02 = 4813;//appid=18816
+    private String consumerId02 = "100108113";//activity_order_con.tb_trade_center_activity_order_0849
+    private Integer user03 = 4814;//appid=2239
+    private String consumerId03 = "100108114";//activity_order_con.tb_trade_center_activity_order_0850
+    private Integer user04 = 4815;//appid=2239
+    private String consumerId04 = "100108115";//activity_order_con.tb_trade_center_activity_order_0851
+
+    List<String> wins = new ArrayList<>();
+    List<String> loses = new ArrayList<>();
+
+
+    private String newBetId = "";
+    private List<String> optionsIds = new ArrayList<>();
+
+
+    @BeforeMethod
+    //注意初始化的方法不能与父类的相同，会被覆盖住
+    public void setUpPkActivity() {
+
+
+        try {
+            createPk("2","2020-08-12 00:00:00",groupId);
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+
+    }
+
+
+    @Test
+    public void 瓜分红包_两个选项_押注人数不同_开奖测试() throws Exception{
+
+
+            List<Map<String,Object>> pks = jdbc.findModeResult("select * from act_com_conf.tb_bet_option where bet_id = ?",newBetId);
+            logger.info("pk活动信息为"+JSONObject.toJSONString(pks));
+            for (int i=0;i<pks.size();i++){
+                optionsIds.add(pks.get(i).get("id").toString());
+            }
+            logger.info("pk活动id为："+newBetId+"，选项id为："+ optionsIds.toString());
+            Map<String,Object> user01_account1 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0848 where consumer_id = '100108112' and account_type = '6'\n");
+            Long use1_Acc1 = Long.valueOf(user01_account1.get("balance_amount").toString());
+            Map<String,Object> user02_account1 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0849 where consumer_id = '100108113' and account_type = '6'\n");
+            Long use2_Acc1 = Long.valueOf(user02_account1.get("balance_amount").toString());
+            Map<String,Object> user03_account1 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0850 where consumer_id = '100108114' and account_type = '6'\n");
+            Long use3_Acc1 = Long.valueOf(user03_account1.get("balance_amount").toString());
+            Map<String,Object> user04_account1 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0851 where consumer_id = '100108115' and account_type = '6'\n");
+            Long use4_Acc1 = Long.valueOf(user04_account1.get("balance_amount").toString());
+
+
+            //押注第一个选项：user01，user02
+            //押注第二个选项：user03，user04
+            Response res1 = pkService.doJoin(user01,newBetId,optionsIds.get(0));
+            Response res2 = pkService.doJoin(user02,newBetId,optionsIds.get(1));
+            Response res3 = pkService.doJoin(user03,newBetId,optionsIds.get(0));
+            Response res4 = pkService.doJoin(user04,newBetId,optionsIds.get(1));
+            wins.add(consumerId01);
+            wins.add(consumerId03);
+            loses.add(consumerId02);
+            loses.add(consumerId04);
+
+            //修改开奖时间
+            this.modifyOpenPrizeTime(newBetId,60);
+
+            //调用开奖接口
+            Response doDrowRresponse = pkActivityService.doDraw();
+            Assert.assertEquals(doDrowRresponse.jsonPath().getString("success"),"true","开奖结果校验失败");
+            Assert.assertEquals(doDrowRresponse.jsonPath().getString("data"),"开奖中。。。","开奖messag校验失败");
+            Thread.sleep(8000);
+
+            //校验点
+            //1、pk活动表配置的状态更新为4；2、订单表的addCredits字段为瓜分的红包值；3、先押注 的选项为胜方，胜负的额押注人数>负方的押注人数，4、校验account表的红包值加上去
+            checkPKConfig();
+            checkPKResult("18816");
+            checkPKResult("2239");
+            checkUserOrder(wins,loses);
+            checkRecord(wins,loses);
+
+            Map<String,Object> user01_account2 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0848 where consumer_id = '100108112' and account_type = '6'\n");
+            Long use1_Acc2 = Long.valueOf(user01_account2.get("balance_amount").toString());
+            Assert.assertEquals(use1_Acc2.toString(),String.valueOf(use1_Acc1+10),"用户1入账校验失败");
+            Map<String,Object> user02_account2 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0849 where consumer_id = '100108113' and account_type = '6'\n");
+            Long use2_Acc2 = Long.valueOf(user02_account2.get("balance_amount").toString());
+            Assert.assertEquals(use2_Acc2,use2_Acc1,"用户2入账校验失败");
+            Map<String,Object> user03_account2 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0850 where consumer_id = '100108114' and account_type = '6'\n");
+            Long use3_Acc2 = Long.valueOf(user03_account2.get("balance_amount").toString());
+            Assert.assertEquals(use3_Acc2.toString(),String.valueOf(use3_Acc1+10),"用户3入账校验失败");
+            Map<String,Object> user04_account2 = jdbc.findSimpleResult("select * from consumer_accounts.tb_consumer_account_0851 where consumer_id = '100108115' and account_type = '6'\n");
+            Long use4_Acc2 = Long.valueOf(user04_account2.get("balance_amount").toString());
+            Assert.assertEquals(use4_Acc2,use4_Acc1,"用户4入账校验失败");
+
+
+    }
+
+
+    public void createPk(String bounsType,String endTime,String groupId) throws Exception {
+
+        Response betResponse = pkActivityService.betForSetUp(bounsType,endTime);
+        logger.info("新建pk活动的结果信息为"+JSONObject.toJSONString(betResponse.prettyPrint()));
+        betResponse.prettyPrint();
+        String betId = betResponse.jsonPath().getString("data");newBetId = betId;
+        logger.info("newBetId的信息为"+newBetId);
+        Response betRelation = pkActivityService.betGroupRelation(betId,endTime,groupId);
+        Response modifyStatusResponse = pkActivityService.modifySatus(betId);
+    }
+
+
+    public void modifyOpenPrizeTime(String betId,int x) throws Exception{
+
+        DateTime time1 = new DateTime();
+//        int x=20+(int)(Math.random()*100);
+        DateTime endTime = time1.minusMillis(x);
+
+        DateTimeFormatter format = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss");
+//        String endTimeStr = format.print(endTime.getMillis()).toString();
+        String endTimeStr = "2018-11-26 20:24:39";
+        logger.info("\ntime1="+ format.print(time1.getMillis())+"\n设置的开奖时间endTime="+ endTimeStr);
+        Boolean result1 = jdbc.update("update act_com_conf.tb_bet_config set end_time = ? where id = ?\n",endTimeStr,betId);
+        Boolean result2 = jdbc.update("update act_com_conf.tb_bet_group_relation set end_time = ? where bet_id = ?\n",endTimeStr,betId);
+
+    }
+
+    public void checkPKConfig() throws Exception{
+        Map<String,Object> betConfig = jdbc.findSimpleResult("select * from act_com_conf.tb_bet_config where id = ?",newBetId);
+        logger.info("betConfig的信息为："+ JSONObject.toJSONString(betConfig));
+        Assert.assertEquals(betConfig.get("config_status").toString(),"4","配置表状态更新失败");
+        Map<String,Object> betGroupRelation = jdbc.findSimpleResult("select * from act_com_conf.tb_bet_group_relation where bet_id = ?\n",newBetId);
+        Assert.assertEquals(betGroupRelation.get("config_status").toString(),"4","pk关系表开奖状态更新失败");
+        logger.info("pk活动配置表状态更新为："+betConfig.get("config_status").toString()+"，pk关系表活动状态更新为："+betGroupRelation.get("config_status").toString());
+        Response betList = pkActivityService.getMngBetList();
+        betList.prettyPrint();
+        List<BetMngVo> betMngVoList = betList.jsonPath().getList("data.page",BetMngVo.class);
+        for (BetMngVo bet:betMngVoList){
+            if (bet.getId().equals(newBetId)){
+                Assert.assertEquals(bet.getConfigStatus(),"4","开奖结果校验失败");
+            }
+        }
+    }
+
+    public void checkPKResult(String appId) throws Exception{
+
+        Map<String,Object> bet1Result = jdbc.findSimpleResult("select * from bet_activity.tb_bet_result where bet_id = ? and option_id = ? and app_id = ?\n",newBetId,optionsIds.get(0),appId);
+        Assert.assertEquals(bet1Result.get("rank").toString(),"1","开始押注的选项获胜校验失败");
+        Map<String,Object> bet2Result = jdbc.findSimpleResult("select * from bet_activity.tb_bet_result where bet_id = ? and option_id = ? and app_id = ?\n",newBetId,optionsIds.get(1),appId);
+        Assert.assertEquals(bet2Result.get("rank").toString(),"2","开始押注的选项获胜校验失败");
+        Long bet1Times = Long.valueOf(bet1Result.get("bet_times").toString());
+        Long bet2Times = Long.valueOf(bet2Result.get("bet_times").toString());
+        Assert.assertTrue(bet1Times>bet2Times,"活动获胜人数比失败人数多校验失败");
+        logger.info("选项1的押注人数为："+bet1Result.get("bet_times").toString()+"，选项2的押注人数为："+bet2Result.get("bet_times").toString());
+
+    }
+
+
+    public void checkUserOrder(List<String> wins,List<String> loses) throws Exception{
+
+        for (int i=0;i<wins.size();i++){
+            String dbName = "activity_order_con.tb_trade_center_activity_order_"+ String.format("%04d", Long.parseLong(wins.get(i)) % 1024);
+            logger.info("用户的分表名dbName为"+dbName);
+            Map<String,Object> user_order = jdbc.findSimpleResult("select * from "+dbName+" where consumer_id = ? and duiba_activity_id = ?\n",wins.get(i),newBetId);
+            Long account = Long.valueOf(user_order.get("add_credits").toString());
+            Assert.assertEquals(account.toString(),"10","开奖后订单更新");
+            logger.info("用户"+wins.get(i)+"订单获取的红包值为："+user_order.get("add_credits").toString());
+
+        }
+
+        for (int i=0;i<loses.size();i++){
+            String dbName = "activity_order_con.tb_trade_center_activity_order_"+ String.format("%04d", Long.parseLong(loses.get(i)) % 1024);
+            logger.info("用户的分表名dbName为"+dbName);
+            Map<String,Object> user_order = jdbc.findSimpleResult("select * from "+dbName+" where consumer_id = ? and duiba_activity_id = ?\n",loses.get(i),newBetId);
+            String account = user_order.get("add_credits").toString();
+            Assert.assertEquals(account.toString(),"","开奖后订单更新");
+            logger.info("用户"+loses.get(i)+"订单获取的红包值为："+user_order.get("add_credits").toString());
+
+        }
+    }
+
+    public void checkRecord(List<String> wins,List<String> loses) throws Exception{
+
+        for (int i=0;i<wins.size();i++){
+            Map<String,Object> useRecord = jdbc.findSimpleResult("select * from act_record.tb_bet_record where bet_id = ? and consumer_id = ? \n",newBetId,wins.get(i));
+            Assert.assertEquals(useRecord.get("bonus").toString(), "10", "record表的红包值校验失败");
+            Assert.assertEquals(useRecord.get("exchange_status").toString(), "2", "record表的发奖状态校验失败");
+            logger.info("用户"+wins.get(i)+"订单获取的红包值为："+useRecord.get("bonus").toString());
+
+        }
+        for (int i=0;i<loses.size();i++){
+            Map<String,Object> useRecord = jdbc.findSimpleResult("select * from act_record.tb_bet_record where bet_id = ? and consumer_id = ? \n",newBetId,loses.get(i));
+            Assert.assertEquals(useRecord.get("bonus").toString(), "0", "record表的红包值校验失败");
+            Assert.assertEquals(useRecord.get("exchange_status").toString(), "0", "record表的发奖状态校验失败");
+            logger.info("用户"+loses.get(i)+"订单获取的红包值为："+useRecord.get("bonus").toString());
+        }
+
+    }
+    @AfterClass
+    public void tearDown() {
+
+        try {
+
+
+            Boolean result1 = jdbc.update("delete from act_com_conf.tb_bet_option where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result4 = jdbc.update("delete from act_record.tb_bet_record where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result5 = jdbc.update("delete from bet_activity.tb_bet_result where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result2 = jdbc.update("delete from act_com_conf.tb_bet_group_relation where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result3 = jdbc.update("delete from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%'");
+
+
+
+        } catch (SQLException e) {
+            e.printStackTrace();
+        } catch (Exception e){
+            e.printStackTrace();
+        }
+    }
+
+}
\ No newline at end of file

src/test/java/http/cases/PkTest/pk_开奖_瓜分红包_押注人数不同测试_AccessTest.java

@@ -234,6 +234,7 @@ public class pk_开奖_瓜分红包_押注人数不同测试_AccessTest extends
 
             Boolean result1 = jdbc.update("delete from act_com_conf.tb_bet_option where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result4 = jdbc.update("delete from act_record.tb_bet_record where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result5 = jdbc.update("delete from bet_activity.tb_bet_result where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result2 = jdbc.update("delete from act_com_conf.tb_bet_group_relation where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result3 = jdbc.update("delete from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%'");
 

src/test/java/http/cases/PkTest/pk_开奖_瓜分红包_押注人数相同测试_AccessTest.java

@@ -186,6 +186,7 @@ public class pk_开奖_瓜分红包_押注人数相同测试_AccessTest extends
 
             Boolean result1 = jdbc.update("delete from act_com_conf.tb_bet_option where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result4 = jdbc.update("delete from act_record.tb_bet_record where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
+            Boolean result5 = jdbc.update("delete from bet_activity.tb_bet_result where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result2 = jdbc.update("delete from act_com_conf.tb_bet_group_relation where bet_id in (select id from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%')");
             Boolean result3 = jdbc.update("delete from act_com_conf.tb_bet_config where title like '【自动化】瓜分红包%'");