|
@@ -12,12 +12,14 @@ import com.steerinfo.dil.model.QmsQueueList;
|
|
|
import com.steerinfo.dil.mapper.QmsQueueListMapper;
|
|
|
import com.steerinfo.dil.service.IQmsQueueListService;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.scheduling.annotation.Scheduled;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.*;
|
|
|
import java.math.BigDecimal;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* QmsQueueList服务实现:
|
|
@@ -47,13 +49,15 @@ public class QmsQueueListServiceImpl implements IQmsQueueListService {
|
|
|
@Autowired
|
|
|
private QueuingRulesMapper queuingRulesMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ QmsQueueResultServiceImpl qmsQueueResultService;
|
|
|
+
|
|
|
@Autowired
|
|
|
private QmsQueueSpellingListMapper qmsQueueSpellingListMapper;
|
|
|
|
|
|
@Autowired
|
|
|
LargeScreenFeign largeScreenFeign;
|
|
|
|
|
|
-
|
|
|
private final SimpleDateFormat gatepostTimeSdf = new SimpleDateFormat("HHmmss");
|
|
|
|
|
|
/**
|
|
@@ -355,15 +359,6 @@ public class QmsQueueListServiceImpl implements IQmsQueueListService {
|
|
|
qmsQueueSpellingListMapper.updateOOMLoadWarehouse(mesMap);
|
|
|
}
|
|
|
queuingRulesService.pushMesToWebsocket(list);
|
|
|
- //更新大屏(钢材科与东门)
|
|
|
- try{
|
|
|
- //展示钢材科大屏
|
|
|
- largeScreenFeign.showLargeScreenForSteelNew(mapList);
|
|
|
- //展示东门大屏
|
|
|
- largeScreenFeign.showLargeScreenNew(mapList);
|
|
|
- }catch (Exception e){
|
|
|
- System.out.println("大屏调用异常");
|
|
|
- }
|
|
|
return count;
|
|
|
}
|
|
|
|
|
@@ -428,6 +423,35 @@ public class QmsQueueListServiceImpl implements IQmsQueueListService {
|
|
|
return qmsQueueResultMapper.getQueueListByQueueUpSpelling(map);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * @author:zyf
|
|
|
+ * @version:1.0
|
|
|
+ * @Date:
|
|
|
+ * @Description:做一个定时任务向两块大屏赋予值
|
|
|
+ */
|
|
|
+ @Scheduled(cron = "*/30 * * * * ?")
|
|
|
+ public void sendDataToLargeCreen(){
|
|
|
+ Map<String,Object> mapValue=new HashMap<>();
|
|
|
+ List<Map<String, Object>> datalist =new ArrayList<>();
|
|
|
+ List<Map<String, Object>> queueListByQueueUp = qmsQueueResultService.getQueueListByQueueUp(mapValue);
|
|
|
+ List<Map<String, Object>> queueListByQueueUpSpelling = qmsQueueResultService.getQueueListByQueueUpSpelling(mapValue);
|
|
|
+ HashSet<Map<String,Object>> set=new HashSet<>(queueListByQueueUpSpelling);
|
|
|
+ //queueListByQueueUp=queueListByQueueUp.stream().distinct().collect(Collectors.toList());
|
|
|
+ datalist.addAll(queueListByQueueUp);
|
|
|
+ queueListByQueueUpSpelling=queueListByQueueUpSpelling.stream().distinct().collect(Collectors.toList());
|
|
|
+ datalist.addAll(set);
|
|
|
+ System.out.println(datalist.toString());
|
|
|
+ //更新大屏(钢材科与东门)
|
|
|
+ try{
|
|
|
+ //展示钢材科大屏
|
|
|
+ largeScreenFeign.showLargeScreenForSteelNew1(datalist);
|
|
|
+ //展示东门大屏
|
|
|
+ largeScreenFeign.showLargeScreenNew1(datalist);
|
|
|
+ System.out.println("大屏调用成功");
|
|
|
+ }catch (Exception e){
|
|
|
+ System.out.println("大屏调用异常");
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
// @Override
|
|
|
// public int queueCutInLine(Map<String, Object> map) {
|
|
@@ -527,4 +551,5 @@ public class QmsQueueListServiceImpl implements IQmsQueueListService {
|
|
|
// }
|
|
|
// return listQueueMes;
|
|
|
// }
|
|
|
+
|
|
|
}
|