[新增]走访任务向市平台推送。推送市平台测环境

manailin

2021-06-27 c3a5a9ae94e5604160f0ba4ac6148934db84f26b

 springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/CommunityJobHandler.java

@@ -42,7 +42,8 @@
    public ReturnT<String> timedTaskDynIstoppingJobHandler(String param) throws Exception {
        log.info("定时任务刷新社区动态置顶状态");
        R r=communityService.timedTaskDynIstopping();
        return new ReturnT(r.getData());
        log.info("执行结果【{}】",r.toString());
        return ReturnT.SUCCESS;
    }

    /**
@@ -53,8 +54,9 @@
    @XxlJob("timedTaskDynStatusJobHandler")
    public ReturnT<String> timedTaskDynStatusJobHandler(String param) throws Exception {
        log.info("定时任务刷新社区动态发布状态");
        R r=communityService.timedTaskDynIstopping();
        return new ReturnT(r.getData());
        R r=communityService.timedTaskDynStatus();
        log.info("执行结果【{}】",r.toString());
        return ReturnT.SUCCESS;
    }

    /**
@@ -68,34 +70,37 @@
        R r=communityService.timedTaskActActivity();
        if (R.isOk(r)) {
            Object data = r.getData();
            List<ComActActivityVO> comActActivityVOS= JSONArray.parseArray(JSONArray.toJSONString(data),ComActActivityVO.class);
            if (!ObjectUtils.isEmpty(comActActivityVOS)) {
                comActActivityVOS.forEach(comActActivityVO -> {
                    List<ActivitySignVO> activitySignVOList = comActActivityVO.getActivitySignVOList();
                    if (!ObjectUtils.isEmpty(activitySignVOList)) {
                        activitySignVOList.forEach(activitySignVO -> {
                            SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO();
                            sysUserNoticeVO.setUserId(activitySignVO.getUserId());
                            sysUserNoticeVO.setType(1);
                            sysUserNoticeVO.setBusinessType(2);
                            sysUserNoticeVO.setBusinessTitle(comActActivityVO.getActivityName());
                            sysUserNoticeVO.setBusinessTime(new Date());
                            sysUserNoticeVO.setBusinessId(comActActivityVO.getId());
                            sysUserNoticeVO.setStatus(0);
                            sysUserNoticeVO.setTitle("活动因故取消");
                            sysUserNoticeVO.setBusinessContent("报名人数不足活动自动取消");
                            sysUserNoticeVO.setBusinessStatus(1);
                            sysUserNoticeVO.setActivityType(activitySignVO.getIsVolunteer().intValue()==1?1:2);
                            R r2 = userService.addNotice(sysUserNoticeVO);
                            if (R.isOk(r2)) {
                                log.info("新增社区活动取消通知成功【{}】", JSONObject.toJSONString(sysUserNoticeVO));
                            }
                        });
                    }
                });
            if (!ObjectUtils.isEmpty(data)) {
                List<ComActActivityVO> comActActivityVOS= JSONArray.parseArray(JSONArray.toJSONString(data),ComActActivityVO.class);
                if (!ObjectUtils.isEmpty(comActActivityVOS)) {
                    comActActivityVOS.forEach(comActActivityVO -> {
                        List<ActivitySignVO> activitySignVOList = comActActivityVO.getActivitySignVOList();
                        if (!ObjectUtils.isEmpty(activitySignVOList)) {
                            activitySignVOList.forEach(activitySignVO -> {
                                SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO();
                                sysUserNoticeVO.setUserId(activitySignVO.getUserId());
                                sysUserNoticeVO.setType(1);
                                sysUserNoticeVO.setBusinessType(2);
                                sysUserNoticeVO.setBusinessTitle(comActActivityVO.getActivityName());
                                sysUserNoticeVO.setBusinessTime(new Date());
                                sysUserNoticeVO.setBusinessId(comActActivityVO.getId());
                                sysUserNoticeVO.setStatus(0);
                                sysUserNoticeVO.setTitle("活动因故取消");
                                sysUserNoticeVO.setBusinessContent("报名人数不足活动自动取消");
                                sysUserNoticeVO.setBusinessStatus(1);
                                sysUserNoticeVO.setActivityType(activitySignVO.getIsVolunteer().intValue()==1?1:2);
                                R r2 = userService.addNotice(sysUserNoticeVO);
                                if (R.isOk(r2)) {
                                    log.info("新增社区活动取消通知成功【{}】", JSONObject.toJSONString(sysUserNoticeVO));
                                }
                            });
                        }
                    });
                }
            }
        }
        return new ReturnT(r.getData());
        log.info("执行结果【{}】",r.toString());
        return ReturnT.SUCCESS;
    }

    /**
@@ -107,6 +112,21 @@
    public ReturnT<String> timedTaskActActivityAllJobHandler(String param) throws Exception {
        log.info("定时任务刷新社区活动的各个状态 除取消外");
        R r=communityService.timedTaskActActivityAll();
        return new ReturnT(r.getData());
        log.info("执行结果【{}】",r.toString());
        return ReturnT.SUCCESS;
    }


    /**
     * 定时任务刷新社区活动的各个状态 除取消外
     * @return 刷新个数
     * @throws Exception 出现的异常
     */
    @XxlJob("timedTaskActMicroWishAllJobHandler")
    public ReturnT<String> timedTaskActMicroWishAllJobHandler(String param) throws Exception {
        log.info("定时任务刷新微心愿 待自动确认的状态");
        R r=communityService.timedTaskActMicroWishAll();
        log.info("执行结果【{}】",r.toString());
        return ReturnT.SUCCESS;
    }
}