easydo-zcgx/src/main/java/com/qdport/controller/PolicyProgressController.java

package com.qdport.controller;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.qdport.core.boot.ctrl.QdportController;
import com.qdport.core.tool.api.R;
import com.qdport.entity.PolicyShare;
import com.qdport.modules.system.entity.SysDept;
import com.qdport.modules.system.service.SysDeptService;
import com.qdport.query.PolicyProgressQuery;
import com.qdport.query.QueryWrapperBuilder;
import com.qdport.service.PolicyShareService;
import com.qdport.service.PolicyStriveService;
import com.qdport.util.StringUtil;
import com.qdport.vo.PolicyProgressVo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.BeanUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.ArrayList;
import java.util.List;

@RestController
@RequestMapping("qdport-zcgx/progress")
@Api(value = "进度管理", tags = "进度管理")
public class PolicyProgressController extends QdportController {
    @Resource
    private PolicyShareService policyShareService;
    @Resource
    private SysDeptService sysDeptService;

    @GetMapping("sharePage")
    @ApiOperation(value = "分页", notes = "分页")
    public R<IPage> page(@Valid PolicyProgressQuery query) {
        IPage<SysDept> deptPage = new Page<>(query.getPage(), query.getSize());
        QueryWrapper<SysDept> wrapper = QueryWrapperBuilder.buildQueryWrapper(query, SysDept.class);
        if (StringUtil.isEmpty(query.getBeginCreateTime()) || StringUtil.isEmpty(query.getEndCreateTime())) {
            throw new RuntimeException("参数错误");
        }

        deptPage = sysDeptService.page(deptPage, wrapper);
        List<SysDept> records = deptPage.getRecords();

        IPage<PolicyProgressVo> page = new Page<>(query.getPage(), query.getSize());
        page.setTotal(deptPage.getTotal());
        List<PolicyProgressVo> progressVoList = new ArrayList<>();
        for (SysDept model : records) {
            PolicyProgressVo vo = new PolicyProgressVo();
            BeanUtils.copyProperties(model, vo);

            QueryWrapper<PolicyShare> policyShareWrapper = new QueryWrapper<>();
            policyShareWrapper.eq("COMPANY_ID", model.getId());
            policyShareWrapper.lt("CREATE_TIME", query.getEndCreateTime());
            policyShareWrapper.gt("CREATE_TIME", query.getBeginCreateTime());
            long count = policyShareService.count(policyShareWrapper);
            vo.setCount(count);

//            if (count == 1) {
//                PolicyShare shareOne = policyShareService.getOne(policyShareWrapper);
//
//            }


            progressVoList.add(vo);
        }
        return null;
    }

    @GetMapping("strivePage")
    @ApiOperation(value = "分页", notes = "分页")
    public R<IPage> strivePage(@Valid PolicyProgressQuery query) {


        return null;
    }
}