package com.chinaztt.mes.quality.controller;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.chinaztt.mes.common.wrapper.QueryWrapperUtil;
import com.chinaztt.mes.quality.dto.UnqualifiedProcessDTO;
import com.chinaztt.mes.quality.entity.UnqualifiedProcess;
import com.chinaztt.mes.quality.service.UnqualifiedProcessService;
import com.chinaztt.ztt.common.core.util.R;
import com.chinaztt.ztt.common.log.annotation.SysLog;
import com.chinaztt.ztt.common.security.annotation.Inner;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
import javax.validation.constraints.NotEmpty;
import java.util.List;


/**
 * 不合格处理表
 *
 * @author cxf
 * @date 2021-04-16 13:15:30
 */
@Validated
@RestController
@AllArgsConstructor
@RequestMapping("/unqualifiedProcess")
@Api(value = "unqualifiedProcess", tags = "不合格处理表管理")
public class UnqualifiedProcessController {

	private final UnqualifiedProcessService unqualifiedProcessService;

	/**
	 * 分页查询
	 *
	 * @param page                  分页对象
	 * @param unqualifiedProcessDTO 不合格处理表
	 * @return
	 */
	@ApiOperation(value = "分页查询", notes = "分页查询")
	@GetMapping("/page")
	public R getUnqualifiedProcessPage(Page page, UnqualifiedProcessDTO unqualifiedProcessDTO) {
		return R.ok(unqualifiedProcessService.getPage(page, QueryWrapperUtil.gen(unqualifiedProcessDTO)));
	}

	/**
	 * 通过id查询不合格处理表
	 *
	 * @param id id
	 * @return R
	 */
	@ApiOperation(value = "通过id查询", notes = "通过id查询")
	@GetMapping("/{id}")
	public R getById(@PathVariable("id") Long id) {
		return R.ok(unqualifiedProcessService.getById(id));
	}

	/**
	 * 发起OA流程
	 *
	 * @param id
	 * @return
	 */
	@GetMapping("/startOa/{id}")
	public R startOa(@PathVariable Long id) {
		return unqualifiedProcessService.startOa(id);
	}


	/**
	 * 新增不合格处理表
	 *
	 * @param unqualifiedProcessDTOList 不合格处理表
	 * @return R
	 */
	@ApiOperation(value = "新增不合格处理表", notes = "新增不合格处理表")
	@SysLog("新增不合格处理表")
	@PostMapping
	public R save(@RequestBody List<UnqualifiedProcessDTO> unqualifiedProcessDTOList) {
		return R.ok(unqualifiedProcessService.saveDto(unqualifiedProcessDTOList));
	}

	/**
	 * 修改不合格处理表
	 *
	 * @param unqualifiedProcessDTO 不合格处理表
	 * @return R
	 */
	@ApiOperation(value = "修改不合格处理表", notes = "修改不合格处理表")
	@SysLog("修改不合格处理表")
	@PutMapping
	public R updateById(@RequestBody UnqualifiedProcessDTO unqualifiedProcessDTO) {
		return R.ok(unqualifiedProcessService.updateById(unqualifiedProcessDTO));
	}

	@ApiOperation(value = "批量修改不合格处理表", notes = "批量修改不合格处理表")
	@SysLog("批量修改不合格处理表")
	@PutMapping("/updateBatch")
	public R updateBatch(@RequestBody List<UnqualifiedProcess> unqualifiedProcessList){
		return R.ok(unqualifiedProcessService.updateBatchById(unqualifiedProcessList));
	}

	/**
	 * 通过id删除不合格处理表
	 *
	 * @param id id
	 * @return R
	 */
	@ApiOperation(value = "通过id删除不合格处理表", notes = "通过id删除不合格处理表")
	@SysLog("通过id删除不合格处理表")
	@DeleteMapping("/{id}")
	public R removeById(@PathVariable Long id) throws Exception {
		return R.ok(unqualifiedProcessService.deleteById(id));
	}

	@ApiOperation(value = "发起射频oa流程")
	@PostMapping("/rfOa")
	public R rfOa(Long id) {
		return this.unqualifiedProcessService.rfOa(id);
	}

	/**
	 * 上传附件
	 * @param file 附件
	 * @param processId 不合格处理表id
	 * @return
	 */
	@ApiOperation(value = "上传附件", notes = "上传附件")
	@SysLog("上传附件" )
	@PostMapping("/upload")
	public R upload(@RequestParam("mainProcessNo") String mainProcessNo, @RequestParam("file") MultipartFile file) throws Exception {
		return R.ok(unqualifiedProcessService.uploadFile(mainProcessNo, file));
	}

	/**
	 * 获取文件
	 *
	 * @param bucket   桶名称
	 * @param fileName 文件空间/名称
	 * @param response
	 * @return
	 */
	@Inner(false)
	@GetMapping("/{bucket}/{fileName}")
	public void file(@PathVariable String bucket, @PathVariable String fileName, HttpServletResponse response) {
		this.unqualifiedProcessService.getFile(bucket, fileName, response);
	}

	/**
	 *
	 * @param ids
	 * @return
	 */
	@PostMapping("/executeByIds")
	public R executeByIds(@NotEmpty @RequestBody List<UnqualifiedProcessDTO> unqualifiedProcessDTOList) {
		this.unqualifiedProcessService.executeByIds(unqualifiedProcessDTOList);
		return R.ok("执行成功");
	}

	/**
	 * 更新处理结果
	 * @param id
	 * @param processResult
	 * @return
	 */
	@ApiOperation(value = "更新处理结果", notes = "更新处理结果")
	@PostMapping("/updateProcessResult")
	public R updateProcessResult(Long id, String processResult) {
		return R.ok(this.unqualifiedProcessService.updateProcessResult(id, processResult));
	}


	/**
	 * 零件降级功能
	 * @param id
	 * @return
	 */
	@ApiOperation(value = "零件降级功能", notes = "零件降级功能")
	@GetMapping("/partDegrade")
	public R partDegrade(@RequestParam("id") Long id,@RequestParam("partId") Long partId) {
		unqualifiedProcessService.partDegrade(id,partId);
		return R.ok();
	}




	/**
	 * 审批
	 * @param
	 * @return
	 */
	@ApiOperation(value = "审批", notes = "审批")
	@PostMapping("/examineApprove")
	public R examineApprove(@RequestBody UnqualifiedProcessDTO unqualifiedProcessDTO) {
		return R.ok(unqualifiedProcessService.examineApprove(unqualifiedProcessDTO));
	}




	/**
	 * 展示默认库位
	 * @param ids
	 * @return
	 */
	@ApiOperation(value = "展示默认库位", notes = "展示默认库位")
	@PostMapping("/showDefaultLocation")
	public R showDefaultLocation(@RequestBody List<Long> ids) {
		return R.ok(unqualifiedProcessService.showDefaultLocation(ids));
	}






}