| @@ -12,6 +12,8 @@ import org.apache.http.client.CredentialsProvider; | |||||
| import org.apache.http.impl.client.BasicCredentialsProvider; | import org.apache.http.impl.client.BasicCredentialsProvider; | ||||
| import org.apache.http.impl.client.CloseableHttpClient; | import org.apache.http.impl.client.CloseableHttpClient; | ||||
| import org.apache.http.impl.client.HttpClients; | import org.apache.http.impl.client.HttpClients; | ||||
| import org.slf4j.Logger; | |||||
| import org.slf4j.LoggerFactory; | |||||
| import org.springframework.stereotype.Component; | import org.springframework.stereotype.Component; | ||||
| import com.iformall.haikang.netty.NioSocketHandler; | import com.iformall.haikang.netty.NioSocketHandler; | ||||
| @@ -20,6 +22,8 @@ import io.netty.channel.ChannelHandlerContext; | |||||
| @Component | @Component | ||||
| public class HKPeopleNumberFactory { | public class HKPeopleNumberFactory { | ||||
| private final Logger log = LoggerFactory.getLogger(this.getClass()); | |||||
| private Map<String,Integer> peopleCountMap; | private Map<String,Integer> peopleCountMap; | ||||
| public List<NioSocketHandler> handlerList; | public List<NioSocketHandler> handlerList; | ||||
| @@ -52,6 +56,7 @@ public class HKPeopleNumberFactory { | |||||
| if (null != handlerList && handlerList.size() > 0 ) { | if (null != handlerList && handlerList.size() > 0 ) { | ||||
| for (int i = 0 ; i < handlerList.size(); i++) { | for (int i = 0 ; i < handlerList.size(); i++) { | ||||
| NioSocketHandler handler = handlerList.get(i); | NioSocketHandler handler = handlerList.get(i); | ||||
| log.info("sendToDengxiang >>> "+handler.cctx+">>>>"+handler.sourceId+">>>>>>>"+handler.destId); | |||||
| if (null != handler && null != handler.cctx && StringUtils.isNotBlank(handler.sourceId) && StringUtils.isNotBlank(handler.destId)) { | if (null != handler && null != handler.cctx && StringUtils.isNotBlank(handler.sourceId) && StringUtils.isNotBlank(handler.destId)) { | ||||
| handler.sendControlData(handler.cctx, handler.sourceId,handler.destId); | handler.sendControlData(handler.cctx, handler.sourceId,handler.destId); | ||||
| } | } | ||||