设备档案增加授权人列表接口切换成ddd模式

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/api/IAuthorizationService.java

@@ -0,0 +1,22 @@
+package com.lc.ibps.components.equipment.api;
+
+import com.lc.ibps.cloud.entity.APIPageList;
+import com.lc.ibps.cloud.entity.APIRequest;
+import com.lc.ibps.cloud.entity.APIResult;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+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;
+
+
+@Validated
+@RequestMapping(value = "/equipment/authorization")
+@RestController
+public interface IAuthorizationService {
+
+    @RequestMapping(value = "/query", method = RequestMethod.POST)
+    public APIResult<APIPageList<AuthorizationPo>> query(
+            @RequestBody(required = true) APIRequest request);
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/domain/AuthorizationRecord.java

@@ -0,0 +1,46 @@
+package com.lc.ibps.components.equipment.domain;
+
+import com.lc.ibps.base.framework.domain.AbstractDomain;
+import com.lc.ibps.base.framework.persistence.dao.IDao;
+import com.lc.ibps.base.framework.persistence.dao.IQueryDao;
+import com.lc.ibps.components.equipment.persistence.dao.AuthorizationDao;
+import com.lc.ibps.components.equipment.persistence.dao.AuthorizationQueryDao;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+import org.springframework.context.annotation.Scope;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+
+@Service
+@Transactional
+@Scope("prototype")
+public class AuthorizationRecord extends AbstractDomain<String, AuthorizationPo> {
+
+    @Resource
+    private AuthorizationDao authorizationDao;
+    @Resource
+    private AuthorizationQueryDao authorizationQueryDao;
+
+
+    protected void init(){
+        //
+    }
+
+    @Override
+    protected IQueryDao<String, AuthorizationPo> getInternalQueryDao() {
+        return authorizationQueryDao;
+    }
+
+    @Override
+    protected IDao<String, AuthorizationPo> getInternalDao() {
+        return authorizationDao;
+    }
+
+    @Override
+    public String getInternalCacheName() {
+        return "authorizationRecord";
+    }
+
+
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/persistence/dao/AuthorizationDao.java

@@ -0,0 +1,9 @@
+package com.lc.ibps.components.equipment.persistence.dao;
+
+import com.lc.ibps.base.framework.persistence.dao.IDao;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+
+public interface AuthorizationDao extends IDao<String, AuthorizationPo> {
+
+
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/persistence/dao/AuthorizationQueryDao.java

@@ -0,0 +1,7 @@
+package com.lc.ibps.components.equipment.persistence.dao;
+
+import com.lc.ibps.base.framework.persistence.dao.IQueryDao;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+
+public interface AuthorizationQueryDao extends IQueryDao<String, AuthorizationPo> {
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/persistence/dao/impl/AuthorizationDaoImpl.java

@@ -0,0 +1,15 @@
+package com.lc.ibps.components.equipment.persistence.dao.impl;
+
+import com.lc.ibps.base.db.ddd.dao.MyBatisDaoImpl;
+import com.lc.ibps.components.equipment.persistence.dao.AuthorizationDao;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class AuthorizationDaoImpl extends MyBatisDaoImpl<String, AuthorizationPo> implements AuthorizationDao {
+
+    @Override
+    public String getNamespace() {
+        return AuthorizationPo.class.getName();
+    }
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/persistence/dao/impl/AuthorizationQueryDaoImpl.java

@@ -0,0 +1,15 @@
+package com.lc.ibps.components.equipment.persistence.dao.impl;
+
+import com.lc.ibps.base.db.ddd.dao.MyBatisQueryDaoImpl;
+import com.lc.ibps.components.equipment.persistence.dao.AuthorizationQueryDao;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class AuthorizationQueryDaoImpl extends MyBatisQueryDaoImpl<String, AuthorizationPo> implements AuthorizationQueryDao {
+
+    @Override
+    public String getNamespace() {
+        return AuthorizationPo.class.getName();
+    }
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/persistence/entity/AuthorizationPo.java

@@ -0,0 +1,25 @@
+package com.lc.ibps.components.equipment.persistence.entity;
+
+import com.lc.ibps.base.core.util.JacksonUtil;
+import io.swagger.annotations.ApiModel;
+
+import java.util.Collections;
+import java.util.List;
+
+@ApiModel(value = "设备授权人对象")
+public class AuthorizationPo extends AuthorizationTbl{
+
+    public static AuthorizationPo fromJsonString(String data){
+        if(JacksonUtil.isNotJsonObject(data)){
+            return null;
+        }
+        return JacksonUtil.getDTO(data, AuthorizationPo.class);
+    }
+
+    public static List<AuthorizationPo> fromJsonArrayString(String listData){
+        if(JacksonUtil.isNotJsonArray(listData)){
+            return Collections.emptyList();
+        }
+        return JacksonUtil.getDTOList(listData, AuthorizationPo.class);
+    }
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/persistence/entity/AuthorizationTbl.java

@@ -0,0 +1,143 @@
+package com.lc.ibps.components.equipment.persistence.entity;
+
+import com.lc.ibps.base.framework.persistence.entity.AbstractPo;
+import io.swagger.annotations.ApiModelProperty;
+
+public class AuthorizationTbl extends AbstractPo<String> {
+    @ApiModelProperty(value = "主键")
+    protected String  id; 		/*主键*/
+    @ApiModelProperty(value = "外键")
+    protected String  parentId; 		/*外键*/
+    @ApiModelProperty(value = "租户ID")
+    protected String  tenantId; 		/*租户ID*/
+    @ApiModelProperty(value = "IP地址")
+    protected String  ip; 		/*IP地址*/
+    @ApiModelProperty(value = "是否过审")
+    protected String  shiFouGuoShen; 		/*是否过审*/
+    @ApiModelProperty(value = "编制人")
+    protected String  bianZhiRen; 		/*编制人*/
+    @ApiModelProperty(value = "编制部门")
+    protected String  bianZhiBuMen; 		/*编制部门*/
+    @ApiModelProperty(value = "编制时间")
+    protected String  bianZhiShiJian; 		/*编制时间*/
+    @ApiModelProperty(value = "姓名")
+    protected String  xingMing; 		/*名称*/
+    @ApiModelProperty(value = "岗位")
+    protected String  gangWei; 		/*规格型号*/
+    @ApiModelProperty(value = "岗位名称")
+    protected String  gangWeiMingCheng; 		/*单位*/
+    @ApiModelProperty(value = "员工编号")
+    protected String  yuanGongBianHao; 		/*数量*/
+    @ApiModelProperty(value = "人员名称")
+    protected String  renYuanMing; 		/*数量*/
+
+    @Override
+    public String getId() {
+        return id;
+    }
+
+    @Override
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getParentId() {
+        return parentId;
+    }
+
+    public void setParentId(String parentId) {
+        this.parentId = parentId;
+    }
+
+    @Override
+    public String getTenantId() {
+        return tenantId;
+    }
+
+    @Override
+    public void setTenantId(String tenantId) {
+        this.tenantId = tenantId;
+    }
+
+    @Override
+    public String getIp() {
+        return ip;
+    }
+
+    @Override
+    public void setIp(String ip) {
+        this.ip = ip;
+    }
+
+    public String getShiFouGuoShen() {
+        return shiFouGuoShen;
+    }
+
+    public void setShiFouGuoShen(String shiFouGuoShen) {
+        this.shiFouGuoShen = shiFouGuoShen;
+    }
+
+    public String getBianZhiRen() {
+        return bianZhiRen;
+    }
+
+    public void setBianZhiRen(String bianZhiRen) {
+        this.bianZhiRen = bianZhiRen;
+    }
+
+    public String getBianZhiBuMen() {
+        return bianZhiBuMen;
+    }
+
+    public void setBianZhiBuMen(String bianZhiBuMen) {
+        this.bianZhiBuMen = bianZhiBuMen;
+    }
+
+    public String getBianZhiShiJian() {
+        return bianZhiShiJian;
+    }
+
+    public void setBianZhiShiJian(String bianZhiShiJian) {
+        this.bianZhiShiJian = bianZhiShiJian;
+    }
+
+    public String getXingMing() {
+        return xingMing;
+    }
+
+    public void setXingMing(String xingMing) {
+        this.xingMing = xingMing;
+    }
+
+    public String getGangWei() {
+        return gangWei;
+    }
+
+    public void setGangWei(String gangWei) {
+        this.gangWei = gangWei;
+    }
+
+    public String getGangWeiMingCheng() {
+        return gangWeiMingCheng;
+    }
+
+    public void setGangWeiMingCheng(String gangWeiMingCheng) {
+        this.gangWeiMingCheng = gangWeiMingCheng;
+    }
+
+    public String getYuanGongBianHao() {
+        return yuanGongBianHao;
+    }
+
+    public void setYuanGongBianHao(String yuanGongBianHao) {
+        this.yuanGongBianHao = yuanGongBianHao;
+    }
+
+    public String getRenYuanMing() {
+        return renYuanMing;
+    }
+
+    public void setRenYuanMing(String renYuanMing) {
+        this.renYuanMing = renYuanMing;
+    }
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/provider/AuthorizationProvider.java

@@ -0,0 +1,44 @@
+package com.lc.ibps.components.equipment.provider;
+
+
+import com.lc.ibps.api.base.constants.StateEnum;
+import com.lc.ibps.api.base.query.QueryFilter;
+import com.lc.ibps.cloud.entity.APIPageList;
+import com.lc.ibps.cloud.entity.APIRequest;
+import com.lc.ibps.cloud.entity.APIResult;
+import com.lc.ibps.cloud.provider.GenericProvider;
+import com.lc.ibps.components.equipment.api.IAuthorizationService;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+import com.lc.ibps.components.equipment.repository.EquipmentAuthorizationRepository;
+import io.swagger.annotations.Api;
+import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+
+@Api(tags = "设备授权", value = "设备授权")
+@Service
+public class AuthorizationProvider extends GenericProvider implements IAuthorizationService {
+
+    @Resource
+    private EquipmentAuthorizationRepository equipmentAuthorizationRepository;
+
+
+    @Override
+    public APIResult<APIPageList<AuthorizationPo>> query(
+            @RequestBody(required = true) APIRequest request) {
+        APIResult<APIPageList<AuthorizationPo>> result = new APIResult<>();
+        try{
+            QueryFilter queryFilter = getQueryFilter(request);
+            List<AuthorizationPo> list = equipmentAuthorizationRepository.query(queryFilter);
+            APIPageList<AuthorizationPo> apiPageData = getAPIPageList(list);
+            result.setData(apiPageData);
+        }catch (Exception e){
+            setExceptionResult(result, StateEnum.ERROR.getCode(), StateEnum.ERROR.getText(), e);
+        }
+        return result;
+    }
+
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/repository/EquipmentAuthorizationRepository.java

@@ -0,0 +1,9 @@
+package com.lc.ibps.components.equipment.repository;
+
+import com.lc.ibps.base.framework.repository.IRepository;
+import com.lc.ibps.components.equipment.domain.AuthorizationRecord;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+
+public interface EquipmentAuthorizationRepository extends IRepository<String, AuthorizationPo, AuthorizationRecord> {
+
+}

ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/components/equipment/repository/impl/EquipmentAuthorizationRepositoryImpl.java

@@ -0,0 +1,45 @@
+package com.lc.ibps.components.equipment.repository.impl;
+
+import com.lc.ibps.base.core.util.AppUtil;
+import com.lc.ibps.base.framework.persistence.dao.IQueryDao;
+import com.lc.ibps.base.framework.repository.AbstractRepository;
+import com.lc.ibps.components.equipment.domain.AuthorizationRecord;
+import com.lc.ibps.components.equipment.domain.EquipmentCard;
+import com.lc.ibps.components.equipment.persistence.dao.AuthorizationQueryDao;
+import com.lc.ibps.components.equipment.persistence.dao.EquipmentCardQueryDao;
+import com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo;
+import com.lc.ibps.components.equipment.persistence.entity.EquipmentCardPo;
+import com.lc.ibps.components.equipment.repository.EquipmentAuthorizationRepository;
+import org.springframework.stereotype.Repository;
+
+import javax.annotation.Resource;
+
+@Repository
+public class EquipmentAuthorizationRepositoryImpl extends AbstractRepository<String, AuthorizationPo, AuthorizationRecord> implements EquipmentAuthorizationRepository {
+
+    @Resource
+    private AuthorizationQueryDao authorizationQueryDao;
+
+    public AuthorizationRecord newInstance() {
+        AuthorizationPo po = new AuthorizationPo();
+        AuthorizationRecord authorizationRecord = AppUtil.getBean(AuthorizationRecord.class);
+        authorizationRecord.setData(po);
+        return authorizationRecord;
+    }
+
+    public AuthorizationRecord newInstance(AuthorizationPo po) {
+        AuthorizationRecord equipmentCard = AppUtil.getBean(AuthorizationRecord.class);
+        equipmentCard.setData(po);
+        return equipmentCard;
+    }
+
+    @Override
+    protected IQueryDao<String, AuthorizationPo> getQueryDao() {
+        return authorizationQueryDao;
+    }
+
+    @Override
+    public String getInternalCacheName() {
+        return "authorizationRecord";
+    }
+}

ibps-provider-root/modules/provider-business/src/main/resources/com/lc/ibps/equipment/persistence/mapping/Authorization.map.xml.xml

@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo">
+    <!--<cache type="net.oschina.j2cache.mybatis.J2CacheAdapter"/>-->
+    <resultMap id="AuthorizationPo" type="com.lc.ibps.components.equipment.persistence.entity.AuthorizationPo">
+        <id property="id" column="ID_" jdbcType="VARCHAR"/>
+        <result property="parentId" column="PARENT_ID_" jdbcType="VARCHAR"/>
+        <result property="tenantId" column="TENANT_ID_" jdbcType="VARCHAR"/>
+        <result property="ip" column="IP_" jdbcType="VARCHAR"/>
+        <result property="createBy" column="CREATE_BY_" jdbcType="VARCHAR"/>
+        <result property="createTime" column="CREATE_TIME_" jdbcType="TIMESTAMP"/>
+        <result property="updateBy" column="UPDATE_BY_" jdbcType="VARCHAR"/>
+        <result property="updateTime" column="UPDATE_TIME_" jdbcType="TIMESTAMP"/>
+        <result property="bianZhiRen" column="BIAN_ZHI_REN_" jdbcType="VARCHAR"/>
+        <result property="bianZhiBuMen" column="BIAN_ZHI_BU_MEN_" jdbcType="VARCHAR"/>
+        <result property="bianZhiShiJian" column="BIAN_ZHI_SHI_JIAN" jdbcType="VARCHAR"/>
+        <result property="shiFouGuoShen" column="SHI_FOU_GUO_SHEN_" jdbcType="VARCHAR"/>
+        <result property="xingMing" column="xing_ming_" jdbcType="VARCHAR"/>
+        <result property="gangWei" column="gang_wei_" jdbcType="VARCHAR"/>
+        <result property="gangWeiMingCheng" column="gang_wei_ming_che" jdbcType="VARCHAR"/>
+        <result property="yuanGongBianHao" column="yuan_gong_bian_ha" jdbcType="VARCHAR"/>
+        <result property="renYuanMing" column="ren_yuan_ming_" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <select id="query" parameterType="java.util.Map" resultMap="AuthorizationPo">
+        SELECT  a.bian_zhi_shi_jian, b.xing_ming_,  b.ren_yuan_ming_, e.positions_ as bian_zhi_bu_men_
+        FROM t_sbsysqb a
+        JOIN t_sbsysqryb b ON a.id_ = b.parent_id_
+        JOIN ibps_party_employee e ON b.xing_ming_ = e.id_
+        <where>
+        a.shi_fou_guo_shen_ = '已完成'
+            <if test="@o.Ognl@isNotEmpty(whereSql)">
+              AND  ${whereSql}
+            </if>
+        </where>
+        GROUP BY a.id_, b.id_, e.id_
+        union all
+        select l.bian_zhi_shi_jian,l.bei_shou_quan_ren as xing_ming_,e.name_ as ren_yuan_ming_,	e.positions_ AS bian_zhi_bu_men_ from t_lhrynlqr l
+        JOIN ibps_party_employee e ON l.bei_shou_quan_ren = e.id_
+        LEFT JOIN ibps_party_position p ON FIND_IN_SET( p.id_, e.positions_ )
+        <where>
+        l.shi_fou_guo_shen_ = '已完成'
+            <if test="@o.Ognl@isNotEmpty(she_bei_ming_chen)">
+             AND   l.shou_quan_shi_yon LIKE CONCAT('%', #{she_bei_ming_chen}, '%')
+            </if>
+        </where>
+    </select>
+
+
+</mapper>