积分

src/main/java/com/huiju/estateagents/common/CommConstant.java

@@ -124,6 +124,21 @@ public class CommConstant {
      */
     public final static String POINTS_CHANGE_DOCUMENT_VERIFY = "document_verify";
 
+    /**
+     * 业主审核通过
+     */
+    public final static String POINTS_USER_VERIFY = "user_verify";
+
+    /**
+     * 工单评价加积分
+     */
+    public final static String POINTS_TICKET_EVALUATION = "ticket_evaluation";
+
+    /**
+     * 缴费加积分
+     */
+    public final static String POINTS_PAYMENT = "payment";
+
     /**
      * 活动签到
      */

src/main/java/com/huiju/estateagents/event/EventBus.java

@@ -42,7 +42,16 @@ public class EventBus extends ApplicationEvent {
 		DocumentVerify(7),
 
 		// 普通活动扫码签到
-		ActivityCheckin(8);
+		ActivityCheckin(8),
+
+		// 业主审核通过
+		UserVerify(9),
+
+		// 评价成功加积分
+		TicketEvaluation(10),
+
+		// 缴费成功加积分
+		payment(11);
 
 		private Integer type;
 

src/main/java/com/huiju/estateagents/event/EventLisenter.java

@@ -1,11 +1,16 @@
 package com.huiju.estateagents.event;
 
 import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.property.model.BillInvoice;
+import com.huiju.estateagents.property.model.BillStatement;
+import com.huiju.estateagents.property.model.TaUserVerify;
+import com.huiju.estateagents.property.model.TpTicket;
 import com.huiju.estateagents.service.ITaPointsRecordsService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
+import sun.security.krb5.internal.Ticket;
 
 /**
  * @author FXF
@@ -52,11 +57,32 @@ public class EventLisenter {
 				break;
 			case ActivityCheckin:
 				getActivityCheckin((TaActivityDynamicEnlist) event.getSource(), event.getOrgId());
+			// 业主认证审核通过
+			case UserVerify:
+				getUserVerify((TaUserVerify) event.getSource(), event.getOrgId());
+			// 工单评价加积分
+			case TicketEvaluation:
+				getTicketEvaluation((TpTicket) event.getSource(), event.getOrgId());
+			// 缴费成功加积分
+			case payment:
+				getPayment((BillInvoice) event.getSource(), event.getOrgId());
 			default:
 				break;
 		}
 	}
 
+	private void getPayment(BillInvoice source, Integer orgId) {
+		taPointsRecordsService.payment(source,orgId);
+	}
+
+	private void getTicketEvaluation(TpTicket source, Integer orgId) {
+		taPointsRecordsService.ticketEvaluationPoints(source,orgId);
+	}
+
+	private void getUserVerify(TaUserVerify source, Integer orgId) {
+		taPointsRecordsService.userVerifyPoints(source, orgId);
+	}
+
 	// 普通活动扫码签到
 	private void getActivityCheckin(TaActivityDynamicEnlist source, Integer orgId) {
 		taPointsRecordsService.checkinActivityPoints(source,orgId);

src/main/java/com/huiju/estateagents/property/controller/SocialController.java

@@ -19,6 +19,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+
 /**
  * @author weichaochao11
  * @Title: SocialController
@@ -62,4 +64,16 @@ public class SocialController extends BaseController {
         return announcementList;
     }
 
+
+    @ApiOperation(value = "评价工单内容以及评分", notes = "评价工单内容以及评分")
+    @ApiImplicitParams({@ApiImplicitParam(paramType = "path", dataType = "integer", name = "orgId", value = "小区Id"),
+            @ApiImplicitParam(name = "parameter", value = "score 评分, comment 评语 ", required = true, dataType = "String"),
+            @ApiImplicitParam(paramType = "query", dataType = "integer", name = "ticketId", value = "工单Id")})
+    @RequestMapping(value = "/wx/accessTicket/{orgId}", method = RequestMethod.POST)
+    public ResponseBean accessTicket(@PathVariable("orgId") Integer orgId, @RequestBody String parameter, @RequestParam("ticketId") String ticketId, HttpServletRequest request) {
+        ResponseBean responseBean = new ResponseBean();
+        TpTicket tpTicket = JSONObject.parseObject(parameter,TpTicket.class);
+        socialServiceI.accessTicket(orgId, tpTicket, ticketId, getPersonId(request));
+        return responseBean;
+    }
 }

src/main/java/com/huiju/estateagents/property/service/SocialServiceI.java

@@ -37,4 +37,12 @@ public interface SocialServiceI {
 	 * @return
 	 */
 	ResponseBean getAnnouncements(Integer orgId, String title, Integer pageNum, Integer pageSize);
+
+	/**
+	 * 评价工单以及评分
+	 * @param orgId
+	 * @param tpTicket
+	 * @param ticketId
+	 */
+    void accessTicket(Integer orgId, TpTicket tpTicket, String ticketId, String personId);
 }

src/main/java/com/huiju/estateagents/property/service/impl/SocialServiceImpl.java

@@ -9,6 +9,8 @@ import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.center.taUser.entity.TaUser;
 import com.huiju.estateagents.center.taUser.mapper.TaUserMapper;
 import com.huiju.estateagents.center.taUser.service.ITaUserService;
+import com.huiju.estateagents.event.EventBus;
+import com.huiju.estateagents.mapper.TaPersonMapper;
 import com.huiju.estateagents.property.common.Constant;
 import com.huiju.estateagents.property.common.UserElement;
 import com.huiju.estateagents.property.dao.*;
@@ -22,6 +24,7 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
 
 import java.io.IOException;
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -43,6 +46,18 @@ public class SocialServiceImpl implements SocialServiceI {
     @Autowired
     private TdImagesMapper tdImagesMapper;
 
+    @Autowired
+    private TpTicketMapper tpTicketMapper;
+
+    @Autowired
+    private TpTicketRecordMapper tpTicketRecordMapper;
+
+    @Autowired
+    private TaPersonMapper taPersonMapper;
+
+    @Autowired
+    private ApplicationContext applicationContext;
+
     @Override
     @Transactional
     public TpAnnouncement findAnnouncementDetail(Integer id, Integer orgId, Integer userId) {
@@ -86,6 +101,37 @@ public class SocialServiceImpl implements SocialServiceI {
         return responseBean;
     }
 
+    /**
+     * 评价工单以及评分
+     *
+     * @param orgId
+     * @param tpTicket
+     * @param ticketId
+     * @param personId
+     */
+    @Override
+    public void accessTicket(Integer orgId, TpTicket tpTicket, String ticketId, String personId) {
+
+        //修改工单内容和评分
+        tpTicket.setId(Integer.valueOf(ticketId));
+        tpTicket.setStatus("5");
+        tpTicketMapper.updateById(tpTicket);
+        //根据1.4版本需要被终止时，清空当前工单受理人
+        tpTicketMapper.updateTpUserId(Integer.valueOf(ticketId));
+        //工单处理表新增评分记录
+        TpTicketRecord record = new TpTicketRecord();
+        record.setOrgId(orgId);
+        record.setTicketId(Integer.valueOf(ticketId));
+        record.setStatus("5");
+        record.setContent(tpTicket.getComment());
+        record.setCreateUser(personId);
+        record.setCreateDate(LocalDateTime.now());
+        tpTicketRecordMapper.insert(record);
+
+        TpTicket tic = tpTicketMapper.selectById(Integer.valueOf(ticketId));
+        // 评价成功加积分
+        applicationContext.publishEvent(new EventBus(tic, EventBus.EventType.DocumentVerify,1));
+    }
 
 
     /**

src/main/java/com/huiju/estateagents/property/service/impl/TaUserVerifyServiceImpl.java

@@ -9,6 +9,7 @@ import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.center.taUser.entity.TaUser;
 import com.huiju.estateagents.center.taUser.mapper.TaUserMapper;
 import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.event.EventBus;
 import com.huiju.estateagents.mapper.TaPersonMapper;
 import com.huiju.estateagents.property.common.Constant;
 import com.huiju.estateagents.property.common.UserElement;
@@ -21,6 +22,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.ss.formula.functions.T;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -69,6 +71,9 @@ public class TaUserVerifyServiceImpl extends ServiceImpl<TaUserVerifyMapper, TaU
     @Autowired
     private MessageMapper tpmessageMapper;
 
+    @Autowired
+    private ApplicationContext applicationContext;
+
     @Override
     public ResponseBean selectAll(String phone, String userName, String idCard, Integer pageNum, Integer pageSize, TaUser userElement) {
         ResponseBean responseBean = new ResponseBean();
@@ -126,6 +131,11 @@ public class TaUserVerifyServiceImpl extends ServiceImpl<TaUserVerifyMapper, TaU
         userVerify.setVerifyName(user.getUserName());
         taUserVerifyMapper.updateById(userVerify);
 
+        if (Constant.APPROVED.equals(status)){
+            // 审核通过加20积分
+            applicationContext.publishEvent(new EventBus(userVerify, EventBus.EventType.DocumentVerify,1));
+        }
+
         String[] messageArr= new messagePush().messagePushAll( );
         for (String count : messageArr) {
             Message message = new Message();

src/main/java/com/huiju/estateagents/property/service/impl/WxPayServiceImpl.java

@@ -14,6 +14,7 @@ import com.huiju.estateagents.common.wxpay.WXPayUtil;
 import com.huiju.estateagents.common.wxpay.WxConfig;
 import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.entity.TaWxPayConfig;
+import com.huiju.estateagents.event.EventBus;
 import com.huiju.estateagents.mapper.TaPersonMapper;
 import com.huiju.estateagents.mapper.TaWxPayConfigMapper;
 import com.huiju.estateagents.property.common.Constant;
@@ -248,6 +249,8 @@ public class WxPayServiceImpl implements WxPayServiceI {
 			// 缴费方式  0：微信支付  1：线下缴费 2.支付宝支付
 			tpBillInvoice.setPayType(resultMap.get("pay_type"));
 			tpBillInvoiceMapper.updateById(tpBillInvoice);
+			// 同时加积分
+			applicationContext.publishEvent(new EventBus(tpBillInvoice, EventBus.EventType.payment,1));
 
 			//插入流水账单表
 			BillStatement tpBillStatement = new BillStatement();

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

@@ -3,6 +3,10 @@ package com.huiju.estateagents.service;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.property.model.BillInvoice;
+import com.huiju.estateagents.property.model.BillStatement;
+import com.huiju.estateagents.property.model.TaUserVerify;
+import com.huiju.estateagents.property.model.TpTicket;
 
 /**
  * <p>
@@ -71,4 +75,25 @@ public interface ITaPointsRecordsService extends IService<TaPointsRecords> {
 	void saveGroupRecord(TaPerson person, Integer integral, String buildingId, Integer groupActivityId);
 
 	Integer sumPointByPersonId(String personId);
+
+	/**
+	 * 业主审核通过 
+	 * @param source
+	 * @param orgId
+	 */
+	void userVerifyPoints(TaUserVerify source, Integer orgId);
+
+	/**
+	 * 工单评价加积分
+	 * @param source
+	 * @param orgId
+	 */
+    void ticketEvaluationPoints(TpTicket source, Integer orgId);
+
+	/**
+	 * 缴费加积分
+	 * @param source
+	 * @param orgId
+	 */
+	void payment(BillInvoice source, Integer orgId);
 }

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

@@ -13,6 +13,11 @@ import com.huiju.estateagents.entity.*;
 import com.huiju.estateagents.mapper.TaPersonMapper;
 import com.huiju.estateagents.mapper.TaPointsRecordsMapper;
 import com.huiju.estateagents.mapper.TdPointsRulesMapper;
+import com.huiju.estateagents.property.dao.TaUserVerifyMapper;
+import com.huiju.estateagents.property.model.BillInvoice;
+import com.huiju.estateagents.property.model.BillStatement;
+import com.huiju.estateagents.property.model.TaUserVerify;
+import com.huiju.estateagents.property.model.TpTicket;
 import com.huiju.estateagents.service.ITaPointsRecordsService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -41,6 +46,9 @@ public class TaPointsRecordsServiceImpl extends ServiceImpl<TaPointsRecordsMappe
     @Autowired
     private TaPointsRecordsMapper taPointsRecordsMapper;
 
+    @Autowired
+    private TaUserVerifyMapper taUserVerifyMapper;
+
     /**
      * 获取规则积分, 0 代表未启用
      *
@@ -434,4 +442,92 @@ public class TaPointsRecordsServiceImpl extends ServiceImpl<TaPointsRecordsMappe
     public Integer sumPointByPersonId(String personId) {
         return taPointsRecordsMapper.sumPointByPersonId(personId);
     }
+
+    /**
+     * 业主审核通过
+     *
+     * @param userVerify
+     * @param orgId
+     */
+    @Override
+    public void userVerifyPoints(TaUserVerify userVerify, Integer orgId) {
+        //
+        String changeType = CommConstant.POINTS_USER_VERIFY;
+        // 是否开启积分规则
+        Integer pointsAmount = getRulePoints(changeType, orgId);
+        if (pointsAmount == 0) {
+            return;
+        }
+
+        // 已经领取过的不会再次领取
+        boolean hasJoined = isPointsRecordsExist(userVerify.getPersonId(), changeType, null);
+        if (hasJoined) {
+            return;
+        }
+
+        // 发放积分
+        TaPerson person = taPersonMapper.selectById(userVerify.getPersonId());
+        if (savePoints(person, changeType, null, pointsAmount, orgId)) {
+            taPersonMapper.setPointsIncrement(person.getPersonId(), pointsAmount);
+        }
+    }
+
+    /**
+     * 工单评价加积分
+     *
+     * @param source
+     * @param orgId
+     */
+    @Override
+    public void ticketEvaluationPoints(TpTicket source, Integer orgId) {
+        //
+        String changeType = CommConstant.POINTS_TICKET_EVALUATION;
+        // 是否开启积分规则
+        Integer pointsAmount = getRulePoints(changeType, orgId);
+        if (pointsAmount == 0) {
+            return;
+        }
+
+        // 已经领取过的不会再次领取
+        boolean hasJoined = isPointsRecordsExist(source.getPersonId(), changeType, null);
+        if (hasJoined) {
+            return;
+        }
+
+        // 发放积分
+        TaPerson person = taPersonMapper.selectById(source.getPersonId());
+        if (savePoints(person, changeType, null, pointsAmount, orgId)) {
+            taPersonMapper.setPointsIncrement(person.getPersonId(), pointsAmount);
+        }
+    }
+
+    /**
+     * 缴费加积分
+     *
+     * @param source
+     * @param orgId
+     */
+    @Override
+    public void payment(BillInvoice source, Integer orgId) {
+        //
+        String changeType = CommConstant.POINTS_PAYMENT;
+        // 是否开启积分规则
+        Integer pointsAmount = getRulePoints(changeType, orgId);
+        if (pointsAmount == 0) {
+            return;
+        }
+        // 缴费金额乘以积分加积分
+        Integer roomNoId = source.getRoomNoId();
+        QueryWrapper<TaUserVerify> taUserVerifyQueryWrapper = new QueryWrapper<>();
+        taUserVerifyQueryWrapper.eq("room_no_id",roomNoId);
+        taUserVerifyQueryWrapper.eq("verify_status",1);
+        TaUserVerify taUserVerify = taUserVerifyMapper.selectOne(taUserVerifyQueryWrapper);
+
+        int money = source.getPayPrice() / 100;
+        // 发放积分
+        TaPerson person = taPersonMapper.selectById(taUserVerify.getPersonId());
+        if (savePoints(person, changeType, null, pointsAmount * money, orgId)) {
+            taPersonMapper.setPointsIncrement(person.getPersonId(), pointsAmount);
+        }
+    }
 }