old mode 100644
new mode 100755
| | |
| | | import com.java110.job.adapt.DatabusAdaptImpl; |
| | | import com.java110.po.fee.PayFeeDetailPo; |
| | | import com.java110.utils.cache.MappingCache; |
| | | import com.java110.utils.constant.WechatConstant; |
| | | import com.java110.utils.util.Assert; |
| | | import com.java110.utils.util.BeanConvertUtil; |
| | | import com.java110.utils.util.DateUtil; |
| | |
| | | if (feeTypeCd.equals("888800010012")) { |
| | | //给处理报修完结单的维修师傅推送消息 |
| | | sendMsg(paramIn, communityDtos.get(0), payFeeDetailPo); |
| | | } else { |
| | | //给员工推送消息 |
| | | publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo); |
| | | } |
| | | //给员工推送消息 |
| | | publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo); |
| | | |
| | | } |
| | | |
| | | /** |
| | |
| | | basePrivilegeDto.setResource("/wechatNotification"); |
| | | basePrivilegeDto.setStoreId(feeDtos.get(0).getIncomeObjId()); |
| | | List<UserDto> userDtos = privilegeInnerServiceSMO.queryPrivilegeUsers(basePrivilegeDto); |
| | | String url = sendMsgUrl + accessToken; |
| | | String sendTemplate = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, WechatConstant.SEND_TEMPLATE_URL); |
| | | if (StringUtil.isEmpty(sendTemplate)) { |
| | | sendTemplate = sendMsgUrl; |
| | | } |
| | | String url = sendTemplate + accessToken; |
| | | for (UserDto userDto : userDtos) { |
| | | //根据 userId 查询到openId |
| | | try { |
| | |
| | | Assert.listOnlyOne(feeDtos, "费用不存在"); |
| | | //获取创建用户,即处理结单的维修维修师傅 |
| | | String userId = feeDtos.get(0).getUserId(); |
| | | String url = sendMsgUrl + accessToken; |
| | | String sendTemplate = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, WechatConstant.SEND_TEMPLATE_URL); |
| | | if (StringUtil.isEmpty(sendTemplate)) { |
| | | sendTemplate = sendMsgUrl; |
| | | } |
| | | String url = sendTemplate + accessToken; |
| | | //根据 userId 查询到openId |
| | | try { |
| | | StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto(); |
| | |
| | | } |
| | | String templateId = smallWechatAttrDtos.get(0).getValue(); |
| | | String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret()); |
| | | if (accessToken == null || accessToken == "") { |
| | | if (StringUtil.isEmpty(accessToken)) { |
| | | logger.info("推送微信模板,获取accessToken失败:{}", accessToken); |
| | | return; |
| | | } |