/**
* 模拟数据上报，这里的初始化数据根据插件端传入数据组合来的，当前只有根据报表期生成初始化数据
*
* @author xiaoli
*
*/
public class CreateMultiTaskReportTest3 extends TestCase {
private UserManager userManager;
private UserService userService;
@Override
protected void setUp() throws Exception {
super.setUp();
String[] paths = { "classpath:applicationContext.xml" };
ApplicationContext ctx = new ClassPathXmlApplicationContext(paths);
SpringContextListener.setApplicationContext(ctx);
// ############模拟servlet容器启动，手动更改配置文件路径
Constant.CURRENT_PROJECT_PATH = "src/";
// ############直接容器中获取bean
userManager = (UserManager) ctx.getBean("userManager");
userService = (UserService) ctx.getBean("userService");
}
@Override
protected void tearDown() throws Exception {
super.tearDown();
}
@Test
public void test(){
// ###########自动生成报表期串集合
List<String> bbqs = new ArrayList<String>();
UnitTestUtils.imitateCreateMultiBbq(bbqs， 2， "2048"， "5");
// 创建线程
TestRunnable[] tr = new TestRunnable[bbqs.size()];
int processCount = 0;
// ##########对这些数据进行填报
for (String bbq : bbqs) {
// 模拟上报数据
String reportMap = "{taskID:"402880ee425a92f501425aa75ad50002"，bbq_:""
+ bbq
+ """
+ "，bbhid:"402855b942099b1b014209b1177e03f5"，approvalFlag:2，reportFlag:False，auditFlag:False，sheetMap:"
+ "[{id:"402880ee425a92f501425aa75ad60004"，sheetType:"BASIC"，values:{}}]}";
// 模拟上报的user
UserVO user = null;
try {
user = checkUser("xl1"， "1");
} catch (BaseAppException e) {
e.printStackTrace();
} // 模拟插件端checkUser
String sessionInfo = "{institutionname:"南昌分行"，institutioncode:"A01NC"，username:"肖力1"
+ "1"，usercode:"xl1"，rolecode:"null"，bbhId:"402855b942099b1b014209b1177e03f5"，bbhcode:"B01b"，btype:"BASIC"，taskid:"402880ee425a92f501425a"
+ "a75ad50002"，bbhname:"基层财务b"，bbq:"" + bbq
+ ""，frequency:"MONTH"，SESSIONDIMENSION:{}}";
try {
userService.updateSession(sessionInfo， user);
} catch (BaseAppException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} // 模拟插件端updateSession
// 初始化上报方式
InvokeSource invokeSource = InvokeSource.WSCALL;
CreateMulltiTaskReportGroboThread reportThread = new CreateMulltiTaskReportGroboThread(reportMap，user， invokeSource，bbq);
tr[processCount] = reportThread;
processCount++;
}
System.out.println("#######################################计时开始########################");
long startTime = System.currentTimeMillis();
// 生成测试线程运行器
MultiThreadedTestRunner mttr = new MultiThreadedTestRunner(tr);
// 运行测试线程
try {
mttr.runTestRunnables();
} catch (Throwable e) {
e.printStackTrace();
}
System.out.println("#######################一共耗时："
+ String.valueOf((System.currentTimeMillis() - startTime) / 1000) + "秒");
}
/**
* xl1 1
* */
public UserVO checkUser(String userid，
String password) throws BaseAppException {
Map<String， String> paramMap = new HashMap<String， String>();
paramMap.put("UserName"， userid);
paramMap.put("Password"， password);
List<User> users = userManager.findByCodeCache(userid);
List<User> needUsers = new ArrayList<User>();
if (users != null && users.size() > 0) {
for (User user : users) {
if (user.getState() && user.getCode().equals(userid)
&& user.getPassword().equals(Encryption.encryption(password))) {
needUsers.add(user);
}
}
}
// 通过验证
if (needUsers != null && needUsers.size() > 0) {
User user = needUsers.get(0);
// 获取用户权限，并存放于session中
// UserVO userVO = userManager.getUserPermission(user.getId());
String ipAddress = "0.0.0.0";
UserVO userVO = new UserVO();
BeanUtil2.copyProperties(user， userVO);
userVO.setIpAddress(ipAddress);
return userVO; // 通过验证
} else {
return null;
}
}
}
　　真实环境并发和压力测试不仅仅是在多个线程同时启动在测，还可能是增量式压力测试。这些还是要封装好和处理好。