quality-inspection/business-server/src/main/java/com/rongwei/bsserver/controller/ZhcxPMQMController.java

package com.rongwei.bsserver.controller;

import com.rongwei.bscommon.sys.service.ZhcxPMQMService;
import com.rongwei.bscommon.sys.service.ZhcxPmqManagementDistributionService;
import com.rongwei.bscommon.sys.service.ZhcxPmqManagementRecoredService;
import com.rongwei.bscommon.sys.utils.SqlServerJdbcUtils;
import com.rongwei.bscommon.sys.utils.ZhcxCommon;
import com.rongwei.bsentity.domain.ZhcxPmqManagementSourceDo;
import com.rongwei.bsentity.dto.sqlServer.ZhcxPmqManagementSource;
import com.rongwei.rwcommon.base.R;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;

@Slf4j
@RestController
@RequestMapping("/zhcxPMQM")
@Api(tags = "接口相关", description = "三单管理接口")
public class ZhcxPMQMController {
    @Autowired
    private ZhcxCommon zhcxCommon;

    @Autowired
    private ZhcxPMQMService pmqmService;

    @Autowired
    private ZhcxPmqManagementDistributionService pmqManagementDistributionService;

    @Autowired
    private ZhcxPmqManagementRecoredService managementRecoredService;

    @PostMapping("/gdfnx")
    @ApiOperation("获取NX系统的三单数据")
    public R getDataFromNX() {
        Map<String,String> map2 = new HashMap<>();
        map2.put("dateStr", "2021-01-01 10:10:10");
        List<Map<String, Object>> list = pmqmService.getPMQMData(map2);
        return R.ok(list);
    }

    @PostMapping("/gdfnxTest")
    @ApiOperation("获取NX系统的三单数据(测试)")
    public R getDataFromNXTest() {
        List<ZhcxPmqManagementSource> list = SqlServerJdbcUtils.queryZHCXPMQMANAGEMENTSOURCEDataPRO();
        for (ZhcxPmqManagementSource zhcxPmqManagementSource : list) {
            System.out.println("zhcxPmqManagementSource = " + zhcxPmqManagementSource);
        }
        return R.ok(list);
    }

    // 三单核心接口之一(只能通过接口调用去执行,谨慎调用)
    @PostMapping("/updateClosedStatus")
    @ApiOperation("更新三单全表的关闭状态(慎用)")
    public R updateClosedStatus() {
        managementRecoredService.updateClosedStatus();
        return R.ok();
    }

    @PostMapping("/ucs")
    public R updateCloseStatus(@RequestBody Map<String,Object> map) {
        String id = (String) map.get("id");
        pmqmService.updateCloseStatusSimple(id);
        return R.ok();
    }


    @PostMapping("/gnsd")
    public R getNxSystemData() {
        List<ZhcxPmqManagementSourceDo> list = pmqmService.getNxSystemData();
        return R.ok(list);
    }


    @PostMapping("/generateDistributionDetail")
    @ApiOperation("第二层生成三单派单数据(单一派单)")
    public R generateDistributionDetail(@RequestBody Map<String,Object> map){
        try {
            if(Objects.isNull(map.get("pid"))){
                return R.error("pid不能为空");
            }
            String pid = (String) map.get("pid");
            log.info("生成三单派单数据__>pid:{}",pid);
            return pmqManagementDistributionService.generateDistributionDetail(pid);
        } catch (Exception e) {
            log.info(String.valueOf(e));
            return R.error("生成三单派单数据异常");
        }
    }

    @GetMapping("/selectManifestList")
    @ApiOperation("三单清单数据源")
    public R selectManifestList(String projectId){
        try {
            if(Objects.isNull(projectId)){
                return R.ok("项目id为空");
            }
            log.info("三单清单数据源__>项目id:{}",projectId);
            return pmqManagementDistributionService.selectManifestList(projectId);
        } catch (Exception e) {
            log.info(String.valueOf(e));
            return R.error("三单清单数据源异常");
        }
    }

    @GetMapping("/selectManifestList2")
    @ApiOperation("三单清单数据源(第二层接口)")
    public R selectManifestList2(String projectId,String id){
        try {
            if(Objects.isNull(projectId)){return R.ok("项目id为空");}
            if(Objects.isNull(id)){return R.ok("id为空");}
            log.info("三单清单数据源__>项目id:{}",projectId);
            return pmqManagementDistributionService.selectManifestList2(projectId,id);
        } catch (Exception e) {
            log.info(String.valueOf(e));
            return R.error("三单清单数据源异常");
        }
    }
}