## 拨比计算时,保存拓展业绩数据;
This commit is contained in:
		
							parent
							
								
									b768f493c5
								
							
						
					
					
						commit
						4e88bc2ac3
					
				|  | @ -19,9 +19,7 @@ import com.hzs.common.core.web.domain.AjaxResult; | |||
| import com.hzs.common.core.web.page.TableDataInfo; | ||||
| import com.hzs.common.security.utils.SecurityUtils; | ||||
| import com.hzs.common.util.TransactionUtils; | ||||
| import com.hzs.member.statis.service.ICuBonusLenjoyStatisService; | ||||
| import com.hzs.member.statis.service.ICuBonusVertexStatisService; | ||||
| import com.hzs.member.statis.vo.CuBonusLenjoyStatisVO; | ||||
| import com.hzs.member.statis.vo.CuBonusVertexStatisVO; | ||||
| import com.hzs.system.base.ICurrencyServiceApi; | ||||
| import com.hzs.system.base.dto.CurrencyDTO; | ||||
|  | @ -55,8 +53,6 @@ public class CuBonusVertexStatisController extends BaseController { | |||
| 
 | ||||
|     @Autowired | ||||
|     private ICuBonusVertexStatisService iCuBonusVertexStatisService; | ||||
|     @Autowired | ||||
|     private ICuBonusLenjoyStatisService iCuBonusLenjoyStatisService; | ||||
| 
 | ||||
|     @DubboReference | ||||
|     ICurrencyServiceApi currencyServiceApi; | ||||
|  | @ -866,8 +862,8 @@ public class CuBonusVertexStatisController extends BaseController { | |||
|         if (StringUtils.isEmpty(startDate) || StringUtils.isEmpty(endDate)) { | ||||
|             return AjaxResult.error(TransactionUtils.getContent(FinanceMsgConstants.SELECT_DATE_NOT_NULL)); | ||||
|         } | ||||
|         List<CuBonusLenjoyStatisVO> vertexList = iCuBonusLenjoyStatisService.vertexList(null); | ||||
|         List<Integer> pkVertexList = vertexList.stream().map(CuBonusLenjoyStatisVO::getPkVertex).collect(Collectors.toList()); | ||||
|         List<CuBonusVertexStatisVO> vertexList = iCuBonusVertexStatisService.vertexList(null); | ||||
|         List<Integer> pkVertexList = vertexList.stream().map(CuBonusVertexStatisVO::getPkVertex).collect(Collectors.toList()); | ||||
|         //删除数据 | ||||
|         if (CollectionUtil.isNotEmpty(pkVertexList)) { | ||||
|             iCuBonusVertexStatisService.delStatis(startDate, endDate, pkVertexList); | ||||
|  |  | |||
|  | @ -3,9 +3,8 @@ package com.hzs.member.statis.provider; | |||
| import cn.hutool.core.collection.CollectionUtil; | ||||
| import com.hzs.common.core.domain.R; | ||||
| import com.hzs.member.statis.ICuBonusVertexStatisServiceApi; | ||||
| import com.hzs.member.statis.service.ICuBonusLenjoyStatisService; | ||||
| import com.hzs.member.statis.service.ICuBonusVertexStatisService; | ||||
| import com.hzs.member.statis.vo.CuBonusLenjoyStatisVO; | ||||
| import com.hzs.member.statis.vo.CuBonusVertexStatisVO; | ||||
| import lombok.extern.slf4j.Slf4j; | ||||
| import org.apache.dubbo.config.annotation.DubboService; | ||||
| import org.springframework.beans.factory.annotation.Autowired; | ||||
|  | @ -22,8 +21,6 @@ public class ICuBonusVertexStatisServiceProvider implements ICuBonusVertexStatis | |||
| 
 | ||||
|     @Autowired | ||||
|     private ICuBonusVertexStatisService iCuBonusVertexStatisService; | ||||
|     @Autowired | ||||
|     private ICuBonusLenjoyStatisService iCuBonusLenjoyStatisService; | ||||
| 
 | ||||
|     /** | ||||
|      * @description: 7天重算顶点奖金拨比统计 | ||||
|  | @ -38,9 +35,9 @@ public class ICuBonusVertexStatisServiceProvider implements ICuBonusVertexStatis | |||
|      **/ | ||||
|     @Override | ||||
|     public R<?> delStats(String startDate, String endDate) { | ||||
|         List<CuBonusLenjoyStatisVO> vertexList = iCuBonusLenjoyStatisService.vertexList(null); | ||||
|         List<CuBonusVertexStatisVO> vertexList = iCuBonusVertexStatisService.vertexList(null); | ||||
|         if (CollectionUtil.isNotEmpty(vertexList)) { | ||||
|             List<Integer> pkVertexList = vertexList.stream().map(CuBonusLenjoyStatisVO::getPkVertex).collect(Collectors.toList()); | ||||
|             List<Integer> pkVertexList = vertexList.stream().map(CuBonusVertexStatisVO::getPkVertex).collect(Collectors.toList()); | ||||
|             if (CollectionUtil.isNotEmpty(pkVertexList)) { | ||||
|                 iCuBonusVertexStatisService.delStatis(startDate, endDate, pkVertexList); | ||||
|             } | ||||
|  |  | |||
|  | @ -373,6 +373,8 @@ public class CuBonusVertexStatisServiceImpl extends ServiceImpl<CuBonusVertexSta | |||
|             bs.setHiFunIncome(cb.getHiFunIncome()); | ||||
|             bs.setMakerDirect(cb.getMakerDirect()); | ||||
|             bs.setMakerShare(cb.getMakerShare()); | ||||
|             bs.setCalFirAchieve(cb.getCalFirAchieve()); | ||||
|             bs.setCalRepAchieve(cb.getCalRepAchieve()); | ||||
| 
 | ||||
|             // 查询数据库判断记录是否存在 | ||||
|             List<CuBonusVertexStatis> existingRecord = getCuBonusStatis(bs); | ||||
|  |  | |||
|  | @ -204,8 +204,7 @@ | |||
|         AND m.del_flag = 0 | ||||
|         AND m.pk_country = 1 | ||||
|         AND m.category = 0 | ||||
|         AND m.pay_status =1 | ||||
|         AND m.SYSTEM_TYPE =1 | ||||
|         AND m.pay_status = 1 | ||||
|         <if test="pkVertex!=null"> | ||||
|             AND m.pk_id=#{pkVertex} | ||||
|         </if> | ||||
|  |  | |||
|  | @ -845,10 +845,10 @@ | |||
|         ) | ||||
|     </select> | ||||
| 
 | ||||
|     <!--    删除奖金拨比统计表数据--> | ||||
|     <!-- 删除奖金拨比统计表数据--> | ||||
|     <delete id="delStatis"> | ||||
|         delete from CU_BONUS_VERTEX_STATIS | ||||
|         where 1=1 | ||||
|         where 1 = 1 | ||||
|         <if test="pkVertexList!=null and pkVertexList.size> 0 "> | ||||
|             and PK_BD_VERTEX not in | ||||
|             <foreach collection="pkVertexList" item="item" open="(" close=")" separator=","> | ||||
|  |  | |||
|  | @ -89,8 +89,4 @@ public class AdaRefundNotifyController { | |||
|         throw new BaseException("汇付退款回调处理失败"); | ||||
|     } | ||||
| 
 | ||||
|     public static void main(String[] args) { | ||||
|         System.out.println(); | ||||
|     } | ||||
| 
 | ||||
| } | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue