考试排班初始化

yiming
1 parent 93a5e244
Showing 8 changed files with 71 additions and 11 deletions
src/main/java/com/bsth/repository/LineInformationRepository.java
src/main/java/com/bsth/repository/LineRepository.java
src/main/java/com/bsth/repository/StationRouteRepository.java
src/main/java/com/bsth/repository/realcontrol/LineConfigRepository.java
src/main/java/com/bsth/repository/realcontrol/ScheduleRealInfoRepository.java
src/main/java/com/bsth/repository/sys/RealControAuthorityRepository.java
src/main/java/com/bsth/service/ddexam/impl/DdexamServiceImpl.java
src/main/java/com/bsth/service/subject/impl/SubjectUserServiceImpl.java
@@ -2,6 +2,7 @@ package com.bsth.repository;
 import java.util.List;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
@@ -31,4 +32,8 @@ public interface LineInformationRepository extends BaseRepository&lt;LineInformatio
 	List<LineInformation> findByLine(List<String> lineCodes);
 	List<LineInformation> findByLine(Line line);
+
+	@Modifying
+	@Query(value = "delete from bsth_c_line_information  where line in ( ?1 )", nativeQuery = true)
+	void deleteLineInformationBylineCodes(List<String> lineCodes);
 }
@@ -101,4 +101,8 @@ public interface LineRepository extends BaseRepository&lt;Line, Integer&gt; {
 	@Query(value = "UPDATE bsth_c_line_file_version set version_count=?2 WHERE line = ?1", nativeQuery = true)
 	public void editFileVersions(Integer lineId, Integer version_count);
+
+	@Modifying
+	@Query(value = "delete from Line l where l.lineCode in ( ?1 )")
+	void deleteLineBylineCodes(List<String> lineCodes);
 }
@@ -508,4 +508,8 @@ public interface StationRouteRepository extends BaseRepository&lt;StationRoute, Int
 	@Modifying
 	@Query(value="update bsth_c_stationroute set industry_code =?2 where id = ?1 ", nativeQuery=true)
 	void updIndustryCode(Integer id,String IndustryCode);
+
+	@Modifying
+	@Query(value = "delete from StationRoute sr where sr.lineCode in ( ?1 )")
+	void deleteStationRouteBylineCodes(List<String> lineCodes);
 }
@@ -6,6 +6,8 @@ import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.domain.Specification;
 import org.springframework.data.jpa.repository.EntityGraph;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
 import com.bsth.entity.realcontrol.LineConfig;
@@ -26,4 +28,8 @@ public interface LineConfigRepository extends BaseRepository&lt;LineConfig, Integer
     @Override
     List<LineConfig> findAll();
+    @Modifying
+    @Query(value = "delete from bsth_c_line_config where line in ( ?1 )", nativeQuery = true)
+    void deleteLineConfigBylineCodes(List<String> lineCodes);
+
 }
@@ -240,5 +240,7 @@ public interface ScheduleRealInfoRepository extends BaseRepository&lt;ScheduleRealI
 	@Query(value="select count(*) from ScheduleRealInfo s where s.scheduleDateStr = ?1 and s.xlBm  = ?2")
 	int selectCountAll(String scheduleDateStr,String lineCode);
-
+	@Modifying
+	@Query(value = "delete from ScheduleRealInfo sr where sr.xlBm in ( ?1 )")
+	void deleteScheduleRealInfoBylineCodes(List<String> lineCodes);
 }
@@ -2,9 +2,12 @@ package com.bsth.repository.sys;
 import com.bsth.entity.sys.RealControAuthority;
 import com.bsth.repository.BaseRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
+import java.util.List;
+
 /**
  * Created by panzhao on 2017/2/14.
  */
@@ -13,4 +16,8 @@ public interface RealControAuthorityRepository extends BaseRepository&lt;RealContro
     @Query("select t from RealControAuthority t where t.userId=?1")
     RealControAuthority findByUserId(Integer userId);
+
+    @Modifying
+    @Query(value = "delete from RealControAuthority rca where rca.userId = ?1 ")
+    void deleteRealControAuthorityBylineCodes(int userId);
 }
@@ -80,8 +80,8 @@ public class DdexamServiceImpl implements DdexamService {
     LineConfigStRepository lineConfigStRepository;
     @Autowired
     LineConfigData lineConfigData;
-    
-    
+    @Autowired
+    ScheduleRealInfoRepository scheduleRealInfoRepository;
     @Autowired
     LineConfigRepository lineConfigRepository;
@@ -248,7 +248,7 @@ public class DdexamServiceImpl implements DdexamService {
                 List<SysUser> finalUserList = userList;
                 new Thread() {
                     public synchronized void run() {
-                        if (snt(finalUserList)) {
+                        if (snt(finalUserList,false)) {
                             kk();
                         }
                     }
@@ -336,11 +336,11 @@ public class DdexamServiceImpl implements DdexamService {
     }
     //已创建好的用户分配排班
-    public Boolean snt(List<SysUser> userList){
+    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) {
-                useryType(user);
+                useryType(user,type);
                 System.out.println("分配班次...");
                 sysUserRepository.changeKsStatus(user.getId()); ////状态  表示今日账户已用
             }
@@ -348,13 +348,20 @@ public class DdexamServiceImpl implements DdexamService {
         return true;
     }
-    
-    public Boolean useryType(SysUser user){
+    //type true:考试 false:练习 考试只初始化A线路排班
+    public Boolean useryType(SysUser user,boolean type){
         RealControAuthority hoit = realControAuthorityRepository.findByUserId(user.getId());
         String[] st = hoit.getLineCodeStr().split(",");
-        for (int k = 0 ; k < st.length ; k++){
-           Line l = lineRepository.findById(Integer.parseInt(st[k])).get();
-            inforealType(l);
+        if(!type){
+            for (int k = 0 ; k < st.length ; k++){
+                Line l = lineRepository.findById(Integer.parseInt(st[k])).get();
+                inforealType(l);
+            }
+        }else {
+            if(st.length>0){
+                Line l = lineRepository.findById(Integer.parseInt(st[0])).get();
+                inforealType(l);
+            }
         }
         return true;
     }
@@ -522,4 +529,13 @@ public class DdexamServiceImpl implements DdexamService {
         //-------------------分配本次线调权限-----------------------//
         return true;
     }
+
+    public synchronized void  clearScheduleRealInfo(SysUser user){
+        RealControAuthority hoit = realControAuthorityRepository.findByUserId(user.getId());
+        String[] st = hoit.getLineCodeStr().split(",");
+        List<String> lines=Arrays.asList(st);
+        //bsth_c_s_sp_info_real
+        scheduleRealInfoRepository.deleteScheduleRealInfoBylineCodes(lines);
+    }
+
 }
@@ -10,6 +10,7 @@ import com.bsth.repository.LineRepository;
 import com.bsth.repository.subject.SubjectUserRepository;
 import com.bsth.repository.sys.SysUserRepository;
 import com.bsth.security.util.SecurityUtils;
+import com.bsth.service.ddexam.impl.DdexamServiceImpl;
 import com.bsth.service.impl.BaseServiceImpl;
 import com.bsth.service.subject.SubjectUserService;
 import com.bsth.util.subject.subEnum;
@@ -39,6 +40,10 @@ public class SubjectUserServiceImpl extends BaseServiceImpl&lt;SubjectUser, Integer
     @Autowired
     SysUserRepository sysUserRepository;
+    @Autowired
+    DdexamServiceImpl ddexamService;
+
+
     public List<SubjectUser> userAll(){
         SysUser user = SecurityUtils.getCurrentUser();
         Integer userId = user.getId();
@@ -213,8 +218,11 @@ public class SubjectUserServiceImpl extends BaseServiceImpl&lt;SubjectUser, Integer
         for (SysUser user : userList) {
             userIds.add(user.getId());
         }
+        //清除考生考题
         subjectUserRepository.deleteSubjectUserByUserIds(rq,userIds);
         for (SysUser user : userList) {
+            //清除考生排班
+            ddexamService.clearScheduleRealInfo(user);
             for (String s : arr) {
                 SubjectUser subjectUser=new SubjectUser();
                 subjectUser.setUserId(user.getId());
@@ -226,5 +234,13 @@ public class SubjectUserServiceImpl extends BaseServiceImpl&lt;SubjectUser, Integer
                 subjectUserRepository.save(subjectUser);
             }
         }
+        //初始化考生排班 只初始化A线
+        new Thread() {
+            public synchronized void run() {
+                if (ddexamService.snt(userList,true)) {
+                    ddexamService.kk();
+                }
+            }
+        }.start();
     }
 }