仓储模块三个表格及增删改查、数据推送

wangfei

2024-09-12 3d27b68f16299cb37d5705b3d9b3f5485faf607e

 hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/push.java

@@ -2,6 +2,12 @@


import cn.hutool.json.JSONObject;



import com.mes.rawglassdetails.entity.RawGlassStorageDetails;

import com.mes.rawglassdetails.service.RawGlassStorageDetailsService;

import com.mes.rawglassstation.entity.RawGlassStorageStation;

import com.mes.rawglassstation.service.RawGlassStorageStationService;

import com.mes.rawglasstask.entity.RawGlassStorageTask;

import com.mes.rawglasstask.service.RawGlassStorageTaskService;

import com.mes.shelfrack.entity.request.RawUsageAndShelfRack;

import com.mes.shelfrack.service.ShelfRackService;

import com.mes.storagetask.entity.request.StorageTaskRequest;

@@ -26,20 +32,27 @@
    private StorageTaskService storageTaskService;

    @Autowired

    private ShelfRackService shelfRackService;

    @Autowired

    private RawGlassStorageDetailsService rawGlassStorageDetailsService;

    @Autowired

    private RawGlassStorageStationService rawGlassStorageStationService;

    @Autowired

    private RawGlassStorageTaskService rawGlassStorageTaskService;





    @Scheduled(fixedDelay = 2000)

    public void sendDownWorkstations() {

        log.info("发送任务信息和架子信息");

        JSONObject jsonObject = new JSONObject();



        List<RawUsageAndShelfRack> rack =  shelfRackService.selectshelf_rack();

        List<StorageTaskRequest>  tasks =  storageTaskService.Tasks();

        List<RawGlassStorageDetails> rack =  rawGlassStorageDetailsService.list();

        List<RawGlassStorageStation> state =  rawGlassStorageStationService.list();

        List<RawGlassStorageTask> tasks =  rawGlassStorageTaskService.selectTasks();



        jsonObject.append("rack",rack);

        jsonObject.append("state",state);

        jsonObject.append("tasks",tasks);

        log.info(jsonObject.toString());

        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("storageTask");

        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("rawGlass");

        if (sendwServer != null) {

            for (WebSocketServer webserver : sendwServer) {

                if (webserver != null&&webserver.session.isOpen()) {