Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes

wangfei

2024-08-01 c1cb663f4308ddf02ee6ea435c809c8162585b03

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

New file
@@ -0,0 +1,54 @@
package com.mes.job;



import cn.hutool.json.JSONObject;



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

import com.mes.shelfrack.service.ShelfRackService;

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

import com.mes.storagetask.service.StorageTaskService;

import com.mes.tools.WebSocketServer;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.annotation.Scheduled;

import lombok.extern.slf4j.Slf4j;

import org.springframework.stereotype.Component;



import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.Map;



@Slf4j

@Component

public class push {



    @Autowired

    private StorageTaskService storageTaskService;

    @Autowired

    private ShelfRackService shelfRackService;





    @Scheduled(fixedDelay = 2000)

    public void sendDownWorkstations() {

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

        JSONObject jsonObject = new JSONObject();



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

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



        jsonObject.append("rack",rack);

        jsonObject.append("tasks",tasks);

        log.info(jsonObject.toString());

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

        if (sendwServer != null) {

            for (WebSocketServer webserver : sendwServer) {

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

                    log.info("已发送");

                    webserver.sendMessage(String.valueOf(jsonObject));

                }

            }

        }

    }





}