SettlementServiceImpl.java 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537
  1. package com.crm.settlement.service.impl;
  2. import com.alibaba.fastjson2.JSON;
  3. import com.crm.rely.backend.core.constant.Constants;
  4. import com.crm.rely.backend.core.dto.base.BaseResultDto;
  5. import com.crm.rely.backend.core.dto.base.BaseResultWithPagerDto;
  6. import com.crm.rely.backend.core.dto.base.PageDto;
  7. import com.crm.rely.backend.core.entity.base.PageEntity;
  8. import com.crm.rely.backend.core.exception.PayValidatedException;
  9. import com.crm.rely.backend.core.exception.ServiceException;
  10. import com.crm.rely.backend.model.constant.ConfigConstants;
  11. import com.crm.rely.backend.model.constant.SettlementConstant;
  12. import com.crm.rely.backend.model.dto.settlement.SettlementDepositDto;
  13. import com.crm.rely.backend.model.dto.settlement.SettlementValidateDto;
  14. import com.crm.rely.backend.model.dto.settlement.SettlementWithdrawDto;
  15. import com.crm.rely.backend.model.entity.base.MerchantPayInRequestEntity;
  16. import com.crm.rely.backend.model.entity.base.MerchantPayOutRequestEntity;
  17. import com.crm.rely.backend.model.entity.settlement.SettlementDepositListSearchEntity;
  18. import com.crm.rely.backend.model.entity.settlement.SettlementValidateDepositEntity;
  19. import com.crm.rely.backend.model.entity.settlement.SettlementValidateWithdrawEntity;
  20. import com.crm.rely.backend.model.entity.settlement.SettlementWithdrawListSearchEntity;
  21. import com.crm.rely.backend.model.entity.settlement.log.SettlementCallbackLogAddEntity;
  22. import com.crm.rely.backend.model.entity.settlement.vaultody.VaultodyDepositRequestEntity;
  23. import com.crm.rely.backend.model.entity.settlement.vaultody.VaultodyWithdrawRequestEntity;
  24. import com.crm.rely.backend.model.pojo.table.SettlementDepositRecordTable;
  25. import com.crm.rely.backend.model.pojo.table.SettlementWithdrawRecordTable;
  26. import com.crm.rely.backend.model.pojo.table.SysSettlementConfigTable;
  27. import com.crm.rely.backend.model.util.MapToEntityConverterUtil;
  28. import com.crm.rely.backend.service.MqSendService;
  29. import com.crm.rely.backend.util.FormatPage;
  30. import com.crm.rely.backend.util.HttpUtil;
  31. import com.crm.rely.backend.util.MapUtil;
  32. import com.crm.settlement.dao.mapper.SettlementDepositRecordMapper;
  33. import com.crm.settlement.dao.mapper.SettlementWithdrawRecordMapper;
  34. import com.crm.settlement.dao.repository.SettlementDepositRecordRepository;
  35. import com.crm.settlement.dao.repository.SettlementWithdrawRecordRepository;
  36. import com.crm.settlement.service.SettlementLogService;
  37. import com.crm.settlement.service.SettlementService;
  38. import com.crm.settlement.service.SysSettlementConfigService;
  39. import com.crm.settlement.service.VaultodyService;
  40. import com.crm.settlement.service.impl.base.BaseSettlementServiceImpl;
  41. import lombok.extern.slf4j.Slf4j;
  42. import org.apache.commons.lang3.StringUtils;
  43. import org.jsoup.Connection;
  44. import org.springframework.beans.BeanUtils;
  45. import org.springframework.beans.factory.annotation.Autowired;
  46. import org.springframework.jms.annotation.JmsListener;
  47. import org.springframework.scheduling.annotation.Scheduled;
  48. import org.springframework.stereotype.Service;
  49. import org.springframework.transaction.annotation.Transactional;
  50. import org.springframework.util.CollectionUtils;
  51. import java.math.BigDecimal;
  52. import java.util.*;
  53. @Slf4j
  54. @Service
  55. public class SettlementServiceImpl extends BaseSettlementServiceImpl implements SettlementService {
  56. @Autowired
  57. private SettlementDepositRecordRepository settlementDepositRecordRepository;
  58. @Autowired
  59. private SettlementWithdrawRecordRepository settlementWithdrawRecordRepository;
  60. @Autowired
  61. private SettlementDepositRecordMapper settlementDepositRecordMapper;
  62. @Autowired
  63. private SettlementWithdrawRecordMapper settlementWithdrawRecordMapper;
  64. @Autowired
  65. private SysSettlementConfigService sysSettlementConfigService;
  66. @Autowired
  67. private VaultodyService vaultodyService;
  68. @Autowired
  69. private SettlementLogService settlementLogService;
  70. @Autowired
  71. private MqSendService mqSendService;
  72. /**
  73. * 验证入金订单
  74. */
  75. @Override
  76. public BaseResultDto validateDepositOrder(SettlementValidateDepositEntity entity) {
  77. try {
  78. //验证时间
  79. Long requestTimestamp = entity.getRequestTime();
  80. //验证时间
  81. long serverTimestamp = System.currentTimeMillis();
  82. long timeDiff = Math.abs(serverTimestamp - requestTimestamp);
  83. if (timeDiff > 60000) {
  84. log.error("time out :" + JSON.toJSONString(entity) + ",serverTime:" + serverTimestamp + ",requestTime:" + requestTimestamp + ",diff:" + timeDiff);
  85. throw ServiceException.exception("Time out");
  86. }
  87. verifySign(entity.getSign(), getDepositSignString(entity), entity.getMerchantId());
  88. SettlementDepositRecordTable recordTable = settlementDepositRecordRepository.findFirstBySerialAndChannelCode(entity.getSerial(), entity.getChannelCode());
  89. if (recordTable == null || recordTable.getStatus() == null || recordTable.getStatus().equals(0)) {
  90. return BaseResultDto.error();
  91. }
  92. SettlementValidateDto dto = new SettlementValidateDto();
  93. dto.setStatus(recordTable.getStatus());
  94. return BaseResultDto.success(dto);
  95. } catch (Exception e) {
  96. return BaseResultDto.error();
  97. }
  98. }
  99. /**
  100. * 验证出金订单
  101. */
  102. @Override
  103. public BaseResultDto validateWithdrawOrder(SettlementValidateWithdrawEntity entity) throws PayValidatedException {
  104. try {
  105. //验证时间
  106. Long requestTimestamp = entity.getRequestTime();
  107. //验证时间
  108. long serverTimestamp = System.currentTimeMillis();
  109. long timeDiff = Math.abs(serverTimestamp - requestTimestamp);
  110. if (timeDiff > 60000) {
  111. log.error("time out :" + JSON.toJSONString(entity) + ",serverTime:" + serverTimestamp + ",requestTime:" + requestTimestamp + ",diff:" + timeDiff);
  112. throw ServiceException.exception("Time out");
  113. }
  114. verifySign(entity.getSign(), getWithdrawSignString(entity), entity.getMerchantId());
  115. SettlementWithdrawRecordTable recordTable = settlementWithdrawRecordRepository.findFirstBySerialAndChannelCode(entity.getSerial(), entity.getChannelCode());
  116. if (recordTable == null || recordTable.getStatus() == null || recordTable.getStatus().equals(0)) {
  117. return BaseResultDto.error();
  118. }
  119. SettlementValidateDto dto = new SettlementValidateDto();
  120. dto.setStatus(recordTable.getStatus());
  121. return BaseResultDto.success(dto);
  122. } catch (Exception e) {
  123. return BaseResultDto.error();
  124. }
  125. }
  126. @Override
  127. public BaseResultDto deposit(Map<String, String> request) throws Exception {
  128. MerchantPayInRequestEntity requestEntity = verifyDepositRequest(request);
  129. String channelCode = requestEntity.getChannelCode();
  130. switch (channelCode) {
  131. case SettlementConstant.VAULTODY_PAY_KEY:
  132. VaultodyDepositRequestEntity vaultodyDepositRequest = MapToEntityConverterUtil.convertAndValidate(request, VaultodyDepositRequestEntity.class);
  133. return vaultodyService.deposit(vaultodyDepositRequest);
  134. default:
  135. throw ServiceException.exception("channel Not support");
  136. }
  137. }
  138. @Override
  139. public BaseResultDto withdraw(Map<String, String> request) throws Exception{
  140. MerchantPayOutRequestEntity requestEntity = verifyWithdrawRequest(request);
  141. String channelCode = requestEntity.getChannelCode();
  142. switch (channelCode) {
  143. case SettlementConstant.VAULTODY_PAY_REMIT:
  144. VaultodyWithdrawRequestEntity vaultodyWithdrawRequest = MapToEntityConverterUtil.convertAndValidate(request, VaultodyWithdrawRequestEntity.class);
  145. return vaultodyService.withdraw(vaultodyWithdrawRequest);
  146. default:
  147. throw ServiceException.exception("channel Not support");
  148. }
  149. }
  150. @Override
  151. public BaseResultWithPagerDto<List<SettlementDepositDto>> depositSearchList(SettlementDepositListSearchEntity entity) throws Exception {
  152. String signString = getDepositlistSignString(entity);
  153. verifySign(entity.getSign(), signString, entity.getMerchantId());
  154. if (entity.getCurrent() != null && entity.getRow() != null){
  155. PageEntity page = new PageEntity();
  156. page.setCurrent(entity.getCurrent());
  157. page.setRow(entity.getRow());
  158. entity.setPage(page);
  159. }
  160. /*
  161. 获取总数
  162. */
  163. Integer count = settlementDepositRecordMapper.countList(entity);
  164. PageDto pageDto = FormatPage.format(entity.getPage(), count);
  165. if (count <= 0) {
  166. if (count == null || count == 0) {
  167. return BaseResultWithPagerDto.success(pageDto);
  168. }
  169. }
  170. /*
  171. 获取列表
  172. */
  173. List<SettlementDepositRecordTable> depositRecordTables = settlementDepositRecordMapper.pageList(entity);
  174. if (depositRecordTables == null || depositRecordTables.size() <= 0) {
  175. throw new ServiceException(Constants.SYSTEM_ERROR);
  176. }
  177. List<SettlementDepositDto> depositDtos = new ArrayList<>(depositRecordTables.size());
  178. for (SettlementDepositRecordTable depositRecordTable : depositRecordTables) {
  179. SettlementDepositDto depositDto = depositTransform(depositRecordTable);
  180. depositDtos.add(depositDto);
  181. }
  182. return BaseResultWithPagerDto.success(depositDtos, pageDto);
  183. }
  184. @Override
  185. public BaseResultWithPagerDto<List<SettlementWithdrawDto>> withdrawSearchList(SettlementWithdrawListSearchEntity entity) throws Exception {
  186. String signString = getWithdrawlistSignString(entity);
  187. verifySign(entity.getSign(), signString, entity.getMerchantId());
  188. if (entity.getCurrent() != null && entity.getRow() != null){
  189. PageEntity page = new PageEntity();
  190. page.setCurrent(entity.getCurrent());
  191. page.setRow(entity.getRow());
  192. entity.setPage(page);
  193. }
  194. /*
  195. 获取总数
  196. */
  197. Integer count = settlementWithdrawRecordMapper.countList(entity);
  198. PageDto pageDto = FormatPage.format(entity.getPage(), count);
  199. if (count <= 0) {
  200. if (count == null || count == 0) {
  201. return BaseResultWithPagerDto.success(pageDto);
  202. }
  203. }
  204. /*
  205. 获取列表
  206. */
  207. List<SettlementWithdrawRecordTable> withdrawRecordTables = settlementWithdrawRecordMapper.pageList(entity);
  208. if (withdrawRecordTables == null || withdrawRecordTables.size() <= 0) {
  209. throw new ServiceException(Constants.SYSTEM_ERROR);
  210. }
  211. List<SettlementWithdrawDto> withdrawDtos = new ArrayList<>(withdrawRecordTables.size());
  212. for (SettlementWithdrawRecordTable depositRecordTable : withdrawRecordTables) {
  213. SettlementWithdrawDto depositDto = withdrawTransform(depositRecordTable);
  214. withdrawDtos.add(depositDto);
  215. }
  216. return BaseResultWithPagerDto.success(withdrawDtos, pageDto);
  217. }
  218. private SettlementDepositDto depositTransform(SettlementDepositRecordTable depositRecordTable) {
  219. SettlementDepositDto depositDto = new SettlementDepositDto();
  220. BeanUtils.copyProperties(depositRecordTable, depositDto);
  221. return depositDto;
  222. }
  223. private SettlementWithdrawDto withdrawTransform(SettlementWithdrawRecordTable withdrawRecordTable) {
  224. SettlementWithdrawDto withdrawDto = new SettlementWithdrawDto();
  225. BeanUtils.copyProperties(withdrawRecordTable, withdrawDto);
  226. return withdrawDto;
  227. }
  228. /**
  229. * 验证请求时间和金额
  230. */
  231. protected MerchantPayOutRequestEntity verifyWithdrawRequest(Map<String, String> request) throws ServiceException {
  232. MerchantPayOutRequestEntity requestEntity = MapToEntityConverterUtil.convertAndValidate(request, MerchantPayOutRequestEntity.class);
  233. String merchantId = requestEntity.getMerchantId();
  234. BigDecimal amount = requestEntity.getAmount();
  235. Long requestTimestamp = requestEntity.getRequestTime();
  236. //验证时间
  237. long serverTimestamp = System.currentTimeMillis();
  238. long timeDiff = Math.abs(serverTimestamp - requestTimestamp);
  239. if (timeDiff > 60000) {
  240. log.error("time out :" + JSON.toJSONString(request) + ",serverTime:" + serverTimestamp + ",requestTime:" + requestTimestamp + ",diff:" + timeDiff);
  241. throw ServiceException.exception("Time out");
  242. }
  243. // 验证金额
  244. if (amount.compareTo(BigDecimal.ZERO) <= 0) {
  245. throw ServiceException.exception("Invalid amount");
  246. }
  247. // 验证商户
  248. SysSettlementConfigTable table = sysSettlementConfigService.getByCode(merchantId);
  249. if (table == null || StringUtils.isEmpty(table.getValue())) {
  250. throw ServiceException.exception("Merchant error");
  251. }
  252. // 验证订单
  253. if (settlementWithdrawRecordRepository.existsByMerchantIdAndSerial(request.get("merchantId"), request.get("serial"))) {
  254. throw ServiceException.exception("Duplicate order");
  255. }
  256. return requestEntity;
  257. }
  258. /**
  259. * 验证请求时间和金额
  260. */
  261. protected MerchantPayInRequestEntity verifyDepositRequest(Map<String, String> request) throws ServiceException {
  262. MerchantPayInRequestEntity requestEntity = MapToEntityConverterUtil.convertAndValidate(request, MerchantPayInRequestEntity.class);
  263. String merchantId = requestEntity.getMerchantId();
  264. BigDecimal amount = requestEntity.getAmount();
  265. Long requestTimestamp = requestEntity.getRequestTime();
  266. //验证时间
  267. long serverTimestamp = System.currentTimeMillis();
  268. long timeDiff = Math.abs(serverTimestamp - requestTimestamp);
  269. if (timeDiff > 60000) {
  270. log.error("time out :" + JSON.toJSONString(request) + ",serverTime:" + serverTimestamp + ",requestTime:" + requestTimestamp + ",diff:" + timeDiff);
  271. throw ServiceException.exception("Time out");
  272. }
  273. // 验证金额
  274. if (amount.compareTo(BigDecimal.ZERO) <= 0) {
  275. throw ServiceException.exception("Invalid amount");
  276. }
  277. // 验证商户
  278. SysSettlementConfigTable table = sysSettlementConfigService.getByCode(merchantId);
  279. if (table == null || StringUtils.isEmpty(table.getValue())) {
  280. throw ServiceException.exception("Merchant error");
  281. }
  282. // 验证订单
  283. if (settlementDepositRecordRepository.existsByMerchantIdAndSerial(request.get("merchantId"), request.get("serial"))) {
  284. throw ServiceException.exception("Duplicate order");
  285. }
  286. return requestEntity;
  287. }
  288. @Transactional(rollbackFor = Exception.class)
  289. @JmsListener(destination = ConfigConstants.DEPOSIT_CALLBACK)
  290. public void depositCallback(String content) throws Exception {
  291. log.info("DEPOSIT_CALLBACK: content:" + content);
  292. SettlementDepositRecordTable recordTable = JSON.parseObject(content, SettlementDepositRecordTable.class);
  293. SettlementDepositRecordTable table = settlementDepositRecordRepository.findFirstById(recordTable.getId());
  294. if (table == null) {
  295. log.error("DEPOSIT_CALLBACK SettlementDepositRecordTable is null");
  296. return;
  297. }
  298. // 判断三方回调状态
  299. if (!table.getCallbackStatus()) {
  300. log.info("DEPOSIT_CALLBACK: callbackStatus is Failed ");
  301. return;
  302. }
  303. // 判断状态
  304. if (table.getCallbackMerchantStatus().equals(1)) {
  305. log.info("DEPOSIT_CALLBACK: callbackMerchantStatus is Success ");
  306. return;
  307. }
  308. if (table.getCallbackMerchantCount() >= table.getCallbackMerchantMaxRetryCount()) {
  309. log.info("DEPOSIT_CALLBACK: callbackMerchantCount is max retry count");
  310. return;
  311. }
  312. String callbackUrl = table.getCallbackUrl();
  313. Map<String, String> params = new HashMap<>();
  314. params.put("serial", table.getSerial());
  315. params.put("login", String.valueOf(table.getLogin()));
  316. params.put("channelCode", table.getChannelCode());
  317. params.put("callbackAmount", table.getCallbackAmount().stripTrailingZeros().toPlainString());
  318. params.put("callbackCurrency", table.getCallbackCurrency());
  319. params.put("callbackSerial", table.getCallbackSerial());
  320. String sign = getSign(params, table.getMerchantId());
  321. params.put("sign", sign);
  322. String callbackContent = JSON.toJSONString(params);
  323. try {
  324. Connection.Response response = HttpUtil.post(callbackUrl, callbackContent);
  325. //打印请求日志
  326. log.info("DEPOSIT_CALLBACK Request URL: {},data:{},response body:{}", callbackUrl, callbackContent, response.body());
  327. BaseResultDto requestEntity = JSON.parseObject(response.body(), BaseResultDto.class);
  328. if (requestEntity == null || requestEntity.getCode() != 200) {
  329. table.setCallbackMerchantStatus(2);
  330. } else {
  331. table.setCallbackMerchantStatus(1);
  332. }
  333. } catch (Exception e) {
  334. log.error("DEPOSIT_CALLBACK, Request URL: {}, data:{}", callbackUrl, callbackContent, e);
  335. table.setCallbackMerchantStatus(2);
  336. } finally {
  337. SettlementCallbackLogAddEntity addEntity = new SettlementCallbackLogAddEntity();
  338. addEntity.setMerchantId(table.getMerchantId());
  339. addEntity.setSerial(table.getSerial());
  340. addEntity.setAmount(table.getCallbackAmount());
  341. addEntity.setChannelCode(table.getChannelCode());
  342. addEntity.setCallbackUrl(callbackUrl);
  343. addEntity.setCallbackData(callbackContent);
  344. addEntity.setAddTime(new Date());
  345. addEntity.setNote("入金回调");
  346. settlementLogService.add(addEntity);
  347. }
  348. table.setCallbackMerchantCount(table.getCallbackMerchantCount() + 1);
  349. table.setCallbackMerchantTime(new Date());
  350. settlementDepositRecordRepository.save(table);
  351. if (table.getCallbackMerchantStatus().equals(2) && table.getCallbackMerchantCount() < table.getCallbackMerchantMaxRetryCount()) {
  352. mqSendService.send(ConfigConstants.DEPOSIT_CALLBACK, table, 3 * 60 * 1000);
  353. }
  354. }
  355. @Transactional(rollbackFor = Exception.class)
  356. @JmsListener(destination = ConfigConstants.WITHDRAW_CALLBACK)
  357. public void withdrawCallback(String content) throws Exception {
  358. log.info("WITHDRAW_CALLBACK: content:" + content);
  359. SettlementWithdrawRecordTable withdrawRecordTable = JSON.parseObject(content, SettlementWithdrawRecordTable.class);
  360. SettlementWithdrawRecordTable table = settlementWithdrawRecordRepository.findFirstById(withdrawRecordTable.getId());
  361. if (table == null) {
  362. log.error("WITHDRAW_CALLBACK SettlementDepositRecordTable is null");
  363. return;
  364. }
  365. // 判断状态
  366. if (table.getCallbackMerchantStatus().equals(1)) {
  367. log.info("WITHDRAW_CALLBACK: callbackMerchantStatus is Success ");
  368. return;
  369. }
  370. if (table.getCallbackMerchantCount() >= table.getCallbackMerchantMaxRetryCount()) {
  371. log.info("WITHDRAW_CALLBACK: callbackMerchantCount is max retry count");
  372. return;
  373. }
  374. String callbackUrl = table.getCallbackUrl();
  375. Map<String, String> params = new HashMap<>();
  376. params.put("serial", table.getSerial());
  377. params.put("login", String.valueOf(table.getLogin()));
  378. params.put("channelCode", table.getChannelCode());
  379. params.put("callbackAmount", table.getCallbackAmount().stripTrailingZeros().toPlainString());
  380. params.put("callbackCurrency", table.getCallbackCurrency());
  381. params.put("callbackSerial", table.getCallbackSerial());
  382. String sign = getSign(params, table.getMerchantId());
  383. params.put("sign", sign);
  384. String callbackContent = JSON.toJSONString(params);
  385. try {
  386. Connection.Response response = HttpUtil.post(callbackUrl, callbackContent);
  387. //打印请求日志
  388. log.info("WITHDRAW_CALLBACK Request URL: {},data:{},response body:{}", callbackUrl, callbackContent, response.body());
  389. BaseResultDto requestEntity = JSON.parseObject(response.body(), BaseResultDto.class);
  390. if (requestEntity == null || requestEntity.getCode() != 200) {
  391. table.setCallbackMerchantStatus(2);
  392. } else {
  393. table.setCallbackMerchantStatus(1);
  394. }
  395. } catch (Exception e) {
  396. log.error("WITHDRAW_CALLBACK, Request URL: {}, data:{}", callbackUrl, callbackContent, e);
  397. table.setCallbackMerchantStatus(2);
  398. } finally {
  399. SettlementCallbackLogAddEntity addEntity = new SettlementCallbackLogAddEntity();
  400. addEntity.setMerchantId(table.getMerchantId());
  401. addEntity.setSerial(table.getSerial());
  402. addEntity.setAmount(table.getCallbackAmount());
  403. addEntity.setChannelCode(table.getChannelCode());
  404. addEntity.setCallbackUrl(callbackUrl);
  405. addEntity.setCallbackData(callbackContent);
  406. addEntity.setAddTime(new Date());
  407. addEntity.setNote("入金回调");
  408. settlementLogService.add(addEntity);
  409. }
  410. // table.setCallbackMerchantBody(callbackMerchantBody);
  411. table.setCallbackMerchantCount(table.getCallbackMerchantCount() + 1);
  412. table.setCallbackMerchantTime(new Date());
  413. settlementWithdrawRecordRepository.save(table);
  414. if (table.getCallbackMerchantStatus().equals(2) && table.getCallbackMerchantCount() < table.getCallbackMerchantMaxRetryCount()) {
  415. mqSendService.send(ConfigConstants.WITHDRAW_CALLBACK, table, 3 * 60 * 1000);
  416. }
  417. }
  418. /**
  419. * 订单通知失败重新发送通知
  420. * 查询入金和出金 回调失败的 未达到最大回调次数的 超过一天的数据 分别发送回调
  421. */
  422. @Scheduled(cron = "0 23 0 * * ?")
  423. @Transactional(rollbackFor = Exception.class)
  424. public void scheduleCallback() throws ServiceException {
  425. log.info("scheduleCallback start");
  426. List<SettlementDepositRecordTable> depositRecordTables = settlementDepositRecordMapper.getAllCallback();
  427. List<SettlementWithdrawRecordTable> withdrawRecordTables = settlementWithdrawRecordMapper.getAllCallback();
  428. if (!CollectionUtils.isEmpty(depositRecordTables)) {
  429. log.info("scheduleCallback: depositRecordTables size:{}", depositRecordTables.size());
  430. for (SettlementDepositRecordTable table : depositRecordTables) {
  431. mqSendService.send(ConfigConstants.DEPOSIT_CALLBACK, table);
  432. }
  433. }
  434. if (!CollectionUtils.isEmpty(withdrawRecordTables)) {
  435. log.info("scheduleCallback: withdrawRecordTables size:{}", withdrawRecordTables.size());
  436. for (SettlementWithdrawRecordTable table : withdrawRecordTables) {
  437. mqSendService.send(ConfigConstants.WITHDRAW_CALLBACK, table);
  438. }
  439. }
  440. log.info("scheduleCallback end");
  441. }
  442. private String getDepositSignString(SettlementValidateDepositEntity entity) {
  443. Map<String, String> map = new HashMap<>();
  444. map.put("merchantId", entity.getMerchantId());
  445. map.put("channelCode", entity.getChannelCode());
  446. map.put("serial", entity.getSerial());
  447. map.put("requestTime", String.valueOf(entity.getRequestTime()));
  448. return MapUtil.getStringSortByKey(map);
  449. }
  450. private String getWithdrawSignString(SettlementValidateWithdrawEntity entity) {
  451. Map<String, String> map = new HashMap<>();
  452. map.put("merchantId", entity.getMerchantId());
  453. map.put("channelCode", entity.getChannelCode());
  454. map.put("serial", entity.getSerial());
  455. map.put("requestTime", String.valueOf(entity.getRequestTime()));
  456. return MapUtil.getStringSortByKey(map);
  457. }
  458. private String getDepositlistSignString(SettlementDepositListSearchEntity entity) {
  459. Map<String, String> map = new HashMap<>();
  460. map.put("merchantId", entity.getMerchantId());
  461. map.put("name", entity.getName());
  462. map.put("email", entity.getEmail());
  463. map.put("serial", entity.getSerial());
  464. map.put("login", String.valueOf(entity.getLogin()));
  465. map.put("channelCode", entity.getChannelCode());
  466. map.put("callbackMerchantStatus", String.valueOf(entity.getCallbackMerchantStatus()));
  467. map.put("startDate", String.valueOf(entity.getStartDate()));
  468. map.put("endDate", String.valueOf(entity.getEndDate()));
  469. map.put("current", String.valueOf(entity.getCurrent()));
  470. map.put("row", String.valueOf(entity.getRow()));
  471. map.put("requestTime", String.valueOf(entity.getRequestTime()));
  472. return MapUtil.getStringSortByKey(map);
  473. }
  474. private String getWithdrawlistSignString(SettlementWithdrawListSearchEntity entity) {
  475. Map<String, String> map = new HashMap<>();
  476. map.put("merchantId", entity.getMerchantId());
  477. map.put("name", entity.getName());
  478. map.put("email", entity.getEmail());
  479. map.put("serial", entity.getSerial());
  480. map.put("login", String.valueOf(entity.getLogin()));
  481. map.put("channelCode", entity.getChannelCode());
  482. map.put("callbackMerchantStatus", String.valueOf(entity.getCallbackMerchantStatus()));
  483. map.put("startDate", String.valueOf(entity.getStartDate()));
  484. map.put("endDate", String.valueOf(entity.getEndDate()));
  485. map.put("current", String.valueOf(entity.getCurrent()));
  486. map.put("row", String.valueOf(entity.getRow()));
  487. map.put("requestTime", String.valueOf(entity.getRequestTime()));
  488. return MapUtil.getStringSortByKey(map);
  489. }
  490. }