| | |
| | | @Override |
| | | protected void process(TaskDto taskDto) { |
| | | logger.debug("开始执行微信模板信息推送" + taskDto.toString()); |
| | | |
| | | // 获取小区 |
| | | List<CommunityDto> communityDtos = getAllCommunity(); |
| | | |
| | | for (CommunityDto communityDto : communityDtos) { |
| | | try { |
| | | returnVisitRepair(taskDto, communityDto); |
| | |
| | | repairDto.setRow(100); |
| | | //查询需要程序轮训派单 订单 |
| | | List<RepairDto> repairDtos = repairInnerServiceSMOImpl.queryRepairs(repairDto); |
| | | |
| | | for (RepairDto tmpRepairDto : repairDtos) { |
| | | |
| | | doReturnVisitRepair(tmpRepairDto); |
| | | |
| | | } |
| | | |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param tmpRepairDto |
| | | */ |
| | | private void doReturnVisitRepair(RepairDto tmpRepairDto) { |
| | | |
| | | if ("001".equals(tmpRepairDto.getReturnVisitFlag())) { |
| | | RepairPoolPo repairPoolPo = new RepairPoolPo(); |
| | | repairPoolPo.setRepairId(tmpRepairDto.getRepairId()); |
| | |
| | | repairInnerServiceSMOImpl.updateRepair(repairPoolPo); |
| | | return; |
| | | } |
| | | |
| | | if ("002".equals(tmpRepairDto.getReturnVisitFlag()) && RepairDto.STATE_APPRAISE.equals(tmpRepairDto.getState())) { |
| | | RepairPoolPo repairPoolPo = new RepairPoolPo(); |
| | | repairPoolPo.setRepairId(tmpRepairDto.getRepairId()); |
| | |
| | | repairInnerServiceSMOImpl.updateRepair(repairPoolPo); |
| | | return; |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | |
| | | } |