From 03f241781205b4aaafa6cee66e7402a41ef97fc1 Mon Sep 17 00:00:00 2001 From: wuyouming666 <2265557248@qq.com> Date: 星期五, 24 五月 2024 15:27:40 +0800 Subject: [PATCH] 增加websocket 推送下片数据给前端 --- hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/glassinfo/service/impl/GlassInfoServiceImpl.java | 31 ++++++++++++------------------- 1 files changed, 12 insertions(+), 19 deletions(-) diff --git a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/glassinfo/service/impl/GlassInfoServiceImpl.java b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/glassinfo/service/impl/GlassInfoServiceImpl.java index ef1b9ca..58bb4b0 100644 --- a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/glassinfo/service/impl/GlassInfoServiceImpl.java +++ b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/glassinfo/service/impl/GlassInfoServiceImpl.java @@ -1,4 +1,4 @@ -package com.mes.uppattenusage.service.impl; +package com.mes.glassinfo.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -24,41 +24,34 @@ private GlassInfoMapper glassInfoMapper; - @Autowired + @Autowired(required=false) public GlassInfoServiceImpl(GlassInfoMapper glassInfoMapper) { this.glassInfoMapper = glassInfoMapper; } @Override public int getGlassInfoCountByFlowCardId(String flowCardId) { - QueryWrapper<GlassInfo> queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("flow_card_id", flowCardId); - - return baseMapper.selectCount(queryWrapper); + return baseMapper.selectCount(new QueryWrapper<GlassInfo>().lambda() + .eq(GlassInfo::getFlowCardId, flowCardId)); } + @Override public List<Map<String, Object>> getFlowCardId() { - return baseMapper.selectMaps(new QueryWrapper<GlassInfo>().select("DISTINCT flow_card_id")); + return baseMapper.selectMaps(new QueryWrapper<GlassInfo>().lambda().select(GlassInfo::getFlowCardId).groupBy(GlassInfo::getFlowCardId)); } + + @Override public GlassInfo selectGlassId(String id) { - QueryWrapper<GlassInfo> queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("glass_id", id); - - return baseMapper.selectOne(queryWrapper); + return baseMapper.selectOne(new QueryWrapper<GlassInfo>().lambda() + .eq(GlassInfo::getGlassId, id)); } -// public void updateFlowCardIdAndCount(String flowCardId, int glassInfoCount, int workstationId) { -// int rowsAffected = glassInfoMapper.updateFlowCardIdAndCount(flowCardId, glassInfoCount, workstationId); -// if (rowsAffected > 0) { -// System.out.println("鏇存柊鏋跺瓙涓婃祦绋嬪崱 ID 鍜屾暟閲忔垚鍔�"); -// } else { -// System.out.println("鏇存柊鏋跺瓙涓婃祦绋嬪崱 ID 鍜屾暟閲忓け璐�"); -// } -// } + + } -- Gitblit v1.8.0