meidu2021/daju/target/classes/cn/com/lzt/sysmsg/service/impl/SysMsgServiceImpl.java

package cn.com.lzt.sysmsg.service.impl;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import javax.validation.Validator;

import cn.com.lzt.sysmsgdetail.service.SysMsgDetailServiceI;
import org.apache.log4j.Logger;
import org.jeecgframework.core.common.exception.BusinessException;
import org.jeecgframework.core.common.model.json.AjaxJson;
import org.jeecgframework.core.common.service.impl.CommonServiceImpl;
import org.jeecgframework.core.constant.Globals;
import org.jeecgframework.core.util.ApplicationContextUtil;
import org.jeecgframework.core.util.JeecgDataAutorUtils;
import org.jeecgframework.core.util.MyBeanUtils;
import org.jeecgframework.core.util.MyClassLoader;
import org.jeecgframework.core.util.ResourceUtil;
import org.jeecgframework.core.util.StringUtil;
import org.jeecgframework.minidao.pojo.MiniDaoPage;
import org.jeecgframework.web.cgform.enhance.CgformEnhanceJavaInter;
import org.jeecgframework.web.system.pojo.base.TSUser;
import org.jeecgframework.web.system.service.SystemService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import cn.com.lzt.arrangedutyoperate.dto.UserAndUserPersonnelDto;
import cn.com.lzt.arrangedutyoperate.service.ArrangeDutyOperateServiceI;
import cn.com.lzt.common.push.JPushProcessor;
import cn.com.lzt.common.push.PushMsgContentProcess;
import cn.com.lzt.common.push.PushReq;
import cn.com.lzt.dialogDeal.service.UserDepartOrgDealServiceI;
import cn.com.lzt.projarrangedetail.projectarrangecommonmethod.ProjectArrangeCommonMethod;
import cn.com.lzt.sysmsg.controller.SysMsgController;
import cn.com.lzt.sysmsg.dao.SysMsgMinidao;
import cn.com.lzt.sysmsg.dto.SysMsgDto;
import cn.com.lzt.sysmsg.entity.SysMsgEntity;
import cn.com.lzt.sysmsg.service.SysMsgServiceI;
import cn.com.lzt.sysmsgdetail.entity.SysMsgDetailEntity;

@Service("sysMsgService")
@Transactional
public class SysMsgServiceImpl extends CommonServiceImpl implements SysMsgServiceI {

	/**
	 * Logger for this class
	 */
	private static final Logger logger = Logger.getLogger(SysMsgController.class);
	@Autowired
	private SystemService systemService;
	@Autowired
	private Validator validator;
	
	@Autowired
	ArrangeDutyOperateServiceI arrangeDutyOperateServiceI;
	
	@Autowired
	UserDepartOrgDealServiceI userDepartOrgDealServiceI;
	
	@Autowired
	SysMsgMinidao sysMsgMinidao;
	
	@Autowired
	private JPushProcessor pushProcessor;

	@Autowired
	private SysMsgDetailServiceI sysMsgDetailService;

	/**
	 * 添加系统消息
	 * @author 刘梦祥
	 * @date 2022年8月5日14:40:36
	 * @param msgTitle 标题
	 * @param msgContent 内容
	 * @param sendId 发送人userid
	 * @param receivedId 接收人userid
	 */
	public void saveSysMsg(String msgTitle,String msgContent,String sendId,String receivedId) throws Exception {
		SysMsgEntity sysMsg = new SysMsgEntity();
		String msgId = UUID.randomUUID().toString().replaceAll("-", "");
		sysMsg.setId(msgId);
		sysMsg.setMsgTitle(msgTitle);
		sysMsg.setMsgContent(msgContent);
		sysMsg.setSendId(sendId);
		sysMsg.setSendStatus("1");
		sysMsg.setCreateDate(new Date());
		sysMsg.setSendTime(new Date());
		sysMsg.setIsPushapp("0");
		sysMsg.setReceivedRange("1");
		sysMsg.setBusid("1");
		sysMsg.setMsgType("1");
		save(sysMsg);

		SysMsgDetailEntity sysMsgDetail = new SysMsgDetailEntity();
		sysMsgDetail.setId(UUID.randomUUID().toString().replaceAll("-", ""));
		sysMsgDetail.setMsgId(sysMsg.getId());
		sysMsgDetail.setReceivedId(receivedId);
		sysMsgDetail.setReadStatus("0");
		sysMsgDetail.setCreateDate(new Date());
		sysMsgDetailService.save(sysMsgDetail);
	}

	/**
	 * 根据接收人科室添加系统消息
	 * @author 刘梦祥
	 * @date 2022年8月5日14:40:36
	 * @param msgTitle 标题
	 * @param msgContent 内容
	 * @param sendId 发送人userid
	 * @param receivedId 接收人userid
	 */
	public void saveSysMsgToDepart(String msgTitle,String msgContent,String sendId,String receivedId) throws Exception {
		SysMsgEntity sysMsg = new SysMsgEntity();
		String msgId = UUID.randomUUID().toString().replaceAll("-", "");
		sysMsg.setId(msgId);
		sysMsg.setMsgTitle(msgTitle);
		sysMsg.setMsgContent(msgContent);
		sysMsg.setSendId(sendId);
		sysMsg.setSendStatus("1");
		sysMsg.setCreateDate(new Date());
		sysMsg.setSendTime(new Date());
		sysMsg.setIsPushapp("0");
		sysMsg.setReceivedRange("1");
		sysMsg.setBusid("1");
		sysMsg.setMsgType("1");
		save(sysMsg);

		SysMsgDetailEntity sysMsgDetail = new SysMsgDetailEntity();
		sysMsgDetail.setId(UUID.randomUUID().toString().replaceAll("-", ""));
		sysMsgDetail.setMsgId(sysMsg.getId());
		// 根据接收人userid得到科室信息(发送消息给对应科室科长)
		String querySql = "SELECT\n" +
				"\ttsuo.org_id orgId\n" +
				"FROM\n" +
				"\tt_s_user tsu\n" +
				"LEFT JOIN t_s_user_org tsuo ON tsuo.user_id = tsu.id\n" +
				"LEFT JOIN t_bus_user_personnel tbup ON tbup.userid = tsu.id\n" +
				"LEFT JOIN t_s_depart tsd ON tsd.id = tsuo.org_id\n" +
				"LEFT JOIN t_bus_post tbp ON tbp.id = tbup.in_postid where tsu.id = '"+receivedId+"';";
		Map<String,Object> departMap = this.systemService.findOneForJdbc(querySql);
		if(departMap != null && departMap.containsKey("orgId")){
			String departStr = "{\"departId\":\""+departMap.get("orgId").toString()+"\",\"inPostid\":\"ff8080817b760b5d017b8057b15901c6\"}";
			sysMsgDetail.setReceivedId(departStr);
		}
		sysMsgDetail.setReadStatus("0");
		sysMsgDetail.setCreateDate(new Date());
		sysMsgDetailService.save(sysMsgDetail);
	}
	
	
 	public void delete(SysMsgEntity entity) throws Exception{
 		super.delete(entity);
 		//执行删除操作增强业务
		this.doDelBus(entity);
 	}
 	
 	public Serializable save(SysMsgEntity entity) throws Exception{
 		Serializable t = super.save(entity);
 		//执行新增操作增强业务
 		this.doAddBus(entity);
 		return t;
 	}
 	
 	public void saveOrUpdate(SysMsgEntity entity) throws Exception{
 		super.saveOrUpdate(entity);
 		//执行更新操作增强业务
 		this.doUpdateBus(entity);
 	}
 	
 	/**
	 * 新增操作增强业务
	 * @param t
	 * @return
	 */
	private void doAddBus(SysMsgEntity t) throws Exception{
		//-----------------sql增强 start----------------------------
	 	//-----------------sql增强 end------------------------------
	 	
	 	//-----------------java增强 start---------------------------
	 	//-----------------java增强 end-----------------------------
 	}
 	/**
	 * 更新操作增强业务
	 * @param t
	 * @return
	 */
	private void doUpdateBus(SysMsgEntity t) throws Exception{
		//-----------------sql增强 start----------------------------
	 	//-----------------sql增强 end------------------------------
	 	
	 	//-----------------java增强 start---------------------------
	 	//-----------------java增强 end-----------------------------
 	}
 	/**
	 * 删除操作增强业务
	 * @return
	 */
	private void doDelBus(SysMsgEntity t) throws Exception{
	    //-----------------sql增强 start----------------------------
	 	//-----------------sql增强 end------------------------------
	 	
	 	//-----------------java增强 start---------------------------
	 	//-----------------java增强 end-----------------------------
 	}
 	
 	private Map<String,Object> populationMap(SysMsgEntity t){
		Map<String,Object> map = new HashMap<String,Object>();
		map.put("id", t.getId());
		map.put("msg_type", t.getMsgType());
		map.put("msg_title", t.getMsgTitle());
		map.put("msg_content", t.getMsgContent());
		map.put("send_id", t.getSendId());
		map.put("send_status", t.getSendStatus());
		map.put("create_date", t.getCreateDate());
		map.put("send_time", t.getSendTime());
		map.put("is_pushapp", t.getIsPushapp());
		map.put("received_range", t.getReceivedRange());
		map.put("busid", t.getBusid());
		return map;
	}
 	
 	/**
	 * 替换sql中的变量
	 * @param sql
	 * @param t
	 * @return
	 */
 	public String replaceVal(String sql,SysMsgEntity t){
 		sql  = sql.replace("#{id}",String.valueOf(t.getId()));
 		sql  = sql.replace("#{msg_type}",String.valueOf(t.getMsgType()));
 		sql  = sql.replace("#{msg_title}",String.valueOf(t.getMsgTitle()));
 		sql  = sql.replace("#{msg_content}",String.valueOf(t.getMsgContent()));
 		sql  = sql.replace("#{send_id}",String.valueOf(t.getSendId()));
 		sql  = sql.replace("#{send_status}",String.valueOf(t.getSendStatus()));
 		sql  = sql.replace("#{create_date}",String.valueOf(t.getCreateDate()));
 		sql  = sql.replace("#{send_time}",String.valueOf(t.getSendTime()));
 		sql  = sql.replace("#{is_pushapp}",String.valueOf(t.getIsPushapp()));
 		sql  = sql.replace("#{received_range}",String.valueOf(t.getReceivedRange()));
 		sql  = sql.replace("#{busid}",String.valueOf(t.getBusid()));
 		sql  = sql.replace("#{UUID}",UUID.randomUUID().toString());
 		return sql;
 	}
 	
 	/**
	 * 执行JAVA增强
	 */
 	private void executeJavaExtend(String cgJavaType,String cgJavaValue,Map<String,Object> data) throws Exception {
 		if(StringUtil.isNotEmpty(cgJavaValue)){
			Object obj = null;
			try {
				if("class".equals(cgJavaType)){
					//因新增时已经校验了实例化是否可以成功，所以这块就不需要再做一次判断
					obj = MyClassLoader.getClassByScn(cgJavaValue).newInstance();
				}else if("spring".equals(cgJavaType)){
					obj = ApplicationContextUtil.getContext().getBean(cgJavaValue);
				}
				if(obj instanceof CgformEnhanceJavaInter){
					CgformEnhanceJavaInter javaInter = (CgformEnhanceJavaInter) obj;
					javaInter.execute("t_bus_sys_msg",data);
				}
			} catch (Exception e) {
				e.printStackTrace();
				throw new Exception("执行JAVA增强出现异常！");
			} 
		}
 	}

 	@Override
	public AjaxJson saveSysMsg(SysMsgEntity sysMsg) throws Exception {
		
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "";
		if (StringUtil.isNotEmpty(sysMsg.getId())) {
			SysMsgEntity t =  get(SysMsgEntity.class, sysMsg.getId());
			if(t!=null){
				try {
					MyBeanUtils.copyBeanNotNull2Bean(sysMsg, t);
					saveOrUpdate(t);
					
					List<SysMsgDetailEntity> sysMsgDetailEntityList =findByProperty(SysMsgDetailEntity.class,"msgId",t.getId());
					String sysMsgDetailIds="";
					Date date=sysMsgDetailEntityList.get(0).getCreateDate();
					for (int i = 0; i < sysMsgDetailEntityList.size(); i++) {
						if(sysMsgDetailIds.length()!=0){
							sysMsgDetailIds+=","+sysMsgDetailEntityList.get(i).getId();
						}else{
							sysMsgDetailIds=sysMsgDetailEntityList.get(i).getId();
						}
					}
					//批量删除系统消息详细
					doBatchDelSysMsgDetail(sysMsgDetailIds);
					
					//批量保存系统消息详细表数据
					sysMsgDetailEntityList=new ArrayList<SysMsgDetailEntity>();
					if(sysMsg.getReceivedRange().equals(Globals.received_range_0)){
						UserAndUserPersonnelDto userAndUserPersonnelDto=new UserAndUserPersonnelDto();
						String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString();
						List<UserAndUserPersonnelDto> personnelAndUserList=arrangeDutyOperateServiceI.getPersonnelAndUser(userAndUserPersonnelDto, authSql);
						for (int i = 0; i < personnelAndUserList.size(); i++) {
							SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
							sysMsgDetail.setMsgId(sysMsg.getId());
							sysMsgDetail.setReadStatus(Globals.read_status_0);
							sysMsgDetail.setReceivedId(personnelAndUserList.get(i).getUserid());
							sysMsgDetail.setCreateDate(date);
							sysMsgDetailEntityList.add(sysMsgDetail);
						}
						//批量保存
						batchSave(sysMsgDetailEntityList);
					}else if(sysMsg.getReceivedRange().equals(Globals.received_range_1)){
						List<String> orgIdList=ProjectArrangeCommonMethod.extractIdListByComma(sysMsg.getBusid());
						for (int i = 0; i < orgIdList.size(); i++) {
							//根据项目pid获取所有的userid；--
							//根据项目id查询所有子节点id
							List<String> userIdList=getUserIdListByOrgId(orgIdList.get(i));
							for (int k = 0; k < userIdList.size(); k++) {
								SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
								sysMsgDetail.setMsgId(sysMsg.getId());
								sysMsgDetail.setReadStatus(Globals.read_status_0);
								sysMsgDetail.setReceivedId(userIdList.get(k));
								sysMsgDetail.setCreateDate(date);
								sysMsgDetailEntityList.add(sysMsgDetail);
							}
							//批量保存
							batchSave(sysMsgDetailEntityList);
						}
					}else if(sysMsg.getReceivedRange().equals(Globals.received_range_2)){
						List<String> userIdList=ProjectArrangeCommonMethod.extractIdListByComma(sysMsg.getBusid());
						for (int i = 0; i < userIdList.size(); i++) {
							SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
							sysMsgDetail.setMsgId(sysMsg.getId());
							sysMsgDetail.setReadStatus(Globals.read_status_0);
							sysMsgDetail.setReceivedId(userIdList.get(i));
							sysMsgDetail.setCreateDate(date);
							sysMsgDetailEntityList.add(sysMsgDetail);
						}
						//批量保存
						batchSave(sysMsgDetailEntityList);
					}
					
					
					
					systemService.addLog(message, Globals.Log_Type_UPDATE, Globals.Log_Leavel_INFO);
					message = "系统消息更新成功";
				} catch (Exception e) {
					e.printStackTrace();
					message = "系统消息更新失败";
					j.setSuccess(false);
				}
			}else{
				try{
					sysMsg.setSendStatus(Globals.send_status_0);
					sysMsg.setMsgType(Globals.msg_type_0);
					sysMsg.setIsPushapp(Globals.is_pushapp_0);
					save(sysMsg);
					
					//保存系统消息详细表数据
					List<SysMsgDetailEntity> sysMsgDetailEntityList=new ArrayList<SysMsgDetailEntity>();
					
					if(sysMsg.getReceivedRange().equals(Globals.received_range_0)){
						UserAndUserPersonnelDto userAndUserPersonnelDto=new UserAndUserPersonnelDto();
						String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString();
						List<UserAndUserPersonnelDto> personnelAndUserList=arrangeDutyOperateServiceI.getPersonnelAndUser(userAndUserPersonnelDto, authSql);
						for (int i = 0; i < personnelAndUserList.size(); i++) {
							SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
							sysMsgDetail.setMsgId(sysMsg.getId());
							sysMsgDetail.setReadStatus(Globals.read_status_0);
							sysMsgDetail.setReceivedId(personnelAndUserList.get(i).getUserid());
							sysMsgDetailEntityList.add(sysMsgDetail);
						}
						//批量保存
						batchSave(sysMsgDetailEntityList);
					}else if(sysMsg.getReceivedRange().equals(Globals.received_range_1)){
						List<String> orgIdList=ProjectArrangeCommonMethod.extractIdListByComma(sysMsg.getBusid());
						for (int i = 0; i < orgIdList.size(); i++) {
							//根据项目pid获取所有的userid；--
							//根据项目id查询所有子节点id
							List<String> userIdList=getUserIdListByOrgId(orgIdList.get(i));
							for (int k = 0; k < userIdList.size(); k++) {
								SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
								sysMsgDetail.setMsgId(sysMsg.getId());
								sysMsgDetail.setReadStatus(Globals.read_status_0);
								sysMsgDetail.setReceivedId(userIdList.get(k));
								sysMsgDetailEntityList.add(sysMsgDetail);
							}
							//批量保存
							batchSave(sysMsgDetailEntityList);
						}
					}else if(sysMsg.getReceivedRange().equals(Globals.received_range_2)){
						List<String> userIdList=ProjectArrangeCommonMethod.extractIdListByComma(sysMsg.getBusid());
						for (int i = 0; i < userIdList.size(); i++) {
							SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
							sysMsgDetail.setMsgId(sysMsg.getId());
							sysMsgDetail.setReadStatus(Globals.read_status_0);
							sysMsgDetail.setReceivedId(userIdList.get(i));
							sysMsgDetailEntityList.add(sysMsgDetail);
						}
						//批量保存
						batchSave(sysMsgDetailEntityList);
					}
					
					
					systemService.addLog(message, Globals.Log_Type_INSERT, Globals.Log_Leavel_INFO);
					message = "系统消息添加成功";
				}catch(Exception e){
					e.printStackTrace();
					message = "系统消息添加失败";
					j.setSuccess(false);
				}
			}
		} else {
			try{
				sysMsg.setMsgType(Globals.msg_type_0);
				sysMsg.setSendStatus(Globals.send_status_0);
				sysMsg.setIsPushapp(Globals.is_pushapp_0);
				save(sysMsg);
				
				//保存系统消息详细表数据
				List<SysMsgDetailEntity> sysMsgDetailEntityList=new ArrayList<SysMsgDetailEntity>();
				
				
				if(sysMsg.getReceivedRange().equals(Globals.received_range_0)){
					UserAndUserPersonnelDto userAndUserPersonnelDto=new UserAndUserPersonnelDto();
					String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString();
					List<UserAndUserPersonnelDto> personnelAndUserList=arrangeDutyOperateServiceI.getPersonnelAndUser(userAndUserPersonnelDto, authSql);
					for (int i = 0; i < personnelAndUserList.size(); i++) {
						SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
						sysMsgDetail.setMsgId(sysMsg.getId());
						sysMsgDetail.setReadStatus(Globals.read_status_0);
						sysMsgDetail.setReceivedId(personnelAndUserList.get(i).getUserid());
						sysMsgDetailEntityList.add(sysMsgDetail);
					}
					//批量保存
					batchSave(sysMsgDetailEntityList);
				}else if(sysMsg.getReceivedRange().equals(Globals.received_range_1)){
					List<String> orgIdList=ProjectArrangeCommonMethod.extractIdListByComma(sysMsg.getBusid());
					for (int i = 0; i < orgIdList.size(); i++) {
						//根据项目pid获取所有的userid；--
						//根据项目id查询所有子节点id
						List<String> userIdList=getUserIdListByOrgId(orgIdList.get(i));
						for (int k = 0; k < userIdList.size(); k++) {
							SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
							sysMsgDetail.setMsgId(sysMsg.getId());
							sysMsgDetail.setReadStatus(Globals.read_status_0);
							sysMsgDetail.setReceivedId(userIdList.get(k));
							sysMsgDetailEntityList.add(sysMsgDetail);
						}
						//批量保存
						batchSave(sysMsgDetailEntityList);
					}
				}else if(sysMsg.getReceivedRange().equals(Globals.received_range_2)){
					List<String> userIdList=ProjectArrangeCommonMethod.extractIdListByComma(sysMsg.getBusid());
					for (int i = 0; i < userIdList.size(); i++) {
						SysMsgDetailEntity sysMsgDetail=new SysMsgDetailEntity();
						sysMsgDetail.setMsgId(sysMsg.getId());
						sysMsgDetail.setReadStatus(Globals.read_status_0);
						sysMsgDetail.setReceivedId(userIdList.get(i));
						sysMsgDetailEntityList.add(sysMsgDetail);
					}
					//批量保存
					batchSave(sysMsgDetailEntityList);
				}
				
				
				systemService.addLog(message, Globals.Log_Type_INSERT, Globals.Log_Leavel_INFO);
				message = "系统消息添加成功";
			}catch(Exception e){
				e.printStackTrace();
				message = "系统消息添加失败";
				j.setSuccess(false);
			}
		}
		j.setMsg(message);
		return j;
	}

	@Override
	public AjaxJson saveSysMsgDetail(SysMsgDetailEntity sysMsgDetail)
			throws Exception {
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "";
		if (StringUtil.isNotEmpty(sysMsgDetail.getId())) {
			SysMsgDetailEntity t =  get(SysMsgDetailEntity.class, sysMsgDetail.getId());
			if(t!=null){
				try {
					MyBeanUtils.copyBeanNotNull2Bean(sysMsgDetail, t);
					saveOrUpdate(t);
					systemService.addLog(message, Globals.Log_Type_UPDATE, Globals.Log_Leavel_INFO);
					message = "系统消息详细更新成功";
				} catch (Exception e) {
					e.printStackTrace();
					message = "系统消息详细更新失败";
					j.setSuccess(false);
				}
			}else{
				try{
					 save(sysMsgDetail);
					systemService.addLog(message, Globals.Log_Type_INSERT, Globals.Log_Leavel_INFO);
					message = "系统消息详细添加成功";
				}catch(Exception e){
					e.printStackTrace();
					message = "系统消息详细添加失败";
					j.setSuccess(false);
				}
			}
		} else {
			try{
				 save(sysMsgDetail);
				systemService.addLog(message, Globals.Log_Type_INSERT, Globals.Log_Leavel_INFO);
				message = "系统消息详细添加成功";
			}catch(Exception e){
				e.printStackTrace();
				message = "系统消息详细添加失败";
				throw new BusinessException(e.getMessage());
			}
		}
		j.setMsg(message);
		return j;
	}
	
	@Override
	public List<String> getUserIdListByOrgId(String orgId){
		//根据项目pid获取所有的userid；--
		//根据项目id查询所有子节点id
		List<String> ChildIdList=userDepartOrgDealServiceI.getChildIdByProjectDepartId(orgId);
		UserAndUserPersonnelDto userAndUserPersonnelDto=new UserAndUserPersonnelDto();
		userAndUserPersonnelDto.setChildDepartIdList(ChildIdList);
		String authSql = JeecgDataAutorUtils.loadDataSearchConditonSQLString();
		List<UserAndUserPersonnelDto> listUserAndUserPersonnelDto = arrangeDutyOperateServiceI.getUserAndUserPersonnelNoPage(userAndUserPersonnelDto,authSql);
		List<String> userIdList=new ArrayList<String>();
		for (int i = 0; i < listUserAndUserPersonnelDto.size(); i++) {
			userIdList.add(listUserAndUserPersonnelDto.get(i).getUserid());
		}
		//根据项目pid获取所有的userid；--
		
		return userIdList;
	}

	@Override
	public AjaxJson doBatchDelSysMsg(String ids) throws Exception {
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "系统消息删除成功";
		try{
			for(String id:ids.split(",")){
				SysMsgEntity sysMsg = systemService.getEntity(SysMsgEntity.class, id);
				
				List<SysMsgDetailEntity> sysMsgDetailEntityList =findByProperty(SysMsgDetailEntity.class,"msgId",id);
				String sysMsgDetailIds="";
				for (int i = 0; i < sysMsgDetailEntityList.size(); i++) {
					if(sysMsgDetailIds.length()!=0){
						sysMsgDetailIds+=","+sysMsgDetailEntityList.get(i).getId();
					}else{
						sysMsgDetailIds=sysMsgDetailEntityList.get(i).getId();
					}
				}
				//批量删除系统消息详细
				doBatchDelSysMsgDetail(sysMsgDetailIds);
				
				delete(sysMsg);
				systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO);
			}
		}catch(Exception e){
			e.printStackTrace();
			message = "系统消息删除失败";
			throw new BusinessException(e.getMessage());
		}
		j.setMsg(message);
		return j;
	}

	@Override
	public AjaxJson doBatchDelSysMsgDetail(String ids) throws Exception {
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "系统消息详细删除成功";
		try{
			for(String id:ids.split(",")){
				SysMsgDetailEntity sysMsgDetail = systemService.getEntity(SysMsgDetailEntity.class, id);
				delete(sysMsgDetail);
				systemService.addLog(message, Globals.Log_Type_DEL, Globals.Log_Leavel_INFO);
			}
		}catch(Exception e){
			e.printStackTrace();
			message = "系统消息详细删除失败";
			j.setSuccess(false);
		}
		j.setMsg(message);
		return j;
	}

	@Override
	public List<SysMsgDto> getSysMsgDtoExport(SysMsgDto sysMsgDto,
			String authSql) {
		return sysMsgMinidao.getSysMsgDtoExport(sysMsgDto, authSql);
	}

	@Override
	public MiniDaoPage<SysMsgDto> getMyMsgDtoPage(SysMsgDto sysMsgDto,
			int page, int rows, String authSql) {
		// TODO Auto-generated method stub
		return sysMsgMinidao.getMyMsgDtoPage(sysMsgDto, page, rows, authSql);
	}

	@Override
	public AjaxJson doBatchPublishSysMsg(String ids) throws Exception {
		TSUser tSUser=ResourceUtil.getSessionUser();
		String message = null;
		AjaxJson j = new AjaxJson();
		message = "系统消息发布成功";
		
		try {
			for(String id:ids.split(",")){
				SysMsgEntity t = systemService.get(SysMsgEntity.class, id);
				SysMsgEntity sysMsg=t;
				sysMsg.setSendStatus(Globals.send_status_1);
				sysMsg.setSendTime(new Date());
				sysMsg.setSendId(tSUser.getId());
				MyBeanUtils.copyBeanNotNull2Bean(sysMsg, t);
				saveOrUpdate(t);
				systemService.addLog(message, Globals.Log_Type_UPDATE, Globals.Log_Leavel_INFO);
				
				
				StringBuffer hql = new StringBuffer(" FROM SysMsgDetailEntity where msgId=? ");
				List<SysMsgDetailEntity> sysMsgDetailEntityList = this.findHql(hql.toString(),id);
				ArrayList<String> idList = new ArrayList<String>();
				for (int i = 0; i < sysMsgDetailEntityList.size(); i++) {
					idList.add(sysMsgDetailEntityList.get(i).getReceivedId());
				}
				//极光推送
				pushProcessor.pushCommon(idList,Globals.msg_type_0);
				//极光推送
				/*PushReq pushreq = new PushReq();
				Map<String,String> extrasParam = new HashMap<String, String>();
				extrasParam.put("sendReport", "sendReport");
				pushreq.setExtras(extrasParam);
				pushreq.setAlert(PushMsgContentProcess.PUSH_INSPECTION_ATTENDANCE_YW.value());
				ArrayList<String> ls = new ArrayList<String>();
				for (int i = 0; i < sysMsgDetailEntityList.size(); i++) {
					ls.add(sysMsgDetailEntityList.get(i).getReceivedId());
				}
				pushreq.setAudiences(ls);
				pushProcessor.pushMessage(pushreq);*/
				
				
				
				
				/*PushReq pushreq = new PushReq();
				Map<String,String> extrasParam = new HashMap<String, String>();
				extrasParam.put("sendReport", "sendReport");
				pushreq.setExtras(extrasParam);
				pushreq.setAlert(PushMsgContentProcess.PUSH_INSPECTION_ATTENDANCE_YW.value());
				ArrayList<String> ls = new ArrayList<String>();
				ls.add("4028e4a55fdd331a015fdd36ac9e0001");
				pushreq.setAudiences(ls);
				pushProcessor.pushMessage(pushreq);*/
				
				
			}
			
		} catch (Exception e) {
			e.printStackTrace();
			message = "系统消息发布失败";
			j.setSuccess(false);
		}
		j.setMsg(message);
		return j;
	}

	@Override
	public MiniDaoPage<SysMsgDto> getSysMsgDtoPage(SysMsgDto sysMsgDto, int page,
			int rows, String authSql) {
		// TODO Auto-generated method stub
		return sysMsgMinidao.getSysMsgDtoPage(sysMsgDto, page, rows, authSql);
	}
	
	

	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	/*@Override
	public AjaxJson saveSysMsgAndSysMsgDetail(SysMsgEntity sysMsg)
			throws Exception {
		AjaxJson j = new AjaxJson();
		try {
			j=saveSysMsg(sysMsg);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return j;
	}*/
}