|
|
@@ -1,17 +1,25 @@
|
|
|
package cn.com.qmth.examcloud.core.basic.service.impl;
|
|
|
|
|
|
+import java.io.File;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.Collections;
|
|
|
+import java.util.List;
|
|
|
import java.util.Map;
|
|
|
import java.util.Map.Entry;
|
|
|
|
|
|
+import org.apache.commons.collections.CollectionUtils;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
+import com.google.common.collect.Lists;
|
|
|
import com.google.common.collect.Maps;
|
|
|
|
|
|
import cn.com.qmth.examcloud.commons.base.exception.StatusException;
|
|
|
import cn.com.qmth.examcloud.commons.base.helpers.DynamicEnum;
|
|
|
import cn.com.qmth.examcloud.commons.base.helpers.DynamicEnumManager;
|
|
|
+import cn.com.qmth.examcloud.commons.base.helpers.poi.ExcelReader;
|
|
|
+import cn.com.qmth.examcloud.commons.base.util.PathUtil;
|
|
|
import cn.com.qmth.examcloud.core.basic.dao.ExamSiteRepo;
|
|
|
import cn.com.qmth.examcloud.core.basic.dao.OrgPropertyRepo;
|
|
|
import cn.com.qmth.examcloud.core.basic.dao.OrgRepo;
|
|
|
@@ -49,6 +57,8 @@ public class OrgServiceImpl implements OrgService {
|
|
|
@Autowired
|
|
|
StudentRepo studentRepo;
|
|
|
|
|
|
+ private static final String[] EXCEL_HEADER = new String[]{"专业名称", "专业代码"};
|
|
|
+
|
|
|
/*
|
|
|
* 保存顶级机构
|
|
|
*
|
|
|
@@ -273,4 +283,121 @@ public class OrgServiceImpl implements OrgService {
|
|
|
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public List<Map<String, Object>> importSubOrg(Long rootOrgId, File file) {
|
|
|
+
|
|
|
+ List<String[]> lineList = null;
|
|
|
+ try {
|
|
|
+ lineList = ExcelReader.readSheetBySax(PathUtil.getCanonicalPath(file), 1, 3);
|
|
|
+ } catch (Exception e) {
|
|
|
+ throw new StatusException("B-100110", "Excel 解析失败");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (CollectionUtils.isEmpty(lineList)) {
|
|
|
+ throw new StatusException("B-100111", "Excel无内容");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (10001 < lineList.size()) {
|
|
|
+ throw new StatusException("B-100112", "数据行数不能超过10000");
|
|
|
+ }
|
|
|
+
|
|
|
+ List<Map<String, Object>> failRecords = Collections
|
|
|
+ .synchronizedList(new ArrayList<Map<String, Object>>());
|
|
|
+
|
|
|
+ List<OrgEntity> courseList = Lists.newArrayList();
|
|
|
+
|
|
|
+ for (int i = 0; i < lineList.size(); i++) {
|
|
|
+ String[] line = lineList.get(i);
|
|
|
+ if (0 == i) {
|
|
|
+ if (headerError(line)) {
|
|
|
+ throw new StatusException("B-100111", "Excel表头错误");
|
|
|
+ }
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ boolean hasError = false;
|
|
|
+ StringBuilder msg = new StringBuilder();
|
|
|
+
|
|
|
+ OrgEntity org = new OrgEntity();
|
|
|
+ org.setParentId(rootOrgId);
|
|
|
+ org.setEnable(true);
|
|
|
+
|
|
|
+ String name = trimAndNullIfBlank(line[0]);
|
|
|
+ if (StringUtils.isBlank(name)) {
|
|
|
+ msg.append(" 课程名称不能为空");
|
|
|
+ hasError = true;
|
|
|
+ } else if (name.length() > 30) {
|
|
|
+ msg.append(" 课程名称不能超过30个字符");
|
|
|
+ hasError = true;
|
|
|
+ }
|
|
|
+ org.setName(name);
|
|
|
+
|
|
|
+ String code = trimAndNullIfBlank(line[1]);
|
|
|
+ if (StringUtils.isBlank(code)) {
|
|
|
+ msg.append(" 课程代码不能为空");
|
|
|
+ hasError = true;
|
|
|
+ } else if (code.length() > 30) {
|
|
|
+ msg.append(" 课程代码不能超过30个字符");
|
|
|
+ hasError = true;
|
|
|
+ }
|
|
|
+
|
|
|
+ org.setCode(code);
|
|
|
+
|
|
|
+ if (hasError) {
|
|
|
+ failRecords.add(newError(i + 1, msg.toString()));
|
|
|
+ } else {
|
|
|
+ courseList.add(org);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ if (CollectionUtils.isNotEmpty(failRecords)) {
|
|
|
+ return failRecords;
|
|
|
+ }
|
|
|
+
|
|
|
+ for (OrgEntity cur : courseList) {
|
|
|
+ OrgInfo info = new OrgInfo();
|
|
|
+ info.setCode(cur.getCode());
|
|
|
+ info.setParentId(cur.getParentId());
|
|
|
+ info.setRootId(cur.getRootId());
|
|
|
+
|
|
|
+ info.setName(cur.getName());
|
|
|
+ info.setContacts(cur.getContacts());
|
|
|
+ info.setTelephone(cur.getTelephone());
|
|
|
+ info.setRemark(cur.getRemark());
|
|
|
+ saveSubOrg(info);
|
|
|
+ }
|
|
|
+
|
|
|
+ return failRecords;
|
|
|
+ }
|
|
|
+
|
|
|
+ private Map<String, Object> newError(int lineNum, String msg) {
|
|
|
+ Map<String, Object> map = Maps.newHashMap();
|
|
|
+ map.put("lineNum", lineNum);
|
|
|
+ map.put("msg", msg);
|
|
|
+ return map;
|
|
|
+ }
|
|
|
+
|
|
|
+ private String trimAndNullIfBlank(String s) {
|
|
|
+ if (StringUtils.isBlank(s)) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ return s.trim();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 方法注释
|
|
|
+ *
|
|
|
+ * @author WANGWEI
|
|
|
+ * @param header
|
|
|
+ */
|
|
|
+ private boolean headerError(String[] header) {
|
|
|
+ for (int i = 0; i < EXCEL_HEADER.length; i++) {
|
|
|
+ if (!EXCEL_HEADER[i].equals(header[i].trim())) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
}
|
wangwei