소스 검색

Merge branch 'develop' of https://git.youlane.cn/server/formallProject into develop

release_toaliyun_real
Burce 6 년 전
부모
커밋
73f3b3c586
5개의 변경된 파일62개의 추가작업 그리고 40개의 파일을 삭제
  1. +8
    -0
      mallinkAdmin/src/main/java/com/iformall/controller/datatower/WxMerchantTradeDailyController.java
  2. +1
    -1
      mallinkBApi/src/main/java/com/iformall/controller/WxCreditHistoryController.java
  3. +3
    -0
      mallinkService/src/main/java/com/iformall/service/WxMerchantTradeDailyService.java
  4. +49
    -38
      mallinkService/src/main/java/com/iformall/service/impl/WxMerchantTradeDailyServiceImpl.java
  5. +1
    -1
      mallinkService/src/main/java/com/iformall/service/impl/WxOrderPressServiceImpl.java

+ 8
- 0
mallinkAdmin/src/main/java/com/iformall/controller/datatower/WxMerchantTradeDailyController.java 파일 보기

@@ -52,6 +52,14 @@ public class WxMerchantTradeDailyController extends BaseController {
return new ResultData(page); return new ResultData(page);
} }


@ApiOperation("数据汇总")
@GetMapping("/summary")
@SystemControllerLog(description = "商户解单-数据汇总")
public ResultData summary(@ModelAttribute WxMerchantTradeDaily wxMerchantTradeDaily) {
logger.debug("[" + getIpAddr() + "] WxMerchantTradeDailyController::summary");
return wxMerchantTradeDailyService.summary(wxMerchantTradeDaily);
}

@ApiOperation("获商户得近30日解单") @ApiOperation("获商户得近30日解单")
@GetMapping("/detail") @GetMapping("/detail")
@SystemControllerLog(description = "商户-获商户得近30日解单detail") @SystemControllerLog(description = "商户-获商户得近30日解单detail")


+ 1
- 1
mallinkBApi/src/main/java/com/iformall/controller/WxCreditHistoryController.java 파일 보기

@@ -122,7 +122,7 @@ public class WxCreditHistoryController extends BaseController {
wxCreditHistory.setBuserId(getBuser().getId()); wxCreditHistory.setBuserId(getBuser().getId());
WxCreditHistory credit = wxCreditHistoryService.saveOrUpdate(wxCreditHistory); WxCreditHistory credit = wxCreditHistoryService.saveOrUpdate(wxCreditHistory);
//更新标签 //更新标签
if (!wxCreditHistory.getTags().isEmpty()) {
if (wxCreditHistory.getTags() != null && !wxCreditHistory.getTags().isEmpty()) {
wxCUserTagsService.updateTagByUserId(wxCreditHistory.getCUserId(), wxCreditHistory.getTags()); wxCUserTagsService.updateTagByUserId(wxCreditHistory.getCUserId(), wxCreditHistory.getTags());
} }
return new ResultData(Result.SUCCESS, "操作成功", credit); return new ResultData(Result.SUCCESS, "操作成功", credit);


+ 3
- 0
mallinkService/src/main/java/com/iformall/service/WxMerchantTradeDailyService.java 파일 보기

@@ -88,4 +88,7 @@ public interface WxMerchantTradeDailyService {
ResultData queryTradeDaily(WxMerchantTradeDaily wxMerchantTradeDaily); ResultData queryTradeDaily(WxMerchantTradeDaily wxMerchantTradeDaily);


void exportData(WxMerchantTradeDaily wxMerchantTradeDaily, HttpServletRequest request, HttpServletResponse response); void exportData(WxMerchantTradeDaily wxMerchantTradeDaily, HttpServletRequest request, HttpServletResponse response);

ResultData summary(WxMerchantTradeDaily wxMerchantTradeDaily);

} }

+ 49
- 38
mallinkService/src/main/java/com/iformall/service/impl/WxMerchantTradeDailyServiceImpl.java 파일 보기

@@ -29,14 +29,14 @@ import java.util.stream.Collectors;
@Service @Service
public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyService { public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyService {
private final Logger logger = LoggerFactory.getLogger(this.getClass()); private final Logger logger = LoggerFactory.getLogger(this.getClass());
@Autowired
@Autowired
WxMerchantTradeDailyMapper wxMerchantTradeDailyMapper; WxMerchantTradeDailyMapper wxMerchantTradeDailyMapper;


@Autowired
@Autowired
WxMerchantBUserService wxMerchantBUserService; WxMerchantBUserService wxMerchantBUserService;


@Autowired
@Autowired
WxMerchantService wxMerchantService; WxMerchantService wxMerchantService;


@Autowired @Autowired
@@ -64,7 +64,7 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
if (record.getId() == null) { if (record.getId() == null) {
//record.setId(UUID.randomUUID().toString().replaceAll("-", "")); //record.setId(UUID.randomUUID().toString().replaceAll("-", ""));
final IdWorker idWorker = IdWorker.get(); final IdWorker idWorker = IdWorker.get();
record.setId(idWorker.nextId());
record.setId(idWorker.nextId());
record.setCreateDate(new Date()); record.setCreateDate(new Date());
record.setUpdateDate(new Date()); record.setUpdateDate(new Date());
wxMerchantTradeDailyMapper.insert(record); wxMerchantTradeDailyMapper.insert(record);
@@ -84,16 +84,16 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ


WxMerchantBUser user = wxMerchantBUserService.getById(userId); WxMerchantBUser user = wxMerchantBUserService.getById(userId);


if (user==null)
if (user == null)
return new ResultData(ErrorCode.USER_IS_EMPTY); return new ResultData(ErrorCode.USER_IS_EMPTY);


WxMerchant merchant = wxMerchantService.getById(user.getMerchantId()); WxMerchant merchant = wxMerchantService.getById(user.getMerchantId());


if (merchant==null)
if (merchant == null)
return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND); return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND);


WxMall mall = wxMallService.getByTenantId(merchant.getTenantId()); WxMall mall = wxMallService.getByTenantId(merchant.getTenantId());
if (mall==null)
if (mall == null)
return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND); return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND);




@@ -101,15 +101,15 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ


wxMerchantTradeDaily.setMerchantId(merchant.getId()); wxMerchantTradeDaily.setMerchantId(merchant.getId());


SimpleDateFormat fmt=new SimpleDateFormat("yyyy-MM-dd");
SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd");
wxMerchantTradeDaily.setReportDate(fmt.format(new Date())); wxMerchantTradeDaily.setReportDate(fmt.format(new Date()));




List<WxMerchantTradeDaily> tradeList = wxMerchantTradeDailyMapper.findList(wxMerchantTradeDaily); List<WxMerchantTradeDaily> tradeList = wxMerchantTradeDailyMapper.findList(wxMerchantTradeDaily);


if (tradeList.size() > 0 ) {
if (tradeList.size() > 0) {
wxMerchantTradeDaily = tradeList.get(0); wxMerchantTradeDaily = tradeList.get(0);
wxMerchantTradeDaily.setTradeAmt(volume+"");
wxMerchantTradeDaily.setTradeAmt(volume + "");
wxMerchantTradeDaily.setUpdateDate(new Date()); wxMerchantTradeDaily.setUpdateDate(new Date());
wxMerchantTradeDailyMapper.updateById(wxMerchantTradeDaily); wxMerchantTradeDailyMapper.updateById(wxMerchantTradeDaily);
return new ResultData(wxMerchantTradeDaily); return new ResultData(wxMerchantTradeDaily);
@@ -120,7 +120,7 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
wxMerchantTradeDaily.setTenantId(merchant.getTenantId()); wxMerchantTradeDaily.setTenantId(merchant.getTenantId());
wxMerchantTradeDaily.setMerchantId(merchant.getId()); wxMerchantTradeDaily.setMerchantId(merchant.getId());
wxMerchantTradeDaily.setbUserId(userId); wxMerchantTradeDaily.setbUserId(userId);
wxMerchantTradeDaily.setTradeAmt(volume+"");
wxMerchantTradeDaily.setTradeAmt(volume + "");
wxMerchantTradeDaily.setCreateDate(new Date()); wxMerchantTradeDaily.setCreateDate(new Date());
wxMerchantTradeDaily.setUpdateDate(new Date()); wxMerchantTradeDaily.setUpdateDate(new Date());
wxMerchantTradeDailyMapper.insert(wxMerchantTradeDaily); wxMerchantTradeDailyMapper.insert(wxMerchantTradeDaily);
@@ -147,7 +147,7 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
if (tradeList.size() > 0) { if (tradeList.size() > 0) {
wxMerchantTradeDaily = tradeList.get(0); wxMerchantTradeDaily = tradeList.get(0);
wxMerchantTradeDaily.setUpdateDate(new Date()); wxMerchantTradeDaily.setUpdateDate(new Date());
wxMerchantTradeDaily.setTradeAmt(tradeDaily.getTradeAmt()+"");
wxMerchantTradeDaily.setTradeAmt(tradeDaily.getTradeAmt() + "");
wxMerchantTradeDaily.setTradeCount(tradeDaily.getTradeCount()); wxMerchantTradeDaily.setTradeCount(tradeDaily.getTradeCount());
wxMerchantTradeDaily.setProof(tradeDaily.getProof()); wxMerchantTradeDaily.setProof(tradeDaily.getProof());
wxMerchantTradeDailyMapper.updateById(wxMerchantTradeDaily); wxMerchantTradeDailyMapper.updateById(wxMerchantTradeDaily);
@@ -158,7 +158,7 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
wxMerchantTradeDaily.setId(idWorker.nextId()); wxMerchantTradeDaily.setId(idWorker.nextId());
wxMerchantTradeDaily.setTenantId(tradeDaily.getTenantId()); wxMerchantTradeDaily.setTenantId(tradeDaily.getTenantId());
wxMerchantTradeDaily.setMerchantId(tradeDaily.getMerchantId()); wxMerchantTradeDaily.setMerchantId(tradeDaily.getMerchantId());
wxMerchantTradeDaily.setTradeAmt(tradeDaily.getTradeAmt()+"");
wxMerchantTradeDaily.setTradeAmt(tradeDaily.getTradeAmt() + "");
wxMerchantTradeDaily.setCreateDate(new Date()); wxMerchantTradeDaily.setCreateDate(new Date());
wxMerchantTradeDaily.setUpdateDate(new Date()); wxMerchantTradeDaily.setUpdateDate(new Date());
wxMerchantTradeDaily.setTradeCount(tradeDaily.getTradeCount()); wxMerchantTradeDaily.setTradeCount(tradeDaily.getTradeCount());
@@ -183,20 +183,31 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
//没有商户ID导出全部数据 //没有商户ID导出全部数据
List<WxMerchantTradeDailyVo> list = wxMerchantTradeDailyMapper.findVoList(tradeDaily); List<WxMerchantTradeDailyVo> list = wxMerchantTradeDailyMapper.findVoList(tradeDaily);


list.stream().forEach(m->{
list.stream().forEach(m -> {
//商铺信息 //商铺信息
m.setShopVos(wxShopMapper.findShopVoList(m.getMerchantId())); m.setShopVos(wxShopMapper.findShopVoList(m.getMerchantId()));
}); });
//商铺信息 //商铺信息


excelService.exportExcel(list, "商户解单数据", "商户解单数据", WxMerchantTradeDailyVo.class, "商户解单数据.xlsx", response, false);
excelService.exportExcel(list, "商户解单数据", "商户解单数据", WxMerchantTradeDailyVo.class, "商户解单数据.xlsx", response, false);
}

@Override
public ResultData summary(WxMerchantTradeDaily record) {
List<WxMerchantTradeDailyVo> voList = wxMerchantTradeDailyMapper.findVoList(record);
Integer tradeAmt = voList.stream().collect(Collectors.summingInt(WxMerchantTradeDailyVo::getTradeAmt));
Integer tradeCount = voList.stream().collect(Collectors.summingInt(WxMerchantTradeDailyVo::getTradeCount));
Map<String, Object> data = new HashMap<>();
data.put("tradeAmt", tradeAmt);
data.put("tradeCount", tradeCount);
return new ResultData(data);
} }


@Override @Override
public ResultData getVolumeOfMonth(Long merchantId) { public ResultData getVolumeOfMonth(Long merchantId) {


WxMerchant merchant = wxMerchantService.getById(merchantId); WxMerchant merchant = wxMerchantService.getById(merchantId);
if (merchant==null)
if (merchant == null)
return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND); return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND);
WxMerchantTradeDaily wxMerchantTradeDaily = new WxMerchantTradeDaily(); WxMerchantTradeDaily wxMerchantTradeDaily = new WxMerchantTradeDaily();
wxMerchantTradeDaily.setMerchantId(merchantId); wxMerchantTradeDaily.setMerchantId(merchantId);
@@ -205,7 +216,7 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
wxMerchantTradeDaily.setStartTime(startTime); wxMerchantTradeDaily.setStartTime(startTime);
wxMerchantTradeDaily.setEndTime(endTime); wxMerchantTradeDaily.setEndTime(endTime);
List<WxMerchantTradeDailyVo> recordList = wxMerchantTradeDailyMapper.findVoList(wxMerchantTradeDaily); List<WxMerchantTradeDailyVo> recordList = wxMerchantTradeDailyMapper.findVoList(wxMerchantTradeDaily);
Map<String,WxMerchantTradeDailyVo> recordMap = recordList.stream().collect(Collectors.toMap(WxMerchantTradeDailyVo::getReportDate, r -> r));
Map<String, WxMerchantTradeDailyVo> recordMap = recordList.stream().collect(Collectors.toMap(WxMerchantTradeDailyVo::getReportDate, r -> r));


List<WxMerchantTradeDailyVo> tradeList = new ArrayList<>(); List<WxMerchantTradeDailyVo> tradeList = new ArrayList<>();
Calendar cal = Calendar.getInstance(); Calendar cal = Calendar.getInstance();
@@ -215,14 +226,14 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
cal.setTime(new Date()); cal.setTime(new Date());
cal.add(Calendar.DAY_OF_YEAR, -i); cal.add(Calendar.DAY_OF_YEAR, -i);
WxMerchantTradeDailyVo trade = recordMap.get(fmt.format(cal.getTime())); WxMerchantTradeDailyVo trade = recordMap.get(fmt.format(cal.getTime()));
if (trade != null){
if (trade != null) {
trade.setReportDate(fmtv.format(cal.getTime())); trade.setReportDate(fmtv.format(cal.getTime()));
trade.setTenantId(null); trade.setTenantId(null);
trade.setMerchantId(null); trade.setMerchantId(null);
trade.setMerchantName(null); trade.setMerchantName(null);
tradeList.add(trade); tradeList.add(trade);
}else {
trade = new WxMerchantTradeDailyVo();
} else {
trade = new WxMerchantTradeDailyVo();
trade.setTradeAmt(0); trade.setTradeAmt(0);
trade.setReportDate(fmtv.format(cal.getTime())); trade.setReportDate(fmtv.format(cal.getTime()));
tradeList.add(trade); tradeList.add(trade);
@@ -241,7 +252,7 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
wxMerchantTradeDaily.setTenantId(tenantId); wxMerchantTradeDaily.setTenantId(tenantId);


List<WxMerchantTradeDaily> recordList = wxMerchantTradeDailyMapper.findTotalListOfMonth(wxMerchantTradeDaily); List<WxMerchantTradeDaily> recordList = wxMerchantTradeDailyMapper.findTotalListOfMonth(wxMerchantTradeDaily);
Map<String,WxMerchantTradeDaily> recordMap = recordList.stream().collect(Collectors.toMap(WxMerchantTradeDaily::getReportDate, r -> r));
Map<String, WxMerchantTradeDaily> recordMap = recordList.stream().collect(Collectors.toMap(WxMerchantTradeDaily::getReportDate, r -> r));


List<WxMerchantTradeDaily> tradeList = new ArrayList<>(); List<WxMerchantTradeDaily> tradeList = new ArrayList<>();
Calendar cal = Calendar.getInstance(); Calendar cal = Calendar.getInstance();
@@ -252,11 +263,11 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
cal.add(Calendar.DAY_OF_MONTH, -i); cal.add(Calendar.DAY_OF_MONTH, -i);
System.out.println(fmt.format(cal.getTime())); System.out.println(fmt.format(cal.getTime()));
WxMerchantTradeDaily trade = recordMap.get(fmt.format(cal.getTime())); WxMerchantTradeDaily trade = recordMap.get(fmt.format(cal.getTime()));
if (trade != null){
if (trade != null) {
trade.setReportDate(fmtv.format(cal.getTime())); trade.setReportDate(fmtv.format(cal.getTime()));
tradeList.add(trade); tradeList.add(trade);
}else {
trade = new WxMerchantTradeDaily();
} else {
trade = new WxMerchantTradeDaily();
trade.setTradeAmt("0"); trade.setTradeAmt("0");
trade.setReportDate(fmtv.format(cal.getTime())); trade.setReportDate(fmtv.format(cal.getTime()));
tradeList.add(trade); tradeList.add(trade);
@@ -269,30 +280,30 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ
} }


@Override @Override
public ResultData getVolume(WxMerchantTradeDaily merchantTradeDaily,Long userId) {
public ResultData getVolume(WxMerchantTradeDaily merchantTradeDaily, Long userId) {
WxMerchantBUser user = wxMerchantBUserService.getById(userId); WxMerchantBUser user = wxMerchantBUserService.getById(userId);
if (user==null)
if (user == null)
return new ResultData(ErrorCode.USER_IS_EMPTY); return new ResultData(ErrorCode.USER_IS_EMPTY);
WxMerchant merchant = wxMerchantService.getById(user.getMerchantId()); WxMerchant merchant = wxMerchantService.getById(user.getMerchantId());
if (merchant==null)
if (merchant == null)
return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND); return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND);
WxMall mall = wxMallService.getByTenantId(merchant.getTenantId()); WxMall mall = wxMallService.getByTenantId(merchant.getTenantId());
if (mall==null)
if (mall == null)
return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND); return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND);


WxMerchantTradeDaily wxMerchantTradeDaily = new WxMerchantTradeDaily(); WxMerchantTradeDaily wxMerchantTradeDaily = new WxMerchantTradeDaily();
wxMerchantTradeDaily.setMerchantId(merchant.getId()); wxMerchantTradeDaily.setMerchantId(merchant.getId());


if(merchantTradeDaily.getReportDate() != null){
if (merchantTradeDaily.getReportDate() != null) {
wxMerchantTradeDaily.setReportDate(merchantTradeDaily.getReportDate()); wxMerchantTradeDaily.setReportDate(merchantTradeDaily.getReportDate());
}else {
SimpleDateFormat fmt=new SimpleDateFormat("yyyy-MM-dd");
} else {
SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd");
wxMerchantTradeDaily.setReportDate(fmt.format(new Date())); wxMerchantTradeDaily.setReportDate(fmt.format(new Date()));
} }


List<WxMerchantTradeDaily> tradeList = wxMerchantTradeDailyMapper.findList(wxMerchantTradeDaily); List<WxMerchantTradeDaily> tradeList = wxMerchantTradeDailyMapper.findList(wxMerchantTradeDaily);


if (tradeList.size() > 0 ) {
if (tradeList.size() > 0) {
wxMerchantTradeDaily = tradeList.get(0); wxMerchantTradeDaily = tradeList.get(0);
return new ResultData(wxMerchantTradeDaily); return new ResultData(wxMerchantTradeDaily);
} }
@@ -306,16 +317,16 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ


WxMerchantBUser user = wxMerchantBUserService.getById(userId); WxMerchantBUser user = wxMerchantBUserService.getById(userId);


if (user==null)
if (user == null)
return new ResultData(ErrorCode.USER_IS_EMPTY); return new ResultData(ErrorCode.USER_IS_EMPTY);


WxMerchant merchant = wxMerchantService.getById(user.getMerchantId()); WxMerchant merchant = wxMerchantService.getById(user.getMerchantId());


if (merchant==null)
if (merchant == null)
return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND); return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND);


WxMall mall = wxMallService.getByTenantId(merchant.getTenantId()); WxMall mall = wxMallService.getByTenantId(merchant.getTenantId());
if (mall==null)
if (mall == null)
return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND); return new ResultData(ErrorCode.MERCHANT_INFO_NOT_FOUND);




@@ -323,11 +334,11 @@ public class WxMerchantTradeDailyServiceImpl implements WxMerchantTradeDailyServ


wxMerchantTradeDaily.setMerchantId(merchant.getId()); wxMerchantTradeDaily.setMerchantId(merchant.getId());


SimpleDateFormat fmt=new SimpleDateFormat("yyyy-MM-dd");
SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd");
wxMerchantTradeDaily.setReportDate(fmt.format(new Date())); wxMerchantTradeDaily.setReportDate(fmt.format(new Date()));


return new ResultData(wxMerchantTradeDailyMapper.findListOfWeek(wxMerchantTradeDaily)); return new ResultData(wxMerchantTradeDailyMapper.findListOfWeek(wxMerchantTradeDaily));


} }
} }

+ 1
- 1
mallinkService/src/main/java/com/iformall/service/impl/WxOrderPressServiceImpl.java 파일 보기

@@ -91,7 +91,7 @@ public class WxOrderPressServiceImpl implements WxOrderPressService {
orderPressQ.setUserId(cUserId); orderPressQ.setUserId(cUserId);
QueryWrapper<WxOrderPress> queryWrapper = new QueryWrapper<>(); QueryWrapper<WxOrderPress> queryWrapper = new QueryWrapper<>();
queryWrapper.setEntity(orderPressQ); queryWrapper.setEntity(orderPressQ);
int count = wxOrderPressMapper.selectCount(new QueryWrapper(queryWrapper));
int count = wxOrderPressMapper.selectCount(queryWrapper);
if(count >= 1) { if(count >= 1) {
logger.error("用户已参与砍价: " + cUserId); logger.error("用户已参与砍价: " + cUserId);
throw new MallinkException(ErrorCode.COUPON_PRESS_IS_EXIST); throw new MallinkException(ErrorCode.COUPON_PRESS_IS_EXIST);


불러오는 중...
취소
저장