|
@@ -17,18 +17,12 @@ import com.fjhx.params.stock.StockVo;
|
|
|
import com.fjhx.service.stock.StockService;
|
|
|
import com.fjhx.utils.WrapperUtil;
|
|
|
import org.springblade.core.log.exception.ServiceException;
|
|
|
-import org.springblade.core.redis.lock.RedisLockClient;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
-import javax.annotation.Resource;
|
|
|
import java.math.BigDecimal;
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.HashMap;
|
|
|
-import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
-import java.util.Set;
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
|
* <p>
|
|
@@ -41,9 +35,6 @@ import java.util.Set;
|
|
|
@Service
|
|
|
public class StockServiceImpl extends ServiceImpl<StockMapper, Stock> implements StockService {
|
|
|
|
|
|
- @Resource
|
|
|
- private RedisLockClient redisLockClient;
|
|
|
-
|
|
|
@Autowired
|
|
|
private StockJournalServiceImpl stockJournalService;
|
|
|
|
|
@@ -55,8 +46,7 @@ public class StockServiceImpl extends ServiceImpl<StockMapper, Stock> implements
|
|
|
WrapperUtil.init(condition, wrapper)
|
|
|
.createTimeDesc();
|
|
|
|
|
|
- Page<Stock> page = page(condition, wrapper);
|
|
|
- return page;
|
|
|
+ return page(condition, wrapper);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -107,22 +97,24 @@ public class StockServiceImpl extends ServiceImpl<StockMapper, Stock> implements
|
|
|
stock.setFrozenQuantity(changeQuantity);
|
|
|
map.put(key, stock);
|
|
|
} else {
|
|
|
-// stock.setQuantity(stock.getQuantity().add(changeQuantity));
|
|
|
stock.setFrozenQuantity(stock.getFrozenQuantity().add(changeQuantity));
|
|
|
}
|
|
|
}
|
|
|
Set<String> keySet = map.keySet();
|
|
|
- if (keySet.size() == 0) return;
|
|
|
+ if (keySet.size() == 0) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
|
|
|
synchronized (this) {
|
|
|
List<Stock> list = list(Wrappers.<Stock>query().in("CONCAT(goods_id, warehouse_id)", keySet));
|
|
|
- if (list.size() == 0) return;
|
|
|
+ if (list.size() == 0) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
for (Stock stock : list) {
|
|
|
String key = stock.getGoodsId() + "" + stock.getWarehouseId();
|
|
|
Stock itemStock = map.get(key);
|
|
|
itemStock.setId(stock.getId());
|
|
|
if (stockChangeVo.getTypeEnum() instanceof InTypeEnum) {
|
|
|
-// itemStock.setQuantity(itemStock.getQuantity().add(stock.getQuantity()));
|
|
|
itemStock.setFrozenQuantity(itemStock.getFrozenQuantity().add(stock.getFrozenQuantity()));
|
|
|
} else {
|
|
|
BigDecimal quantity = itemStock.getQuantity().subtract(stock.getQuantity());
|