|
@@ -1,5 +1,6 @@
|
|
package com.yh.saas.plugin.yiliangyiyun.service.impl;
|
|
package com.yh.saas.plugin.yiliangyiyun.service.impl;
|
|
|
|
|
|
|
|
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
|
import com.baomidou.mybatisplus.plugins.Page;
|
|
import com.baomidou.mybatisplus.plugins.Page;
|
|
import com.google.common.collect.Lists;
|
|
import com.google.common.collect.Lists;
|
|
import com.yh.saas.common.support.util.IdGenerator;
|
|
import com.yh.saas.common.support.util.IdGenerator;
|
|
@@ -7,6 +8,7 @@ import com.yh.saas.plugin.yiliangyiyun.constant.StatusEnum;
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.HyCargoOwnerCapitalInfo;
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.HyCargoOwnerCapitalInfo;
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.HyCargoOwnerInfo;
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.HyCargoOwnerInfo;
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.HyCompanyInfo;
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.HyCompanyInfo;
|
|
|
|
+import com.yh.saas.plugin.yiliangyiyun.entity.OrderInfo;
|
|
import com.yh.saas.plugin.yiliangyiyun.exception.YException;
|
|
import com.yh.saas.plugin.yiliangyiyun.exception.YException;
|
|
import com.yh.saas.plugin.yiliangyiyun.exception.YExceptionEnum;
|
|
import com.yh.saas.plugin.yiliangyiyun.exception.YExceptionEnum;
|
|
import com.yh.saas.plugin.yiliangyiyun.mapper.HyCargoOwnerCapitalInfoMapper;
|
|
import com.yh.saas.plugin.yiliangyiyun.mapper.HyCargoOwnerCapitalInfoMapper;
|
|
@@ -14,6 +16,7 @@ import com.yh.saas.plugin.yiliangyiyun.service.ICargoOwnerInfoService;
|
|
import com.yh.saas.plugin.yiliangyiyun.service.ICompanyInfoService;
|
|
import com.yh.saas.plugin.yiliangyiyun.service.ICompanyInfoService;
|
|
import com.yh.saas.plugin.yiliangyiyun.service.IHyCargoOwnerCapitalInfoService;
|
|
import com.yh.saas.plugin.yiliangyiyun.service.IHyCargoOwnerCapitalInfoService;
|
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
|
|
|
+import com.yh.saas.plugin.yiliangyiyun.service.IOrderInfoService;
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
@@ -39,6 +42,8 @@ public class HyCargoOwnerCapitalInfoServiceImpl extends ServiceImpl<HyCargoOwner
|
|
private ICargoOwnerInfoService cargoOwnerInfoService;
|
|
private ICargoOwnerInfoService cargoOwnerInfoService;
|
|
@Autowired
|
|
@Autowired
|
|
private ICompanyInfoService companyInfoService;
|
|
private ICompanyInfoService companyInfoService;
|
|
|
|
+ @Autowired
|
|
|
|
+ private IOrderInfoService orderInfoService;
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -249,4 +254,55 @@ public class HyCargoOwnerCapitalInfoServiceImpl extends ServiceImpl<HyCargoOwner
|
|
page.setSize(hyCargoOwnerCapitalInfo.getPageSize());
|
|
page.setSize(hyCargoOwnerCapitalInfo.getPageSize());
|
|
return page;
|
|
return page;
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 查看北斗轨迹扣费
|
|
|
|
+ * @param hyCargoOwnerCapitalInfo
|
|
|
|
+ * @return
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
|
+ public String lookBeiDou(HyCargoOwnerCapitalInfo hyCargoOwnerCapitalInfo){
|
|
|
|
+ //新增账单信息
|
|
|
|
+ hyCargoOwnerCapitalInfo.setId(IdGenerator.generateUUID());
|
|
|
|
+ hyCargoOwnerCapitalInfo.setTypes("查看北斗轨迹");
|
|
|
|
+ boolean one = this.insert(hyCargoOwnerCapitalInfo);
|
|
|
|
+ //更新货主查看北斗轨迹时间
|
|
|
|
+ OrderInfo orderInfo = orderInfoService.selectById(hyCargoOwnerCapitalInfo.getOrderId());
|
|
|
|
+ orderInfo.setLookBeiDouDate(new Date());
|
|
|
|
+ orderInfoService.updateById(orderInfo);
|
|
|
|
+
|
|
|
|
+ if ("1".equals(hyCargoOwnerCapitalInfo.getFlag())){
|
|
|
|
+ //查询个人货主信息
|
|
|
|
+ HyCargoOwnerInfo hyCargoOwnerInfo = cargoOwnerInfoService.selectOne(new EntityWrapper<HyCargoOwnerInfo>()
|
|
|
|
+ .eq("common_id",hyCargoOwnerCapitalInfo.getCommonId()));
|
|
|
|
+ //账户余额不足
|
|
|
|
+ if (hyCargoOwnerCapitalInfo.getAmountMoney() > hyCargoOwnerInfo.getAccountBalance()){
|
|
|
|
+ throw new YException(YExceptionEnum.INSUFFICIENT_ACCOUNT_BALANCE);
|
|
|
|
+ }
|
|
|
|
+ Double d = hyCargoOwnerInfo.getAccountBalance();
|
|
|
|
+ hyCargoOwnerInfo.setAccountBalance(d - hyCargoOwnerCapitalInfo.getAmountMoney());
|
|
|
|
+ boolean two = cargoOwnerInfoService.updateById(hyCargoOwnerInfo);
|
|
|
|
+ if (one && two){
|
|
|
|
+ return "ok";
|
|
|
|
+ }else {
|
|
|
|
+ return "ng";
|
|
|
|
+ }
|
|
|
|
+ }else {
|
|
|
|
+ //查询企业信息
|
|
|
|
+ HyCompanyInfo hyCompanyInfo = companyInfoService.selectById(hyCargoOwnerCapitalInfo.getCompanyId());
|
|
|
|
+ //账户余额不足
|
|
|
|
+ if (hyCargoOwnerCapitalInfo.getAmountMoney() > hyCompanyInfo.getAccountBalance()){
|
|
|
|
+ throw new YException(YExceptionEnum.INSUFFICIENT_ACCOUNT_BALANCE);
|
|
|
|
+ }
|
|
|
|
+ Double d = hyCompanyInfo.getAccountBalance();
|
|
|
|
+ hyCompanyInfo.setAccountBalance(d - hyCargoOwnerCapitalInfo.getAmountMoney());
|
|
|
|
+ boolean two = companyInfoService.updateById(hyCompanyInfo);
|
|
|
|
+ if (one && two){
|
|
|
|
+ return "ok";
|
|
|
|
+ }else {
|
|
|
|
+ return "ng";
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
}
|
|
}
|