diff --git a/ruoyi-modules/ruoyi-payment/pom.xml b/ruoyi-modules/ruoyi-payment/pom.xml index 155807e..1a153b5 100644 --- a/ruoyi-modules/ruoyi-payment/pom.xml +++ b/ruoyi-modules/ruoyi-payment/pom.xml @@ -160,13 +160,6 @@ 2.0.1.Final - - org.dromara - ruoyi-system - 2.1.2 - compile - - diff --git a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/channel/mapper/BusChannelProductMapper.java b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/channel/mapper/BusChannelProductMapper.java index cbd7949..921c37f 100644 --- a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/channel/mapper/BusChannelProductMapper.java +++ b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/channel/mapper/BusChannelProductMapper.java @@ -1,12 +1,15 @@ package org.dromara.payment.channel.mapper; +import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.Constants; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; import org.dromara.payment.channel.domain.BusChannelProduct; import org.dromara.payment.channel.domain.bo.BusChannelProductBo; import org.dromara.payment.channel.domain.vo.BusChannelProductVo; import org.dromara.common.mybatis.core.mapper.BaseMapperPlus; +import org.dromara.payment.merchant.domain.vo.BusMerchantProductVo; import java.math.BigDecimal; import java.util.List; @@ -30,6 +33,14 @@ public interface BusChannelProductMapper extends BaseMapperPlus selectAgentProInfos(Map map); + /** + * 查代理商产品页 + * @param page + * @param wrapper + * @return + */ + Page selectProducts(@Param("page") IPage page, @Param(Constants.WRAPPER) Wrapper wrapper); + /* * @Param diff --git a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantProductServiceImpl.java b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantProductServiceImpl.java index 836b437..d20f06d 100644 --- a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantProductServiceImpl.java +++ b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantProductServiceImpl.java @@ -22,6 +22,8 @@ import org.dromara.payment.channel.domain.vo.BusChannelProductVo; import org.dromara.payment.channel.mapper.BusChannelProductMapper; import org.dromara.payment.merchant.domain.BusMerchant; import org.dromara.payment.merchant.mapper.BusMerchantMapper; +import org.dromara.payment.operator.domain.BusOperatorProduct; +import org.dromara.payment.operator.mapper.BusOperatorProductMapper; import org.dromara.payment.sys.domain.SysSyd; import org.dromara.payment.sys.mapper.SysSydMapper; import org.dromara.payment.thirdPlatform.base.domain.SysThirdPlatform; @@ -54,6 +56,8 @@ public class BusMerchantProductServiceImpl extends BaseService implements IBusMe private final BusChannelProductMapper busChannelProductMapper; + private final BusOperatorProductMapper busOperatorProductMapper; + private final BusMerchantMapper busMerchantMapper; private final IXyjService xyjService; @@ -83,24 +87,44 @@ public class BusMerchantProductServiceImpl extends BaseService implements IBusMe if(bo.getMerId() == null){ this.invalidationParamsException("企业ID不能为空"); } - - + BusMerchant busMerchant = busMerchantMapper.selectById(bo.getMerId()); + //代理商编号 + String agentNo = busMerchant.getAgentNo(); + //运营商编号 + String operatorNo = busMerchant.getOperatorNo(); QueryWrapper lqw = Wrappers.query(); lqw.eq("t1.bus_type",bo.getBusType()); - lqw.eq("t.mer_id",bo.getMerId()); - lqw.eq("t3.pro_status",1); lqw.eq("t1.pro_status",1); - if(!LoginHelper.isSuperAdmin()){ - lqw.eq("t1.channel_id",LoginHelper.getBusId()); + Page result = new Page<>(); + //判断代理商编号是否都不为空 + if(StringUtils.isNotBlank(agentNo)){ + lqw.eq("t1.channel_no",agentNo); + lqw.eq("t1.op_no",operatorNo); + //查代理商的产品 + result = busChannelProductMapper.selectProducts(pageQuery.build(), lqw); + result.getRecords().forEach(item->{ + item.setUnId(IdUtil.getSnowflakeNextId()+""); + }); + return TableDataInfo.build(result); + //判断运营商是否为空 + }else if(StringUtils.isNotBlank(operatorNo)){ + lqw.eq("t1.op_no",operatorNo); + //查运营商的产品 + result = busOperatorProductMapper.selectProducts(pageQuery.build(), lqw); + result.getRecords().forEach(item->{ + item.setUnId(IdUtil.getSnowflakeNextId()+""); + }); + return TableDataInfo.build(result); } + return new TableDataInfo<>(null,0); +// if(!LoginHelper.isSuperAdmin()){ +// lqw.eq("t1.channel_id",LoginHelper.getBusId()); +// } + +// Page result = baseMapper.selBusMerProByTypeList(pageQuery.build(), lqw); - Page result = baseMapper.selBusMerProByTypeList(pageQuery.build(), lqw); - result.getRecords().forEach(item->{ - item.setUnId(IdUtil.getSnowflakeNextId()+""); - }); - return TableDataInfo.build(result); } /** @@ -152,76 +176,76 @@ public class BusMerchantProductServiceImpl extends BaseService implements IBusMe @Transactional public Boolean insertByBo(JSONObject map) { - String boListStr = map.getString("boList"); - Long bus_type = map.getLong("busType"); - Long mer_id = map.getLong("merId"); - String merNo = map.getString("merNo"); - if(bus_type == null){ - this.invalidationParamsException("业务类型不能为空"); - } - if(mer_id == null){ - this.invalidationParamsException("企业ID不能为空"); - } + String boListStr = map.getString("boList"); + Long bus_type = map.getLong("busType"); + Long mer_id = map.getLong("merId"); + String merNo = map.getString("merNo"); + if(bus_type == null){ + this.invalidationParamsException("业务类型不能为空"); + } + if(mer_id == null){ + this.invalidationParamsException("企业ID不能为空"); + } if(StringUtils.isEmpty(merNo)){ this.invalidationParamsException("企业编码不能为空"); } - if(StringUtils.isEmpty(boListStr)){ - this.invalidationParamsException("请先配置产品"); - } - boListStr = map.getJSONArray("boList").toJSONString(); - Map paraMap = new HashMap(); - paraMap.put("channel_no", LoginHelper.getNo()); - paraMap.put("bus_type",bus_type); - List agentList = this.busChannelProductMapper.selectAgentProInfos(paraMap); - if(agentList.size() == 0){ - this.invalidationParamsException("当前代理商未配置产品"); - } - List voList = JSONUtil.toList(boListStr, BusMerchantProductBo.class); - List insertList = new ArrayList(); - for(BusMerchantProductBo vo :voList){ - SysSyd sysSyd = sydMapper.selectSysSydById(vo.getSydId()); - log.info("sydId:"+sysSyd.getId()+"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"); - SysThirdPlatform sysThirdPlatform = thirdPlatformMapper.selectThirdAppInfo(sysSyd.getId()); - log.info("sysThirdPlatform:"+sysThirdPlatform.getPlatformName()); - if (ObjectUtils.isNotEmpty(sysThirdPlatform)&&sysThirdPlatform.getPlatformName().equals("薪遇见")){ + if(StringUtils.isEmpty(boListStr)){ + this.invalidationParamsException("请先配置产品"); + } + boListStr = map.getJSONArray("boList").toJSONString(); + Map paraMap = new HashMap(); + paraMap.put("channel_no", LoginHelper.getNo()); + paraMap.put("bus_type",bus_type); + List agentList = this.busChannelProductMapper.selectAgentProInfos(paraMap); + if(agentList.size() == 0){ + this.invalidationParamsException("当前代理商未配置产品"); + } + List voList = JSONUtil.toList(boListStr, BusMerchantProductBo.class); + List insertList = new ArrayList(); + for(BusMerchantProductBo vo :voList){ + SysSyd sysSyd = sydMapper.selectSysSydById(vo.getSydId()); + log.info("sydId:"+sysSyd.getId()+"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"); + SysThirdPlatform sysThirdPlatform = thirdPlatformMapper.selectThirdAppInfo(sysSyd.getId()); + log.info("sysThirdPlatform:"+sysThirdPlatform.getPlatformName()); + if (ObjectUtils.isNotEmpty(sysThirdPlatform)&&sysThirdPlatform.getPlatformName().equals("薪遇见")){ BusMerchant busMerchant = busMerchantMapper.selectById(mer_id); xyjService.addMerchant(busMerchant,vo.getSydId()); } - BusChannelProductVo agentVo = agentList.stream().filter(t -> t.getProNo().equals(vo.getProNo())).findFirst().orElse(null); - if(agentVo == null){ - this.invalidationParamsException("产品编码"+vo.getProNo()+"未配置"); - } - vo.setSydId(agentVo.getSydId()); - vo.setSydNo(agentVo.getSydNo()); - vo.setProId(agentVo.getProId()); - vo.setOpId(agentVo.getOpId()); - vo.setOpNo(agentVo.getOpNo()); - vo.setMerId(mer_id); - vo.setMerNo(merNo); - vo.setChannelId(agentVo.getChannelId()); - vo.setChannelNo(agentVo.getChannelNo()); - vo.setMaxMonth(agentVo.getMaxMonth()); + BusChannelProductVo agentVo = agentList.stream().filter(t -> t.getProNo().equals(vo.getProNo())).findFirst().orElse(null); + if(agentVo == null){ + this.invalidationParamsException("产品编码"+vo.getProNo()+"未配置"); + } + vo.setSydId(agentVo.getSydId()); + vo.setSydNo(agentVo.getSydNo()); + vo.setProId(agentVo.getProId()); + vo.setOpId(agentVo.getOpId()); + vo.setOpNo(agentVo.getOpNo()); + vo.setMerId(mer_id); + vo.setMerNo(merNo); + vo.setChannelId(agentVo.getChannelId()); + vo.setChannelNo(agentVo.getChannelNo()); + vo.setMaxMonth(agentVo.getMaxMonth()); // vo.setInvoiceItems(agentVo.getInvoiceItems()); - vo.setCostServiceCharge(agentVo.getServiceCharge()); + vo.setCostServiceCharge(agentVo.getServiceCharge()); // ValidatorUtils.validate(vo, AddGroup.class); - if(vo.getServiceCharge() != null && vo.getServiceCharge().compareTo(vo.getCostServiceCharge()) < 0){ - vo.setServiceCharge(vo.getCostServiceCharge()); - } - vo.setBusType(bus_type); - vo.setMerId(mer_id); - if(vo.getId() != null){ - vo.setMdyServiceCharge(vo.getServiceCharge()); - vo.setServiceCharge(null); - BusMerchantProduct update = MapstructUtils.convert(vo, BusMerchantProduct.class); - insertList.add(update); - }else{ - BusMerchantProduct add = MapstructUtils.convert(vo, BusMerchantProduct.class); - insertList.add(add); - } + if(vo.getServiceCharge() != null && vo.getServiceCharge().compareTo(vo.getCostServiceCharge()) < 0){ + vo.setServiceCharge(vo.getCostServiceCharge()); + } + vo.setBusType(bus_type); + vo.setMerId(mer_id); + if(vo.getId() != null){ + vo.setMdyServiceCharge(vo.getServiceCharge()); + vo.setServiceCharge(null); + BusMerchantProduct update = MapstructUtils.convert(vo, BusMerchantProduct.class); + insertList.add(update); + }else{ + BusMerchantProduct add = MapstructUtils.convert(vo, BusMerchantProduct.class); + insertList.add(add); + } - } + } this.baseMapper.insertOrUpdateBatch(insertList); return true; } diff --git a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantServiceImpl.java b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantServiceImpl.java index 3045eba..7fa0a6f 100644 --- a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantServiceImpl.java +++ b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/merchant/service/impl/BusMerchantServiceImpl.java @@ -82,9 +82,6 @@ public class BusMerchantServiceImpl extends BaseService implements IBusMerchantS public TableDataInfo queryPageList(BusMerchantBo bo, PageQuery pageQuery) { QueryWrapper lqw = Wrappers.query(); if (!LoginHelper.isSuperAdmin()){ - lqw.between(bo.getStartTime() != null,"t.create_time",bo.getStartTime(),bo.getEndTime()); - lqw.like(StringUtils.isNotEmpty(bo.getName()),"t.name",bo.getName()); - lqw.like(StringUtils.isNotEmpty(bo.getNo()),"t.no",bo.getNo()); lqw.like(StringUtils.isNotEmpty(bo.getScaleName()),"s.name",bo.getScaleName()); if(bo.getIsProduct() != null && bo.getIsProduct() == 1){ lqw.eq("t.create_unit_id",LoginHelper.getBusId()); @@ -94,15 +91,18 @@ public class BusMerchantServiceImpl extends BaseService implements IBusMerchantS lqw.inSql("t.id","select distinct mer_id from bus_merchant_product tt where tt.syd_id ="+LoginHelper.getBusId()); } } + lqw.between(bo.getStartTime() != null,"t.create_time",bo.getStartTime(),bo.getEndTime()); + lqw.like(StringUtils.isNotEmpty(bo.getName()),"t.name",bo.getName()); + lqw.like(StringUtils.isNotEmpty(bo.getNo()),"t.no",bo.getNo()); lqw.orderByDesc("t.create_time"); Page result = baseMapper.selectMerchantList(pageQuery.build(), lqw); result.getRecords().forEach(item->{ - item.setPayPassword(null); - if(item.getCreateUnitId() != null && item.getCreateUnitId().equals(LoginHelper.getBusId())){ - item.setIsCanSetScale(1); - } + item.setPayPassword(null); + if(item.getCreateUnitId() != null && item.getCreateUnitId().equals(LoginHelper.getBusId())){ + item.setIsCanSetScale(1); + } }); return TableDataInfo.build(result); } @@ -219,7 +219,7 @@ public class BusMerchantServiceImpl extends BaseService implements IBusMerchantS boolean flag = false; try{ - flag = baseMapper.insert(add) > 0; + flag = baseMapper.insert(add) > 0; }catch (Exception e){ if( e instanceof DuplicateKeyException){ bo.setNo(LoginHelper.getNo()+"-"+this.getMerNo()); diff --git a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/operator/mapper/BusOperatorProductMapper.java b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/operator/mapper/BusOperatorProductMapper.java index 1b56499..cc979d2 100644 --- a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/operator/mapper/BusOperatorProductMapper.java +++ b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/operator/mapper/BusOperatorProductMapper.java @@ -1,11 +1,14 @@ package org.dromara.payment.operator.mapper; import com.baomidou.mybatisplus.core.conditions.Wrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Constants; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; import org.dromara.payment.channel.domain.BusChannelProduct; +import org.dromara.payment.merchant.domain.BusMerchantProduct; +import org.dromara.payment.merchant.domain.vo.BusMerchantProductVo; import org.dromara.payment.merchant.domain.vo.BusMerchantVo; import org.dromara.payment.operator.domain.BusOperatorProduct; import org.dromara.payment.operator.domain.bo.AllocOperatorProductBo; @@ -57,4 +60,6 @@ public interface BusOperatorProductMapper extends BaseMapperPlus setingOpratorProductList(@Param("page") IPage page, @Param(Constants.WRAPPER) Wrapper wrapper,@Param("opId") Long opId); + + Page selectProducts(Page build, QueryWrapper lqw); } diff --git a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/worker/service/impl/TencentIdCardAndOtherServiceImpl.java b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/worker/service/impl/TencentIdCardAndOtherServiceImpl.java index 6696c95..1d9272f 100644 --- a/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/worker/service/impl/TencentIdCardAndOtherServiceImpl.java +++ b/ruoyi-modules/ruoyi-payment/src/main/java/org/dromara/payment/worker/service/impl/TencentIdCardAndOtherServiceImpl.java @@ -3,13 +3,10 @@ package org.dromara.payment.worker.service.impl; import com.tencentcloudapi.common.profile.ClientProfile; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboReference; -import org.dromara.common.core.constant.MpContants; import org.dromara.common.core.exception.base.BaseException; import org.dromara.common.core.service.BaseService; import org.dromara.common.core.utils.StringUtils; import org.dromara.common.json.utils.JsonUtils; -import org.dromara.common.redis.utils.RedisUtils; -import org.dromara.payment.worker.domain.SysUnitDomain; import org.dromara.payment.worker.domain.ThirdConf; import org.dromara.payment.worker.service.IIdCardAndOtherService; import org.dromara.system.api.RemoteConfigService; diff --git a/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/channel/BusChannelProductMapper.xml b/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/channel/BusChannelProductMapper.xml index 1f89180..b2dc30c 100644 --- a/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/channel/BusChannelProductMapper.xml +++ b/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/channel/BusChannelProductMapper.xml @@ -1,10 +1,38 @@ + PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> + + SELECT - t2.id, - t3.no pro_no, - t4.no syd_no, - t4.gsmc serviceName, - t1.service_charge cost_service_charge, - t1.bus_type, - t2.service_charge, - t1.charge_mode, - t1.settlement_style, - t1.max_month, - t1.invoice_type, - t1.invoice_items, - t2.pro_status + t2.id, + t3.no pro_no, + t4.no syd_no, + t4.gsmc serviceName, + t1.service_charge cost_service_charge, + t1.bus_type, + t2.service_charge, + t1.charge_mode, + t1.settlement_style, + t1.max_month, + t1.invoice_type, + t1.invoice_items, + t2.pro_status FROM - bus_channel_product t1 - LEFT JOIN bus_channel_product t2 ON t1.pro_id = t2.pro_id and t2.channel_id = #{bo.chId} - LEFT JOIN sys_syd_product t3 ON t1.pro_id = t3.id - LEFT JOIN sys_syd t4 ON t1.syd_id = t4.id + bus_channel_product t1 + LEFT JOIN bus_channel_product t2 ON t1.pro_id = t2.pro_id and t2.channel_id = #{bo.chId} + LEFT JOIN sys_syd_product t3 ON t1.pro_id = t3.id + LEFT JOIN sys_syd t4 ON t1.syd_id = t4.id where t1.channel_id = #{bo.channelId} and t3.pro_status = 1 and t1.pro_status = 1 - and t1.bus_type = #{bo.busType} + and t1.bus_type = #{bo.busType} @@ -87,7 +115,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" diff --git a/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/operator/BusOperatorProductMapper.xml b/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/operator/BusOperatorProductMapper.xml index 84e1f96..71a6b6e 100644 --- a/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/operator/BusOperatorProductMapper.xml +++ b/ruoyi-modules/ruoyi-payment/src/main/resources/mapper/payment/operator/BusOperatorProductMapper.xml @@ -1,9 +1,39 @@ + PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> + + + + INSERT INTO `bus_operator_product` ( `syd_id`, @@ -32,19 +62,19 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" `bus_type`, `no`, `id`, - #{item.opNo}, - #{item.opId}, + #{item.opNo}, + #{item.opId}, `service_charge`, - #{item.serviceCharge}, + #{item.serviceCharge}, `charge_mode`, `settlement_style`, `max_month`, `invoice_type`, `invoice_items`, - #{createTime}, - #{createBy}, - #{createTime}, - #{createBy} + #{createTime}, + #{createBy}, + #{createTime}, + #{createBy} FROM sys_syd_product WHERE @@ -73,7 +103,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" `create_by` ) values - (#{item.sydId},#{item.sydNo},#{item.busType},#{item.proNo},#{item.proId},#{item.opNo},#{item.opId},#{item.costServiceCharge},#{item.serviceCharge},#{item.chargeMode}, + (#{item.sydId},#{item.sydNo},#{item.busType},#{item.proNo},#{item.proId},#{item.opNo},#{item.opId},#{item.costServiceCharge},#{item.serviceCharge},#{item.chargeMode}, #{item.settlementStyle},#{item.maxMonth},#{item.invoiceType},#{item.invoiceItems},#{item.proStatus},#{item.createTime},#{item.createBy}) @@ -84,11 +114,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - - - - - + + + + + UPDATE bus_channel_product @@ -111,26 +141,26 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"