WAREAMS/warewms-tianao/src/main/java/com/ruoyi/tianao/job/FeedbackJob.java

package com.ruoyi.tianao.job;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import com.ruoyi.base.domain.CarInfo;
import com.ruoyi.base.service.ICarInfoService;
import com.ruoyi.system.init.PublishAGVInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component("feedbackJob")
public class FeedbackJob {

    @Autowired
    ICarInfoService iCarInfoService;

    @Autowired
    PublishAGVInfo publishAGVInfo;

    public void feedbackVehicleStatus(){
        JSONArray objects = new JSONArray();
        for (CarInfo carInfo : iCarInfoService.selectCarInfoList(new CarInfo())) {
            JSONObject jsonObject = new JSONObject();
            jsonObject.set("carNo",carInfo.getUserdefine2());
            jsonObject.set("status",carInfo.getState());
            objects.add(jsonObject);
        }
    }

    public void feedbackForkliftCoordinates(){
        JSONArray objects = new JSONArray();
        for (CarInfo carInfo : iCarInfoService.selectCarInfoList(new CarInfo())) {
            JSONObject jsonObject = new JSONObject();
            jsonObject.set("carNo",carInfo.getUserdefine2());
            jsonObject.set("X",carInfo.getX());
            jsonObject.set("Y",carInfo.getY());
            objects.add(jsonObject);
        }
        publishAGVInfo.publishMessage(objects.toString());
    }
}