pco/sp-server/src/main/java/com/pj/project/tb_business/TbBusinessService.java

package com.pj.project.tb_business;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.stream.Collectors;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.pj.api.wx.bo.MsgDataBO;
import com.pj.api.wx.service.WxService;
import com.pj.constants.UserTypeEnum;
import com.pj.current.config.CarConfig;
import com.pj.current.config.MyConfig;
import com.pj.current.config.PartConfig;
import com.pj.current.config.WxConfig;
import com.pj.current.satoken.StpUserUtil;
import com.pj.project.tb_business_car.TbBusinessCar;
import com.pj.project.tb_business_car.TbBusinessCarService;
import com.pj.project.tb_business_item.TbBusinessItem;
import com.pj.project.tb_business_item.TbBusinessItemService;
import com.pj.project.tb_business_people.TbBusinessPeople;
import com.pj.project.tb_business_people.TbBusinessPeopleService;
import com.pj.project.tb_car.TbCar;
import com.pj.project.tb_car.TbCarService;
import com.pj.project.tb_costomer.TbCostomer;
import com.pj.project.tb_costomer.TbCostomerService;
import com.pj.project.tb_declare.TbDeclare;
import com.pj.project.tb_declare.TbDeclareService;
import com.pj.project.tb_driver.TbDriver;
import com.pj.project.tb_driver.TbDriverService;
import com.pj.project.tb_goods.TbGoods;
import com.pj.project.tb_goods.TbGoodsService;
import com.pj.project.tb_item.TbItem;
import com.pj.project.tb_item.TbItemService;
import com.pj.project.tb_item_type.TbItemType;
import com.pj.project.tb_item_type.TbItemTypeService;
import com.pj.project.tb_notices.TbNoticesMapper;
import com.pj.project.tb_notices.TbNoticesService;
import com.pj.project.tb_pass_record.TbPassRecord;
import com.pj.project.tb_pass_record.TbPassRecordService;
import com.pj.project.tb_unit.TbUnit;
import com.pj.project.tb_unit.TbUnitService;
import com.pj.project4sp.admin.SpAdmin;
import com.pj.project4sp.global.BusinessException;
import com.pj.project4sp.role.SpRoleUtil;
import com.pj.project4sp.role4permission.SpRolePermissionService;
import com.pj.utils.so.SoMap;
import org.aspectj.weaver.loadtime.Aj;
import org.omg.CORBA.OBJ_ADAPTER;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import com.pj.utils.sg.*;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

/**
 * Service: tb_business -- 入境登记
 *
 * @author qzy
 */
@Service
@Transactional
public class TbBusinessService extends ServiceImpl<TbBusinessMapper, TbBusiness> implements IService<TbBusiness> {

    /**
     * 底层 Mapper 对象
     */
    @Autowired
    TbBusinessMapper tbBusinessMapper;
    @Resource
    private TbCarService tbCarService;
    @Resource
    private TbDriverService tbDriverService;
    @Resource
    private TbCostomerService tbCostomerService;

    @Resource
    private TbItemService tbItemService;
    @Resource
    private TbItemTypeService tbItemTypeService;
    @Resource
    private TbBusinessItemService tbBusinessItemService;

    @Resource
    TbUnitService tbUnitService;
    @Resource
    TbBusinessPeopleService tbBusinessPeopleService;
    @Resource
    private PartConfig partConfig;
    @Resource
    private CarConfig carConfig;

    @Resource
    private TbNoticesService tbNoticesService;
    @Resource
    TbBusinessCarService tbBusinessCarService;
    @Resource
    @Lazy
    TbDeclareService tbDeclareService;
    @Resource
    WxConfig wxConfig;
    @Resource
    @Lazy
    WxService wxService;
    @Resource
    MyConfig myConfig;


    public TbBusiness checkCarNo(String carNo) {
        QueryWrapper<TbBusiness> ew = new QueryWrapper<>();
        ew.eq("card_no", carNo)
                .eq("admin_confirm_out", 0);
        return this.getOne(ew);
    }

    /**
     * 增
     */
    public AjaxJson addOrUpdate(TbBusiness t) {
        if (StrUtil.isNotEmpty(t.getId()) && StrUtil.isNotEmpty(t.getDeclareNo())) {
            TbBusiness db = this.getById(t.getId());
            if (!StrUtil.equals(db.getDeclareNo(), t.getDeclareNo())) {
                TbDeclare tbDeclare = tbDeclareService.findByDeclareNo(db.getDeclareNo());
                if (tbDeclare != null) {
                    tbDeclare.setBusinessId("");
                    tbDeclareService.updateById(tbDeclare);
                }
            }
        }
        Double carSize = t.getCardSize();
        if (carSize != null && carSize > carConfig.getMaxLength()) {
            return AjaxJson.getError("车辆规格不能大于" + carConfig.getMaxLength());
        }
        Double netWeight = t.getNetWeight();
        if (netWeight != null && netWeight > carConfig.getMaxWeight()) {
            return AjaxJson.getError("车辆载重不能大于" + carConfig.getMaxWeight());
        }
        t.setCreateBy(StpUserUtil.getAdmin().getName());
        createCarUnit(t);
        String customerId = t.getCustomerId();
        TbCostomer tbCostomer = tbCostomerService.getById(customerId);
        t.setCustomerName(tbCostomer.getName()).setCustomerType(tbCostomer.getPayType());
        if (StrUtil.equals(customerId, UserTypeEnum.PLATFORM_ADMIN.getCustomerId())) {
            t.setConfirmInputBy(StpUserUtil.getAdmin().getName())
                    .setConfirmInput(1)
                    .setConfirmInputTime(new Date());
        }
        if (StrUtil.isEmpty(t.getId())) {
            t.setCreateTime(new Date());
            t.setNo(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmm")) + RandomUtil.randomNumbers(4));
            storeMsg(t.getCustomerId(), "新增一条业务数据:【" + t.getNo() + "】" + DateUtil.now() + "。");
        } else {
            storeMsg(t.getCustomerId(), "业务订单:【" + t.getNo() + "】数据发生更改，" + DateUtil.now() + "。");
        }
        saveOrUpdate(t);
        createBusinessPeople(t);
        tbBusinessItemService.removeByBusinessId(t.getId());
        BigDecimal price = new BigDecimal(0);
        List<TbBusinessItem> items = JSONUtil.toList(t.getItemJson(), TbBusinessItem.class);
        int index = 1;
        for (TbBusinessItem item : items) {
            Double num = NumberUtil.parseDouble(item.getNum());
            TbItem tbItem = tbItemService.getById(item.getItemId());
            String typeId = tbItem.getTypeId();
            price = price.add(NumberUtil.mul(num, tbItem.getPrice()));
            TbItemType tbItemType = tbItemTypeService.getById(typeId);
            item.setBusinessId(t.getId()).setItemCode(tbItem.getItemCode())
                    .setItemName(tbItem.getItemName()).setItemPrice(tbItem.getPrice())
                    .setItemTypeId(typeId).setItemTypeName(tbItemType.getName()).setBusinessType(tbItemType.getBusinessType())
                    .setUnit(tbItem.getUnit()).setTotal(NumberUtil.mul(num, tbItem.getPrice())).setCreateTime(new Date())
                    .setNo(t.getNo() + "0" + index);
            tbBusinessItemService.save(item);
            String businessType = tbItemType.getBusinessType();
            if (!StrUtil.equals(businessType, TbCostomer.CustomerEnum.BUSINESS_TYPE.getType())) {
                String remark = "车牌：" + t.getCardNo();
                if (StrUtil.isNotEmpty(t.getChinaCarNo())) {
                    remark += "、" + t.getChinaCarNo();
                }
                MsgDataBO msgDataBO = new MsgDataBO("订单号："+item.getNo(), tbItemType.getName(), tbItem.getItemName(), t.getGoodsName(), DateUtil.now(), remark);
                StrUtil.splitTrim(businessType, ",").forEach(type -> {
                    List<String> openidList = tbCostomerService.findByBusinessTypeOpenid(type);
                    openidList.forEach(openid -> {
                        String detailUrl = myConfig.getWebDomain() + "/pages/business-item/item-detail?itemId=" + item.getId() + "&openid=" + openid;
                        wxService.sendTemplateMsg(wxConfig.getBusinessNoticeTemplate(), openid, msgDataBO, detailUrl);
                    });
                });
            }
            index++;
        }
        List<TbBusinessCar> carList = JSONUtil.toList(t.getCarJson(), TbBusinessCar.class);
        String chinaCarNo = carList.stream().map(TbBusinessCar::getCarNo).collect(Collectors.joining("、"));
        t.setChinaCarNo(StrUtil.isNotEmpty(chinaCarNo) ? chinaCarNo.toUpperCase() : "");
        carList.forEach(tbBusinessCar -> {
            String carNo = tbBusinessCar.getCarNo().toUpperCase();
            TbBusinessCar db = tbBusinessCarService.findByBusinessIdAndCarNo(t.getId(), carNo);
            if (db != null) {
                tbBusinessCar.setId(db.getId());
            }
            TbBusinessCar car = tbBusinessCarService.findInAndNoBusinessCar(carNo);
            if (car != null) {
                tbBusinessCar.setId(car.getId()).setRealInTime(car.getRealInTime());
            }
            tbBusinessCar.setBusinessId(t.getId());
            tbBusinessCar.setCarNo(carNo);
            tbBusinessCar.setBusinessId(t.getId()).setCustomerId(t.getCustomerId());
        });
        String yueCarNo = t.getCardNo().toUpperCase();
        TbBusinessCar yueCar = tbBusinessCarService.findInAndNoBusinessCar(yueCarNo);
        if (yueCar == null) {
            yueCar = tbBusinessCarService.findByBusinessIdAndCarNo(t.getId(), yueCarNo);
            if (yueCar == null) {
                yueCar = new TbBusinessCar();
            }
        }
        yueCar.setBusinessId(t.getId()).setCarSize(t.getCardSize()).setCarNo(yueCarNo).setCustomerId(t.getCustomerId());
        carList.add(yueCar);
        tbBusinessCarService.saveOrUpdateBatch(carList);
        BigDecimal initCarPartMoney = partConfig.getBasePrice();
        t.setItemPrice(price)
                .setTotalMoney(price.add(initCarPartMoney.multiply(new BigDecimal(carList.size()))))
                .setChinaPartMoney(initCarPartMoney.multiply(new BigDecimal(carList.size() - 1)))
                .setPartMoney(initCarPartMoney);
        this.saveOrUpdate(t);
        if (StrUtil.isNotEmpty(t.getDeclareNo())) {
            TbDeclare tbDeclare = tbDeclareService.findByDeclareNo(t.getDeclareNo());
            tbDeclare.setBusinessId(t.getId());
            tbDeclareService.updateById(tbDeclare);
        }
        return AjaxJson.getSuccess();
    }

    public void storeMsg(String businessCustomerId, String content) {
        String currentCustomerId = StpUserUtil.getCustomerId();
        if (StrUtil.equals(currentCustomerId, UserTypeEnum.PLATFORM_ADMIN.getCustomerId())) {
            BusinessMessageManager.set(businessCustomerId, content);
        } else {
            BusinessMessageManager.set(UserTypeEnum.PLATFORM_ADMIN.getCustomerId(), content);
        }
    }

    private void createBusinessPeople(TbBusiness t) {
        tbBusinessPeopleService.removeByBusinessId(t.getId());
        List<TbBusinessPeople> peopleList = JSONUtil.toList(t.getPeopleJson(), TbBusinessPeople.class);
        peopleList.forEach(tbBusinessPeople -> tbBusinessPeople.setBusinessId(t.getId()).setCreateTime(new Date()));
        tbBusinessPeopleService.saveBatch(peopleList);
    }

    private void createCarUnit(TbBusiness t) {
        TbUnit tbUnit = tbUnitService.findByUnit(t.getCardSize());
        if (tbUnit == null) {
            tbUnit = new TbUnit();
            tbUnit.setUnit(t.getCardSize() + "");
            tbUnitService.save(tbUnit);
        }
    }


    private TbDriver createDriver(TbBusiness business) {
        TbDriver tbDriver = tbDriverService.findByIdCardNo(business.getCardNo());
        if (tbDriver == null) {
            tbDriver = new TbDriver();
            tbDriver.setCreateTime(new Date()).setIdCard(business.getCardNo())
                    .setName(business.getDriverName()).setPhone(business.getDriverPhone());
            tbDriverService.save(tbDriver);
        }
        return tbDriver;

    }

    private TbCar createCar(TbBusiness business) {
        String cardNo = business.getCardNo();
        TbCar tbCar = tbCarService.findByCardNo(cardNo);
        if (tbCar == null) {
            tbCar = new TbCar();
        }
        tbCar.setCardNo(cardNo)
                .setCardSize(business.getCardSize())
                .setCountryName(business.getCountryName())
                .setLastGoodsName(business.getGoodsName())
                .setLastNetWeight(business.getNetWeight());
        tbCarService.saveOrUpdate(tbCar);
        return tbCar;
    }


    /**
     * 查集合 - 根据条件（参数为空时代表忽略指定条件）
     */
    public List<TbBusiness> getList(SoMap so) {

        return tbBusinessMapper.getList(so);
    }


    public void pay(String id, String payTicket) {
        TbBusiness tbBusiness = this.getById(id);
        SpAdmin admin = StpUserUtil.getAdmin();
        tbBusiness.setPayStatus(2).setPayBy(admin.getName())
                .setPayBy(StpUserUtil.getAdmin().getName())
                .setPayTicket(payTicket)
                .setPayTime(new Date());
        if (StrUtil.equals(admin.getCustomerId(), UserTypeEnum.PLATFORM_ADMIN.getCustomerId())) {
            tbBusiness.setAdminConfirmPay(1).setPayStatus(3)
                    .setAdminConfirmPayBy(admin.getName()).setAdminConfirmPayTime(new Date());
        }
        this.updateById(tbBusiness);
        storeMsg(tbBusiness.getCustomerId(), "业务订单【" + tbBusiness.getNo() + "】已支付" + DateUtil.now() + "。");
        //发送消息
        String text = "您的费用已支付，业务单号[" + tbBusiness.getNo() + "]";
        tbNoticesService.sendNotice(tbBusiness.getId(), tbBusiness.getNo(), tbBusiness.getCustomerId(), text);
    }

    public void confirm(List<String> ids) {
        ids.forEach(id -> {
            TbBusiness business = this.getById(id);
            business.setConfirmInput(1).setConfirmInputTime(new Date()).setConfirmInputBy(StpUserUtil.getAdmin().getName());
            this.updateById(business);
            storeMsg(business.getCustomerId(), "业务订单【" + business.getNo() + "】已确认" + DateUtil.now() + "。");
        });
    }

    public void adminConfirmPay(List<String> ids, String ticket) {
        ids.forEach(id -> {
            TbBusiness business = this.getById(id);
            business.setAdminConfirmPayTime(new Date()).setAdminConfirmPay(1).setAdminConfirmPayBy(StpUserUtil.getAdmin().getName())
                    .setPayStatus(3).setPayTicket(ticket);
            this.updateById(business);
            storeMsg(business.getCustomerId(), "业务订单【" + business.getNo() + "】已确认支付" + DateUtil.now() + "。");
            //发送消息
            String text = "您的费用已支付，业务单号[" + business.getNo() + "]";
            tbNoticesService.sendNotice(business.getId(), business.getNo(), business.getCustomerId(), text);
        });
    }

    public TbBusiness findCarTheNewRecord(String carNo, int inOrOut) {
        QueryWrapper<TbBusiness> ew = new QueryWrapper<>();
        ew.eq("card_no", carNo);
        if (inOrOut == 1) {
            ew.eq("admin_confirm_in", 0).isNull("in_channel");
        } else {
            ew.eq("admin_confirm_out", 0).isNull("out_channel").isNotNull("real_in_time");
        }
        return getOne(ew);
    }

    @Deprecated
    public void adminConfirmIn(String id, String inChannel) {
        TbBusiness tbBusiness = this.getById(id);
        tbBusiness.setRealInTime(new Date()).setInChannel(inChannel);
        this.updateById(tbBusiness);

        //更新境外车入场记录

        //更新中国车入场记录

        //发送消息
        String text = "您的车辆已入场，业务单号[" + tbBusiness.getNo() + "]";
        tbNoticesService.sendNotice(tbBusiness.getId(), tbBusiness.getNo(), tbBusiness.getCustomerId(), text);

    }

    public void adminOut(String id, Date outDayTime, String outChannel, String carType) {
        TbBusiness tbBusiness = this.getById(id);
        tbBusiness.setOutDayTime(outDayTime).setOutChannel(outChannel);
        calculationPartMoney(carType, tbBusiness);
        this.updateById(tbBusiness);

        //更新境外车出场记录

        //更新中国车出场记录

        //发送消息
        String text = "您的车辆已离场，业务单号[" + tbBusiness.getNo() + "]";
        tbNoticesService.sendNotice(tbBusiness.getId(), tbBusiness.getNo(), tbBusiness.getCustomerId(), text);

    }

    @Async
    public void calculationPartMoney(String itemType, TbBusiness tbBusiness) {
        Date iTime = tbBusiness.getRealInTime();
        Date oTime = tbBusiness.getOutDayTime();
        if (itemType.contains("中国")) {
            iTime = tbBusiness.getChinaCarInTime();
            oTime = tbBusiness.getChinaCarOutTime();
        }
        BigDecimal price = calculationPartMoney(iTime, oTime);
        if (itemType.contains("中国")) {
            int len = tbBusiness.getCardNo().split(" ").length;
            tbBusiness.setChinaPartMoney(price.multiply(new BigDecimal(len)));
        } else {
            tbBusiness.setPartMoney(price);
        }
        tbBusiness.setTotalMoney(tbBusiness.getItemPrice().add(tbBusiness.getChinaPartMoney()).add(tbBusiness.getPartMoney()));
    }

    public BigDecimal calculationPartMoney(Date iTime, Date oTime) {
        LocalDateTime inDayTime = iTime.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
        LocalDateTime outDayTime = oTime.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
        long minutes = ChronoUnit.MINUTES.between(inDayTime, outDayTime);
        BigDecimal zero = new BigDecimal("0");
        if (minutes < 0) {
            return zero;
        }
        long days = ChronoUnit.DAYS.between(inDayTime.toLocalDate(), outDayTime.toLocalDate());
        long hour = ChronoUnit.HOURS.between(inDayTime, outDayTime);
        BigDecimal basePrice = partConfig.getBasePrice();
        BigDecimal extraPrice = partConfig.getExtraPrice();
        return basePrice.add(basePrice.multiply(new BigDecimal(hour / 24))).add(new BigDecimal(days).multiply(extraPrice));
    }

    /**
     * @param carNo
     * @param inOrOut 1入 2出
     * @return
     */
    public TbBusiness findByChinaCarNo(String carNo, int inOrOut) {
        QueryWrapper<TbBusiness> ew = new QueryWrapper<>();
        ew.like("china_car_no", carNo);
        if (inOrOut == 1) {
            ew.eq("admin_confirm_in", 0).isNull("china_car_in_channel");
        } else {
            ew.eq("admin_confirm_out", 0)
                    .isNull("china_car_out_channel")
                    .isNotNull("china_car_in_time");
        }
        return this.getOne(ew);
    }


    public TbBusiness finByNo(String no) {
        QueryWrapper<TbBusiness> ew = new QueryWrapper<>();
        ew.eq("no", no);
        return getOne(ew);
    }

    public Map<String, Object> getBusinessMoney(String carId, String state) {
        Map<String, Object> result = new HashMap<>();
        TbBusinessCar car = tbBusinessCarService.getById(carId);
        String businessId = car.getBusinessId();
        result.put("businessId", businessId);
        List<TbBusinessCar> cars = tbBusinessCarService.findByBusinessId(businessId);
        Date now = new Date();
        List<Map<String, Object>> carsList = new ArrayList<>();
        for (TbBusinessCar tbBusinessCar : cars) {
            double partMoney = tbBusinessCar.getBasePartMoney().doubleValue();
            if (!StrUtil.equals("STATE", state)) {
                Date inTime = tbBusinessCar.getRealInTime();
                if (inTime != null) {
                    BigDecimal price = this.calculationPartMoney(inTime, now);
                    BigDecimal money = tbBusinessCar.getMoney();
                    BigDecimal basePrice = tbBusinessCar.getBasePartMoney();
                    partMoney = money == null ? price.subtract(basePrice).doubleValue() : price.subtract(money).doubleValue();
                } else {
                    partMoney = 0D;
                }
            }
            Map<String, Object> carMap = new HashMap<>();
            carMap.put("price", partMoney);
            carMap.put("id", tbBusinessCar.getId());
            carMap.put("carNo", tbBusinessCar.getCarNo());
            carMap.put("pay", tbBusinessCar.getPay());
            carsList.add(carMap);
        }
        result.put("carList", carsList);
        TbBusiness tbBusiness = this.getById(businessId);
        if (tbBusiness != null && tbBusiness.getPayStatus() != TbBusiness.PayStatus.HAS_PAY_CONFIRM.getCode()) {
            List<TbBusinessItem> items = tbBusinessItemService.findByBusinessId(businessId);
            result.put("itemsPrice", tbBusiness.getItemPrice());
            result.put("businessId", businessId);
            List<Map<String, Object>> itemList = new ArrayList<>();
            for (TbBusinessItem item : items) {
                Map<String, Object> itemMap = new HashMap<>();
                itemMap.put("id", item.getId());
                itemMap.put("name", item.getItemName());
                itemMap.put("price", item.getItemPrice());
                itemMap.put("pay", item.getPayStatus());
                itemList.add(itemMap);
            }
            result.put("itemList", itemList);
        }
        return result;
    }

    public void uploadReport(TbBusiness tbBusiness) {
        this.updateById(tbBusiness);
        List<TbBusinessCar> cars = tbBusinessCarService.findByBusinessId(tbBusiness.getId());
        cars.forEach(tbBusinessCar -> tbBusinessCar.setIsLock(0));
        tbBusinessCarService.updateBatchById(cars);
    }
}