package com.taoke.autopay.controller.admin.credit;
|
|
import com.google.gson.Gson;
|
import com.google.gson.GsonBuilder;
|
import com.google.gson.TypeAdapter;
|
import com.google.gson.stream.JsonReader;
|
import com.google.gson.stream.JsonWriter;
|
import com.taoke.autopay.dao.credit.CreditExchangeRecordMapper;
|
import com.taoke.autopay.entity.credit.CreditExchangeRecord;
|
import com.taoke.autopay.exception.UserCreditExchangeException;
|
import com.taoke.autopay.manager.UserCreditExchangeManager;
|
import com.taoke.autopay.service.credit.CreditExchangeRecordService;
|
import com.taoke.autopay.utils.JsonUtil;
|
import com.taoke.autopay.utils.StringUtil;
|
import com.taoke.autopay.utils.TimeUtil;
|
import com.taoke.autopay.vo.admin.UserCreditExchangeRecordSearchVO;
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import javax.annotation.Resource;
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
|
@Controller
|
@RequestMapping("/admin/api/credit/exchange-record")
|
public class UserCreditExchangeRecordAdminController {
|
|
@Resource
|
private UserCreditExchangeManager userCreditExchangeManager;
|
|
private Gson gson = new GsonBuilder()
|
.registerTypeAdapter(Date.class, new TypeAdapter<Date>() {
|
@Override
|
public void write(JsonWriter out, Date value) throws IOException {
|
String desc = "";
|
if (value != null) {
|
desc = TimeUtil.getGernalTime(value.getTime(), "yyyy-MM-dd HH:mm:ss");
|
out.value(desc);
|
} else {
|
out.value("");
|
}
|
}
|
|
@Override
|
public Date read(JsonReader in) throws IOException {
|
return new Date();
|
}
|
}).registerTypeAdapter(CreditExchangeRecord.ExchangeType.class, new TypeAdapter<CreditExchangeRecord.ExchangeType>() {
|
@Override
|
public void write(JsonWriter out, CreditExchangeRecord.ExchangeType value) throws IOException {
|
String desc = "";
|
if (value != null) {
|
desc = value.getDesc();
|
out.value(desc);
|
} else {
|
out.value("");
|
}
|
}
|
|
@Override
|
public CreditExchangeRecord.ExchangeType read(JsonReader in) throws IOException {
|
return null;
|
}
|
}).create();
|
|
@Resource
|
private CreditExchangeRecordService userCreditExchangeRecordService;
|
|
/**
|
* 获取积分兑换记录列表
|
*/
|
@ResponseBody
|
@RequestMapping("list")
|
public String listRecords(UserCreditExchangeRecordSearchVO search, int page, int limit) {
|
CreditExchangeRecordMapper.DaoQuery query = CreditExchangeRecordMapper.DaoQuery.builder().build();
|
if (!StringUtil.isNullOrEmpty(search.getUid())) {
|
query.uid = Long.parseLong(search.getUid());
|
}
|
if (!StringUtil.isNullOrEmpty(search.getStatus())) {
|
query.exchangeStatus = Integer.parseInt(search.getStatus());
|
}
|
|
if (!StringUtil.isNullOrEmpty(search.getStart_date())) {
|
query.minCreateTime = new Date(TimeUtil.convertToTimeTemp(search.getStart_date(), "yyyy-MM-dd"));
|
}
|
|
if (!StringUtil.isNullOrEmpty(search.getEnd_date())) {
|
query.maxCreateTime = new Date(TimeUtil.convertToTimeTemp(search.getEnd_date(), "yyyy-MM-dd") + 1000 * 60 * 60 * 24L);
|
}
|
query.sortList = Arrays.asList(new String[]{"create_time desc"});
|
query.start = (long) (page - 1) * limit;
|
query.count = limit;
|
|
List<CreditExchangeRecord> records = userCreditExchangeRecordService.listExchangeRecords(query);
|
long count = userCreditExchangeRecordService.countExchangeRecords(query);
|
|
JSONObject root = new JSONObject();
|
root.put("list", gson.toJson(records));
|
root.put("count", count);
|
return JsonUtil.loadTrueResult(root);
|
}
|
|
/**
|
* 批量通过兑换记录
|
*/
|
@ResponseBody
|
@RequestMapping("approve")
|
public String approveRecords(String ids) {
|
int successCount = 0;
|
int failCount = 0;
|
JSONArray idsArray = JSONArray.fromObject(ids);
|
List<String> errorMsgList=new ArrayList<>();
|
for (int i = 0; i < idsArray.size(); i++) {
|
long id = idsArray.optLong(i);
|
try {
|
userCreditExchangeManager.approveExchange(id);
|
successCount += 1;
|
} catch (UserCreditExchangeException e) {
|
errorMsgList.add(e.getMessage());
|
failCount += 1;
|
userCreditExchangeRecordService.updateExchangeRecord(CreditExchangeRecord.builder()
|
.id(id)
|
.exchangeStatusDescription(e.getMessage())
|
.updateTime(new Date())
|
.build());
|
}
|
}
|
if(idsArray.size()>1) {
|
return JsonUtil.loadFalseResult(String.format("成功通过 %d 条记录 通过异常 %d 条记录", successCount, failCount));
|
}else{
|
if(!errorMsgList.isEmpty()) {
|
return JsonUtil.loadFalseResult(errorMsgList.get(0));
|
}else{
|
return JsonUtil.loadTrueResult("通过成功");
|
}
|
}
|
}
|
|
/**
|
* 批量驳回兑换记录
|
*/
|
@ResponseBody
|
@RequestMapping("reject")
|
public String rejectRecords(String ids) {
|
int successCount = 0;
|
int failCount = 0;
|
JSONArray idsArray = JSONArray.fromObject(ids);
|
for (int i = 0; i < idsArray.size(); i++) {
|
long id = idsArray.optLong(i);
|
try {
|
userCreditExchangeManager.rejectExchange(id);
|
successCount += 1;
|
} catch (UserCreditExchangeException e) {
|
failCount += 1;
|
}
|
}
|
return JsonUtil.loadFalseResult(String.format("成功驳回 %d 条记录 驳回异常 %d 条记录", successCount, failCount));
|
}
|
}
|
