From 1467d91c4dbface566a81cd7d7a51ffada173465 Mon Sep 17 00:00:00 2001
From: zhangyong <517047165@qq.com>
Date: 星期一, 27 五月 2024 09:24:03 +0800
Subject: [PATCH] Merge branch 'master' of http://bore.pub:10439/r/HangZhouMes
---
hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/S7control.java | 219 +++++++++++++++++++++++++-----------
hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/workstation/service/impl/UpWorkstationServiceImpl.java | 2
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java | 110 +++++++++---------
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageServiceImpl.java | 5
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/S7object.java | 5
5 files changed, 209 insertions(+), 132 deletions(-)
diff --git a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/S7control.java b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/S7control.java
index 10e349a..32812b3 100644
--- a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/S7control.java
+++ b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/S7control.java
@@ -3,6 +3,7 @@
import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
import com.github.xingshuangs.iot.protocol.s7.service.MultiAddressWrite;
import com.github.xingshuangs.iot.protocol.s7.service.S7PLC;
+
import java.util.ArrayList;
import java.util.List;
@@ -24,13 +25,20 @@
s7PLC.close();
}
}
+
/**
* 閲嶅惎瑗块棬瀛恠7閫氳杩炴帴
*/
- public void reStartS7client() {
+ public boolean reStartS7client() {
if (s7PLC != null) {
- s7PLC.hotRestart();
+ try {
+ s7PLC.hotRestart();
+ return true;
+ } catch (Exception ex) {
+ return false;
+ }
}
+ return false;
}
@@ -47,14 +55,24 @@
* @param address 鍦板潃
* @param data word鐨勫��
*/
- public void writeWord(String address, int data) {
+ public boolean writeWord(String address, int data) {
if (s7PLC == null) {
- return;
+ return false;
}
- else if(!s7PLC.checkConnected()) {
- s7PLC.hotRestart();
+ boolean result = false;
+ int tryCount = 2;
+ do {
+ try {
+ s7PLC.writeUInt16(address, data);
+ result = true;
+ } catch (Exception ex) {
+ reStartS7client();
+ } finally {
+ tryCount -= 1;
+ }
}
- s7PLC.writeUInt16(address, data);
+ while (!result && tryCount > 0);
+ return result;
}
/**
@@ -63,20 +81,31 @@
* @param address 鍦板潃
* @param datas word鐨勫��
*/
- public void writeWord(String address, List<Integer> datas) {
+ public boolean writeWord(String address, List<Integer> datas) {
if (s7PLC == null) {
- return;
+ return false;
}
- else if(!s7PLC.checkConnected()) {
- s7PLC.hotRestart();
- }
+ boolean result = false;
+ int tryCount = 2;
// s7PLC.write(address, data);
List<String> addresslist = getAddressList(address, datas.size(), 16);
MultiAddressWrite addressWrite = new MultiAddressWrite();
for (int i = 0; i < datas.size(); i++) {
addressWrite.addUInt16(addresslist.get(i), datas.get(i));
}
- s7PLC.writeMultiData(addressWrite);
+ do {
+ try {
+ s7PLC.writeMultiData(addressWrite);
+ result = true;
+ } catch (Exception ex) {
+ reStartS7client();
+ } finally {
+ tryCount -= 1;
+ }
+ }
+ while (!result && tryCount > 0);
+ return result;
+
}
/**
@@ -93,14 +122,24 @@
* @param address 鍦板潃
* @param data Bit鐨勫��
*/
- public void writeBit(String address, Boolean data) {
+ public boolean writeBit(String address, Boolean data) {
if (s7PLC == null) {
- return;
+ return false;
}
- else if(!s7PLC.checkConnected()) {
- s7PLC.hotRestart();
+ boolean result = false;
+ int tryCount = 2;
+ do {
+ try {
+ s7PLC.writeBoolean(address, data);
+ result = true;
+ } catch (Exception ex) {
+ reStartS7client();
+ } finally {
+ tryCount -= 1;
+ }
}
- s7PLC.writeBoolean(address, data);
+ while (!result && tryCount > 0);
+ return result;
}
/**
@@ -109,20 +148,30 @@
* @param address 鍦板潃
* @param datas bit鐨勫��
*/
- public void writeBit(List<String> address, List<Boolean> datas) {
+ public boolean writeBit(List<String> address, List<Boolean> datas) {
if (s7PLC == null) {
- return;
+ return false;
}
- else if(!s7PLC.checkConnected()) {
- s7PLC.hotRestart();
- }
- // s7PLC.write(address, data);
MultiAddressWrite addressWrite = new MultiAddressWrite();
for (int i = 0; i < address.size(); i++) {
addressWrite.addBoolean(address.get(i), datas.get(i));
}
- s7PLC.writeMultiData(addressWrite);
+ boolean result = false;
+ int tryCount = 2;
+ do {
+ try {
+ s7PLC.writeMultiData(addressWrite);
+ result = true;
+ } catch (Exception ex) {
+ reStartS7client();
+ } finally {
+ tryCount -= 1;
+ }
+ }
+ while (!result && tryCount > 0);
+ return result;
+
}
/**
@@ -131,20 +180,31 @@
* @param address 鍦板潃
* @param datas word鐨勫��
*/
- public void writeBit(String address, List<Boolean> datas) {
+ public boolean writeBit(String address, List<Boolean> datas) {
if (s7PLC == null) {
- return;
+ return false;
}
- else if(!s7PLC.checkConnected()) {
- s7PLC.hotRestart();
- }
+
// s7PLC.write(address, data);
List<String> addresslist = getAddressList(address, datas.size(), 1);
MultiAddressWrite addressWrite = new MultiAddressWrite();
for (int i = 0; i < datas.size(); i++) {
addressWrite.addBoolean(addresslist.get(i), datas.get(i));
}
- s7PLC.writeMultiData(addressWrite);
+ boolean result = false;
+ int tryCount = 2;
+ do {
+ try {
+ s7PLC.writeMultiData(addressWrite);
+ result = true;
+ } catch (Exception ex) {
+ reStartS7client();
+ } finally {
+ tryCount -= 1;
+ }
+ }
+ while (!result && tryCount > 0);
+ return result;
}
/**
@@ -153,15 +213,24 @@
* @param address 鍦板潃
* @param datas byte鐨勫��
*/
- public void writeByte(String address, byte[] datas) {
+ public boolean writeByte(String address, byte[] datas) {
if (s7PLC == null) {
- return;
+ return false;
}
- else if(!s7PLC.checkConnected()) {
- s7PLC.hotRestart();
+ boolean result = false;
+ int tryCount = 2;
+ do {
+ try {
+ s7PLC.writeByte(address, datas);
+ result = true;
+ } catch (Exception ex) {
+ reStartS7client();
+ } finally {
+ tryCount -= 1;
+ }
}
- // s7PLC.write(address, data);
- s7PLC.writeByte(address, datas);
+ while (!result && tryCount > 0);
+ return result;
}
/**
@@ -174,16 +243,17 @@
if (s7PLC == null) {
return null;
}
-
+ List<Integer> result = null;
try {
- return s7PLC.readUInt16(address);
+ result = s7PLC.readUInt16(address);
} catch (Exception e) {
s7PLC.hotRestart();
System.out.println("璇诲彇 " + address + " 澶辫触锛�" + e.getMessage());
- return null;
+
+ } finally {
+ return result;
}
}
-
/**
@@ -197,15 +267,15 @@
if (s7PLC == null) {
return null;
}
-
+ List<Integer> result = null;
List<String> addresslist = getAddressList(address, count, 16);
try {
- return s7PLC.readUInt16(addresslist);
+ result = s7PLC.readUInt16(addresslist);
} catch (Exception e) {
s7PLC.hotRestart();
System.out.println("璇诲彇 " + address + " 澶辫触锛�" + e.getMessage());
-
- return null;
+ } finally {
+ return result;
}
}
@@ -221,14 +291,15 @@
return null;
}
// List<String> addresslist = GetAddressList(address, count, 16);
-
+ byte[] bytes = null;
try {
- return s7PLC.readByte(address, count);
+ bytes = s7PLC.readByte(address, count);
} catch (Exception e) {
// 澶勭悊寮傚父
s7PLC.hotRestart();
System.out.println("璇诲彇 " + address + " 澶辫触锛�" + e.getMessage());
- return null;
+ } finally {
+ return bytes;
}
}
@@ -243,14 +314,15 @@
if (s7PLC == null) {
return null;
}
+ List<Boolean> values = new ArrayList<>();
try {
- return s7PLC.readBoolean(addresslist);
+ values = s7PLC.readBoolean(addresslist);
} catch (Exception e) {
// 澶勭悊寮傚父
s7PLC.hotRestart();
- return null;
+ } finally {
+ return values;
}
-
}
/* //璇诲彇涓嶈繛缁湴鍧�bit
@@ -274,22 +346,21 @@
}*/
-
-
//璇诲彇瀛楃涓�
public String readString(String address) {
if (s7PLC == null) {
return null;
}
+ String result = null;
try {
- return s7PLC.readString(address);
+ result = s7PLC.readString(address);
} catch (Exception e) {
s7PLC.hotRestart();
System.out.println("璇诲彇 " + address + " 澶辫触锛�" + e.getMessage());
- return null;
+ } finally {
+ return result;
}
}
-
//璇诲彇鏃堕棿
@@ -297,27 +368,36 @@
if (s7PLC == null) {
return null;
}
+ Long result = null;
try {
- return s7PLC.readTime(address);
+ result = s7PLC.readTime(address);
} catch (Exception e) {
s7PLC.hotRestart();
System.out.println("璇诲彇 " + address + " 澶辫触锛�" + e.getMessage());
- return null;
+ } finally {
+ return result;
}
}
- public void writetime(String address, long datas) {
+ public boolean writetime(String address, long datas) {
if (s7PLC == null) {
- return;
+ return false;
}
- else if(!s7PLC.checkConnected())
- {
- s7PLC.hotRestart();
+ boolean result = false;
+ int tryCount = 2;
+ do {
+ try {
+ s7PLC.writeTime(address, datas); // 灏嗘暟鎹啓鍏ュ崟涓湴鍧�
+ result = true;
+ } catch (Exception ex) {
+ reStartS7client();
+ } finally {
+ tryCount -= 1;
+ }
}
-
-
- s7PLC.writeTime(address, datas); // 灏嗘暟鎹啓鍏ュ崟涓湴鍧�
+ while (!result && tryCount > 0);
+ return result;
}
@@ -332,15 +412,16 @@
if (s7PLC == null) {
return null;
}
+ List<Boolean> values = new ArrayList<>();
List<String> addresslist = getAddressList(address, count, 1);
try {
- return s7PLC.readBoolean(addresslist);
+ values = s7PLC.readBoolean(addresslist);
} catch (Exception e) {
s7PLC.hotRestart();
System.out.println("璇诲彇 " + address + " 澶辫触锛�" + e.getMessage());
- return null;
+ } finally {
+ return values;
}
-
}
;
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/S7object.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/S7object.java
index 53a7864..f63bc63 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/S7object.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/S7object.java
@@ -53,8 +53,9 @@
}
byte[] getplcvlues = plccontrol.readByte(PlcMesObject.getPlcAddressBegin(), PlcMesObject.getPlcAddressLength());
- PlcMesObject.setPlcParameterList(getplcvlues);
-
+ if (getplcvlues != null) {
+ PlcMesObject.setPlcParameterList(getplcvlues);
+ }
}
}
}
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageServiceImpl.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageServiceImpl.java
index 5d27ac4..12a13ad 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageServiceImpl.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageServiceImpl.java
@@ -108,12 +108,9 @@
.select(EdgStorageCageDetails::getGlassId, EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight, EdgStorageCageDetails::getId)
.leftJoin(EdgStorageCageDetails.class, on -> on
.eq(EdgStorageCageDetails::getDeviceId, EdgStorageCage::getDeviceId)
+ .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)
.eq(EdgStorageCageDetails::getSlot, EdgStorageCage::getSlot))
);
-// return baseMapper.selectJoinMaps(new MPJQueryWrapper<EdgStorageCage>().selectAll(EdgStorageCage.class)
-// .select("escd.glass_id","escd.flow_card_id","escd.width","escd.height")
-// .leftJoin("edg_storage_cage_details escd on t.device_id=escd.device_id and t.slot=escd.slot")
-// );
}
/**
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
index a3615de..365eb8d 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
@@ -5,7 +5,6 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.yulichang.query.MPJQueryWrapper;
-import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.mes.common.S7object;
import com.mes.common.WebSocketServer;
import com.mes.common.config.Const;
@@ -182,7 +181,7 @@
* @param glassId
* @param currentSlot
*/
- private boolean outTo(int out08Glassstate, int out10Glassstate, String confirmationWrodAddress, String glassId, int currentSlot) {
+ public boolean outTo(int out08Glassstate, int out10Glassstate, String confirmationWrodAddress, String glassId, int currentSlot) {
//閫昏緫姝ラ锛�
// 0銆丄09銆丄10鏄惁绌洪棽锛屾槸鍚﹀彲浠ユ墽琛屽嚭鐗囦换鍔�
// 1銆佽幏鍙栭挗鍖栫増鍥炬槸鍚﹁秴杩囬槇鍊�
@@ -219,37 +218,59 @@
endcell = queryLineByGlassInfo(a09EdgGlass, a10EdgGlass, glassInfo, out08Glassstate, out10Glassstate);
} else {
//鍒ゆ柇涓ゆ潯绾挎槸鍚﹂兘绌洪棽
- endcell = out08Glassstate == 1 || out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
+ endcell = out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
if ((out08Glassstate == 0 && out10Glassstate == 0) || (out08Glassstate == 1 && out10Glassstate == 1)) {
EdgStorageCageDetails a09EdgGlass = queryGlassByTaskCache(Const.A09_OUT_TARGET_POSITION, Const.GLASS_CACHE_TYPE_OUT);
EdgStorageCageDetails a10EdgGlass = queryGlassByTaskCache(Const.A10_OUT_TARGET_POSITION, Const.GLASS_CACHE_TYPE_OUT);
if (a09EdgGlass == null && a10EdgGlass == null) {
- MPJLambdaWrapper<EdgStorageCageDetails> wrapper = new MPJLambdaWrapper<>();
- wrapper.select(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight)
- .selectCount(EdgStorageCageDetails::getGlassId, EdgStorageCageDetails::getCount)
- .groupBy(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight)
- .last("order by count(t.glass_id) desc limit 2");
+ MPJQueryWrapper<EdgStorageCageDetails> wrapper = new MPJQueryWrapper<>();
+ wrapper.select("count(t.glass_id), t.width, t.height")
+ .eq("t.state", Const.GLASS_STATE_IN)
+ .groupBy("t.width, t.height");
+ if (endcell == Const.A10_OUT_TARGET_POSITION) {
+ wrapper.innerJoin("(select glass_id, case when height <= width then width else height end as first_length, " +
+ "case when width < height then width else height end as second_length from edg_storage_cage_details) t1 " +
+ "on t.glass_id = t1.glass_id and t1.first_length <3500 and t1.second_length<2600 ");
+ }
+ wrapper.last("order by count(t.glass_id) desc limit 2");
List<EdgStorageCageDetails> list = edgStorageCageDetailsService.list(wrapper);
if (CollectionUtil.isEmpty(list)) {
- GlassInfo one = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
- .eq(GlassInfo::getGlassId, glassId));
- EdgStorageCageDetails resultDetails = new EdgStorageCageDetails();
- BeanUtils.copyProperties(one, resultDetails);
- glassInfo = resultDetails;
+ MPJQueryWrapper<GlassInfo> queryWrapper = new MPJQueryWrapper<GlassInfo>()
+ .selectAll(GlassInfo.class).eq("t.glass_id", glassId);
+ if (endcell == Const.A10_OUT_TARGET_POSITION) {
+ queryWrapper.innerJoin("(select glass_id, case when height <= width then width else height end as first_length, " +
+ "case when width < height then width else height end as second_length from glass_info) t1 " +
+ "on t.glass_id = t1.glass_id and t1.first_length <3500 and t1.second_length<2600 ");
+ }
+ GlassInfo one = glassInfoService.getOne(queryWrapper);
+ if (one != null) {
+ EdgStorageCageDetails resultDetails = new EdgStorageCageDetails();
+ BeanUtils.copyProperties(one, resultDetails);
+ glassInfo = resultDetails;
+ } else {
+ log.info("鑾峰彇绗煎唴鐜荤拑鍜屽甫杩涚墖鐜荤拑涓虹┖鎴栬�呬笉绗﹀悎纾ㄨ竟灏哄");
+ }
} else {
glassInfo = queryMinGlass(list.get(0).getWidth(), list.get(0).getHeight(), glassId);
}
} else if (a09EdgGlass != null && a10EdgGlass != null) {
List<EdgStorageCageDetails> a09Count = queryGlassByTaskLine(Const.A09_OUT_TARGET_POSITION);
- List<EdgStorageCageDetails> a10Count = queryGlassByTaskLine(Const.A09_OUT_TARGET_POSITION);
+ List<EdgStorageCageDetails> a10Count = queryGlassByTaskLine(Const.A10_OUT_TARGET_POSITION);
endcell = a09Count.size() > a10Count.size() ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
glassInfo = a09Count.size() > a10Count.size() ? queryMinGlass(a09EdgGlass.getWidth(), a09EdgGlass.getHeight(), glassId)
: queryMinGlass(a10EdgGlass.getWidth(), a10EdgGlass.getHeight(), glassId);
} else {
- endcell = a09EdgGlass != null ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
- glassInfo = a09EdgGlass != null ? queryMinGlass(a09EdgGlass.getWidth(), a09EdgGlass.getHeight(), glassId)
- : queryMinGlass(a10EdgGlass.getWidth(), a10EdgGlass.getHeight(), glassId);
+ //鎸夌収鍘嗗彶浠诲姟鑾峰彇闇�瑕佹墽琛岀殑璺嚎锛屽鏋滆鏉＄嚎绗煎唴鏃犵幓鐠� 璧板叾浠栭�昏緫
+ endcell = a09EdgGlass == null ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
+ List<EdgStorageCageDetails> details = queryGlassByTaskLine(endcell);
+ if (CollectionUtil.isEmpty(details)) {
+ int othercell = endcell == Const.A10_OUT_TARGET_POSITION ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
+ glassInfo = queryChangeGlassInfo(othercell, glassId);
+ } else {
+ glassInfo = a09EdgGlass != null ? queryMinGlass(a09EdgGlass.getWidth(), a09EdgGlass.getHeight(), glassId)
+ : queryMinGlass(a10EdgGlass.getWidth(), a10EdgGlass.getHeight(), glassId);
+ }
}
} else {
List<EdgStorageCageDetails> edgStorageCageDetails = queryGlassByTaskLine(endcell);
@@ -410,41 +431,14 @@
boolean b10 = a10EdgStorageCageDetails != null && a10EdgStorageCageDetails.getHeight().equals(glassInfo.getHeight())
&& a10EdgStorageCageDetails.getWidth().equals(glassInfo.getWidth());
//瀛樺湪鍑虹墖浠诲姟 07涓虹┖
- if (a08EdgStorageCageDetails == null && a10EdgStorageCageDetails == null) {
- return queryLineNoTask(out08Glassstate, out10Glassstate);
- } else {
- if (b08) {
- return queryLineHasTask(out08Glassstate);
- }
- if (b10) {
- return queryLineHasTask(out10Glassstate);
- }
- return queryLineNoTask(out08Glassstate, out10Glassstate);
+ if (b10) {
+ return out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
}
- }
-
- /**
- * 鑾峰彇鏈変换鍔″悗鐨勫嚭鐗囬�昏緫
- */
- private Integer queryLineHasTask(int outGlassstate) {
- return outGlassstate == 2 ? Const.A10_OUT_TARGET_POSITION : Const.A09_OUT_TARGET_POSITION;
- }
-
- /**
- * 鑾峰彇鏃犱换鍔″悗鐨勫嚭鐗囬�昏緫
- *
- * @return
- */
- private Integer queryLineNoTask(int out08Glassstate, int out10Glassstate) {
- if (out08Glassstate == 2) {
- return Const.A10_OUT_TARGET_POSITION;
+ if (b08) {
+ return out08Glassstate == 2 ? Const.A10_OUT_TARGET_POSITION : Const.A09_OUT_TARGET_POSITION;
}
- if (out10Glassstate == 2 || out08Glassstate == 1) {
- return Const.A09_OUT_TARGET_POSITION;
- }
- return Const.A10_OUT_TARGET_POSITION;
+ return out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
}
-
/**
* 鎸夌収灏哄鍑虹幓鐠�
@@ -453,14 +447,18 @@
* @param glassId
* @return
*/
- private EdgStorageCageDetails queryChangeGlassInfo(int endcell, String glassId) {
+ public EdgStorageCageDetails queryChangeGlassInfo(int endcell, String glassId) {
//鑾峰彇绗煎瓙鍐呮暟閲忓墠浜岀殑鐜荤拑鏁伴噺
- MPJLambdaWrapper<EdgStorageCageDetails> wrapper = new MPJLambdaWrapper<>();
- wrapper.select(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight)
- .selectCount(EdgStorageCageDetails::getGlassId, EdgStorageCageDetails::getCount)
- .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)
- .groupBy(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight)
- .last("order by count(t.glass_id) desc limit 2");
+ MPJQueryWrapper<EdgStorageCageDetails> wrapper = new MPJQueryWrapper<>();
+ wrapper.select("count(t.glass_id), t.width, t.height")
+ .eq("t.state", Const.GLASS_STATE_IN)
+ .groupBy("t.width, t.height");
+ if (endcell == Const.A09_OUT_TARGET_POSITION) {
+ wrapper.innerJoin("(select glass_id, case when height <= width then width else height end as first_length, " +
+ "case when width < height then width else height end as second_length from edg_storage_cage_details) t1 " +
+ "on t.glass_id = t1.glass_id and t1.first_length <3500 and t1.second_length<2600 ");
+ }
+ wrapper.last("order by count(t.glass_id) desc limit 2");
List<EdgStorageCageDetails> list = edgStorageCageDetailsService.list(wrapper);
if (CollectionUtil.isEmpty(list)) {
return null;
diff --git a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/workstation/service/impl/UpWorkstationServiceImpl.java b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/workstation/service/impl/UpWorkstationServiceImpl.java
index 38aa703..a9d15bf 100644
--- a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/workstation/service/impl/UpWorkstationServiceImpl.java
+++ b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/workstation/service/impl/UpWorkstationServiceImpl.java
@@ -90,7 +90,7 @@
@Override
public String updateMesInkageLoad(short inKageWord) {
PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
- log.info("淇敼璁惧涓ゆ爧璇锋眰涓簕}锛�0鑱旂嚎锛�1鑱斿姩", inKageWord);
+ log.info("淇敼璁惧鑱斿姩璇锋眰涓簕}锛�0绂荤嚎锛�1鑱斿姩", inKageWord);
S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("InkageStatus").getAddress(), inKageWord);
return "success";
}
--
Gitblit v1.8.0