原片仓储数据推送

wuyouming666

2024-07-29 80e156f011776cbf4f9feb85b0b809e160359a4c

原片仓储数据推送

 UI-Project/src/utils/api.js

@@ -1,14 +1,18 @@
// src/services/api.js

import request from 'request';



const BASE_URL = 'glassStorage/api/rawUsage'; // Replace with your actual backend base URL



export const findTasks = (id, newState) => {

// Function to find list of raw usages





export const findTasks = () => {

  const url = `glassStorage/api/storageTask/findTasks`;

  const options = {

    method: 'POST',

    method: 'get',

    url,

    json: true,

    body: { id, enableState: newState }

    
  };



  return new Promise((resolve, reject) => {

@@ -21,3 +25,158 @@
    });

  });

};







export const findList = (params) => {

  const url = `${BASE_URL}/findList`;

  const options = {

    method: 'post',

    url,

    json: true,

    body: params

  };



  return new Promise((resolve, reject) => {

    request(options, (error, response, body) => {

      if (error) {

        reject(new Error(error.message));

      } else {

        resolve(body);

      }

    });

  });

};



// Function to find raw usage by ID

export const findById = (id) => {

  const url = `${BASE_URL}/${id}`;

  const options = {

    method: 'get',

    url,

    json: true

  };



  return new Promise((resolve, reject) => {

    request(options, (error, response, body) => {

      if (error) {

        reject(new Error(error.message));

      } else {

        resolve(body);

      }

    });

  });

};



// Function to insert a new raw usage

export const insertRawUsage = (rawUsage) => {

  const url = `${BASE_URL}`;

  const options = {

    method: 'post',

    url,

    json: true,

    body: rawUsage

  };



  return new Promise((resolve, reject) => {

    request(options, (error, response, body) => {

      if (error) {

        reject(new Error(error.message));

      } else {

        resolve(body);

      }

    });

  });

};



// Function to update an existing raw usage

export const updateRawUsage = (rawUsage) => {

  const url = `${BASE_URL}`;

  const options = {

    method: 'put',

    url,

    json: true,

    body: rawUsage

  };



  return new Promise((resolve, reject) => {

    request(options, (error, response, body) => {

      if (error) {

        reject(new Error(error.message));

      } else {

        resolve(body);

      }

    });

  });

};



// Function to delete a raw usage by ID

export const deleteRawUsage = (id) => {

  const url = `${BASE_URL}/${id}`;

  const options = {

    method: 'delete',

    url,

    json: true

  };



  return new Promise((resolve, reject) => {

    request(options, (error, response, body) => {

      if (error) {

        reject(new Error(error.message));

      } else {

        resolve(body);

      }

    });

  });

};





const API_URL = 'glassStorage/api/shelfRack';  // Adjust this based on your actual API URL



export const shelfRackfindList = (params) => {

  return request.post(`${API_URL}/findList`, params)

    .then(response => response.data)

    .catch(error => {

      throw error;  // Handle errors appropriately in your frontend

    });

};



export const shelfRackfindById = (id) => {

  return request.get(`${API_URL}/${id}`)

    .then(response => response.data)

    .catch(error => {

      throw error;

    });

};



export const insertShelfRack = (shelfRack) => {

  return request.post(`${API_URL}`, shelfRack)

    .then(response => response.data)

    .catch(error => {

      throw error;

    });

};



export const updateShelfRack = (shelfRack) => {

  return request.put(`${API_URL}`, shelfRack)

    .then(response => response.data)

    .catch(error => {

      throw error;

    });

};



export const shelfRackdeleteById = (id) => {

  return request.delete(`${API_URL}/${id}`)

    .then(response => response.data)

    .catch(error => {

      throw error;

    });

};



export const findShelfRack = () => {

  return request.get(`${API_URL}/findshelfrack`)

    .then(response => response.data)

    .catch(error => {

      throw error;

    });

};

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

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



import cn.hutool.json.JSONObject;



import com.mes.shelfrack.service.ShelfRackService;

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.util.ArrayList;

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<Map<String, Object>> rack =  shelfRackService.selectshelf_rack();

        List<Map<String, Object>> 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(jsonObject.toString());

                }

            }

        }

    }





}


 hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downworkstation/controller/DownWorkstationController.java

@@ -77,17 +77,9 @@
        // 调用 DownWorkstationService 中的方法清除指定工位ID的信息
        int workstationId = (int) requestData.get("workstationId");

        int totalWorkstations = downWorkstationService.getTotalQuantity(workstationId);
        int downWorkstations = downWorkstationService.getRacksNumber(workstationId);


        if (downWorkstations == totalWorkstations) {
            downWorkstationService.clearFlowCardId(workstationId);
            return Result.build(200, "清除工位信息成功", 1);
        } else {
            // 如果总数量和落架数量不一致，返回错误响应
            return Result.build(500, "清除工位信息失败", 1);
        }



        // 构建响应数据