package com.shlanbao.tzsc.pms.equ.eqpMaintain.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
import javax.servlet.http.HttpSession;
|
|
import com.shlanbao.tzsc.utils.tools.LogAnno;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.EqmWheelCovelParamDaoI;
|
import com.shlanbao.tzsc.base.dao.EqmWheelCovelPlanDaoI;
|
import com.shlanbao.tzsc.base.interceptor.WorkOrderStatChangeInterceptor;
|
import com.shlanbao.tzsc.base.mapping.EqmWheelCovelParam;
|
import com.shlanbao.tzsc.base.mapping.EqmWheelCovelPlanInfo;
|
import com.shlanbao.tzsc.base.model.DataGrid;
|
import com.shlanbao.tzsc.base.model.Json;
|
import com.shlanbao.tzsc.base.model.PageParams;
|
import com.shlanbao.tzsc.base.model.SessionInfo;
|
import com.shlanbao.tzsc.pms.equ.eqpMaintain.service.EqpMaintainServiceI;
|
import com.shlanbao.tzsc.pms.sys.repairResquest.beans.RepairResquestBean;
|
import com.shlanbao.tzsc.pms.sys.user.beans.UserBean;
|
import com.shlanbao.tzsc.utils.tools.StringUtil;
|
|
@Service
|
public class EqpMaintainServiceImpl implements EqpMaintainServiceI {
|
@Autowired
|
private EqmWheelCovelPlanDaoI eqmWheelCovelPlanDao;
|
@Autowired
|
private EqmWheelCovelParamDaoI eqmWheelCovelParamDao;
|
|
/**
|
* 【功能说明】：PMS设备保养计划-查询
|
* @author wanchanghuang
|
* @time 2017年12月7日10:42:08
|
*/
|
@Override
|
public DataGrid queryEqmMaintainPlan(EqmWheelCovelPlanInfo wcpBean, PageParams pageParams) {
|
StringBuilder hql=new StringBuilder();
|
hql.append("from EqmWheelCovelPlanInfo o where o.del=0 ");
|
//维保类型过滤
|
if(StringUtil.notNull(wcpBean.getType())){
|
hql.append("and o.type='"+wcpBean.getType()+"'");
|
}
|
//时间查询
|
if(StringUtil.notNull(wcpBean.getDate1())){
|
hql.append(" and o.plan_date >= to_date('"+wcpBean.getDate1()+"','yyyy-MM-dd')");
|
}
|
if(StringUtil.notNull(wcpBean.getDate2())){
|
hql.append(" and o.plan_date <= to_date('"+wcpBean.getDate2()+"','yyyy-MM-dd')");
|
}
|
if(StringUtil.notNull(wcpBean.getEqpType())){
|
hql.append(" and o.eqp_name like '%"+wcpBean.getEqpType()+"%'");
|
}
|
if(StringUtil.notNull(wcpBean.getEqp_id())){
|
hql.append(" and o.eqp_id like '%"+wcpBean.getEqp_id()+"%'");
|
}
|
if(StringUtil.notNull(wcpBean.getAttr1())){
|
hql.append(" and o.attr1 =" + wcpBean.getAttr1());
|
}
|
if(StringUtil.notNull(wcpBean.getAttr2())){
|
hql.append(" and o.shift_id =" + wcpBean.getAttr2());
|
}
|
if(wcpBean.getSh_status()!=null&&wcpBean.getSh_status()>=0){
|
hql.append(" and o.sh_status =" + wcpBean.getSh_status());
|
}
|
List<EqmWheelCovelPlanInfo> list = eqmWheelCovelPlanDao.queryByPage(hql.toString(), pageParams);
|
hql.insert(0,"select count(*) ");
|
long total = eqmWheelCovelPlanDao.queryTotal(hql.toString());
|
return new DataGrid(list,total);
|
}
|
|
/**
|
* 查询维保计划详细
|
*/
|
@Override
|
public DataGrid queryplanDetail(EqmWheelCovelParam bean) {
|
|
StringBuffer sb=new StringBuffer();
|
sb.append("select t.*,nvl(d.COMPLETE_STATUS,0) as complete_status,d.des as paraDes,d.check_result,d.COMPLETEBY from (");
|
if(bean!=null){
|
if(bean.getTeamName().equals("1")){
|
sb.append("selectb.ID,b.NUM,b.MAIN_MENU as mainMenu,b.MAIN_STANDARDS,(select name from SYS_ROLE where id = b.role_Id) as rolename," +
|
"c.id as planIdfrom SYS_EQP_CATEGORY a,EQM_WHEELCOVER b,EQM_WHEEL_COVEL_PLAN c ");
|
}else if(bean.getTeamName().equals("2")){
|
sb.append(" select b.ID,to_number(b.NUM) as num, b.LUB_METHOD,'',b.SPE_PERSON,c.id as planId "+
|
" from SYS_EQP_CATEGORY a,EQM_LUBRICATION b,EQM_WHEEL_COVEL_PLAN c ");
|
}else if (bean.getTeamName().equals("4")) {
|
sb.append("select b.ID,to_number(b.NUM) as num,b.CLEAN_METHOD, b.CLEAN_STANDARDS,b.SPE_PERSON,c.id as planId "+
|
" from SYS_EQP_CATEGORY a,EQM_MAINTENANCE b,EQM_WHEEL_COVEL_PLAN c ");
|
}else if(bean.getTeamName().equals("5")){
|
sb.append("select b.ID, to_number(b.NUM) as num, b.CHECK_METHOD,b.JUDGEMENT_STANDARD,b.SPE_PERSON,c.id as planId "+
|
" from SYS_EQP_CATEGORY a,EQM_INSPECTION b,EQM_WHEEL_COVEL_PLAN c");
|
}
|
}
|
sb.append(" where a.del=0 and b.enable=1 and a.enable=1 "
|
+"and a.id=b.sys_ec "
|
+" and c.attr1=a.cycle_type "
|
+"and c.attr2=a.cycle_num "
|
+" and a.maintainace_type= ? "
|
+"and a.eqp_type=(select eqp_type_id from MD_EQUIPMENT where del=0 and id=? and rownum=1)"
|
+"and c.id=? "
|
+") t LEFT JOIN EQM_WHEEL_COVEL_PARAM d on t.planId=d.EWCP_ID and t.num=d.job_no order by t.num");
|
|
List<EqmWheelCovelParam> list=new ArrayList<>();
|
try {
|
List<?> result=eqmWheelCovelPlanDao.queryBySql(sb.toString(),bean.getTeamName(),bean.getDes(),bean.getEwcpId());
|
Object[] obj=null;
|
EqmWheelCovelParam paramsBean=null;
|
for (Object object : result) {
|
obj=(Object[]) object;
|
paramsBean=new EqmWheelCovelParam();
|
paramsBean.setId(StringUtil.convertObjToString(obj[0]));
|
paramsBean.setJobNo(StringUtil.convertObjToString(obj[1]));
|
paramsBean.setMaintMethod(StringUtil.convertObjToString(obj[2]));
|
paramsBean.setJobStandard(StringUtil.convertObjToString(obj[3]));
|
paramsBean.setReviewer(StringUtil.convertObjToString(obj[4]));
|
//paramsBean.setJob_standard(StringUtil.convertObjToString(obj[4]));
|
paramsBean.setCompleteStatus(StringUtil.convertObjToString(obj[6]));
|
// paramsBean.setStatus(StringUtil.convert2Integer(obj[6]));
|
paramsBean.setCheckResult(StringUtil.convertObjToString(obj[8]));
|
paramsBean.setCompleteby(StringUtil.convertObjToString(obj[9]));
|
list.add(paramsBean);
|
}
|
return new DataGrid(list, 0L);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return new DataGrid(list , 0L);
|
}
|
|
/**
|
* 反馈设备维保计划
|
*/
|
@Override
|
public int dasSendEquipmentWorkOrderResult(String type, String ids) {
|
ids=ids.replaceAll(",", "','");//如： 1,2拼接成 1','2
|
StringBuilder hql=new StringBuilder(1000);
|
hql.append("from EqmWheelCovelPlanInfo o where 1=1 and o.del=0 and sh_status=1 and o.id in ('"+ids+"')");
|
List<EqmWheelCovelPlanInfo> list = eqmWheelCovelPlanDao.query(hql.toString());
|
//判断，如果没有完成不反馈
|
if(list==null || list.size()<1){
|
return 0;
|
}
|
hql.setLength(0);//清空
|
hql.append("from EqmWheelCovelParam t where 1=1 and t.del=0 and t.eqm_wcp_id in ('"+ids+"') ");
|
List<EqmWheelCovelParam> listParam = eqmWheelCovelParamDao.query(hql.toString());
|
List<String> fackIds=new ArrayList<>();
|
//调用封装XML方法
|
fackIds=WorkOrderStatChangeInterceptor.getInstance().dasSendEquipmentWorkOrderResult(list,listParam,fackIds);
|
EqmWheelCovelPlanInfo fackSuBean=null;
|
for (String id : fackIds) {
|
fackSuBean=eqmWheelCovelPlanDao.findById(EqmWheelCovelPlanInfo.class, id);
|
fackSuBean.setSh_status(5);
|
}
|
if(fackIds.size()==0){
|
return 0;
|
}else{
|
return 1;
|
}
|
}
|
|
/**
|
* 根据详细项id查询改对象
|
*/
|
@Override
|
public EqmWheelCovelParam queryDetailById(String id) {
|
EqmWheelCovelParam bean=new EqmWheelCovelParam();
|
bean.setId(id);
|
try {
|
DataGrid dataGrid=queryplanDetail(bean);
|
bean=(EqmWheelCovelParam) dataGrid.getRows().get(0);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return bean;
|
|
}
|
|
/**
|
* 修改设备维保详细项
|
*/
|
@Override
|
public void editParams(EqmWheelCovelParam bean,HttpSession session) throws Exception {
|
SessionInfo sessionInfo=(SessionInfo) session.getAttribute("sessionInfo");
|
UserBean user=sessionInfo.getUser();
|
String uid=user.getId();
|
String uname=user.getName();
|
/* bean.setDel(0);
|
bean.setActual_user_id(uid);
|
bean.setUpdate_time(new Date());
|
bean.setActual_user_name(uname);
|
bean.setLast_user_id(uid);
|
bean.setLast_time(new Date());*/
|
eqmWheelCovelParamDao.saveOrUpdate(bean);
|
}
|
|
/**
|
* 完成维保计划
|
*/
|
@LogAnno(operateType = "完成维保计划")
|
@Override
|
public void finishMainTainPlan(String id, HttpSession session) throws Exception{
|
SessionInfo sessionInfo=(SessionInfo) session.getAttribute("sessionInfo");
|
UserBean user=sessionInfo.getUser();
|
String uid=user.getId();
|
String uname=user.getName();
|
EqmWheelCovelPlanInfo bean=eqmWheelCovelPlanDao.findById(EqmWheelCovelPlanInfo.class, id);
|
bean.setSh_status(1);
|
bean.setLast_etime(new Date());
|
bean.setLast_stime(new Date());
|
bean.setZx_user_id(uid);
|
bean.setZx_user_name(uname);
|
eqmWheelCovelPlanDao.save(bean);
|
}
|
|
/**
|
* 选择维修工，用于维修呼叫
|
*/
|
@Override
|
public DataGrid callMaintenanceman() {
|
RepairResquestBean bean=null;
|
List<RepairResquestBean> beans=new ArrayList<>();
|
StringBuffer sb=new StringBuffer();
|
String queryFiled="USER_ID,USER_NAME,TYPE_ID,TYPE_NAME,PATH,EQP_TYPE,TEAM_ID,STATUS,SHIFT_ID";
|
sb.append(" SELECT queryFiled from SYS_MAINTENANCE_STAFF ");
|
List<?> ls=eqmWheelCovelPlanDao.queryBySql(sb.toString().replaceAll("queryFiled", "count(*)"));
|
long total=StringUtil.converObj2Long(ls.get(0));
|
if(total>0){
|
ls=eqmWheelCovelPlanDao.queryBySql(sb.toString().replaceAll("queryFiled", queryFiled));
|
Object[] obj=null;
|
for (Object object : ls) {
|
obj=(Object[]) object;
|
bean=new RepairResquestBean();
|
bean.setUserId(StringUtil.convertObjToString(obj[0]));
|
bean.setUserName(StringUtil.convertObjToString(obj[1]));
|
bean.setTypeId(StringUtil.convertObjToString(obj[2]));
|
bean.setTypeName(StringUtil.convertObjToString(obj[3]));
|
bean.setPath(StringUtil.convertObjToString(obj[4]));
|
bean.setEqpType(StringUtil.convertObjToString(obj[5]));
|
bean.setTeamId(StringUtil.convertObjToString(obj[6]));
|
bean.setStatus(StringUtil.convertObjToString(obj[7]));
|
bean.setShiftId(StringUtil.convertObjToString(obj[8]));
|
beans.add(bean);
|
}
|
}
|
return new DataGrid(beans, total);
|
}
|
|
/**
|
* 添加维修呼叫记录
|
*/
|
@Override
|
public Json addCallInfo(String id, String rId,String rName,String rType,HttpSession session) {
|
Json json=new Json();
|
try {
|
SessionInfo sessionInfo=(SessionInfo) session.getAttribute("sessionInfo");
|
UserBean user=sessionInfo.getUser();
|
String uid=user.getId();
|
String uname=user.getName();
|
StringBuffer sb=new StringBuffer();
|
List<Object> params=new ArrayList<>();
|
//根据维保计划id查询班次、班组、设备、工单等信息
|
sb.append(" SELECT a.EQP_ID,a.eqp_name,a.SHIFT_ID,b.TEAM,b.id ");
|
sb.append(" from ");
|
sb.append(" EQM_WHEEL_COVEL_PLAN a LEFT JOIN SCH_WORKORDER b ON a.EQP_ID=b.EQP AND a.PLAN_STIME BETWEEN b.STIM AND b.ETIM where a.id='"+id+"'");
|
List<?> ls=eqmWheelCovelPlanDao.queryBySql(sb.toString());
|
if(ls!=null && ls.size()>0){
|
Object[] obj=(Object[]) ls.get(0);
|
//添加维修呼叫记录,
|
sb.setLength(0);
|
sb.append("INSERT INTO SYS_SERVICE_INFO (ID, SHIFT_ID, TEAM_ID, EQP_ID, EQP_NAME, CREATE_USER_TIME, CREATE_USER_NAME,CREATE_USER_ID,DESIGNATED_PERSON_ID,DESIGNATED_PERSON_NAME,TYPE_NAME,STATUS, WORKORDER_ID,DEL, MES_ID) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
|
params.add(UUID.randomUUID().toString());
|
params.add(StringUtil.convertObjToString(obj[2]));//shift
|
params.add(StringUtil.convertObjToString(obj[3]));//team
|
params.add(StringUtil.convertObjToString(obj[0]));//eqpId
|
params.add(StringUtil.convertObjToString(obj[1]));//eqpName
|
params.add(new Date());//创建时间
|
params.add(uname);//创建人
|
params.add(uid);//创建人id
|
params.add(rId);//呼叫维修工id
|
params.add(rName);//呼叫维修工名
|
params.add(rType);//维修类型
|
params.add("0");//状态
|
params.add(StringUtil.convertObjToString(obj[4]));//工单id
|
params.add(0);//del
|
params.add(id);//MES维保工单id
|
eqmWheelCovelPlanDao.updateBySql(sb.toString(), params);
|
//修改维修工状态为忙碌
|
sb.setLength(0);
|
sb.append(" UPDATE SYS_MAINTENANCE_STAFF SET STATUS='"+1+"' where user_id='"+rId+"'");
|
eqmWheelCovelPlanDao.updateBySql(sb.toString(),null);
|
json.setSuccess(true);
|
json.setMsg("维修呼叫成功！");
|
}else{
|
json.setMsg("没有查询到当前维保工单对应的工单等信息");
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
json.setMsg("维修呼叫添加失败！");
|
}
|
return json;
|
}
|
@LogAnno(operateType = "删除维保计划")
|
@Override
|
public int delMainTainPlan(String id) {
|
String[] ids = id.split(",");
|
int rows=0;
|
for(int i=0;i<ids.length;i++){
|
rows= eqmWheelCovelPlanDao.deleteById(ids[i], EqmWheelCovelPlanInfo.class);
|
}
|
return rows;
|
}
|
|
@LogAnno(operateType = "完成/反馈维保项撤回")
|
@Override
|
public int recallParam(String id) {
|
String[] ids = id.split(",");
|
int rows=0;
|
for(int i=0;i<ids.length;i++){
|
rows += eqmWheelCovelParamDao.deleteById(ids[i], EqmWheelCovelParam.class);
|
}
|
return rows;
|
}
|
|
/**
|
* [功能说明]:设备 保养工单详细
|
* 1. 轮保 2 润滑 3 停产检修 4 周期性保养 5 点检
|
* */
|
@Override
|
public DataGrid queryMaintainInfo(EqmWheelCovelParam bean) {
|
StringBuffer sb=new StringBuffer();
|
sb.append("select t.*,nvl(d.COMPLETE_STATUS,0) as complete_status,d.des as paraDes,d.check_result,d.COMPLETEBY,d.id as paramId from (");
|
if(bean!=null){
|
if(bean.getTeamName().equals("1")){
|
sb.append("select b.ID,b.NUM,b.MAIN_MENU as mainMenu,b.MAIN_STANDARDS,(select name from SYS_ROLE where id = b.role_Id) as rolename," +
|
"c.id as planId from SYS_EQP_CATEGORY a,EQM_WHEELCOVER b,EQM_WHEEL_COVEL_PLAN c ");
|
}else if(bean.getTeamName().equals("2")){
|
sb.append(" select b.ID,to_number(b.NUM) as num, b.LUB_METHOD,b.LUB_POSITION,b.SPE_PERSON,c.id as planId "+
|
" from SYS_EQP_CATEGORY a,EQM_LUBRICATION b,EQM_WHEEL_COVEL_PLAN c ");
|
}else if (bean.getTeamName().equals("4")) {
|
sb.append("select b.ID,to_number(b.NUM) as num,b.CLEAN_METHOD, b.CLEAN_STANDARDS,b.SPE_PERSON,c.id as planId "+
|
" from SYS_EQP_CATEGORY a,EQM_MAINTENANCE b,EQM_WHEEL_COVEL_PLAN c ");
|
}else if(bean.getTeamName().equals("5")){
|
sb.append("select b.ID, to_number(b.NUM) as num, b.CHECK_METHOD,b.JUDGEMENT_STANDARD,b.SPE_PERSON,c.id as planId "+
|
" from SYS_EQP_CATEGORY a,EQM_INSPECTION b,EQM_WHEEL_COVEL_PLAN c ");
|
}
|
}
|
sb.append(" where a.del=0 and a.enable=1 " );
|
if("1".equals(bean.getTeamName())){
|
sb.append(" and b.del=0 " );
|
}else{
|
sb.append(" and b.enable=1 " );
|
}
|
sb.append(" and a.id=b.sys_ec "
|
+" and c.attr1=a.cycle_type "
|
+" and c.attr2=a.cycle_num "
|
+ " and (c.shift_id = b.shift_id or b.shift_id is null or b.shift_id = 0) "
|
+" and a.maintainace_type= ? "
|
+" and a.eqp_type=(select eqp_type_id from MD_EQUIPMENT where del=0 and id=? and rownum=1) "
|
+" and c.id=? "
|
+") t LEFT JOIN EQM_WHEEL_COVEL_PARAM d on t.planId=d.EWCP_ID and t.num=d.job_no order by t.num");
|
|
List<EqmWheelCovelParam> list=new ArrayList<>();
|
try {
|
List<?> result=eqmWheelCovelPlanDao.queryBySql(sb.toString(),bean.getTeamName(),bean.getDes(),bean.getEwcpId());
|
Object[] obj=null;
|
EqmWheelCovelParam paramsBean=null;
|
for (Object object : result) {
|
obj=(Object[]) object;
|
paramsBean=new EqmWheelCovelParam();
|
paramsBean.setId(StringUtil.convertObjToString(obj[10]));
|
paramsBean.setJobNo(StringUtil.convertObjToString(obj[1]));
|
paramsBean.setMaintMethod(StringUtil.convertObjToString(obj[2]));
|
paramsBean.setJobStandard(StringUtil.convertObjToString(obj[3]));
|
paramsBean.setReviewer(StringUtil.convertObjToString(obj[4]));
|
//paramsBean.setJob_standard(StringUtil.convertObjToString(obj[4]));
|
paramsBean.setCompleteStatus(StringUtil.convertObjToString(obj[6]));
|
// paramsBean.setStatus(StringUtil.convert2Integer(obj[6]));
|
paramsBean.setCheckResult(StringUtil.convertObjToString(obj[8]));
|
paramsBean.setCompleteby(StringUtil.convertObjToString(obj[9]));
|
list.add(paramsBean);
|
}
|
return new DataGrid(list, 0L);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return new DataGrid(list , 0L);
|
}
|
|
}
|
