From 09190b164b61947d389c1ee7cf327d46817dd317 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Fri, 25 Oct 2024 13:21:21 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9B=BD=E7=BD=91=E4=B8=8A=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pojo/po/upload/PmsTemProcessApproval.java | 105 ++++++++++++++++++ .../upload/PmsTemProcessApprovalMapper.java | 15 +++ .../upload/PmsTemProcessApprovalService.java | 26 +++++ .../PmsTemProcessApprovalServiceImpl.java | 88 +++++++++++++++ .../mapping/PmsTemProcessApprovalMapper.xml | 11 ++ 5 files changed, 245 insertions(+) create mode 100644 pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/upload/PmsTemProcessApproval.java create mode 100644 pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/upload/PmsTemProcessApprovalMapper.java create mode 100644 pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/PmsTemProcessApprovalService.java create mode 100644 pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/PmsTemProcessApprovalServiceImpl.java create mode 100644 pqs-harmonic/harmonic-boot/src/main/resources/com/njcn/harmonic/mapper/mapping/PmsTemProcessApprovalMapper.xml diff --git a/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/upload/PmsTemProcessApproval.java b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/upload/PmsTemProcessApproval.java new file mode 100644 index 000000000..870f21794 --- /dev/null +++ b/pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/upload/PmsTemProcessApproval.java @@ -0,0 +1,105 @@ +package com.njcn.harmonic.pojo.po.upload; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import java.time.LocalDateTime; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * + * Description: + * Date: 2024/10/25 10:23【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@TableName(value = "pms_tem_process_approval") +public class PmsTemProcessApproval { + /** + * 主键 + */ + @TableId(value = "obj_id", type = IdType.ASSIGN_UUID) + private String objId; + + /** + * 关联临时用户档案主键 + */ + @TableField(value = "temp_user_dossier_id") + private String tempUserDossierId; + + /** + * 验收参与人 + */ + @TableField(value = "approval_join_user_id") + private String approvalJoinUserId; + + /** + * 验收参与人名称 + */ + @TableField(value = "approval_join_user_name") + private String approvalJoinUserName; + + /** + * 验收建议 + */ + @TableField(value = "approval_advise") + private String approvalAdvise; + + /** + * 新增时间 + */ + @TableField(value = "create_time") + private LocalDateTime createTime; + + /** + * 更新时间 + */ + @TableField(value = "update_time") + private LocalDateTime updateTime; + + /** + * 遗留问题 + */ + @TableField(value = "legacy_problem") + private String legacyProblem; + + /** + * 整改状态（是否整改） + */ + @TableField(value = "rectification_status") + private String rectificationStatus; + + /** + * 整改时间 + */ + @TableField(value = "rectification_time") + private LocalDateTime rectificationTime; + + /** + * 整改人 + */ + @TableField(value = "rectification_user_id") + private String rectificationUserId; + + /** + * 整改人名称 + */ + @TableField(value = "rectification_user_name") + private String rectificationUserName; + + /** + * 整改措施 + */ + @TableField(value = "rectification_measure") + private String rectificationMeasure; + + private Integer uploadStatus; + +} \ No newline at end of file diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/upload/PmsTemProcessApprovalMapper.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/upload/PmsTemProcessApprovalMapper.java new file mode 100644 index 000000000..45fb54080 --- /dev/null +++ b/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 { +} \ No newline at end of file diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/PmsTemProcessApprovalService.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/PmsTemProcessApprovalService.java new file mode 100644 index 000000000..107874ff9 --- /dev/null +++ b/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{ + + + Boolean createOrUpdate(PmsTemProcessApprovalParam param); + + Page pageList(PmsTemProcessApprovalParam.QueryPmsTemProcessApprovalParam param); + + Boolean upGw(List ids); + } diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/PmsTemProcessApprovalServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/upload/impl/PmsTemProcessApprovalServiceImpl.java new file mode 100644 index 000000000..c428d1547 --- /dev/null +++ b/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 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 pageList(PmsTemProcessApprovalParam.QueryPmsTemProcessApprovalParam param) { + LambdaQueryWrapper 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 ids) { + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.in(PmsTemProcessApproval::getObjId,ids); + List pmsTemProcessApprovalList = this.list(lambdaQueryWrapper); + if(CollUtil.isEmpty(pmsTemProcessApprovalList)){ + throw new BusinessException("查询用户临时档案数据为空"); + } + + List> list = CollUtil.split(pmsTemProcessApprovalList,100); + for(int i=0;i sendRes = GwSendUtil.newSend(sendParam, GWSendEnum.PROCESS_APPROVAL_CREATE); + List 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 lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); + lambdaUpdateWrapper.set(PmsTemProcessApproval::getUploadStatus,1).in(PmsTemProcessApproval::getObjId,ids); + this.update(lambdaUpdateWrapper); + } + } + return true; + } +} diff --git a/pqs-harmonic/harmonic-boot/src/main/resources/com/njcn/harmonic/mapper/mapping/PmsTemProcessApprovalMapper.xml b/pqs-harmonic/harmonic-boot/src/main/resources/com/njcn/harmonic/mapper/mapping/PmsTemProcessApprovalMapper.xml new file mode 100644 index 000000000..5b8dd5395 --- /dev/null +++ b/pqs-harmonic/harmonic-boot/src/main/resources/com/njcn/harmonic/mapper/mapping/PmsTemProcessApprovalMapper.xml @@ -0,0 +1,11 @@ + + + + + + + obj_id, temp_user_dossier_id, approval_join_user_id, approval_join_user_name, approval_advise, + create_time, update_time, legacy_problem, rectification_status, rectification_time, + rectification_user_id, rectification_user_name, rectification_measure + + \ No newline at end of file