联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiaogang
2021-04-01 6175556f8b73e1e92f53378423359710bca60f4a 
 service-job/src/main/java/com/java110/job/adapt/payment/notice/MachinePaymentNoticeAdapt.java


@@ -36,12 +36,17 @@


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;


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 org.slf4j.LoggerFactory;


@@ -151,18 +156,19 @@


        feeDto.setFeeId(payFeeDetailPo.getFeeId());


        feeDto.setCommunityId(payFeeDetailPo.getCommunityId());


        List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);




        Assert.listOnlyOne(feeDtos, "未查询到费用信息");


        //获取费用类型


        String feeTypeCdName = feeDtos.get(0).getFeeTypeCdName();


        //获取缴费用户楼栋单元房间号


        String payerObjName = computeFeeSMOImpl.getFeeObjName(feeDtos.get(0));


        //获得用户缴费开始时间


        String startTime = payFeeDetailPo.getStartTime();


        String startTime = DateUtil.dateTimeToDate(payFeeDetailPo.getStartTime());


        //获取用户缴费到期时间


        String endTime = payFeeDetailPo.getEndTime();


        String endTime = DateUtil.dateTimeToDate(payFeeDetailPo.getEndTime());


        //获取用户缴费金额


        String receivedAmount = payFeeDetailPo.getReceivedAmount();


        //获取费用类型


        String feeTypeCd = feeDtos.get(0).getFeeTypeCd();


        //获取社区名称


        String name = communityDtos.get(0).getName();


        JSONObject paramIn = new JSONObject();


@@ -172,8 +178,15 @@


        paramIn.put("receivedAmount", receivedAmount);


        paramIn.put("startTime", startTime);


        paramIn.put("endTime", endTime);


        //给业主推送消息


        sendMessage(paramIn, communityDtos.get(0), payFeeDetailPo);


        publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo);


        if (feeTypeCd.equals("888800010012")) {


            //给处理报修完结单的维修师傅推送消息


            sendMsg(paramIn, communityDtos.get(0), payFeeDetailPo);


        } else {


            //给员工推送消息


            publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo);


        }


    }




    /**


@@ -224,27 +237,102 @@


        String url = sendMsgUrl + accessToken;


        for (UserDto userDto : userDtos) {


            //根据 userId 查询到openId


            try {


                StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();


                staffAppAuthDto.setStaffId(userDto.getUserId());


                staffAppAuthDto.setAppType("WECHAT");


                List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMO.queryStaffAppAuths(staffAppAuthDto);


                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("OWNER_WECHAT_URL");


                templateMessage.setUrl(wechatUrl);


                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);


            }


        }


    }




    /**


     * 给完结订单的维修师傅推送信息


     *


     * @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<SmallWeChatDto> 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<SmallWechatAttrDto> 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<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);


        Assert.listOnlyOne(feeDtos, "费用不存在");


        //获取创建用户,即处理结单的维修维修师傅


        String userId = feeDtos.get(0).getUserId();


        String url = sendMsgUrl + accessToken;


        //根据 userId 查询到openId


        try {


            StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();


            staffAppAuthDto.setStaffId(userDto.getUserId());


            staffAppAuthDto.setStaffId(userId);


            staffAppAuthDto.setAppType("WECHAT");


            List<StaffAppAuthDto> 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.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("感谢您的使用,如有疑问请联系相关物业人员"));


            data.setRemark(new Content("请与客服管家核实费用"));


            templateMessage.setData(data);


            String wechatUrl = MappingCache.getValue("OWNER_WECHAT_URL");


            templateMessage.setUrl(wechatUrl);


            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);


        }


    }