|
@@ -9,12 +9,11 @@ import com.ruoyi.common.exception.ServiceException;
|
|
import com.ruoyi.common.utils.DateUtils;
|
|
import com.ruoyi.common.utils.DateUtils;
|
|
import com.ruoyi.common.utils.StringUtils;
|
|
import com.ruoyi.common.utils.StringUtils;
|
|
import com.ruoyi.web.work.api.util.AppUtil;
|
|
import com.ruoyi.web.work.api.util.AppUtil;
|
|
-import com.ruoyi.web.work.domain.Enterprise;
|
|
|
|
-import com.ruoyi.web.work.domain.Position;
|
|
|
|
-import com.ruoyi.web.work.domain.Resume;
|
|
|
|
-import com.ruoyi.web.work.domain.ResumeDeliver;
|
|
|
|
|
|
+import com.ruoyi.web.work.domain.*;
|
|
|
|
+import com.ruoyi.web.work.domain.dto.JTaskCompleteDto;
|
|
import com.ruoyi.web.work.domain.dto.ResumeDeliverDto;
|
|
import com.ruoyi.web.work.domain.dto.ResumeDeliverDto;
|
|
import com.ruoyi.web.work.domain.dto.ResumeInviteDto;
|
|
import com.ruoyi.web.work.domain.dto.ResumeInviteDto;
|
|
|
|
+import com.ruoyi.web.work.domain.dto.YTaskCompleteDto;
|
|
import com.ruoyi.web.work.domain.vo.ReceiveListVo;
|
|
import com.ruoyi.web.work.domain.vo.ReceiveListVo;
|
|
import com.ruoyi.web.work.domain.vo.ReceiveVo;
|
|
import com.ruoyi.web.work.domain.vo.ReceiveVo;
|
|
import com.ruoyi.web.work.mapper.ResumeDeliverMapper;
|
|
import com.ruoyi.web.work.mapper.ResumeDeliverMapper;
|
|
@@ -22,7 +21,9 @@ import com.ruoyi.web.work.service.*;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.core.env.Environment;
|
|
import org.springframework.core.env.Environment;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
+import java.math.BigDecimal;
|
|
import java.text.ParseException;
|
|
import java.text.ParseException;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
|
|
|
@@ -48,6 +49,9 @@ public class ResumeDeliverServiceImpl extends ServiceImpl<ResumeDeliverMapper, R
|
|
private IEnterpriseService enterpriseService;
|
|
private IEnterpriseService enterpriseService;
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
|
|
+ private IPayService payService;
|
|
|
|
+
|
|
|
|
+ @Autowired
|
|
private Environment env;
|
|
private Environment env;
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -243,4 +247,58 @@ public class ResumeDeliverServiceImpl extends ServiceImpl<ResumeDeliverMapper, R
|
|
System.out.println("body:" + body);
|
|
System.out.println("body:" + body);
|
|
System.out.println("小程序订阅消息:" + result);
|
|
System.out.println("小程序订阅消息:" + result);
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public AjaxResult yTaskComplete(YTaskCompleteDto dto) {
|
|
|
|
+ ResumeDeliver resumeDeliver = getById(dto.getId());
|
|
|
|
+ if (resumeDeliver == null || !resumeDeliver.getUserId().equals(AppUtil.getUser().getId())) {
|
|
|
|
+ return AjaxResult.error("兼职任务不存在或非法操作");
|
|
|
|
+ }
|
|
|
|
+ resumeDeliver.setIsComplete(1);
|
|
|
|
+ resumeDeliver.setCMsg(dto.getCMsg());
|
|
|
|
+ if (!updateById(resumeDeliver)) {
|
|
|
|
+ throw new ServiceException("操作任务失败");
|
|
|
|
+ }
|
|
|
|
+ return AjaxResult.success();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Transactional
|
|
|
|
+ @Override
|
|
|
|
+ public AjaxResult jTaskComplete(JTaskCompleteDto dto) {
|
|
|
|
+ ResumeDeliver resumeDeliver = getById(dto.getId());
|
|
|
|
+ if (resumeDeliver == null || !resumeDeliver.getEnterpriseId().equals(AppUtil.getUser().getId())) {
|
|
|
|
+ return AjaxResult.error("兼职任务不存在或非法操作");
|
|
|
|
+ }
|
|
|
|
+ resumeDeliver.setIsComplete(dto.getIsComplete());
|
|
|
|
+ resumeDeliver.setCMsg(dto.getRMsg());
|
|
|
|
+ if (!updateById(resumeDeliver)) {
|
|
|
|
+ throw new ServiceException("操作面试失败");
|
|
|
|
+ }
|
|
|
|
+ //甲方确认完成任务,平台打款到乙方账户余额
|
|
|
|
+ if (resumeDeliver.getIsComplete() == 2) {
|
|
|
|
+ Position position = positionService.getById(resumeDeliver.getPositionId());
|
|
|
|
+ if (position == null) {
|
|
|
|
+ throw new ServiceException("兼职不存在");
|
|
|
|
+ }
|
|
|
|
+ User user = userService.getById(resumeDeliver.getUserId());
|
|
|
|
+ user.setMoney(user.getMoney().add(new BigDecimal(position.getSalary())));
|
|
|
|
+ if (!userService.updateById(user)) {
|
|
|
|
+ throw new ServiceException("更新用户账户余额失败");
|
|
|
|
+ }
|
|
|
|
+ //添加完成余额入账记录
|
|
|
|
+ Pay pay = new Pay();
|
|
|
|
+ pay.setUserId(user.getId());
|
|
|
|
+ pay.setMoney(new BigDecimal(position.getSalary()));
|
|
|
|
+ pay.setState(1);
|
|
|
|
+ pay.setType(3);
|
|
|
|
+ pay.setTitle(position.getTitle());
|
|
|
|
+ pay.setVersion(System.currentTimeMillis());
|
|
|
|
+ pay.setPositionId(position.getId());
|
|
|
|
+ pay.setNums(StringUtils.generateNumber());
|
|
|
|
+ if (!payService.save(pay)) {
|
|
|
|
+ throw new ServiceException("保存余额入账记录失败,请联系平台");
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ return AjaxResult.success();
|
|
|
|
+ }
|
|
}
|
|
}
|