--资源导入功能;

src/main/java/com/ekexiu/portal/dao/ResourceTmpLogDao.java

@@ -0,0 +1,22 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.LimitSelect;
import com.ekexiu.portal.po.ResourceTmpLog;
@DAO
public abstract class ResourceTmpLogDao {
	@Insert
	public abstract int insert(Connection con,ResourceTmpLog log)throws SQLException;
	
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME")
	public abstract List<ResourceTmpLog> query(Connection con,String ownerId,String resourceTmpId,int rows)throws SQLException;
}

src/main/java/com/ekexiu/portal/po/ResourceTmpLog.java

@@ -0,0 +1,54 @@
package com.ekexiu.portal.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.annotation.entry.Unique;
import org.jfw.apt.orm.annotation.entry.Uniques;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
@Table
@Uniques(@Unique(clolumns = { "resourceId", "resourceTmpId" }, name = "RESOURCE_TMP_LOG_UQ"))
public class ResourceTmpLog implements CreateTimeSupported {
	private String ownerId;
	private String resourceId;
	private String resourceTmpId;
	private String createTime;
	@Column(DE.id_32)
	public String getOwnerId() {
		return ownerId;
	}
	public void setOwnerId(String ownerId) {
		this.ownerId = ownerId;
	}
	@Column(DE.id_32)
	public String getResourceId() {
		return resourceId;
	}
	public void setResourceId(String resourceId) {
		this.resourceId = resourceId;
	}
	@Column(DE.id_32)
	public String getResourceTmpId() {
		return resourceTmpId;
	}
	public void setResourceTmpId(String resourceTmpId) {
		this.resourceTmpId = resourceTmpId;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
}

src/main/java/com/ekexiu/portal/service/ResourceService.java

@@ -29,12 +29,14 @@ import com.ekexiu.portal.dao.OrgDao;
import com.ekexiu.portal.dao.OrgResStaffDao;
import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.dao.ResourceDao;
import com.ekexiu.portal.dao.ResourceTmpLogDao;
import com.ekexiu.portal.dao.WatchDao;
import com.ekexiu.portal.po.ArticleRes;
import com.ekexiu.portal.po.Image;
import com.ekexiu.portal.po.Operation;
import com.ekexiu.portal.po.OrgResStaff;
import com.ekexiu.portal.po.Resource;
import com.ekexiu.portal.po.ResourceTmpLog;
import com.ekexiu.portal.pojo.EditOrganization;
import com.ekexiu.portal.pojo.EditProfessor;
@@ -65,6 +67,8 @@ public class ResourceService {
	private OrgResStaffDao orgResStaffDao;
	@Autowrie
	private OrgDao orgDao;
	@Autowrie
	private ResourceTmpLogDao resourceTmpLogDao;
	public String getTimeFormat() {
		return timeFormat;
@@ -170,6 +174,14 @@ public class ResourceService {
		this.orgDao = orgDao;
	}
	public ResourceTmpLogDao getResourceTmpLogDao() {
		return resourceTmpLogDao;
	}
	public void setResourceTmpLogDao(ResourceTmpLogDao resourceTmpLogDao) {
		this.resourceTmpLogDao = resourceTmpLogDao;
	}
	private String publishTime(){
		SimpleDateFormat df = new SimpleDateFormat(this.timeFormat);
		String publishTime = df.format(new Date());
@@ -192,17 +204,26 @@ public class ResourceService {
	
	@Post
	@Path("/importRes")
	public String importRes(@JdbcConn Connection con,Resource resource,@Nullable String imgSrc)throws SQLException{
	public String importRes(@JdbcConn(true) Connection con,Resource resource,String resourceTmpId,@Nullable String imgSrc)throws SQLException, JfwBaseException{
		String resourceId = StringUtil.buildUUID();
		resource.setResourceId(resourceId);
		resource.setStatus("1");
		resource.setPublishTime(this.publishTime());
		resource.setPageViews(0);
		ResourceTmpLog log = new ResourceTmpLog();
		log.setResourceId(resourceId);
		log.setResourceTmpId(resourceTmpId);
		if(resource.getProfessorId() != null){
			resource.setResourceType("1");
			log.setOwnerId(resource.getProfessorId());
		}else if(resource.getOrgId() != null){
			resource.setResourceType("2");
			log.setOwnerId(resource.getOrgId());
		}else{
			throw new JfwBaseException(-1, "bad parameter:ownerId");
		}
		this.resourceDao.insert(con, resource);
		this.resourceTmpLogDao.insert(con, log);
		if(imgSrc != null){
			Image image = new Image();
			image.setImageId(StringUtil.buildUUID());
@@ -214,6 +235,16 @@ public class ResourceService {
		return resourceId;
	}
	
	@Get
	@Path("/isImportRes")
	public boolean isImportRes(@JdbcConn Connection con,String id,String resourceTmpId,@DefaultValue("1") int rows)throws SQLException{
		List<ResourceTmpLog> logs = this.resourceTmpLogDao.query(con, id, resourceTmpId, rows);
		if(logs.isEmpty()){
			return false;
		}
		return true;
	}
	
	@Post
	@Path("/save")
	public String save(@JdbcConn(true) Connection con, Resource resource, @Nullable String[] fns, @Nullable String[] imageIds)