package com.yelang.framework.event;
import org.springframework.context.ApplicationEvent;
import com.yelang.project.webupload.domain.FileEntity;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
@Setter
@Getter
@ToString
public class FileUploadEvent extends ApplicationEvent {
	private static final long serialVersionUID = 7396389156436678379L;
	private FileEntity fileEntity;//上傳文件對象
	/**
	  *   重寫構(gòu)造函數(shù)
	 * @param source 事件源對象
	 * @param fileEntity 已上傳的文件對象
	 */
	public FileUploadEvent(Object source,FileEntity fileEntity) {
		super(source);
		this.fileEntity = fileEntity;
	}
}

package com.yelang.project.webupload.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.yelang.framework.web.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import lombok.ToString;
@TableName("biz_file")
@NoArgsConstructor
@AllArgsConstructor
@Setter
@Getter
@ToString
public class FileEntity extends BaseEntity {
	private static final long serialVersionUID = 1L;
	private Long id;
	@TableField(value = "f_id")
	private String fid;
	@TableField(value = "b_id")
	private String bid;
	@TableField(value = "f_type")
	private String type;
	@TableField(value = "f_name")
	private String name;
	@TableField(value = "f_desc")
	private String desc;
	@TableField(value = "f_state")
	private Integer state;
	@TableField(value = "f_size")
	private Long size;
	@TableField(value = "f_path")
	private String path;
	@TableField(value = "table_name")
	private String tablename = "temp_table";
	private String md5code;
	private String directory;
	@TableField(value = "biz_type")
	private String bizType;
	@TableField(exist = false)
	private boolean previewSign;
	@TableField(exist = false)
	private String previewType;
}

@SuppressWarnings("resource")
private AjaxResult mergeChunks(FileEntity db_file,String chunk_dir,String chunks,String f_path) throws IOException {
	if (db_file == null) {
		return AjaxResult.error(AjaxResult.Type.WEBUPLOADERROR.value(), "找不到數(shù)據(jù)");
	}
	if (db_file.getState() == 1) {
		//未分片文件上傳成功合并成功后發(fā)布相應(yīng)事件，各監(jiān)聽器自由監(jiān)聽并執(zhí)行
		applicationContext.publishEvent(new FileUploadEvent(this, db_file));
		return AjaxResult.success();
    }
	if(db_file.getSize() > block_size){
		//xxx 其它業(yè)務(wù)邏輯
		db_file.setState(1);
		fileService.updateById(db_file);
		File tempFile = new File(chunk_dir);
		if (tempFile.isDirectory() && tempFile.exists()) {
			tempFile.delete();
		}
		//分片文件上傳成功合并成功后發(fā)布相應(yīng)事件，各監(jiān)聽器自由監(jiān)聽并執(zhí)行
		applicationContext.publishEvent(new FileUploadEvent(this, db_file));
	}
	return AjaxResult.success();
}

package com.yelang.framework.aspectj.lang.enums;
/**
 * 文件上傳監(jiān)聽服務(wù)注冊枚舉類
 * @author 夜郎king
 */
public enum FileUploadServiceRegisterEnum {
	UNKOWN(-1,"UNKOWN","","","未知"),
	PROJZSPRCSINFSERVIMPL(0,"biz_student","studentUploadCallbackServiceImpl","123a","項目程序管理文件上傳回調(diào)處理枚舉");
	private int index;//下標(biāo),編號作用
	private String tableName;//業(yè)務(wù)表名稱，根據(jù)表名檢索具體執(zhí)行的servcie
	private String execService;//業(yè)務(wù)實際執(zhí)行service
	private String bizType;//業(yè)務(wù)類型
	private String desc;//描述說明
	public int getIndex() {
		return index;
	}
	public void setIndex(int index) {
		this.index = index;
	}
	public String getTableName() {
		return tableName;
	}
	public void setTableName(String tableName) {
		this.tableName = tableName;
	}
	public String getExecService() {
		return execService;
	}
	public void setExecService(String execService) {
		this.execService = execService;
	}
	public String getDesc() {
		return desc;
	}
	public void setDesc(String desc) {
		this.desc = desc;
	}
	public String getBizType() {
		return bizType;
	}
	public void setBizType(String bizType) {
		this.bizType = bizType;
	}
	private FileUploadServiceRegisterEnum(int index, String tableName, String execService, String bizType, String desc) {
		this.index = index;
		this.tableName = tableName;
		this.execService = execService;
		this.bizType = bizType;
		this.desc = desc;
	}
	public static FileUploadServiceRegisterEnum getEnumByTableName(String tableName){
		FileUploadServiceRegisterEnum result = null;
		for (FileUploadServiceRegisterEnum enumObj : FileUploadServiceRegisterEnum.values()) {
			if(enumObj.getTableName().equals(tableName)){
				result = enumObj;
				break;
			}
		}
		return result;
	}
	public static FileUploadServiceRegisterEnum getEnumByTableNameAndBizType(String tableName,String bizType){
		FileUploadServiceRegisterEnum result = null;
		for (FileUploadServiceRegisterEnum enumObj : FileUploadServiceRegisterEnum.values()) {
			if(enumObj.getTableName().equals(tableName) && enumObj.getBizType().equals(bizType)){
				result = enumObj;
				break;
			}
		}
		return result;
	}
}

package com.yelang.framework.event.listener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import com.yelang.common.utils.StringUtils;
import com.yelang.common.utils.spring.SpringUtils;
import com.yelang.framework.aspectj.lang.enums.FileUploadServiceRegisterEnum;
import com.yelang.framework.event.FileUploadEvent;
import com.yelang.project.common.service.IFileUploadCallbackService;
import com.yelang.project.webupload.domain.FileEntity;
/**
 * 公共事件監(jiān)聽器組件，具體實現(xiàn)使用策略模式實現(xiàn)，統(tǒng)一由本類處理后進行相應(yīng)轉(zhuǎn)發(fā)，
 * 多種event監(jiān)聽均在本類中實現(xiàn)注冊監(jiān)聽，使用event模式便于程序解耦，程序處理邏輯更加清晰
 * @author 夜郎king
 */
@Component
public class YelangSpringListener {
	private static final Logger sys_user_logger = LoggerFactory.getLogger("sys-user");
 
	@EventListener
	public void fileUploadEventRegister(FileUploadEvent event){
		try {
			sys_user_logger.info("當(dāng)前處理線程名稱:" + Thread.currentThread().getName());
			FileEntity fileEntity = event.getFileEntity();
			if(StringUtils.isNotEmpty(fileEntity.getTablename())){
				FileUploadServiceRegisterEnum rigisterEnum = null;
				if(StringUtils.isNotBlank(fileEntity.getBizType())) {//業(yè)務(wù)類型不為空，則根據(jù)表名和業(yè)務(wù)名稱來查找執(zhí)行service
					rigisterEnum = FileUploadServiceRegisterEnum.getEnumByTableNameAndBizType(fileEntity.getTablename(), fileEntity.getBizType());
				}else {
					rigisterEnum = FileUploadServiceRegisterEnum.getEnumByTableName(fileEntity.getTablename());
				}
				if(null != rigisterEnum && StringUtils.isNotEmpty(rigisterEnum.getExecService())){
					String execService = rigisterEnum.getExecService();
					IFileUploadCallbackService service = SpringUtils.getBean(execService);
					service.process(fileEntity);
				}else{
					sys_user_logger.info("未注冊文件上傳監(jiān)聽回調(diào)處理器.");
				}
			}
		} catch (Exception e) {
			sys_user_logger.error("文件上傳事件監(jiān)聽發(fā)生錯誤.",e);
		}
	}
}

if(null != rigisterEnum && StringUtils.isNotEmpty(rigisterEnum.getExecService())){
	String execService = rigisterEnum.getExecService();
	IFileUploadCallbackService service = SpringUtils.getBean(execService);
	service.process(fileEntity);
}

package com.yelang.project.common.service;
import com.yelang.project.webupload.domain.FileEntity;
public interface IFileUploadCallbackService {
	/**
	 * 文件上傳事件監(jiān)聽器回調(diào)服務(wù)接口，封裝公共服務(wù)，可以讀取相關(guān)表格或修改業(yè)務(wù)表，具體實現(xiàn)由各實現(xiàn)類來完成
	 * @param fileEntity 文件實體
	 * @throws Exception
	 */
	void process(FileEntity fileEntity) throws Exception;
}

package com.yelang.project.common.service.impl;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import com.yelang.common.utils.StringUtils;
import com.yelang.project.common.service.IFileUploadCallbackService;
import com.yelang.project.extend.student.domain.Student;
import com.yelang.project.extend.student.service.IStudentService;
import com.yelang.project.webupload.domain.FileEntity;
@Service("studentUploadCallbackServiceImpl")
public class StudentUploadCallbackServiceImpl implements IFileUploadCallbackService{
	private static final Logger logger = LoggerFactory.getLogger("sys-user");
	@Autowired
	private IStudentService studentService;
	@Override
	@Transactional(propagation=Propagation.REQUIRED,rollbackFor=Exception.class)
	public void process(FileEntity fileEntity) throws Exception {
		if(null != fileEntity && StringUtils.isNotEmpty(fileEntity.getBid())){
			String pkId = fileEntity.getBid();
			Student stu = studentService.selectStudentById(Long.valueOf(pkId));
			//System.out.println(fileEntity.getPath());
			//System.out.println(stu.getName() + "\t" + stu.getAddress());
			logger.info("開始處理........");
			Thread.sleep(35 * 1000);//休眠35秒測試
			logger.info("執(zhí)行結(jié)束");
		}
	}
}

23:14:53.169 [http-nio-8080-exec-37] INFO  sys-user - [fileUploadEventRegister,32] - 當(dāng)前處理線程名稱:http-nio-8080-exec-37
23:14:53.198 [http-nio-8080-exec-37] DEBUG c.y.p.e.s.m.S.selectById - [debug,137] - <==      Total: 1
23:14:53.199 [http-nio-8080-exec-37] INFO  sys-user - [process,32] - 開始處理........
23:15:08.200 [http-nio-8080-exec-37] INFO  sys-user - [process,34] - 執(zhí)行結(jié)束