优化消息发布功能

java110

2021-06-11 a4dcca761cfe73acca8b9dc0a0d664451d5cc89a

优化消息发布功能

 service-job/src/main/java/com/java110/job/adapt/payment/notice/MachinePaymentNoticeAdapt.java

@@ -247,6 +247,9 @@
                staffAppAuthDto.setStaffId(userDto.getUserId());
                staffAppAuthDto.setAppType("WECHAT");
                List<StaffAppAuthDto> 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();

 service-job/src/main/java/com/java110/job/task/wechat/PublicWeChatPushMessageTemplate.java

@@ -3,7 +3,6 @@
import com.alibaba.fastjson.JSON;
import com.java110.core.factory.WechatFactory;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.fee.BillDto;
import com.java110.dto.fee.BillOweFeeDto;
import com.java110.dto.fee.FeeDto;
import com.java110.dto.owner.OwnerAppUserDto;
@@ -174,6 +173,7 @@
        for (BillOweFeeDto fee : billOweFeeDtos) {
            oweUrl = FeeDto.PAYER_OBJ_TYPE_ROOM.equals(fee.getPayerObjType()) ? oweRoomUrl : oweCarUrl;
            for (OwnerAppUserDto appUserDto : ownerAppUserDtos) {
                try {
                if (fee.getOwnerId().equals(appUserDto.getMemberId())) {
                    Date date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(fee.getFeeEndTime());
                    Calendar now = Calendar.getInstance();
@@ -203,6 +203,9 @@
                    ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);
                    logger.info("微信模板返回内容:{}", responseEntity);
                }
                } catch (Exception e) {
                    logger.error("推送账单异常", e);
                }
            }

            BillOweFeeDto tmpBillOweFeeDto = new BillOweFeeDto();