InboundOtherService.java 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810
  1. package com.dk.mdm.service.ivt.inbound;
  2. import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
  3. import com.dk.common.exception.BaseBusinessException;
  4. import com.dk.common.infrastructure.annotaiton.Pagination;
  5. import com.dk.common.infrastructure.constant.Constant;
  6. import com.dk.common.infrastructure.enums.ErrorCodeEnum;
  7. import com.dk.common.mapper.BaseMapper;
  8. import com.dk.common.model.pojo.PageList;
  9. import com.dk.common.response.ResponseCodeEnum;
  10. import com.dk.common.response.ResponseResultUtil;
  11. import com.dk.common.response.ResponseResultVO;
  12. import com.dk.common.service.BaseService;
  13. import com.dk.mdm.infrastructure.convert.ivt.InboundConvert;
  14. import com.dk.mdm.infrastructure.convert.ivt.InboundItemConvert;
  15. import com.dk.mdm.mapper.common.CommonMapper;
  16. import com.dk.mdm.mapper.ivt.InboundItemMapper;
  17. import com.dk.mdm.mapper.ivt.InboundMapper;
  18. import com.dk.mdm.model.pojo.ivt.Inbound;
  19. import com.dk.mdm.model.pojo.ivt.InboundItem;
  20. import com.dk.mdm.model.pojo.ivt.Outbound;
  21. import com.dk.mdm.model.pojo.ivt.OutboundItem;
  22. import com.dk.mdm.model.pojo.pur.Purchase;
  23. import com.dk.mdm.model.pojo.pur.PurchaseItem;
  24. import com.dk.mdm.model.query.ivt.InboundItemQuery;
  25. import com.dk.mdm.model.query.ivt.InboundQuery;
  26. import com.dk.mdm.model.response.ivt.InboundItemResponse;
  27. import com.dk.mdm.model.response.ivt.InboundResponse;
  28. import com.dk.mdm.model.vo.ivt.InboundItemVO;
  29. import com.dk.mdm.model.vo.ivt.InboundVO;
  30. import com.dk.mdm.model.vo.ivt.OutboundItemVO;
  31. import com.dk.mdm.service.common.CommonService;
  32. import com.dk.mdm.service.ivt.inventory.InventoryService;
  33. import io.swagger.annotations.ApiOperation;
  34. import org.springframework.beans.factory.annotation.Autowired;
  35. import org.springframework.stereotype.Service;
  36. import org.springframework.transaction.annotation.Transactional;
  37. import org.springframework.web.bind.annotation.PostMapping;
  38. import org.springframework.web.bind.annotation.RequestBody;
  39. import javax.validation.Valid;
  40. import java.math.BigDecimal;
  41. import java.util.HashMap;
  42. import java.util.List;
  43. import java.util.Map;
  44. import java.util.UUID;
  45. /**
  46. * @author : 寇珊珊
  47. * @desc : 其他入库业务层
  48. * @date : 2024/3/7 14:11
  49. */
  50. @Service
  51. public class InboundOtherService extends BaseService<Inbound> {
  52. @Override
  53. public BaseMapper<Inbound> getRepository() {
  54. return inboundMapper;
  55. }
  56. @Autowired
  57. private InboundMapper inboundMapper;
  58. @Autowired
  59. private InboundConvert inboundConvert;
  60. @Autowired
  61. private InboundItemMapper inboundItemMapper;
  62. @Autowired
  63. private InboundItemConvert inboundItemConvert;
  64. @Autowired
  65. private CommonService commonService;
  66. @Autowired
  67. private CommonMapper commonMapper;
  68. @Autowired
  69. private InventoryService inventoryService;
  70. /**
  71. * @desc : 条件查询
  72. * @date : 2024/3/7 14:12
  73. * @author : 寇珊珊
  74. */
  75. @Pagination
  76. public ResponseResultVO<PageList<InboundResponse>> selectByCond(InboundQuery inboundQuery) {
  77. return super.mergeListWithCount(inboundQuery, inboundMapper.selectByCond(inboundQuery),
  78. inboundMapper.countByCond(inboundQuery));
  79. }
  80. /**
  81. * @desc : 查询明细
  82. * @date : 2024/3/9 15:43
  83. * @author : 寇珊珊
  84. */
  85. @Pagination
  86. public ResponseResultVO<Map<String, Object>> selectOtherInboundItemInfoById(String id) {
  87. Map<String, Object> result = new HashMap<>();
  88. // 商品明细
  89. List<InboundItemResponse> inboundItemResponses = inboundItemMapper.selectByCond(new InboundItemQuery().setIntoId(id));
  90. result.put("itemList", inboundItemResponses);
  91. // 收款
  92. // 附件
  93. return ResponseResultUtil.success(result);
  94. }
  95. /**
  96. * @desc : 其他入库新建
  97. * @date : 2024/3/7 14:13
  98. * @author : 寇珊珊
  99. */
  100. @Transactional(rollbackFor = {Exception.class})
  101. public ResponseResultVO<?> otherInboundInsert(InboundVO inboundVO) {
  102. //region 查询当前公司的系统参数 自动办理信息 并赋值
  103. Map<String, Object> map = new HashMap<>();
  104. map.put("cpId", inboundVO.getCpId());
  105. map.put("code", Constant.SystemConstant.IVT_001.getValue());
  106. //自动办理标识
  107. String flgHandleSetting = commonMapper.getSettingValue(map);
  108. //自动办理标识为1 自动办理入库
  109. if (Constant.FlgAutoHandleStringType.ONE.getValue().equals(flgHandleSetting)) {
  110. inboundVO.setFlgHandleSetting(Constant.FlgHandleSetting.TRUE.getValue());
  111. inboundVO.setFlgAutoHandle(Constant.FlgAutoHandle.TRUE.getValue());
  112. }
  113. //endregion
  114. //region 总单
  115. //获取 id/单号
  116. Map<String, Object> codeMap = commonService.getUniqueNoteCode(Constant.docNameConstant.OTHERINBOUND.getName(), false);
  117. inboundVO.setIntoId(codeMap.get("outId").toString()).
  118. setIntoNo(codeMap.get("outNote").toString());
  119. //入库类型
  120. inboundVO.setIntoType(Constant.IntoType.OTHER.getName());
  121. //自动入库标识
  122. if (inboundVO.getFlgAutoHandle()) {
  123. //已入库
  124. inboundVO.setIntoStatus(Constant.IntoStatus.YIRUKU.getName());
  125. } else {
  126. //入库中
  127. inboundVO.setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName());
  128. }
  129. //入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额
  130. if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) {
  131. inboundVO.setIntoQty(inboundVO.getIntoingQty())
  132. .setIntoAmt(inboundVO.getIntoingAmt())
  133. .setIntoingQty(BigDecimal.ZERO)
  134. .setIntoingAmt(BigDecimal.ZERO)
  135. ;
  136. } else {
  137. inboundVO.setIntoQty(BigDecimal.ZERO)
  138. .setIntoAmt(BigDecimal.ZERO)
  139. ;
  140. }
  141. //实体转换
  142. Inbound inbound = inboundConvert.convertToPo(inboundVO);
  143. inboundMapper.insert(inbound);
  144. //endregion
  145. //region 明细
  146. //校验明细
  147. if (inboundVO.getItemList().size() == 0) {
  148. throw new BaseBusinessException(ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getCode(),
  149. ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getMessage());
  150. }
  151. for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
  152. //region 将库存需要的参数赋值
  153. inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
  154. inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  155. inboundItemVO.setAddOrEditFlag(true);
  156. //endregion
  157. //总单id
  158. inboundItemVO.setIntoId(inboundVO.getIntoId());
  159. //入库类型
  160. inboundItemVO.setIntoType(inboundVO.getIntoType());
  161. //出库数量
  162. inboundItemVO.setOutQty(BigDecimal.ZERO);
  163. //入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额
  164. if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) {
  165. inboundItemVO
  166. .setIntoQty(inboundItemVO.getIntoingQty())
  167. .setIntoAmt(inboundItemVO.getIntoingAmt())
  168. .setIntoingQty(BigDecimal.ZERO)
  169. .setIntoingAmt(BigDecimal.ZERO)
  170. .setCostPrice(inboundItemVO.getPriceInto())
  171. .setCostAmt(inboundItemVO.getOutQty().multiply(inboundItemVO.getPriceInto()).setScale(2, BigDecimal.ROUND_HALF_UP))
  172. ;
  173. } else {
  174. inboundItemVO
  175. .setIntoQty(BigDecimal.ZERO)
  176. .setIntoAmt(BigDecimal.ZERO);
  177. }
  178. //入库状态
  179. inboundItemVO.setIntoStatus(inboundVO.getIntoStatus());
  180. //实体转换
  181. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  182. inboundItemMapper.insert(inboundItem);
  183. inboundItemVO.setItemId(inboundItem.getItemId());
  184. }
  185. //endregion
  186. //region 库存
  187. if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) {
  188. Map<String, Object> invMap = new HashMap<>();
  189. invMap.put("intoDetail", inboundVO.getItemList());
  190. inventoryService.operatingInventoryInformation(invMap);
  191. }
  192. //endregion
  193. return ResponseResultUtil.success(inboundVO);
  194. }
  195. /**
  196. * @desc : 其他入库编辑
  197. * @date : 2024/3/25 16:25
  198. * @author : 寇珊珊
  199. */
  200. @Transactional(rollbackFor = {Exception.class})
  201. public ResponseResultVO<?> otherInboundUpdate(InboundVO inboundVO) {
  202. //region 小编辑
  203. if (!inboundVO.getLimitEdit()) {
  204. Inbound inbound = new Inbound();
  205. inbound.setIntoId(inboundVO.getIntoId());
  206. inbound.setRemarks(inboundVO.getRemarks());
  207. inbound.setAnnexPaths(inboundVO.getAnnexPaths());
  208. inboundMapper.update(inbound,
  209. new UpdateWrapper<Inbound>().lambda()
  210. .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
  211. );
  212. for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
  213. InboundItem inboundItem = new InboundItem();
  214. inboundItem.setItemId(inboundItemVO.getItemId());
  215. inboundItem.setRemarks(inboundItemVO.getRemarks());
  216. inboundItemMapper.update(inboundItem,
  217. new UpdateWrapper<InboundItem>().lambda()
  218. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  219. );
  220. }
  221. }
  222. //endregion
  223. //region 大编辑
  224. else {
  225. //region 明细数量金额 求和
  226. BigDecimal sumQty = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP);
  227. BigDecimal sumAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP);
  228. //endregion
  229. //region 自动办理参数为true 已入库编辑
  230. //自动办理参数为true
  231. if (Constant.FlgHandleSetting.TRUE.getValue().equals(inboundVO.getFlgHandleSetting())) {
  232. //region 修改明细
  233. List<InboundItemVO> itemList = inboundVO.getItemList();
  234. for (InboundItemVO inboundItemVO : itemList) {
  235. //region 编辑明细赋值
  236. if (inboundItemVO.getItemId() != null) {
  237. //根据id查询
  238. InboundItemResponse inboundItemResponse = inboundItemMapper.selectById(inboundItemVO.getItemId());
  239. //region 将库存需要的参数赋值
  240. inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
  241. inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  242. //编辑之前的数
  243. inboundItemVO.setQtyBeforeUpdate(inboundItemResponse.getIntoQty());
  244. inboundItemVO.setAmtBeforeUpdate(inboundItemResponse.getIntoAmt());
  245. //编辑之后的数
  246. inboundItemVO.setIntoQty(inboundItemVO.getIntoingQty());
  247. inboundItemVO.setIntoAmt(inboundItemVO.getIntoingAmt());
  248. inboundItemVO.setAddOrEditFlag(false);
  249. //endregion
  250. InboundItem inboundItem = new InboundItem();
  251. inboundItem.setItemId(inboundItemVO.getItemId());
  252. inboundItem.setIntoQty(inboundItemVO.getIntoingQty());
  253. inboundItem.setIntoAmt(inboundItemVO.getIntoingAmt());
  254. inboundItem.setCostPrice(inboundItemVO.getPriceInto());
  255. inboundItem.setCostAmt(inboundItemVO.getIntoQty().multiply(inboundItemVO.getPriceInto()).setScale(6, BigDecimal.ROUND_HALF_UP));
  256. //修改
  257. inboundItemMapper.update(inboundItem,
  258. new UpdateWrapper<InboundItem>().lambda()
  259. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  260. );
  261. }
  262. //endregion
  263. //region 新建明细
  264. else {
  265. inboundItemVO
  266. .setIntoQty(inboundItemVO.getIntoingQty())
  267. .setIntoAmt(inboundItemVO.getIntoingAmt())
  268. .setIntoingQty(BigDecimal.ZERO)
  269. .setIntoingAmt(BigDecimal.ZERO)
  270. .setCostPrice(inboundItemVO.getPriceInto())
  271. .setCostAmt(inboundItemVO.getOutQty().multiply(inboundItemVO.getPriceInto()).setScale(2, BigDecimal.ROUND_HALF_UP))
  272. ;
  273. inboundItemVO.setIntoId(inboundVO.getIntoId());
  274. //入库状态
  275. inboundItemVO.setIntoStatus(inboundVO.getIntoStatus());
  276. inboundItemVO.setIntoType(Constant.IntoType.OTHER.getName());
  277. //实体转换
  278. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  279. inboundItemMapper.insert(inboundItem);
  280. inboundItemVO.setItemId(inboundItem.getItemId());
  281. //region 将库存需要的参数赋值
  282. inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
  283. inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  284. inboundItemVO.setIntoQty(inboundItemVO.getIntoQty());
  285. inboundItemVO.setIntoAmt(inboundItemVO.getIntoAmt());
  286. inboundItemVO.setAddOrEditFlag(true);
  287. //endregion
  288. }
  289. //endregion
  290. }
  291. //endregion
  292. //region 删除明细
  293. if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) {
  294. for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) {
  295. //region 将库存需要的参数赋值
  296. inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
  297. inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  298. //endregion
  299. if (inboundItemVO.getItemId() != null) {
  300. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  301. inboundItem.setFlgValid(false);
  302. //修改
  303. inboundItemMapper.update(inboundItem,
  304. new UpdateWrapper<InboundItem>().lambda()
  305. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  306. );
  307. }
  308. }
  309. }
  310. //endregion
  311. //region 修改入库总单
  312. Inbound inbound = new Inbound();
  313. inbound.setIntoId(inboundVO.getIntoId());
  314. inbound.setIntoQty(sumQty);
  315. inbound.setIntoAmt(sumAmt);
  316. //修改
  317. inboundMapper.update(inbound,
  318. new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
  319. );
  320. //endregion
  321. //region todo调用库存
  322. Map<String, Object> map = new HashMap<>();
  323. map.put("intoDetail", inboundVO.getItemList());
  324. map.put("delIntoDetail", inboundVO.getDeleteItemList());
  325. inventoryService.operatingInventoryInformation(map);
  326. //endregion
  327. } else {
  328. throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.FLG_HANDLE_SETTING_NOT_ENABLED_INTO.getMessage());
  329. }
  330. //endregion
  331. //region 自动办理参数false 入库中编辑
  332. //自动办理标识为false 并且 自动办理参数为false 入库中
  333. if (!inboundVO.getFlgAutoHandle() && Constant.FlgHandleSetting.FALSE.getValue().equals(inboundVO.getFlgHandleSetting())) {
  334. //region 修改明细
  335. List<InboundItemVO> itemList = inboundVO.getItemList();
  336. for (InboundItemVO inboundItemVO : itemList) {
  337. if (inboundItemVO.getItemId() != null) {
  338. //region 编辑赋值
  339. InboundItem inboundItem = new InboundItem();
  340. inboundItem.setItemId(inboundItemVO.getItemId());
  341. inboundItem.setIntoingQty(inboundItemVO.getIntoingQty());
  342. inboundItem.setIntoingAmt(inboundItemVO.getIntoingAmt());
  343. //修改
  344. inboundItemMapper.update(inboundItem,
  345. new UpdateWrapper<InboundItem>().lambda()
  346. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  347. );
  348. }
  349. //endregion
  350. //region 新建明细
  351. else {
  352. inboundItemVO
  353. .setIntoQty(BigDecimal.ZERO)
  354. .setIntoAmt(BigDecimal.ZERO)
  355. .setCostPrice(inboundItemVO.getPriceInto())
  356. .setCostAmt(inboundItemVO.getIntoingQty().multiply(inboundItemVO.getPriceInto()).setScale(2, BigDecimal.ROUND_HALF_UP))
  357. ;
  358. inboundItemVO.setIntoId(inboundVO.getIntoId());
  359. //入库状态
  360. inboundItemVO.setIntoStatus(inboundVO.getIntoStatus());
  361. inboundItemVO.setIntoType(Constant.IntoType.OTHER.getName());
  362. //实体转换
  363. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  364. inboundItemMapper.insert(inboundItem);
  365. inboundItemVO.setItemId(inboundItem.getItemId());
  366. }
  367. //endregion
  368. }
  369. //endregion
  370. //region 删除明细
  371. if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) {
  372. for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) {
  373. if (inboundItemVO.getItemId() != null) {
  374. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  375. inboundItem.setFlgValid(false);
  376. //修改
  377. inboundItemMapper.update(inboundItem,
  378. new UpdateWrapper<InboundItem>().lambda()
  379. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  380. );
  381. }
  382. }
  383. }
  384. //endregion
  385. //region 修改入库总单
  386. Inbound inbound = new Inbound();
  387. inbound.setIntoId(inboundVO.getIntoId());
  388. inbound.setIntoingQty(sumQty);
  389. inbound.setIntoingAmt(sumAmt);
  390. //修改
  391. inboundMapper.update(inbound,
  392. new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
  393. );
  394. //endregion
  395. } else {
  396. throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.FLG_HANDLE_SETTING_NOT_ENABLED_INTO.getMessage());
  397. }
  398. //endregion
  399. }
  400. //endregion
  401. return ResponseResultUtil.success(inboundVO);
  402. }
  403. /**
  404. * @desc : 其他入库作废
  405. * @date : 2024/3/25 16:25
  406. * @author : 寇珊珊
  407. */
  408. @Transactional(rollbackFor = {Exception.class})
  409. public ResponseResultVO<?> otherInboundRepeal(String intoId) {
  410. //region 查询总单 查询明细
  411. //根据id查询 此条入库单的数据还未更改前的数据
  412. InboundResponse inboundResponse = inboundMapper.selectById(intoId);
  413. //根据总单id查询
  414. List<InboundItemResponse> inboundItemResponseList = inboundItemMapper.selectByCond(new InboundItemQuery().setIntoId(inboundResponse.getIntoId()));
  415. //endregion
  416. //region 自动办理参数为true 已入库编辑
  417. //自动办理参数为true
  418. if (Constant.FlgHandleSetting.TRUE.getValue().equals(inboundResponse.getFlgHandleSetting())) {
  419. //region todo 退账 当单据红的账款id不为空说明有账, 要先退账才能进行操作
  420. if (inboundResponse.getReceivableId() != null) {
  421. }
  422. //endregion
  423. //region 修改明细
  424. for (InboundItemResponse inboundItemResponse : inboundItemResponseList) {
  425. //region 将库存需要的参数赋值
  426. inboundItemResponse.setInventoryType(Constant.InventoryType.INBOUND.getName());
  427. inboundItemResponse.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  428. inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate());
  429. inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate());
  430. //endregion
  431. //赋值
  432. InboundItem inboundItem = new InboundItem();
  433. inboundItem.setItemId(inboundItemResponse.getItemId());
  434. inboundItem.setFlgValid(false);
  435. //修改
  436. inboundItemMapper.update(inboundItem,
  437. new UpdateWrapper<InboundItem>().lambda()
  438. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  439. );
  440. }
  441. //endregion
  442. //region 修改入库总单
  443. Inbound inbound = new Inbound();
  444. inbound.setIntoId(inboundResponse.getIntoId());
  445. inbound.setFlgValid(false);
  446. //修改
  447. inboundMapper.update(inbound,
  448. new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
  449. );
  450. //endregion
  451. //region 库存
  452. Map<String, Object> map = new HashMap<>();
  453. map.put("delIntoDetail", inboundItemResponseList);
  454. inventoryService.operatingInventoryInformation(map);
  455. //endregion
  456. } else {
  457. throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.FLG_HANDLE_SETTING_NOT_ENABLED_INTO.getMessage());
  458. }
  459. //endregion
  460. //region 自动办理参数false 入库中编辑
  461. //自动办理标识为false 并且 自动办理参数为false 入库中
  462. if (!inboundResponse.getFlgAutoHandle() && Constant.FlgHandleSetting.FALSE.getValue().equals(inboundResponse.getFlgHandleSetting())) {
  463. //region 修改明细
  464. for (InboundItemResponse inboundItemResponse : inboundItemResponseList) {
  465. //赋值
  466. InboundItem inboundItem = new InboundItem();
  467. inboundItem.setItemId(inboundItemResponse.getItemId());
  468. inboundItem.setIntoingQty(BigDecimal.ZERO);
  469. inboundItem.setIntoingAmt(BigDecimal.ZERO);
  470. inboundItem.setFlgValid(false);
  471. //修改
  472. inboundItemMapper.update(inboundItem,
  473. new UpdateWrapper<InboundItem>().lambda()
  474. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  475. );
  476. }
  477. //endregion
  478. //region 修改入库总单
  479. Inbound inbound = new Inbound();
  480. inbound.setIntoId(inboundResponse.getIntoId());
  481. inbound.setIntoingQty(BigDecimal.ZERO);
  482. inbound.setIntoAmt(BigDecimal.ZERO);
  483. inbound.setFlgValid(false);
  484. //修改
  485. inboundMapper.update(inbound,
  486. new UpdateWrapper<Inbound>().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
  487. );
  488. //endregion
  489. } else {
  490. throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.FLG_HANDLE_SETTING_NOT_ENABLED_INTO.getMessage());
  491. }
  492. //endregion
  493. return ResponseResultUtil.success();
  494. }
  495. /**
  496. * @desc : 其他入库办理
  497. * @date : 2024/3/7 15:47
  498. * @author : 寇珊珊
  499. */
  500. @Transactional(rollbackFor = {Exception.class})
  501. public ResponseResultVO<?> otherHandleInbound(InboundVO inboundVO) {
  502. //region 编辑明细
  503. //校验明细
  504. if (inboundVO.getItemList().size() == 0) {
  505. throw new BaseBusinessException(ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getCode(),
  506. ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getMessage());
  507. }
  508. for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
  509. //region 修改明细
  510. if (inboundItemVO.getIntoId() != null) {
  511. InboundItemResponse inboundItemResponse = inboundItemMapper.selectById(inboundItemVO.getItemId());
  512. //region 校验数量是否超出
  513. if (inboundItemVO.getIntoingQty().compareTo(inboundItemResponse.getIntoingQty()) > 0) {
  514. throw new BaseBusinessException(ErrorCodeEnum.CANNOT_EXCEED_THE_QUANTITY_IN_THE_OUTBOUND_SHIPMENT.getCode(),
  515. ErrorCodeEnum.CANNOT_EXCEED_THE_QUANTITY_IN_THE_OUTBOUND_SHIPMENT.getMessage());
  516. }
  517. //endregion
  518. //region 编辑明细
  519. inboundItemVO
  520. .setIntoQty(inboundItemResponse.getIntoQty().add(inboundItemVO.getIntoingQty()))
  521. .setIntoAmt(inboundItemResponse.getIntoAmt().add(inboundItemVO.getIntoingAmt()))
  522. .setIntoingQty(BigDecimal.ZERO)
  523. .setIntoingAmt(BigDecimal.ZERO)
  524. .setCostPrice(inboundItemVO.getPriceInto())
  525. .setCostPrice(inboundItemVO.getIntoQty().subtract(inboundItemVO.getCostPrice()).setScale(2, BigDecimal.ROUND_HALF_UP))
  526. ;
  527. //入库状态
  528. String intoStatus = this.setIntoStatus(inboundItemVO.getIntoingQty(), inboundItemVO.getIntoQty());
  529. inboundItemVO.setIntoStatus(intoStatus);
  530. //实体转换
  531. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  532. //修改
  533. inboundItemMapper.update(inboundItem,
  534. new UpdateWrapper<InboundItem>().lambda()
  535. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  536. );
  537. //endregion
  538. //region 将库存需要的参数赋值
  539. inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
  540. inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  541. //编辑之前的数
  542. if (inboundItemResponse.getIntoQty().compareTo(BigDecimal.ZERO) > 0) {
  543. inboundItemVO.setQtyBeforeUpdate(inboundItemResponse.getIntoQty());
  544. inboundItemVO.setAmtBeforeUpdate(inboundItemResponse.getIntoAmt());
  545. }
  546. inboundItemVO.setAddOrEditFlag(true);
  547. //endregion
  548. }
  549. //endregion
  550. //region 新建明细
  551. else {
  552. inboundItemVO
  553. .setIntoQty(inboundItemVO.getIntoingQty())
  554. .setIntoAmt(inboundItemVO.getIntoingAmt())
  555. .setIntoId(inboundVO.getIntoId())
  556. .setCostPrice(inboundItemVO.getPriceInto())
  557. .setCostAmt(inboundItemVO.getIntoQty().multiply(inboundItemVO.getPriceInto()).setScale(2, BigDecimal.ROUND_HALF_UP))
  558. .setIntoType(Constant.IntoType.OTHER.getName())
  559. .setIntoingQty(BigDecimal.ZERO)
  560. .setIntoingAmt(BigDecimal.ZERO)
  561. ;
  562. //入库状态
  563. String intoStatus = this.setIntoStatus(inboundItemVO.getIntoingQty(), inboundItemVO.getIntoQty());
  564. inboundItemVO.setIntoStatus(intoStatus);
  565. //实体转换
  566. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  567. //新建
  568. inboundItemMapper.insert(inboundItem);
  569. inboundItemVO.setItemId(inboundItem.getItemId());
  570. //region 将库存需要的参数赋值
  571. inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
  572. inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  573. inboundItemVO.setAddOrEditFlag(true);
  574. //endregion
  575. }
  576. //endregion
  577. }
  578. //endregion
  579. //region 删除明细
  580. if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) {
  581. for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) {
  582. //region 将库存需要的参数赋值
  583. inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
  584. inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  585. //endregion
  586. if (inboundItemVO.getItemId() != null) {
  587. InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
  588. inboundItem.setFlgValid(false);
  589. //修改
  590. inboundItemMapper.update(inboundItem,
  591. new UpdateWrapper<InboundItem>().lambda()
  592. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  593. );
  594. }
  595. }
  596. }
  597. //endregion
  598. //region 编辑总单
  599. BigDecimal sumIntoQty = inboundVO.getItemList().stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP);
  600. BigDecimal sumIntoAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP);
  601. inboundVO.setIntoQty(sumIntoQty);
  602. inboundVO.setIntoAmt(sumIntoAmt);
  603. inboundVO.setIntoingQty(BigDecimal.ZERO);
  604. inboundVO.setIntoingAmt(BigDecimal.ZERO);
  605. //入库状态
  606. String intoStatus = this.setIntoStatus(inboundVO.getIntoingQty(), inboundVO.getIntoQty());
  607. inboundVO.setIntoStatus(intoStatus);
  608. //实体转换
  609. //修改
  610. Inbound inbound = inboundConvert.convertToPo(inboundVO);
  611. inboundMapper.update(inbound,
  612. new UpdateWrapper<Inbound>().lambda()
  613. .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
  614. );
  615. //endregion
  616. //region 修改库存
  617. Map<String, Object> map = new HashMap<>();
  618. map.put("intoDetail", inboundVO.getItemList());
  619. map.put("delIntoDetail", inboundVO.getDeleteItemList());
  620. inventoryService.operatingInventoryInformation(map);
  621. //endregion
  622. return ResponseResultUtil.success(inboundVO);
  623. }
  624. /**
  625. * @desc : 其它入库撤销
  626. * @date : 2024/3/7 17:06
  627. * @author : 寇珊珊
  628. */
  629. @Transactional(rollbackFor = {Exception.class})
  630. public ResponseResultVO<?> otherInboundCancel(InboundVO inboundVO) {
  631. //region 总单数据信息
  632. InboundResponse inboundResponse = inboundMapper.selectById(inboundVO.getIntoId());
  633. Inbound inbound = new Inbound();
  634. inbound.setIntoId(inboundResponse.getIntoId())
  635. .setIntoDate(null)
  636. .setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName())
  637. .setIntoingQty(inboundResponse.getIntoQty())
  638. .setIntoingAmt(inboundResponse.getIntoAmt())
  639. .setIntoQty(BigDecimal.ZERO)
  640. .setIntoAmt(BigDecimal.ZERO);
  641. //修改
  642. inboundMapper.update(inbound,
  643. new UpdateWrapper<Inbound>().lambda()
  644. .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId()))
  645. );
  646. //endregion
  647. //region 明细数据
  648. InboundItemQuery inboundItemQuery = new InboundItemQuery().setIntoId(inbound.getIntoId());
  649. //根据总单查明细
  650. List<InboundItemResponse> inboundItemResponseList = inboundItemMapper.selectByCond(inboundItemQuery);
  651. for (InboundItemResponse inboundItemResponse : inboundItemResponseList) {
  652. //region 将库存需要的参数赋值
  653. inboundItemResponse.setInventoryType(Constant.InventoryType.INBOUND.getName());
  654. inboundItemResponse.setInventoryDocCode(Constant.InventoryDocCode.OTHER_INBOUND.getValue());
  655. inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate());
  656. inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate());
  657. //region
  658. InboundItem inboundItem = new InboundItem();
  659. inboundItem
  660. .setIntoId(inbound.getIntoId())
  661. .setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName())
  662. .setIntoingQty(inboundItemResponse.getInvQty())
  663. .setIntoingAmt(inboundItemResponse.getIntoAmt())
  664. .setIntoQty(BigDecimal.ZERO)
  665. .setIntoAmt(BigDecimal.ZERO)
  666. .setCostPrice(BigDecimal.ZERO)
  667. .setCostAmt(BigDecimal.ZERO)
  668. .setItemId(inboundItemResponse.getItemId());
  669. //修改
  670. inboundItemMapper.update(inboundItem,
  671. new UpdateWrapper<InboundItem>().lambda()
  672. .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId()))
  673. );
  674. //数量金额取反 用于给库存使用
  675. inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate());
  676. inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate());
  677. }
  678. //endregion
  679. //region 修改库存
  680. Map<String, Object> map = new HashMap<>();
  681. map.put("delIntoDetail", inboundItemResponseList);
  682. inventoryService.operatingInventoryInformation(map);
  683. //endregion
  684. return ResponseResultUtil.success();
  685. }
  686. /**
  687. * @desc : 入库状态通用(目前本页面)
  688. * @date : 2024/3/9 8:59
  689. * @author : 寇珊珊
  690. */
  691. @Transactional(rollbackFor = {Exception.class})
  692. public String setIntoStatus(BigDecimal intoingQty, BigDecimal intoQty) {
  693. //入库状态
  694. String intoStatus = null;
  695. //已入库数量>=0 入库中数量>0
  696. if (intoQty.compareTo(BigDecimal.ZERO) >= 0 && intoingQty.compareTo(BigDecimal.ZERO) > 0) {
  697. //入库中
  698. intoStatus = Constant.IntoStatus.RUKUZHONG.getName();
  699. }
  700. //已入库数量=0 入库中数量=0
  701. else if (intoQty.compareTo(BigDecimal.ZERO) == 0 && intoingQty.compareTo(BigDecimal.ZERO) == 0) {
  702. //待入库
  703. intoStatus = Constant.IntoStatus.DAIRUKU.getName();
  704. }
  705. //已入库数量>0 入库中数量=0
  706. else if (intoQty.compareTo(BigDecimal.ZERO) > 0 && intoingQty.compareTo(BigDecimal.ZERO) == 0) {
  707. //已入库
  708. intoStatus = Constant.IntoStatus.YIRUKU.getName();
  709. }
  710. return intoStatus;
  711. }
  712. /**
  713. * @desc : 条件查询 --- web端入库办理用
  714. * @date : 2024/3/23 9:24
  715. * @author : 寇珊珊
  716. */
  717. @Pagination
  718. public ResponseResultVO<PageList<InboundResponse>> selectInbound(InboundQuery inboundQuery) {
  719. return super.mergeListWithCount(inboundQuery, inboundMapper.selectInbound(inboundQuery),
  720. inboundMapper.selectInboundCond(inboundQuery));
  721. }
  722. /**
  723. * @desc : 查询明细查询 --- web端入库办理用
  724. * @date : 2024/3/9 15:43
  725. * @author : 寇珊珊
  726. */
  727. public ResponseResultVO<Map<String, Object>> selectInboundItem(String id) {
  728. Map<String, Object> result = new HashMap<>();
  729. // 商品明细
  730. List<InboundItemResponse> inboundItemResponses = inboundItemMapper.selectInboundItem(new InboundItemQuery().setIntoId(id));
  731. result.put("itemList", inboundItemResponses);
  732. // 收款
  733. // 附件
  734. return ResponseResultUtil.success(result);
  735. }
  736. /**
  737. * @desc : 查询待入库数量(小程序(我的))
  738. * @date : 2024/4/9 15:43
  739. * @author : 周兴
  740. */
  741. public ResponseResultVO<?> selectWaitInboundCount(InboundQuery inboundQuery) {
  742. return ResponseResultUtil.success(inboundMapper.selectInboundCond(inboundQuery));
  743. }
  744. }