package com.doumee.cloud.admin; 
 | 
  
 | 
import com.doumee.api.BaseController; 
 | 
import com.doumee.config.annotation.CloudRequiredPermission; 
 | 
import com.doumee.config.annotation.LoginNoRequired; 
 | 
import com.doumee.core.annotation.excel.ExcelExporter; 
 | 
import com.doumee.core.annotation.pr.PreventRepeat; 
 | 
import com.doumee.dao.business.vo.PlatformJobExportVo; 
 | 
import com.doumee.service.business.third.model.ApiResponse; 
 | 
import com.doumee.service.business.third.model.PageData; 
 | 
import com.doumee.service.business.third.model.PageWrap; 
 | 
import com.doumee.core.utils.Constants; 
 | 
import com.doumee.dao.business.model.PlatformJob; 
 | 
import com.doumee.dao.web.reqeust.JobDetailDTO; 
 | 
import com.doumee.dao.web.reqeust.SignInDTO; 
 | 
import com.doumee.service.business.PlatformJobService; 
 | 
import com.doumee.service.business.third.WmsService; 
 | 
import com.github.xiaoymin.knife4j.core.util.CollectionUtils; 
 | 
import com.mchange.v2.beans.BeansUtils; 
 | 
import io.swagger.annotations.Api; 
 | 
import io.swagger.annotations.ApiOperation; 
 | 
import org.springframework.beans.BeanUtils; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.web.bind.annotation.*; 
 | 
  
 | 
import javax.servlet.http.HttpServletResponse; 
 | 
import java.util.ArrayList; 
 | 
import java.util.List; 
 | 
  
 | 
/** 
 | 
 * @author 江蹄蹄 
 | 
 * @since 2024/04/28 16:06 
 | 
 */ 
 | 
@Api(tags = "月台调度作业信息表") 
 | 
@RestController 
 | 
@RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/business/platformJob") 
 | 
public class PlatformJobCloudController extends BaseController { 
 | 
  
 | 
    @Autowired 
 | 
    private PlatformJobService platformJobService; 
 | 
    @Autowired 
 | 
    private WmsService wmsService; 
 | 
  
 | 
    @PreventRepeat 
 | 
    @ApiOperation("新建") 
 | 
    @PostMapping("/create") 
 | 
    @CloudRequiredPermission("business:platformjob:create") 
 | 
    public ApiResponse create(@RequestBody PlatformJob platformJob,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        return ApiResponse.success(platformJobService.create(platformJob)); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("根据ID删除") 
 | 
    @GetMapping("/delete/{id}") 
 | 
    @CloudRequiredPermission("business:platformjob:delete") 
 | 
    public ApiResponse deleteById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        platformJobService.delete(id); 
 | 
        return ApiResponse.success(null); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("获取当前用户的最近一条待签到的作业信息") 
 | 
    @GetMapping("/getLastWaitJob") 
 | 
    @LoginNoRequired 
 | 
    public ApiResponse<PlatformJob> getLastWaitJob(@RequestParam String uuid,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        return ApiResponse.success( platformJobService.getLastWaitJob(uuid,this.getLoginUser(token))); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("批量删除") 
 | 
    @GetMapping("/delete/batch") 
 | 
    @CloudRequiredPermission("business:platformjob:delete") 
 | 
    public ApiResponse deleteByIdInBatch(@RequestParam String ids,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        platformJobService.deleteByIdInBatch(this.getIdList(ids)); 
 | 
        return ApiResponse.success(null); 
 | 
    } 
 | 
    @ApiOperation("批量更新wms合同总运输量") 
 | 
    @GetMapping("/updateTotalNum") 
 | 
    @CloudRequiredPermission("business:platformjob:update") 
 | 
    public ApiResponse updateTotalNum(@RequestParam String ids,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        wmsService.computjobTotalNum(this.getIdList(ids)); 
 | 
        return ApiResponse.success(null); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("根据ID修改") 
 | 
    @PostMapping("/updateById") 
 | 
    @CloudRequiredPermission("business:platformjob:update") 
 | 
    public ApiResponse updateById(@RequestBody PlatformJob platformJob,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        platformJobService.updateById(platformJob); 
 | 
        return ApiResponse.success(null); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("分页查询") 
 | 
    @PostMapping("/page") 
 | 
    @CloudRequiredPermission("business:platformjob:query") 
 | 
    public ApiResponse<PageData<PlatformJob>> findPage (@RequestBody PageWrap<PlatformJob> pageWrap,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        return ApiResponse.success(platformJobService.findPage(pageWrap)); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("导出Excel") 
 | 
    @PostMapping("/exportExcel") 
 | 
    @CloudRequiredPermission("business:platformjob:exportExcel") 
 | 
    public void exportExcel (@RequestBody PageWrap<PlatformJob> pageWrap, HttpServletResponse response,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        List<PlatformJob> platformJobList = platformJobService.findPage(pageWrap).getRecords(); 
 | 
        if(CollectionUtils.isNotEmpty(platformJobList)){ 
 | 
            for (PlatformJob platformJob:platformJobList) { 
 | 
                platformJob.setJobForm(Constants.ZERO); 
 | 
            } 
 | 
        } 
 | 
        if(Constants.equalsInteger(pageWrap.getModel().getJobType(),1)){ 
 | 
            List<PlatformJobExportVo> exportVoList  =new ArrayList<>(); 
 | 
            if(platformJobList!=null){ 
 | 
                for(PlatformJob job : platformJobList){ 
 | 
                    PlatformJobExportVo t = new PlatformJobExportVo(); 
 | 
                    BeanUtils.copyProperties(job,t); 
 | 
                    exportVoList.add(t); 
 | 
                } 
 | 
                ExcelExporter.build(PlatformJobExportVo.class).export(exportVoList, "预约入园作业记录", response); 
 | 
            } 
 | 
        }else{ 
 | 
            ExcelExporter.build(PlatformJob.class).export(platformJobList, "安泰物流作业任务", response); 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @ApiOperation("根据ID查询") 
 | 
    @GetMapping("/{id}") 
 | 
    @CloudRequiredPermission("business:platformjob:query") 
 | 
    public ApiResponse findById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        return ApiResponse.success(platformJobService.findById(id)); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("任务详情") 
 | 
    @PostMapping("/jobDetail") 
 | 
    @CloudRequiredPermission("business:platformjob:query") 
 | 
    public ApiResponse<PlatformJob>  jobDetail (@RequestBody JobDetailDTO jobDetailDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        return ApiResponse.success(platformJobService.getDetail(jobDetailDTO)); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("任务签到") 
 | 
    @PostMapping("/signIn") 
 | 
    public ApiResponse  signIn (@RequestBody SignInDTO signInDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ 
 | 
        signInDTO.setLoginUserInfo(getLoginUser(token)); 
 | 
        platformJobService.signIn(signInDTO); 
 | 
        return ApiResponse.success("操作成功"); 
 | 
    } 
 | 
} 
 |