添加知识点id

孙向锦
1 parent bda221f4
Showing 7 changed files with 122 additions and 4 deletions
resources/mybatis1/sunvote/PaperQuestionMapper.xml
resources/spring/ApplicationContext-main.xml
resources/spring/ApplicationContext-mvc.xml
src/com/fh/bean/Question.java
src/com/fh/controller/api/CustomMultipartResolver.java
src/com/fh/controller/api/FileUploadProgressListener.java
src/com/fh/controller/api/V1.java
@@ -15,6 +15,7 @@
 		PART_SCORE,	
 		RANK,	
 		NO_NAME,	
+		KNOWLEDGE_ID,	
 		PAPERQUESTION_ID
 	</sql>
@@ -26,6 +27,7 @@
 		#{PART_SCORE},	
 		#{RANK},	
 		#{NO_NAME},	
+		#{KNOWLEDGE_ID},	
 		#{PAPERQUESTION_ID}
 	</sql>
@@ -59,6 +61,7 @@
 			PART_SCORE = #{PART_SCORE},
 			RANK = #{RANK},
 			NO_NAME = #{NO_NAME},
+			KNOWLEDGE_ID = #{KNOWLEDGE_ID},
 		PAPERQUESTION_ID = PAPERQUESTION_ID
 		where 
 		PAPERQUESTION_ID = #{PAPERQUESTION_ID}
@@ -35,5 +35,6 @@
 	</bean> 
    <bean id="springBeanFactoryUtils" class="com.fh.util.SpringBeanFactoryUtils"/>
+   <bean id="progressListener" class="com.fh.controller.api.FileUploadProgressListener"/>
 </beans>
@@ -36,10 +36,11 @@
 	<bean id="exceptionResolver" class="com.fh.resolver.MyExceptionResolver"></bean>
-	<!-- 上传拦截，如最大上传值及最小上传值 -->
-	  <bean id="multipartResolver"   class="org.springframework.web.multipart.commons.CommonsMultipartResolver" >   
+	<!-- 上传拦截，如最大上传值及最小上传值  104857600 104857600 -->
+	<!--   <bean id="multipartResolver"   class="org.springframework.web.multipart.commons.CommonsMultipartResolver" >    -->
+	  <bean id="multipartResolver"   class="com.fh.controller.api.CustomMultipartResolver" >   
 		  <property name="maxUploadSize">    
-	          <value>104857600</value>    
+	          <value>10737418240</value>    
 	       </property>   
 	        <property name="maxInMemorySize">    
 	            <value>4096</value>    
@@ -43,7 +43,7 @@ public class Question {
 	private String sug_part_score;
 	private String questionType ;
-
+	
 	private List<Question> questions;
 	public void setSubject_id(String subject_id) {
+package com.fh.controller.api;
+
+import java.util.List;
+
+import javax.servlet.http.HttpServletRequest;
+
+import org.apache.commons.fileupload.FileItem;
+import org.apache.commons.fileupload.FileUpload;
+import org.apache.commons.fileupload.FileUploadBase;
+import org.apache.commons.fileupload.FileUploadException;
+import org.apache.commons.fileupload.servlet.ServletFileUpload;
+import org.springframework.web.multipart.MaxUploadSizeExceededException;
+import org.springframework.web.multipart.MultipartException;
+import org.springframework.web.multipart.commons.CommonsMultipartResolver;
+
+
+public class CustomMultipartResolver extends CommonsMultipartResolver {
+	
+	/*@Autowired
+	private FileUploadProgressListener progressListener;
+	
+	public void setFileUploadProgressListener(FileUploadProgressListener progressListener){
+		this.progressListener=progressListener;
+	}*/
+
+	@Override
+	@SuppressWarnings("unchecked")
+	public MultipartParsingResult parseRequest(HttpServletRequest request)
+			throws MultipartException {
+		String encoding = determineEncoding(request);
+		FileUpload fileUpload = prepareFileUpload(encoding);
+		FileUploadProgressListener progressListener = new FileUploadProgressListener();
+		String ip = "";
+		if (request.getHeader("x-forwarded-for") == null) {
+			ip = request.getRemoteAddr();
+		} else {
+			ip = request.getHeader("x-forwarded-for");
+		}
+		progressListener.setIp(ip);
+		fileUpload.setProgressListener(progressListener);
+		try {
+			List<FileItem> fileItems = ((ServletFileUpload) fileUpload).parseRequest(request);
+			return parseFileItems(fileItems, encoding);
+		}
+		catch (FileUploadBase.SizeLimitExceededException ex) {
+			throw new MaxUploadSizeExceededException(fileUpload.getSizeMax(), ex);
+		}
+		catch (FileUploadException ex) {
+			throw new MultipartException("Could not parse multipart servlet request", ex);
+		}
+
+	}
+
+
+}
+package com.fh.controller.api;
+
+import java.util.HashMap;
+
+import org.apache.commons.fileupload.ProgressListener;
+
+public class FileUploadProgressListener implements ProgressListener {
+	
+	public static HashMap<String,HashMap<String,String>> map = new HashMap();
+	private String ip ;
+	private long last = 0 ;
+	private HashMap<String,String> ipMap;
+	private String key ;
+
+	@Override
+	public void update(long pBytesRead, long pContentLength, int pItems) {
+		if(!"127.0.0.1".equals(ip)){
+			ipMap.put(key,"" +  ((pBytesRead * 1000.0) / (System.currentTimeMillis() - last)));
+		}
+	}
+	
+	public void setIp(String ip) {
+		this.ip = ip;
+		last = System.currentTimeMillis();
+		if (map.get(ip) == null) {
+			ipMap = new HashMap<String, String>();
+			map.put(ip, ipMap);
+		} else {
+			ipMap = map.get(ip);
+		}
+		for (int i = 0;; i++) {
+			String tkey = "" + i;
+			if (ipMap.get(tkey) == null) {
+				key = tkey;
+				break;
+			}
+		}
+	}
+
+}
@@ -1397,6 +1397,7 @@ public class V1 extends BaseController {
 					pqPd.put("NO_NAME", question.getNo_name());
 					pqPd.put("PAPERQUESTION_ID", this.get32UUID());
 					pqPd.put("P_ID", "0");
+					pqPd.put("KNOWLEDGE_ID", question.getKnowledge_id());//
 					paperquestionService.save(pqPd);
 				}
@@ -2805,6 +2806,21 @@ public class V1 extends BaseController {
 	}
+	/**
+	 * 根据ID班级名称
+	 * @param id
+	 * @return
+	 * @throws Exception
+	 */
+	@RequestMapping(value = "/printmsg", produces = "application/json;charset=UTF-8")
+	@ResponseBody
+	public  String printmsg() throws Exception {
+		ResponseGson<Map> res = new ResponseGson();
+		res.setData(FileUploadProgressListener.map);
+		return res.toJson();
+		
+	}
+	
 	@RequestMapping(value = "/uploadfile", produces = "application/json;charset=UTF-8")
 	@ResponseBody
 	public String uploadFile(@RequestParam(value="file",required=false)MultipartFile file, HttpServletRequest request) throws Exception{
@@ -2833,4 +2849,6 @@ public class V1 extends BaseController {
+	
+	
 }