package com.zy.crm.manager.task.handler; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.core.common.R; import com.core.exception.CoolException; import com.zy.crm.manager.controller.CstmrController; import com.zy.crm.manager.entity.CompanyMoney; import com.zy.crm.manager.entity.Cstmr; import com.zy.crm.manager.mapper.CstmrMapper; import com.zy.crm.manager.service.CompanyMoneyService; import com.zy.crm.manager.service.CstmrService; import com.zy.crm.manager.task.AbstractHandler; import com.zy.crm.manager.task.core.ReturnT; import com.zy.crm.manager.utils.TimeCalculatorUtils; import com.zy.crm.system.entity.User; import com.zy.crm.system.service.UserService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import java.util.ArrayList; import java.util.Date; import java.util.Iterator; import java.util.List; /** * Created by vincent on 2020/7/6 */ @Slf4j @Service public class CstmrCopyHandler extends AbstractHandler { @Autowired private CstmrService cstmrService; @Autowired private CstmrController cstmrController; @Autowired private CstmrMapper cstmrMapper; @Autowired private CompanyMoneyService companyMoneyService; @Autowired private UserService userService; @Transactional public ReturnT start() { try { if (false){ Long hostId = 1L; // List cstmrs = cstmrMapper.selectCopyList(); List cstmrs = new ArrayList<>(); for (Cstmr cstmr33 : cstmrs){ Cstmr cstmr13 = cstmrService.selectByName(hostId,cstmr33.getName()); if (Cools.isEmpty(cstmr13)){ Cstmr cstmr23 = cstmrService.selectById(186); Cstmr cstmr = new Cstmr(cstmr23); cstmr.setName(cstmr33.getName()); cstmr.setUuid(cstmrService.getUuid(hostId)); cstmrService.insert(cstmr); } } } if (false){ List companyMoneyList = companyMoneyService.selectMoneyCopyAll(); for (CompanyMoney companyMoney:companyMoneyList){ User user = userService.selectOne(new EntityWrapper().eq("username", companyMoney.getUserName())); if (Cools.isEmpty(user)){ companyMoneyService.updateMoneyCopyByid(companyMoney.getId()); continue; } companyMoney.setUserId(user.getId()); companyMoney.setUpdateUserId(user.getId()); companyMoney.setReceivablesType(1); switch (companyMoney.getComplete()){ case "未结销": break; case "部分结销": companyMoney.setStatus(1); break; default: companyMoney.setStatus(2); } Cstmr cstmr = cstmrService.selectByName(1L, companyMoney.getCstmrName()); if (!Cools.isEmpty(cstmr)){ companyMoney.setCstmrId(cstmr.getId()); } CompanyMoney companyMoneyNew = new CompanyMoney(companyMoney); Date now = new Date(); companyMoneyNew.setUpdateTime(now); companyMoneyNew.setCreateTime(now); int yest = TimeCalculatorUtils.timeYest(companyMoney.getDeliveryTime()); companyMoneyNew.setYear(String.valueOf(yest)); companyMoneyService.insert(companyMoneyNew); companyMoneyService.updateMoneyCopyByid2(companyMoney.getId()); } } } catch (Exception e) { log.error("fail", e); e.printStackTrace(); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return FAIL.setMsg(e.getMessage()); } return SUCCESS; } }