java/zhihuishenqu.git

			@@ -18,6 +18,7 @@
			import com.panzhihua.common.model.dtos.community.sanshuo.IndexDateDTO;
			import com.panzhihua.common.model.vos.LoginUserInfoVO;
			import com.panzhihua.common.model.vos.R;
			import com.panzhihua.common.model.vos.SanShuoMessageVO;
			import com.panzhihua.common.model.vos.community.switchs.CommunitySwitchAllAppletsVO;
			import com.panzhihua.common.model.vos.sanshuo.*;
			import com.panzhihua.common.service.user.UserService;
			@@ -26,14 +27,12 @@
			import com.panzhihua.common.utlis.Snowflake;
			import com.panzhihua.common.utlis.StringUtils;
			import com.panzhihua.service_community.api.ComSanShuoEventTransferRecordController;
			import com.panzhihua.service_community.dao.ComActDAO;
			import com.panzhihua.service_community.dao.ComEventMapper;
			import com.panzhihua.service_community.dao.ComSanshuoExpertDao;
			import com.panzhihua.service_community.dao.ComStreetDAO;
			import com.panzhihua.service_community.dao.*;
			import com.panzhihua.service_community.entity.*;
			import com.panzhihua.service_community.model.dos.ComActDO;
			import com.panzhihua.service_community.model.dos.ComStreetDO;
			import com.panzhihua.service_community.service.*;
			import com.panzhihua.service_community.util.WXMessageUtil;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.lang3.RandomUtils;
			import org.checkerframework.checker.units.qual.A;
			@@ -87,6 +86,8 @@

			@Resource
			private ComSanshuoExpertDao comSanshuoExpertDao;

			private SysUserDao sysUserDao;


			@Override
			@@ -597,6 +598,8 @@
			comEvent.setUpdateBy(comEvent.getRequestUserId());
			comEvent.setUpdateAt(new Date());
			boolean flag = save(comEvent);
			//推送消息到专家微信
			sendMessage(comEvent.getSpecialistId(),comEvent);
			//添加一条对应记录
			comEventMapper.insertEventAndExpertRecord(comEvent.getId(),expert.getId(),0);
			if (!flag) {
			@@ -605,6 +608,23 @@
			//提交不视为一次流转记录，不保存图片
			saveEventImageList(comEvent.getImages(), comEvent.getId(),null,1);
			return R.ok(ReturnMsgConstants.SAVE_SUCCESS);
			}

			public void sendMessage(Long expertId,ComEvent comEvent){
			//获取专家的openId
			ComSanshuoExpert expert = comSanShuoExpertService.getById(expertId);
			SysUser sysUser = sysUserDao.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getAccount, expert.getAccount()).eq(SysUser::getPhone, expert.getPhone()));
			SanShuoMessageVO vo=new SanShuoMessageVO();
			if (isNull(sysUser.getOpenid())){
			log.info("专家未登陆APP，无法推送");
			return;
			}
			vo.setTouser(sysUser.getOpenid());
			vo.setThing1(commediateTypeService.getById(comEvent.getEventCategory()).getName());
			vo.setThing5("您有一个新的调解事件需处理");
			vo.setThing2(comEvent.getRequestUserName());
			vo.setTime3(DateUtil.now());
			WXMessageUtil.sendStatusMessage(vo);
			}

			@Transactional(rollbackFor = Exception.class)
			@@ -682,7 +702,7 @@
			ComActDO comActDO = comActDAO.selectById(expert.getCommunityId());
			comEvent.setCurrentOrgId(comActDO.getStreetId().toString());
			//生成一次流转记录
			comEvent.setCurrentEventProcessResult("专家上报到社区");
			comEvent.setCurrentEventProcessResult("(专家上报到"+comActDO.getName()+")"+comEventConciliationVO.getCurrentEventProcessResult());
			//更改当前处理部门
			comEvent.setCurrentOrgName(comActDO.getName()+"调解站");
			comEventTransferRecord.setFromId(comEvent.getSpecialistId());
			@@ -697,7 +717,8 @@
			comEvent.setSpecialistName("待分配");
			comEvent.setSpecialistId(99999L);
			//生成一次流转记录
			comEvent.setCurrentEventProcessResult("专家上报到行业分中心");
			ComSanshuoIndustryCenter center = comSanShuoIndustryCenterService.getById(comEvent.getSpecialistId());
			comEvent.setCurrentEventProcessResult("(专家上报到"+center.getName()+")"+comEventConciliationVO.getCurrentEventProcessResult());
			comEvent.setCurrentOrgName(expert.getUnit());
			comEventTransferRecord.setFromId(comEvent.getSpecialistId());
			comEventTransferRecord.setToId(expert.getIndustryCenterId());
			@@ -710,7 +731,7 @@
			comEvent.setCurrentOrgId("99999");
			//生成一次流转记录
			comEvent.setReportHall(1);
			comEvent.setCurrentEventProcessResult("行业分中心上报到区三说会堂");
			comEvent.setCurrentEventProcessResult("(行业分中心上报到区三说会堂中心)"+comEventConciliationVO.getCurrentEventProcessResult());
			comEvent.setCurrentOrgName("区三说会堂");
			comEventTransferRecord.setFromId(comEvent.getSpecialistId());
			comEventTransferRecord.setToId(99999L);
			@@ -724,7 +745,7 @@
			ComActDO comActDO = comActDAO.selectOne(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getCommunityId, comEvent.getRequestUserCommunity()).eq(ComActDO::getAppId, "wx0cef797390444b75"));
			comEvent.setCurrentOrgId(comActDO.getStreetId().toString());
			//生成一次流转记录
			comEvent.setCurrentEventProcessResult("社区报到街道");
			comEvent.setCurrentEventProcessResult("(社区上报到"+comStreetDAO.selectById(comActDO.getStreetId()).getName()+")"+comEventConciliationVO.getCurrentEventProcessResult());
			comEvent.setCurrentOrgName(comStreetDAO.selectById(comActDO.getStreetId()).getName()+"调解站");
			comEventTransferRecord.setFromId(comEvent.getRequestUserCommunity());
			comEventTransferRecord.setToId(comActDO.getStreetId());
			@@ -737,7 +758,7 @@
			comEvent.setCurrentOrgId("99999");
			comEvent.setCurrentOrgName("区三说会堂");
			//生成一次流转记录
			comEvent.setCurrentEventProcessResult("街道上报到区三说会堂");
			comEvent.setCurrentEventProcessResult("(街道上报到区三说会堂中心)"+comEventConciliationVO.getCurrentEventProcessResult());
			comEventTransferRecord.setFromId(Long.parseLong(comEvent.getCurrentOrgId()));
			comEventTransferRecord.setReportLevel(1);
			comEvent.setReportLevel(1);

	springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEventTransferRecord.java	1 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComEventServiceImpl.java	39 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

			@@ -106,4 +106,5 @@
			private List<ComEventRequestImageVO> images;
			@ApiModelProperty("上报等级,4专家上报到社区，3专家到行业分中心2社区上报到街道，1街道上报到三说会堂,5行业分中心上报到区三说会堂")
			private Integer reportLevel;
			private String content;
			}