定时任务

src/main/java/com/huiju/estateagents/controller/TaShareActivityController.java

@@ -1,6 +1,7 @@
 package com.huiju.estateagents.controller;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
@@ -164,10 +165,12 @@ public class TaShareActivityController extends BaseController {
      * @param id  实体ID
      */
     @RequestMapping(value="/admin/taShareActivity/{id}",method= RequestMethod.GET)
-    public ResponseBean taShareActivityGet(@PathVariable Integer id){
+    public ResponseBean taShareActivityGet(@PathVariable Integer id, HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
         try {
-            responseBean.addSuccess(iTaShareActivityService.getById(id));
+
+            TaShareActivity taShareActivity = iTaShareActivityService.getById(id);
+            responseBean.addSuccess(taShareActivity);
         }catch (Exception e){
             e.printStackTrace();
             logger.error("taShareActivityDelete -=- {}",e.toString());
@@ -176,6 +179,29 @@ public class TaShareActivityController extends BaseController {
         return responseBean;
     }
 
+    /**
+     *获取用户平均积分
+     */
+    @RequestMapping( value = "/admin/taShareActivity/avgScore", method = RequestMethod.GET)
+    public ResponseBean taShareActivityAgvScore(HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        try{
+            Integer orgId = getOrgId(request);
+            Integer sumPoints = taPersonService.sumPointsByOrgId(orgId);
+            QueryWrapper<TaPerson> taPersonWrapper = new QueryWrapper<>();
+            taPersonWrapper.eq("org_id", orgId);
+            Integer personNum = taPersonService.count(taPersonWrapper);
+            TaShareActivity taShareActivity = new TaShareActivity();
+            taShareActivity.setAverageScore(sumPoints/personNum);
+            responseBean.addSuccess(taShareActivity);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taShareActivityAgvScore -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
     /**
      * 根据id结束拼团活动
      * @param id

src/main/java/com/huiju/estateagents/entity/TaShareActivity.java

@@ -115,4 +115,10 @@ public class TaShareActivity implements Serializable {
      */
     @TableField(exist = false)
     private String groupStatus;
+
+    /**
+     * 用户平均积分
+     */
+    @TableField(exist = false)
+    private Integer averageScore;
 }

src/main/java/com/huiju/estateagents/mapper/TaPersonMapper.java

@@ -189,4 +189,11 @@ public interface TaPersonMapper extends BaseMapper<TaPerson> {
      * @return
      */
     IPage<TaPerson> InviteClientsList(IPage<TaChannel> pg, @Param("id") String id);
+
+    /**
+     * 获取用户总积分
+     * @param orgId
+     * @return
+     */
+    Integer sumPointsByOrgId(@Param("orgId") Integer orgId);
 }

src/main/java/com/huiju/estateagents/service/ITaPersonService.java

@@ -65,7 +65,7 @@ public interface ITaPersonService extends IService<TaPerson> {
 
     String agentCodeGenerator ();
 
-
+    Integer sumPointsByOrgId(Integer orgId);
 
     /**
      * 渠道管理下的经纪人

src/main/java/com/huiju/estateagents/service/impl/TaPersonServiceImpl.java

@@ -740,5 +740,10 @@ public class TaPersonServiceImpl extends ServiceImpl<TaPersonMapper, TaPerson> i
         }
     }
 
+    @Override
+    public Integer sumPointsByOrgId(Integer orgId) {
+        return taPersonMapper.sumPointsByOrgId(orgId);
+    }
+
 
 }

src/main/resources/mapper/TaPersonMapper.xml

@@ -524,4 +524,11 @@ FROM
     <select id="InviteClientsList" resultType="com.huiju.estateagents.entity.TaPerson">
         select * from ta_person WHERE recommend_agent = #{id}
     </select>
+
+    <select id="sumPointsByOrgId" resultType="java.lang.Integer">
+        select sum(points) from ta_person t where 1 = 1
+        <if test="orgId">
+            and t.org_id = #{orgId}
+        </if>
+    </select>
 </mapper>