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

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.ResourceBundle;
import java.util.UUID;

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 org.springframework.web.multipart.MultipartFile;

import com.shlanbao.tzsc.base.dao.SysMaintenanceStaffDaoI;
import com.shlanbao.tzsc.base.mapping.SysMaintenanceStaff;
import com.shlanbao.tzsc.base.model.DataGrid;
import com.shlanbao.tzsc.base.model.PageParams;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.pms.sys.repairResquest.beans.RepairResquestBean;
import com.shlanbao.tzsc.pms.sys.repairResquest.service.RepairResquestServiceI;
import com.shlanbao.tzsc.utils.tools.StringUtil;

@Service
public class RepairResquestServiceImpl extends BaseService implements RepairResquestServiceI{
	@Autowired
	protected SysMaintenanceStaffDaoI SysMaintenanceStaffDao;
	private static final ResourceBundle bundle = ResourceBundle.getBundle("config");
	private String imgPath=bundle.getString("service_url")+File.separator+bundle.getString("upload_img")+File.separator;//添加图片路径前缀
	/**
	 *
	 * 添加维修人员
	 *
	 * @author 景孟博
	 */
	@LogAnno(operateType = "新增维修人员")
	@Override
	public void addFixUser(RepairResquestBean repairResquestuserBean,MultipartFile file)throws Exception {
		//上传图片
		if(file!=null && file.getSize()>0){
			String fileName = file.getOriginalFilename();
			int index1=fileName.indexOf('.');
			String hz=fileName.substring(index1);
			String name=fileName.substring(0, index1+1).hashCode()+System.currentTimeMillis()+hz;
			byte[] b=new byte[1024];
			InputStream is=file.getInputStream();
		    String tomAdd=bundle.getString("save_url");
			String add1=bundle.getString("upload_img");
			File fl = new File(tomAdd+add1);
			fl.mkdirs();
			FileOutputStream os=new FileOutputStream(tomAdd+File.separator+add1+File.separator+name);//保存路径
			while(is.read(b, 0, b.length)!=-1){
				os.write(b);
			}
			is.close();
			os.close();
			//设置图片显示路径
			repairResquestuserBean.setPath(name);
		}
		StringBuffer sb = new StringBuffer();
		sb.append("INSERT into SYS_MAINTENANCE_STAFF (id,shift_id,user_id,user_name,remark,status,create_user_id,create_user_name,create_user_time,type_id,type_name,path,eqp_type,team_id,update_user_id,update_user_name,update_user_time)  VALUES('"+UUID.randomUUID().toString()+"'");
		if(StringUtil.notNull(repairResquestuserBean.getShiftId())){
			sb.append(",'"+repairResquestuserBean.getShiftId()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getUserId())){
			sb.append(",'"+repairResquestuserBean.getUserId()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getUserName())){
			sb.append(",'"+repairResquestuserBean.getUserName()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getRemark())){
			sb.append(",'"+repairResquestuserBean.getRemark()+"'");
		}else{
			sb.append(",NULL");
		}
		sb.append(",'0'");
		if(StringUtil.notNull(repairResquestuserBean.getCreateUserId())){
			sb.append(",'"+repairResquestuserBean.getCreateUserId()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getCreateUserName())){
			sb.append(",'"+repairResquestuserBean.getCreateUserName()+"'");
		}else{
			sb.append(",NULL");
		}
		sb.append(",SYSDATE");
		if(StringUtil.notNull(repairResquestuserBean.getTypeId())){
			sb.append(",'"+repairResquestuserBean.getTypeId()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getTypeId())){
			if(repairResquestuserBean.getTypeId().equals("1")){
				sb.append(",'机械维修工'");
				}else if(repairResquestuserBean.getTypeId().equals("2")){
					sb.append(",'电气维修工'");
				}else if(repairResquestuserBean.getTypeId().equals("3")){
					sb.append(",'电气维修工'");
				}
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getPath())){
			sb.append(",'"+repairResquestuserBean.getPath()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getEqpType())){
			sb.append(",'"+repairResquestuserBean.getEqpType()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getTeamId())){
			sb.append(",'"+repairResquestuserBean.getTeamId()+"'");
		}else{
			sb.append(",NULL");
		}
		//新增时以下修改信息与创建信息一致
		if(StringUtil.notNull(repairResquestuserBean.getCreateUserId())){
			sb.append(",'"+repairResquestuserBean.getCreateUserId()+"'");
		}else{
			sb.append(",NULL");
		}
		if(StringUtil.notNull(repairResquestuserBean.getCreateUserName())){
			sb.append(",'"+repairResquestuserBean.getCreateUserName()+"'");
		}else{
			sb.append(",NULL");
		}
		sb.append(",SYSDATE");
		sb.append(")");
		SysMaintenanceStaffDao.updateBySql(sb.toString(), null);
	}
	/**
	 *查询维修人员
	 * @author 景孟博
	 */
	@Override
	public DataGrid queryFixUser(RepairResquestBean repairResquestuserBean,PageParams pageParams)throws Exception{
		String userName="";
		String userId="";
		String shiftId="";
		/*if(isNameFuzzy && StringUtil.notNull(repairResquestuserBean.getUserName())){
			userName="user_name like'%"+repairResquestuserBean.getUserName()+"%'";
		}else */
		if(StringUtil.notNull(repairResquestuserBean.getUserName())){
			userName=" and ( user_name like '%"+repairResquestuserBean.getUserName().trim()+"%'";
			userId=" or eno ='"+repairResquestuserBean.getUserName().trim()+"' ) ";
		}
		if(StringUtil.notNull(repairResquestuserBean.getTeamId())){
			shiftId=" and team_id='"+repairResquestuserBean.getTeamId()+"' ";
		}
		if(StringUtil.notNull(repairResquestuserBean.getId())){
			shiftId=" and id='"+repairResquestuserBean.getId()+"' ";
		}
		StringBuffer sb = new StringBuffer();
		sb.append(" (select id,(SELECT name from MD_TEAM where id=team_id) as TeamName,(SELECT ENO from SYS_USER where ID=user_id) as ENO,user_name,remark,status,create_user_id,create_user_name,to_char(create_user_time,'yyyy-mm-dd hh24:mi:ss'),type_id,type_name,path,eqp_type,update_user_name,to_char(update_user_time,'yyyy-mm-dd hh24:mi:ss'),shift_id,team_id");
		sb.append(" from SYS_MAINTENANCE_STAFF");
		sb.append(" where 1=1 )");
		int page=pageParams.getPage();
		int row=pageParams.getRows();
	    String sql="select * from (select rownum bh,jmb.* from"+sb.toString()+"jmb where 1=1"+userName+userId+shiftId+") where 1=1 ";
		long total= 0;//总记录数
		List<?> count = SysMaintenanceStaffDao.queryBySql(sql, null);
		List<?> list = SysMaintenanceStaffDao.queryBySql(sql + " AND bh >  "+(page-1)*row+" AND bh <="+page*row, null);
		if(list.size()>0){
			int arr=count.size();//返回一个对象，而不是 一组数组
			total =Long.parseLong(ObjectUtils.toString(arr));
		}
		List<RepairResquestBean> beans = new ArrayList<RepairResquestBean>();
		if(total>0){
			RepairResquestBean bean = null;
		for(int i=0;i<list.size();i++){
			bean = new RepairResquestBean();
			Object[] arr=(Object[]) list.get(i);
			bean.setId(ObjectUtils.toString(arr[1]));//主键id
			bean.setTeamId(ObjectUtils.toString(arr[2]));
			bean.setEno(ObjectUtils.toString(arr[3]));
			bean.setUserName(ObjectUtils.toString(arr[4]));
			bean.setRemark(ObjectUtils.toString(arr[5]));
			bean.setStatus(ObjectUtils.toString(arr[6]));
			bean.setCreateUserId(ObjectUtils.toString(arr[7]));
			bean.setCreateUserName(ObjectUtils.toString(arr[8]));
			bean.setCreateUserTime(ObjectUtils.toString(arr[9]));
			bean.setTypeId(ObjectUtils.toString(arr[10]));
			bean.setTypeName(ObjectUtils.toString(arr[11]));
			bean.setPath(imgPath+ObjectUtils.toString(arr[12]));
			bean.setEqpType(ObjectUtils.toString(arr[13]));
			bean.setUpdateUserName(ObjectUtils.toString(arr[14]));
			bean.setUpdateUserTime(ObjectUtils.toString(arr[15]));
			bean.setShiftId(ObjectUtils.toString(arr[16]));
			beans.add(bean);
		  }
		 }
		return new DataGrid(beans, total);
		}

	/**
	 *
	 * 修改维修工信息
	 * @author 景孟博
	 * 更改人 石四海 2015-12-4
	 */
	@LogAnno(operateType = "编辑维修工信息")
	@Override
	public void updateFixUser(RepairResquestBean bean,MultipartFile file)throws Exception{
		SysMaintenanceStaff b=SysMaintenanceStaffDao.findById(SysMaintenanceStaff.class, bean.getId());
		if(b!=null){
			//上传图片
			if(file!=null&&!file.isEmpty()){
			    String tomAdd=bundle.getString("save_url");
				String add1=bundle.getString("upload_img");
				String name=null;
				if(StringUtil.notNull(b.getPath())){
					name=b.getPath();
					//删除原图片
					File f2=new File(tomAdd+File.separator+add1+File.separator+name);
					if(f2.exists()&&f2.isFile()){
						f2.delete();
					}
					//重新给文件起名
					String fileName = file.getOriginalFilename();
					int index1=fileName.indexOf('.');
					String hz=fileName.substring(index1);
					name=fileName.substring(0, index1+1).hashCode()+System.currentTimeMillis()+hz;
					//新图片名
					bean.setPath(name);
					byte[] bt=new byte[1024];
					InputStream is=file.getInputStream();
					FileOutputStream os=new FileOutputStream(tomAdd+File.separator+add1+File.separator+name);//保存路径
					while(is.read(bt, 0, bt.length)!=-1){
						os.write(bt);
					}
					is.close();
					os.close();
				}
			}
			//更新数据

			//图片路径
			if(StringUtil.notNull(bean.getPath())){
				b.setPath(bean.getPath());
			}
			//备注
			if(StringUtil.notNull(bean.getRemark())){
				b.setRemark(bean.getRemark());
			}
			//用户名
			if(StringUtil.notNull(bean.getUserName())){
				b.setUser_name(bean.getUserName());
			}
			if(StringUtil.notNull(bean.getUserId())){
				b.setUser_id(bean.getUserId());
			}
			//更新者
			if(StringUtil.notNull(bean.getUpdateUserId())){
				b.setUpdate_user_id(bean.getUpdateUserId());
			}
			if(StringUtil.notNull(bean.getUpdateUserName())){
				b.setUpdate_user_name(bean.getUpdateUserName());
			}
			//班组
			if(StringUtil.notNull(bean.getTeamId())){
				b.setTeam_id(bean.getTeamId());
			}
			//维修设备
			if(StringUtil.notNull(bean.getEqpType())){
				b.setEqp_type(bean.getEqpType());
			}
			//维修工类别
			if(StringUtil.notNull(bean.getTypeId())){
				b.setType_id(bean.getTypeId());
			}
			//状态
			if(StringUtil.notNull(bean.getStatus())){
				b.setStatus(bean.getStatus());
			}
			//更新时间
			b.setUpdate_user_time(new Date());
			SysMaintenanceStaffDao.update(b);

		}

	}


	/**
	 * 通过id查询维修工信息
	 *
	 * @author 景孟博
	 */
	@Override
	public RepairResquestBean getFixUserById(String id,String updateUsrId,String updateUserName)throws Exception{
		String sql = "select id,team_id,user_id,user_name,remark,type_id,type_name,path,eqp_type,(SELECT ENO from SYS_USER where ID=user_id) as ENO,status from sys_maintenance_staff where id='"+id+"'";
		List<?> lt = SysMaintenanceStaffDao.queryBySql(sql);
		if(lt.size()>0){
		Object[] o=(Object[]) lt.get(0);
		RepairResquestBean bean = new RepairResquestBean();
		bean.setId(StringUtil.convertObjToString(o[0]));
		bean.setTeamId(StringUtil.convertObjToString(o[1]));
		bean.setUserId(StringUtil.convertObjToString(o[2]));
		bean.setUserName(StringUtil.convertObjToString(o[3]));
		bean.setRemark(StringUtil.convertObjToString(o[4]));
		bean.setTypeId(StringUtil.convertObjToString(o[5]));
		bean.setTypeName(StringUtil.convertObjToString(o[6]));
		if(null!=o[7]){
			bean.setPath(imgPath+o[7].toString());
		}
		bean.setEqpType(StringUtil.convertObjToString(o[8]));
		bean.setEno(StringUtil.convertObjToString(o[9]));
		bean.setStatus(StringUtil.convertObjToString(o[10]));
		bean.setUpdateUserId(updateUsrId);
		bean.setUpdateUserName(updateUserName);
		return bean;
		}else{
			return null;
		}
	}

	/**
	 * 删除维修人信息
	 * @author 景孟博
	 */
	@LogAnno(operateType = "删除维修人员")
	@Override
	public void deleteFixUser(String id)throws Exception{
		String sql = "delete from sys_maintenance_staff where id ='"+id+"' ";
		SysMaintenanceStaffDao.updateBySql(sql, null);
	}


	/**
	 * 批量删除
	 * @author 景孟博
	 */
	@LogAnno(operateType = "批量删除工单")
	@Override
	public void batchDelete(String ids)throws Exception{
		for(String id : StringUtil.splitToStringList(ids, ",")){
			this.deleteFixUser(id);
		}
	}
	/**
	 * 查询wct维修呼叫处于等待状态的请求信息，用于推送消息
	 * shisihai
	 */
	@Override
	public List<RepairResquestBean> queryAskInfo() {
		List<RepairResquestBean> data=new ArrayList<RepairResquestBean>();
		String sql="SELECT (SELECT name from MD_SHIFT where id=shift_id) as shift_id ,(SELECT name from MD_TEAM where id=team_id) as team_name,eqp_name,create_user_name,to_char(create_user_time,'yyyy-mm-dd,hh24:mi:ss'),designated_person_name,type_name FROM sys_service_info WHERE status=0";
		List<?> ls=SysMaintenanceStaffDao.queryBySql(sql);
		RepairResquestBean bean=null;
		Object[] o=null;
		if(null!=ls&ls.size()>0){
			for (Object obj : ls) {
				bean=new RepairResquestBean();
				o=(Object[])obj;
				bean.setShiftName(StringUtil.convertObjToString(o[0]));//班次
				bean.setTeamName(StringUtil.convertObjToString(o[1]));//班组
				bean.setEqpName(StringUtil.convertObjToString(o[2]));//机台
				bean.setCreateUserName(StringUtil.convertObjToString(o[3]));//呼叫人
				bean.setCreateUserTime(StringUtil.convertObjToString(o[4]));//呼叫时间
				bean.setUserName(StringUtil.convertObjToString(o[5]));//维修工姓名
				bean.setTypeName(StringUtil.convertObjToString(o[6]));//维修工类别
				data.add(bean);
			}
		}
		return data;
	}
}