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);
|
|
}
|
|
}
|