| | |
| | | package com.zy.core.thread; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.core.common.Cools; |
| | | import com.core.common.DateUtils; |
| | | import com.core.common.SpringUtils; |
| | | import com.zy.asrs.entity.BasDevp; |
| | | import com.zy.asrs.service.BasDevpService; |
| | | import com.zy.core.Slave; |
| | | import com.zy.core.ThreadHandler; |
| | | import com.zy.core.cache.OutputQueue; |
| | | import lombok.Data; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | |
| | | import java.net.Socket; |
| | | import java.net.SocketAddress; |
| | | import java.net.SocketTimeoutException; |
| | | import java.util.Date; |
| | | |
| | | /** |
| | | * 磅秤线程 |
| | |
| | | if (null != basDevpService && !basDevpService.updateById(basDevp)) { |
| | | throw new Exception("更新数据库数据失败"); |
| | | } |
| | | JSONObject jsonObject = new JSONObject(); |
| | | jsonObject.put("time", DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmss_F)); |
| | | jsonObject.put("id", staNo); |
| | | jsonObject.put("scale", scale); |
| | | if (OutputQueue.SCALE.size() >= 32) { |
| | | OutputQueue.SCALE.poll(); |
| | | } |
| | | OutputQueue.SCALE.offer(jsonObject); |
| | | } |
| | | } |
| | | } |