积分任务

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

@@ -3,6 +3,7 @@ package com.yizhi.application.portal.controller;
 import com.baomidou.mybatisplus.plugins.Page;
 import com.yizhi.core.application.context.ContextHolder;
 import com.yizhi.core.application.context.RequestContext;
+import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.training.application.feign.LeaveWordClient;
 import com.yizhi.training.application.vo.domain.LeaveWordParamVo;
 import com.yizhi.training.application.vo.domain.LeaveWordVo;
@@ -31,6 +32,9 @@ public class LeaveWordManageController {
     @Autowired
     private LeaveWordClient leaveWordClient;
 
+    @Autowired
+    private PointListenerClients pointListenerClients;
+
 
     @PostMapping("/page")
     @ApiOperation(value = "分页查询", notes = "分页查询")
@@ -88,7 +92,11 @@ public class LeaveWordManageController {
     @ApiOperation(value = "修改状态", notes = "修改状态")
     public Response updateState(@ApiParam(name = "id", value = "")@RequestParam(name = "id")Long id,@ApiParam(name = "state", value = "")@RequestParam(name = "state")Integer state){
         try {
-            return Response.ok(leaveWordClient.updateState(id,state));
+            boolean flase =leaveWordClient.updateState(id,state);
+            if(false&&state==2){
+                pointListenerClients.addPoint("point_comment", id);
+            }
+            return Response.ok(flase);
         }catch (Exception e){
             logger.error("修改状态失败");
             return Response.fail(Constants.MSG_BIZ_FAIL);

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

@@ -5,6 +5,7 @@ import com.yizhi.core.application.context.ContextHolder;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.enums.InternationalEnums;
 import com.yizhi.lecturer.application.enums.DeleteFlag;
+import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.site.application.feign.PortalManagePCFeignClients;
 import com.yizhi.site.application.feign.PublicationManageFeignClients;
 import com.yizhi.site.application.vo.domain.ProtalPlateVo;
@@ -40,6 +41,9 @@ public class SitePublicationManageController {
     @Autowired
     private PortalManagePCFeignClients portalManagePCFeignClient;
 
+    @Autowired
+    private PointListenerClients pointListenerClients;
+
     /**
      * 投稿列表
      *
@@ -172,7 +176,13 @@ public class SitePublicationManageController {
         if (vo.getIds() == null || vo.getIds().size() == 0) {
             return Response.fail(InternationalEnums.SITEINFORMATIONMANAGECONTROLLER1.getCode());
         }
-        return Response.ok(publicationManageFeignClients.releases(vo));
+        boolean flase = publicationManageFeignClients.releases(vo);
+        if(flase) {
+            for (Long id : vo.getIds()) {
+                pointListenerClients.addPoint("point_draft", id);
+            }
+        }
+        return Response.ok(flase);
     }
 
     @PostMapping("/unreleases")

cloud-web-student/src/main/java/com/yizhi/application/calendar/StudentCalendarController.java

@@ -6,7 +6,6 @@ import java.util.List;
 import java.util.Map;
 
 import com.baomidou.mybatisplus.plugins.Page;
-import com.yizhi.application.point.constant.MQqueuesEnum;
 import com.yizhi.application.point.constant.PointEventEnum;
 import com.yizhi.calendar.application.feign.StudentCalendarClient;
 import com.yizhi.calendar.application.vo.CalendarRecordVO;
@@ -14,11 +13,9 @@ import com.yizhi.calendar.application.vo.CalendarSignViewVO;
 import com.yizhi.calendar.application.vo.HeadVO;
 import com.yizhi.core.application.context.ContextHolder;
 import com.yizhi.core.application.context.RequestContext;
-import com.yizhi.point.application.feign.PointActivityFeignClients;
 import com.yizhi.point.application.feign.PointListenerClients;
 import com.yizhi.point.application.feign.PointRedisFeignClients;
 import com.yizhi.point.application.vo.PointParamVO;
-import com.yizhi.point.application.vo.domain.PointActivityVo;
 import com.yizhi.util.application.constant.ReturnCode;
 import com.yizhi.util.application.domain.Response;
 import org.slf4j.Logger;
@@ -47,55 +44,12 @@ public class StudentCalendarController {
     private PointRedisFeignClients pointRedisFeignClients;
 
 	@Autowired
-    private PointActivityFeignClients pointActivityFeignClients;
-
-	@Autowired
 	private PointListenerClients pointListenerClients;
 
 	@ApiOperation(value = "新增签到")
 	@GetMapping(value = "/addPoint")
-	public Response<Map<String, Object>> addPoint(@RequestParam("code") String code) {
-		RequestContext res = ContextHolder.get();
-		Long accountId = res.getAccountId();
-		Long siteId = res.getSiteId();
-		String accountName = res.getAccountName();
-		Long companyId = res.getCompanyId();
-		Long orgId = res.getOrgId();
-		try {
-			PointActivityVo vo = pointActivityFeignClients.getActivity(code);
-			if(vo!=null){
-				try {
-					PointParamVO pointParamVO = new PointParamVO();
-					pointParamVO.setEventName(code);    //事件名称
-					pointParamVO.setActivityType(vo.getActivityType());                //事件类型
-					pointParamVO.setActivitySource("PC");                            //学习活动来源
-					pointParamVO.setActivityName(vo.getActivityName());                //学习活动名称
-					pointParamVO.setReleaseCondition("指定积分发放");                    //发放条件
-					pointParamVO.setReleaseRules(vo.getActivityType()+"成功");                    //发放规则
-					pointParamVO.setCreatePointTime(new Date());                            //积分创建时间
-					pointParamVO.setSourceId(vo.getId());                        //积分来源ID，（业务ID主键）
-					pointParamVO.setOperatingPoint(vo.getMultiple());                //积分数量，  正数 加积分，  负数减积分
-					pointParamVO.setAccountId(accountId);        //学员ID
-					pointParamVO.setAccountName(accountName);    //学员名称
-					pointParamVO.setCompanyId(companyId);        //企业ID
-					pointParamVO.setSiteId(siteId);                //站点ID
-					pointParamVO.setOrgId(orgId);                //组织ID
-					String sitePointId = null;
-					if (null != vo.getMultiple() && 0 != vo.getMultiple()) {
-						sitePointId = pointRedisFeignClients.addPointRedis(pointParamVO);    //调用积分接口添加积分
-					}
-					if (null != sitePointId) {
-						pointListenerClients.saveHandPoint(sitePointId);    //发送积分获取消息
-					}
-				} catch (Exception e) {
-					logger.error("签到打卡积分发放失败：", e);
-				}
-			}
-			return Response.ok();
-		} catch (Exception e) {
-			logger.error(accountId + "签到打卡业务处理失败！！！" + e);
-			return Response.fail(ReturnCode.BIZ_FAIL.getCode(),ReturnCode.BIZ_FAIL.getMsg());
-		}
+	public Response<Object> addPoint(@RequestParam("code") String code,@RequestParam("sourceId") Long sourceId) {
+		return Response.ok(pointListenerClients.addPoint(code,sourceId));
 	}
     
     /*@Autowired