package com.zy.asrs.task;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.zy.asrs.entity.BasCrnp;
|
import com.zy.asrs.entity.BasDevp;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.entity.param.GetShuttleStatusParam;
|
import com.zy.asrs.service.ApiLogService;
|
import com.zy.asrs.service.BasCrnpService;
|
import com.zy.asrs.service.BasDevpService;
|
import com.zy.asrs.service.impl.BasDevpServiceImpl;
|
import com.zy.asrs.task.core.ReturnT;
|
import com.zy.common.utils.HttpHandler;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
@Component
|
public class GetEquipmentStatus {
|
private static final Logger log = LoggerFactory.getLogger(WorkMastScheduler.class);
|
@Value("${wcs.address.URL}")
|
private String addrs;
|
@Value("${wcs.address.deviceStatus}")
|
private String deviceStatus;
|
@Autowired
|
private BasCrnpService basCrnpService;
|
@Autowired
|
private ApiLogService apiLogService;
|
@Autowired
|
private BasDevpService basDevpService;
|
|
@Scheduled(cron = "0/3 * * * * ? ")
|
private void execute() {
|
//获取设备信息
|
String response ="";
|
try {
|
response = new HttpHandler.Builder()
|
// .setHeaders(headParam)
|
.setUri(addrs)
|
.setPath(deviceStatus)
|
.build()
|
.doGet();
|
JSONObject jsonObject = JSON.parseObject(response);
|
if (jsonObject.get("code").equals(200)) {
|
JSONObject data = JSON.parseObject(jsonObject.get("data").toString());
|
List<GetShuttleStatusParam> shuttles = JSON.parseArray(data.get("basShuttle").toString(), GetShuttleStatusParam.class);
|
for (GetShuttleStatusParam shuttle : shuttles) {
|
|
|
BasCrnp shuttle1 = basCrnpService.selectOne(new EntityWrapper<BasCrnp>().eq("crn_no", shuttle.getShuttleNo()));
|
shuttle1.setCrnSts(shuttle.getStatus());//小车模式
|
shuttle1.setCrnErr(Long.valueOf(shuttle.getErrorCode()));//小车报警
|
shuttle1.setLev1(shuttle.getChargeLine());//小车所在层
|
basCrnpService.updateById(shuttle1);
|
}
|
|
List<BasDevp> basDevps = JSON.parseArray(data.get("basDevp").toString(), BasDevp.class);
|
for (BasDevp basDevp : basDevps) {
|
basDevpService.updateById(basDevp);
|
}
|
}
|
} catch (Exception e) {
|
log.error("wms读取wcs小车状态失败");
|
}
|
}
|
}
|
