From ef5a518c3e2c1fe41aa60f56ca31ddafa0cb1561 Mon Sep 17 00:00:00 2001 From: guoyuji <guoyujie@ng.com> Date: 星期四, 23 五月 2024 08:32:36 +0800 Subject: [PATCH] 添加产品汇总报表 --- north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java | 68 ++++++++++++++++++++++----------- 1 files changed, 45 insertions(+), 23 deletions(-) diff --git a/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java b/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java index de23517..b78390d 100644 --- a/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java +++ b/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java @@ -3,13 +3,13 @@ import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.dynamic.datasource.annotation.DS; -import com.example.erp.entity.pp.FlowCard; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.example.erp.entity.pp.PatchLog; -import com.example.erp.entity.pp.Rework; +import com.example.erp.entity.pp.ReportingWork; import com.example.erp.entity.userInfo.SysError; import com.example.erp.mapper.pp.PatchLogMapper; +import com.example.erp.mapper.pp.ReportingWorkMapper; import com.example.erp.service.userInfo.SysErrorService; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; @@ -23,11 +23,20 @@ @DS("pp") @Transactional(rollbackFor = Exception.class) public class ReplenishService { - @Autowired + final PatchLogMapper patchMapper; - @Autowired + final SysErrorService sysErrorService; + + final + ReportingWorkMapper reportingWorkMapper; + + public ReplenishService(PatchLogMapper patchMapper, SysErrorService sysErrorService, ReportingWorkMapper reportingWorkMapper) { + this.patchMapper = patchMapper; + this.sysErrorService = sysErrorService; + this.reportingWorkMapper = reportingWorkMapper; + } public List<Map<String, Object>> getSelectReplenish(Integer pageNum, Integer pageSize) { @@ -99,26 +108,39 @@ public Boolean updateReplenish(Map<String,Object> object) { boolean saveState = true; - - String userName = ""; - String userId = ""; - if (object.get("userName") != null) { - userName = object.get("userName").toString(); - } - if (object.get("userId") != null) { - userId = object.get("userId").toString(); - } - //鑾峰彇瀵硅薄闆嗗悎寰幆杩涜鏂板淇敼 - List<PatchLog> patchLoglist = JSONArray.parseArray(JSONObject.toJSONString(object.get("patchLog")), PatchLog.class); - if (!patchLoglist.isEmpty()){ - for (PatchLog patchLog : patchLoglist) { - //瀹℃牳 - patchMapper.updateReplenish(patchLog,userName); - //淇敼灏忕墖娴佺▼鍗℃暟閲� - patchMapper.updateOrderProcessDetail(patchLog); + Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint(); + try { + String userName = ""; + String userId = ""; + if (object.get("userName") != null) { + userName = object.get("userName").toString(); } - } + if (object.get("userId") != null) { + userId = object.get("userId").toString(); + } + //鑾峰彇瀵硅薄闆嗗悎寰幆杩涜鏂板淇敼 + List<PatchLog> patchLoglist = JSONArray.parseArray(JSONObject.toJSONString(object.get("patchLog")), PatchLog.class); + if (!patchLoglist.isEmpty()){ + for (PatchLog patchLog : patchLoglist) { + //瀹℃牳 + patchMapper.updateReplenish(patchLog,userName); + ReportingWork reportingWork = reportingWorkMapper + .selectOne(new QueryWrapper<ReportingWork>().eq("reporting_work_id",patchLog.getReportingWorkId())); + //淇敼灏忕墖娴佺▼鍗℃暟閲� + patchMapper.updateOrderProcessDetail(patchLog,reportingWork); + } + } + } catch (Exception e) { + TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint); + //灏嗗紓甯镐紶鍏ユ暟鎹簱 + SysError sysError = new SysError(); + sysError.setError(e.toString()); + sysError.setFunc("saveOrder"); + sysErrorService.insert(sysError); + saveState = false; + + } return saveState; -- Gitblit v1.8.0