package com.qxueyou.scc.exercise.service.impl;
|
|
import java.io.BufferedReader;
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.FileNotFoundException;
|
import java.io.FileReader;
|
import java.io.FileWriter;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.math.BigInteger;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.beanutils.BeanUtils;
|
import org.apache.commons.io.FileUtils;
|
import org.apache.commons.io.IOUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.apache.poi.POIXMLDocument;
|
import org.apache.poi.POIXMLTextExtractor;
|
import org.apache.poi.hwpf.extractor.WordExtractor;
|
import org.apache.poi.openxml4j.opc.OPCPackage;
|
import org.apache.poi.xwpf.extractor.XWPFWordExtractor;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
import org.springframework.stereotype.Service;
|
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.IFileUploadService;
|
import com.qxueyou.scc.base.service.impl.CommonAppService;
|
import com.qxueyou.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
import com.qxueyou.scc.base.util.UUIDUtils;
|
import com.qxueyou.scc.config.SccConfig;
|
import com.qxueyou.scc.exercise.model.ExerciseGroupItemRe;
|
import com.qxueyou.scc.exercise.model.ExerciseItem;
|
import com.qxueyou.scc.exercise.model.ExerciseItemAnalisi;
|
import com.qxueyou.scc.exercise.model.ExerciseItemData;
|
import com.qxueyou.scc.exercise.model.ExerciseItemOption;
|
import com.qxueyou.scc.exercise.model.ExerciseOptionData;
|
import com.qxueyou.scc.exercise.service.IExercisePyService;
|
|
@Service
|
@EnableConfigurationProperties(SccConfig.class)
|
public class ExercisePyService extends CommonAppService implements
|
IExercisePyService {
|
|
@Autowired
|
SccConfig sccConfig;
|
|
@Autowired
|
IFileUploadService fileUploadService;
|
|
private static Logger log = LogManager.getLogger("ExercisePyService");
|
|
/**
|
* 上传解析
|
*/
|
public Map<String, Object> parserPyExercise(String groupId, String fullPath,
|
String module) {
|
|
File file = downloadFile(groupId, fullPath, module);
|
List<String> lst = generateLstFromFile(file, fullPath);
|
|
if (null == lst || lst.isEmpty()) {
|
return CollectionUtils.newObjectMap("resultCode",0,"msg","文档解析内容为空");
|
}
|
|
return exerciseParsePy(lst, fullPath);
|
|
}
|
|
/**
|
* 校验
|
*
|
* @param content
|
* 习题文本内容
|
* @return
|
*/
|
public Map<String, Object> validatePyExercise(String content) {
|
|
String[] arrLine = content.split("\n");
|
List<String> lst = new ArrayList<String>(arrLine.length);
|
|
for(int i =0;i<arrLine.length;i++ ){
|
if(StringUtils.isBlank(arrLine[i])){
|
continue ;
|
}
|
lst.add(arrLine[i]);
|
}
|
|
// 判断：是否为空
|
if (null == lst || lst.isEmpty()) {
|
return CollectionUtils.newObjectMap("resultCode",0,"msg","文档解析内容为空");
|
}
|
|
return exerciseParsePy(lst, "" );
|
|
}
|
|
public Result doImportPyExercise(List<ExerciseItemData> lstItems,String groupId) {
|
|
if(null == lstItems || lstItems.isEmpty()){
|
return new Result(false, "没有记录");
|
}
|
|
ExerciseGroupItemRe re ;
|
ExerciseItemAnalisi analysis;
|
ExerciseItemOption option ;
|
ExerciseItem item ;
|
|
int itemOrder = 0;
|
String hql = "from ExerciseGroupItemRe r where r.exerciseGroupId = ? order by r.itemOrder desc ";
|
ExerciseGroupItemRe groupRe = this.findUnique(hql, CollectionUtils.newList(groupId), ExerciseGroupItemRe.class);
|
if( null != groupRe ){
|
itemOrder = groupRe.getItemOrder() ;
|
}
|
|
|
|
BigInteger iCount = BigInteger.ZERO ;
|
try {
|
|
for(ExerciseItemData data : lstItems){
|
|
item = new ExerciseItem();
|
re = new ExerciseGroupItemRe();
|
|
BeanUtils.copyProperties(item, data);
|
item.setDeleteFlag(false);
|
TraceUtils.setCreateTrace(item);
|
this.save(item);
|
|
iCount = iCount.add(BigInteger.ONE);
|
|
BeanUtils.copyProperties(re, data);
|
itemOrder++;
|
re.setDeleteFlag(false);
|
re.setExerciseGroupId(groupId);
|
re.setExerciseItemId(item.getExerciseId());
|
re.setItemOrder(itemOrder);
|
re.setDeleteFlag(false);
|
this.save(re);
|
|
if(StringUtils.isNotBlank(data.getAnalysis())){
|
analysis = new ExerciseItemAnalisi();
|
BeanUtils.copyProperties(analysis, data);
|
TraceUtils.setCreateTrace(analysis);
|
analysis.setDeleteFlag(false);
|
analysis.setExerciseItemId(item.getExerciseId());
|
this.save(analysis);
|
}
|
|
if( data.getOptions() != null && !data.getOptions().isEmpty() ){
|
|
for( ExerciseOptionData opt : data.getOptions() ){
|
option = new ExerciseItemOption();
|
BeanUtils.copyProperties(option, opt);
|
TraceUtils.setCreateTrace(option);
|
option.setDeleteFlag(false);
|
option.setExerciseItemId(item.getExerciseId());
|
this.save(option);
|
}
|
|
}
|
|
}
|
|
this.bulkUpdate("update ExerciseGroup set allCount = allCount + ? , " +
|
" updateTime = sysdate(), updateId = ? , updator = ? where groupId = ? " ,
|
new Object[]{ iCount,ClientUtils.getUserId(), ClientUtils.getUserName(), groupId } );
|
|
} catch (Exception e) {
|
log.error("解析习题copyProperties 失败：" ,e );
|
return new Result(false , "服务器内部转换错误");
|
}
|
|
return new Result(true , "成功导入" + iCount + "道习题");
|
}
|
|
|
private Map<String, Object> exerciseParsePy(List<String> lst, String fullPath) {
|
|
return pyExerciseParseByParam(lst, lst.size());
|
//return pyExerciseParseByCache(lst, lst.size());
|
|
|
}
|
|
/**
|
* post传参
|
* @param key
|
* @param size
|
* @return
|
* @throws Exception
|
*/
|
private Map<String, Object> pyExerciseParseByParam(List<String> lst0, int size) {
|
|
return null;
|
|
}
|
|
|
|
/**
|
* 缓存版本
|
* @param key
|
* @param size
|
* @return
|
* @throws Exception
|
*/
|
|
@SuppressWarnings("unused")
|
private Map<String, Object> pyExerciseParseByCache(List<String> lst, int size){
|
|
return null;
|
|
}
|
|
|
private File downloadFile(String groupId, String fullPath, String module) {
|
|
String filePart[] = fullPath.split("\\.");
|
String fileType = filePart[filePart.length - 1];
|
String uuid = UUIDUtils.generateUUID();
|
String filePath = ExerciseService.class.getClassLoader()
|
.getResource("../uploads").getPath()
|
.concat("exercise/" + uuid + "/" + uuid + "." + fileType);
|
|
return fileUploadService.doGetOssFile(fullPath, filePath, module,
|
ClientUtils.getUserId());
|
|
}
|
|
private List<String> generateLstFromFile(File file, String fullPath) {
|
|
String txtFilePath = transformDocToTxt(file);
|
|
List<String> lst = new ArrayList<String>(100);
|
|
FileReader reader = null;
|
BufferedReader br = null;
|
try {
|
reader = new FileReader(txtFilePath);
|
br = new BufferedReader(reader);
|
|
String currLine = "";
|
while ((currLine = br.readLine()) != null) {
|
if (StringUtils.isNotBlank(currLine)) {
|
lst.add(currLine);
|
}
|
}
|
} catch (Exception e) {
|
log.error("解析练习txt文档失败：" + fullPath, e);
|
} finally {
|
IOUtils.closeQuietly(br);
|
IOUtils.closeQuietly(reader);
|
}
|
|
File txt = new File(txtFilePath);
|
FileUtils.deleteQuietly(txt);
|
|
return lst;
|
|
}
|
|
/**
|
* 从office转换到txt：2007转换：自带序号格式会丢失；2003会解析出来
|
*
|
* @param file
|
* @return
|
*/
|
private String transformDocToTxt(File file) {
|
InputStream is = null;
|
FileWriter writer = null;
|
String strText = "";
|
|
try {
|
String fileExtention = fileExtension(file.getName());
|
is = new FileInputStream(file.getAbsolutePath());
|
|
if ("doc".equals(fileExtention)) {
|
WordExtractor extractor = new WordExtractor(is);
|
// 获取Word文件中的文本+自带序号
|
strText = extractor.getText();
|
extractor.close();
|
} else if ("docx".equals(fileExtention)) {
|
OPCPackage opcPackage = POIXMLDocument.openPackage(file
|
.getAbsolutePath());
|
POIXMLTextExtractor extractor = new XWPFWordExtractor(
|
opcPackage);
|
// 只能获取Word文件中的文本，不能取到office序号
|
strText = extractor.getText();
|
extractor.close();
|
} else {
|
throw new RuntimeException("文件格式错误, 请上传word文档（.doc及.docx）格式",
|
null);
|
}
|
|
// 将得到的文本全角转半角
|
strText = formatFullToHalf(strText);
|
|
// 解决空格保存为txt的时候，乱码为？
|
byte bytes[] = { (byte) 0xC2, (byte) 0xA0 };
|
String UTFSpace = new String(bytes, "UTF-8");
|
strText = strText.replaceAll(UTFSpace, " ");
|
|
File txtFile = new File(file.getParentFile().getAbsolutePath()
|
+ "/"
|
+ file.getName().substring(0,
|
file.getName().lastIndexOf(".")) + ".txt");
|
writer = new FileWriter(txtFile, true);
|
writer.write(strText);
|
|
return txtFile.getAbsolutePath();
|
|
} catch (FileNotFoundException e) {
|
throw new RuntimeException("office文档未找到", e);
|
} catch (IOException e) {
|
throw new RuntimeException("office文档读取失败", e);
|
} catch (Exception e) {
|
throw new RuntimeException(e.getMessage(), e);
|
} finally {
|
IOUtils.closeQuietly(writer);
|
IOUtils.closeQuietly(is);
|
}
|
}
|
|
/**
|
* 全角转半角
|
*
|
* @param oriText
|
* @return
|
*/
|
private String formatFullToHalf(String oriText) {
|
if (null == oriText || oriText.length() <= 0) {
|
return "";
|
}
|
|
char[] charArray = oriText.toCharArray();
|
// 对全角字符转换的char数组遍历
|
for (int i = 0; i < charArray.length; ++i) {
|
int charIntValue = (int) charArray[i];
|
|
// 如果符合转换关系,将对应下标之间减掉偏移量65248;如果是空格的话,直接做转换
|
if (charIntValue >= 65281 && charIntValue <= 65374) {
|
charArray[i] = (char) (charIntValue - 65248);
|
} else if (charIntValue == 12288) {
|
charArray[i] = (char) 32;
|
} else if (charIntValue == 58033) {
|
// 空格
|
charArray[i] = (char) 32;
|
} else if (charIntValue == 65380) {
|
// 顿号
|
charArray[i] = (char) 12289;
|
} else if (charIntValue == 65377) {
|
// 句号
|
charArray[i] = (char) 12290;
|
}
|
}
|
return new String(charArray);
|
|
}
|
|
/**
|
* 解析文件后缀
|
*
|
* @param filename
|
* @return
|
*/
|
private String fileExtension(String filename) {
|
|
return filename.substring(filename.lastIndexOf('.') + 1,
|
filename.length());
|
}
|
|
}
|
