From 2f11fbaf9d9f3d3cf916096d20d99a11f311968c Mon Sep 17 00:00:00 2001
From: 张天森 <1292933220@qq.com>
Date: 星期三, 12 十月 2022 18:36:48 +0800
Subject: [PATCH] 三说会堂事件流程处理

---
 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComSanRequestVO.java                      |    2 
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComEventMapper.java               |   21 +++++
 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComEventVO.java                           |    2 
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEvent.java                  |    8 +
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComEventMapper.xml                                        |   56 ++++++++++++++
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEventTransferRecord.java    |    2 
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComEventServiceImpl.java |  147 +++++++++++++++++++++++++++++-------
 7 files changed, 203 insertions(+), 35 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComEventVO.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComEventVO.java
index ea2c8ea..a788375 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComEventVO.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComEventVO.java
@@ -151,6 +151,6 @@
 	private Long pageNo;
 	private Long pageSize;
 	private String keyword;
-	@ApiModelProperty(value = "查看类型1用户查看自己的调解事件申请2专家查看自己受理的调解事件")
+	@ApiModelProperty(value = "查看类型1用户查看自己的调解事件申请2专家查看自己受理的调解事件,3后台查看")
 	private Integer userType;
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComSanRequestVO.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComSanRequestVO.java
index ffe9caa..b8354c7 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComSanRequestVO.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/sanshuo/ComSanRequestVO.java
@@ -20,7 +20,7 @@
 
 	/**调解发起人诉求事件描述*/
 	@ApiModelProperty(name = "requestUserEventDes", value = "调解发起人诉求事件描述")
-	@Length(max = 500)
+	@Length(max = 1000)
 	private String requestUserEventDes;
 	/**调解事件类型*/
 	@ApiModelProperty(name = "eventCategory", value = "调解事件类型")
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComEventMapper.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComEventMapper.java
index 59ead79..3014a01 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComEventMapper.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComEventMapper.java
@@ -34,6 +34,13 @@
      * @date   2022-09-07 11:23:51
      */
   IPage<ComEvent> pageByComEvent(@Param("comEvent") ComEvent comEvent, Page pagination);
+  IPage<ComEvent> pageByComEventExpert(@Param("eventIds") List<Long> eventIds,@Param("comEvent") ComEvent comEvent, Page pagination);
+  /**
+   *
+   * 获取专家名下的所有事件id
+   * @param expertId 专家id
+   * */
+   List<Long> listEventIds(Long expertId);
       /**
        * description 三说会堂事件表列表数据
        *
@@ -86,4 +93,18 @@
      * */
     List<EventRateVO> mediateTypeRate();
 
+    /**
+     * 获取用户头像
+     * */
+    String getUserAvatar(Long userId);
+
+    /**
+     * 添加事件-专家对应记录
+     * @param status 流转状态(
+     * 0创建时分配,只有一条记录
+     * 1上报后重新分配
+     * 2拒绝后重新分配
+     * )
+     * */
+    void insertEventAndExpertRecord(@Param("eventId") Long eventId, @Param("expertId") Long experId,@Param("status")Integer status);
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEvent.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEvent.java
index 4479636..e35bd9e 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEvent.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEvent.java
@@ -93,7 +93,7 @@
 	/**工作人员的事件处理状态1待处理2待验证3专家已受理4专家未受理,拒绝5调解中6已结案归档7调解取消*/
 	@ApiModelProperty(name = "eventProcessStatus", value = "工作人员的事件处理状态1待处理2待验证3专家已受理4专家未受理,拒绝5调解中6已结案7已归档8调解取消9已删除")
 	private Integer eventProcessStatus;
-	/**当前处理对象类型(1、行业分中心2、社区3、是街道4、区)*/
+	/**当前处理对象类型(1、行业分中心2、社区3、是街道4、区三说会堂,5专家)*/
 	@ApiModelProperty(name = "currentProcessType", value = "当前处理对象类型(1、行业分中心2、社区3、是街道4、区)")
 	private Integer currentProcessType;
 	/**当前处理机构ID*/
@@ -153,7 +153,7 @@
 	private Long createBy;
 	/**创建时间*/
 	@ApiModelProperty(name = "createAt", value = "创建时间")
-	@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+	@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
 	private Date createAt;
 	/**修改人*/
 	@ApiModelProperty(name = "updateBy", value = "修改人")
@@ -182,4 +182,8 @@
 	@ApiModelProperty("社区id")
 	@TableField(exist = false)
 	private Long communityId;
+	@ApiModelProperty("上报等级,4专家上报到社区,3专家上报到行业分中心,2社区上报到街道,1街道上报到三说会堂5行业分中心上报到三说会堂")
+	private Integer reportLevel;
+	@TableField(exist = false)
+	private Integer isArchive;
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEventTransferRecord.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEventTransferRecord.java
index 4a76c23..fd0aa9a 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEventTransferRecord.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComEventTransferRecord.java
@@ -104,4 +104,6 @@
 	@ApiModelProperty(name = "images", value = "调解上传图片地址列表,逗号进行分割")
 	@TableField(exist = false)
 	private List<ComEventRequestImageVO> images;
+	@ApiModelProperty("上报等级,4专家上报到社区,3专家到行业分中心2社区上报到街道,1街道上报到三说会堂,5行业分中心上报到区三说会堂")
+	private Integer reportLevel;
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComEventServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComEventServiceImpl.java
index db278aa..5bb6de4 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComEventServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComEventServiceImpl.java
@@ -20,6 +20,7 @@
 import com.panzhihua.common.utlis.DateUtils;
 import com.panzhihua.common.utlis.Snowflake;
 import com.panzhihua.common.utlis.StringUtils;
+import com.panzhihua.service_community.api.ComSanShuoEventTransferRecordController;
 import com.panzhihua.service_community.dao.ComActDAO;
 import com.panzhihua.service_community.dao.ComEventMapper;
 import com.panzhihua.service_community.dao.ComStreetDAO;
@@ -78,16 +79,26 @@
 
     @Override
     public R pageByComEvent(ComEvent comEvent, Page pagination,LoginUserInfoVO loginUserInfoVO) {
+        Boolean isExpertCheck=false;
+        Long expertId=null;
         if (nonNull(comEvent.getUserType())){
             if (comEvent.getUserType().equals(1)){
                 //个人账号权限
                 comEvent.setRequestUserId(loginUserInfoVO.getUserId());
             }else if (comEvent.getUserType().equals(2) || loginUserInfoVO.getType().equals(11)){
-                //专家账号权限
-                ComSanshuoExpert expert = comSanShuoExpertService.getOne(new QueryWrapper<ComSanshuoExpert>().lambda().eq(ComSanshuoExpert::getPhone, loginUserInfoVO.getPhone()));
+                ComSanshuoExpert expert=new ComSanshuoExpert();
+                //专家账号权限(小程序和后台)
+                if (nonNull(loginUserInfoVO.getPhone())){
+                    expert = comSanShuoExpertService.getOne(new QueryWrapper<ComSanshuoExpert>().lambda().eq(ComSanshuoExpert::getPhone, loginUserInfoVO.getPhone()));
+                }else{
+                    //账号获取
+                    expert = comSanShuoExpertService.getOne(new QueryWrapper<ComSanshuoExpert>().lambda().eq(ComSanshuoExpert::getAccount, loginUserInfoVO.getAccount()));
+                }
                 comEvent.setUserType(2);
                 if (nonNull(expert)){
                     comEvent.setSpecialistId(expert.getId());
+                    isExpertCheck=true;
+                    expertId=expert.getId();
                 }
             }else if (loginUserInfoVO.getType().equals(12)){
                 //行业分中心权限
@@ -103,7 +114,13 @@
                 comEvent.setCommunityId(loginUserInfoVO.getCommunityId());
             }
         }
-        IPage<ComEvent> list = baseMapper.pageByComEvent(comEvent, pagination);
+        IPage<ComEvent> list=null;
+        if (isExpertCheck){
+            list = comEventMapper.pageByComEventExpert(comEventMapper.listEventIds(expertId), comEvent, pagination);
+        }else{
+            list = baseMapper.pageByComEvent(comEvent, pagination);
+        }
+
         if (list.getRecords().size() < 1) {
             return R.ok(Collections.emptyList());
         }
@@ -111,14 +128,16 @@
             List<ComEventResource> resourceList = comEventResourceService.list(new QueryWrapper<ComEventResource>().lambda().eq(ComEventResource::getRefId, comEvent1.getId()));
             List<ComEventRequestImageVO> comEventRequestImageVO = CopyUtil.deepCopyListObject(resourceList, ComEventRequestImageVO.class);
             comEvent1.setImages(comEventRequestImageVO);
-//            if (nonNull(userService.getUserInfoByUserId(comEvent1.getRequestUserId().toString()).getData().getImageUrl())){
-//                comEvent1.setIcon(userService.getUserInfoByUserId(comEvent1.getRequestUserId().toString()).getData().getImageUrl());
-//            }
+            if (nonNull(userService.getUserInfoByUserId(comEvent1.getRequestUserId().toString()).getData().getImageUrl())){
+                comEvent1.setIcon(userService.getUserInfoByUserId(comEvent1.getRequestUserId().toString()).getData().getImageUrl());
+            }
             ComMediateType category = commediateTypeService.getById(comEvent1.getEventCategory());
             comEvent1.setEventCategoryName(category.getName());
-            ComSanshuoExpert byId = comSanShuoExpertService.getById(comEvent1.getSpecialistId());
-            if (nonNull(byId)){
-                comEvent1.setExpertAvatar(byId.getAvatar());
+            //当前账号能否操作此条记录,根据事件流转记录是否有归档的记录决定当前用户能否对添加归档记录
+            ComEventTransferRecord archiveRecord = comEventTransferRecordService.getOne(new QueryWrapper<ComEventTransferRecord>().lambda().eq(ComEventTransferRecord::getEventId, comEvent1.getId()).eq(ComEventTransferRecord::getFromUserId, loginUserInfoVO.getUserId()).eq(ComEventTransferRecord::getEventStatus, 7));
+            comEvent1.setIsArchive(1);
+            if(nonNull(archiveRecord)){
+                comEvent1.setIsArchive(0);
             }
         });
         return R.ok(list);
@@ -138,18 +157,22 @@
     public R insertComEvent(ComEvent comEvent) {
         ComSanshuoExpert expert = comSanShuoExpertService.getById(comEvent.getSpecialistId());
         if (comEvent.getRequestUserCommunity() != null) {
+            //创建时处理级别都是专家
             ComActDO community = comActDAO.selectById(comEvent.getRequestUserCommunity());
             comEvent.setCurrentOrgName(community.getName());
             comEvent.setCurrentOrgId(community.getCommunityId().toString());
-            comEvent.setCurrentProcessType(2);
+            comEvent.setCurrentProcessType(5);
         }
         if (!StringUtils.isEmpty(comEvent.getCenterId())) {
+            //创建时处理级别都是专家
             ComSanshuoIndustryCenter center = comSanShuoIndustryCenterService.getById(comEvent.getCenterId());
             comEvent.setCurrentOrgName(center.getName());
             comEvent.setCurrentOrgId(center.getId().toString());
-            comEvent.setCurrentProcessType(1);
+            comEvent.setCurrentProcessType(5);
         }
         comEvent.setUserEventStatus(2);
+        //设置为未上报
+        comEvent.setReportLevel(0);
         comEvent.setEventProcessStatus(SanShuoEventStatusEnum.UNDO.getCode());
         comEvent.setSpecialistName(expert.getName());
         comEvent.setOrderSn(DateUtils.getDateFormatString(new Date(), "yyyyMMddHHmmss") + RandomUtils.nextLong(1, 10000));
@@ -161,6 +184,8 @@
         comEvent.setUpdateBy(comEvent.getRequestUserId());
         comEvent.setUpdateAt(new Date());
         boolean flag = save(comEvent);
+        //添加一条对应记录
+        comEventMapper.insertEventAndExpertRecord(comEvent.getId(),expert.getId(),0);
         if (!flag) {
             return R.fail(ReturnMsgConstants.DATA_EXIST);
         }
@@ -223,30 +248,77 @@
         comEvent.setEventSucceed(comEventConciliationVO.getEventSucceed());
         comEvent.setEventResult(comEventConciliationVO.getEventResult());
         comEvent.setReportSuperior(comEventConciliationVO.getReportSuperior());
+        ComEventTransferRecord comEventTransferRecord = new ComEventTransferRecord();
         if(comEventConciliationVO.getEventSucceed().equals(2)){
             comEvent.setEventProcessStatus(6);
         }
         comEvent.setCurrentEventProcessResult(comEventConciliationVO.getCurrentEventProcessResult());
         //如果当前请求,需要上报上级进行处理
         if (comEventConciliationVO.getReportSuperior()) {
-            if (comEvent.getCurrentProcessType() == 2) {
-                //查询街道的账号
-                comEvent.setCurrentProcessType(3);
-                ComActDO comActDO = comActDAO.selectById(comEvent.getCurrentOrgId());
-                comEvent.setCurrentOrgId(comActDO.getStreetId().toString());
-            } else {
-                //查询街道的上级区域账号
-                comEvent.setCurrentProcessType(4);
-                try {
-                    ComStreetDO street = comStreetDAO.selectById(comEvent.getCurrentOrgId());
-                    comEvent.setCurrentOrgId(street.getAreaCode().toString());
-                } catch (Exception e) {
-                    e.printStackTrace();
+            //判断当前的处理级别
+            if (comEvent.getCurrentProcessType() == 5) {
+                //获取专家账号级别决定上报的级别
+                ComSanshuoExpert expert = comSanShuoExpertService.getById(comEvent.getSpecialistId());
+                if (expert.getLevel().equals(4)){
+                    //上报到社区
+                    //查询社区账号,由专家转交到社区
+                    comEvent.setCurrentProcessType(2);
+                    ComActDO comActDO = comActDAO.selectById(expert.getCommunityId());
+                    comEvent.setCurrentOrgId(comActDO.getStreetId().toString());
+                    //生成一次流转记录
+                    comEvent.setCurrentEventProcessResult("专家上报到社区");
+                    comEventTransferRecord.setFromId(comEvent.getSpecialistId());
+                    comEventTransferRecord.setToId(Long.parseLong(comEvent.getCurrentOrgId()));
+                    comEventTransferRecord.setReportLevel(4);
+                    comEvent.setReportLevel(4);
+                }else if (expert.getLevel().equals(2)){
+                    //上报到行业分中心
+                    comEvent.setCurrentProcessType(1);
+                    comEvent.setCurrentOrgId(expert.getIndustryCenterId().toString());
+                    //生成一次流转记录
+                    comEvent.setCurrentEventProcessResult("专家上报到行业分中心");
+                    comEventTransferRecord.setFromId(comEvent.getSpecialistId());
+                    comEventTransferRecord.setToId(expert.getIndustryCenterId());
+                    comEventTransferRecord.setReportLevel(3);
+                    comEvent.setReportLevel(3);
                 }
+            }else if (comEvent.getCurrentProcessType() == 1){
+                //行业分中心上报到区三说会堂
+                comEvent.setCurrentProcessType(4);
+                comEvent.setCurrentOrgId("99999");
+                //生成一次流转记录
+                comEvent.setCurrentEventProcessResult("行业分中心上报到区三说会堂");
+                comEventTransferRecord.setFromId(comEvent.getSpecialistId());
+                comEventTransferRecord.setToId(99999L);
+                comEventTransferRecord.setReportLevel(5);
+                comEvent.setReportLevel(5);
+            }else if(comEvent.getCurrentProcessType() == 2){
+                //社区上报到街道
+                comEvent.setCurrentProcessType(3);
+                //获取街道id
+                ComActDO comActDO = comActDAO.selectOne(new QueryWrapper<ComActDO>().lambda().eq(ComActDO::getCommunityId, comEvent.getRequestUserCommunity()).eq(ComActDO::getAppId, "wx0cef797390444b75"));
+                comEvent.setCurrentOrgId(comActDO.getStreetId().toString());
+                //生成一次流转记录
+                comEvent.setCurrentEventProcessResult("社区报到街道");
+                comEventTransferRecord.setFromId(comEvent.getRequestUserCommunity());
+                comEventTransferRecord.setToId(comActDO.getStreetId());
+                comEventTransferRecord.setReportLevel(2);
+                comEvent.setReportLevel(2);
+            }else if(comEvent.getCurrentProcessType() == 3){
+                //街道上报到区三说会堂
+                comEvent.setCurrentProcessType(4);
+                comEvent.setCurrentOrgId("99999");
+                //生成一次流转记录
+                comEvent.setCurrentEventProcessResult("街道上报到区三说会堂");
+                comEventTransferRecord.setFromId(comEvent.getSpecialistId());
+                comEventTransferRecord.setToId(99999L);
+                comEventTransferRecord.setReportLevel(1);
+                comEvent.setReportLevel(1);
+            }else {
+                //已是最高上报级别,无法上报
             }
         }
         int flag = baseMapper.updateById(comEvent);
-        ComEventTransferRecord comEventTransferRecord = new ComEventTransferRecord();
         comEventTransferRecord.setEventId(comEvent.getId());
         comEventTransferRecord.setSave(true);
         comEventTransferRecord.setProcessResult(comEvent.getCurrentEventProcessResult());
@@ -268,6 +340,14 @@
         saveEventImageList(comEventConciliationVO.getImages(), comEventConciliationVO.getId(),comEventTransferRecord.getId(),4);
         comEventTransferRecordService.insertComEventTransferRecord(comEventTransferRecord);
         return flag > 0 ? R.ok() : R.fail(ReturnMsgConstants.UPDATE_FALSE);
+    }
+
+    /**
+     * 创建上报记录
+     * */
+    public  void createTransferLog(ComEventTransferRecord record) {
+        record.setId(Snowflake.getId());
+        comEventTransferRecordService.insertComEventTransferRecord(record);
     }
 
     @Override
@@ -351,6 +431,8 @@
         comEvent.setSpecialistName(specter.getName());
         comEvent.setEventProcessStatus(SanShuoEventStatusEnum.ACCEPT.getCode());
         int flag = baseMapper.updateById(comEvent);
+        //添加一条对应记录
+        comEventMapper.insertEventAndExpertRecord(id, specialistId,1);
         return flag > 0 ? R.ok() : R.fail(ReturnMsgConstants.UPDATE_FALSE);
     }
 
@@ -369,11 +451,12 @@
     @Transactional(rollbackFor = Exception.class)
     public R archiveRequest(ComEventArchiveVO comEventArchiveVO, LoginUserInfoVO sysUser) {
         ComEvent comEvent = baseMapper.selectById(comEventArchiveVO.getId());
-        if (comEvent.getEventSucceed() == 2) {
-            comEvent.setEventProcessStatus(7);
-        } else {
-            comEvent.setEventProcessStatus(6);
-        }
+        //不再设置已归档状态
+//        if (comEvent.getEventSucceed() == 2) {
+//            comEvent.setEventProcessStatus(7);
+//        } else {
+//            comEvent.setEventProcessStatus(6);
+//        }
         comEvent.setResult(comEventArchiveVO.getResult());
         baseMapper.updateById(comEvent);
         ComEventTransferRecord comEventTransferRecord = new ComEventTransferRecord();
@@ -391,7 +474,9 @@
         comEventTransferRecord.setSpecialistLevel(comEvent.getSpecialistLevel());
         comEventTransferRecord.setSpecialistName(comEvent.getSpecialistName());
         comEventTransferRecord.setEventResult(comEvent.getEventSucceed());
-        comEventTransferRecord.setEventStatus(comEvent.getEventProcessStatus());
+        comEventTransferRecord.setFromUserId(sysUser.getUserId());
+        //归档操作统一设置为7
+        comEventTransferRecord.setEventStatus(7);
         comEventTransferRecord.setId(Snowflake.getId());
         saveEventImageList(comEventArchiveVO.getImages(), comEvent.getId(), comEventTransferRecord.getId(), 5);
         return comEventTransferRecordService.insertComEventTransferRecord(comEventTransferRecord);
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComEventMapper.xml b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComEventMapper.xml
index fb9ab31..ae6adca 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComEventMapper.xml
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComEventMapper.xml
@@ -93,6 +93,56 @@
 		</where>
 		order by create_at desc
 	</select>
+	<select id="pageByComEventExpert" resultType="com.panzhihua.service_community.entity.ComEvent">
+		SELECT <include refid="columns" />
+		FROM com_sanshuo_event_info
+		<where>
+			event_process_status !=9
+			<if test="eventIds != null">
+				AND id in 
+				<foreach collection="eventIds" item="id" separator="," open="(" close=")">
+					#{id}
+				</foreach>
+			</if>
+			<if test="comEvent.keyword != null and comEvent.keyword!=''" >
+				AND	( order_sn = #{comEvent.keyword} or request_user_tel =#{comEvent.keyword} or current_org_name=#{comEvent.keyword})
+			</if>
+			<if test="comEvent.createBy != null and comEvent.createBy!=''" >
+				AND create_by = #{comEvent.createBy}
+			</if>
+			<if test="comEvent.eventCategory != null">
+				AND event_category = #{comEvent.eventCategory}
+			</if>
+			<if test="comEvent.eventProcessStatus != null">
+				AND event_process_status = #{comEvent.eventProcessStatus}
+			</if>
+			<if test="comEvent.orderSn != null">
+				AND order_sn = #{comEvent.orderSn}
+			</if>
+			<if test="comEvent.requestUserTel != null">
+				AND request_user_tel = #{comEvent.requestUserTel}
+			</if>
+			<if test="comEvent.currentOrgName != null">
+				AND current_org_name = #{comEvent.currentOrgName}
+			</if>
+			<!--<if test="comEvent.userType == 1">-->
+				<!--AND request_user_id=#{comEvent.requestUserId}-->
+			<!--</if>-->
+			<!--<if test="comEvent.userType == 2">-->
+				<!--AND specialist_id=#{comEvent.specialistId}-->
+			<!--</if>-->
+			<!--<if test="comEvent.userType == 3">-->
+				<!--AND center_id=#{comEvent.centerId}-->
+			<!--</if>-->
+			<!--<if test="comEvent.userType == 4">-->
+				<!--AND request_user_community=#{comEvent.communityId}-->
+			<!--</if>-->
+		</where>
+		order by create_at desc
+	</select>
+	<select id="listEventIds" resultType="java.lang.Long">
+		select event_id from com_sanshuo_expert_event where expert_id=#{expertId}
+	</select>
 	<select id="listByComEvent" resultType="com.panzhihua.service_community.entity.ComEvent">
 		SELECT <include refid="columns" />
 		FROM com_sanshuo_event_info
@@ -402,5 +452,11 @@
 		group by t.event_category
 	</select>
 
+	<select id="getUserAvatar" resultType="String">
+		select  image_url from sys_user where user_id = #{userId}
+	</select>
+	<select id="insertEventAndExpertRecord">
+		insert into com_sanshuo_expert_event values(#{eventId},#{expertId},#{status})
+	</select>
 
 </mapper>

--
Gitblit v1.7.1