blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
廖井涛
2024-08-29 07d08f8dc420ba47f66587fdc5038a59fc340c96 
 north-glass-erp/src/main/java/com/example/erp/service/pp/ReportingWorkService.java


@@ -13,6 +13,7 @@


import com.example.erp.entity.sd.Order;


import com.example.erp.entity.sd.OrderProcessDetail;


import com.example.erp.entity.userInfo.Log;


import com.example.erp.entity.userInfo.SysError;


import com.example.erp.exception.ServiceException;


import com.example.erp.mapper.pp.*;


import com.baomidou.dynamic.datasource.annotation.DS;


@@ -22,8 +23,11 @@


import com.example.erp.mapper.userInfo.LogMapper;


import com.example.erp.service.sd.OrderProcessDetailService;


import com.example.erp.service.userInfo.LogService;


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;




import java.text.SimpleDateFormat;


import java.time.LocalDateTime;


@@ -57,9 +61,10 @@




    final LogMapper logMapper;


    private final OrderGlassDetailMapper orderGlassDetailMapper;


    private final SysErrorService sysErrorService;






    public ReportingWorkService(ReportingWorkMapper reportingWorkMapper, BasicDateProduceMapper basicDateProduceMapper, DamageDetailsMapper damageDetailsMapper, ReportingWorkDetailMapper reportingWorkDetailMapper, OrderProcessDetailMapper orderProcessDetailMapper, OrderProcessDetailService orderProcessDetailService, OrderMapper orderMapper, FlowCardMapper flowCardMapper, LogService logService, LogMapper logMapper, OrderGlassDetailMapper orderGlassDetailMapper) {


    public ReportingWorkService(ReportingWorkMapper reportingWorkMapper, BasicDateProduceMapper basicDateProduceMapper, DamageDetailsMapper damageDetailsMapper, ReportingWorkDetailMapper reportingWorkDetailMapper, OrderProcessDetailMapper orderProcessDetailMapper, OrderProcessDetailService orderProcessDetailService, OrderMapper orderMapper, FlowCardMapper flowCardMapper, LogService logService, LogMapper logMapper, OrderGlassDetailMapper orderGlassDetailMapper, SysErrorService sysErrorService) {


        this.reportingWorkMapper = reportingWorkMapper;


        this.basicDateProduceMapper = basicDateProduceMapper;


        this.damageDetailsMapper = damageDetailsMapper;


@@ -71,6 +76,7 @@


        this.logService = logService;


        this.logMapper = logMapper;


        this.orderGlassDetailMapper = orderGlassDetailMapper;


        this.sysErrorService = sysErrorService;


    }




    public Map<String, Object> AddSelectLastWorkSv(String processIdStr, String technologyStr, String process, String reportType) {


@@ -329,8 +335,9 @@


        String thisProcess = reportingWork.get("thisProcess");


        int index = processId.lastIndexOf("/") + 1;


        String result = processId.substring(index);


        String technologyStr = reportingWork.get("technologyStr");




if (thisProcess.equals("夹胶") || thisProcess.equals("中空") || thisProcess.equals("仓储")){


if (thisProcess.equals("夹胶") || thisProcess.equals("中空") || thisProcess.equals("包装")){


    LambdaUpdateWrapper


                <ReportingWork> updateWrapper = new LambdaUpdateWrapper<>();


        updateWrapper


@@ -340,7 +347,7 @@


                .setSql("reviewed_state =1");


        reportingWorkMapper.update(null, updateWrapper);


}else {


    reportingWorkMapper.ReviewReportingWorkMp(processId.substring(0, 14),reportingWork.get("process"),result);


    reportingWorkMapper.ReviewReportingWorkMp(processId.substring(0, 14),reportingWork.get("process"),technologyStr);




}


        return true;


@@ -610,4 +617,70 @@


        String count=reportingWorkMapper.getPatchConditionMp(reportingWorkId);


        return count;


    }


    @Transactional(rollbackFor = Exception.class , noRollbackFor = ServiceException.class)


    public Boolean mesReportingWorkSv(Map<String,Object> reportingWorkMap) {


        //设置回滚点


        Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();


        try{


            //接收解析主附表信息


            JSONObject reportingWorkJson = new JSONObject(reportingWorkMap);


            ReportingWork reportingWork = JSONObject.parseObject(JSONObject.toJSONString(reportingWorkJson.get("title")), ReportingWork.class);


            ReportingWorkDetail reportingWorkDetail =JSON.parseObject(JSONObject.toJSONString(reportingWorkJson.get("detail")), ReportingWorkDetail.class);




            int processNum = reportingWorkMapper.selectGlassProcessNum(


                    reportingWorkDetail.getOrderNumber(),


                    reportingWorkDetail.getTechnologyNumber(),


                    reportingWork.getProcessId(),


                    reportingWork.getThisProcess()


            );


            //判断是否大于当前数量并且抛出异常


            if (processNum < (reportingWorkDetail.getBreakageQuantity() + reportingWorkDetail.getCompletedQuantity())) {


                return false;


            }






            //获取当前最大报工单号生成报工单号


            String formattedNumber = String.format("%04d", reportingWorkMapper.selectMaxReportingWorkId() + 1);


            //格式化当前日期


            Date currentDate = new Date();


            SimpleDateFormat dateFormat = new SimpleDateFormat("yyMMdd");


            String formattedDate = dateFormat.format(currentDate);


            String reportingWorkId = "BG" + formattedDate + formattedNumber;




            reportingWork.setReportingWorkId(reportingWorkId);


            reportingWorkDetail.setReportingWorkId(reportingWorkId);




            reportingWorkMapper.insert(reportingWork);


            reportingWorkDetailMapper.insert(reportingWorkDetail);








            OrderProcessDetail orderProcessDetail = new OrderProcessDetail();


            orderProcessDetail.setBrokenNum(reportingWorkDetail.getBreakageQuantity());


            orderProcessDetail.setReportingWorkNum(reportingWorkDetail.getCompletedQuantity());


            orderProcessDetail.setReportingWorkNumCount(reportingWorkDetail.getCompletedQuantity());




            //根据订单id，订单序号，以及小片序号 更新小片流程的完工数量以及刺破数量


            LambdaUpdateWrapper<OrderProcessDetail> updateWrapper = new LambdaUpdateWrapper<>();


            updateWrapper.eq(OrderProcessDetail::getOrderNumber, reportingWorkDetail.getOrderNumber())


                    .eq(OrderProcessDetail::getProcessId, reportingWork.getProcessId().substring(0, 14))


                    .eq(OrderProcessDetail::getOrderId, reportingWork.getOrderId())


                    .eq(OrderProcessDetail::getProcess, reportingWork.getThisProcess())


                    .eq(OrderProcessDetail::getTechnologyNumber, reportingWorkDetail.getTechnologyNumber())


                    .setSql("reporting_work_num_count = reporting_work_num_count +" + orderProcessDetail.getReportingWorkNum())


                    .setSql("reporting_work_num =reporting_work_num +" + orderProcessDetail.getReportingWorkNum());




            orderProcessDetailMapper.update(null, updateWrapper);


            return true;


         } catch (Exception e) {


            TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);


            //将异常传入数据库


            SysError sysError = new SysError();


            sysError.setError(e +Arrays.toString(e.getStackTrace()));


            sysError.setFunc("saveOrder");


            sysErrorService.insert(sysError);


            throw new ServiceException(Constants.Code_500, "数据请求异常，请检查");




        }


    }


}