FlowOrderController.java

package com.boco.nbd.wios.flow.controller;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil;
import com.boco.nbd.framework.common.ResponseMessage2;
import com.boco.nbd.wios.export.PoiUtil;
import com.boco.nbd.wios.flow.entity.bo.ManualSapBo;
import com.boco.nbd.wios.flow.entity.po.OrderAbnormalPO;
import com.boco.nbd.wios.flow.entity.po.OrderPO;
import com.boco.nbd.wios.flow.enums.OrderInfoEnum;
import com.boco.nbd.wios.flow.mapper.def.FlowOrderMapper;
import com.boco.nbd.wios.flow.service.IOrderAbnormalService;
import com.boco.nbd.wios.flow.service.IOrderService;
import com.boco.nbd.wios.flow.service.impl.OrderServiceImpl;
import com.boco.nbd.wios.flow.util.ProcessUtil;
import com.boco.nbd.wios.flow.util.ValidUtil;
import com.boco.nbd.wios.manage.contants.WiosConstant;
import com.boco.nbd.wios.flow.entity.pdf.BlockPairBo;
import com.boco.nbd.wios.manage.service.impl.OrderInvoiceService;
import com.ihidea.core.support.session.SessionInfo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import springfox.documentation.annotations.ApiIgnore;

import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * @Description 订单管理处理类
 * @Author Yu
 * @Date 2022/7/11
 */
@RestController
@Slf4j
@RequestMapping("/camsOrder")
@Api(tags = "新版本订单管理接口")
public class FlowOrderController {

    @Autowired
    private IOrderService orderService;

    @Autowired
    private IOrderAbnormalService orderAbnormalService;

    @Autowired
    private OrderInvoiceService orderInvoiceService;

    @PostMapping(value = "order/pushSapOrder")
    @ApiOperation(value = "同步订单到sap")
    public ResponseMessage2 pushSapOrder(@RequestBody ManualSapBo bo) {
        try {
            orderService.pushSapOrder(bo);
            return ResponseMessage2.Success2(bo.getId() + "重推SAP成功。");
        } catch (Exception ex) {
            return ResponseMessage2.Failed(bo.getId() + "重推SAP失败：" + ex.getMessage());
        }
    }

    /**
     * 批量更新开票信息
     *
     * @param invoiceJson
     * @return
     */
    @PostMapping(value = "orderInvoice/batchUpdate")
    @ApiOperation(value = "批量更新开票信息", notes = "")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "invoiceJson", value = "json数据", dataType = "String", paramType = "query", required = true),})
    public ResponseMessage2 batchImportInvoiceData(String invoiceJson) {
        if (StrUtil.isEmpty(invoiceJson)) {
            return ResponseMessage2.Failed("缺少参数");
        }
        try {
            orderInvoiceService.processBatchUpdate(invoiceJson);
        } catch (Exception ex) {
            return ResponseMessage2.Failed(ex.getMessage());
        }

        return ResponseMessage2.Success();
    }

    @ApiOperation("获取工单信息:type=1 勘测详情;type=2 安装详情;type缺失或者其它值 基本信息")
    @GetMapping(value = "/getOrderInfo")
    public ResponseMessage2 getOrderInfo(@RequestParam(value = "id") String id, @RequestParam(value = "type", required = false) Integer type) {
        try {
            OrderInfoEnum infoEnum = OrderInfoEnum.getEnum(type);
            return ResponseMessage2.Success2(orderService.getOrderInfo(id, infoEnum));
        } catch (Exception ex) {
            return ResponseMessage2.Failed("getOrderInfo:" + ex.getMessage());
        }
    }

    @GetMapping(value = "exportOrderDocx.do")
    @ApiOperation(value = "导出工单Docx,type=1 勘测详情;type=2 安装详情;===>调整成前端实现")
    @ApiIgnore
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "工单Id", dataType = "String", paramType = "query", required = true),
            @ApiImplicitParam(name = "type", value = "类型", dataType = "Integer", paramType = "query", required = true)})
    public void exportOrderDocx(HttpServletResponse response, String id, Integer type) throws Exception {
        OrderInfoEnum infoEnum = OrderInfoEnum.getEnum(type);
        if (OrderInfoEnum.BASE_INFO.equals(infoEnum)) {
            infoEnum = OrderInfoEnum.SURVEY_INFO;
        }
        Map<String, Object> dataMap = orderService.getOrderInfo(id, infoEnum);
        String fileName = OrderInfoEnum.SURVEY_INFO.equals(infoEnum) ? WiosConstant.SURVEY_ORDER_DOCX : WiosConstant.INSTALL_ORDER_DOCX;
        String templateName = OrderInfoEnum.SURVEY_INFO.equals(infoEnum) ? WiosConstant.SURVEY_ORDER_DOCX_TEMPLATE : WiosConstant.INSTALL_ORDER_DOCX_TEMPLATE;
        PoiUtil.exportOrderDocx(response, dataMap, fileName, templateName);

    }


    @PostMapping("order/add")
    @ApiOperation(value = "订单管理-添加派单信息")
    public ResponseMessage2 add(OrderPO order) {
        OrderAbnormalPO orderAbnormalPO = new OrderAbnormalPO();
        BeanUtil.copyProperties(order, orderAbnormalPO);
        SessionInfo sessionInfo = ProcessUtil.getUserInfo();
        if (sessionInfo == null) {
            return ResponseMessage2.Failed(ProcessUtil.RE_LOGIN);
        }
        order.setCreateAccount(sessionInfo.getUserId());
        order.setCreateAccountName(sessionInfo.getUserName());
        //车主姓名
        if (StringUtils.isBlank(order.getUserName()) ||
                //车主电话
                !ValidUtil.isMobileSimple(order.getUserPhone()) ||
                //车型
                StringUtils.isBlank(order.getVehicleModel()) ||
                //主机厂
                StringUtils.isBlank(order.getOemName()) ||
                //主机厂业务代码
                order.getOemId() == null ||
                //是否需要人工派单
                order.getManuDispatchEnable() == null ||
                //区域
//                StringUtils.isBlank(order.getArea()) ||
                //安装地址
                StringUtils.isBlank(order.getAddress()) ||
                //是否为售车前预勘测
                order.getSurveyBeforeSaleEnable() == null ||
                //是否联系上客户
                order.getIsConnect() == null ||
                //是否需要勘测
                order.getIsNeedSurvey() == null ||
                //安装紧急程度
                order.getInstallEmergencyLevel() == null) {

            orderAbnormalService.insertSelective(orderAbnormalPO);
            return ResponseMessage2.Failed("异常订单");
        }
        return orderService.startFlow(order);
    }

    @GetMapping("order/getOemCascade")
    @ApiOperation(value = "订单管理-主机厂和套包类型级联关系")
    @ApiImplicitParams({@ApiImplicitParam(name = "oemId", value = "主机厂ID", dataType = "String", paramType = "query", required = true)
    })
    public ResponseMessage2 getOemCascade(String oemId) {
        return ResponseMessage2.Success2(orderService.getOemCascade(oemId));
    }

    /**
     * @Description 订单附件生成pdf
     * @Param
     * @author miaoguoqing
     * @date 2022/10/27
     */
    @PostMapping(value = "order/autogeneratePdf")
    @ApiOperation(value = "订单附件生成pdf")
    public void getAutogeneratePdf(@RequestBody BlockPairBo blockPairBo, HttpServletResponse response) throws IOException {
        try {
            orderService.getAutogeneratePdf(blockPairBo, response);
        } catch (Exception e) {
            log.error("生成PDF失败!", e);
            throw new IOException(e.getMessage());
        }
    }
    @Autowired
    private FlowOrderMapper flowOrderMapper;

    @GetMapping("/getCanDeliveryOrder")
    @ApiOperation("获取可以发货的订单列表")
    public ResponseMessage2 getCanDeliveryOrder(@RequestParam String orderId,@RequestParam String  isproduct){
        List<OrderPO> list=flowOrderMapper.getCanDeliveryOrder(orderId);
        if ("品牌墙盒".equals(isproduct)){
            List<OrderPO> has = list.stream().filter(i -> i.getInstallWallboxModel().equals("CAMS")).collect(Collectors.toList());
            return ResponseMessage2.Success2(has);
        }else {
            List<OrderPO> has = list.stream().filter(i -> !i.getInstallWallboxModel().equals("CAMS")).collect(Collectors.toList());
            return ResponseMessage2.Success2(has);
        }
    }
}