package com.thhy.secure.modules.biz.integralAccount.service.impl;
|
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.thhy.general.common.BasicResult;
|
import com.thhy.general.config.SysUserInfo;
|
import com.thhy.general.utils.ExcelUtils;
|
import com.thhy.general.utils.UUIDUtils;
|
import com.thhy.general.utils.UserInfoUtils;
|
import com.thhy.secure.modules.biz.integralAccount.entity.IntegralAccountEntity;
|
import com.thhy.secure.modules.biz.integralAccount.entity.IntegralDetailEntity;
|
import com.thhy.secure.modules.biz.integralAccount.mapper.IntegralDetailMapper;
|
import com.thhy.secure.modules.biz.integralAccount.service.IntegralDetailService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @Author QiuYuHao
|
* @CreateDate 2023-11-27 18:33:40
|
* 积分超市实现
|
*/
|
@Service
|
public class IntegralDetailServiceImpl implements IntegralDetailService
|
{
|
|
@Autowired
|
private IntegralDetailMapper integralDetailMapper;
|
|
private static final Object Lock= new Object();
|
/**
|
* 积分超市新增和修改
|
* @param integralDetailEntity
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public BasicResult insertAndUpdate(IntegralDetailEntity integralDetailEntity){
|
String id = integralDetailEntity.getId();
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String sysUserId = sysUserInfo.getUserId();
|
String companyId = sysUserInfo.getCompanyId();
|
//扣积分逻辑
|
synchronized (Lock){
|
IntegralAccountEntity integralAccountEntity = IntegralAccountEntity
|
.builder()
|
.userId(integralDetailEntity.getUserId())
|
.updateUser(sysUserId)
|
.updateTime(new Date())
|
.id(UUIDUtils.create())
|
.build();
|
Map map = new HashMap();
|
map.put("userId",integralDetailEntity.getUserId());
|
//查询账户
|
IntegralAccountEntity queryAccount = integralDetailMapper.selectByOne(map);
|
if(queryAccount == null || queryAccount.getTotalIntegral()<integralDetailEntity.getIntegralWater()){//无账户
|
return BasicResult.faild("500","积分不足,无法扣除积分",null);
|
}
|
//有账户
|
Double totalConsumption = queryAccount.getTotalConsumption();//总消耗
|
Double accumulateIntegral = queryAccount.getAccumulateIntegral();//累计积分
|
Double totalIntegral = queryAccount.getTotalIntegral();//当前余额
|
|
integralAccountEntity.setTotalIntegral(totalIntegral-integralDetailEntity.getIntegralWater());
|
integralAccountEntity.setAccumulateIntegral(accumulateIntegral);
|
integralAccountEntity.setTotalConsumption(totalConsumption+integralDetailEntity.getIntegralWater());
|
//修改账户
|
integralDetailMapper.insertAndUpdateAccount(integralAccountEntity);
|
if(id == null){
|
integralDetailEntity.setCompanyId(companyId);
|
integralDetailEntity.setId(UUIDUtils.create());
|
integralDetailEntity.setCreateTime(new Date());
|
integralDetailEntity.setCreateUser(sysUserId);
|
}
|
integralDetailEntity.setBalanc(totalIntegral-integralDetailEntity.getIntegralWater());//拿到当前余额
|
|
integralDetailEntity.setType(2);
|
integralDetailEntity.setIntegralSource("积分超市");
|
//添加或修改明细
|
integralDetailMapper.insertDetailAndUpdate(integralDetailEntity);
|
}
|
return BasicResult.success();
|
}
|
|
/**
|
* 积分超市
|
* @param map
|
* @return
|
*/
|
@Override
|
public BasicResult selectPageList(Map map){
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
int pageNum = (int) map.get("pageNum");
|
int pageSize = (int) map.get("pageSize");
|
PageHelper.startPage(pageNum,pageSize);
|
map.put("companyId",companyId);
|
List<IntegralDetailEntity> integralDetailEntities = integralDetailMapper.selectPageList(map);
|
return BasicResult.success(new PageInfo<>(integralDetailEntities));
|
}
|
|
|
/**
|
* 积分超市删除
|
* @param id
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public BasicResult delete(String id){
|
Map map =new HashMap();
|
map.put("id",id);
|
IntegralDetailEntity integralDetailEntity = integralDetailMapper.selectSafeIntegralInfo(map).get(0);
|
Double integralWater = integralDetailEntity.getIntegralWater();//获取消耗积分
|
Map account = new HashMap();
|
account.put("userId",integralDetailEntity.getUserId());
|
//查询账户
|
IntegralAccountEntity queryAccount = integralDetailMapper.selectByOne(account);
|
|
Double totalConsumption = queryAccount.getTotalConsumption();//总消耗
|
Double accumulateIntegral = queryAccount.getAccumulateIntegral();//累计积分
|
Double totalIntegral = queryAccount.getTotalIntegral();//当前余额
|
synchronized (Lock){
|
IntegralAccountEntity integralAccountEntity = IntegralAccountEntity
|
.builder()
|
.userId(integralDetailEntity.getUserId())
|
.totalConsumption(totalConsumption - integralWater)
|
.accumulateIntegral(accumulateIntegral + integralWater)
|
.totalIntegral(totalIntegral + integralWater)
|
.build();
|
integralDetailMapper.insertAndUpdateAccount(integralAccountEntity);
|
integralDetailMapper.delete(id);
|
}
|
return BasicResult.success();
|
}
|
|
|
/**
|
* 安全积分列表
|
*/
|
@Override
|
public BasicResult selectSafeIntegralPageList(Map map){
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
int pageNum = (int) map.get("pageNum");
|
int pageSize = (int) map.get("pageSize");
|
PageHelper.startPage(pageNum,pageSize);
|
map.put("companyId",companyId);
|
List<IntegralAccountEntity> integralAccountEntities = integralDetailMapper.selectSafeIntegralPageList(map);
|
return BasicResult.success(new PageInfo<>(integralAccountEntities));
|
}
|
|
/**
|
* 安全积分明细
|
* @param map
|
* @return
|
*/
|
@Override
|
public BasicResult selectSafeIntegralInfo(Map map){
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
IntegralAccountEntity integralAccountEntity = integralDetailMapper.selectByOne(map);
|
map.put("integral",integralAccountEntity.getTotalIntegral());
|
int pageNum = (int) map.get("pageNum");
|
int pageSize = (int) map.get("pageSize");
|
PageHelper.startPage(pageNum,pageSize);
|
map.put("companyId",companyId);
|
List<IntegralDetailEntity> integralDetailEntities = integralDetailMapper.selectSafeIntegralInfo(map);
|
map.put("data",new PageInfo<>(integralDetailEntities));
|
return BasicResult.success(map);
|
}
|
|
@Override
|
public void exportList(Map map, HttpServletResponse rsp) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
map.put("companyId",companyId);
|
List<IntegralDetailEntity> integralDetailEntities = integralDetailMapper.selectPageList(map);
|
|
ExcelUtils.downExcel(integralDetailEntities,IntegralDetailEntity.class,rsp,"班组列表");
|
}
|
|
@Override
|
public void exportSafeIntegralInfo(Map map, HttpServletResponse rsp) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
IntegralAccountEntity integralAccountEntity = integralDetailMapper.selectByOne(map);
|
map.put("integral",integralAccountEntity.getTotalIntegral());
|
map.put("companyId",companyId);
|
List<IntegralDetailEntity> integralDetailEntities = integralDetailMapper.selectSafeIntegralInfo(map);
|
ExcelUtils.downExcel(integralDetailEntities,IntegralDetailEntity.class,rsp,"班组列表");
|
}
|
|
}
|
