|  |  | 
 |  |  | import com.github.yulichang.wrapper.MPJLambdaWrapper; | 
 |  |  | import lombok.extern.slf4j.Slf4j; | 
 |  |  | import org.apache.commons.lang3.StringUtils; | 
 |  |  | import org.apache.http.HttpEntity; | 
 |  |  | import org.apache.http.HttpResponse; | 
 |  |  | import org.apache.http.client.HttpClient; | 
 |  |  | import org.apache.http.client.methods.HttpGet; | 
 |  |  | import org.apache.http.impl.client.HttpClientBuilder; | 
 |  |  | import org.apache.http.util.EntityUtils; | 
 |  |  | import org.checkerframework.checker.units.qual.C; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | import org.springframework.stereotype.Service; | 
 |  |  | 
 |  |  | import org.springframework.util.CollectionUtils; | 
 |  |  |  | 
 |  |  | import javax.servlet.http.HttpServletResponse; | 
 |  |  | import java.io.IOException; | 
 |  |  | import java.util.*; | 
 |  |  | import java.util.stream.Collectors; | 
 |  |  |  | 
 |  |  | 
 |  |  |     private PlatformLogMapper platformLogMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private PlatformWarnEventServiceImpl platformWarnEventService; | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 海康门禁事件推送 | 
 |  |  |      * @param param | 
 |  |  | 
 |  |  |                                     Constants.PlatformJobStatus.IN_WAIT.getKey(), | 
 |  |  |                                     Constants.PlatformJobStatus.CALLED.getKey(), | 
 |  |  |                                     Constants.PlatformJobStatus.WORKING.getKey(), | 
 |  |  |                                     Constants.PlatformJobStatus.DONE.getKey(), | 
 |  |  |                                     Constants.PlatformJobStatus.TRANSFERING.getKey(), | 
 |  |  |                                     Constants.PlatformJobStatus.EXCEPTION.getKey(), | 
 |  |  |                                     Constants.PlatformJobStatus.AUTHED_LEAVE.getKey() | 
 |  |  |                                     Constants.PlatformJobStatus.EXCEPTION.getKey() | 
 |  |  |                             ) | 
 |  |  |                     )==Constants.ZERO){ | 
 |  |  |                         PlatformJob platformJob = platformJobMapper.selectOne(new QueryWrapper<PlatformJob>().lambda() | 
 |  |  | 
 |  |  |             if(StringUtils.isBlank(device.getHkId())){ | 
 |  |  |                 continue; | 
 |  |  |             } | 
 |  |  |             if(Constants.equalsInteger(device.getType(),Constants.ZERO)){ | 
 |  |  |             /*if(Constants.equalsInteger(device.getType(),Constants.ZERO)){ | 
 |  |  |                 //如果是LED | 
 |  |  |                 PlatformBroadcastLog log = dealLedContentBiz(model.getId(),device.getHkNo(),device.getName(),content,speed,1); | 
 |  |  |                 logList.add(log); | 
 |  |  |                 ledList.add(device.getHkId()); | 
 |  |  |             }else  if(Constants.equalsInteger(device.getType(),Constants.TWO)){ | 
 |  |  |             }else  */if(Constants.equalsInteger(device.getType(),Constants.TWO)){ | 
 |  |  |                 //如果是广播点 | 
 |  |  |                 bNames += device.getName()+";"; | 
 |  |  |                 broadcastList.add(device.getHkId()); |