首页切换主岗位新增接口

ibps-common-root/modules/org-biz/src/main/java/com/lc/ibps/org/party/repository/PartyPositionUserRepository.java

@@ -2,12 +2,9 @@ package com.lc.ibps.org.party.repository;
 
 import com.lc.ibps.api.base.page.Page;
 import com.lc.ibps.api.org.constant.PartyType;
-import com.lc.ibps.base.framework.repository.AbstractRepository;
 import com.lc.ibps.base.framework.repository.IRepository;
 import com.lc.ibps.org.party.domain.PartyPoUs;
-import com.lc.ibps.org.party.domain.PartyRel;
 import com.lc.ibps.org.party.persistence.entity.PartyPositionUserPo;
-import com.lc.ibps.org.party.persistence.entity.PartyRelPo;
 
 import java.util.List;
 
@@ -25,6 +22,9 @@ public interface PartyPositionUserRepository extends IRepository<String, PartyPo
 
     public void remoBySubId(String ids);
 
-
     List<PartyPositionUserPo> selectAll(String diDian);
+
+    void upByIdGeneral(String oldId);
+
+    void upByIdSpecial(String newId);
 }

ibps-common-root/modules/org-biz/src/main/java/com/lc/ibps/org/party/repository/impl/PartyPositionUserRepositoryImpl.java

@@ -93,4 +93,16 @@ public class PartyPositionUserRepositoryImpl extends AbstractRepository<String,
         partyPoUs.setData(po);
         return partyPoUs;
     }
+
+    @Override
+    public void upByIdGeneral(String oldId) {
+        findByKey("upByIdGeneral", "upByIdGeneral",
+                b().a("oldId", oldId).p());
+    }
+
+    @Override
+    public void upByIdSpecial(String newId) {
+        findByKey("upByIdSpecial", "upByIdSpecial",
+                b().a("newId", newId).p());
+    }
 }

ibps-model-root/modules/org-model/src/main/resources/com/lc/ibps/org/party/persistence/mapping/PartyPositionUser.map.xml

@@ -122,4 +122,18 @@
     AND di_dian_ = #{diDian,jdbcType=VARCHAR} group by POSITION_NAME_
     </select>
 
+    <update id="upByIdGeneral" parameterType="java.util.Map">
+        UPDATE IBPS_PARTY_POSITION_USERS SET
+         DATA_TYPE_ = ''
+        WHERE
+            ID_=#{oldId,jdbcType=VARCHAR}
+    </update>
+
+    <update id="upByIdSpecial" parameterType="java.util.Map">
+        UPDATE IBPS_PARTY_POSITION_USERS SET
+            DATA_TYPE_ = 'mainResp'
+        WHERE
+            ID_=#{newId,jdbcType=VARCHAR}
+    </update>
+
 </mapper>

ibps-provider-base-root/modules/provider-platform-api/src/main/java/com/lc/ibps/org/api/IPartyPositionUserService.java

@@ -0,0 +1,26 @@
+package com.lc.ibps.org.api;
+
+
+import com.lc.ibps.cloud.entity.APIResult;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Map;
+
+@Validated
+@RequestMapping(value = "/positionUser")
+@RestController
+public interface IPartyPositionUserService {
+    /**
+     * 首页更新主岗位接口
+     * @param
+     * @para m
+     * @return
+     */
+    @RequestMapping(value = "/savePositionUser", method = RequestMethod.POST)
+    public APIResult<Void> save(@RequestBody(required = false) @Valid Map<String,String> data);
+}

ibps-provider-root/modules/provider-platform-default/src/main/java/com/lc/ibps/org/provider/PartyPositionUserProvider.java

@@ -0,0 +1,40 @@
+package com.lc.ibps.org.provider;
+
+import com.lc.ibps.api.form.sql.util.BeanUtils;
+import com.lc.ibps.cloud.entity.APIResult;
+import com.lc.ibps.cloud.provider.GenericProvider;
+import com.lc.ibps.org.api.IPartyPositionUserService;
+import com.lc.ibps.org.party.persistence.entity.PartyPositionUserPo;
+import com.lc.ibps.org.party.repository.PartyPositionUserRepository;
+import io.swagger.annotations.Api;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Map;
+
+@Api(tags = "参与者关系", value = "岗位职责关系关系")
+@Service
+public class PartyPositionUserProvider extends GenericProvider implements IPartyPositionUserService {
+
+    @Resource
+    private PartyPositionUserRepository partyPositionUserRepository;
+
+    @Override
+    public APIResult<Void> save(Map<String,String> data) {
+        APIResult<Void> result = new APIResult<>();
+        if(BeanUtils.isNotEmpty(data.get("oldId"))){
+            //先查询旧的id
+            PartyPositionUserPo poOld = partyPositionUserRepository.get(data.get("oldId"));
+            logger.warn("更新主岗位关联表，数据id:()--->oldId: {}",data.get("oldId"));
+            if(BeanUtils.isNotEmpty(poOld)){
+                //有对应的数据将状态改为普通数据
+                partyPositionUserRepository.upByIdGeneral(data.get("oldId"));
+            }
+        }
+        partyPositionUserRepository.upByIdSpecial(data.get("newId"));
+        logger.warn("更新主岗位关联表，数据id:()--->newId: {}",data.get("newId"));
+        result.setMessage("切换主岗位成功");
+        result.setState(200);
+        return result;
+    }
+}