package com.shlanbao.tzsc.pms.sys.datadict.service.impl;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

import com.shlanbao.tzsc.utils.tools.FillUserInfoUtil;
import com.shlanbao.tzsc.utils.tools.LogAnno;
import org.apache.commons.lang.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.shlanbao.tzsc.base.dao.DocFileManageDaoI;
import com.shlanbao.tzsc.base.dao.SysEqpCategoryDaoI;
import com.shlanbao.tzsc.base.mapping.DocFilemanage;
import com.shlanbao.tzsc.base.mapping.SysEqpCategory;
import com.shlanbao.tzsc.base.model.DataGrid;
import com.shlanbao.tzsc.base.model.PageParams;
import com.shlanbao.tzsc.base.model.SessionInfo;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.plugin.service.LoadComboboxServiceI;
import com.shlanbao.tzsc.pms.sys.datadict.beans.SysEqpCategoryBean;
import com.shlanbao.tzsc.pms.sys.datadict.service.SysEqpCategoryServiceI;
import com.shlanbao.tzsc.utils.params.ComboboxType;
import com.shlanbao.tzsc.utils.tools.BeanConvertor;
import com.shlanbao.tzsc.utils.tools.StringUtil;

@Service
public class SysEqpCategoryServiceImpl extends BaseService implements SysEqpCategoryServiceI {
	@Autowired
	protected SysEqpCategoryDaoI sysEqpCategoryDao;
	@Autowired
	protected DocFileManageDaoI docFileManageDao;
	@Autowired
	private LoadComboboxServiceI  comboboxServiceI;
	@Autowired
	private HttpServletRequest request;
	@LogAnno(operateType = "数据字典新增")
	@Override
	public void addMdCategory(SysEqpCategory mdEqpCategory) throws Exception {
			SysEqpCategory categroy = null;		
			//categroy = sysEqpCategoryDao.findById(SysEqpCategory.class, mdEqpCategory.getId());	
			categroy = mdEqpCategory;
			categroy.setDel("0");
			categroy.setId(UUID.randomUUID().toString());
		FillUserInfoUtil.fillCreateUserInfo(categroy,request);
		sysEqpCategoryDao.save(categroy);
		//comboboxServiceI.initCombobox(ComboboxType.EQPCATEGORY);
	}

	@Override
	public SysEqpCategory getMdCategoryById(String id) throws Exception {
		return sysEqpCategoryDao.findById(SysEqpCategory.class, id);
	}

	@Override
	public DataGrid queryMdCategory(SysEqpCategory mdEqpCategory,PageParams pageParams) throws Exception {
		
		StringBuffer whereSql = new StringBuffer();//设置查询参数
		if(StringUtil.notNull(mdEqpCategory.getCode())){
			whereSql.append(" and o.code like '%" + mdEqpCategory.getCode() +"%'");
		}
		if(StringUtil.notNull(mdEqpCategory.getName())){
			whereSql.append(" and o.name like '%" + mdEqpCategory.getName() +"%'");
		}
		if(StringUtil.notNull(mdEqpCategory.getEqpType())){
			whereSql.append(" and o.name like '%"+mdEqpCategory.getEqpType()+"%'");
		}
		if(StringUtil.notNull(mdEqpCategory.getCycleType())){
			whereSql.append(" and o.cycle_type='"+mdEqpCategory.getCycleType()+"' ");
		}
		//总记录数============================================================================================
		long total= 0;
		List<SysEqpCategoryBean> lastRows = new ArrayList<SysEqpCategoryBean>();
		String countSql =" select  count(o.id) from SYS_EQP_CATEGORY o where o.DEL=0  and o.maintainace_type='"+mdEqpCategory.getMaintainaceType()+"'";
		List<?> list = sysEqpCategoryDao.queryBySql(countSql+whereSql.toString(), null);//只会有一条记录
		if(null!=list&&list.size()>0){
			Object arr=(Object) list.get(0);//返回一个对象，而不是 一组数组
			total =Long.parseLong(ObjectUtils.toString(arr));
		}
		//===================================================================================================
		if(total>0){
			StringBuffer lastSql = new StringBuffer();	
			lastSql.append("SELECT * FROM ( ");
			lastSql.append("SELECT ROWNUM as rownumber,o. ID,o.code,o. NAME,o.DES,o.ENABLE,o.DEl,o.maintainace_type,o.CYCLE_NUM,o.CYCLE_TYPE,o.CREATE_USER_NAME,o.CREATE_USER_TIME,o.UPDATE_USER_NAME,o.UPDATE_USER_TIME FROM SYS_EQP_CATEGORY o WHERE o.DEL = 0 ");
			lastSql.append(" and o.maintainace_type='"+mdEqpCategory.getMaintainaceType()+"'");
			lastSql.append(whereSql);
			lastSql.append(")temp1 where  temp1.rownumber>").append(((pageParams.getPage()-1)*pageParams.getRows()))
			.append(" and temp1.rownumber<=").append((pageParams.getPage()*pageParams.getRows())).append(" ");
			
			list = sysEqpCategoryDao.queryBySql(lastSql.toString(), null);
			if(null!=list&&list.size()>0){
				SysEqpCategoryBean bean = null;
				for(int i=0;i<list.size();i++){
					bean = new SysEqpCategoryBean();
					Object[] arr=(Object[]) list.get(i);
					bean.setId(ObjectUtils.toString(arr[1]));
					bean.setCode(ObjectUtils.toString(arr[2]));
					bean.setName(ObjectUtils.toString(arr[3]));
					bean.setDes(ObjectUtils.toString(arr[4]));
					String enable = ObjectUtils.toString(arr[5]);
					if(null!=enable&&!"".equals(enable)){
						bean.setEnable(Long.parseLong(enable));
					}
					bean.setDel(ObjectUtils.toString(arr[6]));
					bean.setCycleNum(ObjectUtils.toString(arr[7]));
					bean.setCycleType(ObjectUtils.toString(arr[8]));
					bean.setCreateUserName(arr[10]==null?null:StringUtil.convertObjToString(arr[10]));
					bean.setCreateUserTime(arr[11]==null?null:(Date) arr[11]);
					bean.setUpdateUserName(arr[12]==null?null:StringUtil.convertObjToString(arr[12]));
					bean.setUpdateUserTime(arr[13]==null?null:(Date) arr[13]);
					lastRows.add(bean);
				}
			}
		}
		return new DataGrid(lastRows, total);
	}

	@LogAnno(operateType = "删除设备类型")
	@Override
	public void deleteMdCategory(String id) throws Exception {
		String sql = "delete from SYS_EQP_CATEGORY where ID='"+id+"'";
		sysEqpCategoryDao.updateBySql(sql, null);
		String typesql = "delete from SYS_EQP_TYPE where CID='"+id+"'";
		sysEqpCategoryDao.updateBySql(typesql, null);
		comboboxServiceI.initCombobox(ComboboxType.EQPCATEGORY);
	}

	@Override
	public List<SysEqpCategoryBean> queryMdCategory() throws Exception {
		String hql = "from SysEqpCategory o where 1=1 and o.enable=1 and o.del=0";
		List<SysEqpCategoryBean> mdeqpcategropbean=beanConvertor.copyList(sysEqpCategoryDao.query(hql, new Object[]{}), SysEqpCategoryBean.class);
		return mdeqpcategropbean;
	}

	@LogAnno(operateType = "修改设备类型")
	@Override
	public void updateCategory(SysEqpCategoryBean mdEqpCategoryBean) throws Exception {
		mdEqpCategoryBean.setDel("0");
		SysEqpCategory o = BeanConvertor.copyProperties(mdEqpCategoryBean, SysEqpCategory.class);
		SysEqpCategory sysEqpCategory = sysEqpCategoryDao.findById(SysEqpCategory.class, mdEqpCategoryBean.getId());
		BeanConvertor.copyProperties(o,sysEqpCategory);
		FillUserInfoUtil.fillUpdateUserInfo(sysEqpCategory,request);
		sysEqpCategoryDao.saveOrUpdate(sysEqpCategory);
		//comboboxServiceI.initCombobox(ComboboxType.EQPCATEGORY);
	}
	

	@Override
	public DocFilemanage fileUpdate(String otherTableId,HttpSession session, HttpServletRequest request,
			SysEqpCategoryBean fmBean) throws Exception {
		request.setCharacterEncoding("utf-8");
		SessionInfo sessionInfo = (SessionInfo) session.getAttribute("sessionInfo");
		//获取文件名
		String[] fileUrls = (String[])request.getParameterValues("fileUrl")[0].split(",");
		String[] fileNames = (String[])request.getParameterValues("fileName")[0].split(",");
		//删除原有图片 保证图片唯一
		String updateSql ="update DOC_FILEMANAGE set IS_DELETED=1  where TABLE_ZJ_ID=? ";
		List<Object> objs = new ArrayList<Object>();
		objs.add(otherTableId);
		docFileManageDao.updateBySql(updateSql, objs);
		
		Long l = Long.valueOf(request.getParameter("securityLevel"));
		DocFilemanage file = null;
		for (int i = 0; i < fileUrls.length; i++) {//这里应该只有一张图片上传
			String uuIdKey = UUID.randomUUID().toString() ;
			file = new DocFilemanage();
			file.setAttr1(fmBean.getImagesVersion());//版本号
			file.setCreatePersonId(sessionInfo.getUser().getId());//新增用户
			file.setCreateName(sessionInfo.getUser().getName());
			file.setCreateTime(new Date());
			file.setIsDeleted("0");
			file.setSecurityLevel(l);
			file.setFileId(fileUrls[i]);
			file.setFileName(fileNames[i].substring(0,fileNames[i].lastIndexOf(".")));
			file.setFileType(fileUrls[i].substring(fileUrls[i].lastIndexOf(".")+1));
			file.setId(uuIdKey);
			file.setTableZjId(otherTableId);
			String key = docFileManageDao.saveBackKey(file);
			file.setId(key);
			file.setTableZjId(otherTableId);
		}
		//更新它下面的 所有子项为 null
		updateSql ="update SYS_EQP_TYPE set SET_IMAGE_POINT=null  where CID=? and DEL=0 ";
		objs = new ArrayList<Object>();
		objs.add(otherTableId);
		docFileManageDao.updateBySql(updateSql, objs);
		return file;
	}
	@Override
	public int updateCategory(DocFilemanage file){
		//回写主表 主键 和 上传的地址
		String updateSql ="update SYS_EQP_CATEGORY set UPLOAD_ID=? where ID=? ";
		List<Object> prams = new ArrayList<Object>();
		prams.add(file.getId());prams.add(file.getTableZjId());
		return docFileManageDao.updateBySql(updateSql, prams);
	}

	@Override
	public void batchDeleteMdCategory(String ids) {
		try {
			String[] split=ids.split(",");
			for (int i = 0; i < split.length; i++) {
				String id = split[i];
				String sql = "delete from SYS_EQP_CATEGORY where ID='"+id+"'";
				sysEqpCategoryDao.updateBySql(sql, null);
				String typesql = "delete from SYS_EQP_TYPE where CID='"+id+"'";
				sysEqpCategoryDao.updateBySql(typesql, null);
			}
			comboboxServiceI.initCombobox(ComboboxType.EQPCATEGORY);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}


}