pipIrr-SV.git - Gitblit

			@@ -4,11 +4,15 @@
			import com.dy.pipIrrGlobal.daoBa.BaDistrictMapper;
			import com.dy.pipIrrGlobal.daoBa.BaSettingsMapper;
			import com.dy.pipIrrGlobal.daoSe.SeClientMapper;
			import com.dy.pipIrrGlobal.daoSe.SeCodeVerifyMapper;
			import com.dy.pipIrrGlobal.daoSe.SeOpenIdMapper;
			import com.dy.pipIrrGlobal.pojoSe.SeClient;
			import com.dy.pipIrrGlobal.pojoSe.SeCodeVerify;
			import com.dy.pipIrrGlobal.pojoSe.SeOpenId;
			import com.dy.pipIrrGlobal.voSe.VoClient;
			import com.dy.pipIrrGlobal.voSe.VoClientWechat;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.dubbo.common.utils.PojoUtils;
			import org.apache.ibatis.annotations.Param;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;

			@@ -32,31 +36,35 @@
			private BaDistrictMapper baDistrictMapper;

			@Autowired
			private SeCodeVerifyMapper seCodeVerifyMapper;

			@Autowired
			private SeOpenIdMapper seOpenIdMapper;

			@Autowired
			private BaSettingsMapper baSettingsMapper;

			/**
			* 根据指定条件获取农户数据
			*
			* @param queryVo
			* @return
			*/
			public QueryResultVo<List<VoClient>> getClients(QueryVo queryVo) {
			Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
			public QueryResultVo<List<VoClient>> getClients(QueryVo queryVo){
			Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo) ;
			Long itemTotal = seClientMapper.getRecordCount(params);

			QueryResultVo<List<VoClient>> rsVo = new QueryResultVo<>();
			rsVo.pageSize = queryVo.pageSize;
			rsVo.pageCurr = queryVo.pageCurr;
			QueryResultVo<List<VoClient>> rsVo = new QueryResultVo<>() ;
			rsVo.pageSize = queryVo.pageSize ;
			rsVo.pageCurr = queryVo.pageCurr ;

			rsVo.calculateAndSet(itemTotal, params);
			rsVo.obj = seClientMapper.getClients(params);

			return rsVo;
			return rsVo ;
			}

			/**
			* 根据主键获取农户对象
			*
			* @param id 农户主键
			* @return 农户对象
			*/
			@@ -65,20 +73,34 @@
			VoClient voClient = SeClientToVoClient.INSTANCT.po2vo(seClient);
			return voClient;
			}

			/**
			* 增开农户
			*
			* @param po
			* @return
			*/
			public Integer addClient(SeClient po) {
			return seClientMapper.insert(po);
			return seClientMapper.insertSelective(po);
			}

			/**
			* 添加验证码记录
			* @param po
			* @return
			*/
			public Integer addCodeVerify(SeCodeVerify po) {
			return seCodeVerifyMapper.insert(po);
			}

			/**
			* 根据手机号获取验证码验证对象
			* @param phoneNumber
			* @return
			*/
			public SeCodeVerify getCodeVerify(String phoneNumber) {
			return seCodeVerifyMapper.getCodeVerify(phoneNumber);
			}
			/**
			* 根据6位区划串模糊查询农户编号
			*
			* @param district6
			* @return
			*/
			@@ -88,7 +110,6 @@

			/**
			* 根据村编号获取5级区划信息
			*
			* @param villageId 村编号（主键）
			* @return 5级行政区划信息
			*/
			@@ -105,7 +126,6 @@

			/**
			* 修改农户对象
			*
			* @param po 农户对象
			* @return 修改记录条数
			*/
			@@ -115,7 +135,6 @@

			/**
			* 根据主键获取村ID
			*
			* @param id
			* @return
			*/
			@@ -125,7 +144,6 @@

			/**
			* 获取虚拟卡号最大值
			*
			* @return
			*/
			public Long getMa1xVirtualId() {
			@@ -134,11 +152,29 @@

			/**
			* 获取用水方式列表
			*
			* @return
			*/
			public List<Map<String, Object>> getWaterTypes() {
			return seClientMapper.getWaterTypes();
			}

			/**
			* 根据电话号码获取农户ID
			* @param phoneNumber
			* @return
			*/
			public Long getClientIdByPhone(String phoneNumber) {
			return seClientMapper.getClientIdByPhone(phoneNumber);
			}

			/**
			* 添加微信用户账户记录
			* @param po
			* @return
			*/
			public Long addOpenId(SeOpenId po) {
			seOpenIdMapper.insert(po);
			return po.getClientId();
			}

			/**
			@@ -149,4 +185,13 @@
			public String getItemValue(String itemName) {
			return baSettingsMapper.getItemValue(itemName);
			}

			/**
			* 获取农户基本信息，小程序首页使用
			* @param sessionId
			* @return
			*/
			public VoClientWechat getSimpleClientInfo(Long sessionId, String openId) {
			return seClientMapper.getSimpleClientInfo(sessionId, openId);
			}
			}