KuaishouRuleSettlementDataServiceImpl.java 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656
  1. package com.ruixuan.isc.service.impl;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.ruixuan.common.utils.Check;
  5. import com.ruixuan.common.utils.DateUtils;
  6. import com.ruixuan.isc.entity.KuaishouRuleSettlementData;
  7. import com.ruixuan.isc.entity.KuaishouSettlementRules;
  8. import com.ruixuan.isc.mapper.KuaishouRuleSettlementDataMapper;
  9. import com.ruixuan.isc.service.IKuaishouRuleSettlementDataService;
  10. import com.ruixuan.isc.service.IKuaishouSettlementRulesService;
  11. import lombok.extern.slf4j.Slf4j;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.stereotype.Service;
  14. import java.math.BigDecimal;
  15. import java.util.ArrayList;
  16. import java.util.List;
  17. /**
  18. * 【请填写功能名称】Service业务层处理
  19. *
  20. * @author ruoyi
  21. * @date 2023-05-16
  22. */
  23. @Service
  24. @Slf4j
  25. public class KuaishouRuleSettlementDataServiceImpl implements IKuaishouRuleSettlementDataService {
  26. @Autowired
  27. private KuaishouRuleSettlementDataMapper kuaishouRuleSettlementDataMapper;
  28. @Autowired
  29. private IKuaishouSettlementRulesService settlementRulesService;
  30. /**
  31. * 查询【请填写功能名称】
  32. *
  33. * @param id 【请填写功能名称】主键
  34. * @return 【请填写功能名称】
  35. */
  36. @Override
  37. public KuaishouRuleSettlementData selectKuaishouRuleSettlementDataById(Long id) {
  38. return kuaishouRuleSettlementDataMapper.selectKuaishouRuleSettlementDataById(id);
  39. }
  40. /**
  41. * 查询【请填写功能名称】列表
  42. *
  43. * @param kuaishouRuleSettlementData 【请填写功能名称】
  44. * @return 【请填写功能名称】
  45. */
  46. @Override
  47. public List<KuaishouRuleSettlementData> selectKuaishouRuleSettlementDataList(KuaishouRuleSettlementData kuaishouRuleSettlementData) {
  48. return kuaishouRuleSettlementDataMapper.selectKuaishouRuleSettlementDataList(kuaishouRuleSettlementData);
  49. }
  50. /**
  51. * 新增【请填写功能名称】
  52. *
  53. * @param kuaishouRuleSettlementData 【请填写功能名称】
  54. * @return 结果
  55. */
  56. @Override
  57. public int insertKuaishouRuleSettlementData(KuaishouRuleSettlementData kuaishouRuleSettlementData) {
  58. kuaishouRuleSettlementData.setCreateTime(DateUtils.getNowDate());
  59. return kuaishouRuleSettlementDataMapper.insertKuaishouRuleSettlementData(kuaishouRuleSettlementData);
  60. }
  61. /**
  62. * 修改【请填写功能名称】
  63. *
  64. * @param kuaishouRuleSettlementData 【请填写功能名称】
  65. * @return 结果
  66. */
  67. @Override
  68. public int updateKuaishouRuleSettlementData(KuaishouRuleSettlementData kuaishouRuleSettlementData) {
  69. kuaishouRuleSettlementData.setUpdateTime(DateUtils.getNowDate());
  70. return kuaishouRuleSettlementDataMapper.updateKuaishouRuleSettlementData(kuaishouRuleSettlementData);
  71. }
  72. /**
  73. * 批量删除【请填写功能名称】
  74. *
  75. * @param ids 需要删除的【请填写功能名称】主键
  76. * @return 结果
  77. */
  78. @Override
  79. public int deleteKuaishouRuleSettlementDataByIds(Long[] ids) {
  80. return kuaishouRuleSettlementDataMapper.deleteKuaishouRuleSettlementDataByIds(ids);
  81. }
  82. /**
  83. * 删除【请填写功能名称】信息
  84. *
  85. * @param id 【请填写功能名称】主键
  86. * @return 结果
  87. */
  88. @Override
  89. public int deleteKuaishouRuleSettlementDataById(Long id) {
  90. return kuaishouRuleSettlementDataMapper.deleteKuaishouRuleSettlementDataById(id);
  91. }
  92. @Override
  93. public void data(Long statDate, JSONArray dataArr) {
  94. if (!Check.isNull(dataArr)) {
  95. List<KuaishouRuleSettlementData> adds = new ArrayList<>();
  96. for (int i = 0; i < dataArr.size(); i++) {
  97. JSONObject dataJson = dataArr.getJSONObject(i);
  98. KuaishouRuleSettlementData settlementData = new KuaishouRuleSettlementData();
  99. Long relateId = dataJson.getLong("relateId");
  100. Long ruleId = dataJson.getLong("ruleId");
  101. String itemIds = dataJson.getString("itemIds");
  102. Long promoterId = dataJson.getLong("promoterId");
  103. String promoterName = dataJson.getString("promoterName");
  104. Long itemCreateId = dataJson.getLong("itemCreateId");
  105. String itemCreateName = dataJson.getString("itemCreateName");
  106. Long promoterCreateId = dataJson.getLong("promoterCreateId");
  107. String promoterCreateName = dataJson.getString("promoterCreateName");
  108. Long orderNum = dataJson.getLong("orderNum");
  109. Long validOrderNum = dataJson.getLong("validOrderNum");
  110. if (validOrderNum == 0 || Check.isNull(validOrderNum)) {
  111. continue;
  112. }
  113. Long yesterdayOrderNum = dataJson.getLong("yesterdayOrderNum");
  114. Long yesterdayValidOrderNum = dataJson.getLong("yesterdayValidOrderNum");
  115. Integer rule_type = dataJson.getInteger("rule_type");
  116. JSONObject ruleData = new JSONObject();
  117. if (rule_type == 1) {
  118. ruleData = getRuleData(relateId, promoterId, ruleId, validOrderNum);
  119. } else if (rule_type == 2) {
  120. ruleData = getOrderRuleData(relateId, promoterId, ruleId, validOrderNum);
  121. }
  122. settlementData.setRuleId(ruleId);
  123. settlementData.setRuleName(ruleData.getString("ruleName"));
  124. settlementData.setSonRuleId(ruleData.getLong("sonRuleId"));
  125. settlementData.setRelateId(relateId);
  126. settlementData.setItemIds(itemIds);
  127. settlementData.setPromoterId(promoterId);
  128. settlementData.setPromoterName(promoterName);
  129. settlementData.setItemCreateId(itemCreateId);
  130. settlementData.setItemCreateName(itemCreateName);
  131. settlementData.setPromoterCreateId(promoterCreateId);
  132. settlementData.setPromoterCreateName(promoterCreateName);
  133. settlementData.setOrderNum(orderNum);
  134. settlementData.setValidOrderNum(validOrderNum);
  135. settlementData.setYesterdayOrderNum(yesterdayOrderNum);
  136. settlementData.setYesterdayValidOrderNum(yesterdayValidOrderNum);
  137. settlementData.setStatDate(statDate);
  138. settlementData.setAnchorAmount(ruleData.getBigDecimal("anchorAmount"));
  139. settlementData.setReferenceAmount(ruleData.getBigDecimal("referenceAmount"));
  140. settlementData.setSettlementStatus(ruleData.getInteger("settlementStatus"));
  141. settlementData.setLastSettlementOrderNum(ruleData.getLong("lastSettlementOrderNum"));
  142. settlementData.setRuleType(rule_type);
  143. adds.add(settlementData);
  144. }
  145. if (!Check.isNull(adds)) {
  146. kuaishouRuleSettlementDataMapper.replaceDatas(adds);
  147. log.info("结算信息入库完成,时间:{},数据量:{}", statDate, adds.size());
  148. }
  149. }
  150. }
  151. @Override
  152. public void promoterData(Long statDate, JSONArray dataArr) {
  153. if (!Check.isNull(dataArr)) {
  154. List<KuaishouRuleSettlementData> adds = new ArrayList<>();
  155. for (int i = 0; i < dataArr.size(); i++) {
  156. JSONObject dataJson = dataArr.getJSONObject(i);
  157. KuaishouRuleSettlementData settlementData = new KuaishouRuleSettlementData();
  158. Long relateId = dataJson.getLong("relateId");
  159. Long ruleId = dataJson.getLong("ruleId");
  160. Long promoterId = dataJson.getLong("promoterId");
  161. String promoterName = dataJson.getString("promoterName");
  162. Long orderNum = dataJson.getLong("orderNum");
  163. Long validOrderNum = dataJson.getLong("validOrderNum");
  164. if (validOrderNum == 0 || Check.isNull(validOrderNum)) {
  165. continue;
  166. }
  167. Long yesterdayOrderNum = dataJson.getLong("yesterdayOrderNum");
  168. Long yesterdayValidOrderNum = dataJson.getLong("yesterdayValidOrderNum");
  169. Integer rule_type = dataJson.getInteger("rule_type");
  170. JSONObject ruleData = new JSONObject();
  171. if (rule_type == 3) {
  172. ruleData = getPromoterRuleData(relateId, promoterId, ruleId, validOrderNum);
  173. } else {
  174. continue;
  175. }
  176. settlementData.setRuleId(ruleId);
  177. settlementData.setRuleName(ruleData.getString("ruleName"));
  178. settlementData.setSonRuleId(ruleData.getLong("sonRuleId"));
  179. settlementData.setPromoterId(promoterId);
  180. settlementData.setPromoterName(promoterName);
  181. settlementData.setOrderNum(orderNum);
  182. settlementData.setValidOrderNum(validOrderNum);
  183. settlementData.setYesterdayOrderNum(yesterdayOrderNum);
  184. settlementData.setYesterdayValidOrderNum(yesterdayValidOrderNum);
  185. settlementData.setStatDate(statDate);
  186. settlementData.setAnchorAmount(ruleData.getBigDecimal("anchorAmount"));
  187. settlementData.setReferenceAmount(ruleData.getBigDecimal("referenceAmount"));
  188. settlementData.setSettlementStatus(ruleData.getInteger("settlementStatus"));
  189. settlementData.setLastSettlementOrderNum(ruleData.getLong("lastSettlementOrderNum"));
  190. settlementData.setRuleType(rule_type);
  191. adds.add(settlementData);
  192. }
  193. if (!Check.isNull(adds)) {
  194. kuaishouRuleSettlementDataMapper.replaceDatas(adds);
  195. log.info("结算信息入库完成,时间:{},数据量:{}", statDate, adds.size());
  196. }
  197. }
  198. }
  199. @Override
  200. public List<JSONObject> getSettlementDataV2(Long date, Long promoterId, String promoterName) {
  201. return kuaishouRuleSettlementDataMapper.getSettlementDataV2(date, promoterId, promoterName);
  202. }
  203. // 按区间结算
  204. @Override
  205. public JSONObject getRuleData(Long relateId, Long promoterId, Long ruleId, Long validOrderNum) {
  206. JSONObject returnJson = new JSONObject();
  207. BigDecimal anchorAmount = new BigDecimal(0); // 达人激励
  208. BigDecimal referenceAmount = new BigDecimal(0); // 推荐人激励
  209. KuaishouSettlementRules kuaishouSettlementRules = settlementRulesService.selectKuaishouSettlementRulesById(ruleId);
  210. returnJson.put("ruleId", ruleId);
  211. returnJson.put("ruleName", kuaishouSettlementRules.getRuleName());
  212. List<JSONObject> ruleList = kuaishouRuleSettlementDataMapper.getRuleList(ruleId);
  213. JSONObject lastRule = kuaishouRuleSettlementDataMapper.lastRule(relateId, promoterId, ruleId); //上次结算命中的规则
  214. Long lastValidOrderNum = 0L;
  215. if (!Check.isNull(lastRule)) {
  216. lastValidOrderNum += lastRule.getLong("validOrderNum");
  217. }
  218. JSONObject ruleJson = new JSONObject();
  219. if (validOrderNum <= lastValidOrderNum) { // 有效订单数据小于等于昨天 不做结算
  220. returnJson.put("ruleId", ruleId);
  221. returnJson.put("sonRuleId", 0);
  222. returnJson.put("ruleName", "未命中结算规则");
  223. returnJson.put("anchorAmount", anchorAmount);
  224. returnJson.put("referenceAmount", referenceAmount);
  225. returnJson.put("settlementStatus", 1);
  226. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  227. return returnJson;
  228. } else if (validOrderNum < 10000) { // 单量 小于等于1w 在第一个结算周期内
  229. for (int i = 0; i < ruleList.size(); i++) {
  230. JSONObject rule = ruleList.get(i);
  231. Long startItemCount = rule.getLong("startItemCount");
  232. Long endItemCount = rule.getLong("endItemCount");
  233. if (validOrderNum >= startItemCount && validOrderNum <= endItemCount) {
  234. ruleJson = rule;
  235. break;
  236. }
  237. }
  238. if (Check.isNull(ruleJson) || ruleJson.size() == 0) {
  239. returnJson.put("sonRuleId", 0);
  240. returnJson.put("anchorAmount", anchorAmount);
  241. returnJson.put("referenceAmount", referenceAmount);
  242. returnJson.put("settlementStatus", 1);
  243. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  244. return returnJson;
  245. }
  246. Integer lastSortCount = null;
  247. if (Check.isNull(lastRule)) {
  248. lastSortCount = 0;
  249. }
  250. if (!Check.isNull(lastRule)) {
  251. Integer sortCount = lastRule.getInteger("sortCount"); // 上次结算命中的规则序号
  252. if (Check.isNull(sortCount)) {
  253. lastSortCount = 0;
  254. } else {
  255. lastSortCount = sortCount;
  256. }
  257. }
  258. Integer currentSortCount = ruleJson.getInteger("sortCount"); // 当前结算命中的规则序号
  259. if (currentSortCount <= lastSortCount) {
  260. returnJson.put("sonRuleId", 0);
  261. returnJson.put("anchorAmount", anchorAmount);
  262. returnJson.put("referenceAmount", referenceAmount);
  263. returnJson.put("settlementStatus", 1);
  264. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  265. return returnJson;
  266. } else {
  267. JSONObject totalAmount = kuaishouRuleSettlementDataMapper.getTotalAmount(ruleId, lastSortCount, currentSortCount);
  268. returnJson.put("sonRuleId", ruleJson.getLong("id"));
  269. returnJson.put("anchorAmount", totalAmount.getBigDecimal("anchorAmount"));
  270. returnJson.put("referenceAmount", totalAmount.getBigDecimal("referenceAmount"));
  271. returnJson.put("settlementStatus", 2);
  272. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  273. return returnJson;
  274. }
  275. } else if (validOrderNum >= 10000) {
  276. System.err.println(validOrderNum);
  277. Integer incentivizedCount = (int) Math.floor(validOrderNum / 10000); // 需要 1w单结算次数
  278. Integer lastIncentivizedCount = kuaishouRuleSettlementDataMapper.selectIncentiveLog(relateId, promoterId); // 一万单已结算次数
  279. if (Check.isNull(lastIncentivizedCount)) {
  280. lastIncentivizedCount = 0;
  281. }
  282. if (incentivizedCount > lastIncentivizedCount) {
  283. BigDecimal count = new BigDecimal(incentivizedCount - lastIncentivizedCount);
  284. BigDecimal promoterRide = new BigDecimal(700); // 达人破万奖励金额
  285. BigDecimal referenceRide = new BigDecimal(100); // 推荐人破万奖励金额
  286. BigDecimal promoterIncentiveAmount = count.multiply(promoterRide); // 达人破万单奖励
  287. BigDecimal referenceIncentiveAmount = count.multiply(referenceRide); // 推荐人破万单奖励
  288. anchorAmount = anchorAmount.add(promoterIncentiveAmount);
  289. referenceAmount = referenceAmount.add(referenceIncentiveAmount);
  290. kuaishouRuleSettlementDataMapper.replaceIncentiveLog(relateId, promoterId, ruleId, incentivizedCount, lastIncentivizedCount);
  291. }
  292. if (Check.isNull(lastRule)) { //查询到上次命中的结算规则 则代表为新结算用户
  293. JSONObject getTotalByCountAndRuleId = kuaishouRuleSettlementDataMapper.getTotalByCountAndRuleId(incentivizedCount, ruleId);
  294. if (!Check.isNull(getTotalByCountAndRuleId)) {
  295. anchorAmount = anchorAmount.add(getTotalByCountAndRuleId.getBigDecimal("anchorAmount"));
  296. referenceAmount = referenceAmount.add(getTotalByCountAndRuleId.getBigDecimal("referenceAmount"));
  297. }
  298. BigDecimal decValidOrderNum = new BigDecimal(validOrderNum);
  299. Long residueNum = decValidOrderNum.subtract(new BigDecimal(incentivizedCount).multiply(new BigDecimal(10000))).longValue(); // 新用户 剩余不到1w单的结算
  300. for (int i = 0; i < ruleList.size(); i++) {
  301. JSONObject rule = ruleList.get(i);
  302. Long startItemCount = rule.getLong("startItemCount");
  303. Long endItemCount = rule.getLong("endItemCount");
  304. if (residueNum >= startItemCount && residueNum <= endItemCount) {
  305. ruleJson = rule;
  306. break;
  307. }
  308. }
  309. if (Check.isNull(ruleJson) || ruleJson.size() == 0) { // 剩余单量未命中结算规则 直接跳出此次结算计算
  310. returnJson.put("sonRuleId", 0);
  311. returnJson.put("anchorAmount", anchorAmount);
  312. returnJson.put("referenceAmount", referenceAmount);
  313. returnJson.put("settlementStatus", 2);
  314. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  315. return returnJson;
  316. }
  317. Integer currentSortCount = ruleJson.getInteger("sortCount"); // 当前结算命中的规则序号
  318. JSONObject totalAmount = kuaishouRuleSettlementDataMapper.getTotalAmount(ruleId, 0, currentSortCount); // 新的规则 序号从0开始
  319. returnJson.put("sonRuleId", ruleJson.getLong("id"));
  320. anchorAmount = anchorAmount.add(totalAmount.getBigDecimal("anchorAmount"));
  321. referenceAmount = referenceAmount.add(totalAmount.getBigDecimal("referenceAmount"));
  322. returnJson.put("anchorAmount", anchorAmount);
  323. returnJson.put("referenceAmount", referenceAmount);
  324. returnJson.put("settlementStatus", 2);
  325. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  326. return returnJson;
  327. } else { // 非新结算达人
  328. if (validOrderNum <= lastValidOrderNum) { // 当前结算有效订单 小于等于上次结算有效订单数 则不参与接下来的结算
  329. returnJson.put("sonRuleId", 0);
  330. returnJson.put("anchorAmount", 0);
  331. returnJson.put("referenceAmount", 0);
  332. returnJson.put("settlementStatus", 1);
  333. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  334. return returnJson;
  335. }
  336. Integer lastSortCount = lastRule.getInteger("sortCount"); // 上次结算命中的规则序号
  337. Integer ruleMaxCount = kuaishouRuleSettlementDataMapper.getMaxRuleCountByRuleId(ruleId); // 当前规则下最大的序号
  338. Long complement = null;
  339. if (lastValidOrderNum > 10000) {
  340. String lastValidOrderNumStr = String.valueOf(lastValidOrderNum);
  341. String substring = lastValidOrderNumStr.substring(lastValidOrderNumStr.length() - 4);
  342. Long aLong = Long.valueOf(substring);
  343. Long curComplement = 10000 - aLong;
  344. if (validOrderNum - lastValidOrderNum <= curComplement) { // 当前单量不够补齐10000单
  345. Long ruleOrder = aLong + (validOrderNum - lastValidOrderNum); // 当前单数补齐上一次结算的最终单数
  346. for (int i = 0; i < ruleList.size(); i++) {
  347. JSONObject rule = ruleList.get(i);
  348. Long startItemCount = rule.getLong("startItemCount");
  349. Long endItemCount = rule.getLong("endItemCount");
  350. if (ruleOrder >= startItemCount && ruleOrder <= endItemCount) {
  351. ruleJson = rule;
  352. break;
  353. }
  354. }
  355. if (Check.isNull(ruleJson) || ruleJson.size() == 0) { // 剩余单量未命中结算规则 直接跳出此次结算计算
  356. returnJson.put("sonRuleId", 0);
  357. returnJson.put("anchorAmount", anchorAmount);
  358. returnJson.put("referenceAmount", referenceAmount);
  359. returnJson.put("settlementStatus", 2);
  360. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  361. return returnJson;
  362. } else {
  363. Integer currentSortCount = ruleJson.getInteger("sortCount"); // 当前结算命中的规则序号
  364. JSONObject amount = kuaishouRuleSettlementDataMapper.getTotalAmount(ruleId, lastSortCount, currentSortCount); // 新的规则 序号从0开始
  365. returnJson.put("sonRuleId", ruleJson.getLong("id"));
  366. anchorAmount = anchorAmount.add(amount.getBigDecimal("anchorAmount"));
  367. referenceAmount = referenceAmount.add(amount.getBigDecimal("referenceAmount"));
  368. returnJson.put("anchorAmount", anchorAmount);
  369. returnJson.put("referenceAmount", referenceAmount);
  370. returnJson.put("settlementStatus", 2);
  371. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  372. return returnJson;
  373. }
  374. } else {
  375. complement = 10000 - aLong;
  376. }
  377. } else {
  378. Long asLong = 10000 - lastValidOrderNum; // 补齐1000单需要的单数
  379. if (validOrderNum - lastValidOrderNum <= asLong) { // 当前单量不够补齐10000单
  380. Long ruleOrder = lastValidOrderNum + (validOrderNum - lastValidOrderNum); // 当前单数补齐上一次结算的最终单数
  381. for (int i = 0; i < ruleList.size(); i++) {
  382. JSONObject rule = ruleList.get(i);
  383. Long startItemCount = rule.getLong("startItemCount");
  384. Long endItemCount = rule.getLong("endItemCount");
  385. if (ruleOrder >= startItemCount && ruleOrder <= endItemCount) {
  386. ruleJson = rule;
  387. break;
  388. }
  389. }
  390. if (Check.isNull(ruleJson) || ruleJson.size() == 0) { // 剩余单量未命中结算规则 直接跳出此次结算计算
  391. returnJson.put("sonRuleId", 0);
  392. returnJson.put("anchorAmount", anchorAmount);
  393. returnJson.put("referenceAmount", referenceAmount);
  394. returnJson.put("settlementStatus", 2);
  395. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  396. return returnJson;
  397. } else {
  398. Integer currentSortCount = ruleJson.getInteger("sortCount"); // 当前结算命中的规则序号
  399. JSONObject amount = kuaishouRuleSettlementDataMapper.getTotalAmount(ruleId, lastSortCount, currentSortCount); // 新的规则 序号从0开始
  400. returnJson.put("sonRuleId", ruleJson.getLong("id"));
  401. anchorAmount = anchorAmount.add(amount.getBigDecimal("anchorAmount"));
  402. referenceAmount = referenceAmount.add(amount.getBigDecimal("referenceAmount"));
  403. returnJson.put("anchorAmount", anchorAmount);
  404. returnJson.put("referenceAmount", referenceAmount);
  405. returnJson.put("settlementStatus", 2);
  406. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  407. return returnJson;
  408. }
  409. } else {
  410. complement = 10000 - lastValidOrderNum;
  411. }
  412. }
  413. // 查询 上次结算补齐10000需要激励的金额
  414. JSONObject totalAmount = kuaishouRuleSettlementDataMapper.getTotalAmount(ruleId, lastSortCount, ruleMaxCount);
  415. anchorAmount = anchorAmount.add(totalAmount.getBigDecimal("anchorAmount"));
  416. referenceAmount = referenceAmount.add(totalAmount.getBigDecimal("referenceAmount"));
  417. Long newValidOrderNum = validOrderNum - complement - lastValidOrderNum;
  418. if (newValidOrderNum > 10000) { // 如果剩余单量大于一万单 计算完成1w周期内的结算金额
  419. Integer newSettlementCount = (int) Math.floor(newValidOrderNum / 10000); // 补齐上次结算10000单后需要结算的完整次数
  420. JSONObject totalByCountAndRuleId = kuaishouRuleSettlementDataMapper.getTotalByCountAndRuleId(newSettlementCount, ruleId);
  421. anchorAmount = anchorAmount.add(totalByCountAndRuleId.getBigDecimal("anchorAmount"));
  422. referenceAmount = referenceAmount.add(totalByCountAndRuleId.getBigDecimal("referenceAmount"));
  423. newValidOrderNum = newValidOrderNum - (newSettlementCount * 10000);
  424. }
  425. for (int i = 0; i < ruleList.size(); i++) {
  426. JSONObject rule = ruleList.get(i);
  427. Long startItemCount = rule.getLong("startItemCount");
  428. Long endItemCount = rule.getLong("endItemCount");
  429. if (newValidOrderNum >= startItemCount && newValidOrderNum <= endItemCount) {
  430. ruleJson = rule;
  431. break;
  432. }
  433. }
  434. if (Check.isNull(ruleJson) || ruleJson.size() == 0) { // 剩余单量未命中结算规则 直接跳出此次结算计算
  435. returnJson.put("sonRuleId", 0);
  436. returnJson.put("anchorAmount", anchorAmount);
  437. returnJson.put("referenceAmount", referenceAmount);
  438. returnJson.put("settlementStatus", 2);
  439. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  440. return returnJson;
  441. }
  442. Integer currentSortCount = ruleJson.getInteger("sortCount"); // 当前结算命中的规则序号
  443. JSONObject amount = kuaishouRuleSettlementDataMapper.getTotalAmount(ruleId, 0, currentSortCount); // 新的规则 序号从0开始
  444. returnJson.put("sonRuleId", ruleJson.getLong("id"));
  445. anchorAmount = anchorAmount.add(amount.getBigDecimal("anchorAmount"));
  446. referenceAmount = referenceAmount.add(amount.getBigDecimal("referenceAmount"));
  447. returnJson.put("anchorAmount", anchorAmount);
  448. returnJson.put("referenceAmount", referenceAmount);
  449. returnJson.put("settlementStatus", 2);
  450. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  451. return returnJson;
  452. }
  453. }
  454. return returnJson;
  455. }
  456. // 按单量结算
  457. @Override
  458. public JSONObject getOrderRuleData(Long relateId, Long promoterId, Long ruleId, Long validOrderNum) {
  459. JSONObject returnJson = new JSONObject();
  460. BigDecimal anchorAmount = new BigDecimal(0); // 达人激励
  461. BigDecimal referenceAmount = new BigDecimal(0); // 推荐人激励
  462. KuaishouSettlementRules kuaishouSettlementRules = settlementRulesService.selectKuaishouSettlementRulesById(ruleId);
  463. returnJson.put("ruleId", ruleId);
  464. JSONObject lastRule = kuaishouRuleSettlementDataMapper.lastRule(relateId, promoterId, ruleId); //上次结算命中的规则
  465. Long lastValidOrderNum = 0L;
  466. if (!Check.isNull(lastRule)) {
  467. lastValidOrderNum += lastRule.getLong("validOrderNum");
  468. }
  469. JSONObject ruleJson = kuaishouRuleSettlementDataMapper.getRuleJson(ruleId);
  470. if (Check.isNull(ruleJson)) {
  471. returnJson.put("sonRuleId", 0);
  472. returnJson.put("ruleName", "未命中结算规则");
  473. returnJson.put("anchorAmount", anchorAmount);
  474. returnJson.put("referenceAmount", referenceAmount);
  475. returnJson.put("settlementStatus", 1);
  476. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  477. return returnJson;
  478. }
  479. Integer itemCount = ruleJson.getInteger("startItemCount"); // 规则单数
  480. BigDecimal ruleAnchorAmount = ruleJson.getBigDecimal("anchorAmount"); // 规则达人激励金额
  481. if (Check.isNull(ruleAnchorAmount)) {
  482. ruleAnchorAmount = new BigDecimal(0);
  483. }
  484. BigDecimal ruleReferenceAmount = ruleJson.getBigDecimal("referenceAmount"); // 规则达人激励金额
  485. if (Check.isNull(ruleReferenceAmount)) {
  486. ruleReferenceAmount = new BigDecimal(0);
  487. }
  488. if (validOrderNum < itemCount) {
  489. returnJson.put("sonRuleId", 0);
  490. returnJson.put("ruleName", "未命中结算规则");
  491. returnJson.put("anchorAmount", anchorAmount);
  492. returnJson.put("referenceAmount", referenceAmount);
  493. returnJson.put("settlementStatus", 1);
  494. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  495. return returnJson;
  496. }
  497. Integer incentivizedCount = (int) Math.floor(validOrderNum / itemCount); // 需要结算的次数
  498. Integer lastIncentivizedCount = kuaishouRuleSettlementDataMapper.selectIncentiveLog(relateId, promoterId); // 已结算次数
  499. if (Check.isNull(lastIncentivizedCount)) {
  500. lastIncentivizedCount = 0;
  501. }
  502. if (incentivizedCount > lastIncentivizedCount) {
  503. BigDecimal count = new BigDecimal(incentivizedCount - lastIncentivizedCount);
  504. BigDecimal promoterIncentiveAmount = count.multiply(ruleAnchorAmount); // 达人奖励
  505. BigDecimal referenceIncentiveAmount = count.multiply(ruleReferenceAmount); // 推荐人奖励
  506. anchorAmount = anchorAmount.add(promoterIncentiveAmount);
  507. referenceAmount = referenceAmount.add(referenceIncentiveAmount);
  508. kuaishouRuleSettlementDataMapper.replaceIncentiveLog(relateId, promoterId, ruleId, incentivizedCount, lastIncentivizedCount);
  509. returnJson.put("sonRuleId", ruleJson.getLong("id"));
  510. returnJson.put("ruleName", kuaishouSettlementRules.getRuleName());
  511. returnJson.put("anchorAmount", anchorAmount);
  512. returnJson.put("referenceAmount", referenceAmount);
  513. returnJson.put("settlementStatus", 2);
  514. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  515. return returnJson;
  516. } else {
  517. returnJson.put("sonRuleId", 0);
  518. returnJson.put("ruleName", "未命中结算规则");
  519. returnJson.put("anchorAmount", anchorAmount);
  520. returnJson.put("referenceAmount", referenceAmount);
  521. returnJson.put("settlementStatus", 1);
  522. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  523. return returnJson;
  524. }
  525. }
  526. // 按达人结算
  527. @Override
  528. public JSONObject getPromoterRuleData(Long relateId, Long promoterId, Long ruleId, Long validOrderNum) {
  529. JSONObject returnJson = new JSONObject();
  530. BigDecimal anchorAmount = new BigDecimal(0); // 达人激励
  531. BigDecimal referenceAmount = new BigDecimal(0); // 推荐人激励
  532. KuaishouSettlementRules kuaishouSettlementRules = settlementRulesService.selectKuaishouSettlementRulesById(ruleId);
  533. returnJson.put("ruleId", ruleId);
  534. JSONObject lastRule = kuaishouRuleSettlementDataMapper.lastRule(null, promoterId, ruleId); //上次结算命中的规则
  535. Long lastValidOrderNum = 0L;
  536. if (!Check.isNull(lastRule)) {
  537. lastValidOrderNum += lastRule.getLong("validOrderNum");
  538. }
  539. JSONObject ruleJson = kuaishouRuleSettlementDataMapper.getRuleJson(ruleId);
  540. if (Check.isNull(ruleJson)) {
  541. returnJson.put("sonRuleId", 0);
  542. returnJson.put("ruleName", "未命中结算规则");
  543. returnJson.put("anchorAmount", anchorAmount);
  544. returnJson.put("referenceAmount", referenceAmount);
  545. returnJson.put("settlementStatus", 1);
  546. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  547. return returnJson;
  548. }
  549. Integer itemCount = ruleJson.getInteger("startItemCount"); // 规则单数
  550. BigDecimal ruleAnchorAmount = ruleJson.getBigDecimal("anchorAmount"); // 规则达人激励金额
  551. if (Check.isNull(ruleAnchorAmount)) {
  552. ruleAnchorAmount = new BigDecimal(0);
  553. }
  554. BigDecimal ruleReferenceAmount = ruleJson.getBigDecimal("referenceAmount"); // 规则达人激励金额
  555. if (Check.isNull(ruleReferenceAmount)) {
  556. ruleReferenceAmount = new BigDecimal(0);
  557. }
  558. if (validOrderNum < itemCount) {
  559. returnJson.put("sonRuleId", 0);
  560. returnJson.put("ruleName", "未命中结算规则");
  561. returnJson.put("anchorAmount", anchorAmount);
  562. returnJson.put("referenceAmount", referenceAmount);
  563. returnJson.put("settlementStatus", 1);
  564. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  565. return returnJson;
  566. }
  567. Integer incentivizedCount = (int) Math.floor(validOrderNum / itemCount); // 需要结算的次数
  568. Integer lastIncentivizedCount = kuaishouRuleSettlementDataMapper.selectPromoterIncentiveLog(promoterId); // 已结算次数
  569. if (Check.isNull(lastIncentivizedCount)) {
  570. lastIncentivizedCount = 0;
  571. }
  572. if (incentivizedCount > lastIncentivizedCount) {
  573. BigDecimal count = new BigDecimal(incentivizedCount - lastIncentivizedCount);
  574. BigDecimal promoterIncentiveAmount = count.multiply(ruleAnchorAmount); // 达人奖励
  575. BigDecimal referenceIncentiveAmount = count.multiply(ruleReferenceAmount); // 推荐人奖励
  576. anchorAmount = anchorAmount.add(promoterIncentiveAmount);
  577. referenceAmount = referenceAmount.add(referenceIncentiveAmount);
  578. kuaishouRuleSettlementDataMapper.replacePromoterIncentiveLog(promoterId, ruleId, incentivizedCount, lastIncentivizedCount);
  579. returnJson.put("sonRuleId", ruleJson.getLong("id"));
  580. returnJson.put("ruleName", kuaishouSettlementRules.getRuleName());
  581. returnJson.put("anchorAmount", anchorAmount);
  582. returnJson.put("referenceAmount", referenceAmount);
  583. returnJson.put("settlementStatus", 2);
  584. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  585. return returnJson;
  586. } else {
  587. returnJson.put("sonRuleId", 0);
  588. returnJson.put("ruleName", "未命中结算规则");
  589. returnJson.put("anchorAmount", anchorAmount);
  590. returnJson.put("referenceAmount", referenceAmount);
  591. returnJson.put("settlementStatus", 1);
  592. returnJson.put("lastSettlementOrderNum", lastValidOrderNum);
  593. return returnJson;
  594. }
  595. }
  596. @Override
  597. public List<JSONObject> getSettlementDate(Long statDate, Long promoterId, String promoterName) {
  598. return kuaishouRuleSettlementDataMapper.getSettlementDate(statDate, promoterId, promoterName);
  599. }
  600. @Override
  601. public void updatePromoterStatus(Long statDate, Long promoterId, Integer status) {
  602. kuaishouRuleSettlementDataMapper.updatePromoterStatus(statDate, promoterId, status);
  603. }
  604. @Override
  605. public List<JSONObject> getPromoterSettlementDetail(Long date, Long promoterId, Integer settlementStatus,Long itemId) {
  606. return kuaishouRuleSettlementDataMapper.getPromoterSettlementDetail(date, promoterId, settlementStatus,itemId);
  607. }
  608. @Override
  609. public JSONObject getData() {
  610. return kuaishouRuleSettlementDataMapper.getData();
  611. }
  612. }