package com.gk.firework.Controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.gk.firework.Controller.Base.BaseController;
import com.gk.firework.Domain.EntryOrderInfo;
import com.gk.firework.Domain.Enum.ErrorCode;
import com.gk.firework.Domain.Log.JsonParams;
import com.gk.firework.Domain.SoldNoStockInfo;
import com.gk.firework.Domain.StockInfo;
import com.gk.firework.Domain.UserInfo;
import com.gk.firework.Domain.Utils.FilterObject;
import com.gk.firework.Domain.Utils.Msg;
import com.gk.firework.Domain.Utils.StringUtils;
import com.gk.firework.Domain.Vo.DirectionDetail;
import com.gk.firework.Domain.Vo.FireworkDeal;
import com.gk.firework.Domain.Vo.ProductVo;
import com.gk.firework.Service.EntryDetailService;
import com.gk.firework.Service.EntryService;
import com.gk.firework.Service.ProductService;
import com.gk.firework.Service.StockService;
import com.gk.firework.Service.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * @author : jingjy
 * @date : 2021/4/9 16:17
 */
@Api(tags = "入库接口")
@RestController
@RequestMapping("/entry")
public class EntryController extends BaseController {
    @Autowired
    private ProductService productService;
    @Autowired
    private EntryService entryService;
    @Autowired
    private EntryDetailService entryDetailService;
    @Autowired
    private StockService stockService;
    @Autowired
    private SoldNoStockService soldNoStockService;
    @Autowired
    private UserService userService;

    @GetMapping(value = "/getEntryDetail/directionCode/{directionCode}")
    public Msg getEntryDetail(@PathVariable String directionCode){
        Msg msg = new Msg(true);
        if (FireworkDeal.isNotDirectionCode(directionCode)){
            msg.setCode(ErrorCode.ERROR_999.getCode());
            msg.setMessage("流向码不符合规则，请重新输入！");
            return msg;
        }

        List<ProductVo>productVoList = new ArrayList<>();
        if (FireworkDeal.is22Characters(directionCode)){
            DirectionDetail detail = FireworkDeal.dealDirectionCode(directionCode);
            ProductVo productVo = productService.selectVoByDirection(directionCode);
            if (productVo == null){
                msg.setCode(ErrorCode.ERROR_999.getCode());
                msg.setMessage("产品不存在，请重新输入！");
                return msg;
            }
            FireworkDeal.getProductVos(directionCode,detail,detail,productVoList,productVo);
        }else {
            ProductVo productVo = productService.selectVoByDirection(directionCode);
            if (productVo == null){
                msg.setCode(ErrorCode.ERROR_999.getCode());
                msg.setMessage("产品不存在，请重新输入！");
                return msg;
            }
            productVoList.add(productVo);
        }


        if (productVoList.size() == 0){
            msg.setCode(ErrorCode.ERROR_999.getCode());
            msg.setMessage("流向码："+directionCode+"未找到相应入库信息！");
            return msg;
        }

        StringBuilder content = new StringBuilder();

        List<ProductVo>productVos = new ArrayList<>();
        for (ProductVo productVo1 : productVoList){
            StockInfo stockInfo = stockService.selectStockByDireAndUser(getUser().getCompanyid(),productVo1.getDirectionCode());
            if (stockInfo == null || stockInfo.getStatus().equals(StockInfo.STOCK_SOLD)){
                msg.setCode(ErrorCode.ERROR_999.getCode());
                content.append(productVo1.getDirectionCode()).append("  未入库或者已经销售了!");
            }else {
                productVos.add(productVo1);
            }
        }

        msg.setMessage(content.toString());
        msg.setResult(productVos);

        return msg;
    }

    @PostMapping("entryPatch")
    @JsonParams
    public Msg entryPatch(@RequestBody JSONArray jsonArray){
        Msg msg = new Msg(true);
        if (jsonArray.size() == 0){
            msg.setCode(ErrorCode.ERROR_999.getCode());
            msg.setMessage(ErrorCode.ERROR_999.getMsg());
            return msg;
        }
        UserInfo userInfo = userService.getById(getUser().getId());
        String auth = getAuth();
        auth = StringUtils.isBlank(auth) ? "NOAUTH" : auth;
        List<SoldNoStockInfo>soldNoStockInfos = new ArrayList<>();
        for (int i = 0; i < jsonArray.size(); i++){
            JSONObject object = jsonArray.getJSONObject(i);
            String directionCode = object.getString("directioncode");
            SoldNoStockInfo soldNoStockInfo = soldNoStockService.selectSoldNoStockByDire(directionCode);
            if (soldNoStockInfo == null){
                msg.setCode(ErrorCode.ERROR_999.getCode());
                msg.setMessage(ErrorCode.ERROR_999.getMsg());
                return msg;
            }
            soldNoStockInfos.add(soldNoStockInfo);
        }
        entryService.entryPatch(soldNoStockInfos,userInfo,auth);

        return msg;
    }



    /**
     * @Description: 入库查询
     * @date 2021/4/14 16:35
     */
    @PostMapping("/inbound-query")
    @ApiOperation(value = "入库查询", httpMethod = "POST")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageIndex", value = "当前页码", required = true),
            @ApiImplicitParam(name = "pageSize", value = "页大小", required = true),
            @ApiImplicitParam(name = "filter.province", value = "省"),
            @ApiImplicitParam(name = "filter.city", value = "市"),
            @ApiImplicitParam(name = "filter.district", value = "区"),
            @ApiImplicitParam(name = "filter.street", value = "街道"),
            @ApiImplicitParam(name = "filter.committee", value = "委员会"),
            @ApiImplicitParam(name = "filter.starttime", value = "开始时间"),
            @ApiImplicitParam(name = "filter.endtime", value = "结束时间"),
            @ApiImplicitParam(name = "filter.transportcert", value = "运输证号码"),
            @ApiImplicitParam(name = "filter.enterprisename", value = "入库企业名称"),
            @ApiImplicitParam(name = "filter.safetysupervision", value = "安全监管分类"),
            @ApiImplicitParam(name = "filter.type", value = "入库类型"),
            @ApiImplicitParam(name = "filter.code", value = "单号"),
    })
    Object getInboundInfo(@RequestBody FilterObject jsonFilter) {
        Integer pageIndex = jsonFilter.getPageIndex();
        Integer pageSize = jsonFilter.getPageSize();
        IPage page = entryService.selectPage(new Page<>(pageIndex, pageSize), jsonFilter.getFilter(), getUser());
        return success(page);
    }

    @PostMapping("/stock/inbound-query")
    @ApiOperation(value = "入库查询", httpMethod = "POST")
    Object getStockInboundInfo(@RequestBody FilterObject jsonFilter) {
        Integer pageIndex = jsonFilter.getPageIndex();
        Integer pageSize = jsonFilter.getPageSize();
        IPage page = entryService.selectStockPage(new Page<>(pageIndex, pageSize), jsonFilter.getFilter(), getUser());
        return success(page);
    }

    /**
    * @Description: 入库导出
    * @date 2021/4/19 17:11
    */

    @PostMapping("/export/inbound")
    @ApiOperation(value = "入库查询导出", httpMethod = "POST")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "filter.province", value = "省"),
            @ApiImplicitParam(name = "filter.city", value = "市"),
            @ApiImplicitParam(name = "filter.district", value = "区"),
            @ApiImplicitParam(name = "filter.street", value = "街道"),
            @ApiImplicitParam(name = "filter.committee", value = "委员会"),
            @ApiImplicitParam(name = "filter.starttime", value = "开始时间"),
            @ApiImplicitParam(name = "filter.endtime", value = "结束时间"),
            @ApiImplicitParam(name = "filter.transportcert", value = "运输证号码"),
            @ApiImplicitParam(name = "filter.enterprisename", value = "入库企业名称"),
    })
    Object exportInbound(@RequestBody FilterObject jsonFilter) {
        List<EntryOrderInfo> list = entryService.selectExportInBound(jsonFilter.getFilter(), getUser());
        return success(list);
    }

    /**
    * @Description: 根据{入库单code}查询入库明细
    * @date 2021/4/15 11:09
    */
    @PostMapping("/inbound-detail")
    @ApiOperation(value = "入库单明细", httpMethod = "POST")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageIndex", value = "当前页码", required = true),
            @ApiImplicitParam(name = "pageSize", value = "页大小", required = true),
            @ApiImplicitParam(name = "filter.code", value = "入库单号code"),
    })
    Object getInboundDetail(@RequestBody FilterObject jsonFilter) {
        Integer pageIndex = jsonFilter.getPageIndex();
        Integer pageSize = jsonFilter.getPageSize();
        IPage page = entryService.selectDetailPage(new Page<>(pageIndex,pageSize),jsonFilter.getFilter());
        return success(page);
    }


    /**
     * @Description: 根据{入库单code}查询入库明细并导出
     * @date 2021/4/15 11:09
     */
    @GetMapping("/export/inbound-detail")
    @ApiOperation(value = "入库单明细导出", httpMethod = "POST")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "code", value = "入库单号code"),
    })
    Object getInboundDetail(@RequestParam String code) {
         List<Map> detailExport = entryDetailService.selectDetailExport(code);
        return success(detailExport);
    }

}