package com.shlanbao.tzsc.pms.equ.sbglplan.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
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.EqmWheelCovelParamDaoI;
|
import com.shlanbao.tzsc.base.dao.EqmWheelCovelPlanDaoI;
|
import com.shlanbao.tzsc.base.dao.EqmipmentsDaoI;
|
import com.shlanbao.tzsc.base.mapping.EqmWheelCovelParam;
|
import com.shlanbao.tzsc.base.mapping.EqmWheelCovelPlan;
|
import com.shlanbao.tzsc.base.mapping.MdEquipment;
|
import com.shlanbao.tzsc.base.mapping.MdShift;
|
import com.shlanbao.tzsc.base.mapping.SysUser;
|
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.equ.sbglplan.beans.EqmPlanBean;
|
import com.shlanbao.tzsc.pms.equ.sbglplan.beans.EquipmentsBean;
|
import com.shlanbao.tzsc.pms.equ.sbglplan.service.EqmPlanServiceI;
|
import com.shlanbao.tzsc.pms.equ.wcplan.beans.BatchWCPlan;
|
import com.shlanbao.tzsc.pms.md.eqptype.beans.MdEqpTypeChildBean;
|
import com.shlanbao.tzsc.utils.tools.BeanConvertor;
|
import com.shlanbao.tzsc.utils.tools.DateUtil;
|
import com.shlanbao.tzsc.utils.tools.StringUtil;
|
|
@Service
|
public class EqmPlanServiceImpl extends BaseService implements EqmPlanServiceI {
|
|
@Autowired
|
private EqmWheelCovelPlanDaoI eqmWheelCovelPlanDao;
|
|
@Autowired
|
private EqmWheelCovelParamDaoI eqmWheelCovelParamDao;
|
|
@Autowired
|
private EqmipmentsDaoI equipmentsDao;
|
|
@Override
|
public DataGrid queryEqu(EquipmentsBean equBean, PageParams pageParams) throws Exception {
|
//hql 语句拼装
|
String hql = "from MdEquipment o "
|
+ "left join fetch o.mdEqpType met "
|
+ "left join fetch met.mdEqpCategory mc "
|
+ "where 1=1 and o.del=0 ";
|
StringBuffer params = new StringBuffer();
|
if(StringUtil.notNull(equBean.getEquipmentCode())){
|
params.append(" and o.equipmentCode like '%"+ equBean.getEquipmentCode() +"%'");
|
}
|
if(StringUtil.notNull(equBean.getEquipmentName())){
|
params.append(" and o.equipmentName like '%"+ equBean.getEquipmentName() +"%'");
|
}
|
//加入两个条件
|
if(StringUtil.notNull(equBean.getWorkShopId())){
|
params.append(" and o.mdWorkshop.id='"+ equBean.getWorkShopId() +"'");
|
}
|
|
if(StringUtil.notNull(equBean.getWorkShopName())){//1卷包车间2成型车间也是对象id
|
params.append(" and o.mdWorkshop.id='"+equBean.getWorkShopName()+"'");
|
}
|
|
if(StringUtil.notNull(equBean.getEqpTypeName())){//传进来Id根据对象比较
|
params.append(" and o.mdEqpType.id='"+equBean.getEqpTypeName()+"'");
|
}
|
|
String param = params.toString();
|
List<MdEquipment> rows = equipmentsDao.queryByPage(hql.concat(param), pageParams);
|
List<EquipmentsBean> equBeans = new ArrayList<EquipmentsBean>();
|
for(MdEquipment me : rows){
|
String typeId = me.getMdEqpType().getId();
|
String typeName = me.getMdEqpType().getName();
|
EquipmentsBean eb = new EquipmentsBean();
|
BeanConvertor.copyProperties(me, eb);
|
eb.setEqpTypeId(typeId);
|
eb.setEqpTypeName(typeName);
|
if(null!=me.getMdWorkshop()){
|
eb.setWorkShopId(me.getMdWorkshop().getId());
|
eb.setWorkShopName(me.getMdWorkshop().getName());
|
}
|
if(null!=me.getMdEqpType()&&null!=me.getMdEqpType().getMdEqpCategory()){
|
eb.setMdEqpCategoryId(me.getMdEqpType().getMdEqpCategory().getId());//设备类型
|
eb.setMdEqpCategoryCode(me.getMdEqpType().getMdEqpCategory().getCode());//设备类型
|
eb.setMdEqpCategoryName(me.getMdEqpType().getMdEqpCategory().getName());//设备类型
|
}
|
equBeans.add(eb);
|
}
|
hql = "select count(*) from MdEquipment o where 1=1 and o.del=0 ";
|
long total = equipmentsDao.queryTotal(hql.concat(param));
|
return new DataGrid(equBeans,total);
|
}
|
/**
|
* 根据设备型号ID查询对应的轮保规则
|
* @return
|
*/
|
@Override
|
public DataGrid queryEqpTypeChild(EquipmentsBean equBean,PageParams pageParams)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("where metc.del=0 and metc.MET_PID=? ");
|
List<Object> objs = new ArrayList<Object>();
|
objs.add(equBean.getQueryEqpTypeId());
|
if(null!=equBean.getQueryType()&&!"".equals(equBean.getQueryType())){
|
sql.append("and metc.TYPE=? ");
|
objs.add(equBean.getQueryType());
|
}
|
List<?> list = eqmWheelCovelPlanDao.queryBySql(sql.toString(), objs);
|
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 new DataGrid(lastList, 100L);
|
}
|
|
|
@Override
|
public EqmWheelCovelPlan addWCPlan(EqmPlanBean wcpBean, String userId) throws Exception {
|
EqmWheelCovelPlan wcp = new EqmWheelCovelPlan();
|
wcp.setId(UUID.randomUUID().toString());
|
|
SysUser addUser = new SysUser();
|
addUser.setId(userId);
|
wcp.setSysUserByCreateId(addUser);//创建人
|
|
MdEquipment mdEquipment = new MdEquipment();//设备
|
mdEquipment.setId(wcpBean.getEquipmentId());//设备ID,设备主数据中的ID
|
wcp.setMdEquipment(mdEquipment);
|
|
MdShift mdShift = new MdShift();//班次
|
mdShift.setId(wcpBean.getMdShiftId());
|
wcp.setMdShift(mdShift);
|
wcp.setPlanNo(StringUtil.trim(wcpBean.getPlanCode()));//计划编号
|
wcp.setPlanName(StringUtil.trim(wcpBean.getPlanName()));//计划名称
|
|
wcp.setScheduleDate(DateUtil.strToDate(wcpBean.getScheduleDate(), "yyyy-MM-dd"));//计划日期
|
wcp.setScheduleStrDate(wcpBean.getScheduleDate());//计划日期
|
wcp.setScheduleEndDate(DateUtil.strToDate(wcpBean.getScheduleDate(), "yyyy-MM-dd"));//计划结束时间
|
wcp.setMaintenanceLength(wcpBean.getEquipmentMinute());//计划时长
|
wcp.setMaintenanceContent(StringUtil.trim(wcpBean.getMaintenanceContent()));//计划内容
|
wcp.setPlanner(userId);//制单人
|
wcp.setMaintenanceType(wcpBean.getMaintenanceType());//计划类型
|
wcp.setWheelParts(wcpBean.getMetcId());//轮保部件
|
wcp.setCreateDate(new Date());//创建日期
|
wcp.setWheelCoverType(wcpBean.getWheelCoverType());//工单状态 类型
|
wcp.setDel(wcpBean.getDel());
|
wcp.setMdMatId(wcpBean.getMatId());//牌号
|
//private String period;//周期
|
//private String remindCycle;//提醒周期
|
//private String dutyPeopleName;//责任人id
|
//private Date endMaintainDate;//最后维修日期
|
//private String locationCode;//车间代码
|
//private SysUser sysUserByDutyPeopleId;//责任人
|
//private Date startTime;//实际开始时间
|
//private Date endTime;//实际结束时间
|
//eqmWheelCovelPlanDao.save(wcp);
|
return wcp;
|
}
|
/**
|
* 添加计划对应的设备
|
* @param planBean
|
* @throws Exception
|
*/
|
@Override
|
public void addEqmWheelCovelParam(EqmWheelCovelPlan planBean,String ruleId) throws Exception{
|
//新增保修项
|
StringBuffer insertSql = new StringBuffer();
|
insertSql.append(" insert into EQM_WHEEL_COVEL_PARAM ");
|
insertSql.append(" select SYS_GUID() as ID,'").append(planBean.getId()).append("'PID,null ACTUAL_TIME,null USER_ID,")
|
.append("'").append(planBean.getScheduleStrDate()).append("'PLAN_TIME,'0'ENABLE,ID as SET_ID,''REMARKS ")
|
.append(",null CZG_USERID,null CZG_DATE,null LBG_USERID,null LBG_DATE,null SHG_USERID,null SHG_DATE,null FIX_TYPE,'0' status")
|
.append(" from SYS_EQP_TYPE ");
|
insertSql.append(" where DEL=0 and cid='"+ruleId+"' ");
|
|
try{
|
eqmWheelCovelPlanDao.updateInfo(insertSql.toString(),null);
|
}catch(Exception e){
|
log.error("新增数据失败:"+e.getMessage());
|
}
|
}
|
|
@Override
|
public void editWCPlan(EqmPlanBean wcpBean, String userId) throws Exception {
|
|
EqmWheelCovelPlan wcp =null;// eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, wcpBean.getPlanId());
|
MdEquipment mdEquipment = new MdEquipment();//设备
|
mdEquipment.setId(wcpBean.getEquipmentId());//设备ID,设备主数据中的ID
|
wcp.setMdEquipment(mdEquipment);
|
|
MdShift mdShift = new MdShift();//班次
|
mdShift.setId(wcpBean.getMdShiftId());
|
wcp.setMdShift(mdShift);
|
wcp.setPlanNo(StringUtil.trim(wcpBean.getPlanCode()));//计划编号
|
wcp.setPlanName(StringUtil.trim(wcpBean.getPlanName()));//计划名称
|
|
wcp.setScheduleDate(DateUtil.strToDate(wcpBean.getScheduleDate(), "yyyy-MM-dd"));//计划日期
|
wcp.setScheduleEndDate(DateUtil.strToDate(wcpBean.getScheduleDate(), "yyyy-MM-dd"));//计划结束时间
|
wcp.setMaintenanceLength(wcpBean.getEquipmentMinute());//计划时长
|
wcp.setMaintenanceContent(StringUtil.trim(wcpBean.getMaintenanceContent()));//计划内容
|
//wcp.setPlanner(userId);//制单人
|
wcp.setMaintenanceType(wcpBean.getMaintenanceType());//计划类型
|
wcp.setWheelParts(wcpBean.getMetcId());//轮保部件
|
wcp.setEndMaintainDate(new Date());//最后修改时间
|
//wcp.setWheelCoverType(wcpBean.getWheelCoverType());//工单状态 类型
|
wcp.setDel(wcpBean.getDel());
|
wcp.setMdMatId(wcpBean.getMatId());//牌号
|
try{
|
//如果编号 不一样 删除保修项 后 新增保修项
|
String delSql = "delete from EQM_WHEEL_COVEL_PARAM where pid='"+wcp.getId()+"' ";
|
eqmWheelCovelPlanDao.updateInfo(delSql,null);
|
//新增保修项
|
StringBuffer insertSql = new StringBuffer();
|
insertSql.append(" insert into EQM_WHEEL_COVEL_PARAM ");
|
insertSql.append(" select SYS_GUID() as ID,'").append(wcp.getId()).append("'PID,null ACTUAL_TIME,null USER_ID,")
|
.append("'").append(wcpBean.getScheduleDate()).append("'PLAN_TIME,'0'ENABLE,ID as SET_ID,''REMARKS ")
|
.append(",null CZG_USERID,null CZG_DATE,null LBG_USERID,null LBG_DATE,null SHG_USERID,null SHG_DATE ")
|
.append(" from SYS_EQP_TYPE ");
|
insertSql.append("where DEL=0 and cid=(select sec_pid from MD_EQP_TYPE_child where DEL=0 and id='")
|
.append(wcp.getWheelParts()).append("') ");
|
try{
|
eqmWheelCovelPlanDao.updateInfo(insertSql.toString(),null);
|
}catch(Exception e){
|
log.error("新增数据失败:"+e.getMessage());
|
}
|
}catch(Exception e){
|
log.error("删除数据失败:"+e.getMessage());
|
}
|
|
/*审核人 AUDIT_USERID
|
AUDIT_TIME
|
批准人 RATIFY_USERID
|
RATIFY_TIME*/
|
//private String period;//周期
|
//private String remindCycle;//提醒周期
|
//private String dutyPeopleName;//责任人id
|
//private String locationCode;//车间代码
|
//private SysUser sysUserByDutyPeopleId;//责任人
|
//private Date startTime;//实际开始时间
|
//private Date endTime;//实际结束时间
|
}
|
|
@Override
|
public EqmPlanBean getById(String id) throws Exception{
|
EqmPlanBean bean = new EqmPlanBean();
|
EqmWheelCovelPlan wcp =null;// eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class,id);
|
bean.setPlanId(wcp.getId());
|
bean.setPlanCode(wcp.getPlanNo());//计划编号
|
bean.setPlanName(wcp.getPlanName());
|
if(null!=wcp.getMdEquipment()){
|
bean.setEquipmentId(wcp.getMdEquipment().getId());//设备ID
|
bean.setEquipmentName(wcp.getMdEquipment().getEquipmentName());//设备名称
|
if(null!=wcp.getMdEquipment().getMdEqpType()){
|
bean.setEquipmentXhId(wcp.getMdEquipment().getMdEqpType().getId());//设备型号 ZJ17
|
bean.setEquipmentXhName(wcp.getMdEquipment().getMdEqpType().getName());
|
}
|
if(null!=wcp.getMdEquipment().getMdEqpType().getMdEqpCategory()){
|
bean.setEquipmentLxId(wcp.getMdEquipment().getMdEqpType().getMdEqpCategory().getId());//设备类型 卷烟机组
|
bean.setEquipmentLxName(wcp.getMdEquipment().getMdEqpType().getMdEqpCategory().getName());
|
}
|
}
|
bean.setPlanner(wcp.getPlanner());//制单人
|
bean.setMaintenanceType(wcp.getMaintenanceType());//轮保类别
|
bean.setEquipmentMinute(wcp.getMaintenanceLength());//轮保时长
|
bean.setScheduleDate(DateUtil.datetoStr(wcp.getScheduleDate(), "yyyy-MM-dd"));//轮保日期 计划日期
|
bean.setMatId(wcp.getMdMatId());//牌号
|
bean.setMdShiftId(wcp.getMdShift().getId());//班次
|
bean.setMaintenanceContent(wcp.getMaintenanceContent());//备注
|
bean.setMetcId(wcp.getWheelParts());//轮保部位;绑定的 项目大类(父节点，根据该节点可以查询出说有 保养项)
|
bean.setWheelCoverType(wcp.getWheelCoverType());//工单状态
|
bean.setDel(wcp.getDel());
|
return bean;
|
}
|
|
@Override
|
public void updateWCPlanStatus(String id, String statusId, String userId) {
|
EqmWheelCovelPlan bean=null;//eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, id);
|
bean.setWheelCoverType(statusId);
|
if("1".equals(statusId)){//审核
|
bean.setAuditUserId(userId);
|
bean.setAuditTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
}else if("2".equals(statusId)){//批准
|
bean.setRatifyUserId(userId);
|
bean.setRatifyTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
}
|
}
|
|
@Override
|
public void batchUpdateWCPlanStatus(String ids, String statusId, String userName) {
|
for(String id:StringUtil.splitToStringList(ids, ",")){
|
EqmWheelCovelPlan bean=null;//eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, id);
|
/*String sql = "select * from SYS_USER_ROLE WHERE UID_="+userId;
|
PageParams params = new PageParams();
|
List role = eqmWheelCovelPlanDao.queryBySql(sql, params);*/
|
/*if("1".equals(statusId)&&bean.getWheelCoverType().equals("0")){//审核--主任审核
|
bean.setWheelCoverType(statusId);
|
bean.setzrName(userName);
|
bean.setAuditTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
eqmWheelCovelPlanDao.update(bean);
|
}else if("2".equals(statusId)&&bean.getWheelCoverType().equals("1")){//批准运行--管理批准
|
bean.setWheelCoverType(statusId);
|
bean.setglName(userName);
|
bean.setRatifyTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
eqmWheelCovelPlanDao.update(bean);
|
}
|
//删除状态
|
if(bean.getWheelCoverType().equals("9")){//删除
|
bean.setWheelCoverType("10");
|
bean.setzrName(userName);
|
bean.setAuditTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
eqmWheelCovelPlanDao.update(bean);
|
}else if(bean.getWheelCoverType().equals("10")){//删除
|
bean.setglName(userName);
|
bean.setRatifyTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
eqmWheelCovelPlanDao.update(bean);
|
}
|
//编辑状态
|
if(bean.getWheelCoverType().equals("11")){//修改状态
|
bean.setWheelCoverType("12");
|
bean.setzrName(userName);
|
bean.setAuditTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
eqmWheelCovelPlanDao.update(bean);
|
}else if(bean.getWheelCoverType().equals("12")){//修改状态
|
bean.setglName(userName);
|
bean.setRatifyTime(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
eqmWheelCovelPlanDao.update(bean);
|
}*/
|
}
|
}
|
|
@Override
|
public DataGrid queryBeanList(EqmWheelCovelParam bean)throws Exception{
|
try {
|
StringBuffer hql=new StringBuffer();
|
//hql.append("from EqmWheelCovelParam o where 1=1 and o.del=0 and o.eqm_wcp_id='"+bean.getEqm_wcp_id()+"' ");
|
List<EqmWheelCovelParam> list=eqmWheelCovelParamDao.query(hql.toString());
|
hql.insert(0,"select count(*) ");
|
long total = eqmWheelCovelPlanDao.queryTotal(hql.toString());
|
return new DataGrid(list, total);
|
} catch (Exception e) {
|
// TODO: handle exception
|
}
|
return null;
|
}
|
|
/**
|
* 功能说明：设备轮保-批量添加
|
*
|
* */
|
@Override
|
public String saveWcPlanf(EqmWheelCovelPlan ep) {
|
String id="";//eqmWheelCovelPlanDao.saveBackKey(ep);
|
return id;
|
}
|
|
/**
|
* type lb -轮保
|
*
|
* met_pid -md_eqp_type表ID
|
* sec_pid -
|
*
|
* */
|
@Override
|
public List<?> queryEqpTypeChild(BatchWCPlan b) {
|
String sql="select * from MD_EQP_TYPE_CHILD where sec_pid='"+b.getRuleId()+"' and type='lb' and met_pid='"+b.getEqp_typeId()+"'";
|
List<?> list=equipmentsDao.queryBySql(sql);
|
return list;
|
}
|
|
/**
|
* 查询SYS_EQP_TYPE
|
*
|
* */
|
@Override
|
public Map<String, String> querySysEqpType(BatchWCPlan b) {
|
String sql="select id,cid from SYS_EQP_TYPE ";
|
List<?> list=equipmentsDao.queryBySql(sql);
|
Map<String, String> map=new HashMap<String, String>();
|
for(Object o:list){
|
Object[] temp=(Object[]) o;
|
map.put(temp[0].toString(), temp[1].toString());
|
}
|
return map;
|
}
|
|
@Override
|
public void saveWcParam(EqmWheelCovelParam ecpb) {
|
eqmWheelCovelParamDao.save(ecpb);
|
}
|
|
@Override
|
public void deleteWCPlan(String id){
|
/*EqmWheelCovelPlan bean=eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, id);
|
if(bean.getWheelCoverType().equals("0")){
|
bean.setWheelCoverType("9");
|
}*/
|
}
|
@Override
|
public void edit(String id){
|
/*EqmWheelCovelPlan bean=eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, id);
|
if(bean.getWheelCoverType().equals("0")){
|
bean.setWheelCoverType("11");
|
}*/
|
}
|
|
/**
|
* 根据当前维保小项目查询当前对象
|
*/
|
@Override
|
public EqmWheelCovelParam queryDetailById(String id) {
|
EqmWheelCovelParam bean=null;
|
try {
|
bean=eqmWheelCovelParamDao.findById(EqmWheelCovelParam.class, id);
|
if(bean==null){
|
bean=new EqmWheelCovelParam();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return bean;
|
}
|
}
|
