package com.product.file.controller;


import java.io.IOException;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.product.common.lang.StringUtils;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.service.support.AbstractBaseService;
import com.product.lucene.service.LuceneService;
import com.product.util.BaseUtil;

/**
 * 	自动清理附件数据，服务器附件（暂不处理）
 * 	文档检索索引，
 * 	每天执行
 */
@Service("fileAutoClear")
public class FileAutoClearService extends AbstractBaseService{

	@Autowired
	BaseDao baseDao;
	
	@Autowired
	LuceneService luceneService;

	
	public void getFileInfo(){
		//获取所有附件信息
		DataTableEntity dtFileInfo=baseDao.listTable("product_sys_attachments");
		if (!BaseUtil.dataTableIsEmpty(dtFileInfo)) {
			//遍历附件信息
			for (int i = 0; i < dtFileInfo.getRows(); i++) {
				FieldSetEntity fseFileInfo=dtFileInfo.getFieldSetEntity(i);
				String table_name=fseFileInfo.getString("attachment_data_table");	//来源表
				String table_filed=fseFileInfo.getString("attachment_data_field");	//来源字段
				String uuid=fseFileInfo.getUUID();
				
				//非空验证
				if (StringUtils.isEmpty(table_name) || StringUtils.isEmpty(table_filed)) {
					continue;
				}
				//获取原数据
				FieldSetEntity fseService=baseDao.getFieldSetEntityByFilter(table_name, table_filed+"=?", new Object[] {uuid}, false);
				if (fseService==null) {
					try {
						//清除索引
						luceneService.deleteIndexByUUID(uuid);
					} catch (IOException e) {
						e.printStackTrace();
					}
				}
			}
		}
	}
}