微心愿详情bug

huanghongfa

2021-01-15 ada9d2e3f734582a0d9ae8c00a936d8c8ed669d7

 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java

@@ -16,12 +16,15 @@
import com.panzhihua.service_dangjian.model.dos.ComPbActivityMemberDO;
import com.panzhihua.service_dangjian.model.dos.ComPbMemberDO;
import com.panzhihua.service_dangjian.service.ComBpActivityService;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.client.utils.DateUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import javax.annotation.Resource;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

@@ -31,6 +34,7 @@
 * @author: huang.hongfa weixin hhf9596 qq 959656820
 * @create: 2020-12-01 09:16
 **/
@Slf4j
@Service
public class ComBpActivityServiceImpl implements ComBpActivityService {
    @Resource
@@ -212,6 +216,16 @@
        page.setSize(pageSize);
        page.setCurrent(pageNum);
        IPage<PartyBuildingActivityVO> iPage = comBpActivityDAO.pageActivity(page, partyBuildingActivityVO);
        List<PartyBuildingActivityVO> records = iPage.getRecords();
        if (!ObjectUtils.isEmpty(records)) {
            DateFormat formatTo = new SimpleDateFormat("M月d ahh:mm");
            records.forEach(partyBuildingActivityVO1 -> {
                Date activityTimeBegin = partyBuildingActivityVO1.getActivityTimeBegin();
                if (!ObjectUtils.isEmpty(activityTimeBegin)) {
                    partyBuildingActivityVO1.setActivityTimeBeginFormat(formatTo.format(activityTimeBegin));
                }
            });
        }
        return R.ok(iPage);
    }

@@ -328,4 +342,66 @@
        }
        return R.fail();
    }

    /**
     * 获取党建活动所有参入人员的id集合
     *
     * @param id 党建活动id
     * @return 人员id集合
     */
    @Override
    public R selectAllPartyBuildingActivityMembers(Long id) {
        List<Long> longs=comPbActivityMemberDAO.selectAllPartyBuildingActivityMembers(id);
        return R.ok(longs);
    }

    /**
     * 定时任务取消党建活动
     *
     * @return 取消党建活动数量
     */
    @Override
    public R timedTaskPartyBuildingActivity() {
        List<Long> ids=comBpActivityDAO.selectTimedTaskPartyBuildingActivity();
        List<PartyBuildingActivityVO> partyBuildingActivityVOS = new ArrayList<>();
        if (!ObjectUtils.isEmpty(ids)) {
            List<ComPbActivityDO> comPbActivityDOS = comBpActivityDAO.selectBatchIds(ids);
            comPbActivityDOS.forEach(comPbActivityDO -> {
                PartyBuildingActivityVO partyBuildingActivityVO = new PartyBuildingActivityVO();
                BeanUtils.copyProperties(comPbActivityDO,partyBuildingActivityVO);
                List<Long> userIdS=comBpActivityDAO.selectTimedTaskPartyBuildingActivityUserids(comPbActivityDO.getId());
                partyBuildingActivityVO.setUserIds(userIdS);
                partyBuildingActivityVOS.add(partyBuildingActivityVO);
            });
            int i = comBpActivityDAO.updateBatchIds(ids);
            log.info("定时任务取消党建活动数量【{}】",i);
        }
        return R.ok(partyBuildingActivityVOS);
    }

    /**
     * 定时任务刷新党建活动的各个状态 除取消外
     *
     * @return 修改结果
     */
    @Override
    public R timedTaskPartyBuildingActivityAll() {
//        修改发布状态为未开始
        int num=comBpActivityDAO.updateStatusToNotBegin();
        log.info("定时任务修改党建活动--修改发布状态为未开始数量【{}】",num);
//        修改报名状态为报名中
        int num1=comBpActivityDAO.updateStatusToSign();
        log.info("定时任务修改党建活动--修改报名状态为报名中始数量【{}】",num1);
//        修改进行状态为进行中 或者已结束
        int num2=comBpActivityDAO.updateStatusToActiveOrEnd();
        log.info("定时任务修改党建活动--修改进行状态为进行中 或者已结束数量【{}】",num2);
        return R.ok();
    }

    public static void main(String[] args) {
        DateFormat formatTo = new SimpleDateFormat("M月d ahh:mm");
        String format = formatTo.format(new Date());
        System.out.println(format);
    }

}