package etcom.servlet; import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.util.ArrayList;
import java.util.List; import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.apache.commons.lang.StringUtils;
import org.json.JSONArray;
import org.json.JSONObject; import etcom.servlet.DBUtil;
import etcom.servlet.SqlActuator; @SuppressWarnings("serial")
public class Execute extends HttpServlet { public Execute() {
super();
} public void destroy() {
super.destroy(); // Just puts "destroy" string in log
// Put your code here
} public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
request.setCharacterEncoding("utf-8");
// String tr = IoToJsonUtils.getIoToJson(request, "UTF-8");
// System.out.println(tr);
String vcRes = "";
String detectTaskJOSN = "";
List<String> sqls = new ArrayList<String>();
Connection conn = DBUtil.getConnection();
SqlActuator sa = new SqlActuator(conn);
try{
String basePath = request.getSession().getServletContext().getRealPath("/");
String filePath = "../images/androidFiles/";
String filename = "";
File file0 =new File(basePath + filePath);
if(!file0.exists()&&!file0.isDirectory())file0.mkdirs();
DiskFileItemFactory factory = new DiskFileItemFactory();
factory.setRepository(file0);
//设置 缓存的大小
factory.setSizeThreshold(1024*1024);
//文件上传处理
ServletFileUpload upload = new ServletFileUpload(factory);
String encoding = request.getCharacterEncoding();
upload.setHeaderEncoding(encoding);
@SuppressWarnings("unchecked")
List<FileItem> list = (List<FileItem>)upload.parseRequest(request);
for(FileItem item : list){
//获取属性名字
String name = item.getFieldName();
//如果获取的 表单信息是普通的 文本 信息
if(item.isFormField()&&"detectTaskJOSN".equals(name)){
//获取用户具体输入的字符串,因为表单提交过来的是 字符串类型的
detectTaskJOSN = new String(item.getString(encoding));
System.out.println("detectTaskJOSN的值:"+detectTaskJOSN);
}else{
if(StringUtils.isNotEmpty(name)){
//获取路径名
String value = item.getName();
//索引到最后一个反斜杠
int start = value.lastIndexOf("\\");
//截取 上传文件的 字符串名字，加1是 去掉反斜杠，
filename = value.substring(start+1);
File file1 =new File(basePath + filePath + filename);
if(file1.exists())file1.delete();
//写到磁盘上
item.write(file1);//第三方提供的
System.out.println("上传成功："+filename);
}
}
}
JSONObject joTask = new JSONObject(detectTaskJOSN);
String _vcTaskNo = joTask.get("vcTaskNo").toString();
String _vcUserId = joTask.get("vcUserId").toString();
String _vcEquipCode = joTask.get("vcEquipCode").toString();
String _vcEquipType = joTask.get("vcEquipType").toString();
String _vcStatus = joTask.get("vcStatus").toString();
String _vcMemo = joTask.get("vcMemo").toString();
String _dtScan = joTask.get("dtScan").toString();
String _dtHandle = joTask.get("dtHandle").toString();
String _vcHandleFlag = joTask.get("vcHandleFlag").toString();
String _vcHandleMemo = joTask.get("vcHandleMemo").toString();
String _vcHandler = joTask.get("vcHandler").toString();
String _nTypeId = joTask.get("nTypeId").toString();
String _nOid = joTask.get("nOid").toString();
String _nCodeId = joTask.get("nCodeId").toString();
String sql = " exec proc_detecttask_add '" + _vcTaskNo + "','" +
_vcUserId + "','" + _vcEquipCode + "','" + _vcEquipType +
"','" + _vcStatus + "','" + _vcMemo + "','" +
filename + "','" + _dtScan + "','" + _dtHandle +
"','" + _vcHandleMemo + "'," + _vcHandleFlag + ",'" +
_vcHandler + "'," + _nTypeId + "," + _nOid + "," +
_nCodeId;
System.out.println(sql);
sqls.add(sql); JSONArray jaDicts = new JSONArray(joTask.get("jaDicts").toString());
for(int idx = 0; idx < jaDicts.length(); idx++){
JSONObject joDict = (JSONObject)jaDicts.get(idx);
String _vcDetectInfo = joDict.get("vcDetectInfo").toString();
String _vcDetectValue = joDict.get("vcDetectValue").toString();
String _vcUnit = joDict.get("vcUnit").toString();
sql = "Insert Into T_DetectTask_Detail(vcTaskNo,vcDetectInfo,vcDetectValue,vcUnit) values ('" +
_vcTaskNo +
"','" +
_vcDetectInfo +
"','" + _vcDetectValue + "','" + _vcUnit + "')";
System.out.println(sql);
sqls.add(sql);
}
sa.batchExec(sqls);
vcRes = "{\"vcRes\":\"success\"}";
}catch(Exception e){
e.printStackTrace();
vcRes = "{\"vcRes\":\"fail\"}";
}finally{
DBUtil.close(null, null, conn);
response.getWriter().println(vcRes);
}
} public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException { doGet(request, response);
} public void init() throws ServletException {
// Put your code here
}
}