package cn.ksource.web.facade.wbx.ydxj;

import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.beans.CI_HEALTH_ITEM;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.StringUtil;
@Service("ydxjItemFacade")
@SuppressWarnings("unchecked")
public class YdxjItemFacadeImpl implements YdxjItemFacade {
	
	@Autowired
	private BaseDao baseDao;


	@Override
	public int jkjcxListCount(Map<String, String> params) {
		String categoryId = params.get("pId");
		SqlParameter param = new SqlParameter();
		
		String sql = "SELECT COUNT(ID) FROM CI_REMIND_ITEM WHERE ITEM_TYPE = 1 ";
		
		
		if(StringUtil.notEmpty(categoryId)) {
			sql += " AND BUSINESS_ID = :categoryId ";
			param.put("categoryId", categoryId);
		}
		 
		sql += " ORDER BY ORDER_NUM ";
		
		return baseDao.queryForInteger(sql,param);
	}

	@Override
	public PageInfo jkjcxListData(PageInfo pageInfo, Map<String, String> params) {
		String categoryId = params.get("pId");
		SqlParameter param = new SqlParameter();
		
		String sql = "SELECT * FROM CI_HEALTH_ITEM WHERE ITEM_TYPE = 1 ";
		
		
		if(StringUtil.notEmpty(categoryId)) {
			sql += " AND BUSINESS_ID = :categoryId ";
			param.put("categoryId", categoryId);
		}
		 
		sql += " ORDER BY ORDER_NUM ";
		
		PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, sql, param);
		
		return info;
	}

	@Override
	public void saveItem(CI_HEALTH_ITEM item) {
		String id = item.getId();
		item.insertOrUpdate();
		if(StringUtil.isEmpty(id)){
			SqlParameter param =  new SqlParameter();
			param.addValue("item_id", item.getId())
				.addValue("id", StringUtil.getUUID())
				.addValue("customer_id","-1");
			String sql = " insert into ci_health_customer_item (id,customer_id,item_id,using_state) "
					+ " values (:id,:customer_id,:item_id,1) ";
			baseDao.execute(sql, param);
		}
	}
	
	@Override
	public CI_HEALTH_ITEM getHealthItem(String id) {
		return new CI_HEALTH_ITEM(id).getInstanceById();
	}

	@Override
	public void updateItem(String id, String state) {
		CI_HEALTH_ITEM cc = new CI_HEALTH_ITEM();
		cc.setState(Integer.parseInt(state));
		cc.setId(id);
		cc.update();
		String sql = "UPDATE CI_HEALTH_CUSTOMER_ITEM SET USING_STATE = :state WHERE ITEM_ID = :item_id AND CUSTOMER_ID = :customer_id ";
		SqlParameter param =  new SqlParameter();
		param.addValue("item_id", id)
			.addValue("state",state)
			.addValue("customer_id","-1");
		baseDao.execute(sql, param);
		
	}

}