MaterialExtendServiceImpl.java 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608
  1. package com.jsh.erp.service.impl;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
  5. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.jsh.erp.constants.BusinessConstants;
  8. import com.jsh.erp.datasource.entities.*;
  9. import com.jsh.erp.datasource.mappers.MaterialCurrentStockMapper;
  10. import com.jsh.erp.datasource.mappers.MaterialExtendMapper;
  11. import com.jsh.erp.datasource.mappers.MaterialExtendMapperEx;
  12. import com.jsh.erp.datasource.vo.MaterialExtendVo4List;
  13. import com.jsh.erp.exception.JshException;
  14. import com.jsh.erp.service.*;
  15. import com.jsh.erp.utils.DateUtils;
  16. import com.jsh.erp.utils.RandomHelper;
  17. import com.jsh.erp.utils.StringUtil;
  18. import org.slf4j.Logger;
  19. import org.slf4j.LoggerFactory;
  20. import org.springframework.stereotype.Service;
  21. import org.springframework.transaction.annotation.Transactional;
  22. import org.springframework.web.context.request.RequestContextHolder;
  23. import org.springframework.web.context.request.ServletRequestAttributes;
  24. import javax.annotation.Resource;
  25. import javax.servlet.http.HttpServletRequest;
  26. import java.math.BigDecimal;
  27. import java.util.ArrayList;
  28. import java.util.Date;
  29. import java.util.List;
  30. @Service
  31. public class MaterialExtendServiceImpl extends ServiceImpl<MaterialExtendMapper, MaterialExtend> implements MaterialExtendService {
  32. private Logger logger = LoggerFactory.getLogger(MaterialExtendServiceImpl.class);
  33. @Resource
  34. private MaterialExtendMapper materialExtendMapper;
  35. @Resource
  36. private MaterialExtendMapperEx materialExtendMapperEx;
  37. @Resource
  38. private MaterialCurrentStockMapper materialCurrentStockMapper;
  39. @Resource
  40. private UserService userService;
  41. @Resource
  42. private RedisService redisService;
  43. @Resource
  44. private MaterialService materialService;
  45. @Resource
  46. private DepotItemService depotItemService;
  47. @Resource
  48. private InventoryLogService inventoryLogService;
  49. @Override
  50. public MaterialExtend getMaterialExtend(long id)throws Exception {
  51. MaterialExtend result=null;
  52. try{
  53. result=materialExtendMapper.selectByPrimaryKey(id);
  54. }catch(Exception e){
  55. JshException.readFail(logger, e);
  56. }
  57. return result;
  58. }
  59. /**
  60. * 根据产品id查询产品价格拓展信息
  61. * @param materialId 产品id
  62. */
  63. @Override
  64. public List<MaterialExtendVo4List> getDetailList(Long materialId) {
  65. List<MaterialExtendVo4List> list=null;
  66. try{
  67. list = materialExtendMapperEx.getDetailList(materialId);
  68. }catch(Exception e){
  69. JshException.readFail(logger, e);
  70. }
  71. return list;
  72. }
  73. @Override
  74. public List<MaterialExtend> getListByMIds(List<Long> idList) {
  75. List<MaterialExtend> meList = null;
  76. try{
  77. Long [] idArray= StringUtil.listToLongArray(idList);
  78. if(idArray!=null && idArray.length>0) {
  79. meList = materialExtendMapperEx.getListByMId(idArray);
  80. }
  81. }catch(Exception e){
  82. JshException.readFail(logger, e);
  83. }
  84. return meList;
  85. }
  86. /**
  87. * 保存产品拓展记录
  88. * @param obj
  89. * @param sortList
  90. * @param materialId
  91. * @param type
  92. * @return
  93. * @throws Exception
  94. */
  95. @Override
  96. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  97. public String saveDetials(JSONObject obj, String sortList, Long materialId, String type) throws Exception {
  98. HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
  99. //获取商品拓展行参数集合
  100. JSONArray meArr = obj.getJSONArray("meList");
  101. //添加商品拓展集合
  102. JSONArray insertedJson = new JSONArray();
  103. //修改商品拓展集合
  104. JSONArray updatedJson = new JSONArray();
  105. //移除商品集合
  106. JSONArray deletedJson = obj.getJSONArray("meDeleteIdList");
  107. JSONArray sortJson = JSONArray.parseArray(sortList);
  108. //添加/修改行数据处理
  109. if (null != meArr) {
  110. if("insert".equals(type)){
  111. for (int i = 0; i < meArr.size(); i++) {
  112. JSONObject tempJson = meArr.getJSONObject(i);
  113. insertedJson.add(tempJson);
  114. }
  115. } else if("update".equals(type)){
  116. for (int i = 0; i < meArr.size(); i++) {
  117. JSONObject tempJson = meArr.getJSONObject(i);
  118. String tempId = tempJson.getString("id");
  119. if(tempId.length()>19){
  120. //id长度大于19,属于新增数据
  121. insertedJson.add(tempJson);
  122. } else {
  123. updatedJson.add(tempJson);
  124. }
  125. }
  126. }
  127. }
  128. //删除行数据处理
  129. if (null != deletedJson && deletedJson.size()>0) {
  130. StringBuffer bf=new StringBuffer();
  131. for (int i = 0; i < deletedJson.size(); i++) {
  132. bf.append(deletedJson.getString(i));
  133. if(i<(deletedJson.size()-1)){
  134. bf.append(",");
  135. }
  136. }
  137. //删除拓展行
  138. this.batchDeleteMaterialExtendByIds(bf.toString(), request);
  139. }
  140. //添加产品拓展行
  141. if (null != insertedJson) {
  142. for (int i = 0; i < insertedJson.size(); i++) {
  143. //商品拓展
  144. MaterialExtend materialExtend = new MaterialExtend();
  145. JSONObject tempInsertedJson = JSONObject.parseObject(insertedJson.getString(i));
  146. //设置商品id
  147. materialExtend.setMaterialId(materialId);
  148. //设置商品单位
  149. if (StringUtils.isNotEmpty(tempInsertedJson.getString("commodityUnit"))) {
  150. materialExtend.setCommodityUnit(tempInsertedJson.getString("commodityUnit"));
  151. }
  152. //设置商品属性
  153. if (tempInsertedJson.get("sku")!=null) {
  154. materialExtend.setSku(tempInsertedJson.getString("sku"));
  155. }
  156. //设置采购价格
  157. if (StringUtils.isNotEmpty(tempInsertedJson.getString("purchaseDecimal"))) {
  158. materialExtend.setPurchaseDecimal(tempInsertedJson.getBigDecimal("purchaseDecimal"));
  159. }
  160. //设置零售价格
  161. if (StringUtils.isNotEmpty(tempInsertedJson.getString("commodityDecimal"))) {
  162. materialExtend.setCommodityDecimal(tempInsertedJson.getBigDecimal("commodityDecimal"));
  163. }
  164. //设置销售价格
  165. if (StringUtils.isNotEmpty(tempInsertedJson.getString("wholesaleDecimal"))) {
  166. materialExtend.setWholesaleDecimal(tempInsertedJson.getBigDecimal("wholesaleDecimal"));
  167. }
  168. //设置最低售价
  169. if (StringUtils.isNotEmpty(tempInsertedJson.getString("lowDecimal"))) {
  170. materialExtend.setLowDecimal(tempInsertedJson.getBigDecimal("lowDecimal"));
  171. }
  172. //设置生产日期
  173. if (StringUtils.isNotEmpty(tempInsertedJson.getString("productionDate"))) {
  174. materialExtend.setProductionDate(tempInsertedJson.getDate("productionDate"));
  175. }
  176. //设置保质期天数
  177. if (StringUtils.isNotEmpty(tempInsertedJson.getString("expiryNum"))) {
  178. materialExtend.setExpiryNum(tempInsertedJson.getInteger("expiryNum"));
  179. }
  180. //设置供应商id
  181. if (StringUtils.isNotEmpty(tempInsertedJson.getString("supplierId"))) {
  182. materialExtend.setSupplierId(tempInsertedJson.getLong("supplierId"));
  183. }
  184. //设置商品条码
  185. if (StringUtils.isNotEmpty(tempInsertedJson.getString("barCode"))) {
  186. materialExtend.setBarCode(tempInsertedJson.getString("barCode"));
  187. }
  188. //设置批次号
  189. String batchNumber = DateUtils.dateTimeNow("yyyyMMdd") + RandomHelper.getRandomStr(6);
  190. materialExtend.setBatchNumber(batchNumber);
  191. //设置库存
  192. if (StringUtils.isNotEmpty(tempInsertedJson.getString("inventory"))) {
  193. materialExtend.setInventory(tempInsertedJson.getBigDecimal("inventory"));
  194. }
  195. //设置仓库id
  196. if (StringUtils.isNotEmpty(tempInsertedJson.getString("depotId"))) {
  197. materialExtend.setDepotId(tempInsertedJson.getLong("depotId"));
  198. }
  199. //设置仓位货架
  200. if (StringUtils.isNotEmpty(tempInsertedJson.getString("position"))) {
  201. materialExtend.setPosition(tempInsertedJson.getString("position"));
  202. }
  203. //添加数据
  204. this.insertMaterialExtend(materialExtend);
  205. }
  206. }
  207. //修改拓展行
  208. if (null != updatedJson) {
  209. for (int i = 0; i < updatedJson.size(); i++) {
  210. JSONObject tempUpdatedJson = JSONObject.parseObject(updatedJson.getString(i));
  211. MaterialExtend materialExtend = new MaterialExtend();
  212. //设置id
  213. materialExtend.setId(tempUpdatedJson.getLong("id"));
  214. materialExtend.setBarCode(tempUpdatedJson.getString("barCode"));
  215. //Json里的数据赋值到对象
  216. this.setMaterialExtend(tempUpdatedJson,materialExtend);
  217. //修改商品拓展
  218. this.updateMaterialExtend(materialExtend);
  219. //如果金额为空,此处单独置空
  220. materialExtendMapperEx.specialUpdatePrice(materialExtend);
  221. }
  222. }
  223. //处理条码的排序,基本单位排第一个
  224. if (null != sortJson && sortJson.size()>0) {
  225. //此处为更新的逻辑
  226. for (int i = 0; i < sortJson.size(); i++) {
  227. JSONObject tempSortJson = JSONObject.parseObject(sortJson.getString(i));
  228. MaterialExtend materialExtend = new MaterialExtend();
  229. if(StringUtil.isExist(tempSortJson.get("id"))) {
  230. materialExtend.setId(tempSortJson.getLong("id"));
  231. }
  232. if(StringUtil.isExist(tempSortJson.get("defaultFlag"))) {
  233. materialExtend.setDefaultFlag(tempSortJson.getString("defaultFlag"));
  234. }
  235. this.updateMaterialExtend(materialExtend);
  236. }
  237. } else {
  238. //新增的时候将第一条记录设置为默认基本单位
  239. MaterialExtendExample example = new MaterialExtendExample();
  240. example.createCriteria().andMaterialIdEqualTo(materialId).andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  241. List<MaterialExtend> meList = materialExtendMapper.selectByExample(example);
  242. if(meList!=null) {
  243. for(int i=0; i<meList.size(); i++) {
  244. MaterialExtend materialExtend = new MaterialExtend();
  245. materialExtend.setId(meList.get(i).getId());
  246. if(i==0) {
  247. materialExtend.setDefaultFlag("1"); //默认
  248. } else {
  249. materialExtend.setDefaultFlag("0"); //非默认
  250. }
  251. this.updateMaterialExtend(materialExtend);
  252. }
  253. }
  254. }
  255. return null;
  256. }
  257. /**
  258. * 添加商品拓展
  259. * @param materialExtend 商品拓展
  260. */
  261. @Override
  262. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  263. public int insertMaterialExtend(MaterialExtend materialExtend)throws Exception {
  264. User user = userService.getCurrentUser();
  265. materialExtend.setDeleteFlag(BusinessConstants.DELETE_FLAG_EXISTS);
  266. materialExtend.setCreateTime(new Date());
  267. materialExtend.setUpdateTime(new Date().getTime());
  268. materialExtend.setCreateSerial(user.getLoginName());
  269. materialExtend.setUpdateSerial(user.getLoginName());
  270. materialExtend.setTenantId(user.getId());
  271. int result = 0;
  272. try{
  273. result= materialExtendMapper.insertSelective(materialExtend);
  274. //更新当前库存
  275. depotItemService.updateCurrentStockFun(materialExtend.getMaterialId(), materialExtend.getDepotId());
  276. }catch(Exception e){
  277. JshException.writeFail(logger, e);
  278. }
  279. //修改当前库存
  280. if (materialExtend.getDepotId() != null && materialExtend.getInventory() != null){
  281. insertCurrentStockByMaterialAndDepot(materialExtend.getDepotId(),materialExtend.getMaterialId(),materialExtend.getInventory(),"add");
  282. }
  283. return result;
  284. }
  285. /**
  286. * 修改商品拓展
  287. * @param materialExtend 商品拓展
  288. */
  289. @Override
  290. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  291. public int updateMaterialExtend(MaterialExtend materialExtend) throws Exception{
  292. User user = userService.getCurrentUser();
  293. materialExtend.setUpdateTime(System.currentTimeMillis());
  294. materialExtend.setUpdateSerial(user.getLoginName());
  295. int res =0;
  296. try{
  297. //修改库存
  298. updateInventory("商品修改",null,materialExtend);
  299. res= materialExtendMapper.updateByPrimaryKeySelective(materialExtend);
  300. }catch(Exception e){
  301. JshException.writeFail(logger, e);
  302. }
  303. return res;
  304. }
  305. @Override
  306. public int checkIsBarCodeExist(Long id, String barCode)throws Exception {
  307. MaterialExtendExample example = new MaterialExtendExample();
  308. MaterialExtendExample.Criteria criteria = example.createCriteria();
  309. criteria.andBarCodeEqualTo(barCode);
  310. if (id > 0) {
  311. criteria.andIdNotEqualTo(id).andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  312. } else {
  313. criteria.andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  314. }
  315. List<MaterialExtend> list =null;
  316. try{
  317. list = materialExtendMapper.selectByExample(example);
  318. }catch(Exception e){
  319. JshException.readFail(logger, e);
  320. }
  321. return list==null?0:list.size();
  322. }
  323. @Override
  324. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  325. public int deleteMaterialExtend(Long id, HttpServletRequest request)throws Exception {
  326. int result =0;
  327. MaterialExtend materialExtend = new MaterialExtend();
  328. materialExtend.setId(id);
  329. materialExtend.setDeleteFlag(BusinessConstants.DELETE_FLAG_DELETED);
  330. Long userId = Long.parseLong(redisService.getObjectFromSessionByKey(request,"userId").toString());
  331. User user = userService.getUser(userId);
  332. materialExtend.setUpdateTime(new Date().getTime());
  333. materialExtend.setUpdateSerial(user.getLoginName());
  334. try{
  335. result= materialExtendMapper.updateByPrimaryKeySelective(materialExtend);
  336. }catch(Exception e){
  337. JshException.writeFail(logger, e);
  338. }
  339. return result;
  340. }
  341. /**
  342. * 删除商品拓展行
  343. * @param ids 拓展行id集合
  344. */
  345. @Override
  346. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  347. public int batchDeleteMaterialExtendByIds(String ids, HttpServletRequest request) throws Exception{
  348. String [] idArray=ids.split(",");
  349. int result = 0;
  350. try{
  351. result = materialExtendMapperEx.batchDeleteMaterialExtendByIds(idArray);
  352. }catch(Exception e){
  353. JshException.writeFail(logger, e);
  354. }
  355. return result;
  356. }
  357. @Override
  358. public int insertMaterialExtend(JSONObject obj, HttpServletRequest request) throws Exception{
  359. MaterialExtend materialExtend = JSONObject.parseObject(obj.toJSONString(), MaterialExtend.class);
  360. int result=0;
  361. try{
  362. result = materialExtendMapper.insertSelective(materialExtend);
  363. }catch(Exception e){
  364. JshException.writeFail(logger, e);
  365. }
  366. return result;
  367. }
  368. @Override
  369. public int updateMaterialExtend(JSONObject obj, HttpServletRequest request)throws Exception {
  370. MaterialExtend materialExtend = JSONObject.parseObject(obj.toJSONString(), MaterialExtend.class);
  371. int result=0;
  372. try{
  373. result = materialExtendMapper.updateByPrimaryKeySelective(materialExtend);
  374. }catch(Exception e){
  375. JshException.writeFail(logger, e);
  376. }
  377. return result;
  378. }
  379. @Override
  380. public List<MaterialExtend> getMaterialExtendByTenantAndTime(Long tenantId, Long lastTime, Long syncNum)throws Exception {
  381. List<MaterialExtend> list=new ArrayList<MaterialExtend>();
  382. try{
  383. //先获取最大的时间戳,再查两个时间戳之间的数据,这样同步能够防止丢失数据(应为时间戳有重复)
  384. Long maxTime = materialExtendMapperEx.getMaxTimeByTenantAndTime(tenantId, lastTime, syncNum);
  385. if(tenantId!=null && lastTime!=null && maxTime!=null) {
  386. MaterialExtendExample example = new MaterialExtendExample();
  387. example.createCriteria().andTenantIdEqualTo(tenantId)
  388. .andUpdateTimeGreaterThan(lastTime)
  389. .andUpdateTimeLessThanOrEqualTo(maxTime);
  390. list=materialExtendMapper.selectByExample(example);
  391. }
  392. }catch(Exception e){
  393. JshException.readFail(logger, e);
  394. }
  395. return list;
  396. }
  397. @Override
  398. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  399. public Long selectIdByMaterialIdAndDefaultFlag(Long materialId, String defaultFlag) {
  400. Long id = 0L;
  401. MaterialExtendExample example = new MaterialExtendExample();
  402. example.createCriteria().andMaterialIdEqualTo(materialId).andDefaultFlagEqualTo(defaultFlag)
  403. .andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  404. List<MaterialExtend> list = materialExtendMapper.selectByExample(example);
  405. if(list!=null && list.size()>0) {
  406. id = list.get(0).getId();
  407. }
  408. return id;
  409. }
  410. @Override
  411. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  412. public Long selectIdByMaterialIdAndBarCode(Long materialId, String barCode) {
  413. Long id = 0L;
  414. MaterialExtendExample example = new MaterialExtendExample();
  415. example.createCriteria().andMaterialIdEqualTo(materialId).andBarCodeEqualTo(barCode)
  416. .andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  417. List<MaterialExtend> list = materialExtendMapper.selectByExample(example);
  418. if(list!=null && list.size()>0) {
  419. id = list.get(0).getId();
  420. }
  421. return id;
  422. }
  423. @Override
  424. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  425. public List<MaterialExtend> getListByMaterialIdAndDefaultFlagAndBarCode(Long materialId, String defaultFlag, String barCode) {
  426. MaterialExtendExample example = new MaterialExtendExample();
  427. example.createCriteria().andMaterialIdEqualTo(materialId).andDefaultFlagEqualTo(defaultFlag).andBarCodeNotEqualTo(barCode)
  428. .andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  429. return materialExtendMapper.selectByExample(example);
  430. }
  431. @Override
  432. public MaterialExtend getInfoByBarCode(String barCode)throws Exception {
  433. MaterialExtendExample example = new MaterialExtendExample();
  434. example.createCriteria().andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  435. List<MaterialExtend> list = materialExtendMapper.selectByExample(example);
  436. if(list!=null && list.size()>0) {
  437. return list.get(0);
  438. } else {
  439. return null;
  440. }
  441. }
  442. /**
  443. * 商品的副条码和数据库里面的商品条码存在重复(除自身商品之外)
  444. * @param manyBarCode
  445. * @param barCode
  446. * @return
  447. */
  448. @Override
  449. public int getCountByManyBarCodeWithoutUs(String manyBarCode, String barCode) {
  450. MaterialExtendExample example = new MaterialExtendExample();
  451. example.createCriteria().andBarCodeEqualTo(manyBarCode).andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
  452. List<MaterialExtend> list = materialExtendMapper.selectByExample(example);
  453. if(list!=null && list.size()>0) {
  454. for(MaterialExtend me: list) {
  455. List<MaterialExtend> basicMeList = materialExtendMapperEx.getBasicInfoByMid(me.getMaterialId());
  456. for(MaterialExtend basicMe: basicMeList) {
  457. if(basicMe!=null && !barCode.equals(basicMe.getBarCode())) {
  458. return 1;
  459. }
  460. }
  461. }
  462. }
  463. return 0;
  464. }
  465. @Override
  466. public MaterialExtend getInfoByBatchNumber(String batchNumber)throws Exception {
  467. MaterialExtend example = materialExtendMapper.selectByBatchNumber(batchNumber);
  468. return example;
  469. }
  470. /**
  471. * 修改子商品库存
  472. */
  473. @Override
  474. public synchronized void updateInventory(String type, Long id, MaterialExtend materialExtend) throws Exception {
  475. if (materialExtend.getInventory() != null){
  476. User user = userService.getCurrentUser();
  477. InventoryLog log = new InventoryLog();
  478. log.setUpdateUser(user.getId());
  479. log.setUpdateTime(new Date());
  480. log.setMaterialId(materialExtend.getMaterialId());
  481. log.setMaterialExtendId(materialExtend.getId());
  482. log.setOriginalStock(materialExtendMapper.selectByPrimaryKey(materialExtend.getId()).getInventory().intValue());
  483. Integer i = materialExtend.getInventory().intValue();
  484. log.setCurrentStock(i);
  485. log.setItemId(id);
  486. log.setType(type);
  487. inventoryLogService.save(log);
  488. update(new UpdateWrapper<MaterialExtend>().set("inventory",materialExtend.getInventory()).set("position",materialExtend.getPosition()).eq("id",materialExtend.getId()));;
  489. }
  490. }
  491. /**
  492. * 设置当前库存
  493. * @param depotId 仓库id
  494. * @param mId 商品id
  495. * @param stock 库存数量
  496. * @param type 加减操作 add|subtract
  497. */
  498. @Transactional(value = "transactionManager", rollbackFor = Exception.class)
  499. public void insertCurrentStockByMaterialAndDepot(Long depotId, Long mId, BigDecimal stock,String type){
  500. //查询当前商品当前库存
  501. BigDecimal currentNumber = materialService.getCurrentStockByMaterialIdAndDepotId(mId,depotId);
  502. MaterialCurrentStock materialCurrentStock = new MaterialCurrentStock();
  503. materialCurrentStock.setDepotId(depotId);
  504. materialCurrentStock.setMaterialId(mId);
  505. materialCurrentStock.setCurrentNumber(stock);
  506. if (currentNumber == null || currentNumber.compareTo(BigDecimal.ZERO) == 0){
  507. materialCurrentStockMapper.insertSelective(materialCurrentStock); //存入当前库存
  508. }else {
  509. BigDecimal sumNumber = new BigDecimal("0");
  510. if ("add".equals(type)){
  511. sumNumber = currentNumber.add(materialCurrentStock.getCurrentNumber());
  512. }else if ("subtract".equals(type)){
  513. sumNumber = currentNumber.subtract(materialCurrentStock.getCurrentNumber());
  514. }
  515. materialCurrentStock.setCurrentNumber(sumNumber);
  516. materialCurrentStockMapper.updateByPrimaryKeySelective(materialCurrentStock);
  517. }
  518. }
  519. /**
  520. * 将Json对象的数据赋值到商品拓展对象中
  521. * @param tempJson
  522. * @param materialExtend
  523. */
  524. private void setMaterialExtend(JSONObject tempJson, MaterialExtend materialExtend){
  525. //设置商品单位
  526. if (StringUtils.isNotEmpty(tempJson.getString("commodityUnit"))) {
  527. materialExtend.setCommodityUnit(tempJson.getString("commodityUnit"));
  528. }
  529. //设置商品属性
  530. if (tempJson.get("sku")!=null) {
  531. materialExtend.setSku(tempJson.getString("sku"));
  532. }
  533. //设置采购价格
  534. if (StringUtils.isNotEmpty(tempJson.getString("purchaseDecimal"))) {
  535. materialExtend.setPurchaseDecimal(tempJson.getBigDecimal("purchaseDecimal"));
  536. }
  537. //设置零售价格
  538. if (StringUtils.isNotEmpty(tempJson.getString("commodityDecimal"))) {
  539. materialExtend.setCommodityDecimal(tempJson.getBigDecimal("commodityDecimal"));
  540. }
  541. //设置销售价格
  542. if (StringUtils.isNotEmpty(tempJson.getString("wholesaleDecimal"))) {
  543. materialExtend.setWholesaleDecimal(tempJson.getBigDecimal("wholesaleDecimal"));
  544. }
  545. //设置最低售价
  546. if (StringUtils.isNotEmpty(tempJson.getString("lowDecimal"))) {
  547. materialExtend.setLowDecimal(tempJson.getBigDecimal("lowDecimal"));
  548. }
  549. //设置生产日期
  550. if (StringUtils.isNotEmpty(tempJson.getString("productionDate"))) {
  551. materialExtend.setProductionDate(tempJson.getDate("productionDate"));
  552. }
  553. //设置保质期天数
  554. if (StringUtils.isNotEmpty(tempJson.getString("expiryNum"))) {
  555. materialExtend.setExpiryNum(tempJson.getInteger("expiryNum"));
  556. }
  557. //设置供应商id
  558. if (StringUtils.isNotEmpty(tempJson.getString("supplierId"))) {
  559. materialExtend.setSupplierId(tempJson.getLong("supplierId"));
  560. }
  561. //设置商品条码
  562. if (StringUtils.isNotEmpty(tempJson.getString("barCode"))) {
  563. materialExtend.setBarCode(tempJson.getString("barCode"));
  564. }
  565. //设置批次号
  566. String batchNumber = DateUtils.dateTimeNow("yyyyMMdd") + RandomHelper.getRandomStr(6);
  567. materialExtend.setBatchNumber(batchNumber);
  568. //设置库存
  569. if (StringUtils.isNotEmpty(tempJson.getString("inventory"))) {
  570. materialExtend.setInventory(tempJson.getBigDecimal("inventory"));
  571. }
  572. //设置仓库id
  573. if (StringUtils.isNotEmpty(tempJson.getString("depotId"))) {
  574. materialExtend.setDepotId(tempJson.getLong("depotId"));
  575. }
  576. //设置仓位货架
  577. if (StringUtils.isNotEmpty(tempJson.getString("position"))) {
  578. materialExtend.setPosition(tempJson.getString("position"));
  579. }
  580. }
  581. }