|
@@ -2,6 +2,7 @@ package com.bofeng.service;
|
|
|
|
|
|
import com.baomidou.mybatisplus.toolkit.IdWorker;
|
|
import com.baomidou.mybatisplus.toolkit.IdWorker;
|
|
import com.bofeng.dao.BuyMapper;
|
|
import com.bofeng.dao.BuyMapper;
|
|
|
|
+import com.bofeng.dao.JmTuangouDao;
|
|
import com.bofeng.entity.Buy;
|
|
import com.bofeng.entity.Buy;
|
|
import com.bofeng.entity.JmTuangou;
|
|
import com.bofeng.entity.JmTuangou;
|
|
import org.joda.time.DateTime;
|
|
import org.joda.time.DateTime;
|
|
@@ -10,6 +11,7 @@ import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Propagation;
|
|
import org.springframework.transaction.annotation.Propagation;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
+import java.util.ArrayList;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
|
|
|
@Service
|
|
@Service
|
|
@@ -19,6 +21,9 @@ public class BuyService {
|
|
@Autowired
|
|
@Autowired
|
|
private BuyMapper buyMapper;
|
|
private BuyMapper buyMapper;
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ private JmTuangouDao jmTuangouDao;
|
|
|
|
+
|
|
@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
|
|
@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
|
|
public int buyGroup(Buy buy) {
|
|
public int buyGroup(Buy buy) {
|
|
Buy buy1 = buyMapper.selectBuyOne(buy.getUserId(), buy.getJmId());
|
|
Buy buy1 = buyMapper.selectBuyOne(buy.getUserId(), buy.getJmId());
|
|
@@ -33,11 +38,15 @@ public class BuyService {
|
|
return buyMapper.insert(buy);
|
|
return buyMapper.insert(buy);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
|
|
public List<JmTuangou> group(Long userId) {
|
|
public List<JmTuangou> group(Long userId) {
|
|
|
|
+ updateStatus();
|
|
return buyMapper.group(userId);
|
|
return buyMapper.group(userId);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
|
|
public List<Buy> MyGroup(Long userId) {
|
|
public List<Buy> MyGroup(Long userId) {
|
|
|
|
+ updateStatus();
|
|
return buyMapper.MyGroup(userId);
|
|
return buyMapper.MyGroup(userId);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -67,4 +76,22 @@ public class BuyService {
|
|
public Buy status(Buy buy) {
|
|
public Buy status(Buy buy) {
|
|
return buyMapper.status(buy.getJmId());
|
|
return buyMapper.status(buy.getJmId());
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ //截止日期状态的更改
|
|
|
|
+ @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
|
|
|
|
+ public int updateStatus() {
|
|
|
|
+ List<JmTuangou> jmTuangous = jmTuangouDao.selectAll();
|
|
|
|
+ if (jmTuangous != null && jmTuangous.size() > 0) {
|
|
|
|
+ for (JmTuangou list : jmTuangous) {
|
|
|
|
+ if (list.getTgEndTime().getTime() >= new DateTime().getMillis()) {
|
|
|
|
+ JmTuangou jmTuangou = new JmTuangou();
|
|
|
|
+ jmTuangou.setJmId(list.getJmId());
|
|
|
|
+ jmTuangou.setTgStatus(2);//截止时间已到 发货
|
|
|
|
+ jmTuangouDao.updateStatusByJmId(list.getJmId(), 2L);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ return 1;
|
|
|
|
+ }
|
|
|
|
+
|
|
}
|
|
}
|