package com.shlanbao.tzsc.pms.qm.self.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 javax.servlet.http.HttpServletRequest;
|
|
import com.shlanbao.tzsc.base.dao.SysLogDaoI;
|
import com.shlanbao.tzsc.base.mapping.*;
|
import com.shlanbao.tzsc.pms.qm.onlineCheck.service.impl.QmOnlineCheckServiceImpl;
|
import com.shlanbao.tzsc.pms.sys.repairResquest.beans.RepairResquestBean;
|
import com.shlanbao.tzsc.utils.tools.*;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.QmOutwardDaoI;
|
import com.shlanbao.tzsc.base.dao.QmOutwardDetDaoI;
|
import com.shlanbao.tzsc.base.interceptor.WorkOrderStatChangeInterceptor;
|
import com.shlanbao.tzsc.base.model.DataGrid;
|
import com.shlanbao.tzsc.base.model.PageParams;
|
import com.shlanbao.tzsc.base.model.SessionInfo;
|
import com.shlanbao.tzsc.base.service.BaseService;
|
import com.shlanbao.tzsc.pms.qm.self.beans.QmAppearanceDataBean;
|
import com.shlanbao.tzsc.pms.qm.self.beans.QmOutWandBean;
|
import com.shlanbao.tzsc.pms.qm.self.beans.QmOutWardBatchMainInfo;
|
import com.shlanbao.tzsc.pms.qm.self.beans.QmOutWardFaultInfo;
|
import com.shlanbao.tzsc.pms.qm.self.beans.QmWardMainInfo;
|
import com.shlanbao.tzsc.pms.qm.self.service.QmOutWandService;
|
import com.shlanbao.tzsc.pms.sch.manualshift.beans.SchCalendarBean;
|
|
/**
|
* 外观质量检验记录实现类
|
*
|
* @author luther.zhang
|
* @create 2015-01-05
|
*/
|
@Service
|
public class QmOutWandServiceImpl extends BaseService implements QmOutWandService {
|
@Autowired
|
private QmOutwardDaoI dao;
|
@Autowired
|
private QmOutwardDetDaoI daoDet;
|
@Autowired
|
private HttpServletRequest request;
|
@Autowired
|
private SysLogDaoI logdao;
|
|
@Override
|
public DataGrid queryList(QmOutWandBean bean, PageParams pageParams) throws Exception {
|
int pageIndex = pageParams.getPage();
|
int rows = pageParams.getRows();
|
int sRow = (pageIndex - 1) * rows + 1;
|
int eRow = pageIndex * rows;
|
StringBuffer sb = new StringBuffer();
|
List<QmOutWandBean> beans = new ArrayList<>();
|
//查询条数
|
sb.append(getQueryOutWardInfoSql(2, bean));
|
List<?> rowNums = dao.queryBySql(sb.toString());
|
long total = StringUtil.converObj2Long(rowNums.get(0));
|
sb.setLength(0);
|
//查询数据
|
if (total > 0) {
|
sb.append(getQueryOutWardInfoSql(1, bean));
|
sb.append(" ) where rNum >=" + sRow + " AND rNum <=" + eRow + "");
|
List<?> datas = dao.queryBySql(sb.toString());
|
Object[] obj = null;
|
QmOutWandBean entity = null;
|
for (Object object : datas) {
|
obj = (Object[]) object;
|
entity = new QmOutWandBean();
|
entity.setId(StringUtil.convertObjToString(obj[1]));
|
entity.setuName(StringUtil.convertObjToString(obj[12]));
|
entity.setEqp(StringUtil.convertObjToString(obj[2]));
|
entity.setShift(StringUtil.convertObjToString(obj[3]));
|
entity.setTeam(StringUtil.convertObjToString(obj[4]));
|
entity.setMat(StringUtil.convertObjToString(obj[5]));
|
entity.setcTime(StringUtil.convertObjToString(obj[6]));
|
entity.setBatchNo(StringUtil.convertObjToString(obj[7]));
|
entity.setoDate(StringUtil.convertObjToString(obj[8]));
|
entity.setFirstLen(StringUtil.convertObjToString(obj[9]));
|
entity.setTwoLen(StringUtil.convertObjToString(obj[10]));
|
entity.setThreeLen(StringUtil.convertObjToString(obj[11]));
|
entity.setSts(StringUtil.convertObjToString(obj[13]));
|
entity.setSts2(StringUtil.convertObjToString(obj[14]));
|
entity.setCreateUserName(StringUtil.convertObjToString(obj[15]));
|
entity.setCreateUserTime(DateUtil.formatStringToDate(StringUtil.convertObjToString(obj[16]), "yyyy-MM-dd HH:mm:ss"));
|
entity.setUpdateUserName(StringUtil.convertObjToString(obj[17]));
|
entity.setUpdateUserTime(DateUtil.formatStringToDate(StringUtil.convertObjToString(obj[18]), "yyyy-MM-dd HH:mm:ss"));
|
beans.add(entity);
|
}
|
}
|
return new DataGrid(beans, total);
|
}
|
|
/**
|
* 得到查询物流外观检主数据sql
|
*
|
* @param type
|
* @param bean
|
* @return
|
*/
|
private StringBuffer getQueryOutWardInfoSql(int type, QmOutWandBean bean) {
|
StringBuffer sb = new StringBuffer();
|
if (type == 1) {
|
sb.append("SELECT * from ( SELECT row_number() over(order by a.time desc) as rNum,a.id as id,");
|
sb.append("c.equipment_name as eqp,d.name as shift,e.name as team, ");
|
sb.append(" f.name as mat,to_char(a.TIME,'yyyy-mm-dd hh24:mi:ss') as cTime,a.BATCH_NO as batchNO, ");
|
sb.append(" to_char(b.DATE_,'yyyy-mm-dd') as oDate , a.FIRST_LEN,a.TWO_LEN,a.THREE_LEN, ");
|
sb.append(" CASE WHEN A .eqp_name IS NOT NULL THEN A .eqp_name ELSE G . NAME END uName ,nvl(a.sts,0),nvl(a.sts2,0), ");
|
sb.append(" a.CREATE_USER_NAME,a.CREATE_USER_TIME,a.UPDATE_USER_NAME,a.UPDATE_USER_TIME");
|
//sb.append(" nvl(a.CREATE_USER_NAME,''),nvl(a.CREATE_USER_TIME,''),nvl(a.UPDATE_USER_NAME,''),nvl(a.UPDATE_USER_TIME,'')");
|
} else {
|
sb.append(" SELECT count(*) ");
|
}
|
sb.append(" from QM_OUTWARD a ");
|
sb.append(" LEFT JOIN SCH_WORKORDER b on a.oid=b.id ");
|
sb.append(" LEFT JOIN MD_EQUIPMENT c on c.id=b.eqp ");
|
sb.append(" LEFT JOIN MD_SHIFT d on b.shift=d.id ");
|
sb.append(" LEFT JOIN MD_TEAM e on b.team=e.id ");
|
sb.append(" LEFT JOIN MD_MAT f on b.mat=f.id ");
|
sb.append(" LEFT JOIN SYS_USER g on a.uid_=g.id ");
|
sb.append(" WHERE 1=1 ");
|
|
if (StringUtil.notEmpty(bean.getInspectionType())) {
|
|
sb.append(" and a.instype in ( " + ("0".equals(bean.getInspectionType()) ? "0,1" : bean.getInspectionType()) + " )");
|
}
|
if (StringUtil.notEmpty(bean.getShift())) {
|
sb.append(" AND b.SHIFT='" + bean.getShift() + "'");
|
}
|
if (StringUtil.notEmpty(bean.getTeam())) {
|
sb.append(" AND b.TEAM='" + bean.getTeam() + "'");
|
}
|
if (StringUtil.notEmpty(bean.getEqp())) {
|
sb.append(" AND b.eqp='" + bean.getEqp() + "'");
|
}
|
if (StringUtil.notEmpty(bean.getoDate())) {
|
sb.append(" AND to_char(a.time,'yyyy-mm-dd')>='" + bean.getoDate() + "'");
|
}
|
if (StringUtil.notEmpty(bean.getcTime())) {
|
sb.append(" AND to_char(a.time,'yyyy-mm-dd')<='" + bean.getcTime() + "'");
|
}
|
if (StringUtil.notEmpty(bean.getMat())) {
|
sb.append(" AND b.mat='" + bean.getMat() + "'");
|
}
|
//MES反馈状态 班长
|
if (StringUtil.notEmpty(bean.getStsMes()) && !",".equals(bean.getStsMes())) {
|
sb.append(" AND a.sts='" + bean.getStsMes() + "'");
|
}
|
//MES反馈状态 质检员
|
if (StringUtil.notEmpty(bean.getStsMes2())) {
|
sb.append(" AND a.sts='" + bean.getStsMes2() + "'");
|
}
|
//20支质量反馈状态
|
if (StringUtil.notEmpty(bean.getSts2())) {
|
sb.append(" AND a.sts2='" + bean.getSts2() + "'");
|
sb.append(" and a.first_len not in (0) "); //过滤
|
}
|
//设备类型
|
if (StringUtil.notEmpty(bean.getEqpType())) {
|
sb.append(" AND b.type='" + bean.getEqpType() + "'");
|
}
|
if ("0".equals(bean.getSts())) {
|
//质检员查询 过滤用户，只能查询当前数据
|
sb.append(" and g.id='" + bean.getUid() + "'");
|
} else if ("1".equals(bean.getSts())) {
|
//班长无需过滤用户，但只能查询状态为(1:班长 2：已反馈MES）的数据
|
sb.append("and a.sts in (1,2) ");
|
}
|
return sb;
|
}
|
|
/**
|
* 查询物理外观检测详细
|
*/
|
@Override
|
public List<QmOutWandBean> queryDel(String id) {
|
List<?> datas = dao.queryBySql(getQueryOutWardDelInfoSql(id).toString());
|
List<QmOutWandBean> beans = new ArrayList<>();
|
Object[] obj = null;
|
QmOutWandBean bean = null;
|
for (Object object : datas) {
|
obj = (Object[]) object;
|
bean = new QmOutWandBean();
|
bean.setCode(StringUtil.convertObjToString(obj[0]));
|
bean.setName(StringUtil.convertObjToString(obj[1]));
|
bean.setType(StringUtil.convertObjToString(obj[2]));
|
bean.setPos(StringUtil.convertObjToString(obj[3]));
|
bean.setDes(StringUtil.convertObjToString(obj[4]));
|
bean.setLvl(StringUtil.convertObjToString(obj[5]));
|
bean.setMinusScore(StringUtil.convertObjToString(obj[6]));
|
bean.setVal(StringUtil.convertObjToString(obj[7]));
|
beans.add(bean);
|
}
|
return beans;
|
}
|
|
/**
|
* 查询物理外观检测详细sql
|
*
|
* @param qqid
|
* @return
|
*/
|
private StringBuffer getQueryOutWardDelInfoSql(String qqid) {
|
StringBuffer sb = new StringBuffer();
|
sb.append(" SELECT b.code,b.name,b.type,b.pos,b.des,b.lvl,b.minusscore,a.val ");
|
sb.append(" from QM_OUTWARD_DET a ");
|
sb.append(" LEFT JOIN QM_OUTWARD_DEFECT_ITEM b on a.item=b.id ");
|
sb.append(" WHERE a.QO_ID='" + qqid + "'");
|
return sb;
|
}
|
|
|
/**
|
* 外观缺陷自检
|
* 1）由于定时器换班时前10分钟反馈
|
* 2）外观巡检手动反馈
|
*/
|
// @LogAnno(operateType="外观反馈MES或20支质量反馈MES")
|
@Override
|
public void sendMsg(String id, String param) {
|
try {
|
/**
|
* 0：默认数据
|
* 自检（1：自动已反馈）
|
* 巡检（ 1：手动反馈班长 2：手动已反馈）
|
* */
|
String sts = "2";
|
if ("".equals(id)) {
|
//只有自动反馈，id为空；通过当前日期查询当班数据
|
sts = "1";
|
id = this.queryIds();
|
}
|
if ("".equals(id)) {//如果id为空说明无自检数据需要反馈
|
return;
|
}
|
List<QmWardMainInfo> beans = new ArrayList<>();
|
if (StringUtil.notEmpty(id)) {
|
id = StringUtil.arrayToStringBySqlin(id.split(","));
|
String sql = getSendMsgSql(id);
|
List<?> datas = dao.queryBySql(sql);
|
List<QmOutWardBatchMainInfo> batchInfos = null;
|
List<QmOutWardFaultInfo> faults = null;
|
Map<String, QmWardMainInfo> checkMap = new HashMap<>();
|
Object[] obj = null;
|
QmWardMainInfo bean = null;
|
//批次
|
QmOutWardBatchMainInfo wardBean = null;
|
//详细项
|
QmOutWardFaultInfo faultBean = null;
|
for (int i = 0; i < datas.size(); i++) {
|
//释放对象
|
bean = null;
|
wardBean = null;
|
faultBean = null;
|
|
obj = (Object[]) datas.get(i);
|
String oid = StringUtil.convertObjToString(obj[0]);
|
String btch = StringUtil.convertObjToString(obj[6]);
|
bean = checkMap.get(oid);
|
if (bean == null) {
|
bean = new QmWardMainInfo();
|
bean.setMaterialCode(StringUtil.convertObjToString(obj[1]));//牌号
|
bean.setInspectionType(StringUtil.convertObjToString(obj[2]));//检测类型
|
bean.setOrderNumber(StringUtil.convertObjToString(obj[3]));//工单号
|
beans.add(bean);
|
}
|
//检测详细,以检测批次判断是否重复（或OutWard主键）
|
String wardId = StringUtil.convertObjToString(obj[4]);
|
batchInfos = bean.getBatchInfo();
|
//查找QmOutWardBatchMainInfo，没有则创建
|
wardBean = findBatchBeanById(batchInfos, wardId, wardBean);
|
wardBean.setTimestamp(StringUtil.convertObjToString(obj[5]));
|
wardBean.setSubBatchCode(btch);
|
wardBean.setFaultType(StringUtil.convertObjToString(obj[7]));
|
//检验人
|
wardBean.setCheckName(StringUtil.convertObjToString(obj[12]));
|
|
wardBean.setSampleNumber(StringUtil.convertObjToString(obj[8]).equals("") ? "20" : StringUtil.convertObjToString(obj[8]));
|
String faultId = StringUtil.convertObjToString(obj[9]);
|
faults = wardBean.getFaults();
|
//查找QmOutWardBatchMainInfo，没有则创建
|
faultBean = findFaultBeanById(faults, faultId, faultBean);
|
faultBean.setFaultCode(StringUtil.convertObjToString(obj[10]));
|
faultBean.setFaultNumber(StringUtil.convertObjToString(obj[11]));
|
//将封装好的对象放入map中
|
checkMap.put(oid, bean);
|
}
|
}
|
try {
|
WorkOrderStatChangeInterceptor.getInstance().DASSendOutWard(beans, param, id, sts);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
} catch (Exception e) {
|
System.out.println("外观缺陷自检数据自动反馈异常!!!");
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 根据id查找QmOutWardBatchMainInfo
|
*
|
* @param batchInfos
|
* @param id
|
* @return
|
*/
|
private QmOutWardBatchMainInfo findBatchBeanById(List<QmOutWardBatchMainInfo> batchInfos, String id, QmOutWardBatchMainInfo wardBean) {
|
for (QmOutWardBatchMainInfo w : batchInfos) {
|
if (w.getWardId().equals(id)) {
|
wardBean = w;
|
break;
|
}
|
}
|
if (wardBean == null) {
|
wardBean = new QmOutWardBatchMainInfo();
|
wardBean.setWardId(id);
|
batchInfos.add(wardBean);
|
}
|
return wardBean;
|
}
|
|
/**
|
* 根据id查找QmOutWardFaultInfo
|
*
|
* @param faults
|
* @param id
|
* @param faultBean
|
* @return
|
*/
|
private QmOutWardFaultInfo findFaultBeanById(List<QmOutWardFaultInfo> faults, String id, QmOutWardFaultInfo faultBean) {
|
for (QmOutWardFaultInfo w : faults) {
|
if (w.getId().equals(id)) {
|
faultBean = w;
|
break;
|
}
|
}
|
if (faultBean == null) {
|
faultBean = new QmOutWardFaultInfo();
|
faultBean.setId(id);
|
faults.add(faultBean);
|
}
|
return faultBean;
|
}
|
|
/**
|
* 根据物理外观检测记录id查询数据
|
*
|
* @param id mvl sts [过滤重复反馈]
|
* @return
|
*/
|
private String getSendMsgSql(String id) {
|
StringBuffer sb = new StringBuffer();
|
sb.append("select a.oid as oid,d.code as matCode,A.instype as inspectionType,c.code as orderCode,a.id as wardId,to_char(a.time,'yyyy-MM-dd hh24:mi:ss') as checkTime,");
|
sb.append(" a.BATCH_NO as batchNo,e.paramter_code as faultType, ");
|
sb.append(" (select f.STD from sch_workorder_craft f where f.parameter_setrevision = c.parameter_set_revision and f.dcs_type ='ROL' and f.ord_code !=-1 and f.param_type =2 and ROWNUM =1) as sampleNum,");
|
sb.append(" b.id as defectItemId,e.code as faultCode,b.val as faultNum,");
|
sb.append(" CASE WHEN A .eqp_name IS NOT NULL THEN A .eqp_name ELSE G . NAME END uName ");
|
sb.append(" from qm_outward a left join qm_outward_det b on a.id=b.qo_id ");
|
sb.append(" left join sch_workorder c on c.id=a.oid ");
|
sb.append(" left join md_mat d on c.mat=d.id ");
|
sb.append(" left join qm_outward_defect_item e on e.id=b.item ");
|
sb.append(" left join SYS_USER G on G.id=a.uid_ ");
|
sb.append(" where a.id in(" + id + ") ");
|
return sb.toString();
|
}
|
|
/**
|
* 根据机台编号查询工单信息
|
* Rengj
|
*/
|
public List<QmOutWandBean> queryOrderNumber(String eqp, SessionInfo info, HttpServletRequest request) {
|
java.util.Date date = new java.util.Date();
|
/*SimpleDateFormat smp = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String d = smp.format(date);*/
|
String sql = " select code,(select equipment_code from MD_EQUIPMENT "
|
+ " where id = '" + eqp + "' )as eqpCode,id,mat from SCH_WORKORDER where 1=1 and sts = 2 "
|
+ " and eqp= '" + eqp + "' and sysdate BETWEEN stim and etim ";
|
List<?> list = dao.queryBySql(sql);
|
QmOutWandBean qm = new QmOutWandBean();
|
List<QmOutWandBean> qwbList = new ArrayList<QmOutWandBean>();
|
if (list.size() > 0) {
|
Object[] obj = (Object[]) list.get(0);
|
String min = "";
|
if (date.getMinutes() <= 9)
|
min = "0" + date.getMinutes();
|
else
|
min = String.valueOf(date.getMinutes());
|
qm.setOrderNumber(obj[0].toString());
|
qm.setBatchNo(genBatchNo(obj[1].toString()));
|
qm.setCreateTime(date.getHours() + ":" + min);
|
qm.setUserName(info.getUser().getName());
|
qm.setUid(info.getUser().getId());
|
qm.setOid(obj[2].toString());
|
qm.setMat(obj[3].toString());
|
request.getSession().setAttribute("itemOdn", obj[0].toString());
|
request.getSession().setAttribute("itemMat", obj[3].toString());
|
qwbList.add(qm);
|
}
|
return qwbList;
|
}
|
|
/**
|
* 生成外观质量检测批次号
|
* Rengj
|
*/
|
private String genBatchNo(String eqpCode) {
|
String batchNo = DateUtil.formatDateToString(new Date(), "yyyyMMddHHmm");
|
batchNo += eqpCode + MathUtil.getRandomInt(100, 1000);
|
return batchNo;
|
}
|
|
/**
|
* 查询缺陷信息
|
* Rengj
|
*/
|
@Override
|
public DataGrid queryOutWandDes(QmOutWandBean bean, HttpServletRequest request, PageParams pageParams) {
|
String orderNumber = (String) request.getSession().getAttribute("itemOdn");
|
String mat = (String) request.getSession().getAttribute("itemMat");
|
// request.getSession().removeAttribute("itemOdn");
|
bean.setOrderNumber(orderNumber);
|
bean.setMat(mat);
|
int pageIndex = pageParams.getPage();
|
int rows = pageParams.getRows();
|
int sRow = (pageIndex - 1) * rows;
|
int eRow = pageIndex * rows;
|
String sql = this.joinSqlCX(bean, "count");
|
List<?> rowNums = dao.queryBySql(sql);
|
long total = StringUtil.converObj2Long(rowNums.get(0));
|
List<QmOutWandBean> beans = new ArrayList<>();
|
if (total > 0) {
|
sql = this.joinSqlCX(bean, "");
|
sql += "where rNum >" + sRow + " AND rNum <=" + eRow;
|
List<?> owdList = dao.queryBySql(sql);
|
QmOutWandBean qowBean = null;
|
Object[] obj = null;
|
if (owdList.size() > 0) {
|
for (Object object : owdList) {
|
obj = (Object[]) object;
|
qowBean = new QmOutWandBean();
|
qowBean.setCode(StringUtil.convertObjToString(obj[1]));
|
qowBean.setDes(StringUtil.convertObjToString(obj[2]));
|
qowBean.setId(StringUtil.convertObjToString(obj[3]));
|
beans.add(qowBean);
|
}
|
}
|
}
|
return new DataGrid(beans, total);
|
}
|
|
/**
|
* 保存外观质量数据
|
* Rengj
|
*/
|
@LogAnno(operateType = "保存外观质量数据")
|
public void saveOutWandDes(QmAppearanceDataBean bean, HttpServletRequest request) {
|
try {
|
QmOutward qo = new QmOutward();
|
SchWorkorder scr = new SchWorkorder();
|
SysUser su = new SysUser();
|
su.setId(bean.getUid());
|
qo.setSysUser(su);
|
scr.setId(bean.getOid());
|
qo.setSchWorkorder(scr);
|
qo.setTime(new Date());
|
qo.setBatchNo(bean.getBatchNo());
|
qo.setInsType(3l);
|
qo.setSts(0l);
|
qo.setSts2(0l);
|
FillUserInfoUtil.fillCreateUserInfo(qo, request);
|
|
//20支质量判断
|
if (!"".equals(bean.getFirstLen()) && bean.getFirstLen() != null) {
|
qo.setFirstLen(Float.parseFloat(bean.getFirstLen()));
|
}
|
if (!"".equals(bean.getTwoLen()) && bean.getTwoLen() != null) {
|
qo.setTwoLen(Float.parseFloat(bean.getTwoLen()));
|
}
|
if (!"".equals(bean.getThreeLen()) && bean.getThreeLen() != null) {
|
qo.setThreeLen(Float.parseFloat(bean.getThreeLen()));
|
}
|
String uuid = dao.saveBackKey(qo);
|
|
List<String> nums = new ArrayList<String>();
|
List<String> blameTest = new ArrayList<String>();
|
if (!"".equals(bean.getBlameTestId()) && bean.getBlameTestId() != null && !"".equals(bean.getNum()) && bean.getNum() != null) {
|
blameTest.add(bean.getBlameTestId());
|
nums.add(bean.getNum());
|
}
|
if (!"".equals(bean.getBlameTestId2()) && bean.getBlameTestId2() != null && !"".equals(bean.getNum2()) && bean.getNum2() != null) {
|
blameTest.add(bean.getBlameTestId2());
|
nums.add(bean.getNum2());
|
}
|
if (!"".equals(bean.getBlameTestId3()) && bean.getBlameTestId3() != null && !"".equals(bean.getNum3()) && bean.getNum3() != null) {
|
blameTest.add(bean.getBlameTestId3());
|
nums.add(bean.getNum3());
|
}
|
if (!"".equals(bean.getBlameTestId4()) && bean.getBlameTestId4() != null && !"".equals(bean.getNum4()) && bean.getNum4() != null) {
|
blameTest.add(bean.getBlameTestId4());
|
nums.add(bean.getNum4());
|
}
|
if (!"".equals(bean.getBlameTestId5()) && bean.getBlameTestId5() != null && !"".equals(bean.getNum5()) && bean.getNum5() != null) {
|
blameTest.add(bean.getBlameTestId5());
|
nums.add(bean.getNum5());
|
}
|
|
if (blameTest.size() > 0) {
|
QmOutwardDet qod;
|
QmOutwardDefectItem qoditem;
|
QmOutward qoward;
|
for (int i = 0; i < blameTest.size(); i++) {
|
qod = new QmOutwardDet();
|
qoditem = new QmOutwardDefectItem();
|
qoward = new QmOutward();
|
qod.setId(UUID.randomUUID().toString());
|
qoditem.setId(blameTest.get(i));
|
qod.setQmOutwardDefectItem(qoditem);
|
qoward.setId(uuid);
|
qod.setQmOutward(qoward);
|
qod.setVal(Long.parseLong(nums.get(i)));
|
daoDet.save(qod);
|
}
|
}
|
request.getSession().removeAttribute("itemOdn");
|
request.getSession().removeAttribute("itemMat");
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
private String joinSqlCX(QmOutWandBean bean, String temp) {
|
List<?> orderTypelist = daoDet.queryBySql("select type from sch_workorder where code='" + bean.getOrderNumber() + "'");
|
|
if (orderTypelist != null && orderTypelist.size() != 0) {
|
String orderType = orderTypelist.get(0).toString();
|
if ("1".equals(orderType)) {//卷烟机
|
bean.setDcsType("ROL");
|
} else if ("2".equals(orderType)) {//包装机
|
bean.setDcsType("PKG");
|
} else if ("3".equals(orderType)) {//封箱机
|
bean.setDcsType("PBOX");
|
} else {
|
bean.setDcsType("FLT");
|
}
|
}
|
|
String sql = "";
|
if ("count".equals(temp)) {
|
sql += " select count(*) from ( ";
|
} else {
|
sql += " select * from ( ";
|
}
|
sql += "select rownum as rNum,q1.code, q1.des,q1.id from qm_outward_defect_item q1,sch_workorder_craft s1,sch_workorder s2, md_mat c "
|
+ " where 1=1 and s1.parameter_setrevision = s2.parameter_set_revision "
|
+ " and q1.paramter_code = s1.parameter_code and c.id=s1.MATERIAL_CODE and c.code=( select code from md_mat where id='" + bean.getMat() + "' and rownum=1) ";
|
if (bean.getName() != null && !"".equals(bean.getName())) {
|
sql += " and q1.name like '%" + bean.getName() + "%'";
|
}
|
if (bean.getDcsType() != null && !"".equals(bean.getDcsType())) {
|
sql += " and s1.dcs_type = '" + bean.getDcsType() + "'";
|
}
|
if (bean.getType() != null && !"".equals(bean.getType())) {
|
sql += " and q1. type = '" + bean.getType() + "'";
|
}
|
if (bean.getOrderNumber() != null && !"".equals(bean.getOrderNumber())) {
|
sql += " and s2.code = '" + bean.getOrderNumber() + "' ";
|
}
|
sql += ")";
|
return sql;
|
}
|
|
/**
|
* 拼接sql
|
* Rengj
|
*/
|
private String joinSql(QmOutWandBean bean, String temp) {
|
List<?> orderTypelist = daoDet.queryBySql("select type from sch_workorder where code='" + bean.getOrderNumber() + "'");
|
if (orderTypelist != null && orderTypelist.size() != 0) {
|
String orderType = orderTypelist.get(0).toString();
|
if ("1".equals(orderType)) {//卷烟机
|
bean.setDcsType("ROL");
|
} else if ("2".equals(orderType)) {//包装机
|
bean.setDcsType("PKG");
|
} else if ("3".equals(orderType)) {//封箱机
|
bean.setDcsType("PBOX");
|
} else {//成型机
|
bean.setDcsType("FTL");
|
}
|
}
|
|
String sql = "";
|
if ("count".equals(temp)) {
|
sql += " select count(*) from ( ";
|
} else {
|
sql += " select * from ( ";
|
}
|
sql += "select rownum as rNum,q1.code, q1.des,q1.id from qm_outward_defect_item q1,sch_workorder_craft s1,sch_workorder s2 "
|
+ " where 1=1 and s1.parameter_setrevision = s2.parameter_set_revision and q1.status =1 "
|
+ " and q1.paramter_code = s1.parameter_code and s1.MATERIAL_CODE = '" + bean.getMat() + "'";
|
|
if (bean.getName() != null && !"".equals(bean.getName())) {
|
sql += " and q1.name like '%" + bean.getName() + "%'";
|
}
|
if (bean.getDcsType() != null && !"".equals(bean.getDcsType())) {
|
sql += " and s1.dcs_type = '" + bean.getDcsType() + "'";
|
}
|
if (bean.getType() != null && !"".equals(bean.getType())) {
|
sql += " and q1. type = '" + bean.getType() + "'";
|
}
|
if (bean.getOrderNumber() != null && !"".equals(bean.getOrderNumber())) {
|
sql += " and s2.code = '" + bean.getOrderNumber() + "' ";
|
}
|
sql += ")";
|
return sql;
|
}
|
|
/**
|
* 查询上一班次外观质检数据
|
* Rengj
|
*/
|
private String queryIds() {
|
String ids = "";
|
try {
|
/**
|
* 1）获得当前系统时间
|
* 2）查询工厂日历，得到：开始日期，结束 日期，班次，班组信息
|
* 3）通过这些日期时间，查询工单表
|
*
|
* */
|
//通过当前系统时间，得到工厂日期信息
|
StringBuffer sql = new StringBuffer();
|
sql.append(" select q1.id from QM_OUTWARD q1,SCH_WORKORDER s1 where 1=1 and q1.oid = s1.id ");
|
sql.append(" and nvl(q1.sts,0)=0 and s1.sts in (2,4) ");
|
sql.append(" and q1.instype in (0,1) and to_date('" + DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss") + "','yyyy-MM-dd hh24:mi:ss') BETWEEN s1.STIM AND s1.ETIM");
|
//sql.append(" and to_char(s1.date_,'yyyy-MM-dd')='"+scbt.getDate()+"'" );
|
//sql.append(" and q1.instype = 0 and s1.shift='"+scbt.getMdShiftCode()+"' " );
|
List<?> idsList = dao.queryBySql(sql.toString());
|
for (int i = 0; i < idsList.size(); i++) {
|
Object obj = idsList.get(i);
|
ids += obj + ",";
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return ids;
|
}
|
|
|
/**
|
* 功能说明：
|
* 反馈班长，修改状态
|
*/
|
@LogAnno(operateType = "反馈班长或回退质检员")
|
@Override
|
public void updateQmOutWardByIds(String ids, String sts) {
|
ids = ids.replaceAll(",", "','");
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
String updateUserName = sessionInfo.getUser().getName();
|
if (ids != null && !"".equals(ids)) {
|
dao.updateBySql("update QM_OUTWARD set sts='" + sts + "',UPDATE_USER_NAME='" + updateUserName + "',UPDATE_USER_TIME=sysdate where instype=3 and id in ('" + ids + "') ", null);
|
}
|
}
|
|
@Override
|
public String updateCheckTimes(String stim, String ids) {
|
String result = "";
|
try {
|
String sql = "update QM_OUTWARD set time = to_date('" + stim + "','yyyy-MM-dd hh24:mi:ss') where id='" + ids + "'";
|
dao.updateBySql(sql, null);
|
result = "保存检测时间成功！";
|
} catch (Exception e) {
|
result = "保存检测时间失败！";
|
}
|
return result;
|
}
|
|
/**
|
* 批量删除外观自检记录
|
*
|
* @param id 需删除的id值
|
* @param request
|
* @return 反馈信息
|
*/
|
@LogAnno(operateType = "删除外观缺陷过程自检记录（可批量）")
|
@Override
|
public String beatchDeleteOutWand(String id, HttpServletRequest request) {
|
String result = "删除失败！";
|
String[] ids = id.split(",");
|
List<Object> qmIds;
|
String sql;
|
try {
|
for (int i = 0; i < ids.length; i++) {
|
qmIds = new ArrayList<>();
|
sql = "delete from QM_OUTWARD_DET where qo_id = ?";
|
qmIds.add(ids[i]);
|
dao.updateBySql(sql, qmIds);//外观质量缺陷详细
|
sql = "delete from QM_OUTWARD where id = ?";
|
dao.updateBySql(sql, qmIds);
|
}
|
result = "删除成功";
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return result;
|
}
|
|
/**
|
* 删除外观自检记录
|
*
|
* @param id 需删除的id值
|
* @param request
|
* @return 反馈信息
|
*/
|
@Override
|
public String deleteOutWand(String id, HttpServletRequest request) {
|
return beatchDeleteOutWand(id, request);
|
}
|
|
@LogAnno(operateType = "编辑")
|
@Override
|
public String edit(QmOutWandBean qmOutWandBean) {
|
String result = "操作成功!";
|
try {
|
QmOutward outward = new QmOutward();
|
outward.setId(qmOutWandBean.getId());
|
if (!StringUtils.isEmpty(qmOutWandBean.getFirstLen())) {
|
outward.setFirstLen(Float.parseFloat(qmOutWandBean.getFirstLen()));
|
}
|
if (!StringUtils.isEmpty(qmOutWandBean.getTwoLen())) {
|
outward.setTwoLen(Float.parseFloat(qmOutWandBean.getTwoLen()));
|
}
|
if (!StringUtils.isEmpty(qmOutWandBean.getThreeLen())) {
|
outward.setThreeLen(Float.parseFloat(qmOutWandBean.getThreeLen()));
|
}
|
dao.updateBySqlParam("update QM_OUTWARD set FIRST_LEN = ? , TWO_LEN = ? , THREE_LEN = ? where id = ? ", qmOutWandBean.getFirstLen(), qmOutWandBean.getTwoLen(), qmOutWandBean.getThreeLen(), qmOutWandBean.getId());
|
} catch (Exception e) {
|
result = "操作失败！";
|
e.printStackTrace();
|
}
|
|
return result;
|
}
|
|
@Override
|
public QmOutWandBean queryById(String id) {
|
List<?> objects = dao.queryBySql("select id,FIRST_LEN,TWO_LEN,THREE_LEN from QM_OUTWARD where id = ?", id);
|
QmOutWandBean bean = new QmOutWandBean();
|
try {
|
Object[] obj = (Object[]) objects.get(0);
|
bean.setId(StringUtil.convertObjToString(obj[0]));
|
bean.setFirstLen(StringUtil.convertObjToString(obj[1]));
|
bean.setTwoLen(StringUtil.convertObjToString(obj[2]));
|
bean.setThreeLen(StringUtil.convertObjToString(obj[3]));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return bean;
|
}
|
}
|
