dev-discount
parent
62b5edea60
commit
f5362ff802
File diff suppressed because one or more lines are too long
@ -0,0 +1,33 @@ |
|||||||
|
package com.hai.service; |
||||||
|
|
||||||
|
/** |
||||||
|
* @serviceName HltMerchantService.java |
||||||
|
* @author Sum1Dream |
||||||
|
* @version 1.0.0 |
||||||
|
* @Description // 测试接口
|
||||||
|
* @createTime 11:46 上午 2021/12/15 |
||||||
|
**/ |
||||||
|
public interface HighTestService { |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author Sum1Dream |
||||||
|
* @name getReadFile.java |
||||||
|
* @Description //读取文件
|
||||||
|
* @Date 5:31 下午 2021/12/16 |
||||||
|
* @Param [] |
||||||
|
* @return void |
||||||
|
*/ |
||||||
|
void getReadFile() throws Exception; |
||||||
|
|
||||||
|
|
||||||
|
/** |
||||||
|
* @Author Sum1Dream |
||||||
|
* @name getUserDiscount.java |
||||||
|
* @Description // 赠送用户卡券
|
||||||
|
* @Date 7:14 下午 2021/12/24 |
||||||
|
* @Param [] |
||||||
|
* @return void |
||||||
|
*/ |
||||||
|
void getUserDiscount(Long id) throws Exception; |
||||||
|
|
||||||
|
} |
||||||
@ -0,0 +1,136 @@ |
|||||||
|
package com.hai.service.impl; |
||||||
|
|
||||||
|
|
||||||
|
import com.hai.common.exception.ErrorCode; |
||||||
|
import com.hai.common.exception.ErrorHelp; |
||||||
|
import com.hai.common.exception.SysCode; |
||||||
|
import com.hai.common.utils.RedisUtil; |
||||||
|
import com.hai.dao.HighUserEtcMapper; |
||||||
|
import com.hai.entity.HighDiscountAgentCode; |
||||||
|
import com.hai.entity.HighUser; |
||||||
|
import com.hai.entity.HighUserEtc; |
||||||
|
import com.hai.service.*; |
||||||
|
|
||||||
|
import org.slf4j.Logger; |
||||||
|
import org.slf4j.LoggerFactory; |
||||||
|
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||||
|
import org.springframework.stereotype.Service; |
||||||
|
import org.springframework.transaction.annotation.Propagation; |
||||||
|
import org.springframework.transaction.annotation.Transactional; |
||||||
|
|
||||||
|
import javax.annotation.Resource; |
||||||
|
import java.io.BufferedReader; |
||||||
|
import java.io.File; |
||||||
|
import java.io.FileReader; |
||||||
|
import java.math.BigDecimal; |
||||||
|
import java.util.Date; |
||||||
|
import java.util.HashMap; |
||||||
|
import java.util.List; |
||||||
|
import java.util.Map; |
||||||
|
|
||||||
|
|
||||||
|
@Service("highTestService") |
||||||
|
public class HighTestServiceImpl implements HighTestService { |
||||||
|
|
||||||
|
private static Logger log = LoggerFactory.getLogger(HighTestService.class); |
||||||
|
|
||||||
|
@Resource |
||||||
|
private HighUserService highUserService; |
||||||
|
|
||||||
|
@Resource |
||||||
|
private HighUserEtcMapper highUserEtcMapper; |
||||||
|
|
||||||
|
@Resource |
||||||
|
private HighDiscountAgentCodeService highDiscountAgentCodeService; |
||||||
|
|
||||||
|
|
||||||
|
@Resource |
||||||
|
private HighDiscountUserRelService highDiscountUserRelService; |
||||||
|
|
||||||
|
@Autowired |
||||||
|
private RedisUtil redisUtil; |
||||||
|
|
||||||
|
@Override |
||||||
|
@Transactional(rollbackFor=Exception.class,propagation= Propagation.REQUIRES_NEW) |
||||||
|
public void getReadFile() throws Exception { |
||||||
|
// BufferedReader bufferedReader = null;
|
||||||
|
//
|
||||||
|
// Map<String , String> mapUser = new HashMap<>();
|
||||||
|
//
|
||||||
|
// //cookie过期时间为7天
|
||||||
|
// int EXPIRE = 3600*24*7;
|
||||||
|
//
|
||||||
|
// List<HighUser> highUsers = highUserService.getListUser(mapUser);
|
||||||
|
//
|
||||||
|
// for (HighUser user: highUsers) {
|
||||||
|
// redisUtil.set(user.getPhone(), user.getPhone(), EXPIRE);
|
||||||
|
// }
|
||||||
|
//
|
||||||
|
// FileReader fileReader = new FileReader("/home/project/hsg/readFile/etccq.txt");
|
||||||
|
// if (fileReader == null) {
|
||||||
|
// throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "读取空数据");
|
||||||
|
// }
|
||||||
|
//
|
||||||
|
// bufferedReader = new BufferedReader(fileReader);
|
||||||
|
// String temp = bufferedReader.readLine();
|
||||||
|
// int i = 0;
|
||||||
|
// while (temp != null) {
|
||||||
|
// i++;
|
||||||
|
// String[] arr = temp.split(";");
|
||||||
|
//
|
||||||
|
// String phone = (String) redisUtil.get(arr[3]);
|
||||||
|
//
|
||||||
|
// if (phone == null || highUsers.size() == 0) {
|
||||||
|
// HighUser user = new HighUser();
|
||||||
|
//
|
||||||
|
// user.setStatus(1);
|
||||||
|
// user.setInfoCompleteStatus(1);
|
||||||
|
// user.setGold(0);
|
||||||
|
// user.setRegTime(new Date());
|
||||||
|
// user.setName(arr[2]);
|
||||||
|
// user.setPhone(arr[3]);
|
||||||
|
// user.setExt4("1");
|
||||||
|
//
|
||||||
|
// highUserService.insertUser(user);
|
||||||
|
//
|
||||||
|
// HighUserEtc userEtc = new HighUserEtc();
|
||||||
|
//
|
||||||
|
// userEtc.setCreateTime(new Date());
|
||||||
|
// userEtc.setStatus(1);
|
||||||
|
// userEtc.setUserId(user.getId());
|
||||||
|
// userEtc.setCustomerName(arr[2]);
|
||||||
|
// userEtc.setCustomerTel(arr[3]);
|
||||||
|
// userEtc.setVehicleId(arr[0]);
|
||||||
|
// userEtc.setVehiclePlate(arr[1]);
|
||||||
|
//
|
||||||
|
// highUserEtcMapper.insert(userEtc);
|
||||||
|
//
|
||||||
|
//// Map<String , Object> map = new HashMap<>();
|
||||||
|
//// map.put("userId" , user.getId());
|
||||||
|
//// map.put("userPhone" , user.getPhone());
|
||||||
|
//// map.put("discountPackageId" , 48);
|
||||||
|
//
|
||||||
|
//// highDiscountPackageService.freeUserDiscountPackage(map);
|
||||||
|
// }
|
||||||
|
//
|
||||||
|
// temp = bufferedReader.readLine();
|
||||||
|
// }
|
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
@Transactional(rollbackFor=Exception.class,propagation= Propagation.REQUIRES_NEW) |
||||||
|
public void getUserDiscount(Long id) throws Exception{ |
||||||
|
List<HighDiscountAgentCode> codeList = highDiscountAgentCodeService.getDiscountCodeByStatus(id , 1); |
||||||
|
Map<String , String> map = new HashMap<>(); |
||||||
|
map.put("ext4" , "1"); |
||||||
|
List<HighUser> userList = highUserService.getListUser(map); |
||||||
|
|
||||||
|
int num = 0; |
||||||
|
for (HighUser user : userList) { |
||||||
|
// 领取优惠券
|
||||||
|
highDiscountUserRelService.receiveDiscount(user.getId(), codeList.get(num).getId()); |
||||||
|
num++; |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
Loading…
Reference in new issue