package com.uas.eis.service.Impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.serializer.SerializerFeature; import com.uas.eis.core.support.TokenProperties; import com.uas.eis.dao.BaseDao; import com.uas.eis.dao.SqlRowList; import com.uas.eis.entity.Make; import com.uas.eis.entity.MakeMaterial; import com.uas.eis.entity.Product; import com.uas.eis.service.ScheduleTaskService; import com.uas.eis.utils.MD5Util; import com.uas.eis.utils.PSHttpUtils; import com.uas.eis.utils.StringUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.BeanPropertyRowMapper; import org.springframework.stereotype.Service; import java.util.HashMap; import java.util.Map; /** * @author koul * @email koul@usoftchina.com * @date 2021-12-23 15:30 */ @Service public class ScheduleTaskServiceImpl implements ScheduleTaskService { private final Logger logger = LoggerFactory.getLogger(this.getClass()); private static Map tokenConfig = TokenProperties.getAllProperty(); @Autowired private BaseDao baseDao; /** * STATUS(W等待执行，F执行失败，D已执行） * */ @Override public void syncProducts() { SqlRowList rs = baseDao.queryForRowSet("select id from mes_product where status='W' order by id"); while (rs.next()){ Product product = baseDao.getJdbcTemplate().queryForObject("select case when pr_kh_user='柏英特' or nvl(pr_kh_user,' ')=' ' then 'BYT' else nvl(cu_mescode,cu_code) end pr_kh_user,pr_code ,pr_detail ,pr_spec,nvl(pr_unit,'PCS') pr_unit,nvl(pr_cop,'BYT') pr_cop,nvl(pr_version,'0') pr_version,case when nvl(pr_kind,'')='半成品' or nvl(pr_kind,' ')='成品' then 'product' else 'raw' end pr_serial,nvl(pr_validdays,'0') pr_validdays,pr_msdlevel ,pr_fhelpcode ,pr_f_115 ,pr_f_116 ,pr_f_102,pr_kind,flag,pr_statuscode,pr_status from mes_product left join customer on pr_kh_user=cu_shortname where id=?", new BeanPropertyRowMapper(Product.class), rs.getInt("id")); product.setMesUser(tokenConfig.get("mesUser")); product.setMesPwd(MD5Util.encodeByMD5(tokenConfig.get("mesPwd"))); Map map = syncMES(JSON.toJSONString(product, SerializerFeature.WriteMapNullValue).replace("null", "\"\""), tokenConfig.get("syncProduct")); if ("ZG".equals(StringUtil.nvl(product.getPr_kh_user(),""))){ product.setPr_kh_user("ZGSDC"); Map map1 = syncMES(JSON.toJSONString(product, SerializerFeature.WriteMapNullValue).replace("null", "\"\""), tokenConfig.get("syncProduct")); if (map1!=null) { int code1 = Integer.parseInt(StringUtil.nvl(map1.get("code"), "100")); if (code1>0){ baseDao.execute("insert into meserrorlog (mel_id,mel_url,mel_error,mel_indate,mel_djcode,mel_type) values (MESERRORLOG_SEQ.NEXTVAL,'"+tokenConfig.get("syncProduct")+"','"+StringUtil.nvl(map.get("msg"),"")+"',sysdate,'"+product.getPr_code()+"','物料资料')"); } } } if (map!=null){ int code = Integer.parseInt(StringUtil.nvl(map.get("code"), "-1")); if (code==0){ baseDao.updateByCondition("mes_product","status='D'","status='W' and id="+rs.getInt("id")); }else { baseDao.updateByCondition("mes_product","status='F'","status='W' and id="+rs.getInt("id")); baseDao.execute("insert into meserrorlog (mel_id,mel_url,mel_error,mel_indate,mel_djcode,mel_type) values (MESERRORLOG_SEQ.NEXTVAL,'"+tokenConfig.get("syncProduct")+"','"+StringUtil.nvl(map.get("msg"),"")+"',sysdate,'"+product.getPr_code()+"','物料资料')"); } } } } @Override public void syncMakeBases() { SqlRowList rs = baseDao.queryForRowSet("select id,ma_code from mes_make where status='W' order by id"); while (rs.next()){ int count = baseDao.getCount("select count(1) from make where ma_statuscode='FINISH' and ma_code='" + rs.getString("ma_code") + "'"); String status="S"; if (count>0){ status="C"; } Make make = baseDao.getJdbcTemplate().queryForObject("select ma_code,ma_prodcode,ma_qty,nvl(cu_mescode,'BYT') ma_custcode,pr_unit,pr_detail,pr_spec,ma_salecode,to_char(ma_planbegindate,'yyyy-MM-dd') ma_planbegindate,to_char(ma_planenddate,'yyyy-MM-dd') ma_planenddate,nvl(ma_cop,'BYT') ma_cop,'"+status+"' status,to_char(ma_date,'yyyy-MM-dd HH24:mi:ss') ma_date,ma_recorder,nvl(ma_version,0) ma_version,erpid,wc_id,pr_id,to_char(ma_modifydate,'yyyy-MM-dd HH24:mi:ss') ma_modifydate,ma_modifier,flag from mes_make left join product on ma_prodcode=pr_code left join workcenter on ma_wccode=wc_code left join customer on ma_custcode=cu_code where id=?",new BeanPropertyRowMapper(Make.class),rs.getInt("id")); make.setMesPwd(MD5Util.encodeByMD5(tokenConfig.get("mesPwd"))); make.setMesUser(tokenConfig.get("mesUser")); Map map = syncMES(JSON.toJSONString(make, SerializerFeature.WriteMapNullValue).replace("null", "\"\""), tokenConfig.get("syncMakeBase")); if (map!=null){ int code = Integer.parseInt(StringUtil.nvl(map.get("code"), "-1")); if (code==0){ baseDao.updateByCondition("mes_make","status='D'","status='W' and id="+rs.getInt("id")); }else { baseDao.updateByCondition("mes_make","status='F'","status='W' and id="+rs.getInt("id")); baseDao.execute("insert into meserrorlog (mel_id,mel_url,mel_error,mel_indate,mel_djcode,mel_type) values (MESERRORLOG_SEQ.NEXTVAL,'"+tokenConfig.get("syncMakeBase")+"','"+StringUtil.nvl(map.get("msg"),"")+"',sysdate,'"+make.getMa_code()+"','工单')"); } } } } @Override public void syncMakeBaseDetails() { SqlRowList rs = baseDao.queryForRowSet("select id,mm_code,mm_detno from mes_makematerial where status='W' order by id"); while (rs.next()) { int count = baseDao.getCount("select count(1) from mes_make where status='D' and action<>'D' and ma_code='" + rs.getGeneralString("mm_code") + "'"); if (count > 0) { MakeMaterial makeMaterial = baseDao.getJdbcTemplate().queryForObject("select mm_code,erpid,mm_prodcode,pr_detail,pr_spec,pr_unit,mm_oneuseqty qty,mm_qty,mm_oneuseqty,'main' type,bo_recorder,to_char(bo_date,'yyyy-MM-dd HH24:mi:ss') bo_date,nvl(bo_version,0) bo_version,nvl(bo_cop,'BYT') bo_cop,mm_prodcode mm_repprodcode,mm_balance,nvl(cu_mescode,'BYT') ma_custcode,to_char(mc_indate,'yyyy-MM-dd HH24:mi:ss') mc_indate,mc_recorder,flag from mes_makematerial left join make on ma_id=mm_maid left join Product on mm_prodcode=pr_code left join bom on bo_id=mm_bomid left join (select max(mc_indate) mc_indate,max(mc_recorder) mc_recorder,max(md_mmdetno) md_mmdetno,max(md_makecode) md_makecode from MakeMaterialChangeDet left join MakeMaterialChange on mc_id=md_mcid) on md_makecode=ma_code and md_mmdetno=mm_detno left join customer on ma_custcode=cu_code where id=? order by mm_detno", new BeanPropertyRowMapper(MakeMaterial.class), rs.getInt("id")); makeMaterial.setMesUser(tokenConfig.get("mesUser")); makeMaterial.setMesPwd(MD5Util.encodeByMD5(tokenConfig.get("mesPwd"))); Map map = syncMES(JSON.toJSONString(makeMaterial, SerializerFeature.WriteMapNullValue).replace("null", "\"\""), tokenConfig.get("syncMakeBaseDetail")); if (map != null) { int code = Integer.parseInt(StringUtil.nvl(map.get("code"), "-1")); if (code == 0) { baseDao.updateByCondition("mes_makematerial", "status='D'", "status='W' and id=" + rs.getInt("id")); } else { baseDao.updateByCondition("mes_makematerial", "status='F'", "status='W' and id=" + rs.getInt("id")); baseDao.execute("insert into meserrorlog (mel_id,mel_url,mel_error,mel_indate,mel_djcode,mel_djdetno,mel_type) values(MESERRORLOG_SEQ.NEXTVAL,'" + tokenConfig.get("syncMakeBaseDetail") + "','" + StringUtil.nvl(map.get("msg"), "") + "',sysdate,'" + rs.getGeneralString("mm_code") + "'," + rs.getInt("mm_detno") + ",'工单BOM')"); } } } } } @Override public void syncMakematerialReplace() { SqlRowList rs = baseDao.queryForRowSet("select id,mp_mmcode, mp_mmdetno,mp_mmid from mes_makematerialreplace where status='W' order by id"); while (rs.next()) { int count = baseDao.getCount("select count(1) from mes_makematerial where status='D' and action<>'D' and " + "erpid=" + rs.getInt("mp_mmid")); if (count > 0) { MakeMaterial makeMaterial = baseDao.getJdbcTemplate().queryForObject("select mm.mm_code,mm.erpid,mr.mp_prodcode mm_prodcode,pr_detail,pr_spec,pr_unit,mm.mm_oneuseqty qty,mr.mp_canuseqty mm_qty,mm.mm_oneuseqty,'alternative' type,bo_recorder,to_char(bo_date,'yyyy-MM-dd HH24:mi:ss') bo_date,nvl(bo_version,0) bo_version,nvl(bo_cop,'BYT') bo_cop,mm.mm_prodcode mm_repprodcode,mm.mm_balance,nvl(cu_mescode,'BYT') ma_custcode,to_char(mc_indate,'yyyy-MM-dd HH24:mi:ss') mc_indate,mc_recorder,mr.flag from mes_makematerialreplace mr left join mes_makematerial mm on mr.mp_mmid=mm.erpid left join make on mm.mm_maid=ma_id left join Product on mr.mp_prodcode=pr_code left join bom on bo_id=mm.mm_bomid left join (select max(mc_indate) mc_indate,max(mc_recorder) mc_recorder,max(md_mmdetno) md_mmdetno,max(md_makecode) md_makecode from MakeMaterialChangeDet left join MakeMaterialChange on mc_id=md_mcid) on md_makecode=ma_code and md_mmdetno=mm.mm_detno left join customer on ma_custcode=cu_code where mr.id=?", new BeanPropertyRowMapper(MakeMaterial.class), rs.getInt("id")); makeMaterial.setMesUser(tokenConfig.get("mesUser")); makeMaterial.setMesPwd(MD5Util.encodeByMD5(tokenConfig.get("mesPwd"))); Map map = syncMES(JSON.toJSONString(makeMaterial, SerializerFeature.WriteMapNullValue).replace("null", "\"\""), tokenConfig.get("syncMakeBaseDetail")); if (map != null) { int code1 = Integer.parseInt(StringUtil.nvl(map.get("code"), "-1")); if (code1 == 0) { baseDao.updateByCondition("mes_makematerialreplace", "status='D'", "status='W' and id=" + rs.getInt("id")); } else { baseDao.updateByCondition("mes_makematerialreplace", "status='F'", "status='W' and id=" + rs.getInt("id")); baseDao.execute("insert into meserrorlog (mel_id,mel_url,mel_error,mel_indate,mel_djcode,mel_djdetno,mel_type) values(MESERRORLOG_SEQ.NEXTVAL,'" + tokenConfig.get("syncMakeBaseDetail") + "','" + StringUtil.nvl(map.get("msg"), "") + "',sysdate,'" + rs.getGeneralString("mp_mmcode") + "'," + rs.getInt("mp_mmdetno") + ",'工单BOM替代料')"); } } } } } private Map syncMES(String params,String url){ Map map = new HashMap<>(); map.put("code",-1); logger.info("params："+params); try { String post = PSHttpUtils.sendPost(tokenConfig.get("mesHttp") + url, params); logger.info("post："+post); JSONObject jsonObject = JSON.parseObject(post); int code = jsonObject.getIntValue("result"); logger.info("code："+code); if (code==0){ map.put("code",code); map.put("msg","同步MES成功"); }else if(code==1){ map.put("code",code); logger.info("msg："+jsonObject.getString("message")); map.put("msg",jsonObject.getString("message")); }else { map.put("code",-1); map.put("msg","接口调用异常，请联系MES处理！"); } }catch (Exception e){ map.put("msg","接口调用异常，请联系MES处理！"); logger.info("异常信息："+e.getMessage()); e.printStackTrace(); } return map; } }