MaterialExtendServiceImpl.java 28 KB

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