This commit is contained in:
zt
2025-03-25 18:27:39 +08:00
parent 1531913a43
commit 489300abe3
9 changed files with 79902 additions and 16 deletions

View File

@ -25,6 +25,7 @@ import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.constraints.NotNull;
import java.io.*;
import java.nio.charset.Charset;
import java.time.LocalDateTime;
@ -58,15 +59,22 @@ public class UploadZipController {
@ApiOperation("上传压缩文件")
@PostMapping("/upload-zip")
public AjaxResult<Void> uploadZipFile(@RequestParam("file") MultipartFile file, @RequestParam("recruitId") Long recruitId, @RequestParam("userId") Long userId) {
public AjaxResult<Void> uploadZipFile(@RequestParam("file") MultipartFile file
, @RequestParam("recruitId")@NotNull(message = "招工不能为空") Long recruitId
, @RequestParam("userId")@NotNull(message = "用户不能为空") Long userId) {
if (file.isEmpty()) {
throw new BaseException("上传的文件为空!");
}
String originalFilename = file.getOriginalFilename();
if (originalFilename == null || !originalFilename.toLowerCase().endsWith(".zip")) {
throw new BaseException("上传的文件不是有效的 ZIP 文件!");
}
String[] split = originalFilename.split("_");
if(split.length != 2 || !split[0].equals(recruitId.toString())){
throw new BaseException("文件名与所选择招工不匹配");
}
if(recruitService.queryById(recruitId) == null){
throw new BaseException("招工信息不存在!");
@ -104,7 +112,7 @@ public class UploadZipController {
asyncProcessRecordAndDeleteTemp(extractDir, zipFile, recruitId,username,userId);
return AjaxResult.success("文件上传并处理成功");
} catch (IOException e) {
} catch (Exception e) {
// 删除临时文件和文件夹
File extractDir = new File(TEMP_DIR, firstLevelFolderName);
deleteFolder(extractDir);
@ -204,6 +212,9 @@ public class UploadZipController {
String[] split = firstLevelFolderName.split("_");
String card = split[1];
WgzUser wgzUser = wgzUserService.findByIdentityCard(card);
if(wgzUser == null){
throw new BaseException("文件格式错误");
}
if (firstLevelFile.isDirectory()) {
File[] secondLevelFiles = firstLevelFile.listFiles();
if (secondLevelFiles != null) {

View File

@ -0,0 +1,108 @@
package com.ruoyi.web.controller.fbs;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.annotation.RepeatSubmit;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.zbf.bo.ZbfProjectSubcontractingQueryBo;
import com.ruoyi.zbf.domain.ZbfProjectSubcontracting;
import com.ruoyi.zbf.service.IZbfProjectSubcontractingService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.Arrays;
import java.util.List;
/**
* 总包方项目分包Controller
*
* @author ruoyi
* @date 2025-02-17
*/
@Api(value = "App分包商项目管理", tags = {"App分包商项目管理"})
@RequiredArgsConstructor(onConstructor_ = @Autowired)
@RestController
@RequestMapping("/fbs/subcontracting")
public class AppFbsProjectSubcontractingController extends BaseController {
private final IZbfProjectSubcontractingService iZbfProjectSubcontractingService;
/**
* 查询总包方项目分包列表
*/
@ApiOperation("查询总包方项目分包列表")
@GetMapping("/list")
public TableDataInfo<ZbfProjectSubcontracting> list(@Validated ZbfProjectSubcontractingQueryBo bo) {
return iZbfProjectSubcontractingService.queryPageList(bo);
}
/**
* 导出总包方项目分包列表
*/
@ApiOperation("导出总包方项目分包列表")
@PreAuthorize("@ss.hasPermi('common:subcontracting:export')")
@Log(title = "总包方项目分包", businessType = BusinessType.EXPORT)
@GetMapping("/export")
public AjaxResult<ZbfProjectSubcontracting> export(@Validated ZbfProjectSubcontractingQueryBo bo) {
List<ZbfProjectSubcontracting> list = iZbfProjectSubcontractingService.queryList(bo);
ExcelUtil<ZbfProjectSubcontracting> util = new ExcelUtil<ZbfProjectSubcontracting>(ZbfProjectSubcontracting.class);
return util.exportExcel(list, "总包方项目分包");
}
/**
* 获取总包方项目分包详细信息
*/
@ApiOperation("获取总包方项目分包详细信息")
@PreAuthorize("@ss.hasPermi('common:subcontracting:query')")
@GetMapping("/{id}")
public AjaxResult<ZbfProjectSubcontracting> getInfo(@NotNull(message = "主键不能为空")
@PathVariable("id") Long id) {
return AjaxResult.success(iZbfProjectSubcontractingService.queryById(id));
}
/**
* 新增总包方项目分包
*/
@ApiOperation("新增总包方项目分包")
@PreAuthorize("@ss.hasPermi('common:subcontracting:add')")
@Log(title = "总包方项目分包", businessType = BusinessType.INSERT)
@RepeatSubmit
@PostMapping()
public AjaxResult<Void> add(@Validated @RequestBody ZbfProjectSubcontracting bo) {
return toAjax(iZbfProjectSubcontractingService.insert(bo) ? 1 : 0);
}
/**
* 修改总包方项目分包
*/
@ApiOperation("修改总包方项目分包")
@PreAuthorize("@ss.hasPermi('common:subcontracting:edit')")
@Log(title = "总包方项目分包", businessType = BusinessType.UPDATE)
@RepeatSubmit
@PutMapping()
public AjaxResult<Void> edit(@Validated @RequestBody ZbfProjectSubcontracting bo) {
return toAjax(iZbfProjectSubcontractingService.update(bo) ? 1 : 0);
}
/**
* 删除总包方项目分包
*/
@ApiOperation("删除总包方项目分包")
@PreAuthorize("@ss.hasPermi('common:subcontracting:remove')")
@Log(title = "总包方项目分包" , businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] ids) {
return toAjax(iZbfProjectSubcontractingService.deleteWithValidByIds(Arrays.asList(ids), true) ? 1 : 0);
}
}

View File

@ -159,7 +159,7 @@ public class AnnexServiceImpl extends ServicePlusImpl<AnnexMapper, Annex> implem
@Override
public void deleteByUserIdAndRecruitIdAndType(List<Long> userIds, Long recruitId, String type) {
baseMapper.delete(Wrappers.<Annex>lambdaQuery().in(Annex::getUserId,userIds)
baseMapper.delete(Wrappers.<Annex>lambdaUpdate().in(Annex::getUserId,userIds)
.eq(Annex::getRecruitId,recruitId).eq(Annex::getAnnexType,type).eq(Annex::getUserType,WGZ));
}

View File

@ -80,7 +80,7 @@ public class BusinessTask
public void recruitRefuse()
{
Console.log("开始招工拒绝任务");
List<String> status = Arrays.asList(RecruitApplyStatus.SIGN_UP.getCode(), RecruitApplyStatus.BGT_PASS.getCode());
List<String> status = Arrays.asList(RecruitApplyStatus.SIGN_UP.getCode(), RecruitApplyStatus.BGT_PASS.getCode(), RecruitApplyStatus.WGZ_PASS.getCode());
List<BgtProjectRecruit> recruitList = recruitService.list(Wrappers.<BgtProjectRecruit>lambdaQuery()
.lt(BgtProjectRecruit::getRecruitEndTime, LocalDate.now()));
if(CollectionUtil.isNotEmpty(recruitList)){

View File

@ -3,7 +3,6 @@ package com.ruoyi.wgz.service.impl;
import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.bgt.domain.vo.BgtQuestionResult;
import com.ruoyi.common.core.mybatisplus.core.ServicePlusImpl;
@ -386,8 +385,8 @@ public class WgzQuestionSaveServiceImpl extends ServicePlusImpl<WgzQuestionSaveM
long time= 0L;
for (WgzQuestionSave wgzQuestionSave : savaList){
score += wgzQuestionSave.getScore();
if(wgzQuestionSave.getCorrect().equals("1")){
score += wgzQuestionSave.getScore();
successNum++;
}else{
errorNum++;

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

View File

@ -4,10 +4,7 @@
<meta charset="UTF-8" />
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
<title>文件上传管理系统</title>
<link
rel="stylesheet"
href="https://unpkg.com/element-plus/dist/index.css"
/>
<link rel="stylesheet" href="./index.css" />
<style>
.container {
display: flex;
@ -116,7 +113,7 @@
</div>
<!-- 右侧上传面板 -->
<div class="right-panel">
<div v-loading="uploadLoading" class="right-panel">
<h3 style="margin-bottom: 15px">文件上传区域</h3>
<el-upload
ref="uploadRef"
@ -145,6 +142,7 @@
class="submit-btn"
@click="submitUpload"
:disabled="!uploadFile"
:loading="uploadLoading"
>
确认上传
</el-button>
@ -152,8 +150,8 @@
</div>
</div>
</body>
<script src="https://unpkg.com/vue@3/dist/vue.global.js"></script>
<script src="https://unpkg.com/element-plus/dist/index.full.js"></script>
<script src="./vue.global.js"></script>
<script src="./index.full.js"></script>
<script>
const { createApp } = Vue;
@ -166,6 +164,7 @@
currentList: [],
userIds: [],
loading: false,
uploadLoading: false,
listStatusText: "请先选择主题",
userId: "",
checkAll: false,
@ -180,7 +179,7 @@
// 获取 URL 中的 userId 参数
const urlParams = new URLSearchParams(window.location.search);
this.userId = urlParams.get("userId");
console.log("userId", this.userId);
// console.log("userId", this.userId);
this.getRecruitList();
},
@ -257,12 +256,15 @@
// 提交上传
async submitUpload() {
if (!this.uploadFile) return;
if (this.themeOptions && this.themeOptions.length == 0) {
ElementPlus.ElMessage.error(`请先选择招工主题`);
return;
}
const formData = new FormData();
formData.append("file", this.uploadFile);
formData.append("recruitId", this.selectedTheme);
formData.append("userId", this.userId);
this.uploadLoading = true;
try {
const res = await this.ajaxRequest({
url: "/ruoyi/upload-zip",
@ -278,6 +280,8 @@
}
} catch (error) {
ElementPlus.ElMessage.error(`${error}`);
} finally {
this.uploadLoading = false;
}
},

File diff suppressed because it is too large Load Diff