Просмотр исходного кода

[会员积分][修改]添加登录或者消费增长积分接口,返回会员等级接口

release_toaliyun_real
masterspirit 7 лет назад
Родитель
Сommit
c96b2b5502
11 измененных файлов: 101 добавлений и 18 удалений
  1. +1
    -0
      mallinkAdmin/src/main/java/com/simple/controller/WxCampaignController.java
  2. +2
    -0
      mallinkService/src/main/java/com/simple/mapper/WxCUserBasicInfoMapper.java
  3. +2
    -0
      mallinkService/src/main/java/com/simple/mapper/WxLevelConfigMapper.java
  4. +10
    -0
      mallinkService/src/main/java/com/simple/service/WxCUserBasicInfoService.java
  5. +7
    -0
      mallinkService/src/main/java/com/simple/service/WxLevelConfigService.java
  6. +9
    -0
      mallinkService/src/main/java/com/simple/service/WxScoreRulesService.java
  7. +6
    -1
      mallinkService/src/main/java/com/simple/service/impl/WxCUserBasicInfoServiceImpl.java
  8. +7
    -8
      mallinkService/src/main/java/com/simple/service/impl/WxLevelConfigServiceImpl.java
  9. +47
    -8
      mallinkService/src/main/java/com/simple/service/impl/WxScoreRulesServiceImpl.java
  10. +6
    -0
      mallinkService/src/main/resources/mapper/WxCUserBasicInfoMapper.xml
  11. +4
    -1
      mallinkService/src/main/resources/mapper/WxLevelConfigMapper.xml

+ 1
- 0
mallinkAdmin/src/main/java/com/simple/controller/WxCampaignController.java Просмотреть файл

@@ -60,6 +60,7 @@ public class WxCampaignController extends BaseController
String[] arys = wxCampaign.getCouponIds().split(",");
wxCampaign.setCouponIds(JSON.toJSONString(arys));
}
wxCampaign.setStatus(0);
wxCampaign.setTenantId(getTenantId());
// wxCampaign.setSortNum(sortNum+1);
wxCampaignService.saveOrUpdate(wxCampaign);


+ 2
- 0
mallinkService/src/main/java/com/simple/mapper/WxCUserBasicInfoMapper.java Просмотреть файл

@@ -14,6 +14,8 @@ public interface WxCUserBasicInfoMapper extends CommonMapper<WxCUserBasicInfo, S

List<WxCUserBasicInfo> list(WxCuerBasicInfoDto record);

void updateScore(WxCUserBasicInfo record);
}

+ 2
- 0
mallinkService/src/main/java/com/simple/mapper/WxLevelConfigMapper.java Просмотреть файл

@@ -11,6 +11,8 @@ public interface WxLevelConfigMapper extends CommonMapper<WxLevelConfig, Long> {
void deleteAll();

String getLevel(@Param("tenantId")String tenantId,@Param("poins")Integer poins);


+ 10
- 0
mallinkService/src/main/java/com/simple/service/WxCUserBasicInfoService.java Просмотреть файл

@@ -41,6 +41,16 @@ public interface WxCUserBasicInfoService {
PageInfo<WxCUserBasicInfo> list(WxCuerBasicInfoDto record, Integer pageIndex, Integer pageSize);

/**
* 修改会员积分
* @param record
*/
void updateScore(WxCUserBasicInfo record);






+ 7
- 0
mallinkService/src/main/java/com/simple/service/WxLevelConfigService.java Просмотреть файл

@@ -39,6 +39,13 @@ public interface WxLevelConfigService {
void deleteAll();
/**
* 根据积分获取会员等级
* @param tenantId
* @param score
* @return
*/
String getLevel(String tenantId,int score);



+ 9
- 0
mallinkService/src/main/java/com/simple/service/WxScoreRulesService.java Просмотреть файл

@@ -37,6 +37,15 @@ public interface WxScoreRulesService {
* @param id
*/
void deleteById(Long id);
/**
* 登录或消费 调用增长积分
* @param tenantId
* @param type 1:登录 2:消费
* @param cUserId
* @return 新增的积分值
*/
int addScoreByType(String tenantId,int type,Long cUserId);



+ 6
- 1
mallinkService/src/main/java/com/simple/service/impl/WxCUserBasicInfoServiceImpl.java Просмотреть файл

@@ -30,9 +30,14 @@ public class WxCUserBasicInfoServiceImpl implements WxCUserBasicInfoService {
return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxCUserBasicInfoMapper.list(record));
}

@Override
public void updateScore(WxCUserBasicInfo record) {
wxCUserBasicInfoMapper.updateScore(record);

}


@Override
@Override
public WxCUserBasicInfo getById(Long id) {
return wxCUserBasicInfoMapper.selectByPrimaryKey(id);
}


+ 7
- 8
mallinkService/src/main/java/com/simple/service/impl/WxLevelConfigServiceImpl.java Просмотреть файл

@@ -49,12 +49,11 @@ public class WxLevelConfigServiceImpl implements WxLevelConfigService {
wxLevelConfigMapper.deleteAll();
}

@Override
public String getLevel(String tenantId, int score) {
return wxLevelConfigMapper.getLevel(tenantId,score);
}


}

+ 47
- 8
mallinkService/src/main/java/com/simple/service/impl/WxScoreRulesServiceImpl.java Просмотреть файл

@@ -3,8 +3,12 @@ package com.simple.service.impl;
import java.util.*;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.simple.domain.po.WxCUser;
import com.simple.domain.po.WxCUserBasicInfo;
import com.simple.domain.po.WxScoreRules;
import com.simple.mapper.WxScoreRulesMapper;
import com.simple.service.WxCUserBasicInfoService;
import com.simple.service.WxCUserService;
import com.simple.service.WxScoreRulesService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -15,6 +19,10 @@ public class WxScoreRulesServiceImpl implements WxScoreRulesService {
@Autowired
WxScoreRulesMapper wxScoreRulesMapper;
@Autowired
WxCUserService wxCUserService;
@Autowired
WxCUserBasicInfoService wxCUserBasicInfoService;


@Override
@@ -43,12 +51,43 @@ public class WxScoreRulesServiceImpl implements WxScoreRulesService {
public void deleteById(Long id) {
wxScoreRulesMapper.deleteByPrimaryKey(id);
}

@Override
public int addScoreByType(String tenantId, int type, Long cUserId) {
int addScoreNumber=0;
WxScoreRules scoreRules = new WxScoreRules();
scoreRules.setTenantId(tenantId);
List<WxScoreRules> list = wxScoreRulesMapper.findList(scoreRules);
if(list.isEmpty()){
return addScoreNumber;
}
scoreRules = list.get(0);

if(type==1){
//login处理
addScoreNumber = scoreRules.getLoginScoreNumber();
}
if(type==2){
//消费
addScoreNumber = scoreRules.getConsumptionScoreNumber();
}
WxCUser wxCUser = wxCUserService.getById(cUserId);
wxCUser.setScore(wxCUser.getScore()+addScoreNumber);
wxCUserService.saveOrUpdate(wxCUser);


//修改basic表积分
if(wxCUser.getPhone()!=null){
//修改basic表积分
WxCUserBasicInfo wxCUserBasicInfo = new WxCUserBasicInfo();
wxCUserBasicInfo.setTenantId(tenantId);
wxCUserBasicInfo.setPhone(wxCUser.getPhone());
wxCUserBasicInfo.setPoins(wxCUser.getScore());
wxCUserBasicInfo.setCUserId(wxCUser.getId());
wxCUserBasicInfoService.updateScore(wxCUserBasicInfo);
}
return addScoreNumber;
}


}

+ 6
- 0
mallinkService/src/main/resources/mapper/WxCUserBasicInfoMapper.xml Просмотреть файл

@@ -132,6 +132,12 @@
</if>
</select>
<update id="updateScore" parameterType="com.simple.domain.po.WxCUserBasicInfo">
update wx_c_user_basic_info set poins=#{poins} where phone=#{phone} and tenant_id=#{tenantId}
and c_user_id=#{cUserId}

</update>



+ 4
- 1
mallinkService/src/main/resources/mapper/WxLevelConfigMapper.xml Просмотреть файл

@@ -63,7 +63,10 @@
<delete id="deleteAll">
delete from wx_level_config;
</delete>

<select id="getLevel" parameterType="com.simple.domain.po.WxLevelConfig" resultType="String">
SELECT `level` FROM `wx_level_config` where tenant_id=#{tenantId} and points &lt;= #{points} ORDER BY points desc LIMIT 1
</select>
</mapper>

Загрузка…
Отмена
Сохранить