/** * 模擬數據上報，這里的初始化數據根據插件端傳入數據組合來的，當前只有根據報表期生成初始化數據 * * @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; } } } |