package com.shlanbao.tzsc.pms.equ.wcplan.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.shlanbao.tzsc.base.model.SessionInfo;
|
import com.shlanbao.tzsc.utils.tools.*;
|
import org.apache.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.EqmWheelCovelParamDaoI;
|
import com.shlanbao.tzsc.base.dao.EqmWheelCovelPlanDaoI;
|
import com.shlanbao.tzsc.base.dao.SysEqpTypeDaoI;
|
import com.shlanbao.tzsc.base.dao.TransmitterOutputDaoI;
|
import com.shlanbao.tzsc.base.dao.TransmitterWorkOrderDaoI;
|
import com.shlanbao.tzsc.base.interceptor.WorkOrderStatChangeInterceptor;
|
import com.shlanbao.tzsc.base.mapping.EqmWheelCovelParam;
|
import com.shlanbao.tzsc.base.mapping.EqmWheelCovelPlan;
|
import com.shlanbao.tzsc.base.mapping.EqmWheelCovelPlanInfo;
|
import com.shlanbao.tzsc.base.mapping.MdEquipment;
|
import com.shlanbao.tzsc.base.mapping.MdShift;
|
import com.shlanbao.tzsc.base.mapping.SysEqpCategory;
|
import com.shlanbao.tzsc.base.mapping.SysEqpType;
|
import com.shlanbao.tzsc.base.mapping.SysUser;
|
import com.shlanbao.tzsc.base.model.DataGrid;
|
import com.shlanbao.tzsc.base.model.PageParams;
|
import com.shlanbao.tzsc.base.service.BaseService;
|
import com.shlanbao.tzsc.pms.equ.wcplan.beans.EqmWheelCalendar;
|
import com.shlanbao.tzsc.pms.equ.wcplan.beans.EqmWheelCovelPlanBean;
|
import com.shlanbao.tzsc.pms.equ.wcplan.service.EqmWheelCovelPlanServiceI;
|
import com.shlanbao.tzsc.pms.sch.workorder.beans.MesMdMatBean;
|
import com.shlanbao.tzsc.pms.sch.workorder.beans.MesWorkOrderBean;
|
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.service.WorkOrderServiceI;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
@Service
|
public class EqmWheelCovelPlanServiceImpl extends BaseService implements EqmWheelCovelPlanServiceI {
|
Logger log = Logger.getLogger(this.getClass());
|
@Autowired
|
private WorkOrderServiceI orderServiceImpl;
|
@Autowired
|
private EqmWheelCovelPlanDaoI eqmWheelCovelPlanDao;
|
@Autowired
|
private EqmWheelCovelParamDaoI eqmWheelCovelParamDao;
|
@Autowired
|
private SysEqpTypeDaoI sysEqpTypeDao;
|
@Autowired
|
private TransmitterWorkOrderDaoI transmitterWorkOrderDaoI;
|
@Autowired
|
private TransmitterOutputDaoI transmitterOutputDao;
|
@Autowired
|
private HttpServletRequest request;
|
//查询功能
|
@Override
|
public DataGrid queryWCPlan(EqmWheelCovelPlanInfo wcpBean,PageParams pageParams) throws Exception {
|
StringBuilder hql=new StringBuilder();
|
hql.append("from EqmWheelCovelPlanInfo o where 1=1 and o.del=0 and o.type='"+wcpBean.getType()+"'");
|
//时间查询
|
if(StringUtil.notNull(wcpBean.getDate1())){
|
hql.append(" and o.plan_date >= to_date('"+wcpBean.getDate1()+"','yyyy-MM-dd')");
|
}
|
if(StringUtil.notNull(wcpBean.getDate2())){
|
hql.append(" and o.plan_date <= to_date('"+wcpBean.getDate2()+"','yyyy-MM-dd')");
|
}
|
List<EqmWheelCovelPlanInfo> list = eqmWheelCovelPlanDao.queryByPage(hql.toString(), pageParams);
|
hql.insert(0,"select count(*) ");
|
long total = eqmWheelCovelPlanDao.queryTotal(hql.toString());
|
return new DataGrid(list,total);
|
}
|
|
//轮保日历查询功能
|
@Override
|
public List<EqmWheelCalendar> queryWCPlanCalendar(String date1,String date2) throws Exception {
|
StringBuilder hql=new StringBuilder();
|
hql.append("from EqmWheelCovelPlan o where 1=1 and o.del=0 ");
|
|
if(StringUtil.notNull(date1)){
|
hql.append(" and o.scheduleDate >= '"+date1+"'");
|
}
|
if(StringUtil.notNull(date2)){
|
hql.append(" and o.scheduleEndDate <= '"+date2+"'");
|
}
|
List<EqmWheelCovelPlan> eqmWheelCovelPlan =null;// eqmWheelCovelPlanDao.query(hql.toString());
|
List<EqmWheelCalendar> list=new ArrayList<EqmWheelCalendar>();
|
for(EqmWheelCovelPlan wcp : eqmWheelCovelPlan){
|
EqmWheelCalendar bean =new EqmWheelCalendar();
|
bean.setName(wcp.getPlanName());
|
bean.setId(wcp.getId());
|
bean.setStart(DateUtil.formatDateToString(wcp.getScheduleDate(),"yyyy-MM-dd"));
|
bean.setTitle(wcp.getPlanName());
|
// 0\新增 1、审核通过2、运行3、停止运行4、操作工操作完毕5、轮保工操作完毕6、操作工、轮保工操作完毕7、审核完毕8、计划完成
|
if(wcp.getWheelCoverType().equals('7')){
|
bean.setColor("GREEN");
|
}else{
|
bean.setColor("Red");
|
}
|
|
list.add(bean);
|
}
|
return list;
|
}
|
//修改轮保内容状态
|
@Override
|
public void updateWCPlanStatus(String id, String status) {
|
/*EqmWheelCovelPlan bean=eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, id);
|
bean.setWheelCoverType(status);
|
eqmWheelCovelPlanDao.save(bean);*/
|
}
|
|
@Override
|
public void addWCPlan(EqmWheelCovelPlanBean wcpBean, String userId) throws Exception {
|
EqmWheelCovelPlan wcp = BeanConvertor.copyProperties(wcpBean, EqmWheelCovelPlan.class);
|
//设备ID赋值
|
wcp.setMdEquipment(new MdEquipment(wcpBean.getEqmId()));
|
//创建人，创建时间赋值（只在设备管理员这赋值）
|
SysUser sysUser = new SysUser();
|
sysUser.setId(userId);
|
wcp.setCreateDate(new Date());
|
wcp.setSysUserByCreateId(sysUser);
|
//轮保状态 设置为已经保存
|
wcp.setWheelCoverType("新建");
|
//责任人赋值
|
wcp.setMdShift(new MdShift(wcpBean.getMdShiftId()));
|
SysUser sysUser2 = new SysUser();
|
sysUser2.setId(wcpBean.getDutyPeopleId());
|
wcp.setSysUserByDutyPeopleId(sysUser2);
|
wcp.setDel("0");
|
//eqmWheelCovelPlanDao.save(wcp);
|
}
|
|
@Override
|
public void editWCPlan(EqmWheelCovelPlanBean wcpBean) throws Exception{
|
/*EqmWheelCovelPlan WCPlan = eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, wcpBean.getId());
|
if(StringUtil.notNull(wcpBean.getId())){
|
WCPlan.setEqmWheelCovelPlan(new EqmWheelCovelPlan(wcpBean.getId()));
|
}
|
WCPlan.setMdShift(new MdShift(wcpBean.getMdShiftId()));
|
WCPlan.setMdEquipment(new MdEquipment(wcpBean.getEqmId()));
|
WCPlan.setSysUserByDutyPeopleId(new SysUser(wcpBean.getDutyPeopleId()));
|
|
BeanConvertor.copyProperties(wcpBean,WCPlan);*/
|
}
|
|
@Override
|
public EqmWheelCovelPlanBean getById(String id) throws Exception {
|
EqmWheelCovelPlan eqmWheelCovelPlan =null;// eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, id);
|
EqmWheelCovelPlanBean wcpBean = BeanConvertor.copyProperties(eqmWheelCovelPlan,EqmWheelCovelPlanBean.class);
|
wcpBean.setEqmId(eqmWheelCovelPlan.getMdEquipment().getId());//设备id
|
wcpBean.setDutyPeopleId(eqmWheelCovelPlan.getSysUserByDutyPeopleId().getId());//责任人id
|
wcpBean.setEqmName(eqmWheelCovelPlan.getMdEquipment().getEquipmentName());
|
if(null!=eqmWheelCovelPlan.getSysUserByDutyPeopleId()){
|
wcpBean.setDutyPeopleName(eqmWheelCovelPlan.getSysUserByDutyPeopleId().getName());
|
}
|
if(eqmWheelCovelPlan.getMdShift()!=null){
|
wcpBean.setMdShiftId(eqmWheelCovelPlan.getMdShift().getId());
|
}
|
return wcpBean;
|
}
|
|
|
@Override
|
public void deleteWCPlan(String id) throws Exception {
|
String sql_eqm_wheel_plan="DELETE from EQM_WHEEL_COVEL_PLAN where id='"+id+"'";
|
eqmWheelCovelPlanDao.updateBySql(sql_eqm_wheel_plan, null);
|
String sql_eqm_wheel_plan_param="DELETE from EQM_WHEEL_COVEL_PARAM where pid='"+id+"'";
|
eqmWheelCovelPlanDao.updateBySql(sql_eqm_wheel_plan_param, null);
|
//eqmWheelCovelPlanDao.findById(EqmWheelCovelPlan.class, id).setDel("1");
|
}
|
|
|
/**
|
* [功能说明]:将设备保养记录信息反馈MES
|
* @param type 1轮保 2润滑 3检修
|
* @param ids 主键ID status 0-默认 1-完成 3-后期处理 4-下发状态
|
* @createTime 2016年6月15日14:53:31
|
* @author wanchanghuang
|
* @说明 为劲量减速数据库操作，通过ids查询主表，
|
* 和子表所有数据 然后通过id对比找出对应值封装XML
|
*/
|
@Override
|
public int dasSendEquipmentWorkOrderResult(String type,String ids) {
|
ids=ids.replaceAll(",", "','");//如： 1,2拼接成 1','2
|
StringBuilder hql=new StringBuilder(1000);
|
hql.append("from EqmWheelCovelPlanInfo o where 1=1 and o.del=0 and sh_status=1 and o.id in ('"+ids+"')");
|
List<EqmWheelCovelPlanInfo> list = eqmWheelCovelPlanDao.query(hql.toString());
|
//判断，如果没有完成不反馈
|
if(list==null || list.size()<1){
|
return 0;
|
}
|
hql.setLength(0);//清空
|
hql.append("from EqmWheelCovelParam t where 1=1 and t.del=0 and t.eqm_wcp_id in ('"+ids+"') ");
|
List<EqmWheelCovelParam> listParam = eqmWheelCovelParamDao.query(hql.toString());
|
//调用封装XML方法
|
List<String> fackIds=new ArrayList<>();
|
fackIds=WorkOrderStatChangeInterceptor.getInstance().dasSendEquipmentWorkOrderResult(list,listParam,fackIds);
|
//反馈成功之后修改状态
|
if(fackIds.size()<1){
|
for (String id : fackIds) {
|
for (EqmWheelCovelPlanInfo bean : list) {
|
if(id.equals(bean.getId())){
|
bean.setSh_status(5);
|
break;
|
}
|
}
|
}
|
return 1;
|
}else {
|
return 0;
|
}
|
|
}
|
|
/** 批量删除*/
|
@Override
|
public void deleteEqmWheelCovelById(String type, String ids) {
|
ids=ids.replaceAll(",", "','");//如： 1,2拼接成 1','2
|
String sql="delete from eqm_wheel_covel_plan where 1=1 id in ('"+ids+"')";
|
String sqlParam="delete from eqm_wheel_covel_param where 1=1 eqm_wcp_id in ('"+ids+"')";
|
eqmWheelCovelParamDao.updateBySql(sql, null);
|
eqmWheelCovelParamDao.updateBySql(sqlParam, null);
|
}
|
|
/**
|
* [功能说明]:设备保养工单下发，保存主表对象
|
* @date 2016年6月16日8:25:09
|
* @author wanchanghuang
|
* */
|
@Override
|
public String saveByEqmWheelCovelPlanByObj(EqmWheelCovelPlanInfo ecp) {
|
return eqmWheelCovelPlanDao.saveBackKey(ecp);
|
}
|
|
/**
|
* [功能说明]:设备保养工单下发，保存子表
|
* @date 2016年6月16日8:25:09
|
* @author wanchanghuang
|
* @type 1轮保 2润滑 3点检
|
* */
|
@Override
|
public void saveByEqmWheelCovelParamByObj(EqmWheelCovelPlanInfo ecp) {
|
//通过设备型号（zj17）和类型 1轮保 2润滑 3检修查询数据字典子表
|
String sql="select * from sys_eqp_type where del=0 and cid in (select id from sys_eqp_category where eqp_type=(select b.id from md_equipment a left join md_eqp_type b on a.eqp_type_id=b.id where a.id='"+ecp.getEqp_id()+"') and maintainace_type='"+ecp.getType()+"') ";
|
//String sql="select * from sys_eqp_type where del=0 and cid in (select id from sys_eqp_category where eqp_type=(select b.id from md_equipment a left join md_eqp_type b on a.eqp_type_id=b.id where a.id='297eefec549a3ec801549a416fa10001') and maintainace_type='1') ";
|
List<SysEqpType> list=getListSysEqpType(sysEqpTypeDao.queryBySql(sql));
|
EqmWheelCovelParam ewcp=null;
|
for(SysEqpType stype:list){
|
ewcp=new EqmWheelCovelParam();
|
/*ewcp.setEqm_wcp_id(ecp.getId()); //主表ID
|
ewcp.setContent(stype.getName());//保养内容
|
ewcp.setJob_standard(stype.getDjMethodId());//保养方法
|
ewcp.setContent_datail(stype.getDes());//保养标准
|
ewcp.setRole_id(stype.getLxType());//保养角色ID
|
ewcp.setRole_name("");//保养角色名称
|
ewcp.setDel(0);
|
ewcp.setStatus(0);
|
ewcp.setAttr3(stype.getRhPart());//润滑部位
|
*/ //保存
|
eqmWheelCovelParamDao.save(ewcp);
|
}
|
}
|
|
/**
|
* [功能说明]：将Object转换成实体bean
|
* */
|
public List<SysEqpType> getListSysEqpType(List<?> list){
|
List<SysEqpType> lists=new ArrayList<SysEqpType>();
|
SysEqpType setp=null;
|
SysEqpCategory sec=null;
|
if(list.size()>0){
|
for(Object o:list){
|
setp=new SysEqpType();
|
Object[] temp=(Object[]) o;
|
sec=new SysEqpCategory();
|
if(temp[1]!=null){
|
sec.setId(temp[1].toString());
|
}
|
setp.setSysEqpCategory(sec);
|
if(temp[2]!=null){
|
setp.setCode(temp[2].toString());
|
}
|
if(temp[3]!=null){
|
setp.setName(temp[3].toString());
|
}
|
if(temp[4]!=null){
|
setp.setDes(temp[4].toString());
|
}
|
if(temp[7]!=null){
|
setp.setLxType(temp[7].toString());
|
}
|
if(temp[9]!=null){
|
setp.setDjMethodId(temp[9].toString());
|
}
|
lists.add(setp);
|
}
|
}
|
return lists;
|
}
|
|
/**
|
* [功能说明]：工单实际反馈
|
* 1)通过ID集合，查询工单表集合，返回MES；
|
* 2)发送成功后修改工单状态；
|
* 1
|
* */
|
@LogAnno(operateType = "反馈MES")
|
@Override
|
public void orderResult(String ids,Integer type) {
|
//ids=ids.replaceAll(",", "','");//如： 1,2拼接成 1','2
|
try {
|
log.error("卷包成型工单返回IDS="+ids.replaceAll(",", "','") );
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
String[] idst=ids.split(",");
|
for(int i=0;i<idst.length;i++){
|
StringBuffer sql=new StringBuffer(1000);
|
sql.append("select ");
|
sql.append("a.code,a.shift,a.team,a.real_stim,a.real_etim,(select code from MD_MAT where id=mat) as matName, ");
|
sql.append("b.qty,(select work_center from MD_EQUIPMENT where id=eqp) as eqpCode, ");
|
sql.append("stop_times,stop_time,b.id,a.type,b.main_qty ");
|
sql.append("from SCH_WORKORDER a LEFT JOIN SCH_STAT_OUTPUT_FB b on a.id=b.oid ");
|
if (type==1) {
|
sql.append("where a.sts=4 and a.id in ('"+idst[i]+"') ");
|
}
|
if (type==2) {
|
sql.append("where a.sts=4 and b.id in ('"+idst[i]+"') ");
|
}
|
|
//查询工单实际消耗
|
List<?> wklist=sysEqpTypeDao.queryBySql(sql.toString());
|
sql.setLength(0);
|
//查询辅料消耗
|
sql.append("select a.qty,( select code from MD_UNIT where id=a.unit) as unitName,b.code from SCH_STAT_INPUT_FB a , MD_MAT b where a.mat=b.id ");
|
if (type==1) {
|
sql.append("and a.out_id in ( select id from SCH_STAT_OUTPUT_FB where oid in ('"+idst[i]+"') ) ");
|
}
|
if (type==2) {
|
sql.append("and a.out_id in ('"+idst[i]+"')");
|
}
|
|
List<?> fllist=sysEqpTypeDao.queryBySql(sql.toString());
|
getListMesWorkOrder(wklist,fllist);
|
}
|
}
|
|
/**
|
* [功能说明]：发射工单结果反馈
|
* 1)通过ID集合，查询工单表集合，返回MES；
|
* 2)发送成功后修改工单状态；
|
* 1
|
* */
|
@LogAnno(operateType = "反馈MES")
|
@Override
|
public void orderResultFSJ(String idarr,Integer type) {
|
//ids=ids.replaceAll(",", "','");//如： 1,2拼接成 1','2
|
String[] idst=idarr.split(",");
|
List<String> ids=new ArrayList<>();
|
for(int i=0;i<idst.length;i++){
|
TransmitterWorkOrderBean bean = null;
|
List<TransmitterOutput> outputs = new ArrayList<>();
|
bean = transmitterWorkOrderDaoI.findById(TransmitterWorkOrderBean.class, idst[i]);
|
if (bean !=null) {
|
List<?> Ueqp = transmitterWorkOrderDaoI.queryBySql("select equipment_code from MD_EQUIPMENT where id = ? ", bean.getEqpId());
|
if (Ueqp != null&&Ueqp.size()>0) {
|
if ("131".equals(Ueqp.get(0).toString())) {
|
bean.setEqpName("S01");
|
}else if("132".equals(Ueqp.get(0).toString())){
|
bean.setEqpName("S02");
|
}else if("133".equals(Ueqp.get(0).toString())){
|
bean.setEqpName("S03");
|
} else {
|
bean.setEqpName("");
|
}
|
}else {
|
bean.setEqpName("");
|
}
|
List<?> outList = transmitterOutputDao.queryBySql(" select a.tw_id,a.piping_no,b.code,a.shut_no,a.receive_no,e.qty*10000 "
|
+" 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 SCH_STAT_OUTPUT d on d.oid =b.id "
|
+" left join SCH_STAT_INPUT e on e.out_id = d.id and e.mat = ? "
|
+" where a.TW_ID=? ",bean.getMaterialCode(),
|
bean.getWorkOrderCode());
|
TransmitterOutput output = null;
|
Object[] obj = null;
|
if(outList!=null && outList.size() > 0) {
|
for (Object object : outList) {
|
obj = (Object[]) object;
|
output = new TransmitterOutput();
|
output.setTwId(StringUtil.convertObjToString(obj[0]));
|
output.setPipingNo(StringUtil.convertObjToString(obj[1]));
|
int num = Integer.parseInt(output.getPipingNo())+1;
|
if(num<10) {
|
output.setPipingNo(bean.getEqpName()+"0"+num);
|
}else {
|
output.setPipingNo(bean.getEqpName()+num);
|
}
|
output.setWorkCode(StringUtil.convertObjToString(obj[2]));
|
output.setShutNo(StringUtil.converObj2Double(obj[3]));
|
output.setDumpNo(StringUtil.converObj2Double(obj[4]));
|
output.setEqpId(output.getWorkCode().substring(0,3));
|
output.setReceiveNo(StringUtil.converObj2Double(obj[5]));
|
outputs.add(output);
|
}
|
}
|
|
List<?> mat = transmitterWorkOrderDaoI.queryBySql("select code from md_mat where id = ? ", bean.getMaterialCode());
|
if (mat != null&&mat.size()>0) {
|
bean.setMatName(mat.get(0).toString());
|
}else {
|
bean.setMatName("");
|
}
|
bean.setOutputs(outputs);
|
FillUserInfoUtil.fillUpdateUserInfo(bean,request);
|
WorkOrderStatChangeInterceptor.getInstance().DASSendFSJOrderResult(bean,ids);
|
}
|
}
|
|
}
|
|
public List<MesWorkOrderBean> getListMesWorkOrder(List<?> wklist,List fllist){
|
List<MesMdMatBean> fllt=new ArrayList<MesMdMatBean>();
|
MesWorkOrderBean bean=null;
|
List<String> ids=new ArrayList<>();
|
if(wklist.size()>0){
|
for(Object o:wklist){
|
bean=new MesWorkOrderBean();
|
Object[] temp=(Object[]) o;
|
Object[] other;
|
List otherFl = new ArrayList();
|
bean.setCode(temp[0].toString()); //工单号
|
if (bean.getCode().endsWith("#020")) {
|
bean.setCode(bean.getCode().substring(0,bean.getCode().indexOf("#"))+"#030");
|
}
|
bean.setShift(temp[1].toString()); //班次
|
bean.setTeam(temp[2].toString()); //班组
|
bean.setReal_stim(temp[3].toString().substring(0,19)); //实际开始时间
|
bean.setReal_etim(temp[4].toString().substring(0,19)); //实际结束时间
|
bean.setMatName(temp[5].toString()); //物料名称
|
bean.setId(temp[10].toString());
|
// 卷包工单反馈时相互查询拼接成一条工单产耗 卷接工单类型 1 包装工单类型 2
|
/*if(temp[11]!=null && "12".contains(temp[11].toString())){ // 判断工单类型
|
if (temp[11].toString().equals("1")){ // 卷接工单
|
// 查询包装工单产耗
|
other = getObjects(bean.getCode().substring(0,bean.getCode().indexOf("#"))+"#020");
|
bean.setYzQuantity(temp[6]==null?0D:Double.parseDouble( temp[6].toString() ));
|
bean.setXhQuantity(other[1]==null?0D:Double.parseDouble( other[1].toString() ));
|
bean.setThQuantity(other[0]==null?0D:Double.parseDouble( other[0].toString() ));
|
getFls(fllist,other[2]);
|
}else{ // 包装工单
|
// 查询卷接工单产耗
|
other = getObjects(bean.getCode().substring(0,bean.getCode().indexOf("#"))+"#010");
|
bean.setXhQuantity(temp[12]==null?0D:Double.parseDouble( temp[12].toString() ));
|
bean.setThQuantity(temp[6]==null?0D:Double.parseDouble( temp[6].toString() ));
|
bean.setYzQuantity(other[0]==null?0D:Double.parseDouble( other[0].toString() ));
|
getFls(fllist,other[2]);
|
}
|
}*/
|
if(temp[6]!=null){
|
bean.setOutput(Double.parseDouble( temp[6].toString() ));//实际产量
|
}
|
// 包装机工单添加条盒和小盒产量反馈
|
if(temp[11]!=null && "2".contains(temp[11].toString())) {
|
bean.setXhQuantity(temp[12] == null ? 0D : Double.parseDouble(temp[12].toString()));
|
bean.setThQuantity(temp[6] == null ? 0D : Double.parseDouble(temp[6].toString()));
|
}
|
if(temp[7]!=null){
|
bean.setEqpCode( temp[7].toString() );//设备mes——code
|
}
|
if(temp[8]!=null){
|
bean.setDowntimeTimes(Integer.parseInt( temp[8].toString() )); //停机次数
|
}
|
if(temp[9]!=null){
|
bean.setDowntimeDuration( temp[9].toString() ); //停机时间
|
}
|
//添加物料
|
if(wklist.size()>0){
|
MesMdMatBean mesMdMat=null;
|
if (otherFl!=null){
|
fllist.addAll(otherFl);
|
}
|
for(Object o2:fllist){
|
mesMdMat=new MesMdMatBean();
|
Object[] temp2=(Object[]) o2;
|
if(temp2[0]!=null){
|
mesMdMat.setQuantity( Float.parseFloat(temp2[0].toString() )); //辅料产量
|
}
|
if(temp2[1]!=null){
|
mesMdMat.setUom(temp2[1].toString() ); //辅料单位
|
}
|
if(temp2[2]!=null){
|
mesMdMat.setMaterialCode( temp2[2].toString() ); //辅料编码
|
}
|
fllt.add(mesMdMat);
|
}
|
}
|
bean.setListFl(fllt);
|
//循环向MES发送
|
WorkOrderStatChangeInterceptor.getInstance().DASSendOrderResult(bean,ids);
|
}
|
}
|
|
for (String string : ids) {
|
try {
|
orderServiceImpl.updateOrder(string);
|
} catch (Exception e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
}
|
return null;
|
}
|
|
public void getFls(List fllist,Object o) {
|
List otherFl;
|
String sql = "select a.qty,( select code from MD_UNIT where id=a.unit) as unitName,b.code from SCH_STAT_INPUT_FB a , MD_MAT b " +
|
"where a.mat=b.id and a.out_id = '"+ o +"'";
|
otherFl=sysEqpTypeDao.queryBySql(sql);
|
if (otherFl != null) {
|
fllist.addAll(otherFl);
|
}
|
}
|
|
public Object[] getObjects(String param) {
|
String sql = "select qty,main_qty,id from SCH_STAT_OUTPUT_FB where oid = (select id from sch_workorder where code = ?)";
|
List<?> list = transmitterWorkOrderDaoI.queryBySql(sql,param);
|
return (Object[]) list.get(0);
|
}
|
|
@LogAnno(operateType = "反馈统计员")
|
@Override
|
public void orderResultToCounter(String ids, Integer type) {
|
String[] idst=ids.split(",");
|
//增加创建人与创建时间信息
|
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 set is_feedback = 2,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 = ?";
|
String insertOutSql = "insert into SCH_STAT_OUTPUT_FB select * from SCH_STAT_OUTPUT where id = ? ";
|
String updateFBTime = "update sch_stat_output_fb set feedback_time = null where id= ? ";
|
String insertInSql = "insert into SCH_STAT_INPUT_fb select * from SCH_STAT_INPUT where out_id = ? ";
|
for(int i=0;i<idst.length;i++){
|
List<Object> list = new ArrayList<>();
|
list.add(idst[i]);
|
transmitterOutputDao.updateBySql(sql, list);
|
transmitterOutputDao.updateBySql(insertOutSql, list);
|
transmitterOutputDao.updateBySql(insertInSql, list);
|
transmitterOutputDao.updateBySql(updateFBTime,list);
|
|
}
|
|
}
|
@LogAnno(operateType = "撤销反馈统计员")
|
@Override
|
public void revokeCounter(String ids, Integer type) {
|
String[] idst=ids.split(",");
|
//增加创建人与创建时间信息
|
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 set is_feedback = 0,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 = ?";
|
String insertOutSql = "delete from SCH_STAT_OUTPUT_FB where id = ? ";
|
|
String insertInSql = "delete from SCH_STAT_INPUT_fb where out_id = ? ";
|
for(int i=0;i<idst.length;i++){
|
List<Object> list = new ArrayList<>();
|
list.add(idst[i]);
|
transmitterOutputDao.updateBySql(sql, list);
|
transmitterOutputDao.updateBySql(insertInSql, list);
|
transmitterOutputDao.updateBySql(insertOutSql, list);
|
|
|
}
|
}
|
|
@LogAnno(operateType = "反馈统计员")
|
@Override
|
public void orderCounterFSJ(String ids, Integer type) {
|
String[] idst=ids.split(",");
|
List<String> idarr=new ArrayList<>();
|
for(int i=0;i<idst.length;i++){
|
List<Object> o = new ArrayList<>();
|
o.add(idst[i]);
|
//增加创建人与创建时间信息
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
String updateUserName = sessionInfo.getUser().getName();
|
String updateUserTime = DateUtil.datetoStr(new Date(), "yyyy-MM-dd HH:mm:ss");
|
transmitterWorkOrderDaoI.updateBySql("update SCH_TRANSMITTER_WKORDER set is_feedback = 2,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=?",o);
|
}
|
}
|
|
|
|
|
}
|
