From 208988e9844eb9541e57b68ca0fd0a1b79382df7 Mon Sep 17 00:00:00 2001
From: shenyuan <shenyuan2825@163.com>
Date: Mon, 5 Jun 2023 11:14:33 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E9=A6=96=E9=A1=B5=E8=BD=AE=E6=92=AD?=
 =?UTF-8?q?=E5=9B=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/views/shopping/shopHome.vue           | 58 ++++++++++++++-----
 1 file changed, 42 insertions(+), 16 deletions(-)

diff --git a/ant-design-vue-jeecg/src/views/shopping/shopHome.vue b/ant-design-vue-jeecg/src/views/shopping/shopHome.vue
index 68f829dc..dddc9e10 100644
--- a/ant-design-vue-jeecg/src/views/shopping/shopHome.vue
+++ b/ant-design-vue-jeecg/src/views/shopping/shopHome.vue
@@ -74,7 +74,16 @@
           <div class="orange"></div>
           <p class="desc">Recommending Commodities</p>
         </div>
-        <a-carousel arrows :slides-to-show="3" :slides-to-scroll="1">
+<!--        <el-carousel :interval="4000" type="card">-->
+<!--          <el-carousel-item v-for="(item, index) in clothList2" :key="index" @click="tjspxq1(item.id,item.title)">-->
+<!--            <div class="box" >-->
+<!--              <img :src="item.imgUrl" alt="" />-->
+<!--              <p class="box1">{{item.title}}</p>-->
+<!--              <p class="box2">{{item.time}}</p>-->
+<!--            </div>-->
+<!--          </el-carousel-item>-->
+<!--        </el-carousel>-->
+        <a-carousel arrows :slides-to-show="3" :slides-to-scroll="1" >
           <div
             slot="prevArrow"
             slot-scope="props"
@@ -89,7 +98,7 @@
           <div class="box" v-for="(item, index) in clothList2" :key="index" @click="tjspxq1(item.id,item.title)">
             <img :src="item.imgUrl" alt="" />
             <p class="box1">{{item.title}}</p>
-            <p class="box2">{{item.time}}</p>
+            <p class="box2">价格:{{item.time}}</p>
           </div>
         </a-carousel>
         <div class="more d-flex" style="padding-top: 20px">
@@ -693,20 +702,37 @@
   @import './assets/common.css';
 </style>
 <style scoped>
-  .box {
-    position: relative;
-  }
-  .img {
-    position: absolute;
-    top: 0;
-  }
-  .box1 {
-    position: absolute;
-    bottom: 20%;
-  }
-  .box2 {
-    position: absolute;
-    bottom: 5%;
+  /*.box {*/
+  /*     position: relative;*/
+  /*   }*/
+  /*.img {*/
+  /*  position: absolute;*/
+  /*  top: 0;*/
+  /*}*/
+  /*.box1 {*/
+  /*  position: absolute;*/
+  /*  bottom: 20%;*/
+  /*}*/
+  /*.box2 {*/
+  /*  position: absolute;*/
+  /*  bottom: 5%;*/
+  /*}*/
+  /*.slick-slide.slick-active:nth-child(2) img{*/
+  /*  height: 450px;*/
+  /*  width: 100%;*/
+  /*}*/
+  .box img{
+    width: 90%;
+    height: 400px;
+  }
+  .box .box1{
+    width: 90%;
+    margin-top: 20px;
+    letter-spacing: 0.1em;
+    font-size: 24px;color: #1B1B1B;
+  }
+  .box .box2{
+    font-size: 18px;color: #1B1B1B;text-align: right;padding-right: 80px;
   }
   .more {
     align-items: center;

From 29baf082415387b3d3f758c83d5e9ecdc0705c97 Mon Sep 17 00:00:00 2001
From: zhc077 <565291854>
Date: Mon, 5 Jun 2023 18:18:27 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E7=94=9F=E4=BA=A7=E7=BA=BF=E5=AE=9E?=
 =?UTF-8?q?=E6=97=B6=E7=8A=B6=E6=80=81=20=E6=95=B0=E6=8D=AE=E7=BB=9F?=
 =?UTF-8?q?=E8=AE=A1=206.5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ProductionLargeScreenController.java      |   7 ++
 .../service/ProductionLargeService.java       |   2 +
 .../impl/ProductionLargeServiceImpl.java      | 119 +++++++++++++-----
 .../largeScreen/vo/ProductRecordVo.java       |  12 +-
 .../message/entity/ZySpeechMessage.java       |   8 ++
 .../controller/ZyProductPlanController.java   |   2 +
 6 files changed, 120 insertions(+), 30 deletions(-)

diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/controller/ProductionLargeScreenController.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/controller/ProductionLargeScreenController.java
index 8e452b39..1cd28b6b 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/controller/ProductionLargeScreenController.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/controller/ProductionLargeScreenController.java
@@ -33,4 +33,11 @@ public class ProductionLargeScreenController {
         return Result.OK(data);
     }
 
+    @ApiOperation(value = "获取生产设备大屏数据", notes = "获取生产设备大屏数据")
+    @GetMapping("/shengchanxian_data")
+    public Result<?> shengchanxian_data() {
+        Map<String, Object> data = productionLargeService.shengchanxian_data();
+        return Result.OK(data);
+    }
+
 }
diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/ProductionLargeService.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/ProductionLargeService.java
index cacff101..cc38e88c 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/ProductionLargeService.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/ProductionLargeService.java
@@ -5,4 +5,6 @@ import java.util.Map;
 public interface ProductionLargeService {
 
     Map<String, Object> getData();
+
+    Map<String, Object> shengchanxian_data();
 }
diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/impl/ProductionLargeServiceImpl.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/impl/ProductionLargeServiceImpl.java
index 3bd4988c..6e814ac7 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/impl/ProductionLargeServiceImpl.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/service/impl/ProductionLargeServiceImpl.java
@@ -64,7 +64,71 @@ public class ProductionLargeServiceImpl implements ProductionLargeService {
         resultMap.put("diaogua_data", diaoguaData);*/
 
 
-        //2,生产线实时状态
+//        //2,生产线实时状态
+//        List<Station> stationGroup = iStationService.list(new LambdaQueryWrapper<Station>().groupBy(Station::getDepartId));
+//        Map<String, Object> shengchanxianMap = new LinkedHashMap<>();
+//        if (!ObjectUtils.isEmpty(stationGroup)) {
+//            stationGroup.stream().forEach(station -> {
+//                Map<String, Object> departMap = new LinkedHashMap<>();
+//                //每个车间的工位
+//                List<Station> stationList = iStationService.list(new LambdaQueryWrapper<Station>()
+//                        .eq(Station::getDepartId, station.getDepartId())
+//                        .orderByAsc(Station::getStationNum)
+//                );
+//                /**
+//                 * 取每个工位的，生产记录状态0(生产中)的最新一条数据
+//                 */
+//                List<ProductRecordVo> productRecordVos = new LinkedList<>();
+//                Optional.ofNullable(stationList).orElse(new LinkedList<>()).forEach(obj -> {
+//                    ProductRecord productRecord = iProductRecordService.getOne(new LambdaQueryWrapper<ProductRecord>()
+//                            .eq(ProductRecord::getStationId, obj.getId())
+//                            .eq(ProductRecord::getStatus, "0")
+//                            .orderByDesc(ProductRecord::getCreateTime)
+//                            .last("limit 1")
+//                    );
+//                    if (!ObjectUtils.isEmpty(productRecord)) {
+//                        ZyProductPlan productPlan = iZyProductPlanService.getOne(new LambdaQueryWrapper<ZyProductPlan>().eq(ZyProductPlan::getProductCode, productRecord.getOrderCode()));
+//                        Optional.ofNullable(productPlan).orElseThrow(() -> new JeecgBootException("工单编号:" + productRecord.getOrderCode() + "不存在!"));
+//                        List<ZyPlanProcess> zyPlanProcessList = iZyPlanProcessService.list(new LambdaQueryWrapper<ZyPlanProcess>()
+//                                .eq(ZyPlanProcess::getPlanId, productPlan.getId())
+//                                .eq(ZyPlanProcess::getStationId, obj.getId())
+//                        );
+//                        if (!ObjectUtils.isEmpty(zyPlanProcessList)) {
+//                            ZyPlanProcess zyPlanProcess = zyPlanProcessList.get(0);
+//                            ProductRecordVo vo = new ProductRecordVo();
+//                            vo.setProductCode(productRecord.getOrderCode());
+//                            vo.setProcessName(zyPlanProcess.getProcessName());
+//                            vo.setStationName(zyPlanProcess.getStationName());
+//                            vo.setMachineNames(zyPlanProcess.getMachineNames());
+//                            vo.setStationNum(zyPlanProcess.getStationNum());
+//                            productRecordVos.add(vo);
+//                        } else {
+//                            ProductRecordVo vo = new ProductRecordVo();
+//                            vo.setStationName(obj.getStationName());
+//                            vo.setStationNum(obj.getStationNum());
+//                            productRecordVos.add(vo);
+//                        }
+//                    } else {
+//                        ProductRecordVo vo = new ProductRecordVo();
+//                        vo.setStationName(obj.getStationName());
+//                        vo.setStationNum(obj.getStationNum());
+//                        productRecordVos.add(vo);
+//                    }
+//                });
+//                SysDepart depart = iSysDepartService.getOne(new LambdaQueryWrapper<SysDepart>().eq(SysDepart::getId, station.getDepartId()));
+////                productRecordVos.stream().map(o -> o.getStationNum()).collect(Collectors.toList());
+//                departMap.put(depart.getDepartName(), productRecordVos);
+//                shengchanxianMap.putAll(departMap);
+//            });
+//        }
+//        resultMap.put("shengchanxian_data", shengchanxianMap);
+        return resultMap;
+    }
+
+    @Override
+    public Map<String, Object> shengchanxian_data() {
+        Map<String, Object> resultMap = new HashMap<>();
+
         List<Station> stationGroup = iStationService.list(new LambdaQueryWrapper<Station>().groupBy(Station::getDepartId));
         Map<String, Object> shengchanxianMap = new LinkedHashMap<>();
         if (!ObjectUtils.isEmpty(stationGroup)) {
@@ -80,34 +144,32 @@ public class ProductionLargeServiceImpl implements ProductionLargeService {
                  */
                 List<ProductRecordVo> productRecordVos = new LinkedList<>();
                 Optional.ofNullable(stationList).orElse(new LinkedList<>()).forEach(obj -> {
-                    ProductRecord productRecord = iProductRecordService.getOne(new LambdaQueryWrapper<ProductRecord>()
-                            .eq(ProductRecord::getStationId, obj.getId())
-                            .eq(ProductRecord::getStatus, "0")
-                            .orderByDesc(ProductRecord::getCreateTime)
-                            .last("limit 1")
-                    );
-                    if (!ObjectUtils.isEmpty(productRecord)) {
-                        ZyProductPlan productPlan = iZyProductPlanService.getOne(new LambdaQueryWrapper<ZyProductPlan>().eq(ZyProductPlan::getProductCode, productRecord.getOrderCode()));
-                        Optional.ofNullable(productPlan).orElseThrow(() -> new JeecgBootException("工单编号:" + productRecord.getOrderCode() + "不存在!"));
-                        List<ZyPlanProcess> zyPlanProcessList = iZyPlanProcessService.list(new LambdaQueryWrapper<ZyPlanProcess>()
-                                .eq(ZyPlanProcess::getPlanId, productPlan.getId())
-                                .eq(ZyPlanProcess::getStationId, obj.getId())
-                        );
-                        if (!ObjectUtils.isEmpty(zyPlanProcessList)) {
-                            ZyPlanProcess zyPlanProcess = zyPlanProcessList.get(0);
-                            ProductRecordVo vo = new ProductRecordVo();
-                            vo.setProductCode(productRecord.getOrderCode());
-                            vo.setProcessName(zyPlanProcess.getProcessName());
-                            vo.setStationName(zyPlanProcess.getStationName());
-                            vo.setMachineNames(zyPlanProcess.getMachineNames());
-                            vo.setStationNum(zyPlanProcess.getStationNum());
-                            productRecordVos.add(vo);
-                        } else {
-                            ProductRecordVo vo = new ProductRecordVo();
-                            vo.setStationName(obj.getStationName());
-                            vo.setStationNum(obj.getStationNum());
-                            productRecordVos.add(vo);
+//                    ProductRecord productRecord = iProductRecordService.getOne(new LambdaQueryWrapper<ProductRecord>()
+//                            .eq(ProductRecord::getStationId, obj.getId())
+//                            .eq(ProductRecord::getStatus, "0")
+//                            .orderByDesc(ProductRecord::getCreateTime)
+//                            .last("limit 1")
+//                    );
+                    //查询生产计划工序表，对应设备状态 为生产中的数据
+                    ZyPlanProcess zyPlanProcess = iZyPlanProcessService.getOne(new LambdaQueryWrapper<ZyPlanProcess>()
+                            .eq(ZyPlanProcess::getStationId, obj.getId())
+//                            .eq(ZyPlanProcess::getStatus,"1"))
+                            .orderByDesc(ZyPlanProcess::getUpdateTime)
+                            .last("limit 1"));
+                    if (!ObjectUtils.isEmpty(zyPlanProcess)) {
+                        ZyProductPlan productPlan = iZyProductPlanService.getById(zyPlanProcess.getPlanId());
+//                        Optional.ofNullable(productPlan).orElseThrow(() -> new JeecgBootException("生产计划:" + zyPlanProcess.getPlanId() + "不存在!"));
+                        ProductRecordVo vo = new ProductRecordVo();
+                        if (!ObjectUtils.isEmpty(productPlan)) {
+                            vo.setWorkOrder(productPlan.getProductNo());
                         }
+                        vo.setProcessName(zyPlanProcess.getProcessName());
+                        vo.setStationName(zyPlanProcess.getStationName());
+                        vo.setMachineNames(zyPlanProcess.getMachineNames());
+                        vo.setStationNum(zyPlanProcess.getStationNum());
+                        vo.setProcessStatus(zyPlanProcess.getStatus());
+                        vo.setPlanProcessInfo(zyPlanProcess);
+                        productRecordVos.add(vo);
                     } else {
                         ProductRecordVo vo = new ProductRecordVo();
                         vo.setStationName(obj.getStationName());
@@ -116,7 +178,6 @@ public class ProductionLargeServiceImpl implements ProductionLargeService {
                     }
                 });
                 SysDepart depart = iSysDepartService.getOne(new LambdaQueryWrapper<SysDepart>().eq(SysDepart::getId, station.getDepartId()));
-//                productRecordVos.stream().map(o -> o.getStationNum()).collect(Collectors.toList());
                 departMap.put(depart.getDepartName(), productRecordVos);
                 shengchanxianMap.putAll(departMap);
             });
diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/vo/ProductRecordVo.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/vo/ProductRecordVo.java
index f2a57098..9be807c2 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/vo/ProductRecordVo.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/largeScreen/vo/ProductRecordVo.java
@@ -1,12 +1,15 @@
 package org.jeecg.modules.largeScreen.vo;
 
+import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
+import org.jeecg.modules.productplan.entity.ZyPlanProcess;
 import org.jeecgframework.poi.excel.annotation.Excel;
 
 import java.io.Serializable;
 
 @Data
+@ApiModel(value="生产大屏-生产线实时状态", description="生产大屏-生产线实时状态")
 public class ProductRecordVo implements Serializable {
     private static final long serialVersionUID = 007555;
 
@@ -21,6 +24,7 @@ public class ProductRecordVo implements Serializable {
 //    @ApiModelProperty(value = "设备id列表")
 //    @Dict(dictTable = "zy_device", dicText = "name", dicCode = "id")
 //    private String machineIds;
+
     private String machineNames;
 
 
@@ -44,7 +48,13 @@ public class ProductRecordVo implements Serializable {
 
     @Excel(name = "工单编号", width = 15)
     @ApiModelProperty(value = "工单编号")
-    private String productCode;
+    private String workOrder;
 
     private Integer stationNum;
+
+    @ApiModelProperty(value = "工位工序状态")
+    private Integer processStatus;
+
+    @ApiModelProperty(value = "工序信息")
+    private ZyPlanProcess planProcessInfo;
 }
diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/entity/ZySpeechMessage.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/entity/ZySpeechMessage.java
index 1ac07612..8423d214 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/entity/ZySpeechMessage.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/entity/ZySpeechMessage.java
@@ -30,6 +30,9 @@ import java.util.Date;
 public class ZySpeechMessage implements Serializable {
     private static final long serialVersionUID = 1L;
 
+    public static final int XIAOSHOU = 1;
+    public static final int SHENGCHAN = 2;
+
     /**
      * 主键
      */
@@ -89,4 +92,9 @@ public class ZySpeechMessage implements Serializable {
     @Excel(name = "消息", width = 15)
     @ApiModelProperty(value = "消息")
     private String message;
+
+    @Excel(name = "消息类型", width = 15)
+    @ApiModelProperty(value = "消息类型")
+//    1：销售类(订单) 2：生产(生产计划/工单)',
+    private Integer messageType;
 }
diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/productplan/controller/ZyProductPlanController.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/productplan/controller/ZyProductPlanController.java
index 2bbd6b06..94b3e99e 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/productplan/controller/ZyProductPlanController.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/productplan/controller/ZyProductPlanController.java
@@ -101,6 +101,8 @@ public class ZyProductPlanController extends JeecgController<ZyProductPlan, IZyP
         String productCode = zyProductPlan.getProductCode();
         String code = productCode.substring(productCode.length() - 6);
         String mess = "工单尾号" + code + ",生产计划已完成制定,请跟进后续生产作业.";
+        //生产类型的消息，保存工单id,播报工单id
+        zySpeechMessage.setMessageType(ZySpeechMessage.SHENGCHAN);
         zySpeechMessage.setMessage(mess);
         zySpeechMessage.setWorkorderId(productCode);
         iZySpeechMessageService.save(zySpeechMessage);