国网上送

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/upload/PmsTemProcessApprovalMapper.java

@@ -0,0 +1,15 @@
+package com.njcn.harmonic.mapper.upload;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.upload.PmsTemProcessApproval;
+
+/**
+ * 
+ * Description:
+ * Date: 2024/10/25  10:23【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface PmsTemProcessApprovalMapper extends BaseMapper<PmsTemProcessApproval> {
+}

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/PmsTemProcessApprovalService.java

@@ -0,0 +1,26 @@
+package com.njcn.harmonic.service.upload;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.njcn.harmonic.pojo.param.upload.PmsTemProcessApprovalParam;
+import com.njcn.harmonic.pojo.po.upload.PmsTemProcessApproval;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.List;
+
+/**
+ * 
+ * Description:
+ * Date: 2024/10/25  10:23【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface PmsTemProcessApprovalService extends IService<PmsTemProcessApproval>{
+
+
+        Boolean createOrUpdate(PmsTemProcessApprovalParam param);
+
+        Page<PmsTemProcessApproval> pageList(PmsTemProcessApprovalParam.QueryPmsTemProcessApprovalParam param);
+
+        Boolean upGw(List<String> ids);
+    }

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/PmsTemProcessApprovalServiceImpl.java

@@ -0,0 +1,88 @@
+package com.njcn.harmonic.service.upload.impl;
+
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.njcn.common.pojo.enums.common.DataStateEnum;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.harmonic.pojo.param.upload.PmsTemProcessApprovalParam;
+import com.njcn.harmonic.pojo.po.upload.PmsTemProcessTrackPO;
+import com.njcn.web.enums.GWSendEnum;
+import com.njcn.web.factory.PageFactory;
+import com.njcn.web.pojo.param.SendParam;
+import com.njcn.web.utils.GwSendUtil;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.harmonic.mapper.upload.PmsTemProcessApprovalMapper;
+import com.njcn.harmonic.pojo.po.upload.PmsTemProcessApproval;
+import com.njcn.harmonic.service.upload.PmsTemProcessApprovalService;
+/**
+ * 
+ * Description:
+ * Date: 2024/10/25  10:23【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Service
+public class PmsTemProcessApprovalServiceImpl extends ServiceImpl<PmsTemProcessApprovalMapper, PmsTemProcessApproval> implements PmsTemProcessApprovalService{
+
+    @Override
+    public Boolean createOrUpdate(PmsTemProcessApprovalParam param) {
+        PmsTemProcessApproval pmsTemProcessApproval = new PmsTemProcessApproval();
+        BeanUtils.copyProperties(param,pmsTemProcessApproval);
+        pmsTemProcessApproval.setUploadStatus(DataStateEnum.DELETED.getCode());
+
+        boolean b = this.saveOrUpdate(pmsTemProcessApproval);
+        return b;
+    }
+
+    @Override
+    public Page<PmsTemProcessApproval> pageList(PmsTemProcessApprovalParam.QueryPmsTemProcessApprovalParam param) {
+        LambdaQueryWrapper<PmsTemProcessApproval> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.between(StringUtils.isNotBlank(param.getSearchBeginTime())&&StringUtils.isNotBlank(param.getSearchEndTime()),PmsTemProcessApproval::getCreateTime,param.getSearchBeginTime(),param.getSearchEndTime());
+
+        return this.page(new Page<>(PageFactory.getPageNum(param), PageFactory.getPageSize(param)), lambdaQueryWrapper);
+    }
+
+    @Override
+    public Boolean upGw(List<String> ids) {
+        LambdaQueryWrapper<PmsTemProcessApproval> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.in(PmsTemProcessApproval::getObjId,ids);
+        List<PmsTemProcessApproval> pmsTemProcessApprovalList = this.list(lambdaQueryWrapper);
+        if(CollUtil.isEmpty(pmsTemProcessApprovalList)){
+            throw new BusinessException("查询用户临时档案数据为空");
+        }
+
+        List<List<PmsTemProcessApproval>> list = CollUtil.split(pmsTemProcessApprovalList,100);
+        for(int i=0;i<list.size();i++){
+            SendParam sendParam = new SendParam();
+            if(i==0){
+                sendParam.setIsAppend("0");
+            }else if(i==list.size()-1){
+                sendParam.setIsAppend("2");
+            }else {
+                sendParam.setIsAppend("1");
+            }
+            sendParam.setStats(list.get(i));
+            Map<String, String> sendRes = GwSendUtil.newSend(sendParam, GWSendEnum.PROCESS_APPROVAL_CREATE);
+            List<String> TemProcessTrackPOIds = list.get(i).stream().map(PmsTemProcessApproval::getObjId).collect(Collectors.toList());
+            int count = GwSendUtil.returnInfoMsg(TemProcessTrackPOIds,sendRes);
+            System.out.println("上送成功,上送成功返回"+count+"条");
+            if(count == list.get(i).size()){
+                LambdaUpdateWrapper<PmsTemProcessApproval> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
+                lambdaUpdateWrapper.set(PmsTemProcessApproval::getUploadStatus,1).in(PmsTemProcessApproval::getObjId,ids);
+                this.update(lambdaUpdateWrapper);
+            }
+        }
+        return true;
+    }
+}