package com.yeshi.fanli.service.impl.lable;

import java.io.InputStream;
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;

import javax.annotation.Resource;
import javax.transaction.Transactional;

import jxl.Sheet;
import jxl.Workbook;

import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import com.yeshi.fanli.dao.mybatis.lable.LabelClassMapper;
import com.yeshi.fanli.dao.mybatis.lable.LabelGoodsMapper;
import com.yeshi.fanli.dao.mybatis.lable.LabelMapper;
import com.yeshi.fanli.entity.bus.lable.Label;
import com.yeshi.fanli.entity.bus.lable.LabelGoods;
import com.yeshi.fanli.entity.common.AdminUser;
import com.yeshi.fanli.exception.LabelException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.lable.LabelService;
import com.yeshi.fanli.util.StringUtil;
import org.yeshi.utils.tencentcloud.COSManager;

@Service
public class LabelServiceImpl implements LabelService {

	@Resource
	private LabelMapper labelMapper;
	@Resource
	private LabelService labelService;
	
	@Resource
	private LabelGoodsMapper labelGoodsMapper;
	
	@Resource
	private LabelClassMapper labelClassMapper;
	

	@Override
	public int insertSelective(Label record) throws LabelException{
		return labelMapper.insertSelective(record);
	}

	@Override
	@Transactional
	public void insertList(List<Label>  records,AdminUser admin) throws LabelException{
		if (records != null && records.size() > 0) {
			for (Label label : records) {
				
				//   录入方式
				label.setEntrymode(Label.MODE_BACKSTAGE);
				
				Date nowTime = new Date();
				// 录入时间。人
				label.setCreatetime(nowTime);
				label.setUpdatetime(nowTime);
				label.setCreateUser(admin);
				label.setIosClick(0l);
				label.setAndroidClick(0l);
				
				labelMapper.insertSelective(label);
			}
		}
		
	}
	
	
	@Override
	public void insertSingle(Label label, AdminUser admin,MultipartFile file) throws Exception{
				
		Date nowTime = new Date();
		// 录入时间。人
		label.setCreatetime(nowTime);
		label.setUpdatetime(nowTime);
		label.setCreateUser(admin);
		label.setIosClick(0l);
		label.setAndroidClick(0l);
		//   录入方式
		label.setEntrymode(Label.MODE_BACKSTAGE);
		
		labelMapper.insertSelective(label);
		
		// 上传图片
		if (file != null) {
			labelService.uploadPicture(file, label);
		}
				
		
	}
	
	@Override
	@Transactional
	public void updateList(List<Label>  records) throws LabelException{
		if (records != null && records.size() > 0) {
			for (Label label : records) {
				
				Date nowTime = new Date();
				label.setUpdatetime(nowTime);
				
				labelMapper.updateByPrimaryKeySelective(label);
			}
		}
		
	}
	
	
	@Override
	public int updateByPrimaryKey(Label record) throws LabelException{
		// TODO Auto-generated method stub
		return labelMapper.updateByPrimaryKey(record);
	}

	@Override
	public int updateByPrimaryKeySelective(Label record) throws LabelException{
		// TODO Auto-generated method stub
		return labelMapper.updateByPrimaryKeySelective(record);
	}

	
	@Override
	@Transactional
	public int deleteBatchById(long[] ids) throws LabelException{
		return labelMapper.deleteBatchByPrimaryKey(ids);
	}

	@Override
	@Transactional
	public void deleteBatchByPrimaryKey(List<Long> ids) throws LabelException {
		for (Long id : ids) {
			Label label = labelMapper.selectByPrimaryKey(id);
			if (label != null) {
				// 删除图片
				labelService.deleteImg(label);
				// 删除数据信息
				labelMapper.deleteByPrimaryKey(id);
				
				// 删除商品对应的标签
				labelGoodsMapper.deleteByLabId(id);
				// 删除分类对应的标签
				labelClassMapper.deleteByLabId(id);
			}
		}
	}

	@Override
	public Label selectByPrimaryKey(Long id) throws LabelException{
		return labelMapper.selectByPrimaryKey(id);
	}
	
	@Override
	public List<Label> selectByTitle(String title) throws LabelException{
		LogHelper.test("查询标签：  "+title);
		return labelMapper.selectByTitle(title);
	}

	@Override
	@Cacheable(value = "labelCache",key="'selectByTitleCache-'+#labKey +'-'+#title")
	public List<Label> selectByTitleCache(String labKey, String title) throws LabelException{
		return selectByTitle(title);
	}
	
	
	@Override
	public List<Label> query(int pageIndex, int pageSize, String key,
			String startTime, String endTime, String orderMode) throws LabelException {
		return labelMapper.query(pageIndex, pageSize, key, startTime, endTime,orderMode);
	}
	
	@Override
	public int getQueryCount( String key, String startTime, String endTime) throws LabelException {
		return labelMapper.getQueryCount(key, startTime, endTime);
	}
	
	/**
	 * 从excel文件解析订单
	 * 
	 * @param in
	 * @return
	 */
	@Override
	public void analysisExcel(InputStream in, AdminUser admin) throws Exception {

		jxl.Workbook rwb = Workbook.getWorkbook(in);
		Sheet sheet = rwb.getSheet(0);

		Date nowTime = new Date();
		
		Set<String> titles = new HashSet<String>();
		for (int r = 1; r < sheet.getRows(); r++) {
		
			for (int c = 0; c < sheet.getColumns(); c++) {
				String content = sheet.getCell(c, r).getContents();

				if (StringUtil.isNullOrEmpty(content)) 
					break;// 为空则结束当前行遍历
				
				// 去掉重复字段
				titles.add(content.trim());
			}
		}
		
		
		
		if (titles != null && titles.size() > 0) {
			
			for (String title : titles) {
				
				List<Label> labels = labelService.selectByTitle(title.trim());
				// 若已存在则不存入数据库
				if (labels == null || labels.size() == 0) {
					Label label = new Label();
					
					label.setTitle(title.trim()); // 名称
					label.setEntrymode(Label.MODE_EXCEL); // 批量录入
					label.setCreatetime(nowTime);
					label.setUpdatetime(nowTime);
					label.setCreateUser(admin);
					
					labelService.insertSelective(label);
				}

			}
		}

	}
	
	@Override
	public int uploadPicture(MultipartFile file, Label label) throws Exception {
		
		InputStream inputStream = file.getInputStream();
		String contentType = file.getContentType();
		String type = contentType.substring(contentType.indexOf("/") + 1);
		// 上传文件相对位置
		String fileUrl="LableImg/"+UUID.randomUUID().toString().replace("-", "") + "." + type;
		
		boolean deleteFile =true;
		
		/*  修改图片时，先删除已存在图片  */
		String picture = label.getPicture();
		if (!StringUtil.isNullOrEmpty(picture)) 
			deleteFile = COSManager.getInstance().deleteFile(picture);
		
		
		int result = 2;
		
		/*  上传新图片  */
		if (deleteFile) {
			
			String uploadFilePath = COSManager.getInstance().uploadFile(inputStream, fileUrl).getUrl();
			
			/*  更新数据库信息  */
			if (!StringUtil.isNullOrEmpty(uploadFilePath)) {
				
				Date nowTime = new Date();
				
				label.setPicture(uploadFilePath);
				label.setUpdatetime(nowTime);
				
				result = labelService.updateByPrimaryKeySelective(label);
			}
		}
		
		return result;
		
	}
	
	/**
	 * 删除图片
	 */
	@Override
	public int deleteImg(Label label) throws LabelException {
		
		String fileUrl = label.getPicture();
		
		int result = 2;
		boolean deleteFile = true;
		
		if (!StringUtil.isNullOrEmpty(fileUrl)) {
			
			deleteFile = COSManager.getInstance().deleteFile(fileUrl);
			
			if (deleteFile) {
				Date nowTime = new Date();
				
				label.setPicture(null);
				label.setUpdatetime(nowTime);
				// 更新数据库
				result = labelService.updateByPrimaryKey(label);
			}
			
		}
		return result;
		
	}
	
	
	@Override
	public Map<String, Object> getCountByEntryMode() throws LabelException{
		return labelMapper.getCountByEntryMode();
	}

	@Override
	public long getCountToday() throws LabelException{
		return labelMapper.getCountToday();
	}

	@Override
	public long getCount() {
		return labelMapper.getCount();
	}
	
	@Override
	public List<Label> queryGoodsCandidate(int start, int count, String key, Long classId) throws LabelException{
		return labelMapper.queryGoodsCandidate(start, count, key, classId);
	}
	
	@Override
	public int getCountQueryGoodsCandidate( String key, Long classId) throws LabelException{
		return labelMapper.getCountQueryGoodsCandidate(key, classId);
	}
	
	@Override
	public List<Label> queryClassCandidate(int start, int count, String key, Long classId) throws LabelException{
		return labelMapper.queryClassCandidate(start, count, key, classId);
	}
	
	@Override
	public int getCountQueryClassCandidate( String key, Long classId) throws LabelException{
		return labelMapper.getCountQueryClassCandidate(key, classId);
	}
	
	@Override
	public List<Label> querySubClassCandidate(int start, int count, String key, Long subClassId) throws LabelException{
		return labelMapper.querySubClassCandidate(start, count, key, subClassId);
	}

	@Override
	public int getCountQuerySubClassCandidate( String key, Long subClassId) throws LabelException{
		return labelMapper.getCountQuerySubClassCandidate(key, subClassId);
	}

	@Override
	public List<LabelGoods> getByGoodsId(Long goodsId) {
		return labelMapper.getByGoodsId(goodsId);
	}
	
}