package com.shlanbao.tzsc.pms.md.eqptype.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.UUID;
|
|
import org.apache.commons.lang.ObjectUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.MdEqpTypeChildDaoI;
|
import com.shlanbao.tzsc.base.mapping.MdEqpTypeChild;
|
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.plugin.service.LoadComboboxServiceI;
|
import com.shlanbao.tzsc.pms.md.eqptype.beans.MdEqpTypeChildBean;
|
import com.shlanbao.tzsc.pms.md.eqptype.service.MdEqpTypeChildServiceI;
|
import com.shlanbao.tzsc.utils.tools.StringUtil;
|
/**
|
*
|
* @author luther.zhang
|
*
|
*/
|
@Service
|
public class MdEqpTypeChildServiceImpl extends BaseService implements MdEqpTypeChildServiceI {
|
@Autowired
|
private MdEqpTypeChildDaoI mdEqpTypeChildDao;
|
@Autowired
|
private LoadComboboxServiceI comboboxServiceI;
|
|
@Override
|
public DataGrid queryMdTypeChild(MdEqpTypeChildBean mdTypeBean, PageParams pageParams) throws Exception {
|
String countSql ="select count(temp1.id) len ";
|
String rowNumberSql ="select ROWNUM as rownumber,";
|
String titleSql = "select temp1.id as SECID,temp1.CODE,temp1.NAME,temp2.id,temp2.SEC_PID,temp2.MET_PID,TYPE ";
|
|
StringBuffer temp1=new StringBuffer();
|
temp1.append(titleSql).append(" from ( ")
|
.append(rowNumberSql).append(" c.* from SYS_EQP_CATEGORY c where del=0 ");
|
//根据名称 模糊查询
|
if(null!=mdTypeBean.getQueryName()&&!"".equals(mdTypeBean.getQueryName())){
|
temp1.append("and name like '%"+mdTypeBean.getQueryName().trim()+"%' ");
|
}
|
temp1.append(")temp1 left join ( ")
|
.append(" select * from MD_EQP_TYPE_child where del=0 ");
|
if(null!=mdTypeBean.getQueryId()&&!"".equals(mdTypeBean.getQueryId())){
|
temp1.append("and MET_PID='"+mdTypeBean.getQueryId().trim()+"' ");
|
}
|
if(null!=mdTypeBean.getQueryType()&&!"".equals(mdTypeBean.getQueryType())){
|
temp1.append("and TYPE='"+mdTypeBean.getQueryType()+"' ");
|
}
|
temp1.append(" )temp2 on temp1.id = temp2.sec_pid ");
|
|
String lastSql = temp1.toString().replaceAll(titleSql,countSql);
|
lastSql = lastSql.replaceAll(rowNumberSql, "select ");
|
List<?> list = mdEqpTypeChildDao.queryBySql(lastSql, null);//只会有一条记录
|
long total= 0;//总记录数
|
List<MdEqpTypeChildBean> lastList = new ArrayList<MdEqpTypeChildBean>();
|
if(null!=list&&list.size()>0){
|
Object arr=(Object) list.get(0);//返回一个对象，而不是 一组数组
|
total =Long.parseLong(ObjectUtils.toString(arr));
|
}
|
if(total>0){
|
temp1.append(" where rownumber>"+(pageParams.getPage()-1)*pageParams.getRows()
|
+" and rownumber<="+(pageParams.getPage()*pageParams.getRows())+" ");//分页
|
lastSql = temp1.toString();
|
//System.out.println(lastSql);
|
list = mdEqpTypeChildDao.queryBySql(lastSql, null);
|
if(null!=list&&list.size()>0){
|
MdEqpTypeChildBean childBean = null;
|
for(int i=0;i<list.size();i++){
|
childBean = new MdEqpTypeChildBean();
|
Object[] arr=(Object[]) list.get(i);
|
childBean.setSecId(ObjectUtils.toString(arr[0]));
|
childBean.setSecCode(ObjectUtils.toString(arr[1]));
|
childBean.setSecName(ObjectUtils.toString(arr[2]));
|
String metcId = ObjectUtils.toString(arr[3]);
|
childBean.setMetcId(metcId);//这个是 绑定表中的主键
|
childBean.setIsCheck("false");
|
if(null!=metcId&&metcId.length()>0){
|
childBean.setIsCheck("true");
|
}
|
childBean.setSecPid(ObjectUtils.toString(arr[4]));
|
childBean.setMetPid(ObjectUtils.toString(arr[5]));
|
childBean.setType(ObjectUtils.toString(arr[6]));
|
lastList.add(childBean);
|
}
|
}
|
}
|
return new DataGrid(lastList, total);
|
}
|
|
/**
|
* 新增 或 删除 绑定的 轮保大类项
|
* @param type
|
* @param beans
|
* @throws Exception
|
*/
|
public void saveMdTypeChild(String type,MdEqpTypeChildBean[] beans) throws Exception{
|
if(null!=beans&&beans.length>0){
|
for(MdEqpTypeChildBean bean : beans){
|
String key = bean.getMetcId();
|
if(null!=key&&!"".equals(key)){//存在就更新DEL=0
|
//更新
|
StringBuffer temp = new StringBuffer();
|
temp.append("update MD_EQP_TYPE_CHILD set DEL=? where ID=? ");
|
List<Object> params = new ArrayList<Object>();
|
params.add(bean.getDel());
|
params.add(key);
|
mdEqpTypeChildDao.updateInfo(temp.toString(),params);
|
}else{//新增一条记录
|
//是不是 曾经保存过，如果是 更新下
|
StringBuffer temp = new StringBuffer();
|
List<Object> params = new ArrayList<Object>();
|
//直接更新
|
temp.append("update MD_EQP_TYPE_CHILD set DEL=? where SEC_PID=? and MET_PID=? and TYPE=? ");
|
params.add("0");params.add(bean.getSecPid());
|
params.add(bean.getMetPid());params.add(bean.getType());
|
int count = mdEqpTypeChildDao.updateBySql(temp.toString(),params);
|
if(count<=0){
|
String id = UUID.randomUUID().toString();
|
temp = new StringBuffer();
|
temp.append("insert into MD_EQP_TYPE_CHILD(")
|
.append("ID,DEL,SEC_PID,MET_PID,TYPE) values(?,?,?,?,?) ");
|
params = new ArrayList<Object>();
|
params.add(id);
|
params.add(bean.getDel());
|
params.add(bean.getSecPid());
|
params.add(bean.getMetPid());
|
params.add(bean.getType());
|
mdEqpTypeChildDao.updateInfo(temp.toString(),params);
|
}
|
}
|
}
|
}
|
}
|
/**
|
* 取消绑定的 轮保大类项
|
* @param type
|
* @param beans
|
* @throws Exception
|
*/
|
public void editMdTypeChild(String type,MdEqpTypeChildBean[] beans) throws Exception{
|
if(null!=beans&&beans.length>0){
|
for(MdEqpTypeChildBean bean : beans){
|
String key = bean.getMetcId();//更新
|
StringBuffer temp = new StringBuffer();
|
temp.append("update MD_EQP_TYPE_CHILD set DEL=? where ID=? ");
|
List<Object> params = new ArrayList<Object>();
|
params.add(bean.getDel());
|
params.add(key);
|
mdEqpTypeChildDao.updateInfo(temp.toString(),params);
|
}
|
}
|
}
|
/**
|
*
|
* @Title: getPaulbyEqpType
|
* @Description: 查询设备规程
|
* @param 设备类型Id
|
* @param 类型， 保养，润滑，点检
|
* @return void 返回类型
|
* @throws
|
*/
|
@Override
|
public List<MdEqpTypeChildBean> getPaulbyEqpType(String eqpTypeId,String type){
|
StringBuffer sql=new StringBuffer();
|
sql.append("select sec.ID,sec.NAME from MD_EQP_TYPE met left join MD_EQP_TYPE_CHILD mc on met.ID=mc.MET_PID ");
|
sql.append("left join SYS_EQP_CATEGORY sec on mc.SEC_PID=sec.ID ");
|
sql.append("where 1=1 and sec.del=0 and met.del=0 and mc.del=0");
|
if(StringUtil.notNull(eqpTypeId)){
|
//sql.append("and met.id = (select eqp_type_id from MD_EQUIPMENT where id='"+eqpTypeId+"') ");
|
sql.append("and met.id = '"+eqpTypeId+"' ");
|
}
|
if(StringUtil.notNull(type)){
|
sql.append("and mc.TYPE='"+type+"' ");
|
}
|
List<?> list = mdEqpTypeChildDao.queryBySql(sql.toString());//只会有一条记录
|
List<MdEqpTypeChildBean> returnList=new ArrayList<MdEqpTypeChildBean>();
|
for(int i=0;i<list.size();i++){
|
MdEqpTypeChildBean childBean = new MdEqpTypeChildBean();
|
Object[] arr=(Object[]) list.get(i);
|
childBean.setSecId(ObjectUtils.toString(arr[0]));
|
childBean.setSecName(ObjectUtils.toString(arr[1]));
|
returnList.add(childBean);
|
}
|
return returnList;
|
}
|
/**
|
*
|
* @Title: getPaulbyEqpType
|
* @Description: 查询设备规程
|
* @param 设备类型Id
|
* @param 类型， 保养，润滑，点检
|
* @return void 返回类型
|
* @throws
|
*/
|
@Override
|
public List<MdEqpTypeChildBean> getPaulbyEqp(String eqpId,String type){
|
StringBuffer sql=new StringBuffer();
|
sql.append("select sec.ID,sec.NAME from MD_EQP_TYPE met left join MD_EQP_TYPE_CHILD mc on met.ID=mc.MET_PID ");
|
sql.append("left join SYS_EQP_CATEGORY sec on mc.SEC_PID=sec.ID ");
|
sql.append("where 1=1 and sec.del=0 and met.del=0 and mc.del=0");
|
if(StringUtil.notNull(eqpId)){
|
sql.append("and met.id = (select eqp_type_id from MD_EQUIPMENT where id='"+eqpId+"') ");
|
}
|
if(StringUtil.notNull(type)){
|
sql.append("and mc.TYPE='"+type+"' ");
|
}
|
List<?> list = mdEqpTypeChildDao.queryBySql(sql.toString());//只会有一条记录
|
List<MdEqpTypeChildBean> returnList=new ArrayList<MdEqpTypeChildBean>();
|
for(int i=0;i<list.size();i++){
|
MdEqpTypeChildBean childBean = new MdEqpTypeChildBean();
|
Object[] arr=(Object[]) list.get(i);
|
childBean.setSecId(ObjectUtils.toString(arr[0]));
|
childBean.setSecName(ObjectUtils.toString(arr[1]));
|
returnList.add(childBean);
|
}
|
return returnList;
|
}
|
/**
|
* 根据设备ID查询对应的轮保规则
|
* @return
|
*/
|
@Override
|
public List<MdEqpTypeChildBean> queryEqpTypeChildByEqp(String eqpid,String type)throws Exception{
|
|
StringBuffer sql=new StringBuffer();
|
sql.append("select sec.id,sec.CODE, sec.NAME,metc.SEC_PID,metc.MET_PID,metc.TYPE,metc.ID as METC_ID ");
|
sql.append("from MD_EQP_TYPE_child metc left join SYS_EQP_CATEGORY sec on sec.id = metc.sec_pid ");
|
sql.append("left join MD_EQUIPMENT me on me.EQP_TYPE_ID = metc.MET_PID ");
|
sql.append("where metc.del=0 ");
|
if(null!=eqpid&&!"".equals(eqpid)){
|
sql.append("and me.id='"+eqpid+"' ");
|
}
|
if(null!=type&&!"".equals(type)){
|
sql.append("and metc.TYPE='"+type+"' ");
|
}
|
List<?> list = mdEqpTypeChildDao.queryBySql(sql.toString());
|
List<MdEqpTypeChildBean> lastList = new ArrayList<MdEqpTypeChildBean>();
|
if(null!=list&&list.size()>0){
|
MdEqpTypeChildBean childBean = null;
|
for(int i=0;i<list.size();i++){
|
childBean = new MdEqpTypeChildBean();
|
Object[] arr=(Object[]) list.get(i);
|
childBean.setSecId(ObjectUtils.toString(arr[0]));
|
childBean.setSecCode(ObjectUtils.toString(arr[1]));
|
childBean.setSecName(ObjectUtils.toString(arr[2]));
|
childBean.setSecPid(ObjectUtils.toString(arr[3]));
|
childBean.setMetPid(ObjectUtils.toString(arr[4]));
|
childBean.setType(ObjectUtils.toString(arr[5]));
|
childBean.setMetcId(ObjectUtils.toString(arr[6]));
|
lastList.add(childBean);
|
}
|
}
|
return lastList;
|
}
|
|
}
|
