花城 新增社区组织共建定时更新项目进度

lidongdong

2024-07-01 e399d500449886311e483e4028593165ea2361a8

花城 新增社区组织共建定时更新项目进度

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/partybuilding/NewStriveForFeign.java

@@ -541,6 +541,9 @@
    @PostMapping("/NeedProblem/timedNewFightNeedProblemInventoryHandler")
    public R timedNewFightNeedProblemInventoryHandler();

    @PostMapping("/NeedProblem/taskTimed/getListTime")
    public R taskTimedGetListTime();





 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/api/NewFightCommunityConstructionApi.java

@@ -193,7 +193,14 @@
    }





    /****************************************************************************************************************************************************
     *
     *              计时器
     *
     *****************************************************************************************************************************************/
    @PostMapping("/taskTimed/getListTime")
    public R getListTime()
    {
        return claimService.getListTime();
    }
}

 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/dao/NewFightCommunityConstructionDAO.java

@@ -8,6 +8,8 @@
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
 * @description: 党员双争双评排序
@@ -30,4 +32,10 @@

    int expurgateData(@Param("id") String id);

    List<NewFightCommunityConstructionDTO> getListTime();





}

 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/NewFightCommunityConstructionService.java

@@ -5,6 +5,8 @@
import com.panzhihua.common.model.dtos.partybuilding.NewFightCommunityConstructionDTO;
import com.panzhihua.common.model.vos.R;

import java.util.List;

/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
 * @description: 党组织
@@ -25,4 +27,7 @@

    R expurgateData(String id);


    R getListTime();

}

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

@@ -17,6 +17,8 @@
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
@@ -31,7 +33,6 @@

    @Resource
    private NewFightProjectPlanDAO projectPlanService;


    @Override
    public IPage<NewFightCommunityConstructionDTO> getList(int pageNum, int pageSize,
@@ -102,5 +103,47 @@
        return R.fail("操作失败");
    }

    @Override
    public R  getListTime()
    {
        List<NewFightCommunityConstructionDTO> list=baseMapper.getListTime();
        if(list==null || list.size()<=0 )
        {
            return R.ok();
        }

        for (NewFightCommunityConstructionDTO item:list) {

//            if(StringUtils.equals("1",item.getStatus()))
//            {
//                // 1 已发布
//
//
//
//            }
//            else if(StringUtils.equals("2",item.getStatus()))
//            {
//                // 1 进行中
//
//
//            }

            //预计完成时间
            Date estimatedTime = item.getEstimatedTime();
            if (estimatedTime!=null)
            {
                if(new Date().getTime()>estimatedTime.getTime())
                {
                    NewFightCommunityConstructionDTO dto=new NewFightCommunityConstructionDTO();
                    dto.setId(item.getId());
                    dto.setStatus("3");
                    baseMapper.editData(dto);
                }
            }
        }

        return R.ok();
    }


}

 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/resources/mapper/NewFightCommunityConstructionMapper.xml

@@ -201,5 +201,29 @@
    </delete>




    <select id="getListTime" resultType="com.panzhihua.common.model.dtos.partybuilding.NewFightCommunityConstructionDTO">
        SELECT
        nfcc.id,
        nfcc.item_cover,
        nfcc.item_title,
        nfcc.agreement_title,
        nfcc.agreement_customization_time,
        nfcc.agreement_content,
        nfcc.construction_community_id,
        nfcc.estimated_time,
        nfcc.creation_time,
        nfcc.update_time,
        nfcc.user_id,
        nfcc.status,
        nfcc.community_id
        FROM new_fight_community_construction as nfcc
        where nfcc.status in (1,2)
    </select>




</mapper>


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

@@ -50,5 +50,17 @@



    //定时任务  社区组织共建  定时更新项目进度
    @XxlJob("taskTimedGetListTimeHandler")
    public ReturnT<String> taskTimedGetListTimeHandler(String param) throws Exception
    {
        log.info("定时任务 社区组织共建 定时更新项目进度 ");
        R r = communityService.taskTimedGetListTime();
        log.info("执行结果【{}】", r.toString());
        ReturnT rt= new ReturnT<String>();
        rt.setCode(ReturnT.SUCCESS_CODE);
        rt.setContent("执行结果【{"+r.toString()+"}】");

        return rt;
    }
}