|
|
@@ -1,5 +1,6 @@
|
|
|
package com.sckw.payment.service;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
import com.github.pagehelper.PageHelper;
|
|
|
import com.github.pagehelper.PageInfo;
|
|
|
import com.sckw.core.exception.BusinessException;
|
|
|
@@ -16,7 +17,7 @@ import com.sckw.payment.model.constant.TradeUnitType;
|
|
|
import com.sckw.payment.model.dto.LedgerTradeDto;
|
|
|
import com.sckw.payment.model.vo.req.*;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
-import org.apache.commons.lang3.StringUtils;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
@@ -33,6 +34,7 @@ import java.util.Objects;
|
|
|
|
|
|
@Service
|
|
|
@AllArgsConstructor
|
|
|
+@Slf4j
|
|
|
public class KwpLedgerTradeService extends AbsLedger {
|
|
|
private final KwpLedgerTradeMapper tradeMapper;
|
|
|
private final KwpLedgerTradeTrackService tradeTrackService;
|
|
|
@@ -47,15 +49,9 @@ public class KwpLedgerTradeService extends AbsLedger {
|
|
|
* @return
|
|
|
*/
|
|
|
public PageRes<LedgerTradeDto> pageList(TradeReq tradeReq) {
|
|
|
- String keywords = tradeReq.getKeywords();
|
|
|
- if (StringUtils.isNotBlank(keywords)) {
|
|
|
-
|
|
|
- }
|
|
|
PageHelper.startPage(tradeReq.getPage(), tradeReq.getPageSize());
|
|
|
- List<LedgerTradeDto> ledgerTradeDto = tradeMapper.pageSelect(tradeReq, new ArrayList<>());
|
|
|
-
|
|
|
+ List<LedgerTradeDto> ledgerTradeDto = tradeMapper.pageSelect(tradeReq);
|
|
|
return new PageRes<>(new PageInfo<>(ledgerTradeDto));
|
|
|
-
|
|
|
}
|
|
|
|
|
|
private void removeDraft(Long id) {
|
|
|
@@ -67,35 +63,7 @@ public class KwpLedgerTradeService extends AbsLedger {
|
|
|
tradeUnitService.remove(id);
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 保存对账单
|
|
|
- *
|
|
|
- * @param tradeSendReq
|
|
|
- * @return
|
|
|
- */
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public String sendLedger(TradeSendReq tradeSendReq) {
|
|
|
- Long id = tradeSendReq.getId();
|
|
|
- if (Objects.isNull(id)) {
|
|
|
- //新增
|
|
|
- sendLedgerDraft(tradeSendReq);
|
|
|
- } else {
|
|
|
- //先删除
|
|
|
- removeDraft(id);
|
|
|
- //在新增
|
|
|
- sendLedgerDraft(tradeSendReq);
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 保存草稿
|
|
|
- *
|
|
|
- * @param tradeSendReq
|
|
|
- * @return
|
|
|
- */
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public String sendLedgerDraft(TradeSendReq tradeSendReq) {
|
|
|
+ private Long saveDraft(TradeSendReq tradeSendReq) {
|
|
|
KwpLedgerTrade kwpLedgerTrade = new KwpLedgerTrade();
|
|
|
kwpLedgerTrade.setId(Objects.isNull(tradeSendReq.getId()) ? new IdWorker(1).nextId() : tradeSendReq.getId());
|
|
|
kwpLedgerTrade.setEntId(0L);//todo
|
|
|
@@ -110,6 +78,7 @@ public class KwpLedgerTradeService extends AbsLedger {
|
|
|
kwpLedgerTrade.setActualPrice(new BigDecimal("0.0"));
|
|
|
kwpLedgerTrade.setAuditUser("");
|
|
|
kwpLedgerTrade.setAuditPhone("");
|
|
|
+ kwpLedgerTrade.setGenerateTime(tradeSendReq.getGenerateTime());
|
|
|
kwpLedgerTrade.setUrl("");
|
|
|
kwpLedgerTrade.setRemark("");
|
|
|
kwpLedgerTrade.setStatus(LedgerEnum.SAVE.getStatus());
|
|
|
@@ -151,9 +120,48 @@ public class KwpLedgerTradeService extends AbsLedger {
|
|
|
|
|
|
list.add(kwpLedgerTradeUnit);
|
|
|
tradeUnitService.saveList(list);
|
|
|
- /*保存操作记录*/
|
|
|
- tradeTrackService.saveTrack(kwpLedgerTrade.getId(), "", LedgerTrackEnum.SAVE);
|
|
|
- return null;
|
|
|
+ return kwpLedgerTrade.getId();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 保存对账单
|
|
|
+ *
|
|
|
+ * @param tradeSendReq
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public String sendLedger(TradeSendReq tradeSendReq) {
|
|
|
+ Long id = tradeSendReq.getId();
|
|
|
+ if (Objects.isNull(id)) {
|
|
|
+ //新增
|
|
|
+ tradeSendReq.setGenerateTime(LocalDateTime.now());
|
|
|
+ Long aLong = saveDraft(tradeSendReq);
|
|
|
+ tradeTrackService.saveTrack(aLong, "", LedgerTrackEnum.TO_LEDGER);
|
|
|
+ } else {
|
|
|
+ //先删除
|
|
|
+ removeDraft(id);
|
|
|
+ //在新增
|
|
|
+ tradeSendReq.setGenerateTime(LocalDateTime.now());
|
|
|
+ Long aLong = saveDraft(tradeSendReq);
|
|
|
+ tradeTrackService.saveTrack(aLong, "", LedgerTrackEnum.TO_LEDGER);
|
|
|
+
|
|
|
+ }
|
|
|
+ return "保存对账单成功";
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 保存草稿
|
|
|
+ *
|
|
|
+ * @param tradeSendReq
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public String sendLedgerDraft(TradeSendReq tradeSendReq) {
|
|
|
+ log.info("贸易对账单保存草稿:{}", JSONObject.toJSONString(tradeSendReq));
|
|
|
+ tradeSendReq.setGenerateTime(null);
|
|
|
+ Long aLong = saveDraft(tradeSendReq);
|
|
|
+ tradeTrackService.saveTrack(aLong, "", LedgerTrackEnum.SAVE);
|
|
|
+ return "草稿保存成功";
|
|
|
}
|
|
|
|
|
|
|