|
@@ -88,15 +88,15 @@ public class QueueDealWithAsync {
|
|
|
*/
|
|
|
@Async("taskExecutor")
|
|
|
public void dealWithThree(long nowTime){
|
|
|
- List<Map<String, Object>> listMap = queuingRulesMapper.getAllNotSureEnFactoryList();
|
|
|
- for (Map<String, Object> map : listMap) {
|
|
|
- if((nowTime - ((Date) map.get("insertTime")).getTime()) > 86400000){
|
|
|
- //踢出队列
|
|
|
- qmsQueueListMapper.deleteByPrimaryKey(DataChange.dataToBigDecimal(map.get("listId")));
|
|
|
- //修改信息
|
|
|
- queuingRulesMapper.updateQQRRemoveList(DataChange.dataToBigDecimal(map.get("resultId")));
|
|
|
- }
|
|
|
- }
|
|
|
+ //List<Map<String, Object>> listMap = queuingRulesMapper.getAllNotSureEnFactoryList();
|
|
|
+ //for (Map<String, Object> map : listMap) {
|
|
|
+ // if((nowTime - ((Date) map.get("insertTime")).getTime()) > 86400000){
|
|
|
+ // //踢出队列
|
|
|
+ // qmsQueueListMapper.deleteByPrimaryKey(DataChange.dataToBigDecimal(map.get("listId")));
|
|
|
+ // //修改信息
|
|
|
+ // queuingRulesMapper.updateQQRRemoveList(DataChange.dataToBigDecimal(map.get("resultId")));
|
|
|
+ // }
|
|
|
+ //}
|
|
|
}
|
|
|
|
|
|
|
|
@@ -106,14 +106,14 @@ public class QueueDealWithAsync {
|
|
|
*/
|
|
|
@Async("taskExecutor")
|
|
|
public void dealWithFour(long nowTime){
|
|
|
- List<Map<String, Object>> spellingListMap = queuingRulesMapper.getAllNotSureEnFactorySpellingList();
|
|
|
- for (Map<String, Object> map : spellingListMap) {
|
|
|
- if((nowTime - ((Date) map.get("spellingSureTime")).getTime()) > 86400000){
|
|
|
- //如果大于一天则直接删除队列信息
|
|
|
- qmsQueueSpellingListMapper.deleteByPrimaryKey(DataChange.dataToBigDecimal(map.get("spellingResultId")));
|
|
|
- queuingRulesMapper.updateQQRRemoveList(DataChange.dataToBigDecimal(map.get("resultId")));
|
|
|
- }
|
|
|
- }
|
|
|
+ //List<Map<String, Object>> spellingListMap = queuingRulesMapper.getAllNotSureEnFactorySpellingList();
|
|
|
+ //for (Map<String, Object> map : spellingListMap) {
|
|
|
+ // if((nowTime - ((Date) map.get("spellingSureTime")).getTime()) > 86400000){
|
|
|
+ // //如果大于一天则直接删除队列信息
|
|
|
+ // qmsQueueSpellingListMapper.deleteByPrimaryKey(DataChange.dataToBigDecimal(map.get("spellingResultId")));
|
|
|
+ // queuingRulesMapper.updateQQRRemoveList(DataChange.dataToBigDecimal(map.get("resultId")));
|
|
|
+ // }
|
|
|
+ //}
|
|
|
}
|
|
|
|
|
|
}
|