| | |
| | | import com.zy.system.entity.Config; |
| | | import com.zy.system.service.ConfigService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Async; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.ArrayList; |
| | |
| | | return response; |
| | | } |
| | | |
| | | @Async |
| | | public void reportCrnDb110StatusAsync(Integer crnNo, List<Integer> indices) { |
| | | try { |
| | | if (crnNo == null || indices == null || indices.isEmpty()) { |
| | | return; |
| | | } |
| | | reportCrnDb110Status(crnNo, indices); |
| | | } catch (Exception e) { |
| | | News.error("异步上报堆垛机DB110状态异常,crnNo={},indices={}", crnNo, JSON.toJSONString(indices), e); |
| | | } finally { |
| | | if (crnNo != null) { |
| | | redisUtil.del(RedisKeyType.REPORT_CRN_DB110_STATUS_LIMIT.key + crnNo); |
| | | } |
| | | } |
| | | } |
| | | |
| | | // 上报堆垛机DB110状态数据 |
| | | public void reportCrnDb110Status(Integer crnNo, List<Integer> indices) { |
| | | Object systemConfigMapObj = redisUtil.get(RedisKeyType.SYSTEM_CONFIG_MAP.key); |