package com.gk.firework.Service.ServiceImpl;


import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gk.firework.Domain.EntryDetailInfo;
import com.gk.firework.Domain.EntryOrderInfo;
import com.gk.firework.Domain.Exception.BusinessException;
import com.gk.firework.Domain.SoldNoStockInfo;
import com.gk.firework.Domain.UserInfo;
import com.gk.firework.Domain.Vo.EntryOrderInfoVo;
import com.gk.firework.Domain.Vo.EntryUtils;
import com.gk.firework.Domain.Vo.FireworkDeal;
import com.gk.firework.Domain.Vo.ProductVo;
import com.gk.firework.Mapper.EntryDetailInfoMapper;
import com.gk.firework.Domain.Utils.StringUtils;
import com.gk.firework.Mapper.EntryOrderInfoMapper;
import com.gk.firework.Service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;
import java.util.List;

import java.util.ArrayList;
import java.util.Date;

/**
 * @author : jingjy
 * @date : 2021/3/24 11:10
 */
@Service("EntryService")
public class EntryServiceImpl extends ServiceImpl<EntryOrderInfoMapper,EntryOrderInfo> implements EntryService{
    @Autowired
    private ProductService productService;
    @Autowired
    private EntryService entryService;
    @Autowired
    private EntryDetailService entryDetailService;
    @Autowired
    private SoldNoStockService soldNoStockService;
    @Autowired
    private SaleOrderService orderService;

    @Override
    public void entryPatch(List<SoldNoStockInfo> soldNoStockInfos, UserInfo user, String auth) {
        EntryOrderInfo orderInfo = generateEntryOrderInfo(EntryUtils.RK_ENTRY,user,new Date(),"",auth);
        List<EntryDetailInfo>detailInfos = new ArrayList<>();
        int i = 0;
        for (SoldNoStockInfo soldNoStockInfo : soldNoStockInfos){
            String dire = soldNoStockInfo.getDirectioncode();
            ProductVo productVo = productService.selectVoByDirection(dire);
            EntryDetailInfo detailInfo = new EntryDetailInfo(orderInfo.getCode(),dire,productVo.getItemCode(),
                    productVo.getName(),productVo.getManufacturer(),new Date(),user.getCompanynumber());
            //已销未入库信息只会存19位流向码信息
            detailInfo.setNum(1);
            detailInfos.add(detailInfo);
            i++;

            //更新soldNoStock信息
            soldNoStockInfo.setHandler(user.getUsername());
            soldNoStockInfo.setHandledat(new Date());
            soldNoStockInfo.setEntryorder(orderInfo.getCode());
            soldNoStockInfo.setFlag(SoldNoStockInfo.PROCESSED);
        }
        //插入入库单及入库明细单，更新已销未入库单，不更新库存
        orderInfo.setNum(i);
        entryService.save(orderInfo);
        entryDetailService.saveBatch(detailInfos);
        soldNoStockService.updateBatchById(soldNoStockInfos);

    }

    @Autowired
    private EntryOrderInfoMapper entryOrderInfoMapper;
    @Autowired
    private UserService userService;
    @Autowired
    private EntryDetailInfoMapper entryDetailInfoMapper;

    /**
    * @Description: 入库查询
    * @date 2021/4/15 10:28
    */
    @Override
    public IPage selectPage(Page<EntryOrderInfoVo> page, Map filter, UserInfo user) {

        UserInfo userInfo = userService.getById(user.getId());

        Map<String, Object> params = new HashMap<>();
        //筛选条件
        //可视权限
        {
            params.put("enterprisenumber", userInfo.getCompanynumber());
            params.put("province", userInfo.getProvince());
            params.put("city", userInfo.getCity());
            params.put("district", userInfo.getArea());
            params.put("street", userInfo.getTown());
            params.put("committee", userInfo.getCommunity());
        }
        //基本查询条件
        {
            params.put("filterProvince", filter.get("province"));
            params.put("filterCity", filter.get("city"));
            params.put("filterDistrict", filter.get("district"));
            params.put("filterStreet", filter.get("street"));
            params.put("filterCommittee", filter.get("committee"));

            params.put("transportcert", filter.get("transportcert"));
            params.put("starttime", filter.get("starttime"));
            params.put("endtime", filter.get("endtime"));
            params.put("enterprisename", filter.get("enterprisename"));
            params.put("safetysupervision", filter.get("safetysupervision"));
            params.put("type", filter.get("type"));
            params.put("code", filter.get("code"));
        }

        List<EntryOrderInfoVo> list = entryOrderInfoMapper.selectPages(page,params);
        return page.setRecords(list);
    }

    /**
    * @Description:  根据{入库单code}查询入库明细
    * @date 2021/4/15 11:12
    */
    @Override
    public Page selectDetailPage(Page<Map> page, Map filter) {
        String code = (String) filter.get("code");
        if (StringUtils.isBlank(code)) {
            throw new BusinessException("入库单号不能为空");
        }

        Map<String, Object> params = new HashMap<>();
        params.put("code", code);
        params.put("starttime", filter.get("starttime"));
        params.put("endtime", filter.get("endtime"));
        List<Map> list = entryDetailInfoMapper.selectDetailPage(page, params);
        return page.setRecords(list);
    }

    @Override
    public BigDecimal getEntryNumByCondition(Map<String, Object> condition) {
        return entryDetailInfoMapper.getEntryNumByCondition(condition);
    }

    @Override
    public BigDecimal getReturnNumByCondition(Map<String, Object> condition) {
        return entryDetailInfoMapper.getReturnNumByCondition(condition);
    }

    @Override
    public boolean isEntryExist(String datetime, UserInfo userInfo) {
        EntryOrderInfo entryOrderInfo = entryOrderInfoMapper.selectEntryOrderByTimeAndUser(datetime,userInfo.getUsername());
        return entryOrderInfo != null;
    }

    /**
    * @Description: 入库导出
    * @date 2021/4/19 17:13
    */
    @Override
    public List<EntryOrderInfo> selectExportInBound(Map filter, UserInfo user) {

        UserInfo userInfo = userService.getById(user.getId());

        Map<String, Object> params = new HashMap<>();
        //筛选条件
        //可视权限
        {
            params.put("enterprisenumber", userInfo.getCompanynumber());
            params.put("province", userInfo.getProvince());
            params.put("city", userInfo.getCity());
            params.put("district", userInfo.getArea());
            params.put("street", userInfo.getTown());
            params.put("committee", userInfo.getCommunity());
        }
        //基本查询条件
        {
            params.put("filterProvince", filter.get("province"));
            params.put("filterCity", filter.get("city"));
            params.put("filterDistrict", filter.get("district"));
            params.put("filterStreet", filter.get("street"));
            params.put("filterCommittee", filter.get("committee"));

            params.put("transportcert", filter.get("transportcert"));
            params.put("starttime", filter.get("starttime"));
            params.put("endtime", filter.get("endtime"));
            params.put("enterprisename", filter.get("enterprisename"));
            params.put("type", filter.get("type"));
        }

        return entryOrderInfoMapper.selectPages(params);
    }

    @Override
    public BigDecimal selectEnterpriseEntryNumber(String enterprisenumber, Object starttime, Object endtime) {
        return entryOrderInfoMapper.selectEnterpriseEntryNumber(enterprisenumber,starttime,endtime);
    }

    @Override
    public BigDecimal selectCityEntryNumber(String name, Object starttime, Object endtime) {
        return entryOrderInfoMapper.selectCityEntryNumber(name,starttime,endtime);
    }

    @Override
    public Boolean isTransportCertEntry(String code) {
        if (StringUtils.isBlank(code)){
            return false;
        }
        List<EntryOrderInfo> entryOrderInfo = entryOrderInfoMapper.selectByCert(code);
        return entryOrderInfo != null && entryOrderInfo.size() > 0;
    }

    @Override
    public IPage selectStockPage(Page<EntryOrderInfoVo> page, Map<String, Object> filter, UserInfo user) {
        Map<String, Object> params = new HashMap<>();
        {
            params.put("filterProvince", filter.get("province"));
            params.put("filterCity", filter.get("city"));
            params.put("filterDistrict", filter.get("district"));
            params.put("filterStreet", filter.get("street"));
            params.put("filterCommittee", filter.get("committee"));

            params.put("transportcert", filter.get("transportcert"));
            params.put("starttime", filter.get("starttime"));
            params.put("endtime", filter.get("endtime"));
            params.put("enterprisename", filter.get("enterprisename"));
            params.put("type", filter.get("type"));
        }
        List<EntryOrderInfoVo> list = entryOrderInfoMapper.selectPages(page,params);
        return page.setRecords(list);
    }

    @Override
    public EntryOrderInfo generateEntryOrderInfo(String type, UserInfo userInfo, Date date, String transport, String auth){
        EntryOrderInfo orderInfo = new EntryOrderInfo();
        orderInfo.setCode(orderService.generateOrderCode(FireworkDeal.MODULE_ENTRY,type,new Date(),userInfo.getId()));
        orderInfo.setType(Byte.parseByte(type));
        orderInfo.setCreateddate(new Date());
        orderInfo.setCreatedby(userInfo.getUsername());
        orderInfo.setEntrydate(date);
        orderInfo.setTransportcert(transport);
        orderInfo.setUnit(userInfo.getCompany());
        orderInfo.setCompanynumber(userInfo.getCompanynumber());
        return orderInfo;
    }

}