|
@@ -1,24 +1,25 @@
|
|
|
package com.ydtech.modules.admin.service.impl;
|
|
package com.ydtech.modules.admin.service.impl;
|
|
|
|
|
|
|
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.ydtech.core.page.HttpResult;
|
|
import com.ydtech.core.page.HttpResult;
|
|
|
import com.ydtech.modules.admin.constants.MoneyAttrConstants;
|
|
import com.ydtech.modules.admin.constants.MoneyAttrConstants;
|
|
|
import com.ydtech.modules.admin.constants.WithdrawTypeConstants;
|
|
import com.ydtech.modules.admin.constants.WithdrawTypeConstants;
|
|
|
import com.ydtech.modules.admin.dao.SysUserAccountMapper;
|
|
import com.ydtech.modules.admin.dao.SysUserAccountMapper;
|
|
|
|
|
+import com.ydtech.modules.admin.model.SysUser;
|
|
|
import com.ydtech.modules.admin.model.po.SysAmountAuditingEntity;
|
|
import com.ydtech.modules.admin.model.po.SysAmountAuditingEntity;
|
|
|
import com.ydtech.modules.admin.model.po.SysUserAccount;
|
|
import com.ydtech.modules.admin.model.po.SysUserAccount;
|
|
|
import com.ydtech.modules.admin.model.po.SysUserAccountHistory;
|
|
import com.ydtech.modules.admin.model.po.SysUserAccountHistory;
|
|
|
import com.ydtech.modules.admin.model.po.SysUserBankCard;
|
|
import com.ydtech.modules.admin.model.po.SysUserBankCard;
|
|
|
|
|
+import com.ydtech.modules.admin.model.vo.SubOrder;
|
|
|
import com.ydtech.modules.admin.model.vo.SysUserAccountVo;
|
|
import com.ydtech.modules.admin.model.vo.SysUserAccountVo;
|
|
|
-import com.ydtech.modules.admin.service.SysAmountAuditingService;
|
|
|
|
|
-import com.ydtech.modules.admin.service.SysUserAccountHistoryService;
|
|
|
|
|
-import com.ydtech.modules.admin.service.SysUserAccountService;
|
|
|
|
|
-import com.ydtech.modules.admin.service.SysUserBankCardService;
|
|
|
|
|
|
|
+import com.ydtech.modules.admin.service.*;
|
|
|
import com.ydtech.modules.base.controller.BaseController;
|
|
import com.ydtech.modules.base.controller.BaseController;
|
|
|
import com.ydtech.modules.esm.service.EsmUserReferrerService;
|
|
import com.ydtech.modules.esm.service.EsmUserReferrerService;
|
|
|
import com.ydtech.modules.message.constants.MessageTypeConstants;
|
|
import com.ydtech.modules.message.constants.MessageTypeConstants;
|
|
|
import com.ydtech.modules.message.service.MessageSecretaryService;
|
|
import com.ydtech.modules.message.service.MessageSecretaryService;
|
|
|
|
|
+import com.ydtech.modules.order.dao.InsAreaCompanyMapper;
|
|
|
import com.ydtech.modules.order.dao.InsOrdersMapper;
|
|
import com.ydtech.modules.order.dao.InsOrdersMapper;
|
|
|
import com.ydtech.modules.order.entity.BasePageResult;
|
|
import com.ydtech.modules.order.entity.BasePageResult;
|
|
|
import com.ydtech.modules.order.entity.InsOrders;
|
|
import com.ydtech.modules.order.entity.InsOrders;
|
|
@@ -71,6 +72,11 @@ public class SysUserAccountServiceImpl extends ServiceImpl<SysUserAccountMapper,
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private MessageSecretaryService messageSecretaryService;
|
|
private MessageSecretaryService messageSecretaryService;
|
|
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private InsAreaCompanyMapper insAreaCompanyMapper;
|
|
|
|
|
+
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private SysUserService sysUserService;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional
|
|
@Transactional
|
|
@@ -281,30 +287,50 @@ public class SysUserAccountServiceImpl extends ServiceImpl<SysUserAccountMapper,
|
|
|
if (ObjectUtils.isEmpty(sysUserAccount)) {
|
|
if (ObjectUtils.isEmpty(sysUserAccount)) {
|
|
|
return sysUserAccountVo;
|
|
return sysUserAccountVo;
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
BeanUtils.copyProperties(sysUserAccount, sysUserAccountVo);
|
|
BeanUtils.copyProperties(sysUserAccount, sysUserAccountVo);
|
|
|
-
|
|
|
|
|
BigDecimal willHalding = BigDecimal.ZERO; //预收手续费佣金
|
|
BigDecimal willHalding = BigDecimal.ZERO; //预收手续费佣金
|
|
|
BigDecimal willDocumentary = BigDecimal.ZERO; //预收 非跟单佣金
|
|
BigDecimal willDocumentary = BigDecimal.ZERO; //预收 非跟单佣金
|
|
|
BigDecimal willPromotion = BigDecimal.ZERO; //预收 推广
|
|
BigDecimal willPromotion = BigDecimal.ZERO; //预收 推广
|
|
|
|
|
+ BigDecimal receivedWillHalding = BigDecimal.ZERO; //实收手续费佣金
|
|
|
|
|
+ BigDecimal receivedWillDocumentary = BigDecimal.ZERO; //实收非跟单佣金
|
|
|
|
|
+ BigDecimal receivedWillPromotion = BigDecimal.ZERO; //实收推广费
|
|
|
StringBuffer stringBuffer = new StringBuffer();
|
|
StringBuffer stringBuffer = new StringBuffer();
|
|
|
-
|
|
|
|
|
- willPromotion = this.willPromotion(willPromotion, userId); // 佣金
|
|
|
|
|
|
|
+ // 预收手续费佣金
|
|
|
|
|
+ willPromotion = this.willPromotionAll(willPromotion, userId,"1");
|
|
|
|
|
+ // 实收手续费佣金
|
|
|
|
|
+ receivedWillPromotion = this.willPromotionAll(willPromotion, userId,"2");
|
|
|
// add by hxl 修改sql 添加承保状态和不在审核表中的条件 begin ===============
|
|
// add by hxl 修改sql 添加承保状态和不在审核表中的条件 begin ===============
|
|
|
- //List<InsFeeOrderNew> willList = insFeeOrderNewService.getByUserId(userId);
|
|
|
|
|
- List<InsFeeOrderNew> willList = insFeeOrderNewService.getByUserIdAndOrderStatusAndNoCheck(userId);
|
|
|
|
|
|
|
+ List<InsFeeOrderNew> willList = insFeeOrderNewService.getByUserIdAndOrderStatusAndNoCheckType(userId,"1");
|
|
|
|
|
+ List<InsFeeOrderNew> willListnew = insFeeOrderNewService.getByUserIdAndOrderStatusAndNoCheckType(userId,"2");
|
|
|
// add by hxl end ==========================
|
|
// add by hxl end ==========================
|
|
|
if (!CollectionUtils.isEmpty(willList)) {
|
|
if (!CollectionUtils.isEmpty(willList)) {
|
|
|
for (InsFeeOrderNew item : willList) {
|
|
for (InsFeeOrderNew item : willList) {
|
|
|
- String quoteno = item.getInsOrderNo();
|
|
|
|
|
- stringBuffer.append(quoteno).append(",");
|
|
|
|
|
if (ObjectUtils.isNotEmpty(item)) {
|
|
if (ObjectUtils.isNotEmpty(item)) {
|
|
|
- this.willAmount(item, willHalding, willDocumentary, sysUserAccountVo); // 推广 非跟单
|
|
|
|
|
|
|
+ //1.预收手续费佣金 2. 预收非跟单佣金
|
|
|
|
|
+ willHalding = willHalding.add(this.willAmountNew(item,1));
|
|
|
|
|
+ willDocumentary = willDocumentary.add(this.willAmountNew(item,2));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|
+ if (!CollectionUtils.isEmpty(willListnew)) {
|
|
|
|
|
+ for (InsFeeOrderNew item : willListnew) {
|
|
|
|
|
+ if (ObjectUtils.isNotEmpty(item)) {
|
|
|
|
|
+ //1.实收手续费佣金 2. 实收非跟单佣金
|
|
|
|
|
+ receivedWillHalding = willHalding.add(this.willAmountNew(item,1));
|
|
|
|
|
+ receivedWillDocumentary = willDocumentary.add(this.willAmountNew(item,2));
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
-// 提现现中
|
|
|
|
|
|
|
+ //预收手续费佣金
|
|
|
|
|
+ sysUserAccountVo.setWillHalding(willPromotion);
|
|
|
|
|
+ //预收非跟单佣金
|
|
|
|
|
+ sysUserAccountVo.setWillDocumentary(willDocumentary);
|
|
|
|
|
+ //实收手续费佣金
|
|
|
|
|
+ sysUserAccountVo.setReceivedWillHalding(receivedWillHalding);
|
|
|
|
|
+ //实收非跟单佣金
|
|
|
|
|
+ sysUserAccountVo.setReceivedWillDocumentary(receivedWillDocumentary);
|
|
|
|
|
+ //提现现中
|
|
|
HashMap<String, Object> params = new HashMap<>();
|
|
HashMap<String, Object> params = new HashMap<>();
|
|
|
params.put("auditingStatus", "2"); // 待审核
|
|
params.put("auditingStatus", "2"); // 待审核
|
|
|
params.put("userId", userId);
|
|
params.put("userId", userId);
|
|
@@ -315,12 +341,10 @@ public class SysUserAccountServiceImpl extends ServiceImpl<SysUserAccountMapper,
|
|
|
params.put("userId", userId);
|
|
params.put("userId", userId);
|
|
|
List<SysAmountAuditingEntity> sysAmountAuditingApproved = sysAmountAuditingService.getProgressIng(params);
|
|
List<SysAmountAuditingEntity> sysAmountAuditingApproved = sysAmountAuditingService.getProgressIng(params);
|
|
|
this.judgeSysAmountAuditing(sysAmountAuditingApproved, sysUserAccountVo);
|
|
this.judgeSysAmountAuditing(sysAmountAuditingApproved, sysUserAccountVo);
|
|
|
|
|
+ //预收手续费佣金
|
|
|
sysUserAccountVo.setWillPromotion(willPromotion);
|
|
sysUserAccountVo.setWillPromotion(willPromotion);
|
|
|
- String ids = stringBuffer.toString();
|
|
|
|
|
- if (ids.endsWith(",")) {
|
|
|
|
|
- ids = ids.substring(0, ids.length() - 1); // 去掉末尾的逗号
|
|
|
|
|
- }
|
|
|
|
|
- sysUserAccountVo.setIds(ids);
|
|
|
|
|
|
|
+ //实收手续费佣金
|
|
|
|
|
+ sysUserAccountVo.setReceivedWillPromotion(receivedWillPromotion);
|
|
|
return sysUserAccountVo;
|
|
return sysUserAccountVo;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -329,14 +353,20 @@ public class SysUserAccountServiceImpl extends ServiceImpl<SysUserAccountMapper,
|
|
|
ArrayList<InsFeeOrderNew> resultList = new ArrayList<>();
|
|
ArrayList<InsFeeOrderNew> resultList = new ArrayList<>();
|
|
|
HashMap<String, Object> params = new HashMap<>();
|
|
HashMap<String, Object> params = new HashMap<>();
|
|
|
params.put("userId", BaseController.getUser().getId());
|
|
params.put("userId", BaseController.getUser().getId());
|
|
|
|
|
+ //日期
|
|
|
params.put("timeFiltering", sysUserAccountVo.getTimeFiltering());
|
|
params.put("timeFiltering", sysUserAccountVo.getTimeFiltering());
|
|
|
-
|
|
|
|
|
|
|
+ // 预收和实收标志 1 预收 2.实收
|
|
|
|
|
+ params.put("type",sysUserAccountVo.getAuditingStatus());
|
|
|
|
|
+ sysUserAccountVo.setInsFeeOrderNewList(null);
|
|
|
if ("3".equals(sysUserAccountVo.getAmountType())) {
|
|
if ("3".equals(sysUserAccountVo.getAmountType())) {
|
|
|
- List<InsFeeOrderNew> sumWillAmountGeneralization = insFeeOrderNewService.getSumWillAmountGeneralization(params);
|
|
|
|
|
|
|
+ List<InsFeeOrderNew> sumWillAmountGeneralization = insFeeOrderNewService.getSumWillAmountGeneralizationNew(params);
|
|
|
|
|
+ //List<InsFeeOrderNew> sumWillAmountGeneralization = insFeeOrderNewService.getSumWillAmountGeneralization(params);
|
|
|
sysUserAccountVo.setInsFeeOrderNewList(sumWillAmountGeneralization);
|
|
sysUserAccountVo.setInsFeeOrderNewList(sumWillAmountGeneralization);
|
|
|
} else {
|
|
} else {
|
|
|
- List<InsFeeOrderNew> resultInsFeeOrderNew = insFeeOrderNewService.getSumWillAmount(params);
|
|
|
|
|
- if (!resultInsFeeOrderNew.isEmpty()) {
|
|
|
|
|
|
|
+
|
|
|
|
|
+ //List<InsFeeOrderNew> resultInsFeeOrderNew = insFeeOrderNewService.getSumWillAmount(params);
|
|
|
|
|
+ List<InsFeeOrderNew> resultInsFeeOrderNew = insFeeOrderNewService.getSumWillAmountNew(params);
|
|
|
|
|
+ if (resultInsFeeOrderNew!=null && resultInsFeeOrderNew.size()>0) {
|
|
|
for (InsFeeOrderNew item : resultInsFeeOrderNew) {
|
|
for (InsFeeOrderNew item : resultInsFeeOrderNew) {
|
|
|
BigDecimal willPromotion = BigDecimal.ZERO;
|
|
BigDecimal willPromotion = BigDecimal.ZERO;
|
|
|
if ("1".equals(sysUserAccountVo.getAmountType())) {
|
|
if ("1".equals(sysUserAccountVo.getAmountType())) {
|
|
@@ -531,6 +561,86 @@ public class SysUserAccountServiceImpl extends ServiceImpl<SysUserAccountMapper,
|
|
|
sysUserAccountVo.setWillDocumentary(sysUserAccountVo.getWillDocumentary().add(jqExportOtherCostsPremiums).add(syExportOtherCostsPremiums).add(noExportOtherCostsPremiums));
|
|
sysUserAccountVo.setWillDocumentary(sysUserAccountVo.getWillDocumentary().add(jqExportOtherCostsPremiums).add(syExportOtherCostsPremiums).add(noExportOtherCostsPremiums));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * @version
|
|
|
|
|
+ * @author: hxl
|
|
|
|
|
+ * @Date: 2024/6/3 11:20
|
|
|
|
|
+ * @Description: 通过类型查询预收、实收的金额
|
|
|
|
|
+ */
|
|
|
|
|
+ private BigDecimal willPromotionAll(BigDecimal willPromotion, String userId,String type) {
|
|
|
|
|
+ InsFeeOrderNew insFeeOrderNew = new InsFeeOrderNew();
|
|
|
|
|
+ insFeeOrderNew.setUserId(userId);
|
|
|
|
|
+ InsOrders InsOrders = insAreaCompanyService.selectByInFeeOrderNewByType(insFeeOrderNew,type);
|
|
|
|
|
+ if (ObjectUtils.isNotEmpty(InsOrders)) {
|
|
|
|
|
+ BigDecimal willFirstPremiums = ObjectUtils.defaultIfNull(InsOrders.getWillFirstPremiums(), BigDecimal.ZERO);
|
|
|
|
|
+ // 累加保费
|
|
|
|
|
+ willPromotion = willPromotion.add(willFirstPremiums);
|
|
|
|
|
+ }
|
|
|
|
|
+ return willPromotion;
|
|
|
|
|
+ }
|
|
|
|
|
+ /**
|
|
|
|
|
+ * @version
|
|
|
|
|
+ * @author: hxl
|
|
|
|
|
+ * @Date: 2024/6/4 11:51
|
|
|
|
|
+ * @Description: 获取费用
|
|
|
|
|
+ */
|
|
|
|
|
+ private BigDecimal willAmountNew(InsFeeOrderNew insFeeOrderNew, int type) {
|
|
|
|
|
+ BigDecimal val= BigDecimal.ZERO;
|
|
|
|
|
+ if (ObjectUtils.isNotEmpty(insFeeOrderNew)) {
|
|
|
|
|
+ if(type==1){
|
|
|
|
|
+ // 交强手续费+商业手续费+非车手续费
|
|
|
|
|
+ val= val.add(insFeeOrderNew.getJqExportSuperviseCostsPremiums()).add(insFeeOrderNew.getSyExportSuperviseCostsPremiums()).add(insFeeOrderNew.getNoExportSuperviseCostsPremiums());
|
|
|
|
|
+ }else{
|
|
|
|
|
+ // 交强跟单出口费用+商业跟单出口费用+非车跟单出口费用
|
|
|
|
|
+ val= val.add(insFeeOrderNew.getJqExportOtherCostsPremiums()).add(insFeeOrderNew.getSyExportOtherCostsPremiums()).add(insFeeOrderNew.getNoExportOtherCostsPremiums());
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ return val;
|
|
|
|
|
+ }
|
|
|
|
|
+ /**
|
|
|
|
|
+ * @version
|
|
|
|
|
+ * @author: hxl
|
|
|
|
|
+ * @Date: 2024/6/3 15:16
|
|
|
|
|
+ * @Description: 查询子订单的详细信息
|
|
|
|
|
+ */
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public SubOrder getSubOrderDetails(String subOrderId, String userId) {
|
|
|
|
|
+ SubOrder subOrder=insAreaCompanyMapper.getSubOrderDetails(subOrderId);
|
|
|
|
|
+ subOrder.setAgentName("");
|
|
|
|
|
+ subOrder.setAgentLevel("");
|
|
|
|
|
+ //根据用户id查询分销等级
|
|
|
|
|
+ InsFeeOrderNew insFeeOrderNew = insFeeOrderNewService.getOne(new LambdaQueryWrapper<InsFeeOrderNew>()
|
|
|
|
|
+ .eq(InsFeeOrderNew::getInsOrderNo, subOrder.getSubOrderId()));
|
|
|
|
|
+ if(userId.equals(insFeeOrderNew.getFirstLevelUserId())){
|
|
|
|
|
+ subOrder.setAgentName(this.getUserName(insFeeOrderNew.getFirstLevelUserId()));
|
|
|
|
|
+ subOrder.setAgentLevel("一级分销代理");
|
|
|
|
|
+ }
|
|
|
|
|
+ if(userId.equals(insFeeOrderNew.getTwoLevelUserId())){
|
|
|
|
|
+ subOrder.setAgentName(this.getUserName(insFeeOrderNew.getTwoLevelUserId()));
|
|
|
|
|
+ subOrder.setAgentLevel("二级分销代理");
|
|
|
|
|
+ }
|
|
|
|
|
+ if(userId.equals(insFeeOrderNew.getThreeLevelUserId())){
|
|
|
|
|
+ subOrder.setAgentName(this.getUserName(insFeeOrderNew.getThreeLevelUserId()));
|
|
|
|
|
+ subOrder.setAgentLevel("三级分销代理");
|
|
|
|
|
+ }
|
|
|
|
|
+ return subOrder;
|
|
|
|
|
+ }
|
|
|
|
|
+ /**
|
|
|
|
|
+ * @version
|
|
|
|
|
+ * @author: hxl
|
|
|
|
|
+ * @Date: 2024/6/3 16:34
|
|
|
|
|
+ * @Description: 查询分销人名称
|
|
|
|
|
+ */
|
|
|
|
|
+ private String getUserName(String userId) {
|
|
|
|
|
+ if(StringUtils.isNotEmpty(userId)){
|
|
|
|
|
+ SysUser sysUser = sysUserService.getBaseMapper().selectById(userId);
|
|
|
|
|
+ if(ObjectUtils.isNotEmpty(sysUser)){
|
|
|
|
|
+ return sysUser.getName();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ return "";
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|