增加积分商城相关代码

cloud-web-manage/src/main/java/com/yizhi/application/portal/controller/LeaveWordManageController.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.plugins.Page;
 import com.yizhi.core.application.cache.RedisCache;
 import com.yizhi.core.application.cache.RedisCache;
 import com.yizhi.core.application.context.ContextHolder;
 import com.yizhi.core.application.context.ContextHolder;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.context.RequestContext;
+import com.yizhi.point.application.feign.PointFeignClients;
 import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.site.application.feign.api.EventTrackApiClients;
 import com.yizhi.site.application.feign.api.EventTrackApiClients;
 import com.yizhi.training.application.feign.LeaveWordClient;
 import com.yizhi.training.application.feign.LeaveWordClient;
@@ -39,6 +40,8 @@ public class LeaveWordManageController {
 
 
     @Autowired
     @Autowired
     private PointListenerClients pointListenerClients;
     private PointListenerClients pointListenerClients;
+    @Autowired
+    private PointFeignClients pointFeignClients;
 
 
     @Autowired
     @Autowired
     private EventTrackApiClients eventTrackApiClients;
     private EventTrackApiClients eventTrackApiClients;
@@ -108,7 +111,7 @@ public class LeaveWordManageController {
         try {
         try {
             boolean flase =leaveWordClient.updateState(id,state);
             boolean flase =leaveWordClient.updateState(id,state);
             if(false&&state==2){
             if(false&&state==2){
-                pointListenerClients.addPoint("point_comment", id);
+                //pointFeignClients.addPoint(0,"point_comment", id);
             }
             }
             return Response.ok(flase);
             return Response.ok(flase);
         }catch (Exception e){
         }catch (Exception e){

cloud-web-manage/src/main/java/com/yizhi/application/portal/controller/SitePublicationManageController.java

 package com.yizhi.application.portal.controller;
 package com.yizhi.application.portal.controller;
 
 
+import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.plugins.Page;
 import com.baomidou.mybatisplus.plugins.Page;
 import com.yizhi.core.application.cache.RedisCache;
 import com.yizhi.core.application.cache.RedisCache;
@@ -7,6 +8,7 @@ import com.yizhi.core.application.context.ContextHolder;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.enums.InternationalEnums;
 import com.yizhi.core.application.enums.InternationalEnums;
 import com.yizhi.lecturer.application.enums.DeleteFlag;
 import com.yizhi.lecturer.application.enums.DeleteFlag;
+import com.yizhi.point.application.feign.PointFeignClients;
 import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.site.application.feign.PortalManagePCFeignClients;
 import com.yizhi.site.application.feign.PortalManagePCFeignClients;
 import com.yizhi.site.application.feign.PublicationManageFeignClients;
 import com.yizhi.site.application.feign.PublicationManageFeignClients;
@@ -18,6 +20,7 @@ import com.yizhi.util.application.constant.ReturnCode;
 import com.yizhi.util.application.domain.Response;
 import com.yizhi.util.application.domain.Response;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
 import org.slf4j.Logger;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,7 +37,7 @@ import java.util.Objects;
  * @author yanglang
  * @author yanglang
  * @Date: 2024/12/17 16:30
  * @Date: 2024/12/17 16:30
  */
  */
-
+@Slf4j
 @Api(tags = "投稿管理")
 @Api(tags = "投稿管理")
 @RestController
 @RestController
 @RequestMapping("/manage/site/classify/publication")
 @RequestMapping("/manage/site/classify/publication")
@@ -48,6 +51,8 @@ public class SitePublicationManageController {
 
 
     @Autowired
     @Autowired
     private PointListenerClients pointListenerClients;
     private PointListenerClients pointListenerClients;
+    @Autowired
+    private PointFeignClients pointFeignClients;
 
 
     @Autowired
     @Autowired
     private EventTrackApiClients eventTrackApiClients;
     private EventTrackApiClients eventTrackApiClients;
@@ -193,7 +198,12 @@ public class SitePublicationManageController {
     public Response<Boolean> releases(@RequestParam(name = "id") Long id) {
     public Response<Boolean> releases(@RequestParam(name = "id") Long id) {
         boolean flase = publicationManageFeignClients.releases(id);
         boolean flase = publicationManageFeignClients.releases(id);
         if(flase) {
         if(flase) {
-           pointListenerClients.addPoint("point_draft", id);
+            PublicationVo publicationVo = publicationManageFeignClients.publicationView(id);
+            log.info("投稿发布成功,增加积分获取对象:{}", JSONUtil.toJsonStr(publicationVo));
+            if(publicationVo != null) {
+                //pointListenerClients.addPoint("point_draft", id);
+                pointFeignClients.addPoint(publicationVo.getCreateById(), "point_publication", "" + id);
+            }
         }
         }
         return Response.ok(flase);
         return Response.ok(flase);
     }
     }

cloud-web-student/src/main/java/com/yizhi/application/enroll/controller/EnrollApiController.java

@@ -5,6 +5,7 @@ import com.yizhi.core.application.context.ContextHolder;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.enroll.application.feign.EnrollFeignClient;
 import com.yizhi.enroll.application.feign.EnrollFeignClient;
 import com.yizhi.enroll.application.vo.IdEnrollVO;
 import com.yizhi.enroll.application.vo.IdEnrollVO;
+import com.yizhi.point.application.feign.PointApiFeignClients;
 import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.site.application.feign.api.EventTrackApiClients;
 import com.yizhi.site.application.feign.api.EventTrackApiClients;
 import com.yizhi.training.application.feign.TpEnrollPassedClient;
 import com.yizhi.training.application.feign.TpEnrollPassedClient;
@@ -44,6 +45,9 @@ public class EnrollApiController {
 	private PointListenerClients pointListenerClients;
 	private PointListenerClients pointListenerClients;
 
 
 	@Autowired
 	@Autowired
+	private PointApiFeignClients pointApiFeignClients;
+
+	@Autowired
 	private EventTrackApiClients eventTrackApiClients;
 	private EventTrackApiClients eventTrackApiClients;
 	@Autowired
 	@Autowired
 	private RedisCache redisCache;
 	private RedisCache redisCache;
@@ -64,7 +68,8 @@ public class EnrollApiController {
 				return Response.fail("2010", "报名已满", "");
 				return Response.fail("2010", "报名已满", "");
 			}
 			}
 			tpEnrollPassedClient.insertTpStudentEnrollPassed(vo.getId(), id);
 			tpEnrollPassedClient.insertTpStudentEnrollPassed(vo.getId(), id);
-			pointListenerClients.addPoint("CreditClendarDone", id);
+			//pointListenerClients.addPoint("CreditClendarDone", id);
+			pointApiFeignClients.addPoint(requestContext.getAccountId(), "point_activity", ""+id);
 
 
 			// 添加学院报名埋点
 			// 添加学院报名埋点
 			//if(request.getHeader("Cookie")!=null&& Objects.equals(redisCache.get(request.getHeader("Cookie").replace("JSESSIONID=","")),"2")){
 			//if(request.getHeader("Cookie")!=null&& Objects.equals(redisCache.get(request.getHeader("Cookie").replace("JSESSIONID=","")),"2")){