考生账号批量导入批量初始化当天排班

yiming
1 parent bd498804
Showing 7 changed files with 296 additions and 13 deletions
src/main/java/com/bsth/controller/ddexam/DdexamController.java
src/main/java/com/bsth/entity/sys/SysUser.java
src/main/java/com/bsth/repository/sys/SysUserRepository.java
src/main/java/com/bsth/service/ddexam/DdexamService.java
src/main/java/com/bsth/service/ddexam/impl/DdexamServiceImpl.java
src/main/resources/static/pages/ddexam/index.html
src/main/resources/static/pages/ddexam/upload.html
@@ -2,11 +2,15 @@ package com.bsth.controller.ddexam;
 import com.bsth.entity.sys.SysUser;
 import com.bsth.service.ddexam.DdexamService;
+import com.google.common.io.Files;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+import java.io.File;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
@@ -51,7 +55,19 @@ public class DdexamController {
         return new Date();
     }
-    
-    
-    
+
+
+    @RequestMapping(value = "/uploadFile",method = RequestMethod.POST)
+    public String uploadFile(@RequestParam Map map , MultipartFile file) throws Exception{
+        System.out.println(file.getSize());
+        File newFile = new File(
+                getDataImportClasspath() + File.separator +
+                        file.getOriginalFilename());
+        Files.write(file.getBytes(), newFile);
+        String result = ddexamService.importExcel(newFile,map);
+        return "{\"result\":" + "\""+result+"\"}";
+    }
+    public String getDataImportClasspath(){
+        return this.getClass().getResource("/").getPath() + "/static/pages/ddexam";
+    }
 }
@@ -41,6 +41,9 @@ public class SysUser implements Serializable {
 	private String status;
 	private String ksstatus;
+
+	@Column(name = "parent_id")
+	private String parentID;
 	@ManyToMany(fetch = FetchType.EAGER)
 	private Set<Role> roles = new LinkedHashSet<>();
@@ -133,4 +136,12 @@ public class SysUser implements Serializable {
 	public void setKsstatus(String ksstatus) {
 		this.ksstatus = ksstatus;
 	}
+
+	public String getParentID() {
+		return parentID;
+	}
+
+	public void setParentID(String parentID) {
+		this.parentID = parentID;
+	}
 }
@@ -49,4 +49,7 @@ public interface SysUserRepository extends BaseRepository&lt;SysUser, Integer&gt;{
 	@Query("SELECT u FROM SysUser u where u.status is null")
 	List<SysUser> findBySusUserAll();
+
+	@Query("SELECT u FROM SysUser u where u.parentID = ?1")
+	List<SysUser> findByParentID(String parentID );
 }
@@ -2,7 +2,7 @@ package com.bsth.service.ddexam;
 import com.bsth.entity.sys.SysUser;
-import java.io.IOException;
+import java.io.File;
 import java.util.List;
 import java.util.Map;
@@ -18,5 +18,7 @@ public interface DdexamService {
     public int initDate(String date);
     public List<SysUser> userAll();
+
+    String importExcel(File file, Map map);
 }
 package com.bsth.service.ddexam.impl;
-import com.alibaba.dubbo.common.URL;
 import com.bsth.data.BasicData;
 import com.bsth.data.LineConfigData;
 import com.bsth.data.schedule.DayOfSchedule;
@@ -21,9 +20,13 @@ import com.bsth.repository.realcontrol.ScheduleRealInfoStRepository;
 import com.bsth.repository.sys.BsthCSysUserRolesRepository;
 import com.bsth.repository.sys.RealControAuthorityRepository;
 import com.bsth.repository.sys.SysUserRepository;
+import com.bsth.security.util.SecurityUtils;
 import com.bsth.service.ddexam.DdexamService;
 import com.bsth.util.ConfigUtil;
-import org.junit.Test;
+import org.apache.poi.xssf.usermodel.XSSFCell;
+import org.apache.poi.xssf.usermodel.XSSFRow;
+import org.apache.poi.xssf.usermodel.XSSFSheet;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
@@ -32,7 +35,10 @@ import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import java.io.File;
+import java.io.FileInputStream;
 import java.io.IOException;
+import java.io.InputStream;
 import java.net.URLConnection;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -226,15 +232,22 @@ public class DdexamServiceImpl implements DdexamService {
     public Map initializationAll2(Long userName){
         Long start = System.currentTimeMillis();
         Map m = new HashMap<>();
-        String t = String.valueOf(userName).substring(0,7);
+
         try {  //用户当天分配完直接改状态  无二次分配的可能
-            List<SysUser> userList = sysUserRepository.findBySusUser(t); //已有的用户   不考虑用户角色表  正常情况下创建必分配
+            List<SysUser> userList=new ArrayList<>();
+            if(userName!=null){
+                userList= sysUserRepository.findBySusUser(String.valueOf(userName));
+            }else {
+                SysUser loginUser = SecurityUtils.getCurrentUser();
+                userList= sysUserRepository.findByParentID(String.valueOf(loginUser.getId()));
+            }
             if (userList.size() > 0) {
                 //已有的人检查分配线路
+                List<SysUser> finalUserList = userList;
                 new Thread() {
                     public synchronized void run() {
-                        if (snt(userList)) {
+                        if (snt(finalUserList)) {
                             kk();
                         }
                     }
@@ -444,7 +457,153 @@ public class DdexamServiceImpl implements DdexamService {
         ScheduleRealInfoRepository.saveAll(sriList);
     }
+    public String importExcel(File file, Map map) {
+        List<String> textList = new ArrayList<>();
+        List<SysUser> userList = new ArrayList<>();
+
+        try{
+            InputStream fs = new FileInputStream(file);
+            XSSFWorkbook wb = new XSSFWorkbook(fs);
+            XSSFSheet sheet = wb.getSheetAt(0);
+            // 取得总行数
+            int rowNum = sheet.getLastRowNum() + 1;
+            // 取得总列数
+            int cellNum = sheet.getRow(0).getLastCellNum();
+            XSSFRow row = null;
+            XSSFCell cell = null;
+            for(int i = 1; i < rowNum; i++){
+                row = sheet.getRow(i);
+                if (row == null){
+                    continue;
+                }
+                String text = "";
+                for(int j = 0; j < cellNum; j++){
+                    row.getCell(j).setCellType(1);
+                    cell = row.getCell(j);
+                    if(cell == null){
+                        text += ",";
+                        continue;
+                    }
+                    text += String.valueOf(cell) + ",";
+                }
+                String[] split = (text+";").split(",");
+                String str = "";
+                for(int j = 0; j < split.length && j < 5; j++){
+                    str += split[j];
+                }
+                if(str.trim().length() == 0)
+                    continue;
+                textList.add(text + ";");
+            }
+            SysUser loginUser = SecurityUtils.getCurrentUser();
+            for(int i = 0; i < textList.size(); i++) {
+                String text = textList.get(i);
+                String[] split = text.split(",");
+                SysUser user = new SysUser();
+                user.setCreateDate(new Date());
+                user.setEnabled(true);
+                user.setName(split[1].trim());
+                user.setPassword(new BCryptPasswordEncoder(4).encode("123456"));
+                user.setUserName(split[0].trim());
+                user.setKsstatus("1"); //状态  表示今日账户已用
+                user.setLastLoginDate(new Date());
+                user.setParentID(String.valueOf(loginUser.getId()));
+                userList.add(user);
+            }
+            List<SysUser> users = sysUserRepository.findBySusUserAll();
+            Iterator<SysUser> it=userList.iterator();
+            while (it.hasNext()){
+                SysUser u=it.next();
+                for (SysUser user : users) {
+                    if(u.getUserName().equals(user.getUserName())){
+                        it.remove();
+                        continue;
+                    }
+                }
+            }
+            boolean flag = true;
+            for (SysUser user : userList) {
+                if(!createUser(user)){
+                    flag=false;
+                }
+            }
+            if(!flag){
+                return "文件导入失败";
+            }
+        }catch (Exception e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+            return "文件导入失败";
+        } finally {
+            file.delete();
+        }
+
+        return "导入文件成功";
+
+    }
+
-  
+    public synchronized Boolean  createUser(SysUser user){
+        sysUserRepository.save(user); //用户存库
+        BsthCSysUserRoles userRoles = new BsthCSysUserRoles();
+        userRoles.setUsers(user.getId());
+        userRoles.setRoles(73); //统一用73考生
+        bsthCSysUserRolesRepository.save(userRoles); //权限存库
+        List<LineConfigSt> lineConfigList = lineConfigStRepository.findAll(); //线调 线路相关配置信息
+        Integer linebumber = lineRepository.findAll().size(); //线路数量 线路code
+        String [] mtline = {"A线","B线","C线","D线","E线","F线"}; //对应模板6条线 换成线路name
+        List<LineInformationSt> litst = (List<LineInformationSt>) LineInformationStRepository.findAll(); //所有模板线路标准和线路
+        if(litst.size() != 6){
+            return false;
+        }
+        String lineCodeStr = "";
+        for(int j = 0 ; j < litst.size() ; j++){  //6个  <6
+            LineSt linest = litst.get(j).getLine(); //旧line
+            LineInformationSt Limst = litst.get(j);
+            Line line = new Line();
+            BeanUtils.copyProperties(linest,line); //copy
+            Integer linecodeId = linebumber++ ;
+            line.setId(linecodeId);
+            line.setLineCode(linecodeId.toString());
+            line.setName(mtline[j]+"-"+user.getUserName());
+            line.setCoLineCode(linest.getLineCode());
+            lineRepository.save(line);  //线路添加
+            //----------------线路--------------------------//
+            LineInformation lifat = new LineInformation();  //线路标准
+            BeanUtils.copyProperties(Limst,lifat);
+            lifat.setLine(line);
+            lineInformationRepository.save(lifat); //线路标准信息条件
+            //-------------------线路标准-----------------------//
+            for(LineConfigSt cfgt : lineConfigList){
+                if(cfgt.getLine().getLineCode().equals(linest.getLineCode())){
+                    LineConfig config = new LineConfig();
+                    BeanUtils.copyProperties(cfgt,config); //copy
+                    config.setLine(line);
+                    lineConfigRepository.save(config);
+                }
+            }
+            //-------------------线调 线路相关配置信息-----------------------//
+            List<StationRouteSt> srstList = stationRouteStRepository.findByLine(linest.getLineCode());
+            List<StationRoute> srstListAll = new ArrayList<>();
+            for(StationRouteSt route : srstList){
+                StationRoute srt = new StationRoute();
+                BeanUtils.copyProperties(route,srt); //copy
+                srt.setLine(line);
+                srt.setLineCode(linecodeId.toString());
+                srstListAll.add(srt);
+            }
+            stationRouteRepository.saveAll(srstListAll);//添加站点
+            //-------------------站点-----------------------//
+            lineCodeStr += linecodeId.toString()+",";  //线调线路
+            inforealType(line);
+        }
+        RealControAuthority raty = new RealControAuthority();
+        raty.setUserId(user.getId());
+        raty.setLineCodeStr(lineCodeStr);
+        raty.setPattern(1); //可用
+        realControAuthorityRepository.save(raty);
+        //-------------------分配本次线调权限-----------------------//
+        return true;
+    }
 }
@@ -47,13 +47,13 @@
       overflow-y:hidden;
   }
 </style>
-
+<script src="/assets/js/ajaxfileupload/ajaxfileupload.js"></script>
+<link rel="stylesheet" href="/assets/js/ajaxfileupload/ajaxfileupload.css" />
 <div class="row">
     <div class="col-md-12 st ">
         <div class="portlet light porttlet-fit bordered at img1">
             <div class="tes">
-
-                <label class="col-md-12 sizell">请输入账号格式：</label>
+                <label class="col-md-12 sizell">请输入学号：</label>
                 <div class="col-md-9 scm">
                     <input id="userName" type="text" class="form-control" name="rnumber" autocomplete="off"  oninput="value=value.replace(/[^\d]/g,'')"/>
@@ -68,6 +68,9 @@
                 <div class="col-md-12 nt" >
                     <button type="button" class="btn btn-primary textk" id="onckil">创建账号</button>
+                    <button type="button" class="btn btn-primary textk" id="upload"><i class="fa fa-file-excel-o"></i>
+                        批量创建
+                    </button>
                     <button type="button" class="btn btn-primary textk" id="onckil2">初始化当天排班</button>
                 </div>
                 <div class="col-md-12 nt" >
@@ -212,6 +215,10 @@
         })
     }
+    //导入
+    $("#upload").on("click", function(){
+        $.get('upload.html', function(m){$(pjaxContainer).append(m);});
+    });
 </script>
 \ No newline at end of file
+<div class="modal fade" id="uploadFile" tabindex="-1" role="basic"
+	aria-hidden="true">
+	<div class="modal-dialog">
+		<div class="modal-content">
+			<div class="modal-header">
+				<button type="button" class="close" data-dismiss="modal"
+					aria-hidden="true"></button>
+				<h4 class="modal-title">导入Excel</h4>
+			</div>
+			<div class="modal-body">
+				<form class="form-horizontal" role="form" id="excelFile" method="post"
+						action="" enctype="multipart/form-data">
+					<input type="hidden" name="groupType" value="3">
+					<div class="alert alert-danger display-hide">
+						<button class="close" data-close="alert"></button>
+						您的输入有误，请检查下面的输入项
+					</div>
+					<div class="form-body">
+						<div class="form-group">
+							<label class="col-md-4 control-label">选择文件</label>
+							<div class="col-md-6">
+								<input type="file" name="file" id="file"
+									accept="application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"/>
+								
+							</div>
+						</div>
+					</div>
+				</form>
+			</div>
+			<div class="modal-footer">
+				<button type="button" class="btn default" data-dismiss="modal">取消</button>
+				<button type="button" class="btn btn-primary" id="submit">确认导入</button>
+			</div>
+		</div>
+	</div>
+</div>
+
+</script>
+<script data-exclude=1>
+	$(function() {
+		var form = $('#excelFile');
+		var error = $('.alert-danger', form);
+
+
+		var curDate = new Date();
+		var preDate = new Date(curDate.getTime() - 24*60*60*1000);
+		$("#date").val(preDate);
+		$("#date").datetimepicker({
+			format : 'YYYY-MM-DD',
+			locale : 'zh-cn',
+			maxDate : preDate
+		});
+		
+		//modal 显示事件
+		$('#uploadFile').on('show.bs.modal', function(){
+		})
+		.modal('show');
+		
+		$('#submit').on('click', function() {
+		
+            var j = layer.load(2);
+			var param = {
+			};
+			$.ajaxFileUpload({
+				url : '/ddexam/uploadFile',
+				secureuri : false,
+				fileElementId : 'file',
+				dataType : 'json',
+				data : param,
+				success : function(data) {
+	                layer.close(j);
+					alert(data.result);
+// 					alert("文件导入成功");
+					$('#uploadFile').modal('hide');
+					$('tr.filter .filter-submit').click();
+				},
+				error : function(data, status, e) {
+	                layer.close(j);
+					alert("文件导入失败");
+				}
+			})
+		});
+		
+	});
+</script>
 \ No newline at end of file