java/zhihuishenqu.git

			@@ -6,9 +6,11 @@

			import javax.annotation.Resource;

			import com.panzhihua.common.model.vos.community.ComActDpcVO;
			import com.panzhihua.common.model.vos.user.SysTemplateConfigVO;
			import com.panzhihua.common.service.user.UserService;
			import com.panzhihua.service_community.dao.ComActDAO;
			import com.panzhihua.service_community.dao.ComActDpcDAO;
			import com.panzhihua.service_community.model.dos.ComActDO;
			import org.springframework.beans.BeanUtils;
			import org.springframework.stereotype.Service;
			@@ -34,6 +36,8 @@
			import com.panzhihua.service_community.model.dos.ComActMessageDO;
			import com.panzhihua.service_community.service.ComActMessageService;

			import static java.util.Objects.isNull;

			@Service
			public class ComActMessageServiceImpl extends ServiceImpl<ComActMessageDAO, ComActMessageDO>
			implements ComActMessageService {
			@@ -47,6 +51,8 @@
			private ComActDAO comActDAO;
			@Resource
			private UserService userService;
			@Resource
			private ComActDpcDAO comActDpcDAO;

			@Override
			public R addMessage(ComActMessageVO comActMessageVO) {
			@@ -66,6 +72,13 @@
			return R.fail();
			phone = party.getPhone();
			sendtoUserName = party.getName();
			} else if (type == 3) {
			ComActDpcVO dpcVO = comActDpcDAO.detailDpc(comActMessageVO.getSendtoUserId());
			if (isNull(dpcVO)) {
			return R.fail();
			}
			phone = dpcVO.getPhone();
			sendtoUserName = dpcVO.getName();
			}
			if (ObjectUtils.isEmpty(phone))
			return R.fail("未找到联系方式");
			@@ -209,7 +222,7 @@
			ComActDO comActDO=comActDAO.selectById(comActMessageBackVO.getCommunityId());
			R<SysTemplateConfigVO> r=userService.selectTemplate(comActDO.getAreaCode(),2);
			try {
			WxUtil.sendSubscribeLYHF(openid, util.getAppAccessToken(), comActMessageBackVO.getUserName(),
			WxUtil.sendSubscribeLYHF(openid, util.getAccessToken(), comActMessageBackVO.getUserName(),
			DateUtils.format(new Date(), DateUtils.ymdhms_format), comActMessageBackVO.getMsgContent(),r.getData().getTemplateId());
			} catch (Exception e) {
			log.error("消息推送失败，失败原因：" + e.getMessage());