package com.ruoyi.warehouseBusiness.service.impl;


import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.basicData.domain.*;
import com.ruoyi.basicData.mapper.*;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.core.domain.model.LoginUser;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.reportManagement.domain.TWhgenleg;
import com.ruoyi.reportManagement.mapper.TWhgenlegMapper;
import com.ruoyi.system.mapper.SysDeptMapper;
import com.ruoyi.system.mapper.SysUserMapper;
import com.ruoyi.warehouseBusiness.domain.TEnclosure;
import com.ruoyi.warehouseBusiness.domain.TWarehouseBills;
import com.ruoyi.warehouseBusiness.domain.TWarehousebillsfees;
import com.ruoyi.warehouseBusiness.domain.TWarehousebillsitems;
import com.ruoyi.warehouseBusiness.mapper.TEnclosureMapper;
import com.ruoyi.warehouseBusiness.mapper.TWarehouseBillsMapper;
import com.ruoyi.warehouseBusiness.mapper.TWarehousebillsfeesMapper;
import com.ruoyi.warehouseBusiness.mapper.TWarehousebillsitemsMapper;
import com.ruoyi.warehouseBusiness.service.ITWarehouseBillsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.*;

/**
 * 详情主表Service业务层处理
 *
 * @author ruoyi
 * @date 2020-12-11
 */
@Service
public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {


    @Autowired
    private TWhgenlegMapper tWhgenlegMapper;

    @Autowired
    private TGoodsMapper tGoodsMapper;

    @Autowired
    private SysDeptMapper sysDeptMapper;

    @Autowired
    private SysUserMapper sysUserMapper;

    @Autowired
    private TCorpsMapper tCorpsMapper;

    @Autowired
    private TFeesMapper tFeesMapper;

    @Autowired
    private TWarehouseMapper tWarehouseMapper;

    @Autowired
    private TWarehouseAreaMapper tWarehouseAreaMapper;

    @Autowired
    private TEnclosureMapper tEnclosureMapper;

    @Autowired
    private TWarehouseBillsMapper tWarehouseBillsMapper;

    @Autowired
    private TWarehousebillsfeesMapper tWarehousebillsfeesMapper;

    @Autowired
    private TWarehousebillsitemsMapper tWarehousebillsitemsMapper;

    @Autowired
    private BillnoSerialServiceImpl billnoSerialServiceImpl;


    /**
     * 查询详情主表
     *
     * @param fId 详情主表ID
     * @return 详情主表
     */
    @Override
    public Map<String, Object> selectTWarehousebillsById(Long fId) {
        Map<String, Object> map = new HashMap<>();
        // 查询仓库主表数据
        TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
        // 客户表
        List<TCorps> corpsList = new ArrayList<>();
        // 用户表
        List<SysUser> sysUserList = new ArrayList<>();
        // 仓库表
        List<TWarehouse> warehouseList = new ArrayList<>();
        // 商品
        List<TGoods> goodsList = new ArrayList<>();
        // 费用
        List<TFees> feesList = new ArrayList<>();
        // 库区
        List<TWarehouseArea> warehouseAreaList = new ArrayList<>();

        if (!StringUtils.isNull(tWarehousebills)) {
            // 查询货权方
            TCorps corps = tCorpsMapper.selectTCorpsById(tWarehousebills.getfCorpid());
            if (StringUtils.isNotNull(corps)) {
                corpsList.add(corps);
            }
            // 查询联系人
            SysUser sysUser = sysUserMapper.selectUserByUserName(tWarehousebills.getfContacts());
            if (StringUtils.isNotNull(sysUser)) {
                sysUserList.add(sysUser);
            }
            // 查询仓库
            TWarehouse tWarehouse = tWarehouseMapper.selectTWarehouseById(tWarehousebills.getfWarehouseid());
            if (StringUtils.isNotNull(tWarehouse)) {
                warehouseList.add(tWarehouse);
            }
            // 查询经营单位
            TCorps corp = tCorpsMapper.selectTCorpsById(tWarehousebills.getfSbu());
            if (StringUtils.isNotNull(corp)) {
                corpsList.add(corp);
            }
            map.put("warehousebills", tWarehousebills);
        }
        // 查询仓库明细从表数据
        TWarehousebillsitems tWarehousebillsitems = new TWarehousebillsitems();
        tWarehousebillsitems.setfPid(fId);
        List<TWarehousebillsitems> warehousebillsitems = tWarehousebillsitemsMapper.selectTWarehousebillsitemsList(tWarehousebillsitems);
        if (StringUtils.isNotEmpty(warehousebillsitems)) {
            for (TWarehousebillsitems wb : warehousebillsitems) {
                TGoods tGoods = tGoodsMapper.selectTGoodsById(wb.getfGoodsid());
                if (StringUtils.isNotNull(tGoods)) {
                    goodsList.add(tGoods);
                }
                TWarehouseArea warehouseArea = tWarehouseAreaMapper.selectTWarehouseAreaById(wb.getfWarehouselocid());
                if (StringUtils.isNotNull(warehouseArea)) {
                    warehouseAreaList.add(warehouseArea);
                }
            }
            map.put("warehouseBillsItem", warehousebillsitems);
        }

        // 查询仓库费用明细表数据
        TWarehousebillsfees tWarehousebillsfees = new TWarehousebillsfees();
        tWarehousebillsfees.setfPid(fId);
        List<TWarehousebillsfees> warehousebillsfeesDr = new ArrayList<>();
        List<TWarehousebillsfees> warehousebillsfeesCr = new ArrayList<>();
        List<TWarehousebillsfees> warehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(tWarehousebillsfees);
        if (StringUtils.isNotEmpty(warehousebillsfees)) {
            for (TWarehousebillsfees fees : warehousebillsfees) {
                if ("C".equals(fees.getfDc())) {
                    warehousebillsfeesCr.add(fees);
                } else {
                    warehousebillsfeesDr.add(fees);
                }
                TCorps corps = tCorpsMapper.selectTCorpsById(fees.getfCorpid());
                if (StringUtils.isNotNull(corps)) {
                    corpsList.add(corps);
                }
                TFees tFees = tFeesMapper.selectTFeesById(fees.getfFeeid());
                if (StringUtils.isNotNull(tFees)) {
                    feesList.add(tFees);
                }
            }
        }
        // 查询附件表数据
        TEnclosure enclosure = new TEnclosure();
        enclosure.setfPid(fId);
        List<TEnclosure> enclosures = tEnclosureMapper.selectTEnclosureList(enclosure);
        if (StringUtils.isNotEmpty(enclosures)) {
            map.put("enclosures", enclosures);
        }
        map.put("corps", corpsList);
        map.put("goodsList", goodsList);
        map.put("feesList", feesList);
        map.put("sysUser", sysUserList);
        map.put("warehouse", warehouseList);
        map.put("warehouseAreas", warehouseAreaList);
        map.put("warehousebillsfeesDr", warehousebillsfeesDr);
        map.put("warehousebillsfeesCr", warehousebillsfeesCr);
        map.put("dept", sysDeptMapper.selectDeptById(tWarehousebills.getfDeptid()));
        return map;
    }

    /**
     * 查询详情主表列表
     *
     * @param tWarehousebills 详情主表
     * @return 详情主表
     */
    @Override
    public List<Map<String, Object>> selectWarehouseBusinessList(TWarehouseBills tWarehousebills) {
        return tWarehouseBillsMapper.selectWarehouseBusinessList(tWarehousebills);
    }

    /**
     * 查询导出所需主表列表
     *
     * @param tWarehousebills 详情主表
     * @return 详情主表
     */
    @Override
    public List<TWarehouseBills> selectTWarehousebillsList(TWarehouseBills tWarehousebills) {
        return tWarehouseBillsMapper.selectTWarehousebillsList(tWarehousebills);
    }

    /**
     * 根据条件查询总账是否存在
     *
     * @param warehouseBills      仓库主表
     * @param warehousebillsitems 仓库明细表
     * @return 库存总账
     */
    public TWhgenleg queryTWhgenleg(TWarehouseBills warehouseBills, TWarehousebillsitems warehousebillsitems) {
        TWhgenleg tWhgenleg = new TWhgenleg();
        // 客户
        tWhgenleg.setfCorpid(warehouseBills.getfCorpid());
        // 提单号
        tWhgenleg.setfMblno(warehouseBills.getfMblno());
        // 库区
        tWhgenleg.setfWarehouseLocationid(warehousebillsitems.getfWarehouselocid());
        // 货物品名
        tWhgenleg.setfGoodsid(warehousebillsitems.getfGoodsid());
        // 贸易方式
        tWhgenleg.setfTrademodeid(warehouseBills.getfTrademodeid());
        return tWhgenlegMapper.selectTWhgenleg(tWhgenleg);
    }

    /**
     * 新增库存总账
     * @param warehouseBills        仓库主表
     * @param warehousebillsitems   仓库明细表
     * @return  结果
     */
    @Transactional
    public int instalTWhgenleg(TWarehouseBills warehouseBills, TWarehousebillsitems warehousebillsitems, SysUser user) {
        TWhgenleg tWhgenleg = new TWhgenleg();
        // 客户
        tWhgenleg.setfCorpid(warehouseBills.getfCorpid());
        // 提单号
        tWhgenleg.setfMblno(warehouseBills.getfMblno());
        // 原始单号
        tWhgenleg.setfOriginalbillno(warehouseBills.getfMblno());
        // 库区
        tWhgenleg.setfWarehouseLocationid(warehousebillsitems.getfWarehouselocid());
        // 货物品名
        tWhgenleg.setfGoodsid(warehousebillsitems.getfGoodsid());
        // 贸易方式
        tWhgenleg.setfTrademodeid(warehouseBills.getfTrademodeid());
        // 入库数
        tWhgenleg.setfQtyd(warehousebillsitems.getfQty());
        // 入库尺码
        tWhgenleg.setfVolumnd(warehousebillsitems.getfVolumn());
        // 入库毛重
        tWhgenleg.setfGrossweightd(warehousebillsitems.getfGrossweight());
        // 入库净重
        tWhgenleg.setfNetweightd(warehousebillsitems.getfNetweight());
        // 入库箱号
        tWhgenleg.setfCntrno(warehousebillsitems.getfCntrno());
        // 创建人
        tWhgenleg.setCreateBy(user.getUserName());
        // 创建人
        tWhgenleg.setCreateTime(new Date());
        // 状态
        tWhgenleg.setfStatus("T");
        // 结余件数
        tWhgenleg.setfQtyblc(warehousebillsitems.getfQty());
        return tWhgenlegMapper.insertTWhgenleg(tWhgenleg);
    }

    @Transactional
    public int updateTWhgenlegData(TWarehousebillsitems warehousebillsitems, long whgenlegId, String billtype) {
        Map<String, Object> map = new HashMap<>();
        map.put("whgenlegId", whgenlegId);
        map.put("billType", billtype);
        map.put("warehousebillsitems", warehousebillsitems);
        return tWhgenlegMapper.updateTWhgenlegData(map);
    }

    /**
     * 新增详情主表
     *
     * @param tWarehouseBills       仓库主表
     * @param tWarehousebillsfeesCr 仓库费付款用明细表
     * @param tWarehousebillsfeesDr 仓库费收
     *                              款用明细表
     * @param tWarehousebillsitems  仓库货物明细表
     * @param loginUser             当前登陆人
     * @param billsType             判断标识
     * @return 结果
     */
    @Override
    @Transactional
    public AjaxResult insertTWarehousebills(String tWarehouseBills, String tWarehousebillsfeesCr, String tWarehousebillsfeesDr
            , String tWarehousebillsitems, String tWhgenleg, LoginUser loginUser, String billsType) {
        Long fPid = null;
        TWarehouseBills warehouseBills = JSONArray.parseObject(tWarehouseBills, TWarehouseBills.class);

        // 查询库存总账   库存明细不为空 并且 入库不是暂存状态 进行库存总账的查询新增修改
        if (tWarehousebillsitems != null && !warehouseBills.getfBillstatus().equals("2")) {
            JSONArray warehouseJSON = JSONArray.parseArray(tWarehousebillsitems);
            List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
            for (TWarehousebillsitems wbItem : warehousebillsitemsList) {
                // 查询总账是否存在
                TWhgenleg tWhgenle=queryTWhgenleg(warehouseBills,wbItem);
                if(billsType=="SJRK"){ //  入库数 、结余数
                    if(StringUtils.isNull(tWhgenle)){ // 为空添加库存总账
                        SysUser sysUser=new SysUser();
                        sysUser.setUserName(loginUser.getUser().getUserName());
                        instalTWhgenleg(warehouseBills,wbItem,sysUser);
                    }else { // 非空修改库存总账
                        if(warehouseBills.getfBillstatus().equals("6")){
                            updateTWhgenlegData(wbItem,tWhgenle.getfId(),billsType);
                        }
                    }
                } else if (billsType=="SJCK"){ // 出库 查询
                    if(StringUtils.isNull(tWhgenle)){ // 为空 提示没有库存
                        return AjaxResult.error("库存为空");
                    }else { // 非空修改库存总账
                        if(warehouseBills.getfBillstatus().equals("6")){
                            //  库存 <  出库件数  提示库存不足
                            if(tWhgenle.getfQtyblc()< wbItem.getfQty()){
                                return AjaxResult.error("库存不足");
                            }
                            updateTWhgenlegData(wbItem,tWhgenle.getfId(),billsType);
                        }
                    }
                }

            }
        }

        if (StringUtils.isNull(warehouseBills.getfId())) {
            // 如果是新数据
            warehouseBills.setCreateBy(loginUser.getUser().getUserName());
            warehouseBills.setfBilltype(billsType);
            warehouseBills.setfBsdeptid(loginUser.getUser().getDeptId());
            // 提交时：  生流水号
            if (warehouseBills.getfBillstatus().equals("6")) {
                // 业务编码
                String billNo = billnoSerialServiceImpl.getBillNo("SJRK", warehouseBills.getfBsdate());
                warehouseBills.setfBillno(billNo);
                // 存货编码
                Date time = new Date();
                String bscorpno = billnoSerialServiceImpl.getCorpNo(warehouseBills.getfCorpid(), time);
                warehouseBills.setfBscorpno(bscorpno);
            }
            tWarehouseBillsMapper.insertTWarehousebills(warehouseBills);
            fPid = warehouseBills.getfId();
        } else {
            fPid = warehouseBills.getfId();
            warehouseBills.setUpdateBy(loginUser.getUser().getUserName());
            warehouseBills.setUpdateTime(new Date());
            tWarehouseBillsMapper.updateTWarehousebills(warehouseBills);
            tWarehousebillsitemsMapper.deleteByFPid(fPid);
            tWarehousebillsfeesMapper.deleteByFPid(fPid);
            tEnclosureMapper.deleteByFPid(fPid);
        }

        // 库存明细添加
        if (tWarehousebillsitems != null) {
            JSONArray warehouseJSON = JSONArray.parseArray(tWarehousebillsitems);
            List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
            for (TWarehousebillsitems wbItem : warehousebillsitemsList) {
                wbItem.setfPid(fPid);
                wbItem.setCreateBy(loginUser.getUser().getUserName());
                wbItem.setCreateTime(new Date());
                tWarehousebillsitemsMapper.insertTWarehousebillsitems(wbItem);
            }
        }
        //  附件添加
        if (StringUtils.isNotNull(tWhgenleg)) {
            JSONArray jsonDrArray = JSONArray.parseArray(tWhgenleg);
            List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
            for (TEnclosure tEnclosure : tEnclosureList) {
                tEnclosure.setfPid(fPid);
                tEnclosure.setCreateBy(loginUser.getUser().getUserName());
                tEnclosure.setCreateTime(new Date());
                tEnclosureMapper.insertTEnclosure(tEnclosure);
            }
        }
        // 收款明细添加
        if (tWarehousebillsfeesDr != null) {
            JSONArray jsonDrArray = JSONArray.parseArray(tWarehousebillsfeesDr);
            List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
            for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
                // 检验  数量*单价=金额
                if (wbDr.getfQty() != null && !wbDr.getfQty().equals("")
                        && wbDr.getfUnitprice() != null && !wbDr.getfUnitprice().equals("")) {
                    BigDecimal fqty = wbDr.getfQty();
                    BigDecimal funitprice = wbDr.getfUnitprice();
                    Long result = check(fqty, funitprice);
                    wbDr.setfAmount(result);
                }
                wbDr.setfPid(fPid);
                wbDr.setfDc("D");
                wbDr.setCreateBy(loginUser.getUser().getUserName());
                wbDr.setCreateTime(new Date());
                tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
            }
        }
        // 付款明细添加
        if (tWarehousebillsfeesCr != null) {
            JSONArray jsonCrArray = JSONArray.parseArray(tWarehousebillsfeesCr);
            List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
            for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
                // 检验  数量*单价=金额
                /*if (wbCr.getfQty() != null && !wbCr.getfQty().equals("")
                        && wbCr.getfUnitprice() != null && !wbCr.getfUnitprice().equals("")) {
                    BigDecimal fqty = wbCr.getfQty();
                    BigDecimal funitprice = wbCr.getfUnitprice();
                    Long result = check(fqty, funitprice);
                    wbCr.setfAmount(result);
                }*/
                wbCr.setfPid(fPid);
                wbCr.setfDc("C");
                wbCr.setCreateBy(loginUser.getUser().getUserName());
                wbCr.setCreateTime(new Date());
                tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
            }
        }


        return AjaxResult.success();
    }

    // 入库 收费明细 校验
    public Long check (BigDecimal number ,BigDecimal unitPrice){
        BigDecimal result1 =  number.multiply(unitPrice);
        // 保留两位小数且四舍五入
        result1 = result1.setScale(2, BigDecimal.ROUND_HALF_UP);
        // 转换去掉小数点
        String result=result1.toString().replace(".","");
        return Long.valueOf(result);
    }


    /**
     * 修改详情主表
     *
     * @param tWarehousebills 详情主表
     * @return 结果
     */
    @Override
    public int updateTWarehousebills(TWarehouseBills tWarehousebills) {
        tWarehousebills.setUpdateTime(DateUtils.getNowDate());
        return tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
    }

    /**
     * 批量删除详情主表
     *
     * @param fIds 需要删除的详情主表ID
     * @return 结果
     */
    @Override
    public int deleteTWarehousebillsByIds(Long[] fIds) {
        return tWarehouseBillsMapper.deleteTWarehousebillsByIds(fIds);
    }

    /**
     * 删除详情主表信息
     *
     * @param fId 详情主表ID
     * @return 结果
     */
    @Override
    public int deleteTWarehousebillsById(Long fId) {
        return tWarehouseBillsMapper.deleteTWarehousebillsById(fId);
    }

    @Override
    public String getWarehouseInStockBillsNo(TWarehouseBills tWarehouseBills) {

        return null;
    }

    @Override
    public String getWarehouseOutStockBillsNo(TWarehouseBills tWarehouseBills) {
        return null;
    }


    @Override
    public int revokeTWarehousebillsById(Long fId, LoginUser loginUser, String billsType) {
        // 查询 仓库主表信息、库存明细信息
        TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
        // 查询库存明细从表数据
        TWarehousebillsitems tWarehousebillsitems = new TWarehousebillsitems();
        tWarehousebillsitems.setfPid(fId);
        List<TWarehousebillsitems> warehousebillsitems = tWarehousebillsitemsMapper.selectTWarehousebillsitemsList(tWarehousebillsitems);
        // 撤销 库存总账
        if (StringUtils.isNotEmpty(warehousebillsitems)) {
            for (TWarehousebillsitems wb : warehousebillsitems) {
                // 查询库存总账
                TWhgenleg tWhgenle=queryTWhgenleg(tWarehousebills,wb);
                if(!StringUtils.isNull(tWhgenle)){ // 非空修改
                    updateTWhgenlegData(wb,tWhgenle.getfId(),billsType);
                }
            }
        }
        // 修改主表信息
        tWarehousebills.setUpdateBy(loginUser.getUser().getUserName());
        tWarehousebills.setUpdateTime(new Date());
        tWarehousebills.setfBillstatus("3"); //撤销状态
        return tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
    }

}