DeXun/be-process-control-system
9
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat():下发钢卷设定值请求到模型程序

Browse Source
This commit is contained in:
Allenxy
2025-01-14 10:34:30 +08:00
parent 7917e65a47
commit d7d27bd6ba
4 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
business/src/main/java/com/fizz/business/domain/ModSetupResult.java
View File

@@ -20,7 +20,7 @@ public class ModSetupResult {
private Integer id; private Integer id;
@ApiModelProperty(value = "logid") @ApiModelProperty(value = "logid")
private Integer logId; private Long logId;
@ApiModelProperty(value = "钢卷ID") @ApiModelProperty(value = "钢卷ID")
private String coilId; private String coilId;

4
business/src/main/java/com/fizz/business/mq/RabbitMQ/RabbitQueueListener.java
View File

@@ -16,6 +16,7 @@ import org.springframework.messaging.handler.annotation.Headers;
import org.springframework.messaging.handler.annotation.Payload; import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@@ -25,6 +26,7 @@ public class RabbitQueueListener {
public static List<String> measureList = Lists.newArrayList(); public static List<String> measureList = Lists.newArrayList();
@Resource
ModSetupResultService modSetupResultService; ModSetupResultService modSetupResultService;
private Double LastRolledLength = 0d; private Double LastRolledLength = 0d;
@@ -63,7 +65,7 @@ public class RabbitQueueListener {
// 获取 messageId // 获取 messageId
String messageId = (String) headers.get("amqp_messageId"); String messageId = (String) headers.get("amqp_messageId");
// 处理消息逻辑 todo // 处理消息逻辑
if ("TOTAL_PRESET_DONE".equalsIgnoreCase(messageId)) { if ("TOTAL_PRESET_DONE".equalsIgnoreCase(messageId)) {
List<ModSetupResultVO> setup = modSetupResultService.getSetupByCoilid(message); List<ModSetupResultVO> setup = modSetupResultService.getSetupByCoilid(message);

6
business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java
View File

@@ -15,6 +15,7 @@ import com.fizz.business.service.ModSetupResultService;
import com.fizz.business.utils.WebSocketUtil; import com.fizz.business.utils.WebSocketUtil;
import com.fizz.business.vo.ModSetupResultKeyVO; import com.fizz.business.vo.ModSetupResultKeyVO;
import com.fizz.business.vo.ModSetupResultVO; import com.fizz.business.vo.ModSetupResultVO;
import org.apache.commons.compress.utils.Lists;
import org.springframework.amqp.core.Message; import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties; import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.core.MessagePropertiesBuilder; import org.springframework.amqp.core.MessagePropertiesBuilder;
@@ -135,6 +136,11 @@ public class ModSetupResultServiceImpl extends ServiceImpl<ModSetupResultMapper,
List<ModSetupResult> results = this.baseMapper.selectList(queryWrapper); List<ModSetupResult> results = this.baseMapper.selectList(queryWrapper);
if (results == null || results.isEmpty()){
return Lists.newArrayList();
}
return BeanUtil.copyToList(results, ModSetupResultVO.class); return BeanUtil.copyToList(results, ModSetupResultVO.class);
} }

2
business/src/main/java/com/fizz/business/vo/ModSetupResultVO.java
View File

@@ -17,7 +17,7 @@ public class ModSetupResultVO {
private Integer id; private Integer id;
@ApiModelProperty(value = "logid") @ApiModelProperty(value = "logid")
private Integer logId; private Long logId;
@ApiModelProperty(value = "钢卷ID") @ApiModelProperty(value = "钢卷ID")
private String coilId; private String coilId;