提交

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/gx/controller/GxResumptionController.java

@@ -5,6 +5,9 @@ import com.xunmei.common.core.web.domain.AjaxResult;
 import com.xunmei.common.redis.utils.RedisUtils;
 import com.xunmei.core.resumption.gx.service.ResumptionService;
 import com.xunmei.core.resumption.gx.vo.ResumptionTaskDetailVo;
+import com.xunmei.system.api.factory.RemoteJobFallbackFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -19,6 +22,8 @@ import java.time.Duration;
 @RequestMapping("gx/resumption")
 public class GxResumptionController {
 
+    private static final Logger log = LoggerFactory.getLogger(GxResumptionController.class);
+
     @Autowired
     private ResumptionService resumptionService;
 
@@ -58,6 +63,7 @@ public class GxResumptionController {
             return AjaxResult.success();
         } catch (Exception e) {
             e.printStackTrace();
+            log.error("数据处理出错",e);
             RedisUtils.deleteObject("resumption" + taskDetailVo.getTaskId());
             return AjaxResult.error(e.getMessage());
         }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/gx/service/ResumptionServiceImpl.java

@@ -1,12 +1,20 @@
 package com.xunmei.core.resumption.gx.service;
 
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.xunmei.common.core.constant.SecurityConstants;
 import com.xunmei.common.core.utils.DateHelper;
 import com.xunmei.common.security.utils.SecurityUtils;
+import com.xunmei.core.question.QuestionSrcType;
+import com.xunmei.core.question.domain.Question;
+import com.xunmei.core.question.service.IQuestionService;
 import com.xunmei.core.resumption.domain.*;
 import com.xunmei.core.resumption.gx.vo.*;
 import com.xunmei.core.resumption.mapper.*;
 import com.xunmei.core.resumption.vo.ResumptionTaskNewDto;
+import com.xunmei.system.api.RemoteOrgService;
+import com.xunmei.system.api.domain.SysOrg;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -31,6 +39,12 @@ public class ResumptionServiceImpl implements ResumptionService{
     @Autowired
     private AppResumptionDataNfcMapper appResumptionDataNfcMapper;
 
+    @Autowired
+    private RemoteOrgService remoteOrgService;
+
+    @Autowired
+    private IQuestionService questionService;
+
     @Override
     public Map<String, List<ResumptionTaskListVo>> getTaskList(ResumptionTaskNewDto dto) {
 
@@ -105,6 +119,8 @@ public class ResumptionServiceImpl implements ResumptionService{
         int quarter =dateTime.getQuarter() ;
         //获取履职任务
         Resumption sysResumption = resumptionMapper.findOneByTaskIdAndDate(taskId,year,quarter);
+        Long orgId = sysResumption.getOrgId();
+
         sysResumption.setUpdateBy(SecurityUtils.getUsername());
         sysResumption.setUpdateTime(new Date());
         sysResumption.setSubmitTime(new Date());
@@ -153,6 +169,29 @@ public class ResumptionServiceImpl implements ResumptionService{
                 }
                  appResumptionDataMapper.insert(data);
 
+                if(taskDetailVo.getSubType() == 2){
+                    SysOrg org = remoteOrgService.selectSysOrgById(sysResumption.getOrgId(), SecurityConstants.INNER);
+                    Question question = Question.builder()
+                            .srcTaskId(taskId)
+                            .orgId(org.getId())
+                            .orgName(org.getShortName())
+                            .orgPath(org.getPath())
+                            .SrcPointId(point.getPointId())
+                            .srcDataPointId(data.getId())
+                            .srcType(QuestionSrcType.Resumption.getValue())
+                            .srcTaskName(sysResumption.getName())
+                            .checkItem(check.getItemName())
+                            .checkContent(point.getPointName())
+                            .questionDesc(data.getResRemark())
+                            .submitorId(ObjectUtil.isNull(data.getSubmitBy()) ? SecurityUtils.getLoginUser().getUserid() : data.getSubmitBy())
+                            .submitorName(ObjectUtil.isNull(data.getSubmitName()) ? SecurityUtils.getLoginUser().getName() : data.getSubmitName())
+                            .submitTime(ObjectUtil.isNull(data.getSubmitTime()) ? new Date() : data.getSubmitTime())
+                            .reformDeadline(DateUtil.endOfDay(DateUtil.offsetDay(new Date(), Integer.parseInt(point.getRectificationDeadline()))))
+                            .build();
+
+                    questionService.insertQuestion(question);
+                }
+
                 List<AppResumptionDataRemarkimg> imgs = point.getImgs();
                 for (AppResumptionDataRemarkimg img : imgs) {
                     img.setResumptionDataId(data.getId());