package com.terra.system.controller.show;
|
|
import com.terra.common.annotation.SysLog;
|
import com.terra.common.controller.all.BaseController;
|
import com.terra.common.entity.all.HttpStatus;
|
import com.terra.common.entity.all.ResponseMsg;
|
import com.terra.common.entity.all.StaticData;
|
import com.terra.system.entity.ctrl.DownloadReqEntity;
|
import com.terra.system.entity.data.DownloadEntity;
|
import com.terra.system.entity.show.ApplyEntity;
|
import com.terra.system.entity.show.FlowEntity;
|
import com.terra.system.entity.sys.UserEntity;
|
import com.terra.system.helper.AesHelper;
|
import com.terra.common.helper.StringHelper;
|
import com.terra.common.helper.WebHelper;
|
import com.terra.system.service.data.DownloadService;
|
import com.terra.system.service.show.ApplyService;
|
import com.terra.system.service.show.FlowService;
|
import com.terra.system.service.sys.DownlogService;
|
import com.terra.system.service.sys.TokenService;
|
import com.terra.system.service.sys.UserService;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.Parameters;
|
import javax.annotation.Resource;
|
|
import io.swagger.v3.oas.annotations.enums.ParameterIn;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import org.springframework.web.bind.annotation.*;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.sql.Timestamp;
|
import java.util.List;
|
|
/**
|
* 数据申请
|
* @author WWW
|
*/
|
@Tag(name = "综合展示\\数据申请")
|
@RestController
|
@RequestMapping("/apply")
|
public class ApplyController extends BaseController {
|
@Resource
|
ApplyService applyService;
|
|
@Resource
|
FlowService flowService;
|
|
@Resource
|
TokenService tokenService;
|
|
@Resource
|
UserService userService;
|
|
@Resource
|
DownlogService downlogService;
|
|
@Resource
|
DownloadService downloadService;
|
|
@SysLog()
|
@Operation(summary = "插入数据申请")
|
@Parameters({
|
@Parameter(name = "dr", description = "请求下载实体")
|
})
|
@ResponseBody
|
@PostMapping(value = "/insertApply")
|
public ResponseMsg<Object> insertApply(@RequestBody DownloadReqEntity dr, HttpServletRequest req) {
|
try {
|
if (null == dr || null == dr.getEntities() || dr.getEntities().isEmpty()) {
|
return fail("请选择要下载的实体名");
|
}
|
if (StringHelper.isEmpty(dr.getPwd())) {
|
return fail("密码不能为空");
|
}
|
dr.setPwd(AesHelper.decrypt(dr.getPwd()));
|
if (StringHelper.isPwdInvalid(dr.getPwd())) {
|
return fail("密码不符合要求");
|
}
|
if (!StringHelper.isEmpty(dr.getWkt())) {
|
dr.setWkt(AesHelper.decrypt(dr.getWkt()));
|
}
|
if (null == dr.getTabs() || dr.getTabs().isEmpty()) {
|
return fail("请选择要下载的表名");
|
}
|
if (null == dr.getDepcodes() || dr.getDepcodes().isEmpty()) {
|
return fail("请选择待申请的单位编码(多个以逗号隔开)");
|
}
|
|
UserEntity ue = tokenService.getCurrentUser(req);
|
int rows = applyService.insertApply(ue, dr);
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "分页查询申请")
|
@Parameters({
|
@Parameter(name = "uname", description = "用户名", in = ParameterIn.QUERY, example = "员"),
|
@Parameter(name = "status", description = "状态", in = ParameterIn.QUERY, example = "0"),
|
@Parameter(name = "start", description = "开始时间", in = ParameterIn.QUERY, example = "2022-12-09 09:00:00"),
|
@Parameter(name = "end", description = "结束时间", in = ParameterIn.QUERY, example = "2022-12-31 23:00:00"),
|
@Parameter(name = "pageSize", description = "每页条数", in = ParameterIn.QUERY, example = "10"),
|
@Parameter(name = "pageIndex", description = "分页数（从1开始）", in = ParameterIn.QUERY, example = "1")
|
})
|
@GetMapping(value = "/selectByPage")
|
public ResponseMsg<Object> selectByPage(String uname, Integer status, Timestamp start, Timestamp end, Integer pageSize, Integer pageIndex, HttpServletRequest req) {
|
try {
|
if (pageSize < 1 || pageIndex < 1) {
|
return fail("每页页数或分页数小于1", null);
|
}
|
|
int count = applyService.selectCount(uname, status, start, end);
|
if (count == 0) {
|
return success(0, null);
|
}
|
|
UserEntity ue = tokenService.getCurrentUser(req);
|
List<ApplyEntity> rs = applyService.selectByPage(ue.getId(), uname, status, start, end, pageSize, pageSize * (pageIndex - 1));
|
|
return success(count, rs);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "查询待审核数")
|
@GetMapping(value = "/selectSubmits")
|
public ResponseMsg<Object> selectSubmits(HttpServletRequest req) {
|
try {
|
UserEntity ue = tokenService.getCurrentUser(req);
|
int rows = applyService.selectSubmits(ue.getId());
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "查询流程")
|
@Parameters({
|
@Parameter(name = "applyid", description = "数据申请ID", in = ParameterIn.QUERY, example = "1")
|
})
|
@GetMapping(value = "/selectFlows")
|
public ResponseMsg<Object> selectFlows(Integer applyid) {
|
try {
|
List<FlowEntity> rs = applyService.selectFlows(applyid);
|
|
return success(rs);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "废弃申请")
|
@Parameters({
|
@Parameter(name = "applyid", description = "数据申请ID", in = ParameterIn.QUERY, example = "1")
|
})
|
@GetMapping(value = "/updateForDiscard")
|
public ResponseMsg<Object> updateForDiscard(Integer applyid, HttpServletRequest req) {
|
try {
|
ApplyEntity applyEntity = applyService.selectById(applyid);
|
if (null == applyEntity) {
|
return fail("找不到数据申请");
|
}
|
if (!(applyEntity.getStatus() >= -1 && applyEntity.getStatus() <= StaticData.NINE)) {
|
return fail("该数据申请无法废弃");
|
}
|
|
UserEntity ue = tokenService.getCurrentUser(req);
|
int rows = applyService.updateForDiscard(ue.getId(), applyid);
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "重新提交")
|
@Parameters({
|
@Parameter(name = "applyid", description = "数据申请ID", in = ParameterIn.QUERY, example = "1")
|
})
|
@GetMapping(value = "/updateForResubmit")
|
public ResponseMsg<Object> updateForResubmit(Integer applyid, HttpServletRequest req) {
|
try {
|
ApplyEntity applyEntity = applyService.selectById(applyid);
|
if (null == applyEntity) {
|
return fail("找不到数据申请");
|
}
|
if (-1 != applyEntity.getStatus()) {
|
return fail("该数据申请无需重新提交");
|
}
|
|
UserEntity ue = tokenService.getCurrentUser(req);
|
int rows = applyService.updateForResubmit(ue.getId(), applyid);
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "提交流程")
|
@Parameters({
|
@Parameter(name = "flowId", description = "申请流程ID", in = ParameterIn.QUERY, example = "1")
|
})
|
@GetMapping(value = "/updateForSubmit")
|
public ResponseMsg<Object> updateForSubmit(Integer flowId, HttpServletRequest req) {
|
try {
|
FlowEntity flowEntity = flowService.selectById(flowId);
|
if (null == flowEntity) {
|
return fail("找不到申请流程");
|
}
|
if (flowEntity.getStatus() != 0) {
|
return fail("该申请流程无需提交");
|
}
|
|
ApplyEntity applyEntity = applyService.selectById(flowEntity.getApplyid());
|
if (null == applyEntity) {
|
return fail("找不到数据申请");
|
}
|
if (!(applyEntity.getStatus() >= 0 && applyEntity.getStatus() <= StaticData.NINE)) {
|
return fail("该数据申请无需打回");
|
}
|
|
UserEntity ue = tokenService.getCurrentUser(req);
|
int rows = applyService.updateForSubmit(ue.getId(), applyEntity.getId(), flowEntity.getId());
|
|
applyEntity = applyService.selectById(applyEntity.getId());
|
if (StaticData.I10 == applyEntity.getStatus()) {
|
UserEntity user = userService.selectUser(applyEntity.getUserid());
|
applyService.zipDbData(user, applyEntity);
|
}
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "打回流程")
|
@Parameters({
|
@Parameter(name = "flowId", description = "申请流程ID", in = ParameterIn.QUERY, example = "1")
|
})
|
@GetMapping(value = "/updateForReject")
|
public ResponseMsg<Object> updateForReject(Integer flowId, HttpServletRequest req) {
|
try {
|
FlowEntity flowEntity = flowService.selectById(flowId);
|
if (null == flowEntity) {
|
return fail("找不到申请流程");
|
}
|
if (flowEntity.getStatus() != 0) {
|
return fail("该申请流程无需打回");
|
}
|
|
ApplyEntity applyEntity = applyService.selectById(flowEntity.getApplyid());
|
if (null == applyEntity) {
|
return fail("找不到数据申请");
|
}
|
if (!(applyEntity.getStatus() >= 0 && applyEntity.getStatus() <= StaticData.NINE)) {
|
return fail("该数据申请无需打回");
|
}
|
|
UserEntity ue = tokenService.getCurrentUser(req);
|
Integer rows = applyService.updateForReject(ue.getId(), applyEntity.getId(), flowEntity.getId());
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, null);
|
}
|
}
|
|
@SysLog()
|
@Operation(summary = "下载文件")
|
@Parameters({
|
@Parameter(name = "guid", description = "文件GUID", in = ParameterIn.QUERY)
|
})
|
@ResponseBody
|
@GetMapping(value = "/downloadFile")
|
public void downloadFile(String guid, HttpServletRequest req, HttpServletResponse res) {
|
try {
|
DownloadEntity de = downloadService.selectByGuid(guid);
|
if (null == de) {
|
WebHelper.writeInfo(HttpStatus.NOT_FOUND, "文件不存在", res);
|
return;
|
}
|
|
UserEntity ue = tokenService.getCurrentUser(req);
|
downlogService.updateInfos(ue, de, req);
|
|
String filePath = downloadService.getDownloadFilePath(de);
|
WebHelper.download(filePath, de.getName(), res);
|
} catch (Exception ex) {
|
WebHelper.writeInfo(HttpStatus.ERROR, ex.getMessage(), res);
|
}
|
}
|
}
|
