|  |  | @ -39,6 +39,7 @@ import com.epmet.commons.tools.utils.SendMqMsgUtils; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.constant.ActMessageConstant; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.dao.ActLivePicDao; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.dao.ActLiveRecDao; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.dto.ActInfoDTO; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.dto.ActLivePicDTO; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.dto.ActLiveRecDTO; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.dto.form.resi.ResiActInsertLiveFormDTO; | 
			
		
	
	
		
			
				
					|  |  | @ -48,6 +49,7 @@ import com.epmet.entity.ActLivePicEntity; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.entity.ActLiveRecEntity; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.feign.EpmetUserOpenFeignClient; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.redis.ActLiveRecRedis; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.service.ActInfoService; | 
			
		
	
		
			
				
					|  |  |  | import com.epmet.service.ActLiveRecService; | 
			
		
	
		
			
				
					|  |  |  | import org.apache.logging.log4j.LogManager; | 
			
		
	
		
			
				
					|  |  |  | import org.apache.logging.log4j.Logger; | 
			
		
	
	
		
			
				
					|  |  | @ -77,6 +79,9 @@ public class ActLiveRecServiceImpl extends BaseServiceImpl<ActLiveRecDao, ActLiv | 
			
		
	
		
			
				
					|  |  |  |     @Autowired | 
			
		
	
		
			
				
					|  |  |  |     private ActLivePicDao actLivePicDao; | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |     @Autowired | 
			
		
	
		
			
				
					|  |  |  |     private ActInfoService actInfoService; | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |     @Value("${openapi.scan.server.url}") | 
			
		
	
		
			
				
					|  |  |  |     private String scanApiUrl; | 
			
		
	
		
			
				
					|  |  |  |     @Value("${openapi.scan.method.textSyncScan}") | 
			
		
	
	
		
			
				
					|  |  | @ -217,8 +222,9 @@ public class ActLiveRecServiceImpl extends BaseServiceImpl<ActLiveRecDao, ActLiv | 
			
		
	
		
			
				
					|  |  |  |     } | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |     private void grantActPoints(ResiActInsertLiveFormDTO formDTO){ | 
			
		
	
		
			
				
					|  |  |  |         //备注
 | 
			
		
	
		
			
				
					|  |  |  |         String remark=String.format(ActMessageConstant.ACT_POINTS_EVENT_VOLUNTEER_LIVE,formDTO.getUserId(),formDTO.getActId()); | 
			
		
	
		
			
				
					|  |  |  |         // 查询 活动信息
 | 
			
		
	
		
			
				
					|  |  |  |         ActInfoDTO actInfoDTO = actInfoService.get(formDTO.getActId()); | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |         MqBaseMsgDTO mqBaseMsgDTO=new MqBaseMsgDTO(); | 
			
		
	
		
			
				
					|  |  |  |         //mq的事件类型
 | 
			
		
	
		
			
				
					|  |  |  |         mqBaseMsgDTO.setEventClass(EventEnum.ACTIVE_INSERT_LIVE.getEventClass()); | 
			
		
	
	
		
			
				
					|  |  | @ -230,7 +236,7 @@ public class ActLiveRecServiceImpl extends BaseServiceImpl<ActLiveRecDao, ActLiv | 
			
		
	
		
			
				
					|  |  |  |         actPointEventMsg.setUserId(formDTO.getUserId()); | 
			
		
	
		
			
				
					|  |  |  |         actPointEventMsg.setActionFlag(MqConstant.PLUS); | 
			
		
	
		
			
				
					|  |  |  |         actPointEventMsg.setIsCommon(false); | 
			
		
	
		
			
				
					|  |  |  |         actPointEventMsg.setRemark(remark); | 
			
		
	
		
			
				
					|  |  |  |         actPointEventMsg.setRemark(actInfoDTO.getTitle()); | 
			
		
	
		
			
				
					|  |  |  |         actPointEventMsg.setSourceId(formDTO.getActId()); | 
			
		
	
		
			
				
					|  |  |  |         actPointEventMsgList.add(actPointEventMsg); | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
	
		
			
				
					|  |  | 
 |