package com.shlanbao.tzsc.pms.msg.qm.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.MsgQmWarnDaoI;
|
import com.shlanbao.tzsc.base.dao.SchWorkorderDaoI;
|
import com.shlanbao.tzsc.base.mapping.MsgQmWarn;
|
import com.shlanbao.tzsc.base.mapping.SchWorkorder;
|
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.msg.qm.beans.MsgQmWarnBean;
|
import com.shlanbao.tzsc.pms.msg.qm.service.MsgQmWarnServiceI;
|
import com.shlanbao.tzsc.utils.tools.DateUtil;
|
import com.shlanbao.tzsc.utils.tools.StringUtil;
|
@Service
|
public class MsgQmWarnServiceImpl extends BaseService implements MsgQmWarnServiceI{
|
|
@Autowired
|
protected MsgQmWarnDaoI msgQmWarnDao;
|
@Autowired
|
SchWorkorderDaoI workOderDao;
|
|
@Override
|
public void addMsgQmWarn(MsgQmWarn msgQmWarn) throws Exception {
|
MsgQmWarn msgQm = null;
|
if(StringUtil.notNull(msgQmWarn.getId())){
|
msgQm = msgQmWarnDao.findById(MsgQmWarn.class, msgQmWarn.getId());
|
beanConvertor.copyProperties(msgQmWarn, msgQm);
|
}else{
|
msgQm = msgQmWarn;
|
msgQm.setDel(0L);
|
msgQm.setTime(new Date());
|
msgQm.setSts(0L);
|
msgQm.setId(null);
|
}
|
msgQmWarnDao.saveOrUpdate(msgQm);
|
}
|
|
@Override
|
public MsgQmWarn getMsgQmWarnById(String id) throws Exception {
|
return msgQmWarnDao.findById(MsgQmWarn.class, id);
|
}
|
|
/**
|
* 功能：查询质量警告记录
|
* 张璐--2015.10.13
|
*/
|
@Override
|
public DataGrid queryMsgQmWarn(MsgQmWarnBean msgQmWarn, PageParams pageParams)throws Exception {
|
StringBuffer sb= new StringBuffer();
|
String star="SELECT * from";
|
sb.append(" (SELECT qw.id,mw.name as mname,me.equipment_name,qw.CONTENT,qw.QI,qw.VAL,qw.ITEM,qw.TIME,qw.STS,ROWNUM AS num FROM MSG_QM_WARN qw ");
|
sb.append("LEFT JOIN SCH_WORKORDER sw on qw.oid = sw.id LEFT JOIN MD_EQUIPMENT me on sw.EQP = me.ID LEFT JOIN MD_WORKSHOP mw on me.work_shop = mw.id ");
|
sb.append("WHERE qw.del = 0 and mw.del='0'");
|
if(StringUtil.notNull(msgQmWarn.getEquipName()))
|
sb.append(" and me.equipment_name like'%"+msgQmWarn.getEquipName()+"%'");
|
if(StringUtil.notNull(msgQmWarn.getWorkShopId()))
|
sb.append(" and mw.id='"+msgQmWarn.getWorkShopId()+"' ");
|
sb.append(StringUtil.fmtDateHHmmssBetweenParams("qw.time", msgQmWarn.getTime(), msgQmWarn.getTime2()));
|
sb.append(") ");
|
String end ="zl where num>'"+((pageParams.getPage()-1)*pageParams.getRows())+"' and num<='"+(pageParams.getPage()*pageParams.getRows())+"' ";
|
List<?> listFY = msgQmWarnDao.queryBySql("SELECT COUNT(*) FROM "+sb.toString(),null);
|
List<?> list=msgQmWarnDao.queryBySql(star+sb.toString()+end,null);
|
List<MsgQmWarnBean> beans = new ArrayList<MsgQmWarnBean>();
|
if(list.size()>0){
|
for(Object ob : list){
|
Object[] temp = (Object[]) ob;
|
MsgQmWarnBean bean = new MsgQmWarnBean();
|
bean.setId(temp[0].toString());
|
bean.setWorkShopName(temp[1].toString());
|
bean.setEquipName(temp[2].toString());
|
// bean.setuName(temp[3].toString());
|
if(temp[3]!=null&&!temp[3].equals("")){
|
bean.setContent(temp[3].toString());
|
}
|
if(temp[4]!=null&&!temp[4].equals("")){
|
double qi=Double.parseDouble(temp[4].toString());
|
bean.setQi(qi);
|
}
|
if(temp[5]!=null&&!temp[5].equals("")){
|
double val=Double.parseDouble(temp[5].toString());
|
bean.setVal(val);
|
}
|
if(temp[6]!=null&&!temp[6].equals("")){
|
bean.setItem(temp[6].toString());
|
}
|
|
bean.setTime(temp[7].toString());
|
long status = Long.parseLong(temp[8].toString());
|
bean.setSts(status);
|
beans.add(bean);
|
}
|
}
|
long total = Long.parseLong(listFY.get(0).toString());
|
|
return new DataGrid(beans, total);
|
|
/*String hql = "from MsgQmWarn o where 1=1 and o.del=0";
|
String params = "";
|
if(StringUtil.notNull(msgQmWarn.getEquipName()))
|
params += " and o.schWorkorder.mdEquipment.equipmentName like'%"+msgQmWarn.getEquipName()+"%'";
|
if(StringUtil.notNull(msgQmWarn.getWorkShopId()))
|
params += " and o.schWorkorder.mdEquipment.mdWorkshop.id='"+msgQmWarn.getWorkShopId()+"' ";
|
params+=StringUtil.fmtDateBetweenParams("o.time", msgQmWarn.getTime(), msgQmWarn.getTime2());
|
List<MsgQmWarn> msgQmWarns = msgQmWarnDao.queryByPage(hql.concat(params), pageParams);
|
hql = "select count(*) "+hql;
|
long total = msgQmWarnDao.queryTotal(hql.concat(params));
|
return new DataGrid(convertBeans(msgQmWarns), total);*/
|
}
|
|
@Override
|
public List<MsgQmWarnBean> getMsgQmWarns(Long sts) throws Exception {
|
String hql = "from MsgQmWarn o where 1=1 and o.del=0 and o.sts=" + sts;
|
List<MsgQmWarn> msgQmWarns = msgQmWarnDao.query(hql, new Object[]{});
|
return convertBeans(msgQmWarns);
|
}
|
|
@Override
|
public void deleteMsgQmWarn(String id) throws Exception {
|
msgQmWarnDao.findById(MsgQmWarn.class, id).setDel(1L);
|
}
|
|
@Override
|
public void batchDeleteMsgQmWarn(String ids) {
|
|
String[] split = ids.split(",");
|
for (int i = 0; i < split.length; i++) {
|
msgQmWarnDao.findById(MsgQmWarn.class, split[i]).setDel(1L);
|
}
|
}
|
|
/**
|
* 修改人：张璐--2015-10-13
|
* 将po实体列表转化为vo实体列表
|
* @param msgQmWarns
|
* @return
|
* @throws Exception
|
*/
|
private List<MsgQmWarnBean> convertBeans(List<MsgQmWarn> msgQmWarns)throws Exception{
|
List<MsgQmWarnBean> beans = new ArrayList<MsgQmWarnBean>();
|
for (MsgQmWarn msgQm : msgQmWarns) {
|
MsgQmWarnBean bean = beanConvertor.copyProperties(msgQm, MsgQmWarnBean.class);
|
if(msgQm.getSysUser() != null){
|
bean.setUid(msgQm.getSysUser().getId());
|
bean.setuName(msgQm.getSysUser().getName());
|
}
|
if(msgQm.getSchWorkorder() != null){
|
String hqlByOrder="select ID from SCH_WORKORDER where code='"+msgQm.getSchWorkorder().getId()+"'";
|
List<?> listO= workOderDao.queryBySql(hqlByOrder, null);
|
String oder = (String) listO.get(0);
|
SchWorkorder wokder = workOderDao.findById(SchWorkorder.class, oder);
|
bean.setWorkId(wokder.getId());
|
bean.setWorkCode(wokder.getCode());
|
bean.setWorkShopId(wokder.getMdEquipment().getMdWorkshop().getId());
|
bean.setWorkShopName(wokder.getMdEquipment().getMdWorkshop().getName());
|
bean.setEquipId(wokder.getMdEquipment().getId());
|
bean.setEquipName(wokder.getMdEquipment().getEquipmentName());
|
}
|
beans.add(bean);
|
}
|
return beans;
|
}
|
|
@Override
|
public MsgQmWarnBean getMsgQmWarnBeanById(String id) throws Exception {
|
MsgQmWarn msgQmWarn = msgQmWarnDao.findById(MsgQmWarn.class, id);
|
MsgQmWarnBean bean = beanConvertor.copyProperties(msgQmWarn, MsgQmWarnBean.class);
|
if(msgQmWarn.getSysUser() != null){
|
bean.setUid(msgQmWarn.getSysUser().getId());
|
bean.setuName(msgQmWarn.getSysUser().getName());
|
}
|
if(msgQmWarn.getSchWorkorder() != null){
|
bean.setWorkId(msgQmWarn.getSchWorkorder().getId());
|
bean.setWorkCode(msgQmWarn.getSchWorkorder().getCode());
|
bean.setWorkShopId(msgQmWarn.getSchWorkorder().getMdEquipment().getMdWorkshop().getId());
|
bean.setWorkShopName(msgQmWarn.getSchWorkorder().getMdEquipment().getMdWorkshop().getName());
|
bean.setEquipId(msgQmWarn.getSchWorkorder().getMdEquipment().getId());
|
bean.setEquipName(msgQmWarn.getSchWorkorder().getMdEquipment().getEquipmentName());
|
}
|
bean.setContent(bean.getContent().length() > 24 ? bean.getContent().substring(24):bean.getContent());
|
return bean;
|
}
|
}
|
