任务模块编写

duhanyu
dongdingding 5 months ago
parent 7c4eff528e
commit 0c71be162a

@ -6,6 +6,7 @@ import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.tc.entity.AssetCurrent; import com.ruoyi.tc.entity.AssetCurrent;
import com.ruoyi.tc.entity.AssetTask; import com.ruoyi.tc.entity.AssetTask;
import com.ruoyi.tc.entity.request.AssestTaskXqRequest; import com.ruoyi.tc.entity.request.AssestTaskXqRequest;
import com.ruoyi.tc.entity.request.AssetCurrentShRequest;
import com.ruoyi.tc.entity.request.AssetTaskPageRequest; import com.ruoyi.tc.entity.request.AssetTaskPageRequest;
import com.ruoyi.tc.entity.response.*; import com.ruoyi.tc.entity.response.*;
import com.ruoyi.tc.service.*; import com.ruoyi.tc.service.*;
@ -154,12 +155,19 @@ public class AssetTaskController extends BaseController {
@PostMapping("/zc") @PostMapping("/zc")
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public AjaxResult zcHc(@RequestBody AssetCurrentResponse assetCurrent) { public AjaxResult zcHc(@RequestBody AssetCurrentResponse assetCurrent) {
//根据资产id和任务id删除五张表数据 // //根据资产id和任务id删除五张表数据
assetCurrentCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId()); // assetCurrentCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId());
assetBusinessFormCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId()); // assetBusinessFormCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId());
assetSupplyChainCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId()); // assetSupplyChainCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId());
unitOtherConcatCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId()); // unitOtherConcatCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId());
assetBasicNetworkCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId()); // assetBasicNetworkCpService.deletByAssetIdandTaskId(assetCurrent.getId(), assetCurrent.getTaskId());
if(assetCurrent.getBfyy().isEmpty()) {
//待审批
assetCurrent.setStatus(1);
}else{
//已报废
assetCurrent.setStatus(5);
}
assetCurrent.setGlym(String.join(",", assetCurrent.getGlymList())); assetCurrent.setGlym(String.join(",", assetCurrent.getGlymList()));
assetCurrent.setGlIp(String.join(",", assetCurrent.getGlIpList())); assetCurrent.setGlIp(String.join(",", assetCurrent.getGlIpList()));
assetCurrentCpService.save(assetCurrent); assetCurrentCpService.save(assetCurrent);
@ -211,13 +219,21 @@ public class AssetTaskController extends BaseController {
} }
/**
*
*
* @param req
* @return
*/
@ApiOperation(value = "管理端审核") @ApiOperation(value = "管理端审核")
@PostMapping("/sh") @PostMapping("/sh")
public AjaxResult sh(@RequestBody AssetCurrentResponse assetCurrent) { public AjaxResult sh(@RequestBody AssetCurrentShRequest req) {
return AjaxResult.success(assetTaskService.sh(req));
}
return AjaxResult.success();
}
} }

@ -0,0 +1,38 @@
package com.ruoyi.tc.entity.request;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author dong
* @since 2024/11/20 16:29
*/
@Data
@ApiModel("管理端审核请求类")
public class AssetCurrentShRequest {
/**
* id
*/
@ApiModelProperty("任务id")
private Integer taskId;
/**
* id
*/
@ApiModelProperty("资产id")
private Integer assetId;
/**
* 01345
*/
@ApiModelProperty("审核状态0待核查1待审批3审核通过4审核不通过5已报废")
private Integer status;
}

@ -934,6 +934,6 @@ public class AssetCurrentResponse extends BaseClass implements Serializable {
@ApiModelProperty("报废原因") @ApiModelProperty("报废原因")
private String bfyy; private String bfyy;
@ApiModelProperty("审核状态0待核查1待审3审核通过4审核不通过5审核不通过") @ApiModelProperty("审核状态0待核查1待审3审核通过4审核不通过5已报废")
private String status; private Integer status;
} }

@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.tc.entity.AssetTask; import com.ruoyi.tc.entity.AssetTask;
import com.ruoyi.tc.entity.request.AssestTaskXqRequest; import com.ruoyi.tc.entity.request.AssestTaskXqRequest;
import com.ruoyi.tc.entity.request.AssetCurrentShRequest;
import com.ruoyi.tc.entity.request.AssetTaskPageRequest; import com.ruoyi.tc.entity.request.AssetTaskPageRequest;
import com.ruoyi.tc.entity.response.AssestTaskXqresponse; import com.ruoyi.tc.entity.response.AssestTaskXqresponse;
import com.ruoyi.tc.entity.response.AssetCurrentResponse; import com.ruoyi.tc.entity.response.AssetCurrentResponse;
@ -125,5 +126,15 @@ public interface AssetTaskMapper extends BaseMapper<AssetTask> {
* @return * @return
*/ */
AssetCurrentResponse findBytaskIdandAssestId(@Param("taskId") int taskId, @Param("assetId") int assetId); AssetCurrentResponse findBytaskIdandAssestId(@Param("taskId") int taskId, @Param("assetId") int assetId);
/**
*
*
* @param req
* @return
*/
int sh(@Param("req") AssetCurrentShRequest req);
} }

@ -1,18 +1,14 @@
package com.ruoyi.tc.service; package com.ruoyi.tc.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.tc.entity.AssetCurrent;
import com.ruoyi.tc.entity.AssetTask; import com.ruoyi.tc.entity.AssetTask;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.tc.entity.request.AssestTaskXqRequest; import com.ruoyi.tc.entity.request.AssestTaskXqRequest;
import com.ruoyi.tc.entity.request.AssetCurrentShRequest;
import com.ruoyi.tc.entity.request.AssetTaskPageRequest; import com.ruoyi.tc.entity.request.AssetTaskPageRequest;
import com.ruoyi.tc.entity.response.AssestTaskXqresponse; import com.ruoyi.tc.entity.response.AssestTaskXqresponse;
import com.ruoyi.tc.entity.response.AssetCurrentResponse; import com.ruoyi.tc.entity.response.AssetCurrentResponse;
import com.ruoyi.tc.entity.response.AssetTaskIdResponse;
import com.ruoyi.tc.entity.response.AssetTaskResponse; import com.ruoyi.tc.entity.response.AssetTaskResponse;
import org.springframework.data.domain.PageRequest;
import java.util.List;
/** /**
* (AssetTask) * (AssetTask)
@ -81,4 +77,13 @@ public interface AssetTaskService extends IService<AssetTask> {
* @return * @return
*/ */
Page<AssestTaskXqresponse> zcHc(Page<AssestTaskXqresponse> page, AssestTaskXqRequest pageRequest); Page<AssestTaskXqresponse> zcHc(Page<AssestTaskXqresponse> page, AssestTaskXqRequest pageRequest);
/**
*
*
* @param req
* @return
*/
int sh(AssetCurrentShRequest req);
} }

@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.tc.entity.*; import com.ruoyi.tc.entity.*;
import com.ruoyi.tc.entity.request.AssestTaskXqRequest; import com.ruoyi.tc.entity.request.AssestTaskXqRequest;
import com.ruoyi.tc.entity.request.AssetCurrentShRequest;
import com.ruoyi.tc.entity.request.AssetTaskPageRequest; import com.ruoyi.tc.entity.request.AssetTaskPageRequest;
import com.ruoyi.tc.entity.response.*; import com.ruoyi.tc.entity.response.*;
import com.ruoyi.tc.mapper.AssetTaskMapper; import com.ruoyi.tc.mapper.AssetTaskMapper;
@ -174,4 +175,10 @@ public class AssetTaskServiceImpl extends ServiceImpl<AssetTaskMapper, AssetTask
public Page<AssestTaskXqresponse> zcHc(Page<AssestTaskXqresponse> assetTask, AssestTaskXqRequest pageRequest) { public Page<AssestTaskXqresponse> zcHc(Page<AssestTaskXqresponse> assetTask, AssestTaskXqRequest pageRequest) {
return assetTaskDao.zcHc(assetTask,pageRequest); return assetTaskDao.zcHc(assetTask,pageRequest);
} }
@Override
public int sh(AssetCurrentShRequest req) {
return assetTaskDao.sh(req);
}
} }

@ -223,7 +223,10 @@
</where> </where>
</select> </select>
<select id="findBytaskIdandAssestId" resultType="com.ruoyi.tc.entity.response.AssetCurrentResponse"> <select id="findBytaskIdandAssestId" resultType="com.ruoyi.tc.entity.response.AssetCurrentResponse">
select * from asset_current_cp where task_id =#{taskId} and id =#{assetId} select *
from asset_current_cp
where task_id = #{taskId}
and id = #{assetId}
</select> </select>
<!--新增所有列--> <!--新增所有列-->
@ -317,6 +320,20 @@
</set> </set>
where id = #{id} where id = #{id}
</update> </update>
<update id="sh" parameterType="com.ruoyi.tc.entity.request.AssetCurrentShRequest">
update asset_current_cp
<set>
<if test="req.taskId != null ">
task_id = #{req.taskId},
</if>
<if test="req.assetId != null ">
id = #{req.assetId},
</if>
<if test="req.status != null ">
status = #{req.status},
</if>
</set>
</update>
<!--通过主键删除--> <!--通过主键删除-->
<delete id="deleteById"> <delete id="deleteById">

Loading…
Cancel
Save