|
@@ -9,15 +9,16 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
+import org.springframework.context.annotation.Lazy;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
import shop.alien.entity.second.SecondTradeOperation;
|
|
import shop.alien.entity.second.SecondTradeOperation;
|
|
|
import shop.alien.entity.second.SecondTradeRecord;
|
|
import shop.alien.entity.second.SecondTradeRecord;
|
|
|
-import shop.alien.entity.second.vo.SecondGoodsVo;
|
|
|
|
|
import shop.alien.entity.second.vo.SecondTradeRecordVo;
|
|
import shop.alien.entity.second.vo.SecondTradeRecordVo;
|
|
|
-import shop.alien.mapper.second.SecondGoodsMapper;
|
|
|
|
|
import shop.alien.mapper.second.SecondTradeOperationMapper;
|
|
import shop.alien.mapper.second.SecondTradeOperationMapper;
|
|
|
import shop.alien.mapper.second.SecondTradeRecordMapper;
|
|
import shop.alien.mapper.second.SecondTradeRecordMapper;
|
|
|
import shop.alien.second.service.PlatformSecondTradeService;
|
|
import shop.alien.second.service.PlatformSecondTradeService;
|
|
|
|
|
+import shop.alien.second.service.SecondGoodsService;
|
|
|
|
|
|
|
|
import java.time.ZoneId;
|
|
import java.time.ZoneId;
|
|
|
import java.time.format.DateTimeFormatter;
|
|
import java.time.format.DateTimeFormatter;
|
|
@@ -29,12 +30,15 @@ import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
@Slf4j
|
|
@Slf4j
|
|
|
@Service
|
|
@Service
|
|
|
-@RequiredArgsConstructor
|
|
|
|
|
public class PlatformSecondTradeServiceImpl extends ServiceImpl<SecondTradeRecordMapper, SecondTradeRecord> implements PlatformSecondTradeService {
|
|
public class PlatformSecondTradeServiceImpl extends ServiceImpl<SecondTradeRecordMapper, SecondTradeRecord> implements PlatformSecondTradeService {
|
|
|
|
|
|
|
|
- private final SecondTradeRecordMapper secondTradeRecordMapper;
|
|
|
|
|
- private final SecondGoodsMapper secondGoodsMapper;
|
|
|
|
|
- private final SecondTradeOperationMapper secondTradeOperationMapper;
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private SecondTradeRecordMapper secondTradeRecordMapper;
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private SecondTradeOperationMapper secondTradeOperationMapper;
|
|
|
|
|
+ @Lazy
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private SecondGoodsService secondGoodsService;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public IPage<SecondTradeRecordVo> getTradeRecordPage(SecondTradeRecordVo vo) throws Exception {
|
|
public IPage<SecondTradeRecordVo> getTradeRecordPage(SecondTradeRecordVo vo) throws Exception {
|
|
@@ -56,12 +60,12 @@ public class PlatformSecondTradeServiceImpl extends ServiceImpl<SecondTradeRecor
|
|
|
@Override
|
|
@Override
|
|
|
public SecondTradeRecordVo getTradeRecordById(Integer id) throws Exception {
|
|
public SecondTradeRecordVo getTradeRecordById(Integer id) throws Exception {
|
|
|
try {
|
|
try {
|
|
|
|
|
+ // 交易信息
|
|
|
SecondTradeRecordVo vo = secondTradeRecordMapper.getTradeRecordById(id);
|
|
SecondTradeRecordVo vo = secondTradeRecordMapper.getTradeRecordById(id);
|
|
|
|
|
+ // 交易流程
|
|
|
vo.setOperationJsonList(getOperationJsonList(id));
|
|
vo.setOperationJsonList(getOperationJsonList(id));
|
|
|
-
|
|
|
|
|
- QueryWrapper<SecondGoodsVo> wrapper = new QueryWrapper<>();
|
|
|
|
|
- wrapper.eq("sg.id", vo.getGoodsId());
|
|
|
|
|
- vo.setGoodsInfo(secondGoodsMapper.getGoodsDetails(wrapper));
|
|
|
|
|
|
|
+ // 商品信息
|
|
|
|
|
+ vo.setGoodsInfo(secondGoodsService.dealSecondGoodsRecordInfo(vo.getGoodsRecordId()));
|
|
|
return vo;
|
|
return vo;
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
log.error("PlatformSecondTradeServiceImpl.getTradeRecordById(): Error Msg={}", e.getMessage());
|
|
log.error("PlatformSecondTradeServiceImpl.getTradeRecordById(): Error Msg={}", e.getMessage());
|
|
@@ -174,7 +178,7 @@ public class PlatformSecondTradeServiceImpl extends ServiceImpl<SecondTradeRecor
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// 签到后取消交易
|
|
// 签到后取消交易
|
|
|
- if (CollectionUtil.isEmpty(successFail) && 7 == operationList.get(operationList.size() - 1).getType()) {
|
|
|
|
|
|
|
+ if (CollectionUtil.isEmpty(successFail) && CollectionUtil.isNotEmpty(operationList) && 7 == operationList.get(operationList.size() - 1).getType()) {
|
|
|
JSONObject cancelJson = new JSONObject();
|
|
JSONObject cancelJson = new JSONObject();
|
|
|
cancelJson.put("flag", 1);
|
|
cancelJson.put("flag", 1);
|
|
|
cancelJson.put("message", "取消交易");
|
|
cancelJson.put("message", "取消交易");
|