| | |
| | | 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; |
| | |
| | | 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; |
| | |
| | | |
| | | @Resource |
| | | private ComSanshuoExpertDao comSanshuoExpertDao; |
| | | |
| | | private SysUserDao sysUserDao; |
| | | |
| | | |
| | | @Override |
| | |
| | | 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) { |
| | |
| | | //提交不视为一次流转记录,不保存图片 |
| | | 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) |
| | |
| | | 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()); |
| | |
| | | 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()); |
| | |
| | | comEvent.setCurrentOrgId("99999"); |
| | | //生成一次流转记录 |
| | | comEvent.setReportHall(1); |
| | | comEvent.setCurrentEventProcessResult("行业分中心上报到区三说会堂"); |
| | | comEvent.setCurrentEventProcessResult("(行业分中心上报到区三说会堂中心)"+comEventConciliationVO.getCurrentEventProcessResult()); |
| | | comEvent.setCurrentOrgName("区三说会堂"); |
| | | comEventTransferRecord.setFromId(comEvent.getSpecialistId()); |
| | | comEventTransferRecord.setToId(99999L); |
| | |
| | | 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()); |
| | |
| | | comEvent.setCurrentOrgId("99999"); |
| | | comEvent.setCurrentOrgName("区三说会堂"); |
| | | //生成一次流转记录 |
| | | comEvent.setCurrentEventProcessResult("街道上报到区三说会堂"); |
| | | comEvent.setCurrentEventProcessResult("(街道上报到区三说会堂中心)"+comEventConciliationVO.getCurrentEventProcessResult()); |
| | | comEventTransferRecord.setFromId(Long.parseLong(comEvent.getCurrentOrgId())); |
| | | comEventTransferRecord.setReportLevel(1); |
| | | comEvent.setReportLevel(1); |