package com.java110.job.adapt.payment.notice; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.serializer.SerializerFeature; import com.aliyuncs.CommonRequest; import com.aliyuncs.CommonResponse; import com.aliyuncs.DefaultAcsClient; import com.aliyuncs.IAcsClient; import com.aliyuncs.exceptions.ClientException; import com.aliyuncs.exceptions.ServerException; import com.aliyuncs.http.MethodType; import com.aliyuncs.profile.DefaultProfile; import com.java110.core.factory.WechatFactory; import com.java110.core.smo.IComputeFeeSMO; import com.java110.dto.basePrivilege.BasePrivilegeDto; import com.java110.dto.community.CommunityDto; import com.java110.dto.fee.FeeDetailDto; import com.java110.dto.fee.FeeDto; import com.java110.dto.owner.OwnerAppUserDto; import com.java110.dto.owner.OwnerCarDto; import com.java110.dto.owner.OwnerDto; import com.java110.dto.owner.OwnerRoomRelDto; import com.java110.dto.smallWeChat.SmallWeChatDto; import com.java110.dto.smallWechatAttr.SmallWechatAttrDto; import com.java110.dto.staffAppAuth.StaffAppAuthDto; import com.java110.dto.user.UserDto; import com.java110.entity.order.Business; import com.java110.entity.wechat.Content; import com.java110.entity.wechat.Data; import com.java110.entity.wechat.PropertyFeeTemplateMessage; import com.java110.intf.community.ICommunityInnerServiceSMO; import com.java110.intf.fee.IFeeDetailInnerServiceSMO; import com.java110.intf.fee.IFeeInnerServiceSMO; import com.java110.intf.order.IPrivilegeInnerServiceSMO; import com.java110.intf.store.ISmallWeChatInnerServiceSMO; import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO; 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; import com.java110.utils.constant.MappingConstant; import com.java110.utils.constant.WechatConstant; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.DateUtil; import com.java110.utils.util.StringUtil; import org.slf4j.Logger; import com.java110.core.log.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Component; import org.springframework.web.client.RestTemplate; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import java.util.List; import java.util.Map; /** * 缴费通知适配器 * * @author fqz * @date 2020-12-11 18:54 */ @Component(value = "machinePaymentNoticeAdapt") public class MachinePaymentNoticeAdapt extends DatabusAdaptImpl { private static Logger logger = LoggerFactory.getLogger(MachinePaymentNoticeAdapt.class); @Autowired private ICommunityInnerServiceSMO communityInnerServiceSMO; @Autowired private ISmallWeChatInnerServiceSMO smallWeChatInnerServiceSMOImpl; @Autowired private ISmallWechatAttrInnerServiceSMO smallWechatAttrInnerServiceSMOImpl; @Autowired private IPrivilegeInnerServiceSMO privilegeInnerServiceSMO; @Autowired private RestTemplate outRestTemplate; @Autowired private IStaffAppAuthInnerServiceSMO staffAppAuthInnerServiceSMO; @Autowired private IFeeInnerServiceSMO feeInnerServiceSMOImpl; @Autowired private IFeeDetailInnerServiceSMO feeDetailInnerServiceSMOImpl; @Autowired private IComputeFeeSMO computeFeeSMOImpl; @Autowired private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMO; @Autowired private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMO; @Autowired private IOwnerInnerServiceSMO ownerInnerServiceSMO; @Autowired private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMO; //模板信息推送地址 private static String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="; public final static String ALI_SMS_DOMAIN = "ALI_SMS"; @Override public void execute(Business business, List businesses) { JSONObject data = business.getData(); JSONArray businessPayFeeDetails = null; if (data == null) { FeeDetailDto feeDetailDto = new FeeDetailDto(); feeDetailDto.setbId(business.getbId()); List feeDetailDtos = feeDetailInnerServiceSMOImpl.queryFeeDetails(feeDetailDto); Assert.listOnlyOne(feeDetailDtos, "未查询到缴费记录"); businessPayFeeDetails = JSONArray.parseArray(JSONArray.toJSONString(feeDetailDtos, SerializerFeature.WriteDateUseDateFormat)); } else if (data.containsKey(PayFeeDetailPo.class.getSimpleName())) { Object bObj = data.get(PayFeeDetailPo.class.getSimpleName()); if (bObj instanceof JSONObject) { businessPayFeeDetails = new JSONArray(); businessPayFeeDetails.add(bObj); } else if (bObj instanceof Map) { businessPayFeeDetails = new JSONArray(); businessPayFeeDetails.add(JSONObject.parseObject(JSONObject.toJSONString(bObj))); } else if (bObj instanceof List) { businessPayFeeDetails = JSONArray.parseArray(JSONObject.toJSONString(bObj)); } else { businessPayFeeDetails = (JSONArray) bObj; } } else { if (data instanceof JSONObject) { businessPayFeeDetails = new JSONArray(); businessPayFeeDetails.add(data); } } for (int bPayFeeDetailIndex = 0; bPayFeeDetailIndex < businessPayFeeDetails.size(); bPayFeeDetailIndex++) { JSONObject businessPayFeeDetail = businessPayFeeDetails.getJSONObject(bPayFeeDetailIndex); doSendPayFeeDetail(business, businessPayFeeDetail); } } private String subDay(String date) throws ParseException { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); Date dt = sdf.parse(date); Calendar rightNow = Calendar.getInstance(); rightNow.setTime(dt); rightNow.add(Calendar.DAY_OF_MONTH, -1); Date dt1 = rightNow.getTime(); String reStr = sdf.format(dt1); return reStr; } private void doSendPayFeeDetail(Business business, JSONObject businessPayFeeDetail) { //查询缴费明细 PayFeeDetailPo payFeeDetailPo = BeanConvertUtil.covertBean(businessPayFeeDetail, PayFeeDetailPo.class); //查询小区信息 CommunityDto communityDto = new CommunityDto(); communityDto.setCommunityId(payFeeDetailPo.getCommunityId()); List communityDtos = communityInnerServiceSMO.queryCommunitys(communityDto); FeeDto feeDto = new FeeDto(); feeDto.setFeeId(payFeeDetailPo.getFeeId()); feeDto.setCommunityId(payFeeDetailPo.getCommunityId()); List feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto); Assert.listOnlyOne(feeDtos, "未查询到费用信息"); //获取费用类型 String feeTypeCdName = feeDtos.get(0).getFeeTypeCdName(); //获取缴费用户楼栋单元房间号 String payerObjName = computeFeeSMOImpl.getFeeObjName(feeDtos.get(0)); //获得用户缴费开始时间 String startTime = DateUtil.dateTimeToDate(payFeeDetailPo.getStartTime()); //获取用户缴费到期时间 String endTime = DateUtil.dateTimeToDate(payFeeDetailPo.getEndTime()); try { endTime = subDay(endTime); } catch (ParseException e) { e.printStackTrace(); } //获取用户缴费金额 String receivedAmount = payFeeDetailPo.getReceivedAmount(); //获取费用类型 String feeTypeCd = feeDtos.get(0).getFeeTypeCd(); //获取付费对象类型 String payerObjType = feeDtos.get(0).getPayerObjType(); //获取状态 String state = payFeeDetailPo.getState(); //车牌号 String carNum = ""; //停车场 String num = ""; //车位 String spaceNum = ""; if (!StringUtil.isEmpty(payerObjType) && payerObjType.equals("6666")) { String[] split = payerObjName.split("-"); //获取车牌 carNum = split[0]; //获取停车场 num = split[1]; //获取车位 spaceNum = split[2]; } //获取社区名称 String name = communityDtos.get(0).getName(); JSONObject paramIn = new JSONObject(); paramIn.put("payFeeRoom", name + "-" + payerObjName); paramIn.put("feeTypeCdName", feeTypeCdName); paramIn.put("payFeeTime", startTime + "至" + endTime); paramIn.put("receivedAmount", receivedAmount); paramIn.put("startTime", startTime); paramIn.put("endTime", endTime); paramIn.put("payerObjType", payerObjType); paramIn.put("carNum", carNum); paramIn.put("num", num); paramIn.put("spaceNum", spaceNum); paramIn.put("state", state); //给业主推送消息 sendMessage(paramIn, communityDtos.get(0), payFeeDetailPo); if (!StringUtil.isEmpty(state) && !state.equals("1300") && feeTypeCd.equals("888800010012")) { //给处理报修完结单的维修师傅推送消息 sendMsg(paramIn, communityDtos.get(0), payFeeDetailPo); } if (!StringUtil.isEmpty(state) && !state.equals("1300")) { //给员工推送消息 publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo); } } /** * 给员工推送信息 * * @param paramIn * @param communityDto * @param payFeeDetailPo */ private void publishMsg(JSONObject paramIn, CommunityDto communityDto, PayFeeDetailPo payFeeDetailPo) { //查询公众号配置 SmallWeChatDto smallWeChatDto = new SmallWeChatDto(); smallWeChatDto.setWeChatType("1100"); smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY); smallWeChatDto.setObjId(communityDto.getCommunityId()); List smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto); if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) { logger.info("未配置微信公众号信息,定时任务执行结束"); return; } SmallWeChatDto weChatDto = smallWeChatDtos.get(0); SmallWechatAttrDto smallWechatAttrDto = new SmallWechatAttrDto(); smallWechatAttrDto.setCommunityId(communityDto.getCommunityId()); smallWechatAttrDto.setWechatId(weChatDto.getWeChatId()); smallWechatAttrDto.setSpecCd(SmallWechatAttrDto.SPEC_CD_WECHAT_SUCCESS_TEMPLATE); List smallWechatAttrDtos = smallWechatAttrInnerServiceSMOImpl.querySmallWechatAttrs(smallWechatAttrDto); if (smallWechatAttrDtos == null || smallWechatAttrDtos.size() <= 0) { logger.info("未配置微信公众号消息模板"); return; } String templateId = smallWechatAttrDtos.get(0).getValue(); String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret()); if (StringUtil.isEmpty(accessToken)) { logger.info("推送微信模板,获取accessToken失败:{}", accessToken); return; } FeeDto feeDto = new FeeDto(); feeDto.setFeeId(payFeeDetailPo.getFeeId()); feeDto.setCommunityId(payFeeDetailPo.getCommunityId()); List feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto); Assert.listOnlyOne(feeDtos, "费用不存在"); // 根据特定权限查询 有该权限的 员工 BasePrivilegeDto basePrivilegeDto = new BasePrivilegeDto(); //basePrivilegeDto.setPId("502020121454780004"); basePrivilegeDto.setResource("/wechatNotification"); basePrivilegeDto.setStoreId(feeDtos.get(0).getIncomeObjId()); List userDtos = privilegeInnerServiceSMO.queryPrivilegeUsers(basePrivilegeDto); String sendTemplate = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, WechatConstant.SEND_TEMPLATE_URL); if (StringUtil.isEmpty(sendTemplate)) { sendTemplate = sendMsgUrl; } String url = sendTemplate + accessToken; //获取付费对象类型 String payerObjType = paramIn.getString("payerObjType"); if (userDtos != null && userDtos.size() > 0) { for (UserDto userDto : userDtos) { //根据 userId 查询到openId try { StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto(); staffAppAuthDto.setStaffId(userDto.getUserId()); staffAppAuthDto.setAppType("WECHAT"); List staffAppAuthDtos = staffAppAuthInnerServiceSMO.queryStaffAppAuths(staffAppAuthDto); if (staffAppAuthDtos == null || staffAppAuthDtos.size() < 1) { continue; } String openId = staffAppAuthDtos.get(0).getOpenId(); Data data = new Data(); PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage(); templateMessage.setTemplate_id(templateId); templateMessage.setTouser(openId); data.setFirst(new Content("本次缴费已到账")); if (payerObjType.equals("3333")) { //房屋 data.setKeyword1(new Content(paramIn.getString("payFeeRoom"))); data.setKeyword2(new Content(paramIn.getString("feeTypeCdName"))); } else { //车辆 data.setKeyword1(new Content(communityDto.getName() + "-" + paramIn.getString("num") + "-" + paramIn.getString("spaceNum"))); data.setKeyword2(new Content(paramIn.getString("feeTypeCdName") + "-" + paramIn.getString("carNum"))); } data.setKeyword3(new Content(paramIn.getString("payFeeTime"))); data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元")); data.setRemark(new Content("感谢您的使用,如有疑问请联系相关物业人员")); templateMessage.setData(data); //获取员工公众号地址 String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN,"STAFF_WECHAT_URL"); templateMessage.setUrl(wechatUrl); logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage)); ResponseEntity responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class); logger.info("微信模板返回内容:{}", responseEntity); } catch (Exception e) { logger.error("发送缴费信息失败", e); } } } } /** * 给完结订单的维修师傅推送信息 * * @param paramIn * @param communityDto * @param payFeeDetailPo */ private void sendMsg(JSONObject paramIn, CommunityDto communityDto, PayFeeDetailPo payFeeDetailPo) { //查询公众号配置 SmallWeChatDto smallWeChatDto = new SmallWeChatDto(); smallWeChatDto.setWeChatType("1100"); smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY); smallWeChatDto.setObjId(communityDto.getCommunityId()); List smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto); if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) { logger.info("未配置微信公众号信息,定时任务执行结束"); return; } SmallWeChatDto weChatDto = smallWeChatDtos.get(0); SmallWechatAttrDto smallWechatAttrDto = new SmallWechatAttrDto(); smallWechatAttrDto.setCommunityId(communityDto.getCommunityId()); smallWechatAttrDto.setWechatId(weChatDto.getWeChatId()); smallWechatAttrDto.setSpecCd(SmallWechatAttrDto.SPEC_CD_WECHAT_SUCCESS_TEMPLATE); List smallWechatAttrDtos = smallWechatAttrInnerServiceSMOImpl.querySmallWechatAttrs(smallWechatAttrDto); if (smallWechatAttrDtos == null || smallWechatAttrDtos.size() <= 0) { logger.info("未配置微信公众号消息模板"); return; } String templateId = smallWechatAttrDtos.get(0).getValue(); String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret()); if (StringUtil.isEmpty(accessToken)) { logger.info("推送微信模板,获取accessToken失败:{}", accessToken); return; } FeeDto feeDto = new FeeDto(); feeDto.setFeeId(payFeeDetailPo.getFeeId()); feeDto.setCommunityId(payFeeDetailPo.getCommunityId()); List feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto); Assert.listOnlyOne(feeDtos, "费用不存在"); //获取创建用户,即处理结单的维修维修师傅 String userId = feeDtos.get(0).getUserId(); 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(); staffAppAuthDto.setStaffId(userId); staffAppAuthDto.setAppType("WECHAT"); List staffAppAuthDtos = staffAppAuthInnerServiceSMO.queryStaffAppAuths(staffAppAuthDto); Assert.listOnlyOne(staffAppAuthDtos, "员工未认证"); String openId = staffAppAuthDtos.get(0).getOpenId(); Data data = new Data(); PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage(); templateMessage.setTemplate_id(templateId); templateMessage.setTouser(openId); data.setFirst(new Content("业主已缴纳维修费，信息如下：")); data.setKeyword1(new Content(paramIn.getString("payFeeRoom"))); data.setKeyword2(new Content(paramIn.getString("feeTypeCdName"))); data.setKeyword3(new Content(paramIn.getString("payFeeTime"))); data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元")); data.setRemark(new Content("请与客服管家核实费用")); templateMessage.setData(data); //获取员工公众号地址 String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN,"STAFF_WECHAT_URL"); templateMessage.setUrl(wechatUrl); logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage)); ResponseEntity responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class); logger.info("微信模板返回内容:{}", responseEntity); } catch (Exception e) { logger.error("发送缴费信息失败", e); } } /** * 给业主推送消息 * * @param paramIn * @param communityDto * @param payFeeDetailPo */ private void sendMessage(JSONObject paramIn, CommunityDto communityDto, PayFeeDetailPo payFeeDetailPo) { //查询公众号配置 SmallWeChatDto smallWeChatDto = new SmallWeChatDto(); smallWeChatDto.setWeChatType("1100"); smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY); smallWeChatDto.setObjId(communityDto.getCommunityId()); List smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto); if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) { logger.info("未配置微信公众号信息,定时任务执行结束"); return; } SmallWeChatDto weChatDto = smallWeChatDtos.get(0); SmallWechatAttrDto smallWechatAttrDto = new SmallWechatAttrDto(); smallWechatAttrDto.setCommunityId(communityDto.getCommunityId()); smallWechatAttrDto.setWechatId(weChatDto.getWeChatId()); smallWechatAttrDto.setSpecCd(SmallWechatAttrDto.SPEC_CD_WECHAT_SUCCESS_TEMPLATE); List smallWechatAttrDtos = smallWechatAttrInnerServiceSMOImpl.querySmallWechatAttrs(smallWechatAttrDto); if (smallWechatAttrDtos == null || smallWechatAttrDtos.size() <= 0) { logger.info("未配置微信公众号消息模板"); return; } String templateId = smallWechatAttrDtos.get(0).getValue(); String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret()); if (StringUtil.isEmpty(accessToken)) { logger.info("推送微信模板,获取accessToken失败:{}", accessToken); return; } FeeDto feeDto = new FeeDto(); feeDto.setFeeId(payFeeDetailPo.getFeeId()); feeDto.setCommunityId(payFeeDetailPo.getCommunityId()); List feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto); Assert.listOnlyOne(feeDtos, "费用不存在"); //支付房间id(支付车辆id) String payerObjId = feeDtos.get(0).getPayerObjId(); //支付类型(房屋、车辆) String payerObjType = feeDtos.get(0).getPayerObjType(); String ownerId = ""; //3333 房屋缴费 6666 是车位缴费 if (payerObjType.equals("3333")) { OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto(); ownerRoomRelDto.setRoomId(payerObjId); List ownerRoomRelDtos = ownerRoomRelInnerServiceSMO.queryOwnerRoomRels(ownerRoomRelDto); //取得业主id ownerId = ownerRoomRelDtos.get(0).getOwnerId(); } else if (payerObjType.equals("6666")) { OwnerCarDto ownerCarDto = new OwnerCarDto(); ownerCarDto.setCarId(payerObjId); List ownerCarDtos = ownerCarInnerServiceSMO.queryOwnerCars(ownerCarDto); Assert.listOnlyOne(ownerCarDtos, "查询车辆所属业主信息错误！"); //取得业主id ownerId = ownerCarDtos.get(0).getOwnerId(); } OwnerDto ownerDto = new OwnerDto(); ownerDto.setOwnerId(ownerId); //1001 业主本人 1002 家庭成员 ownerDto.setOwnerTypeCd("1001"); //查询业主 List ownerDtos = ownerInnerServiceSMO.queryOwners(ownerDto); Assert.listOnlyOne(ownerDtos, "查询业主信息错误！"); //获得成员id String memberId = ownerDtos.get(0).getMemberId(); OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto(); ownerAppUserDto.setMemberId(memberId); ownerAppUserDto.setAppType("WECHAT"); List ownerAppUserDtos = ownerAppUserInnerServiceSMO.queryOwnerAppUsers(ownerAppUserDto); if (ownerAppUserDtos.size() > 0) { //获取openId String openId = ownerAppUserDtos.get(0).getOpenId(); String url = sendMsgUrl + accessToken; Data data = new Data(); PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage(); templateMessage.setTemplate_id(templateId); templateMessage.setTouser(openId); if (!StringUtil.isEmpty(paramIn.getString("state")) && paramIn.getString("state").equals("1300")) { data.setFirst(new Content("本次退费已到账")); } else { data.setFirst(new Content("本次缴费已到账")); } if (payerObjType.equals("3333")) { //房屋 data.setKeyword1(new Content(paramIn.getString("payFeeRoom"))); data.setKeyword2(new Content(paramIn.getString("feeTypeCdName"))); } else { //车辆 data.setKeyword1(new Content(communityDto.getName() + "-" + paramIn.getString("num") + "-" + paramIn.getString("spaceNum"))); data.setKeyword2(new Content(paramIn.getString("feeTypeCdName") + "-" + paramIn.getString("carNum"))); } data.setKeyword3(new Content(paramIn.getString("payFeeTime"))); if (!StringUtil.isEmpty(paramIn.getString("state")) && paramIn.getString("state").equals("1300")) { //获取退费金额 double receivedAmount = Double.parseDouble(paramIn.getString("receivedAmount")); double money = receivedAmount * (-1.00); data.setKeyword4(new Content("退费" + money + "元")); } else { data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元")); } data.setRemark(new Content("感谢您的使用,如有疑问请联系相关物业人员")); templateMessage.setData(data); //获取业主公众号地址 String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN,"OWNER_WECHAT_URL"); if(wechatUrl.contains("?")){ wechatUrl += ( "&wAppId="+smallWeChatDtos.get(0).getAppId()); }else{ wechatUrl += ( "?wAppId="+smallWeChatDtos.get(0).getAppId()); } templateMessage.setUrl(wechatUrl); logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage)); ResponseEntity responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class); logger.info("微信模板返回内容:{}", responseEntity); } else { //获取业主手机号 String tel = ownerDtos.get(0).getLink(); //获取业主姓名 String name = ownerDtos.get(0).getName(); //获取费用类型 String feeTypeCdName = paramIn.getString("feeTypeCdName"); //获取费用开始时间 String startTime = paramIn.getString("startTime"); //获取费用结束时间 String endTime = paramIn.getString("endTime"); //获取缴费金额 String receivedAmount = paramIn.getString("receivedAmount"); //获取房屋号 String payFeeRoom = paramIn.getString("payFeeRoom"); DefaultProfile profile = DefaultProfile.getProfile(MappingCache.getValue(ALI_SMS_DOMAIN, "region"), MappingCache.getValue(ALI_SMS_DOMAIN, "accessKeyId"), MappingCache.getValue(ALI_SMS_DOMAIN, "accessSecret")); IAcsClient client = new DefaultAcsClient(profile); CommonRequest request = new CommonRequest(); request.setSysMethod(MethodType.POST); request.setSysDomain("dysmsapi.aliyuncs.com"); request.setSysVersion("2017-05-25"); request.setSysAction("SendSms"); request.putQueryParameter("RegionId", MappingCache.getValue(ALI_SMS_DOMAIN, "region")); request.putQueryParameter("PhoneNumbers", tel); request.putQueryParameter("SignName", MappingCache.getValue(ALI_SMS_DOMAIN, "signName")); //获取模板编码(SMS_207160078为缴费成功提示模板编码) String payFeeCode = MappingCache.getValue(ALI_SMS_DOMAIN, "PayFeeCode"); String substring = ""; if (!StringUtil.isEmpty(payFeeCode)) { substring = payFeeCode.substring(0, 4); } if (substring.equals("SMS_")) { request.putQueryParameter("TemplateCode", payFeeCode); } request.putQueryParameter("TemplateParam", "{\"user\":" + "\"" + name + "\"" + "," + "\"house\":" + "\"" + payFeeRoom + "\"" + "," + "\"feeType\":" + "\"" + feeTypeCdName + "\"" + "," + "\"startTime\":" + "\"" + startTime + "\"" + "," + "\"endTime\":" + "\"" + endTime + "\"" + "," + "\"mount\":" + "\"" + receivedAmount + "\"" + "}"); try { CommonResponse response = client.getCommonResponse(request); logger.debug("发送短信：{}", response.getData()); } catch (ServerException e) { e.printStackTrace(); } catch (ClientException e) { e.printStackTrace(); } } } }