add：2023年7月21日新增代码3

src/test/java/com/lemon/cases/BaseCase.java

@@ -118,6 +118,15 @@ public class BaseCase {
     }
 
 
+    public boolean assertSqlB(String expectValue, String beforeSqlResult) {
+        // 判断如果B段SQL执行首次为空，第二次非空
+        boolean flag = false;
+        if (beforeSqlResult == null && expectValue != null) {
+            flag = true;
+        }
+        return flag;
+    }
+
     /**
      * 适用于非Excel接口和用例类型的调用。
      *

src/test/java/com/lemon/cases/ServerCase.java

@@ -47,7 +47,7 @@ public class ServerCase extends BaseCase {
         System.out.println("A-sql: " + cas.getCheckSQL());
         Object afterASqlResult = SqlUtils.querySingle(cas.getCheckSQL());
         System.out.println("B-sql: " + cas.getCheckBSQL());
-        Thread.sleep(1000 * 120);  //验证B段SQL的休眠时间60秒
+        Thread.sleep(1000 * 60);  //验证B段SQL的休眠时间60秒
         Object afterBSqlResult = SqlUtils.querySingle(cas.getCheckBSQL());
         //7-1、A段数据库断言
         boolean sqlAFlag = assertSql(cas.getaExpectValue(), beforeASqlResult == null ? null : beforeASqlResult.toString(), afterASqlResult == null ? null : afterASqlResult.toString());
@@ -138,4 +138,63 @@ public class ServerCase extends BaseCase {
         Object[][] data = ExcelUtils.getAPIAndCaseByApiId("3");  // 传参apiID
         return data;
     }
+
+
+    @Test(dataProvider = "data4", description = "推送消息-第2段部分匹配判断")   // DTO数据传输
+    @Description("推送消息-第2段部分匹配判断")
+    public void testManager4(API api, Case cas) throws Exception {
+        //0、执行前休眠30秒
+        Thread.sleep(1000 * 30);
+        //1、参数化替换
+        String params = replace(cas.getParams());
+        String sql = replace(cas.getCheckSQL());
+        String Bsql = replace(cas.getCheckBSQL());
+        cas.setParams(params);
+        cas.setCheckSQL(sql);
+        cas.setCheckBSQL(Bsql);
+        //2、数据库前置查询结果（断言必须在接口执行前后都查询）
+        Object beforeASqlResult = SqlUtils.querySingle(cas.getCheckSQL());
+        Object beforeBSqlResult = SqlUtils.querySingle(cas.getCheckBSQL());
+        //3、调用接口
+        String body = call(api, cas, false);
+        // 3.1 将登录的token存储（仅限于登录接口特有）
+        AuthorizationUtils.storeToken(body);
+//        System.out.println(AuthorizationUtils.env);
+        //4、断言响应结果，Excel中预期响应数据与实际响应数据进行对比
+        boolean assertResponseFlag = assertResponse(cas, body);
+        //5、添加接口响应回写excel内容
+        addWBD(Integer.parseInt(cas.getId()), Constants.ACTURL_WRITER_BACK_CELL_NUM, body);
+        //6、数据库后置查询结果
+        System.out.println("A-sql: " + cas.getCheckSQL());
+        Object afterASqlResult = SqlUtils.querySingle(cas.getCheckSQL());
+        System.out.println("B-sql: " + cas.getCheckBSQL());
+        Thread.sleep(1000 * 60);  //验证B段SQL的休眠时间60秒
+        Object afterBSqlResult = SqlUtils.querySingle(cas.getCheckBSQL());
+        //7-1、A段数据库断言
+        boolean sqlAFlag = assertSql(cas.getaExpectValue(), beforeASqlResult == null ? null : beforeASqlResult.toString(), afterASqlResult == null ? null : afterASqlResult.toString());
+        String assertSqlAFlag = (sqlAFlag) ? "Pass" : "Fail";
+        addWBD(Integer.parseInt(cas.getId()), Constants.A_ASSERT_RESULT_CELL_NUM, assertSqlAFlag);
+        System.out.println("数据库A-sql断言结果：" + sqlAFlag);
+        //7-2、B段数据库断言
+        boolean sqlBFlag=assertSqlB(cas.getbExpectValue(),beforeBSqlResult == null ? null : beforeBSqlResult.toString());
+        String assertSqlBFlag = (sqlBFlag) ? "Pass" : "Fail";
+        addWBD(Integer.parseInt(cas.getId()), Constants.B_ASSERT_RESULT_CELL_NUM, assertSqlBFlag);
+        System.out.println("数据库B-sql断言结果：" + sqlBFlag);
+        //8、添加断言回写内容
+        String assertContent = (assertResponseFlag && sqlAFlag && sqlBFlag) ? "Pass" : "Fail";
+        addWBD(Integer.parseInt(cas.getId()), Constants.ASSERT_RESULT_CELL_NUM, assertContent);
+        //9、添加日志
+        //10、报表断言
+        Assert.assertEquals(assertContent, "Pass");
+    }
+
+    // 使用Excel文件传输接口信息和请求信息
+    @DataProvider(name = "data4")
+    public Object[][] data4() {
+        Object[][] data = ExcelUtils.getAPIAndCaseByApiId("4");  // 传参apiID
+        return data;
+    }
+
+
+
 }