add

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

 /**
  * Copyright (C), 2015-2018
- * FileName: pk_开奖_瓜分红包_押注人数不同测试_PkTest
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试
  * Author:   qianwenjun
  * Date:     2018/8/9 20:13
  * Description:

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

 /**
  * Copyright (C), 2015-2018
- * FileName: pk_开奖_瓜分红包_押注人数不同测试_PkTest
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试
  * Author:   qianwenjun
  * Date:     2018/8/9 20:13
  * Description:

src/test/java/http/cases/PkTest/pk_开奖_瓜分红包_投放两个app_PkTest.java

 /**
  * Copyright (C), 2015-2018
- * FileName: pk_开奖_瓜分红包_押注人数不同测试_PkTest
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试
  * Author:   qianwenjun
  * Date:     2018/8/9 20:13
  * Description:

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

 /**
  * Copyright (C), 2015-2018
- * FileName: pk_开奖_瓜分红包_押注人数不同测试_PkTest
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试
  * Author:   qianwenjun
  * Date:     2018/8/9 20:13
  * Description:
@@ -44,7 +44,7 @@ import java.util.Map;
  * @create 2018/8/9
  * @since 1.0.0
  */
-public class pk_开奖_瓜分红包_押注人数不同测试_PkTest extends DuibaTestBase {
+public class pk_开奖_瓜分红包_押注人数不同测试 extends DuibaTestBase {
 
     @Autowired
     PkService pkService;

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

 /**
  * Copyright (C), 2015-2018
- * FileName: pk_开奖_瓜分红包_押注人数不同测试_PkTest
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试
  * Author:   qianwenjun
  * Date:     2018/8/9 20:13
  * Description:
@@ -38,7 +38,7 @@ import java.util.Map;
  * @create 2018/8/9
  * @since 1.0.0
  */
-public class pk_开奖_瓜分红包_押注人数相同测试_PkTest extends DuibaTestBase {
+public class pk_开奖_瓜分红包_押注人数相同测试 extends DuibaTestBase {
 
     @Autowired
     PkService pkService;

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

+/**
+ * Copyright (C), 2015-2018
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试
+ * 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 utils.GetDbName;
+
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * 〈〉
+ *
+ * @author qianwenjun
+ * @create 2018/8/9
+ * @since 1.0.0
+ */
+public class pk_瓜分红包_押注人数不同测试_PkTest extends DuibaTestBase {
+
+    @Autowired
+    PkService pkService;
+    @Autowired
+    PkActivityService pkActivityService;
+
+
+    private static DuibaLog logger = DuibaLog.getLogger();
+
+    private String groupId = "132";
+
+    private Integer user01 = 5165;
+    private String consumerId01 = "100114015";//activity_order_con.tb_trade_center_activity_order_0060
+    private Integer user02 = 5166;
+    private String consumerId02 = "100114016";//activity_order_con.tb_trade_center_activity_order_0061
+    private Integer user03 = 5167;
+    private String consumerId03 = "100114017";//activity_order_con.tb_trade_center_activity_order_0062
+    private Integer user04 = 5168;
+    private String consumerId04 = "100114018";//activity_order_con.tb_trade_center_activity_order_0063
+
+
+    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 = this.accountInfo(consumerId01);
+            Long use1_Acc1 = Long.valueOf(user01_account1.get("balance_amount").toString());
+            Map<String,Object> user02_account1 = this.accountInfo(consumerId02);
+            Long use2_Acc1 = Long.valueOf(user02_account1.get("balance_amount").toString());
+            Map<String,Object> user03_account1 = this.accountInfo(consumerId03);
+            Long use3_Acc1 = Long.valueOf(user03_account1.get("balance_amount").toString());
+            Map<String,Object> user04_account1 = this.accountInfo(consumerId04);
+            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(1));
+            Response res4 = pkService.doJoin(user04,newBetId,optionsIds.get(1));
+
+            //修改开奖时间
+            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表的红包值加上去
+            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","开奖结果校验失败");
+                }
+            }
+
+            Map<String,Object> user01_order = this.orderInfo(consumerId01,newBetId);
+            Assert.assertEquals(user01_order.get("add_credits").toString(),"","开奖后发奖值校验失败");
+            Map<String,Object> user02_order = this.orderInfo(consumerId02,newBetId);
+            Assert.assertEquals(user02_order.get("add_credits").toString(),"10","开奖后发奖值校验失败");
+            Map<String,Object> user03_order = this.orderInfo(consumerId03,newBetId);
+            Assert.assertEquals(user03_order.get("add_credits").toString(),"10","开奖后发奖值校验失败");
+            Map<String,Object> user04_order = this.orderInfo(consumerId04,newBetId);
+            Assert.assertEquals(user04_order.get("add_credits").toString(),"10","开奖后发奖值校验失败");
+            logger.info("用户01获取的红包值为："+user01_order.get("add_credits").toString()+",用户02获取的红包值为："+user02_order.get("add_credits").toString());
+            logger.info("用户03获取的红包值为："+user03_order.get("add_credits").toString()+",用户04获取的红包值为："+user04_order.get("add_credits").toString());
+
+            Map<String,Object> bet1Result = jdbc.findSimpleResult("select * from bet_activity.tb_bet_result where bet_id = ? and option_id = ?\n",newBetId,optionsIds.get(0));
+            Assert.assertEquals(bet1Result.get("rank").toString(),"2","开始押注的选项获胜校验失败");
+            Map<String,Object> bet2Result = jdbc.findSimpleResult("select * from bet_activity.tb_bet_result where bet_id = ? and option_id = ?\n",newBetId,optionsIds.get(1));
+            Assert.assertEquals(bet2Result.get("rank").toString(),"1","开始押注的选项获胜校验失败");
+            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());
+
+            Map<String,Object> user01_account2 = this.accountInfo(consumerId01);
+            Long use1_Acc2 = Long.valueOf(user01_account2.get("balance_amount").toString());
+            Assert.assertEquals(use1_Acc2,use1_Acc1,"用户1入账校验失败");
+            Map<String,Object> user02_account2 = this.accountInfo(consumerId02);
+            Long use2_Acc2 = Long.valueOf(user02_account2.get("balance_amount").toString());
+            Assert.assertEquals(use2_Acc2.toString(),String.valueOf(use2_Acc1+10),"用户2入账校验失败");
+            Map<String,Object> user03_account2 = this.accountInfo(consumerId03);
+            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 = this.accountInfo(consumerId04);
+            Long use4_Acc2 = Long.valueOf(user04_account2.get("balance_amount").toString());
+            Assert.assertEquals(use4_Acc2.toString(),String.valueOf(use4_Acc1+10),"用户4入账校验失败");
+
+
+    }
+
+    public Map<String,Object> accountInfo(String consumerId) throws Exception{
+        Map<String,Object> map = new HashMap<>();
+        String dbName1 = GetDbName.getDbName("consumer_accounts.tb_consumer_account_",consumerId,"1");
+        String sql1 = "select * from "+dbName1+" where consumer_id = ? and account_type = '6'";
+        map = jdbc.findSimpleResult(sql1,consumerId);
+        return map;
+
+    }
+
+    public Map<String,Object> orderInfo(String consumerId,String betId) throws Exception{
+        Map<String,Object> map = new HashMap<>();
+        String dbName1 = GetDbName.getDbName("activity_order_con.tb_trade_center_activity_order_",consumerId,"1");
+        String sql1 = "select * from "+dbName1+" where consumer_id = ? and duiba_activity_id = ?\n";
+        map = jdbc.findSimpleResult(sql1,consumerId,betId);
+        return map;
+
+    }
+
+    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);
+
+    }
+
+//    @Test
+    public void 调试(){
+        try {
+            Map<String,Object> betConfig = jdbc.findSimpleResult("select * from act_com_conf.tb_bet_config where id = ?","1179");
+            logger.info("betConfig的信息为："+ JSONObject.toJSONString(betConfig));
+            logger.info("betConfig的信息为："+ betConfig.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("1185")){
+                    Assert.assertEquals(bet.getConfigStatus(),"4","开奖结果校验失败");
+                }
+            }
+
+
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+
+    }
+
+
+
+    @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_瓜分红包_押注人数相同测试_PkTest.java

+/**
+ * Copyright (C), 2015-2018
+ * FileName: pk_开奖_瓜分红包_押注人数不同测试
+ * 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 utils.GetDbName;
+
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * 〈〉
+ *
+ * @author qianwenjun
+ * @create 2018/8/9
+ * @since 1.0.0
+ */
+public class pk_瓜分红包_押注人数相同测试_PkTest extends DuibaTestBase {
+
+    @Autowired
+    PkService pkService;
+    @Autowired
+    PkActivityService pkActivityService;
+
+
+    private static DuibaLog logger = DuibaLog.getLogger();
+
+    private String groupId = "129";//appId=21830
+
+    private Integer user01 = 5156;
+    private String consumerId01 = "100114000";//activity_order_con.tb_trade_center_activity_order_0804
+    private Integer user02 = 5157;
+    private String consumerId02 = "100114001";//activity_order_con.tb_trade_center_activity_order_0805
+
+
+    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 = this.accountInfo(consumerId01);
+        Long use1_Acc1 = Long.valueOf(user01_account1.get("balance_amount").toString());
+        Map<String,Object> user02_account1 = this.accountInfo(consumerId02);
+        Long use2_Acc1 = Long.valueOf(user02_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));
+
+        //修改开奖时间
+        this.modifyOpenPrizeTime(newBetId,120);
+
+        //调用开奖接口
+        Response doDrowRresponse = pkActivityService.doDraw();
+        Assert.assertEquals(doDrowRresponse.jsonPath().getString("success"),"true","开奖结果校验失败");
+        Assert.assertEquals(doDrowRresponse.jsonPath().getString("data"),"开奖中。。。","开奖messag校验失败");
+        Thread.sleep(16000);
+
+        //校验点
+        //1、pk活动表配置的状态更新为4；2、订单表的addCredits字段为瓜分的红包值；3、先押注 的选项为胜方，胜负的额押注人数>负方的押注人数
+        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","开奖结果校验失败");
+            }
+        }
+
+        Map<String,Object> user01_order = this.orderInfo(consumerId01,newBetId);
+        Assert.assertEquals(user01_order.get("add_credits").toString(),"10","开奖后发奖值校验失败");
+        Map<String,Object> user02_order = this.orderInfo(consumerId02,newBetId);
+        Assert.assertEquals(user02_order.get("add_credits").toString(),"","开奖后发奖值校验失败");
+        logger.info("用户01获取的红包值为："+user01_order.get("add_credits").toString()+",用户02获取的红包值为："+user02_order.get("add_credits").toString());
+
+        Map<String,Object> bet1Result = jdbc.findSimpleResult("select * from bet_activity.tb_bet_result where bet_id = ? and option_id = ?\n",newBetId,optionsIds.get(0));
+        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 = ?\n",newBetId,optionsIds.get(1));
+        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());
+
+        Map<String,Object> user01_account2 = this.accountInfo(consumerId01);
+        Long use1_Acc2 = Long.valueOf(user01_account2.get("balance_amount").toString());
+        Assert.assertEquals(use1_Acc2.toString(),String.valueOf(use1_Acc1+10),"用户2入账校验失败");
+        Map<String,Object> user02_account2 = this.accountInfo(consumerId02);
+        Long use2_Acc2 = Long.valueOf(user02_account2.get("balance_amount").toString());
+        Assert.assertEquals(use2_Acc2,use2_Acc1,"用户2入账校验失败");
+
+    }
+
+
+
+    public Map<String,Object> accountInfo(String consumerId) throws Exception{
+        Map<String,Object> map = new HashMap<>();
+        String dbName1 = GetDbName.getDbName("consumer_accounts.tb_consumer_account_",consumerId,"1");
+        String sql1 = "select * from "+dbName1+" where consumer_id = ? and account_type = '6'";
+        map = jdbc.findSimpleResult(sql1,consumerId);
+        return map;
+
+    }
+
+    public Map<String,Object> orderInfo(String consumerId,String betId) throws Exception{
+        Map<String,Object> map = new HashMap<>();
+        String dbName1 = GetDbName.getDbName("activity_order_con.tb_trade_center_activity_order_",consumerId,"1");
+        String sql1 = "select * from "+dbName1+" where consumer_id = ? and duiba_activity_id = ?\n";
+        map = jdbc.findSimpleResult(sql1,consumerId,betId);
+        return map;
+
+    }
+
+    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");
+//        String betId = MatcherString.getString(betResponse.asString(),"\"data\": (\\w*)",1);
+        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);
+
+    }
+
+    @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/utils/GetDbName.java

@@ -7,6 +7,8 @@
  */
 package utils;
 
+import base.DuibaLog;
+
 /**
  * 〈〉
  *
@@ -16,6 +18,7 @@ package utils;
  */
 public class GetDbName {
 
+    private static DuibaLog looger = DuibaLog.getLogger();
 
     public static String getDbName(String prex,String consumerId,String type){
         String dbName = "";
@@ -25,6 +28,7 @@ public class GetDbName {
         }else if (type.equals("2")){
             dbName = prex + String.format("%04d", Long.parseLong(consumerId) / 10000000);
         }
+        looger.info("dbName为："+dbName);
         return dbName;
     }