root/wms1.0
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

配置文件更新

Browse Source
This commit is contained in:
ludj
2023-03-17 09:05:42 +08:00
parent f1cc1c832d
commit 48e080d2cb
9 changed files with 43 additions and 169 deletions
Download Patch File Download Diff File Expand all files Collapse all files

98
mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/bigScreen/autoTask/AutoAgvStatus.java
View File

@@ -1,98 +0,0 @@
package org.nl.wms.ext.bigScreen.autoTask;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.nl.modules.wql.core.bean.WQLObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Component;
import java.util.ArrayDeque;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
@Slf4j
@Component
public class AutoAgvStatus {
@Autowired
private MongoTemplate mongoTemplate;
public void run() {
WQLObject agv_status = WQLObject.getWQLObject("DS_AGV_AgvStatus");
WQLObject agv_point = WQLObject.getWQLObject("DS_AGV_PointCoordinateRelate");
for (int i = 1; i <= 7; i++) {
String device_code = String.valueOf(i);
Query query = new Query();
query.addCriteria(Criteria.where("device_code").is(device_code));
List<JSONObject> avg_all = mongoTemplate.find(query, JSONObject.class, "agv_test");
JSONObject jsonAgv = agv_status.query("agv_code = '" + device_code + "'").uniqueResult(0);
String real_x_coor = "";
String real_y_coor = "";
for (JSONObject json : avg_all) {
String key = json.getString("key");
switch (key) {
case "pic_name" :
jsonAgv.put("pic_name",json.getString("value"));
break;
case "agv_power" :
jsonAgv.put("agv_power",json.getString("value"));
break;
case "agv_stateType" :
jsonAgv.put("agv_statetype",json.getString("value"));
break;
case "x_coordinate" :
String value = NumberUtil.div(json.getString("value"), "100").toString();
real_x_coor = NumberUtil.round(value, 0).toString();
break;
case "y_coordinate" :
String value2 = NumberUtil.div(json.getString("value"), "100").toString();
real_y_coor = NumberUtil.round(value2, 0).toString();
break;
case "error_status" :
jsonAgv.put("error_status",json.getString("value"));
break;
case "error_info" :
jsonAgv.put("error_info",json.getString("value"));
break;
case "direction_type" :
jsonAgv.put("direction_type",json.getString("value"));
break;
}
}
JSONObject jsonPoint = agv_point.query("real_x_coor = '" + real_x_coor + "' and real_y_coor = '" + real_y_coor + "'").uniqueResult(0);
if (ObjectUtil.isNotEmpty(jsonPoint)) {
jsonAgv.put("x_coordinate", jsonPoint.getString("web_x_coor"));
jsonAgv.put("y_coordinate", jsonPoint.getString("web_y_coor"));
}
jsonAgv.put("update_datetime", DateUtil.now());
agv_status.update(jsonAgv);
}
}
public static void main(String[] args) {
ArrayList<Integer> objects = new ArrayList<>();
objects.add(null);
LinkedList<Object> objects1 = new LinkedList<>();
objects1.add(4);
objects1.add(4.4);
objects1.add(null);
ArrayDeque<Object> objects2 = new ArrayDeque<>();
System.out.println(objects1);
}
}

9
mes/hd/nladmin-system/src/main/java/org/nl/wms/ext/bigScreen/service/impl/AgvBigScreenServiceImpl.java
View File

@@ -5,20 +5,13 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;
import lombok.RequiredArgsConstructor;
import org.nl.common.anno.Log;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.nl.modules.wql.WQL;
import org.nl.modules.wql.core.bean.WQLObject;
import org.nl.wms.ext.bigScreen.service.AgvBigScreenService;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
@Service