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 | 38 ++++++++++++++++---------------------- 1 files changed, 16 insertions(+), 22 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 fcf4605..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,9 +1,7 @@ -package com.mes.uppattenusage.service.impl; +package com.mes.glassinfo.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.mes.downworkstation.entity.DownWorkstation; import com.mes.glassinfo.entity.GlassInfo; import com.mes.glassinfo.mapper.GlassInfoMapper; import com.mes.glassinfo.service.GlassInfoService; @@ -15,7 +13,7 @@ /** * <p> - * 鏈嶅姟瀹炵幇绫� + * 鏈嶅姟瀹炵幇绫� * </p> * * @author zhoush @@ -26,38 +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("flowcard_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 flowcard_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("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