package project.futures.internal;

import java.io.Serializable;
import java.util.Date;
import java.util.List;

import org.springframework.jdbc.core.JdbcTemplate;

import kernel.bo.RecordObjectMapper;
import kernel.web.ApplicationUtil;
import project.Constants;
import project.futures.FuturesRedisKeys;
import project.futures.ProfitAndLossConfig;
import project.futures.ProfitAndLossConfigService;
import project.log.Log;
import project.log.LogService;
import project.party.PartyService;
import project.party.model.Party;
import project.redis.RedisHandler;

public class ProfitAndLossConfigServiceImpl implements ProfitAndLossConfigService {

	private JdbcTemplate jdbcTemplate;
	private RedisHandler redisHandler;
	private LogService logService;
	private PartyService partyService;

	public void save(ProfitAndLossConfig entity, String Operater_username) {
		ProfitAndLossConfig config = this.findByPartyId(entity.getPartyId());
		// 如果存在则更新
		if (config != null) {
			config.setRemark(entity.getRemark());
			config.setType(entity.getType());
			
			String updateSql = "UPDATE T_PROFIT_LOSS_CONFIG SET TYPE=?, REMARK=? WHERE UUID=?";
			jdbcTemplate.update(updateSql, config.getType(), config.getRemark(), config.getId());
			
			redisHandler.setSync(FuturesRedisKeys.FUTURES_PROFIT_LOSS_PARTY_ID + config.getPartyId().toString(), config);
		} else {
			entity.setId(ApplicationUtil.getCurrentTimeUUID());
			String insertSql = "INSERT INTO T_PROFIT_LOSS_CONFIG(UUID,PARTY_ID,TYPE,REMARK) VALUES (?,?,?,?)";
			jdbcTemplate.update(insertSql,entity.getId(),entity.getPartyId(),entity.getType(),entity.getRemark());
			
			redisHandler.setSync(FuturesRedisKeys.FUTURES_PROFIT_LOSS_PARTY_ID + entity.getPartyId().toString(), entity);
		}
		
		String type = "";
		
		if("profit".equals(entity.getType())) {
			type = "盈利";
		}
		if("loss".equals(entity.getType())) {
			type = "亏损";
		}
		if("buy_profit".equals(entity.getType())) {
			type = "买多盈利";
		}
		if("sell_profit".equals(entity.getType())) {
			type = "买空盈利";
		}
		if("buy_profit_sell_loss".equals(entity.getType())) {
			type = "买多盈利并且买空亏损";
		}
		if("sell_profit_buy_loss".equals(entity.getType())) {
			type = "买空盈利并且买多亏损";
		}
		
		Party party = this.partyService.cachePartyBy(entity.getPartyId(), true);
		Log log = new Log();
		log.setCategory(Constants.LOG_CATEGORY_OPERATION);
		log.setOperator(Operater_username);
		log.setUsername(party.getUsername());
		log.setPartyId(entity.getPartyId());
		log.setCreateTime(new Date());
		log.setLog("管理员手动添加场控交割状态。操作类型[" + type + "]。");
		this.logService.saveSync(log);


	}

	public void update(ProfitAndLossConfig entity,String Operater_username) {
		
		String updateSql = "UPDATE T_PROFIT_LOSS_CONFIG SET TYPE=?, REMARK=? WHERE UUID=?";
		jdbcTemplate.update(updateSql, entity.getType(), entity.getRemark(), entity.getId());
		
		redisHandler.setSync(FuturesRedisKeys.FUTURES_PROFIT_LOSS_PARTY_ID + entity.getPartyId().toString(), entity);
		
		String type = "";
		
		if("profit".equals(entity.getType())) {
			type = "盈利";
		}
		if("loss".equals(entity.getType())) {
			type = "亏损";
		}
		if("buy_profit".equals(entity.getType())) {
			type = "买多盈利";
		}
		if("sell_profit".equals(entity.getType())) {
			type = "买空盈利";
		}
		if("buy_profit_sell_loss".equals(entity.getType())) {
			type = "买多盈利并且买空亏损";
		}
		if("sell_profit_buy_loss".equals(entity.getType())) {
			type = "买空盈利并且买多亏损";
		}
		Party party = this.partyService.cachePartyBy(entity.getPartyId(), true);
		Log log = new Log();
		log.setCategory(Constants.LOG_CATEGORY_OPERATION);
		log.setOperator(Operater_username);
		log.setUsername(party.getUsername());
		log.setPartyId(entity.getPartyId());
		log.setCreateTime(new Date());
		log.setLog("管理员手动修改场控交割状态。修改后操作类型为[" + type + "]。");
		this.logService.saveSync(log);
	}

	public void delete(String id,String Operater_username) {
		ProfitAndLossConfig entity = findById(id);
		if (null != entity) {
			jdbcTemplate.update("DELETE FROM T_PROFIT_LOSS_CONFIG WHERE UUID=?", entity.getId());
			redisHandler.remove(FuturesRedisKeys.FUTURES_PROFIT_LOSS_PARTY_ID + entity.getPartyId().toString());
			
			Party party = this.partyService.cachePartyBy(entity.getPartyId(), true);
			Log log = new Log();
			log.setCategory(Constants.LOG_CATEGORY_OPERATION);
			log.setOperator(Operater_username);
			log.setUsername(party.getUsername());
			log.setPartyId(entity.getPartyId());
			log.setCreateTime(new Date());
			log.setLog("管理员手动删除场控交割状态");
			this.logService.saveSync(log);
		}
	}

	public ProfitAndLossConfig findById(String id) {
		List<ProfitAndLossConfig> list = jdbcTemplate.query("SELECT * FROM T_PROFIT_LOSS_CONFIG WHERE UUID=?", RecordObjectMapper.newInstance(ProfitAndLossConfig.class), id);
		if (null != list && list.size() > 0) {
			return list.get(0);
        }
		return null;
	}

	public ProfitAndLossConfig findByPartyId(Serializable partyId) {
		List<ProfitAndLossConfig> list = jdbcTemplate.query("SELECT * FROM T_PROFIT_LOSS_CONFIG WHERE PARTY_ID=?", 
				RecordObjectMapper.newInstance(ProfitAndLossConfig.class), partyId);
		if (list.size() > 0)
			return list.get(0);
		return null;
	}

	public ProfitAndLossConfig cacheByPartyId(Serializable partyId) {
		return (ProfitAndLossConfig) redisHandler
				.get(FuturesRedisKeys.FUTURES_PROFIT_LOSS_PARTY_ID + partyId.toString());
	}

	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
		this.jdbcTemplate = jdbcTemplate;
	}

	public void setRedisHandler(RedisHandler redisHandler) {
		this.redisHandler = redisHandler;
	}

	public void setLogService(LogService logService) {
		this.logService = logService;
	}

	public void setPartyService(PartyService partyService) {
		this.partyService = partyService;
	}

}