package com.qxueyou.scc.sys.service.impl;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.qxueyou.scc.base.model.Result;
import com.qxueyou.scc.base.service.IFileUploadService;
import com.qxueyou.scc.base.service.impl.CommonAppService;
import com.qxueyou.scc.base.util.CollectionUtils;
import com.qxueyou.scc.base.util.TraceUtils;
import com.qxueyou.scc.sys.model.SysAttachment;
import com.qxueyou.scc.sys.model.SysFileUploadTrace;
import com.qxueyou.scc.sys.service.ISysAttachmentService;

/**
 * 数据库配置服务
 * @author kevin
 *
 */
@Service
public class SysAttachmentService extends CommonAppService implements ISysAttachmentService {
	
	private final Logger logger = LogManager.getLogger(SysAttachmentService.class);
	
	@Autowired
	IFileUploadService fileUploadService;

	@Override
	public Result querySysAttachement(String relaedObjectId) {
		
		String hql = "from SysAttachment s where s.realatedObjectId = ? and s.deleteFlag is false order by s.createTime desc";

		List<SysAttachment> lstAttachements = this.find(hql, CollectionUtils.newList(relaedObjectId), SysAttachment.class);

		return new Result(true, "",lstAttachements);
	}

	@Override
	public Result insertSysAttachment(String attachmentName, String attachmentPath,long fileSize , String relatedObjectId) {
		SysAttachment attachement = null;
		String fileSuffix = null;
		Result result = new Result(false);
		try {
			fileSuffix = StringUtils.substring(attachmentPath, attachmentPath.lastIndexOf('.'));
			attachement = new SysAttachment();
			TraceUtils.setCreateTrace(attachement);
			attachement.setAttachmentId(null);
			attachement.setAttachmentName(attachmentName);
			attachement.setAttachmentPath(attachmentPath);
			attachement.setFileSize(fileSize);
			attachement.setRealatedObjectId(relatedObjectId);
			attachement.setFileSuffix(fileSuffix);
			attachement.setAttachmentType(0);
			this.save(attachement);
			
			// 更新上传文件使用轨迹
			fileUploadService.updateUploadTrace(attachmentPath, "sys_attachment_file", SysFileUploadTrace.FILE_USE, attachement.getAttachmentId());			
			result =new Result(true);
			Map<String,Object> attrMap = new HashMap<String,Object>();
			attrMap.put("attachmentId", attachement.getAttachmentId());
			result.setData(attrMap);
		} catch (Exception ex) {
			logger.error("新增附件出错。。attachmentName="+attachmentName,ex);
		}
		
		return result;
	}

	@Override
	public Result deleteSysAttachement(String attachementIds) {
		Result result = new Result(false);
		SysAttachment tempAttach = null;
		String[] arrAttachementId = null;
		try {
			// 保存到服务器
			if(StringUtils.isEmpty(attachementIds)){
				return new Result(false,"参数错误，需要删除的附件不存在");
			}
			
			arrAttachementId = attachementIds.split(",");
			for (String tempId : arrAttachementId) {
				tempAttach = read(SysAttachment.class, tempId);
				tempAttach.setDeleteFlag(true);
				TraceUtils.setUpdateTrace(tempAttach);
				this.save(tempAttach);
			}
			result = new Result(true);
		} catch (Exception ex) {
			logger.error("删除附件出错。。attachementIds="+attachementIds,ex);
		}
		return result;
	}
}