From 33308e16bbb153d9aac76fd703ec0f38ea7e344a Mon Sep 17 00:00:00 2001 From: wangfei <3597712270@qq.com> Date: 星期三, 09 十月 2024 15:47:59 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java | 112 +++++++++++++++++++++++++++++--------------------------- 1 files changed, 58 insertions(+), 54 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java index c77392e..8a73f9e 100644 --- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java +++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java @@ -186,30 +186,34 @@ TemperingGlassInfo temperingGlassInfo = temperingGlassInfoMapper.selectOne(temperingGlassInfoWrapper); LambdaQueryWrapper<BigStorageCageDetails> bigStorageCageDetailsWrapper = new LambdaQueryWrapper<>(); - bigStorageCageDetailsWrapper.eq(BigStorageCageDetails::getGlassId, glassId); + bigStorageCageDetailsWrapper + .eq(BigStorageCageDetails::getGlassId, glassId) + .eq(BigStorageCageDetails::getState,Const.GLASS_STATE_IN); BigStorageCageDetails bigStorageCageDetails = baseMapper.selectOne(bigStorageCageDetailsWrapper); if (temperingGlassInfo != null) { if (status == 0) { - temperingGlassInfo.setState(Const.TEMPERING_DAMAGE); + temperingGlassInfo.setState(Const.GLASS_STATE_DAMAGE); } else { - temperingGlassInfo.setState(Const.TEMPERING_TAKE); + temperingGlassInfo.setState(Const.GLASS_STATE_TAKE); } temperingGlassInfoMapper.updateById(temperingGlassInfo); } + Damage damage = new Damage(); if (status == 0) { bigStorageCageDetails.setState(Const.GLASS_STATE_DAMAGE); + damage.setType(Const.GLASS_STATE_DAMAGE); } else { bigStorageCageDetails.setState(Const.GLASS_STATE_TAKE); + damage.setType(Const.GLASS_STATE_TAKE); } baseMapper.updateById(bigStorageCageDetails); bigStorageCageService.updateRemainWidth(bigStorageCageDetails.getSlot()); - //todo:鎻掑叆鐮存崯鏁版嵁 - Damage damage = new Damage(); damage.setGlassId(bigStorageCageDetails.getGlassId()); - damage.setWorkingProcedure("鍐峰姞宸�"); - damage.setRemark("澶х悊鐗囩鐮存崯"); - damage.setStatus(2); + damage.setWorkingProcedure("閽㈠寲"); + damage.setLine(4001); + damage.setRemark("澶х悊鐗囩"); + damage.setStatus(1); damageService.insertDamage(damage); } @@ -217,6 +221,7 @@ @Override public List<BigStorageCageDetails> selectBigStorageCageDetails(String glassId) { LambdaQueryWrapper<GlassInfo> glassInfoWrapper = new LambdaQueryWrapper<>(); + List<BigStorageCageDetails> bigStorageCageDetailsList=new ArrayList<>(); glassInfoWrapper.eq(GlassInfo::getGlassId, glassId); GlassInfo glassInfo = glassInfoMapper.selectOne(glassInfoWrapper); BigStorageCageDetails bigStorageCageDetails = new BigStorageCageDetails(); @@ -224,13 +229,10 @@ BeanUtils.copyProperties(glassInfo, bigStorageCageDetails); bigStorageCageDetails.setState(1); bigStorageCageDetails.setGap(glassGap); - List<BigStorageCageDetails> bigStorageCageDetailsList = new ArrayList<>(); + bigStorageCageDetailsList = new ArrayList<>(); bigStorageCageDetailsList.add(bigStorageCageDetails); - return bigStorageCageDetailsList; - } else { - return null; } - + return bigStorageCageDetailsList; } //鐞嗙墖绗艰鎯呮坊鍔� @@ -268,13 +270,15 @@ .selectAll(BigStorageCage.class) .leftJoin(BigStorageCageDetails.class, BigStorageCageDetails::getSlot, BigStorageCage::getSlot) .eq(BigStorageCage::getEnableState, Const.SLOT_ON) - .in(BigStorageCageDetails::getState, Const.GLASS_STATE_NEW, Const.GLASS_STATE_IN_ALL) + .in(BigStorageCageDetails::getState, Const.GLASS_STATE_IN_ALL_ZERO) .eq(BigStorageCageDetails::getEngineerId, glassInfo.getEngineerId()) .eq(BigStorageCageDetails::getTemperingLayoutId, glassInfo.getTemperingLayoutId()) .gt(BigStorageCage::getRemainWidth, Math.max(glassInfo.getWidth(), glassInfo.getHeight())) .last("limit 1"); if (glassInfo.getTemperingLayoutId() == 0) { - wrapper.eq(BigStorageCageDetails::getWidth, glassInfo.getWidth()).eq(BigStorageCageDetails::getHeight, glassInfo.getHeight()); + wrapper.eq(BigStorageCageDetails::getFlowCardId,glassInfo.getFlowCardId()) + .eq(BigStorageCageDetails::getLayer,glassInfo.getLayer()); +// wrapper.eq(BigStorageCageDetails::getWidth, glassInfo.getWidth()).eq(BigStorageCageDetails::getHeight, glassInfo.getHeight()); } else { wrapper.eq(BigStorageCageDetails::getTemperingFeedSequence, glassInfo.getTemperingFeedSequence() + 1); } @@ -303,41 +307,42 @@ return bigStorageDTO; } - //鑾峰彇鐜荤拑鐨勫帤搴︼細閲嶆柊閫夌瀛愰渶瑕佹寜鐓х瀛愬彲鏀剧幓鐠冨帤搴﹁繘琛岄�夋嫨 - bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>() - .eq(BigStorageCage::getRemainWidth, slotWidth) - .eq(BigStorageCage::getEnableState, Const.SLOT_ON) - .inSql(BigStorageCage::getDeviceId, - "select t.device_id from big_storage_cage t left join big_storage_cage_details t1 on t.slot = t1.slot " + - " where state in (0,100,102,103,104) and t.max_thickness >= " + glassInfo.getThickness() + " and t.enable_state = 1 " + - " group by t.device_id " + - " order by count(DISTINCT t1.tempering_layout_id), count(distinct t1.slot)") - .last("limit 1")); - if (null != bigStorageCage) { - log.info("鎸夌収瀛樼鐜荤拑鏍煎瓙鏁板崰鐢ㄦ渶灏戞柟寮忚幏鍙栦俊鎭牸瀛愪负锛歿},鐜荤拑id锛歿}", bigStorageCage.getSlot(), glassInfo.getGlassId()); - bigStorageDTO = new BigStorageDTO(); - bigStorageDTO.setWidth(bigStorageCage.getRemainWidth()); - bigStorageDTO.setSlot(bigStorageCage.getSlot()); - bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId()); - return bigStorageDTO; + //鑾峰彇鐜荤拑鐨勫帤搴︼細閲嶆柊閫夌瀛愰渶瑕佹寜鐓х瀛愬彲鏀剧幓鐠冨帤搴﹁繘琛岄�夋嫨 鍥犱负瀛愭煡璇㈡帓搴忓涓籹ql鏃犲奖鍝嶏紝鎵�浠ュ厛鎵ц瀛愭煡璇㈣幏鍙栭『搴忥紝鐒跺悗涓�娆″幓鏌ヨ + List<Integer> deviceUsedList = bigStorageCageService.queryFreeDeviceByUsed(glassInfo.getThickness()); + for (Integer item : deviceUsedList) { + bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>() + .eq(BigStorageCage::getRemainWidth, slotWidth) + .eq(BigStorageCage::getEnableState, Const.SLOT_ON) + .eq(BigStorageCage::getDeviceId, item) + .last("limit 1")); + if (null != bigStorageCage) { + log.info("鎸夌収瀛樼鐜荤拑鏍煎瓙鏁板崰鐢ㄦ渶灏戞柟寮忚幏鍙栦俊鎭牸瀛愪负锛歿},鐜荤拑id锛歿}", bigStorageCage.getSlot(), glassInfo.getGlassId()); + bigStorageDTO = new BigStorageDTO(); + bigStorageDTO.setWidth(bigStorageCage.getRemainWidth()); + bigStorageDTO.setSlot(bigStorageCage.getSlot()); + bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId()); + return bigStorageDTO; + } } //鑾峰彇鐜荤拑鐨勫帤搴︼細閲嶆柊閫夌瀛愰渶瑕佹寜鐓х瀛愬彲鏀剧幓鐠冨帤搴﹁繘琛岄�夋嫨 - bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>() - .eq(BigStorageCage::getRemainWidth, slotWidth) - .eq(BigStorageCage::getEnableState, Const.SLOT_ON) - .inSql(BigStorageCage::getDeviceId, - "select t.device_id from big_storage_cage t left join big_storage_cage_details t1 on t.slot = t1.slot " + - " where state in (0,100,102,103,104) and t.max_thickness >= " + glassInfo.getThickness() + " and t.enable_state = 1 " + - " group by t.device_id " + - " order by count(DISTINCT t1.tempering_layout_id), count(distinct t.slot) - count(distinct t1.slot) desc") - .last("limit 1")); +// List<Integer> deviceNotUsedList = bigStorageCageService.queryFreeDeviceByNotUsed(glassInfo.getThickness()); +// for (Integer item : deviceNotUsedList) { +// bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>() +// .eq(BigStorageCage::getRemainWidth, slotWidth) +// .eq(BigStorageCage::getEnableState, Const.SLOT_ON) +// .eq(BigStorageCage::getDeviceId, item) +// .last("limit 1")); +// if (null != bigStorageCage) { +// log.info("鎸夌収瀛樼鐜荤拑鏍煎瓙鏁板墿浣欐渶澶氬緱鏂瑰紡鑾峰彇淇℃伅鐗堝浘id:{},鏍煎瓙锛歿},鐜荤拑id锛歿}", glassInfo.getTemperingLayoutId(), bigStorageCage.getSlot(), glassInfo.getGlassId()); +// bigStorageDTO = new BigStorageDTO(); +// bigStorageDTO.setWidth(bigStorageCage.getRemainWidth()); +// bigStorageDTO.setSlot(bigStorageCage.getSlot()); +// bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId()); +// return bigStorageDTO; +// } +// } Assert.isTrue(null != bigStorageCage, "娌℃湁绌轰綑鐨勭瀛愬瓨鏀剧幓鐠�"); - log.info("鎸夌収瀛樼鐜荤拑鏍煎瓙鏁板墿浣欐渶澶氬緱鏂瑰紡鑾峰彇淇℃伅鐗堝浘id:{},鏍煎瓙锛歿},鐜荤拑id锛歿}", glassInfo.getTemperingLayoutId(), bigStorageCage.getSlot(), glassInfo.getGlassId()); - bigStorageDTO = new BigStorageDTO(); - bigStorageDTO.setWidth(bigStorageCage.getRemainWidth()); - bigStorageDTO.setSlot(bigStorageCage.getSlot()); - bigStorageDTO.setDeviceId(bigStorageCage.getDeviceId()); return bigStorageDTO; } @@ -385,14 +390,8 @@ @Override public List<Map<String, Object>> selectTemperingGlass() { - QueryWrapper<BigStorageCageDetails> wrapper = new QueryWrapper<>(); - wrapper.select("engineer_id,tempering_layout_id,count(*) as count") - .in("state", Const.GLASS_STATE_IN, Const.GLASS_STATE_ARTIFICIAL) - .groupBy("engineer_id,tempering_layout_id") - .orderByAsc("engineer_id") - .orderByAsc("tempering_layout_id"); - List<Map<String, Object>> TemperingGlass = baseMapper.selectMaps(wrapper); - return TemperingGlass; + List<Map<String, Object>> temperingGlass = baseMapper.selectTemperingGlassCount(); + return temperingGlass; } @Override @@ -405,4 +404,9 @@ redisUtil.setCacheObject("temperingSwitch", flag); return "success"; } + + @Override + public void appointEngineerId(String engineerId){ + redisUtil.setCacheObject("temperingengineerId", engineerId); + } } -- Gitblit v1.8.0