package com.zyf.services;

import java.awt.Image;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.PrintWriter;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import java.text.SimpleDateFormat;

import java.util.Date;

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.FileItemFactory;

import org.apache.commons.fileupload.disk.DiskFileItemFactory;

import org.apache.commons.fileupload.servlet.ServletFileUpload;

import com.zyf.staticvalues.DbValues;

public class ReceiveArticle extends HttpServlet {

private static final long serialVersionUID = 1L;

String driver =DbValues.driver;

String url = DbValues.url;

String user = DbValues.user;

String password =DbValues.password;

int sender;String image;String content;String title;int code;

       

   

    public ReceiveArticle() {

        super();

        // TODO Auto-generated constructor stub

    }

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

// TODO Auto-generated method stub

}

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

// TODO Auto-generated method stub

boolean isMultipart=ServletFileUpload.isMultipartContent(request);

if(isMultipart)

{

String realpath=request.getSession().getServletContext().getRealPath("/files");

System.out.println(realpath);

File dir=new File(realpath);

if(!dir.exists())

{

dir.mkdir();

}

FileItemFactory factory=new DiskFileItemFactory();

ServletFileUpload upload=new ServletFileUpload(factory);

upload.setHeaderEncoding("UTF-8");

try

{

List items=upload.parseRequest(request);

for(FileItem item : items)

{

if(item.isFormField())

{

if(item.getFieldName().equals("sender"))

{

sender=Integer.parseInt(item.getString("UTF-8"));

}

if(item.getFieldName().equals("content"))

{

content=item.getString("UTF-8");

}

if(item.getFieldName().equals("title"))

{

title=item.getString("UTF-8");

}

}

else

{

image=System.currentTimeMillis()+item.getName().substring(item.getName().lastIndexOf("."));

item.write(new File(dir,image));

}

}

writeSql(response);

}

catch(Exception e)

{

e.printStackTrace();

}

}

else

{

doGet(request,response);

}

}

private void writeSql(HttpServletResponse response) throws ClassNotFoundException, SQLException, IOException

{

Class.forName(driver);

Connection conn =DriverManager.getConnection(url, user, password);

if(!conn.isClosed())

    {

    System.out.println("Succeeded connecting to the Database!");

    Statement statement = conn.createStatement();

    Date now = new Date(); 

    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");

    String sql = "insert into contenttext(sendtime,sender,pic,content,texttitle) values('"+dateFormat.format(now)+"','"+sender+"','"+image+"','"+content+"','"+title+"')";

    statement.executeUpdate(sql); 

    System.out.println("写入文章成功");

    PrintWriter out = response.getWriter();

    out.print("success");

    }

    else

    {

    System.out.println("失败");

    }

}

}