修改错误提交

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/FailureDetailsServiceImpl.java

 package com.yeejoin.amos.boot.module.common.biz.service.impl;
 
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.List;
+import java.util.Random;
 
+import org.apache.commons.lang3.ObjectUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.biz.common.workflow.RemoteWorkFlowService;
 import com.yeejoin.amos.boot.module.common.api.dto.FailureDetailsDto;
 import com.yeejoin.amos.boot.module.common.api.entity.FailureDetails;
+import com.yeejoin.amos.boot.module.common.api.enums.FailureStatuEnum;
 import com.yeejoin.amos.boot.module.common.api.mapper.FailureDetailsMapper;
 import com.yeejoin.amos.boot.module.common.api.service.IFailureDetailsService;
 
@@ -30,9 +38,11 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
     @Autowired
     SourceFileServiceImpl sourceFileServiceImpl;
  
-
-    @Value("${params.work.flow.processDefinitionKey}")
-    private String processDefinitionKey;
+//    @Autowired
+//	RemoteWorkFlowService remoteWorkFlowService;
+//    
+//    @Value("${failure.work.flow.processDefinitionKey}")
+//    private String processDefinitionKey;
 
     private final Logger logger = LoggerFactory.getLogger(FailureDetailsServiceImpl.class);
 
@@ -64,23 +74,46 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
     /**
      * 发起故障保修单
      */
-//       public CommonResponse savemodel(FailureDetailsDto failureDetailsDto) {
-//    String businessKey = RandomUtil.buildOrderNo();
-//        JSONObject jsonObject = remoteWorkFlow.start( businessKey, processDefinitionKey);
+//       public Object savemodel(FailureDetailsDto failureDetailsDto) {
+//    	 String businessKey = buildOrderNo();
+//        JSONObject jsonObject = remoteWorkFlowService.start( businessKey, processDefinitionKey);
 //        if (jsonObject == null) {
 //            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-//            return CommonResponseUtil.failure("启动流程失败");
+//           // return CommonResponseUtil.failure("启动流程失败");
 //        }
 //        JSONObject instance = jsonObject.getJSONObject("data");
 //        if(instance==null){
-//            return CommonResponseUtil.failure("无提交隐患权限");
+//            //return CommonResponseUtil.failure("无提交隐患权限");
 //        }
 //        failureDetailsDto.setCurrentStatus(FailureStatuEnum.WAITING_AUDIT.getCode());
-//        FailureDetailsDto model = this.createWithModel(failureDetailsDto);
-//
+//        //拿到流程id
+//        failureDetailsDto.setProcessId(instance.getString("processInstanceId"));
+//        FailureDetailsDto model =null;
+//        try {
 //             sourceFileServiceImpl.saveSourceFile(failureDetailsDto.getSequenceNbr(), failureDetailsDto.getAttachment());
-//        return CommonResponseUtil.success(model);
+//             model = this.createWithModel(failureDetailsDto);
+//		} catch (Exception e) {
+//			logger.info("添加故障维修信息到数据库失败");
+//			// return CommonResponseUtil.failure("添加失败");
+//		}
+//        if(ObjectUtils.isNotEmpty(model)) {
+//        	JSONObject  teskObject = remoteWorkFlowService.currentTask(instance.getString("processInstanceId"));
+//        	if(ObjectUtils.isNotEmpty(teskObject)) {
+//        		 JSONObject taskDetail = teskObject.getJSONObject("data");
+//        		 String taskId = taskDetail.getString("id");
+//        		 remoteWorkFlowService.excute(taskId, null);
+//        	}
+//        }
+//        return model;
+//    }
+//       public static String buildOrderNo() {
+//           SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
+//           String newDate = sdf.format(new Date());
+//           String result = "";
+//           Random random = new Random();
+//           for (int i = 0; i < 3; i++) {
+//               result += random.nextInt(10);
+//           }
+//           return newDate + result;
 //       }
-
-
 }
\ No newline at end of file