生成排班改多线程

yiming
1 parent 9058e6ea
Showing 2 changed files with 14 additions and 11 deletions
src/main/java/com/bsth/service/ddexam/impl/DdexamServiceImpl.java
src/main/java/com/bsth/service/subject/impl/SubjectUserServiceImpl.java
@@ -246,7 +246,9 @@ public class DdexamServiceImpl implements DdexamService {
             if (userList.size() > 0) {
                 //已有的人检查分配线路
                 List<SysUser> finalUserList = userList;
-                snt(finalUserList,false);
+                if (snt(finalUserList,false)) {
+                    kk();
+                }
             }
         }catch (Exception e){
             log.error("-----考试初始化失败------",e);
@@ -330,18 +332,13 @@ public class DdexamServiceImpl implements DdexamService {
     }
     //已创建好的用户分配排班
  
-    public Boolean snt(List<SysUser> userList,boolean type) throws Exception{
+    public Boolean snt(List<SysUser> userList,boolean type){
         for (int i = 0 ; i < userList.size() ; i++ ){   //已rs人数为准
             SysUser user = userList.get(i);
             if (realControAuthorityRepository.findByUserId(user.getId()) != null) {
-                new Thread() {
-                    public synchronized void run() {
-                        useryType(user,type);
-                        System.out.println("分配班次...");
-                        sysUserRepository.changeKsStatus(user.getId()); ////状态  表示今日账户已用
-                        kk();
-                    }
-                }.start();
+                useryType(user,type);
+                System.out.println("分配班次...");
+                sysUserRepository.changeKsStatus(user.getId()); ////状态  表示今日账户已用
             }
         }
         return true;
@@ -254,6 +254,12 @@ public class SubjectUserServiceImpl extends BaseServiceImpl&lt;SubjectUser, Integer
             }
         }
         //初始化考生排班 只初始化A线
-        ddexamService.snt(userList,true);
+        new Thread() {
+            public synchronized void run() {
+                if (ddexamService.snt(userList,true)) {
+                    ddexamService.kk();
+                }
+            }
+        }.start();
     }
 }