package com.ruoyi.web.controller.product;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.ruoyi.common.core.controller.BaseController;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.core.page.TableDataInfo;
|
import com.ruoyi.im.comm.Result;
|
import com.ruoyi.im.service.MedicalInsuranceAccountService;
|
import com.ruoyi.system.domain.MedicalInsuranceAccount;
|
import com.ruoyi.system.domain.MedicalInsuranceDailyClaim;
|
import com.ruoyi.system.domain.UserPolicy;
|
import com.ruoyi.system.domain.out.CollectionRecordOut;
|
import com.ruoyi.system.mapper.MedicalInsuranceAccountMapper;
|
import com.ruoyi.system.mapper.MedicalInsuranceDailyClaimMapper;
|
import com.ruoyi.system.service.UserAccountService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.time.LocalDate;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.locks.ReentrantLock;
|
|
@RestController
|
@RequestMapping("/MedicalInsuranceAccount")
|
public class MedicalInsuranceAccountController {
|
|
@Autowired
|
MedicalInsuranceAccountService medicalInsuranceAccountService;
|
|
@Autowired
|
private MedicalInsuranceAccountMapper medicalInsuranceAccountMapper;
|
|
@Autowired
|
private MedicalInsuranceDailyClaimMapper medicalInsuranceDailyClaimMapper;
|
|
@Autowired
|
UserAccountService userAccountService;
|
|
|
/**
|
* 领取保险金
|
*/
|
@GetMapping("/getInsuranceBenefit")
|
public Result getInsuranceBenefit(@RequestParam(value = "account") String account) {
|
try {
|
return medicalInsuranceAccountService.getInsuranceBenefit(account);
|
}catch (Exception e){
|
e.printStackTrace();
|
return Result.error("购买失败!");
|
}
|
}
|
|
/**
|
* 查询领取状态
|
*/
|
@GetMapping("/getReceiveStatus")
|
public Result getReceiveStatus(@RequestParam(value = "account") String account) {
|
try {
|
return medicalInsuranceAccountService.getReceiveStatus(account);
|
}catch (Exception e){
|
e.printStackTrace();
|
return Result.error("获取失败!");
|
}
|
}
|
|
|
/**
|
* 领取记录
|
*/
|
@GetMapping("/list")
|
public AjaxResult list(@RequestParam(value = "userId",required = true) String userId) {
|
|
MedicalInsuranceAccount medicalInsuranceAccount = medicalInsuranceAccountMapper.selectOne(new LambdaQueryWrapper<MedicalInsuranceAccount>()
|
.eq(MedicalInsuranceAccount::getUserId, userId)
|
.eq(MedicalInsuranceAccount::getAccountStatus, MedicalInsuranceAccount.AccountStatus.ACTIVE)
|
);
|
TableDataInfo rspData = new TableDataInfo();
|
if (medicalInsuranceAccount == null) {
|
return AjaxResult.error("用户医保账户未激活！");
|
}
|
|
// 检查今天是否已经领取
|
List<MedicalInsuranceDailyClaim> medicalInsuranceDailyClaims = medicalInsuranceDailyClaimMapper.selectList(new LambdaQueryWrapper<MedicalInsuranceDailyClaim>()
|
.eq(MedicalInsuranceDailyClaim::getUserId, userId)
|
);
|
|
CollectionRecordOut collectionRecordOut = new CollectionRecordOut();
|
List<CollectionRecordOut.RecordLog> recordLogList = new ArrayList<>();
|
collectionRecordOut.setNumber(medicalInsuranceDailyClaims.size());
|
collectionRecordOut.setMoney(medicalInsuranceAccount.getAlreadyReceived());
|
medicalInsuranceDailyClaims.forEach(f->{
|
CollectionRecordOut.RecordLog recordLog = new CollectionRecordOut.RecordLog();
|
recordLog.setReceiveTime(f.getClaimDate());
|
recordLog.setMoney(f.getClaimAmount());
|
recordLogList.add(recordLog);
|
});
|
collectionRecordOut.setRecords(recordLogList);
|
return AjaxResult.success(collectionRecordOut);
|
}
|
|
}
|
