package com.shlanbao.tzsc.pms.sch.workorder.service.impl;
|
|
import java.net.InetAddress;
|
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 com.shlanbao.tzsc.base.dao.*;
|
import com.shlanbao.tzsc.base.model.*;
|
import com.shlanbao.tzsc.pms.sch.workorder.beans.BomBean;
|
import com.shlanbao.tzsc.utils.tools.*;
|
import org.apache.commons.lang.ObjectUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.interceptor.WorkOrderStatChangeInterceptor;
|
import com.shlanbao.tzsc.base.mapping.ChangeShiftDatas;
|
import com.shlanbao.tzsc.base.mapping.MdEquipment;
|
import com.shlanbao.tzsc.base.mapping.MdMat;
|
import com.shlanbao.tzsc.base.mapping.MdMatType;
|
import com.shlanbao.tzsc.base.mapping.MdShift;
|
import com.shlanbao.tzsc.base.mapping.MdTeam;
|
import com.shlanbao.tzsc.base.mapping.MdUnit;
|
import com.shlanbao.tzsc.base.mapping.MdWorkshop;
|
import com.shlanbao.tzsc.base.mapping.QualityCheckInfo;
|
import com.shlanbao.tzsc.base.mapping.QualityCheckInfoParams;
|
import com.shlanbao.tzsc.base.mapping.SchCalendar;
|
import com.shlanbao.tzsc.base.mapping.SchWorkorder;
|
import com.shlanbao.tzsc.base.mapping.SchWorkorderBom;
|
import com.shlanbao.tzsc.base.mapping.SysLog;
|
import com.shlanbao.tzsc.base.mapping.SysMessageQueue;
|
import com.shlanbao.tzsc.base.service.BaseService;
|
import com.shlanbao.tzsc.data.runtime.handler.DbOutputOrInputInfos;
|
import com.shlanbao.tzsc.init.BaseParams;
|
import com.shlanbao.tzsc.pms.md.fixCode.beans.FixCodeBean;
|
import com.shlanbao.tzsc.pms.sch.stat.beans.OutputBean;
|
import com.shlanbao.tzsc.pms.sch.stat.service.StatServiceI;
|
import com.shlanbao.tzsc.pms.sch.workorder.beans.TransmitterOutput;
|
import com.shlanbao.tzsc.pms.sch.workorder.beans.TransmitterWorkOrderBean;
|
import com.shlanbao.tzsc.pms.sch.workorder.beans.WorkOrderBean;
|
import com.shlanbao.tzsc.pms.sch.workorder.service.WorkOrderServiceI;
|
import com.shlanbao.tzsc.utils.params.SysEqpTypeBase;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
@Service
|
public class WorkOrderServiceImpl extends BaseService implements WorkOrderServiceI {
|
@Autowired
|
private SchWorkorderDaoI schWorkorderDao;
|
@Autowired
|
private MdShiftDaoI shiftDao;
|
@Autowired
|
private SchWorkorderBomDaoI schWorkorderBomDao;
|
@Autowired
|
private StatServiceI statService;
|
@Autowired
|
private SchCalendarDaoI schCalendarDao;
|
@Autowired
|
private SysLogDaoI logdao;
|
@Autowired
|
private SysMessageQueueDaoI SysMessageQueueDao;
|
@Autowired
|
private StatServiceI statServiceImpl;
|
@Autowired
|
private SysLogDaoI sysLogDaoImpl;
|
@Autowired
|
private MdMatTypeDaoI mdMatTypeDao;
|
@Autowired
|
private MdMatDaoI mdMatDao;
|
@Autowired
|
private EqmipmentsDaoI equipmentDao;
|
|
@Autowired
|
private QualityCheckMesDataParamsDaoI InfoParamsDao;
|
@Autowired
|
private QualityCheckMesDataDaoI infoDao;
|
|
@Autowired
|
private TransmitterWorkOrderDaoI transmitterWorkOrderDaoI;
|
|
@Autowired
|
private TransmitterOutputDaoI transmitterOutputDaoI;
|
@Autowired
|
HttpServletRequest request;
|
|
public SchWorkorder getRunSchWorkorder(String code) {
|
String hql = "from SchWorkorder o where o.del=0 and o.isCheck=1 and o.sts=2 and o.mdEquipment.equipmentCode=? ";
|
List<Object> params = new ArrayList<Object>();
|
params.add(code);
|
SchWorkorder schWorkorder = null;
|
try {
|
schWorkorder = schWorkorderDao.unique(SchWorkorder.class, hql, params);
|
} catch (Exception e) {
|
log.debug("error :" + e.getMessage());
|
}
|
return schWorkorder;
|
}
|
|
/**
|
* 根据设备CODE 获取正在运行的工单 并填充辅料
|
*
|
* @throws Exception
|
*/
|
public void queryRunWorkFl(SchWorkorder schWorkorder) {
|
//向DataHandler中calcValues保存辅料计数参数和烟机滚轴系数
|
try {
|
if (null != schWorkorder) {
|
this.setCalcValue(schWorkorder);
|
}
|
} catch (Exception e) {
|
log.debug("error :" + e.getMessage());
|
}
|
}
|
|
|
public SchWorkorder getWork(String code) {
|
String hql = "from SchWorkorder o where o.del=0 and o.isCheck=1 and o.sts=2 and o.mdEquipment.equipmentCode=? ";
|
List<Object> params = new ArrayList<Object>();
|
params.add(code);
|
SchWorkorder schWorkorder = null;
|
//有运行的工单
|
//向DataHandler中calcValues保存辅料计数参数和烟机滚轴系数
|
try {
|
schWorkorder = schWorkorderDao.unique(SchWorkorder.class, hql, params);
|
if (null != schWorkorder) {
|
this.setCalcValue(schWorkorder);
|
}
|
} catch (Exception e) {
|
log.debug("error :" + e.getMessage());
|
}
|
return schWorkorder;
|
}
|
|
@Override
|
public DataGrid getAllWorkOrders(WorkOrderBean workOrderBean,
|
PageParams pageParams) {
|
try {
|
return new DataGrid(convertWorkOrderBean(schWorkorderDao.queryByPage(getQuerySql(workOrderBean), pageParams)),
|
schWorkorderDao.queryTotal("select count(o) ".concat(getQuerySql(workOrderBean).replace("fetch", ""))));
|
} catch (Exception e) {
|
log.error("查询工单异常", e);
|
}
|
return null;
|
}
|
|
private List<WorkOrderBean> convertWorkOrderBean(List<SchWorkorder> rows) throws Exception {
|
List<WorkOrderBean> orderBeans = new ArrayList<>();
|
|
WorkOrderBean bean = null;
|
for (SchWorkorder schWorkorder : rows) {
|
|
bean = BeanConvertor.copyProperties(schWorkorder, WorkOrderBean.class);
|
bean.setTeam(schWorkorder.getMdTeam() == null ? null : schWorkorder.getMdTeam().getName());
|
bean.setShift(schWorkorder.getMdShift() == null ? null : schWorkorder.getMdShift().getName());
|
bean.setTeamId(schWorkorder.getMdTeam() == null ? null : schWorkorder.getMdTeam().getId());
|
bean.setShiftId(schWorkorder.getMdShift() == null ? null : schWorkorder.getMdShift().getId());
|
bean.setEquipment(schWorkorder.getMdEquipment() == null ? null : schWorkorder.getMdEquipment().getEquipmentName());
|
bean.setEquipmentId(schWorkorder.getMdEquipment() == null ? null : schWorkorder.getMdEquipment().getId());
|
bean.setUnit(schWorkorder.getMdUnit() == null ? null : schWorkorder.getMdUnit().getName());
|
bean.setUnitId(schWorkorder.getMdUnit() == null ? null : schWorkorder.getMdUnit().getId());//(新增生产实绩产量时需要同步工单计量单位)
|
bean.setMat(schWorkorder.getMdMat() == null ? null : schWorkorder.getMdMat().getName());
|
bean.setMatId(schWorkorder.getMdMat() == null ? null : schWorkorder.getMdMat().getId());
|
bean.setType(schWorkorder.getType());
|
FillUserInfoUtil.fillCreateAndUpdateUserInfo(schWorkorder, bean);
|
orderBeans.add(bean);
|
|
bean = null;
|
}
|
return orderBeans;
|
}
|
|
private String getQuerySql(WorkOrderBean workOrderBean) {
|
String hql = "from SchWorkorder o left join fetch o.mdTeam t left join fetch o.mdShift s left join fetch " +
|
"o.mdEquipment e left join fetch e.mdEqpType et left join fetch e.mdWorkshop w left join fetch " +
|
"o.mdUnit u left join fetch o.mdMat m where o.del=0 and o.type in (" + workOrderBean.getParam() + ") ";
|
String params = "";
|
if (StringUtil.notNull(workOrderBean.getTeam())) {
|
params = params.concat(" and t.code = '" + workOrderBean.getTeam() + "'");
|
}
|
if (StringUtil.notNull(workOrderBean.getShift())) {
|
params = params.concat(" and s.code = '" + workOrderBean.getShift() + "'");
|
}
|
if (StringUtil.notNull(workOrderBean.getDate())) {
|
params = params.concat(" and to_char(o.date,'yyyy-MM-dd') >= '" + workOrderBean.getDate() + "'");
|
}
|
if (StringUtil.notNull(workOrderBean.getDate2())) {
|
params = params.concat(" and to_char(o.date,'yyyy-MM-dd') <= '" + workOrderBean.getDate2() + "'");
|
}
|
if (workOrderBean.getSts() != null) {
|
params = params.concat(" and o.sts = " + workOrderBean.getSts() + "");
|
}
|
if (workOrderBean.getType() != null) {
|
params = params.concat(" and o.type = " + workOrderBean.getType() + "");
|
}
|
if (workOrderBean.getIsCheck() != null) {
|
params = params.concat(" and o.isCheck = " + workOrderBean.getIsCheck() + "");
|
}
|
if (StringUtil.notNull(workOrderBean.getCode())) {
|
params = params.concat(" and (o.code like '%" + workOrderBean.getCode() + "%' or m.name like '%" + workOrderBean.getCode() + "%')");
|
}
|
params = params.concat(" order by o.date desc,s.code,e.equipmentCode asc");
|
return hql.concat(params);
|
}
|
|
|
@LogAnno(operateType = "单个审核工单")
|
@Override
|
public String checkWorkOrder(String id) throws Exception {
|
SchWorkorder schWorkorder = schWorkorderDao.findById(SchWorkorder.class, id);
|
if (schWorkorder != null) {
|
if (DateUtil.datetoStr(schWorkorder.getDate(), "yyyy-MM-dd").equals(DateUtil.datetoStr(new Date(), "yyyy-MM-dd"))) {
|
schWorkorder.setIsCheck(1L);
|
schWorkorder.setSts(Long.parseLong("1"));//状态
|
schWorkorder.setIsAuto("Y");
|
schWorkorder.setCheckTime(new Date());
|
FillUserInfoUtil.fillUpdateUserInfo(schWorkorder, request);
|
} else {
|
return schWorkorder.getCode();
|
}
|
|
} else {
|
log.error("id:" + id + "的工单不存在");
|
throw new Exception();
|
}
|
return null;
|
}
|
|
@LogAnno(operateType = "批量审核工单")
|
@Override
|
public String checkWorkOrders(String ids) throws Exception {
|
String msg = "";
|
for (String id : StringUtil.splitToStringList(ids, ",")) {
|
String s = this.checkWorkOrder(id);
|
if (s != null) {
|
msg += "[" + s + "] ";
|
}
|
}
|
if (msg != "") {
|
|
return "部分工单未审核！->非当日工单！";
|
} else {
|
return null;
|
}
|
}
|
|
@LogAnno(operateType = "编辑工单状态")
|
@Override
|
public void editWorkOrderStatus(String id, Long sts) throws Exception {
|
SchWorkorder schWorkorder = schWorkorderDao.findById(SchWorkorder.class, id);//锁定状态（1-允许，0-不允许）。当为7时表示已经允许
|
if (schWorkorder != null) {
|
/* 1,下发 <br>
|
* 2,运行 -->运行时在生产实绩中保存val=0的数据，即采集程序只做update操作<br>
|
* 3,暂停 -->MES取消撤销工单时<br>
|
* 4,完成 -->工单完成,更新工单结束时间<br>
|
* 5,终止 -->错误的工单运行时，执行本操作删除生产实绩相关数据<br>
|
* 6,结束 -->工单已经反馈<br>
|
* 7,锁定 -->MES发起撤销时<br>
|
* 8,撤销 -->MES确定撤销时<br>
|
*/
|
if (sts == 1) {
|
schWorkorder.setIsAuto("Y");//下发工单 默认自动运行
|
}
|
if (sts == 2) {
|
//只让没有运行过的工单改变运行状态，防止出现多个产出数据
|
long status = schWorkorder.getSts();
|
if (status != 2 && status != 4 && schWorkorder.getRealStim() == null) {
|
List<?> list = schWorkorderDao.queryBySql("select * from SCH_WORKORDER where eqp = ? and sts = 2 and del = 0",schWorkorder.getMdEquipment().getId());
|
if (list!=null && list.size() > 0){
|
throw new RuntimeException("此工单所属机台有未结束的工单！！");
|
}
|
Date date = new Date();
|
schWorkorder.setRealStim(date);//实绩开始时间
|
//保存生产实绩空数据
|
OutputBean outputBean = new OutputBean();
|
outputBean.setWorkorder(id);
|
outputBean.setStim(DateUtil.formatDateToString(date, "yyyy-MM-dd HH:mm:ss"));//保证工单与生产实绩开始时间同步。
|
statService.addOutput(outputBean, 0);
|
//向 redis 中保存辅料计数参数
|
this.setCalcValue(schWorkorder);
|
|
//2运行-4完成-5终止 信号反馈MES -将数采编号转换成MES编号
|
FixCodeBean fcb = SysEqpTypeBase.getFixCodeByMesCode(sts.toString(), "WK001", false);
|
DASSendOrderChange(fcb.getMesCode(), schWorkorder);
|
|
}/*else{
|
throw new RuntimeException(status==2?"该工单已经在运行！！":status==4?"完成状态的工单不可运行！！":"该工单不可运行，请联系管理员！");
|
}*/
|
} else if (sts == 0) {//表示 手动托班，需要手动结束工单
|
schWorkorder.setIsAuto("N");//表示 手动结束工单
|
}
|
if (sts == 4) { // 工单结束
|
String ecode = schWorkorder.getMdEquipment().getEquipmentCode(); // 设备code
|
RedisUtil.del(ecode + "CC");
|
RedisUtil.del(ecode + "WK");
|
|
Map<String, Object> dbOutputOrInputInfos = RedisUtil.getMap("outputInput");
|
DbOutputOrInputInfos info = (DbOutputOrInputInfos) JSONUtil.JSONString2Bean(dbOutputOrInputInfos.get(ecode).toString(), DbOutputOrInputInfos.class);
|
OutputBean outputBean = new OutputBean();
|
if (info.getStatOutputId() != null) {
|
outputBean.setId(info.getStatOutputId());
|
//实绩完成时间
|
outputBean.setEtim(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
statServiceImpl.editOutput(outputBean);
|
|
}
|
schWorkorder.setRealEtim(new Date());//实绩结束时间
|
outputBean.setEqpCode(ecode);
|
outputBean.setWorkorder(schWorkorder.getId());
|
outputBean.setWorkorderCode(schWorkorder.getCode());
|
statService.saveEquipmentData(outputBean);
|
|
String sql = "select * from (select * from SCH_WORKORDER where type = ? and eqp = ? and stim < ? and del=0 and enable = 1 and sts = 4 order by stim desc ) where rownum <= 1";
|
List<?> lastOrder = schWorkorderDao.queryBySql(sql, schWorkorder.getType(), schWorkorder.getMdEquipment().getId(), schWorkorder.getStim());
|
if (lastOrder != null && lastOrder.size() > 0) {
|
Object[] oldOrder = (Object[]) lastOrder.get(0);
|
if (!schWorkorder.getMdMat().getId().equals(oldOrder[9].toString())) {
|
|
List<Object> params = new ArrayList<>();
|
params.add(schWorkorder.getMdTeam().getId());
|
params.add(oldOrder[7].toString());
|
params.add(schWorkorder.getMdShift().getId());
|
params.add(schWorkorder.getMdMat().getId());
|
params.add(oldOrder[6].toString());
|
params.add(oldOrder[9].toString());
|
params.add(schWorkorder.getDate());
|
params.add(DateUtil.strToDate(oldOrder[20].toString(), "yyyy-MM-dd HH:mm:ss"));
|
params.add(schWorkorder.getRealStim());
|
params.add(oldOrder[0].toString());
|
params.add(schWorkorder.getId());
|
|
schCalendarDao.updateBySql("INSERT INTO SCH_SHIFT_EXCHG(ID, TO_TEAM, HO_TEAM, TO_SHIFT, TO_MAT, HO_SHIFT, HO_MAT, " +
|
"DATE_, HO_TIME, TO_TIME, HO_ORDER, TO_ORDER, DEL,TYPE) VALUES (sys_guid(), ?,?,?,?,?,?,?,?,?,?,?,0,2)", params);
|
}
|
}
|
|
//2运行-4完成-5终止 信号反馈MES -将数采编号转换成MES编号
|
FixCodeBean fcb = SysEqpTypeBase.getFixCodeByMesCode(sts.toString(), "WK001", false);
|
DASSendOrderChange(fcb.getMesCode(), schWorkorder);
|
}
|
if (sts == 5) {
|
//删除生产实绩数据
|
statService.deleteOutputByWorkOrder(id);
|
}
|
|
schWorkorder.setSts(sts);
|
FillUserInfoUtil.fillUpdateUserInfo(schWorkorder, request);
|
|
/* 只有运行和完成状态才反馈mes
|
* FixCodeBean
|
* fcb=SysEqpTypeBase.getFixCodeByMesCode(sts.toString(),"WK001",false);
|
* DASSendOrderChange(fcb.getMesCode(), schWorkorder);
|
*/
|
|
} else {
|
log.error("id:" + id + "的工单不存在");
|
throw new Exception("id:" + id + "的工单不存在");
|
}
|
}
|
|
/**
|
* [功能说明]：向MES发送工单状态
|
*/
|
public void DASSendOrderChange(String sts, SchWorkorder schWorkorder) {
|
//将数据封装成XML
|
WorkOrderStatChangeInterceptor.getInstance().dasSendOrderChange(sts, schWorkorder);
|
}
|
|
|
/**
|
* @return void
|
* @title setCalcValue
|
* @description 运行工单时，向Redis保存辅料计数参数
|
* @author bsw
|
* @params [schWorkorder]
|
* @updateTime 16:37 2019/8/5 0005
|
**/
|
private void setCalcValue(SchWorkorder schWorkorder) throws Exception {
|
// 获得工单类型
|
/**
|
1: "卷烟机工单";
|
2: "包装机工单";
|
3: "封箱机工单";
|
4: "成型机工单";
|
*/
|
Long workorderType = schWorkorder.getType();
|
String equipmentCode = schWorkorder.getMdEquipment().getEquipmentCode();
|
String workOrderCode = schWorkorder.getCode();
|
RedisUtil.del(equipmentCode + "CC");
|
RedisUtil.del(equipmentCode + "WK");
|
Map<String, String> map = new HashMap<>();
|
String hql = "select mp.val,mp.mdMat.mdMatType.code from SchWorkorderBom bom,MdMatParam mp where bom.bom_lot_id=? and bom.mdMat.id=mp.mdMat.id";
|
List<Object[]> vals = schWorkorderDao.queryObjectArray(hql, schWorkorder.getBomVersion());
|
if (vals == null) {
|
throw new Exception("工单号:" + workOrderCode + " 物料信息未在辅料计数参数中配置，请联系管理员配置");
|
}
|
if (workorderType == 1) {
|
|
Double shuisongzhiValue = null; //水松纸系数
|
|
for (Object[] o : vals) {
|
if (o[1].toString().equals("3")) {//水松纸系数
|
shuisongzhiValue = Double.valueOf(o[0].toString());
|
}
|
}
|
//判断是否配置完整
|
if (shuisongzhiValue == null) {
|
throw new Exception("工单号:" + workOrderCode + " 水松纸辅料计数参数未配置");
|
}
|
map.put("ssz", shuisongzhiValue + "");
|
} else if (workorderType == 2) {
|
|
Double xiaohemoValue = null, //小盒膜系数
|
tiaohemoValue = null, //条盒膜系数
|
neichenzhiValue = null;//内衬纸系数
|
for (Object[] o : vals) {
|
if (o[1].toString().equals("5")) {//小盒膜系数
|
xiaohemoValue = Double.valueOf(o[0].toString());
|
}
|
if (o[1].toString().equals("6")) {//条盒膜系数
|
tiaohemoValue = Double.valueOf(o[0].toString());
|
}
|
if (o[1].toString().equals("9")) {//内衬纸系数
|
neichenzhiValue = Double.valueOf(o[0].toString());
|
}
|
}
|
//判断是否配置完整
|
if (xiaohemoValue == null) {
|
throw new Exception("工单号:" + workOrderCode + " 小盒膜辅料计数参数未配置");
|
}
|
if (tiaohemoValue == null) {
|
throw new Exception("工单号:" + workOrderCode + " 条盒膜辅料计数参数未配置");
|
}
|
if (neichenzhiValue == null) {
|
throw new Exception("工单号:" + workOrderCode + " 内衬纸辅料计数参数未配置");
|
}
|
map.put("xhm", xiaohemoValue + "");
|
map.put("thm", tiaohemoValue.toString());
|
map.put("ncz", neichenzhiValue.toString());
|
}
|
|
RedisUtil.setMap(equipmentCode + "CC", map);
|
|
}
|
|
@Override
|
public WorkOrderBean getWorkOrderById(String id) throws Exception {
|
SchWorkorder schWorkorder = schWorkorderDao.findById(SchWorkorder.class, id);
|
|
WorkOrderBean bean = BeanConvertor.copyProperties(schWorkorder, WorkOrderBean.class);
|
|
bean.setTeam(schWorkorder.getMdTeam().getName());
|
bean.setShift(schWorkorder.getMdShift().getName());
|
bean.setEquipment(schWorkorder.getMdEquipment().getEquipmentName());
|
bean.setMat(schWorkorder.getMdMat().getSimpleName());
|
bean.setId(schWorkorder.getId());
|
bean.setEqpcode(schWorkorder.getMdEquipment().getEquipmentCode());
|
bean.setEquipmentId(schWorkorder.getMdEquipment().getId());
|
|
|
return bean;
|
}
|
|
@LogAnno(operateType = "新增工单")
|
@Override
|
public void addOrder(WorkOrderBean workOrderBean) throws Exception {
|
SchWorkorder schWorkorder = BeanConvertor.copyProperties(workOrderBean, SchWorkorder.class);
|
List<SchWorkorder> workorders = schWorkorderDao.query("from SchWorkorder where ((? between stim and etim) or (? between stim and etim)) and mdEquipment.id = ? and del = 0 and enable = 1",
|
schWorkorder.getStim(), schWorkorder.getEtim(), workOrderBean.getEquipmentId());
|
if (workorders != null && workorders.size() > 0) {
|
throw new RuntimeException("工单时间与另一个工单时间重叠！");
|
}
|
schWorkorder.setMdUnit(new MdUnit(workOrderBean.getUnitId()));
|
schWorkorder.setMdEquipment(new MdEquipment(workOrderBean.getEquipmentId()));
|
schWorkorder.setMdTeam(new MdTeam(workOrderBean.getTeamId()));
|
schWorkorder.setMdMat(new MdMat(workOrderBean.getMatId()));
|
schWorkorder.setMdShift(new MdShift(workOrderBean.getShiftId()));
|
schWorkorder.setRunSeq(1L);
|
schWorkorder.setEnable(1L);
|
schWorkorder.setDel(0L);
|
schWorkorder.setIsCheck(0L);
|
schWorkorder.setIsAuto("Y");
|
List<Combobox> param = getParamVersionByProd(workOrderBean.getMatId());
|
if (param != null && param.size() == 1) {
|
schWorkorder.setParameterSetRevision(param.get(0).getId());
|
} else {
|
throw new RuntimeException("未找到工艺参数或工艺参数不唯一！");
|
}
|
FillUserInfoUtil.fillCreateUserInfo(schWorkorder, request);
|
schWorkorderDao.save(schWorkorder);
|
}
|
|
@Override
|
public void initAllRunnedWorkOrderCalcValues() throws Exception {
|
List<SchWorkorder> schWorkorders = schWorkorderDao.query("from SchWorkorder o where o.sts=2");
|
for (SchWorkorder schWorkorder : schWorkorders) {
|
this.setCalcValue(schWorkorder);
|
}
|
}
|
|
@LogAnno(operateType = "新增排班")
|
@Override
|
public boolean addPbWork(WorkOrderBean workOrderBean) throws Exception {
|
if (null != workOrderBean) {
|
String start = workOrderBean.getStim();//开始日期
|
String end = workOrderBean.getEtim();//结束日期
|
//一共多少天
|
int days = DateUtil.computerDiffDate(start.replaceAll("-", ""), end.replaceAll("-", ""));
|
if (days >= 0) {//表示 包含当前
|
//删除当前时间段的记录
|
StringBuffer hql = new StringBuffer();
|
hql.append("delete from SchCalendar s ");
|
List<Object> params = new ArrayList<Object>();
|
hql.append("where s.date>=? and s.date<=? and s.mdWorkshop.id=? ");
|
Date startDay = DateUtil.strToDate(start + " 00:00:00", "yyyy-MM-dd HH:mm:ss");
|
Date endDay = DateUtil.strToDate(end + " 23:59:59", "yyyy-MM-dd HH:mm:ss");
|
params.add(startDay);
|
params.add(endDay);
|
params.add(String.valueOf(workOrderBean.getType()));
|
schWorkorderDao.deleteByParams(hql.toString(), params);
|
this.addCurMonth((days + 1), workOrderBean);
|
}
|
}
|
return true;
|
|
}
|
|
/**
|
* 排班，现在具体的班次开始和结束时间还没有最后确定，最终结果等生产之后确认。现在使用的是MES系统的排班时间。成型车间和卷包车间是不同的排班
|
*/
|
public void addCurMonth(int days, WorkOrderBean workOrderBean) {
|
for (int j = 0; j < days; j++) {//2天
|
String stim = workOrderBean.getStim();
|
Date beginDay = DateUtil.strToDate(stim, "yyyy-MM-dd");
|
Date lastTime = null;
|
for (int i = 0; i < workOrderBean.getShiftnum(); i++) {
|
SchCalendar sch = new SchCalendar();
|
MdWorkshop mdWorkshop = new MdWorkshop();
|
String workShop = String.valueOf(workOrderBean.getType());
|
mdWorkshop.setId(workShop);//1.卷包车间 2.成型车间
|
sch.setId(UUID.randomUUID().toString());
|
sch.setMdWorkshop(mdWorkshop);
|
String begin = DateUtil.dateAdd("d", j, beginDay, "yyyy-MM-dd");
|
sch.setDate(DateUtil.strToDate(begin + " 00:00:00", "yyyy-MM-dd HH:mm:ss"));
|
MdShift mdShift = null;
|
MdTeam team = new MdTeam();
|
|
if (i == 0) {//早班
|
mdShift = shiftDao.findById(MdShift.class,workOrderBean.getShiftId());
|
lastTime = StimAndEtim(lastTime, sch, begin, mdShift);
|
team.setId(workOrderBean.getTeamId());
|
team.setName(workOrderBean.getTeamName());
|
} else if (i == 1) {//中班
|
mdShift = shiftDao.findById(MdShift.class,workOrderBean.getShiftTwoId());
|
if (HbUtils.isProxy(mdShift)){
|
mdShift = HbUtils.deproxy(mdShift);
|
}
|
lastTime = StimAndEtim(lastTime, sch, begin, mdShift);
|
team.setId(workOrderBean.getTeamTwoId());
|
team.setName(workOrderBean.getTeamTwoName());
|
} else if (i == 2) {//晚班
|
mdShift = shiftDao.findById(MdShift.class,workOrderBean.getShiftThreeId());
|
if (HbUtils.isProxy(mdShift)){
|
mdShift = HbUtils.deproxy(mdShift);
|
}
|
lastTime = StimAndEtim(lastTime, sch, begin, mdShift);
|
team.setId(workOrderBean.getTeamThreeId());
|
team.setName(workOrderBean.getTeamThreeName());
|
}
|
sch.setMdTeam(team);
|
sch.setMdShift(mdShift);
|
FillUserInfoUtil.fillCreateUserInfo(sch, request);
|
sch.setDel(0L);
|
schCalendarDao.save(sch);
|
}
|
}
|
}
|
|
public Date StimAndEtim(Date lastTime, SchCalendar sch, String begin, MdShift mdShift) {
|
Date newTime;
|
if(mdShift.getStim()==null || "".equals(mdShift.getStim())){
|
throw new RuntimeException("班次开始时间未设置，请在班次管理中维护");
|
}
|
if(mdShift.getEtim()==null || "".equals(mdShift.getEtim())){
|
throw new RuntimeException("班次结束时间未设置，请在班次管理中维护");
|
}
|
newTime = DateUtil.strToDate(begin + " " + mdShift.getStim(), "yyyy-MM-dd HH:mm");
|
sch.setStim(getRightDate(newTime, lastTime));
|
lastTime = sch.getStim();
|
|
newTime = DateUtil.strToDate(begin + " " + mdShift.getEtim(), "yyyy-MM-dd HH:mm");
|
sch.setEtim(getRightDate(newTime, lastTime));
|
|
return sch.getEtim();
|
}
|
|
|
public Date getRightDate(Date newTime,Date lastTime){
|
return lastTime!=null?newTime.getTime()>=lastTime.getTime()?newTime:DateUtil.dateAdd("d",1,newTime):newTime;
|
}
|
|
|
/**
|
* 批量新增指定机台数据
|
*
|
* @author luther.zhang
|
* @create 2015-04-29
|
*/
|
@LogAnno(operateType = "批量新增工单")
|
@Override
|
public boolean saveBatckWork(WorkOrderBean workBean) throws Exception{
|
// 设备信息
|
MdEquipment eqp = equipmentDao.findById(MdEquipment.class, workBean.getEquipmentId());
|
|
// 排班信息
|
List<SchCalendar> calendars = schCalendarDao.query("from SchCalendar where date >= ? and mdWorkshop.id = ? and date <= ?"
|
, DateUtil.strToDate(workBean.getStim(), "yyyy-MM-dd HH:mm:ss")
|
, workBean.getType() <= 3 ? "1" : "2" // 车间：1卷包；2成型 工单类型：1.卷烟机工单 2.包装机工单 3.封箱机工单 4.成型机工单
|
, DateUtil.strToDate(workBean.getEtim(), "yyyy-MM-dd HH:mm:ss"));
|
|
if (null != calendars && calendars.size() > 0) {
|
|
// 查询新增工单时间段内是否有正在运行或已经完成的工单
|
List<SchWorkorder> runOrders = schWorkorderDao.query("from SchWorkorder where date >= ? and date <= ? and type = ? and mdEquipment.id = ? and (sts = 2 or sts = 4) and enable = 1 and del = 0"
|
,DateUtil.strToDate(workBean.getStim(), "yyyy-MM-dd HH:mm:ss")
|
,DateUtil.strToDate(workBean.getEtim(), "yyyy-MM-dd HH:mm:ss")
|
,workBean.getType()
|
,workBean.getEquipmentId());
|
|
|
if (runOrders!=null && runOrders.size()>0){
|
throw new RuntimeException("不可覆盖！此时间段内有正在运行或已经完成的工单！");
|
}
|
|
//删除投料表
|
schWorkorderDao.updateInfo("delete SCH_STAT_INPUT where out_id in(" +
|
"SELECT b.id from SCH_WORKORDER a LEFT JOIN SCH_STAT_OUTPUT b ON a.id=b.oid " +
|
"WHERE a.DATE_>=to_date('" + workBean.getStim() + "','yyyy-MM-dd hh24:mi:ss') and a.DATE_<= to_date('" + workBean.getEtim() + "','yyyy-mm-dd hh24:mi:ss') " +
|
"and a.type='" + workBean.getType() + "' and a.EQP='" + workBean.getEquipmentId() + "')", null);
|
//删除产量数据表
|
schWorkorderDao.updateInfo("DELETE SCH_STAT_OUTPUT where oid in(" +
|
"select id from SCH_WORKORDER where DATE_>=to_date('" + workBean.getStim() + "','yyyy-MM-dd hh24:mi:ss') " +
|
"and DATE_<= to_date('" + workBean.getEtim() + "','yyyy-mm-dd hh24:mi:ss') and type='" + workBean.getType() + "' and EQP='" + workBean.getEquipmentId() + "')", null);
|
//删除工单表
|
schWorkorderDao.updateInfo("DELETE SCH_WORKORDER where id in(" +
|
"select id from SCH_WORKORDER where DATE_>=to_date('" + workBean.getStim() + "','yyyy-MM-dd hh24:mi:ss') " +
|
"and DATE_<= to_date('" + workBean.getEtim() + "','yyyy-mm-dd hh24:mi:ss') and type='" + workBean.getType() + "' and EQP='" + workBean.getEquipmentId() + "')", null);
|
|
for (SchCalendar calendar : calendars) {
|
// 工单号生成规则 设备代码+六位当前日期+班次+班组+#010/#020
|
// 发射机暂时没有代码 故用“T“ + 机台号
|
String code = (eqp.getWorkCenter() == null ? "T" + (eqp.getEquipmentCode().substring(1)) : eqp.getWorkCenter()) +
|
DateUtil.datetoStr(calendar.getStim(), "yyMMdd") + calendar.getMdShift().getId() + calendar.getMdTeam().getId() + ((workBean.getType() == 2) ? "#020" : "#010");
|
|
//增加创建人与创建时间信息
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
|
//新增工单
|
try {
|
SchWorkorder workorder = new SchWorkorder();
|
workorder.setId(UUID.randomUUID().toString().replace("-", ""));
|
workorder.setCode(code);
|
workorder.setBth(code.replaceAll("#", ""));
|
workorder.setIsNew(1L);
|
workorder.setType(workBean.getType());
|
workorder.setProdType(1L);
|
workorder.setMdShift(calendar.getMdShift());
|
workorder.setMdTeam(calendar.getMdTeam());
|
workorder.setMdEquipment(new MdEquipment(workBean.getEquipmentId()));
|
workorder.setMdMat(new MdMat(workBean.getMatId()));
|
workorder.setQty(workBean.getQty());
|
workorder.setMdUnit(new MdUnit(workBean.getUnitId()));
|
workorder.setDate(calendar.getDate());
|
workorder.setStim(calendar.getStim());
|
workorder.setEtim(calendar.getEtim());
|
workorder.setBomVersion(workBean.getBomVersion());
|
workorder.setSts(1L);
|
workorder.setIsCheck(0L);
|
workorder.setRunSeq(1L);
|
workorder.setEnable(1L);
|
workorder.setDel(0L);
|
workorder.setIsAuto("Y");
|
workorder.setParameterSetRevision(workBean.getParameterSetRevision());
|
workorder.setCreateUserName(sessionInfo.getUser().getName());
|
workorder.setCreateUserTime(new Date());
|
workorder.setUpdateUserName(sessionInfo.getUser().getName());
|
workorder.setUpdateUserTime(new Date());
|
schWorkorderDao.save(workorder);
|
} catch (Exception e) {
|
log.error("新增工单 报错:" + e.getMessage());
|
throw e;
|
}
|
}
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
/**
|
* 批量新增指定机台数据
|
*
|
* @author luther.zhang
|
* @create 2015-04-29
|
*/
|
@LogAnno(operateType = "新增发射机工单")
|
@Override
|
public boolean saveBatckWorkFSJ(TransmitterWorkOrderBean workBean, String date1, String date2) throws Exception{
|
//查询该设备在该事件段内是否有工单
|
String queryOrder = "SELECT * FROM SCH_TRANSMITTER_WKORDER WHERE DATE_ >= TO_DATE('"+date1+"', 'SYYYY-MM-DD HH24:MI:SS') AND DATE_ <= TO_DATE('"+date2+"', 'SYYYY-MM-DD HH24:MI:SS')" +
|
" AND EQP_ID = '"+workBean.getEqpId()+"' AND (sts = 2 or sts = 4) AND DEL = 0" ;
|
List<?> objects = schWorkorderDao.queryBySql(queryOrder);
|
|
if (objects!=null && objects.size()>0){
|
throw new RuntimeException("不可覆盖！此时间段内有正在运行或已经完成的工单！");
|
}
|
|
|
//1.查询换班时间 SHIFT是班次(早中晚)
|
//2.假删除大于今天的所有工单 以及 辅料
|
//for循环begin
|
//新增工单，新增工单对应的辅料数据
|
//end
|
String workshop = "2";
|
StringBuffer sql = new StringBuffer();
|
sql.append("select ID,SHIFT,TEAM,to_char(STIM,'yyyy-mm-dd hh24:mi:ss'),to_char(ETIM,'yyyy-mm-dd hh24:mi:ss'),WORKSHOP,to_char(date_,'yyyy-MM-dd') as pDate from SCH_CALENDAR ");
|
sql.append("where date_>=to_date(?,'yyyy-mm-dd hh24:mi:ss') and DEL=0 and WORKSHOP=? and date_<=to_date(?,'yyyy-mm-dd hh24:mi:ss') ");
|
|
date1 = date1.trim() + " 00:00:00";//如果是 5.10
|
date2 = date2.trim() + " 23:59:59";//如果是 5.10
|
// 设备信息
|
MdEquipment eqp = equipmentDao.findById(MdEquipment.class, workBean.getEqpId());
|
|
List<Object> params = new ArrayList<Object>();
|
params.add(date1);
|
params.add(workshop);
|
params.add(date2);
|
List<?> list = schWorkorderDao.queryBySql(sql.toString(), params);
|
|
|
if (null != list && list.size() > 0) {
|
//假删除所有工单 (修改成删除时间段内的工单)
|
StringBuffer temp = new StringBuffer();
|
////////////////////////真删除式覆盖工单/////////////////////////////
|
//覆盖删除该时间段内的工单相关数据
|
//删除产量数据表
|
temp = new StringBuffer();
|
temp.append("DELETE SCH_TRANSMITTER_OUTPUT where Tw_ID in(select id from SCH_TRANSMITTER_WKORDER where DATE_>=to_date('" + date1 + "','yyyy-MM-dd hh24:mi:ss') and DATE_<= to_date('" + date2 + "','yyyy-mm-dd hh24:mi:ss') and order_type='" + workBean.getOrderType() + "' and EQP_ID='" + workBean.getEqpId() + "')");
|
schWorkorderDao.updateInfo(temp.toString(), null);
|
//删除工单表
|
temp = new StringBuffer();
|
temp.append("DELETE SCH_TRANSMITTER_WKORDER where id in(select id from SCH_TRANSMITTER_WKORDER where DATE_>=to_date('" + date1 + "','yyyy-MM-dd hh24:mi:ss') and DATE_<= to_date('" + date2 + "','yyyy-mm-dd hh24:mi:ss') and order_type='" + workBean.getOrderType() + "' and EQP_ID='" + workBean.getEqpId() + "')");
|
schWorkorderDao.updateInfo(temp.toString(), null);
|
/////////////////////////////////end//////////////////////////////
|
|
|
List<Combobox> comboxList = BaseParams.getAllEqpsCombobox(false);
|
for (int i = 0; i < list.size(); i++) {
|
Object[] arr = (Object[]) list.get(i);
|
//String key = ObjectUtils.toString(arr[0]);//主键
|
String shift = ObjectUtils.toString(arr[1]);//SHIFT是班次(早中晚)
|
String team = ObjectUtils.toString(arr[2]);//班组 甲乙丙
|
String stim = ObjectUtils.toString(arr[3]);//开始时间 yyyy-MM-dd HH:mm:ss
|
String etim = ObjectUtils.toString(arr[4]);//结束时间 yyyy-MM-dd HH:mm:ss
|
String pDate = ObjectUtils.toString(arr[6]);//工单日期
|
Date startTime = DateUtil.strToDate(stim, "yyyy-MM-dd HH:mm:ss");
|
String startStr = DateUtil.datetoStr(startTime, "yyMMdd");
|
Date pDateTime = DateUtil.strToDate(pDate, "yyyy-MM-dd");
|
// 工单号生成规则 设备代码+六位当前日期+班次+班组+#010/#020
|
// 发射机暂时没有代码 故用“T“ + 机台号
|
String code = (eqp.getWorkCenter() == null ? "T" + (eqp.getEquipmentCode().substring(1)) : eqp.getWorkCenter()) + startStr + shift + team + "#010";
|
|
String workId = UUID.randomUUID().toString().replace("-", "");
|
//增加创建人与创建时间信息
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
String createUserName = sessionInfo.getUser().getName();
|
String createUserTime = DateUtil.datetoStr(new Date(), "yyyy-MM-dd HH:mm:ss");
|
String updateUserName = createUserName;
|
String updateUserTime = createUserTime;
|
//新增工单
|
temp = new StringBuffer();
|
temp.append("insert into SCH_TRANSMITTER_WKORDER(")
|
.append("ID,WORK_ORDER_CODE,BATCH_CODE,ORDER_TYPE,PRODUCT_TYPE,SHIFT,TEAM,EQP_ID,MATERIAL_CODE,")
|
.append("PLAN_QUANTITY,UNIT,DATE_,STIM,ETIM,STS,IS_CHECK,DEL,IS_FEEDBACK,CREATE_USER_NAME,CREATE_USER_TIME,UPDATE_USER_NAME,UPDATE_USER_TIME ) values(")
|
.append(" '" + workId + "','" + code + "','" + code.replaceAll("#", "") + "','" + workBean.getOrderType() //ID,CODE,BTH,IS_NEW,TYPE
|
+ "','1','" + shift + "','" + team + "','" + workBean.getEqpId() + "','" + workBean.getMaterialCode() + "' ")
|
.append(",'" + workBean.getQty() + "','" + workBean.getUnit()
|
+ "',to_date('" + DateUtil.datetoStr(pDateTime, "yyyy-MM-dd") + "','yyyy-mm-dd'),to_date('" + stim + "','yyyy-mm-dd hh24:mi:ss'),to_date('" + etim
|
+ "','yyyy-mm-dd hh24:mi:ss'),'1','0','0','0','" + createUserName + "',to_date('" + createUserTime + "','yyyy-mm-dd hh24:mi:ss'),'" + updateUserName + "',to_date('" + updateUserTime + "','yyyy-mm-dd hh24:mi:ss')) ");
|
try {
|
schWorkorderDao.updateInfo(temp.toString(), null);
|
|
} catch (Exception e) {
|
log.error("新增工单 报错:" + e.getMessage());
|
}
|
}
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
@Override
|
public long queryTransmitterOrderByCode(String workOrderCode) {
|
try {
|
String hql = "select count(1) from TransmitterWorkOrderBean o where o.del=0 and o.workOrderCode=? ";
|
long num = mdMatDao.queryTotal(hql, workOrderCode);
|
return num;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return 0;
|
}
|
|
|
/**
|
* 根据条件查询 工单
|
*
|
* @param sts 工单状态：2运行工单，1.下发工单
|
* @param isAuto 是否 自动模式 （Y or null）;N 表示 拖班 手动模式
|
* @param isCheck 1:审核通过 0 审核未通过
|
* @param mdShiftCode 班次
|
* @param mdTeamCode 班组
|
* @param workshopCode 工作车间
|
* @param workType 开启 or 关闭 工单
|
* @param date1 前后结束时间
|
* @param date2 结束时间
|
* @param params 条件集合
|
* @param qcEqp 去除不开启工单的机台
|
* @return
|
*/
|
public List<?> getSchWorkorderList(String sts, String isCheck, String isAuto, String mdShiftCode, String mdTeamCode,
|
String workshopCode, String workType, String date1, String date2,
|
List<Object> params, String qcEqp) {
|
StringBuffer sql = new StringBuffer();
|
sql.append("select m.EQUIPMENT_NAME, m.EQUIPMENT_CODE ,s.id,s.TYPE,s.EQP,s.mat,");//5个
|
sql.append("s.date,s.STIM,s.ETIM,s.sts,s.IS_CHECK,s.RUN_SEQ,s.IS_AUTO,s.SHIFT,s.TEAM ");//5+9=14
|
sql.append(" from SCH_WORKORDER s WITH (NOLOCK) left join MD_EQUIPMENT m WITH (NOLOCK) on s.EQP=m.id ");
|
sql.append(" where s.DEL=0 ");
|
sql.append(" and s.STS=? and s.IS_CHECK=? ");
|
params.add(sts);//运行工单
|
params.add(isCheck);//审核通过
|
if ("START".equals(workType)) {
|
sql.append(" and (s.IS_AUTO=? or s.IS_AUTO is null) ");
|
sql.append(" and s.SHIFT=? and s.TEAM=? ");
|
params.add(isAuto);//是否托班 标识
|
params.add(mdShiftCode);//班次
|
params.add(mdTeamCode);//班组
|
sql.append(" and s.STIM>=? and s.STIM<=? ");
|
params.add(date1);//开始时间 //2015-04-18 15:00:00.0
|
params.add(date2);//结束时间 //2015-04-18 15:10:00
|
if ("Y".equals(qcEqp)) {//有拖班的工单，不开启该机台的下一个工单
|
sql.append(" and s.EQP not in (select distinct s.EQP from SCH_WORKORDER s WITH (NOLOCK) ")
|
.append(" where s.DEL=0 and IS_CHECK=1 and STS=1 and IS_AUTO='N' ) ");//审核通过，运行的+ 手动模式工单
|
}
|
} else if ("END1".equals(workType)) {
|
sql.append(" and (s.IS_AUTO=? or s.IS_AUTO is null) ");
|
sql.append(" and s.SHIFT=? and s.TEAM=? ");
|
params.add(isAuto);//是否托班 标识
|
params.add(mdShiftCode);//班次
|
params.add(mdTeamCode);//班组
|
sql.append(" and s.ETIM>=? and s.ETIM<=? ");
|
params.add(date1);//开始时间2015-04-18 22:50:00
|
params.add(date2);//结束时间2015-04-18 23:00:00.0
|
} else if ("END2".equals(workType)) {
|
sql.append(" and s.REAL_STIM<=? ");
|
params.add(date1);//开始时间 2015-04-18 06:00:00
|
}
|
List<?> list = schWorkorderDao.queryBySql(sql.toString(), params);
|
return list;
|
}
|
|
|
/**
|
* 查询上一班次采集数据详细
|
*
|
* @createTime 2015年10月26日08:35:09
|
* @author wanchanghuang
|
*/
|
@Override
|
public Map<Integer, List<ChangeShiftDatas>> getMapChangeShiftDates(ChangeShiftDatas csd) {
|
StringBuffer sbf = new StringBuffer();
|
sbf.append(" select c.equipment_code,sum(b.qty)from SCH_WORKORDER a,SCH_STAT_OUTPUT b,MD_EQUIPMENT c where a.id=b.oid and a.eqp=c.id and a.sts='4' ");
|
//获得班次
|
Integer shift = csd.getShift();
|
//dac采集 0=早班 1=中班 2=晚班 -> 数据库 1=早班 2=中班 3=晚班
|
if (shift == 2) { //=1，查询早班
|
sbf.append(" and a.shift in ('" + (shift - 1) + "')");
|
} else if (shift == 3) { //=2 ，查询早班+中班
|
sbf.append(" and a.shift in ('" + (shift - 2) + "','" + (shift - 1) + "')");
|
}
|
//时间
|
sbf.append(" and convert(varchar(24),a.date,23)='" + csd.getDate() + "'");
|
//设备表code
|
sbf.append(" group by c.equipment_code ");
|
List<?> list = schWorkorderDao.queryBySql(sbf.toString());
|
ChangeShiftDatas shiftDataf = null;
|
List<ChangeShiftDatas> listShiftDatas = new ArrayList<ChangeShiftDatas>();
|
Map<Integer, List<ChangeShiftDatas>> map = new HashMap<Integer, List<ChangeShiftDatas>>();
|
//将object转换成bean
|
if (list.size() > 0) {
|
for (Object o : list) {
|
shiftDataf = new ChangeShiftDatas();
|
Object[] temp = (Object[]) o;
|
shiftDataf.setEquipment_code(temp[0].toString());
|
shiftDataf.setQty(Double.parseDouble(temp[1].toString()));
|
listShiftDatas.add(shiftDataf);
|
}
|
}
|
map.put(shift, listShiftDatas);
|
return map;
|
}
|
|
|
/**
|
* 删除工单
|
* shisihai
|
*/
|
@LogAnno(operateType = "删除工单")
|
@Override
|
public void deleteWorkOrders(String ids, String eqpName, String team, String date, String mat, SessionInfo info) {
|
this.deleteWorkOrderData(ids, eqpName, team, date, mat, info);
|
}
|
|
/**
|
* 删除工单和辅料数据
|
*
|
* @param id
|
*/
|
private void deleteWorkOrderData(String id, String eqpName, String team, String date, String mat, SessionInfo info) {
|
try {
|
|
//删除投料表
|
String sql = "delete SCH_STAT_INPUT where out_id=(SELECT b.id from SCH_WORKORDER a LEFT JOIN SCH_STAT_OUTPUT b ON a.id=b.oid WHERE oid='" + id + "')";
|
schWorkorderDao.updateBySql(sql, null);
|
//删除产量数据表
|
sql = "DELETE from SCH_STAT_OUTPUT where oid='" + id + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
//删除工单表
|
sql = "DELETE from SCH_WORKORDER where id='" + id + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
|
SysLog log = new SysLog();
|
log.setSys("PMS");
|
if (info != null) {
|
log.setName(info.getUser().getName());//操作人
|
log.setIp(info.getIp());
|
}
|
log.setOptname("删除工单以及与此工单相关的产量/辅料数据操作");//操作名或路径
|
log.setParams("删除的工单id:" + id + " 机台：" + eqpName + " 班组：" + team + " 牌号：" + mat + " 工单时间：" + date);//参数
|
log.setSuccess("操作成功");
|
log.setDate(new Date());
|
log.setDel(0L);
|
logdao.save(log);
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
|
/**
|
* 批量删除工单
|
*
|
* @param ids
|
* @param eqpName
|
* @param team
|
* @param date
|
* @param mat
|
* @param info
|
*/
|
@LogAnno(operateType = "批量删除工单")
|
@Override
|
public void deleteBeatchWorkOrders(String ids, String eqpName, String team, String date, String mat,
|
SessionInfo info) {
|
try {
|
String[] id = ids.split(",");
|
String[] ens = eqpName.split(",");
|
String[] ts = team.split(",");
|
String[] ds = date.split(",");
|
String[] ms = mat.split(",");
|
for (int i = 0; i < id.length; i++) {
|
this.deleteWorkOrderData(id[i], ens[i], ts[i], ds[i], ms[i], info);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 【功能说明】：MES工单撤销
|
*
|
* @author wanchanghuang
|
* @createTime 2016年1月13日10:36:22
|
* @state 1-审核完成状态
|
*/
|
@Override
|
public boolean updateTntryCancel(SchWorkorder pxd) {
|
StringBuffer sbf = new StringBuffer();
|
sbf.append("update SCH_WORKORDER set sts='" + pxd.getSts() + "' ,del='1',enable='0' where erp_code='" + pxd.getCode() + "' ");
|
schWorkorderDao.updateInfo(sbf.toString(), null);
|
return true;
|
}
|
|
/**
|
* 【功能说明】：工单信号
|
*
|
* @return
|
* @author wch
|
* @createTime 2015年12月18日09:07:30
|
* 步骤：1）通过工单号查询，是否存在，存在再继续修改开始时间，结束时间，
|
* 工单状态为运行状态
|
*/
|
@Override
|
public boolean deleteAndCancelWS(ParsingXmlDataBean pxd) {
|
StringBuffer sbf = new StringBuffer();
|
SysLog slog = new SysLog();
|
slog.setName("MES接口");
|
try {
|
slog.setIp(InetAddress.getLocalHost().getHostAddress());
|
} catch (Exception e) {
|
// TODO: handle exception
|
}
|
slog.setSys("MES");
|
sbf.append(" select id from SCH_WORKORDER where code='" + pxd.getWo_id() + "' and sts<>2 and del=0 and eqp='" + pxd.getEqu_id() + "' and erp_code='" + pxd.getLot_id() + "' ");
|
List<?> lt = schWorkorderDao.queryBySql(sbf.toString());
|
if (lt.size() > 0 && lt != null) {
|
sbf.setLength(0); //清空
|
sbf.append(" update SCH_WORKORDER set stim='" + pxd.getStartTime() + "' ,etim='" + pxd.getEndTime() + "' and sts=2 where eqp='" + pxd.getEqu_id() + "' and code='" + pxd.getWo_id() + "' and bth='" + pxd.getMod_id() + "' and erp_code='" + pxd.getLot_id() + "' ");
|
}
|
slog.setSuccess("操作成功");
|
slog.setDate(new Date());
|
slog.setDel(0l);
|
sysLogDaoImpl.saveBackKey(slog);
|
return true;
|
}
|
|
/**
|
* [功能说明]：质量接口-基础表QUALITY_INSPECTION
|
*
|
* @author wanchanghuang
|
* @crateTime 2016年1月12日16:40:37
|
*/
|
@Override
|
public QualityCheckInfo saveQualityInfo(QualityCheckInfo qci) {
|
try {
|
qci = infoDao.saveAndReturn(qci);
|
} catch (Exception e) {
|
// TODO: handle exception
|
}
|
|
return qci;
|
}
|
|
/**
|
* [功能说明]：质量接口-基础详细QUALITY_INSPECTION_PARAM
|
*
|
* @author wanchanghuang
|
* @crateTime 2016年1月12日16:40:37
|
*/
|
@Override
|
public void saveQualityParamInfo(QualityCheckInfoParams qcip) {
|
InfoParamsDao.save(qcip);
|
}
|
|
/**
|
* [功能描述]：接口解析完成，调用日志
|
*
|
* @author wanchanghuang
|
* @createTime 2016年1月12日17:36:35
|
*/
|
@Override
|
public void saveAndReturn(SysMessageQueue log) {
|
try {
|
SysMessageQueueDao.saveAndReturn(log);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
/**
|
* [功能描述]：接口解析,保存工厂日历
|
*
|
* @author wanchanghuang
|
* @createTime 2016年1月13日09:37:12
|
*/
|
@Override
|
public void saveSchCalendar(SchCalendar scr1) {
|
schCalendarDao.save(scr1);
|
}
|
|
@Override
|
public boolean batchInsertAndReturn(List<SchCalendar> schCalendars) {
|
return schCalendarDao.batchInsertAndReturn(schCalendars, SchCalendar.class);
|
}
|
|
/**
|
* [功能描述]：接口解析,保存工单下发主数据
|
*
|
* @author wanchanghuang
|
* @createTime 2016年1月13日09:37:12
|
*/
|
@Override
|
public SchWorkorder addSchWorkOrder(SchWorkorder swd) {
|
try {
|
swd = schWorkorderDao.saveAndReturn(swd);
|
} catch (Exception e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return swd;
|
}
|
|
/**
|
* [功能描述]：接口解析,保存工单下发辅料数据
|
*
|
* @author wanchanghuang
|
* @createTime 2016年1月13日09:37:12
|
*/
|
@Override
|
public void saveSchWorkOrderBom(SchWorkorderBom swb) {
|
schWorkorderBomDao.save(swb);
|
}
|
|
/**
|
* [功能描述]：查询md_mat_type表数据,存在返回ID，不存在插入返回主键ID
|
*
|
* @param mmt:mes传过来的物料组ID
|
*/
|
@Override
|
public String queryRetByCode(MdMatType mmt) {
|
StringBuffer sbf = new StringBuffer();
|
sbf.append("select id from MD_MAT_TYPE where mes_code='" + mmt.getMesCode() + "'");
|
List<?> list = schWorkorderBomDao.queryBySql(sbf.toString());
|
if (list.size() > 0) {
|
Object temp = list.get(0);
|
return StringUtil.convertObjToString(temp);
|
} else {
|
return mdMatTypeDao.saveBackKey(mmt);
|
}
|
|
}
|
|
/**
|
* [功能说明]：插入md_mat表数据，且验证是否重复插入
|
*
|
* @author wanchanghuang
|
* @createTime 2016年2月25日13:14:45
|
*/
|
@Override
|
public void saveMdMatByCode(MdMat mm) {
|
StringBuffer sbf = new StringBuffer();
|
sbf.append("select id from MD_MAT where code='" + mm.getCode() + "' and tid='" + mm.getMdMatType().getId() + "'");
|
List<?> list = schWorkorderBomDao.queryBySql(sbf.toString());
|
if (list != null && list.size() <= 0) {
|
mdMatDao.save(mm);
|
} else {
|
String id = StringUtil.convertObjToString(list.get(0));
|
mm.setId(id);
|
mdMatDao.saveOrUpdate(mm);
|
}
|
}
|
|
@Override
|
public void deleteCalendar(SchCalendar sCalendars, SchCalendar eCalendars) {
|
schCalendarDao.deleteByParams("delete SchCalendar o where o.date >=? and o.date <=? and mdWorkshop=? ", sCalendars.getDate(), eCalendars.getDate(), sCalendars.getMdWorkshop());
|
}
|
|
@Override
|
public String CancelRequestWorkOrderByCode(String workCode, boolean CancelRequest) throws Exception {
|
StringBuffer sql = new StringBuffer("SELECT id FROM SCH_WORKORDER o WHERE o.CODE='" + workCode + "'");
|
if (CancelRequest) {
|
sql.append(" and o.STS <> '2' AND o.STS<> '4' ");//工单非运行、非完成状态
|
} else {
|
sql.append(" and o.STS='7' ");//工单锁定状态
|
}
|
List<?> ls = schCalendarDao.queryBySql(sql.toString());
|
if (ls == null || ls.size() != 1) {
|
return null;
|
}
|
return ls.get(0).toString();
|
}
|
|
|
/**
|
* MES请求撤销工单，修改工单状态
|
*/
|
@Override
|
public void MESRequestCancelWorkOrder(String workOrderId, Long sts) throws Exception {
|
SchWorkorder schWorkorder = schWorkorderDao.findById(SchWorkorder.class, workOrderId);
|
//锁定状态（1-允许，0-不允许）。当为7时表示已经允许
|
schWorkorder.setSts(sts);
|
|
}
|
|
/**
|
* 接口批量插入工单
|
*/
|
@Override
|
public void batchAddSchWorkOrder(List<SchWorkorder> orders) throws Exception {
|
schWorkorderDao.batchInsert(orders, SchWorkorder.class);
|
}
|
|
/**
|
* 接口批量插入工单bom
|
*/
|
@Override
|
public void batchAddSchWorkOrderBom(List<SchWorkorderBom> ordersBoms) throws Exception {
|
schWorkorderBomDao.batchInsert(ordersBoms, SchWorkorderBom.class);
|
|
}
|
|
@Override
|
public boolean isExistByWorkOrderCode(String orderCode) throws Exception {
|
String sql = "SELECT id from SCH_WORKORDER where code='" + orderCode + "'";
|
List<?> ls = schWorkorderDao.queryBySql(sql);
|
if (ls != null && ls.size() > 0) {
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
public void deleteOrderByCode(String orderId) throws Exception {
|
try {
|
//删除辅料表数据
|
String sql = "DELETE from SCH_WORKORDER_BOM where OID='" + orderId + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
//删除工单表
|
sql = "DELETE from SCH_WORKORDER where id='" + orderId + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
SysLog log = new SysLog();
|
log.setSys("PMS");
|
log.setName("MES确认撤销工单");//操作人
|
log.setOptname("删除工单以及与此工单相关Bom");//操作名或路径
|
log.setParams("删除的工单id:" + orderId);//参数
|
log.setSuccess("操作成功");
|
log.setDate(new Date());
|
log.setDel(0L);
|
logdao.save(log);
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new Exception("查询并删除处于MES确认撤销状态的工单失败！该工单id：" + orderId);
|
}
|
|
}
|
|
@Override
|
public SchWorkorder getSchWorkorderById(String id) {
|
return schWorkorderDao.findById(SchWorkorder.class, id);
|
}
|
|
@Override
|
public void updateOrder(String ids) {
|
// TODO Auto-generated method stub
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
String updateUserName = sessionInfo.getUser().getName();
|
String updateUserTime = DateUtil.datetoStr(new Date(), "yyyy-MM-dd HH:mm:ss");
|
String sql = "UPDATE SCH_STAT_OUTPUT_FB set IS_FEEDBACK='1',UPDATE_USER_NAME = '" + updateUserName + "' ,FEEDBACK_TIME=to_date('"+updateUserTime+"','yyyy-mm-dd hh24:mi:ss'),UPDATE_USER_TIME = to_date('" + updateUserTime + "','yyyy-mm-dd hh24:mi:ss') where id='" + ids + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
|
}
|
|
@Override
|
public void updateFSJOrder(String ids) {
|
try {
|
String updateUserTime = DateUtil.datetoStr(new Date(), "yyyy-MM-dd HH:mm:ss");
|
String sql = "UPDATE SCH_TRANSMITTER_WKORDER set IS_FEEDBACK='1',FEEDBACK_TIME=to_date('"+updateUserTime+"','yyyy-mm-dd hh24:mi:ss') where id='" + ids + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* Rengj
|
* 运行时间修改
|
*/
|
@LogAnno(operateType = "编辑运行时间")
|
@Override
|
public String editRuntime(String stim, String etim, String ids) {
|
String result = "";
|
try {
|
//增加创建人与创建时间信息
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
String createUserName = sessionInfo.getUser().getName();
|
String createUserTime = DateUtil.datetoStr(new Date(), "yyyy-MM-dd HH:mm:ss");
|
String sql = "update SCH_WORKORDER set stim = to_date('" + stim + "','yyyy-MM-dd hh24:mi:ss'),etim = to_date('" + etim + "','yyyy-MM-dd hh24:mi:ss'),UPDATE_USER_NAME = '" + createUserName + "',UPDATE_USER_TIME = to_date('" + createUserTime + "','yyyy-MM-dd hh24:mi:ss') where id= '"
|
+ ids + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
String sql2 = "update SCH_TRANSMITTER_WKORDER set stim = to_date('" + stim + "','yyyy-MM-dd hh24:mi:ss'),etim = to_date('" + etim + "','yyyy-MM-dd hh24:mi:ss'),UPDATE_USER_NAME = '" + createUserName + "',UPDATE_USER_TIME = to_date('" + createUserTime + "','yyyy-MM-dd hh24:mi:ss') where id= '"
|
+ ids + "'";
|
schWorkorderDao.updateBySql(sql2, null);
|
result = "保存成功！";
|
} catch (Exception e) {
|
result = "保存失败！";
|
}
|
return result;
|
}
|
|
/**
|
* Rengj
|
* 运行时间查询
|
*/
|
@Override
|
public WorkOrderBean getRuntime(String ids) {
|
WorkOrderBean workOrder = new WorkOrderBean();
|
String sql = "select to_char(stim,'yyyy-MM-dd hh24:mi:ss'),to_char(etim,'yyyy-MM-dd hh24:mi:ss') from SCH_WORKORDER where id='" + ids + "'";
|
String sq2 = "select to_char(stim,'yyyy-MM-dd hh24:mi:ss'),to_char(etim,'yyyy-MM-dd hh24:mi:ss') from SCH_TRANSMITTER_WKORDER where id='" + ids + "'";
|
List workList = schWorkorderDao.queryBySql(sql);
|
List list2 = schWorkorderDao.queryBySql(sq2);
|
workList.addAll(list2);
|
if (workList.size() > 0) {
|
Object[] obj = (Object[]) workList.get(0);
|
workOrder.setStim(String.valueOf(obj[0]));
|
workOrder.setEtim(String.valueOf(obj[1]));
|
}
|
return workOrder;
|
}
|
|
/**
|
* [功能说明]：验证发射机工单code是否重复
|
*
|
* @author wanchanghuanbg
|
* @date 2017年10月18日15:12:45
|
*/
|
@Override
|
public boolean isExistByWorkOrderCodeFSJ(String workOrderCode) {
|
String sql = "SELECT id from SCH_TRANSMITTER_WKORDER where del=0 and WORK_ORDER_CODE='" + workOrderCode + "'";
|
List<?> ls = schWorkorderDao.queryBySql(sql);
|
if (ls != null && ls.size() > 0) {
|
return true;
|
}
|
return false;
|
}
|
|
/**
|
* [功能说明]：保存发射机工单
|
*
|
* @author wanchanghuanbg
|
* @date 2017年10月18日15:12:45
|
*/
|
@Override
|
public void saveTransmitterWorkOrder(TransmitterWorkOrderBean tbean) {
|
transmitterWorkOrderDaoI.save(tbean);
|
}
|
|
@Override
|
public TransmitterWorkOrderBean getRunOrders(String eqp) throws Exception {
|
String hql = "from TransmitterWorkOrderBean o where o.del=0 and o.sts=2 and o.eqpId=? ";
|
List<Object> params = new ArrayList<Object>();
|
params.add(eqp);
|
TransmitterWorkOrderBean schWorkorder = null;
|
try {
|
schWorkorder = transmitterWorkOrderDaoI.unique(TransmitterWorkOrderBean.class, hql, params);
|
} catch (Exception e) {
|
log.debug("error :" + e.getMessage());
|
}
|
return schWorkorder;
|
}
|
|
@Override
|
public DataGrid getAllFSJOrders(TransmitterWorkOrderBean workOrderBean, PageParams pageParams) throws Exception {
|
String hql = "from TransmitterWorkOrderBean o where o.del=0 ";
|
String params = "";
|
if (StringUtil.notNull(workOrderBean.getTeam())) {
|
params = params.concat(" and o.team = '" + workOrderBean.getTeam() + "'");
|
}
|
if (StringUtil.notNull(workOrderBean.getShift())) {
|
params = params.concat(" and o.shift = '" + workOrderBean.getShift() + "'");
|
}
|
if (StringUtil.notNull(workOrderBean.getQstim())) {
|
params = params.concat(" and to_char(o.date_,'yyyy-MM-dd') >= '" + workOrderBean.getQstim() + "'");
|
}
|
if (StringUtil.notNull(workOrderBean.getQetim())) {
|
params = params.concat(" and to_char(o.date_,'yyyy-MM-dd') <= '" + workOrderBean.getQetim() + "'");
|
}
|
if (workOrderBean.getSts() != null) {
|
params = params.concat(" and o.sts = " + workOrderBean.getSts());
|
}
|
if (StringUtil.notNull(workOrderBean.getIsCheck())) {
|
params = params.concat(" and o.isCheck = '" + workOrderBean.getIsCheck() + "'");
|
}
|
if (StringUtil.notNull(workOrderBean.getWorkOrderCode())) {
|
params = params.concat(" and (o.workOrderCode like '%" + workOrderBean.getWorkOrderCode() + "%' )");
|
}
|
if (StringUtil.notNull(workOrderBean.getEqpId())) {
|
params = params.concat(" and o.eqpId = " + workOrderBean.getEqpId());
|
}
|
params = params.concat(" order by o.date_ desc");
|
try {
|
List<TransmitterWorkOrderBean> rows = transmitterWorkOrderDaoI.queryByPage(hql.concat(params), pageParams);
|
|
for (TransmitterWorkOrderBean bean : rows) {
|
bean.setOutputs(null);
|
List<?> mat = transmitterWorkOrderDaoI.queryBySql("select name from MD_MAT where id = ?", bean.getMaterialCode());
|
if (mat != null && mat.size() > 0) {
|
bean.setMatName(mat.get(0).toString());
|
}
|
List<?> eqp = transmitterWorkOrderDaoI.queryBySql("select equipment_name from MD_EQUIPMENT where id = ?", bean.getEqpId());
|
if (eqp != null && eqp.size() > 0) {
|
bean.setEqpName(eqp.get(0).toString());
|
}
|
List<?> team = transmitterWorkOrderDaoI.queryBySql("select name from MD_TEAM where id = ?", bean.getTeam());
|
if (team != null && team.size() > 0) {
|
bean.setTeamName(team.get(0).toString());
|
}
|
List<?> shift = transmitterWorkOrderDaoI.queryBySql("select name from MD_SHIFT where id = ?", bean.getShift());
|
if (shift != null && shift.size() > 0) {
|
bean.setShiftName(shift.get(0).toString());
|
}
|
List<?> unit = transmitterWorkOrderDaoI.queryBySql("select name from MD_UNIT where id=?", bean.getUnit());
|
if (unit != null && unit.size() > 0) {
|
bean.setUnitName(unit.get(0).toString());
|
}
|
}
|
hql = "select count(o) ".concat(hql.replace("fetch", ""));
|
|
long total = schWorkorderDao.queryTotal(hql.concat(params));
|
|
return new DataGrid(rows, total);
|
|
} catch (Exception e) {
|
|
log.error("查询发射机工单异常", e);
|
|
}
|
|
return null;
|
}
|
|
@LogAnno(operateType = "审核发射机工单")
|
@Override
|
public void checkFSJOrder(String id) throws Exception {
|
TransmitterWorkOrderBean schWorkorder = transmitterWorkOrderDaoI.findById(TransmitterWorkOrderBean.class, id);
|
if (schWorkorder != null) {
|
schWorkorder.setSts(1);//状态
|
schWorkorder.setIsCheck("1");
|
schWorkorder.setCheckTime(new Date());
|
FillUserInfoUtil.fillUpdateUserInfo(schWorkorder, request);
|
} else {
|
log.error("id:" + id + "的工单不存在");
|
throw new Exception();
|
}
|
|
}
|
|
@LogAnno(operateType = "批量审核发射机工单")
|
@Override
|
public void checkFSJOrders(String ids) throws Exception {
|
for (String id : StringUtil.splitToStringList(ids, ",")) {
|
this.checkFSJOrder(id);
|
}
|
}
|
|
@LogAnno(operateType = "更改发射机工单状态")
|
@Override
|
public void editFSJOrderStatus(String id, Long sts) throws Exception {
|
TransmitterWorkOrderBean schWorkorder = transmitterWorkOrderDaoI.findById(TransmitterWorkOrderBean.class, id);//锁定状态（1-允许，0-不允许）。当为7时表示已经允许
|
if (schWorkorder != null) {
|
//修改状态
|
String sql = "update SCH_TRANSMITTER_WKORDER set sts=" + sts;
|
if (sts == 2) {
|
//只让没有运行过的工单改变运行状态，防止出现多个产出数据
|
long status = schWorkorder.getSts();
|
if (status != 2) {
|
List<?> list = schWorkorderDao.queryBySql("select * from SCH_TRANSMITTER_WKORDER where EQP_ID = ? and sts = 2 and del = 0",schWorkorder.getEqpId());
|
if (list!=null && list.size() > 0){
|
throw new RuntimeException("此工单所属机台有未结束的工单！！");
|
}
|
}else {
|
sql += ",real_stim=to_date('" + DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss") + "','yyyy-MM-dd hh24:mi:ss')";
|
}
|
|
} else if (sts == 4) {
|
sql += ",real_etim=to_date('" + DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss") + "','yyyy-MM-dd hh24:mi:ss')";
|
}
|
//增加创建人与创建时间信息
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
String updateUserName = sessionInfo.getUser().getName();
|
String updateUserTime = DateUtil.datetoStr(new Date(), "yyyy-MM-dd HH:mm:ss");
|
sql += ",UPDATE_USER_NAME='" + updateUserName + "'";
|
sql += ",UPDATE_USER_TIME=to_date('" + updateUserTime + "','yyyy-mm-dd hh24:mi:ss')";
|
sql += " where id='" + id + "'";
|
log.error("[修改发射机工单状态成功]：" + sts);
|
schWorkorderDao.updateBySql(sql, null);
|
} else {
|
log.error("id:" + id + "的工单不存在");
|
throw new Exception("id:" + id + "的工单不存在");
|
}
|
|
}
|
|
@Override
|
public TransmitterWorkOrderBean getFSJOrderById(String id) throws Exception {
|
TransmitterWorkOrderBean schWorkorder = transmitterWorkOrderDaoI.findById(TransmitterWorkOrderBean.class, id);
|
MdEquipment equipment = equipmentDao.findById(MdEquipment.class, schWorkorder.getEqpId());
|
schWorkorder.setEquCode(equipment.getEquipmentCode());
|
schWorkorder.setEqpName(equipment.getEquipmentName());
|
return schWorkorder;
|
}
|
|
@Override
|
public void addFSJOrder(TransmitterWorkOrderBean workOrderBean) throws Exception {
|
workOrderBean.setQty(0D);
|
workOrderBean.setDel(0);
|
transmitterWorkOrderDaoI.save(workOrderBean);
|
}
|
|
@LogAnno(operateType = "删除发射机工单")
|
@Override
|
public void deleteFSJOrders(String id, String eqpName, String team, String date, String mat, SessionInfo info) {
|
try {
|
transmitterWorkOrderDaoI.deleteById(id, TransmitterWorkOrderBean.class);
|
//删除辅料表数据
|
String sql = "DELETE from SCH_TRANSMITTER_OUTPUT where TW_ID='" + id + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
|
SysLog log = new SysLog();
|
log.setSys("PMS");
|
if (info != null) {
|
log.setName(info.getUser().getName());//操作人
|
log.setIp(info.getIp());
|
}
|
log.setOptname("删除工单以及与此工单相关的产量/辅料数据操作");//操作名或路径
|
log.setParams("删除的工单id:" + id + "机台：" + eqpName + "班组：" + team + "牌号：" + mat + "工单时间：" + date);//参数
|
log.setSuccess("操作成功");
|
log.setDate(new Date());
|
log.setDel(0L);
|
logdao.save(log);
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
@Override
|
public void deleteBeatchFSJOrders(String ids, String eqpName, String team, String date, String mat,
|
SessionInfo info) {
|
try {
|
String[] id = ids.split(",");
|
String[] ens = eqpName.split(",");
|
String[] ts = team.split(",");
|
String[] ds = date.split(",");
|
String[] ms = mat.split(",");
|
for (int i = 0; i < id.length; i++) {
|
this.deleteFSJOrders(id[i], ens[i], ts[i], ds[i], ms[i], info);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Override
|
public String editFSJRuntime(String stim, String etim, String ids) {
|
String result = "";
|
try {
|
String sql = "update SCH_TRANSMITTER_WKORDER set stim = to_date('" + stim + "','yyyy-MM-dd hh24:mi:ss'),etim = to_date('" + etim + "','yyyy-MM-dd hh24:mi:ss') where id= '"
|
+ ids + "'";
|
schWorkorderDao.updateBySql(sql, null);
|
result = "保存成功！";
|
} catch (Exception e) {
|
result = "保存失败！";
|
}
|
return result;
|
}
|
|
/**
|
* Rengj
|
* 运行时间查询
|
*/
|
@Override
|
public TransmitterWorkOrderBean getFSJRuntime(String ids) {
|
TransmitterWorkOrderBean workOrder = transmitterWorkOrderDaoI.findById(TransmitterWorkOrderBean.class, ids);
|
if (workOrder != null) {
|
workOrder.setQstim(DateUtil.formatDateToString(workOrder.getStim(), "yyyy-MM-dd HH:mm:ss"));
|
workOrder.setQetim(DateUtil.formatDateToString(workOrder.getEtim(), "yyyy-MM-dd HH:mm:ss"));
|
}
|
return workOrder;
|
}
|
|
@Override
|
public DataGrid getAllFSJOrderDetails(TransmitterWorkOrderBean workOrderBean, PageParams pageParams) {
|
try {
|
List<TransmitterOutput> outputs = new ArrayList<>();
|
List<?> outList = transmitterOutputDaoI.queryBySql(" select a.id,a.tw_id,a.piping_no+1,d.name,a.shut_no,a.receive_no,c.equipment_name "
|
+ " from SCH_TRANSMITTER_OUTPUT a "
|
+ " left join SCH_WORKORDER b on a.work_code = b.id "
|
+ " left join MD_EQUIPMENT c on a.EQP_ID = c.id "
|
+ " left join md_mat d on b.mat = d.id"
|
+ " where a.TW_ID=? order by PIPING_NO",
|
workOrderBean.getWorkOrderCode());
|
TransmitterOutput output = null;
|
Object[] obj = null;
|
if (outList != null && outList.size() > 0) {
|
for (Object object : outList) {
|
obj = (Object[]) object;
|
output = new TransmitterOutput();
|
output.setId(StringUtil.convertObjToString(obj[0]));
|
output.setTwId(StringUtil.convertObjToString(obj[1]));
|
output.setPipingNo(StringUtil.convertObjToString(obj[2]));
|
output.setWorkCode(StringUtil.convertObjToString(obj[3]));
|
output.setShutNo(StringUtil.converObj2Double(obj[4]));
|
output.setReceiveNo(StringUtil.converObj2Double(obj[5]));
|
output.setEqpId(StringUtil.convertObjToString(obj[6]));
|
outputs.add(output);
|
}
|
}
|
return new DataGrid(outputs, (long) outputs.size());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
return null;
|
}
|
|
/**
|
* 查询发射机消耗详细
|
*/
|
@Override
|
public TransmitterOutput querytransmitterOutPut(
|
String id) {
|
try {
|
StringBuffer sb = new StringBuffer();
|
sb.append("select id,tw_id,PIPING_NO,work_code,SHUT_NO,EQP_ID from SCH_TRANSMITTER_OUTPUT where id='" + id + "'");
|
List<?> list = transmitterOutputDaoI.queryBySql(sb.toString());
|
if (list.size() > 0 && list != null) {
|
TransmitterOutput toutput = new TransmitterOutput();
|
Object[] temp = (Object[]) list.get(0);
|
toutput.setId(StringUtil.convertObjToString(temp[0]));
|
toutput.setTwId(StringUtil.convertObjToString(temp[1]));
|
toutput.setPipingNo(StringUtil.convertObjToString(temp[2]));
|
toutput.setWorkCode(StringUtil.convertObjToString(temp[3]));
|
toutput.setShutNo(StringUtil.converObj2Double(temp[4]));
|
toutput.setEqpId(StringUtil.convertObjToString(temp[5]));
|
return toutput;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
/**
|
* 修改数据
|
*
|
* @auther wanchanghuang
|
* @createTime 2017年12月19日10:35:00
|
*/
|
@Override
|
public void saveFSJDatas(TransmitterOutput tobean) {
|
if (tobean.getShutNo() >= 0) {
|
StringBuffer sb = new StringBuffer();
|
sb.append("update SCH_TRANSMITTER_OUTPUT set shut_no='" + tobean.getReceiveNo() + "' where id='" + tobean.getId() + "' ");
|
transmitterOutputDaoI.updateBySql(sb.toString(), null);
|
sb.setLength(0);
|
Double val = tobean.getReceiveNo() - tobean.getShutNo();
|
sb.append(" update SCH_TRANSMITTER_WKORDER set qty=qty+'" + val + "' where work_order_code='" + tobean.getTwId() + "' ");
|
transmitterOutputDaoI.updateBySql(sb.toString(), null);
|
}
|
}
|
|
|
/**
|
* [说明]： 查询
|
*
|
* @author wanchanghuang
|
* @date 2019年5月8日09:42:23
|
*/
|
@Override
|
public long querySchWorkOrderByCode(SchWorkorder schWk) {
|
try {
|
String hql = "select count(1) from SchWorkorder o where o.del=0 and o.code=? ";
|
long num = mdMatDao.queryTotal(hql, schWk.getCode());
|
return num;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return 0;
|
}
|
|
/**
|
* [说明]： 保存
|
*
|
* @author wanchanghuang
|
* @date 2019年5月8日09:42:23
|
*/
|
@Override
|
public void addSchWorkOrderObj(SchWorkorder schWk) {
|
schWorkorderDao.save(schWk);
|
}
|
|
/**
|
* [说明]:工单撤销-查询
|
*
|
* @author wanchanghuang
|
* @date 2019年5月8日09:42:29
|
*/
|
@Override
|
public long querySchworkOrderByCodes(SchWorkorder wkorder) {
|
try {
|
String hql = "select count(1) from SchWorkorder o where o.del=0 and o.sts>=2 and o.isCheck=1 and o.code=? ";
|
long l1 = mdMatDao.queryTotal(hql, wkorder.getCode());
|
|
String hql2 = "select count(1) from TransmitterWorkOrderBean o where o.del=0 and o.sts>=2 and o.isCheck=1 and o.workOrderCode=? ";
|
long l2 = mdMatDao.queryTotal(hql2, wkorder.getCode());
|
|
return l1+l2;
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return 0;
|
}
|
|
/**
|
* [说明]:工单撤销-修改工单状态
|
*
|
* @author wanchanghuang
|
* @date 2019年5月8日09:42:29
|
*/
|
@Override
|
public void updateSchWorkOrderStatus(SchWorkorder wkorder) {
|
String sql = "update SCH_WORKORDER set sts=5,del=1 where code='" + wkorder.getCode() + "' and del=0 and sts not in (2,4) ";
|
String sql2 = "update SCH_TRANSMITTER_WKORDER set sts=5,del=1 where WORK_ORDER_CODE='" + wkorder.getCode() + "' and del=0 and sts not in (2,4) ";
|
schWorkorderDao.updateBySql(sql, null);
|
schWorkorderDao.updateBySql(sql2,null);
|
}
|
|
/**
|
* 根据生产牌号获取对应所有bom版本
|
*
|
* @param matid
|
* @return
|
*/
|
@Override
|
public List<Combobox> queryBomVersionByProd(String matid) {
|
List<Combobox> list = new ArrayList<>();
|
Combobox combobox = null;
|
String sql = "select bom_lot_id id,bom_lot_id name " +
|
"from SCH_WORKORDER_BOM " +
|
"where (prod = ? ) and del = 0 " +
|
"and bom_lot_id is not null and effect_time is not null " +
|
"group by bom_lot_id,effect_time " +
|
"order by effect_time desc";
|
List<?> result = schWorkorderDao.queryBySql(sql, matid);
|
if (result != null && result.size() > 0) {
|
|
Object[] objs = (Object[]) result.get(0);
|
combobox = new Combobox();
|
combobox.setId(StringUtil.convertObjToString(objs[0]));
|
combobox.setName(StringUtil.convertObjToString(objs[1]));
|
list.add(combobox);
|
|
}
|
return list;
|
}
|
|
/**
|
* 根据生产牌号获取对应所有工艺参数版本
|
*
|
* @param matid
|
* @return
|
*/
|
@Override
|
public List<Combobox> getParamVersionByProd(String matid) {
|
List<Combobox> list = new ArrayList<>();
|
Combobox combobox = null;
|
String sql = "select PARAMETER_SETREVISION id,PARAMETER_SETREVISION name " +
|
"from SCH_WORKORDER_CRAFT " +
|
"where MATERIAL_CODE = ? and del = 0 " +
|
"and parameter_setrevision is not null and effect_time is not null " +
|
"group by PARAMETER_SETREVISION,EFFECT_TIME " +
|
"order by EFFECT_TIME desc";
|
List<?> result = schWorkorderDao.queryBySql(sql, matid);
|
if (result != null && result.size() > 0) {
|
|
Object[] objs = (Object[]) result.get(0);
|
combobox = new Combobox();
|
combobox.setId(StringUtil.convertObjToString(objs[0]));
|
combobox.setName(StringUtil.convertObjToString(objs[1]));
|
list.add(combobox);
|
|
}
|
return list;
|
}
|
|
|
@Override
|
public DataGrid getBomDetail(String bomVersion) {
|
String hql = "from SchWorkorderBom where bom_lot_id=?";
|
List<SchWorkorderBom> boms = schWorkorderBomDao.query(hql, bomVersion);
|
List<BomBean> beans = new ArrayList<>();
|
BomBean bean = null;
|
if (boms != null && boms.size() > 0) {
|
for (SchWorkorderBom bom : boms) {
|
bean = new BomBean();
|
bean.setMat(bom.getMdMat().getName());
|
bean.setMatId(bom.getMdMat().getId());
|
bean.setQty(bom.getQty());
|
bean.setUnit(bom.getMdUnit().getName());
|
bean.setUnitId(bom.getMdUnit().getId());
|
bean.setId(bom.getId());
|
beans.add(bean);
|
}
|
}
|
return new DataGrid(beans, 0L);
|
}
|
|
@Override
|
public SchWorkorder findWorkOrderByDateShiftEqp(String date, String shift, String eqp) {
|
String hql = "from SchWorkorder where to_char(date,'yyyy-MM-dd') = ? and mdShift.id = ? and mdEquipment.id = ? and del=0";
|
return schWorkorderDao.unique(SchWorkorder.class,hql,date,shift,eqp);
|
}
|
|
|
@Override
|
public String sendOrderChange(String ids) {
|
String msg = "";
|
for (String id : StringUtil.splitToStringList(ids, ",")) {
|
SchWorkorder schWorkorder = schWorkorderDao.findById(SchWorkorder.class, id);
|
schWorkorder.setSts(9L);
|
WorkOrderStatChangeInterceptor.getInstance().sendOrderStatus("5",schWorkorder);
|
}
|
return null;
|
}
|
|
@Override
|
public SchCalendar queryTeamByDateShift(String actualDate, String shift) {
|
try {
|
String hql = "from SchCalendar where to_char(date,'yyyy-MM-dd') = ? and mdShift.id = ? and mdWorkshop.id = 1";
|
return schCalendarDao.unique(SchCalendar.class, hql, actualDate, shift);
|
}catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
}
|
