This commit is contained in:
zt
2025-03-21 16:49:51 +08:00
parent fa37ceb800
commit da2b45f344
4 changed files with 26 additions and 15 deletions

View File

@ -48,4 +48,8 @@ public enum RecruitApplyStatus
return Arrays.asList(WORKING.getCode(), OUT_WORK.getCode());
}
//满员
public static List<String> getFull(){
return Arrays.asList(WORKING.getCode(), WGZ_PASS.getCode());
}
}

View File

@ -11,7 +11,6 @@ import com.ruoyi.wgz.bo.req.WgzAppUnderwayReq;
import com.ruoyi.wgz.bo.res.WgzAppUnderwayRes;
import com.ruoyi.wgz.bo.rests.WgzAppUserAllRecruitmentTwo;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
import java.util.Collection;
import java.util.List;
@ -141,7 +140,7 @@ public interface IBgtProjectRecruitApplyService extends IServicePlus<BgtProjectR
/**
* 评分
*/
Boolean score( @RequestBody BgtScoreDTO dto);
Boolean score( BgtScoreDTO dto);
/**
* 务工者取消报名

View File

@ -177,6 +177,13 @@ public class BgtProjectRecruitServiceImpl extends ServicePlusImpl<BgtProjectRecr
userDTO.setStatus(0);
}
TableDataInfo<BgtProjectRecruitApplyVO> page = bgtProjectRecruitApplyService.recruitApplyList(userDTO);
int count = bgtProjectRecruitApplyService.count(Wrappers.<BgtProjectRecruitApply>lambdaQuery()
.eq(BgtProjectRecruitApply::getRecruitId, vo.getId())
.in(BgtProjectRecruitApply::getStatus, RecruitApplyStatus.getFull()));
if(count == vo.getRecruitStaffNum()){
vo.setStatus(RecruitStatus.FULL.getCode());
}
vo.setApplyList(page.getRows());
}
return PageUtils.buildDataInfo(queryVOPage);

View File

@ -5,6 +5,7 @@ import cn.hutool.core.lang.Console;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.bgt.domain.BgtProjectRecruit;
import com.ruoyi.bgt.domain.BgtProjectRecruitApply;
import com.ruoyi.bgt.domain.dto.BgtScoreDTO;
import com.ruoyi.bgt.service.IBgtProjectRecruitApplyService;
import com.ruoyi.bgt.service.IBgtProjectRecruitService;
import com.ruoyi.common.constants.WgzAndBgtMessageConstant;
@ -24,6 +25,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
@ -123,6 +125,9 @@ public class BusinessTask
//任务下的招工
List<BgtProjectRecruit> recruitList = recruitService.list(Wrappers.<BgtProjectRecruit>lambdaQuery()
.in(BgtProjectRecruit::getTaskId, taskIds));
Map<Long, Long> map = recruitList.stream().collect(Collectors.toMap(BgtProjectRecruit::getId, BgtProjectRecruit::getUserId));
List<Long> recruitIds = recruitList.stream().map(BgtProjectRecruit::getId).collect(Collectors.toList());
if(CollectionUtil.isNotEmpty(recruitIds)){
//招工下的人员
@ -130,25 +135,21 @@ public class BusinessTask
.in(BgtProjectRecruitApply::getRecruitId, recruitIds));
//筛选已离场的
List<BgtProjectRecruitApply> outList = applyList.stream().filter(apply -> apply.getStatus().equals(RecruitApplyStatus.OUT_WORK.getCode())).collect(Collectors.toList());
List<WgzScoreRecord> addList = new ArrayList<>();
for (BgtProjectRecruitApply bgtProjectRecruitApply : outList) {
WgzScoreRecord byUserIdAndRecruitApplyId = wgzScoreRecordService.getByUserIdAndRecruitApplyId(bgtProjectRecruitApply.getUserId(), bgtProjectRecruitApply.getId());
if (byUserIdAndRecruitApplyId == null) {
WgzScoreRecord wgzScoreRecord = new WgzScoreRecord();
wgzScoreRecord.setRecruitId(bgtProjectRecruitApply.getRecruitId());
wgzScoreRecord.setRecruitApplyId(bgtProjectRecruitApply.getId());
wgzScoreRecord.setScore(5D);
wgzScoreRecord.setContent("默认评分");
wgzScoreRecord.setCreateBy("系统");
wgzScoreRecord.setUpdateBy("系统");
addList.add(wgzScoreRecord);
BgtScoreDTO bgtScoreDTO = new BgtScoreDTO();
bgtScoreDTO.setScore(new BigDecimal(5));
bgtScoreDTO.setRecruitId(bgtProjectRecruitApply.getRecruitId());
bgtScoreDTO.setRecruitApplyId(bgtProjectRecruitApply.getId());
bgtScoreDTO.setUserId(bgtProjectRecruitApply.getUserId());
bgtScoreDTO.setScoreBy(map.get(bgtProjectRecruitApply.getRecruitId()));
bgtScoreDTO.setContent("默认评分");
iBgtProjectRecruitApplyService.score(bgtScoreDTO);
}
}
if(CollectionUtil.isNotEmpty(addList)){
wgzScoreRecordService.saveBatch(addList);
}
}
}
Console.log("务工评价任务结束!");