优化催交

wuxw

2023-10-29 d7d3b53ab846738cc9a4ed3de46d28fd872f333b

 service-job/src/main/java/com/java110/job/adapt/fee/OweFeeCallableAdapt.java

@@ -102,11 +102,17 @@
            contents = new ArrayList<>();
            String notifyWay = MsgNotifyFactory.NOTIFY_WAY_WECHAT;
            userId = "";
            String ofcId = "";
            String ownerId = "";
            try {
            sendOweFeeCallablePos = new ArrayList<>();
            for (OweFeeCallablePo oweFeeCallablePo : oweFeeCallablePos) {
                if (!oweFeeCallablePo.getPayerObjId().equals(roomIds.getString(roomIndex))) {
                    continue;
                }

                    ofcId = oweFeeCallablePo.getOfcId();
                    ownerId = oweFeeCallablePo.getOwnerId();

                //todo 业主不存在
                if (StringUtil.isEmpty(oweFeeCallablePo.getOwnerId()) || oweFeeCallablePo.getOwnerId().startsWith("-")) {
@@ -146,16 +152,17 @@
            }

            if (contents.isEmpty()) {
                return;
                    continue;
            }

            //todo 催缴
            ResultVo resultVo = MsgNotifyFactory.sendOweFeeMsg(data.getString("communityId"), userId, oweFeeCallablePos.get(0).getOwnerId(), contents, notifyWay);
                ResultVo resultVo = MsgNotifyFactory.sendOweFeeMsg(data.getString("communityId"), userId, ownerId, contents, notifyWay);

            for (OweFeeCallablePo oweFeeCallablePo : sendOweFeeCallablePos) {
                if (StringUtil.isEmpty(oweFeeCallablePo.getOwnerId()) || oweFeeCallablePo.getOwnerId().startsWith("-")) {
                    continue;
                }
                    ofcId = oweFeeCallablePo.getOfcId();
                updateOweFeeCallablePo = new OweFeeCallablePo();
                updateOweFeeCallablePo.setOfcId(oweFeeCallablePo.getOfcId());
                updateOweFeeCallablePo.setCommunityId(oweFeeCallablePo.getCommunityId());
@@ -167,6 +174,19 @@
                }
                oweFeeCallableV1InnerServiceSMOImpl.updateOweFeeCallable(updateOweFeeCallablePo);
            }
            }catch (Exception e){
                e.printStackTrace();

                if(!StringUtil.isEmpty(ofcId)){
                    updateOweFeeCallablePo = new OweFeeCallablePo();
                    updateOweFeeCallablePo.setOfcId(ofcId);
                    updateOweFeeCallablePo.setCommunityId(data.getString("communityId"));
                    updateOweFeeCallablePo.setState(OweFeeCallableDto.STATE_FAIL);
                    updateOweFeeCallablePo.setRemark(e.getMessage());
                    oweFeeCallableV1InnerServiceSMOImpl.updateOweFeeCallable(updateOweFeeCallablePo);
                }

            }

        }
    }