| | |
|---|
| | | import com.java110.intf.order.IPrivilegeInnerServiceSMO; |
|---|
| | | import com.java110.intf.store.ISmallWeChatInnerServiceSMO; |
|---|
| | | import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO; |
|---|
| | | import com.java110.intf.user.*; |
|---|
| | | import com.java110.intf.user.IOwnerAppUserInnerServiceSMO; |
|---|
| | | import com.java110.intf.user.IOwnerCarInnerServiceSMO; |
|---|
| | | import com.java110.intf.user.IOwnerInnerServiceSMO; |
|---|
| | | import com.java110.intf.user.IOwnerRoomRelInnerServiceSMO; |
|---|
| | | import com.java110.intf.user.IStaffAppAuthInnerServiceSMO; |
|---|
| | | import com.java110.job.adapt.DatabusAdaptImpl; |
|---|
| | | import com.java110.po.fee.PayFeeDetailPo; |
|---|
| | | import com.java110.utils.cache.MappingCache; |
|---|
| | |
|---|
| | | String url = sendMsgUrl + accessToken; |
|---|
| | | for (UserDto userDto : userDtos) { |
|---|
| | | //根据 userId 查询到openId |
|---|
| | | try { |
|---|
| | | StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto(); |
|---|
| | | staffAppAuthDto.setStaffId(userDto.getUserId()); |
|---|
| | | staffAppAuthDto.setAppType("WECHAT"); |
|---|
| | |
|---|
| | | logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage)); |
|---|
| | | ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class); |
|---|
| | | logger.info("微信模板返回内容:{}", responseEntity); |
|---|
| | | } catch (Exception e) { |
|---|
| | | logger.error("发送缴费信息失败", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
